backnotprop/plannotator

"name": "backnotprop"   },   "repository": "https://github.com/backnotprop/plannotator",

},   "repository": "https://github.com/backnotprop/plannotator",   "keywords": ["planning", "review", "hooks", "ExitPlanMode", "collaboration"]

"repository": "https://github.com/backnotprop/plannotator",

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

turns.onPromptEntered({ text: 'Review PR 12.', fromUs: false, originKind: 'plugin' })     turns.onTurnStart('plugin-turn', 'The workspaces plugin sent a message: Review PR 12.')     const client = createBridge({ host, baseUrl: 'http://127.0

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

describe('how a bridge loop ends', () => {   const POLL = 'http://127.0.0.1:4321/api/ai/bridge/poll'

const POLL = 'http://127.0.0.1:4321/api/ai/bridge/poll'

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

/** e.g. `http://127.0.0.1:4321`; always the loopback literal. */

export function bridgeBaseUrl(port: number): string {   return `http://127.0.0.1:${port}`

return `http://127.0.0.1:${port}`

if (events.length === 0) return     try {       const response = await host.fetch(`${base}${BRIDGE_EVENT_PATH}`, {

try {       const response = await host.fetch(`${base}${BRIDGE_EVENT_PATH}`, {         method: 'POST',

const response = await host.fetch(`${base}${BRIDGE_EVENT_PATH}`, {

let response       try {         response = await host.fetch(`${base}${BRIDGE_POLL_PATH}`, {

try {         response = await host.fetch(`${base}${BRIDGE_POLL_PATH}`, {           method: 'POST',

response = await host.fetch(`${base}${BRIDGE_POLL_PATH}`, {

Executable file

function serveOnLaunch(host: FakeHost, port = 4321) {   host.onRun = (call) => {     if (isLaunch(call)) host.files.set(`${launchDirOf(call)}/ready`, `${JSON.stringify({ url: `http://localhost:${port}`, isRemote: false, port })}\n`)

host.onRun = (call) => {     if (isLaunch(call)) host.files.set(`${launchDirOf(call)}/ready`, `${JSON.stringify({ url: `http://localhost:${port}`, isRemote: false, port })}\n`)   }

if (isLaunch(call)) host.files.set(`${launchDirOf(call)}/ready`, `${JSON.stringify({ url: `http://localhost:${port}`, isRemote: false, port })}\n`)

[Credential-related source omitted]

const text = await mod.runCommand('review', 'https://github.com/o/r/pull/412 --base "feature one"')

expect(text).toContain('PR #412')     expect(text).toContain('http://localhost:5555')

expect(text).toContain('http://localhost:5555')

expect(launches(host)[0]?.argv.slice(5)).toEqual(['plannotator', 'review', 'https://github.com/o/r/pull/412', '--base', 'feature one'])

expect(byTool?.argv.slice(5)).toEqual(byCommand?.argv.slice(5))     expect(Object.keys(byTool?.env ?? {}).sort()).toEqual(Object.keys(byCommand?.env ?? {}).sort())     expect('text' in answer && answer.text).toContain('http://localhost:6060

expect(Object.keys(byTool?.env ?? {}).sort()).toEqual(Object.keys(byCommand?.env ?? {}).sort())     expect('text' in answer && answer.text).toContain('http://localhost:6060')     expect('text' in answer && answer.text).toContain('End your t

expect('text' in answer && answer.text).toContain('http://localhost:6060')

serveOnLaunch(host)     const mod = new PlannotatorMod(host, SESSION)     await mod.runTool({ action: 'review', target: 'https://github.com/o/r/pull/7', gate: true })

const mod = new PlannotatorMod(host, SESSION)     await mod.runTool({ action: 'review', target: 'https://github.com/o/r/pull/7', gate: true })     await mod.runTool({ action: 'review', target: 'https://github.com/o/r/pull/8' })

await mod.runTool({ action: 'review', target: 'https://github.com/o/r/pull/7', gate: true })

await mod.runTool({ action: 'review', target: 'https://github.com/o/r/pull/8' })

const [gated, plain] = launches(host)     const status = (n: number) => ({ surface: 'review', decision: 'annotated', noop: true, platform: true, message: `Pull request approved on GitHub: https://github.com/o/r/pull/${n}` })     decide(host

const status = (n: number) => ({ surface: 'review', decision: 'annotated', noop: true, platform: true, message: `Pull request approved on GitHub: https://github.com/o/r/pull/${n}` })

expect(host.submits).toHaveLength(1)     expect(host.submits[0]).toMatch(/^Plannotator: .+ \(pn-[0-9a-f]{6}\) — Review posted\./)     expect(host.submits[0]).toContain('Pull request approved on GitHub: https://github.com/o/r/pull/7')

expect(host.submits[0]).toMatch(/^Plannotator: .+ \(pn-[0-9a-f]{6}\) — Review posted\./)     expect(host.submits[0]).toContain('Pull request approved on GitHub: https://github.com/o/r/pull/7')     expect(host.logs.some((line) => line.includ

expect(host.submits[0]).toContain('Pull request approved on GitHub: https://github.com/o/r/pull/7')

'  a.md -> /r/a.md',       '  b.md -> /r/b.md',       'Re-run with exactly one target: plannotator annotate <file.md | file.txt | file.html | https://... | folder/>',

'  b.md -> /r/b.md',       'Re-run with exactly one target: plannotator annotate <file.md | file.txt | file.html | https://... | folder/>',     ].join('\n')

'Re-run with exactly one target: plannotator annotate <file.md | file.txt | file.html | https://... | folder/>',

}     const mod = new PlannotatorMod(host, SESSION)     const answer = await mod.runTool({ action: 'annotate', target: ['a.md', 'https://example.com'] })

const mod = new PlannotatorMod(host, SESSION)     const answer = await mod.runTool({ action: 'annotate', target: ['a.md', 'https://example.com'] })     expect('deny' in answer && answer.deny).toContain(PLANNOTATOR_BUNDLE_HINT_LINE)

const answer = await mod.runTool({ action: 'annotate', target: ['a.md', 'https://example.com'] })

const host = fakeHost()     host.onRun = (call) =>       call.argv[1] === 'inbox' ? { exitCode: 0, stdout: 'http://localhost:59812/\n', stderr: '' } : undefined

host.onRun = (call) =>       call.argv[1] === 'inbox' ? { exitCode: 0, stdout: 'http://localhost:59812/\n', stderr: '' } : undefined     const mod = new PlannotatorMod(host, SESSION)

call.argv[1] === 'inbox' ? { exitCode: 0, stdout: 'http://localhost:59812/\n', stderr: '' } : undefined

expect(call?.argv).toEqual(['plannotator', 'inbox', '--open'])     expect(call?.env?.PLANNOTATOR_DATA_DIR).toBe('/data')     expect(text).toContain('http://localhost:59812/')

expect(text).toContain('http://localhost:59812/')

test('over SSH the CLI opens no browser and says how to reach the Inbox: the answer passes that on', async () => {     const host = fakeHost()     host.onRun = () => ({ exitCode: 0, stdout: 'http://localhost:59812/\n', stderr: 'No browser o

const host = fakeHost()     host.onRun = () => ({ exitCode: 0, stdout: 'http://localhost:59812/\n', stderr: 'No browser opened: this is a remote session. Forward the port (ssh -L 59812:127.0.0.1:59812 <this host>) and open the URL, or run p

host.onRun = () => ({ exitCode: 0, stdout: 'http://localhost:59812/\n', stderr: 'No browser opened: this is a remote session. Forward the port (ssh -L 59812:127.0.0.1:59812 <this host>) and open the URL, or run plannotator inbox --tailscale

const { text } = await new PlannotatorMod(host, SESSION).openInbox()     expect(text).toContain('http://localhost:59812/')     expect(text).toContain('ssh -L 59812:127.0.0.1:59812')

expect(text).toContain('http://localhost:59812/')

Executable file

if (!launch.port || !launch.bridgeToken) return null     try {       const response = await this.host.fetch(`${bridgeBaseUrl(launch.port)}${HOST_STATUS_PATH}`, {

try {       const response = await this.host.fetch(`${bridgeBaseUrl(launch.port)}${HOST_STATUS_PATH}`, {         method: 'GET',

const response = await this.host.fetch(`${bridgeBaseUrl(launch.port)}${HOST_STATUS_PATH}`, {

}     const response = await this.host       .fetch(`${bridgeBaseUrl(launch.port)}${HOST_CLOSE_PATH}`, {

const response = await this.host       .fetch(`${bridgeBaseUrl(launch.port)}${HOST_CLOSE_PATH}`, {         method: 'POST',

.fetch(`${bridgeBaseUrl(launch.port)}${HOST_CLOSE_PATH}`, {

Executable file

test('a review posted to the PR platform logs and suggests the follow-up', () => {     const delivery = deliveryFor(       record({ surface: 'review', noop: true, platform: true, message: 'Pull request reviewed on GitHub: https://x/pull/412

const delivery = deliveryFor(       record({ surface: 'review', noop: true, platform: true, message: 'Pull request reviewed on GitHub: https://x/pull/412' }),       { ...CONTEXT, subject: 'PR #412' },

record({ surface: 'review', noop: true, platform: true, message: 'Pull request reviewed on GitHub: https://x/pull/412' }),

test('a gated review posted to the PR platform is a turn with its status line; ungated it logs', () => {     const status = 'Pull request approved on GitHub: https://x/pull/412'

const status = 'Pull request approved on GitHub: https://x/pull/412'

const lines = [       ...['Pull request', 'Merge request'].flatMap((kind) =>         ['approved', 'reviewed'].map((verb) => `${kind} ${verb} on GitLab: https://x/-/merge_requests/9`),

...['Pull request', 'Merge request'].flatMap((kind) =>         ['approved', 'reviewed'].map((verb) => `${kind} ${verb} on GitLab: https://x/-/merge_requests/9`),       ),

['approved', 'reviewed'].map((verb) => `${kind} ${verb} on GitLab: https://x/-/merge_requests/9`),

),       'Changes requested on GitHub: https://x/pull/412',       'Pull request reviewed on Bitbucket',

'Changes requested on GitHub: https://x/pull/412',

Executable file

Executable file

Executable file

Executable file

Executable file

fetch(url: string, init: { method: string; headers: Record<string, string>; body?: string }): Promise<HttpResult>

Executable file

servers.push(server)   const client = new Client({ name: 'mod-inbox-ask-test', version: '1.0.0' })   await client.connect(new StreamableHTTPClientTransport(new URL(`http://127.0.0.1:${server.port}/mcp`)))

const client = new Client({ name: 'mod-inbox-ask-test', version: '1.0.0' })   await client.connect(new StreamableHTTPClientTransport(new URL(`http://127.0.0.1:${server.port}/mcp`)))   clients.push(client)

await client.connect(new StreamableHTTPClientTransport(new URL(`http://127.0.0.1:${server.port}/mcp`)))

[Credential-related source omitted]

[Credential-related source omitted]

const ASK_POLL = `http://127.0.0.1:4321${inboxAskBridgeBase(SESSION)}${BRIDGE_POLL_PATH}`

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

Executable file

[Credential-related source omitted]

Executable file

test("is exactly what a real Inbox's /mcp tools/list answers (run scripts/sync-mod-inbox-tools.ts when it is not)", async () => {     const response = await fetch(`http://127.0.0.1:${inbox.port}/mcp`, {

const response = await fetch(`http://127.0.0.1:${inbox.port}/mcp`, {

Executable file

"inputSchema": {       "type": "object",       "$schema": "https://json-schema.org/draft/2020-12/schema",

"type": "object",       "$schema": "https://json-schema.org/draft/2020-12/schema",       "properties": {

"$schema": "https://json-schema.org/draft/2020-12/schema",

"type": "string",           "minLength": 1,           "description": "The message, markdown. Question blocks render as answerable cards. Blocks fenced as `mermaid` or `dot` draw as diagrams; one fenced as `html` draws as a live, sandboxed p

"minLength": 1,           "description": "The message, markdown. Question blocks render as answerable cards. Blocks fenced as `mermaid` or `dot` draw as diagrams; one fenced as `html` draws as a live, sandboxed page in the message (chart, S

"description": "The message, markdown. Question blocks render as answerable cards. Blocks fenced as `mermaid` or `dot` draw as diagrams; one fenced as `html` draws as a live, sandboxed page in the message (chart, SVG, mock; https libraries 

[Credential-related source omitted]

"inputSchema": {       "type": "object",       "$schema": "https://json-schema.org/draft/2020-12/schema",

"type": "object",       "$schema": "https://json-schema.org/draft/2020-12/schema",       "properties": {

"$schema": "https://json-schema.org/draft/2020-12/schema",

"inputSchema": {       "type": "object",       "$schema": "https://json-schema.org/draft/2020-12/schema",

"type": "object",       "$schema": "https://json-schema.org/draft/2020-12/schema",       "properties": {

"$schema": "https://json-schema.org/draft/2020-12/schema",

"inputSchema": {       "type": "object",       "$schema": "https://json-schema.org/draft/2020-12/schema",

"type": "object",       "$schema": "https://json-schema.org/draft/2020-12/schema",       "properties": {

"$schema": "https://json-schema.org/draft/2020-12/schema",

"inputSchema": {       "type": "object",       "$schema": "https://json-schema.org/draft/2020-12/schema",

"type": "object",       "$schema": "https://json-schema.org/draft/2020-12/schema",       "properties": {

"$schema": "https://json-schema.org/draft/2020-12/schema",

"inputSchema": {       "type": "object",       "$schema": "https://json-schema.org/draft/2020-12/schema",

"type": "object",       "$schema": "https://json-schema.org/draft/2020-12/schema",       "properties": {},

"$schema": "https://json-schema.org/draft/2020-12/schema",

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

Executable file

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

}     expect(await readSessionThreads(host, DATA, 'sess-1', '/work', TOOL)).toBeNull()     expect(urls).toEqual(['http://127.0.0.1:4100/api/inbox/health'])

expect(await readSessionThreads(host, DATA, 'sess-1', '/work', TOOL)).toBeNull()     expect(urls).toEqual(['http://127.0.0.1:4100/api/inbox/health'])   })

expect(urls).toEqual(['http://127.0.0.1:4100/api/inbox/health'])

}     expect(await readSessionThreads(host, DATA, 'sess-1', '/work', TOOL)).toBeNull()     expect(urls).toEqual(['http://127.0.0.1:4100/api/inbox/health'])

expect(await readSessionThreads(host, DATA, 'sess-1', '/work', TOOL)).toBeNull()     expect(urls).toEqual(['http://127.0.0.1:4100/api/inbox/health'])   })

expect(urls).toEqual(['http://127.0.0.1:4100/api/inbox/health'])

Executable file

async function thread(w: World, threadId: string): Promise<{ subject: string; thread_name: string | null; project: { root: string }; messages: ThreadMessage[] }> {   const response = await fetch(`http://127.0.0.1:${registry(w).port}/api/inb

const response = await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/threads/${threadId}`)

async function personSends(w: World, messageId: string, words: string): Promise<string> {   const { port } = registry(w)   const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }

const { port } = registry(w)   const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }   const response = await fetch(`http://127.0.0.1:${port}/api/inbox/messages/${messageId}/re

const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }

const response = await fetch(`http://127.0.0.1:${port}/api/inbox/messages/${messageId}/reply`, {

method: 'POST',     headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },     body: JSON.stringify({ serverSession: health.serverSession, idempotency_key: `window-${messageId}-${words.length}`, words }),

headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },

const listed = await fetch(`http://127.0.0.1:${registry(w).port}/mcp`, {

const delivered = await waitFor('the delivery record', async () => (await thread(w, asked.thread_id)).messages.find((m) => m.id === replyId)?.delivery)     expect(delivered).toMatchObject({ state: 'delivered', host: 'claude-code', session: 

expect(delivered).toMatchObject({ state: 'delivered', host: 'claude-code', session: 'session-wake' })     const list = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/threads`)).json()) as { sections: { id: string; threa

const list = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/threads`)).json()) as { sections: { id: string; threads: { thread_id: string; sent: { checked_at: string | null } | null }[] }[] }

const sent = await send(session, w, 'Merged the refund fix. CI is green on main; nothing needs you here.')     const { port } = registry(w)     const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { se

const { port } = registry(w)     const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }     const pressed = Date.now()

const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }

const pressed = Date.now()     const response = await fetch(`http://127.0.0.1:${port}/api/inbox/messages/${sent.message_id}/ack`, {       method: 'POST',

const response = await fetch(`http://127.0.0.1:${port}/api/inbox/messages/${sent.message_id}/ack`, {

method: 'POST',       headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },       body: JSON.stringify({ serverSession: health.serverSession }),

headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },

const poll = await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/bridge/poll`, {

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

const { port } = registry(w)     const live = await waitFor('both sessions live', async () => {       const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/sessions`)).json()) as {

const live = await waitFor('both sessions live', async () => {       const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/sessions`)).json()) as {         sessions: { session: string; host: string

const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/sessions`)).json()) as {

const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }

const post = (session: string, body: string, key: string) =>       fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/message`, {         method: 'POST',

fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/message`, {

method: 'POST',         headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },         body: JSON.stringify({ serverSession: health.serverSession, session, body, idempotency_key: key }),

headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },

const before = (await thread(w, asked.thread_id)).messages.length     await waitFor('session-other no longer live', async () => {       const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/session

await waitFor('session-other no longer live', async () => {       const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/sessions`)).json()) as { sessions: { session: string }[] }       return model

const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/sessions`)).json()) as { sessions: { session: string }[] }

const { port } = registry(w)     await waitFor('the other session live', async () => {       const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/sessions`)).json()) as { sessions: { session: stri

await waitFor('the other session live', async () => {       const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/sessions`)).json()) as { sessions: { session: string }[] }       return model.sessi

const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/sessions`)).json()) as { sessions: { session: string }[] }

return model.sessions.some((s) => s.session === 'session-taker') ? true : null     })     const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }

})     const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }     const words = 'Retry with the same key.'

const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }

const words = 'Retry with the same key.'     const response = await fetch(`http://127.0.0.1:${port}/api/inbox/messages/${asked.message_id}/reply`, {       method: 'POST',

const response = await fetch(`http://127.0.0.1:${port}/api/inbox/messages/${asked.message_id}/reply`, {

method: 'POST',       headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },       body: JSON.stringify({ serverSession: health.serverSession, idempotency_key: 'ended-1', words, to: { host: 'claude-code', sessi

headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },

await waitFor('the tagged session taggable', async () => {       const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/taggable`)).json()) as { sessions: { session: string; taggable: boolean }[] }

const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/taggable`)).json()) as { sessions: { session: string; taggable: boolean }[] }

await owner.startTurn('Refactor the webhook handler.')     const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }

const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }

const response = await fetch(`http://127.0.0.1:${port}/api/inbox/messages/${asked.message_id}/reply`, {

method: 'POST',       headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },       body: JSON.stringify({

headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },

const listed = await waitFor('the session in the live list', async () => {       const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/sessions`)).json()) as {

const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/sessions`)).json()) as {

const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }

const words = 'Idea: show which session wrote each thread.\n\nA small chip on each row would do.'     const response = await fetch(`http://127.0.0.1:${port}/api/inbox/messages`, {       method: 'POST',

const response = await fetch(`http://127.0.0.1:${port}/api/inbox/messages`, {

method: 'POST',       headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },       body: JSON.stringify({ serverSession: health.serverSession, to: { host: 'claude-code', session: 'session-compose' }, body: word

headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },

const connection = await waitFor('the busy connection', async () => {       const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/sessions?asker=session-send-now`)).json()) as {

const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/sessions?asker=session-send-now`)).json()) as {

const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }

const pressed = await fetch(`http://127.0.0.1:${port}/api/inbox/messages/${replyId}/send-now`, {

method: 'POST',       headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },       body: JSON.stringify({ serverSession: health.serverSession }),

headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },

const replyId = await personSends(w, asked.message_id, 'Fail the job and alert.')     await waitFor('the busy connection', async () => {       const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/

await waitFor('the busy connection', async () => {       const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/sessions?asker=session-late`)).json()) as {         asker: { connection: { busy: boole

const model = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/threads/${asked.thread_id}/sessions?asker=session-late`)).json()) as {

return model.asker.connection?.busy === true     })     const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }

})     const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }     expect(

const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }

expect(       (         await fetch(`http://127.0.0.1:${port}/api/inbox/messages/${replyId}/send-now`, {

(         await fetch(`http://127.0.0.1:${port}/api/inbox/messages/${replyId}/send-now`, {           method: 'POST',

await fetch(`http://127.0.0.1:${port}/api/inbox/messages/${replyId}/send-now`, {

method: 'POST',           headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },           body: JSON.stringify({ serverSession: health.serverSession }),

headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },

async function pressSendNow(w: World, replyId: string): Promise<void> {     const { port } = registry(w)     const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }

const { port } = registry(w)     const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }     const pressed = await fetch(`http://127.0.0.1:${port}/api/inbox/messages/${replyId}/s

const health = (await (await fetch(`http://127.0.0.1:${port}/api/inbox/health`)).json()) as { serverSession: string }

const pressed = await fetch(`http://127.0.0.1:${port}/api/inbox/messages/${replyId}/send-now`, {

method: 'POST',       headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },       body: JSON.stringify({ serverSession: health.serverSession }),

headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${port}` },

async function busyKnown(w: World, threadId: string, session: string): Promise<void> {     await waitFor('the busy connection', async () => {       const model = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/threads/${

await waitFor('the busy connection', async () => {       const model = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/threads/${threadId}/sessions?asker=${session}`)).json()) as {         asker: { connection: { busy: bo

const model = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/threads/${threadId}/sessions?asker=${session}`)).json()) as {

await waitFor('the busy connection without Send now', async () => {       const model = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/threads/${asked.thread_id}/sessions?asker=session-ask`)).json()) as {

const model = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/threads/${asked.thread_id}/sessions?asker=session-ask`)).json()) as {

return model.asker.connection?.busy === true && model.asker.connection.send_now === false     })     const health = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/health`)).json()) as { serverSession: string }

})     const health = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/health`)).json()) as { serverSession: string }     const refused = await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/messages/${replyId}/sen

const health = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/health`)).json()) as { serverSession: string }

const refused = await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/messages/${replyId}/send-now`, {

method: 'POST',       headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${registry(w).port}` },       body: JSON.stringify({ serverSession: health.serverSession }),

headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${registry(w).port}` },

const replyId = await personSends(w, asked.message_id, 'Retry with the same key.')     await waitFor('the busy connection without Send now', async () => {       const model = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inb

await waitFor('the busy connection without Send now', async () => {       const model = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/threads/${asked.thread_id}/sessions?asker=session-other-plugin`)).json()) as {      

const model = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/threads/${asked.thread_id}/sessions?asker=session-other-plugin`)).json()) as {

return model.asker.connection?.busy === true && model.asker.connection.send_now === false     })     const health = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/health`)).json()) as { serverSession: string }

})     const health = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/health`)).json()) as { serverSession: string }     const refused = await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/messages/${replyId}/sen

const health = (await (await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/health`)).json()) as { serverSession: string }

const refused = await fetch(`http://127.0.0.1:${registry(w).port}/api/inbox/messages/${replyId}/send-now`, {

method: 'POST',       headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${registry(w).port}` },       body: JSON.stringify({ serverSession: health.serverSession }),

headers: { 'Content-Type': 'application/json', Origin: `http://127.0.0.1:${registry(w).port}` },

Executable file

const health = await host.fetch(`http://127.0.0.1:${registry.port}/api/inbox/health`, { method: 'GET', headers: {} }).catch(() => null)

'rm -rf "$d"',

async function mcpCall(host: Host, port: number, method: string, params: Record<string, unknown>): Promise<{ result?: unknown; error?: { message?: string } } | null> {   const response = await host.fetch(`http://127.0.0.1:${port}/mcp`, {

const response = await host.fetch(`http://127.0.0.1:${port}/mcp`, {

private async isRunning(registry: InboxRegistryView): Promise<boolean> {     const response = await this.host       .fetch(`http://127.0.0.1:${registry.port}/api/inbox/health`, { method: 'GET', headers: {} })

const response = await this.host       .fetch(`http://127.0.0.1:${registry.port}/api/inbox/health`, { method: 'GET', headers: {} })       .catch(() => null)

.fetch(`http://127.0.0.1:${registry.port}/api/inbox/health`, { method: 'GET', headers: {} })

if (!registry) return null     return this.host       .fetch(`http://127.0.0.1:${registry.port}${path}`, {

return this.host       .fetch(`http://127.0.0.1:${registry.port}${path}`, {         method: 'POST',

.fetch(`http://127.0.0.1:${registry.port}${path}`, {

Executable file

Executable file

'for f in "$@"; do rm -f "$dir/$f"; done',

`if [ ! -e "$dir/${LAUNCH_FILES.overflow}" ]; then rm -f "$dir/${SETTLED_BY}" "$dir/${SETTLED_DIR}/delivered" "$dir/${SETTLED_DIR}/reported"; rmdir "$dir/${SETTLED_DIR}" 2>/dev/null; rmdir "$dir" 2>/dev/null; fi`,

return ['/bin/sh', '-c', 'rm -f "$1"', 'plannotator-rm', path]

Executable file

export const CLASSIC_PLAN_REVIEW_TEXT =   'Your plannotator CLI is older than the Plannotator plugin and has no non-blocking plan review, so plans open in the classic review, which holds this session until you decide. Update the CLI (curl -

'Your plannotator CLI is older than the Plannotator plugin and has no non-blocking plan review, so plans open in the classic review, which holds this session until you decide. Update the CLI (curl -fsSL https://plannotator.ai/install.sh | b

'Your plannotator CLI is older than the Plannotator plugin and has no non-blocking plan review, so plans open in the classic review, which holds this session until you decide. Update the CLI (curl -fsSL https://plannotator.ai/install.sh | b

Executable file

Executable file

}))     },     fetch: (url, init) => $.http.fetch(url, init),

},     fetch: (url, init) => $.http.fetch(url, init),     abortTurn: (turnId) => $.turn.abort({ turnId }),

fetch: (url, init) => $.http.fetch(url, init),

Executable file

Executable file

Executable file

const TAILNET_URL = 'https://studio.tail0000.ts.net:6060/'

for (const url of [TAILNET_URL, 'http://localhost:6060']) {

expect('text' in answer && answer.text).toContain('Plannotator is starting')     const dir = launchDirOf(launches(host)[0]!)     host.files.set(`${dir}/ready`, `${JSON.stringify({ url: 'http://localhost:6060', isRemote: false, port: 6060 })

const dir = launchDirOf(launches(host)[0]!)     host.files.set(`${dir}/ready`, `${JSON.stringify({ url: 'http://localhost:6060', isRemote: false, port: 6060 })}\n`)     await host.tick()

host.files.set(`${dir}/ready`, `${JSON.stringify({ url: 'http://localhost:6060', isRemote: false, port: 6060 })}\n`)

serveWith(host, { url: 'http://localhost:6060', isRemote: false, port: 6060 })

test('the slash command passes --tailscale on, for last too, and checks nothing', async () => {     const host = fakeHost()     serveWith(host, { url: 'http://localhost:6060', isRemote: false, port: 6060 })

const host = fakeHost()     serveWith(host, { url: 'http://localhost:6060', isRemote: false, port: 6060 })     host.transcript = [{ role: 'assistant', text: 'Hi.' }]

serveWith(host, { url: 'http://localhost:6060', isRemote: false, port: 6060 })

Executable file

function serveOnLaunch(host: FakeHost, port = 4321) {   host.onRun = (call) => {     if (isLaunch(call)) host.files.set(`${call.argv[4]}/ready`, `${JSON.stringify({ url: `http://localhost:${port}`, isRemote: false, port })}\n`)

host.onRun = (call) => {     if (isLaunch(call)) host.files.set(`${call.argv[4]}/ready`, `${JSON.stringify({ url: `http://localhost:${port}`, isRemote: false, port })}\n`)   }

if (isLaunch(call)) host.files.set(`${call.argv[4]}/ready`, `${JSON.stringify({ url: `http://localhost:${port}`, isRemote: false, port })}\n`)

[Credential-related source omitted]

const bashText = 'result' in answer ? answer.result.stdout : ''     expect(withoutSession(bashText)).toBe(withoutSession('text' in viaTool ? viaTool.text : ''))     expect(JSON.stringify(answer)).toContain('http://localhost:7070')

expect(withoutSession(bashText)).toBe(withoutSession('text' in viaTool ? viaTool.text : ''))     expect(JSON.stringify(answer)).toContain('http://localhost:7070')   })

expect(JSON.stringify(answer)).toContain('http://localhost:7070')

Executable file

Executable file

host.files.set(       `${dirOf(call)}/ready`,       `${JSON.stringify({ url: `http://localhost:${port}`, isRemote: false, port, ...(target ? { target } : {}) })}\n`,

`${dirOf(call)}/ready`,       `${JSON.stringify({ url: `http://localhost:${port}`, isRemote: false, port, ...(target ? { target } : {}) })}\n`,     )

`${JSON.stringify({ url: `http://localhost:${port}`, isRemote: false, port, ...(target ? { target } : {}) })}\n`,

test('a review switched in place to another PR is headed and targeted as that PR', async () => {     const host = fakeHost()     serve(host, ['https://github.com/o/r/pull/12'])

const host = fakeHost()     serve(host, ['https://github.com/o/r/pull/12'])     const mod = new PlannotatorMod(host, SESSION)

serve(host, ['https://github.com/o/r/pull/12'])

await mod.runTool({ action: 'review', target: 'https://github.com/o/r/pull/12' })

message: 'fix the handler',       noop: false,       target: 'https://github.com/o/r/pull/13',

noop: false,       target: 'https://github.com/o/r/pull/13',     })

target: 'https://github.com/o/r/pull/13',

expect(host.submits[0]?.split('\n').slice(0, 2)).toEqual([       expect.stringContaining('Plannotator: PR #13 ('),       'Target: https://github.com/o/r/pull/13',

expect.stringContaining('Plannotator: PR #13 ('),       'Target: https://github.com/o/r/pull/13',     ])

'Target: https://github.com/o/r/pull/13',

Executable file

fetch: async (url, init) => {       host.fetches.push(`${init.method} ${url}`)       const response = await fetch(url, { method: init.method, headers: init.headers, ...(init.body !== undefined ? { body: init.body } : {}) })

host.fetches.push(`${init.method} ${url}`)       const response = await fetch(url, { method: init.method, headers: init.headers, ...(init.body !== undefined ? { body: init.body } : {}) })       return { status: response.status, ok: response

const response = await fetch(url, { method: init.method, headers: init.headers, ...(init.body !== undefined ? { body: init.body } : {}) })

Executable file

/** Answer a fetch (the bridge). */

Executable file

Executable file

Executable file

Executable file

| Annotate a markdown, text, config, or HTML file | `plannotator annotate <file>` | | Annotate a web page | `plannotator annotate <https-url>` | | Annotate a running local app (dev server) | `plannotator annotate <http://localhost:PORT/>` |

| Annotate a web page | `plannotator annotate <https-url>` | | Annotate a running local app (dev server) | `plannotator annotate <http://localhost:PORT/>` | | Pick a file to annotate from a folder | `plannotator annotate <folder/>` |

| Annotate a running local app (dev server) | `plannotator annotate <http://localhost:PORT/>` |

- `--patch-file <path>` reviews a static caller-supplied unified diff with no repository at all (use `-` to read it from stdin): the session serves the patch as-is with no file-system affordances that need a worktree. It cannot be combined 

- Pass a directory to review another repo or worktree: `plannotator review ../feature-worktree` or `plannotator review ./backend --diff-type last-commit`. Paths resolve relative to the invoking directory; quote paths containing spaces. A di

- PR review (`plannotator review https://github.com/owner/repo/pull/123`, GitLab MR and Bitbucket Cloud PR URLs too) needs an authenticated `gh` or `glab` CLI; Bitbucket Cloud (`https://bitbucket.org/<workspace>/<repo>/pull-requests/<id>`) 

Plain `annotate` is feedback-only: it shows **Close** but no **Approve** button. When the user asks to review, approve, accept, or gate a generated plan/spec/document saved as a file, call the `plannotator` tool with `"gate": true` if you h

- AsciiDoc files: `.adoc`, `.asciidoc`. - HTML files (`.html`, `.htm`): rendered as the raw page by default; `--markdown` converts to markdown instead. `--render-html` is accepted for compatibility; raw rendering is already the default. - U

- HTML files (`.html`, `.htm`): rendered as the raw page by default; `--markdown` converts to markdown instead. `--render-html` is accepted for compatibility; raw rendering is already the default. - URLs (`https://...`): fetched and convert

- URLs (`https://...`): fetched and converted via Jina Reader by default; `--no-jina` uses plain fetch plus Turndown instead.

- Running local apps: a loopback `http://localhost:PORT/` URL whose probe returns HTML opens in live-app mode (annotate the real running page). `--app` forces live mode and fails loudly when it cannot apply; `--static` forces the classic co

<meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Compound Planning — What 370 Files Reveal</title> <link rel="preconnect" href="https://fonts.googleapis.com">

<title>Compound Planning — What 370 Files Reveal</title> <link rel="preconnect" href="https://fonts.googleapis.com"> <link href="https://fonts.googleapis.com/css2?family=Playfair+Display:ital,wght@0,400;0,500;1,400&family=Inter:wght@300;400

<link rel="preconnect" href="https://fonts.googleapis.com">

<link href="https://fonts.googleapis.com/css2?family=Playfair+Display:ital,wght@0,400;0,500;1,400&family=Inter:wght@300;400;500;600&family=JetBrains+Mono:wght@400;500&display=swap" rel="stylesheet">

<div class="prompt-header">           <span class="prompt-header-label">             <svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="roun

<span class="prompt-header-label">             <svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"><polyline points="4 17 10 11 4 5"><

<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"><polyline points="4 17 10 11 4 5"></polyline><line x1="12" y1="19" x2="20" y2="19"

</span>           <button class="copy-btn" onclick="copyPrompt(this)">             <svg xmlns="http://www.w3.org/2000/svg" width="14" height="14" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" 

<button class="copy-btn" onclick="copyPrompt(this)">             <svg xmlns="http://www.w3.org/2000/svg" width="14" height="14" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="r

<svg xmlns="http://www.w3.org/2000/svg" width="14" height="14" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"><rect x="9" y="9" width="13" height="13" rx="2" ry="2"></re

const text = document.getElementById('prompt-content').textContent;   navigator.clipboard.writeText(text).then(() => {     btn.innerHTML = '<svg xmlns="http://www.w3.org/2000/svg" width="14" height="14" viewBox="0 0 24 24" fill="none" strok

navigator.clipboard.writeText(text).then(() => {     btn.innerHTML = '<svg xmlns="http://www.w3.org/2000/svg" width="14" height="14" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejo

btn.innerHTML = '<svg xmlns="http://www.w3.org/2000/svg" width="14" height="14" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"><path d="M22 11.08V12a10 10 0 1 1-5.93-9.1

btn.classList.add('copied');     setTimeout(() => {       btn.innerHTML = '<svg xmlns="http://www.w3.org/2000/svg" width="14" height="14" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-l

setTimeout(() => {       btn.innerHTML = '<svg xmlns="http://www.w3.org/2000/svg" width="14" height="14" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"><rect x="9" y="9"

btn.innerHTML = '<svg xmlns="http://www.w3.org/2000/svg" width="14" height="14" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"><rect x="9" y="9" width="13" height="13" r

#!/usr/bin/env python3

<!-- Grilling protocol below adapted verbatim from the /grill-me skill by Matt Pocock (MIT-licensed):      https://github.com/mattpocock/skills/blob/main/skills/productivity/grill-me/SKILL.md -->

https://github.com/mattpocock/skills/blob/main/skills/productivity/grill-me/SKILL.md -->

Executable file

Executable file

<div class="diagram-panel">   <svg viewBox="0 0 720 280" xmlns="http://www.w3.org/2000/svg" style="width:100%">

<svg viewBox="0 0 720 280" xmlns="http://www.w3.org/2000/svg" style="width:100%">

<script type="module">   import { getSingularPatch, registerDiffsComponent } from 'https://cdn.jsdelivr.net/npm/@pierre/diffs@1.1.21/+esm';

import { getSingularPatch, registerDiffsComponent } from 'https://cdn.jsdelivr.net/npm/@pierre/diffs@1.1.21/+esm';

<svg viewBox="0 0 720 280" xmlns="http://www.w3.org/2000/svg"

<svg viewBox="0 0 400 180" xmlns="http://www.w3.org/2000/svg"

<svg viewBox="0 0 720 280" xmlns="http://www.w3.org/2000/svg">