feat(pipeline): add the fact-record pipeline core

.agents/skills/deploy-to-cloudflare/SKILL.md

@@ -27,7 +27,7 @@ Run Wrangler through `pnpm wrangler` and preserve its live terminal output. Read
 4. Run `pnpm jiti scripts/require-wrangler-config.ts`.
 5. Run `pnpm wrangler deployments status --json`. Continue only when Wrangler explicitly reports that the configured Worker does not exist. Stop when it reports an existing deployment or any authentication, network, account, or ambiguous failure.
 6. Run `pnpm run build:web`, because the shared Wrangler configuration includes `apps/web/dist/client` as its Static Assets directory.
-7. Publish the bootstrap probe through a reviewed command file, retaining the final Worker name, bindings, Durable Object migration, assets, cron, and routes. This first version installs the configured `new_sqlite_classes` migration:
+7. Publish the bootstrap probe through a reviewed command file, retaining the final Worker name, bindings, Durable Object migration, assets, cron, and routes. This first version installs the configured Durable Object class migrations:
 
    ```bash
    pnpm wrangler deploy .agents/skills/deploy-to-cloudflare/assets/binding-probe.js \
@@ -52,7 +52,7 @@ Run Wrangler through `pnpm wrangler` and preserve its live terminal output. Read
      <DEPLOYED_ORIGIN>/api/deployment-probe
    ```
 
-10. Require HTTP 200, the exact body `Hello World`, and `x-floway-binding-probe: DB,FILES,IMAGES,KV,EXECUTION_DO`. The probe performs a D1 query, an R2 read, a KV read, an Images inspection, and a Durable Object request. Stop before migrations when any check fails.
+10. Require HTTP 200, the exact body `Hello World`, and `x-floway-binding-probe: DB,FILES,IMAGES,KV,EXECUTION_DO,LOG_STREAM_DO`. The probe performs a D1 query, an R2 read, a KV read, an Images inspection, an execution-cell request, and a SQLite-backed log-stream request. Stop before migrations when any check fails.
 11. Set `ADMIN_KEY` with `pnpm wrangler secret put ADMIN_KEY`; accept the value only through Wrangler's secret prompt or redirected secure input. Confirm its name in `pnpm wrangler secret list`.
 12. Continue with the deployment-state collection below. Treat the probe deployment as the current code version and omit the historical Floway `CHANGELOG.md` diff because no previous Floway deployment exists at this Worker name.
 

.agents/skills/deploy-to-cloudflare/assets/binding-probe.d.ts

@@ -0,0 +1,10 @@
+export class ExecutionDO {
+  constructor(context: DurableObjectState, env: unknown);
+  fetch(): Response;
+}
+export class LogStreamDO {
+  constructor(context: DurableObjectState, env: unknown);
+  fetch(): Response;
+}
+declare const probe: { fetch(request: Request, env: Record<string, unknown>): Promise<Response> };
+export default probe;

.agents/skills/deploy-to-cloudflare/assets/binding-probe.js

@@ -37,6 +37,13 @@ const checks = {
       throw new Error(`Durable Object probe returned HTTP ${response.status}`);
     }
   },
+  LOG_STREAM_DO: async (env) => {
+    const id = env.LOG_STREAM_DO.idFromName(PROBE_KEY);
+    const response = await env.LOG_STREAM_DO.get(id).fetch(new Request('https://deployment-probe.internal/'));
+    if (!response.ok || await response.text() !== 'Hello World') {
+      throw new Error(`LogStream probe returned HTTP ${response.status}`);
+    }
+  },
 };
 
 const probe = async env => Promise.all(Object.values(checks).map(check => check(env)));
@@ -47,14 +54,22 @@ export class ExecutionDO extends DurableObject {
   }
 }
 
+export class LogStreamDO extends DurableObject {
+  fetch() {
+    const row = this.ctx.storage.sql.exec('SELECT 1 AS value').one();
+    if (row.value !== 1) throw new Error('LogStream SQLite probe failed');
+    return new Response('Hello World');
+  }
+}
+
 export default {
   async fetch(request, env) {
     if (new URL(request.url).pathname !== '/api/deployment-probe') return new Response('Not Found', { status: 404 });
 
     try {
       await probe(env);
       return new Response('Hello World', {
-        headers: { 'x-floway-binding-probe': 'DB,FILES,IMAGES,KV,EXECUTION_DO' },
+        headers: { 'x-floway-binding-probe': Object.keys(checks).join(',') },
       });
     } catch (error) {
       const detail = error instanceof Error

.github/workflows/verify.yaml

@@ -114,7 +114,7 @@ jobs:
           - name: lint (gateway)
             targets: packages/gateway
           - name: lint (other packages)
-            targets: eslint.config.ts vitest.config.ts packages/agent-setup packages/http packages/interceptor packages/platform packages/protocols packages/provider packages/provider-azure packages/provider-claude-code packages/provider-codex packages/provider-copilot packages/provider-custom packages/provider-ollama packages/proxy packages/test-utils packages/translate scripts tools
+            targets: eslint.config.ts vitest.config.ts packages/agent-setup packages/dump packages/http packages/interceptor packages/pipeline packages/platform packages/protocols packages/provider packages/provider-azure packages/provider-claude-code packages/provider-codex packages/provider-copilot packages/provider-custom packages/provider-ollama packages/proxy packages/test-utils packages/translate scripts tools
     name: ${{ matrix.name }}
     steps:
       - name: Checkout

AGENTS.md

@@ -58,9 +58,11 @@
 | Package | `apps/platform-node` | Hosts Floway on Node. |
 | Package | `apps/web` | Provides the operator dashboard. |
 | Package | `packages/agent-setup` | Configures supported coding agents. |
+| Package | `packages/dump` | Records pipeline runs and publishes diagnostics. |
 | Package | `packages/gateway` | Composes gateway services. |
 | Package | `packages/http` | Provides HTTP transport primitives. |
 | Package | `packages/interceptor` | Intercepts gateway traffic. |
+| Package | `packages/pipeline` | Runs stages over a fact record. |
 | Package | `packages/platform` | Defines portable runtime contracts. |
 | Package | `packages/protocols` | Defines protocol contracts. |
 | Package | `packages/provider` | Defines provider contracts. |

apps/platform-cloudflare/entry.ts

@@ -14,6 +14,7 @@ import {
 // Re-exported here because the current binding and the rename migration's
 // target resolve the class by its Worker-module export name.
 export { ExecutionDO } from './src/execution-do.ts';
+export { LogStreamDO } from './src/log-stream-do.ts';
 
 export class ExecutionOperationEntrypoint extends WorkerEntrypoint<CloudflareEnv> {
   async fetch(request: Request): Promise<Response> {

apps/platform-cloudflare/package.json

@@ -7,6 +7,7 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
+    "@floway-dev/dump": "workspace:*",
     "@floway-dev/gateway": "workspace:*",
     "@floway-dev/http": "workspace:*",
     "@floway-dev/platform": "workspace:*",