carp-streamer - npm Package Compare versions

Comparing version 0.2.2 to 0.2.3

dist/app.js

@@ -69,8 +69,19 @@ "use strict";
             else if (!this.remoteFile) {
-                const { dir, base } = path_1.default.parse(this.relativePath);
-                const dirs = dir === '' ? [] : dir.split(path_1.default.sep);
-                (pretend ? Promise.resolve({})
-                    : findRemoteFolderByPath(dirs, this.remoteRoot, client)
-                        .then(folder => folder || createRemoteFolderByPath(dirs, this.remoteRoot, client))
-                        .then(folder => client.files.uploadFile(folder.id, base, this.createReadStream()))).then(() => resolve(ResultStatus.UPLOADED)).catch(reject);
+                Promise.resolve().then(() => __awaiter(this, void 0, void 0, function* () {
+                    if (pretend)
+                        Promise.resolve();
+                    const { dir, base } = path_1.default.parse(this.relativePath);
+                    const dirs = dir === '' ? [] : dir.split(path_1.default.sep);
+                    debug('Finding `%s`...', dir);
+                    const foundFolder = yield findRemoteFolderByPath(dirs, this.remoteRoot, client);
+                    try {
+                        const folder = foundFolder || (yield createRemoteFolderByPath(dirs, this.remoteRoot, client));
+                        debug('Uploading `%s`...', this.relativePath);
+                        return client.files.uploadFile(folder.id, base, this.createReadStream());
+                    }
+                    catch (error) {
+                        debug("Failed to create '%s' folder.", dir);
+                        throw error;
+                    }
+                })).then(() => resolve(ResultStatus.UPLOADED)).catch(reject);
             }
@@ -83,4 +94,8 @@ else {
                     else {
-                        (pretend ? Promise.resolve({})
-                            : client.files.uploadNewFileVersion(this.remoteFile.id, this.createReadStream())).then(() => resolve(ResultStatus.UPGRADED)).catch(reject);
+                        Promise.resolve().then(() => {
+                            if (pretend)
+                                Promise.resolve();
+                            debug('Upgrading `%s`...', this.relativePath);
+                            return client.files.uploadNewFileVersion(this.remoteFile.id, this.createReadStream());
+                        }).then(() => resolve(ResultStatus.UPGRADED)).catch(reject);
                     }
@@ -141,5 +156,3 @@ });
     const subFolder = lodash_1.default.first(items.entries.filter(isMiniFolder).filter(item => item.name === folderName));
-    const folder = yield new Promise((resolve, reject) => {
-        return subFolder ? resolve(subFolder) : client.folders.create(rootFolder.id, folderName).then(resolve);
-    });
+    const folder = subFolder || (yield client.folders.create(rootFolder.id, folderName));
     return yield createRemoteFolderByPath(folderPath.slice(1), folder, client);
@@ -146,0 +159,0 @@ });

