chore(release): v0.0.3

.github/workflows/ci.yaml

@@ -7,7 +7,7 @@ on:
     branches: [ main ]
 
 jobs:
-  build:
+  nodejs:
 
     runs-on: ubuntu-latest
 

API.md

@@ -43,29 +43,29 @@ nodeA.link(nodeB);
 nodeA.link(nodeB, (node, ctx) => ctx.n > 0);
 ```
 
-## Touch a Node
+## Sink Output
 
 ```ts
 import Node from "@wecandobetter/node";
 
 const node = new Node<{ n: number }>({ id: "A" });
 
-// The context is passed to the activation function and middleware
-const context = { n: 5 };
-
-// Touch the node with the context
-await node.touch(context);
+// Sinks are executed when the node is activated and has completed processing
+node.sink((ctx) => console.log(`Sink output: ${ctx.n}`));
 ```
 
-## Sink Output
+## Touch a Node
 
 ```ts
 import Node from "@wecandobetter/node";
 
 const node = new Node<{ n: number }>({ id: "A" });
 
-// Sinks are executed when the node is activated and has completed processing
-node.sink((ctx) => console.log(`Sink output: ${ctx.n}`));
+// The context is passed to the activation function and middleware
+const context = { n: 5 };
+
+// Touch the node with the context
+await node.touch(context);
 ```
 
 ## Explore Nodes

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@wecandobetter/node",
   "description": "Node is a graph execution engine.",
-  "version": "0.0.2",
+  "version": "0.0.3",
   "type": "module",
   "license": "MIT",
   "main": "dist/index.js",
@@ -10,7 +10,7 @@
     "build:ts": "tsc -p tsconfig.build.json",
     "test": "npm run build && jest",
     "test:coverage": "npm run test -- --coverage",
-    "publish:npm": "npm run build:ts && npm publish"
+    "publish:npm": "npm run test && npm publish"
   },
   "repository": {
     "type": "git",

src/Node.ts

@@ -43,12 +43,11 @@ export class Node<T> {
   /** The metadata of the node. */
   readonly metadata: Record<string, unknown> = {};
 
-  /** The middleware stack. */
-  readonly stack: Processor<T>[] = [];
-
   /** The activation function. */
   shouldActivate: ShouldActivate<T>;
 
+  /** The middleware stack. */
+  readonly #stack: Processor<T>[] = [];
   /** The outputs of the node. */
   readonly #outputs = new Map<Node<T>, ShouldActivate<T>>();
   /** The sinks of the node. */
@@ -59,6 +58,13 @@ export class Node<T> {
     this.shouldActivate = shouldActivate ?? true;
   }
 
+  /**
+   * The middleware stack.
+   */
+  get stack(): ReadonlyArray<Processor<T>> {
+    return this.#stack;
+  }
+
   /**
    * The outputs of the node.
    */
@@ -73,6 +79,16 @@ export class Node<T> {
     return this.#sinks;
   }
 
+  /**
+   * Adds one or more processors to the middleware stack. The processors will be
+   * executed in the order they are added.
+   * @param processors The processors to add.
+   */
+  use(...processors: Processor<T>[]): Node<T> {
+    this.#stack.push(...processors);
+    return this;
+  }
+
   /**
    * Links the given node to this node. When the node is activated, the given node
    * will be touched with the same context. If the given node is already linked
@@ -129,7 +145,7 @@ export class Node<T> {
    * Clears the middleware stack.
    */
   clearStack(): Node<T> {
-    this.stack.length = 0;
+    this.#stack.length = 0;
     return this;
   }
 
@@ -157,7 +173,7 @@ export class Node<T> {
     }
 
     // NOTE: Errors are handled by the pipeline.
-    await pipe(...this.stack)(ctx);
+    await pipe(...this.#stack)(ctx);
 
     if (this.#outputs.size) {
       // Touch all outputs in parallel. We don't need to wait for them to

tests/node.ts

@@ -17,7 +17,7 @@ describe("Node API", () => {
     const node = new Node<{ n: number }>({ id: "A" });
     const context = { n: 5 };
 
-    node.stack.push(async (ctx, next) => {
+    node.use(async (ctx, next) => {
       ctx.n += 10;
       await next();
     });