Embed the Engine in Node

node examples/node-embedded-engine.mjs

import { createExternalSmithersEngine } from "smthrs";
import { z } from "zod";

const engine = await createExternalSmithersEngine({
  schemas: {
    input: z.object({ label: z.string() }),
    result: z.object({ value: z.string() }),
  },
  agents: {},
  backend: "pglite",
  pgliteDataDir: ".smithers/pg",
  logger: (record) => hostLogger[record.level](record.message, record.annotations),
});

const workflow = (name, value) =>
  engine.workflow(
    () => ({
      kind: "element",
      tag: "smithers:workflow",
      props: {},
      rawProps: { name },
      children: [
        {
          kind: "element",
          tag: "smithers:task",
          props: {},
          rawProps: {
            id: name,
            output: "result",
            __smithersKind: "static",
            __smithersPayload: { value },
          },
          children: [],
        },
      ],
    }),
    { output: "result" },
  );

try {
  await engine.run(workflow("first", "one"), { input: { label: "first" } });
  await engine.run(workflow("second", "two"), { input: { label: "second" } });
} finally {
  await engine.close();
}

try {
  await engine.run(failingWorkflow, { input });
} catch (error) {
  for (let current = error; current; current = current.cause) {
    hostLogger.error(current.message);
  }
}