dist/app.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"app.js","sourceRoot":"","sources":["../src/app.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AACA,oDAAuB;AACvB,oDAA4B;AAC5B,4CAAoB;AACpB,gDAAwB;AACxB,gDAAwB;AAExB,IAAY,YAKX;AALD,WAAY,YAAY;IACtB,2DAAU,CAAA;IACV,+DAAY,CAAA;IACZ,uDAAQ,CAAA;IACR,uDAAQ,CAAA;AACV,CAAC,EALW,YAAY,GAAZ,oBAAY,KAAZ,oBAAY,QAKvB;AAED,MAAM,KAAK,GAAG,cAAI,CAAC,QAAQ,CAAC,mBAAmB,CAAC,CAAC;AAEjD,MAAa,IAAI;IAEf,YAAoB,IAAY,EAAW,YAAoB,EAAU,MAA6B,EAAU,UAAyB,EAAU,UAAuC;QAAtK,SAAI,GAAJ,IAAI,CAAQ;QAAW,iBAAY,GAAZ,YAAY,CAAQ;QAAU,WAAM,GAAN,MAAM,CAAuB;QAAU,eAAU,GAAV,UAAU,CAAe;QAAU,eAAU,GAAV,UAAU,CAA6B;IAC1L,CAAC;IAED,IAAI,YAAY;QACd,OAAO,cAAI,CAAC,OAAO,CAAC,IAAI,CAAC,IAAI,EAAE,IAAI,CAAC,YAAY,CAAC,CAAC;IACpD,CAAC;IAED,WAAW,CAAC,MAAwB,EAAE,UAAmB,KAAK;QAC5D,OAAO,IAAI,OAAO,CAAe,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnD,IAAI,CAAC,IAAI,CAAC,MAAM,EAAE;gBAChB,+BAA+B;gBAC/B,OAAO,CAAC,YAAY,CAAC,UAAU,CAAC,CAAC;aAClC;iBAAM,IAAI,CAAC,IAAI,CAAC,UAAU,EAAE;gBAC3B,MAAM,EAAE,GAAG,EAAE,IAAI,EAAE,GAAG,cAAI,CAAC,KAAK,CAAC,IAAI,CAAC,YAAY,CAAC,CAAC;gBACpD,MAAM,IAAI,GAAG,GAAG,KAAK,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,KAAK,CAAC,cAAI,CAAC,GAAG,CAAC,CAAC;gBACnD,CAAC,OAAO,CAAC,CAAC,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,CAAC;oBAC5B,CAAC,CAAC,sBAAsB,CAAC,IAAI,EAAE,IAAI,CAAC,UAAU,EAAE,MAAM,CAAC;yBACtD,IAAI,CAAC,MAAM,CAAC,EAAE,CAAC,MAAM,IAAI,wBAAwB,CAAC,IAAI,EAAE,IAAI,CAAC,UAAU,EAAE,MAAM,CAAC,CAAC;yBACjF,IAAI,CAAC,MAAM,CAAC,EAAE,CAAC,MAAM,CAAC,KAAK,CAAC,UAAU,CAAC,MAAM,CAAC,EAAE,EAAE,IAAI,EAAE,IAAI,CAAC,gBAAgB,EAAE,CAAC,CAAC,CACnF,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,YAAY,CAAC,QAAQ,CAAC,CAAC,CAAC,KAAK,CAAC,MAAM,CAAC,CAAC;aAC5D;iBAAM;gBACL,IAAI,CAAC,MAAM,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE;oBACxB,IAAI,IAAI,KAAK,IAAI,CAAC,UAAW,CAAC,IAAI,EAAE;wBAClC,OAAO,CAAC,YAAY,CAAC,YAAY,CAAC,CAAC;qBACpC;yBAAM;wBACL,CAAC,OAAO,CAAC,CAAC,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,CAAC;4BAC5B,CAAC,CAAC,MAAM,CAAC,KAAK,CAAC,oBAAoB,CAAC,IAAI,CAAC,UAAW,CAAC,EAAE,EAAE,IAAI,CAAC,gBAAgB,EAAE,CAAC,CAClF,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,YAAY,CAAC,QAAQ,CAAC,CAAC,CAAC,KAAK,CAAC,MAAM,CAAC,CAAC;qBAC5D;gBACH,CAAC,CAAC,CAAC;aACJ;QACH,CAAC,CAAC,CAAC;IACL,CAAC;IAEO,MAAM;QACZ,OAAO,IAAI,OAAO,CAAS,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YAC7C,MAAM,IAAI,GAAG,gBAAM,CAAC,UAAU,CAAC,MAAM,CAAC,CAAC;YACvC,MAAM,MAAM,GAAG,IAAI,CAAC,gBAAgB,EAAE,CAAC;YACvC,MAAM,CAAC,EAAE,CAAC,MAAM,EAAE,KAAK,CAAC,EAAE,CAAC,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC;YAC/C,MAAM,CAAC,EAAE,CAAC,OAAO,EAAE,GAAG,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;QACxD,CAAC,CAAC,CAAC;IACL,CAAC;IAEO,gBAAgB;QACtB,OAAO,YAAE,CAAC,gBAAgB,CAAC,IAAI,CAAC,YAAY,CAAC,CAAA;IAC/C,CAAC;CACF;AAhDD,oBAgDC;AAED,MAAM,UAAU,GAAG,CAAC,IAAiB,EAA2B,EAAE,CAAC,IAAI,CAAC,IAAI,KAAK,MAAM,CAAC;AAExF,SAAsB,oBAAoB,CAAC,YAAoB,EAAE,UAA6B,EAAE,MAAwB;;QACtH,MAAM,EAAE,GAAG,EAAE,IAAI,EAAE,GAAG,cAAI,CAAC,KAAK,CAAC,YAAY,CAAC,CAAC;QAC/C,MAAM,IAAI,GAAG,GAAG,KAAK,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,KAAK,CAAC,cAAI,CAAC,GAAG,CAAC,CAAC;QACnD,OAAO,qBAAqB,CAAC,IAAI,EAAE,IAAI,EAAE,UAAU,EAAE,MAAM,CAAC,CAAC;IAC/D,CAAC;CAAA;AAJD,oDAIC;AAED,SAAe,qBAAqB,CAAC,UAAoB,EAAE,QAAgB,EAAE,UAA6B,EAAE,MAAwB;;QAClI,MAAM,MAAM,GAAG,MAAM,sBAAsB,CAAC,UAAU,EAAE,UAAU,EAAE,MAAM,CAAC,CAAC;QAC5E,OAAO,MAAM,IAAI,MAAM,CAAC,OAAO,CAAC,QAAQ,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,EAAE,CAAC,gBAAC,CAAC,KAAK,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,CAAC,UAAU,CAAC,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,EAAE,KAAK,QAAQ,CAAC,SAAS,EAAE,CAAC,CAAC,CAAC,CAAA;IAC7K,CAAC;CAAA;AAED,MAAM,QAAQ,GAAG,CAAC,IAAuB,EAAyB,EAAE,CAAE,IAAsB,CAAC,IAAI,KAAK,SAAS,CAAC;AAChH,MAAM,YAAY,GAAG,CAAC,IAAiB,EAA6B,EAAE,CAAC,IAAI,CAAC,IAAI,KAAK,QAAQ,CAAC;AAE9F,SAAsB,sBAAsB,CAAC,UAAoB,EAAE,UAAyC,EAAE,MAAwB;;QACpI,IAAI,UAAU,CAAC,MAAM,KAAK,CAAC,IAAI,UAAU,KAAK,SAAS,EAAE;YACvD,OAAO,UAAU,KAAK,SAAS,IAAI,QAAQ,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,OAAO,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC;SAC3H;QAED,MAAM,UAAU,GAAG,gBAAC,CAAC,KAAK,CAAC,UAAU,CAAC,CAAC;QACvC,MAAM,KAAK,GAAG,MAAM,MAAM,CAAC,OAAO,CAAC,QAAQ,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC;QAC3D,MAAM,SAAS,GAAG,gBAAC,CAAC,KAAK,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,CAAC,YAAY,CAAC,CAAC,MAAM,CAAC,MAAM,CAAC,EAAE,CAAC,MAAM,CAAC,IAAI,KAAK,UAAU,CAAC,CAAC,CAAC;QAC3G,OAAO,sBAAsB,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,SAAS,EAAE,MAAM,CAAC,CAAC;IACxE,CAAC;CAAA;AATD,wDASC;AAAA,CAAC;AAEF,MAAM,wBAAwB,GAAG,CAAO,UAAoB,EAAE,UAA6B,EAAE,MAAwB,EAA0B,EAAE;IAC/I,IAAI,UAAU,CAAC,MAAM,KAAK,CAAC,EAAE;QAC3B,OAAO,QAAQ,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,OAAO,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC;KAC/F;IAED,MAAM,UAAU,GAAG,gBAAC,CAAC,KAAK,CAAC,UAAU,CAAC,IAAI,EAAE,CAAC;IAC7C,MAAM,KAAK,GAAG,MAAM,MAAM,CAAC,OAAO,CAAC,QAAQ,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC;IAC3D,MAAM,SAAS,GAAG,gBAAC,CAAC,KAAK,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,CAAC,YAAY,CAAC,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE,CAAC,IAAI,CAAC,IAAI,KAAK,UAAU,CAAC,CAAC,CAAC;IACvG,MAAM,MAAM,GAAG,MAAM,IAAI,OAAO,CAAoB,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;QACtE,OAAO,SAAS,CAAC,CAAC,CAAC,OAAO,CAAC,SAAS,CAAC,CAAC,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,MAAM,CAAC,UAAU,CAAC,EAAE,EAAE,UAAU,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;IACzG,CAAC,CAAC,CAAC;IACH,OAAO,MAAM,wBAAwB,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,MAAM,EAAE,MAAM,CAAC,CAAC;AAC7E,CAAC,CAAA,CAAC;AAEF,MAAM,OAAO,GAAG,cAAI,CAAC,SAAS,CAAC,YAAE,CAAC,OAAO,CAAC,CAAC;AAC3C,SAAuB,+BAA+B,CAAC,IAAY;;QACjE,KAAI,IAAI,MAAM,IAAI,cAAM,OAAO,CAAC,IAAI,EAAE,EAAE,aAAa,EAAE,IAAI,EAAE,CAAC,CAAA,EAAE;YAC9D,MAAM,SAAS,GAAG,cAAI,CAAC,IAAI,CAAC,IAAI,EAAE,MAAM,CAAC,IAAI,CAAC,CAAC;YAC/C,IAAI,MAAM,CAAC,WAAW,EAAE,EAAE;gBACxB,cAAA,KAAK,CAAC,CAAC,iBAAA,cAAA,+BAA+B,CAAC,SAAS,CAAC,CAAA,CAAA,CAAA,CAAC;aACnD;YACD,oBAAM,CAAC,EAAE,IAAI,EAAE,SAAS,EAAE,MAAM,EAAE,CAAC,CAAA,CAAC;SACrC;IACH,CAAC;CAAA;AARD,0EAQC"}
+{"version":3,"file":"app.js","sourceRoot":"","sources":["../src/app.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AACA,oDAAuB;AACvB,oDAA4B;AAC5B,4CAAoB;AACpB,gDAAwB;AACxB,gDAAwB;AAExB,IAAY,YAKX;AALD,WAAY,YAAY;IACtB,2DAAU,CAAA;IACV,+DAAY,CAAA;IACZ,uDAAQ,CAAA;IACR,uDAAQ,CAAA;AACV,CAAC,EALW,YAAY,GAAZ,oBAAY,KAAZ,oBAAY,QAKvB;AAED,MAAM,KAAK,GAAG,cAAI,CAAC,QAAQ,CAAC,mBAAmB,CAAC,CAAC;AAEjD,MAAa,IAAI;IAEf,YAAoB,IAAY,EAAW,YAAoB,EAAU,MAA6B,EAAU,UAAyB,EAAU,UAAuC;QAAtK,SAAI,GAAJ,IAAI,CAAQ;QAAW,iBAAY,GAAZ,YAAY,CAAQ;QAAU,WAAM,GAAN,MAAM,CAAuB;QAAU,eAAU,GAAV,UAAU,CAAe;QAAU,eAAU,GAAV,UAAU,CAA6B;IAC1L,CAAC;IAED,IAAI,YAAY;QACd,OAAO,cAAI,CAAC,OAAO,CAAC,IAAI,CAAC,IAAI,EAAE,IAAI,CAAC,YAAY,CAAC,CAAC;IACpD,CAAC;IAED,WAAW,CAAC,MAAwB,EAAE,UAAmB,KAAK;QAC5D,OAAO,IAAI,OAAO,CAAe,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnD,IAAI,CAAC,IAAI,CAAC,MAAM,EAAE;gBAChB,+BAA+B;gBAC/B,OAAO,CAAC,YAAY,CAAC,UAAU,CAAC,CAAC;aAClC;iBAAM,IAAI,CAAC,IAAI,CAAC,UAAU,EAAE;gBAC3B,OAAO,CAAC,OAAO,EAAE,CAAC,IAAI,CAAC,GAAS,EAAE;oBAChC,IAAI,OAAO;wBAAE,OAAO,CAAC,OAAO,EAAE,CAAC;oBAE/B,MAAM,EAAE,GAAG,EAAE,IAAI,EAAE,GAAG,cAAI,CAAC,KAAK,CAAC,IAAI,CAAC,YAAY,CAAC,CAAC;oBACpD,MAAM,IAAI,GAAG,GAAG,KAAK,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,KAAK,CAAC,cAAI,CAAC,GAAG,CAAC,CAAC;oBACnD,KAAK,CAAC,iBAAiB,EAAE,GAAG,CAAC,CAAC;oBAC9B,MAAM,WAAW,GAAG,MAAM,sBAAsB,CAAC,IAAI,EAAE,IAAI,CAAC,UAAU,EAAE,MAAM,CAAC,CAAC;oBAChF,IAAI;wBACF,MAAM,MAAM,GAAG,WAAW,KAAI,MAAM,wBAAwB,CAAC,IAAI,EAAE,IAAI,CAAC,UAAU,EAAE,MAAM,CAAC,CAAA,CAAC;wBAC5F,KAAK,CAAC,mBAAmB,EAAE,IAAI,CAAC,YAAY,CAAC,CAAC;wBAC9C,OAAO,MAAM,CAAC,KAAK,CAAC,UAAU,CAAC,MAAM,CAAC,EAAE,EAAE,IAAI,EAAE,IAAI,CAAC,gBAAgB,EAAE,CAAC,CAAC;qBAC1E;oBAAC,OAAO,KAAK,EAAE;wBACd,KAAK,CAAC,+BAA+B,EAAE,GAAG,CAAC,CAAC;wBAC5C,MAAM,KAAK,CAAC;qBACb;gBACH,CAAC,CAAA,CAAC,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,YAAY,CAAC,QAAQ,CAAC,CAAC,CAAC,KAAK,CAAC,MAAM,CAAC,CAAC;aAC7D;iBAAM;gBACL,IAAI,CAAC,MAAM,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE;oBACxB,IAAI,IAAI,KAAK,IAAI,CAAC,UAAW,CAAC,IAAI,EAAE;wBAClC,OAAO,CAAC,YAAY,CAAC,YAAY,CAAC,CAAC;qBACpC;yBAAM;wBACL,OAAO,CAAC,OAAO,EAAE,CAAC,IAAI,CAAC,GAAG,EAAE;4BAC1B,IAAI,OAAO;gCAAE,OAAO,CAAC,OAAO,EAAE,CAAC;4BAE/B,KAAK,CAAC,mBAAmB,EAAE,IAAI,CAAC,YAAY,CAAC,CAAC;4BAC9C,OAAO,MAAM,CAAC,KAAK,CAAC,oBAAoB,CAAC,IAAI,CAAC,UAAW,CAAC,EAAE,EAAE,IAAI,CAAC,gBAAgB,EAAE,CAAC,CAAC;wBACzF,CAAC,CAAC,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,YAAY,CAAC,QAAQ,CAAC,CAAC,CAAC,KAAK,CAAC,MAAM,CAAC,CAAC;qBAC7D;gBACH,CAAC,CAAC,CAAC;aACJ;QACH,CAAC,CAAC,CAAC;IACL,CAAC;IAEO,MAAM;QACZ,OAAO,IAAI,OAAO,CAAS,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YAC7C,MAAM,IAAI,GAAG,gBAAM,CAAC,UAAU,CAAC,MAAM,CAAC,CAAC;YACvC,MAAM,MAAM,GAAG,IAAI,CAAC,gBAAgB,EAAE,CAAC;YACvC,MAAM,CAAC,EAAE,CAAC,MAAM,EAAE,KAAK,CAAC,EAAE,CAAC,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC;YAC/C,MAAM,CAAC,EAAE,CAAC,OAAO,EAAE,GAAG,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;QACxD,CAAC,CAAC,CAAC;IACL,CAAC;IAEO,gBAAgB;QACtB,OAAO,YAAE,CAAC,gBAAgB,CAAC,IAAI,CAAC,YAAY,CAAC,CAAA;IAC/C,CAAC;CACF;AA5DD,oBA4DC;AAED,MAAM,UAAU,GAAG,CAAC,IAAiB,EAA2B,EAAE,CAAC,IAAI,CAAC,IAAI,KAAK,MAAM,CAAC;AAExF,SAAsB,oBAAoB,CAAC,YAAoB,EAAE,UAA6B,EAAE,MAAwB;;QACtH,MAAM,EAAE,GAAG,EAAE,IAAI,EAAE,GAAG,cAAI,CAAC,KAAK,CAAC,YAAY,CAAC,CAAC;QAC/C,MAAM,IAAI,GAAG,GAAG,KAAK,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,KAAK,CAAC,cAAI,CAAC,GAAG,CAAC,CAAC;QACnD,OAAO,qBAAqB,CAAC,IAAI,EAAE,IAAI,EAAE,UAAU,EAAE,MAAM,CAAC,CAAC;IAC/D,CAAC;CAAA;AAJD,oDAIC;AAED,SAAe,qBAAqB,CAAC,UAAoB,EAAE,QAAgB,EAAE,UAA6B,EAAE,MAAwB;;QAClI,MAAM,MAAM,GAAG,MAAM,sBAAsB,CAAC,UAAU,EAAE,UAAU,EAAE,MAAM,CAAC,CAAC;QAC5E,OAAO,MAAM,IAAI,MAAM,CAAC,OAAO,CAAC,QAAQ,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,EAAE,CAAC,gBAAC,CAAC,KAAK,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,CAAC,UAAU,CAAC,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,EAAE,KAAK,QAAQ,CAAC,SAAS,EAAE,CAAC,CAAC,CAAC,CAAA;IAC7K,CAAC;CAAA;AAED,MAAM,QAAQ,GAAG,CAAC,IAAuB,EAAyB,EAAE,CAAE,IAAsB,CAAC,IAAI,KAAK,SAAS,CAAC;AAChH,MAAM,YAAY,GAAG,CAAC,IAAiB,EAA6B,EAAE,CAAC,IAAI,CAAC,IAAI,KAAK,QAAQ,CAAC;AAE9F,SAAsB,sBAAsB,CAAC,UAAoB,EAAE,UAAyC,EAAE,MAAwB;;QACpI,IAAI,UAAU,CAAC,MAAM,KAAK,CAAC,IAAI,UAAU,KAAK,SAAS,EAAE;YACvD,OAAO,UAAU,KAAK,SAAS,IAAI,QAAQ,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,OAAO,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC;SAC3H;QAED,MAAM,UAAU,GAAG,gBAAC,CAAC,KAAK,CAAC,UAAU,CAAC,CAAC;QACvC,MAAM,KAAK,GAAG,MAAM,MAAM,CAAC,OAAO,CAAC,QAAQ,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC;QAC3D,MAAM,SAAS,GAAG,gBAAC,CAAC,KAAK,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,CAAC,YAAY,CAAC,CAAC,MAAM,CAAC,MAAM,CAAC,EAAE,CAAC,MAAM,CAAC,IAAI,KAAK,UAAU,CAAC,CAAC,CAAC;QAC3G,OAAO,sBAAsB,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,SAAS,EAAE,MAAM,CAAC,CAAC;IACxE,CAAC;CAAA;AATD,wDASC;AAAA,CAAC;AAEF,MAAM,wBAAwB,GAAG,CAAO,UAAoB,EAAE,UAA6B,EAAE,MAAwB,EAA0B,EAAE;IAC/I,IAAI,UAAU,CAAC,MAAM,KAAK,CAAC,EAAE;QAC3B,OAAO,QAAQ,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,OAAO,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC;KAC/F;IAED,MAAM,UAAU,GAAG,gBAAC,CAAC,KAAK,CAAC,UAAU,CAAC,IAAI,EAAE,CAAC;IAC7C,MAAM,KAAK,GAAG,MAAM,MAAM,CAAC,OAAO,CAAC,QAAQ,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC;IAC3D,MAAM,SAAS,GAAG,gBAAC,CAAC,KAAK,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,CAAC,YAAY,CAAC,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE,CAAC,IAAI,CAAC,IAAI,KAAK,UAAU,CAAC,CAAC,CAAC;IACvG,MAAM,MAAM,GAAG,SAAS,KAAI,MAAM,MAAM,CAAC,OAAO,CAAC,MAAM,CAAC,UAAU,CAAC,EAAE,EAAE,UAAU,CAAC,CAAA,CAAC;IACnF,OAAO,MAAM,wBAAwB,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,MAAM,EAAE,MAAM,CAAC,CAAC;AAC7E,CAAC,CAAA,CAAC;AAEF,MAAM,OAAO,GAAG,cAAI,CAAC,SAAS,CAAC,YAAE,CAAC,OAAO,CAAC,CAAC;AAC3C,SAAuB,+BAA+B,CAAC,IAAY;;QACjE,KAAI,IAAI,MAAM,IAAI,cAAM,OAAO,CAAC,IAAI,EAAE,EAAE,aAAa,EAAE,IAAI,EAAE,CAAC,CAAA,EAAE;YAC9D,MAAM,SAAS,GAAG,cAAI,CAAC,IAAI,CAAC,IAAI,EAAE,MAAM,CAAC,IAAI,CAAC,CAAC;YAC/C,IAAI,MAAM,CAAC,WAAW,EAAE,EAAE;gBACxB,cAAA,KAAK,CAAC,CAAC,iBAAA,cAAA,+BAA+B,CAAC,SAAS,CAAC,CAAA,CAAA,CAAA,CAAC;aACnD;YACD,oBAAM,CAAC,EAAE,IAAI,EAAE,SAAS,EAAE,MAAM,EAAE,CAAC,CAAA,CAAC;SACrC;IACH,CAAC;CAAA;AARD,0EAQC"}

dist/index.js

@@ -29,3 +29,3 @@ #!/usr/bin/env node
 const npmPackage = require('../package.json');
-const debug = util_1.default.debuglog(npmPackage.name);
+const debug = util_1.default.debuglog(`${npmPackage.name}:index`);
 const argsOption = {
@@ -70,21 +70,28 @@ 'alias': { t: 'token', v: 'version' },
             promises.push(app_1.findRemoteFileByPath(relativePath, rootFolder, client).then((remoteFile) => __awaiter(this, void 0, void 0, function* () {
+                debug('%o', { relativePath, dirent, remoteFile });
                 const file = new app_1.File(rootPath, relativePath, dirent, rootFolder, remoteFile);
-                debug('%o', file);
-                const status = yield file.synchronize(client, pretend);
-                switch (status) {
-                    case app_1.ResultStatus.DOWNLOADED:
-                        console.log(`'${file.relativePath}' only exists remotely.`);
-                        break;
-                    case app_1.ResultStatus.SYNCHRONIZED:
-                        console.log(`'${file.relativePath}' is synchronized.`);
-                        break;
-                    case app_1.ResultStatus.UPLOADED:
-                        console.log(`'${file.relativePath}' is newly uploaded.`);
-                        break;
-                    case app_1.ResultStatus.UPGRADED:
-                        console.log(`A new version of '${file.relativePath}' has been uploaded.`);
-                        break;
-                    default:
-                        throw new Error('unknown result status');
+                try {
+                    const status = yield file.synchronize(client, pretend);
+                    switch (status) {
+                        case app_1.ResultStatus.DOWNLOADED:
+                            console.log(`'${file.relativePath}' only exists remotely.`);
+                            break;
+                        case app_1.ResultStatus.SYNCHRONIZED:
+                            console.log(`'${file.relativePath}' is synchronized.`);
+                            break;
+                        case app_1.ResultStatus.UPLOADED:
+                            console.log(`'${file.relativePath}' is newly uploaded.`);
+                            break;
+                        case app_1.ResultStatus.UPGRADED:
+                            console.log(`A new version of '${file.relativePath}' has been uploaded.`);
+                            break;
+                        default:
+                            throw new Error('unknown result status');
+                    }
                 }
+                catch (error) {
+                    debug('%s\n%s', error.message, error.stack);
+                    console.log(`Failed to synchronize '${file.relativePath}'.`);
+                    throw error;
+                }
             })));
@@ -102,3 +109,10 @@ }
     return Promise.all(promises);
-})).then(() => console.log('successful!'));
+})).then(() => {
+    console.log('successful!');
+    process.exit(0);
+}).catch(reason => {
+    console.log(reason.message);
+    console.log(`failure!`);
+    process.exit(1);
+});
 //# sourceMappingURL=index.js.map

