First compilable client

Author: sfodagain

sdk/src/main/java/software/amazon/awssdk/iot/iotcommands/IotCommandsClient.java

@@ -0,0 +1,71 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0.
+ *
+ * This file is generated.
+ */
+
+package software.amazon.awssdk.iot.iotcommands;
+
+import software.amazon.awssdk.iot.iotcommands.model.CommandExecutionEvent;
+import software.amazon.awssdk.iot.iotcommands.model.CommandExecutionStatus;
+import software.amazon.awssdk.iot.iotcommands.model.CommandExecutionsSubscriptionRequest;
+import software.amazon.awssdk.iot.iotcommands.model.DeviceType;
+import software.amazon.awssdk.iot.iotcommands.model.RejectedErrorCode;
+import software.amazon.awssdk.iot.iotcommands.model.StatusReason;
+import software.amazon.awssdk.iot.iotcommands.model.UpdateCommandExecutionRequest;
+import software.amazon.awssdk.iot.iotcommands.model.UpdateCommandExecutionResponse;
+import software.amazon.awssdk.iot.iotcommands.model.V2ErrorResponse;
+
+import java.nio.charset.StandardCharsets;
+
+import software.amazon.awssdk.crt.mqtt.MqttClientConnection;
+import software.amazon.awssdk.crt.mqtt.QualityOfService;
+import software.amazon.awssdk.crt.mqtt.MqttException;
+import software.amazon.awssdk.crt.mqtt.MqttMessage;
+
+import software.amazon.awssdk.iot.Timestamp;
+import software.amazon.awssdk.iot.EnumSerializer;
+
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+
+import java.io.UnsupportedEncodingException;
+import java.nio.ByteBuffer;
+import java.util.concurrent.CompletableFuture;
+import java.util.function.Consumer;
+
+/**
+ * The AWS IoT commands service is used to send an instruction from the cloud to a device that is connected to AWS IoT.
+ *
+ * AWS documentation: https://docs.aws.amazon.com/iot/latest/developerguide/iot-remote-command.html
+ *
+*/
+public class IotCommandsClient {
+    private MqttClientConnection connection = null;
+    private final Gson gson = getGson();
+
+    /**
+     * Constructs a new IotCommandsClient
+     * @param connection The connection to use
+     */
+    public IotCommandsClient(MqttClientConnection connection) {
+        this.connection = connection;
+    }
+
+    private Gson getGson() {
+        GsonBuilder gson = new GsonBuilder();
+        gson.disableHtmlEscaping();
+        gson.registerTypeAdapter(Timestamp.class, new Timestamp.Serializer());
+        gson.registerTypeAdapter(Timestamp.class, new Timestamp.Deserializer());
+        addTypeAdapters(gson);
+        return gson.create();
+    }
+
+    private void addTypeAdapters(GsonBuilder gson) {
+        gson.registerTypeAdapter(CommandExecutionStatus.class, new EnumSerializer<CommandExecutionStatus>());
+        gson.registerTypeAdapter(DeviceType.class, new EnumSerializer<DeviceType>());
+        gson.registerTypeAdapter(RejectedErrorCode.class, new EnumSerializer<RejectedErrorCode>());
+    }
+
+}

sdk/src/main/java/software/amazon/awssdk/iot/iotcommands/IotCommandsV2Client.java

@@ -0,0 +1,45 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0.
+ *
+ * This file is generated.
+ */
+
+package software.amazon.awssdk.iot.iotcommands.model;
+
+
+/**
+ * Sent whenever a command execution is added for a thing or a client.
+ *
+ */
+public class CommandExecutionEvent {
+
+    /**
+     * Opaque data containing instructions sent from the IoT commands service.
+     *
+     */
+    public byte[] payload;
+
+
+    /**
+     * Unique ID for the specific execution of a command. A command can have multiple executions, each with a unique ID.
+     *
+     */
+    public String executionId;
+
+
+    /**
+     * Data format of the payload. It is supposed to be a MIME type (IANA media type), but can be an arbitrary string.
+     *
+     */
+    public String contentType;
+
+
+    /**
+     * Number of seconds before the IoT commands service decides that this command execution is timed out.
+     *
+     */
+    public Integer timeout;
+
+
+}

sdk/src/main/java/software/amazon/awssdk/iot/iotcommands/model/CommandExecutionEvent.java

@@ -0,0 +1,71 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0.
+ *
+ * This file is generated.
+ */
+
+package software.amazon.awssdk.iot.iotcommands.model;
+
+/**
+ * The status of the command execution.
+ *
+ */
+public enum CommandExecutionStatus {
+
+    /**
+     * Enum value is an unknown value
+     */
+    UNKNOWN_ENUM_VALUE("UNKNOWN_ENUM_VALUE"),
+
+    /**
+     * The device is currently processing the received command.
+     */
+    IN_PROGRESS("IN_PROGRESS"),
+
+    /**
+     * The device successfully completed the command.
+     */
+    SUCCEEDED("SUCCEEDED"),
+
+    /**
+     * The device failed to complete the command.
+     */
+    FAILED("FAILED"),
+
+    /**
+     * The device received an invalid or incomplete request.
+     */
+    REJECTED("REJECTED"),
+
+    /**
+     * When the command execution timed out, this status can be used to provide additional information in the statusReason field in the UpdateCommandExecutionRequest request.
+     */
+    TIMED_OUT("TIMED_OUT");
+
+    private String value;
+
+    private CommandExecutionStatus(String value) {
+        this.value = value;
+    }
+
+    @Override
+    public String toString() {
+        return value;
+    }
+
+    /**
+     * Returns The enum associated with the given string or UNKNOWN_ENUM_VALUE
+     * if no enum is found.
+     * @param val The string to use
+     * @return The enum associated with the string or UNKNOWN_ENUM_VALUE
+     */
+    static CommandExecutionStatus fromString(String val) {
+        for (CommandExecutionStatus e : CommandExecutionStatus.class.getEnumConstants()) {
+            if (e.toString().compareTo(val) == 0) {
+                return e;
+            }
+        }
+        return UNKNOWN_ENUM_VALUE;
+    }
+}

