fix(core): update
This commit is contained in:
		| @@ -3,6 +3,6 @@ | ||||
|  */ | ||||
| export const commitinfo = { | ||||
|   name: '@push.rocks/smartarchive', | ||||
|   version: '4.0.0', | ||||
|   version: '4.0.1', | ||||
|   description: 'work with archives' | ||||
| } | ||||
|   | ||||
| @@ -74,7 +74,26 @@ export class SmartArchive { | ||||
|     // return archiveStream; | ||||
|   } | ||||
|  | ||||
|   public async exportToFs(targetDir: string): Promise<void> {} | ||||
|   public async exportToFs(targetDir: string): Promise<void> { | ||||
|     const done = plugins.smartpromise.defer<void>(); | ||||
|     const streamFileStream = await this.exportToStreamOfStreamFiles(); | ||||
|     streamFileStream.pipe(new plugins.smartstream.SmartDuplex({ | ||||
|       objectMode: true, | ||||
|       writeAndTransformFunction: async (chunkArg: plugins.smartfile.StreamFile, streamtools) => { | ||||
|         console.log(chunkArg.relativeFilePath); | ||||
|         const streamFile = chunkArg; | ||||
|         const readStream = await streamFile.createReadStream(); | ||||
|         const writePath = plugins.path.join(targetDir + streamFile.relativeFilePath); | ||||
|         const dir = plugins.path.parse(writePath).dir; | ||||
|         await plugins.smartfile.fs.ensureDir(plugins.path.dirname(dir)); | ||||
|         const writeStream = plugins.smartfile.fsStream.createWriteStream(writePath); | ||||
|         readStream.pipe(writeStream).end(() => { | ||||
|           done.resolve(); | ||||
|         }); | ||||
|       }, | ||||
|     })); | ||||
|     return done.promise; | ||||
|   } | ||||
|  | ||||
|   public async exportToStreamOfStreamFiles() { | ||||
|     const streamFileIntake = new plugins.smartstream.StreamIntake<plugins.smartfile.StreamFile>({ | ||||
|   | ||||
		Reference in New Issue
	
	Block a user