dist/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;AAEA,gEAAkC;AAElC,wDAAgC;AAChC,4CAAoB;AACpB,gDAAwB;AACxB,gDAAwB;AACxB,+BAA+F;AAE/F,MAAM,UAAU,GAAG,OAAO,CAAC,iBAAiB,CAAC,CAAC;AAC9C,MAAM,KAAK,GAAG,cAAI,CAAC,QAAQ,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;AAE7C,MAAM,UAAU,GAAG;IACjB,OAAO,EAAE,EAAE,CAAC,EAAE,OAAO,EAAE,CAAC,EAAE,SAAS,EAAE;IACrC,QAAQ,EAAE,CAAC,GAAG,EAAE,SAAS,CAAC;IAC1B,SAAS,EAAE,CAAC,GAAG,EAAE,SAAS,CAAC;IAC3B,SAAS,EAAE,EAAE,SAAS,EAAE,KAAK,EAAE;CAChC,CAAC;AACF,MAAM,IAAI,GAAG,kBAAQ,CAAC,OAAO,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,UAAU,CAAC,CAAC;AAEzD,IAAI,IAAI,CAAC,OAAO,EAAE;IAChB,OAAO,CAAC,GAAG,CAAC,UAAU,CAAC,OAAO,CAAC,CAAC;IAChC,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;CACjB;AAED,MAAM,CAAC,MAAM,EAAE,WAAW,CAAC,GAAG,IAAI,CAAC,CAAC,CAAA;AAEpC,IAAI,MAAM,KAAK,SAAS,IAAI,WAAW,KAAK,SAAS,EAAE;IACrD,OAAO,CAAC,KAAK,CAAC,UAAU,UAAU,CAAC,IAAI,+BAA+B,CAAC,CAAC;IACxE,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;CACjB;AAED,MAAM,OAAO,GAAY,IAAI,CAAC,SAAS,CAAC,CAAC;AAEzC,MAAM,SAAS,GAAG,OAAO,CAAC,GAAG,CAAC,cAAc,IAAI,IAAI,CAAC,KAAK,CAAC,YAAE,CAAC,YAAY,CAAC,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,CAAC,QAAQ,EAAE,CAAC,CAAC;AACnH,MAAM,eAAe,GAAG,CAAC,MAA8C,EAAE,EAAE;IACzE,IAAI,MAAM,CAAC,KAAK;QAAE,OAAO,sBAAM,CAAC,cAAc,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC;IAE7D,MAAM,GAAG,GAAG,sBAAM,CAAC,wBAAwB,CAAC,SAAS,CAAC,CAAC;IACvD,OAAO,GAAG,CAAC,gBAAgB,CAAC,YAAY,CAAC,CAAC;AAC5C,CAAC,CAAA;AAED,MAAM,QAAQ,GAAG,cAAI,CAAC,OAAO,CAAC,OAAO,CAAC,GAAG,EAAE,EAAE,MAAM,CAAC,CAAC;AACrD,MAAM,MAAM,GAAG,eAAe,CAAC,EAAE,SAAS,EAAE,KAAK,EAAE,IAAI,CAAC,KAAK,EAAE,CAAC,CAAC;AACjE,IAAI,IAAI,CAAC,SAAS,CAAC,EAAE;IACnB,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC,CAAC;CAChC;AACD,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,WAAW,CAAC,CAAC,IAAI,CAAC,CAAO,UAAU,EAAE,EAAE;;IACxD,MAAM,QAAQ,GAAG,EAAE,CAAC;;QACpB,KAAiD,IAAA,KAAA,cAAA,qCAA+B,CAAC,QAAQ,CAAC,CAAA,IAAA;YAA/E,IAAI,EAAE,IAAI,EAAE,YAAY,EAAE,MAAM,EAAE,WAAA,CAAA;YAC3C,MAAM,YAAY,GAAG,cAAI,CAAC,QAAQ,CAAC,QAAQ,EAAE,YAAY,CAAC,CAAC;YAC3D,IAAI,MAAM,CAAC,WAAW,EAAE;gBAAE,SAAS;YACnC,QAAQ,CAAC,IAAI,CAAC,0BAAoB,CAAC,YAAY,EAAE,UAAU,EAAE,MAAM,CAAC,CAAC,IAAI,CAAC,CAAO,UAAU,EAAE,EAAE;gBAC7F,MAAM,IAAI,GAAG,IAAI,UAAI,CAAC,QAAQ,EAAE,YAAY,EAAE,MAAM,EAAE,UAAU,EAAE,UAAU,CAAC,CAAA;gBAC7E,KAAK,CAAC,IAAI,EAAE,IAAI,CAAC,CAAC;gBAClB,MAAM,MAAM,GAAG,MAAM,IAAI,CAAC,WAAW,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;gBACvD,QAAQ,MAAM,EAAE;oBACd,KAAK,kBAAY,CAAC,UAAU;wBAC1B,OAAO,CAAC,GAAG,CAAC,IAAI,IAAI,CAAC,YAAY,yBAAyB,CAAC,CAAC;wBAC5D,MAAM;oBACR,KAAK,kBAAY,CAAC,YAAY;wBAC5B,OAAO,CAAC,GAAG,CAAC,IAAI,IAAI,CAAC,YAAY,oBAAoB,CAAC,CAAC;wBACvD,MAAM;oBACR,KAAK,kBAAY,CAAC,QAAQ;wBACxB,OAAO,CAAC,GAAG,CAAC,IAAI,IAAI,CAAC,YAAY,sBAAsB,CAAC,CAAC;wBACzD,MAAM;oBACR,KAAK,kBAAY,CAAC,QAAQ;wBACxB,OAAO,CAAC,GAAG,CAAC,qBAAqB,IAAI,CAAC,YAAY,sBAAsB,CAAC,CAAC;wBAC1E,MAAM;oBACR;wBACE,MAAM,IAAI,KAAK,CAAC,uBAAuB,CAAC,CAAC;iBAC5C;YACH,CAAC,CAAA,CAAC,CAAC,CAAA;SACJ;;;;;;;;;IACD,OAAO,CAAC,GAAG,CAAC,GAAG,QAAQ,CAAC,MAAM,sBAAsB,CAAC,CAAC;IACtD,OAAO,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;AAC/B,CAAC,CAAA,CAAC,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,GAAG,CAAC,aAAa,CAAC,CAAC,CAAC"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;AAEA,gEAAkC;AAElC,wDAAgC;AAChC,4CAAoB;AACpB,gDAAwB;AACxB,gDAAwB;AACxB,+BAA+F;AAE/F,MAAM,UAAU,GAAG,OAAO,CAAC,iBAAiB,CAAC,CAAC;AAC9C,MAAM,KAAK,GAAG,cAAI,CAAC,QAAQ,CAAC,GAAG,UAAU,CAAC,IAAI,QAAQ,CAAC,CAAC;AAExD,MAAM,UAAU,GAAG;IACjB,OAAO,EAAE,EAAE,CAAC,EAAE,OAAO,EAAE,CAAC,EAAE,SAAS,EAAE;IACrC,QAAQ,EAAE,CAAC,GAAG,EAAE,SAAS,CAAC;IAC1B,SAAS,EAAE,CAAC,GAAG,EAAE,SAAS,CAAC;IAC3B,SAAS,EAAE,EAAE,SAAS,EAAE,KAAK,EAAE;CAChC,CAAC;AACF,MAAM,IAAI,GAAG,kBAAQ,CAAC,OAAO,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,UAAU,CAAC,CAAC;AAEzD,IAAI,IAAI,CAAC,OAAO,EAAE;IAChB,OAAO,CAAC,GAAG,CAAC,UAAU,CAAC,OAAO,CAAC,CAAC;IAChC,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;CACjB;AAED,MAAM,CAAC,MAAM,EAAE,WAAW,CAAC,GAAG,IAAI,CAAC,CAAC,CAAA;AAEpC,IAAI,MAAM,KAAK,SAAS,IAAI,WAAW,KAAK,SAAS,EAAE;IACrD,OAAO,CAAC,KAAK,CAAC,UAAU,UAAU,CAAC,IAAI,+BAA+B,CAAC,CAAC;IACxE,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;CACjB;AAED,MAAM,OAAO,GAAY,IAAI,CAAC,SAAS,CAAC,CAAC;AAEzC,MAAM,SAAS,GAAG,OAAO,CAAC,GAAG,CAAC,cAAc,IAAI,IAAI,CAAC,KAAK,CAAC,YAAE,CAAC,YAAY,CAAC,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,CAAC,QAAQ,EAAE,CAAC,CAAC;AACnH,MAAM,eAAe,GAAG,CAAC,MAA8C,EAAE,EAAE;IACzE,IAAI,MAAM,CAAC,KAAK;QAAE,OAAO,sBAAM,CAAC,cAAc,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC;IAE7D,MAAM,GAAG,GAAG,sBAAM,CAAC,wBAAwB,CAAC,SAAS,CAAC,CAAC;IACvD,OAAO,GAAG,CAAC,gBAAgB,CAAC,YAAY,CAAC,CAAC;AAC5C,CAAC,CAAA;AAED,MAAM,QAAQ,GAAG,cAAI,CAAC,OAAO,CAAC,OAAO,CAAC,GAAG,EAAE,EAAE,MAAM,CAAC,CAAC;AACrD,MAAM,MAAM,GAAG,eAAe,CAAC,EAAE,SAAS,EAAE,KAAK,EAAE,IAAI,CAAC,KAAK,EAAE,CAAC,CAAC;AACjE,IAAI,IAAI,CAAC,SAAS,CAAC,EAAE;IACnB,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC,CAAC;CAChC;AACD,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,WAAW,CAAC,CAAC,IAAI,CAAC,CAAO,UAAU,EAAE,EAAE;;IACxD,MAAM,QAAQ,GAAG,EAAE,CAAC;;QACpB,KAAiD,IAAA,KAAA,cAAA,qCAA+B,CAAC,QAAQ,CAAC,CAAA,IAAA;YAA/E,IAAI,EAAE,IAAI,EAAE,YAAY,EAAE,MAAM,EAAE,WAAA,CAAA;YAC3C,MAAM,YAAY,GAAG,cAAI,CAAC,QAAQ,CAAC,QAAQ,EAAE,YAAY,CAAC,CAAC;YAC3D,IAAI,MAAM,CAAC,WAAW,EAAE;gBAAE,SAAS;YACnC,QAAQ,CAAC,IAAI,CAAC,0BAAoB,CAAC,YAAY,EAAE,UAAU,EAAE,MAAM,CAAC,CAAC,IAAI,CAAC,CAAO,UAAU,EAAE,EAAE;gBAC7F,KAAK,CAAC,IAAI,EAAE,EAAE,YAAY,EAAE,MAAM,EAAE,UAAU,EAAE,CAAC,CAAC;gBAClD,MAAM,IAAI,GAAG,IAAI,UAAI,CAAC,QAAQ,EAAE,YAAY,EAAE,MAAM,EAAE,UAAU,EAAE,UAAU,CAAC,CAAA;gBAC7E,IAAI;oBACF,MAAM,MAAM,GAAG,MAAM,IAAI,CAAC,WAAW,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;oBACvD,QAAQ,MAAM,EAAE;wBACd,KAAK,kBAAY,CAAC,UAAU;4BAC1B,OAAO,CAAC,GAAG,CAAC,IAAI,IAAI,CAAC,YAAY,yBAAyB,CAAC,CAAC;4BAC5D,MAAM;wBACR,KAAK,kBAAY,CAAC,YAAY;4BAC5B,OAAO,CAAC,GAAG,CAAC,IAAI,IAAI,CAAC,YAAY,oBAAoB,CAAC,CAAC;4BACvD,MAAM;wBACR,KAAK,kBAAY,CAAC,QAAQ;4BACxB,OAAO,CAAC,GAAG,CAAC,IAAI,IAAI,CAAC,YAAY,sBAAsB,CAAC,CAAC;4BACzD,MAAM;wBACR,KAAK,kBAAY,CAAC,QAAQ;4BACxB,OAAO,CAAC,GAAG,CAAC,qBAAqB,IAAI,CAAC,YAAY,sBAAsB,CAAC,CAAC;4BAC1E,MAAM;wBACR;4BACE,MAAM,IAAI,KAAK,CAAC,uBAAuB,CAAC,CAAC;qBAC5C;iBACF;gBAAC,OAAM,KAAK,EAAE;oBACb,KAAK,CAAC,QAAQ,EAAE,KAAK,CAAC,OAAO,EAAE,KAAK,CAAC,KAAK,CAAC,CAAC;oBAC5C,OAAO,CAAC,GAAG,CAAC,0BAA0B,IAAI,CAAC,YAAY,IAAI,CAAC,CAAC;oBAC7D,MAAM,KAAK,CAAC;iBACb;YACH,CAAC,CAAA,CAAC,CAAC,CAAA;SACJ;;;;;;;;;IACD,OAAO,CAAC,GAAG,CAAC,GAAG,QAAQ,CAAC,MAAM,sBAAsB,CAAC,CAAC;IACtD,OAAO,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;AAC/B,CAAC,CAAA,CAAC,CAAC,IAAI,CAAC,GAAG,EAAE;IACX,OAAO,CAAC,GAAG,CAAC,aAAa,CAAC,CAAC;IAC3B,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;AAClB,CAAC,CAAC,CAAC,KAAK,CAAC,MAAM,CAAC,EAAE;IAChB,OAAO,CAAC,GAAG,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC;IAC5B,OAAO,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC;IACxB,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;AAClB,CAAC,CAAC,CAAC"}

