https://supraos.ai/_next/static/chunks/95372-8050ef9f6f58cdaa.js

1"use strict";(self.webpackChunk_N_E=self.webpackChunk_N_E||[]).push([[95372],{5004:(e,t,r)=>{r.d(t,{eA:()=>n,mn:()=>a,tJ:()=>s});let n="supraos-wheel-changed";function a(e){window.dispatchEvent(new CustomEvent(n,{detail:e}))}function s(e,t){var r;let n=e.detail;return n&&n.sessionId===t&&null!=(r=n.wheel)?r:null}},39687:(e,t,r)=>{function n(e){window.dispatchEvent(new CustomEvent("supraos-templates-changed",{detail:e}))}function a(e,t){var r;return(null==(r=e.detail)?void 0:r.templateId)===t}r.d(t,{QP:()=>n,l6:()=>a})},87634:(e,t,r)=>{r.d(t,{YM:()=>a,md:()=>n,TX:()=>u,TH:()=>i,vS:()=>s,n9:()=>c,gv:()=>o,KN:()=>l});let n=50,a=150;function s(e,t){let r=arguments.length>2&&void 0!==arguments[2]?arguments[2]:a,n=new Set(t.map(e=>e.id)),s=e.filter(e=>!n.has(e.id)),l=s.length?[...s,...t]:t;return l.length<=r?{messages:l.slice(),evictedTail:!1}:{messages:l.slice(0,r),evictedTail:!0}}function l(e,t){let r=0,n=e.length;for(;r<n;){let a=r+n>>>1,s=e[a],l=Number.isSafeInteger(s.message_sequence),u=Number.isSafeInteger(t.message_sequence),o=i(s.id),c=i(t.id),d=function(e,t){let r=Date.parse(e),n=Date.parse(t);return Number.isFinite(r)&&Number.isFinite(n)&&r!==n?r<n?-1:1:e<t?-1:+(e>t)}(s.created_at,t.created_at);(o!==c?!o:l&&u?s.message_sequence<t.message_sequence||s.message_sequence===t.message_sequence&&s.id<t.id:d<0||0===d&&s.id<t.id)?r=a+1:n=a}return r}function u(e,t){let r=l(e,t);if(r>0&&e[r-1].id===t.id||r<e.length&&e[r].id===t.id)return e;let n=e.slice();return n.splice(r,0,t),n}function i(e){return e.startsWith("tmp-")}function o(e){for(let t of e)if(Number.isSafeInteger(t.message_sequence))return t.message_sequence;return null}function c(e){for(let t=e.length-1;t>=0;t--){let r=e[t].message_sequence;if(Number.isSafeInteger(r))return r}return null}},90434:(e,t,r)=>{r.d(t,{gK:()=>s,kb:()=>n,lH:()=>a});let n="room-delta",a="supraos-room-delta";function s(e,t){let r=!t||"object"!=typeof t||Array.isArray(t)||"string"!=typeof t.roomId||"string"!=typeof t.turnId||"string"!=typeof t.agentId||"number"!=typeof t.seq||!Number.isSafeInteger(t.seq)||t.seq<1||"string"!=typeof t.text||"boolean"!=typeof t.done?null:{roomId:t.roomId,turnId:t.turnId,agentId:t.agentId,seq:t.seq,text:t.text,done:t.done};r&&window.dispatchEvent(new CustomEvent(a,{detail:{sessionId:e,delta:r}}))}},95372:(e,t,r)=>{r.d(t,{TN:()=>S});var n=r(12115),a=r(76565),s=r(71247),l=r(74514);let u=e=>"string"==typeof e?e:null==e?"":String(e);var i=r(39687),o=r(5004),c=r(90434),d=r(12330),f=r(91540),m=r(31538),g=r(87634);function p(e,t){var r,n,a,s;let l=e.filter(e=>e.id===t.id),u=1===l.length?l[0]:null,i=!!u&&!Number.isSafeInteger(null==u?void 0:u.message_sequence)&&Number.isSafeInteger(t.message_sequence),o=JSON.stringify(null!=(r=null==u?void 0:u.metadata)?r:null)===JSON.stringify(null!=(n=t.metadata)?n:null),c=(null!=(a=null==u?void 0:u.message_type)?a:null)===(null!=(s=t.message_type)?s:null);return u&&u.content===t.content&&!i&&o&&c?e:(0,g.TX)(e.filter(e=>e.id!==t.id),t)}function h(e){let t=Date.parse(e);return Number.isFinite(t)?t:NaN}function _(e,t){let r=h(e),n=h(t);return Number.isNaN(r)||Number.isNaN(n)?e===t:r===n}function y(e){let t="string"==typeof(null==e?void 0:e.completion_status)?e.completion_status:"";return"verified"===t||"complete"===t||"completed"===t||"done"===t?2:+("waiting"!==t&&"pending"!==t)}function v(e,t){return e.filter(e=>(0,g.TH)(e.id)&&e.role===t.role&&e.content===t.content)}function w(e,t){let r=v(e,t);if(1!==r.length)return null;let n=r[0];return _(n.created_at,t.created_at)||function(e,t){let r=h(e),n=h(t);return Number.isNaN(r)||Number.isNaN(n)?e<=t:r<=n}(n.created_at,t.created_at)?n:null}let b=["id","session_id","address","role","content","message_type","metadata","created_at","message_sequence"];function T(e,t){window.dispatchEvent(new CustomEvent("supraos-message-arrived",{detail:{sessionId:t,message:e}})),(0,f.y8)(e)&&window.dispatchEvent(new CustomEvent("supraos-relay-turn-stopped",{detail:{sessionId:t}}))}function S(e){var t,r;let f=arguments.length>1&&void 0!==arguments[1]?arguments[1]:{},{initialMessages:h,address:S,enabled:N=!0}

1=f,[E,I]=(0,n.useState)(null!=h?h:[]),[q,R]=(0,n.useState)(void 0===h),[k,A]=(0,n.useState)(null),[H,M]=(0,n.useState)(0),[C,x]=(0,n.useState)((null!=(t=null==h?void 0:h.length)?t:0)>=g.md),[Y,j]=(0,n.useState)(!1),L=(0,n.useRef)(null),X=(e,t)=>{var r,n,a;let s=null==e?void 0:e.next_before_sequence;if("number"!=typeof s||!Number.isSafeInteger(s)||s<=0)return;let l=null!=(a=null!=(n=(0,g.gv)(t))?n:null==(r=L.current)?void 0:r.anchor)?a:(0,g.gv)(et.current);null!==l&&(L.current={cursor:s,anchor:l})},[F,P]=(0,n.useState)(!1),J=(0,n.useRef)(!1),D=(0,n.useRef)(new Map),O=(0,n.useRef)(new Set),K=(0,n.useRef)(new Set),W=(0,n.useRef)(new Set),z=(0,n.useRef)(null),B=(0,n.useRef)(!1),Q=(0,n.useRef)(0),U="".concat(e,":").concat(null!=S?S:""),G=(0,n.useRef)(U),V=(0,n.useRef)(0),Z=(0,n.useRef)(void 0!==h?U:null),$=(0,n.useRef)(null),ee=(0,n.useRef)(null!=(r=(0,g.n9)(null!=h?h:[]))?r:0),et=(0,n.useRef)(E);et.current=E;let er=(0,n.useCallback)(e=>{J.current=e,P(e)},[]);return(0,n.useEffect)(()=>(j(!1),G.current!==U&&(G.current=U,Z.current=null,$.current=null,ee.current=0,et.current=[],I([]),R(!0),A(null),x(!1),D.current.clear(),z.current=null,L.current=null,er(!1)),()=>{var e;e={requestEpochRef:V,inFlightRef:B,initialFetchCountRef:Q,setIsLoadingMore:j},e.requestEpochRef.current+=1,e.inFlightRef.current=!1,e.initialFetchCountRef.current=0,e.setIsLoadingMore(!1)}),[U,N,er]),(0,n.useEffect)(()=>{if(!N||!e)return;let t=!1,r=null,n=null,s=0,f=!1,m=!1,h=!1,v=()=>{let e=r;r=null,e&&Promise.resolve(a.supabase.removeChannel(e)).catch(()=>{})},b=e=>{if(t||h||n)return;m||(m=e),v();let r=(0,l.realtimeRetryDelayMs)(s);s+=1,n=setTimeout(()=>{n=null,q()},r)},E=function(t){let r=arguments.length>1&&void 0!==arguments[1]?arguments[1]:"live",n=!(0,g.TH)(t.id)&&W.current.has(t.id);I(e=>{var a,s,l,u;let i=e.find(e=>e.id===t.id&&!(0,g.TH)(e.id)),o=null!=i?i:D.current.get(t.id),c=!!o&&"error"===t.message_type&&"error"!==o.message_type;if(o&&"error"===o.message_type&&"error"!==t.message_type||o&&!c&&_(o.created_at,t.created_at)&&y(o.metadata)>y(t.metadata))return et.current=e,e;let d=D.current.get(t.id);if("insert"===r&&d){let r=y(t.metadata)>y(d.metadata)||"error"===t.message_type&&"error"!==d.message_type,n=JSON.stringify(null!=(a=d.metadata)?a:null)===JSON.stringify(null!=(s=t.metadata)?s:null),i=(null!=(l=d.message_type)?l:null)===(null!=(u=t.message_type)?u:null);if(!r&&(d.content!==t.content||!n||!i))return et.current=e,e}let f=((e,t,r)=>{if((0,g.TH)(t.id)||r||e.some(e=>e.id===t.id))return D.current.set(t.id,t),p(e,t);let n=w(e,t);return n&&D.current.delete(n.id),D.current.set(t.id,t),p(n?e.filter(e=>e.id!==n.id):e,t)})(e,t,n);return et.current=f,f}),(0,g.TH)(t.id)||W.current.add(t.id),T(t,e)},q=async()=>{if(!S||t||h||f)return;f=!0;let n=m;m=!1;let g=n?await (0,l.remintRealtimeAuthResult)(S,e):await (0,l.ensureRealtimeAuthResult)(S,e);if(f=!1,t||h)return;if(!g.ok){if(403===g.status){h=!0;return}console.warn("[use-session-realtime] realtime auth unavailable; retrying",{sessionId:e,status:g.status}),b(!1);return}let p=a.supabase.channel("relay-msgs-".concat(e),{config:{private:!0,broadcast:{self:!1}}}).on("postgres_changes",{event:"INSERT",schema:"public",table:"vms_relay_messages",filter:"session_id=eq.".concat(e)},e=>{t||E(e.new,"insert")}).on("broadcast",{event:"relay-message"},r=>{let{payload:n}=r;if(t)return;let a=function(e,t){if(!e||"object"!=typeof e)return null;let r=u(e.type);if("tool_call"===r)return{name:"supraos-tool-call-start",detail:{sessionId:t,toolCallId:u(e.tool_call_id),name:u(e.tool_name)||"tool",inputPreview:u(e.input_preview).slice(0,200)}};if("tool_result"===r)return{name:"supraos-tool-call-result",detail:{sessionId:t,toolCallId:u(e.tool_call_id),output:u(e.output_preview).slice(0,200),is_error:!0===e.is_error}};if("partial_output"===r){let r=u(e.input_message_id);return{name:"supraos-relay-partial-output",detail:{sessionId:t,...r?{runId:r}:{},text:u(e.content)}}}if("run_stream_chunk"===r){let r=u(e.run_id).trim(),n=u(e.content),a="step"===e.kind||"raw"===e.kind?e.kind:void 0;return r&&n?{name:"supraos-run-stream-chunk",detail:{sessionId:t,runId:r,laneLabel:u(e.lane_label)||"design-round",chunk:n,at:u(e.at),...a?{kind:a}:{}}}:null}if("status"===r){let r=u(e.content);if("typing_start"===r)return{name:"supraos-relay-turn-started",detail

1:{sessionId:t}};if("typing_stop"===r)return{name:"supraos-relay-turn-stopped",detail:{sessionId:t}}}return null}(n,e);if(a)return void window.dispatchEvent(new CustomEvent(a.name,{detail:a.detail}));E(n)}).on("broadcast",{event:"workflow-template-changed"},e=>{let{payload:r}=e;t||(0,i.QP)(r)}).on("broadcast",{event:"wheel-changed"},r=>{var n;let{payload:a}=r;t||(0,o.mn)({sessionId:null!=(n=null==a?void 0:a.session_id)?n:e,wheel:null==a?void 0:a.wheel})}).on("broadcast",{event:c.kb},r=>{let{payload:n}=r;t||(0,c.gK)(e,n)}).on("broadcast",{event:d.Jo},r=>{let{payload:n}=r;t||(0,d.Lw)(e,n)}).on("broadcast",{event:d.k5},r=>{let{payload:n}=r;t||(0,d.yW)(e,n)});r=p,p.subscribe(n=>{if(!t&&!h&&r===p){if("SUBSCRIBED"===n){s=0;return}(0,l.isRealtimeRecoveryStatus)(n)&&(console.warn("[use-session-realtime] realtime channel interrupted; retrying",{sessionId:e,status:n}),b(!0))}})};q();let R=r=>{if(t)return;let{sessionId:n,message:a}=r.detail;n===e&&E(a)};window.addEventListener("supraos-message-sent",R);let k=r=>{if(t)return;let{sessionId:n,message:a}=r.detail;n===e&&(D.current.set(a.id,a),I(e=>{let t=p(e,a);return et.current=t,t}))},A=r=>{if(t)return;let{sessionId:n,tempId:a,message:s}=r.detail;n===e&&(D.current.delete(a),D.current.set(s.id,s),O.current.add(s.id),K.current.add(s.id),(0,g.TH)(s.id)||W.current.add(s.id),I(e=>{let t=p(e.filter(e=>e.id!==a),s);return et.current=t,t}))},H=r=>{if(t)return;let{sessionId:n,tempId:a}=r.detail;n===e&&(D.current.delete(a),I(e=>{let t=e.filter(e=>e.id!==a);return et.current=t,t}))};return window.addEventListener("supraos-message-optimistic",k),window.addEventListener("supraos-message-confirmed",A),window.addEventListener("supraos-message-rejected",H),()=>{t=!0,n&&clearTimeout(n),v(),window.removeEventListener("supraos-message-sent",R),window.removeEventListener("supraos-message-optimistic",k),window.removeEventListener("supraos-message-confirmed",A),window.removeEventListener("supraos-message-rejected",H)}},[e,S,N]),(0,n.useEffect)(()=>{let t;if(!N||!e||!S)return;let r=!1,n=V.current,a=async()=>{if(r||"visible"!==document.visibilityState||J.current||B.current||Q.current>0)return;if(Z.current!==U)return void M(e=>e+1);let l=ee.current;B.current=!0;try{var u;let n=await (0,s.authFetch)("/api/vms/relay/sessions/".concat(e,"/messages?after_sequence=").concat(l,"&count=none"),{address:S});if(!n.ok)throw Error(await n.text().catch(()=>"HTTP ".concat(n.status)));let i=await n.json();if(r||J.current)return;let o=Array.isArray(i)?i:null!=(u=i.messages)?u:[],c=(0,g.n9)(o);if(null!==c&&c>l&&(ee.current=c),o.length>0){let t=et.current,r=[];for(let e of o){(0,g.TH)(e.id)||W.current.add(e.id);let n=(0,g.TX)(t,e);n!==t&&r.push(e),t=n}if(t.length>g.YM&&(x(!0),t=t.slice(-g.YM)),r.length>0)for(let n of(et.current=t,I(t),r))T(n,e)}("boolean"==typeof i.has_more?i.has_more:o.length>=g.md)&&null!==c&&c>l&&(t=setTimeout(()=>{a()},0))}catch(e){r||console.warn("[use-session-realtime] transcript reconciliation failed",e)}finally{n===V.current&&(B.current=!1)}},l=$.current===U;$.current=U,l&&Z.current===U&&a();let u=setInterval(()=>{a()},25e3);return()=>{r=!0,clearTimeout(t),clearInterval(u)}},[e,S,N,U]),(0,n.useEffect)(()=>{if(!N||!e||!S||Z.current===U)return;let t=!1;return(async()=>{let r=await (0,m.CW)(e);if(t||Z.current===U||!(null==r?void 0:r.length))return;let n=[];for(let e of r){let t=function(e){let t=function(e){let t=null,r=e.data;if("string"==typeof r&&r.trim())try{let e=JSON.parse(r);e&&"object"==typeof e&&!Array.isArray(e)&&(t=e)}catch(e){t=null}else r&&"object"==typeof r&&!Array.isArray(r)&&(t=r);let n={};if(t)for(let e of b)void 0!==t[e]&&(n[e]=t[e]);for(let t of b)void 0!==e[t]&&(n[t]=e[t]);return n}(e);if("string"!=typeof t.id||!t.id||"string"!=typeof t.role||!t.role||"string"!=typeof t.content||"string"!=typeof t.created_at||!t.created_at)return null;let r={id:t.id,role:t.role,content:t.content,created_at:t.created_at};return"string"==typeof t.session_id&&(r.session_id=t.session_id),"string"==typeof t.address&&(r.address=t.address),"string"==typeof t.message_type&&(r.message_type=t.message_type),null===t.metadata?r.metadata=null:t.metadata&&"object"==typeof t.metadata&&!Array.isArray(t.metadata)&&(r.metadata=t.metadata),"number"==typeof t.message_sequence&&Number.isSafeInteger(t.message_sequence)?r.message_sequence=t.message_sequence:null===t.message_sequence&&(r.message_sequence=null),r}(e);t&&n.push(t)}if(t||Z.current===U||0===n.length)return;let a=new Set(W.current);for(let e of(I(e=>{if(Z.current===U)return e;let t=new Set(D.current.keys()),r=[];for(let e of D.current.values())r=(0,g.TX)(r,e);for(let n of e)!t.has(n.id)&&(0,g.TH)(n.id)&&(r=(0,g.TX)(r,n));for(let e of n)if(!(t.has(e.id)||r.some(t=>t.id===e.id))){if(!a.has(e.id)){let t=function(e,t){if((0,g.TH)(t.id))return null;let r=v(e,t);return 1!==r.length?null:_(r[0].created_at,t.created_at)?r[0]:null}(r,e);t&&(D.current.delete(t.id),r=r.filter(e=>e.id!==t.id))}r=(0,g.TX)(r,e)}if(r.length>g.YM){let e=new Set(t);for(let t of r)(0,g.TH)(t.id)&&e.add(t.id);let n=new Set,a=r.length-g.YM;for(let t of r){if(a<=0)break;e.has(t.id)||(n.add(t.id),a-=1)}if((r=r.filter(e=>!n.has(e.id))).length>g.YM){let t=r.filter(t=>e.has(t.id)),n=Math.max(0,g.YM-t.length),a=new Set(t.slice(-g.YM).map(e=>e.id));for(let s of r)if(a.size>=g.YM||!e.has(s.id)&&(a.add(s.id),a.size>=n+t.length))break;r=r.filter(e=>a.has(e.id))}}return r.length?r:e}),n))(0,g.TH)(e.id)||W.current.add(e.id);t||Z.current===U||R(!1)})(),()=>{t=!0}},[e,S,N,U]),(0,n.useEffect)(()=>

1{if(!N||Z.current===U||!e||!S)return;let t=!1,r=V.current;return Q.current+=1,(async()=>{let r=null;for(let l of[0,1e3,3e3]){if(l&&await new Promise(e=>setTimeout(e,l)),t)return;try{var n,a;let r=await (0,s.authFetch)("/api/vms/relay/sessions/".concat(e,"/messages?count=none&collapse_repeats=1"),{address:S});if(!r.ok)throw Error(await r.text().catch(()=>"HTTP ".concat(r.status)));let l=await r.json();if(t)return;let u=Array.isArray(l)?l:null!=(n=l.messages)?n:[];L.current=null,X(l,u),Z.current=U,ee.current=null!=(a=(0,g.n9)(u))?a:0,Array.isArray(l)||"boolean"!=typeof l.has_more?x(u.length>=g.md):x(l.has_more);let i=new Set(W.current);for(let e of(I(e=>{let t=new Set(D.current.keys()),r=[];for(let n of e)!t.has(n.id)&&(0,g.TH)(n.id)&&(r=(0,g.TX)(r,n));for(let e of D.current.values())r=(0,g.TX)(r,e);let n=new Set(r.map(e=>e.id));for(let t of u){if(n.has(t.id)){let e=r.find(e=>e.id===t.id),n=!!e&&(e.message_sequence===t.message_sequence||!Number.isSafeInteger(e.message_sequence)),a=!!e&&_(e.created_at,t.created_at)&&n;e&&a&&"error"!==e.message_type&&(y(t.metadata)>y(e.metadata)||"error"===t.message_type)&&(D.current.set(t.id,t),r=p(r,t));continue}let a=e.some(e=>e.id===t.id&&!(0,g.TH)(e.id))||i.has(t.id)?null:w(r,t);a&&(D.current.delete(a.id),r=r.filter(e=>e.id!==a.id)),r=(0,g.TX)(r,t),n.add(t.id)}return et.current=r,r}),u))(0,g.TH)(e.id)||W.current.add(e.id);A(null),R(!1);return}catch(e){r=e}}t||(A(r),R(!1))})().finally(()=>{r===V.current&&(Q.current=Math.max(0,Q.current-1))}),()=>{t=!0}},[e,S,N,U,H]),{messages:E,isLoading:q,error:k,hasMore:C,isLoadingMore:Y,loadMore:(0,n.useCallback)(()=>{var t,r;if(!N||B.current||Q.current>0||!S)return;let n=et.current,a=(t=(0,g.gv)(n),r=L.current,null===t?null:r&&r.anchor===t&&r.cursor<t?r.cursor:t);if(!a)return;B.current=!0,j(!0);let l=V.current;(async()=>{try{var t;let r=await (0,s.authFetch)("/api/vms/relay/sessions/".concat(e,"/messages?before_sequence=").concat(a,"&limit=").concat(g.md,"&count=none&collapse_repeats=1"),{address:S});if(!r.ok)throw Error(await r.text().catch(()=>"HTTP ".concat(r.status)));let n=await r.json();if(l!==V.current)return;let u=Array.isArray(n)?n:null!=(t=n.messages)?t:[];X(n,u),x("boolean"==typeof(null==n?void 0:n.has_more)?n.has_more:u.length>=g.md),u.length>0&&I(e=>{let{messages:t,evictedTail:r}=(0,g.vS)(u,e,g.YM);if(!r)return t;z.current=(0,g.n9)(t),er(!0);let n=t;for(let e of D.current.values())n=function(e,t,r){if("update"!==t.realtime_operation)return r(e,t);let n=e.findIndex(e=>e.id===t.id);if(n<0)return r(e,t);let a=e.slice();return a[n]=t,a}(n,e,g.TX);return n})}catch(e){l===V.current&&A(e)}finally{l===V.current&&(j(!1),B.current=!1)}})()},[e,S,N,er]),loadNewer:(0,n.useCallback)(()=>{var t;if(!N||B.current||Q.current>0||!J.current||!S)return;let r=et.current,n=null!=(t=z.current)?t:(0,g.n9)(r);if(!n)return;B.current=!0,j(!0);let a=V.current;(async()=>{try{var t,r;let l=await (0,s.authFetch)("/api/vms/relay/sessions/".concat(e,"/messages?after_sequence=").concat(n,"&limit=").concat(g.md,"&count=none"),{address:S});if(!l.ok)throw Error(await l.text().catch(()=>"HTTP ".concat(l.status)));let u=await l.json();if(a!==V.current)return;let i=Array.isArray(u)?u:null!=(t=u.messages)?t:[];i.length>0&&(I(e=>{let t=e;for(let e of i)t=(0,g.TX)(t,e);return t.length<=g.YM?t:(x(!0),t.slice(-g.YM))}),z.current=(0,g.n9)(i)),(!1===u.has_more||i.length<g.md)&&(ee.current=null!=(r=z.current)?r:ee.current,z.current=null,D.current.clear(),er(!1))}catch(e){a===V.current&&A(e)}finally{a===V.current&&(j(!1),B.current=!1)}})()},[e,S,N,er]),tailEvicted:F}}}}]);