Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
876c8ce9d8 | |||
7327bf1bd0 |
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@push.rocks/smartarchive",
|
"name": "@push.rocks/smartarchive",
|
||||||
"version": "4.0.20",
|
"version": "4.0.21",
|
||||||
"description": "work with archives",
|
"description": "work with archives",
|
||||||
"main": "dist_ts/index.js",
|
"main": "dist_ts/index.js",
|
||||||
"typings": "dist_ts/index.d.ts",
|
"typings": "dist_ts/index.d.ts",
|
||||||
|
@ -3,6 +3,6 @@
|
|||||||
*/
|
*/
|
||||||
export const commitinfo = {
|
export const commitinfo = {
|
||||||
name: '@push.rocks/smartarchive',
|
name: '@push.rocks/smartarchive',
|
||||||
version: '4.0.20',
|
version: '4.0.21',
|
||||||
description: 'work with archives'
|
description: 'work with archives'
|
||||||
}
|
}
|
||||||
|
@ -82,10 +82,10 @@ export class SmartArchive {
|
|||||||
streamFileStream.pipe(
|
streamFileStream.pipe(
|
||||||
new plugins.smartstream.SmartDuplex({
|
new plugins.smartstream.SmartDuplex({
|
||||||
objectMode: true,
|
objectMode: true,
|
||||||
writeFunction: async (chunkArg: plugins.smartfile.StreamFile, streamtools) => {
|
writeFunction: async (streamFileArg: plugins.smartfile.StreamFile, streamtools) => {
|
||||||
const done = plugins.smartpromise.defer<void>();
|
const done = plugins.smartpromise.defer<void>();
|
||||||
console.log(chunkArg.relativeFilePath ? chunkArg.relativeFilePath : 'no relative path');
|
console.log(streamFileArg.relativeFilePath ? streamFileArg.relativeFilePath : 'no relative path');
|
||||||
const streamFile = chunkArg;
|
const streamFile = streamFileArg;
|
||||||
const readStream = await streamFile.createReadStream();
|
const readStream = await streamFile.createReadStream();
|
||||||
await plugins.smartfile.fs.ensureDir(targetDir);
|
await plugins.smartfile.fs.ensureDir(targetDir);
|
||||||
const writePath = plugins.path.join(
|
const writePath = plugins.path.join(
|
||||||
|
@ -11,7 +11,7 @@ class DecompressZipTransform extends plugins.smartstream.SmartDuplex<ArrayBuffer
|
|||||||
if (final) {
|
if (final) {
|
||||||
const streamFile = plugins.smartfile.StreamFile.fromBuffer(resultBuffer);
|
const streamFile = plugins.smartfile.StreamFile.fromBuffer(resultBuffer);
|
||||||
streamFile.relativeFilePath = fileArg.name;
|
streamFile.relativeFilePath = fileArg.name;
|
||||||
this.streamtools.push(fileArg);
|
this.streamtools.push(streamFile);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
fileArg.start();
|
fileArg.start();
|
||||||
|
Reference in New Issue
Block a user