@nuclia/sync-agent - npm Package Compare versions

Comparing version 1.2.13 to 1.2.15

build/logic/connector/infrastructure/connectors/confluence.connector.js

@@ -47,20 +47,11 @@ "use strict";
         }
-        try {
-            return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFiles('', false, folder.originalId))).pipe((0, rxjs_1.map)((results) => {
-                const result = {
-                    items: [],
-                };
-                results.forEach((res) => {
-                    result.items = [...result.items, ...res.items];
-                });
-                return result;
-            }));
-        }
-        catch (err) {
-            console.error(err);
-            return (0, rxjs_1.of)({
+        return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFiles('', false, folder.originalId))).pipe((0, rxjs_1.map)((results) => {
+            const result = {
                 items: [],
-                error: `Error fetching files: ${err}`,
+            };
+            results.forEach((res) => {
+                result.items = [...result.items, ...res.items];
             });
-        }
+            return result;
+        }));
     }
@@ -74,12 +65,3 @@ getLastModified(since, folders) {
         else {
-            try {
-                return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFiles('', false, folder.originalId, since))).pipe((0, rxjs_1.map)((results) => ({ items: results.reduce((acc, result) => acc.concat(result.items), []) })));
-            }
-            catch (err) {
-                console.error(err);
-                return (0, rxjs_1.of)({
-                    items: [],
-                    error: `Error fetching last modified files: ${err}`,
-                });
-            }
+            return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFiles('', false, folder.originalId, since))).pipe((0, rxjs_1.map)((results) => ({ items: results.reduce((acc, result) => acc.concat(result.items), []) })));
         }
@@ -86,0 +68,0 @@ }

build/logic/connector/infrastructure/connectors/dropbox.connector.js

@@ -47,16 +47,8 @@ "use strict";
         }
-        try {
-            return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFiles('', false, folder.originalId))).pipe((0, rxjs_1.map)((results) => {
-                const items = results.reduce((acc, result) => acc.concat(result.items.filter((item) => item.modifiedGMT && item.modifiedGMT > since)), []);
-                return {
-                    items,
-                };
-            }));
-        }
-        catch (err) {
-            return (0, rxjs_1.of)({
-                items: [],
-                error: `Error fetching last modified files: ${err}`,
-            });
-        }
+        return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFiles('', false, folder.originalId))).pipe((0, rxjs_1.map)((results) => {
+            const items = results.reduce((acc, result) => acc.concat(result.items.filter((item) => item.modifiedGMT && item.modifiedGMT > since)), []);
+            return {
+                items,
+            };
+        }));
     }
@@ -69,19 +61,11 @@ getFilesFromFolders(folders) {
         }
-        try {
-            return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFiles('', false, folder.originalId))).pipe((0, rxjs_1.map)((results) => {
-                const result = {
-                    items: [],
-                };
-                results.forEach((res) => {
-                    result.items = [...result.items, ...res.items];
-                });
-                return result;
-            }));
-        }
-        catch (err) {
-            return (0, rxjs_1.of)({
+        return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFiles('', false, folder.originalId))).pipe((0, rxjs_1.map)((results) => {
+            const result = {
                 items: [],
-                error: `Error fetching files: ${err}`,
+            };
+            results.forEach((res) => {
+                result.items = [...result.items, ...res.items];
             });
-        }
+            return result;
+        }));
     }
@@ -88,0 +72,0 @@ getFolders(query) {

build/logic/connector/infrastructure/connectors/folder.connector.js

@@ -70,18 +70,11 @@ "use strict";
         }
-        try {
-            return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFiles(folder.originalId))).pipe((0, rxjs_1.map)((results) => {
-                const result = {
-                    items: [],
-                };
-                results.forEach((res) => {
-                    result.items = [...result.items, ...res.items];
-                });
-                return result;
-            }));
-        }
-        catch (err) {
-            return (0, rxjs_1.of)({
+        return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFiles(folder.originalId))).pipe((0, rxjs_1.map)((results) => {
+            const result = {
                 items: [],
+            };
+            results.forEach((res) => {
+                result.items = [...result.items, ...res.items];
             });
-        }
+            return result;
+        }));
     }
@@ -94,21 +87,13 @@ getLastModified(since, folders) {
         }
