(self.webpackChunk_N_E=self.webpackChunk_N_E||[]).push([[18264],{51371:function(){},96127:function(){},81824:function(e,t,a){"use strict";a.d(t,{O:function(){return d}});var i=a(12603);let n=i.z.object({createdAt:i.z.number().optional(),data:i.z.instanceof(ArrayBuffer).optional(),fileType:i.z.string(),metadata:i.z.any().optional(),name:i.z.string(),saveMode:i.z.enum(["local","url"]),size:i.z.number(),url:i.z.string().optional()});var r=a(18388),l=a(56509),s=a(9109).Buffer;class o extends l.g{async create(e){let t=(0,r.x0)();return this._addWithSync(e,"file-".concat(t))}async findById(e){let t=await this.table.get(e);if(!t)return;let a=s.from(t.data).toString("base64");return{...t,url:"data:".concat(t.fileType,";base64,").concat(a)}}async delete(e){return this.table.delete(e)}async clear(){return this.table.clear()}constructor(){super("files",n)}}let d=new o},13906:function(e,t,a){"use strict";a.d(t,{b:function(){return o}});var i=a(27166),n=a(81824),r=a(9109).Buffer;class l{async createFile(e){let t=await n.O.create(e),a=r.from(e.data).toString("base64");return{id:t.id,url:"data:".concat(e.fileType,";base64,").concat(a)}}async getFile(e){let t=await n.O.findById(e);if(!t)throw Error("file not found");let a=URL.createObjectURL(new Blob([t.data],{type:t.fileType}));return{createdAt:new Date(t.createdAt),id:e,name:t.name,size:t.size,type:t.fileType,updatedAt:new Date(t.updatedAt),url:a}}async removeFile(e){return n.O.delete(e)}async removeFiles(e){await Promise.all(e.map(e=>n.O.delete(e)))}async removeAllFiles(){return n.O.clear()}}var s=a(3851);let o=i.ZN?new s.N:new l},3851:function(e,t,a){"use strict";a.d(t,{N:function(){return n}});var i=a(2684);class n{async createFile(e,t){return i.oq.file.createFile.mutate({...e,knowledgeBaseId:t})}async getFile(e){let t=await i.oq.file.findById.query({id:e});if(!t)throw Error("file not found");return{...t,type:t.fileType}}async removeFile(e){await i.oq.file.removeFile.mutate({id:e})}async removeFiles(e){await i.oq.file.removeFiles.mutate({ids:e})}async removeAllFiles(){await i.oq.file.removeAllFiles.mutate()}async getFiles(e){return i.oq.file.getFiles.query(e)}async getFileItem(e){return i.oq.file.getFileItemById.query({id:e})}async checkFileHash(e){return i.oq.file.checkFileHash.mutate({hash:e})}async removeFileAsyncTask(e,t){return await i.oq.file.removeFileAsyncTask.mutate({id:e,type:t})}}},35222:function(e,t,a){"use strict";a.d(t,{S:function(){return r}});var i=a(2684);class n{async createParseFileTask(e,t){return await i.oq.chunk.createParseFileTask.mutate({id:e,skipExist:t})}async retryParseFile(e){return await i.oq.chunk.retryParseFileTask.mutate({id:e})}async createEmbeddingChunksTask(e){return await i.oq.chunk.createEmbeddingChunksTask.mutate({id:e})}async semanticSearch(e,t){return await i.oq.chunk.semanticSearch.mutate({fileIds:t,query:e})}async semanticSearchForChat(e){return await i.oq.chunk.semanticSearchForChat.mutate(e)}async deleteMessageRagQuery(e){return await i.oq.message.removeMessageQuery.mutate({id:e})}}let r=new n},56922:function(e,t,a){"use strict";a.d(t,{W:function(){return g},T:function(){return f}});var i=a(26566),n=a(12603),r=a(25566);let l=(()=>{r.env.NEXT_PUBLIC_S3_DOMAIN&&console.warn("⚠️ `NEXT_PUBLIC_S3_DOMAIN` will be de deprecated in the next major version, please replace it with `S3_PUBLIC_DOMAIN` in your env");let e=r.env.S3_PUBLIC_DOMAIN||r.env.NEXT_PUBLIC_S3_DOMAIN;return(0,i.D)({client:{NEXT_PUBLIC_S3_DOMAIN:n.z.string().optional(),NEXT_PUBLIC_S3_FILE_PATH:n.z.string().optional()},runtimeEnv:{CHUNKS_AUTO_EMBEDDING:"0"!==r.env.CHUNKS_AUTO_EMBEDDING,CHUNKS_AUTO_GEN_METADATA:"0"!==r.env.CHUNKS_AUTO_GEN_METADATA,NEXT_PUBLIC_S3_DOMAIN:r.env.NEXT_PUBLIC_S3_DOMAIN,NEXT_PUBLIC_S3_FILE_PATH:r.env.NEXT_PUBLIC_S3_FILE_PATH||"files",S3_ACCESS_KEY_ID:r.env.S3_ACCESS_KEY_ID,S3_BUCKET:r.env.S3_BUCKET,S3_ENABLE_PATH_STYLE:"1"===r.env.S3_ENABLE_PATH_STYLE,S3_ENDPOINT:r.env.S3_ENDPOINT,S3_PUBLIC_DOMAIN:e,S3_REGION:r.env.S3_REGION,S3_SECRET_ACCESS_KEY:r.env.S3_SECRET_ACCESS_KEY,S3_SET_ACL:"0"!==r.env.S3_SET_ACL},server:{CHUNKS_AUTO_EMBEDDING:n.z.boolean(),CHUNKS_AUTO_GEN_METADATA:n.z.boolean(),S3_ACCESS_KEY_ID:n.z.string().optional(),S3_BUCKET:n.z.string().optional(),S3_ENABLE_PATH_STYLE:n.z.boolean(),S3_ENDPOINT:n.z.string().url().optional(),S3_PUBLIC_DOMAIN:n.z.string().url().optional(),S3_REGION:n.z.string().optional(),S3_SECRET_ACCESS_KEY:n.z.string().optional(),S3_SET_ACL:n.z.boolean()}})})();var s=a(81824),o=a(2666),d=a(10312),u=a(20920),c=a(9109).Buffer;let g="NetWorkError";class p{constructor(){this.uploadWithProgress=async(e,t)=>{let{onProgress:a,directory:i}=t,n=new XMLHttpRequest,{preSignUrl:r,...l}=await this.getSignedUploadUrl(e,i),s=Date.now();n.upload.addEventListener("progress",e=>{if(e.lengthComputable){let t=Number((e.loaded/e.total*100).toFixed(1)),i=e.loaded/((Date.now()-s)/1e3);null==a||a("uploading",{progress:100===t?99.9:t,restTime:(e.total-e.loaded)/i,speed:i})}}),n.open("PUT",r),n.setRequestHeader("Content-Type",e.type);let o=await e.arrayBuffer();return await new Promise((t,i)=>{n.addEventListener("load",()=>{n.status>=200&&n.status<300?(null==a||a("success",{progress:100,restTime:0,speed:e.size/((Date.now()-s)/1e3)}),t(n.response)):i(n.statusText)}),n.addEventListener("error",()=>{0===n.status?i(g):i(n.statusText)}),n.send(o)}),l},this.uploadToClientDB=async(e,t)=>{let a=await t.arrayBuffer(),i=await s.O.create({createdAt:Date.now(),...e,data:a}),n=c.from(a).toString("base64");return{id:i.id,url:"data:".concat(e.fileType,";base64,").concat(n)}},this.getImageFileByUrlWithCORS=async function(e,t){let a=arguments.length>2&&void 0!==arguments[2]?arguments[2]:"image/png",i=await fetch(d.P.proxy,{body:e,method:"POST"});return new File([await i.arrayBuffer()],t,{lastModified:Date.now(),type:a})},this.getSignedUploadUrl=async(e,t)=>{let a="".concat((0,u.Z)(),".").concat(e.name.split(".").at(-1)),i=(Date.now()/1e3/60/60).toFixed(0),n="".concat(t||l.NEXT_PUBLIC_S3_FILE_PATH,"/").concat(i),r="".concat(n,"/").concat(a),s=await o.V.upload.createS3PreSignedUrl.mutate({pathname:r});return{date:i,dirname:n,filename:a,path:r,preSignUrl:s}}}}let f=new p},16310:function(e,t,a){"use strict";a.d(t,{y:function(){return w}});var i=a(3512),n=a(99056),r=a(8939),l=a(37492),s=a(88688),o=a(61887);let d=e=>(0,o.T)(r.t9,e.agentMap[n.B9]),u=e=>t=>(0,o.T)(t.defaultAgentConfig,t.agentMap[e]),c=e=>u(e.activeId)(e),g=e=>{let t=c(e);return(null==t?void 0:t.knowledgeBases)||[]},p=e=>{let t=c(e);return(null==t?void 0:t.files)||[]},f=e=>{let t=c(e);return(null==t?void 0:t.tts)||r.cW},m=e=>{let t=g(e);return[...p(e).filter(e=>e.enabled).map(e=>({fileType:e.type,id:e.id,name:e.name,type:s.n.File})),...t.filter(e=>e.enabled).map(e=>({id:e.id,name:e.name,type:s.n.KnowledgeBase}))]},h=e=>g(e).length>0,y=e=>p(e).length>0,w={currentAgentChatConfig:e=>c(e).chatConfig||{},currentAgentConfig:c,currentAgentFiles:p,currentAgentKnowledgeBases:g,currentAgentModel:e=>{let t=c(e);return(null==t?void 0:t.model)||l.Q6},currentAgentModelProvider:e=>{let t=c(e);return(null==t?void 0:t.provider)||l.WW},currentAgentPlugins:e=>{let t=c(e);return(null==t?void 0:t.plugins)||[]},currentAgentSystemRole:e=>c(e).systemRole,currentAgentTTS:f,currentAgentTTSVoice:e=>t=>{var a,n,r;let l;let{voice:s,ttsService:o}=f(t),d=new i.VoiceList(e);switch(o){case"openai":l=s.openai||(null===(a=i.VoiceList.openaiVoiceOptions)||void 0===a?void 0:a[0].value);break;case"edge":l=s.edge||(null===(n=d.edgeVoiceOptions)||void 0===n?void 0:n[0].value);break;case"microsoft":l=s.microsoft||(null===(r=d.microsoftVoiceOptions)||void 0===r?void 0:r[0].value)}return l||"alloy"},currentEnabledKnowledge:m,currentKnowledgeIds:e=>({fileIds:p(e).filter(e=>e.enabled).map(e=>e.id),knowledgeBaseIds:g(e).filter(e=>e.enabled).map(e=>e.id)}),getAgentConfigById:u,hasEnabledKnowledge:e=>m(e).length>0,hasKnowledge:e=>h(e)||y(e),hasSystemRole:e=>!!c(e).systemRole,inboxAgentConfig:d,inboxAgentModel:e=>d(e).model,isInboxSession:e=>e.activeId===n.B9}},91192:function(e,t,a){"use strict";a.d(t,{E:function(){return E}});var i=a(28769),n=a(71327),r=a(55059),l=a(8939);let s={activeId:"inbox",agentMap:{},defaultAgentConfig:l.t9,isInboxAgentConfigInit:!1};var o=a(59731),d=a.n(o),u=a(61472),c=a(83048),g=a(36904),p=a(99056),f=a(65945),m=a(2684);class h{async createAgentKnowledgeBase(e,t,a){return await m.oq.agent.createAgentKnowledgeBase.mutate({agentId:e,enabled:a,knowledgeBaseId:t})}async deleteAgentKnowledgeBase(e,t){return await m.oq.agent.deleteAgentKnowledgeBase.mutate({agentId:e,knowledgeBaseId:t})}async toggleKnowledgeBase(e,t,a){return await m.oq.agent.toggleKnowledgeBase.mutate({agentId:e,enabled:a,knowledgeBaseId:t})}async createAgentFiles(e,t,a){return await m.oq.agent.createAgentFiles.mutate({agentId:e,enabled:a,fileIds:t})}async deleteAgentFile(e,t){return await m.oq.agent.deleteAgentFile.mutate({agentId:e,fileId:t})}async toggleFile(e,t,a){return await m.oq.agent.toggleFile.mutate({agentId:e,enabled:a,fileId:t})}async getFilesAndKnowledgeBases(e){return await m.oq.agent.getKnowledgeBasesAndFiles.query({agentId:e})}}let y=new h;var w=a(46585),F=a(55082),S=a(61887),v=a(16310);let A="FETCH_AGENT_CONFIG",T="FETCH_AGENT_KNOWLEDGE",_=(e,t)=>({addFilesToAgent:async(e,a)=>{let{activeAgentId:i,internal_refreshAgentConfig:n,internal_refreshAgentKnowledge:r}=t();i&&0!==e.length&&(await y.createAgentFiles(i,e,a),await n(t().activeId),await r())},addKnowledgeBaseToAgent:async e=>{let{activeAgentId:a,internal_refreshAgentConfig:i,internal_refreshAgentKnowledge:n}=t();a&&(await y.createAgentKnowledgeBase(a,e,!0),await i(t().activeId),await n())},removeFileFromAgent:async e=>{let{activeAgentId:a,internal_refreshAgentConfig:i,internal_refreshAgentKnowledge:n}=t();a&&(await y.deleteAgentFile(a,e),await i(t().activeId),await n())},removeKnowledgeBaseFromAgent:async e=>{let{activeAgentId:a,internal_refreshAgentConfig:i,internal_refreshAgentKnowledge:n}=t();a&&(await y.deleteAgentKnowledgeBase(a,e),await i(t().activeId),await n())},removePlugin:async e=>{await t().togglePlugin(e,!1)},toggleFile:async(e,a)=>{let{activeAgentId:i,internal_refreshAgentConfig:n}=t();i&&(await y.toggleFile(i,e,a),await n(t().activeId))},toggleKnowledgeBase:async(e,a)=>{let{activeAgentId:i,internal_refreshAgentConfig:n}=t();i&&(await y.toggleKnowledgeBase(i,e,a),await n(t().activeId))},togglePlugin:async(e,a)=>{let i=v.y.currentAgentConfig(t()),n=(0,u.Uy)(i,t=>{t.plugins=(0,u.Uy)(t.plugins||[],t=>{let i=t.indexOf(e);(void 0!==a?a:-1===i)?-1===i&&t.push(e):-1!==i&&t.splice(i,1)})});await t().updateAgentConfig(n)},updateAgentChatConfig:async e=>{let{activeId:a}=t();a&&await t().updateAgentConfig({chatConfig:e})},updateAgentConfig:async e=>{let{activeId:a}=t();if(!a)return;let i=t().internal_createAbortController("updateAgentConfigSignal");await t().internal_updateAgentConfig(a,e,i.signal)},useFetchAgentConfig:a=>(0,f.O4)([A,a],e=>{let[,t]=e;return w.F.getSessionConfig(t)},{fallbackData:l.t9,onSuccess:i=>{t().internal_dispatchAgentMap(a,i,"fetch"),e({activeAgentId:i.id},!1,"updateActiveAgentId")},suspense:!0}),useFetchFilesAndKnowledgeBases:()=>(0,f.O4)([T,t().activeAgentId],e=>{let[,t]=e;return y.getFilesAndKnowledgeBases(t)},{fallbackData:[],suspense:!0}),useInitAgentStore:(a,i)=>(0,f.Zo)(a?"fetchInboxAgentConfig":null,()=>w.F.getSessionConfig(p.B9),{onSuccess:a=>{e({defaultAgentConfig:(0,S.T)(t().defaultAgentConfig,i),isInboxAgentConfigInit:!0},!1,"initDefaultAgent"),a&&t().internal_dispatchAgentMap(p.B9,a,"initInbox")}}),internal_dispatchAgentMap:(a,i,n)=>{let r=(0,u.Uy)(t().agentMap,e=>{e[a]?e[a]=(0,S.T)(e[a],i):e[a]=i});d()(t().agentMap,r)||e({agentMap:r},!1,"dispatchAgent"+(n?"/".concat(n):""))},internal_updateAgentConfig:async(e,a,i)=>{let n=v.y.currentAgentModel(t());t().internal_dispatchAgentMap(e,a,"optimistic_updateAgentConfig"),await w.F.updateSessionConfig(e,a,i),await t().internal_refreshAgentConfig(e),n!==a.model&&await F.F.getState().refreshSessions()},internal_refreshAgentConfig:async e=>{await (0,c.mutate)([A,e])},internal_refreshAgentKnowledge:async()=>{await (0,c.mutate)([T,t().activeAgentId])},internal_createAbortController:a=>{let i=t()[a];i&&i.abort(g.F);let n=new AbortController;return e({[a]:n},!1,"internal_createAbortController"),n}}),C=(0,r.B)("agent"),E=(0,n.F)()(C(function(){for(var e=arguments.length,t=Array(e),a=0;a<e;a++)t[a]=arguments[a];return{...s,..._(...t)}}),i.X)},43613:function(e,t,a){"use strict";a.d(t,{k:function(){return n}});let i=new Set(["uploading","pending","processing"]),n={dockFileList:e=>e.dockUploadFileList,dockRawFileList:e=>e.dockUploadFileList.map(e=>e.file),getFileById:e=>t=>{if(e)return t.fileList.find(t=>t.id===e)},isCreatingChunkEmbeddingTask:e=>t=>t.creatingEmbeddingTaskIds.includes(e),isCreatingFileParseTask:e=>t=>t.creatingChunkingTaskIds.includes(e),isUploadingFiles:e=>e.dockUploadFileList.some(e=>i.has(e.status)),overviewUploadingProgress:e=>{let t=e.dockUploadFileList.filter(e=>"uploading"===e.status||"pending"===e.status);if(0===t.length)return 100;let a=100*t.length;return t.reduce((e,t)=>{var a;return e+((null===(a=t.uploadState)||void 0===a?void 0:a.progress)||0)},0)/a*100},overviewUploadingStatus:e=>0===e.dockUploadFileList.length?"pending":e.dockUploadFileList.some(e=>i.has(e.status))?"uploading":"success"}},30526:function(e,t,a){"use strict";a.d(t,{O:function(){return z}});var i=a(28769),n=a(71327),r=a(55059);let l={chatUploadFileList:[],uploadingIds:[],creatingChunkingTaskIds:[],creatingEmbeddingTaskIds:[],dockUploadFileList:[],fileList:[],chunkDetailId:null,highlightChunkIds:[],similaritySearchChunks:[]};var s=a(79951),o=a(76662);let d=[".DS_Store"];var u=a(13906),c=a(3851),g=a(35222),p=a(56922),f=a(51585),m=a(91192),h=a(61472);let y=(e,t)=>{switch(t.type){case"addFile":return(0,h.Uy)(e,e=>{let{atStart:a,file:i}=t;a?e.unshift(i):e.push(i)});case"addFiles":return(0,h.Uy)(e,e=>{let{atStart:a,files:i}=t;for(let t of i)a?e.unshift(t):e.push(t)});case"updateFile":return(0,h.Uy)(e,e=>{let a=e.find(e=>e.id===t.id);a&&Object.assign(a,t.value)});case"updateFileStatus":return(0,h.Uy)(e,e=>{let a=e.find(e=>e.id===t.id);a&&(a.status=t.status)});case"updateFileUploadState":return(0,h.Uy)(e,e=>{let a=e.find(e=>e.id===t.id);a&&(a.uploadState=t.uploadState)});case"removeFile":return(0,h.Uy)(e,e=>{let a=e.findIndex(e=>e.id===t.id);-1!==a&&e.splice(a,1)});case"removeFiles":return(0,h.Uy)(e,e=>{for(let a of t.ids){let t=e.findIndex(e=>e.id===a);-1!==t&&e.splice(t,1)}});default:throw Error("Unhandled action type")}};var w=a(97013),F=a(78593);let S=async e=>await new Promise(t=>{setTimeout(t,e)});var v=a(7136),A=a(9109).Buffer;let T=(0,v.Z)("chat"),_=new c.N,C=(e,t)=>({clearChatUploadFileList:()=>{e({chatUploadFileList:[]},!1,T("clearChatUploadFileList"))},dispatchChatUploadFileList:a=>{let i=y(t().chatUploadFileList,a);i!==t().chatUploadFileList&&e({chatUploadFileList:i},!1,"dispatchChatFileList/".concat(a.type))},removeChatUploadFile:async e=>{let{dispatchChatUploadFileList:a}=t();a({id:e,type:"removeFile"}),await u.b.removeFile(e)},startAsyncTask:async(e,t,a)=>{await t(e);let i=!1;for(;!i;){let t;await S(2e3);try{t=await _.getFileItem(e)}catch(e){console.error("getFileItem Error:",e);continue}if(!t)return;a(t),t.finishEmbedding?i=!0:("error"===t.chunkingStatus||"error"===t.embeddingStatus)&&(i=!0)}},uploadChatFiles:async e=>{let{dispatchChatUploadFileList:a,startAsyncTask:i}=t(),n=e.filter(e=>!d.includes(e.name));a({files:await Promise.all(n.map(async e=>{let t,a;if(e.type.startsWith("image")||e.type.startsWith("video")){let i=await e.arrayBuffer();t=URL.createObjectURL(new Blob([i],{type:e.type}));let n=A.from(i).toString("base64");a="data:".concat(e.type,";base64,").concat(n)}return{base64Url:a,file:e,id:e.name,previewUrl:t,status:"pending"}})),type:"addFiles"});let r=n.map(async e=>{let n;try{n=await t().uploadWithProgress({file:e,onStatusUpdate:a})}catch(t){(null==t?void 0:t.message)!=="UNAUTHORIZED"&&o.t6.error({description:t===p.W?(0,s.t)("upload.networkError",{ns:"error"}):"string"==typeof t?t:(0,s.t)("upload.unknownError",{ns:"error",reason:t.message}),message:(0,s.t)("upload.uploadFailed",{ns:"error"})}),a({id:e.name,type:"removeFile"})}n&&(e.type.startsWith("image")||(a({id:n.id,type:"updateFile",value:{tasks:{}}}),await i(n.id,async e=>{let t=await g.S.createParseFileTask(e);if(!t||!t.id)throw Error("failed to createParseFileTask");return m.E.getState().addFilesToAgent([e],!1).then(()=>{F.l.shouldTriggerFileInKnowledgeBaseTip(w.L.getState())&&f.W.updateGuide({uploadFileInKnowledgeBase:!0})}),t.id},e=>{a({id:n.id,type:"updateFile",value:{tasks:{chunkCount:e.chunkCount,chunkingError:e.chunkingError,chunkingStatus:e.chunkingStatus,embeddingError:e.embeddingError,embeddingStatus:e.embeddingStatus,finishEmbedding:e.finishEmbedding}}})})))});await Promise.all(r)}}),E=e=>({closeChunkDrawer:()=>{e({chunkDetailId:null,isSimilaritySearch:!1,similaritySearchChunks:[]})},highlightChunks:t=>{e({highlightChunkIds:t})},openChunkDrawer:t=>{e({chunkDetailId:t})},semanticSearch:async(t,a)=>{e({isSimilaritySearching:!0}),e({isSimilaritySearching:!1,similaritySearchChunks:await g.S.semanticSearch(t,[a])})}});var I=a(83048),k=a(65945),b=a(43613);let U=new c.N,B="useFetchFileManage",L=(e,t)=>({dispatchDockFileList:a=>{let i=y(t().dockUploadFileList,a);i!==t().dockUploadFileList&&e({dockUploadFileList:i},!1,"dispatchDockFileList/".concat(a.type))},embeddingChunks:async e=>{t().toggleEmbeddingIds(e);let a=e.map(async e=>{try{await g.S.createEmbeddingChunksTask(e)}catch(e){console.error(e)}});await Promise.all(a),await t().refreshFileList(),t().toggleEmbeddingIds(e,!1)},parseFilesToChunks:async(e,a)=>{t().toggleParsingIds(e);let i=e.map(async e=>{try{await g.S.createParseFileTask(e,null==a?void 0:a.skipExist)}catch(e){console.error(e)}});await Promise.all(i),await t().refreshFileList(),t().toggleParsingIds(e,!1)},pushDockFileList:async(e,a)=>{let{dispatchDockFileList:i}=t(),n=e.filter(e=>!d.includes(e.name));i({atStart:!0,files:n.map(e=>({file:e,id:e.name,status:"pending"})),type:"addFiles"});let r=n.map(async e=>{await t().uploadWithProgress({file:e,knowledgeBaseId:a,onStatusUpdate:i}),await t().refreshFileList()});await Promise.all(r)},reEmbeddingChunks:async e=>{b.k.isCreatingChunkEmbeddingTask(e)(t())||(t().toggleEmbeddingIds([e]),await U.removeFileAsyncTask(e,"embedding"),await t().refreshFileList(),await g.S.createEmbeddingChunksTask(e),await t().refreshFileList(),t().toggleEmbeddingIds([e],!1))},reParseFile:async e=>{t().toggleParsingIds([e]),await g.S.retryParseFile(e),await t().refreshFileList(),t().toggleParsingIds([e],!1)},refreshFileList:async()=>{await (0,I.mutate)([B,t().queryListParams])},removeAllFiles:async()=>{await u.b.removeAllFiles()},removeFileItem:async e=>{await u.b.removeFile(e),await t().refreshFileList()},removeFiles:async e=>{await u.b.removeFiles(e),await t().refreshFileList()},toggleEmbeddingIds:(t,a)=>{e(e=>{let i=new Set(e.creatingEmbeddingTaskIds);return t.forEach(e=>{void 0===a?i.has(e)?i.delete(e):i.add(e):a?i.add(e):i.delete(e)}),{creatingEmbeddingTaskIds:Array.from(i.values())}})},toggleParsingIds:(t,a)=>{e(e=>{let i=new Set(e.creatingChunkingTaskIds);return t.forEach(e=>{void 0===a?i.has(e)?i.delete(e):i.add(e):a?i.add(e):i.delete(e)}),{creatingChunkingTaskIds:Array.from(i.values())}})},useFetchFileItem:e=>(0,k.O4)(e?["useFetchFileItem",e]:null,()=>U.getFileItem(e)),useFetchFileManage:t=>(0,k.O4)([B,t],()=>U.getFiles(t),{onSuccess:a=>{e({fileList:a,queryListParams:t})}})}),P=(e,t)=>({removeTTSFile:async e=>{await u.b.removeFile(e)},uploadTTSByArrayBuffers:async(e,a)=>{let i="audio/mp3",n=new Blob(a,{type:i}),r={lastModified:Date.now(),type:i},l=new File([n],"".concat(e,".mp3"),r),s=await t().uploadWithProgress({file:l,skipCheckFileType:!0});return null==s?void 0:s.id},useFetchTTSFile:e=>(0,k.O4)(e?["fetchTTSFile",e]:null,()=>u.b.getFile(e))});var N=a(75544),D=a(72109),O=a(27166);let K=new c.N,M=(e,t)=>({internal_uploadToClientDB:async e=>{let{file:t,onStatusUpdate:a,skipCheckFileType:i}=e;if(!i&&!t.type.startsWith("image")){null==a||a({id:t.name,type:"removeFile"}),o.yw.info({content:(0,s.t)("upload.fileOnlySupportInServerMode",{cloud:D.Ms,ext:t.name.split(".").pop(),ns:"error"}),duration:5});return}let n=await t.arrayBuffer(),r=(0,N.sha256)(n),l=await p.T.uploadToClientDB({fileType:t.type,hash:r,name:t.name,saveMode:"local",size:t.size},t);return null==a||a({id:t.name,type:"updateFile",value:{fileUrl:l.url,id:l.id,status:"success",uploadState:{progress:100,restTime:0,speed:0}}}),l},internal_uploadToServer:async e=>{let t,{file:i,onStatusUpdate:n,knowledgeBaseId:r}=e,l=await i.arrayBuffer(),s=(0,N.sha256)(l),o=await K.checkFileHash(s);o.isExist?(t=o.metadata,null==n||n({id:i.name,type:"updateFile",value:{status:"processing",uploadState:{progress:100,restTime:0,speed:0}}})):t=await p.T.uploadWithProgress(i,{onProgress:(e,t)=>{null==n||n({id:i.name,type:"updateFile",value:{status:"success"===e?"processing":e,uploadState:t}})}});let d=i.type;if(!i.type){let{fileTypeFromBuffer:e}=await a.e(61474).then(a.bind(a,61474)),t=await e(l);d=(null==t?void 0:t.mime)||"text/plain"}let c=await u.b.createFile({createdAt:Date.now(),fileType:d,hash:s,metadata:t,name:i.name,saveMode:"url",size:i.size,url:t.path},r);return null==n||n({id:i.name,type:"updateFile",value:{fileUrl:c.url,id:c.id,status:"success",uploadState:{progress:100,restTime:0,speed:0}}}),c},uploadWithProgress:async e=>{let{internal_uploadToServer:a,internal_uploadToClientDB:i}=t();return O.ZN?a(e):i(e)}}),q=(0,r.B)("file"),z=(0,n.F)()(q(function(){for(var e=arguments.length,t=Array(e),a=0;a<e;a++)t[a]=arguments[a];return{...l,...C(...t),...L(...t),...P(...t),...E(...t),...M(...t)}}),i.X)},88688:function(e,t,a){"use strict";var i,n,r,l;a.d(t,{n:function(){return n}}),(r=i||(i={})).Files="files",r.Settings="Settings",r.Testing="testing",(l=n||(n={})).File="file",l.KnowledgeBase="knowledgeBase"}}]);