diff --git a/sdk/greengrass/event-stream-rpc-model/src/main/java/software/amazon/awssdk/eventstreamrpc/EventStreamRPCServiceModel.java b/sdk/greengrass/event-stream-rpc-model/src/main/java/software/amazon/awssdk/eventstreamrpc/EventStreamRPCServiceModel.java index 0a6a1916a..923c25f4c 100644 --- a/sdk/greengrass/event-stream-rpc-model/src/main/java/software/amazon/awssdk/eventstreamrpc/EventStreamRPCServiceModel.java +++ b/sdk/greengrass/event-stream-rpc-model/src/main/java/software/amazon/awssdk/eventstreamrpc/EventStreamRPCServiceModel.java @@ -70,7 +70,7 @@ public T read(JsonReader in) throws IOException { }; } } - + private static class OptionalTypeAdapter extends TypeAdapter> { public static final TypeAdapterFactory FACTORY = new TypeAdapterFactory() { @Override @@ -103,20 +103,16 @@ public void write(JsonWriter out, Optional value) throws IOException { @Override public Optional read(JsonReader in) throws IOException { - final JsonToken peek = in.peek(); - if (peek != JsonToken.NULL){ - return Optional.ofNullable(adapter.read(in)); - } - return Optional.empty(); + return Optional.ofNullable(adapter.read(in)); } } /** * Used to compare two members of a blob shape for equality. Array equals nesting * inside of an Optional doesn't work - * + * * Note: Generated code for equals method of Smithy shapes relies on this - * + * * @param lhs * @param rhs * @return @@ -169,7 +165,7 @@ public JsonElement serialize(Instant src, Type typeOfSrc, JsonSerializationConte * @return */ public abstract String getServiceName(); - + private static final Map> FRAMEWORK_APPLICATION_MODEL_TYPES = new HashMap<>(); static { diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/DeleteThingShadowResponseHandler.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/DeleteThingShadowResponseHandler.java new file mode 100644 index 000000000..67fef59a0 --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/DeleteThingShadowResponseHandler.java @@ -0,0 +1,43 @@ +package software.amazon.awssdk.aws.greengrass; + +import java.lang.Override; +import java.lang.Void; +import java.util.concurrent.CompletableFuture; +import software.amazon.awssdk.aws.greengrass.model.DeleteThingShadowResponse; +import software.amazon.awssdk.eventstreamrpc.OperationResponse; +import software.amazon.awssdk.eventstreamrpc.StreamResponse; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public final class DeleteThingShadowResponseHandler implements StreamResponse { + private final OperationResponse operationResponse; + + public DeleteThingShadowResponseHandler( + final OperationResponse operationResponse) { + this.operationResponse = operationResponse; + } + + @Override + public CompletableFuture getRequestFlushFuture() { + return operationResponse.getRequestFlushFuture(); + } + + @Override + public CompletableFuture getResponse() { + return operationResponse.getResponse(); + } + + @Override + public CompletableFuture sendStreamEvent(final EventStreamJsonMessage event) { + return operationResponse.sendStreamEvent(event); + } + + @Override + public CompletableFuture closeStream() { + return operationResponse.closeStream(); + } + + @Override + public boolean isClosed() { + return operationResponse.isClosed(); + } +} diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GetThingShadowResponseHandler.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GetThingShadowResponseHandler.java new file mode 100644 index 000000000..88c98b37f --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GetThingShadowResponseHandler.java @@ -0,0 +1,43 @@ +package software.amazon.awssdk.aws.greengrass; + +import java.lang.Override; +import java.lang.Void; +import java.util.concurrent.CompletableFuture; +import software.amazon.awssdk.aws.greengrass.model.GetThingShadowResponse; +import software.amazon.awssdk.eventstreamrpc.OperationResponse; +import software.amazon.awssdk.eventstreamrpc.StreamResponse; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public final class GetThingShadowResponseHandler implements StreamResponse { + private final OperationResponse operationResponse; + + public GetThingShadowResponseHandler( + final OperationResponse operationResponse) { + this.operationResponse = operationResponse; + } + + @Override + public CompletableFuture getRequestFlushFuture() { + return operationResponse.getRequestFlushFuture(); + } + + @Override + public CompletableFuture getResponse() { + return operationResponse.getResponse(); + } + + @Override + public CompletableFuture sendStreamEvent(final EventStreamJsonMessage event) { + return operationResponse.sendStreamEvent(event); + } + + @Override + public CompletableFuture closeStream() { + return operationResponse.closeStream(); + } + + @Override + public boolean isClosed() { + return operationResponse.isClosed(); + } +} diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPC.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPC.java index b9cb10c55..0aa19dd3a 100644 --- a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPC.java +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPC.java @@ -6,13 +6,16 @@ import software.amazon.awssdk.aws.greengrass.model.CreateDebugPasswordRequest; import software.amazon.awssdk.aws.greengrass.model.CreateLocalDeploymentRequest; import software.amazon.awssdk.aws.greengrass.model.DeferComponentUpdateRequest; +import software.amazon.awssdk.aws.greengrass.model.DeleteThingShadowRequest; import software.amazon.awssdk.aws.greengrass.model.GetComponentDetailsRequest; import software.amazon.awssdk.aws.greengrass.model.GetConfigurationRequest; import software.amazon.awssdk.aws.greengrass.model.GetLocalDeploymentStatusRequest; import software.amazon.awssdk.aws.greengrass.model.GetSecretValueRequest; +import software.amazon.awssdk.aws.greengrass.model.GetThingShadowRequest; import software.amazon.awssdk.aws.greengrass.model.IoTCoreMessage; import software.amazon.awssdk.aws.greengrass.model.ListComponentsRequest; import software.amazon.awssdk.aws.greengrass.model.ListLocalDeploymentsRequest; +import software.amazon.awssdk.aws.greengrass.model.ListNamedShadowsForThingRequest; import software.amazon.awssdk.aws.greengrass.model.PublishToIoTCoreRequest; import software.amazon.awssdk.aws.greengrass.model.PublishToTopicRequest; import software.amazon.awssdk.aws.greengrass.model.RestartComponentRequest; @@ -26,6 +29,7 @@ import software.amazon.awssdk.aws.greengrass.model.SubscriptionResponseMessage; import software.amazon.awssdk.aws.greengrass.model.UpdateConfigurationRequest; import software.amazon.awssdk.aws.greengrass.model.UpdateStateRequest; +import software.amazon.awssdk.aws.greengrass.model.UpdateThingShadowRequest; import software.amazon.awssdk.aws.greengrass.model.ValidateAuthorizationTokenRequest; import software.amazon.awssdk.aws.greengrass.model.ValidateConfigurationUpdateEvents; import software.amazon.awssdk.eventstreamrpc.StreamResponseHandler; @@ -35,9 +39,6 @@ public interface GreengrassCoreIPC { SubscribeToIoTCoreResponseHandler subscribeToIoTCore(final SubscribeToIoTCoreRequest request, final Optional> streamResponseHandler); - PublishToTopicResponseHandler publishToTopic(final PublishToTopicRequest request, - final Optional> streamResponseHandler); - PublishToIoTCoreResponseHandler publishToIoTCore(final PublishToIoTCoreRequest request, final Optional> streamResponseHandler); @@ -45,26 +46,47 @@ SubscribeToConfigurationUpdateResponseHandler subscribeToConfigurationUpdate( final SubscribeToConfigurationUpdateRequest request, final Optional> streamResponseHandler); + DeleteThingShadowResponseHandler deleteThingShadow(final DeleteThingShadowRequest request, + final Optional> streamResponseHandler); + + DeferComponentUpdateResponseHandler deferComponentUpdate( + final DeferComponentUpdateRequest request, + final Optional> streamResponseHandler); + + SubscribeToValidateConfigurationUpdatesResponseHandler subscribeToValidateConfigurationUpdates( + final SubscribeToValidateConfigurationUpdatesRequest request, + final Optional> streamResponseHandler); + + GetConfigurationResponseHandler getConfiguration(final GetConfigurationRequest request, + final Optional> streamResponseHandler); + + SubscribeToTopicResponseHandler subscribeToTopic(final SubscribeToTopicRequest request, + final Optional> streamResponseHandler); + + GetComponentDetailsResponseHandler getComponentDetails(final GetComponentDetailsRequest request, + final Optional> streamResponseHandler); + + PublishToTopicResponseHandler publishToTopic(final PublishToTopicRequest request, + final Optional> streamResponseHandler); + ListComponentsResponseHandler listComponents(final ListComponentsRequest request, final Optional> streamResponseHandler); CreateDebugPasswordResponseHandler createDebugPassword(final CreateDebugPasswordRequest request, final Optional> streamResponseHandler); - DeferComponentUpdateResponseHandler deferComponentUpdate( - final DeferComponentUpdateRequest request, + GetThingShadowResponseHandler getThingShadow(final GetThingShadowRequest request, final Optional> streamResponseHandler); SendConfigurationValidityReportResponseHandler sendConfigurationValidityReport( final SendConfigurationValidityReportRequest request, final Optional> streamResponseHandler); - UpdateConfigurationResponseHandler updateConfiguration(final UpdateConfigurationRequest request, + UpdateThingShadowResponseHandler updateThingShadow(final UpdateThingShadowRequest request, final Optional> streamResponseHandler); - SubscribeToValidateConfigurationUpdatesResponseHandler subscribeToValidateConfigurationUpdates( - final SubscribeToValidateConfigurationUpdatesRequest request, - final Optional> streamResponseHandler); + UpdateConfigurationResponseHandler updateConfiguration(final UpdateConfigurationRequest request, + final Optional> streamResponseHandler); ValidateAuthorizationTokenResponseHandler validateAuthorizationToken( final ValidateAuthorizationTokenRequest request, @@ -83,13 +105,8 @@ GetSecretValueResponseHandler getSecretValue(final GetSecretValueRequest request UpdateStateResponseHandler updateState(final UpdateStateRequest request, final Optional> streamResponseHandler); - GetConfigurationResponseHandler getConfiguration(final GetConfigurationRequest request, - final Optional> streamResponseHandler); - - SubscribeToTopicResponseHandler subscribeToTopic(final SubscribeToTopicRequest request, - final Optional> streamResponseHandler); - - GetComponentDetailsResponseHandler getComponentDetails(final GetComponentDetailsRequest request, + ListNamedShadowsForThingResponseHandler listNamedShadowsForThing( + final ListNamedShadowsForThingRequest request, final Optional> streamResponseHandler); SubscribeToComponentUpdatesResponseHandler subscribeToComponentUpdates( diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPCClient.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPCClient.java index a68a746c5..b7e4d583b 100644 --- a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPCClient.java +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPCClient.java @@ -7,13 +7,16 @@ import software.amazon.awssdk.aws.greengrass.model.CreateDebugPasswordRequest; import software.amazon.awssdk.aws.greengrass.model.CreateLocalDeploymentRequest; import software.amazon.awssdk.aws.greengrass.model.DeferComponentUpdateRequest; +import software.amazon.awssdk.aws.greengrass.model.DeleteThingShadowRequest; import software.amazon.awssdk.aws.greengrass.model.GetComponentDetailsRequest; import software.amazon.awssdk.aws.greengrass.model.GetConfigurationRequest; import software.amazon.awssdk.aws.greengrass.model.GetLocalDeploymentStatusRequest; import software.amazon.awssdk.aws.greengrass.model.GetSecretValueRequest; +import software.amazon.awssdk.aws.greengrass.model.GetThingShadowRequest; import software.amazon.awssdk.aws.greengrass.model.IoTCoreMessage; import software.amazon.awssdk.aws.greengrass.model.ListComponentsRequest; import software.amazon.awssdk.aws.greengrass.model.ListLocalDeploymentsRequest; +import software.amazon.awssdk.aws.greengrass.model.ListNamedShadowsForThingRequest; import software.amazon.awssdk.aws.greengrass.model.PublishToIoTCoreRequest; import software.amazon.awssdk.aws.greengrass.model.PublishToTopicRequest; import software.amazon.awssdk.aws.greengrass.model.RestartComponentRequest; @@ -27,6 +30,7 @@ import software.amazon.awssdk.aws.greengrass.model.SubscriptionResponseMessage; import software.amazon.awssdk.aws.greengrass.model.UpdateConfigurationRequest; import software.amazon.awssdk.aws.greengrass.model.UpdateStateRequest; +import software.amazon.awssdk.aws.greengrass.model.UpdateThingShadowRequest; import software.amazon.awssdk.aws.greengrass.model.ValidateAuthorizationTokenRequest; import software.amazon.awssdk.aws.greengrass.model.ValidateConfigurationUpdateEvents; import software.amazon.awssdk.eventstreamrpc.EventStreamRPCClient; @@ -47,13 +51,6 @@ public SubscribeToIoTCoreResponseHandler subscribeToIoTCore( return new SubscribeToIoTCoreResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); } - @Override - public PublishToTopicResponseHandler publishToTopic(final PublishToTopicRequest request, - final Optional> streamResponseHandler) { - final PublishToTopicOperationContext operationContext = GreengrassCoreIPCServiceModel.getPublishToTopicModelContext(); - return new PublishToTopicResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); - } - @Override public PublishToIoTCoreResponseHandler publishToIoTCore(final PublishToIoTCoreRequest request, final Optional> streamResponseHandler) { @@ -69,6 +66,58 @@ public SubscribeToConfigurationUpdateResponseHandler subscribeToConfigurationUpd return new SubscribeToConfigurationUpdateResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); } + @Override + public DeleteThingShadowResponseHandler deleteThingShadow(final DeleteThingShadowRequest request, + final Optional> streamResponseHandler) { + final DeleteThingShadowOperationContext operationContext = GreengrassCoreIPCServiceModel.getDeleteThingShadowModelContext(); + return new DeleteThingShadowResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); + } + + @Override + public DeferComponentUpdateResponseHandler deferComponentUpdate( + final DeferComponentUpdateRequest request, + final Optional> streamResponseHandler) { + final DeferComponentUpdateOperationContext operationContext = GreengrassCoreIPCServiceModel.getDeferComponentUpdateModelContext(); + return new DeferComponentUpdateResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); + } + + @Override + public SubscribeToValidateConfigurationUpdatesResponseHandler subscribeToValidateConfigurationUpdates( + final SubscribeToValidateConfigurationUpdatesRequest request, + final Optional> streamResponseHandler) { + final SubscribeToValidateConfigurationUpdatesOperationContext operationContext = GreengrassCoreIPCServiceModel.getSubscribeToValidateConfigurationUpdatesModelContext(); + return new SubscribeToValidateConfigurationUpdatesResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); + } + + @Override + public GetConfigurationResponseHandler getConfiguration(final GetConfigurationRequest request, + final Optional> streamResponseHandler) { + final GetConfigurationOperationContext operationContext = GreengrassCoreIPCServiceModel.getGetConfigurationModelContext(); + return new GetConfigurationResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); + } + + @Override + public SubscribeToTopicResponseHandler subscribeToTopic(final SubscribeToTopicRequest request, + final Optional> streamResponseHandler) { + final SubscribeToTopicOperationContext operationContext = GreengrassCoreIPCServiceModel.getSubscribeToTopicModelContext(); + return new SubscribeToTopicResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); + } + + @Override + public GetComponentDetailsResponseHandler getComponentDetails( + final GetComponentDetailsRequest request, + final Optional> streamResponseHandler) { + final GetComponentDetailsOperationContext operationContext = GreengrassCoreIPCServiceModel.getGetComponentDetailsModelContext(); + return new GetComponentDetailsResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); + } + + @Override + public PublishToTopicResponseHandler publishToTopic(final PublishToTopicRequest request, + final Optional> streamResponseHandler) { + final PublishToTopicOperationContext operationContext = GreengrassCoreIPCServiceModel.getPublishToTopicModelContext(); + return new PublishToTopicResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); + } + @Override public ListComponentsResponseHandler listComponents(final ListComponentsRequest request, final Optional> streamResponseHandler) { @@ -85,11 +134,10 @@ public CreateDebugPasswordResponseHandler createDebugPassword( } @Override - public DeferComponentUpdateResponseHandler deferComponentUpdate( - final DeferComponentUpdateRequest request, + public GetThingShadowResponseHandler getThingShadow(final GetThingShadowRequest request, final Optional> streamResponseHandler) { - final DeferComponentUpdateOperationContext operationContext = GreengrassCoreIPCServiceModel.getDeferComponentUpdateModelContext(); - return new DeferComponentUpdateResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); + final GetThingShadowOperationContext operationContext = GreengrassCoreIPCServiceModel.getGetThingShadowModelContext(); + return new GetThingShadowResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); } @Override @@ -100,6 +148,13 @@ public SendConfigurationValidityReportResponseHandler sendConfigurationValidityR return new SendConfigurationValidityReportResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); } + @Override + public UpdateThingShadowResponseHandler updateThingShadow(final UpdateThingShadowRequest request, + final Optional> streamResponseHandler) { + final UpdateThingShadowOperationContext operationContext = GreengrassCoreIPCServiceModel.getUpdateThingShadowModelContext(); + return new UpdateThingShadowResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); + } + @Override public UpdateConfigurationResponseHandler updateConfiguration( final UpdateConfigurationRequest request, @@ -108,14 +163,6 @@ public UpdateConfigurationResponseHandler updateConfiguration( return new UpdateConfigurationResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); } - @Override - public SubscribeToValidateConfigurationUpdatesResponseHandler subscribeToValidateConfigurationUpdates( - final SubscribeToValidateConfigurationUpdatesRequest request, - final Optional> streamResponseHandler) { - final SubscribeToValidateConfigurationUpdatesOperationContext operationContext = GreengrassCoreIPCServiceModel.getSubscribeToValidateConfigurationUpdatesModelContext(); - return new SubscribeToValidateConfigurationUpdatesResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); - } - @Override public ValidateAuthorizationTokenResponseHandler validateAuthorizationToken( final ValidateAuthorizationTokenRequest request, @@ -154,25 +201,11 @@ public UpdateStateResponseHandler updateState(final UpdateStateRequest request, } @Override - public GetConfigurationResponseHandler getConfiguration(final GetConfigurationRequest request, - final Optional> streamResponseHandler) { - final GetConfigurationOperationContext operationContext = GreengrassCoreIPCServiceModel.getGetConfigurationModelContext(); - return new GetConfigurationResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); - } - - @Override - public SubscribeToTopicResponseHandler subscribeToTopic(final SubscribeToTopicRequest request, - final Optional> streamResponseHandler) { - final SubscribeToTopicOperationContext operationContext = GreengrassCoreIPCServiceModel.getSubscribeToTopicModelContext(); - return new SubscribeToTopicResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); - } - - @Override - public GetComponentDetailsResponseHandler getComponentDetails( - final GetComponentDetailsRequest request, + public ListNamedShadowsForThingResponseHandler listNamedShadowsForThing( + final ListNamedShadowsForThingRequest request, final Optional> streamResponseHandler) { - final GetComponentDetailsOperationContext operationContext = GreengrassCoreIPCServiceModel.getGetComponentDetailsModelContext(); - return new GetComponentDetailsResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); + final ListNamedShadowsForThingOperationContext operationContext = GreengrassCoreIPCServiceModel.getListNamedShadowsForThingModelContext(); + return new ListNamedShadowsForThingResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler)); } @Override diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/ListNamedShadowsForThingResponseHandler.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/ListNamedShadowsForThingResponseHandler.java new file mode 100644 index 000000000..65c025eb7 --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/ListNamedShadowsForThingResponseHandler.java @@ -0,0 +1,43 @@ +package software.amazon.awssdk.aws.greengrass; + +import java.lang.Override; +import java.lang.Void; +import java.util.concurrent.CompletableFuture; +import software.amazon.awssdk.aws.greengrass.model.ListNamedShadowsForThingResponse; +import software.amazon.awssdk.eventstreamrpc.OperationResponse; +import software.amazon.awssdk.eventstreamrpc.StreamResponse; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public final class ListNamedShadowsForThingResponseHandler implements StreamResponse { + private final OperationResponse operationResponse; + + public ListNamedShadowsForThingResponseHandler( + final OperationResponse operationResponse) { + this.operationResponse = operationResponse; + } + + @Override + public CompletableFuture getRequestFlushFuture() { + return operationResponse.getRequestFlushFuture(); + } + + @Override + public CompletableFuture getResponse() { + return operationResponse.getResponse(); + } + + @Override + public CompletableFuture sendStreamEvent(final EventStreamJsonMessage event) { + return operationResponse.sendStreamEvent(event); + } + + @Override + public CompletableFuture closeStream() { + return operationResponse.closeStream(); + } + + @Override + public boolean isClosed() { + return operationResponse.isClosed(); + } +} diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/UpdateThingShadowResponseHandler.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/UpdateThingShadowResponseHandler.java new file mode 100644 index 000000000..32e500a5b --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/UpdateThingShadowResponseHandler.java @@ -0,0 +1,43 @@ +package software.amazon.awssdk.aws.greengrass; + +import java.lang.Override; +import java.lang.Void; +import java.util.concurrent.CompletableFuture; +import software.amazon.awssdk.aws.greengrass.model.UpdateThingShadowResponse; +import software.amazon.awssdk.eventstreamrpc.OperationResponse; +import software.amazon.awssdk.eventstreamrpc.StreamResponse; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public final class UpdateThingShadowResponseHandler implements StreamResponse { + private final OperationResponse operationResponse; + + public UpdateThingShadowResponseHandler( + final OperationResponse operationResponse) { + this.operationResponse = operationResponse; + } + + @Override + public CompletableFuture getRequestFlushFuture() { + return operationResponse.getRequestFlushFuture(); + } + + @Override + public CompletableFuture getResponse() { + return operationResponse.getResponse(); + } + + @Override + public CompletableFuture sendStreamEvent(final EventStreamJsonMessage event) { + return operationResponse.sendStreamEvent(event); + } + + @Override + public CompletableFuture closeStream() { + return operationResponse.closeStream(); + } + + @Override + public boolean isClosed() { + return operationResponse.isClosed(); + } +} diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/DeleteThingShadowOperationContext.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/DeleteThingShadowOperationContext.java new file mode 100644 index 000000000..be1314769 --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/DeleteThingShadowOperationContext.java @@ -0,0 +1,62 @@ +package software.amazon.awssdk.aws.greengrass; + +import java.lang.Class; +import java.lang.Override; +import java.lang.String; +import java.util.Optional; +import software.amazon.awssdk.aws.greengrass.model.DeleteThingShadowRequest; +import software.amazon.awssdk.aws.greengrass.model.DeleteThingShadowResponse; +import software.amazon.awssdk.eventstreamrpc.EventStreamRPCServiceModel; +import software.amazon.awssdk.eventstreamrpc.OperationModelContext; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public class DeleteThingShadowOperationContext implements OperationModelContext { + @Override + public EventStreamRPCServiceModel getServiceModel() { + return GreengrassCoreIPCServiceModel.getInstance(); + } + + @Override + public String getOperationName() { + return GreengrassCoreIPCServiceModel.DELETE_THING_SHADOW; + } + + @Override + public Class getRequestTypeClass() { + return DeleteThingShadowRequest.class; + } + + @Override + public Class getResponseTypeClass() { + return DeleteThingShadowResponse.class; + } + + @Override + public String getRequestApplicationModelType() { + return DeleteThingShadowRequest.APPLICATION_MODEL_TYPE; + } + + @Override + public String getResponseApplicationModelType() { + return DeleteThingShadowResponse.APPLICATION_MODEL_TYPE; + } + + @Override + public Optional> getStreamingRequestTypeClass() { + return Optional.empty(); + } + + @Override + public Optional> getStreamingResponseTypeClass() { + return Optional.empty(); + } + + public Optional getStreamingRequestApplicationModelType() { + return Optional.empty(); + } + + @Override + public Optional getStreamingResponseApplicationModelType() { + return Optional.empty(); + } +} diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/GetThingShadowOperationContext.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/GetThingShadowOperationContext.java new file mode 100644 index 000000000..dae63085d --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/GetThingShadowOperationContext.java @@ -0,0 +1,62 @@ +package software.amazon.awssdk.aws.greengrass; + +import java.lang.Class; +import java.lang.Override; +import java.lang.String; +import java.util.Optional; +import software.amazon.awssdk.aws.greengrass.model.GetThingShadowRequest; +import software.amazon.awssdk.aws.greengrass.model.GetThingShadowResponse; +import software.amazon.awssdk.eventstreamrpc.EventStreamRPCServiceModel; +import software.amazon.awssdk.eventstreamrpc.OperationModelContext; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public class GetThingShadowOperationContext implements OperationModelContext { + @Override + public EventStreamRPCServiceModel getServiceModel() { + return GreengrassCoreIPCServiceModel.getInstance(); + } + + @Override + public String getOperationName() { + return GreengrassCoreIPCServiceModel.GET_THING_SHADOW; + } + + @Override + public Class getRequestTypeClass() { + return GetThingShadowRequest.class; + } + + @Override + public Class getResponseTypeClass() { + return GetThingShadowResponse.class; + } + + @Override + public String getRequestApplicationModelType() { + return GetThingShadowRequest.APPLICATION_MODEL_TYPE; + } + + @Override + public String getResponseApplicationModelType() { + return GetThingShadowResponse.APPLICATION_MODEL_TYPE; + } + + @Override + public Optional> getStreamingRequestTypeClass() { + return Optional.empty(); + } + + @Override + public Optional> getStreamingResponseTypeClass() { + return Optional.empty(); + } + + public Optional getStreamingRequestApplicationModelType() { + return Optional.empty(); + } + + @Override + public Optional getStreamingResponseApplicationModelType() { + return Optional.empty(); + } +} diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPCServiceModel.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPCServiceModel.java index a6df68b68..56196aeef 100644 --- a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPCServiceModel.java +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPCServiceModel.java @@ -24,6 +24,8 @@ import software.amazon.awssdk.aws.greengrass.model.CreateLocalDeploymentResponse; import software.amazon.awssdk.aws.greengrass.model.DeferComponentUpdateRequest; import software.amazon.awssdk.aws.greengrass.model.DeferComponentUpdateResponse; +import software.amazon.awssdk.aws.greengrass.model.DeleteThingShadowRequest; +import software.amazon.awssdk.aws.greengrass.model.DeleteThingShadowResponse; import software.amazon.awssdk.aws.greengrass.model.DeploymentStatus; import software.amazon.awssdk.aws.greengrass.model.FailedUpdateConditionCheckError; import software.amazon.awssdk.aws.greengrass.model.GetComponentDetailsRequest; @@ -34,6 +36,8 @@ import software.amazon.awssdk.aws.greengrass.model.GetLocalDeploymentStatusResponse; import software.amazon.awssdk.aws.greengrass.model.GetSecretValueRequest; import software.amazon.awssdk.aws.greengrass.model.GetSecretValueResponse; +import software.amazon.awssdk.aws.greengrass.model.GetThingShadowRequest; +import software.amazon.awssdk.aws.greengrass.model.GetThingShadowResponse; import software.amazon.awssdk.aws.greengrass.model.InvalidArgumentsError; import software.amazon.awssdk.aws.greengrass.model.InvalidArtifactsDirectoryPathError; import software.amazon.awssdk.aws.greengrass.model.InvalidRecipeDirectoryPathError; @@ -45,6 +49,8 @@ import software.amazon.awssdk.aws.greengrass.model.ListComponentsResponse; import software.amazon.awssdk.aws.greengrass.model.ListLocalDeploymentsRequest; import software.amazon.awssdk.aws.greengrass.model.ListLocalDeploymentsResponse; +import software.amazon.awssdk.aws.greengrass.model.ListNamedShadowsForThingRequest; +import software.amazon.awssdk.aws.greengrass.model.ListNamedShadowsForThingResponse; import software.amazon.awssdk.aws.greengrass.model.LocalDeployment; import software.amazon.awssdk.aws.greengrass.model.MQTTMessage; import software.amazon.awssdk.aws.greengrass.model.PostComponentUpdateEvent; @@ -83,6 +89,8 @@ import software.amazon.awssdk.aws.greengrass.model.UpdateConfigurationResponse; import software.amazon.awssdk.aws.greengrass.model.UpdateStateRequest; import software.amazon.awssdk.aws.greengrass.model.UpdateStateResponse; +import software.amazon.awssdk.aws.greengrass.model.UpdateThingShadowRequest; +import software.amazon.awssdk.aws.greengrass.model.UpdateThingShadowResponse; import software.amazon.awssdk.aws.greengrass.model.ValidateAuthorizationTokenRequest; import software.amazon.awssdk.aws.greengrass.model.ValidateAuthorizationTokenResponse; import software.amazon.awssdk.aws.greengrass.model.ValidateConfigurationUpdateEvent; @@ -108,10 +116,6 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel { private static final SubscribeToIoTCoreOperationContext _SUBSCRIBE_TO_IOT_CORE_OPERATION_CONTEXT = new SubscribeToIoTCoreOperationContext(); - public static final String PUBLISH_TO_TOPIC = SERVICE_NAMESPACE + "#" + "PublishToTopic"; - - private static final PublishToTopicOperationContext _PUBLISH_TO_TOPIC_OPERATION_CONTEXT = new PublishToTopicOperationContext(); - public static final String PUBLISH_TO_IOT_CORE = SERVICE_NAMESPACE + "#" + "PublishToIoTCore"; private static final PublishToIoTCoreOperationContext _PUBLISH_TO_IOT_CORE_OPERATION_CONTEXT = new PublishToIoTCoreOperationContext(); @@ -120,6 +124,34 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel { private static final SubscribeToConfigurationUpdateOperationContext _SUBSCRIBE_TO_CONFIGURATION_UPDATE_OPERATION_CONTEXT = new SubscribeToConfigurationUpdateOperationContext(); + public static final String DELETE_THING_SHADOW = SERVICE_NAMESPACE + "#" + "DeleteThingShadow"; + + private static final DeleteThingShadowOperationContext _DELETE_THING_SHADOW_OPERATION_CONTEXT = new DeleteThingShadowOperationContext(); + + public static final String DEFER_COMPONENT_UPDATE = SERVICE_NAMESPACE + "#" + "DeferComponentUpdate"; + + private static final DeferComponentUpdateOperationContext _DEFER_COMPONENT_UPDATE_OPERATION_CONTEXT = new DeferComponentUpdateOperationContext(); + + public static final String SUBSCRIBE_TO_VALIDATE_CONFIGURATION_UPDATES = SERVICE_NAMESPACE + "#" + "SubscribeToValidateConfigurationUpdates"; + + private static final SubscribeToValidateConfigurationUpdatesOperationContext _SUBSCRIBE_TO_VALIDATE_CONFIGURATION_UPDATES_OPERATION_CONTEXT = new SubscribeToValidateConfigurationUpdatesOperationContext(); + + public static final String GET_CONFIGURATION = SERVICE_NAMESPACE + "#" + "GetConfiguration"; + + private static final GetConfigurationOperationContext _GET_CONFIGURATION_OPERATION_CONTEXT = new GetConfigurationOperationContext(); + + public static final String SUBSCRIBE_TO_TOPIC = SERVICE_NAMESPACE + "#" + "SubscribeToTopic"; + + private static final SubscribeToTopicOperationContext _SUBSCRIBE_TO_TOPIC_OPERATION_CONTEXT = new SubscribeToTopicOperationContext(); + + public static final String GET_COMPONENT_DETAILS = SERVICE_NAMESPACE + "#" + "GetComponentDetails"; + + private static final GetComponentDetailsOperationContext _GET_COMPONENT_DETAILS_OPERATION_CONTEXT = new GetComponentDetailsOperationContext(); + + public static final String PUBLISH_TO_TOPIC = SERVICE_NAMESPACE + "#" + "PublishToTopic"; + + private static final PublishToTopicOperationContext _PUBLISH_TO_TOPIC_OPERATION_CONTEXT = new PublishToTopicOperationContext(); + public static final String LIST_COMPONENTS = SERVICE_NAMESPACE + "#" + "ListComponents"; private static final ListComponentsOperationContext _LIST_COMPONENTS_OPERATION_CONTEXT = new ListComponentsOperationContext(); @@ -128,21 +160,21 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel { private static final CreateDebugPasswordOperationContext _CREATE_DEBUG_PASSWORD_OPERATION_CONTEXT = new CreateDebugPasswordOperationContext(); - public static final String DEFER_COMPONENT_UPDATE = SERVICE_NAMESPACE + "#" + "DeferComponentUpdate"; + public static final String GET_THING_SHADOW = SERVICE_NAMESPACE + "#" + "GetThingShadow"; - private static final DeferComponentUpdateOperationContext _DEFER_COMPONENT_UPDATE_OPERATION_CONTEXT = new DeferComponentUpdateOperationContext(); + private static final GetThingShadowOperationContext _GET_THING_SHADOW_OPERATION_CONTEXT = new GetThingShadowOperationContext(); public static final String SEND_CONFIGURATION_VALIDITY_REPORT = SERVICE_NAMESPACE + "#" + "SendConfigurationValidityReport"; private static final SendConfigurationValidityReportOperationContext _SEND_CONFIGURATION_VALIDITY_REPORT_OPERATION_CONTEXT = new SendConfigurationValidityReportOperationContext(); - public static final String UPDATE_CONFIGURATION = SERVICE_NAMESPACE + "#" + "UpdateConfiguration"; + public static final String UPDATE_THING_SHADOW = SERVICE_NAMESPACE + "#" + "UpdateThingShadow"; - private static final UpdateConfigurationOperationContext _UPDATE_CONFIGURATION_OPERATION_CONTEXT = new UpdateConfigurationOperationContext(); + private static final UpdateThingShadowOperationContext _UPDATE_THING_SHADOW_OPERATION_CONTEXT = new UpdateThingShadowOperationContext(); - public static final String SUBSCRIBE_TO_VALIDATE_CONFIGURATION_UPDATES = SERVICE_NAMESPACE + "#" + "SubscribeToValidateConfigurationUpdates"; + public static final String UPDATE_CONFIGURATION = SERVICE_NAMESPACE + "#" + "UpdateConfiguration"; - private static final SubscribeToValidateConfigurationUpdatesOperationContext _SUBSCRIBE_TO_VALIDATE_CONFIGURATION_UPDATES_OPERATION_CONTEXT = new SubscribeToValidateConfigurationUpdatesOperationContext(); + private static final UpdateConfigurationOperationContext _UPDATE_CONFIGURATION_OPERATION_CONTEXT = new UpdateConfigurationOperationContext(); public static final String VALIDATE_AUTHORIZATION_TOKEN = SERVICE_NAMESPACE + "#" + "ValidateAuthorizationToken"; @@ -164,17 +196,9 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel { private static final UpdateStateOperationContext _UPDATE_STATE_OPERATION_CONTEXT = new UpdateStateOperationContext(); - public static final String GET_CONFIGURATION = SERVICE_NAMESPACE + "#" + "GetConfiguration"; - - private static final GetConfigurationOperationContext _GET_CONFIGURATION_OPERATION_CONTEXT = new GetConfigurationOperationContext(); - - public static final String SUBSCRIBE_TO_TOPIC = SERVICE_NAMESPACE + "#" + "SubscribeToTopic"; - - private static final SubscribeToTopicOperationContext _SUBSCRIBE_TO_TOPIC_OPERATION_CONTEXT = new SubscribeToTopicOperationContext(); + public static final String LIST_NAMED_SHADOWS_FOR_THING = SERVICE_NAMESPACE + "#" + "ListNamedShadowsForThing"; - public static final String GET_COMPONENT_DETAILS = SERVICE_NAMESPACE + "#" + "GetComponentDetails"; - - private static final GetComponentDetailsOperationContext _GET_COMPONENT_DETAILS_OPERATION_CONTEXT = new GetComponentDetailsOperationContext(); + private static final ListNamedShadowsForThingOperationContext _LIST_NAMED_SHADOWS_FOR_THING_OPERATION_CONTEXT = new ListNamedShadowsForThingOperationContext(); public static final String SUBSCRIBE_TO_COMPONENT_UPDATES = SERVICE_NAMESPACE + "#" + "SubscribeToComponentUpdates"; @@ -195,24 +219,36 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel { static { SERVICE_OPERATION_MODEL_MAP.put(SUBSCRIBE_TO_IOT_CORE, _SUBSCRIBE_TO_IOT_CORE_OPERATION_CONTEXT); SERVICE_OPERATION_SET.add(SUBSCRIBE_TO_IOT_CORE); - SERVICE_OPERATION_MODEL_MAP.put(PUBLISH_TO_TOPIC, _PUBLISH_TO_TOPIC_OPERATION_CONTEXT); - SERVICE_OPERATION_SET.add(PUBLISH_TO_TOPIC); SERVICE_OPERATION_MODEL_MAP.put(PUBLISH_TO_IOT_CORE, _PUBLISH_TO_IOT_CORE_OPERATION_CONTEXT); SERVICE_OPERATION_SET.add(PUBLISH_TO_IOT_CORE); SERVICE_OPERATION_MODEL_MAP.put(SUBSCRIBE_TO_CONFIGURATION_UPDATE, _SUBSCRIBE_TO_CONFIGURATION_UPDATE_OPERATION_CONTEXT); SERVICE_OPERATION_SET.add(SUBSCRIBE_TO_CONFIGURATION_UPDATE); + SERVICE_OPERATION_MODEL_MAP.put(DELETE_THING_SHADOW, _DELETE_THING_SHADOW_OPERATION_CONTEXT); + SERVICE_OPERATION_SET.add(DELETE_THING_SHADOW); + SERVICE_OPERATION_MODEL_MAP.put(DEFER_COMPONENT_UPDATE, _DEFER_COMPONENT_UPDATE_OPERATION_CONTEXT); + SERVICE_OPERATION_SET.add(DEFER_COMPONENT_UPDATE); + SERVICE_OPERATION_MODEL_MAP.put(SUBSCRIBE_TO_VALIDATE_CONFIGURATION_UPDATES, _SUBSCRIBE_TO_VALIDATE_CONFIGURATION_UPDATES_OPERATION_CONTEXT); + SERVICE_OPERATION_SET.add(SUBSCRIBE_TO_VALIDATE_CONFIGURATION_UPDATES); + SERVICE_OPERATION_MODEL_MAP.put(GET_CONFIGURATION, _GET_CONFIGURATION_OPERATION_CONTEXT); + SERVICE_OPERATION_SET.add(GET_CONFIGURATION); + SERVICE_OPERATION_MODEL_MAP.put(SUBSCRIBE_TO_TOPIC, _SUBSCRIBE_TO_TOPIC_OPERATION_CONTEXT); + SERVICE_OPERATION_SET.add(SUBSCRIBE_TO_TOPIC); + SERVICE_OPERATION_MODEL_MAP.put(GET_COMPONENT_DETAILS, _GET_COMPONENT_DETAILS_OPERATION_CONTEXT); + SERVICE_OPERATION_SET.add(GET_COMPONENT_DETAILS); + SERVICE_OPERATION_MODEL_MAP.put(PUBLISH_TO_TOPIC, _PUBLISH_TO_TOPIC_OPERATION_CONTEXT); + SERVICE_OPERATION_SET.add(PUBLISH_TO_TOPIC); SERVICE_OPERATION_MODEL_MAP.put(LIST_COMPONENTS, _LIST_COMPONENTS_OPERATION_CONTEXT); SERVICE_OPERATION_SET.add(LIST_COMPONENTS); SERVICE_OPERATION_MODEL_MAP.put(CREATE_DEBUG_PASSWORD, _CREATE_DEBUG_PASSWORD_OPERATION_CONTEXT); SERVICE_OPERATION_SET.add(CREATE_DEBUG_PASSWORD); - SERVICE_OPERATION_MODEL_MAP.put(DEFER_COMPONENT_UPDATE, _DEFER_COMPONENT_UPDATE_OPERATION_CONTEXT); - SERVICE_OPERATION_SET.add(DEFER_COMPONENT_UPDATE); + SERVICE_OPERATION_MODEL_MAP.put(GET_THING_SHADOW, _GET_THING_SHADOW_OPERATION_CONTEXT); + SERVICE_OPERATION_SET.add(GET_THING_SHADOW); SERVICE_OPERATION_MODEL_MAP.put(SEND_CONFIGURATION_VALIDITY_REPORT, _SEND_CONFIGURATION_VALIDITY_REPORT_OPERATION_CONTEXT); SERVICE_OPERATION_SET.add(SEND_CONFIGURATION_VALIDITY_REPORT); + SERVICE_OPERATION_MODEL_MAP.put(UPDATE_THING_SHADOW, _UPDATE_THING_SHADOW_OPERATION_CONTEXT); + SERVICE_OPERATION_SET.add(UPDATE_THING_SHADOW); SERVICE_OPERATION_MODEL_MAP.put(UPDATE_CONFIGURATION, _UPDATE_CONFIGURATION_OPERATION_CONTEXT); SERVICE_OPERATION_SET.add(UPDATE_CONFIGURATION); - SERVICE_OPERATION_MODEL_MAP.put(SUBSCRIBE_TO_VALIDATE_CONFIGURATION_UPDATES, _SUBSCRIBE_TO_VALIDATE_CONFIGURATION_UPDATES_OPERATION_CONTEXT); - SERVICE_OPERATION_SET.add(SUBSCRIBE_TO_VALIDATE_CONFIGURATION_UPDATES); SERVICE_OPERATION_MODEL_MAP.put(VALIDATE_AUTHORIZATION_TOKEN, _VALIDATE_AUTHORIZATION_TOKEN_OPERATION_CONTEXT); SERVICE_OPERATION_SET.add(VALIDATE_AUTHORIZATION_TOKEN); SERVICE_OPERATION_MODEL_MAP.put(RESTART_COMPONENT, _RESTART_COMPONENT_OPERATION_CONTEXT); @@ -223,12 +259,8 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel { SERVICE_OPERATION_SET.add(GET_SECRET_VALUE); SERVICE_OPERATION_MODEL_MAP.put(UPDATE_STATE, _UPDATE_STATE_OPERATION_CONTEXT); SERVICE_OPERATION_SET.add(UPDATE_STATE); - SERVICE_OPERATION_MODEL_MAP.put(GET_CONFIGURATION, _GET_CONFIGURATION_OPERATION_CONTEXT); - SERVICE_OPERATION_SET.add(GET_CONFIGURATION); - SERVICE_OPERATION_MODEL_MAP.put(SUBSCRIBE_TO_TOPIC, _SUBSCRIBE_TO_TOPIC_OPERATION_CONTEXT); - SERVICE_OPERATION_SET.add(SUBSCRIBE_TO_TOPIC); - SERVICE_OPERATION_MODEL_MAP.put(GET_COMPONENT_DETAILS, _GET_COMPONENT_DETAILS_OPERATION_CONTEXT); - SERVICE_OPERATION_SET.add(GET_COMPONENT_DETAILS); + SERVICE_OPERATION_MODEL_MAP.put(LIST_NAMED_SHADOWS_FOR_THING, _LIST_NAMED_SHADOWS_FOR_THING_OPERATION_CONTEXT); + SERVICE_OPERATION_SET.add(LIST_NAMED_SHADOWS_FOR_THING); SERVICE_OPERATION_MODEL_MAP.put(SUBSCRIBE_TO_COMPONENT_UPDATES, _SUBSCRIBE_TO_COMPONENT_UPDATES_OPERATION_CONTEXT); SERVICE_OPERATION_SET.add(SUBSCRIBE_TO_COMPONENT_UPDATES); SERVICE_OPERATION_MODEL_MAP.put(LIST_LOCAL_DEPLOYMENTS, _LIST_LOCAL_DEPLOYMENTS_OPERATION_CONTEXT); @@ -241,28 +273,40 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel { SERVICE_OBJECT_MODEL_MAP.put(SubscribeToIoTCoreResponse.APPLICATION_MODEL_TYPE, SubscribeToIoTCoreResponse.class); SERVICE_OBJECT_MODEL_MAP.put(ServiceError.APPLICATION_MODEL_TYPE, ServiceError.class); SERVICE_OBJECT_MODEL_MAP.put(UnauthorizedError.APPLICATION_MODEL_TYPE, UnauthorizedError.class); - SERVICE_OBJECT_MODEL_MAP.put(PublishToTopicRequest.APPLICATION_MODEL_TYPE, PublishToTopicRequest.class); - SERVICE_OBJECT_MODEL_MAP.put(PublishToTopicResponse.APPLICATION_MODEL_TYPE, PublishToTopicResponse.class); SERVICE_OBJECT_MODEL_MAP.put(PublishToIoTCoreRequest.APPLICATION_MODEL_TYPE, PublishToIoTCoreRequest.class); SERVICE_OBJECT_MODEL_MAP.put(PublishToIoTCoreResponse.APPLICATION_MODEL_TYPE, PublishToIoTCoreResponse.class); SERVICE_OBJECT_MODEL_MAP.put(SubscribeToConfigurationUpdateRequest.APPLICATION_MODEL_TYPE, SubscribeToConfigurationUpdateRequest.class); SERVICE_OBJECT_MODEL_MAP.put(SubscribeToConfigurationUpdateResponse.APPLICATION_MODEL_TYPE, SubscribeToConfigurationUpdateResponse.class); SERVICE_OBJECT_MODEL_MAP.put(ResourceNotFoundError.APPLICATION_MODEL_TYPE, ResourceNotFoundError.class); + SERVICE_OBJECT_MODEL_MAP.put(DeleteThingShadowRequest.APPLICATION_MODEL_TYPE, DeleteThingShadowRequest.class); + SERVICE_OBJECT_MODEL_MAP.put(DeleteThingShadowResponse.APPLICATION_MODEL_TYPE, DeleteThingShadowResponse.class); + SERVICE_OBJECT_MODEL_MAP.put(InvalidArgumentsError.APPLICATION_MODEL_TYPE, InvalidArgumentsError.class); + SERVICE_OBJECT_MODEL_MAP.put(DeferComponentUpdateRequest.APPLICATION_MODEL_TYPE, DeferComponentUpdateRequest.class); + SERVICE_OBJECT_MODEL_MAP.put(DeferComponentUpdateResponse.APPLICATION_MODEL_TYPE, DeferComponentUpdateResponse.class); + SERVICE_OBJECT_MODEL_MAP.put(SubscribeToValidateConfigurationUpdatesRequest.APPLICATION_MODEL_TYPE, SubscribeToValidateConfigurationUpdatesRequest.class); + SERVICE_OBJECT_MODEL_MAP.put(SubscribeToValidateConfigurationUpdatesResponse.APPLICATION_MODEL_TYPE, SubscribeToValidateConfigurationUpdatesResponse.class); + SERVICE_OBJECT_MODEL_MAP.put(GetConfigurationRequest.APPLICATION_MODEL_TYPE, GetConfigurationRequest.class); + SERVICE_OBJECT_MODEL_MAP.put(GetConfigurationResponse.APPLICATION_MODEL_TYPE, GetConfigurationResponse.class); + SERVICE_OBJECT_MODEL_MAP.put(SubscribeToTopicRequest.APPLICATION_MODEL_TYPE, SubscribeToTopicRequest.class); + SERVICE_OBJECT_MODEL_MAP.put(SubscribeToTopicResponse.APPLICATION_MODEL_TYPE, SubscribeToTopicResponse.class); + SERVICE_OBJECT_MODEL_MAP.put(GetComponentDetailsRequest.APPLICATION_MODEL_TYPE, GetComponentDetailsRequest.class); + SERVICE_OBJECT_MODEL_MAP.put(GetComponentDetailsResponse.APPLICATION_MODEL_TYPE, GetComponentDetailsResponse.class); + SERVICE_OBJECT_MODEL_MAP.put(PublishToTopicRequest.APPLICATION_MODEL_TYPE, PublishToTopicRequest.class); + SERVICE_OBJECT_MODEL_MAP.put(PublishToTopicResponse.APPLICATION_MODEL_TYPE, PublishToTopicResponse.class); SERVICE_OBJECT_MODEL_MAP.put(ListComponentsRequest.APPLICATION_MODEL_TYPE, ListComponentsRequest.class); SERVICE_OBJECT_MODEL_MAP.put(ListComponentsResponse.APPLICATION_MODEL_TYPE, ListComponentsResponse.class); SERVICE_OBJECT_MODEL_MAP.put(CreateDebugPasswordRequest.APPLICATION_MODEL_TYPE, CreateDebugPasswordRequest.class); SERVICE_OBJECT_MODEL_MAP.put(CreateDebugPasswordResponse.APPLICATION_MODEL_TYPE, CreateDebugPasswordResponse.class); - SERVICE_OBJECT_MODEL_MAP.put(DeferComponentUpdateRequest.APPLICATION_MODEL_TYPE, DeferComponentUpdateRequest.class); - SERVICE_OBJECT_MODEL_MAP.put(DeferComponentUpdateResponse.APPLICATION_MODEL_TYPE, DeferComponentUpdateResponse.class); - SERVICE_OBJECT_MODEL_MAP.put(InvalidArgumentsError.APPLICATION_MODEL_TYPE, InvalidArgumentsError.class); + SERVICE_OBJECT_MODEL_MAP.put(GetThingShadowRequest.APPLICATION_MODEL_TYPE, GetThingShadowRequest.class); + SERVICE_OBJECT_MODEL_MAP.put(GetThingShadowResponse.APPLICATION_MODEL_TYPE, GetThingShadowResponse.class); SERVICE_OBJECT_MODEL_MAP.put(SendConfigurationValidityReportRequest.APPLICATION_MODEL_TYPE, SendConfigurationValidityReportRequest.class); SERVICE_OBJECT_MODEL_MAP.put(SendConfigurationValidityReportResponse.APPLICATION_MODEL_TYPE, SendConfigurationValidityReportResponse.class); + SERVICE_OBJECT_MODEL_MAP.put(UpdateThingShadowRequest.APPLICATION_MODEL_TYPE, UpdateThingShadowRequest.class); + SERVICE_OBJECT_MODEL_MAP.put(UpdateThingShadowResponse.APPLICATION_MODEL_TYPE, UpdateThingShadowResponse.class); + SERVICE_OBJECT_MODEL_MAP.put(ConflictError.APPLICATION_MODEL_TYPE, ConflictError.class); SERVICE_OBJECT_MODEL_MAP.put(UpdateConfigurationRequest.APPLICATION_MODEL_TYPE, UpdateConfigurationRequest.class); SERVICE_OBJECT_MODEL_MAP.put(UpdateConfigurationResponse.APPLICATION_MODEL_TYPE, UpdateConfigurationResponse.class); - SERVICE_OBJECT_MODEL_MAP.put(ConflictError.APPLICATION_MODEL_TYPE, ConflictError.class); SERVICE_OBJECT_MODEL_MAP.put(FailedUpdateConditionCheckError.APPLICATION_MODEL_TYPE, FailedUpdateConditionCheckError.class); - SERVICE_OBJECT_MODEL_MAP.put(SubscribeToValidateConfigurationUpdatesRequest.APPLICATION_MODEL_TYPE, SubscribeToValidateConfigurationUpdatesRequest.class); - SERVICE_OBJECT_MODEL_MAP.put(SubscribeToValidateConfigurationUpdatesResponse.APPLICATION_MODEL_TYPE, SubscribeToValidateConfigurationUpdatesResponse.class); SERVICE_OBJECT_MODEL_MAP.put(ValidateAuthorizationTokenRequest.APPLICATION_MODEL_TYPE, ValidateAuthorizationTokenRequest.class); SERVICE_OBJECT_MODEL_MAP.put(ValidateAuthorizationTokenResponse.APPLICATION_MODEL_TYPE, ValidateAuthorizationTokenResponse.class); SERVICE_OBJECT_MODEL_MAP.put(InvalidTokenError.APPLICATION_MODEL_TYPE, InvalidTokenError.class); @@ -275,12 +319,8 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel { SERVICE_OBJECT_MODEL_MAP.put(GetSecretValueResponse.APPLICATION_MODEL_TYPE, GetSecretValueResponse.class); SERVICE_OBJECT_MODEL_MAP.put(UpdateStateRequest.APPLICATION_MODEL_TYPE, UpdateStateRequest.class); SERVICE_OBJECT_MODEL_MAP.put(UpdateStateResponse.APPLICATION_MODEL_TYPE, UpdateStateResponse.class); - SERVICE_OBJECT_MODEL_MAP.put(GetConfigurationRequest.APPLICATION_MODEL_TYPE, GetConfigurationRequest.class); - SERVICE_OBJECT_MODEL_MAP.put(GetConfigurationResponse.APPLICATION_MODEL_TYPE, GetConfigurationResponse.class); - SERVICE_OBJECT_MODEL_MAP.put(SubscribeToTopicRequest.APPLICATION_MODEL_TYPE, SubscribeToTopicRequest.class); - SERVICE_OBJECT_MODEL_MAP.put(SubscribeToTopicResponse.APPLICATION_MODEL_TYPE, SubscribeToTopicResponse.class); - SERVICE_OBJECT_MODEL_MAP.put(GetComponentDetailsRequest.APPLICATION_MODEL_TYPE, GetComponentDetailsRequest.class); - SERVICE_OBJECT_MODEL_MAP.put(GetComponentDetailsResponse.APPLICATION_MODEL_TYPE, GetComponentDetailsResponse.class); + SERVICE_OBJECT_MODEL_MAP.put(ListNamedShadowsForThingRequest.APPLICATION_MODEL_TYPE, ListNamedShadowsForThingRequest.class); + SERVICE_OBJECT_MODEL_MAP.put(ListNamedShadowsForThingResponse.APPLICATION_MODEL_TYPE, ListNamedShadowsForThingResponse.class); SERVICE_OBJECT_MODEL_MAP.put(SubscribeToComponentUpdatesRequest.APPLICATION_MODEL_TYPE, SubscribeToComponentUpdatesRequest.class); SERVICE_OBJECT_MODEL_MAP.put(SubscribeToComponentUpdatesResponse.APPLICATION_MODEL_TYPE, SubscribeToComponentUpdatesResponse.class); SERVICE_OBJECT_MODEL_MAP.put(ListLocalDeploymentsRequest.APPLICATION_MODEL_TYPE, ListLocalDeploymentsRequest.class); @@ -293,25 +333,25 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel { SERVICE_OBJECT_MODEL_MAP.put(InvalidArtifactsDirectoryPathError.APPLICATION_MODEL_TYPE, InvalidArtifactsDirectoryPathError.class); SERVICE_OBJECT_MODEL_MAP.put(QOS.APPLICATION_MODEL_TYPE, QOS.class); SERVICE_OBJECT_MODEL_MAP.put(IoTCoreMessage.APPLICATION_MODEL_TYPE, IoTCoreMessage.class); - SERVICE_OBJECT_MODEL_MAP.put(PublishMessage.APPLICATION_MODEL_TYPE, PublishMessage.class); SERVICE_OBJECT_MODEL_MAP.put(ConfigurationUpdateEvents.APPLICATION_MODEL_TYPE, ConfigurationUpdateEvents.class); - SERVICE_OBJECT_MODEL_MAP.put(ConfigurationValidityReport.APPLICATION_MODEL_TYPE, ConfigurationValidityReport.class); SERVICE_OBJECT_MODEL_MAP.put(ValidateConfigurationUpdateEvents.APPLICATION_MODEL_TYPE, ValidateConfigurationUpdateEvents.class); + SERVICE_OBJECT_MODEL_MAP.put(SubscriptionResponseMessage.APPLICATION_MODEL_TYPE, SubscriptionResponseMessage.class); + SERVICE_OBJECT_MODEL_MAP.put(ComponentDetails.APPLICATION_MODEL_TYPE, ComponentDetails.class); + SERVICE_OBJECT_MODEL_MAP.put(PublishMessage.APPLICATION_MODEL_TYPE, PublishMessage.class); + SERVICE_OBJECT_MODEL_MAP.put(ConfigurationValidityReport.APPLICATION_MODEL_TYPE, ConfigurationValidityReport.class); SERVICE_OBJECT_MODEL_MAP.put(RequestStatus.APPLICATION_MODEL_TYPE, RequestStatus.class); SERVICE_OBJECT_MODEL_MAP.put(LocalDeployment.APPLICATION_MODEL_TYPE, LocalDeployment.class); SERVICE_OBJECT_MODEL_MAP.put(SecretValue.APPLICATION_MODEL_TYPE, SecretValue.class); SERVICE_OBJECT_MODEL_MAP.put(ReportedLifecycleState.APPLICATION_MODEL_TYPE, ReportedLifecycleState.class); - SERVICE_OBJECT_MODEL_MAP.put(SubscriptionResponseMessage.APPLICATION_MODEL_TYPE, SubscriptionResponseMessage.class); - SERVICE_OBJECT_MODEL_MAP.put(ComponentDetails.APPLICATION_MODEL_TYPE, ComponentDetails.class); SERVICE_OBJECT_MODEL_MAP.put(ComponentUpdatePolicyEvents.APPLICATION_MODEL_TYPE, ComponentUpdatePolicyEvents.class); SERVICE_OBJECT_MODEL_MAP.put(MQTTMessage.APPLICATION_MODEL_TYPE, MQTTMessage.class); + SERVICE_OBJECT_MODEL_MAP.put(ConfigurationUpdateEvent.APPLICATION_MODEL_TYPE, ConfigurationUpdateEvent.class); + SERVICE_OBJECT_MODEL_MAP.put(ValidateConfigurationUpdateEvent.APPLICATION_MODEL_TYPE, ValidateConfigurationUpdateEvent.class); SERVICE_OBJECT_MODEL_MAP.put(JsonMessage.APPLICATION_MODEL_TYPE, JsonMessage.class); SERVICE_OBJECT_MODEL_MAP.put(BinaryMessage.APPLICATION_MODEL_TYPE, BinaryMessage.class); - SERVICE_OBJECT_MODEL_MAP.put(ConfigurationUpdateEvent.APPLICATION_MODEL_TYPE, ConfigurationUpdateEvent.class); + SERVICE_OBJECT_MODEL_MAP.put(LifecycleState.APPLICATION_MODEL_TYPE, LifecycleState.class); SERVICE_OBJECT_MODEL_MAP.put(ConfigurationValidityStatus.APPLICATION_MODEL_TYPE, ConfigurationValidityStatus.class); - SERVICE_OBJECT_MODEL_MAP.put(ValidateConfigurationUpdateEvent.APPLICATION_MODEL_TYPE, ValidateConfigurationUpdateEvent.class); SERVICE_OBJECT_MODEL_MAP.put(DeploymentStatus.APPLICATION_MODEL_TYPE, DeploymentStatus.class); - SERVICE_OBJECT_MODEL_MAP.put(LifecycleState.APPLICATION_MODEL_TYPE, LifecycleState.class); SERVICE_OBJECT_MODEL_MAP.put(PreComponentUpdateEvent.APPLICATION_MODEL_TYPE, PreComponentUpdateEvent.class); SERVICE_OBJECT_MODEL_MAP.put(PostComponentUpdateEvent.APPLICATION_MODEL_TYPE, PostComponentUpdateEvent.class); SERVICE_OBJECT_MODEL_MAP.put(RunWithInfo.APPLICATION_MODEL_TYPE, RunWithInfo.class); @@ -333,10 +373,6 @@ public static SubscribeToIoTCoreOperationContext getSubscribeToIoTCoreModelConte return _SUBSCRIBE_TO_IOT_CORE_OPERATION_CONTEXT; } - public static PublishToTopicOperationContext getPublishToTopicModelContext() { - return _PUBLISH_TO_TOPIC_OPERATION_CONTEXT; - } - public static PublishToIoTCoreOperationContext getPublishToIoTCoreModelContext() { return _PUBLISH_TO_IOT_CORE_OPERATION_CONTEXT; } @@ -346,6 +382,35 @@ public static SubscribeToConfigurationUpdateOperationContext getSubscribeToConfi return _SUBSCRIBE_TO_CONFIGURATION_UPDATE_OPERATION_CONTEXT; } + public static DeleteThingShadowOperationContext getDeleteThingShadowModelContext() { + return _DELETE_THING_SHADOW_OPERATION_CONTEXT; + } + + public static DeferComponentUpdateOperationContext getDeferComponentUpdateModelContext() { + return _DEFER_COMPONENT_UPDATE_OPERATION_CONTEXT; + } + + public static SubscribeToValidateConfigurationUpdatesOperationContext getSubscribeToValidateConfigurationUpdatesModelContext( + ) { + return _SUBSCRIBE_TO_VALIDATE_CONFIGURATION_UPDATES_OPERATION_CONTEXT; + } + + public static GetConfigurationOperationContext getGetConfigurationModelContext() { + return _GET_CONFIGURATION_OPERATION_CONTEXT; + } + + public static SubscribeToTopicOperationContext getSubscribeToTopicModelContext() { + return _SUBSCRIBE_TO_TOPIC_OPERATION_CONTEXT; + } + + public static GetComponentDetailsOperationContext getGetComponentDetailsModelContext() { + return _GET_COMPONENT_DETAILS_OPERATION_CONTEXT; + } + + public static PublishToTopicOperationContext getPublishToTopicModelContext() { + return _PUBLISH_TO_TOPIC_OPERATION_CONTEXT; + } + public static ListComponentsOperationContext getListComponentsModelContext() { return _LIST_COMPONENTS_OPERATION_CONTEXT; } @@ -354,8 +419,8 @@ public static CreateDebugPasswordOperationContext getCreateDebugPasswordModelCon return _CREATE_DEBUG_PASSWORD_OPERATION_CONTEXT; } - public static DeferComponentUpdateOperationContext getDeferComponentUpdateModelContext() { - return _DEFER_COMPONENT_UPDATE_OPERATION_CONTEXT; + public static GetThingShadowOperationContext getGetThingShadowModelContext() { + return _GET_THING_SHADOW_OPERATION_CONTEXT; } public static SendConfigurationValidityReportOperationContext getSendConfigurationValidityReportModelContext( @@ -363,13 +428,12 @@ public static SendConfigurationValidityReportOperationContext getSendConfigurati return _SEND_CONFIGURATION_VALIDITY_REPORT_OPERATION_CONTEXT; } - public static UpdateConfigurationOperationContext getUpdateConfigurationModelContext() { - return _UPDATE_CONFIGURATION_OPERATION_CONTEXT; + public static UpdateThingShadowOperationContext getUpdateThingShadowModelContext() { + return _UPDATE_THING_SHADOW_OPERATION_CONTEXT; } - public static SubscribeToValidateConfigurationUpdatesOperationContext getSubscribeToValidateConfigurationUpdatesModelContext( - ) { - return _SUBSCRIBE_TO_VALIDATE_CONFIGURATION_UPDATES_OPERATION_CONTEXT; + public static UpdateConfigurationOperationContext getUpdateConfigurationModelContext() { + return _UPDATE_CONFIGURATION_OPERATION_CONTEXT; } public static ValidateAuthorizationTokenOperationContext getValidateAuthorizationTokenModelContext( @@ -393,16 +457,8 @@ public static UpdateStateOperationContext getUpdateStateModelContext() { return _UPDATE_STATE_OPERATION_CONTEXT; } - public static GetConfigurationOperationContext getGetConfigurationModelContext() { - return _GET_CONFIGURATION_OPERATION_CONTEXT; - } - - public static SubscribeToTopicOperationContext getSubscribeToTopicModelContext() { - return _SUBSCRIBE_TO_TOPIC_OPERATION_CONTEXT; - } - - public static GetComponentDetailsOperationContext getGetComponentDetailsModelContext() { - return _GET_COMPONENT_DETAILS_OPERATION_CONTEXT; + public static ListNamedShadowsForThingOperationContext getListNamedShadowsForThingModelContext() { + return _LIST_NAMED_SHADOWS_FOR_THING_OPERATION_CONTEXT; } public static SubscribeToComponentUpdatesOperationContext getSubscribeToComponentUpdatesModelContext( diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/ListNamedShadowsForThingOperationContext.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/ListNamedShadowsForThingOperationContext.java new file mode 100644 index 000000000..66c62bbfd --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/ListNamedShadowsForThingOperationContext.java @@ -0,0 +1,62 @@ +package software.amazon.awssdk.aws.greengrass; + +import java.lang.Class; +import java.lang.Override; +import java.lang.String; +import java.util.Optional; +import software.amazon.awssdk.aws.greengrass.model.ListNamedShadowsForThingRequest; +import software.amazon.awssdk.aws.greengrass.model.ListNamedShadowsForThingResponse; +import software.amazon.awssdk.eventstreamrpc.EventStreamRPCServiceModel; +import software.amazon.awssdk.eventstreamrpc.OperationModelContext; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public class ListNamedShadowsForThingOperationContext implements OperationModelContext { + @Override + public EventStreamRPCServiceModel getServiceModel() { + return GreengrassCoreIPCServiceModel.getInstance(); + } + + @Override + public String getOperationName() { + return GreengrassCoreIPCServiceModel.LIST_NAMED_SHADOWS_FOR_THING; + } + + @Override + public Class getRequestTypeClass() { + return ListNamedShadowsForThingRequest.class; + } + + @Override + public Class getResponseTypeClass() { + return ListNamedShadowsForThingResponse.class; + } + + @Override + public String getRequestApplicationModelType() { + return ListNamedShadowsForThingRequest.APPLICATION_MODEL_TYPE; + } + + @Override + public String getResponseApplicationModelType() { + return ListNamedShadowsForThingResponse.APPLICATION_MODEL_TYPE; + } + + @Override + public Optional> getStreamingRequestTypeClass() { + return Optional.empty(); + } + + @Override + public Optional> getStreamingResponseTypeClass() { + return Optional.empty(); + } + + public Optional getStreamingRequestApplicationModelType() { + return Optional.empty(); + } + + @Override + public Optional getStreamingResponseApplicationModelType() { + return Optional.empty(); + } +} diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/UpdateThingShadowOperationContext.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/UpdateThingShadowOperationContext.java new file mode 100644 index 000000000..5aa33c95b --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/UpdateThingShadowOperationContext.java @@ -0,0 +1,62 @@ +package software.amazon.awssdk.aws.greengrass; + +import java.lang.Class; +import java.lang.Override; +import java.lang.String; +import java.util.Optional; +import software.amazon.awssdk.aws.greengrass.model.UpdateThingShadowRequest; +import software.amazon.awssdk.aws.greengrass.model.UpdateThingShadowResponse; +import software.amazon.awssdk.eventstreamrpc.EventStreamRPCServiceModel; +import software.amazon.awssdk.eventstreamrpc.OperationModelContext; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public class UpdateThingShadowOperationContext implements OperationModelContext { + @Override + public EventStreamRPCServiceModel getServiceModel() { + return GreengrassCoreIPCServiceModel.getInstance(); + } + + @Override + public String getOperationName() { + return GreengrassCoreIPCServiceModel.UPDATE_THING_SHADOW; + } + + @Override + public Class getRequestTypeClass() { + return UpdateThingShadowRequest.class; + } + + @Override + public Class getResponseTypeClass() { + return UpdateThingShadowResponse.class; + } + + @Override + public String getRequestApplicationModelType() { + return UpdateThingShadowRequest.APPLICATION_MODEL_TYPE; + } + + @Override + public String getResponseApplicationModelType() { + return UpdateThingShadowResponse.APPLICATION_MODEL_TYPE; + } + + @Override + public Optional> getStreamingRequestTypeClass() { + return Optional.empty(); + } + + @Override + public Optional> getStreamingResponseTypeClass() { + return Optional.empty(); + } + + public Optional getStreamingRequestApplicationModelType() { + return Optional.empty(); + } + + @Override + public Optional getStreamingResponseApplicationModelType() { + return Optional.empty(); + } +} diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/DeleteThingShadowRequest.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/DeleteThingShadowRequest.java new file mode 100644 index 000000000..45a547ff6 --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/DeleteThingShadowRequest.java @@ -0,0 +1,85 @@ +package software.amazon.awssdk.aws.greengrass.model; + +import com.google.gson.annotations.Expose; +import java.lang.Object; +import java.lang.Override; +import java.lang.String; +import java.util.Objects; +import java.util.Optional; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public class DeleteThingShadowRequest implements EventStreamJsonMessage { + public static final String APPLICATION_MODEL_TYPE = "aws.greengrass#DeleteThingShadowRequest"; + + public static final DeleteThingShadowRequest VOID; + + static { + VOID = new DeleteThingShadowRequest() { + @Override + public boolean isVoid() { + return true; + } + }; + } + + @Expose( + serialize = true, + deserialize = true + ) + private Optional thingName; + + @Expose( + serialize = true, + deserialize = true + ) + private Optional shadowName; + + public DeleteThingShadowRequest() { + this.thingName = Optional.empty(); + this.shadowName = Optional.empty(); + } + + public String getThingName() { + if (thingName.isPresent()) { + return thingName.get(); + } + return null; + } + + public void setThingName(final String thingName) { + this.thingName = Optional.ofNullable(thingName); + } + + public String getShadowName() { + if (shadowName.isPresent()) { + return shadowName.get(); + } + return null; + } + + public void setShadowName(final String shadowName) { + this.shadowName = Optional.ofNullable(shadowName); + } + + @Override + public String getApplicationModelType() { + return APPLICATION_MODEL_TYPE; + } + + @Override + public boolean equals(Object rhs) { + if (rhs == null) return false; + if (!(rhs instanceof DeleteThingShadowRequest)) return false; + if (this == rhs) return true; + final DeleteThingShadowRequest other = (DeleteThingShadowRequest)rhs; + boolean isEquals = true; + isEquals = isEquals && this.thingName.equals(other.thingName); + isEquals = isEquals && this.shadowName.equals(other.shadowName); + return isEquals; + } + + @Override + public int hashCode() { + return Objects.hash(thingName, shadowName); + } +} diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/DeleteThingShadowResponse.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/DeleteThingShadowResponse.java new file mode 100644 index 000000000..97aa2984b --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/DeleteThingShadowResponse.java @@ -0,0 +1,67 @@ +package software.amazon.awssdk.aws.greengrass.model; + +import com.google.gson.annotations.Expose; +import java.lang.Object; +import java.lang.Override; +import java.lang.String; +import java.util.Objects; +import java.util.Optional; +import software.amazon.awssdk.eventstreamrpc.EventStreamRPCServiceModel; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public class DeleteThingShadowResponse implements EventStreamJsonMessage { + public static final String APPLICATION_MODEL_TYPE = "aws.greengrass#DeleteThingShadowResponse"; + + public static final DeleteThingShadowResponse VOID; + + static { + VOID = new DeleteThingShadowResponse() { + @Override + public boolean isVoid() { + return true; + } + }; + } + + @Expose( + serialize = true, + deserialize = true + ) + private Optional payload; + + public DeleteThingShadowResponse() { + this.payload = Optional.empty(); + } + + public byte[] getPayload() { + if (payload.isPresent()) { + return payload.get(); + } + return null; + } + + public void setPayload(final byte[] payload) { + this.payload = Optional.ofNullable(payload); + } + + @Override + public String getApplicationModelType() { + return APPLICATION_MODEL_TYPE; + } + + @Override + public boolean equals(Object rhs) { + if (rhs == null) return false; + if (!(rhs instanceof DeleteThingShadowResponse)) return false; + if (this == rhs) return true; + final DeleteThingShadowResponse other = (DeleteThingShadowResponse)rhs; + boolean isEquals = true; + isEquals = isEquals && EventStreamRPCServiceModel.blobTypeEquals(this.payload, other.payload); + return isEquals; + } + + @Override + public int hashCode() { + return Objects.hash(payload); + } +} diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/GetThingShadowRequest.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/GetThingShadowRequest.java new file mode 100644 index 000000000..71b9bfd8d --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/GetThingShadowRequest.java @@ -0,0 +1,85 @@ +package software.amazon.awssdk.aws.greengrass.model; + +import com.google.gson.annotations.Expose; +import java.lang.Object; +import java.lang.Override; +import java.lang.String; +import java.util.Objects; +import java.util.Optional; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public class GetThingShadowRequest implements EventStreamJsonMessage { + public static final String APPLICATION_MODEL_TYPE = "aws.greengrass#GetThingShadowRequest"; + + public static final GetThingShadowRequest VOID; + + static { + VOID = new GetThingShadowRequest() { + @Override + public boolean isVoid() { + return true; + } + }; + } + + @Expose( + serialize = true, + deserialize = true + ) + private Optional thingName; + + @Expose( + serialize = true, + deserialize = true + ) + private Optional shadowName; + + public GetThingShadowRequest() { + this.thingName = Optional.empty(); + this.shadowName = Optional.empty(); + } + + public String getThingName() { + if (thingName.isPresent()) { + return thingName.get(); + } + return null; + } + + public void setThingName(final String thingName) { + this.thingName = Optional.ofNullable(thingName); + } + + public String getShadowName() { + if (shadowName.isPresent()) { + return shadowName.get(); + } + return null; + } + + public void setShadowName(final String shadowName) { + this.shadowName = Optional.ofNullable(shadowName); + } + + @Override + public String getApplicationModelType() { + return APPLICATION_MODEL_TYPE; + } + + @Override + public boolean equals(Object rhs) { + if (rhs == null) return false; + if (!(rhs instanceof GetThingShadowRequest)) return false; + if (this == rhs) return true; + final GetThingShadowRequest other = (GetThingShadowRequest)rhs; + boolean isEquals = true; + isEquals = isEquals && this.thingName.equals(other.thingName); + isEquals = isEquals && this.shadowName.equals(other.shadowName); + return isEquals; + } + + @Override + public int hashCode() { + return Objects.hash(thingName, shadowName); + } +} diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/GetThingShadowResponse.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/GetThingShadowResponse.java new file mode 100644 index 000000000..1a4780615 --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/GetThingShadowResponse.java @@ -0,0 +1,67 @@ +package software.amazon.awssdk.aws.greengrass.model; + +import com.google.gson.annotations.Expose; +import java.lang.Object; +import java.lang.Override; +import java.lang.String; +import java.util.Objects; +import java.util.Optional; +import software.amazon.awssdk.eventstreamrpc.EventStreamRPCServiceModel; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public class GetThingShadowResponse implements EventStreamJsonMessage { + public static final String APPLICATION_MODEL_TYPE = "aws.greengrass#GetThingShadowResponse"; + + public static final GetThingShadowResponse VOID; + + static { + VOID = new GetThingShadowResponse() { + @Override + public boolean isVoid() { + return true; + } + }; + } + + @Expose( + serialize = true, + deserialize = true + ) + private Optional payload; + + public GetThingShadowResponse() { + this.payload = Optional.empty(); + } + + public byte[] getPayload() { + if (payload.isPresent()) { + return payload.get(); + } + return null; + } + + public void setPayload(final byte[] payload) { + this.payload = Optional.ofNullable(payload); + } + + @Override + public String getApplicationModelType() { + return APPLICATION_MODEL_TYPE; + } + + @Override + public boolean equals(Object rhs) { + if (rhs == null) return false; + if (!(rhs instanceof GetThingShadowResponse)) return false; + if (this == rhs) return true; + final GetThingShadowResponse other = (GetThingShadowResponse)rhs; + boolean isEquals = true; + isEquals = isEquals && EventStreamRPCServiceModel.blobTypeEquals(this.payload, other.payload); + return isEquals; + } + + @Override + public int hashCode() { + return Objects.hash(payload); + } +} diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/ListNamedShadowsForThingRequest.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/ListNamedShadowsForThingRequest.java new file mode 100644 index 000000000..1b0aa6d35 --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/ListNamedShadowsForThingRequest.java @@ -0,0 +1,105 @@ +package software.amazon.awssdk.aws.greengrass.model; + +import com.google.gson.annotations.Expose; +import java.lang.Integer; +import java.lang.Object; +import java.lang.Override; +import java.lang.String; +import java.util.Objects; +import java.util.Optional; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public class ListNamedShadowsForThingRequest implements EventStreamJsonMessage { + public static final String APPLICATION_MODEL_TYPE = "aws.greengrass#ListNamedShadowsForThingRequest"; + + public static final ListNamedShadowsForThingRequest VOID; + + static { + VOID = new ListNamedShadowsForThingRequest() { + @Override + public boolean isVoid() { + return true; + } + }; + } + + @Expose( + serialize = true, + deserialize = true + ) + private Optional thingName; + + @Expose( + serialize = true, + deserialize = true + ) + private Optional nextToken; + + @Expose( + serialize = true, + deserialize = true + ) + private Optional pageSize; + + public ListNamedShadowsForThingRequest() { + this.thingName = Optional.empty(); + this.nextToken = Optional.empty(); + this.pageSize = Optional.empty(); + } + + public String getThingName() { + if (thingName.isPresent()) { + return thingName.get(); + } + return null; + } + + public void setThingName(final String thingName) { + this.thingName = Optional.ofNullable(thingName); + } + + public String getNextToken() { + if (nextToken.isPresent()) { + return nextToken.get(); + } + return null; + } + + public void setNextToken(final String nextToken) { + this.nextToken = Optional.ofNullable(nextToken); + } + + public Integer getPageSize() { + if (pageSize.isPresent()) { + return pageSize.get(); + } + return null; + } + + public void setPageSize(final Integer pageSize) { + this.pageSize = Optional.ofNullable(pageSize); + } + + @Override + public String getApplicationModelType() { + return APPLICATION_MODEL_TYPE; + } + + @Override + public boolean equals(Object rhs) { + if (rhs == null) return false; + if (!(rhs instanceof ListNamedShadowsForThingRequest)) return false; + if (this == rhs) return true; + final ListNamedShadowsForThingRequest other = (ListNamedShadowsForThingRequest)rhs; + boolean isEquals = true; + isEquals = isEquals && this.thingName.equals(other.thingName); + isEquals = isEquals && this.nextToken.equals(other.nextToken); + isEquals = isEquals && this.pageSize.equals(other.pageSize); + return isEquals; + } + + @Override + public int hashCode() { + return Objects.hash(thingName, nextToken, pageSize); + } +} diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/ListNamedShadowsForThingResponse.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/ListNamedShadowsForThingResponse.java new file mode 100644 index 000000000..7ca64d36d --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/ListNamedShadowsForThingResponse.java @@ -0,0 +1,106 @@ +package software.amazon.awssdk.aws.greengrass.model; + +import com.google.gson.annotations.Expose; +import java.lang.Object; +import java.lang.Override; +import java.lang.String; +import java.time.Instant; +import java.util.List; +import java.util.Objects; +import java.util.Optional; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public class ListNamedShadowsForThingResponse implements EventStreamJsonMessage { + public static final String APPLICATION_MODEL_TYPE = "aws.greengrass#ListNamedShadowsForThingResponse"; + + public static final ListNamedShadowsForThingResponse VOID; + + static { + VOID = new ListNamedShadowsForThingResponse() { + @Override + public boolean isVoid() { + return true; + } + }; + } + + @Expose( + serialize = true, + deserialize = true + ) + private Optional> results; + + @Expose( + serialize = true, + deserialize = true + ) + private Optional timestamp; + + @Expose( + serialize = true, + deserialize = true + ) + private Optional nextToken; + + public ListNamedShadowsForThingResponse() { + this.results = Optional.empty(); + this.timestamp = Optional.empty(); + this.nextToken = Optional.empty(); + } + + public List getResults() { + if (results.isPresent()) { + return results.get(); + } + return null; + } + + public void setResults(final List results) { + this.results = Optional.ofNullable(results); + } + + public Instant getTimestamp() { + if (timestamp.isPresent()) { + return timestamp.get(); + } + return null; + } + + public void setTimestamp(final Instant timestamp) { + this.timestamp = Optional.ofNullable(timestamp); + } + + public String getNextToken() { + if (nextToken.isPresent()) { + return nextToken.get(); + } + return null; + } + + public void setNextToken(final String nextToken) { + this.nextToken = Optional.ofNullable(nextToken); + } + + @Override + public String getApplicationModelType() { + return APPLICATION_MODEL_TYPE; + } + + @Override + public boolean equals(Object rhs) { + if (rhs == null) return false; + if (!(rhs instanceof ListNamedShadowsForThingResponse)) return false; + if (this == rhs) return true; + final ListNamedShadowsForThingResponse other = (ListNamedShadowsForThingResponse)rhs; + boolean isEquals = true; + isEquals = isEquals && this.results.equals(other.results); + isEquals = isEquals && this.timestamp.equals(other.timestamp); + isEquals = isEquals && this.nextToken.equals(other.nextToken); + return isEquals; + } + + @Override + public int hashCode() { + return Objects.hash(results, timestamp, nextToken); + } +} diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/UpdateThingShadowRequest.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/UpdateThingShadowRequest.java new file mode 100644 index 000000000..816eb29eb --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/UpdateThingShadowRequest.java @@ -0,0 +1,105 @@ +package software.amazon.awssdk.aws.greengrass.model; + +import com.google.gson.annotations.Expose; +import java.lang.Object; +import java.lang.Override; +import java.lang.String; +import java.util.Objects; +import java.util.Optional; +import software.amazon.awssdk.eventstreamrpc.EventStreamRPCServiceModel; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public class UpdateThingShadowRequest implements EventStreamJsonMessage { + public static final String APPLICATION_MODEL_TYPE = "aws.greengrass#UpdateThingShadowRequest"; + + public static final UpdateThingShadowRequest VOID; + + static { + VOID = new UpdateThingShadowRequest() { + @Override + public boolean isVoid() { + return true; + } + }; + } + + @Expose( + serialize = true, + deserialize = true + ) + private Optional thingName; + + @Expose( + serialize = true, + deserialize = true + ) + private Optional shadowName; + + @Expose( + serialize = true, + deserialize = true + ) + private Optional payload; + + public UpdateThingShadowRequest() { + this.thingName = Optional.empty(); + this.shadowName = Optional.empty(); + this.payload = Optional.empty(); + } + + public String getThingName() { + if (thingName.isPresent()) { + return thingName.get(); + } + return null; + } + + public void setThingName(final String thingName) { + this.thingName = Optional.ofNullable(thingName); + } + + public String getShadowName() { + if (shadowName.isPresent()) { + return shadowName.get(); + } + return null; + } + + public void setShadowName(final String shadowName) { + this.shadowName = Optional.ofNullable(shadowName); + } + + public byte[] getPayload() { + if (payload.isPresent()) { + return payload.get(); + } + return null; + } + + public void setPayload(final byte[] payload) { + this.payload = Optional.ofNullable(payload); + } + + @Override + public String getApplicationModelType() { + return APPLICATION_MODEL_TYPE; + } + + @Override + public boolean equals(Object rhs) { + if (rhs == null) return false; + if (!(rhs instanceof UpdateThingShadowRequest)) return false; + if (this == rhs) return true; + final UpdateThingShadowRequest other = (UpdateThingShadowRequest)rhs; + boolean isEquals = true; + isEquals = isEquals && this.thingName.equals(other.thingName); + isEquals = isEquals && this.shadowName.equals(other.shadowName); + isEquals = isEquals && EventStreamRPCServiceModel.blobTypeEquals(this.payload, other.payload); + return isEquals; + } + + @Override + public int hashCode() { + return Objects.hash(thingName, shadowName, payload); + } +} diff --git a/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/UpdateThingShadowResponse.java b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/UpdateThingShadowResponse.java new file mode 100644 index 000000000..a11c5463b --- /dev/null +++ b/sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/model/UpdateThingShadowResponse.java @@ -0,0 +1,67 @@ +package software.amazon.awssdk.aws.greengrass.model; + +import com.google.gson.annotations.Expose; +import java.lang.Object; +import java.lang.Override; +import java.lang.String; +import java.util.Objects; +import java.util.Optional; +import software.amazon.awssdk.eventstreamrpc.EventStreamRPCServiceModel; +import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage; + +public class UpdateThingShadowResponse implements EventStreamJsonMessage { + public static final String APPLICATION_MODEL_TYPE = "aws.greengrass#UpdateThingShadowResponse"; + + public static final UpdateThingShadowResponse VOID; + + static { + VOID = new UpdateThingShadowResponse() { + @Override + public boolean isVoid() { + return true; + } + }; + } + + @Expose( + serialize = true, + deserialize = true + ) + private Optional payload; + + public UpdateThingShadowResponse() { + this.payload = Optional.empty(); + } + + public byte[] getPayload() { + if (payload.isPresent()) { + return payload.get(); + } + return null; + } + + public void setPayload(final byte[] payload) { + this.payload = Optional.ofNullable(payload); + } + + @Override + public String getApplicationModelType() { + return APPLICATION_MODEL_TYPE; + } + + @Override + public boolean equals(Object rhs) { + if (rhs == null) return false; + if (!(rhs instanceof UpdateThingShadowResponse)) return false; + if (this == rhs) return true; + final UpdateThingShadowResponse other = (UpdateThingShadowResponse)rhs; + boolean isEquals = true; + isEquals = isEquals && EventStreamRPCServiceModel.blobTypeEquals(this.payload, other.payload); + return isEquals; + } + + @Override + public int hashCode() { + return Objects.hash(payload); + } +}