Add generated headers to Greengrass generated code (#319)

Add generated headers to Greengrass generated code

Author: TwistedTwigleg

sdk/greengrass/event-stream-rpc-client/src/main/java/software/amazon/awssdk/eventstreamrpc/EventStreamRPCClient.java

@@ -24,27 +24,27 @@ public class EventStreamRPCClient {
     private final EventStreamRPCConnection connection;
 
     /**
-      * Creates a new EventStreamRPCClient
-      * @param connection The connection for the EventStreamRPCClient to use
-      */
+     * Creates a new EventStreamRPCClient
+     * @param connection The connection for the EventStreamRPCClient to use
+     */
     public EventStreamRPCClient(EventStreamRPCConnection connection) {
         if (connection == null) {
             throw new IllegalArgumentException("Cannot create eventstream RPC client with null connection");
         }
         this.connection = connection;
     }
 
-    /**
-     * Work horse of all operations, streaming or otherwise.
-     * @param <ReqType> The request type
-     * @param <RespType> The response type
-     * @param <StrReqType> The streaming request type
-     * @param <StrRespType> The streaming response type
-     * @param operationModelContext The operation context
-     * @param request The request
-     * @param streamResponseHandler The streaming handler
-     * @return The operation result
-     */
+     /**
+      * Work horse of all operations, streaming or otherwise.
+      * @param <ReqType> The request type
+      * @param <RespType> The response type
+      * @param <StrReqType> The streaming request type
+      * @param <StrRespType> The streaming response type
+      * @param operationModelContext The operation context
+      * @param request The request
+      * @param streamResponseHandler The streaming handler
+      * @return The operation result
+      */
     public <ReqType extends EventStreamJsonMessage,
             RespType extends EventStreamJsonMessage,
             StrReqType extends EventStreamJsonMessage,
@@ -145,7 +145,7 @@ protected void onContinuationMessage(List<Header> headers, byte[] payload, Messa
                     }
                 }
             }