sdk/src/main/java/software/amazon/awssdk/iot/iotcommands/model/CommandExecutionStatus.java

@@ -0,0 +1,32 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0.
+ *
+ * This file is generated.
+ */
+
+package software.amazon.awssdk.iot.iotcommands.model;
+
+import software.amazon.awssdk.iot.iotcommands.model.DeviceType;
+
+/**
+ * Data needed to subscribe to CommandExecution events.
+ *
+ */
+public class CommandExecutionsSubscriptionRequest {
+
+    /**
+     * The type of a target device. Determine if the device should subscribe for commands addressed to an IoT Thing or MQTT client.
+     *
+     */
+    public DeviceType deviceType;
+
+
+    /**
+     * Depending on device type value, this field is either an IoT Thing name or a client ID.
+     *
+     */
+    public String deviceId;
+
+
+}

sdk/src/main/java/software/amazon/awssdk/iot/iotcommands/model/CommandExecutionsSubscriptionRequest.java

@@ -0,0 +1,56 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0.
+ *
+ * This file is generated.
+ */
+
+package software.amazon.awssdk.iot.iotcommands.model;
+
+/**
+ * Possible device types for command executions.
+ *
+ */
+public enum DeviceType {
+
+    /**
+     * Enum value is an unknown value
+     */
+    UNKNOWN_ENUM_VALUE("UNKNOWN_ENUM_VALUE"),
+
+    /**
+     * A target for the commands is an IoT Thing.
+     */
+    THING("things"),
+
+    /**
+     * A target for the commands is an MQTT client ID.
+     */
+    CLIENT("clients");
+
+    private String value;
+
+    private DeviceType(String value) {
+        this.value = value;
+    }
+
+    @Override
+    public String toString() {
+        return value;
+    }
+
+    /**
+     * Returns The enum associated with the given string or UNKNOWN_ENUM_VALUE
+     * if no enum is found.
+     * @param val The string to use
+     * @return The enum associated with the string or UNKNOWN_ENUM_VALUE
+     */
+    static DeviceType fromString(String val) {
+        for (DeviceType e : DeviceType.class.getEnumConstants()) {
+            if (e.toString().compareTo(val) == 0) {
+                return e;
+            }
+        }
+        return UNKNOWN_ENUM_VALUE;
+    }
+}

sdk/src/main/java/software/amazon/awssdk/iot/iotcommands/model/DeviceType.java

@@ -0,0 +1,91 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0.
+ *
+ * This file is generated.
+ */
+
+package software.amazon.awssdk.iot.iotcommands.model;
+
+/**
+ * A value indicating the kind of error encountered while processing an AWS IoT Commands request
+ *
+ */
+public enum RejectedErrorCode {
+
+    /**
+     * Enum value is an unknown value
+     */
+    UNKNOWN_ENUM_VALUE("UNKNOWN_ENUM_VALUE"),
+
+    /**
+     * The request was sent to a topic in the AWS IoT Commands namespace that does not map to any API.
+     */
+    INVALID_TOPIC("InvalidTopic"),
+
+    /**
+     * The contents of the request could not be interpreted as valid UTF-8-encoded JSON.
+     */
+    INVALID_JSON("InvalidJson"),
+
+    /**
+     * The contents of the request were invalid. The message contains details about the error.
+     */
+    INVALID_REQUEST("InvalidRequest"),
+
+    /**
+     * An update attempted to change the command execution to a state that is invalid because of the command execution's current state. In this case, the body of the error message also contains the executionState field.
+     */
+    INVALID_STATE_TRANSITION("InvalidStateTransition"),
+
+    /**
+     * The CommandExecution specified by the request topic does not exist.
+     */
+    RESOURCE_NOT_FOUND("ResourceNotFound"),
+
+    /**
+     * The expected version specified in the request does not match the version of the command execution in the AWS IoT Commands service. In this case, the body of the error message also contains the executionState field.
+     */
+    VERSION_MISMATCH("VersionMismatch"),
+
+    /**
+     * There was an internal error during the processing of the request.
+     */
+    INTERNAL_ERROR("InternalError"),
+
+    /**
+     * The request was throttled.
+     */
+    REQUEST_THROTTLED("RequestThrottled"),
+
+    /**
+     * Occurs when a command to describe a command is performed on a command that is in a terminal state.
+     */
+    TERMINAL_STATE_REACHED("TerminalStateReached");
+
+    private String value;
+
+    private RejectedErrorCode(String value) {
+        this.value = value;
+    }
+
+    @Override
+    public String toString() {
+        return value;
+    }
+
+    /**
+     * Returns The enum associated with the given string or UNKNOWN_ENUM_VALUE
+     * if no enum is found.
+     * @param val The string to use
+     * @return The enum associated with the string or UNKNOWN_ENUM_VALUE
+     */
+    static RejectedErrorCode fromString(String val) {
+        for (RejectedErrorCode e : RejectedErrorCode.class.getEnumConstants()) {
+            if (e.toString().compareTo(val) == 0) {
+                return e;
+            }
+        }
+        return UNKNOWN_ENUM_VALUE;
+    }
+}