typescript
235 files
Ack Gate
/** * H3.1 — Ack Gate: wrap every tool result with obs_hash; enforce that the * NEXT assistant turn begins with `<ack …
Ack Gate.Test
/** * Tests for ack-gate (H3.1). * * Proves: * - wrapResult produces deterministic hex hash from tool result * - ch…
Ai
import type { Env } from "../types"; /** * AI namespace tools — powered by Workers AI binding. * * Uses `env.AI.run(…
Analyze Batches
import { Agent } from "@earendil-works/pi-agent-core"; import { getModel } from "@earendil-works/pi-ai"; import { Type }…
Approve Skills
#!/usr/bin/env bun /** * Approval CLI for skill proposals. * * This is OPERATOR TOOLING — a bun script, NOT workerd c…
Artifact Contract.Test
/** * Artifact Contract Tests for run.ts dispatch paths. * * Proves that run.ts enforces the Dispatch Artifact Contra…
Artifact Contract.Test
/** * Artifact Contract Tests for run.ts dispatch paths. * * Proves that run.ts enforces the Dispatch Artifact Contra…
Artifacts
import type { Env } from "../types"; /** * Artifacts namespace tools — R2 bucket for binary artifacts. * * Provides …
Browser
import type { Env } from "../types"; /** * Browser namespace tools — powered by Browser Rendering quick actions. * *…
Budget Governor
/** * H3.6 — Budget Governor: hard caps B_tokens / B_calls / B_wallclock_ms from * the envelope. Breach → graceful sus…
Budget Governor.Test
/** * Tests for budget-governor (H3.6). * * Proves: * - all 3 hard cap types (calls, tokens, wallclock) are enforced…
Cf
/** * Cloudflare REST API client types and the typed error surfaced to sandbox * code when the API returns `success:fa…
Chaos Scenarios
/** * Shared chaos scenario runners used by both chaos.test.ts and * no-silent-failure.test.ts. Lives outside *.test.t…
Chaos.Test
/** * Chaos Tests — fault injection, one scenario per test. * * Five scenarios: * 1. dropped-tool-result — ack gat…
Checkpoint
/** * H1.1 + H1.4 — The alarm-tick sequence: assemble current GoalState, * evaluate active stage done-criteria predica…
Checkpoint.Test
/** * Tests for CheckpointEngine (H1.1 + H1.4). * * Proves: * - scripted fake stage results drive fail_streak to EXA…
Client
import type { CfEnvelope, CfError, Env } from "../types"; import { CloudflareApiError } from "../types"; /** * Host-si…
Codegen
/** * Golden goal: codegen — multi-stage code-generation goal. * * All stages pass done-criteria; the goal completes …
Compactor
/** * H4.5 — Compactor: summarize raw working context into semantic MemoryRecords. * * compactStage(goal_id, stage_id…
Compactor.Test
/** * Compactor tests (H4.5). * * Proves: * - Compactor output records all validate against memory-record.schema.j…
Conf Monitor
/** * H3.5 — Confidence Monitor: every assistant turn must include conf ∈ [0,1] * (schema-enforced; extract from a tra…
Conf Monitor.Test
/** * Tests for conf-monitor (H3.5). * * Proves: * - extractConf finds trailing JSON line `{"conf": 0.8}` in assista…
Confidence Calibrator
/** P5 — Brier-score confidence calibration over (stated confidence, outcome) pairs. */ import type { Escalation } from…
Config
/** Harness configuration — one section per loop. */ import type { ToolExecutionMode } from "@earendil-works/pi-agent-c…
Consolidation
/** * Offline consolidation: Hippocampus -> Neocortex. * * This engine is intentionally not called from transformCont…
Consolidation.Test
import { describe, expect, test } from "bun:test"; import { ConsolidationEngine } from "../src/engines/consolidation.ts"…
Context Assembler
/** * H4.1 — Context Assembler. * * assembleContext({scope, goal_id, query, token_budget}): * 1. Query SemanticIndex…
Context Assembler.Test
/** * ContextAssembler tests (H4.1). * * Proves: * - Budget NEVER exceeded: table-driven over budgets {0, tiny, ex…
Contracts
/** * TypeScript mirrors of the 5 LOOM contracts (src/contracts/*.schema.json). * The JSON Schemas are the source of t…
Contracts.Test
import { describe, expect, test } from "bun:test"; import { parseContract, checkContract, isContractName } from "../src/…
Cybernetic Harness
/** * ADR-001 — Concentric Wrapper. One pi-agent Agent instance, four regulatory * layers attached through its hook su…
Data Pipeline
/** * Golden goal: data_pipeline — destructive step requires approval token (mint → verify path). * * Stages: * 1.…
Dataset Emitter
/** * H5.6 — Dataset Emitter. * * Exports (failure_pattern, root_cause_signature, successful_intervention) * tuples …
Dataset Emitter.Test
/** * Tests for H5.6 — Dataset Emitter. * * Proves: * - extractDatasetTuples extracts (failure_pattern, root_cause…
Db
import type { Env } from "../types"; /** * `db` namespace tools — generic SQL over the bound D1 database `env.DB`. * …
Decomposer
/** * H1.3 — Decompose a goal spec into a sequence of StageSpec[] via a single * model call. Each StageSpec is validat…
Decomposer.Test
/** * Tests for decomposer (H1.3). * * Proves: * - rejects non-machine-evaluable done_criteria with the specific vio…
Desideratum Gate
/** * ADR-004 — D1→D2→D3 enforced at runtime. Failed prerequisites put dependent * modules into degraded passthrough m…
Dispatch Archive
/** * dispatch-archive — THE single source of truth for the Dispatch Artifact Contract. * * Contract (see /home/mikes…
Dispatch Archive
/** * dispatch-archive — THE single source of truth for the Dispatch Artifact Contract. * * Contract (see /home/mikes…
Dispatch Archive.Test
/** * Structural proof of the Dispatch Artifact Contract across paths. * Asserts: on BOTH normal completion AND a SIGT…
Dispatch Archive.Test
/** * Structural proof of the Dispatch Artifact Contract across paths. * Asserts: on BOTH normal completion AND a SIGT…
Dispatch Scanner
import { Agent } from "@earendil-works/pi-agent-core"; import { getModel } from "@earendil-works/pi-ai"; import { Type }…
Dispatch Scanner V2
import { Agent } from "@earendil-works/pi-agent-core"; import { getModel } from "@earendil-works/pi-ai"; import { Type }…
Dispatch Scanner V3
import { Agent } from "@earendil-works/pi-agent-core"; import { getModel } from "@earendil-works/pi-ai"; import { Type }…
Dlq Escalator
/** * H2.4 — DLQ Escalator. * * Converts a dead letter into a Loop 1 escalation: * - builds typed escalation payload…
Dlq Escalator.Test
/** * Tests for DlqEscalator (H2.4). * * Proves: * - DLQ letter → escalation POST with correct payload (goal_id, sta…
Do
import { drizzle } from "drizzle-orm/d1"; import { goals } from "../db/schema"; import { parseContract } from "../lib/va…
Drift Detector
/** P3 — semantic drift between execution trajectory and original spec. */ import type { Escalation } from "../types/in…
Drift Sentinel
/** * H1.6 — Drift Sentinel: embed last N stage summaries, compare cosine distance * against the original_spec embeddi…
Drift Sentinel.Test
/** * Tests for DriftSentinel (H1.6). * * Proves: * - single spike does NOT raise sustained drift * - sustained div…
Drizzle.Config
import type { Config } from "drizzle-kit"; /** * Drizzle is the typed query layer over D1 (src/db/schema.ts). * Migra…
Enforcement.Test
/** * Unit tests for the enforcement bridge: classifySkill, buildArtifact, emitArtifact. * Tests deterministic mapping…
Entropy Monitor
/** P6 — channel capacity tracking: context utilization, query/source entropy. */ import { estimateTokens, extractText,…
Entropy Monitors
/** * H5.4 — Entropy Monitors. * * Queries entropy H(q) (dispatch outcome entropy) and H(s) (source/variety_class * …
Entropy Monitors.Test
/** * Tests for H5.4 — Entropy Monitors. * * Proves: * - Shannon entropy computed correctly with natural log (hand…
Env
/** * Worker environment bindings for codemode-gateway. * * `LOADER` is the `worker_loaders` binding used by `Dynamic…
Env
import type { DispatchEnvelope } from "./contracts"; /** Worker bindings — must match wrangler.jsonc exactly. */ export…
Envelope Compiler
/** * H2.2 + H2.3 — Envelope Compiler. * * compile(stage, mode, opts): DispatchEnvelope * - Tool allowlist: only the…
Envelope Compiler.Test
/** * Tests for EnvelopeCompiler (H2.2 + H2.3). * * Proves: * - compiled envelope validates against dispatch-envelop…
Episodic Store
/** Episodic memory — raw traces with deterministic term-overlap retrieval. */ import type { InteractionTrace } from ".…
Errors
/** Typed error hierarchy — never throw bare Error, never swallow. */ export abstract class LoomError extends Error { …
Escalation Ledger
/** * H1.4 — Escalation ledger for per-stage fail_streak persistence and * escalation records. Append-only records are…
Escalation Ledger.Test
/** * Tests for EscalationLedger (H1.4). * * Proves: * - fail_streak increment/reset * - escalation records append-…
Execute
/** * HTTP request/response contracts for `POST /execute`. * * These are the gateway's own wire types and are intenti…
Execution
/** * Execution harness types — Loop 3: model client, monitors, stage result. * All new execution types go here; barre…
Exit Matrix
/** * Exit-code retry matrix — maps process outcomes to verdicts. * * Bug fixed: executor exit -1 previously could re…
Exit Matrix
/** * Exit-code retry matrix — maps process outcomes to verdicts. * * Bug fixed: executor exit -1 previously could re…
Exit Matrix.Test
import { describe, test, expect } from "bun:test"; import { exitToVerdict, isRetryable, canBeDone, retryBackoffMs } from…
Exit Matrix.Test
import { describe, test, expect } from "bun:test"; import { exitToVerdict, isRetryable, canBeDone, retryBackoffMs } from…
Exporter
/** * exporter.ts — emits enforcement artifacts to a file-based queue. * * Callable from MetaEngine.consolidateLesson…
Failure Clusterer
/** * H5.1 — Failure Clusterer. * * Groups trace failures by (tool, normalized error signature, variety_class). * Er…
Failure Clusterer.Test
/** * Tests for H5.1 — Failure Clusterer. * * Proves: * - normalizeErrorSignature strips ids, paths, numbers deter…
Fakes
/** * Shared fake implementations for LOOM E2E tests. * * Consolidates patterns from: * tests/orchestrator/checkpo…
Fixtures
/** Shared deterministic test fixtures — mock the LLM, never the hooks. */ import { createAssistantMessageEventStream }…
Fixtures
/** * Synthetic trace corpus for Loop 5 synthesis tests. * ~50 enriched trace events covering failures, successes, rep…
Gate Analyzer
/** * gate-analyzer — preflight gate complexity review. * * Runs on EVERY dispatch after spec lint, before the execut…
Gate Analyzer
/** * gate-analyzer — preflight gate complexity review. * * Runs on EVERY dispatch after spec lint, before the execut…
Gate Analyzer.Test
import { describe, expect, test, mock, beforeEach } from "bun:test"; import type { DispatchSpec, ValidationCmd, GateAnal…
Gate Analyzer.Test
import { describe, expect, test, mock, beforeEach } from "bun:test"; import type { DispatchSpec, ValidationCmd, GateAnal…
Gate Escalation
/** * gate-escalation — consecutive-failure tracking and diagnostic interrogation. * * When the same validation gate …
Gate Escalation
/** * gate-escalation — consecutive-failure tracking and diagnostic interrogation. * * When the same validation gate …
Gate Escalation.Test
import { describe, expect, test } from "bun:test"; import { GateEscalationTracker, buildDiagnosticPrompt, parseDia…
Gate Escalation.Test
import { describe, expect, test } from "bun:test"; import { GateEscalationTracker, buildDiagnosticPrompt, parseDia…
Gate Integrity
/** * gate-integrity.ts — Layer 1 runtime enforcement (A13 / N15 / N16). * * Verifies a spec's pinned gate reference …
Gate Integrity
/** * gate-integrity.ts — Layer 1 runtime enforcement (A13 / N15 / N16). * * Verifies a spec's pinned gate reference …
Gate Integrity
/** * gate-integrity.ts — Layer 1 runtime enforcement (A13 / N15 / N16). * * Verifies a spec's pinned gate reference …
Gate Packs
import { existsSync, readFileSync, statSync } from "node:fs"; import { join, resolve } from "node:path"; import type { V…
Gate Packs
import { existsSync, readFileSync, statSync } from "node:fs"; import { join, resolve } from "node:path"; import type { V…
Gate Packs.Test
import { describe, test, expect } from "bun:test"; import { loadGatePack, resolvePackValidation, staleDigestGuard,…
Gate Packs.Test
import { describe, test, expect } from "bun:test"; import { loadGatePack, resolvePackValidation, staleDigestGuard,…
Gates
import { createHash } from "node:crypto"; import { GateHaltError, type HaltReason, type ValidationCmd } from "./types.js…
Gates
import { createHash } from "node:crypto"; import { GateHaltError, type HaltReason, type ValidationCmd } from "./types.js…
Gates.Test
import { describe, expect, test } from "bun:test"; import { BudgetGovernor, LoopDetector, actionHash, canonicalJ…
Gates.Test
import { describe, expect, test } from "bun:test"; import { BudgetGovernor, LoopDetector, actionHash, canonicalJ…
Gear Shifter
/** * Loop 4 — GearShifter. Deterministic memory router (ADR-005..009). * Preserves the MemoryEngine hook surface whil…
Gear Shifter.Test
import { describe, expect, test } from "bun:test"; import type { AgentMessage } from "@earendil-works/pi-agent-core"; im…
Goal State
/** Loop 1 — goal homeostasis types (P3). */ export type GoalItemStatus = "pending" | "active" | "complete" | "failed";…
Golden Runner
/** * E2E Golden Runner — in-process composition root for LOOM integration tests. * * Wires Loop 1 (CheckpointEngine,…
Golden.Test
/** * E2E Golden Goal Tests. * * Runs all three golden goals end-to-end through all LOOM loops. * Each asserts: * …
Harness
/** * H3 — Harness: runStage(envelope, modelCaller, deps): Promise<StageResult> * composing all monitors around the to…
Harness.Test
/** * End-to-end: real Agent, real hooks, mock LLM (scripted streamFn). * Verifies the concentric wrapper against pi-a…
Harness.Test
/** * Integration tests for harness (runStage). * * Proves every StageTermination kind is reachable: * DONE | GATE_R…
Helpers
/** * Test helpers for memory module tests. * * Provides: * - FakeD1: in-memory SQLite (bun:sqlite) implementing D…
Hmac
/** * HMAC utilities shared by Loop 1 (token-mint) and Loop 3 (reversibility-gate). * WebCrypto only — workerd-compati…
Ids
/** * Identity + hashing primitives shared by every loop. * Web Crypto only — identical behavior on workerd and Bun (H…
Ids.Test
import { describe, expect, test } from "bun:test"; import { actionHash, canonicalJSON, dispatchId, newEventId, newGoalId…
Import Lesson
/** * import-lesson.ts — reads enforcement artifacts from pi-cybernetic's file-based * queue and applies them to loom-…
Import Lesson
/** * import-lesson.ts — reads enforcement artifacts from pi-cybernetic's file-based * queue and applies them to loom-…
Import Lesson.Test
/** * Tests for import-lesson.ts — the bridge from pi-cybernetic enforcement * artifacts to loom-builder's gate govern…
Import Lesson.Test
/** * Tests for import-lesson.ts — the bridge from pi-cybernetic enforcement * artifacts to loom-builder's gate govern…
Index
export * from "./types/index.ts"; export * from "./monitors/index.ts"; export * from "./storage/index.ts"; export * from…
Index
/** * Enforcement artifact types — the bridge from pi-cybernetic Loop-5 lessons to * loom-builder gate enforcement art…
Index
export * from "./goal-state.ts"; export * from "./metrics.ts"; export * from "./tool-registry.ts"; export * from "./memo…
Index
export * from "./cybernetic-harness.ts"; export * from "./desideratum-gate.ts"; export * from "./ladders.ts";
Index
export * from "./episodic-store.ts"; export * from "./semantic-store.ts"; export * from "./procedural-store.ts"; export …
Index
export * from "./management.ts"; export * from "./strategic.ts"; export * from "./memory.ts"; export * from "./gear-shif…
Index
export * from "./loop-detector.ts"; export * from "./confidence-calibrator.ts"; export * from "./drift-detector.ts"; exp…
Index
console.log("Hello via Bun!");
Index
console.log("Hello via Bun!");
Index
import { DynamicWorkerExecutor } from "@cloudflare/codemode"; import type { Env, ErrorResponse, ExecuteRequest, …
Index
/** * Barrel export for gateway-local types. */ export type { Env } from "./env"; export type { ExecuteRequest, Ex…
Index
/** Barrel for golden goal scripts. */ export { script as codegenScript, assert as assertCodegen } from "./codegen"; ex…
Index
import { drizzle } from "drizzle-orm/d1"; import { dispatches, traceEvents } from "./db/schema"; import { checkContract,…
Index
/** * Loop 5 — Synthesis batch glue. * * Thin scheduled() handler that wires injectables from the worker's Env * int…
Index
/** * Loop 2 dispatcher — thin worker-side barrel + concrete wire-ups. * * All logic lives in src/dispatcher/core/ (p…
Index
/** * Loop 4 — Memory Service: thin worker shell. * * Factory: pick VectorizeIndex when env.SEMANTIC binding present,…
Index
/** Barrel — import all LOOM types from "@/types" or relative "../types". */ export * from "./contracts"; export * from …
Index
/** * Barrel — all core orchestration classes and types. */ export { type PredicateEvaluation, evaluatePredicate, eva…
Isolation.Test
/** * Isolation test for src/synthesis/. * * Enforces at the grep level: * 1. No import from src/orchestrator/, sr…
Ladders
/** * Model escalation ladders — P2 variety expansion. * A ladder is an ordered list of rungs with strictly increasing…
Live Run
/** * Live-wire smoke run: real opencode-go model through the full 5-loop harness. * * set -a && source /home/mikes…
Logger
/** * Structured logger. The single sanctioned sink for log output — * bare console.log in logic paths is a lint-level…
Loop Detector
/** P5 — action-sequence loop detection over a sliding window. */ import type { Escalation } from "../types/index.ts"; …
Loop Detector
/** * H3.2 — Loop Detector: actionHash(tool, args) via src/lib/ids.ts; * ring buffer W=10; ≥3 identical in window → HA…
Loop Detector.Test
/** * Tests for loop-detector (H3.2). * * Proves: * - the identical action halts at exactly the 3rd occurrence (not …
Management
/** * Loop 2 — ManagementEngine. Variety allocator + feedback enforcer (P1, P2, P4). * Attaches via beforeToolCall (di…
Management.Test
import { describe, expect, test } from "bun:test"; import { ManagementEngine } from "../src/engines/management.ts"; impo…
Memory
/** Loop 4 — three-level memory hierarchy types (P6). */ export interface InteractionTrace { id: string; kind: "too…
Memory
/** * Loop 4 — MemoryEngine. Channel-capacity manager (P6). * Attaches via transformContext (entropy gate) and convert…
Memory
/** * Memory service types — Loop 4. * * Injectables: BlobStore, SemanticIndex, Clock, TokenCounter. * D1DatabaseLik…
Memory.Test
import { describe, expect, test } from "bun:test"; import type { AgentMessage } from "@earendil-works/pi-agent-core"; im…
Messages
/** * ADR-003 — inter-loop communication as custom AgentMessage types via * declaration merging. Carried in the transc…
Meta
/** * Loop 5 — MetaEngine. Second-order regulator (P5): watches the regulators, * extracts failure patterns, revises c…
Meta.Test
import { describe, expect, test } from "bun:test"; import { ManagementEngine } from "../src/engines/management.ts"; impo…
Metrics
/** Cross-loop metric, escalation, and meta-learning types. */ export type LoopId = "strategic" | "management" | "execu…
Mode Registry
/** * H2.1 — D1-backed mode registry. * * selectMode(variety_class) picks the mode with highest success rate for that…
Mode Registry.Test
/** * Tests for ModeRegistry (H2.1). * * Proves: * - unknown variety_class → highest-capability mode + variety_defic…
Model Client
/** * H3.0 — Fetch-based Anthropic Messages API client. * workerd-compatible: plain fetch, NO node SDK, no node:* impo…
Model Client.Test
/** * Tests for model-client (H3.0). * * Proves: * - createAnthropicModelCaller returns a callable ModelCaller * - …
Model Router
import { existsSync, readFileSync } from "node:fs"; import { resolve } from "node:path"; import type { DispatchSpec, Mod…
Model Router
import { existsSync, readFileSync } from "node:fs"; import { resolve } from "node:path"; import type { DispatchSpec, Mod…
Model Router.Test
import { describe, expect, test } from "bun:test"; import { PreFlightError } from "./preflight.js"; import { routeModelF…
Model Router.Test
import { describe, expect, test } from "bun:test"; import { PreFlightError } from "./preflight.js"; import { routeModelF…
Monitors.Test
import { describe, expect, test } from "bun:test"; import { LoopDetector } from "../src/monitors/loop-detector.ts"; impo…
No Silent Failure.Test
/** * No-Silent-Failure Invariant Walk. * * For EVERY terminated (non-DONE) stage across all golden runs + chaos runs…
Outcome
import type { DispatchOutcome } from "./types.js"; export type DispatchStatus = DispatchOutcome["status"]; export func…
Outcome
import type { DispatchOutcome } from "./types.js"; export type DispatchStatus = DispatchOutcome["status"]; export func…
Outcome.Test
import { describe, expect, test } from "bun:test"; import { normalizeMaxReformulations, settleStatusAfterValidation, val…
Outcome.Test
import { describe, expect, test } from "bun:test"; import { normalizeMaxReformulations, settleStatusAfterValidation, val…
Parity Check
#!/usr/bin/env bun /** * Parity Check — byte-stable decision log for LOOM monitor decision path. * * Replays a script…
Parse
/** * Parse-don't-validate helpers for tool argument parsing. * * Each helper throws a plain `Error` with a `"<tool>:…
Performance Log
/** Loop 5 raw data — structured event log for pattern analysis. */ export interface ToolExecutionRecord { toolName: …
Pi Executable
import { existsSync } from "node:fs"; export interface PiExecutableCheck { ok: boolean; path: string; reason: str…
Pi Executable
import { existsSync } from "node:fs"; export interface PiExecutableCheck { ok: boolean; path: string; reason: str…
Pi Executable.Test
import { afterEach, describe, expect, test } from "bun:test"; import { mkdtempSync, rmSync, writeFileSync } from "node:f…
Pi Executable.Test
import { afterEach, describe, expect, test } from "bun:test"; import { mkdtempSync, rmSync, writeFileSync } from "node:f…
Pointer Hierarchy
/** * H4.4 — Pointer Hierarchy. * * topic → summary → episodic_ref (R2 key). * * memoryExpand(record_id): resolve e…
Pointer Hierarchy.Test
/** * PointerHierarchy tests (H4.4). * * Proves: * - memory_expand round-trips: put full text in fake BlobStore → …
Predicates
/** * H1.1 — Predicate evaluators for the six machine-evaluable predicate kinds. * * Each takes a Predicate spec + an…
Predicates.Test
/** * Tests for predicate evaluators (H1.1). * All six kinds: pass + fail cases each. * Injects a scripted PredicateR…
Preflight
import { readFileSync } from "node:fs"; import { globSync } from "glob"; import { resolve, relative } from "node:path"; …
Preflight
import { readFileSync } from "node:fs"; import { globSync } from "glob"; import { resolve, relative } from "node:path"; …
Preflight
/** * H3.7 — Preflight: before any recoverable|destructive action, scan a provided * list of staged file contents for …
Preflight Cli
/** * Pre-flight CLI: estimate tokens for a spec and exit non-zero if too large. * Usage: bun run src/preflight-cli.ts…
Preflight Cli
/** * Pre-flight CLI: estimate tokens for a spec and exit non-zero if too large. * Usage: bun run src/preflight-cli.ts…
Preflight.Test
/** * Tests for token-cliff gate: pre-flight estimate, runtime ceiling, chain awareness. */ import { describe, test, e…
Preflight.Test
/** * Tests for token-cliff gate: pre-flight estimate, runtime ceiling, chain awareness. */ import { describe, test, e…
Preflight.Test
/** * Tests for preflight (H3.7). * * Proves: * - clean files (no markers) pass * - every marker (TODO, FIXME, <<<<…
Probe Planner
/** * H2.5 — Probe Planner. * * For stages with variety_class === "api_integration" AND no management-scope * behavi…
Probe Planner.Test
/** * Tests for ProbePlanner (H2.5). * * Proves: * - api_integration + no behavior model → probe prepended (recovera…
Procedural Store
/** Procedural memory — verified skills + working memory (active hypotheses). */ import type { ActiveHypothesis, Eviden…
Promotion Engine
/** * H4.2 — Promotion Engine. * * episodic → semantic: when a pattern recurs across ≥ m_promote distinct traces. * …
Promotion Engine.Test
/** * PromotionEngine tests (H4.2). * * Proves: * - Promotion fires at EXACTLY m_promote distinct traces (not m-1;…
Purpose
import type { DispatchSpec } from "./types.js"; export const PURPOSE_HEADER = "## PURPOSE (INVARIANT — restated verbati…
Purpose
import type { DispatchSpec } from "./types.js"; export const PURPOSE_HEADER = "## PURPOSE (INVARIANT — restated verbati…
Purpose.Test
import { describe, expect, test } from "bun:test"; import { injectPurpose, purposeBlock } from "./purpose.js"; describe…
Purpose.Test
import { describe, expect, test } from "bun:test"; import { injectPurpose, purposeBlock } from "./purpose.js"; describe…
Registry
import { DynamicWorkerExecutor, type ResolvedProvider } from "@cloudflare/codemode"; import type { Env, ToolDef, T…
Registry
import type { Env } from "./env"; /** * Tool registry types. The registry (`src/registry.ts`) is the single source * …
Registry Seed
/** * Seed data for the mode_registry D1 table. * * Three modes covering the spec's default model set, with typed see…
Registry Updater
/** * H5.3 — Registry Updater. * * Recomputes mode_registry success_n / fail_n / avg_cost_tokens per * (mode, variet…
Registry Updater.Test
/** * Tests for H5.3 — Registry Updater. * * Proves: * - computeModeStats groups correctly by (model, harnessProfi…
Reinjector
/** * H3.4 — Reinjector: normalize observations. Truncate to per-tool obs_cap_tokens * from the envelope; store full t…
Reinjector.Test
/** * Tests for reinjector (H3.4). * * Proves: * - normalizeObservation truncates content exceeding obs_cap_tokens …
Report
/** * Synthesis Report Assembler. * * Orchestrates all Loop 5 monitors (H5.1–H5.6) into a single SynthesisReport: * …
Report.Test
/** * Integration test for the full synthesis report pipeline. * * Proves: * - Synthetic trace corpus → determinis…
Research
/** * Golden goal: research — mid-goal failing stage drives fail_streak to m=3 → REFORMULATE → recovers → completes. *…
Retry
import { RetryExhaustedError } from "../types/errors"; /** * Exponential backoff with FULL jitter (HC-6): delay = rand…
Retry.Test
import { describe, expect, test } from "bun:test"; import { withRetry } from "../src/lib/retry"; import { RetryExhausted…
Reversibility Gate
/** * H3.3 — Reversibility Gate: every tool call checked against the envelope * allowlist. Each allowlist entry has re…
Reversibility Gate.Test
/** * Tests for reversibility-gate (H3.3). * * Proves: * - allowlist lookup accepts allowed tools and denies unknown…
Revision Governor
/** * H5.5 — Revision Governor. * * Hard caps on skill proposals per window (tunable, default 5). * Tunable-paramete…
Revision Governor.Test
/** * Tests for H5.5 — Revision Governor. * * Proves: * - Caps proposals at maxSkillProposals (default 5) * - N…
Run
/** * loom-builder — homeostatic dispatch harness. * Runs one DispatchSpec: agent loop (pi-coding-agent SDK) under har…
Run
/** * loom-builder — homeostatic dispatch harness. * Runs one DispatchSpec: agent loop (pi-coding-agent SDK) under har…
Schema
import { sqliteTable, text, integer, index } from "drizzle-orm/sqlite-core"; /** * 7-table D1 schema — mirrors LOOM-SP…
Scope Wall
/** * H4.3 — Scope Wall. * * All reads/writes carry a required scope. Default read path filters to the * caller's sc…
Scope Wall.Test
/** * ScopeWall tests (H4.3). * * Proves: * - Same-scope read works (constructor requires scope) * - Cross-scop…
Scrape
import type { Env } from "../types"; /** * `scrape` namespace tools — convenience persistence over the bound D1 * dat…
Semantic Index
/** * H4.6 — SemanticIndex: search abstraction with two implementations. * * VectorizeIndex — wraps Cloudflare Vecto…
Semantic Index.Test
/** * SemanticIndex contract test suite. * * Shared tests run against BOTH Fts5Index (with fake D1/SQLite) and * Vec…
Semantic Store
/** Semantic memory — compressed summaries + entity-relation tuples, with promotion. */ import type { CompressedSummary…
Skill Proposer
/** * H5.2 — Skill Proposer. * * Detects recurring successful sub-sequences across ≥ N distinct goals * (tunable, de…
Skill Proposer.Test
/** * Tests for H5.2 — Skill Proposer. * * Proves: * - extractSuccessfulSequences groups tool calls by dispatch *…
Snippet
/** * Snippet store types. A snippet is a saved, named sandbox script — the * gateway's "procedural memory". Stored as…
Spec Lint
/** * Spec-schema lint — validates DispatchSpec at preflight before dispatch. * * Checks: * - Unknown top-level keys…
Spec Lint
/** * Spec-schema lint — validates DispatchSpec at preflight before dispatch. * * Checks: * - Unknown top-level keys…
Store
import { normalizeCode } from "@cloudflare/codemode"; import type { Env, Snippet, SnippetSummary } from "../types"; /**…
Strategic
/** * Loop 1 — StrategicEngine. Homeostatic regulator over Ω_goal (P3, P5). * * pi-agent-core 0.79 exposes `shouldSto…
Strategic.Test
import { describe, expect, test } from "bun:test"; import type { AgentMessage } from "@earendil-works/pi-agent-core"; im…
Synthesis
/** * Loop 5 synthesis types — report shapes, interfaces, contract-style types. * * All Loop 5 outputs are typed here…
Token Mint
/** * H1.5 — HMAC single-use, stage-scoped, TTL'd approval tokens for destructive * actions. WebCrypto only. * * Tok…
Token Mint.Test
/** * Tests for TokenMint (H1.5). * * Proves: * - mint → Loop 3 verify passes (round-trip) * - expired tokens fail …
Tool Registry
/** Loop 2 — variety + reversibility registries (P2, P4). */ export type Reversibility = "read" | "recoverable" | "dest…
Tools
import type { CfEnvelope, CfError, D1Database, Env, KvNamespace } from "../types"; import { CloudflareApiError } from ".…
Trace
import { appendFileSync, mkdirSync } from "node:fs"; import { dirname } from "node:path"; import type { TraceEvent } fro…
Trace
import { appendFileSync, mkdirSync } from "node:fs"; import { dirname } from "node:path"; import type { TraceEvent } fro…
Types
/** Contract types for loom-builder dispatches. */ export interface ModelRef { provider: string; id: string; } exp…
Types
/** Contract types for loom-builder dispatches. */ export interface ModelRef { provider: string; id: string; } exp…
Types
/** * Injectable interfaces for the Loop 2 dispatcher core. * * Every dependency is an interface so tests inject fake…
Types
/** * Injectable interfaces for LOOM Loop 1 orchestration core. * Every dependency is an interface so tests can inject…
Util
/** Deterministic shared helpers — no LLM reasoning, no randomness beyond ids. */ let idCounter = 0; export function n…
Util
/** * Implementations for the `util` namespace: `util.echo(x)`, `util.now()`, * `util.rand()`. Contains only trivial, …
Validate
import { Ajv, type ValidateFunction } from "ajv"; import addFormats from "ajv-formats"; import { ContractViolationError …