@gotamedia/aws - npm Package Compare versions

Comparing version 0.0.6 to 0.0.7

CHANGELOG.md

@@ -5,2 +5,9 @@ # Changelog
 
+## [0.0.7](https://bitbucket.org/gotamedia/aws/compare/0.0.7..0.0.6) (2023-05-26)
+
+
+### Bug Fixes
+
+* configure & silenceXrayContextErrors exports. ([72b52ef](https://bitbucket.org/gotamedia/aws/commits/72b52efd2d694d49656d85fd0db86d7c5daac789))
+
 ## [0.0.6](https://bitbucket.org/gotamedia/aws/compare/0.0.6..0.0.5) (2023-05-26)
@@ -7,0 +14,0 @@

configure.d.ts

@@ -8,2 +8,2 @@ export type AWS_SERVICES_CONFIG_Type = {
 declare const configure: (config: AWS_SERVICES_CONFIG_Type) => void;
-export { AWS_SERVICES_CONFIG, configure as default };
+export { AWS_SERVICES_CONFIG, configure };

configure.js

 "use strict";
-var __assign = (this && this.__assign) || function () {
-    __assign = Object.assign || function(t) {
-        for (var s, i = 1, n = arguments.length; i < n; i++) {
-            s = arguments[i];
-            for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
-                t[p] = s[p];
-        }
-        return t;
-    };
-    return __assign.apply(this, arguments);
-};
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.default = exports.AWS_SERVICES_CONFIG = void 0;
-var AWS_SERVICES_CONFIG = {
+exports.configure = exports.AWS_SERVICES_CONFIG = void 0;
+let AWS_SERVICES_CONFIG = {
     debug: false,
@@ -21,5 +10,5 @@ throwErrors: false,
 exports.AWS_SERVICES_CONFIG = AWS_SERVICES_CONFIG;
-var configure = function (config) {
-    exports.AWS_SERVICES_CONFIG = AWS_SERVICES_CONFIG = __assign(__assign({}, AWS_SERVICES_CONFIG), config);
+const configure = (config) => {
+    exports.AWS_SERVICES_CONFIG = AWS_SERVICES_CONFIG = Object.assign(Object.assign({}, AWS_SERVICES_CONFIG), config);
 };
-exports.default = configure;
+exports.configure = configure;

debug.js

 "use strict";
-var __spreadArray = (this && this.__spreadArray) || function (to, from, pack) {
-    if (pack || arguments.length === 2) for (var i = 0, l = from.length, ar; i < l; i++) {
-        if (ar || !(i in from)) {
-            if (!ar) ar = Array.prototype.slice.call(from, 0, i);
-            ar[i] = from[i];
-        }
-    }
-    return to.concat(ar || Array.prototype.slice.call(from));
-};
 Object.defineProperty(exports, "__esModule", { value: true });
-var configure_1 = require("./configure");
-function debug() {
-    var args = [];
-    for (var _i = 0; _i < arguments.length; _i++) {
-        args[_i] = arguments[_i];
-    }
+const configure_1 = require("./configure");
+function debug(...args) {
     if (configure_1.AWS_SERVICES_CONFIG.debug) {
         console.log("AWS Services:");
-        console.log.apply(console, __spreadArray(["\t"], args, false));
+        console.log("\t", ...args);
     }
 }
 exports.default = debug;

handleError.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-var utils_1 = require("@gotamedia/utils");
-var configure_1 = require("./configure");
-var handleError = function (error, info) {
+const utils_1 = require("@gotamedia/utils");
+const configure_1 = require("./configure");
+const handleError = (error, info) => {
     if (configure_1.AWS_SERVICES_CONFIG.outputErrors) {
@@ -7,0 +7,0 @@ (0, utils_1.logError)(error, info);

index.d.ts

 export * from "./services";
-export * from "./utils";
 export * from "./configure";

index.js

@@ -18,3 +18,2 @@ "use strict";
 __exportStar(require("./services"), exports);
-__exportStar(require("./utils"), exports);
 __exportStar(require("./configure"), exports);

package.json

 {
     "name": "@gotamedia/aws",
-    "version": "0.0.6",
+    "version": "0.0.7",
     "private": false,
@@ -5,0 +5,0 @@ "description": "Set of AWS helpers for NodeJs Runtime.",

services/Lambda.js

 "use strict";
-var __assign = (this && this.__assign) || function () {
-    __assign = Object.assign || function(t) {
-        for (var s, i = 1, n = arguments.length; i < n; i++) {
-            s = arguments[i];
-            for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
-                t[p] = s[p];
-        }
-        return t;
-    };
-    return __assign.apply(this, arguments);
-};
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
@@ -22,29 +11,2 @@ function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
 };
-var __generator = (this && this.__generator) || function (thisArg, body) {
-    var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
-    return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
-    function verb(n) { return function (v) { return step([n, v]); }; }
-    function step(op) {
-        if (f) throw new TypeError("Generator is already executing.");
-        while (g && (g = 0, op[0] && (_ = 0)), _) try {
-            if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
-            if (y = 0, t) op = [op[0] & 2, t.value];
-            switch (op[0]) {
-                case 0: case 1: t = op; break;
-                case 4: _.label++; return { value: op[1], done: false };
-                case 5: _.label++; y = op[1]; op = [0]; continue;
-                case 7: op = _.ops.pop(); _.trys.pop(); continue;
-                default:
-                    if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
-                    if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
-                    if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
-                    if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
-                    if (t[2]) _.ops.pop();
-                    _.trys.pop(); continue;
-            }
-            op = body.call(thisArg, _);
-        } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
-        if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
-    }
-};
 var __rest = (this && this.__rest) || function (s, e) {
@@ -63,31 +25,20 @@ var t = {};
 exports.client = exports.invoke = void 0;
-var client_lambda_1 = require("@aws-sdk/client-lambda");
-var debug_1 = require("../debug");
-var handleError_1 = require("../handleError");
-var Xray_1 = require("./Xray");
-var Lambda = (0, Xray_1.wrapClient)(new client_lambda_1.LambdaClient({ region: process.env.AWS_REGION }));
+const client_lambda_1 = require("@aws-sdk/client-lambda");
+const debug_1 = require("../debug");
+const handleError_1 = require("../handleError");
+const Xray_1 = require("./Xray");
+const Lambda = (0, Xray_1.wrapClient)(new client_lambda_1.LambdaClient({ region: process.env.AWS_REGION }));
 exports.client = Lambda;
-var invoke = function (params) { return __awaiter(void 0, void 0, void 0, function () {
-    var FunctionName, Payload, _a, InvocationType, filteredParams, invokeCommand, response, error_1;
-    return __generator(this, function (_b) {
-        switch (_b.label) {
-            case 0:
-                FunctionName = params.FunctionName, Payload = params.Payload, _a = params.InvocationType, InvocationType = _a === void 0 ? "Event" : _a, filteredParams = __rest(params, ["FunctionName", "Payload", "InvocationType"]);
-                (0, debug_1.default)("Invoke Lambda with function name: ", FunctionName, ", type: ", InvocationType, ", payload: ", Payload);
-                _b.label = 1;
-            case 1:
-                _b.trys.push([1, 3, , 4]);
-                invokeCommand = new client_lambda_1.InvokeCommand(__assign({ FunctionName: FunctionName, InvocationType: InvocationType, Payload: Payload ? Buffer.from(JSON.stringify(Payload)) : undefined }, filteredParams));
-                return [4 /*yield*/, Lambda.send(invokeCommand)];
-            case 2:
-                response = _b.sent();
-                return [2 /*return*/, response];
-            case 3:
-                error_1 = _b.sent();
-                (0, handleError_1.default)(error_1, "Something went wrong while invoking Lambda function");
-                return [3 /*break*/, 4];
-            case 4: return [2 /*return*/];
-        }
-    });
-}); };
+const invoke = (params) => __awaiter(void 0, void 0, void 0, function* () {
+    const { FunctionName, Payload, InvocationType = "Event" } = params, filteredParams = __rest(params, ["FunctionName", "Payload", "InvocationType"]);
+    (0, debug_1.default)("Invoke Lambda with function name: ", FunctionName, ", type: ", InvocationType, ", payload: ", Payload);
+    try {
+        const invokeCommand = new client_lambda_1.InvokeCommand(Object.assign({ FunctionName: FunctionName, InvocationType: InvocationType, Payload: Payload ? Buffer.from(JSON.stringify(Payload)) : undefined }, filteredParams));
+        const response = yield Lambda.send(invokeCommand);
+        return response;
+    }
+    catch (error) {
+        (0, handleError_1.default)(error, "Something went wrong while invoking Lambda function");
+    }
+});
 exports.invoke = invoke;

services/S3.js

 "use strict";
-var __assign = (this && this.__assign) || function () {
-    __assign = Object.assign || function(t) {
-        for (var s, i = 1, n = arguments.length; i < n; i++) {
-            s = arguments[i];
-            for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
-                t[p] = s[p];
-        }
-        return t;
-    };
-    return __assign.apply(this, arguments);
-};
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
@@ -22,29 +11,2 @@ function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
 };
-var __generator = (this && this.__generator) || function (thisArg, body) {
-    var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
-    return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
-    function verb(n) { return function (v) { return step([n, v]); }; }
-    function step(op) {
-        if (f) throw new TypeError("Generator is already executing.");
-        while (g && (g = 0, op[0] && (_ = 0)), _) try {
-            if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
-            if (y = 0, t) op = [op[0] & 2, t.value];
-            switch (op[0]) {
-                case 0: case 1: t = op; break;
-                case 4: _.label++; return { value: op[1], done: false };
-                case 5: _.label++; y = op[1]; op = [0]; continue;
-                case 7: op = _.ops.pop(); _.trys.pop(); continue;
-                default:
-                    if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
-                    if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
-                    if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
-                    if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
-                    if (t[2]) _.ops.pop();
-                    _.trys.pop(); continue;
-            }
-            op = body.call(thisArg, _);
-        } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
-        if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
-    }
-};
 var __rest = (this && this.__rest) || function (s, e) {
@@ -63,55 +25,31 @@ var t = {};
 exports.client = exports.deleteObject = exports.putObject = void 0;
-var client_s3_1 = require("@aws-sdk/client-s3");
-var debug_1 = require("../debug");
-var handleError_1 = require("../handleError");
-var Xray_1 = require("./Xray");
-var S3 = (0, Xray_1.wrapClient)(new client_s3_1.S3Client({ region: process.env.AWS_REGION }));
+const client_s3_1 = require("@aws-sdk/client-s3");
+const debug_1 = require("../debug");
+const handleError_1 = require("../handleError");
+const Xray_1 = require("./Xray");
+const S3 = (0, Xray_1.wrapClient)(new client_s3_1.S3Client({ region: process.env.AWS_REGION }));
 exports.client = S3;
-var putObject = function (params) { return __awaiter(void 0, void 0, void 0, function () {
-    var Bucket, Key, Body, _a, ContentType, filteredParams, putObjectCommand, error_1;
-    return __generator(this, function (_b) {
-        switch (_b.label) {
-            case 0:
-                Bucket = params.Bucket, Key = params.Key, Body = params.Body, _a = params.ContentType, ContentType = _a === void 0 ? "application/json" : _a, filteredParams = __rest(params, ["Bucket", "Key", "Body", "ContentType"]);
-                (0, debug_1.default)("Put S3 object, BUCKET: ", Bucket, ", KEY: ", Key, ", BODY: ", Body);
-                _b.label = 1;
-            case 1:
-                _b.trys.push([1, 3, , 4]);
-                putObjectCommand = new client_s3_1.PutObjectCommand(__assign({ Bucket: Bucket, Key: Key, Body: Body, ContentType: ContentType }, filteredParams));
-                return [4 /*yield*/, S3.send(putObjectCommand)];
-            case 2:
-                _b.sent();
-                return [3 /*break*/, 4];
-            case 3:
-                error_1 = _b.sent();
-                (0, handleError_1.default)(error_1, "Something went wrong while putting S3 object");
-                return [3 /*break*/, 4];
-            case 4: return [2 /*return*/];
-        }
-    });
-}); };
+const putObject = (params) => __awaiter(void 0, void 0, void 0, function* () {
+    const { Bucket, Key, Body, ContentType = "application/json" } = params, filteredParams = __rest(params, ["Bucket", "Key", "Body", "ContentType"]);
+    (0, debug_1.default)("Put S3 object, BUCKET: ", Bucket, ", KEY: ", Key, ", BODY: ", Body);
+    try {
+        const putObjectCommand = new client_s3_1.PutObjectCommand(Object.assign({ Bucket: Bucket, Key: Key, Body: Body, ContentType: ContentType }, filteredParams));
+        yield S3.send(putObjectCommand);
+    }
+    catch (error) {
+        (0, handleError_1.default)(error, "Something went wrong while putting S3 object");
+    }
+});
 exports.putObject = putObject;
-var deleteObject = function (params) { return __awaiter(void 0, void 0, void 0, function () {
-    var Bucket, Key, filteredParams, deleteObjectCommand, error_2;
-    return __generator(this, function (_a) {
-        switch (_a.label) {
-            case 0:
-                Bucket = params.Bucket, Key = params.Key, filteredParams = __rest(params, ["Bucket", "Key"]);
-                (0, debug_1.default)("Delete S3 object, BUCKET: ", Bucket, ", KEY: ", Key);
-                _a.label = 1;
-            case 1:
-                _a.trys.push([1, 3, , 4]);
-                deleteObjectCommand = new client_s3_1.DeleteObjectCommand(__assign({ Bucket: Bucket, Key: Key }, filteredParams));
-                return [4 /*yield*/, S3.send(deleteObjectCommand)];
-            case 2:
-                _a.sent();
-                return [3 /*break*/, 4];
-            case 3:
-                error_2 = _a.sent();
-                (0, handleError_1.default)(error_2, "Something went wrong while deleteing S3 object");
-                return [3 /*break*/, 4];
-            case 4: return [2 /*return*/];
-        }
-    });
-}); };
+const deleteObject = (params) => __awaiter(void 0, void 0, void 0, function* () {
+    const { Bucket, Key } = params, filteredParams = __rest(params, ["Bucket", "Key"]);
+    (0, debug_1.default)("Delete S3 object, BUCKET: ", Bucket, ", KEY: ", Key);
+    try {
+        const deleteObjectCommand = new client_s3_1.DeleteObjectCommand(Object.assign({ Bucket: Bucket, Key: Key }, filteredParams));
+        yield S3.send(deleteObjectCommand);
+    }
+    catch (error) {
+        (0, handleError_1.default)(error, "Something went wrong while deleteing S3 object");
+    }
+});
 exports.deleteObject = deleteObject;

services/SNS.js

@@ -11,59 +11,20 @@ "use strict";
 };
-var __generator = (this && this.__generator) || function (thisArg, body) {
-    var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
-    return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
-    function verb(n) { return function (v) { return step([n, v]); }; }
-    function step(op) {
-        if (f) throw new TypeError("Generator is already executing.");
-        while (g && (g = 0, op[0] && (_ = 0)), _) try {
-            if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
-            if (y = 0, t) op = [op[0] & 2, t.value];
-            switch (op[0]) {
-                case 0: case 1: t = op; break;
-                case 4: _.label++; return { value: op[1], done: false };
-                case 5: _.label++; y = op[1]; op = [0]; continue;
-                case 7: op = _.ops.pop(); _.trys.pop(); continue;
-                default:
-                    if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
-                    if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
-                    if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
-                    if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
-                    if (t[2]) _.ops.pop();
-                    _.trys.pop(); continue;
-            }
-            op = body.call(thisArg, _);
-        } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
-        if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
-    }
-};
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.client = exports.publishMessage = void 0;
-var client_sns_1 = require("@aws-sdk/client-sns");
-var debug_1 = require("../debug");
-var handleError_1 = require("../handleError");
-var Xray_1 = require("./Xray");
-var SNS = (0, Xray_1.wrapClient)(new client_sns_1.SNSClient({ region: process.env.AWS_REGION }));
+const client_sns_1 = require("@aws-sdk/client-sns");
+const debug_1 = require("../debug");
+const handleError_1 = require("../handleError");
+const Xray_1 = require("./Xray");
+const SNS = (0, Xray_1.wrapClient)(new client_sns_1.SNSClient({ region: process.env.AWS_REGION }));
 exports.client = SNS;
-var publishMessage = function (params) { return __awaiter(void 0, void 0, void 0, function () {
-    var publishMessageCommand, error_1;
-    return __generator(this, function (_a) {
-        switch (_a.label) {
-            case 0:
-                (0, debug_1.default)("Publish SNS message with topic: ", params.TopicArn, ", message: ", params.Message);
-                _a.label = 1;
-            case 1:
-                _a.trys.push([1, 3, , 4]);
-                publishMessageCommand = new client_sns_1.PublishCommand(params);
-                return [4 /*yield*/, SNS.send(publishMessageCommand)];
-            case 2:
-                _a.sent();
-                return [3 /*break*/, 4];
-            case 3:
-                error_1 = _a.sent();
-                (0, handleError_1.default)(error_1, "Something went wrong while publishing SNS message");
-                return [3 /*break*/, 4];
-            case 4: return [2 /*return*/];
-        }
-    });
-}); };
+const publishMessage = (params) => __awaiter(void 0, void 0, void 0, function* () {
+    (0, debug_1.default)("Publish SNS message with topic: ", params.TopicArn, ", message: ", params.Message);
+    try {
+        const publishMessageCommand = new client_sns_1.PublishCommand(params);
+        yield SNS.send(publishMessageCommand);
+    }
+    catch (error) {
+        (0, handleError_1.default)(error, "Something went wrong while publishing SNS message");
+    }
+});
 exports.publishMessage = publishMessage;

services/SQS.js

@@ -11,82 +11,31 @@ "use strict";
 };
-var __generator = (this && this.__generator) || function (thisArg, body) {
-    var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
-    return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
-    function verb(n) { return function (v) { return step([n, v]); }; }
-    function step(op) {
-        if (f) throw new TypeError("Generator is already executing.");
-        while (g && (g = 0, op[0] && (_ = 0)), _) try {
-            if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
-            if (y = 0, t) op = [op[0] & 2, t.value];
-            switch (op[0]) {
-                case 0: case 1: t = op; break;
-                case 4: _.label++; return { value: op[1], done: false };
-                case 5: _.label++; y = op[1]; op = [0]; continue;
-                case 7: op = _.ops.pop(); _.trys.pop(); continue;
-                default:
-                    if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
-                    if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
-                    if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
-                    if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
-                    if (t[2]) _.ops.pop();
-                    _.trys.pop(); continue;
-            }
-            op = body.call(thisArg, _);
-        } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
-        if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
-    }
-};
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.client = exports.sendMessageBatch = exports.sendMessage = void 0;
-var client_sqs_1 = require("@aws-sdk/client-sqs");
-var debug_1 = require("../debug");
-var handleError_1 = require("../handleError");
-var Xray_1 = require("./Xray");
-var SQS = (0, Xray_1.wrapClient)(new client_sqs_1.SQSClient({ region: process.env.AWS_REGION }));
+const client_sqs_1 = require("@aws-sdk/client-sqs");
+const debug_1 = require("../debug");
+const handleError_1 = require("../handleError");
+const Xray_1 = require("./Xray");
+const SQS = (0, Xray_1.wrapClient)(new client_sqs_1.SQSClient({ region: process.env.AWS_REGION }));
 exports.client = SQS;
-var sendMessage = function (params) { return __awaiter(void 0, void 0, void 0, function () {
-    var sendMessageCommand, error_1;
-    return __generator(this, function (_a) {
-        switch (_a.label) {
-            case 0:
-                (0, debug_1.default)("Send SQS message with queue: ", params.QueueUrl, ", message: ", params.MessageBody);
-                _a.label = 1;
-            case 1:
-                _a.trys.push([1, 3, , 4]);
-                sendMessageCommand = new client_sqs_1.SendMessageCommand(params);
-                return [4 /*yield*/, SQS.send(sendMessageCommand)];
-            case 2:
-                _a.sent();
-                return [3 /*break*/, 4];
-            case 3:
-                error_1 = _a.sent();
-                (0, handleError_1.default)(error_1, "Something went wrong while sending SQS message");
-                return [3 /*break*/, 4];
-            case 4: return [2 /*return*/];
-        }
-    });
-}); };
+const sendMessage = (params) => __awaiter(void 0, void 0, void 0, function* () {
+    (0, debug_1.default)("Send SQS message with queue: ", params.QueueUrl, ", message: ", params.MessageBody);
+    try {
+        const sendMessageCommand = new client_sqs_1.SendMessageCommand(params);
+        yield SQS.send(sendMessageCommand);
+    }
+    catch (error) {
+        (0, handleError_1.default)(error, "Something went wrong while sending SQS message");
+    }
+});
 exports.sendMessage = sendMessage;
-var sendMessageBatch = function (params) { return __awaiter(void 0, void 0, void 0, function () {
-    var sendMessageBatchCommand, error_2;
-    return __generator(this, function (_a) {
-        switch (_a.label) {
-            case 0:
-                (0, debug_1.default)("Send SQS message batch with queue: ", params.QueueUrl, ", entries: ", params.Entries);
-                _a.label = 1;
-            case 1:
-                _a.trys.push([1, 3, , 4]);
-                sendMessageBatchCommand = new client_sqs_1.SendMessageBatchCommand(params);
-                return [4 /*yield*/, SQS.send(sendMessageBatchCommand)];
-            case 2:
-                _a.sent();
-                return [3 /*break*/, 4];
-            case 3:
-                error_2 = _a.sent();
-                (0, handleError_1.default)(error_2, "Something went wrong while sending SQS message batch");
-                return [3 /*break*/, 4];
-            case 4: return [2 /*return*/];
-        }
-    });
-}); };
+const sendMessageBatch = (params) => __awaiter(void 0, void 0, void 0, function* () {
+    (0, debug_1.default)("Send SQS message batch with queue: ", params.QueueUrl, ", entries: ", params.Entries);
+    try {
+        const sendMessageBatchCommand = new client_sqs_1.SendMessageBatchCommand(params);
+        yield SQS.send(sendMessageBatchCommand);
+    }
+    catch (error) {
+        (0, handleError_1.default)(error, "Something went wrong while sending SQS message batch");
+    }
+});
 exports.sendMessageBatch = sendMessageBatch;

services/SSM.js

 "use strict";
-var __assign = (this && this.__assign) || function () {
-    __assign = Object.assign || function(t) {
-        for (var s, i = 1, n = arguments.length; i < n; i++) {
-            s = arguments[i];
-            for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
-                t[p] = s[p];
-        }
-        return t;
-    };
-    return __assign.apply(this, arguments);
-};
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
@@ -22,29 +11,2 @@ function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
 };
-var __generator = (this && this.__generator) || function (thisArg, body) {
-    var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
-    return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
-    function verb(n) { return function (v) { return step([n, v]); }; }
-    function step(op) {
-        if (f) throw new TypeError("Generator is already executing.");
-        while (g && (g = 0, op[0] && (_ = 0)), _) try {
-            if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
-            if (y = 0, t) op = [op[0] & 2, t.value];
-            switch (op[0]) {
-                case 0: case 1: t = op; break;
-                case 4: _.label++; return { value: op[1], done: false };
-                case 5: _.label++; y = op[1]; op = [0]; continue;
-                case 7: op = _.ops.pop(); _.trys.pop(); continue;
-                default:
-                    if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
-                    if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
-                    if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
-                    if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
-                    if (t[2]) _.ops.pop();
-                    _.trys.pop(); continue;
-            }
-            op = body.call(thisArg, _);
-        } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
-        if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
-    }
-};
 var __rest = (this && this.__rest) || function (s, e) {
@@ -63,60 +25,38 @@ var t = {};
 exports.client = exports.putParameter = exports.getParameter = void 0;
-var client_ssm_1 = require("@aws-sdk/client-ssm");
-var debug_1 = require("../debug");
-var handleError_1 = require("../handleError");
-var Xray_1 = require("./Xray");
-var SSM = (0, Xray_1.wrapClient)(new client_ssm_1.SSMClient({ region: process.env.AWS_REGION }));
+const client_ssm_1 = require("@aws-sdk/client-ssm");
+const debug_1 = require("../debug");
+const handleError_1 = require("../handleError");
+const Xray_1 = require("./Xray");
+const SSM = (0, Xray_1.wrapClient)(new client_ssm_1.SSMClient({ region: process.env.AWS_REGION }));
 exports.client = SSM;
-var getParameter = function (params) { return __awaiter(void 0, void 0, void 0, function () {
-    var Name, filteredParams, getParameterCommand, Parameter, error_1;
-    return __generator(this, function (_a) {
-        switch (_a.label) {
-            case 0:
-                Name = params.Name, filteredParams = __rest(params, ["Name"]);
-                (0, debug_1.default)("Get SSM patameter with name: ", Name);
-                _a.label = 1;
-            case 1:
-                _a.trys.push([1, 3, , 4]);
-                getParameterCommand = new client_ssm_1.GetParameterCommand(__assign({ Name: Name }, filteredParams));
-                return [4 /*yield*/, SSM.send(getParameterCommand)];
-            case 2:
-                Parameter = (_a.sent()).Parameter;
-                if (!(Parameter === null || Parameter === void 0 ? void 0 : Parameter.Value)) {
-                    (0, debug_1.default)("Got invalid SSM patameter: ", Parameter);
-                    (0, handleError_1.default)(new Error("Failed to retrieve parameters from SSM, got empty value"));
-                    return [2 /*return*/, null];
-                }
-                return [2 /*return*/, Parameter.Value];
-            case 3:
-                error_1 = _a.sent();
-                (0, handleError_1.default)(error_1, "Something went wrong while retrieving parameters from SSM");
-                return [2 /*return*/, null];
-            case 4: return [2 /*return*/];
+const getParameter = (params) => __awaiter(void 0, void 0, void 0, function* () {
+    const { Name } = params, filteredParams = __rest(params, ["Name"]);
+    (0, debug_1.default)("Get SSM patameter with name: ", Name);
+    try {
+        const getParameterCommand = new client_ssm_1.GetParameterCommand(Object.assign({ Name: Name }, filteredParams));
+        const { Parameter } = yield SSM.send(getParameterCommand);
+        if (!(Parameter === null || Parameter === void 0 ? void 0 : Parameter.Value)) {
+            (0, debug_1.default)("Got invalid SSM patameter: ", Parameter);
+            (0, handleError_1.default)(new Error("Failed to retrieve parameters from SSM, got empty value"));
+            return null;
         }
-    });
-}); };
+        return Parameter.Value;
+    }
+    catch (error) {
+        (0, handleError_1.default)(error, "Something went wrong while retrieving parameters from SSM");
+        return null;
+    }
+});
 exports.getParameter = getParameter;
-var putParameter = function (params) { return __awaiter(void 0, void 0, void 0, function () {
-    var Name, Value, _a, Type, _b, Overwrite, filteredParams, putParameterCommand, error_2;
-    return __generator(this, function (_c) {
-        switch (_c.label) {
-            case 0:
-                Name = params.Name, Value = params.Value, _a = params.Type, Type = _a === void 0 ? "String" : _a, _b = params.Overwrite, Overwrite = _b === void 0 ? true : _b, filteredParams = __rest(params, ["Name", "Value", "Type", "Overwrite"]);
-                (0, debug_1.default)("Put SSM patameter with name: ", Name, ", value: ", Value, ", type: ", Type);
-                _c.label = 1;
-            case 1:
-                _c.trys.push([1, 3, , 4]);
-                putParameterCommand = new client_ssm_1.PutParameterCommand(__assign({ Name: Name, Value: Value, Type: Type, Overwrite: Overwrite }, filteredParams));
-                return [4 /*yield*/, SSM.send(putParameterCommand)];
-            case 2:
-                _c.sent();
-                return [3 /*break*/, 4];
-            case 3:
-                error_2 = _c.sent();
-                (0, handleError_1.default)(error_2, "Something went wrong while storing parameter value in SSM");
-                return [3 /*break*/, 4];
-            case 4: return [2 /*return*/];
-        }
-    });
-}); };
+const putParameter = (params) => __awaiter(void 0, void 0, void 0, function* () {
+    const { Name, Value, Type = "String", Overwrite = true } = params, filteredParams = __rest(params, ["Name", "Value", "Type", "Overwrite"]);
+    (0, debug_1.default)("Put SSM patameter with name: ", Name, ", value: ", Value, ", type: ", Type);
+    try {
+        const putParameterCommand = new client_ssm_1.PutParameterCommand(Object.assign({ Name: Name, Value: Value, Type: Type, Overwrite: Overwrite }, filteredParams));
+        yield SSM.send(putParameterCommand);
+    }
+    catch (error) {
+        (0, handleError_1.default)(error, "Something went wrong while storing parameter value in SSM");
+    }
+});
 exports.putParameter = putParameter;

services/Xray.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.wrapClient = void 0;
-var http = require("http");
-var https = require("https");
-var XrayCore = require("aws-xray-sdk-core");
+const http = require("http");
+const https = require("https");
+const XrayCore = require("aws-xray-sdk-core");
 XrayCore.captureHTTPsGlobal(http);
 XrayCore.captureHTTPsGlobal(https);
 XrayCore.capturePromise();
-var wrapClient = function (client) {
+const wrapClient = (client) => {
     return XrayCore.captureAWSv3Client(client);
 };
 exports.wrapClient = wrapClient;

utils/silenceXrayContextErrors.d.ts

@@ -1,2 +0,1 @@
-declare const silenceXrayContextErrors: () => void;
-export default silenceXrayContextErrors;
+export {};

utils/silenceXrayContextErrors.js

 "use strict";
-var __assign = (this && this.__assign) || function () {
-    __assign = Object.assign || function(t) {
-        for (var s, i = 1, n = arguments.length; i < n; i++) {
-            s = arguments[i];
-            for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
-                t[p] = s[p];
-        }
-        return t;
-    };
-    return __assign.apply(this, arguments);
-};
 Object.defineProperty(exports, "__esModule", { value: true });
-var XrayCore = require("aws-xray-sdk-core");
+const XrayCore = require("aws-xray-sdk-core");
 // Ignore "context missing" logs
-var silenceXrayContextErrors = function () {
-    XrayCore.setContextMissingStrategy("IGNORE_ERROR");
-    XrayCore.setLogger(__assign(__assign({}, XrayCore.getLogger()), { error: function () { } }));
-};
-exports.default = silenceXrayContextErrors;
+XrayCore.setContextMissingStrategy("IGNORE_ERROR");
+XrayCore.setLogger(Object.assign(Object.assign({}, XrayCore.getLogger()), { error: () => { } }));

utils/index.d.ts

-export * as silenceXrayContextErrors from "./silenceXrayContextErrors";

utils/index.js

-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.silenceXrayContextErrors = void 0;
-exports.silenceXrayContextErrors = require("./silenceXrayContextErrors");

New alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

20500

-44.15%

Number of package files

27

-6.9%

Lines of code

353

-46.52%

Number of medium supply chain risk alerts

3

50%

No dependency changes