Remove unneeded multistream dependency

NOTICE.txt

@@ -7317,38 +7317,6 @@ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 SOFTWARE.
 
 
----------------------------------------------------------
-
----------------------------------------------------------
-
-multistream 2.1.1 - MIT
-https://github.com/feross/multistream
-
-Copyright (c) Feross Aboukhadijeh
-Copyright (c) Feross Aboukhadijeh (http://feross.org).
-
-The MIT License (MIT)
-
-Copyright (c) Feross Aboukhadijeh
-
-Permission is hereby granted, free of charge, to any person obtaining a copy of
-this software and associated documentation files (the "Software"), to deal in
-the Software without restriction, including without limitation the rights to
-use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
-the Software, and to permit persons to whom the Software is furnished to do so,
-subject to the following conditions:
-
-The above copyright notice and this permission notice shall be included in all
-copies or substantial portions of the Software.
-
-THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
-IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
-FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
-COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
-IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
-CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
-
-
 ---------------------------------------------------------
 
 ---------------------------------------------------------

package.json

@@ -30,7 +30,6 @@
     "jsonwebtoken": "^9.0.0",
     "lokijs": "^1.5.6",
     "morgan": "^1.9.1",
-    "multistream": "^2.1.1",
     "mysql2": "^3.10.1",
     "rimraf": "^3.0.2",
     "sequelize": "^6.31.0",
@@ -60,7 +59,6 @@
     "@types/lokijs": "^1.5.2",
     "@types/mocha": "^9.0.0",
     "@types/morgan": "^1.7.35",
-    "@types/multistream": "^2.1.1",
     "@types/node": "^14.14.24",
     "@types/rimraf": "^3.0.0",
     "@types/stoppable": "^1.1.1",

src/common/persistence/FSExtentStore.ts

@@ -9,9 +9,8 @@ import {
   stat,
   unlink
 } from "fs";
-import multistream = require("multistream");
 import { join } from "path";
-import { Writable } from "stream";
+import { PassThrough, Writable, pipeline } from "stream";
 import { promisify } from "util";
 import uuid = require("uuid");
 
@@ -350,10 +349,8 @@ export default class FSExtentStore implements IExtentStore {
     const op = () =>
       new Promise<NodeJS.ReadableStream>((resolve, reject) => {
         this.logger.verbose(
-          `FSExtentStore:readExtent() Creating read stream. LocationId:${persistencyId} extentId:${
-            extentChunk.id
-          } path:${path} offset:${extentChunk.offset} count:${
-            extentChunk.count
+          `FSExtentStore:readExtent() Creating read stream. LocationId:${persistencyId} extentId:${extentChunk.id
+          } path:${path} offset:${extentChunk.offset} count:${extentChunk.count
           } end:${extentChunk.offset + extentChunk.count - 1}`,
           contextId
         );
@@ -362,10 +359,8 @@ export default class FSExtentStore implements IExtentStore {
           end: extentChunk.offset + extentChunk.count - 1
         }).on("close", () => {
           this.logger.verbose(
-            `FSExtentStore:readExtent() Read stream closed. LocationId:${persistencyId} extentId:${
-              extentChunk.id
-            } path:${path} offset:${extentChunk.offset} count:${
-              extentChunk.count
+            `FSExtentStore:readExtent() Read stream closed. LocationId:${persistencyId} extentId:${extentChunk.id
+            } path:${path} offset:${extentChunk.offset} count:${extentChunk.count
             } end:${extentChunk.offset + extentChunk.count - 1}`,
             contextId
           );
@@ -449,7 +444,12 @@ export default class FSExtentStore implements IExtentStore {
       );
     }
 
-    return multistream(streams);
+    const writable = pipeline(streams);
+    const passthrough = new PassThrough();
+
+    passthrough.pipe(writable);
+
+    return passthrough;
   }
 
   /**
@@ -561,7 +561,7 @@ export default class FSExtentStore implements IExtentStore {
             )}, after ${count} bytes piped. Reject streamPipe().`,
             contextId
           );
-          
+
           reject(err);
         });
 

src/common/persistence/MemoryExtentStore.ts

@@ -4,8 +4,7 @@ import ZeroBytesStream from "../ZeroBytesStream";
 import IExtentMetadataStore, { IExtentModel } from "./IExtentMetadataStore";
 import IExtentStore, { IExtentChunk } from "./IExtentStore";
 import uuid = require("uuid");
-import multistream = require("multistream");
-import { Readable } from "stream";
+import { PassThrough, Readable, pipeline } from "stream";
 import { totalmem } from "os";
 
 export interface IMemoryExtentChunk extends IExtentChunk {
@@ -367,7 +366,12 @@ export default class MemoryExtentStore implements IExtentStore {
       );
     }
 
-    return multistream(streams);
+    const writable = pipeline(streams);
+    const passthrough = new PassThrough();
+
+    passthrough.pipe(writable);
+
+    return passthrough;
   }
 
   async deleteExtents(extents: Iterable<string>): Promise<number> {