-        try {
-            return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFiles(folder.originalId).pipe((0, rxjs_1.switchMap)((results) => (0, rxjs_1.from)(this.getFilesModifiedSince(results.items, since)).pipe((0, rxjs_1.map)((items) => ({ items, error: results.error }))))))).pipe((0, rxjs_1.map)((results) => {
-                const items = results.reduce((acc, result) => acc.concat(result.items), []);
-                const errors = results
-                    .map((result) => result.error)
-                    .filter((error) => !!error)
-                    .join('. ');
-                return {
-                    items,
-                    error: errors,
-                };
-            }));
-        }
-        catch (err) {
-            return (0, rxjs_1.of)({
-                items: [],
-                error: 'Error getting last modified files.',
-            });
-        }
+        return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFiles(folder.originalId).pipe((0, rxjs_1.switchMap)((results) => (0, rxjs_1.from)(this.getFilesModifiedSince(results.items, since)).pipe((0, rxjs_1.map)((items) => ({ items, error: results.error }))))))).pipe((0, rxjs_1.map)((results) => {
+            const items = results.reduce((acc, result) => acc.concat(result.items), []);
+            const errors = results
+                .map((result) => result.error)
+                .filter((error) => !!error)
+                .join('. ');
+            return {
+                items,
+                error: errors,
+            };
+        }));
     }
@@ -115,0 +100,0 @@ _getFiles(path, query) {

build/logic/connector/infrastructure/connectors/gdrive.connector.js

@@ -47,16 +47,8 @@ "use strict";
         }
-        try {
-            return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFileItems('', folder.uuid))).pipe((0, rxjs_1.map)((results) => {
-                const items = results.reduce((acc, result) => acc.concat(result.items.filter((item) => item.modifiedGMT && item.modifiedGMT > since)), []);
-                return {
-                    items,
-                };
-            }));
-        }
-        catch (err) {
-            return (0, rxjs_1.of)({
-                items: [],
-                error: `Error fetching last modified files: ${err}`,
-            });
-        }
+        return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFileItems('', folder.uuid))).pipe((0, rxjs_1.map)((results) => {
+            const items = results.reduce((acc, result) => acc.concat(result.items.filter((item) => item.modifiedGMT && item.modifiedGMT > since)), []);
+            return {
+                items,
+            };
+        }));
     }
@@ -69,19 +61,11 @@ getFilesFromFolders(folders) {
         }
-        try {
-            return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFileItems('', folder.uuid))).pipe((0, rxjs_1.map)((results) => {
-                const result = {
-                    items: [],
-                };
-                results.forEach((res) => {
-                    result.items = [...result.items, ...res.items];
-                });
-                return result;
-            }));
-        }
-        catch (err) {
-            return (0, rxjs_1.of)({
+        return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getFileItems('', folder.uuid))).pipe((0, rxjs_1.map)((results) => {
+            const result = {
                 items: [],
-                error: `Error fetching files: ${err}`,
+            };
+            results.forEach((res) => {
+                result.items = [...result.items, ...res.items];
             });
-        }
+            return result;
+        }));
     }
@@ -88,0 +72,0 @@ getFolders(query) {

build/logic/connector/infrastructure/connectors/onedrive.connector.js

@@ -47,16 +47,8 @@ "use strict";
         }
-        try {
-            return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getItems('', folder.uuid))).pipe((0, rxjs_1.map)((results) => {
-                const items = results.reduce((acc, result) => acc.concat(result.items.filter((item) => item.modifiedGMT && item.modifiedGMT > since)), []);
-                return {
-                    items,
-                };
-            }));
-        }
-        catch (err) {
-            return (0, rxjs_1.of)({
-                items: [],
-                error: `Error fetching last modified files: ${err}`,
-            });
-        }
+        return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getItems('', folder.uuid))).pipe((0, rxjs_1.map)((results) => {
+            const items = results.reduce((acc, result) => acc.concat(result.items.filter((item) => item.modifiedGMT && item.modifiedGMT > since)), []);
+            return {
+                items,
+            };
+        }));
     }
@@ -69,19 +61,11 @@ getFilesFromFolders(folders) {
         }
-        try {
-            return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getItems('', folder.uuid))).pipe((0, rxjs_1.map)((results) => {
-                const result = {
-                    items: [],
-                };
-                results.forEach((res) => {
-                    result.items = [...result.items, ...res.items];
-                });
-                return result;
-            }));
-        }
-        catch (err) {
-            return (0, rxjs_1.of)({
+        return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getItems('', folder.uuid))).pipe((0, rxjs_1.map)((results) => {
+            const result = {
                 items: [],
-                error: `Error fetching files: ${err}`,
+            };
+            results.forEach((res) => {
+                result.items = [...result.items, ...res.items];
             });
-        }
+            return result;
+        }));
     }
