feat(cloud-agent): event-driven agent host + message-first CLI by SarkarShubhdeep · Pull Request #1 · mieweb/cloud

SarkarShubhdeep · 2026-07-01T01:13:40Z

Summary

Adds @mieweb/cloud-agent and @mieweb/cloud-agent-cli — the L2 event shell that binds an AgentDefinition + AgentRuntime to a Durable Object with queue-driven turns, suspend/resume, and alarms.

Developed and exercised by the Jerry project (Phase 1 MVP) via the vendor/cloud submodule pin at ecb8aa7.

`@mieweb/cloud-agent`

hostAgent() — returns SessionClass, handleFetch, handleQueue, and optional handleScheduled
Session DO: one instance per session key; drains TurnJob messages one at a time
Storage layer: sessions, events, messages, activity_events, summaries (D1/SQLite via CloudDatabase)
createTools(ctx) factory — optional per-turn tool injection (used by Jerry for DB/vector/alarm-bound tools)
POST /v1/sessions/:id/messages runs turns synchronously for --call CLI ergonomics; /enqueue keeps the async path

`@mieweb/cloud-agent-cli`

Message-first dispatcher: --call (streaming fetch), -txt / --put (fire-and-forget enqueue)
Agent identity from basename(argv[0]); agent-specific packages (jerry, etc.) wrap with config
Parse tests + HTTP client

Jerry consumer

Jerry repo	Detail
Submodule pin	`vendor/cloud` @ `ecb8aa7` on `development`
Consumer	`packages/jerry-app` uses `hostAgent()` + `createJerryTools`
CLI	`packages/cli` thin wrapper over `@mieweb/cloud-agent-cli`

Commits

c154c39 — initial cloud-agent + cloud-agent-cli packages
ecb8aa7 — synchronous --call turns; createTools injection; profile passthrough

Test plan

storage.test.ts — schema init, session/event/message CRUD
parse.test.ts — CLI flag/message parsing
Jerry integration on local target (pnpm dev + jerry --call …)
Conformance on mieweb (libSQL + Valkey + MinIO) — tracked in Jerry Phase 1

Made with Cursor

- Add @mieweb/cloud-agent with hostAgent() API - Session DO for queue-driven turns, suspend/resume, alarms - Storage module for sessions, events, messages, activity_events, summaries - Add @mieweb/cloud-agent-cli with message-first dispatcher - Support --call (streaming) and -txt/--put (fire-and-forget) modes - Update README with new packages Co-authored-by: Cursor <cursoragent@cursor.com>

…a createTools POST /messages now executes the turn inline instead of only enqueueing, and hostAgent accepts an optional createTools(ctx) factory so agents like Jerry can bind runtime tools with DB/vector/alarm context. Co-authored-by: Cursor <cursoragent@cursor.com>

Document the feature/cloud-agent PR opened on mieweb/cloud and track Jerry's vendor/cloud pin (ecb8aa7) in phase-1 plan, README, and chat10. Co-authored-by: Cursor <cursoragent@cursor.com>

wreiske · 2026-07-01T19:43:25Z

fix broken CI failures
resolve any open copilot code review comments
add a video on the PR description showing what this is doing, why, who's going to use it, etc.

wreiske · 2026-07-01T19:45:53Z

