Merge pull request #216 from LeoPlatform/feat/ES-2929-async-lambda-wrappers

feat(wrappers): convert Lambda handler exports to async for nodejs20.x+ compatibility

Author: czirker

wrappers/cron.js

@@ -1,5 +1,6 @@
 "use strict";
 
+const wrapAsAsync = require("./wrapAsAsync");
 
 let cachedHandler;
 module.exports = function(configOverride, botHandler) {
@@ -100,7 +101,7 @@ module.exports = function(configOverride, botHandler) {
 	}
 
 	Object.assign(config, configOverride);
-	return function(event, context, callback) {
+	return wrapAsAsync(function(event, context, callback) {
 		context.callbackWaitsForEmptyEventLoop = false;
 		context.resources = process.resources;
 		context.botId = event.botId || botId;
@@ -252,6 +253,6 @@ module.exports = function(configOverride, botHandler) {
 				}
 			});
 		}
-	};
+	});
 };
 module.exports.CronWrapper = module.exports;

wrappers/fanout.js

@@ -1,4 +1,5 @@
 
+const wrapAsAsync = require("./wrapAsAsync");
 const { Lambda } = require("@aws-sdk/client-lambda");
 const async = require("async");
 const eventIdFormat = "[z/]YYYY/MM/DD/HH/mm/";
@@ -110,7 +111,7 @@ const fanoutFactory = (handler, eventPartition, opts = {}) => {
 
 
 	logger.log("Fanout Return", process.env.FANOUT_iid, process.env.FANOUT_icount, process.env.FANOUT_maxeid);
-	return (event, context, callback) => {
+	return wrapAsAsync((event, context, callback) => {
 
 		cronData = event.__cron || {};
 
@@ -199,7 +200,7 @@ const fanoutFactory = (handler, eventPartition, opts = {}) => {
 				return callback(err);
 			});
 		}
-	};
+	});
 };
 
 function callCheckpointOnResponses(leoBotCheckpoint, callback) {

wrappers/resource.js

@@ -1,12 +1,13 @@
 "use strict";
+const wrapAsAsync = require("./wrapAsAsync");
 let config = require("../leoConfigure.js");
 module.exports = function (configOverride, botHandler) {
 	if (!botHandler) {
 		botHandler = configOverride;
 		configOverride = {};
 	}
 	Object.assign(config, configOverride);
-	return function (event, context, callback) {
+	return wrapAsAsync(function (event, context, callback) {
 		context.callbackWaitsForEmptyEventLoop = false;
 		if (context.identity) { // Called Directly not via Api Gateway
 			event = {
@@ -120,5 +121,5 @@ module.exports = function (configOverride, botHandler) {
 				}
 			});
 		}
-	};
+	});
 };

wrappers/test.js

@@ -1,5 +1,6 @@
 "use strict";
 
+const wrapAsAsync = require("./wrapAsAsync");
 
 let cachedHandler;
 module.exports = function(configOverride, botHandler) {
@@ -47,7 +48,7 @@ module.exports = function(configOverride, botHandler) {
 	}
 
 	Object.assign(config, configOverride);
-	return function(event, context, callback) {
+	return wrapAsAsync(function(event, context, callback) {
 		let cb = callback;
 		callback = (err, data) => {
 			assert.print();
@@ -97,5 +98,5 @@ module.exports = function(configOverride, botHandler) {
 		}
 
 
-	};
+	});
 };

wrappers/wrapAsAsync.js

@@ -0,0 +1,20 @@
+"use strict";
+
+/**
+ * Converts a callback-style Lambda handler into an async handler that returns a Promise.
+ * Newer Node.js Lambda runtimes (nodejs20.x+) no longer support the callback pattern,
+ * so all exported handlers must be async.
+ *
+ * @param {function(event, context, callback)} handler - A callback-style Lambda handler
+ * @returns {function(event, context): Promise} An async Lambda handler
+ */
+module.exports = function wrapAsAsync(handler) {
+	return async function(event, context) {
+		return new Promise((resolve, reject) => {
+			handler(event, context, function(err, result) {
+				if (err) reject(err);
+				else resolve(result);
+			});
+		});
+	};
+};