1try{let e="undefined"!=typeof window?window:"undefined"!=typeof global?global:"undefined"!=typeof globalThis?globalThis:"undefined"!=typeof self?self:{},n=(new e.Error).stack;n&&(e._sentryDebugIds=e._sentryDebugIds||{},e._sentryDebugIds[n]="d61a798f-f756-4d4a-acf9-89664073f0d0",e._sentryDebugIdIdentifier="sentry-dbid-d61a798f-f756-4d4a-acf9-89664073f0d0")}catch(e){}(self.webpackChunk_N_E=self.webpackChunk_N_E||[]).push([[8207],{66484:()=>{},87409:()=>{},90258:()=>{},92385:()=>{},99789:(e,n,t)=>{"use strict";t.d(n,{sendPushCore:()=>c});var i=t(50707),a=t.n(i),o=t(48339),r=t(73647),s=t(98132);async function l(e){console.warn("[Push Server Debug] getBulkPushSubscriptions called with memberIds:",e);let n=await (0,s.zV)(),{data:t}=await n.from("push_subscriptions").select("member_id, endpoint, created_at").order("created_at",{ascending:!1});console.warn("[Push Server Debug] All subscriptions in database:",{total:(null==t?void 0:t.length)||0,byMember:null==t?void 0:t.reduce((e,n)=>(e[n.member_id]=(e[n.member_id]||0)+1,e),{})});let{data:i,error:a}=await n.from("push_subscriptions").select("member_id, endpoint, p256dh, auth").in("member_id",e);if(a)throw console.error("[Push Server Debug] Error fetching subscriptions:",a),a;console.warn("[Push Server Debug] Subscriptions fetched for requested members:",{requestedMemberIds:e,count:(null==i?void 0:i.length)||0,memberIds:(null==i?void 0:i.map(e=>e.member_id))||[],endpoints:(null==i?void 0:i.map(e=>e.endpoint.substring(0,50)+"..."))||[]});let o=new Map;return null==i||i.forEach(e=>{let n={endpoint:e.endpoint,keys:{p256dh:e.p256dh,auth:e.auth}},t=o.get(e.member_id)||[];t.push(n),o.set(e.member_id,t)}),o}var d=t(43735);async function c(e){var n,t,i,c,u,f,b,m,p,_,h,g,w,y;let I=await (0,s.db)();if(!r.h.VAPID_PUBLIC_KEY||!o.N.VAPID_PRIVATE_KEY)throw Error("VAPID keys not configured");a().setVapidDetails(o.N.VAPID_EMAIL,r.h.VAPID_PUBLIC_KEY,o.N.VAPID_PRIVATE_KEY);let P=!1!==e.respectPreferences,k=null!=(n=e.notificationType)?n:"message",D=await l(e.recipientMemberIds),v=D;if(P){let{data:e}=await I.from("workspace_members").select("id, notification_preferences").in("id",Array.from(D.keys())),n=new Map;for(let t of null!=e?e:[]){let e=t.notification_preferences;n.set(t.id,null!=e?e:{})}let a=new Map;for(let[e,o]of D){let r=null!=(t=n.get(e))?t:{};if(!(null==(i=r.push_enabled)||i))continue;let s=null!=(c=r.team_chat)?c:{},l=!0;switch(k){case"mention":l=null==(u=s.mention_direct)||u||null==(f=s.mention_all)||f||null==(b=s.mention_here)||b||null==(m=s.mention_channel)||m;break;case"mention_direct":l=null==(p=s.mention_direct)||p;break;case"mention_here":l=null==(_=s.mention_here)||_;break;case"mention_channel":l=null==(h=s.mention_channel)||h;break;case"mention_all":l=null==(g=s.mention_all)||g;break;case"message":l=null==(w=s.all_messages)||w;break;case"thread_reply":l=null==(y=s.threads_participated)||y;break;default:l=!0}l&&a.set(e,o)}v=a}let E={title:e.notification.title,body:e.notification.body,tag:e.notification.tag||"notification-".concat(Date.now()),data:e.notification.data||{},requireInteraction:e.notification.requireInteraction||!1,actions:e.notification.actions||[],icon:e.notification.icon||"/icon-192x192.png",badge:e.notification.badge||"/badge-72x72.png",image:e.notification.image},A=0,S=0,V=new Set;for(let[e,n]of v){let t=n.filter(n=>!(0,d.fz)(n.endpoint)||(console.warn("[Push Server Debug] Skipping Tauri subscription for Web Push delivery:",{memberId:e,endpoint:n.endpoint}),!1));if(0!==t.length)for(let n of(V.add(e),t))try{await a().sendNotification(n,JSON.stringify(E)),A++}catch(t){S++,t&&"object"==typeof t&&"statusCode"in t&&410===t.statusCode&&await I.from("push_subscriptions").delete().eq("member_id",e).eq("endpoint",n.endpoint)}}return{success:!0,recipientCount:V.size,sent:A,failed:S}}}}]);
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.