package.json

 {
   "name": "carp-streamer",
-  "version": "0.2.2",
+  "version": "0.2.3",
   "description": "Carp streamer",
@@ -5,0 +5,0 @@ "bin": "dist/index.js",

src/app.ts

@@ -32,9 +32,18 @@ import BoxSDK from 'box-node-sdk';
       } else if (!this.remoteFile) {
-        const { dir, base } = path.parse(this.relativePath);
-        const dirs = dir === '' ? [] : dir.split(path.sep);
-        (pretend ? Promise.resolve({})
-          : findRemoteFolderByPath(dirs, this.remoteRoot, client)
-          .then(folder => folder || createRemoteFolderByPath(dirs, this.remoteRoot, client))
-          .then(folder => client.files.uploadFile(folder.id, base, this.createReadStream()))
-        ).then(() => resolve(ResultStatus.UPLOADED)).catch(reject);
+        Promise.resolve().then(async () => {
+          if (pretend) Promise.resolve();
+
+          const { dir, base } = path.parse(this.relativePath);
+          const dirs = dir === '' ? [] : dir.split(path.sep);
+          debug('Finding `%s`...', dir);
+          const foundFolder = await findRemoteFolderByPath(dirs, this.remoteRoot, client);
+          try {
+            const folder = foundFolder || await createRemoteFolderByPath(dirs, this.remoteRoot, client);
+            debug('Uploading `%s`...', this.relativePath);
+            return client.files.uploadFile(folder.id, base, this.createReadStream());
+          } catch (error) {
+            debug("Failed to create '%s' folder.", dir);
+            throw error;
+          }
+        }).then(() => resolve(ResultStatus.UPLOADED)).catch(reject);
       } else {
@@ -45,5 +54,8 @@ this.digest().then(sha1 => {
           } else {
-            (pretend ? Promise.resolve({})
-              : client.files.uploadNewFileVersion(this.remoteFile!.id, this.createReadStream())
-            ).then(() => resolve(ResultStatus.UPGRADED)).catch(reject);
+            Promise.resolve().then(() => {
+              if (pretend) Promise.resolve();
+
+              debug('Upgrading `%s`...', this.relativePath);
+              return client.files.uploadNewFileVersion(this.remoteFile!.id, this.createReadStream());
+            }).then(() => resolve(ResultStatus.UPGRADED)).catch(reject);
           }
@@ -104,5 +116,3 @@ });
   const subFolder = _.first(items.entries.filter(isMiniFolder).filter(item => item.name === folderName));
