Resident process: Bun with SQLite

bun add yieldstar @yieldstar/core @yieldstar/sqlite-runtime @yieldstar/worker-invoker

import { SqliteEventLoop } from "@yieldstar/sqlite-runtime";
import { createSqliteDb } from "@yieldstar/sqlite-runtime/bun";

export const db = createSqliteDb({ path: "./.db/local.sqlite" });
export const eventLoop = new SqliteEventLoop(db);

import pino from "pino";
import { WorkflowRunner } from "@yieldstar/core";
import {
  SqliteHeapClient,
  SqliteSchedulerClient,
  SqliteStoreClient,
  SqliteTaskQueueClient,
  SqliteTimersClient,
} from "@yieldstar/sqlite-runtime";
import { createWorkflowWorker } from "@yieldstar/worker-invoker";
import { db, router } from "./shared";

const logger = pino();
const taskQueueClient = new SqliteTaskQueueClient(db);
const timersClient = new SqliteTimersClient(db);
const schedulerClient = new SqliteSchedulerClient({
  taskQueueClient,
  timersClient,
});
const runner = new WorkflowRunner({
  router,
  heapClient: new SqliteHeapClient(db),
  schedulerClient,
  storeClient: new SqliteStoreClient({ db, schedulerClient }),
  logger,
});

createWorkflowWorker(runner, logger).listen();

import pino from "pino";
import { createLocalSdk } from "yieldstar";
import { createWorkflowInvoker } from "@yieldstar/worker-invoker";
import { eventLoop } from "./shared";
import type { Router } from "./shared";

const logger = pino();
const workerPath = new URL("./worker.ts", import.meta.url).href;
const invoker = createWorkflowInvoker({ workerPath, logger });

eventLoop.start({ onNewEvent: invoker.execute, logger });
const sdk = createLocalSdk<Router>(invoker);
const result = await sdk.triggerAndWait({ workflowId: "my-workflow" });
eventLoop.stop();