1import{ar as e,s as t,r,w as i,c as n}from"./vendor-core-DockhpYX.js";import{bu as s,u as a,bv as l,bw as o,bx as u,by as c,bz as d,bA as m,aR as v,bB as _,bC as g,bD as f,bE as p,bF as y,bG as h}from"./index-DIXwfVMT.js";const b=e=>e&&"object"==typeof e&&!Array.isArray(e)?e:{},k=e=>"string"==typeof e?e:"",S=e=>{if(null==e||""===e)return;const t=Number(e);return Number.isFinite(t)?t:void 0},I=e=>{const t=b(e);if(!["tool_type","selected_model","lyric_llm_model","references","vocals","audios","photos","videos","skills"].some(e=>e in t))return;const r=e=>Array.isArray(t[e])?t[e].flatMap(e=>{const t=b(e),r=k(t.source).trim();if(!r)return[];const i=b(t.snapshot),n={...k(i.title).trim()?{title:k(i.title).trim()}:{},...k(i.thumbnail_url).trim()?{thumbnail_url:k(i.thumbnail_url).trim()}:{},...k(i.mime_type).trim()?{mime_type:k(i.mime_type).trim()}:{},...Number.isFinite(Number(i.duration_ms))?{duration_ms:Math.max(0,Number(i.duration_ms))}:{}};return[{source:r,...Object.keys(n).length?{snapshot:n}:{}}]}):[],i=Array.isArray(t.skills)?t.skills.flatMap(e=>{const t=b(e),r=k(t.skill_name||t.type).trim();return r?[{skill_name:r}]:[]}):[];return{version:"agent.user_input.v1",tool_type:k(t.tool_type).trim(),...k(t.selected_model).trim()?{selected_model:k(t.selected_model).trim()}:{},...k(t.lyric_llm_model).trim()?{lyric_llm_model:k(t.lyric_llm_model).trim()}:{},references:r("references"),vocals:r("vocals"),audios:r("audios"),photos:r("photos"),videos:r("videos"),skills:i}},A=e=>"string"==typeof e?e.trim():"number"==typeof e&&Number.isSafeInteger(e)?String(e):"",w=(...e)=>{for(const t of e){if("string"==typeof t&&t.includes(":")){const e=t.split(":").map(Number);if(2===e.length&&e.every(e=>Number.isFinite(e))&&e[0]>=0&&e[1]>=0&&e[1]<60)return Math.round(1e3*(60*e[0]+e[1]))}const e=Number(t);if(Number.isFinite(e)&&e>0)return Math.round(e<1e3?1e3*e:e)}return 0},j=(e={})=>k(e.cover||e.cover_url||e.coverUrl||e.image_url||e.imageUrl),q=(e={},t={})=>A(e.song_id||e.songId||e.item_id||e.itemId||e.id||t.song_id||t.songId),x=(e,t="")=>{const r=b(e),i=b(r.artifact),n=Object.keys(i).length?i:r,s=A(n.artifact_id||n.artifactId),a=k(n.tool_name||n.tool);if(!s||!a)return null;const l=b(n.data),o=A(n.job_id||n.jobId||l.job_id||l.jobId||t);return{artifact_id:s,tool_name:a,data:l,...o?{job_id:o}:{}}},$=(...e)=>{for(const t of e){const e=b(t).lyrics_sections;if(Array.isArray(e)&&e.length)return e}for(const t of e){const e=b(t);for(const t of[e.lyrics,e.lyric]){if("string"==typeof t&&t.trim())return t;if(Array.isArray(t)&&t.length)return t}}},M=e=>{if("string"==typeof e||"number"==typeof e)return k(e).trim();if(Array.isArray(e))return e.map(e=>M(e)).filter(Boolean).join("\n");const t=b(e);if(!Object.keys(t).length)return"";const r=k(t.text||t.content).trim();if(r)return r;const i=[t.rows,t.lines,t.items,t.sections].map(e=>M(e)).find(Boolean);if(!i)return"";const n=k(t.label||t.section_name||t.sectionName).trim();return n?`${n}\n${i}`:i},E=e=>{if(!e)return[];const t=b(e.data),r=Array.isArray(t.choices)?t.choices.map(b):[],i=[t,...r];let n="";for(const l of i){for(const e of[l.lyrics,l.lyric,l.lyrics_text,l.lyric_text,l.lyrics_sections])if(n=M(e),n)break;if(n)break}if(!n)return[];const s=i.find(e=>k(e.title||e.name||e.song_title).trim()),a=k((null==s?void 0:s.title)||(null==s?void 0:s.name)||(null==s?void 0:s.song_title)||(null==s?void 0:s.song_name)||(null==s?void 0:s.track_title)||t.title||t.name||t.song_title||t.song_name||t.track_title).trim();return[{id:`${e.artifact_id}:lyrics`,artifact_id:e.artifact_id,title:a,text:n}]},N=(e,t)=>({...e,...void 0===e.model&&void 0!==t.model?{model:t.model}:{},...void 0===e.model_display&&void 0!==t.model_display?{model_display:t.model_display}:{}}),O=e=>{var t;if(!e)return[];if("music.separate_stems"===e.tool_name)return[];const r=b(e.data),i=k(r.kind),n="music.generate_soundtrack"===e.tool_name;if(!("audio"===i||(null==(t=e.tool_name)?void 0:t.startsWith("music."))&&"music.generate_lyrics"!==e.tool_name)||"video"===i&&!n)return[];return(Array.isArray(r.choices)?r.choices:[]).flatMap((t,i)=>{const n=b(t),s=N(n,r),a=((e={})=>k(e.audio_url||e.audioUrl||e.mp3_url||e.mp3Url||e.url||e.flac_url||e.wav_url||e.source_url||e.sourceUrl))(s);if(!a)return[];const l=q(n,r),o=l||`${e.artifact_id}:${i}`,u=$(s,r);return[{...s,id:o,song_id:l||o,title:k(n.title||n.name)||`Audio ${i+1}`,audio_url:a,url:a,mp3_url:k(n.mp3_url||n.mp3Url)||a,cover:j(n),cover_url:j(n),duration_ms:w(n.duration_ms,n.durationMs,n.duration),state:k(r.status)||"completed",pstate:3,generate_state:3,is_streaming:!1,artifact_id:e.artifact_id,choice_index:i,tool_name:e.tool_name,job_id:A(n.job_id||n.jobId)||e.job_id||void 0,...u?{lyrics:u}:{}}]})},U=e=>{if(!e||"music.separate_stems"!==e.tool_name)return[];const t=b(e.data),r=k(t.zip_url||t.zipUrl||t.url).trim();if(!r)return[];const i=k(t.midi_zip_url||t.midiZipUrl).trim(),n=k(t.content_type||t.contentType).trim(),s=k(t.stem_type||t.stemType).trim();return[{id:e.artifact_id,artifact_id:e.artifact_id,download_url:r,...i?{midi_download_url:i}:{},...n?{content_type:n}:{},...s?{stem_type:s}:{},tool_name:e.tool_name}]},B=e=>{if(!e)return[];const t=b(e.data),r=Array.isArray(t.images)?t.images.map(b):[];if(r.length)return r.flatMap((r,i)=>{const n=k(r.url||r.image_url||r.imageUrl);return n?[{id:`${e.artifact_id}:image:${i}`,type:"image",url:n,cover_url:j(r),title:k(r.title||t.title)}]:[]});const i=Array.isArray(t.choices)?t.choices:[];return(i.length?i.map(b):[t]).flatMap((r,n)=>{const s=k(r.mime_type||r.content_type).toLowerCase()||(i.length?"":k(t.mime_type||t.content_type).toLowerCase()),a=k(r.url),l=k(r.video_url||r.videoUrl)||(s.startsWith("video/")?a:""),o=k(r.image_url||r.imageUrl||(s.startsWith("image/")?a:"")),u=l||o;if(!u)return[];const c=q(r,t);return[{id:`${e.artifact_id}:${c||n}`,type:l?"video":"image",url:u,cover_url:j(r),title:k(r.title||t.title),artifact_id:e.artifact_id,...c?{song_id:c}:{},choice_index:n}]})},C=(e={})=>{const t=b(e.content);return k(t.text)?k(t.text):(Array.isArray(t.blocks)?t.blocks:[]).filter(e=>{const t=k(b(e).type);return!t||"text"===t}).map(e=>
1k(b(e).text)).filter(Boolean).join("\n")},T=(e={})=>k(e.message_type||e.messageType).trim().toLowerCase(),P=(e={})=>{if("message"!==e.type||!e.message)return null;const t=b(e.message),r="tool"===t.role?"system":t.role;if(!["user","assistant","system"].includes(r))return null;const i=b(t.content),n=T(t)||T(e),s=k(t.content_kind||t.contentKind||i.content_kind||i.contentKind).trim().toLowerCase(),a="lyrics"===n||"lyrics"===s,l=(Array.isArray(i.blocks)?i.blocks:[]).filter(e=>"artifact_card"===b(e).type).map(e=>x(b(e).artifact)).filter(Boolean),o=((e={})=>{const t=I(e.structured_input);if(t)return t;const r=b(e.content),i=Array.isArray(r.blocks)?r.blocks:[];for(const n of i){const e=b(n);if("input_context"===e.type){const t=I(e);if(t)return t}}})(t),u=A(t.message_id||t.messageId||t.id||e.message_id||e.messageId)||`message_${e.session_id||"unknown"}_${e.message_sequence||Date.now()}`,c=l.flatMap(E),d=a?((e={})=>{const t=b(e.content),r=k(e.content).trim()||C(e).trim();return r||M(e.lyrics||e.lyric||t.lyrics||t.lyric||t.lyrics_text||t.lyric_text)})(t):"";d&&c.push({id:`message:${u}`,message_id:u,title:k(t.title||i.title||t.song_title||i.song_title||t.song_name||i.song_name||t.track_title||i.track_title).trim(),text:d,...k(e.run_id||t.run_id||t.runId)?{run_id:A(e.run_id||t.run_id||t.runId)}:{}});const m=l.flatMap(U),v=C(t),_="artifact"===n&&(l.some(e=>e.tool_name===v)||m.length)?"":v;return{id:u,role:r,content:a?"":_,...n?{messageType:n}:{},...s?{contentKind:s}:{},...o?{structuredInput:o}:{},tracks:l.flatMap(O),lyricArtifacts:c,media:l.flatMap(B),stemPackages:m,artifacts:l,status:"failed"===t.status?"error":"done",runId:A(e.run_id||t.run_id||t.runId),sequence:Number(e.message_sequence)||0,createdAt:Number(e.created_at_ms)||Date.now()}},L=(e={})=>{let t={text:k(e.content)},r=e.structured_input;if(e.content_json)try{const i=b(JSON.parse(e.content_json));t=Object.keys(b(i.content)).length?b(i.content):i,r=r||i.structured_input||i.structuredInput||b(i.content).structured_input||b(i.content).structuredInput,!t.text&&e.content&&(t.text=e.content)}catch{}const i=P({type:"message",session_id:e.session_id,run_id:e.run_id,message_id:e.message_id,message_sequence:e.sequence,created_at_ms:e.created_at_ms,message:{message_id:e.message_id,role:e.role,message_type:e.message_type,content_kind:e.content_kind||e.contentKind,status:e.status,structured_input:r,content:t}});if(!i)return null;const n=(e=>{const t=S(e);return[1,2,3].includes(t)?t:void 0})(e.reaction);return void 0===n?i:{...i,reaction:n}},D=(e={})=>{if("run_event"!==e.type&&"run_live_event"!==e.type)return null;const t=b(e.activity),r=b(e.payload),i="run.activity"===t.type?t:b(r.activity),n=k(i.activity_id||i.activityId).trim();if("run.activity"!==i.type||!n)return null;const s=k(i.visibility)||"user";if("user"!==s)return null;const a=S(i.progress),l=void 0!==a&&Number.isInteger(a)&&a>=0&&a<=100?a:void 0,o=(e=>{const t=Object.entries(b(e)).flatMap(([e,t])=>"string"==typeof t||"number"==typeof t||"boolean"==typeof t||null===t?[[e,t]]:[]);return t.length?Object.fromEntries(t):void 0})(i.message_args),u=k(i.skill_name||i.skillName||i.skill||i.name||i.tool_name||i.tool).trim();return{type:"run.activity",activity_id:n,kind:k(i.kind)||"working",status:k(i.status)||"running",message_key:k(i.message_key),message:k(i.message),...u?{skill_name:u}:{},...o?{message_args:o}:{},icon_key:k(i.icon_key)||"activity",visibility:s,...void 0!==l?{progress:l}:{},priority:S(i.priority)??0,...k(i.source_item_id)?{source_item_id:k(i.source_item_id)}:{},updated_at_ms:Number(e.created_at_ms)||Date.now()}},z=(e,t)=>String(t.job_id||t.jobId||t.tool_call_id||t.toolCallId||t.id||t.path||e),F=(e={})=>{if("run_event"!==e.type&&"run_live_event"!==e.type)return{};if("reasoning.summary_delta"!==e.event_type)return{};const t=b(e.payload),r=k(t.delta||t.message||t.text);return r?{runtimeItems:[{id:z(e.event_type,t),title:"Thought",status:k(t.status)||"running",content:r,mode:"append"}]}:{}},R=(e={})=>{if("run_live_event"!==e.type||"model.message.delta"!==e.event_type)return{text:"",isLyrics:!1};const t=b(e.payload),r=k(t.delta||t.text||t.content),i=k(t.content_kind||t.contentKind||e.content_kind||e.contentKind).trim().toLowerCase(),n=k(t.message_type||t.messageType||e.message_type||e.messageType).trim().toLowerCase();return{text:r,contentKind:i,messageType:n,isLyrics:"lyrics"===i||"lyrics"===n,itemId:A(t.item_id||t.itemId||t.message_id||t.messageId),title:k(t.title||t.name||t.song_title||t.song_name||t.track_title).trim()}},W=Symbol("agent-song-actions"),K=(e={})=>Object.fromEntries(["title","cover","song_cover_task_video_m3u8","song_cover_task_video_cover","song_cover_task_used","is_liked","is_disliked","favorite_state","publish_state","machine_audit_state","allow_remix","is_played"].filter(t=>void 0!==e[t]).map(t=>[t,e[t]])),Q=(e,t={})=>Object.fromEntries(Object.entries(K(e)).filter(([e,r])=>!Object.is(r,t[e]))),G=(e,t,r)=>{var i;if(!(null==(i=e.playlist)?void 0:i.length))return r();e.addToPlayItemAfterCurrent(t),"agent_chat"===e.curPlayGroup&&e.playlist.length>1&&(e.noAutoAdvance=!1)},J={beat:"sys-linear-beats",make_beat:"sys-linear-beats",make_a_beat:"sys-linear-beats",lyrics_video:"biz-nav-create-video",lyrics:"sys-linear-lyrics",lyric_writing:"sys-linear-lyrics",write_lyrics:"sys-linear-lyrics",remix:"sys-linear-remix-on",soundtrack:"sys-linear-sound",sound_track:"sys-linear-sound",stems:"sys-linear-sound",get_stems:"sys-linear-sound",get_stem:"sys-linear-sound",video:"biz-video-generate",voice_clone:"sys-linear-tts-1"},V={"get stems":"sys-linear-sound","lyric video":"biz-nav-create-video","lyrics video":"biz-nav-create-video","lyric writing":"sys-linear-lyrics","make a beat":"sys-linear-beats",remix:"sys-linear-remix-on",soundtrack:"sys-linear-sound","voice clone":"sys-linear-tts-1"},Z=(e={})=>{const t=String(e.type||"").trim().toLowerCase().replace(/[^a-z0-9]+/g,"_").replace(/^_|_$/g,""),r=String(e.dis
1play_name||e.name||"").trim().toLowerCase(),i=String(e.icon||"").trim();return V[r]||J[t]||(i.startsWith("sys-")||i.startsWith("biz-")?i:J[i])||"sys-linear-lyrics"},H=(e={},t={})=>{const r=String(e.display_name||e.name||t.name||"").trim().toLowerCase().replace(/[^a-z0-9]+/g,"_").replace(/^_|_$/g,""),i=String(e.type||e.tool_type||t.type||r).trim(),n=String(e.display_name||e.name||t.name||i).trim();return i&&n?{...t,...e,type:i,name:n,placeholder:String(e.placeholder||t.placeholder||"").trim(),icon:Z({...t,...e,type:i,name:n}),dividerBefore:Boolean(e.dividerBefore??e.divider_before??t.dividerBefore)}:null},X=(e=[],t="")=>{const r=String(t).trim().toLowerCase();return r&&e.find(e=>String((null==e?void 0:e.display_name)||(null==e?void 0:e.name)||"").trim().toLowerCase()===r)||null},Y=e=>{const t=String(e||"").trim();if(!t||/^(https?:)?\/\//i.test(t)||/^(blob:|data:)/i.test(t))return t;const r=String("https://static-cos.mureka.ai/").replace(/\/$/,"");return r?`${r}/${t.replace(/^\//,"")}`:t},ee=(e={})=>{const t=String(e.card_key||"").trim();if(t)return t;const r=String(e.song_id||e.songId||"").trim();if(!e.is_streaming&&r)return`song:${r}`;const i=String(e.job_id||e.jobId||e.run_id||e.runId||"").trim();return i?`stream:${i}`:String(e.id||e.audio_url||e.url||"").trim()},te=e=>"string"==typeof e||"number"==typeof e?String(e).trim():"",re=(e={})=>{const t=e&&"object"==typeof e?e:{},r=String(t.id??t.song_id??t.songId??t.item_id??t.itemId??""),i=t.song_id??t.songId??(r&&!r.startsWith("stream:")?r:""),n=Number(i),a=/^\d+$/.test(String(i).trim())&&Number.isSafeInteger(n)&&n>0?n:"",l=((e={})=>String(e.stream_url||e.streamUrl||"").trim())(t),o=((e={})=>String(e.mp3_url||e.mp3Url||e.completed_audio_url||e.completedAudioUrl||Y(e.mp3_oss_key)||(e.is_streaming?"":e.audio_url)||(e.is_streaming?"":e.audioUrl)||(e.is_streaming?"":e.url)||"").trim())(t),u=String(t.cover||t.cover_url||t.coverUrl||"").trim()||Y(t.cover_oss_key),c=((e={})=>{const t=[e.duration_milliseconds,e.duration_ms,e.durationMs,e.duration];for(const r of t){if("string"==typeof r&&r.includes(":")){const e=r.split(":").map(Number);if(2===e.length&&e.every(e=>Number.isFinite(e))&&e[0]>=0&&e[1]>=0&&e[1]<60)return Math.round(1e3*(60*e[0]+e[1]))}const e=Number(r);if(Number.isFinite(e)&&e>0)return Math.round(e<1e3?1e3*e:e)}return 0})(t),d=!0===t.is_streaming||Boolean(l)&&!o,m=((e={})=>{const t=[e.model_info,e.modelInfo,e.model].find(e=>e&&"object"==typeof e&&!Array.isArray(e)),r=t||{},i=te(e.model_name)||te(e.modelName)||te(r.name)||(t?"":te(e.model)),n=te(e.model_label);return{model:te(e.model_display_name)||te(e.model_display)||te(r.display_name)||te(r.displayName)||te(e.model)||n||i,model_name:i,...n?{model_label:n}:{},...t?{model_info:t,modelInfo:t}:{}}})(t);return{...t,...void 0!==t.lyrics||void 0!==t.lyrics_sections?{lyrics:s(t.lyrics??t.lyrics_sections)}:{},...r?{id:r}:{},song_id:a,title:String(t.title||t.name||"Audio").trim(),cover:u,cover_url:u,cover_oss_key:t.cover_oss_key,mp3_oss_key:t.mp3_oss_key,mp3_url:o,audio_url:o||l||String(t.audio_url||t.url||""),url:o||l||String(t.url||""),stream_url:l,...t.completed_audio_url||t.completedAudioUrl?{completed_audio_url:t.completed_audio_url||t.completedAudioUrl}:{},duration_milliseconds:c,duration_ms:c,...m,generate_state:t.generate_state??(d?2:3),pstate:t.pstate??(d?2:3),is_streaming:d,is_agent_track:!0}},ie=(e={})=>{const t=re(e),r=!0===t.is_streaming;return{feed_id:t.feed_id,song_id:t.song_id,songs:[t],title:t.title,cover:t.cover,state:r?2:3,mode:t.mode,model:t.model,model_label:t.model_label,generation_method:t.generation_method,thinking_process_url:t.thinking_process_url,is_generated_from_uploaded_file:t.is_generated_from_uploaded_file}},ne=new Set(["completed","failed","canceled","expired"]),se=e=>String(e||"").replace(/\s+/g," ").trim().toLowerCase(),ae=e=>{const t=Number(e);return Number.isFinite(t)&&t>0?t:0},le=(e,t="")=>{if(!e||"object"!=typeof e)return null;const r=String(e.status||"").toLowerCase();if(!ne.has(r))return null;let i=48e3;const n=(Array.isArray(e.blocks)?e.blocks:[]).slice(0,80).flatMap((e,t)=>{const r=((e,t,r)=>{if(!e||"object"!=typeof e)return null;const i="skill"===e.type?"skill":"thought",n=String(e.text||"").slice(0,Math.max(0,r));return"skill"===i||n?{id:String(e.id||`${i}:${t}`),type:i,label:String(e.label||""),text:n,status:String(e.status||""),sequence:Number(e.sequence)||t,updatedAt:ae(e.updatedAt)}:null})(e,t,i);return r?(i-=r.text.length,[r]):[]}),s=String(e.runId||t).trim();return s?{runId:s,status:r,startedAt:ae(e.startedAt),finishedAt:ae(e.finishedAt),blocks:n}:null},oe=(e={})=>Object.fromEntries(Object.entries(e).flatMap(([e,t])=>{const r=le(t,e);return r?[[e,r]]:[]})),ue=(e={})=>Object.fromEntries(Object.entries(oe(e)).sort(([,e],[,t])=>(t.finishedAt||t.startedAt)-(e.finishedAt||e.startedAt)).slice(0,20)),ce=(e,t)=>{const r=String((null==e?void 0:e.content)||"").trim(),i=String((null==t?void 0:t.content)||"").trim();if(!r)return i;if(!i)return r;const n=se(r),s=se(i);return n===s?i:n.includes(s)?r:s.includes(n)?i:`${r}\n\n${i}`},de=e=>{var t,r;return(null==(r=null==(t=globalThis.crypto)?void 0:t.randomUUID)?void 0:r.call(t))||`${e}_${Date.now()}_${Math.random().toString(16).slice(2)}`},me=(e=[])=>e.flatMap(e=>{var t;const r=String((null==e?void 0:e.chat_id)||""),i=String((null==e?void 0:e.current_session_id)||r);return r&&i?[{...e,chat_id:r,current_session_id:i,title:e.title||(null==(t=e.last_message)?void 0:t.content)||"New chat"}]:[]}),ve=e=>Array.isArray(e)?e:e&&"object"==typeof e?Array.isArray(e.list)?e.list:Array.isArray(e.songs)?e.songs:Array.isArray(e.items)?e.items:e.data&&e.data!==e?ve(e.data):[]:[],_e=(e={})=>[e.song_id,e.songId,e.id,e.item_id,e.itemId].map(e=>String(e||"").trim()).find(e=>/^\d+$/.test(e))||"",ge=(e={})=>[e.job_id,e.jobId,e.run_id,e.runId,e.artifact_id,e.artifactId,e.message_id,e.messageId].map(e=>
1String(e||"").trim()).filter(Boolean),fe=(e={})=>[e.audio_url,e.audioUrl,e.mp3_url,e.mp3Url,e.mp3_oss_key,e.cover_url,e.coverUrl,e.cover_oss_key,e.stream_url,e.streamUrl,e.url].map(e=>String(e||"").trim()).filter(Boolean),pe=e("agentEasyV1",()=>{const e=a(),s=t(null),I=r(!1),q=r(!1),M=r(!1),C=r(""),T=r(""),z=r(""),W=r(""),Q=r([]),G=r(!1),J=r(!1),V=r([]),Z=r({}),X=r([]),Y=e=>{const t=_e(e);if(X.value.includes(t))return[];const r=Z.value[t];return[r?{...e,...r}:e]};i(()=>{var t;return null==(t=e.authData)?void 0:t.user_id},()=>{Z.value={},X.value=[]});const ee=r(""),te=r(!1),ie=r({}),ae=r({}),pe=r({}),ye=r({}),he=r({}),be=r({}),ke=r([]),Se=r(!1),Ie=r(""),Ae=r("Describe an idea to create a song"),we=r([]),je=r([]),qe=r({}),xe=r({message:"",template_id:null}),$e=r(0),Me=r([]);let Ee=0,Ne=null,Oe=null,Ue=0,Be=[];const Ce=new Map,Te=new Map,Pe=new Map,Le=new Map,De=new Map,ze=new Map,Fe=new Set,Re=new Map,We=new Set,Ke=new Map,Qe=new Map,Ge=new Map,Je=new Map;let Ve=null,Ze=null,He=0,Xe=0;const Ye=n(()=>V.value.length>0),et=t=>{return`mureka_agent_runtime_v1:${encodeURIComponent(String((null==(r=e.authData)?void 0:r.user_id)||(null==(n=null==(i=e.userInfo)?void 0:i.user)?void 0:n.id)||"").trim()||"anonymous")}:${encodeURIComponent(String(t||""))}`;var r,i,n},tt=()=>{if("undefined"==typeof window)return null;try{return window.sessionStorage}catch{return null}},rt=e=>{const t=et(e),r=tt();if(r)try{const e=JSON.parse(r.getItem(t)||"null");if(1===(null==e?void 0:e.version)&&e.runs){const r=ue(e.runs);return Je.set(t,r),oe(r)}}catch{}return oe(Je.get(t))},it=(e,t)=>{const r=String(ae.value[e]||T.value||"").trim(),i=le(t,e);r&&i&&((e,t)=>{const r=et(e),i=ue(t);Je.set(r,i);const n=tt();if(n)try{n.setItem(r,JSON.stringify({version:1,runs:i}))}catch{}})(r,{...rt(r),[i.runId]:i})},nt=()=>Object.entries(ie.value).some(([e,t])=>!ne.has(t)&&(e=>!ae.value[e]||ae.value[e]===T.value)(e)),st=()=>Object.values(qe.value).filter(e=>e.session_id===T.value).length,at=n(()=>je.value.length>0||we.value.length>0||$e.value>0||st()>0||nt()),lt=e=>{const t=De.get(e.run_id)||e.optimistic_id,r=V.value.find(r=>r.id===t||r.messageId===e.message_id||r.id===e.message_id||r.id===`message:${e.message_id}`),i=String((null==r?void 0:r.content)||e.content||e.message||"").trim(),n=Array.isArray(null==r?void 0:r.skills)?r.skills.map(e=>String((null==e?void 0:e.skill_name)||(null==e?void 0:e.type)||"").trim()).filter(Boolean):[],s=(null==r?void 0:r.structuredInput)||{},a=["references","vocals","audios","photos","videos"].some(e=>Array.isArray(s[e])&&s[e].length);return i||(n.length?n.join(", "):"")||(a?"Attachment":"Queued message")},ot=n(()=>[...we.value,...je.value.map((e,t)=>({...e,queue_position:we.value.length+t+1,local:!0}))].map(e=>({...e,content:lt(e)}))),ut=n(()=>new Set([...we.value.map(e=>e.run_id),...je.value.map(e=>e.run_id)]).size+st()+$e.value>=3),ct=n(()=>{var e;return(null==(e=Object.entries(ie.value).filter(([e,t])=>!(ne.has(t)||"queued"===t||"canceling"===t||ae.value[e]&&ae.value[e]!==T.value)).at(-1))?void 0:e[0])||""}),dt=n(()=>Boolean(ct.value)),mt=n(()=>te.value||Object.values(ie.value).some(e=>!ne.has(e))),vt=n(()=>{const e=[...we.value,...je.value],t=new Set(e.map(e=>e.run_id)),r=new Set(e.flatMap(e=>{const t=String(e.message_id||"").trim();return t?[t,`message:${t}`]:[]}));return V.value.filter(e=>!("user"===e.role&&(t.has(e.runId)||r.has(e.id)))).map(e=>{var t;return(null==(t=e.tracks)?void 0:t.length)?{...e,tracks:e.tracks.flatMap(Y)}:e})}),_t=n(()=>{const e=new Set;return V.value.flatMap(e=>(e.tracks||[]).flatMap(Y)).filter(t=>{if(1===Number(t.is_disliked))return!1;const r=String(t.id||t.audio_url||t.url||"");return!(!r||e.has(r))&&(e.add(r),!0)})}),gt=e=>(Ee+=1,`${e}_${Date.now()}_${Ee}`),ft=(e=null)=>{const t=Be;Be=[],t.forEach(({resolve:t,reject:r,timer:i})=>{globalThis.clearTimeout(i),e?r(e):t()})},pt=e=>{Ce.forEach(({reject:t,timer:r})=>{globalThis.clearTimeout(r),t(e)}),Ce.clear()},yt=e=>{const t=Re.get(e),r=V.value.find(e=>e.id===t);if(r)return r;const i={id:`stream:${e||de("run")}`,role:"assistant",content:"",tracks:[],lyricArtifacts:[],media:[],stemPackages:[],artifacts:[],status:"streaming",runId:e,transient:!0,createdAt:Date.now()};return Re.set(e,i.id),V.value.push(i),i},ht=e=>{if(!e)return null;const t=ye.value[e];if(t)return t;const r={runId:e,status:"queued",startedAt:Date.now(),finishedAt:0,currentActivity:null,blocks:[]};return ye.value={...ye.value,[e]:r},r},bt=(e,t)=>{const r=ht(e);
1if(!r)return null;const i={...r,...t};return ye.value={...ye.value,[e]:i},i},kt=e=>{const t=String((null==e?void 0:e.skill_name)||"").trim(),r=String((null==e?void 0:e.message)||"").trim(),i=String((null==e?void 0:e.message_key)||"").trim(),n=String((null==e?void 0:e.kind)||"").trim();return t||r||i||n||"Working"},St=(e,t,r=0)=>{if(!e||!t)return;const i=ht(e),n=`activity:${t.activity_id}`,s=[...i.blocks],a=s.findIndex(e=>e.id===n),l={id:n,type:"skill",label:kt(t),text:String(t.message||"").trim(),status:t.status||"running",sequence:r||s.length,updatedAt:Date.now()};if(a>=0)s[a]={...s[a],...l};else{const e=s.at(-1);"skill"===(null==e?void 0:e.type)&&(e.text||e.label)===(l.text||l.label)||s.push(l)}s.sort((e,t)=>(e.sequence||0)-(t.sequence||0)),bt(e,{currentActivity:t,blocks:s}),Qt(e)||yt(e)},It=(e,t,r=0)=>{if(!e||!(null==t?void 0:t.content))return;const i=ht(e),n=`thought:${t.id}`,s=[...i.blocks],a=s.findIndex(e=>e.id===n),l=a>=0?s[a]:null,o=t.mode||"replace";let u=String(t.content||"");if(l&&"append"===o&&(u=`${l.text||""}${u}`),l&&"append_line"===o){const e=String(l.text||"").trim().split("\\n").at(-1),t=u.trim();u=t&&t!==e?`${l.text?`${l.text}\\n`:""}${u}`:l.text}const c={id:n,type:"thought",label:t.title||"Thought",text:u,status:t.status||"running",sequence:(null==l?void 0:l.sequence)||r||s.length,updatedAt:Date.now()};a>=0?s[a]=c:s.push(c),s.sort((e,t)=>(e.sequence||0)-(t.sequence||0)),bt(e,{blocks:s}),Qt(e)||yt(e)},At=(e={})=>String(e.job_id||e.jobId||""),wt=(e={})=>String(e.run_id||e.runId||""),jt=(e={})=>String(e.artifact_id||""),qt=(e={})=>{const t=e.choice_index??e.choiceIndex;if(null==t||""===t)return"";const r=Number(t);return Number.isInteger(r)&&r>=0?String(r):""},xt=(e={})=>String(e.audio_url||e.audioUrl||e.url||""),$t=(e={})=>String(e.stream_url||e.streamUrl||""),Mt=(e={})=>Boolean(!0===e.is_streaming||$t(e)&&!((e={})=>String(e.mp3_url||e.mp3Url||""))(e)),Et=l,Nt=(e={},t={})=>({...e,...t,...Et(t.lyrics)||Et(e.lyrics)?{lyrics:h(e.lyrics,t.lyrics)}:{}}),Ot=(e={},t={})=>{const r=At(e),i=At(t);if(r&&i&&r!==i)return!1;const n=wt(e),s=wt(t);if(n&&s&&n!==s)return!1;const a=jt(e),l=jt(t);if(a&&l&&a!==l)return!1;const o=qt(e),u=qt(t);return(!o||!u||o===u)&&(!(!r||!i)||(!(!n||!s)||Boolean((Mt(e)||Mt(t))&&a&&a===l)))},Ut=(e=[],t=[])=>{const r=new Map;return[...e,...t].forEach(e=>{const t=String(e.id||xt(e));if(t&&r.set(t,Nt(r.get(t),e)),t)for(const[i,n]of[...r])if(i!==t&&Ot(n,e))if(Mt(n)||!Mt(e)){if(Mt(n)){if(!Mt(e)&&$t(n)){const s=Nt(n,r.get(t)||e),a=String(n.card_key||n.id||i);$t(s)?r.set(t,{...s,card_key:s.card_key||a}):r.set(t,{...s,stream_url:$t(n),card_key:s.card_key||a})}r.delete(i)}}else r.delete(t)}),[...r.values()]},Bt=(e=[],t=[])=>{const r=new Map;return[...e||[],...t||[]].forEach(e=>{const t=String((null==e?void 0:e.id)||`${(null==e?void 0:e.type)||""}:${(null==e?void 0:e.url)||""}`).trim();t&&r.set(t,{...r.get(t)||{},...e})}),[...r.values()]},Ct=(e=[],t=[])=>{const r=new Map;return[...e||[],...t||[]].forEach(e=>{const t=String((null==e?void 0:e.id)||(null==e?void 0:e.artifact_id)||(null==e?void 0:e.download_url)||"").trim();t&&r.set(t,{...r.get(t)||{},...e})}),[...r.values()]},Tt=(e=[],t=[])=>{const r=new Map;return[...e,...t].forEach(e=>{const t=String((null==e?void 0:e.id)||(null==e?void 0:e.artifact_id)||`${(null==e?void 0:e.title)||""}:${(null==e?void 0:e.text)||""}`).trim();if(!t)return;const i=se(null==e?void 0:e.text),n=i?[...r.entries()].find(([,e])=>{const t=se(null==e?void 0:e.text);return t&&(t===i||t.includes(i)||i.includes(t))}):null,s=(null==n?void 0:n[0])||t,a=r.get(s),l=String((null==a?void 0:a.text)||""),o=String((null==e?void 0:e.text)||"");r.set(s,{...a||{},...e,...l.length>o.length?{text:l}:{}})}),[...r.values()]},Pt=e=>{var t,r;if(!(null==(t=null==e?void 0:e.lyricArtifacts)?void 0:t.length)||!(null==(r=null==e?void 0:e.tracks)?void 0:r.length))return;const i=e.tracks.map(e=>String((null==e?void 0:e.title)||(null==e?void 0:e.name)||"").trim()).find(Boolean);i&&(e.lyricArtifacts=e.lyricArtifacts.map(e=>String((null==e?void 0:e.title)||(null==e?void 0:e.song_title)||(null==e?void 0:e.song_name)||"").trim()?e:{...e,title:i}))},Lt=(e=[],t="")=>{const r=new Map;
1return e.forEach(e=>{var i;if("assistant"!==(null==e?void 0:e.role)||!(null==(i=null==e?void 0:e.lyricArtifacts)?void 0:i.length))return;const n=String(e.runId||"").trim();if(!n||t&&n!==String(t))return;const s=r.get(n)||[];e.lyricArtifacts.forEach(t=>s.push({message:e,lyric:t})),r.set(n,s)}),r.forEach(e=>{var t,r;if(e.length<2)return;const i=e.filter(({message:e})=>"lyrics"===e.messageType),n=i[0]||e[0],s=(i.length?i:e).reduce((e,t)=>{var r,i;return String((null==(r=t.lyric)?void 0:r.text)||"").length>String((null==(i=null==e?void 0:e.lyric)?void 0:i.text)||"").length?t:e},null),a=[...e].reverse().find(({lyric:e})=>String((null==e?void 0:e.title)||"").trim()),l={...n.lyric,title:(null==(t=null==a?void 0:a.lyric)?void 0:t.title)||n.lyric.title||"",text:(null==(r=null==s?void 0:s.lyric)?void 0:r.text)||n.lyric.text||"",streaming:!1},o=new Map;e.forEach(({message:e,lyric:t})=>{const r=o.get(e)||new Set;r.add(t.id),o.set(e,r)}),o.forEach((e,t)=>{t.lyricArtifacts=t.lyricArtifacts.filter(t=>!e.has(t.id))}),n.message.lyricArtifacts=[...n.message.lyricArtifacts,l]}),e},Dt=(e,t)=>{const r=$t(e),i=String(e.card_key||e.id||""),n=h(null==e?void 0:e.lyrics,null==t?void 0:t.lyrics);return re({...e,...t,...i?{card_key:i}:{},...At(e)&&!At(t)?{job_id:At(e)}:{},...wt(e)&&!wt(t)?{run_id:wt(e)}:{},...jt(e)&&!jt(t)?{artifact_id:jt(e)}:{},...r?{stream_url:r}:{},...Et(n)?{lyrics:n}:{}})},zt=(e,t)=>{const r=_e(t);if(r&&_e(e)===r)return!0;const i=qt(e),n=qt(t);if(i&&n&&i!==n)return!1;const s=new Set(ge(t));if(s.size&&ge(e).some(e=>s.has(e)))return!0;const a=new Set(fe(t));return a.size&&fe(e).some(e=>a.has(e))},Ft=(e=[])=>{if(!e.length)return;const t=V.value.map(e=>({message:e,tracks:[...e.tracks||[]]})),r=t.filter(({message:e})=>"assistant"===e.role),i=t.flatMap(e=>e.tracks.filter(Mt).map(t=>({entry:e,track:t}))),n=new Set,s=new Set;e.forEach((a,l)=>{const o=_e(a);if(!o||s.has(o))return;let u=t.find(({tracks:e})=>e.some(e=>zt(e,a)));if(u)return u.tracks=u.tracks.map(e=>zt(e,a)?Dt(e,a):e),void s.add(o);const c=wt(a),d=At(a);if(u=r.find(({message:e})=>{var t;return c&&String(e.runId||"")===c||d&&(null==(t=e.tracks)?void 0:t.some(e=>At(e)===d))})||null,!u){const t=String(a.title||"").trim().toLowerCase(),r=i.find(({track:e})=>!n.has(e)&&t&&String(e.title||"").trim().toLowerCase()===t),u=e.length===i.length?i[l]:null,c=r||u;if(c&&!n.has(c.track))return c.entry.tracks=c.entry.tracks.map(e=>e===c.track?Dt(e,a):e),n.add(c.track),void s.add(o)}if(!u&&1===e.length){const e=t.filter(({tracks:e})=>e.some(Mt));1===e.length&&(u=e[0])}if(!u){u=r.find(({message:e})=>e.transient)||(r.length?r[r.length-1]:null)}u&&(u.tracks.push(((e,t,r)=>{var i;const n=String((null==(i=null==r?void 0:r.message)?void 0:i.runId)||"").trim(),s=!wt(t)&&n?{...t,run_id:n}:t;return Dt(e,s)})({},a,u)),s.add(o))}),t.forEach(e=>{e.message.tracks=e.tracks})},Rt=async(e=C.value,t=T.value)=>{if(!e||"function"!=typeof o)return[];const r=++Xe;try{const i=await o(e);if(r!==Xe||e!==C.value||t&&t!==T.value)return[];const n=ve(i).map(e=>re(e)).filter(e=>Boolean(_e(e)));return Ft(n),await Promise.all(n.filter(e=>!(e.audio_url&&e.cover_url&&Array.isArray(e.lyrics)&&e.lyrics.length)).map(r=>(async(e,t=C.value,r=T.value)=>{if("function"!=typeof g)return;const i=_e(e);if(!i)return;const n=`${t}:${i}`;if(Ge.has(n))return Ge.get(n);const s=Number(i),a=/^\d+$/.test(i)&&Number.isSafeInteger(s)?s:i,l=Promise.resolve(g(a)).then(e=>{var i;const n=(null==e?void 0:e.song)||(null==(i=null==e?void 0:e.data)?void 0:i.song)||(null==e?void 0:e.data)||e,s=re(n);!s||t!==C.value||r&&r!==T.value||Ft([s])}).catch(()=>{}).finally(()=>{Ge.delete(n)});return Ge.set(n,l),l})(r,e,t))),n}catch{return[]}},Wt=(e,t)=>((null==e?void 0:e.items)||[]).filter(e=>String(e.session_id)===String(t)).map(L).filter(Boolean),Kt=e=>new Set(((null==e?void 0:e.artifacts)||[]).map(e=>String((null==e?void 0:e.artifact_id)||"")).filter(Boolean)),Qt=(e,t)=>{const r=e?Re.get(e):"",i=V.value.find(e=>e.id===r);if(i)return i;const n=String((null==t?void 0:t.artifact_id)||""),s=String((null==t?void 0:t.job_id)||"");return V.value.find(t=>"assistant"===t.role&&(!(!e||String(t.runId||"")!==String(e))||(!(!n||!Kt(t).has(n))||Boolean(s&&(t.tracks||[]).some(e=>At(e)===s)))))},Gt=e=>{const t=String((null==e?void 0:e.runId)||"");if("assistant"!==(null==e?void 0:e.role))return null;const r=new Set([...Kt(e).values(),...(e.tracks||[]).flatMap(e=>[_e(e)?`song:${_e(e)}`:"",At(e)?`job:${At(e)}`:"",jt(e)?`artifact:${jt(e)}
1`:""]).filter(Boolean)]);return V.value.find(i=>{if(i.id===e.id||i.transient||"assistant"!==i.role)return!1;const n=t&&String(i.runId||"")===t,s=new Set([...Kt(i).values(),...(i.tracks||[]).flatMap(e=>[_e(e)?`song:${_e(e)}`:"",At(e)?`job:${At(e)}`:"",jt(e)?`artifact:${jt(e)}`:""]).filter(Boolean)]),a=[...r].some(e=>s.has(e));return(n||a)&&(a||((e,t)=>{const r=se(null==e?void 0:e.content),i=se(null==t?void 0:t.content);return!(!r||!i)&&(r===i||Math.min(r.length,i.length)>=8&&(r.includes(i)||i.includes(r)))})(i,e))})},Jt=(e,t)=>{const r=t.filter(e=>!Mt(e));if(!r.length)return;const i=new Set(r.map(_e).filter(Boolean));V.value.forEach(t=>{var n;if(t.id===e.id||!(null==(n=t.tracks)?void 0:n.length))return;const s=t.tracks.filter(e=>{const t=r.some(t=>xt(t)&&xt(t)===xt(e)),n=r.some(t=>Mt(e)&&Ot(e,t)),s=i.has(_e(e));return!t&&!n&&!s});s.length!==t.tracks.length&&(t.tracks=s)})},Vt=e=>{var t;if(!e.session_id||e.session_id!==T.value)return;const r=P(e);if(!r)return;const i="user"===r.role?V.value.find(e=>e.transient&&"user"===e.role&&e.content===r.content):null;(e=>{if("user"!==(null==e?void 0:e.role))return;const t=V.value.find(t=>t.transient&&"user"===t.role&&t.content===e.content);t&&(V.value=V.value.filter(e=>e.id!==t.id))})(r);const n=(e=>{const t=e.runId?Re.get(e.runId):"";if(t){const e=V.value.find(e=>e.id===t);if(e)return e}const r=new Set((e.artifacts||[]).map(e=>String((null==e?void 0:e.artifact_id)||"")).filter(Boolean)),i=new Set((e.tracks||[]).map(At).filter(Boolean));return V.value.find(e=>{if(!e.transient||"assistant"!==e.role)return!1;const t=Kt(e),n=[...r].some(e=>t.has(e)),s=(e.tracks||[]).some(e=>i.has(At(e)));return n||s})})(r),s=(null==n?void 0:n.id)||"",a=(r.tracks||[]).map(e=>({...e,...r.runId&&!wt(e)?{run_id:r.runId}:{}})),l=Boolean(null==(t=null==n?void 0:n.tracks)?void 0:t.some(Mt)),o=r.runId||(null==n?void 0:n.runId)||"";if("assistant"===r.role&&o){const e=new Set(Qe.get(o)||[]);e.add(r.id),Qe.set(o,e)}const u="assistant"===r.role&&"error"!==r.status&&((e,t)=>{const r=se(null==e?void 0:e.content),i=se(null==t?void 0:t.content);return!(!r||!i)&&(r===i||!(Math.min(r.length,i.length)<8)&&i.includes(r))})(n,r);if("assistant"===r.role&&"error"!==r.status&&n&&o&&!ne.has(ie.value[o])){const t=Ke.get(o)||[];return void(t.some(e=>{const t=P(e);return(null==t?void 0:t.id)===r.id})||Ke.set(o,[...t,e]))}if("assistant"===r.role&&"lyrics"===r.messageType&&n)return n.lyricArtifacts=Tt(n.lyricArtifacts,r.lyricArtifacts),void Lt(V.value,o);const c=r.runId&&pe.value[r.runId]||(null==n?void 0:n.accessIssue);let d={...r,id:`message:${r.id}`,runId:r.runId||(null==n?void 0:n.runId)||"",content:ce(n,r),...r.structuredInput||(null==i?void 0:i.structuredInput)?{structuredInput:r.structuredInput||i.structuredInput}:{},...r.skills||(null==i?void 0:i.skills)?{skills:r.skills||i.skills}:{},...r.nodes||(null==i?void 0:i.nodes)?{nodes:r.nodes||i.nodes}:{},tracks:Ut(null==n?void 0:n.tracks,a),lyricArtifacts:Tt(null==n?void 0:n.lyricArtifacts,r.lyricArtifacts),media:Bt(null==n?void 0:n.media,r.media),stemPackages:Ct(null==n?void 0:n.stemPackages,r.stemPackages),...c?{accessIssue:c}:{}};const m=Gt(d);m&&(d={...m,...d,id:m.id,content:ce(m,d),tracks:Ut(m.tracks,d.tracks),lyricArtifacts:Tt(m.lyricArtifacts,d.lyricArtifacts),media:Bt(m.media,d.media),stemPackages:Ct(m.stemPackages,d.stemPackages),artifacts:[...m.artifacts||[],...d.artifacts||[]]}),(e=>{if(!e)return;const t=V.value.find(t=>t.id===e.id);t?Object.assign(t,e):V.value.push(e),V.value.sort((e,t)=>e.sequence&&t.sequence?e.sequence-t.sequence:e.createdAt-t.createdAt)})(d),Lt(V.value,d.runId);s&&(u||!l||d.tracks.some(e=>!Mt(e)))&&(V.value=V.value.filter(e=>e.id!==s),n.runId&&Re.delete(n.runId),r.runId&&Re.delete(r.runId)),u&&o&&We.add(o),Jt(d,d.tracks),r.sequence&&(he.value={...he.value,[e.session_id]:r.sequence}),vr()};Ve=e=>{const t=Ke.get(e)||[];return!!t.length&&(Ke.delete(e),t.forEach(e=>Vt(e)),!0)};const Zt=e=>new Set([...Kt(e).values(),...((null==e?void 0:e.tracks)||[]).flatMap(e=>[_e(e)?`song:${_e(e)}`:"",At(e)?`job:${At(e)}`:"",jt(e)?`artifact:${jt(e)}`:""]).filter(Boolean)]),Ht=(e,t,r,i)=>!(!e||"assistant"!==e.role)&&(String(e.runId||"")===String(t)||(!!r.has(String(e.id||""))||[...Zt(e)].some(e=>i.has(e)))),Xt=()=>{te.value=Boolean(Ne)||Object.keys(qe.value).length>0},Yt=()=>{$e.value=Math.max(0,$e.value-1)},er=e=>{if(!e||!qe.value[e])return ze.delete(e),null;const t=qe.value[e],{[e]:r,...i}=qe.value;qe.value=i,ze.delete(e),Le.delete(e);for(const[n,s]of Pe)s===e&&Pe.delete(n);return Xt(),t},tr=e=>{const t=qe.value[e];if(!t||t.sent||z.value!==t.session_id)return;const r=gt("send_message");Pe.set(r,e),Te.set(r,t.optimistic_id),qe.value={...qe.value,[e]:{...t,sent:!0}};try{cr().send({type:"send_message",template_id:t.template_id,request_id:r,idempotency_key:e,session_id:t.session_id,message:t.message,structured_input:t.structured_input})}catch(i){throw qe.value={...qe.value,[e]:{...t,sent:!1}},Pe.delete(r),Te.delete(r),i}}
1,rr=async(e=T.value)=>{if(Ze||!e||e!==T.value||!je.value.length||nt()||st()>0||$e.value>0)return;const[t,...r]=je.value;je.value=r,$e.value+=1;const i=He;return Ze=(async()=>{try{if(await dr(),z.value!==e&&await mr(e),i!==He||e!==T.value)return void Yt();Le.set(t.idempotency_key,t.optimistic_id),qe.value={...qe.value,[t.idempotency_key]:{session_id:e,message:t.message,template_id:t.template_id,structured_input:t.structured_input,optimistic_id:t.optimistic_id,sent:!1}};const r=V.value.find(e=>e.id===t.optimistic_id);r&&(r.status="streaming"),Yt(),tr(t.idempotency_key)}catch(r){if(Yt(),i===He){je.value=[t,...je.value];qe.value[t.idempotency_key]&&er(t.idempotency_key),ee.value=r instanceof Error?r.message:"Unable to send queued message"}}finally{Ze=null,Xt()}})(),Ze},ir=(e,t,r)=>{if(!e||"object"!=typeof e)return null;const i=String(e.run_id||e.runId||"").trim();if(!i)return null;const n=Number(e.queue_position??e.queuePosition);return{run_id:i,message_id:String(e.message_id||e.messageId||"").trim(),queue_position:Number.isInteger(n)&&n>0?n:t+1,status:"queued",session_id:String(e.session_id||r||"").trim(),...String(e.content||e.message||"").trim()?{content:String(e.content||e.message).trim()}:{}}},nr=e=>{we.value=we.value.filter(t=>t.run_id!==e)},sr=(e=T.value)=>{if(e&&I.value&&z.value===e&&!Fe.has(e)){Fe.add(e);try{cr().send({type:"list_queued_runs",request_id:gt("list_queued_runs"),session_id:e})}catch{Fe.delete(e)}}},ar=(e,t)=>{if(!e||!t)return;const r=ie.value[e];if(r&&ne.has(r)&&r!==t)return;const i=ht(e),n=(null==i?void 0:i.startedAt)||("running"===t||"queued"===t?Date.now():0),s=bt(e,{status:t,...n?{startedAt:n}:{},...ne.has(t)?{finishedAt:Date.now()}:{}});ie.value={...ie.value,[e]:t};const a=De.get(e),l=a?V.value.find(e=>e.id===a):null;if(l&&(l.status="queued"===t?"queued":"streaming"),!ne.has(t)&&"queued"!==t){const t=Qt(e)||yt(e);t.status="streaming",t.runId=e}if("running"!==t&&"waiting_job"!==t&&"waiting_async_tool"!==t||(W.value=e,nr(e)),ne.has(t)){it(e,s);const r=Object.entries(qe.value).filter(([,e])=>e.session_id===T.value),i=Object.entries(ie.value).some(([t,r])=>t!==e&&!ne.has(r));a||1!==r.length||i||er(r[0][0]);const n=V.value.find(t=>t.id===Re.get(e));n&&(n.status="failed"===t?"error":"done"),null==Ve||Ve(e),We.add(e),nr(e),Me.value=Me.value.filter(t=>t!==e),W.value===e&&(W.value=ct.value),"completed"===t&&C.value&&((async e=>{const t=C.value,r=T.value;if(!e||!t||!r)return!1;const i=Re.get(e)||"";for(let n=0;n<3;n+=1){let s;try{s=await f(t)}catch{s=null}if(t!==C.value||r!==T.value)return!1;const a=Wt(s,r),l=new Set(Qe.get(e)||[]),o=new Set(V.value.filter(t=>"assistant"===t.role&&(t.id===i||String(t.runId||"")===e)).flatMap(e=>[...Zt(e)])),u=a.filter(t=>Ht(t,e,l,o));if(u.length){const t=V.value.filter(t=>"assistant"===t.role&&(t.id===i||String(t.runId||"")===e)),r=t.flatMap(e=>e.tracks||[]),n=t.flatMap(e=>e.media||[]),s=t.flatMap(e=>e.lyricArtifacts||[]),a=t.flatMap(e=>e.stemPackages||[]),l=t.flatMap(e=>e.artifacts||[]);let o=u.findIndex(e=>(e.tracks||[]).some(e=>r.some(t=>Ot(e,t))));o<0&&(o=u.findIndex(e=>{var t,r;return(null==(t=e.tracks)?void 0:t.length)||(null==(r=e.artifacts)?void 0:r.length)})),o<0&&(o=u.length-1);const c=u[o],d=u.find(e=>"lyrics"===e.messageType)||c;c.tracks=Ut(r,c.tracks),c.media=Bt(c.media,n),c.stemPackages=Ct(a,c.stemPackages),d.lyricArtifacts=Tt(s,d.lyricArtifacts),Pt(d),c.artifacts=[...c.artifacts||[],...l.filter(e=>!(c.artifacts||[]).some(t=>t.artifact_id===e.artifact_id))],Lt(u,e);const m=new Set(u.map(e=>`message:${e.id}`));V.value=V.value.filter(t=>t.id!==i&&("assistant"!==t.role||String(t.runId||"")!==String(e)&&!m.has(t.id))),V.value.push(...u.map(t=>({...t,id:`message:${t.id}`,...t.runId?{}:{runId:e}}))),V.value.sort((e,t)=>e.sequence&&t.sequence?e.sequence-t.sequence:e.createdAt-t.createdAt);const v=V.value.find(e=>e.id===`message:${c.id}`);return v&&Jt(v,v.tracks||[]),Lt(V.value,e),Re.delete(e),Ke.delete(e),Qe.delete(e),We.add(e),!0}n<2&&await new Promise(e=>globalThis.setTimeout(e,150))}Ke.delete(e),Qe.delete(e)})(e),Rt()),sr(),rr()}},lr=e=>{const t=String(e.run_id||"");if(!t)return;e.session_id&&(ae.value={...ae.value,[t]:String(e.session_id)});const r=Number(e.sequence)||0;if(r&&r<=(be.value[t]||0))return;const i=D(e);i&&St(t,i,r);for(const l of F(e).runtimeItems||[])It(t,l,r);const n=((e={})=>
1{if("run_event"!==e.type||"artifact.created"!==e.event_type)return null;const t=b(e.payload);return x(t,A(t.job_id||t.jobId||b(t.data).job_id))})(e);if(n){const e=Qt(t,n)||yt(t);e.runId||(e.runId=t);const r=O(n).map(e=>({...e,run_id:t}));e.tracks=Ut(e.tracks,r),e.lyricArtifacts=Tt(e.lyricArtifacts,E(n)),Pt(e),e.media=Bt(e.media,B(n)),e.stemPackages=Ct(e.stemPackages,U(n)),e.artifacts=[...(e.artifacts||[]).filter(e=>e.artifact_id!==n.artifact_id),n],Lt(V.value,t),Rt()}const s=((e={})=>{if("run_event"!==e.type||"job.failed"!==e.event_type&&"run.failed"!==e.event_type)return null;const t=b(e.payload),r=b(t.tool_workset),i=[t,...(Array.isArray(r.failed)?r.failed:r.failed&&"object"==typeof r.failed?[r.failed]:[]).map(b)],n=i.some(e=>6335===Number(e.code))?6335:i.some(e=>6310===Number(e.code))?6310:0;if(6310===n){const e=[...i,b(t.data)],r=e.map(e=>S(e.current_credits??e.currentCredits)).find(e=>void 0!==e),s=e.map(e=>S(e.required_credits??e.requiredCredits)).find(e=>void 0!==e);return{kind:"insufficient_credits",code:n,...void 0!==r?{current_credits:r}:{},...void 0!==s?{required_credits:s}:{}}}if(6335!==n)return null;const s=i.find(e=>Number(e.code)===n)||{},a=k(s.tool_name)||k(t.tool_name),l="music.separate_stems"===a?"stem_separation":a.startsWith("video.")?"video_generation":void 0;return{kind:"premium_feature",code:n,...l?{feature:l}:{}}})(e);s&&((e,t)=>{if(!e||!t)return;pe.value={...pe.value,[e]:t};const r=Qt(e)||yt(e);r.accessIssue=t,r.status="error"})(t,s);const a={"run.queued":"queued","run.started":"running","run.completed":"completed","job.failed":"failed","run.failed":"failed","run.canceled":"canceled","run.expired":"expired"};a[e.event_type]&&ar(t,a[e.event_type]),r&&(be.value={...be.value,[t]:r})},or=e=>{const t=String(e.run_id||"");if(!t)return;const r=D(e);r&&St(t,r,0);for(const a of F(e).runtimeItems||[])It(t,a,0);if(We.has(t))return;const i=Qt(t)||yt(t),n=R(e);n.isLyrics?((e,t)=>{if(!e||!(null==t?void 0:t.isLyrics)||!t.text)return;
1const r=String(t.itemId||"lyrics"),i=`stream:${e.runId||"unknown"}:${r}`,n=e.lyricArtifacts.find(e=>e.id===i),s=`${(null==n?void 0:n.text)||""}${t.text}`,a={...n||{},id:i,run_id:e.runId||"",item_id:t.itemId||void 0,title:t.title||(null==n?void 0:n.title)||"",text:s,streaming:!0};e.lyricArtifacts=[...e.lyricArtifacts.filter(e=>e.id!==i),a]})(i,n):i.content+=n.text||((e={})=>R(e).text)(e);const s=((e={})=>{if("run_live_event"!==e.type||"tool_call.progress"!==e.event_type)return[];const t=b(e.payload),r=b(t.data),i=Array.isArray(t.choices)?t.choices:Array.isArray(r.choices)?r.choices:[],n=A(e.run_id);return i.flatMap((e,i)=>{const s=b(e),a=k(s.stream_url||s.streamUrl);if(!a)return[];const l=A(t.job_id||t.jobId||s.job_id||s.jobId||r.job_id||r.jobId),o=l&&n?`${n}:${l}`:l||n||a,u=`${o}:choice:${i}`,c=`stream:${u}`,d=$(s,t,r);return[{...N(s,r),id:`stream:${o}:choice:${i}`,card_key:c,generation_key:u,choice_index:i,song_id:A(s.song_id||s.songId||s.id||t.song_id||t.songId||r.song_id||r.songId)||void 0,title:k(s.title)||`Audio ${i+1}`,audio_url:a,url:a,stream_url:a,mp3_url:"",cover:j(s),cover_url:j(s),image_url:j(s),duration_ms:w(s.duration_ms,s.durationMs,s.duration),...d?{lyrics:d}:{},state:"generating",pstate:2,generate_state:2,is_streaming:!0,run_id:n||void 0,...l?{job_id:l}:{}}]})})(e).filter(e=>!i.tracks.some(t=>!Mt(t)&&Ot(t,e)));i.tracks=Ut(i.tracks,s),Pt(i)},ur=(e={})=>{switch(e.type){case"session_subscribed":{const t=String(e.session_id||"");if(t!==T.value)return;z.value=t;const r=Ce.get(t);return r&&(globalThis.clearTimeout(r.timer),r.resolve(),Ce.delete(t)),(e.active_runs||[]).forEach(e=>{ae.value={...ae.value,[e.run_id]:t},ar(e.run_id,e.status),cr().send({type:"subscribe_run",request_id:gt("subscribe_run"),run_id:e.run_id,after_sequence:be.value[e.run_id]||0})}),(e=>{Object.keys(qe.value).forEach(t=>{qe.value[t].session_id===e&&tr(t)})})(t),sr(t),void rr(t)}case"message_accepted":{const r=String(e.run_id||""),i=Pe.get(e.request_id),n=i?qe.value[i]:null,s=i?ze.get(i):null,a=Te.get(e.request_id)||(null==n?void 0:n.optimistic_id),l=V.value.find(e=>e.id===a);l&&r&&(l.runId=r,De.set(r,l.id)),r&&(ae.value={...ae.value,[r]:String(e.session_id||T.value)});const o=Number(e.queue_position),u=e.status||(Number.isInteger(o)&&o>0?"queued":"running");ar(r,u),"queued"===u&&(e=>{const t=ir(e,we.value.length,T.value);if(!t||t.session_id!==T.value)return;const r=we.value.findIndex(e=>e.run_id===t.run_id);if(-1===r)we.value=[...we.value,t].sort((e,t)=>e.queue_position-t.queue_position);else{const e=[...we.value];e.splice(r,1,t),we.value=e.sort((e,t)=>e.queue_position-t.queue_position)}ae.value={...ae.value,[t.run_id]:T.value}})({...e,run_id:r,message_id:e.user_message_id||a||"",queue_position:o,session_id:e.session_id||T.value});const c=e.user_message_id||e.userMessageId||e.message_id;if("function"==typeof s&&c)try{s({messageId:c,sessionId:e.session_id||T.value})}catch(t){}return i&&er(i),Te.delete(e.request_id),Pe.delete(e.request_id),void sr(e.session_id||T.value)}case"queued_runs":{const t=String(e.session_id||T.value);return Fe.delete(t),void((e,t=[])=>{if(!e||e!==T.value)return;const r=t.map((t,r)=>ir(t,r,e)).filter(Boolean).sort((e,t)=>e.queue_position-t.queue_position);we.value=r,r.forEach(t=>{ae.value={...ae.value,[t.run_id]:e},ar(t.run_id,"queued")})})(t,e.items||e.queued_runs||e.runs||[])}case"cancel_accepted":{const t=String(e.run_id||"");if(!t)return;return Me.value.includes(t)||(Me.value=[...Me.value,t]),void sr(ae.value[t]||T.value)}case"message":return void Vt(e);case"run_event":return void lr(e);case"run_live_event":return void or(e);case"error":case"proxy_error":if(e.request_id){const t=Pe.get(e.request_id);if(t){const r=er(t),i=(null==r?void 0:r.optimistic_id)?V.value.find(e=>e.id===r.optimistic_id):null;i&&(i.status="error"),Te.delete(e.request_id),Pe.delete(e.request_id)}}return ee.value="string"==typeof e.message&&e.message||e.msg||String(e.code||"Agent request failed"),void(e.run_id?ar(String(e.run_id),"failed"):(Xt(),rr()));default:return}},cr=()=>(s.value||(s.value=new y({onOpen:()=>{I.value=!0,q.value=!1,ee.value="",ft(),Object.entries(qe.value).forEach(([e,t])=>{qe.value[e]={...t,sent:!1}}),T.value&&mr(T.value)},onClose:()=>{I.value=!1,q.value=!1,z.value="",Fe.clear(),qe.value=Object.fromEntries(Object.entries(qe.value).map(([e,t])=>[e,{...t,sent:!1}])),Xt(),ft(new Error("Agent connection closed")),pt(new Error("Agent session subscription closed"))},onError:()=>{q.value&&(ee.value="Agent connection error")},onMessage:ur})),s.value),dr=()=>I.value?Promise.resolve():(q.value=!0,cr().connect(),new Promise((e,t)=>
1{const r=globalThis.setTimeout(()=>{Be=Be.filter(t=>t.resolve!==e),q.value=!1,t(new Error("Agent connection timed out"))},1e4);Be.push({resolve:e,reject:t,timer:r})})),mr=e=>{if(!e)return Promise.reject(new Error("Missing Agent session"));if(z.value===e)return Promise.resolve();if(Ce.has(e))return Ce.get(e).promise;let t,r;const i=new Promise((e,i)=>{t=e,r=i}),n=globalThis.setTimeout(()=>{Ce.delete(e),r(new Error("Agent session subscription timed out"))},1e4);return Ce.set(e,{promise:i,resolve:t,reject:r,timer:n}),cr().send({type:"subscribe_session",request_id:gt("subscribe_session"),session_id:e,after_message_sequence:he.value[e]||0}),i},vr=async()=>{if(e.isLogin&&!G.value){G.value=!0;try{const e=await u();Q.value=me((null==e?void 0:e.items)||[])}catch(t){ee.value=t instanceof Error?t.message:"Unable to load chats"}finally{G.value=!1}}},_r=async({force:e=!1}={})=>{if(Oe&&!e)return Oe;if(ke.value.length&&!e)return ke.value;const t=++Ue;return Se.value=!0,Ie.value="",Oe=c().then(e=>(t!==Ue||(ke.value=((e=[])=>e.map(e=>H(e)).filter(Boolean))(null==e?void 0:e.tools),Ae.value=String((null==e?void 0:e.defaultPlaceholder)||Ae.value).trim()||Ae.value),ke.value)).catch(e=>(t===Ue&&(Ie.value=e instanceof Error?e.message:"Unable to load tools"),ke.value)).finally(()=>{t===Ue&&(Se.value=!1,Oe=null)}),Oe},gr=async(e,t)=>{const r=await f(e),i=Lt(Wt(r,t).map(e=>({...e,id:`message:${e.id}`}))),n=i.reduce((e,t)=>Math.max(e,t.sequence||0),0);V.value=i.sort((e,t)=>e.sequence-t.sequence),((e,t)=>{const r=new Set((t||[]).filter(e=>"assistant"===(null==e?void 0:e.role)).map(e=>String(e.runId||"").trim()).filter(Boolean));if(!r.size)return;const i=Object.fromEntries(Object.entries(rt(e)).filter(([e])=>r.has(e)));Object.keys(i).length&&(ye.value={...ye.value,...i},ae.value={...ae.value,...Object.fromEntries(Object.keys(i).map(t=>[t,String(e)]))},ie.value={...ie.value,...Object.fromEntries(Object.entries(i).map(([e,t])=>[e,t.status]))})})(t,V.value),pe.value={},he.value={...he.value,[t]:n}},fr=e=>{const t=String(e||"").trim();if(!t||Me.value.includes(t))return!1;const r=je.value.find(e=>e.run_id===t);if(r)return je.value=je.value.filter(e=>e.run_id!==t),V.value=V.value.filter(e=>e.id!==r.optimistic_id),Le.delete(r.idempotency_key),ze.delete(r.idempotency_key),rr(),!0;if(!I.value)return!1;try{cr().send({type:"cancel_run",request_id:gt("cancel_run"),run_id:t})}catch{return!1}return Me.value=[...Me.value,t],we.value.some(e=>e.run_id===t)||ar(t,"canceling"),!0},pr=()=>{xe.value={message:"",template_id:null}},yr=()=>{var e,t;if(I.value&&z.value)try{null==(e=s.value)||e.send({type:"unsubscribe_session",request_id:gt("unsubscribe_session"),session_id:z.value})}catch{}null==(t=s.value)||t.close(),s.value=null,I.value=!1,q.value=!1,z.value="",Fe.clear(),qe.value=Object.fromEntries(Object.entries(qe.value).map(([e,t])=>[e,{...t,sent:!1}])),Xt(),ft(new Error("Agent connection closed")),pt(new Error("Agent session subscription closed"))},hr=()=>{yr(),He+=1,Xe+=1,C.value="",T.value="",W.value="",V.value=[],ie.value={},ae.value={},pe.value={},ye.value={},we.value=[],je.value=[],qe.value={},$e.value=0,Me.value=[],Fe.clear(),te.value=!1,ee.value="",pr(),Re.clear(),We.clear(),Ke.clear(),Qe.clear(),Te.clear(),Pe.clear(),Le.clear(),ze.clear(),De.clear(),Ge.clear()};return{activeRunId:W,activeCancelableRunId:ct,chatId:C,chatLoading:J,chats:Q,chatsLoading:G,connected:I,connecting:q,defaultPlaceholder:Ae,currentTracks:_t,error:ee,hasConversation:Ye,initialized:M,isGenerating:dt,isQueueFull:ut,isRunning:mt,messages:V,visibleMessages:vt,pendingSends:qe,queuedRuns:we,queuedMessages:ot,cancelingQueuedRunIds:Me,queueSubmissionReservations:$e,tools:ke,toolsError:Ie,toolsLoading:Se,runStatuses:ie,runAccessIssues:pe,runtimeByRun:ye,sending:te,sessionId:T,templateDraft:xe,cancelRun:()=>{const e=ct.value||W.value;return fr(e)},cancelQueuedRun:fr,clearTemplateDraft:pr,dispose:()=>{Xe+=1,He+=1,yr(),Ge.clear(),ye.value={},pe.value={},We.clear(),Ke.clear(),Qe.clear(),ze.clear(),Ue+=1,Oe=null,Se.value=!1,M.value=!1},initialize:async()=>
1{M.value||(M.value=!0,_r(),e.isLogin&&await vr())},loadTools:_r,refreshChats:vr,refreshChatSongs:Rt,getLyricsForTrack:(e={})=>{if(Et(null==e?void 0:e.lyrics))return e.lyrics;const t=wt(e);if(!t)return"";const r=String((null==e?void 0:e.title)||(null==e?void 0:e.name)||"").trim().toLowerCase(),i=V.value.filter(e=>"assistant"===(null==e?void 0:e.role)&&String(e.runId||"")===t).flatMap(e=>e.lyricArtifacts||[]),n=r?i.filter(e=>String((null==e?void 0:e.title)||(null==e?void 0:e.song_title)||(null==e?void 0:e.song_name)||"").trim().toLowerCase()===r):[];return((e=[])=>e.reduce((e,t)=>{const r=String((null==t?void 0:t.text)||"").trim();return r.length>e.length?r:e},""))(n.length?n:i)},patchSong:(e,t)=>{const r=_e({song_id:e});if(!r)return;const i=K(t),n=Z.value[r]||{};Object.keys(i).some(e=>!Object.is(i[e],n[e]))&&(Z.value[r]={...n,...i})},removeSong:e=>{const t=_e({song_id:e});t&&!X.value.includes(t)&&X.value.push(t)},removeChat:async e=>{await _(e),Q.value=Q.value.filter(t=>t.chat_id!==e),C.value===e&&hr()},selectChat:async e=>{var t;if(!e||J.value)return!1;J.value=!0,ee.value="",He+=1,Xe+=1,yr(),V.value=[],ie.value={},ae.value={},pe.value={},ye.value={},we.value=[],je.value=[],qe.value={},ze.clear(),$e.value=0,Me.value=[],Fe.clear(),Re.clear(),We.clear(),Ke.clear(),Qe.clear(),Te.clear(),Pe.clear(),Le.clear(),De.clear(),W.value="",Xt();try{const r=await d(e),i=String(m(r));if(!i)throw new Error("Agent chat does not have a session");return C.value=String((null==(t=r.chat)?void 0:t.chat_id)||e),T.value=i,await gr(C.value,i),Rt(C.value,i),await dr(),await mr(i),!0}catch(r){return ee.value=r instanceof Error?r.message:"Unable to load chat",!1}finally{J.value=!1}},sendPrompt:async(t,r={})=>{var i;const n=t&&"object"==typeof t?t:{message:t},s=String(n.message||"").trim(),a=v(n.template_id),l=(Array.isArray(n.skills)?n.skills.flatMap(e=>{const t="string"==typeof e?e:(null==e?void 0:e.skill_name)||(null==e?void 0:e.type)||"",r=String(t).trim();return r?[{skill_name:r}]:[]}):[]).filter((e,t,r)=>r.findIndex(t=>t.skill_name===e.skill_name)===t),o=((e,t=[])=>{const r=e&&"object"==typeof e?e:{},i=e=>Array.isArray(r[e])?r[e].flatMap(e=>{if(!e||"object"!=typeof e)return[];const t=String(e.source||"").trim();if(!t)return[];const r=e.snapshot&&"object"==typeof e.snapshot?e.snapshot:{},i={...r.title?{title:String(r.title)}:{},...r.thumbnail_url?{thumbnail_url:String(r.thumbnail_url)}:{},...r.mime_type?{mime_type:String(r.mime_type)}:{},...Number.isFinite(Number(r.duration_ms))?{duration_ms:Math.max(0,Number(r.duration_ms))}:{}};return[{source:t,...Object.keys(i).length?{snapshot:i}:{}}]}):[];return{version:"agent.user_input.v1",tool_type:String(r.tool_type||""),...r.selected_model?{selected_model:String(r.selected_model)}:{},...r.lyric_llm_model?{lyric_llm_model:String(r.lyric_llm_model)}:{},references:i("references"),vocals:i("vocals"),audios:i("audios"),photos:i("photos"),videos:i("videos"),skills:t}})(n.structuredInput||n.structured_input,l),u=["references","vocals","audios","photos","videos"].some(e=>o[e].length);if(!s&&!l.length&&!u||ut.value)return!!ut.value&&{queueFull:!0};if(!(await e.checkLoginStatus()))return!1;const c=at.value;if(ut.value||($e.value+=1,0))return{queueFull:!0};let d=!0;ee.value="";const _={id:de("optimistic"),role:"user",content:s,nodes:Array.isArray(n.nodes)?n.nodes:[],skills:l,structuredInput:o,tracks:[],media:[],status:"queued",transient:!0,createdAt:Date.now()};V.value.push(_);let g="";try{const e=await(f=s.slice(0,40),C.value&&T.value?Promise.resolve({chatId:C.value,sessionId:T.value}):Ne||(Ne=p(f).then(e=>{var t,r;const i=String((null==(t=null==e?void 0:e.chat)?void 0:t.chat_id)||""),n=String(m(e));if(!i||!n)throw new Error("Agent chat creation did not return a session");return C.value=i,T.value=n,Q.value=me([{...e.chat,title:(null==(r=e.chat)?void 0:r.title)||f},...Q.value]),{chatId:i,sessionId:n}}).finally(()=>{Ne=null}),Ne));return g=de("message"),"function"==typeof(null==r?void 0:r.onAccepted)&&ze.set(g,r.onAccepted),c?(je.value=[...je.value,{run_id:de("local_queue"),message_id:_.id,queue_position:je.value.length+1,session_id:e.sessionId,status:"queued",local:!0,idempotency_key:g,optimistic_id:_.id,message:s,template_id:a,structured_input:o}],Yt(),d=!1,Xt(),rr(e.sessionId),!0):(await dr(),Le.set(g,_.id),qe.value={...qe.value,[g]:{session_id:e.sessionId,message:s,template_id:a,structured_input:o,optimistic_id:_.id,sent:!1}},Yt(),d=!1,Xt(),z.value!==e.sessionId&&await mr(e.sessionId),tr(g),!0)}catch(y){g&&ze.delete(g),d&&Yt();const e=null==(i=Object.entries(qe.value).find(([,e])=>e.optimistic_id===_.id))?void 0:i[0];return e&&er(e),_.status="error",ee.value=y instanceof Error?y.message:"Unable to send message",Xt(),rr(),!1}var f},setTemplateDraft:(e={})=>{var t;const r=String((null==(t=null==e?void 0:e.prompt)?void 0:t.content)||"").trim();xe.value={message:r,template_id:r?v(null==e?void 0:e.id):null}},startNewChat:hr}}),ye=Object.freeze(Object.defineProperty({__proto__:null,default:pe,useAgentEasyStore:pe},Symbol.toStringTag,{value:"Module"}));
1export{W as A,Q as a,K as b,ie as c,H as d,ye as e,X as f,ee as g,re as n,G as q,pe as u};
Line numbers count LF bytes from the start of the resource, as the search results do. Vendor segments are library code the classifier recognised; they are stored but not indexed. Bytes are shown as Latin1 characters, one per byte.