-  const folder = await new Promise<BoxSDK.MiniFolder>((resolve, reject) => {
-    return subFolder ? resolve(subFolder) : client.folders.create(rootFolder.id, folderName).then(resolve);
-  });
+  const folder = subFolder || await client.folders.create(rootFolder.id, folderName);
   return await createRemoteFolderByPath(folderPath.slice(1), folder, client);
@@ -109,0 +119,0 @@ };

src/index.ts

@@ -12,3 +12,3 @@ #!/usr/bin/env node
 const npmPackage = require('../package.json');
-const debug = util.debuglog(npmPackage.name);
+const debug = util.debuglog(`${npmPackage.name}:index`);
 
@@ -56,20 +56,26 @@ const argsOption = {
     promises.push(findRemoteFileByPath(relativePath, rootFolder, client).then(async (remoteFile) => {
+      debug('%o', { relativePath, dirent, remoteFile });
       const file = new File(rootPath, relativePath, dirent, rootFolder, remoteFile)
-      debug('%o', file);
-      const status = await file.synchronize(client, pretend);
-      switch (status) {
-        case ResultStatus.DOWNLOADED:
-          console.log(`'${file.relativePath}' only exists remotely.`);
-          break;
-        case ResultStatus.SYNCHRONIZED:
-          console.log(`'${file.relativePath}' is synchronized.`);
-          break;
-        case ResultStatus.UPLOADED:
-          console.log(`'${file.relativePath}' is newly uploaded.`);
-          break;
-        case ResultStatus.UPGRADED:
-          console.log(`A new version of '${file.relativePath}' has been uploaded.`);
-          break;
-        default:
-          throw new Error('unknown result status');
+      try {
+        const status = await file.synchronize(client, pretend);
+        switch (status) {
+          case ResultStatus.DOWNLOADED:
+            console.log(`'${file.relativePath}' only exists remotely.`);
+            break;
+          case ResultStatus.SYNCHRONIZED:
+            console.log(`'${file.relativePath}' is synchronized.`);
+            break;
+          case ResultStatus.UPLOADED:
+            console.log(`'${file.relativePath}' is newly uploaded.`);
+            break;
+          case ResultStatus.UPGRADED:
+            console.log(`A new version of '${file.relativePath}' has been uploaded.`);
+            break;
+          default:
+            throw new Error('unknown result status');
+        }
+      } catch(error) {
+        debug('%s\n%s', error.message, error.stack);
+        console.log(`Failed to synchronize '${file.relativePath}'.`);
+        throw error;
       }
@@ -80,2 +86,9 @@ }))
   return Promise.all(promises);
-}).then(() => console.log('successful!'));
+}).then(() => {
+  console.log('successful!');
+  process.exit(0);
+}).catch(reason => {
+  console.log(reason.message);
+  console.log(`failure!`);
+  process.exit(1);
+});

New alerts

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

Fixed alerts

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

47865

5.6%

Lines of code

760

6.74%

No dependency changes