diff --git a/FlowPluginsTs/CommunityFlowPlugins/file/replaceOriginalFile/1.0.0/index.ts b/FlowPluginsTs/CommunityFlowPlugins/file/replaceOriginalFile/1.0.0/index.ts index d84bacd..3f48f23 100644 --- a/FlowPluginsTs/CommunityFlowPlugins/file/replaceOriginalFile/1.0.0/index.ts +++ b/FlowPluginsTs/CommunityFlowPlugins/file/replaceOriginalFile/1.0.0/index.ts @@ -1,4 +1,4 @@ -import fs from 'fs'; +import { promises as fsp } from 'fs'; import fileMoveOrCopy from '../../../../FlowHelpers/1.0.0/fileMoveOrCopy'; import { fileExists, @@ -81,7 +81,7 @@ const plugin = async (args: IpluginInputArgs): Promise => { && args.originalLibraryFile._id !== currentPath ) { args.jobLog(`Deleting original file:${args.originalLibraryFile._id}`); - fs.unlinkSync(args.originalLibraryFile._id); + await fsp.unlink(args.originalLibraryFile._id); } await new Promise((resolve) => setTimeout(resolve, 2000)); diff --git a/FlowPluginsTs/CommunityFlowPlugins/video/transcodeVideo/1.0.0/index.ts b/FlowPluginsTs/CommunityFlowPlugins/video/transcodeVideo/1.0.0/index.ts index b74345d..cc9f730 100644 --- a/FlowPluginsTs/CommunityFlowPlugins/video/transcodeVideo/1.0.0/index.ts +++ b/FlowPluginsTs/CommunityFlowPlugins/video/transcodeVideo/1.0.0/index.ts @@ -1,4 +1,4 @@ -import fs from 'fs'; +import fs, { promises as fsp } from 'fs'; import { IpluginDetails, IpluginInputArgs, @@ -57,7 +57,7 @@ const plugin = async (args:IpluginInputArgs):Promise => { const newFile = `${args.inputFileObj._id}.tmp`; if (await fileExists(newFile)) { - fs.unlinkSync(newFile); + await fsp.unlink(newFile); } fs.copyFileSync(oldFile, newFile);