@arc-dev/core - npm Package Compare versions

Comparing version 0.0.2-alpha.11 to 0.0.2-alpha.12

dist/builders/builder.arc.d.ts

@@ -32,4 +32,13 @@ import { ArcStateContext } from "../types/state";
     private lastEdge;
+    private hasInitialized;
     constructor(arcBuilder: ArcBuilder<State, OutputContext>, internalBuilder: InternalArcBuilder<State, OutputContext>);
     /**
+     * Set the initial state for the arc. This can only be called as the first method.
+     * Creates an initialization action that sets up the initial state.
+     *
+     * @param initialState - The initial state object or a function that returns it
+     * @returns This builder for chaining
+     */
+    state(initialState: State | ((state: ImmutableMap<string, any>) => ImmutableMap<string, any>)): this;
+    /**
      * Create an edge from a source node to one or more target nodes.
@@ -36,0 +45,0 @@ * Automatically handles factory functions for node registration.

dist/builders/builder.arc.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"builder.arc.d.ts","sourceRoot":"","sources":["../../src/builders/builder.arc.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAE,MAAM,gBAAgB,CAAC;AACjD,OAAO,EAAe,OAAO,EAAE,MAAM,gBAAgB,CAAC;AACtD,OAAO,EAAE,WAAW,EAAE,kBAAkB,EAAE,MAAM,gBAAgB,CAAC;AACjE,OAAO,KAAK,EAAE,kBAAkB,EAAE,MAAM,oBAAoB,CAAC;AAC7D,OAAO,EAAE,GAAG,IAAI,YAAY,EAAE,MAAM,WAAW,CAAC;AAChD,OAAO,KAAK,EAAE,GAAG,IAAI,IAAI,EAAE,MAAM,cAAc,CAAC;AAChD,OAAO,KAAK,EAAE,OAAO,EAAE,MAAM,gBAAgB,CAAC;AAC9C,OAAO,KAAK,EAAE,CAAC,EAAE,MAAM,KAAK,CAAC;AAC7B,OAAO,KAAK,EAAW,UAAU,EAAE,MAAM,eAAe,CAAC;AAEzD;;GAEG;AACH,KAAK,aAAa,CAChB,KAAK,SAAS,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC,EACjC,aAAa,SAAS,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC,IACvC,OAAO,GAAG,CAAC,CAAC,GAAG,EAAE,UAAU,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,CAAC,CAAC;AAEnE;;;;;;;;;;;;;GAaG;AACH,qBAAa,gBAAgB,CAC3B,KAAK,SAAS,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC,EACjC,aAAa,SAAS,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC;IAKvC,OAAO,CAAC,UAAU;IAClB,OAAO,CAAC,eAAe;IAJzB,OAAO,CAAC,QAAQ,CAAwB;gBAG9B,UAAU,EAAE,UAAU,CAAC,KAAK,EAAE,aAAa,CAAC,EAC5C,eAAe,EAAE,kBAAkB,CAAC,KAAK,EAAE,aAAa,CAAC;IAGnE;;;;;;;;OAQG;IACH,IAAI,CACF,IAAI,EAAE,aAAa,CAAC,KAAK,EAAE,aAAa,CAAC,GAAG,IAAI,GAAG,SAAS,EAC5D,EAAE,EACE,aAAa,CAAC,KAAK,EAAE,aAAa,CAAC,GACnC,aAAa,CAAC,KAAK,EAAE,aAAa,CAAC,EAAE,EACzC,IAAI,CAAC,EAAE,UAAU,GAChB,IAAI;IA4BP;;;;;;OAMG;IACH,IAAI,CACF,IAAI,EAAE,MAAM,EACZ,SAAS,EAAE,CAAC,EAAE,EAAE,eAAe,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,GAChE,IAAI;IAgBP;;;;OAIG;IACH,IAAI,CAAC,IAAI,SAAS,OAAO,EACvB,IAAI,EAAE,IAAI,EACV,MAAM,EAAE;QACN,KAAK,EAAE,CAAC,EAAE,EAAE,eAAe,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,CAAC;QAC9D,GAAG,EAAE,MAAM,CAAC;KACb,GACA,IAAI;IAKP;;;;;OAKG;IACH,GAAG,CAAC,MAAM,SAAS,MAAM,EAAE,EAAE,EAAE,MAAM,EAAE,GAAG,EAAE,IAAI,CAAC,GAAG,CAAC,GAAG,OAAO,CAAC,MAAM,CAAC;IAIvE;;;;;;;;;;;;;OAaG;IACH,YAAY,CACV,EAAE,EAAE,MAAM,EACV,EAAE,EACE,aAAa,CAAC,KAAK,EAAE,aAAa,CAAC,GACnC,aAAa,CAAC,KAAK,EAAE,aAAa,CAAC,EAAE,GACxC,IAAI;CAGR;AAED;;;;;;;;;;GAUG;AACH,qBAAa,UAAU,CACrB,KAAK,SAAS,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC,EACjC,aAAa,SAAS,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC;IAEzC,OAAO,CAAC,WAAW,CAAoC;IACvD,OAAO,CAAC,WAAW,CAAoC;IACvD,OAAO,CAAC,eAAe,CAA2C;gBAEtD,eAAe,EAAE,kBAAkB,CAAC,KAAK,EAAE,aAAa,CAAC;IASrE;;OAEG;IACH,KAAK,IAAI,IAAI,CAAC,KAAK,EAAE,aAAa,CAAC;IAKnC,MAAM,CAAC,MAAM,SAAS,MAAM,EAC1B,EAAE,EAAE,MAAM,EACV,OAAO,EAAE,CACP,EAAE,EAAE,eAAe,CAAC,KAAK,EAAE,aAAa,CAAC,KACtC,OAAO,CAAC,YAAY,CAAC,MAAM,EAAE,GAAG,CAAC,CAAC,GAAG,YAAY,CAAC,MAAM,EAAE,GAAG,CAAC,GAClE,OAAO,CAAC,MAAM,CAAC;IAIlB,KAAK,CAAC,MAAM,SAAS,MAAM,EAAE,MAAM,SAAS,CAAC,CAAC,UAAU,EACtD,EAAE,EAAE,MAAM,EACV,MAAM,EAAE;QACN,KAAK,EAAE,OAAO,CAAC;QACf,QAAQ,EAAE,CAAC,EAAE,EAAE,eAAe,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK;YACvD,IAAI,EAAE,QAAQ,GAAG,MAAM,CAAC;YACxB,OAAO,EAAE,MAAM,CAAC;SACjB,EAAE,CAAC;QACJ,MAAM,EAAE,MAAM,CAAC;KAChB,GACA,OAAO,CAAC,MAAM,CAAC;IAIlB;;;;OAIG;IACH,GAAG,CAAC,MAAM,SAAS,MAAM,EAAE,EAAE,EAAE,MAAM,EAAE,GAAG,EAAE,IAAI,CAAC,GAAG,CAAC,GAAG,OAAO,CAAC,MAAM,CAAC;IAIvE;;;OAGG;IACH,GAAG,CAAC,MAAM,SAAS,MAAM,EAAE,EAAE,EAAE,MAAM,EAAE,GAAG,EAAE,IAAI,CAAC,GAAG,CAAC,GAAG,OAAO,CAAC,MAAM,CAAC;IAKvE;;;;OAIG;IACH,YAAY,CAAC,EAAE,EAAE,MAAM,GAAG;QACxB,EAAE,CAAC,MAAM,SAAS,MAAM,EACtB,MAAM,EAAE,MAAM,EACd,OAAO,EAAE,CAAC,GAAG,EAAE,UAAU,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,CAAC,MAAM,CAAC,GAClE,kBAAkB,CAAC,KAAK,EAAE,aAAa,CAAC,CAAC;KAC7C;IAID;;;;OAIG;IACH,IAAI,CAAC,IAAI,SAAS,OAAO,EACvB,IAAI,EAAE,IAAI,EACV,MAAM,EAAE;QACN,KAAK,EAAE,CAAC,EAAE,EAAE,eAAe,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,CAAC;QAC9D,GAAG,EAAE,MAAM,CAAC;KACb,GACA,IAAI;IAaP,IAAI,CAAC,IAAI,SAAS,OAAO,EACvB,IAAI,EAAE,IAAI,GAAG,CAAC,CAAC,GAAG,EAAE,UAAU,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,CAAC,GAChE,IAAI;IAKP,EAAE,CACA,IAAI,EACA,OAAO,GACP,OAAO,EAAE,GACT,CAAC,CAAC,GAAG,EAAE,UAAU,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,CAAC,GACpD,CAAC,CAAC,GAAG,EAAE,UAAU,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,CAAC,EAAE,GACzD,UAAU,CAAC,WAAW,CAAC,KAAK,EAAE,aAAa,CAAC,CAAC,IAAI,CAAC,CAAC;IAItD,SAAS,CAAC,aAAa,SAAS,MAAM,EACpC,IAAI,EAAE,aAAa,EACnB,EAAE,EAAE,CAAC,EAAE,EAAE,eAAe,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,GACzD,MAAM;CAGV"}
+{"version":3,"file":"builder.arc.d.ts","sourceRoot":"","sources":["../../src/builders/builder.arc.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAE,MAAM,gBAAgB,CAAC;AACjD,OAAO,EAAe,OAAO,EAAE,MAAM,gBAAgB,CAAC;AACtD,OAAO,EAAE,WAAW,EAAE,kBAAkB,EAAE,MAAM,gBAAgB,CAAC;AACjE,OAAO,KAAK,EAAE,kBAAkB,EAAE,MAAM,oBAAoB,CAAC;AAC7D,OAAO,EAAE,GAAG,IAAI,YAAY,EAAE,MAAM,WAAW,CAAC;AAChD,OAAO,KAAK,EAAE,GAAG,IAAI,IAAI,EAAE,MAAM,cAAc,CAAC;AAChD,OAAO,KAAK,EAAE,OAAO,EAAE,MAAM,gBAAgB,CAAC;AAC9C,OAAO,KAAK,EAAE,CAAC,EAAE,MAAM,KAAK,CAAC;AAC7B,OAAO,KAAK,EAAW,UAAU,EAAE,MAAM,eAAe,CAAC;AAEzD;;GAEG;AACH,KAAK,aAAa,CAChB,KAAK,SAAS,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC,EACjC,aAAa,SAAS,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC,IACvC,OAAO,GAAG,CAAC,CAAC,GAAG,EAAE,UAAU,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,CAAC,CAAC;AAEnE;;;;;;;;;;;;;GAaG;AACH,qBAAa,gBAAgB,CAC3B,KAAK,SAAS,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC,EACjC,aAAa,SAAS,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC;IAMvC,OAAO,CAAC,UAAU;IAClB,OAAO,CAAC,eAAe;IALzB,OAAO,CAAC,QAAQ,CAAwB;IACxC,OAAO,CAAC,cAAc,CAAkB;gBAG9B,UAAU,EAAE,UAAU,CAAC,KAAK,EAAE,aAAa,CAAC,EAC5C,eAAe,EAAE,kBAAkB,CAAC,KAAK,EAAE,aAAa,CAAC;IAGnE;;;;;;OAMG;IACH,KAAK,CACH,YAAY,EACR,KAAK,GACL,CAAC,CAAC,KAAK,EAAE,YAAY,CAAC,MAAM,EAAE,GAAG,CAAC,KAAK,YAAY,CAAC,MAAM,EAAE,GAAG,CAAC,CAAC,GACpE,IAAI;IA2BP;;;;;;;;OAQG;IACH,IAAI,CACF,IAAI,EAAE,aAAa,CAAC,KAAK,EAAE,aAAa,CAAC,GAAG,IAAI,GAAG,SAAS,EAC5D,EAAE,EACE,aAAa,CAAC,KAAK,EAAE,aAAa,CAAC,GACnC,aAAa,CAAC,KAAK,EAAE,aAAa,CAAC,EAAE,EACzC,IAAI,CAAC,EAAE,UAAU,GAChB,IAAI;IA4BP;;;;;;OAMG;IACH,IAAI,CACF,IAAI,EAAE,MAAM,EACZ,SAAS,EAAE,CAAC,EAAE,EAAE,eAAe,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,GAChE,IAAI;IAgBP;;;;OAIG;IACH,IAAI,CAAC,IAAI,SAAS,OAAO,EACvB,IAAI,EAAE,IAAI,EACV,MAAM,EAAE;QACN,KAAK,EAAE,CAAC,EAAE,EAAE,eAAe,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,CAAC;QAC9D,GAAG,EAAE,MAAM,CAAC;KACb,GACA,IAAI;IAKP;;;;;OAKG;IACH,GAAG,CAAC,MAAM,SAAS,MAAM,EAAE,EAAE,EAAE,MAAM,EAAE,GAAG,EAAE,IAAI,CAAC,GAAG,CAAC,GAAG,OAAO,CAAC,MAAM,CAAC;IAIvE;;;;;;;;;;;;;OAaG;IACH,YAAY,CACV,EAAE,EAAE,MAAM,EACV,EAAE,EACE,aAAa,CAAC,KAAK,EAAE,aAAa,CAAC,GACnC,aAAa,CAAC,KAAK,EAAE,aAAa,CAAC,EAAE,GACxC,IAAI;CAGR;AAED;;;;;;;;;;GAUG;AACH,qBAAa,UAAU,CACrB,KAAK,SAAS,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC,EACjC,aAAa,SAAS,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC;IAEzC,OAAO,CAAC,WAAW,CAAoC;IACvD,OAAO,CAAC,WAAW,CAAoC;IACvD,OAAO,CAAC,eAAe,CAA2C;gBAEtD,eAAe,EAAE,kBAAkB,CAAC,KAAK,EAAE,aAAa,CAAC;IASrE;;OAEG;IACH,KAAK,IAAI,IAAI,CAAC,KAAK,EAAE,aAAa,CAAC;IAKnC,MAAM,CAAC,MAAM,SAAS,MAAM,EAC1B,EAAE,EAAE,MAAM,EACV,OAAO,EAAE,CACP,EAAE,EAAE,eAAe,CAAC,KAAK,EAAE,aAAa,CAAC,KACtC,OAAO,CAAC,YAAY,CAAC,MAAM,EAAE,GAAG,CAAC,CAAC,GAAG,YAAY,CAAC,MAAM,EAAE,GAAG,CAAC,GAClE,OAAO,CAAC,MAAM,CAAC;IAIlB,KAAK,CAAC,MAAM,SAAS,MAAM,EAAE,MAAM,SAAS,CAAC,CAAC,UAAU,EACtD,EAAE,EAAE,MAAM,EACV,MAAM,EAAE;QACN,KAAK,EAAE,OAAO,CAAC;QACf,QAAQ,EAAE,CAAC,EAAE,EAAE,eAAe,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK;YACvD,IAAI,EAAE,QAAQ,GAAG,MAAM,CAAC;YACxB,OAAO,EAAE,MAAM,CAAC;SACjB,EAAE,CAAC;QACJ,MAAM,EAAE,MAAM,CAAC;KAChB,GACA,OAAO,CAAC,MAAM,CAAC;IAIlB;;;;OAIG;IACH,GAAG,CAAC,MAAM,SAAS,MAAM,EAAE,EAAE,EAAE,MAAM,EAAE,GAAG,EAAE,IAAI,CAAC,GAAG,CAAC,GAAG,OAAO,CAAC,MAAM,CAAC;IAIvE;;;OAGG;IACH,GAAG,CAAC,MAAM,SAAS,MAAM,EAAE,EAAE,EAAE,MAAM,EAAE,GAAG,EAAE,IAAI,CAAC,GAAG,CAAC,GAAG,OAAO,CAAC,MAAM,CAAC;IAKvE;;;;OAIG;IACH,YAAY,CAAC,EAAE,EAAE,MAAM,GAAG;QACxB,EAAE,CAAC,MAAM,SAAS,MAAM,EACtB,MAAM,EAAE,MAAM,EACd,OAAO,EAAE,CAAC,GAAG,EAAE,UAAU,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,CAAC,MAAM,CAAC,GAClE,kBAAkB,CAAC,KAAK,EAAE,aAAa,CAAC,CAAC;KAC7C;IAID;;;;OAIG;IACH,IAAI,CAAC,IAAI,SAAS,OAAO,EACvB,IAAI,EAAE,IAAI,EACV,MAAM,EAAE;QACN,KAAK,EAAE,CAAC,EAAE,EAAE,eAAe,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,CAAC;QAC9D,GAAG,EAAE,MAAM,CAAC;KACb,GACA,IAAI;IAaP,IAAI,CAAC,IAAI,SAAS,OAAO,EACvB,IAAI,EAAE,IAAI,GAAG,CAAC,CAAC,GAAG,EAAE,UAAU,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,CAAC,GAChE,IAAI;IAKP,EAAE,CACA,IAAI,EACA,OAAO,GACP,OAAO,EAAE,GACT,CAAC,CAAC,GAAG,EAAE,UAAU,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,CAAC,GACpD,CAAC,CAAC,GAAG,EAAE,UAAU,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,CAAC,EAAE,GACzD,UAAU,CAAC,WAAW,CAAC,KAAK,EAAE,aAAa,CAAC,CAAC,IAAI,CAAC,CAAC;IAItD,SAAS,CAAC,aAAa,SAAS,MAAM,EACpC,IAAI,EAAE,aAAa,EACnB,EAAE,EAAE,CAAC,EAAE,EAAE,eAAe,CAAC,KAAK,EAAE,aAAa,CAAC,KAAK,OAAO,GACzD,MAAM;CAGV"}

dist/index.cjs

@@ -604,2 +604,3 @@ 'use strict';
     lastEdge = null;
+    hasInitialized = false;
     constructor(arcBuilder, internalBuilder) {
@@ -610,2 +611,30 @@ this.arcBuilder = arcBuilder;
     /**
+     * Set the initial state for the arc. This can only be called as the first method.
+     * Creates an initialization action that sets up the initial state.
+     *
+     * @param initialState - The initial state object or a function that returns it
+     * @returns This builder for chaining
+     */
+    state(initialState) {
+        if (this.hasInitialized) {
+            throw new Error("state() can only be called once and must be the first method in the arc chain");
+        }
+        this.hasInitialized = true;
+        // Create an internal initialization action
+        const initAction = this.arcBuilder.action("__init__", ({ state }) => {
+            if (typeof initialState === "function") {
+                return initialState(state);
+            }
+            // Merge initial state into current state
+            let newState = state;
+            for (const [key, value] of Object.entries(initialState)) {
+                newState = newState.set(key, value);
+            }
+            return newState;
+        });
+        // Create entry edge to initialization action
+        this.edge(null, initAction);
+        return this;
+    }
+    /**
      * Create an edge from a source node to one or more target nodes.
@@ -612,0 +641,0 @@ * Automatically handles factory functions for node registration.

dist/index.d.ts

@@ -362,4 +362,13 @@ import { Map as Map$1 } from 'immutable';
     private lastEdge;
+    private hasInitialized;
     constructor(arcBuilder: ArcBuilder<State, OutputContext>, internalBuilder: InternalArcBuilder<State, OutputContext>);
     /**
+     * Set the initial state for the arc. This can only be called as the first method.
+     * Creates an initialization action that sets up the initial state.
+     *
+     * @param initialState - The initial state object or a function that returns it
+     * @returns This builder for chaining
+     */
+    state(initialState: State | ((state: Map$1<string, any>) => Map$1<string, any>)): this;
+    /**
      * Create an edge from a source node to one or more target nodes.
@@ -366,0 +375,0 @@ * Automatically handles factory functions for node registration.

dist/index.js

@@ -603,2 +603,3 @@ import { z } from 'zod';
     lastEdge = null;
+    hasInitialized = false;
     constructor(arcBuilder, internalBuilder) {
@@ -609,2 +610,30 @@ this.arcBuilder = arcBuilder;
     /**
+     * Set the initial state for the arc. This can only be called as the first method.
+     * Creates an initialization action that sets up the initial state.
+     *
+     * @param initialState - The initial state object or a function that returns it
+     * @returns This builder for chaining
+     */
+    state(initialState) {
+        if (this.hasInitialized) {
+            throw new Error("state() can only be called once and must be the first method in the arc chain");
+        }
+        this.hasInitialized = true;
+        // Create an internal initialization action
+        const initAction = this.arcBuilder.action("__init__", ({ state }) => {
+            if (typeof initialState === "function") {
+                return initialState(state);
+            }
+            // Merge initial state into current state
+            let newState = state;
+            for (const [key, value] of Object.entries(initialState)) {
+                newState = newState.set(key, value);
+            }
+            return newState;
+        });
+        // Create entry edge to initialization action
+        this.edge(null, initAction);
+        return this;
+    }
+    /**
      * Create an edge from a source node to one or more target nodes.
@@ -611,0 +640,0 @@ * Automatically handles factory functions for node registration.

package.json

 {
   "name": "@arc-dev/core",
-  "version": "0.0.2-alpha.11",
+  "version": "0.0.2-alpha.12",
   "description": "Core ARC runtime types utilities and builder",
@@ -5,0 +5,0 @@ "type": "module",

No alert changes

Improved metrics

Total package byte prevSize

328969

2.24%

Lines of code

3285

2.37%

No dependency changes