node-compress-commons/test/zip-archive-output-stream.js at master · archiverjs/node-compress-commons · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
import { createReadStream } from "fs";
import { Stream, Transform } from "stream";
import { assert } from "chai";
import { mkdirp } from "mkdirp";
import { Readable } from "readable-stream";
import { WriteHashStream, binaryBuffer } from "./helpers/index.js";
import {
  ZipArchiveEntry,
  ZipArchiveOutputStream,
} from "../lib/compress-commons.js";

var testBuffer = binaryBuffer(1024 * 16);
var testDate = new Date("Jan 03 2013 14:26:38 GMT");

describe("ZipArchiveOutputStream", function () {
  before(function () {
    mkdirp.sync("tmp");
  });
  describe("#entry", function () {
    it("should append Buffer sources", function (done) {
      var archive = new ZipArchiveOutputStream();
      var testStream = new WriteHashStream("tmp/zip-buffer.zip");
      var entry = new ZipArchiveEntry("buffer.txt");
      testStream.on("close", function () {
        done();
      });
      archive.pipe(testStream);
      archive.entry(entry, testBuffer).finish();
    });
    it("should append Stream sources", function (done) {
      var archive = new ZipArchiveOutputStream();
      var testStream = new WriteHashStream("tmp/zip-stream.zip");
      var entry = new ZipArchiveEntry("stream.txt");
      testStream.on("close", function () {
        done();
      });
      archive.pipe(testStream);
      archive.entry(entry, createReadStream("test/fixtures/test.txt")).finish();
    });
    it("should append Stream-like sources", function (done) {
      var archive = new ZipArchiveOutputStream();
      var testStream = new WriteHashStream("tmp/zip-stream-like.zip");
      var entry = new ZipArchiveEntry("stream-like.txt");
      testStream.on("close", function () {
        done();
      });
      archive.pipe(testStream);
      archive.entry(entry, Readable.from(["test"])).finish();
    });
    it("should stop streaming on Stream error", function (done) {
      var archive = new ZipArchiveOutputStream();
      var testStream = new WriteHashStream("tmp/zip-stream.zip");
      var entry = new ZipArchiveEntry("stream.txt");
      var callbackError = null;
      var callbackCalls = 0;
      testStream.on("close", function () {
        assert.equal(callbackError.message, "something went wrong");
        assert.equal(callbackCalls, 1);
        done();
      });
      archive.pipe(testStream);
      var file = new Transform();
      archive.entry(entry, file, function (err) {
        callbackCalls += 1;
        callbackError = err;
      });
      archive.finish();
      process.nextTick(function () {
        file.emit("error", new Error("something went wrong"));
      });
    });
    it("should append multiple sources", function (done) {
      var archive = new ZipArchiveOutputStream();
      var testStream = new WriteHashStream("tmp/zip-multiple.zip");
      var entry = new ZipArchiveEntry("string.txt");
      var entry2 = new ZipArchiveEntry("buffer.txt");
      var entry3 = new ZipArchiveEntry("stream.txt");
      var entry4 = new ZipArchiveEntry("stream-store.png");
      entry4.setMethod(0);
      var entry5 = new ZipArchiveEntry("buffer-store.txt");
      entry5.setMethod(0);
      testStream.on("close", function () {
        done();
      });
      archive.pipe(testStream);
      archive.entry(entry, "string", function (err) {
        if (err) throw err;
        archive.entry(entry2, testBuffer, function (err) {
          if (err) throw err;
          archive.entry(
            entry3,
            createReadStream("test/fixtures/test.txt"),
            function (err) {
              if (err) throw err;
              archive.entry(
                entry4,
                createReadStream("test/fixtures/image.png"),
                function (err) {
                  if (err) throw err;
                  archive.entry(entry5, testBuffer, function (err) {
                    if (err) throw err;
                    archive.finish();
                  });
                },
              );
            },
          );
        });
      });
    });
    it("should force ZIP64", function (done) {
      var archive = new ZipArchiveOutputStream({
        forceZip64: true,
      });
      var testStream = new WriteHashStream("tmp/zip-stream64.zip");
      var entry = new ZipArchiveEntry("stream.txt");
      testStream.on("close", function () {
        done();
      });
      archive.pipe(testStream);
      archive.entry(entry, createReadStream("test/fixtures/test.txt")).finish();
    });
  });
});