diff --git a/FlowPlugins/CommunityFlowPlugins/file/replaceOriginalFile/1.0.0/index.js b/FlowPlugins/CommunityFlowPlugins/file/replaceOriginalFile/1.0.0/index.js index 4440a66..f4b5c34 100644 --- a/FlowPlugins/CommunityFlowPlugins/file/replaceOriginalFile/1.0.0/index.js +++ b/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()) - && args.originalLibraryFile._id !== currentPath)) return [3 /*break*/, 5]; + originalFileExists = _a.sent(); + 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: diff --git a/FlowPluginsTs/CommunityFlowPlugins/file/replaceOriginalFile/1.0.0/index.ts b/FlowPluginsTs/CommunityFlowPlugins/file/replaceOriginalFile/1.0.0/index.ts index f4182f0..fb88b14 100644 --- a/FlowPluginsTs/CommunityFlowPlugins/file/replaceOriginalFile/1.0.0/index.ts +++ b/FlowPluginsTs/CommunityFlowPlugins/file/replaceOriginalFile/1.0.0/index.ts @@ -79,10 +79,18 @@ const plugin = async (args: IpluginInputArgs): Promise => { 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) - && args.originalLibraryFile._id !== currentPath + originalFileExists + && currentFileIsNotOriginal ) { args.jobLog(`Deleting original file:${args.originalLibraryFile._id}`); await fsp.unlink(args.originalLibraryFile._id);