feat: move to native web streams (#56)

resolves #55

.github/workflows/ci.yml

@@ -22,13 +22,13 @@ jobs:
     strategy:
       matrix:
         node-version:
-          - 16
+          - 20
     steps:
       - name: Checkout
-        uses: actions/checkout@v3
+        uses: actions/checkout@v4
 
       - name: Setup node ${{ matrix.node-version }}
-        uses: actions/setup-node@v3
+        uses: actions/setup-node@v4
         with:
           node-version: ${{ matrix.node-version }}
 
@@ -45,13 +45,13 @@ jobs:
     strategy:
       matrix:
         node-version:
-          - 16
+          - 20
     steps:
       - name: Checkout
-        uses: actions/checkout@v3
+        uses: actions/checkout@v4
 
       - name: Setup node ${{ matrix.node-version }}
-        uses: actions/setup-node@v3
+        uses: actions/setup-node@v4
         with:
           node-version: ${{ matrix.node-version }}
 
@@ -75,16 +75,16 @@ jobs:
     strategy:
       matrix:
         node-version:
-          - 16
+          - 20
         os:
           - ubuntu-latest
 
     steps:
       - name: Checkout
-        uses: actions/checkout@v3
+        uses: actions/checkout@v4
 
       - name: Setup Node
-        uses: actions/setup-node@v3
+        uses: actions/setup-node@v4
         with:
           node-version: ${{ matrix.node-version }}
 
@@ -100,16 +100,16 @@ jobs:
     strategy:
       matrix:
         node-version:
-          - 16
+          - 20
 
     steps:
       - name: Checkout
-        uses: actions/checkout@v3
+        uses: actions/checkout@v4
 
       - name: Setup Node
-        uses: actions/setup-node@v3
+        uses: actions/setup-node@v4
         with:
-          node-version: 16
+          node-version: 20
 
       - name: Install dependencies
         uses: bahmutov/npm-install@v1

README.md

@@ -31,7 +31,6 @@ This library provides functionality similar to [ipfs-unixfs-importer][], but it
 You can encode a file as follows
 
 ```js
-import { TransformStream } from "@web-std/stream"
 import * as UnixFS from "@ipld/unixfs"
 
 // Create a redable & writable streams with internal queue that can

package.json

@@ -33,14 +33,12 @@
     "@ipld/dag-pb": "^4.0.0",
     "@multiformats/murmur3": "^2.1.3",
     "@perma/map": "^1.0.2",
-    "@web-std/stream": "1.0.1",
     "actor": "^2.3.1",
     "multiformats": "^11.0.1",
     "protobufjs": "^7.1.2",
     "rabin-rs": "^2.1.0"
   },
   "type": "module",
-  "main": "src/lib.js",
   "types": "./dist/src/lib.d.ts",
   "typesVersions": {
     "*": {
@@ -126,8 +124,6 @@
     "@types/chai": "^4.3.3",
     "@types/mocha": "^10.0.0",
     "@types/tsv": "^0.2.1",
-    "@web-std/fetch": "^4.1.0",
-    "@web-std/file": "^3.0.2",
     "c8": "^7.12.0",
     "chai": "^4.3.6",
     "fzstd": "^0.0.4",

test/codec.spec.js

@@ -2,7 +2,6 @@
 import * as unixfs from "../src/codec.js"
 import { assert } from "chai"
 import * as blocks from "./fixtures.js"
-import { fetch } from "./util.js"
 
 const utf8 = new TextEncoder()
 const MURMUR = 0x22

test/convergence.js

@@ -3,7 +3,6 @@ import Matrix from "./dataset/convergence_rawdata.js"
 import * as UnixFS from "../src/lib.js"
 import { parseConfig, unpackFile } from "./matrix.js"
 import { Link, collect, iterate, encodeCar, writeFile } from "./util.js"
-import { TransformStream } from "@web-std/stream"
 
 /**
  *

test/directory.spec.js

@@ -1,5 +1,4 @@
 import * as UnixFS from "../src/lib.js"
-import { TransformStream } from "@web-std/stream"
 import { assert } from "chai"
 import { encodeUTF8, Link, collect, importFile } from "./util.js"
 

test/file.spec.js

@@ -8,7 +8,6 @@ import * as Balanced from "../src/file/layout/balanced.js"
 import * as FixedSize from "../src/file/chunker/fixed.js"
 import * as Rabin from "../src/file/chunker/rabin.js"
 import { sha256 } from "multiformats/hashes/sha2"
-import { TransformStream } from "@web-std/stream"
 
 const CHUNK_SIZE = 262144
 describe("test file", () => {

test/lib.spec.js

@@ -1,7 +1,6 @@
 import * as UnixFS from "../src/lib.js"
 import { assert } from "chai"
 import { encodeUTF8, Link, collect, importFile } from "./util.js"
-import { TransformStream } from "@web-std/stream"
 
 describe("UnixFS.createWriter", () => {
   it("UnixFS.createFileWriter", async () => {

test/matrix.js

@@ -1,4 +1,4 @@
-import { Link, File, fetch } from "./util.js"
+import { Link } from "./util.js"
 import * as Trickle from "../src/file/layout/trickle.js"
 import * as Balanced from "../src/file/layout/balanced.js"
 import * as FixedSize from "../src/file/chunker/fixed.js"

test/sharded-directory.spec.js

@@ -1,5 +1,4 @@
 import * as UnixFS from "../src/lib.js"
-import { TransformStream } from "@web-std/stream"
 import { assert } from "chai"
 import { encodeUTF8, Link, collect, importFile } from "./util.js"
 

test/util.js

@@ -1,6 +1,4 @@
-import { File, Blob } from "@web-std/file"
 import * as Link from "multiformats/link"
-import fetch from "@web-std/fetch"
 import { sha256 } from "multiformats/hashes/sha2"
 import { CarWriter } from "@ipld/car"
 import * as UnixFS from "../src/lib.js"
@@ -143,4 +141,4 @@ export const importFile = async (fs, content) => {
   return await file.close()
 }
 
-export { File, Link, fetch }
+export { Link }

test/writer.spec.js

@@ -1,6 +1,5 @@
 import * as Writer from "../src/file/writer.js"
 import * as UnixFS from "../src/lib.js"
-import { TransformStream } from "@web-std/stream"
 import { assert } from "chai"
 
 describe("Writer", () => {