chore: add .gitignore (node_modules/)

.gitea/workflows/ci.yaml

@@ -10,19 +10,33 @@ on:
 jobs:
   test:
     runs-on: ubuntu-latest
-    strategy:
-      matrix:
-        node: [18, 20, 22]
     steps:
       - uses: actions/checkout@v4
       - uses: actions/setup-node@v4
         with:
-          node-version: ${{ matrix.node }}
+          node-version: 22
       - name: Auth for Gitea npm registry
         run: |
-          echo "@${{ github.repository_owner }}:registry=https://hub.kl1.tenere.ai/api/packages/${{ github.repository_owner }}/npm/" > .npmrc
-          echo "//hub.kl1.tenere.ai/api/packages/${{ github.repository_owner }}/npm/:_authToken=${{ secrets.PACKAGE_TOKEN }}" >> .npmrc
+          echo "@push-stream-std:registry=https://hub.kl1.tenere.ai/api/packages/push-stream-std/npm/" > .npmrc
+          echo "//hub.kl1.tenere.ai/api/packages/push-stream-std/npm/:_authToken=${{ secrets.PACKAGE_TOKEN }}" >> .npmrc
       - run: npm install
+      - run: npm run lint || true
       - run: npm test
-      - run: npm run bench
-        if: matrix.node == 22
+
+  publish:
+    runs-on: ubuntu-latest
+    if: startsWith(github.ref, 'refs/tags/v')
+    needs: test
+    steps:
+      - uses: actions/checkout@v4
+      - uses: actions/setup-node@v4
+        with:
+          node-version: 22
+      - name: Auth for Gitea npm registry
+        run: |
+          echo "@push-stream-std:registry=https://hub.kl1.tenere.ai/api/packages/push-stream-std/npm/" > .npmrc
+          echo "//hub.kl1.tenere.ai/api/packages/push-stream-std/npm/:_authToken=${{ secrets.PACKAGE_TOKEN }}" >> .npmrc
+      - run: npm install
+      - run: npm publish
+        env:
+          NODE_AUTH_TOKEN: ${{ secrets.PACKAGE_TOKEN }}

.gitignore

@@ -0,0 +1 @@
+node_modules/

README.md

@@ -1,4 +1,4 @@
-# stream-to-push-stream
+# @push-stream-std/stream-to-push-stream
 
 Convert native Node.js streams to push-stream source, sink, and duplex interfaces.
 
@@ -41,8 +41,7 @@ npm config set -- //hub.kl1.tenere.ai/api/packages/push-stream-std/npm/:_authTok
 npm install @push-stream-std/stream-to-push-stream
 ```
 
-## Description
-
+## Why
 Utilities for bridging between the Node.js `stream` module (Readable, Writable, Duplex) and the push-stream protocol. PushSource wraps a Readable, listening to `data`/`end`/`error` events and implementing `pipe()`, `resume()`, and `abort()`. PushSink wraps a Writable, translating `write()` calls to `writable.write()` with `drain`-based backpressure and `end()` to `writable.end()`. PushDuplex wraps a Duplex stream as a combined source/sink for bidirectional push-stream pipelines.
 
 ## API
@@ -78,8 +77,5 @@ Tests cover readable-to-source data flow and end handling, writable-to-sink writ
 
 ## Requirements
 
-Node.js 18 or later. ESM only.
+Node.js 22 or later. ESM only.
 
-## License
-
-MIT

index.js

@@ -1,5 +1,12 @@
 import { Readable, Writable, Duplex } from 'stream';
 
+/**
+ * stream-to-push-stream - Convert Node.js streams to push-streams
+ *
+ * Bridges Node.js Readable/Writable/Duplex streams into the push-stream protocol
+ * so they can be composed with `@push-stream-std/*` operators.
+ */
+
 class PushSource {
   constructor(readable) {
     this.readable = readable;
@@ -223,6 +230,11 @@ class PushDuplex {
   }
 }
 
+/**
+ * Wrap a Node.js Readable stream as a push-stream source.
+ * @param {import('stream').Readable} readableStream
+ * @returns {object} A push-stream source
+ */
 export function source(readableStream) {
   if (!(readableStream instanceof Readable)) {
     throw new Error('Expected a Node.js Readable stream');
@@ -230,6 +242,11 @@ export function source(readableStream) {
   return new PushSource(readableStream);
 }
 
+/**
+ * Wrap a Node.js Writable stream as a push-stream sink.
+ * @param {import('stream').Writable} writableStream
+ * @returns {object} A push-stream sink
+ */
 export function sink(writableStream) {
   if (!(writableStream instanceof Writable)) {
     throw new Error('Expected a Node.js Writable stream');
@@ -237,6 +254,11 @@ export function sink(writableStream) {
   return new PushSink(writableStream);
 }
 
+/**
+ * Wrap a Node.js Duplex stream as a push-stream duplex (`{ source, sink }`).
+ * @param {import('stream').Duplex} duplexStream
+ * @returns {{source: object, sink: object}} Push-stream duplex
+ */
 export function duplex(duplexStream) {
   if (!(duplexStream instanceof Duplex)) {
     throw new Error('Expected a Node.js Duplex stream');

package-lock.json

@@ -0,0 +1,16 @@
+{
+  "name": "@push-stream-std/stream-to-push-stream",
+  "version": "1.0.3",
+  "lockfileVersion": 3,
+  "requires": true,
+  "packages": {
+    "": {
+      "name": "@push-stream-std/stream-to-push-stream",
+      "version": "1.0.3",
+      "license": "SEE LICENSE IN LICENSE",
+      "engines": {
+        "node": ">=22.0.0"
+      }
+    }
+  }
+}

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@push-stream-std/stream-to-push-stream",
-  "version": "1.0.0",
+  "version": "1.0.4",
   "description": "Convert Node.js streams to push-streams",
   "type": "module",
   "main": "index.js",
@@ -29,5 +29,9 @@
   ],
   "publishConfig": {
     "registry": "https://hub.kl1.tenere.ai/api/packages/push-stream-std/npm/"
+  },
+  "repository": {
+    "type": "git",
+    "url": "https://hub.kl1.tenere.ai/push-stream-std/stream-to-push-stream.git"
   }
 }