Skip to content

Commit d688a0b

Browse files
fengmk2fengmk2
committed
f
1 parent cc3712c commit d688a0b

File tree

12 files changed

+88
-80
lines changed

12 files changed

+88
-80
lines changed

‎test/gzip/file_stream.test.js‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ describe('test/gzip/file_stream.test.js', () => {
1111
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
1212
const sourceStream = fs.createReadStream(sourceFile);
1313
const destFile = path.join(os.tmpdir(), uuid.v4() + '.log.gz');
14-
console.log('destFile', destFile);
14+
// console.log('destFile', destFile);
1515
const gzipStream = new compressing.gzip.FileStream();
1616
const destStream = fs.createWriteStream(destFile);
1717
pump(sourceStream, gzipStream, destStream, err => {
@@ -24,7 +24,7 @@ describe('test/gzip/file_stream.test.js', () => {
2424
it('should compress according to file path', done => {
2525
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
2626
const destFile = path.join(os.tmpdir(), uuid.v4() + '.log.gz');
27-
console.log('destFile', destFile);
27+
// console.log('destFile', destFile);
2828
const gzipStream = new compressing.gzip.FileStream({ source: sourceFile });
2929
const destStream = fs.createWriteStream(destFile);
3030
pump(gzipStream, destStream, err => {
@@ -44,14 +44,14 @@ describe('test/gzip/file_stream.test.js', () => {
4444

4545
const destFile = path.join(os.tmpdir(), uuid.v4() + '.log.gz');
4646
await fs.promises.writeFile(destFile, Buffer.concat(gzipChunks));
47-
console.log(destFile);
47+
// console.log(destFile);
4848
});
4949

5050
it('should compress buffer', done => {
5151
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
5252
const sourceBuffer = fs.readFileSync(sourceFile);
5353
const destFile = path.join(os.tmpdir(), uuid.v4() + '.log.gz');
54-
console.log('destFile', destFile);
54+
// console.log('destFile', destFile);
5555
const destStream = fs.createWriteStream(destFile);
5656
const gzipStream = new compressing.gzip.FileStream({ source: sourceBuffer });
5757
pump(gzipStream, destStream, err => {
@@ -66,7 +66,7 @@ describe('test/gzip/file_stream.test.js', () => {
6666
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
6767
const sourceStream = fs.createReadStream(sourceFile);
6868
const destFile = path.join(os.tmpdir(), uuid.v4() + '.log.gz');
69-
console.log('destFile', destFile);
69+
// console.log('destFile', destFile);
7070
const destStream = fs.createWriteStream(destFile);
7171
const gzipStream = new compressing.gzip.FileStream({ source: sourceStream });
7272
pump(gzipStream, destStream, err => {

‎test/gzip/index.test.js‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ describe('test/gzip/index.test.js', () => {
1313
it('gzip.compressFile(file, stream)', async () => {
1414
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
1515
const destFile = path.join(os.tmpdir(), uuid.v4() + '.log.gz');
16-
console.log('destFile', destFile);
16+
// console.log('destFile', destFile);
1717
const fileStream = fs.createWriteStream(destFile);
1818
await compressing.gzip.compressFile(sourceFile, fileStream);
1919
assert(fs.existsSync(destFile));
@@ -38,7 +38,7 @@ describe('test/gzip/index.test.js', () => {
3838
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
3939
const sourceBuffer = fs.readFileSync(sourceFile);
4040
const destFile = path.join(os.tmpdir(), uuid.v4() + '.log.gz');
41-
console.log('destFile', destFile);
41+
// console.log('destFile', destFile);
4242
const fileStream = fs.createWriteStream(destFile);
4343
await compressing.gzip.compressFile(sourceBuffer, fileStream);
4444
assert(fs.existsSync(destFile));
@@ -48,7 +48,7 @@ describe('test/gzip/index.test.js', () => {
4848
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
4949
const sourceStream = fs.createReadStream(sourceFile);
5050
const destFile = path.join(os.tmpdir(), uuid.v4() + '.log.gz');
51-
console.log('destFile', destFile);
51+
// console.log('destFile', destFile);
5252
const fileStream = fs.createWriteStream(destFile);
5353
await compressing.gzip.compressFile(sourceStream, fileStream);
5454
assert(fs.existsSync(destFile));

‎test/tar/file_stream.test.js‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ describe('test/tar/file_stream.test.js', () => {
1515
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
1616
const sourceStream = fs.createReadStream(sourceFile);
1717
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
18-
console.log('dest', destFile);
18+
// console.log('dest', destFile);
1919

2020
mm(console, 'warn', msg => {
2121
assert(msg === 'You should specify the size of streamming data by opts.size to prevent all streaming data from loading into memory. If you are sure about memory cost, pass opts.suppressSizeWarning: true to suppress this warning');
@@ -34,7 +34,7 @@ describe('test/tar/file_stream.test.js', () => {
3434
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
3535
const sourceStream = fs.createReadStream(sourceFile);
3636
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
37-
console.log('dest', destFile);
37+
// console.log('dest', destFile);
3838

3939
mm(console, 'warn', msg => {
4040
assert(!msg);

‎test/tar/index.test.js‎

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ describe('test/tar/index.test.js', () => {
1616
it('tar.compressFile(file, stream)', async () => {
1717
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
1818
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
19-
console.log('dest', destFile);
19+
// console.log('dest', destFile);
2020
const fileStream = fs.createWriteStream(destFile);
2121
await compressing.tar.compressFile(sourceFile, fileStream);
2222
assert(fs.existsSync(destFile));
@@ -25,7 +25,7 @@ describe('test/tar/index.test.js', () => {
2525
it('tar.compressFile(file, stream, { relativePath })', async () => {
2626
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
2727
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
28-
console.log('dest', destFile);
28+
// console.log('dest', destFile);
2929
const fileStream = fs.createWriteStream(destFile);
3030
await compressing.tar.compressFile(sourceFile, fileStream, { relativePath: 'dd/dd.log' });
3131
assert(fs.existsSync(destFile));
@@ -35,7 +35,7 @@ describe('test/tar/index.test.js', () => {
3535
it('tar.compressFile(file, stream) should error if file not exist', async () => {
3636
const sourceFile = path.join(__dirname, '..', 'fixtures', 'not-exist.log');
3737
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
38-
console.log('dest', destFile);
38+
// console.log('dest', destFile);
3939
const fileStream = fs.createWriteStream(destFile);
4040
let err;
4141
try {
@@ -65,7 +65,7 @@ describe('test/tar/index.test.js', () => {
6565
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
6666
const sourceStream = fs.createReadStream(sourceFile);
6767
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
68-
console.log('dest', destFile);
68+
// console.log('dest', destFile);
6969
const fileStream = fs.createWriteStream(destFile);
7070
mm(console, 'warn', msg => {
7171
assert(msg === 'You should specify the size of streamming data by opts.size to prevent all streaming data from loading into memory. If you are sure about memory cost, pass opts.suppressSizeWarning: true to suppress this warning');
@@ -78,7 +78,7 @@ describe('test/tar/index.test.js', () => {
7878
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
7979
const sourceStream = fs.createReadStream(sourceFile);
8080
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
81-
console.log('destFile', destFile);
81+
// console.log('destFile', destFile);
8282
const fileStream = fs.createWriteStream(destFile);
8383
mm(console, 'warn', msg => {
8484
assert(!msg);
@@ -91,7 +91,7 @@ describe('test/tar/index.test.js', () => {
9191
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
9292
const sourceBuffer = fs.readFileSync(sourceFile);
9393
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
94-
console.log('dest', destFile);
94+
// console.log('dest', destFile);
9595
const fileStream = fs.createWriteStream(destFile);
9696
await compressing.tar.compressFile(sourceBuffer, fileStream, { relativePath: 'xx.log' });
9797
assert(fs.existsSync(destFile));
@@ -101,7 +101,7 @@ describe('test/tar/index.test.js', () => {
101101
const sourceFile = path.join(__dirname, '..', 'fixtures/xxx/bin');
102102
const originStat = fs.statSync(sourceFile);
103103
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
104-
console.log('dest', destFile);
104+
// console.log('dest', destFile);
105105
const fileStream = fs.createWriteStream(destFile);
106106
await compressing.tar.compressFile(sourceFile, fileStream);
107107
assert(fs.existsSync(destFile));
@@ -111,7 +111,7 @@ describe('test/tar/index.test.js', () => {
111111
await compressing.tar.uncompress(destFile, destDir);
112112
const stat = fs.statSync(path.join(destDir, 'bin'));
113113
assert(stat.mode === originStat.mode);
114-
console.log(destDir);
114+
// console.log(destDir);
115115
});
116116

117117
});
@@ -120,7 +120,7 @@ describe('test/tar/index.test.js', () => {
120120
it('tar.compressDir(dir, destFile)', async () => {
121121
const sourceDir = path.join(__dirname, '..', 'fixtures');
122122
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
123-
console.log('dest', destFile);
123+
// console.log('dest', destFile);
124124
await compressing.tar.compressDir(sourceDir, destFile);
125125
assert(fs.existsSync(destFile));
126126
});
@@ -129,7 +129,7 @@ describe('test/tar/index.test.js', () => {
129129
const sourceDir = path.join(__dirname, '..', 'fixtures');
130130
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
131131
const destStream = fs.createWriteStream(destFile);
132-
console.log('dest', destFile);
132+
// console.log('dest', destFile);
133133
await compressing.tar.compressDir(sourceDir, destStream);
134134
assert(fs.existsSync(destFile));
135135
});
@@ -138,15 +138,15 @@ describe('test/tar/index.test.js', () => {
138138
const sourceDir = path.join(__dirname, '..', 'fixtures');
139139
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
140140
const destStream = fs.createWriteStream(destFile);
141-
console.log('dest', destFile);
141+
// console.log('dest', destFile);
142142
await compressing.tar.compressDir(sourceDir, destStream, { ignoreBase: true });
143143
assert(fs.existsSync(destFile));
144144
});
145145

146146
it('tar.compressDir(dir, destStream) should return promise', async () => {
147147
const sourceDir = path.join(__dirname, '..', 'fixtures');
148148
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
149-
console.log('dest', destFile);
149+
// console.log('dest', destFile);
150150
await compressing.tar.compressDir(sourceDir, destFile);
151151
assert(fs.existsSync(destFile));
152152
});
@@ -155,7 +155,7 @@ describe('test/tar/index.test.js', () => {
155155
const sourceDir = path.join(__dirname, '..', 'fixtures');
156156
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
157157
const destStream = fs.createWriteStream(destFile);
158-
console.log('dest', destFile);
158+
// console.log('dest', destFile);
159159
setImmediate(() => {
160160
destStream.emit('error', new Error('xxx'));
161161
});

‎test/tar/stream.test.js‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -17,13 +17,13 @@ describe('test/tar/stream.test.js', () => {
1717
it('.addEntry(file)', done => {
1818
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
1919
const fileStream = fs.createWriteStream(destFile);
20-
console.log('dest', destFile);
20+
// console.log('dest', destFile);
2121

2222
const tarStream = new TarStream();
2323
tarStream.addEntry(path.join(__dirname, '..', 'fixtures', 'xx.log'));
2424

2525
pump(tarStream, fileStream, err => {
26-
console.log('error', err);
26+
// console.log('error', err);
2727
assert(!err);
2828
assert(fs.existsSync(destFile));
2929
done();
@@ -33,13 +33,13 @@ describe('test/tar/stream.test.js', () => {
3333
it('.addEntry(file, { relativePath })', done => {
3434
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
3535
const fileStream = fs.createWriteStream(destFile);
36-
console.log('dest', destFile);
36+
// console.log('dest', destFile);
3737

3838
const tarStream = new TarStream();
3939
tarStream.addEntry(path.join(__dirname, '..', 'fixtures', 'xx.log'), { relativePath: 'dd/dd.log' });
4040

4141
pump(tarStream, fileStream, err => {
42-
console.log('error', err);
42+
// console.log('error', err);
4343
assert(!err);
4444
assert(fs.existsSync(destFile));
4545
done();
@@ -49,7 +49,7 @@ describe('test/tar/stream.test.js', () => {
4949
it('.addEntry(dir)', done => {
5050
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
5151
const fileStream = fs.createWriteStream(destFile);
52-
console.log('dest', destFile);
52+
// console.log('dest', destFile);
5353

5454
const tarStream = new TarStream();
5555
tarStream.addEntry(path.join(__dirname, '..', 'fixtures'));
@@ -65,7 +65,7 @@ describe('test/tar/stream.test.js', () => {
6565
it('.addEntry(dir, { ignoreBase: true })', done => {
6666
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
6767
const fileStream = fs.createWriteStream(destFile);
68-
console.log('dest', destFile);
68+
// console.log('dest', destFile);
6969

7070
const tarStream = new TarStream();
7171
tarStream.addEntry(path.join(__dirname, '..', 'fixtures'), { ignoreBase: true });
@@ -81,7 +81,7 @@ describe('test/tar/stream.test.js', () => {
8181
it('.addEntry(dir, { relativePath })', done => {
8282
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
8383
const fileStream = fs.createWriteStream(destFile);
84-
console.log('dest', destFile);
84+
// console.log('dest', destFile);
8585

8686
const tarStream = new TarStream();
8787
tarStream.addEntry(path.join(__dirname, '..', 'fixtures'), { relativePath: 'xxx' });
@@ -97,7 +97,7 @@ describe('test/tar/stream.test.js', () => {
9797
it('.addEntry(dir, { relativePath, ignoreBase: true })', done => {
9898
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
9999
const fileStream = fs.createWriteStream(destFile);
100-
console.log('dest', destFile);
100+
// console.log('dest', destFile);
101101

102102
const tarStream = new TarStream();
103103
tarStream.addEntry(path.join(__dirname, '..', 'fixtures'), { relativePath: 'xxx', ignoreBase: true });
@@ -113,7 +113,7 @@ describe('test/tar/stream.test.js', () => {
113113
it('.addEntry(buffer, { relativePath })', done => {
114114
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
115115
const fileStream = fs.createWriteStream(destFile);
116-
console.log('dest', destFile);
116+
// console.log('dest', destFile);
117117

118118
const tarStream = new TarStream();
119119
tarStream.addEntry(fs.readFileSync(path.join(__dirname, '..', 'fixtures', 'xx.log')), { relativePath: 'xx.log' });
@@ -127,7 +127,7 @@ describe('test/tar/stream.test.js', () => {
127127
it('.addEntry(stream, { relativePath })', done => {
128128
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
129129
const fileStream = fs.createWriteStream(destFile);
130-
console.log('dest', destFile);
130+
// console.log('dest', destFile);
131131

132132
mm(console, 'warn', msg => {
133133
assert(msg === 'You should specify the size of streamming data by opts.size to prevent all streaming data from loading into memory. If you are sure about memory cost, pass opts.suppressSizeWarning: true to suppress this warning');
@@ -145,7 +145,7 @@ describe('test/tar/stream.test.js', () => {
145145
it('.addEntry(stream, { relativePath, size })', done => {
146146
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
147147
const fileStream = fs.createWriteStream(destFile);
148-
console.log('dest', destFile);
148+
// console.log('dest', destFile);
149149

150150
mm(console, 'warn', msg => {
151151
assert(!msg);
@@ -166,7 +166,7 @@ describe('test/tar/stream.test.js', () => {
166166
const sourceDir = path.join(__dirname, '..', 'fixtures');
167167
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
168168
const fileStream = fs.createWriteStream(destFile);
169-
console.log('dest', destFile);
169+
// console.log('dest', destFile);
170170

171171
const tarStream = new TarStream();
172172

‎test/tgz/file_stream.test.js‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ describe('test/tgz/file_stream.test.js', () => {
1313
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
1414
const sourceStream = fs.createReadStream(sourceFile);
1515
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tgz');
16-
console.log('dest', destFile);
16+
// console.log('dest', destFile);
1717
const fileStream = fs.createWriteStream(destFile);
1818
const tgzStream = new compressing.tgz.FileStream({ relativePath: 'dd/dd.log' });
1919
pump(sourceStream, tgzStream, fileStream, err => {

‎test/tgz/index.test.js‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ describe('test/tgz/index.test.js', () => {
1313
it('tgz.compressFile(file, stream)', async () => {
1414
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
1515
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tgz');
16-
console.log('dest', destFile);
16+
// console.log('dest', destFile);
1717
const fileStream = fs.createWriteStream(destFile);
1818
await compressing.tgz.compressFile(sourceFile, fileStream);
1919
assert(fs.existsSync(destFile));
@@ -22,7 +22,7 @@ describe('test/tgz/index.test.js', () => {
2222
it('tgz.compressFile(file, stream, { relativePath })', async () => {
2323
const sourceFile = path.join(__dirname, '..', 'fixtures', 'xx.log');
2424
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tgz');
25-
console.log('dest', destFile);
25+
// console.log('dest', destFile);
2626
const fileStream = fs.createWriteStream(destFile);
2727
await compressing.tgz.compressFile(sourceFile, fileStream, { relativePath: 'dd/dd.log' });
2828
assert(fs.existsSync(destFile));
@@ -61,7 +61,7 @@ describe('test/tgz/index.test.js', () => {
6161
const sourceFile = path.join(__dirname, '..', 'fixtures/xxx/bin');
6262
const originStat = fs.statSync(sourceFile);
6363
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tar');
64-
console.log('dest', destFile);
64+
// console.log('dest', destFile);
6565
const fileStream = fs.createWriteStream(destFile);
6666
await compressing.tgz.compressFile(sourceFile, fileStream);
6767
assert(fs.existsSync(destFile));
@@ -72,7 +72,7 @@ describe('test/tgz/index.test.js', () => {
7272
const stat = fs.statSync(path.join(destDir, 'bin'));
7373
assert(stat.mode);
7474
assert(originStat.mode);
75-
console.log(destDir);
75+
// console.log(destDir);
7676
});
7777

7878
});
@@ -81,7 +81,7 @@ describe('test/tgz/index.test.js', () => {
8181
it('tgz.compressDir(dir, destFile)', async () => {
8282
const sourceDir = path.join(__dirname, '..', 'fixtures');
8383
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tgz');
84-
console.log('dest', destFile);
84+
// console.log('dest', destFile);
8585
await compressing.tgz.compressDir(sourceDir, destFile);
8686
assert(fs.existsSync(destFile));
8787
});
@@ -90,7 +90,7 @@ describe('test/tgz/index.test.js', () => {
9090
const sourceDir = path.join(__dirname, '..', 'fixtures');
9191
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tgz');
9292
const destStream = fs.createWriteStream(destFile);
93-
console.log('dest', destFile);
93+
// console.log('dest', destFile);
9494
await compressing.tgz.compressDir(sourceDir, destStream);
9595
assert(fs.existsSync(destFile));
9696
});
@@ -99,15 +99,15 @@ describe('test/tgz/index.test.js', () => {
9999
const sourceDir = path.join(__dirname, '..', 'fixtures');
100100
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tgz');
101101
const destStream = fs.createWriteStream(destFile);
102-
console.log('dest', destFile);
102+
// console.log('dest', destFile);
103103
await compressing.tgz.compressDir(sourceDir, destStream, { ignoreBase: true });
104104
assert(fs.existsSync(destFile));
105105
});
106106

107107
it('tgz.compressDir(dir, destStream) should return promise', async () => {
108108
const sourceDir = path.join(__dirname, '..', 'fixtures');
109109
const destFile = path.join(os.tmpdir(), uuid.v4() + '.tgz');
110-
console.log('dest', destFile);
110+
// console.log('dest', destFile);
111111
await compressing.tgz.compressDir(sourceDir, destFile);
112112
assert(fs.existsSync(destFile));
113113
});
@@ -185,7 +185,7 @@ describe('test/tgz/index.test.js', () => {
185185

186186
if (isWindows) {
187187
const names = fs.readdirSync(destDir);
188-
console.log(names);
188+
// console.log(names);
189189
assert.equal(names.length, 3);
190190
} else {
191191
const res = dircompare.compareSync(originalDir, destDir);

0 commit comments

Comments
 (0)