https://www.007icu.top/assets/message-D0HRzm1P.js

1import{n as e,r as t}from"./rolldown-runtime-CMxvf4Kt.js";import{i as n,t as r}from"./_api-Bwh1mFfN.js";import{n as i,t as a}from"./abortableRequest-C6SDiPFy.js";var o=t({MessageBatchMutationError:()=>c,MessageService:()=>u,messageService:()=>d});async function s(e,t){let n=await r(e,t);return`data`in n?n.data:n}var c,l,u,d,f=e((()=>{n(),i(),c=class extends Error{result;constructor(e){let t=e.results?.filter(e=>!e.success)??[],n=[...new Set(t.map(e=>e.error).filter(Boolean))];super(`Message batch mutation failed for ${t.length||`unknown`} operation(s)`+(n.length>0?`: ${n.join(`; `)}`:``)),this.result=e}},l=e=>{if(e.length!==1)return;let[t]=e;if(t.type===`updateToolMessage`)return`tool-message-${t.id}`},u=class{batchMutate=async(e,t)=>{let n={operations:e.map(e=>e.type===`createMessage`?{message:e.message,type:e.type}:{id:e.id,type:e.type,value:e.value})};return s(`/app/front-hub/messages/batch`,{method:`POST`,body:JSON.stringify(n),signal:t})};batchMutateOrThrow=async e=>{let t=async t=>{let n=await(t?this.batchMutate(e,t):this.batchMutate(e)),r=n.results?.some(e=>!e.success)??!1,i=n.results?.length===e.length;if(n.success!==!0||!i||r)throw new c(n);return n},n=l(e);return n?a.execute(n,t):t()};createMessage=async e=>s(`/app/front-hub/messages`,{method:`POST`,body:JSON.stringify(e)});getMessages=async e=>{let t=new URLSearchParams;e.agentId&&t.set(`sessionId`,e.agentId),e.topicId&&t.set(`topicId`,e.topicId),e.threadId&&t.set(`threadId`,e.threadId),e.groupId&&t.set(`groupId`,e.groupId);let n=t.toString();return await s(`/app/front-hub/messages${n?`?${n}`:``}`)};diagnoseTopic=async e=>({hiddenCount:0,issues:[],patch:{}});repairTopic=async e=>({restoredMessageIds:[]});countMessages=async e=>s(`/app/front-hub/messages/count${e?`?`+new URLSearchParams(Object.entries(e).flatMap(([e,t])=>Array.isArray(t)?[[e,t[0]],[e,t[1]]]:t==null?[]:[[e,String(t)]])).toString():``}`);countWords=async e=>0;rankModels=async()=>[];getHeatmaps=async()=>[];getTokenHeatmaps=async()=>[];updateMessageError=async(e,t,n)=>{let r=t.type?t:{body:t,message:t.message,type:`ApplicationRuntimeError`};return s(`/app/front-hub/messages/${e}`,{method:`PATCH`,body:JSON.stringify({...n,value:{error:r}})})};updateMessagePluginArguments=async(e,t)=>Promise.resolve();updateToolArguments=async(e,t,n)=>({success:!1,messages:[]});updateMessage=async(e,t,n)=>s(`/app/front-hub/messages/${e}`,{method:`PATCH`,body:JSON.stringify({...n,value:t})});updateMessageTranslate=async(e,t)=>{};updateMessageTTS=async(e,t)=>{};updateMessageMetadata=async(e,t,n)=>Promise.resolve();updateMessagePluginState=async(e,t,n)=>Promise.resolve();updateMessagePluginError=async(e,t,n)=>Promise.resolve();updateMessagePlugin=async(e,t,n)=>Promise.resolve();updateMessageRAG=async(e,t,n)=>Promise.resolve();updateToolMessage=async(e,t,n)=>Promise.resolve();removeMessage=async(e,t)=>s(`/app/front-hub/messages/${e}`,{method:`DELETE`});removeMessages=async(e,t)=>Promise.resolve();removeMessagesByAssistant=async(e,t)=>{};removeMessagesByGroup=async(e,t)=>{};addFilesToMessage=async(e,t,n)=>Promise.resolve();createCompressionGroup=async e=>({messageGroupId:``,messages:[],messagesToSummarize:[]});finalizeCompression=async e=>({messages:[]});updateMessageGroupMetadata=async e=>({messages:[]});cancelCompression=async e=>({messages:[]})},d=new u}));export{d as n,o as r,f as t};