+export async function initSchema(db: CloudDatabase): Promise<void> {
+  await db.exec(`
+    CREATE TABLE IF NOT EXISTS sessions (
+      id TEXT PRIMARY KEY,
+      user_id TEXT,
+      status TEXT NOT NULL DEFAULT 'idle',
+      conversation_id TEXT,
+      continuation TEXT,
+      created_at TEXT NOT NULL,
+      updated_at TEXT NOT NULL
+    );
+
+    CREATE TABLE IF NOT EXISTS events (
+      id TEXT PRIMARY KEY,
+      session_id TEXT NOT NULL,


I'm wondering if this should be using https://orm.drizzle.team/

Take a look and see if this makes more sense. it might be more of a mieweb/cloud thing that we should support drizzle.

Copilot

Pull request overview

This PR introduces an event-driven “agent host” package (@mieweb/cloud-agent) that wires an AgentDefinition + AgentRuntime into a Durable Object with queue-driven turns, plus a message-first CLI dispatcher package (@mieweb/cloud-agent-cli) for synchronous --call and async enqueue usage.

Changes:

Added @mieweb/cloud-agent host wiring (hostAgent, session DO) and a D1/SQLite-compatible storage layer with initial tests.
Added @mieweb/cloud-agent-cli with argument parsing, HTTP client (streaming-or-JSON), and a generic bin dispatcher.
Updated the packages README to document the new packages.

Reviewed changes

Copilot reviewed 15 out of 16 changed files in this pull request and generated 8 comments.

Show a summary per file

File	Description
packages/README.md	Documents the new `cloud-agent` and `cloud-agent-cli` packages in the monorepo index.
packages/cloud-agent/src/types.ts	Defines host/session/storage/runtime types for the agent host.
packages/cloud-agent/src/storage.ts	Implements schema init + CRUD helpers for sessions/events/messages/activity/summaries.
packages/cloud-agent/src/storage.test.ts	Adds basic tests for storage helpers using a mock DB.
packages/cloud-agent/src/session.ts	Implements the session Durable Object turn lifecycle, suspend/resume, and alarm handling.
packages/cloud-agent/src/index.ts	Public exports for the cloud-agent package.
packages/cloud-agent/src/host.ts	Worker wiring: HTTP routes (`/v1/sessions/...`) + queue forwarding into the session DO.
packages/cloud-agent/package.json	Declares the new `@mieweb/cloud-agent` package metadata/exports/scripts.
packages/cloud-agent-cli/src/types.ts	Defines CLI config/options and streamed event types.
packages/cloud-agent-cli/src/run.ts	Implements CLI command dispatch and help/version output.
packages/cloud-agent-cli/src/parse.ts	Implements message-first CLI argument parsing.
packages/cloud-agent-cli/src/parse.test.ts	Adds tests for CLI parsing behavior.
packages/cloud-agent-cli/src/index.ts	Public exports for the cloud-agent-cli package.
packages/cloud-agent-cli/src/client.ts	Implements HTTP client for `/messages` (call) and `/enqueue` (put).
packages/cloud-agent-cli/package.json	Declares the new `@mieweb/cloud-agent-cli` package metadata/bin/scripts.
packages/cloud-agent-cli/bin/agent-cli.js	Adds a generic agent CLI bin entrypoint.

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

Add lockfile entries for @types/node@^20.0.0 in cloud-agent and cloud-agent-cli so CI pnpm install --frozen-lockfile succeeds. Co-authored-by: Cursor <cursoragent@cursor.com>

Tests use `node --import tsx` but tsx was not declared, causing CI unit job failures on a clean install. Co-authored-by: Cursor <cursoragent@cursor.com>

SarkarShubhdeep · 2026-07-02T15:28:15Z

✅ `mieweb` conformance verified (libSQL + Valkey + MinIO)

Ran the conformance checklist item locally against the real @mieweb/cloud-os docker stack — no changes to vendor/cloud required.

Infrastructure (`pnpm --filter @mieweb/cloud-os infra:up`)

libSQL (:8080), MinIO (:9000), Valkey (:6379) — all healthy.

1. Adapter conformance (`pnpm --filter @mieweb/cloud-os test`)

Contract	Backend	Result
D1	libSQL	✅ pass
Vectorize	libsql-vec	✅ pass
R2	MinIO (S3)	✅ pass
KV	Valkey	✅ pass
Queue	valkey-queue	✅ pass

5/5 passed.

2. Jerry on `mieweb` target (`mieweb --target mieweb dev`)

Check	Binding exercised	Result
`GET /health`	worker on mieweb target	✅ pass
`GET /v1/sessions/:id/status`	libSQL + inproc DO	✅ pass
`POST /v1/events`	libSQL (`activity_events`)	✅ pass
`POST /v1/sessions/:id/enqueue`	Valkey queue + DO	✅ pass
session alive after queue turn	queue consumer	✅ pass

Persistence confirmed in libSQL: sessions = 2 rows, activity_events = 2 rows.

Note

Full end-to-end agent turns (jerry --call … / sync /messages) require a running Ollama (:11434), which is application-level and outside target/infra conformance. The DB / KV / queue / object-storage contracts all pass on the mieweb backends.

CI status on the branch: unit ✅ + conformance ✅ (after the lockfile + tsx devDependency fixes).

Copilot

Pull request overview

Copilot reviewed 15 out of 17 changed files in this pull request and generated 8 comments.

Files not reviewed (1)

pnpm-lock.yaml: Generated file

- Forward profile and userId through the /enqueue path into TurnJob so async turns honor the per-request privacy profile. - Persist the enqueued user message and status transitions inside handleTurn so queued turns actually consume the new message; slim handleMessage to delegate and avoid double-inserts. - Reset session status to idle (and log an error event) when a turn throws, preventing sessions from getting stuck in "running". - Retry failed/exception queue jobs instead of ack-ing them so transient failures are not dropped permanently. Co-authored-by: Cursor <cursoragent@cursor.com>

- alarm(): create the scheduled_wake event first and reuse its eventId for the queued wake job, and only delete alarm_payload after JOBS.send() succeeds so a failed enqueue can be retried. - insertEvent(): only store NULL when payload is undefined, so falsy payloads (0, false, "") are persisted instead of silently dropped. Co-authored-by: Cursor <cursoragent@cursor.com>

SarkarShubhdeep and others added 2 commits June 30, 2026 16:49

SarkarShubhdeep added this to Scrum Team Jerry Jul 1, 2026

SarkarShubhdeep moved this to Review in Scrum Team Jerry Jul 1, 2026

SarkarShubhdeep self-assigned this Jul 1, 2026

wreiske requested a review from Copilot July 1, 2026 19:38

Copilot started reviewing on behalf of wreiske July 1, 2026 19:38 View session

wreiske reviewed Jul 1, 2026

View reviewed changes

Copilot AI reviewed Jul 1, 2026

View reviewed changes

SarkarShubhdeep and others added 2 commits July 1, 2026 16:16

chore: update pnpm-lock.yaml to match package.json

054795c

Add lockfile entries for @types/node@^20.0.0 in cloud-agent and cloud-agent-cli so CI pnpm install --frozen-lockfile succeeds. Co-authored-by: Cursor <cursoragent@cursor.com>

fix: add tsx devDependency for cloud-agent test scripts

ed36546

Tests use `node --import tsx` but tsx was not declared, causing CI unit job failures on a clean install. Co-authored-by: Cursor <cursoragent@cursor.com>

SarkarShubhdeep requested a review from Copilot July 2, 2026 15:41

Copilot started reviewing on behalf of SarkarShubhdeep July 2, 2026 15:41 View session

Copilot AI reviewed Jul 2, 2026

View reviewed changes

SarkarShubhdeep and others added 2 commits July 2, 2026 11:55

Uh oh!

Conversation

SarkarShubhdeep commented Jul 1, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Summary

@mieweb/cloud-agent

@mieweb/cloud-agent-cli

Jerry consumer

Commits

Test plan

Uh oh!

wreiske commented Jul 1, 2026 • edited by SarkarShubhdeep Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

wreiske Jul 1, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI left a comment

Choose a reason for hiding this comment

Pull request overview

Reviewed changes

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

SarkarShubhdeep commented Jul 2, 2026

✅ mieweb conformance verified (libSQL + Valkey + MinIO)

Infrastructure (pnpm --filter @mieweb/cloud-os infra:up)

1. Adapter conformance (pnpm --filter @mieweb/cloud-os test)

2. Jerry on mieweb target (mieweb --target mieweb dev)

Note

Uh oh!

Copilot AI left a comment

Choose a reason for hiding this comment

Pull request overview

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

SarkarShubhdeep commented Jul 1, 2026 •

edited

Loading

`@mieweb/cloud-agent`

`@mieweb/cloud-agent-cli`

wreiske commented Jul 1, 2026 •

edited by SarkarShubhdeep

Loading

✅ `mieweb` conformance verified (libSQL + Valkey + MinIO)

Infrastructure (`pnpm --filter @mieweb/cloud-os infra:up`)

1. Adapter conformance (`pnpm --filter @mieweb/cloud-os test`)

2. Jerry on `mieweb` target (`mieweb --target mieweb dev`)