@lifeomic/aws-sdk-helpers - npm Package Compare versions

Comparing version 2.6.1-pr-14-1295943124-1633108109.0 to 2.7.0

package.json

 {
   "name": "@lifeomic/aws-sdk-helpers",
-  "version": "2.6.1-pr-14-1295943124-1633108109.0",
+  "version": "2.7.0",
   "description": "Utility methods to format data for AWS services",
   "main": "src/index.js",
-  "types": "src/index.ts",
+  "types": "src/index.d.ts",
   "files": [
@@ -27,4 +27,4 @@ "src"
     "prepublishOnly": "yarn tsc --project tsconfig.build.json",
-    "coverage": "nyc report --reporter=text-lcov > ./.nyc_output/lcov.info",
     "lint": "eslint . --ext .js,.ts -f codeframe",
+    "postlint": "yarn tsc",
     "pretest": "yarn lint",
@@ -31,0 +31,0 @@ "test": "jest"

src/kinesis/stream.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.createKinesisStreamRecord = exports.createKinesisStreamRecordPayload = void 0;
+exports.createKinesisStreamEvent = exports.createKinesisStreamRecord = exports.createKinesisStreamRecordPayload = void 0;
 const uuid_1 = require("uuid");
 const arn_1 = require("../arn");
-function createKinesisStreamRecordPayload({ approximateArrivalTimestamp = Math.floor(Date.now() / 1e3), data = {}, kinesisSchemaVersion = '1', partitionKey = (0, uuid_1.v4)(), sequenceNumber = (0, uuid_1.v4)(), } = {}) {
+function createKinesisStreamRecordPayload({ approximateArrivalTimestamp = Math.floor(Date.now() / 1e3), data: rawData = {}, kinesisSchemaVersion = '1', partitionKey = (0, uuid_1.v4)(), sequenceNumber = (0, uuid_1.v4)(), } = {}) {
+    let data = rawData;
+    if (typeof data !== 'string') {
+        data = Buffer.from(JSON.stringify(data)).toString('base64');
+    }
     return {
         approximateArrivalTimestamp,
-        data: Buffer.from(JSON.stringify(data)).toString('base64'),
+        data,
         kinesisSchemaVersion,
@@ -29,2 +33,8 @@ partitionKey,
 exports.createKinesisStreamRecord = createKinesisStreamRecord;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic3RyZWFtLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsic3RyZWFtLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7OztBQUVBLCtCQUFrQztBQUNsQyxnQ0FBd0M7QUFjeEMsU0FBZ0IsZ0NBQWdDLENBQzlDLEVBQ0UsMkJBQTJCLEdBQUcsSUFBSSxDQUFDLEtBQUssQ0FBQyxJQUFJLENBQUMsR0FBRyxFQUFFLEdBQUcsR0FBRyxDQUFDLEVBQzFELElBQUksR0FBRyxFQUFFLEVBQ1Qsb0JBQW9CLEdBQUcsR0FBRyxFQUMxQixZQUFZLEdBQUcsSUFBQSxTQUFJLEdBQUUsRUFDckIsY0FBYyxHQUFHLElBQUEsU0FBSSxHQUFFLE1BQ2MsRUFBRTtJQUV6QyxPQUFPO1FBQ0wsMkJBQTJCO1FBQzNCLElBQUksRUFBRSxNQUFNLENBQUMsSUFBSSxDQUFDLElBQUksQ0FBQyxTQUFTLENBQUMsSUFBSSxDQUFDLENBQUMsQ0FBQyxRQUFRLENBQUMsUUFBUSxDQUFDO1FBQzFELG9CQUFvQjtRQUNwQixZQUFZO1FBQ1osY0FBYztLQUNmLENBQUM7QUFDSixDQUFDO0FBaEJELDRFQWdCQztBQUVELFNBQWdCLHlCQUF5QixDQUN2QyxFQUNFLFNBQVMsR0FBRyxXQUFXLEVBQ3ZCLE9BQU8sR0FBRyxJQUFBLFNBQUksR0FBRSxFQUNoQixXQUFXLEVBQ1gsWUFBWSxHQUFHLElBQUEsU0FBSSxHQUFFLEVBQ3JCLGlCQUFpQixHQUFHLElBQUEsb0JBQWMsRUFBQyxFQUFFLE9BQU8sRUFBRSxLQUFLLEVBQUUsUUFBUSxFQUFFLGNBQWMsRUFBRSxDQUFDLEVBQ2hGLE9BQU8sTUFDdUIsRUFBRTtJQUVsQyxPQUFPO1FBQ0wsV0FBVyxFQUFFLGFBQWE7UUFDMUIsU0FBUyxFQUFFLG9CQUFvQjtRQUMvQixTQUFTO1FBQ1QsT0FBTztRQUNQLFlBQVk7UUFDWixpQkFBaUI7UUFDakIsY0FBYyxFQUFFLElBQUEsb0JBQWMsRUFBQyxFQUFFLEdBQUcsV0FBVyxFQUFFLE9BQU8sRUFBRSxTQUFTLEVBQUUsQ0FBQztRQUN0RSxPQUFPLEVBQUUsZ0NBQWdDLENBQUMsT0FBTyxDQUFDO0tBQ25ELENBQUM7QUFDSixDQUFDO0FBcEJELDhEQW9CQyIsInNvdXJjZXNDb250ZW50IjpbImltcG9ydCB7IEtpbmVzaXNTdHJlYW1SZWNvcmQgfSBmcm9tICdhd3MtbGFtYmRhJztcbmltcG9ydCB7IEtpbmVzaXNTdHJlYW1SZWNvcmRQYXlsb2FkIH0gZnJvbSAnYXdzLWxhbWJkYS90cmlnZ2VyL2tpbmVzaXMtc3RyZWFtJztcbmltcG9ydCB7IHY0IGFzIHV1aWQgfSBmcm9tICd1dWlkJztcbmltcG9ydCB7IGJ1aWxkQVJOU3RyaW5nIH0gZnJvbSAnLi4vYXJuJztcbmltcG9ydCB7IEFSTiB9IGZyb20gJ0Bhd3Mtc2RrL3V0aWwtYXJuLXBhcnNlcic7XG5cbmV4cG9ydCBpbnRlcmZhY2UgUGFydGlhbEtpbmVzaXNTdHJlYW1SZWNvcmRQYXlsb2FkXG4gIGV4dGVuZHMgUGFydGlhbDxPbWl0PEtpbmVzaXNTdHJlYW1SZWNvcmRQYXlsb2FkLCAnZGF0YSc+PiB7XG4gIGRhdGE/OiBhbnk7XG59XG5cbmV4cG9ydCBpbnRlcmZhY2UgUGFydGlhbEtpbmVzaXNTdHJlYW1SZWNvcmRcbiAgZXh0ZW5kcyBQYXJ0aWFsPE9taXQ8S2luZXNpc1N0cmVhbVJlY29yZCwgJ2tpbmVzaXMnIHwgJ2V2ZW50U291cmNlJyB8ICdldmVudE5hbWUnIHwgJ2V2ZW50U291cmNlQVJOJz4+IHtcbiAga2luZXNpcz86IFBhcnRpYWxLaW5lc2lzU3RyZWFtUmVjb3JkUGF5bG9hZDtcbiAgZXZlbnRTb3VyY2U/OiBQYXJ0aWFsPE9taXQ8QVJOLCAnc2VydmljZSc+Pjtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIGNyZWF0ZUtpbmVzaXNTdHJlYW1SZWNvcmRQYXlsb2FkIChcbiAge1xuICAgIGFwcHJveGltYXRlQXJyaXZhbFRpbWVzdGFtcCA9IE1hdGguZmxvb3IoRGF0ZS5ub3coKSAvIDFlMyksXG4gICAgZGF0YSA9IHt9LFxuICAgIGtpbmVzaXNTY2hlbWFWZXJzaW9uID0gJzEnLFxuICAgIHBhcnRpdGlvbktleSA9IHV1aWQoKSxcbiAgICBzZXF1ZW5jZU51bWJlciA9IHV1aWQoKSxcbiAgfTogUGFydGlhbEtpbmVzaXNTdHJlYW1SZWNvcmRQYXlsb2FkID0ge30sXG4pOiBLaW5lc2lzU3RyZWFtUmVjb3JkUGF5bG9hZCB7XG4gIHJldHVybiB7XG4gICAgYXBwcm94aW1hdGVBcnJpdmFsVGltZXN0YW1wLFxuICAgIGRhdGE6IEJ1ZmZlci5mcm9tKEpTT04uc3RyaW5naWZ5KGRhdGEpKS50b1N0cmluZygnYmFzZTY0JyksXG4gICAga2luZXNpc1NjaGVtYVZlcnNpb24sXG4gICAgcGFydGl0aW9uS2V5LFxuICAgIHNlcXVlbmNlTnVtYmVyLFxuICB9O1xufVxuXG5leHBvcnQgZnVuY3Rpb24gY3JlYXRlS2luZXNpc1N0cmVhbVJlY29yZCAoXG4gIHtcbiAgICBhd3NSZWdpb24gPSAndXMtZWFzdC0xJyxcbiAgICBldmVudElEID0gdXVpZCgpLFxuICAgIGV2ZW50U291cmNlLFxuICAgIGV2ZW50VmVyc2lvbiA9IHV1aWQoKSxcbiAgICBpbnZva2VJZGVudGl0eUFybiA9IGJ1aWxkQVJOU3RyaW5nKHsgc2VydmljZTogJ2lhbScsIHJlc291cmNlOiAncm9sZS91bmtub3duJyB9KSxcbiAgICBraW5lc2lzLFxuICB9OiBQYXJ0aWFsS2luZXNpc1N0cmVhbVJlY29yZCA9IHt9LFxuKTogS2luZXNpc1N0cmVhbVJlY29yZCB7XG4gIHJldHVybiB7XG4gICAgZXZlbnRTb3VyY2U6ICdhd3M6a2luZXNpcycsXG4gICAgZXZlbnROYW1lOiAnYXdzOmtpbmVzaXM6cmVjb3JkJyxcbiAgICBhd3NSZWdpb24sXG4gICAgZXZlbnRJRCxcbiAgICBldmVudFZlcnNpb24sXG4gICAgaW52b2tlSWRlbnRpdHlBcm4sXG4gICAgZXZlbnRTb3VyY2VBUk46IGJ1aWxkQVJOU3RyaW5nKHsgLi4uZXZlbnRTb3VyY2UsIHNlcnZpY2U6ICdraW5lc2lzJyB9KSxcbiAgICBraW5lc2lzOiBjcmVhdGVLaW5lc2lzU3RyZWFtUmVjb3JkUGF5bG9hZChraW5lc2lzKSxcbiAgfTtcbn1cbiJdfQ==
+function createKinesisStreamEvent(records = []) {
+    return {
+        Records: records.map(createKinesisStreamRecord),
+    };
+}
+exports.createKinesisStreamEvent = createKinesisStreamEvent;
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic3RyZWFtLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsic3RyZWFtLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7OztBQUVBLCtCQUFrQztBQUNsQyxnQ0FBd0M7QUFjeEMsU0FBZ0IsZ0NBQWdDLENBQzlDLEVBQ0UsMkJBQTJCLEdBQUcsSUFBSSxDQUFDLEtBQUssQ0FBQyxJQUFJLENBQUMsR0FBRyxFQUFFLEdBQUcsR0FBRyxDQUFDLEVBQzFELElBQUksRUFBRSxPQUFPLEdBQUcsRUFBRSxFQUNsQixvQkFBb0IsR0FBRyxHQUFHLEVBQzFCLFlBQVksR0FBRyxJQUFBLFNBQUksR0FBRSxFQUNyQixjQUFjLEdBQUcsSUFBQSxTQUFJLEdBQUUsTUFDYyxFQUFFO0lBRXpDLElBQUksSUFBSSxHQUFHLE9BQU8sQ0FBQztJQUNuQixJQUFJLE9BQU8sSUFBSSxLQUFLLFFBQVEsRUFBRTtRQUM1QixJQUFJLEdBQUcsTUFBTSxDQUFDLElBQUksQ0FBQyxJQUFJLENBQUMsU0FBUyxDQUFDLElBQUksQ0FBQyxDQUFDLENBQUMsUUFBUSxDQUFDLFFBQVEsQ0FBQyxDQUFDO0tBQzdEO0lBQ0QsT0FBTztRQUNMLDJCQUEyQjtRQUMzQixJQUFJO1FBQ0osb0JBQW9CO1FBQ3BCLFlBQVk7UUFDWixjQUFjO0tBQ2YsQ0FBQztBQUNKLENBQUM7QUFwQkQsNEVBb0JDO0FBRUQsU0FBZ0IseUJBQXlCLENBQ3ZDLEVBQ0UsU0FBUyxHQUFHLFdBQVcsRUFDdkIsT0FBTyxHQUFHLElBQUEsU0FBSSxHQUFFLEVBQ2hCLFdBQVcsRUFDWCxZQUFZLEdBQUcsSUFBQSxTQUFJLEdBQUUsRUFDckIsaUJBQWlCLEdBQUcsSUFBQSxvQkFBYyxFQUFDLEVBQUUsT0FBTyxFQUFFLEtBQUssRUFBRSxRQUFRLEVBQUUsY0FBYyxFQUFFLENBQUMsRUFDaEYsT0FBTyxNQUN1QixFQUFFO0lBRWxDLE9BQU87UUFDTCxXQUFXLEVBQUUsYUFBYTtRQUMxQixTQUFTLEVBQUUsb0JBQW9CO1FBQy9CLFNBQVM7UUFDVCxPQUFPO1FBQ1AsWUFBWTtRQUNaLGlCQUFpQjtRQUNqQixjQUFjLEVBQUUsSUFBQSxvQkFBYyxFQUFDLEVBQUUsR0FBRyxXQUFXLEVBQUUsT0FBTyxFQUFFLFNBQVMsRUFBRSxDQUFDO1FBQ3RFLE9BQU8sRUFBRSxnQ0FBZ0MsQ0FBQyxPQUFPLENBQUM7S0FDbkQsQ0FBQztBQUNKLENBQUM7QUFwQkQsOERBb0JDO0FBRUQsU0FBZ0Isd0JBQXdCLENBQ3RDLFVBQXdDLEVBQUU7SUFFMUMsT0FBTztRQUNMLE9BQU8sRUFBRSxPQUFPLENBQUMsR0FBRyxDQUFDLHlCQUF5QixDQUFDO0tBQ2hELENBQUM7QUFDSixDQUFDO0FBTkQsNERBTUMiLCJzb3VyY2VzQ29udGVudCI6WyJpbXBvcnQgeyBLaW5lc2lzU3RyZWFtRXZlbnQsIEtpbmVzaXNTdHJlYW1SZWNvcmQgfSBmcm9tICdhd3MtbGFtYmRhJztcbmltcG9ydCB7IEtpbmVzaXNTdHJlYW1SZWNvcmRQYXlsb2FkIH0gZnJvbSAnYXdzLWxhbWJkYS90cmlnZ2VyL2tpbmVzaXMtc3RyZWFtJztcbmltcG9ydCB7IHY0IGFzIHV1aWQgfSBmcm9tICd1dWlkJztcbmltcG9ydCB7IGJ1aWxkQVJOU3RyaW5nIH0gZnJvbSAnLi4vYXJuJztcbmltcG9ydCB7IEFSTiB9IGZyb20gJ0Bhd3Mtc2RrL3V0aWwtYXJuLXBhcnNlcic7XG5cbmV4cG9ydCBpbnRlcmZhY2UgUGFydGlhbEtpbmVzaXNTdHJlYW1SZWNvcmRQYXlsb2FkXG4gIGV4dGVuZHMgUGFydGlhbDxPbWl0PEtpbmVzaXNTdHJlYW1SZWNvcmRQYXlsb2FkLCAnZGF0YSc+PiB7XG4gIGRhdGE/OiBhbnk7XG59XG5cbmV4cG9ydCBpbnRlcmZhY2UgUGFydGlhbEtpbmVzaXNTdHJlYW1SZWNvcmRcbiAgZXh0ZW5kcyBQYXJ0aWFsPE9taXQ8S2luZXNpc1N0cmVhbVJlY29yZCwgJ2tpbmVzaXMnIHwgJ2V2ZW50U291cmNlJyB8ICdldmVudE5hbWUnIHwgJ2V2ZW50U291cmNlQVJOJz4+IHtcbiAga2luZXNpcz86IFBhcnRpYWxLaW5lc2lzU3RyZWFtUmVjb3JkUGF5bG9hZDtcbiAgZXZlbnRTb3VyY2U/OiBQYXJ0aWFsPE9taXQ8QVJOLCAnc2VydmljZSc+Pjtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIGNyZWF0ZUtpbmVzaXNTdHJlYW1SZWNvcmRQYXlsb2FkIChcbiAge1xuICAgIGFwcHJveGltYXRlQXJyaXZhbFRpbWVzdGFtcCA9IE1hdGguZmxvb3IoRGF0ZS5ub3coKSAvIDFlMyksXG4gICAgZGF0YTogcmF3RGF0YSA9IHt9LFxuICAgIGtpbmVzaXNTY2hlbWFWZXJzaW9uID0gJzEnLFxuICAgIHBhcnRpdGlvbktleSA9IHV1aWQoKSxcbiAgICBzZXF1ZW5jZU51bWJlciA9IHV1aWQoKSxcbiAgfTogUGFydGlhbEtpbmVzaXNTdHJlYW1SZWNvcmRQYXlsb2FkID0ge30sXG4pOiBLaW5lc2lzU3RyZWFtUmVjb3JkUGF5bG9hZCB7XG4gIGxldCBkYXRhID0gcmF3RGF0YTtcbiAgaWYgKHR5cGVvZiBkYXRhICE9PSAnc3RyaW5nJykge1xuICAgIGRhdGEgPSBCdWZmZXIuZnJvbShKU09OLnN0cmluZ2lmeShkYXRhKSkudG9TdHJpbmcoJ2Jhc2U2NCcpO1xuICB9XG4gIHJldHVybiB7XG4gICAgYXBwcm94aW1hdGVBcnJpdmFsVGltZXN0YW1wLFxuICAgIGRhdGEsXG4gICAga2luZXNpc1NjaGVtYVZlcnNpb24sXG4gICAgcGFydGl0aW9uS2V5LFxuICAgIHNlcXVlbmNlTnVtYmVyLFxuICB9O1xufVxuXG5leHBvcnQgZnVuY3Rpb24gY3JlYXRlS2luZXNpc1N0cmVhbVJlY29yZCAoXG4gIHtcbiAgICBhd3NSZWdpb24gPSAndXMtZWFzdC0xJyxcbiAgICBldmVudElEID0gdXVpZCgpLFxuICAgIGV2ZW50U291cmNlLFxuICAgIGV2ZW50VmVyc2lvbiA9IHV1aWQoKSxcbiAgICBpbnZva2VJZGVudGl0eUFybiA9IGJ1aWxkQVJOU3RyaW5nKHsgc2VydmljZTogJ2lhbScsIHJlc291cmNlOiAncm9sZS91bmtub3duJyB9KSxcbiAgICBraW5lc2lzLFxuICB9OiBQYXJ0aWFsS2luZXNpc1N0cmVhbVJlY29yZCA9IHt9LFxuKTogS2luZXNpc1N0cmVhbVJlY29yZCB7XG4gIHJldHVybiB7XG4gICAgZXZlbnRTb3VyY2U6ICdhd3M6a2luZXNpcycsXG4gICAgZXZlbnROYW1lOiAnYXdzOmtpbmVzaXM6cmVjb3JkJyxcbiAgICBhd3NSZWdpb24sXG4gICAgZXZlbnRJRCxcbiAgICBldmVudFZlcnNpb24sXG4gICAgaW52b2tlSWRlbnRpdHlBcm4sXG4gICAgZXZlbnRTb3VyY2VBUk46IGJ1aWxkQVJOU3RyaW5nKHsgLi4uZXZlbnRTb3VyY2UsIHNlcnZpY2U6ICdraW5lc2lzJyB9KSxcbiAgICBraW5lc2lzOiBjcmVhdGVLaW5lc2lzU3RyZWFtUmVjb3JkUGF5bG9hZChraW5lc2lzKSxcbiAgfTtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIGNyZWF0ZUtpbmVzaXNTdHJlYW1FdmVudCAoXG4gIHJlY29yZHM6IFBhcnRpYWxLaW5lc2lzU3RyZWFtUmVjb3JkW10gPSBbXSxcbik6IEtpbmVzaXNTdHJlYW1FdmVudCB7XG4gIHJldHVybiB7XG4gICAgUmVjb3JkczogcmVjb3Jkcy5tYXAoY3JlYXRlS2luZXNpc1N0cmVhbVJlY29yZCksXG4gIH07XG59XG4iXX0=

src/kinesis/stream.ts

@@ -1,2 +0,2 @@
-import { KinesisStreamRecord } from 'aws-lambda';
+import { KinesisStreamEvent, KinesisStreamRecord } from 'aws-lambda';
 import { KinesisStreamRecordPayload } from 'aws-lambda/trigger/kinesis-stream';
@@ -21,3 +21,3 @@ import { v4 as uuid } from 'uuid';
     approximateArrivalTimestamp = Math.floor(Date.now() / 1e3),
-    data = {},
+    data: rawData = {},
     kinesisSchemaVersion = '1',
@@ -28,5 +28,9 @@ partitionKey = uuid(),
 ): KinesisStreamRecordPayload {
+  let data = rawData;
+  if (typeof data !== 'string') {
+    data = Buffer.from(JSON.stringify(data)).toString('base64');
+  }
   return {
     approximateArrivalTimestamp,
-    data: Buffer.from(JSON.stringify(data)).toString('base64'),
+    data,
     kinesisSchemaVersion,
@@ -59,1 +63,9 @@ partitionKey,
 }
+
+export function createKinesisStreamEvent (
+  records: PartialKinesisStreamRecord[] = [],
+): KinesisStreamEvent {
+  return {
+    Records: records.map(createKinesisStreamRecord),
+  };
+}

Fixed alerts

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

103917

increased by14.23%

Number of package files

53

increased by47.22%

Lines of code

1448

increased by12.6%

Number of low quality alerts

1

decreased by-50%

No dependency changes