mongodb-snapshot - npm Package Compare versions

Comparing version 1.2.0 to 1.2.1

dist/connectors/filesystem/FileSystemDuplexConnector.js

@@ -6,3 +6,3 @@ "use strict";
             ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
-            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+            function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; };
         return extendStatics(d, b);
@@ -27,2 +27,21 @@ };
 };
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
+    Object.defineProperty(o, "default", { enumerable: true, value: v });
+}) : function(o, v) {
+    o["default"] = v;
+});
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    __setModuleDefault(result, mod);
+    return result;
+};
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
@@ -64,10 +83,4 @@ function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
 };
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (Object.hasOwnProperty.call(mod, k)) result[k] = mod[k];
-    result["default"] = mod;
-    return result;
-};
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.FileSystemDuplexConnector = void 0;
 var rxjs_1 = require("rxjs");
@@ -74,0 +87,0 @@ var operators_1 = require("rxjs/operators");

dist/connectors/filesystem/LocalFileSystemDuplexConnector.js

@@ -6,3 +6,3 @@ "use strict";
             ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
-            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+            function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; };
         return extendStatics(d, b);
@@ -16,2 +16,21 @@ };
 })();
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
+    Object.defineProperty(o, "default", { enumerable: true, value: v });
+}) : function(o, v) {
+    o["default"] = v;
+});
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    __setModuleDefault(result, mod);
+    return result;
+};
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
@@ -53,10 +72,4 @@ function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
 };
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (Object.hasOwnProperty.call(mod, k)) result[k] = mod[k];
-    result["default"] = mod;
-    return result;
-};
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.LocalFileSystemDuplexConnector = void 0;
 var fs_1 = require("fs");
@@ -63,0 +76,0 @@ var joi = __importStar(require("joi"));

dist/connectors/index.js

 "use strict";
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __exportStar = (this && this.__exportStar) || function(m, exports) {
+    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./MongoDBDuplexConnector"));
-__export(require("./filesystem/FileSystemDuplexConnector"));
-__export(require("./filesystem/LocalFileSystemDuplexConnector"));
+__exportStar(require("./Connector"), exports);
+__exportStar(require("./MongoDBDuplexConnector"), exports);
+__exportStar(require("./filesystem/FileSystemDuplexConnector"), exports);
+__exportStar(require("./filesystem/LocalFileSystemDuplexConnector"), exports);
 //# sourceMappingURL=index.js.map

dist/connectors/MongoDBDuplexConnector.d.ts

@@ -41,3 +41,3 @@ /// <reference types="node" />
         name: string;
-        size: any;
+        size: number;
         indexes: any;
@@ -44,0 +44,0 @@ }[]>;

dist/connectors/MongoDBDuplexConnector.js

@@ -6,3 +6,3 @@ "use strict";
             ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
-            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+            function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; };
         return extendStatics(d, b);
@@ -16,2 +16,21 @@ };
 })();
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
+    Object.defineProperty(o, "default", { enumerable: true, value: v });
+}) : function(o, v) {
+    o["default"] = v;
+});
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    __setModuleDefault(result, mod);
+    return result;
+};
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
@@ -72,10 +91,4 @@ function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
 };
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (Object.hasOwnProperty.call(mod, k)) result[k] = mod[k];
-    result["default"] = mod;
-    return result;
-};
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.MongoDBDuplexConnector = void 0;
 var mongodb_1 = require("mongodb");
@@ -134,3 +147,3 @@ var rxjs_1 = require("rxjs");
                 collection = this.db.collection(collection_name);
-                data_cursor = collection.find({}, { timeout: false, batchSize: this.assource.bulk_read_size }).snapshot(true).stream();
+                data_cursor = collection.find({}, { timeout: false, batchSize: this.assource.bulk_read_size }).stream();
                 return [2 /*return*/, cursorToObservalbe(data_cursor)];
@@ -137,0 +150,0 @@ });

dist/connectors/Validatable.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.Validatable = void 0;
 var errors_1 = require("../errors");
@@ -4,0 +5,0 @@ var Validatable = /** @class */ (function () {

dist/errors.js

@@ -6,3 +6,3 @@ "use strict";
             ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
-            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+            function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; };
         return extendStatics(d, b);
@@ -17,2 +17,3 @@ };
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.ConnectorSchemaError = exports.MongoTransferError = void 0;
 var verror_1 = require("verror");
@@ -19,0 +20,0 @@ var MongoTransferError = /** @class */ (function (_super) {

dist/index.js

 "use strict";
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __exportStar = (this && this.__exportStar) || function(m, exports) {
+    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./MongoTransferer"));
-__export(require("./errors"));
-__export(require("./connectors"));
+__exportStar(require("./MongoTransferer"), exports);
+__exportStar(require("./contracts"), exports);
+__exportStar(require("./errors"), exports);
+__exportStar(require("./connectors"), exports);
 //# sourceMappingURL=index.js.map

dist/MongoTransferer.js

@@ -57,2 +57,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.MongoTransferer = void 0;
 var lodash_1 = require("lodash");
@@ -59,0 +60,0 @@ var rxjs_1 = require("rxjs");

dist/utils.js

@@ -46,2 +46,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.convertAsyncGeneratorToObservable = void 0;
 var rxjs_1 = require("rxjs");
@@ -48,0 +49,0 @@ function convertAsyncGeneratorToObservable(iterator) {

package.json

 {
   "name": "mongodb-snapshot",
-  "version": "1.2.0",
+  "version": "1.2.1",
   "description": "Manages MongoDB snapshots, provides functionality to deliver MongoDB content between data sources for backup and restore",
@@ -5,0 +5,0 @@ "main": "./dist/index.js",

src/connectors/MongoDBDuplexConnector.ts

@@ -86,3 +86,3 @@
             const collection = this.db.collection(collection_name);
-            const data_cursor = collection.find<Buffer>({}, { timeout: false, batchSize: this.assource.bulk_read_size }).snapshot(true as any).stream();
+            const data_cursor = collection.find<Buffer>({}, { timeout: false, batchSize: this.assource.bulk_read_size }).stream();
 
@@ -89,0 +89,0 @@ return cursorToObservalbe(data_cursor);

No alert changes

Improved metrics

Total package byte prevSize

168240

increased by2.12%

Number of downloads

1803

increased by10.21%

Lines of code

2846

increased by2.12%

No dependency changes