Spaces:
Running
on
CPU Upgrade
l.at is not a function
7.ff53d70c.js:2 TypeError: l.at is not a function
at Xe (7.ff53d70c.js:2)
at Xe.next ()
at _ (7.ff53d70c.js:2)
at async O2.ee (7.ff53d70c.js:2)
_ @ 7.ff53d70c.js:2
async function (async)
_ @ 7.ff53d70c.js:2
ee @ 7.ff53d70c.js:2
(anonymous) @ scheduler.e442882f.js:1
(anonymous) @ scheduler.e442882f.js:1
q0 @ pendingMessage.f0c38773.js:299
(anonymous) @ scheduler.e442882f.js:1
te @ scheduler.e442882f.js:1
n @ pendingMessage.f0c38773.js:7
somewhere in
...),t=[];for(const n of s)try{t.push(JSON.parse(n))}catch(a){if(a instanceof SyntaxError)return{messageUpdates:t,remainingText:s.at(-1)??""}}return{messageUpdates:t,remainingText:""}}async function*He(e){let s=[];const t=/[a-zA-Z0-9À-ž']+$/,n=/^[a-zA-Z0-9À-ž']+/;for await(const a of e){if(a.type!=="stream"){yield a;continue}s.push(a);let d=0;for(let c=1;c<s.length;c++){const l=t.test(s[c-1].token),h=n.test(s[c].token),r=l&&h,m=c-d>=5;r&&!m||(yield{type:"stream",token:s.slice(d,c).map(p=>p.token).join("")},d=c)}s=s.slice(d)}for(const a of s)yield a}async function*Xe(e){const s=new EventTarget;let t=!1;const n=[],a=[],d=async()=>{const l=await e.next();l.done?t=!0:(n.push(l.value),a.push(performance.now()),d()),s.dispatchEvent(new Event("next"))};d();let c=performance.now();for(;!t||n.length>0;){const l=a.slice(-30),h=2e3,r=l.map((b,A,_)=>b-_[A-1]).slice(1).filter(b=>b>h).reduce((b,A)=>b+A,0),p=l.at(-1)-l[0]-r,f=Math.min(200,p/(l.length-1)),y=performance.now()-c;await Promise.race([ze(Math.max(5,f-y)),Fe(s,"next")])||n.length!==0&&(c=performance.now(),yield n.shift())}}const ze=e=>new Promise(s=>setTimeout(s,e)),Fe=(e,s)=>new Promise(t=>e.addEventListener(s,()=>t(!0),{once:!0}));function Ge(e){let s,t,n,a,d,c;document.title=s=e[5];function l(r){e[13](r)}let h={loading:e[2],pending:e[3],messages:e[6],shared:e[0].shared,preprompt:e[0].preprompt,models:e[0].models,currentModel:K([...e[0].models,...e[0].oldModels],e[0].model),assistant:e[0].assistant};return e[4]!==void 0&&(h.files=e[4]),a=new ke({props:h}),le.push(()=>_e(a,"files",l)),a.$on("message",e[9]),a.$on("retry",e[10]),a.$on("continue",e[11]),a.$on("vote",e[14]),a.$on("share",e[15]),a.$on("stop",e[16]),{c(){t=me("link"),n=ue(),Ee(a.$$.fragment),this.h()},l(r){const m=fe("svelte-626amo",document.head);t=he(m,"LINK",{rel:!0,href:!0,integrity:!0,crossorigin:!0}),m.forEach(B),n=pe(r),Te(a.$$.fragment,r),this.h()},h(){P(t,"rel","stylesheet"),P(t,"href","https://cdn.jsdelivr.net/npm/katex@0.16.8/dist/katex.min.css"),P(t,"integrity","sha384-GvrOXuhMATgEsSwCs4smul74iXGOixntILdUW9XmUC6+HX0sLNAK3q71HotJqlAn"),P(t,"crossorigin","anonymous")},m(r,m){ge(document.head,t),we(r,n,m),Ae(a,r,m),c=!0},p(r,[m]){(!c||m&32)&&s!==(s=r[5])&&(document.title=s);const p={};m&4&&(p.loading=r[2]),m&8&&(p.pending=r[3]),m&64&&(p.messages=r[6]),m&1&&(p.shared=r[0].shared),m&1&&(p.preprompt=r[0].preprompt),m&1&&(p.models=r[0].models),m&1&&(p.currentModel=K([...r[0].models,...r[0].oldModels],r[0].model)),m&1&&(p.assistant=r[0].assistant),!d&&m&16&&(d=!0,p.files=r[4],ye(()=>d=!1)),a.$set(p)},i(r){c||(Ie(a.$$.fragment,r),c=!0)},o(r){Ue(a.$$.fragment,r),c=!1},d(r){r&&B(n),B(t),Ce(a,r)}}}function Ke(e,s,t){let n,a,d,c,l,h,r,m,p;I(e,Le,o=>t(1,d=o)),I(e,L,o=>t(7,l=o)),I(e,Z,o=>t(18,h=o)),I(e,M,o=>t(19,r=o)),I(e,x,o=>t(20,m=o)),I(e,ve,o=>t(21,p=o));let{data:f}=s,y=!1,U=!1,b=[];async function A(){try{t(2,y=!0);const o=await fetch(${C}/conversation,{method:"POST",headers:{"Content-Type":"application/json"},body:JSON.stringify({fromShare:d.params.id,model:f.model})});if(!o.ok){M.set(await o.text()),console.error("Error while creating conversation: "+await o.text());return}const{conversationId:u}=await o.json();return u}catch(o){throw M.set(q.default),console.error(String(o)),o}}async function _({prompt:o,messageId:u=c.leaf??void 0,isRetry:k=!1,isContinue:D=!1}){var S,z;try{w(L,l=!1,l),t(2,y=!0),t(3,U=!0);const E=await de(()=>import("../chunks/index.dbaf2747.js").then(i=>i.i),["../chunks/index.dbaf2747.js","../chunks/_commonjsHelpers.d4b30cbb.js"],import.meta.url),V=await Promise.all(b.map(async i=>await E.readAndCompressImage(i,{maxHeight:224,maxWidth:224,quality:1}).then(async T=>await Oe(T))));let v;if(D&&u)(((z=(S=n.find(i=>i.id===u))==null?void 0:S.children)==null?void 0:z.length)??0)>0?w(M,r="Can only continue the last message",r):v=u;else if(k&&u){const i=n.find(T=>T.id===u);if(i||w(M,r="Message not found",r),(i==null?void 0:i.from)==="user"&&o){const T=Q({messages:n,rootMessageId:f.rootMessageId},{from:"user",content:o},u);v=J({messages:n,rootMessageId:f.rootMessageId},{from:"assistant",content:"",files:V},T)}else(i==null?void 0:i.from)==="assistant"&&(v=Q({messages:n,rootMessageId:f.rootMessageId},{from:"assistant",content:""},u))}else{const i=J({messages:n,rootMessageId:f.rootMessageId},{from:"user",content:o??"",files:V,createdAt:new Date,updatedAt:new Date},u);f.rootMessageId||t(0,f.rootMessageId=i,f),v=J({messages:n,rootMessageId:f.rootMessageId},{from:"assistant",content:"",createdAt:new Date,updatedAt:new Date},i)}t(6,n=[...n]);const O=n.find(i=>i.id===v);if(!O)throw new Error("Message to write to not found");const re=!!d.data.assistant,N=new AbortController,F=await We(d.params.id,{base:C,inputs:o,messageId:u,isRetry:k,isContinue:D,webSearch:!re&&p.useSearch,files:k?void 0:V},N.signal).catch(i=>{M.set(i.message)});if(F===void 0)return;t(4,b=[]);const G=[];for await(const i of F){if(l){N.abort();return}if(i.type==="finalAnswer"){t(2,y=!1),t(3,U=!1);break}if(G.push(i),i.type==="stream")t(3,U=!1),O.content+=i.token,t(6,n=[...n]);else if(i.type==="webSearch")O.updates=[...O.updates??[],i],t(6,n=[...n]);else if(i.type==="status")if(i.status==="title"&&i.message){const T=f.conversations.find(({id:ie})=>ie===d.params.id);T&&(T.title=i.message,w(x,m={title:i.message,convId:d.params.id},m))}else i.status==="error"&&w(M,r=i.message??"An error has occurred",r);else i.type==="error"&&(M.set(i.message),N.abort())}O.updates=G}catch(E){E instanceof Error&&E.message.includes("overloaded")?w(M,r="Too much traffic, please try again.",r):E instanceof Error&&E.message.includes("429")?w(M,r=q.rateLimited,r):E instanceof Error?w(M,r=E.message,r):w(M,r=q.default,r),console.error(E)}finally{t(2,y=!1),t(3,U=!1),await Re()}}async function X(o,u){let k=d.params.id,D;t(6,n=n.map(S=>S.id===u?(D=S.score,{...S,score:o}):S));try{await fetch(${C}/conversation/${k}/message/${u}/vote,{method:"POST",body:JSON.stringify({score:o})})}catch{t(6,n=n.map(S=>S.id!==u?S:{...S,score:D}))}}be(async()=>{h&&(t(4,b=h.files),await _({prompt:h.content}),w(Z,h=void 0,h))});async function $(o){f.shared?await A().then(async u=>{await W(${C}/conversation/${u},{invalidateAll:!0})}).then(async()=>await _({prompt:o.detail})).finally(()=>t(2,y=!1)):await _({prompt:o.detail})}async function ee(o){f.shared?await A().then(async u=>{await W(${C}/conversation/${u},{invalidateAll:!0})}).then(async()=>await _({prompt:o.detail.content,messageId:o.detail.id,isRetry:!0})).finally(()=>t(2,y=!1)):await _({prompt:o.detail.content,messageId:o.detail.id,isRetry:!0})}async function te(o){f.shared?await A().then(async u=>{await W(${C}/conversation/${u}`,{invalidateAll:!0})}).then(async()=>await ({messageId:o.detail.id,isContinue:!0})).finally(()=>t(2,y=!1)):({messageId:o.detail.id,isContinue:!0})}const j=De();I(e,j,o=>t(17,c=o));function se(o){b=o,t(4,b)}const ne=o=>X(o.detail.score,o.detail.id),ae=()=>Pe(d.params.id,f.title),oe=()=>(w(L,l=!0,l),t(2,y=!1));return e.$$set=o=>{"data"in o&&t(0,f=o.data)},e.$$.update=()=>{var o;e.$$.dirty&1&&t(6,{messages:n}=f,n),e.$$.dirty&2&&(d.params.id,w(L,l=!0,l),t(2,y=!1),w(j,c.editing=null,c)),e.$$.dirty&3&&t(5,a=((o=f.conversations.find(u=>u.id===d.params.id))==null?void 0:o.title)??f.title)},[f,d,y,U,b,a,n,l,X,$,ee,te,j,se,ne,ae,oe]}class at extends Me{constructor(s){super(),Se(this,s,Ke,Ge,ce,{data:0})}}export{at as component};