-
+            
             @Override
             protected void onContinuationClosed() {
                 super.onContinuationClosed();
@@ -169,10 +169,10 @@ protected void onContinuationClosed() {
         return response;
     }
 
-
+    
 
     /**
-     * Sends an empty close message on the open stream.
+     * Sends an empty close message on the open stream. 
      * @param continuation continuation to send the close message on
      * @return CompletableFuture indicating flush of the close message.
      */

sdk/greengrass/event-stream-rpc-client/src/main/java/software/amazon/awssdk/eventstreamrpc/EventStreamRPCConnection.java

@@ -34,12 +34,12 @@ enum Phase {
             CONNECTED,
             CLOSING
         };
-
+        
         Phase connectionPhase;
         ClientConnection connection;
         Throwable closeReason;
         boolean onConnectCalled;
-
+        
         protected ConnectionState(Phase phase, ClientConnection connection) {
             this.connectionPhase = phase;
             this.connection = connection;
@@ -75,7 +75,7 @@ protected String getVersionString() {
 
     /**
      * Connects to the event stream RPC server asynchronously
-     *
+     * 
      * @return A future that completes when connected
      */
     public CompletableFuture<Void> connect(final LifecycleHandler lifecycleHandler) {
@@ -156,7 +156,7 @@ protected void onProtocolMessage(List<Header> headers, byte[] payload, MessageTy
                                     LOGGER.warning("AccessDenied to event stream RPC server");
                                     connectionState.connectionPhase = ConnectionState.Phase.CLOSING;
                                     connectionState.connection.closeConnection(0);
-
+                                    
                                     final AccessDeniedException ade = new AccessDeniedException("Connection access denied to event stream RPC server");
                                     if (!initialConnectFuture.isDone()) {
                                         initialConnectFuture.completeExceptionally(ade);
@@ -179,7 +179,7 @@ protected void onProtocolMessage(List<Header> headers, byte[] payload, MessageTy
                             disconnect();
                         } else if (MessageType.ProtocolError.equals(messageType) || MessageType.ServerError.equals(messageType)) {
                             LOGGER.severe("Received " + messageType.name() + ": " + CRT.awsErrorName(CRT.awsLastError()));
-                            connectionState.closeReason = EventStreamError.create(headers, payload, messageType);
+                            connectionState.closeReason = EventStreamError.create(headers, payload, messageType);                            
                             doOnError(lifecycleHandler, connectionState.closeReason);
                             disconnect();
                         } else {
@@ -222,7 +222,7 @@ protected void onConnectionClosed(int errorCode) {
     /**
      * Creates a new stream with the given continuation handler.
      * Trhows an exception if not connected
-     *
+     * 
      * @param continuationHandler The continuation handler to use
      * @return A new ClientConnectionContinuation containing the new stream.
      */
@@ -375,7 +375,7 @@ public interface LifecycleHandler {
           * Do nothing on ping by default. Inform handler of ping data
          *
          * TODO: Could use boolean return here as a hint on whether a pong reply should be sent?
-         *
+         * 
           * @param headers The ping headers
           * @param payload The ping payload
           */

sdk/greengrass/event-stream-rpc-client/src/main/java/software/amazon/awssdk/eventstreamrpc/GreengrassConnectMessageSupplier.java

@@ -13,7 +13,7 @@
  * The connect message supplier for Greengrass
  */
 public class GreengrassConnectMessageSupplier {
-
+    
     /**
      * Returns a new connect message supplier using the given token
      * @param authToken The auth token to use

sdk/greengrass/event-stream-rpc-model/src/main/java/software/amazon/awssdk/eventstreamrpc/EventStreamRPCServiceModel.java

@@ -281,7 +281,7 @@ final public Optional<Class<? extends EventStreamJsonMessage>> getApplicationMod
      *
      * This may not be a useful interface as generated code will typically pull a known operation model context
      * Public visibility is useful for testing
-     *
+     * 
      * @param operationName The name of the operation
      * @return The operation context associated with the given operation name
      */

sdk/greengrass/event-stream-rpc-model/src/main/java/software/amazon/awssdk/eventstreamrpc/MessageAmendInfo.java

@@ -36,7 +36,7 @@ public MessageAmendInfo(List<Header> headers, byte[] payload) {
      * Returns the headers stored in the object. For sent messages,
      * the headers stored in the object may be used to append to existing headers,
      * where it won't overwrite an existing one that may be outgoing.
-     *
+     * 
      * @return The headers stored
      */
     public List<Header> getHeaders() {

sdk/greengrass/event-stream-rpc-model/src/main/java/software/amazon/awssdk/eventstreamrpc/OperationModelContext.java

@@ -11,7 +11,7 @@
  * Smithy code generation should produce one of these per model, but we aren't going to take steps to prevent
  * hand construction.
  *
- * @param <RequestType> The initial-request
+ * @param <RequestType> The initial-request 
  * @param <ResponseType> The initial-response
  * @param <StreamingRequestType> The streaming initial-request
  * @param <StreamingResponseType> The streaming initial-response

sdk/greengrass/event-stream-rpc-model/src/main/java/software/amazon/awssdk/eventstreamrpc/Version.java

@@ -62,7 +62,7 @@ public String toString() {
     /**
      * Returns a new Version class from the given version string.
      * Will throw an exception if it cannot convert.
-     *
+     * 
      * @param versionString The version string to convert
      * @return The Version class created from the string
      */

sdk/greengrass/event-stream-rpc-model/src/main/java/software/amazon/awssdk/eventstreamrpc/model/AccessDeniedException.java

@@ -27,7 +27,7 @@ public AccessDeniedException(String serviceName, String message) {
      * or the principal/authN that was rejected
      *
      * Do not overexpose reason or logic for AccessDenied. Prefer internal logging
-     *
+     * 
      * @param serviceName The name of the service that caused the exception
      */
     public AccessDeniedException(String serviceName) {

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

@@ -1,3 +1,10 @@
+/**
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0.
+ *
+ * This file is generated.
+ */
+
 package software.amazon.awssdk.aws.greengrass;
 
 import java.lang.Override;

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

@@ -1,3 +1,10 @@
+/**
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0.
+ *
+ * This file is generated.
+ */
+
 package software.amazon.awssdk.aws.greengrass;
 
 import java.lang.Override;