From cdb356415e651b9be1a2476fea4eee9f7bf94ca7 Mon Sep 17 00:00:00 2001
From: Cameron Pfiffer <cameron@pfiffer.org>
Date: Mon, 10 Aug 2026 19:58:08 -0700
Subject: [PATCH] Remove misleading feed chrome.
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Stop presenting the 100-row snapshot cap as a total, remove passive runtime status from the personal feed, and name the resident processor as The Stream.

👾 Generated with [Letta Code](https://letta.com)

Co-Authored-By: Letta Code <noreply@letta.com>
---
 src/web/inspector.ts   | 19 ++++++++-----------
 test/inspector.test.ts |  4 ++++
 2 files changed, 12 insertions(+), 11 deletions(-)

diff --git a/src/web/inspector.ts b/src/web/inspector.ts
index 2199f43..94a6bfa 100644
--- a/src/web/inspector.ts
+++ b/src/web/inspector.ts
@@ -584,16 +584,16 @@ export function renderInspectorHtml(): string {
   </style>
 </head>
 <body>
-<header><h1>thought stream</h1><nav><button id="events-tab" class="active">feed</button><span>|</span><button id="runs-tab">runs</button><span>|</span><button id="sources-tab">sources</button><span>|</span><button id="suggestions-tab">suggestions</button><span>|</span><button id="reviews-tab">review</button><span>|</span><button id="artifacts-tab">artifacts</button></nav><span id="status" class="muted">loading</span></header>
-<main><section id="list-pane"><div class="section-head"><span id="list-title">recent activity</span><span id="count">…</span></div><details id="filters-shell" class="filters" hidden><summary>filter</summary><div id="filter-bar" class="filter-bar" hidden></div></details><div id="list"><div class="empty"><span class="spinner" aria-hidden="true"></span>Loading recent activity…</div></div></section><section id="detail-pane"><button id="detail-back" class="detail-back">← back</button><div id="detail"></div></section></main>
+<header><h1>thought stream</h1><nav><button id="events-tab" class="active">feed</button><span>|</span><button id="runs-tab">runs</button><span>|</span><button id="sources-tab">sources</button><span>|</span><button id="suggestions-tab">suggestions</button><span>|</span><button id="reviews-tab">review</button><span>|</span><button id="artifacts-tab">artifacts</button></nav></header>
+<main><section id="list-pane"><div class="section-head"><span id="list-title">recent activity</span></div><details id="filters-shell" class="filters" hidden><summary>filter</summary><div id="filter-bar" class="filter-bar" hidden></div></details><div id="list"><div class="empty"><span class="spinner" aria-hidden="true"></span>Loading recent activity…</div></div></section><section id="detail-pane"><button id="detail-back" class="detail-back">← back</button><div id="detail"></div></section></main>
 <script>
-const state={snapshot:null,proposals:null,reviews:null,artifacts:null,session:null,loading:{snapshot:true,proposals:true,reviews:true,artifacts:true,session:true},errors:{},tab:'events',selected:null,proposalReceipt:'',eventFilters:{source:'all',activity:'all',processing:'all',query:''},sourceScope:'inputs',live:'connecting',snapshotRefreshInFlight:false,snapshotRefreshPending:false};
+const state={snapshot:null,proposals:null,reviews:null,artifacts:null,session:null,loading:{snapshot:true,proposals:true,reviews:true,artifacts:true,session:true},errors:{},tab:'events',selected:null,proposalReceipt:'',eventFilters:{source:'all',activity:'all',processing:'all',query:''},sourceScope:'inputs',snapshotRefreshInFlight:false,snapshotRefreshPending:false};
 const resources={snapshot:{path:'api/snapshot',label:'recent activity'},proposals:{path:'api/proposals',label:'suggestions'},reviews:{path:'api/reviews',label:'review queue'},artifacts:{path:'api/artifacts',label:'artifacts'},session:{path:'api/session',label:'session'}};
 const esc=s=>String(s??'').replace(/[&<>"']/g,c=>({'&':'&amp;','<':'&lt;','>':'&gt;','"':'&quot;',"'":'&#39;'}[c]));
 const json=value=>esc(JSON.stringify(value,null,2));
-const agentName=id=>state.snapshot?.agents?.find(agent=>agent.id===id)?.spec?.name??id;
+const agentName=id=>id==='resident-letta-conversation'?'The Stream':state.snapshot?.agents?.find(agent=>agent.id===id)?.spec?.name??id;
 async function fetchJson(path,label,options){const response=await fetch(path,options);const contentType=(response.headers.get('content-type')??'').split(';',1)[0].trim().toLowerCase();if(!response.ok)throw new Error(label+' failed (HTTP '+response.status+')');if(contentType!=='application/json')throw new Error(label+' returned '+(contentType||'an unknown content type')+' instead of JSON');return response.json()}
-async function loadResource(key){const resource=resources[key];state[key]=null;state.loading[key]=true;delete state.errors[key];updateStatus();if(tabResource()===key)renderList();try{state[key]=await fetchJson(resource.path,resource.label)}catch(error){state.errors[key]=error instanceof Error?error.message:String(error)}finally{state.loading[key]=false;updateStatus();if(tabResource()===key)renderList()}}
+async function loadResource(key){const resource=resources[key];state[key]=null;state.loading[key]=true;delete state.errors[key];if(tabResource()===key)renderList();try{state[key]=await fetchJson(resource.path,resource.label)}catch(error){state.errors[key]=error instanceof Error?error.message:String(error)}finally{state.loading[key]=false;if(tabResource()===key)renderList()}}
 async function load(){
   renderList();
   await loadResource('snapshot');
@@ -604,7 +604,6 @@ async function load(){
   startLiveUpdates();
 }
 function tabResource(){return state.tab==='suggestions'?'proposals':state.tab==='reviews'?'reviews':state.tab==='artifacts'?'artifacts':'snapshot'}
-function updateStatus(){const pending=Object.values(state.loading).filter(Boolean).length;const failed=Object.keys(state.errors).length;const parts=[];if(failed)parts.push(failed+' failed');if(pending)parts.push('loading '+pending);if(!pending&&!failed)parts.push('ready');parts.push(state.live==='live'?'live':state.live==='reconnecting'?'reconnecting':'connecting');if(state.session)parts.push(state.session.reviewWriteEnabled?'review enabled':'read-only');document.querySelector('#status').textContent=parts.join(' · ')}
 function emptyMessage(){return state.tab==='events'?'No recent activity has been recorded.':state.tab==='runs'?'No agent runs have been recorded.':state.tab==='sources'?'No configured or observed sources are available.':state.tab==='suggestions'?'No suggestions are waiting.':state.tab==='reviews'?'No reviews are waiting.':'No artifacts are available.'}
 function renderList(){
   const list=document.querySelector('#list'); const isEvents=state.tab==='events'; const isRuns=state.tab==='runs'; const isSources=state.tab==='sources'; const isSuggestions=state.tab==='suggestions'; const isReviews=state.tab==='reviews'; const isArtifacts=state.tab==='artifacts';
@@ -614,18 +613,16 @@ function renderList(){
   const allValues=!ready?[]:isEvents?state.snapshot.activity.items:isRuns?state.snapshot.runs:isSuggestions?state.proposals.items:isReviews?state.reviews.items:isArtifacts?state.artifacts.entries:state.snapshot.sources;
   const values=isEvents?filterEvents(allValues):isSources?filterSources(allValues):allValues;
   if(isEvents&&ready)renderEventFilters(allValues);else if(isSources&&ready)renderSourceFilter();else renderEventFilters(undefined);
-  const filtersActive=(isEvents&&Object.values(state.eventFilters).some(value=>value&&value!=='all'))||(isSources&&state.sourceScope!=='all');
-  document.querySelector('#count').textContent=error?'error':ready?(filtersActive?values.length+' / '+allValues.length:values.length):'…';
   const empty=isEvents&&ready&&values.length===0?eventFilterEmptyMessage():emptyMessage();
   list.innerHTML=error?'<div class="empty failed">'+esc(error)+'<div><button class="retry" data-resource="'+esc(resourceKey)+'">Retry</button></div></div>':!ready?'<div class="empty"><span class="spinner" aria-hidden="true"></span>Loading '+esc(resource.label)+'…</div>':values.map(value=>isEvents?eventItem(value):isRuns?runItem(value):isSuggestions?suggestionItem(value):isReviews?reviewItem(value):isArtifacts?artifactItem(value):sourceItem(value)).join('')||'<div class="empty">'+esc(empty)+'</div>';
   list.querySelector('.retry')?.addEventListener('click',event=>loadResource(event.currentTarget.dataset.resource));
   list.querySelectorAll('.item[data-kind]').forEach(item=>{const open=event=>{if(event.target.closest('a,details,input,select,textarea')&&event.target!==item)return;list.querySelectorAll('.item').forEach(value=>value.classList.remove('active'));item.classList.add('active');select(item.dataset.kind,item.dataset.id)};item.addEventListener('click',open);item.addEventListener('keydown',event=>{if((event.key==='Enter'||event.key===' ')&&event.target===item){event.preventDefault();open(event)}})});
   if(state.selected)list.querySelectorAll('.item[data-kind]').forEach(item=>item.classList.toggle('active',item.dataset.kind===state.selected.kind&&item.dataset.id===state.selected.id));
 }
-function startLiveUpdates(){const stream=new EventSource('api/live');stream.addEventListener('open',()=>{state.live='live';updateStatus()});stream.addEventListener('change',()=>scheduleSnapshotRefresh());stream.addEventListener('error',()=>{state.live='reconnecting';updateStatus()})}
+function startLiveUpdates(){const stream=new EventSource('api/live');stream.addEventListener('change',()=>scheduleSnapshotRefresh())}
 let snapshotRefreshTimer;
 function scheduleSnapshotRefresh(){clearTimeout(snapshotRefreshTimer);snapshotRefreshTimer=setTimeout(()=>void refreshSnapshot(),120)}
-async function refreshSnapshot(){if(state.snapshotRefreshInFlight){state.snapshotRefreshPending=true;return}state.snapshotRefreshInFlight=true;try{state.snapshot=await fetchJson(resources.snapshot.path,resources.snapshot.label);delete state.errors.snapshot;renderList();if(state.selected?.kind==='source')await showSource(state.selected.id);else if(state.selected&&(state.selected.kind==='event'||state.selected.kind==='run'))await select(state.selected.kind,state.selected.id,{preserveScroll:true})}catch(error){state.errors.snapshot=error instanceof Error?error.message:String(error)}finally{state.snapshotRefreshInFlight=false;updateStatus();if(state.snapshotRefreshPending){state.snapshotRefreshPending=false;scheduleSnapshotRefresh()}}}
+async function refreshSnapshot(){if(state.snapshotRefreshInFlight){state.snapshotRefreshPending=true;return}state.snapshotRefreshInFlight=true;try{state.snapshot=await fetchJson(resources.snapshot.path,resources.snapshot.label);delete state.errors.snapshot;renderList();if(state.selected?.kind==='source')await showSource(state.selected.id);else if(state.selected&&(state.selected.kind==='event'||state.selected.kind==='run'))await select(state.selected.kind,state.selected.id,{preserveScroll:true})}catch(error){state.errors.snapshot=error instanceof Error?error.message:String(error)}finally{state.snapshotRefreshInFlight=false;if(state.snapshotRefreshPending){state.snapshotRefreshPending=false;scheduleSnapshotRefresh()}}}
 const inputSourceKinds=new Set(['filesystem','rss','jetstream','fastmail','telegram','x-webhook']);
 function isInputSource(source){return inputSourceKinds.has(source.kind)}
 function filterSources(sources){return state.sourceScope==='all'?sources:sources.filter(source=>state.sourceScope==='inputs'?isInputSource(source):!isInputSource(source))}
@@ -635,7 +632,7 @@ function renderEventFilters(events){const shell=document.querySelector('#filters
 function eventFilterEmptyMessage(){if(state.eventFilters.source!=='all'){const source=state.snapshot?.sources?.find(value=>value.source===state.eventFilters.source);if(source&&!source.hasActivityEvidence)return sourceLabelFromId(source.source)+' is configured but has no durable activity yet.'}return 'No observations match these filters.'}
 function eventItem(event){
   const observation=observationPresentation(event);
-  const consumers=(event.consumerRuns??[]).map(run=>'<div class="consumer"><strong>'+esc(agentName(run.agentId))+'</strong> <span class="badge">'+esc(run.kind)+'</span> <span class="badge '+(run.status==='failed'?'failed':'')+'">'+esc(run.status)+'</span><br>'+esc(run.description)+'</div>').join('');
+  const consumers=(event.consumerRuns??[]).map(run=>'<div class="consumer"><strong>'+esc(agentName(run.agentId))+'</strong>'+(run.status==='completed'?'':' <span class="badge '+(run.status==='failed'?'failed':'')+'">'+esc(run.status)+'</span>')+'<br>'+esc(run.description)+'</div>').join('');
   const processing=consumers?'<details class="feed-processing"><summary>'+event.consumerRuns.length+' processor'+(event.consumerRuns.length===1?'':'s')+'</summary>'+consumers+'</details>':'<div class="processing-state"><span class="status-dot"></span>Not processed</div>';
   const links=observationAnchor(observation.urlLabel,observation.url)+observationAnchor(observation.parentLabel,observation.parentUrl);
   return '<article class="item" tabindex="0" data-kind="event" data-id="'+esc(event.id)+'"><div class="type">'+esc(observation.title)+'</div><div class="summary">'+esc(observation.body||observation.objectLabel)+'</div><div class="meta">'+esc(observation.sourceLabel)+' · '+esc(new Date(event.occurredAt).toLocaleString())+' · '+esc(humanPrivacy(event.privacy))+'</div>'+(links?'<div class="feed-links">'+links+'</div>':'')+processing+'</article>';
diff --git a/test/inspector.test.ts b/test/inspector.test.ts
index 667d998..7bc5a6a 100644
--- a/test/inspector.test.ts
+++ b/test/inspector.test.ts
@@ -118,6 +118,10 @@ describe("thought stream inspector", () => {
     expect(pageHtml).toContain("scheduleSnapshotRefresh");
     expect(pageHtml).toContain("Internal producers");
     expect(pageHtml).toContain("Loading source activity…");
+    expect(pageHtml).toContain("id==='resident-letta-conversation'?'The Stream'");
+    expect(pageHtml).not.toContain('id="status"');
+    expect(pageHtml).not.toContain('id="count"');
+    expect(pageHtml).not.toContain("review enabled");
     expect(pageHtml).toContain("main.detail-selected #list-pane");
     expect(pageHtml).toContain('class="item" tabindex="0" data-kind="event"');
     expect(pageHtml).toContain("feed-processing");
-- 
2.51.2