Merge pull request #769 from HaveAGitGat/replace_original_2

Replace Original File: Additional logging

FlowPlugins/CommunityFlowPlugins/file/replaceOriginalFile/1.0.0/index.js

@@ -67,7 +67,7 @@ var details = function () { return ({
 exports.details = details;
 // eslint-disable-next-line @typescript-eslint/no-unused-vars
 var plugin = function (args) { return __awaiter(void 0, void 0, void 0, function () {
-    var lib, currentPath, orignalFolder, fileName, container, newPath, newPathTmp;
+    var lib, currentPath, orignalFolder, fileName, container, newPath, newPathTmp, originalFileExists, currentFileIsNotOriginal;
     return __generator(this, function (_a) {
         switch (_a.label) {
             case 0:
@@ -108,8 +108,14 @@ var plugin = function (args) { return __awaiter(void 0, void 0, void 0, function
                 _a.sent();
                 return [4 /*yield*/, (0, fileUtils_1.fileExists)(args.originalLibraryFile._id)];
             case 3:
-                if (!((_a.sent())
+                originalFileExists = _a.sent();
-                    && args.originalLibraryFile._id !== currentPath)) return [3 /*break*/, 5];
+                currentFileIsNotOriginal = args.originalLibraryFile._id !== currentPath;
+                args.jobLog(JSON.stringify({
+                    originalFileExists: originalFileExists,
+                    currentFileIsNotOriginal: currentFileIsNotOriginal,
+                }));
+                if (!(originalFileExists
+                    && currentFileIsNotOriginal)) return [3 /*break*/, 5];
                 args.jobLog("Deleting original file:".concat(args.originalLibraryFile._id));
                 return [4 /*yield*/, fs_1.promises.unlink(args.originalLibraryFile._id)];
             case 4:

FlowPluginsTs/CommunityFlowPlugins/file/replaceOriginalFile/1.0.0/index.ts

@@ -79,10 +79,18 @@ const plugin = async (args: IpluginInputArgs): Promise<IpluginOutputArgs> => {
     args,
   });
 
+  const originalFileExists = await fileExists(args.originalLibraryFile._id);
+  const currentFileIsNotOriginal = args.originalLibraryFile._id !== currentPath;
+
+  args.jobLog(JSON.stringify({
+    originalFileExists,
+    currentFileIsNotOriginal,
+  }));
+
   // delete original file
   if (
-    await fileExists(args.originalLibraryFile._id)
+    originalFileExists
-    && args.originalLibraryFile._id !== currentPath
+    && currentFileIsNotOriginal
   ) {
     args.jobLog(`Deleting original file:${args.originalLibraryFile._id}`);
     await fsp.unlink(args.originalLibraryFile._id);