leo-sdk - npm Package Compare versions

Comparing version 6.0.18-alpha to 6.0.19-alpha

lib/mock-wrapper.js

@@ -9,2 +9,3 @@ "use strict";
 const aws_util_1 = __importDefault(require("./aws-util"));
+//import uuid from "uuid";
 const reference_1 = __importDefault(require("./reference"));
@@ -11,0 +12,0 @@ const requireFn = typeof __webpack_require__ === "function" ? __non_webpack_require__ : require;

lib/stream/helper/leo-stream-helper.js

@@ -592,2 +592,3 @@ "use strict";
 function determineReadHooks(settings, partialHookSettings, extraConfig) {
+    var _a;
     let extraConfiguration = {
@@ -617,3 +618,3 @@ tmpDir: process.env.RSTREAMS_TMP_DIR || "/tmp/rstreams"
             ...settings.parserOpts,
-            ...partialHookSettings === null || partialHookSettings === void 0 ? void 0 : partialHookSettings.parseTaskParser.opts
+            ...(_a = partialHookSettings === null || partialHookSettings === void 0 ? void 0 : partialHookSettings.parseTaskParser) === null || _a === void 0 ? void 0 : _a.opts
         },
@@ -648,2 +649,3 @@ } : undefined;
     if (defaultsFromMem.parallelFetchMax > 0) {
+        readOpts.stream_query_limit = 1000;
         readOpts.fast_s3_read = true;
@@ -650,0 +652,0 @@ readOpts.fast_s3_read_parallel_fetch_max_bytes = readOpts.fast_s3_read_parallel_fetch_max_bytes || defaultsFromMem.parallelFetchMax;

lib/stream/helper/parser-util.js

@@ -101,3 +101,3 @@ "use strict";
             [FastParseType.String]: { parse: (value) => value },
-            [FastParseType.Number]: { parse: (value) => parseInt(value.toString(), 10) },
+            [FastParseType.Number]: { parse: (value) => Number(value) },
             [FastParseType.Eid]: { parse: (value) => value.toString().startsWith("z/") ? value : parseInt(value.toString(), 10) },
@@ -104,0 +104,0 @@ [FastParseType.Raw]: { set: (field, value) => set(field, value, "_raw") }

lib/types.d.ts

 export * from "./lib";
 export * from "./streams";
 import { Context } from "aws-lambda";
-import { Callback, RStreamsSdk } from "../index";
+import { Callback, RStreamsSdk, ReadOptions } from "../index";
 /// <reference types="node" />
@@ -16,2 +16,3 @@ import stream from 'stream';
 	get(): Checkpoint;
+	getOpts(): ReadOptions<T>;
 	checkpoint(params: Checkpoint, done: Callback): void;
@@ -18,0 +19,0 @@ checkpoint(done: Callback): void;

package.json

 {
 	"name": "leo-sdk",
-	"version": "6.0.18-alpha",
+	"version": "6.0.19-alpha",
 	"description": "Load data onto the LEO Platform",
@@ -48,3 +48,3 @@ "homepage": "https://leoplatform.io",
 		"through2": "3.0.1",
-		"uuid": "3.3.2"
+		"uuid": "8.3.2"
 	},
@@ -81,3 +81,3 @@ "devDependencies": {
 	"peerDependencies": {
-		"aws-sdk": "^2.1470.0"
+		"aws-sdk": "^2.1488.0"
 	},
@@ -84,0 +84,0 @@ "author": "LEO Enterprises <[e-mail]> (http://leoplatform.io)",

wrappers/cron.js

@@ -16,3 +16,6 @@ "use strict";
 
-	process.__config = config;
+	process.__config = process.__config || config;
+	process.__config.registry = process.__config.registry || {};
+	config.registry = Object.assign(process.__config.registry, config.registry || {});
+	
 	const fill = require("../lib/build-config").fillWithTableReferences;
@@ -19,0 +22,0 @@ process.env.TZ = config.timezone;

No alert changes

Improved metrics

Total package byte prevSize

1147257

increased by0.02%

Lines of code

22522

increased by0.03%

Dependency changes

• + Addeduuid@8.3.2(transitive)

• - Removeduuid@3.3.2(transitive)

• Updateduuid@8.3.2