https://igitems.es/build/es/q-DgQxK9Ki.js

1import{v as o,J as f,x as c}from"./q-B7_OLekH.js";import{aD as P}from"./q-BdjGOZ__.js";const x=e=>{const[t]=o();return t("typing",e)},A=Object.freeze(Object.defineProperty({__proto__:null,_hW:c,s_FhwgCrMNrgs:x},Symbol.toStringTag,{value:"Module"})),O=(e,t)=>{const[s]=o();return s._eventHandlers||(s._eventHandlers=f(new Map)),s._eventHandlers.has(e)||s._eventHandlers.set(e,new Set),s._eventHandlers.get(e).add(t),()=>{s._eventHandlers?.get(e)?.delete(t)}},R=Object.freeze(Object.defineProperty({__proto__:null,_hW:c,s_glJyTakl6g4:O},Symbol.toStringTag,{value:"Module"})),j=e=>{const[t]=o();return t("seen",e)},L=Object.freeze(Object.defineProperty({__proto__:null,_hW:c,s_NwVrpnq9nTI:j},Symbol.toStringTag,{value:"Module"})),v=e=>{const[t]=o();return t("contact",e)},N=Object.freeze(Object.defineProperty({__proto__:null,_hW:c,s_5ySo6PvdQz0:v},Symbol.toStringTag,{value:"Module"})),k=e=>{const[t]=o();return t("message",e)},J=Object.freeze(Object.defineProperty({__proto__:null,_hW:c,s_0U7wsEqfL0A:k},Symbol.toStringTag,{value:"Module"})),m=e=>{const[t]=o();return t("offer",e)},q=Object.freeze(Object.defineProperty({__proto__:null,_hW:c,s_spVPCRoEC3c:m},Symbol.toStringTag,{value:"Module"})),C=(e,t,s)=>{const[n]=o();if(typeof window>"u")return null;let r=null,u=!0,i=0,h=null;const p=async()=>{const g=await s(),y=new URL(P());y.searchParams.set("type",e),y.searchParams.set("room",t),Object.entries(g).forEach(([l,a])=>y.searchParams.set(l,a));const _=new WebSocket(y.toString());r=_,e==="user"?(n._userSocket=f(_),n.userConnected=!1):(n._chatSocket=f(_),n.chatConnected=!1,n.currentChatRoom=t),_.onopen=()=>{const l=i>0;i=0,e==="user"?n.userConnected=!0:n.chatConnected=!0,n._eventHandlers?.get(`${e}:connected`)?.forEach(d=>d({type:e,room:t,reconnected:l}))},_.onmessage=l=>{try{const a=JSON.parse(l.data);if(a.type&&n._eventHandlers){const d=n._eventHandlers.get(a.type);if(d){const S=a.payload!==void 0?a.payload:a;d.forEach(b=>b(S))}}}catch(a){console.error("[WS] Message parse error",a)}},_.onclose=async l=>{if(e==="user"?n._userSocket===_:n._chatSocket===_){if(e==="user"?n.userConnected=!1:n.chatConnected=!1,l.code===1008){u=!1;return}if(u){const d=Math.min(1e3*Math.pow(2,i),1e4);i++,h=setTimeout(p,d)}}},_.onerror=l=>{console.error(`[WS] Error ${e}:${t}`,l),_.close()}};return p(),()=>{u=!1,h&&clearTimeout(h),r&&r.close(),e==="user"?(n._userSocket=null,n.userConnected=!1):(n._chatSocket=null,n.chatConnected=!1,n.currentChatRoom=null)}},U=Object.freeze(Object.defineProperty({__proto__:null,_hW:c,s_Mvv307wa6pc:C},Symbol.toStringTag,{value:"Module"})),M=()=>{const[e]=o();e._chatDisconnect&&(e._chatDisconnect(),e._chatDisconnect=null)},B=Object.freeze(Object.defineProperty({__proto__:null,_hW:c,s_WhB2dLbjw7I:M},Symbol.toStringTag,{value:"Module"})),T=()=>{const[e]=o();e._userDisconnect&&(e._userDisconnect(),e._userDisconnect=null),e._chatDisconnect&&(e._chatDisconnect(),e._chatDisconnect=null)},F=Object.freeze(Object.defineProperty({__proto__:null,_hW:c,s_nddXKe9LucE:T},Symbol.toStringTag,{value:"Module"})),W=e=>{const[t]=o();return t("notification",e)},K=Object.freeze(Object.defineProperty({__proto__:null,_hW:c,s_1ebRxhHWv8c:W},Symbol.toStringTag,{value:"Module"})),w=async(e,t)=>{const[s,n]=o();if(n._userSocket)return;const r=await s("user",e,async()=>({token:typeof localStorage<"u"&&localStorage.getItem("authToken")||t}));r&&(n._userDisconnect=f(r))},Q=Object.freeze(Object.defineProperty({__proto__:null,_hW:c,s_ksAx7F01IMg:w},Symbol.toStringTag,{value:"Module"})),z=e=>{const[t]=o();return t("chat:connected",e)},V=Object.freeze(Object.defineProperty({__proto__:null,_hW:c,s_Q7c9B3lIi94:z},Symbol.toStringTag,{value:"Module"})),D=e=>{const[t]=o();return t("presence",e)},X=Object.freeze(Object.defineProperty({__proto__:null,_hW:c,s_pWtKtw96z98:D},Symbol.toStringTag,{value:"Module"})),I=async(e,t,s)=>{const[n,r]=o();r._chatDisconnect&&(r._chatDisconnect(),r._chatDisconnect=null);const u=await n("chat",e,async()=>{const i=typeof localStorage<"u"&&localStorage.getItem("authToken")||s;return{userId:t,token:i}});u&&(r._chatDisconnect=f(u))},Z=Object.freeze(Object.defineProperty({__proto__:null,_hW:c,s_CZAkAkkMAfI:I},Symbol.toStringTag,{value:"Module"})),E=e=>{const[t]=o();t._chatSocket&&t._chatSocket.readyState===WebSocket.OPEN&&t._chatSocket.send(JSON.stringify({type:"typing",isTyping:e}))},G=Object.freeze(Object.defineProperty({__proto__:null,_hW:c,s_OnyoLR5CgPs:E},Symbol.toStringTag,{value:"Module"}));

1export{c as _hW,R as a,L as b,N as c,J as d,q as e,U as f,B as g,F as h,K as i,Q as j,V as k,X as l,Z as m,G as n,A as p,k as s_0U7wsEqfL0A,W as s_1ebRxhHWv8c,v as s_5ySo6PvdQz0,I as s_CZAkAkkMAfI,x as s_FhwgCrMNrgs,C as s_Mvv307wa6pc,j as s_NwVrpnq9nTI,E as s_OnyoLR5CgPs,z as s_Q7c9B3lIi94,M as s_WhB2dLbjw7I,O as s_glJyTakl6g4,w as s_ksAx7F01IMg,T as s_nddXKe9LucE,D as s_pWtKtw96z98,m as s_spVPCRoEC3c};