Commit81d64c6

committed

feat: tolerate disconnects in agent metadata frontend

1 parent3680f9e commit81d64c6Copy full SHA for 81d64c6

File tree

+21

-10

lines changed

+21

-10

lines changed

Lines changed: 21 additions & 10 deletions

Original file line number	Diff line number	Diff line change
`@@ -241,18 +241,29 @@ export const AgentMetadata: FC<{`
`241`	`241`	`setMetadata(storybookMetadata)`
`242`	`242`	`return`
`243`	`243`	`}`
`244`		`-constsource=watchAgentMetadata(agent.id)`
`245`	`244`
`246`		`-source.onerror=(e)=>{`
`247`		`-console.error("received error in watch stream",e)`
`248`		`-}`
`249`		`-source.addEventListener("data",(e)=>{`
`250`		`-constdata=JSON.parse(e.data)`
`251`		`-setMetadata(data)`
`252`		`-})`
`253`		`-return()=>{`
`254`		`-source.close()`
	`245`	`+constconnect=():(()=>void)=>{`
	`246`	`+constsource=watchAgentMetadata(agent.id)`
	`247`	`+`
	`248`	`+source.onerror=(e)=>{`
	`249`	`+console.error("received error in watch stream",e)`
	`250`	`+setMetadata(undefined)`
	`251`	`+source.close()`
	`252`	`+`
	`253`	`+setTimeout(()=>{`
	`254`	`+connect()`
	`255`	`+},3000)`
	`256`	`+}`
	`257`	`+`
	`258`	`+source.addEventListener("data",(e)=>{`
	`259`	`+constdata=JSON.parse(e.data)`
	`260`	`+setMetadata(data)`
	`261`	`+})`
	`262`	`+return()=>{`
	`263`	`+source.close()`
	`264`	`+}`
`255`	`265`	`}`
	`266`	`+returnconnect()`
`256`	`267`	`},[agent.id,watchAgentMetadata,storybookMetadata])`
`257`	`268`
`258`	`269`	`if(metadata===undefined){`

Comments

(0)