https://cdn.pi.inc/web/3dab686ae1d6879cee0bf16fed35e60ab739be9d/assets/api-CoB9YYBy.js

1import{$ as e,B as t,Ct as n,In as r,Ln as i,Nn as a,Pn as o,Qt as s,R as c,V as l,Vn as u,Xt as d,Yt as f,Zt as p,_t as m,at as ee,ct as h,dn as g,f as _,l as v,lt as y,on as b,pn as x,pt as S,tt as C,ut as w,v as T,z as E}from"./main-BVhmgz58.js";import{Nr as D,hr as O}from"./index-DHugf5H0.js";var k=()=>{let e={Accept:`text/event-stream`,"Content-Type":`application/json`},t=localStorage.getItem(`auth`),n=localStorage.getItem(`locale`),r=Intl.DateTimeFormat().resolvedOptions().timeZone;return t&&(e.Authorization=t),n&&(e[`Accept-Language`]=n),r&&(e[`X-Timezone`]=r),e},A=(e,t)=>{let n=e.trim();if(!(!n||n===`data: [DONE]`)&&n.startsWith(`data: `))try{t(JSON.parse(n.replace(/^data:\s*/,``)))}catch(e){console.warn(`Failed to parse agent stream payload`,e)}},j=({agentName:e,imageStyleId:t,workspaceId:n,requestData:r,onMessage:i,onError:a,onComplete:o})=>{let s=new AbortController,c=`${u()}/api/v1/workspace/${n}/agent/chat`,l={...r,...e?{agent_name:e}:{},...t?{image_style:{id:t}}:{}};if(l.agent_name!==`pi_image_agent`){let e=r.messages[0]?.content;(e?.type!==`form`||e.schema_version===2)&&(l.schema_version=2,l.project_id&&(l.agent_name=`General_ppt_agent`))}return fetch(c,{body:JSON.stringify(l),headers:k(),method:`POST`,signal:s.signal}).then(async e=>{if(!e.ok){let t=`Request failed: ${e.status} ${e.statusText}`,n;try{let r=await e.json();r.message&&(t=r.message),n=r.error}catch{}let r=Error(t);throw r.code=n,r.status=e.status,r}let t=e.body?.getReader();if(!t){o?.();return}let n=new TextDecoder,r=``;for(;;){let{done:e,value:a}=await t.read();if(e){r.trim()&&A(r,i),o?.();break}if(r+=n.decode(a,{stream:!0}),!r.includes(`
2
3`))continue;let s=r.split(`
4
5`);r=s.pop()??``,s.forEach(e=>A(e,i))}}).catch(e=>{s.signal.aborted||a?.(e)}),()=>s.abort()},M=async()=>(await x()).data.data??[],N=async(e,t={},n)=>{let r=await E(e,{page:t.page??1,size:t.size??20,...n?{agent_type:n}:{}});return{list:r.data.data,page:r.data.page,size:r.data.size,total:r.data.total}},P=async e=>(await t({image:[],model:e.model||`gpt-image-2`,prompt:e.prompt,response_format:e.response_format||`url`,size:e.size||`1248x832`,style:e.style||`Auto`,...e.workspaceId&&e.workspaceId!==`0`?{workspace_id:e.workspaceId}:{},...e.projectId?{project_id:e.projectId}:{}})).data.data,F=async e=>(await l(e)).data.data,I=async(e,t)=>(await c(e,t)).data.data,L=async(e,t)=>({...(await h(e,t)).data.data,workspace_id:e}),R=async(e,t,n)=>{let r=typeof n==`string`?Number(n):n;if(!Number.isFinite(r))throw Error(`Invalid snapshot id: ${n}`);return(await S(e,t,r)).data.data},te=async(e,t,n)=>(await m(e,t,{layout:n})).data.data,z=async(e,t)=>{let n=(await g(e,t,{skipGlobalErrorToast:!0})).data.data.user_lottery_winning_record??[];return n.length>0&&O(),n},B=async(e,t)=>({...(await C(e,t)).data.data,workspace_id:e}),V=e=>e.update_time||e.share_time||e.create_time,H=e=>e.slice().sort((e,t)=>{let n=new Date(V(e)||0).getTime();return new Date(V(t)||0).getTime()-n}),U=async(e,t=6)=>{let n={direction:`desc`,is_archived:!1,page:1,size:t},r=[`update_time`,`update`,`view`];for(let i of r)try{return H((await y(e,{...n,column:i})).data.data).slice(0,t)}catch(e){if(i===r[r.length-1])throw e}return[]},W=async(e,t,r)=>(await n(e,t,{title:r},{skipGlobalErrorToast:!0})).data.data,G=async(t,n)=>{await e(t,n,{force:!1})},K=async(e,t,n)=>{await ee(e,t,{favorite:n})},q=async(e,t)=>(await w(e,{column:`publish`,direction:`desc`,page:t,size:60})).data.data,J=async()=>(await o()).data.data,Y=e=>{if(e!=null)return String(e).trim()||void 0},X=async e=>{let t=Y(e.colorId),n=Y(e.sceneId),r=Y(e.styleId);return(await a({column:`priority`,page:1,size:200,...t?{color_id:t}:{},...n?{scene_id:n}:{},...r?{style_id:r}:{}})).data.data},Z=async e=>(await i(e,{page:1,size:200})).data.data,Q=async(e,t)=>{let n=Number(t);if(!Number.isFinite(n))throw Error(`Invalid theme id: ${t}`);let i=(await r(e,n)).data;return`data`in i&&i.data?i.data:i},ne=async e=>{let[t,n]=await Promise.all([a({page:1,size:0}),e&&e!==`0`?i(e,{page:1,size:0}):Promise.resolve(null)]);return[...t.data.data,...n?.data.data??[]]},re=async(e,t=``)=>(t.trim()?await T({keyword:t.trim(),page:1,size:100}):await _({page:1,parent_id:String(e),size:100})).data.data??[],ie=async e=>{if(!e.storage_url)throw Error(`Cloud drive file has no storage URL`);let t=await v({url:e.storage_url},{format:`blob`}),n=t.data instanceof Blob?t.data:new Blob([t.data],{type:e.mime_type}),r=e.extension?`.${e.extension}`:``,i=e.name.toLowerCase().endsWith(r.toLowerCase())?e.name:`${e.name}${r}`;return new File([n],i,{type:n.type||e.mime_type})},ae=async(e,t,n)=>(await D({data:n?{project_id:n}:{},method:`POST`,url:`/api/v1/workspace/${encodeURIComponent(e)}/drive/attachments/${encodeURIComponent(t)}`})).data,oe=async(e,t,n)=>(await d(e,(await b(e,{file:t,...n?{project_id:n}:{}})).data.data.id)).data.data,$=async(e,t)=>(await d(e,t)).data.data,se=async(e,t,n)=>{let r=(await b(e,{file:t,...n?{project_id:n}:{}})).data.data;return{drive_node_id:r.drive_node_id??void 0,file_type:`image`,filename:t.name,id:r.id,project_id:r.project_id??void 0,url:r.url}},ce=async(e,t,n)=>(await p(e,{url:t,...n?{project_id:n}:{}})).data.data,le=async(e,t,n)=>(await f(e,t,n)).data.data,ue=async(e,t)=>(await s(e,t)).data.data;export{se as A,le as C,$ as D,te as E,oe as O,P as S,j as T,M as _,B as a,Q as b,I as c,R as d,ue as f,U as g,X as h,z as i,ce as k,N as l,q as m,G as n,K as o,F as p,ie as r,re as s,ae as t,L as u,ne as v,W as w,Z as x,J as y};