Update Greengrass V2 IPC models

sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/AuthorizeClientDeviceActionResponseHandler.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.AuthorizeClientDeviceActionResponse;
+import software.amazon.awssdk.eventstreamrpc.OperationResponse;
+import software.amazon.awssdk.eventstreamrpc.StreamResponse;
+import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage;
+
+public final class AuthorizeClientDeviceActionResponseHandler implements StreamResponse<AuthorizeClientDeviceActionResponse, EventStreamJsonMessage> {
+  private final OperationResponse<AuthorizeClientDeviceActionResponse, EventStreamJsonMessage> operationResponse;
+
+  public AuthorizeClientDeviceActionResponseHandler(
+      final OperationResponse<AuthorizeClientDeviceActionResponse, EventStreamJsonMessage> operationResponse) {
+    this.operationResponse = operationResponse;
+  }
+
+  @Override
+  public CompletableFuture<Void> getRequestFlushFuture() {
+    return operationResponse.getRequestFlushFuture();
+  }
+
+  @Override
+  public CompletableFuture<AuthorizeClientDeviceActionResponse> getResponse() {
+    return operationResponse.getResponse();
+  }
+
+  @Override
+  public CompletableFuture<Void> sendStreamEvent(final EventStreamJsonMessage event) {
+    return operationResponse.sendStreamEvent(event);
+  }
+
+  @Override
+  public CompletableFuture<Void> closeStream() {
+    return operationResponse.closeStream();
+  }
+
+  @Override
+  public boolean isClosed() {
+    return operationResponse.isClosed();
+  }
+}

sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GetClientDeviceAuthTokenResponseHandler.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.GetClientDeviceAuthTokenResponse;
+import software.amazon.awssdk.eventstreamrpc.OperationResponse;
+import software.amazon.awssdk.eventstreamrpc.StreamResponse;
+import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage;
+
+public final class GetClientDeviceAuthTokenResponseHandler implements StreamResponse<GetClientDeviceAuthTokenResponse, EventStreamJsonMessage> {
+  private final OperationResponse<GetClientDeviceAuthTokenResponse, EventStreamJsonMessage> operationResponse;
+
+  public GetClientDeviceAuthTokenResponseHandler(
+      final OperationResponse<GetClientDeviceAuthTokenResponse, EventStreamJsonMessage> operationResponse) {
+    this.operationResponse = operationResponse;
+  }
+
+  @Override
+  public CompletableFuture<Void> getRequestFlushFuture() {
+    return operationResponse.getRequestFlushFuture();
+  }
+
+  @Override
+  public CompletableFuture<GetClientDeviceAuthTokenResponse> getResponse() {
+    return operationResponse.getResponse();
+  }
+
+  @Override
+  public CompletableFuture<Void> sendStreamEvent(final EventStreamJsonMessage event) {
+    return operationResponse.sendStreamEvent(event);
+  }
+
+  @Override
+  public CompletableFuture<Void> closeStream() {
+    return operationResponse.closeStream();
+  }
+
+  @Override
+  public boolean isClosed() {
+    return operationResponse.isClosed();
+  }
+}

sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPC.java

@@ -1,12 +1,15 @@
 package software.amazon.awssdk.aws.greengrass;
 
 import java.util.Optional;
+import software.amazon.awssdk.aws.greengrass.model.AuthorizeClientDeviceActionRequest;
+import software.amazon.awssdk.aws.greengrass.model.CertificateUpdateEvent;
 import software.amazon.awssdk.aws.greengrass.model.ComponentUpdatePolicyEvents;
 import software.amazon.awssdk.aws.greengrass.model.ConfigurationUpdateEvents;
 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.GetClientDeviceAuthTokenRequest;
 import software.amazon.awssdk.aws.greengrass.model.GetComponentDetailsRequest;
 import software.amazon.awssdk.aws.greengrass.model.GetConfigurationRequest;
 import software.amazon.awssdk.aws.greengrass.model.GetLocalDeploymentStatusRequest;
@@ -23,6 +26,7 @@
 import software.amazon.awssdk.aws.greengrass.model.ResumeComponentRequest;
 import software.amazon.awssdk.aws.greengrass.model.SendConfigurationValidityReportRequest;
 import software.amazon.awssdk.aws.greengrass.model.StopComponentRequest;
