@@ -111,6 +129,12 @@ export function RunViewer({ runId, accessToken }: Props) {
{(latestStatus.usage.cacheReadTokens > 0) && ` (${latestStatus.usage.cacheReadTokens.toLocaleString()} cached)`}
)}
+ {isRunActive && (
+
+ )}
+ {cancelError &&
{cancelError}}
@@ -164,6 +188,22 @@ export function RunViewer({ runId, accessToken }: Props) {
const diffStatus = statusParts.find(s => s.type === "diff")
const pushedStatus = statusParts.find(s => s.type === "pushed")
+ if (run?.status === "CANCELED") {
+ return (
+
+ )
+ }
+
+ if (run?.status === "FAILED" || run?.status === "CRASHED" || run?.status === "SYSTEM_FAILURE") {
+ return (
+
+
Run failed ({run.status})
+
+ )
+ }
+
if (isComplete || run?.status === "COMPLETED") {
return (
From 65081e79344ccceada9ad9dee1c8e79d95915796 Mon Sep 17 00:00:00 2001
From: D-K-P <8297864+D-K-P@users.noreply.github.com>
Date: Sun, 11 Jan 2026 20:14:27 +0000
Subject: [PATCH 11/72] Generate PRD from prompt
---
background-ralph/src/trigger/ralph-loop.ts | 122 ++++++++++++++++++++-
background-ralph/src/trigger/streams.ts | 44 +++++++-
2 files changed, 164 insertions(+), 2 deletions(-)
diff --git a/background-ralph/src/trigger/ralph-loop.ts b/background-ralph/src/trigger/ralph-loop.ts
index c47bb7c..139a48c 100644
--- a/background-ralph/src/trigger/ralph-loop.ts
+++ b/background-ralph/src/trigger/ralph-loop.ts
@@ -6,7 +6,7 @@ import { promisify } from "util"
import { mkdtemp, rm, readFile } from "fs/promises"
import { tmpdir } from "os"
import { join } from "path"
-import { appendStatus, agentOutputStream, type TokenUsage } from "./streams"
+import { appendStatus, agentOutputStream, type TokenUsage, type Prd } from "./streams"
const execAsync = promisify(exec)
const anthropic = new Anthropic()
@@ -87,6 +87,106 @@ function parseGitHubUrl(repoUrl: string): { owner: string; repo: string } | null
return { owner: match[1], repo: match[2] }
}
+// Shallow exploration of repo structure (token-efficient)
+async function exploreRepo(repoPath: string): Promise
{
+ const parts: string[] = []
+
+ // Get directory structure (top 2 levels)
+ try {
+ const { stdout } = await execAsync(`find . -maxdepth 2 -type f | head -50`, { cwd: repoPath })
+ parts.push(`Files:\n${stdout}`)
+ } catch {
+ // Fallback to ls
+ try {
+ const { stdout } = await execAsync(`ls -la`, { cwd: repoPath })
+ parts.push(`Directory:\n${stdout}`)
+ } catch {
+ parts.push("Could not list files")
+ }
+ }
+
+ // Read package.json if exists
+ try {
+ const packageJson = await readFile(join(repoPath, "package.json"), "utf-8")
+ const pkg = JSON.parse(packageJson)
+ parts.push(`package.json:\n- name: ${pkg.name}\n- scripts: ${Object.keys(pkg.scripts || {}).join(", ")}\n- deps: ${Object.keys(pkg.dependencies || {}).join(", ")}`)
+ } catch {
+ // No package.json
+ }
+
+ // Read README first 50 lines if exists
+ try {
+ const readme = await readFile(join(repoPath, "README.md"), "utf-8")
+ const lines = readme.split("\n").slice(0, 50).join("\n")
+ parts.push(`README.md (first 50 lines):\n${lines}`)
+ } catch {
+ // No README
+ }
+
+ return parts.join("\n\n")
+}
+
+// Generate PRD from exploration + user prompt
+async function generatePrd(exploration: string, prompt: string, repoName: string): Promise {
+ const response = await anthropic.messages.create({
+ model: "claude-sonnet-4-20250514",
+ max_tokens: 2000,
+ messages: [
+ {
+ role: "user",
+ content: `You are generating a PRD (Product Requirements Document) for an autonomous coding agent.
+
+Repo exploration:
+${exploration}
+
+User task: ${prompt}
+
+Generate a PRD with 3-7 stories to accomplish this task. Each story should be small and focused.
+
+Output valid JSON only, no markdown fences:
+{
+ "name": "${repoName}",
+ "description": "brief description of the task",
+ "stories": [
+ {
+ "id": "US-001",
+ "title": "short title",
+ "acceptance": ["criterion 1", "criterion 2"],
+ "dependencies": []
+ }
+ ]
+}
+
+Rules:
+- Stories should be in dependency order (later stories can depend on earlier ones)
+- Each story should be completable in 1-3 agent iterations
+- Acceptance criteria should be verifiable
+- Use sequential IDs: US-001, US-002, etc.`,
+ },
+ ],
+ })
+
+ const text = response.content[0]
+ if (text.type !== "text") {
+ throw new Error("Failed to generate PRD: no text response")
+ }
+
+ try {
+ // Try to parse, handling potential markdown fences
+ let jsonStr = text.text.trim()
+ if (jsonStr.startsWith("```")) {
+ jsonStr = jsonStr.replace(/^```json?\n?/, "").replace(/\n?```$/, "")
+ }
+ const prd = JSON.parse(jsonStr) as Prd
+ // Ensure all stories start with passes: false
+ prd.stories = prd.stories.map(s => ({ ...s, passes: false }))
+ return prd
+ } catch (e) {
+ logger.error("Failed to parse PRD JSON", { text: text.text, error: e })
+ throw new Error("Failed to parse PRD: invalid JSON from Claude")
+ }
+}
+
async function summarizeChanges(diff: string): Promise {
const response = await anthropic.messages.create({
model: "claude-sonnet-4-20250514",
@@ -219,6 +319,26 @@ export const ralphLoop = task({
await appendStatus({ type: "cloned", message: `Cloned to ${repoPath}` })
try {
+ // Phase 1: Shallow exploration
+ await appendStatus({ type: "exploring", message: "Exploring repo structure..." })
+ const exploration = await exploreRepo(repoPath)
+ logger.info("Repo exploration complete", { explorationLength: exploration.length })
+
+ // Phase 2: Generate PRD
+ const parsed = parseGitHubUrl(repoUrl)
+ const repoName = parsed?.repo ?? "task"
+ const prd = await generatePrd(exploration, prompt, repoName)
+ logger.info("PRD generated", { stories: prd.stories.length })
+
+ await appendStatus({
+ type: "prd_generated",
+ message: `Generated PRD with ${prd.stories.length} stories`,
+ prd,
+ })
+
+ // TODO (US-011): Add waitpoint here for user to edit PRD
+ // For now, proceed directly to execution
+
// Run Claude Agent SDK loop with approval gates
await appendStatus({ type: "working", message: "Starting agent loop..." })
diff --git a/background-ralph/src/trigger/streams.ts b/background-ralph/src/trigger/streams.ts
index 4292c0b..779fc9a 100644
--- a/background-ralph/src/trigger/streams.ts
+++ b/background-ralph/src/trigger/streams.ts
@@ -8,9 +8,44 @@ export type TokenUsage = {
cacheCreationTokens: number
}
+// PRD story type (what Claude generates)
+export type PrdStory = {
+ id: string
+ title: string
+ acceptance: string[]
+ dependencies: string[]
+ passes?: boolean
+}
+
+export type Prd = {
+ name: string
+ description: string
+ stories: PrdStory[]
+}
+
// Status object type
export type StatusUpdate = {
- type: "cloning" | "cloned" | "working" | "iteration" | "diff" | "pushing" | "pushed" | "push_failed" | "complete" | "error" | "waitpoint" | "agent_complete" | "user_approved" | "tests_passed" | "tests_failed"
+ type:
+ | "cloning"
+ | "cloned"
+ | "exploring"
+ | "prd_generated"
+ | "prd_review"
+ | "working"
+ | "iteration"
+ | "story_start"
+ | "story_complete"
+ | "diff"
+ | "pushing"
+ | "pushed"
+ | "push_failed"
+ | "complete"
+ | "error"
+ | "waitpoint"
+ | "agent_complete"
+ | "user_approved"
+ | "tests_passed"
+ | "tests_failed"
message: string
iteration?: number
diff?: string
@@ -22,6 +57,13 @@ export type StatusUpdate = {
question: string
}
usage?: TokenUsage
+ prd?: Prd
+ story?: {
+ current: number
+ total: number
+ title: string
+ acceptance: string[]
+ }
}
// Status updates - use string stream with manual JSON serialization
From b6047888e6c93064e3afe0d7bdabf00352de3fea Mon Sep 17 00:00:00 2001
From: D-K-P <8297864+D-K-P@users.noreply.github.com>
Date: Sun, 11 Jan 2026 21:01:06 +0000
Subject: [PATCH 12/72] Story-by-story execution with yolo mode
---
background-ralph/src/app/actions.ts | 4 +-
background-ralph/src/components/ralph-app.tsx | 20 +-
.../src/components/run-viewer.tsx | 88 +++-
background-ralph/src/lib/schemas.ts | 2 +-
background-ralph/src/trigger/ralph-loop.ts | 412 +++++++++++-------
background-ralph/src/trigger/streams.ts | 1 +
6 files changed, 351 insertions(+), 176 deletions(-)
diff --git a/background-ralph/src/app/actions.ts b/background-ralph/src/app/actions.ts
index c3d5caf..555c676 100644
--- a/background-ralph/src/app/actions.ts
+++ b/background-ralph/src/app/actions.ts
@@ -28,7 +28,7 @@ export async function submitTask(
const raw = {
repoUrl: formData.get("repoUrl"),
prompt: formData.get("prompt"),
- pauseEvery: formData.get("pauseEvery") ?? "5",
+ yoloMode: formData.get("yoloMode") === "on",
}
const parsed = submitTaskSchema.safeParse(raw)
@@ -40,7 +40,7 @@ export async function submitTask(
const handle = await tasks.trigger("ralph-loop", {
repoUrl: parsed.data.repoUrl,
prompt: parsed.data.prompt,
- pauseEvery: parsed.data.pauseEvery,
+ yoloMode: parsed.data.yoloMode,
})
// Create public token for realtime access
diff --git a/background-ralph/src/components/ralph-app.tsx b/background-ralph/src/components/ralph-app.tsx
index 05fb3b1..6622324 100644
--- a/background-ralph/src/components/ralph-app.tsx
+++ b/background-ralph/src/components/ralph-app.tsx
@@ -81,19 +81,17 @@ export function RalphApp() {
/>
-
-
-
+
-
Set to 0 for no pauses
+
{error && (
diff --git a/background-ralph/src/components/run-viewer.tsx b/background-ralph/src/components/run-viewer.tsx
index 3cfad75..ceafd8d 100644
--- a/background-ralph/src/components/run-viewer.tsx
+++ b/background-ralph/src/components/run-viewer.tsx
@@ -2,7 +2,7 @@
import { useState } from "react"
import { useRealtimeRun, useRealtimeStream, useWaitToken } from "@trigger.dev/react-hooks"
-import { statusStream, agentOutputStream, type StatusUpdate } from "@/trigger/streams"
+import { statusStream, agentOutputStream, type StatusUpdate, type Prd } from "@/trigger/streams"
import type { ralphLoop } from "@/trigger/ralph-loop"
import { Button } from "@/components/ui/button"
import { cancelRun } from "@/app/actions"
@@ -60,6 +60,61 @@ function ApprovalGate({
)
}
+function PRDEditor({
+ prd,
+ tokenId,
+ publicAccessToken,
+}: {
+ prd: Prd
+ tokenId: string
+ publicAccessToken: string
+}) {
+ const [prdJson, setPrdJson] = useState(() => JSON.stringify(prd, null, 2))
+ const [parseError, setParseError] = useState
()
+ const [isSubmitting, setIsSubmitting] = useState(false)
+ const [submitError, setSubmitError] = useState()
+ const { complete } = useWaitToken(tokenId, { accessToken: publicAccessToken })
+
+ function handleChange(value: string) {
+ setPrdJson(value)
+ setParseError(undefined)
+ try {
+ JSON.parse(value)
+ } catch (e) {
+ setParseError(e instanceof Error ? e.message : "Invalid JSON")
+ }
+ }
+
+ async function handleApprove() {
+ setIsSubmitting(true)
+ setSubmitError(undefined)
+ try {
+ const parsed = JSON.parse(prdJson) as Prd
+ await complete({ action: "approve_prd", prd: parsed })
+ } catch (e) {
+ setSubmitError(e instanceof Error ? e.message : "Failed to approve")
+ setIsSubmitting(false)
+ }
+ }
+
+ return (
+
+
Review and edit the generated PRD:
+