Issue 14 fixes

aws-greengrass-core-sdk/stream-manager/client.js

@@ -41,6 +41,10 @@ const removeFromArray = (arr, f) => {
  * c.onConnected(async () => {
  *     // Do work with the client (c) here.
  * });
+ * process.on('unhandledRejection', (reason, promise) => {
+ *     console.log('Unhandled Rejection at:', promise, 'reason:', reason);
+ *     // Application specific logging, throwing an error, or other logic here
+*  });
  */
 class StreamManagerClient {
     #closed = false;

greengrassExamples/HelloWorld/index.js

@@ -37,7 +37,8 @@ function greengrassHelloWorldRun() {
 setInterval(greengrassHelloWorldRun, 5000);
 
 // This is a handler which does nothing for this example
-exports.handler = function handler(event, context) {
+exports.handler = function handler(event, context, callback) {
     console.log(event);
     console.log(context);
+    callback(null, 0);
 };

greengrassExamples/LambdaInvoke/invokerbinary.js

@@ -10,7 +10,7 @@ const ggSdk = require('aws-greengrass-core-sdk');
 
 const lambdaClient = new ggSdk.Lambda();
 
-exports.handler = function handler(event, context) {
+exports.handler = function handler(event, context, callback) {
     console.log(event);
     console.log(context);
 
@@ -33,8 +33,10 @@ exports.handler = function handler(event, context) {
     lambdaClient.invoke(params, (err, data) => {
         if (err) {
             console.error(err, err.stack);
+            callback(err);
         } else {
             console.log(data);
+            callback(undefined, 0);
         }
     });
 };

greengrassExamples/LambdaInvoke/invokerjson.js

@@ -10,7 +10,7 @@ const ggSdk = require('aws-greengrass-core-sdk');
 
 const lambdaClient = new ggSdk.Lambda();
 
-exports.handler = function handler(event, context) {
+exports.handler = function handler(event, context, callback) {
     console.log(event);
     console.log(context);
 
@@ -33,8 +33,10 @@ exports.handler = function handler(event, context) {
     lambdaClient.invoke(params, (err, data) => {
         if (err) {
             console.error(err, err.stack);
+            callback(err);
         } else {
             console.log(data);
+            callback(null, 0);
         }
     });
 };

greengrassExamples/ShadowOperations/index.js

@@ -23,26 +23,28 @@ const shadowGetParams = {
     thingName: 'platform',
 };
 
-exports.handler = function handler(event, context) {
+exports.handler = function handler(event, context, callback) {
     console.log(context);
 
     // Update Thing Shadow
     console.log('Update Thing Operation');
     iotClient.updateThingShadow(shadowUpdateParams, (err, data) => {
         if (err) {
             console.log(err);
+            callback(err);
         } else {
             console.log(data);
+            // Get Thing Shadow
+            console.log('Shadow Get Operation');
+            iotClient.getThingShadow(shadowGetParams, (err, data) => {
+                if (err) {
+                    console.log(err);
+                    callback(err);
+                } else {
+                    console.log(data);
+                    callback(null, 0);
+                } 
+            });
         }
-    });
-
-    // Get Thing Shadow
-    console.log('Shadow Get Operation');
-    iotClient.getThingShadow(shadowGetParams, (err, data) => {
-        if (err) {
-            console.log(err);
-        } else {
-            console.log(data);
-        }
-    });
+    }); 
 };

greengrassExamples/StreamManagerIoTSiteWise/index.js

@@ -89,6 +89,11 @@ c.onConnected(async () => {
     }
 });
 
+process.on('unhandledRejection', (reason, promise) => {
+    console.log('Unhandled Rejection at:', promise, 'reason:', reason);
+    // Perform the appropriate action based on the reason
+});
+
 // Dummy handler because this example should run as a long-lived lambda
 module.exports.handler = function handler() {
     return '';

greengrassExamples/StreamManagerKinesis/index.js

@@ -79,6 +79,11 @@ c.onConnected(async () => {
     }
 });
 
+process.on('unhandledRejection', (reason, promise) => {
+    console.log('Unhandled Rejection at:', promise, 'reason:', reason);
+    // Perform the appropriate action based on the reason
+});
+
 // Dummy handler because this example should run as a pinned lambda
 module.exports.handler = function handler() {
     return '';

greengrassExamples/StreamManagerS3/index.js

@@ -112,6 +112,11 @@ c.onConnected(async () => {
     }
 });
 
+process.on('unhandledRejection', (reason, promise) => {
+    console.log('Unhandled Rejection at:', promise, 'reason:', reason);
+    // Perform the appropriate action based on the reason
+});
+
 // Dummy handler because this example should run as a pinned lambda
 module.exports.handler = function handler() {
     return '';

greengrassExamples/TES/index.js

@@ -34,7 +34,8 @@ function getCredential(retryInterval) {
 getCredential(initialRetryInterval);
 
 // This is a handler which does nothing for this example
-exports.handler = function handler(event, context) {
+exports.handler = function handler(event, context, callback) {
     console.log(event);
     console.log(context);
+    callback(null, 0);
 };