+import software.amazon.awssdk.aws.greengrass.model.SubscribeToCertificateUpdatesRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToComponentUpdatesRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreRequest;
@@ -34,10 +38,15 @@
 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.aws.greengrass.model.VerifyClientDeviceIdentityRequest;
 import software.amazon.awssdk.eventstreamrpc.StreamResponseHandler;
 import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage;
 
 public interface GreengrassCoreIPC {
+  AuthorizeClientDeviceActionResponseHandler authorizeClientDeviceAction(
+      final AuthorizeClientDeviceActionRequest request,
+      final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
+
   CreateDebugPasswordResponseHandler createDebugPassword(final CreateDebugPasswordRequest request,
       final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
 
@@ -52,6 +61,10 @@ DeferComponentUpdateResponseHandler deferComponentUpdate(
   DeleteThingShadowResponseHandler deleteThingShadow(final DeleteThingShadowRequest request,
       final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
 
+  GetClientDeviceAuthTokenResponseHandler getClientDeviceAuthToken(
+      final GetClientDeviceAuthTokenRequest request,
+      final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
+
   GetComponentDetailsResponseHandler getComponentDetails(final GetComponentDetailsRequest request,
       final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
 
@@ -101,6 +114,10 @@ SendConfigurationValidityReportResponseHandler sendConfigurationValidityReport(
   StopComponentResponseHandler stopComponent(final StopComponentRequest request,
       final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
 
+  SubscribeToCertificateUpdatesResponseHandler subscribeToCertificateUpdates(
+      final SubscribeToCertificateUpdatesRequest request,
+      final Optional<StreamResponseHandler<CertificateUpdateEvent>> streamResponseHandler);
+
   SubscribeToComponentUpdatesResponseHandler subscribeToComponentUpdates(
       final SubscribeToComponentUpdatesRequest request,
       final Optional<StreamResponseHandler<ComponentUpdatePolicyEvents>> streamResponseHandler);
@@ -131,4 +148,8 @@ UpdateThingShadowResponseHandler updateThingShadow(final UpdateThingShadowReques
   ValidateAuthorizationTokenResponseHandler validateAuthorizationToken(
       final ValidateAuthorizationTokenRequest request,
       final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
+
+  VerifyClientDeviceIdentityResponseHandler verifyClientDeviceIdentity(
+      final VerifyClientDeviceIdentityRequest request,
+      final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
 }

sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPCClient.java

@@ -2,12 +2,15 @@
 
 import java.lang.Override;
 import java.util.Optional;
+import software.amazon.awssdk.aws.greengrass.model.AuthorizeClientDeviceActionRequest;
+import software.amazon.awssdk.aws.greengrass.model.CertificateUpdateEvent;
 import software.amazon.awssdk.aws.greengrass.model.ComponentUpdatePolicyEvents;
 import software.amazon.awssdk.aws.greengrass.model.ConfigurationUpdateEvents;
 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.GetClientDeviceAuthTokenRequest;
 import software.amazon.awssdk.aws.greengrass.model.GetComponentDetailsRequest;
 import software.amazon.awssdk.aws.greengrass.model.GetConfigurationRequest;
 import software.amazon.awssdk.aws.greengrass.model.GetLocalDeploymentStatusRequest;
@@ -24,6 +27,7 @@
 import software.amazon.awssdk.aws.greengrass.model.ResumeComponentRequest;
 import software.amazon.awssdk.aws.greengrass.model.SendConfigurationValidityReportRequest;
 import software.amazon.awssdk.aws.greengrass.model.StopComponentRequest;
+import software.amazon.awssdk.aws.greengrass.model.SubscribeToCertificateUpdatesRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToComponentUpdatesRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreRequest;
@@ -35,6 +39,7 @@
 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.aws.greengrass.model.VerifyClientDeviceIdentityRequest;
 import software.amazon.awssdk.eventstreamrpc.EventStreamRPCClient;
 import software.amazon.awssdk.eventstreamrpc.EventStreamRPCConnection;
 import software.amazon.awssdk.eventstreamrpc.StreamResponseHandler;
@@ -45,6 +50,14 @@ public GreengrassCoreIPCClient(final EventStreamRPCConnection connection) {
     super(connection);
   }
 
+  @Override
+  public AuthorizeClientDeviceActionResponseHandler authorizeClientDeviceAction(
+      final AuthorizeClientDeviceActionRequest request,
+      final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler) {
+    final AuthorizeClientDeviceActionOperationContext operationContext = GreengrassCoreIPCServiceModel.getAuthorizeClientDeviceActionModelContext();
+    return new AuthorizeClientDeviceActionResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
+  }
+
   @Override
   public CreateDebugPasswordResponseHandler createDebugPassword(
       final CreateDebugPasswordRequest request,
@@ -76,6 +89,14 @@ public DeleteThingShadowResponseHandler deleteThingShadow(final DeleteThingShado
     return new DeleteThingShadowResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
   }
 
+  @Override
+  public GetClientDeviceAuthTokenResponseHandler getClientDeviceAuthToken(
+      final GetClientDeviceAuthTokenRequest request,
+      final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler) {
+    final GetClientDeviceAuthTokenOperationContext operationContext = GreengrassCoreIPCServiceModel.getGetClientDeviceAuthTokenModelContext();
+    return new GetClientDeviceAuthTokenResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
+  }
+
   @Override
   public GetComponentDetailsResponseHandler getComponentDetails(
       final GetComponentDetailsRequest request,
@@ -186,6 +207,14 @@ public StopComponentResponseHandler stopComponent(final StopComponentRequest req
     return new StopComponentResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
   }
 
+  @Override
+  public SubscribeToCertificateUpdatesResponseHandler subscribeToCertificateUpdates(
+      final SubscribeToCertificateUpdatesRequest request,
+      final Optional<StreamResponseHandler<CertificateUpdateEvent>> streamResponseHandler) {
+    final SubscribeToCertificateUpdatesOperationContext operationContext = GreengrassCoreIPCServiceModel.getSubscribeToCertificateUpdatesModelContext();
+    return new SubscribeToCertificateUpdatesResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
+  }
+
   @Override
   public SubscribeToComponentUpdatesResponseHandler subscribeToComponentUpdates(
       final SubscribeToComponentUpdatesRequest request,
@@ -254,4 +283,12 @@ public ValidateAuthorizationTokenResponseHandler validateAuthorizationToken(
     final ValidateAuthorizationTokenOperationContext operationContext = GreengrassCoreIPCServiceModel.getValidateAuthorizationTokenModelContext();
     return new ValidateAuthorizationTokenResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
   }
+
+  @Override
+  public VerifyClientDeviceIdentityResponseHandler verifyClientDeviceIdentity(
+      final VerifyClientDeviceIdentityRequest request,
+      final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler) {
+    final VerifyClientDeviceIdentityOperationContext operationContext = GreengrassCoreIPCServiceModel.getVerifyClientDeviceIdentityModelContext();
+    return new VerifyClientDeviceIdentityResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
+  }
 }