Jint WorkflowsDurable JavaScript workflows for .NET

Write long-running orchestration in JavaScript. Suspend, serialize, and resume — potentially days later, in a different process.

Get Started

View on GitHub

💾

Tiny, Portable State

Serialized state is a compact JSON journal of results — no closure snapshots, no opaque heap dumps. Store it anywhere.

⏳

Suspend for Days

Pause at any `await`, persist, and resume later in a different process. Sleep timers, external events, or manual signals all work the same way.

🔁

Deterministic Replay

On resume, the script re-executes from the start and fast-forwards past journaled operations. `Date.now()`, `new Date()`, and `Math.random()` are overridden for determinism.

🛡️

Journaled Side Effects

Step functions execute once and replay from cache. Wrap any .NET code — HTTP calls, DB writes, email sends — without worrying about duplicate execution.

🩹

Policy-Based Retries

Attach a Foundatio.Resilience policy to any step for in-process retry with jitter, backoff, and circuit breaker. Or throw `RetryableStepException` for durable retries across process restarts.

🌐

Browser-Compatible fetch

Opt-in WHATWG `fetch(url, init)` with `.json()`, `.text()`, and `.clone()`. Journaled responses survive replays — no double-requests.

📣

Named External Events

`waitForEvent('payment-received')` suspends until the caller delivers it. Wait for one name, multiple names, or compose with `Promise.race`.

♾️

Continue As New

Long-running polling workflows shouldn't grow the journal forever. `continueAsNew(...)` hands off to a fresh run with the same entry point.

🔨

Zero Engine Modifications

Built entirely on Jint's public API. No forks, no patches — runs against the official Jint 4 package.

Quick Example

csharp

var workflow = new WorkflowEngine();
workflow.RegisterSuspendFunction("sleep", args => DurationParser.Parse(args[0]));
workflow.RegisterStepFunction("fetchOrder", args => orderService.GetOrder((string)args[0]!));
workflow.RegisterSuspendFunction("getApproval");

var script = """
    async function processOrder(orderId) {
        const order = await fetchOrder(orderId);   // journaled step
        await sleep('3d');                         // suspends for 3 days
        const approved = await getApproval('manager', orderId);
        return approved ? 'shipped' : 'cancelled';
    }
""";

var result = workflow.RunWorkflow(script, "processOrder", "ORD-001");
// result.Status == Suspended, result.Suspension.ResumeAt == 3 days from now

var json = result.State!.Serialize();            // persist anywhere

// ... 3 days later, in a different process
var resumed = workflow.ResumeWorkflow(script, json);