@@ -88,0 +72,0 @@ getFolders(query) {

build/logic/connector/infrastructure/connectors/rss.connector.js

@@ -117,2 +117,3 @@ "use strict";
             cssSelector: this.getParameters().cssSelector,
+            xpathSelector: this.getParameters().xpathSelector,
         });
@@ -119,0 +120,0 @@ }

build/logic/connector/infrastructure/connectors/sharepoint.connector.js

@@ -47,16 +47,8 @@ "use strict";
         }
-        try {
-            return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getItems(folder.uuid, false, since))).pipe((0, rxjs_1.map)((results) => {
-                const items = results.reduce((acc, result) => acc.concat(result.items), []);
-                return {
-                    items,
-                };
-            }));
-        }
-        catch (err) {
-            return (0, rxjs_1.of)({
-                items: [],
-                error: `Error fetching last modified files: ${err}`,
-            });
-        }
+        return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getItems(folder.uuid, false, since))).pipe((0, rxjs_1.map)((results) => {
+            const items = results.reduce((acc, result) => acc.concat(result.items), []);
+            return {
+                items,
+            };
+        }));
     }
@@ -73,19 +65,11 @@ // eslint-disable-next-line @typescript-eslint/no-unused-vars
         }
-        try {
-            return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getItems(folder.uuid))).pipe((0, rxjs_1.map)((results) => {
-                const result = {
-                    items: [],
-                };
-                results.forEach((res) => {
-                    result.items = [...result.items, ...res.items];
-                });
-                return result;
-            }));
-        }
-        catch (err) {
-            return (0, rxjs_1.of)({
+        return (0, rxjs_1.forkJoin)((folders || []).map((folder) => this._getItems(folder.uuid))).pipe((0, rxjs_1.map)((results) => {
+            const result = {
                 items: [],
-                error: `Error fetching files: ${err}`,
+            };
+            results.forEach((res) => {
+                result.items = [...result.items, ...res.items];
             });
-        }
+            return result;
+        }));
     }
@@ -92,0 +76,0 @@ isAccessTokenValid() {

build/logic/connector/infrastructure/connectors/sitemap.connector.js

@@ -123,2 +123,3 @@ "use strict";
             cssSelector: this.getParameters().cssSelector,
+            xpathSelector: this.getParameters().xpathSelector,
         };
@@ -125,0 +126,0 @@ return (0, rxjs_1.of)(newLink);

build/logic/sync/domain/nuclia-cloud.js

@@ -140,3 +140,5 @@ "use strict";
         else {
-            payload.links = { link: { uri: data.uri, css_selector: data.cssSelector } };
+            payload.links = {
+                link: { uri: data.uri, css_selector: data.cssSelector || undefined, xpath: data.xpathSelector || undefined },
+            };
             payload.icon = 'application/stf-link';
@@ -143,0 +145,0 @@ }

build/types/logic/connector/domain/connector.d.ts

@@ -14,2 +14,3 @@ import { Observable } from 'rxjs';
     cssSelector?: string;
+    xpathSelector?: string;
 }
@@ -16,0 +17,0 @@ export interface ConnectorParameters {

package.json

 {
   "name": "@nuclia/sync-agent",
-  "version": "1.2.13",
+  "version": "1.2.15",
   "description": "This is a sync agent to synchronize user files from diferent sources to nuclia",
@@ -28,3 +28,3 @@ "main": "build/index.js",
   "dependencies": {
-    "@nuclia/core": "^1.14.2",
+    "@nuclia/core": "^1.14.4",
     "cheerio": "^1.0.0-rc.12",
@@ -31,0 +31,0 @@ "commander": "^11.1.0",

No alert changes

Worsened metrics

Total package byte prevSize

183562

decreased by-1.36%

Lines of code

4293

decreased by-2.1%

Dependency changes

• + Added@nuclia/core@1.24.1(transitive)

• + Addedobject-inspect@1.13.4(transitive)

• - Removed@nuclia/core@1.24.0(transitive)

• - Removedobject-inspect@1.13.3(transitive)

• Updated@nuclia/core@^1.14.4