[{"_1":2,"_186":-5,"_187":-5},"loaderData",{"_3":4,"_98":99},"root",{"_5":6,"_39":40,"_71":72},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20,"_36":-5,"_37":20,"_38":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","ENV",{"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","6001c7decb8dfd083f3b0ffa5d457c864fb16b4a","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","API_URL","https://api.val.town","clerkState",{"_73":74},"__internal_clerk_state",{"_75":76,"_77":50,"_78":79,"_80":79,"_81":20,"_82":79,"_83":79,"_84":79,"_85":79,"_86":87,"_96":20,"_97":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_88":20,"_19":20,"_89":79,"_90":91,"_92":79,"_93":50,"_94":20,"_95":79},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_100":101,"_102":103,"_104":105,"_106":107,"_163":164,"_183":184,"_185":-5},"handle","jowood94","name","notifyCompletion","path","scheduled.ts","project",{"_108":109,"_102":103,"_110":111,"_112":-5,"_113":20,"_114":115,"_116":-5,"_117":-5,"_12":118,"_119":-5,"_120":20,"_121":-5,"_122":-5,"_123":33,"_14":124,"_125":-5,"_126":-5,"_127":-5,"_128":-5,"_129":130,"_131":130,"_132":133,"_134":133,"_135":133,"_136":130,"_137":130,"_23":138,"_141":142,"_146":147,"_162":20},"id","b2f7a1c2-399c-11f1-8224-42b51c65c3df","createdAt",["D",1776348060532],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","be2d4e89-1497-47a1-9051-1fee95fe0b49","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","019d9692-976f-76db-bd3a-758011d08db5","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_100":101,"_139":140},"profileImageUrl","https://avatars.githubusercontent.com/u/34335418?v=4","org",{"_100":101,"_143":140,"_12":118,"_144":145},"avatar","tier","free","branch",{"_148":149,"_102":48,"_108":150,"_151":109,"_152":153,"_154":155,"_156":115,"_157":158,"_159":124,"_160":103,"_161":101},"version",44,"b2fd158a-399c-11f1-8224-42b51c65c3df","projectId","forkedBranchId","775d8550-399c-11f1-9019-42b51c65c3df","forkedBranchVersion",1,"forkedProjectPrivacy","forkedProjectId","775cbc1a-399c-11f1-9019-42b51c65c3df","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_108":165,"_102":105,"_166":167,"_168":-5,"_169":150,"_170":171,"_172":173,"_110":174,"_148":175,"_176":177,"_178":179,"_180":20,"_181":-5,"_104":182},"b81966e2-399f-11f1-903c-42b51c65c3df","fileId","9a450e50-399f-11f1-8c6c-42b51c65c3df","parentId","branchId","branchVersion",10,"latest",true,["D",1776349357617],3,"fileType","interval","content","// punto! — scheduled reminder delivery (val.town Cron trigger, every 1 min)\n//\n// Port del cron GitHub Actions (server/index.js) con granularità 1 min invece di 5.\n//\n// Deploy:\n// - Nuovo file nel Project \"notifyCompletion\" (o val separato)\n// - Trigger: Cron → \"* * * * *\" (ogni minuto)\n// - Env vars condivise col val HTTP: FIREBASE_PROJECT_ID, FIREBASE_SERVICE_ACCOUNT\n//\n// Funzioni:\n// 1. checkAndSendReminders() — query reminderStatus=pending, invia FCM,\n// gestisce ricorrenze e snooze, aggiorna reminderTime/reminderStatus e blocks[]\n// 2. checkAndSendCompletions() — cleanup di flag completionNotifyPending residui\n// (rete di sicurezza: il val HTTP è il path primario, questo pulisce i lost event)\n\nimport { SignJWT } from \"npm:jose@5\";\n\nconst FIREBASE_PROJECT_ID = Deno.env.get(\"FIREBASE_PROJECT_ID\")!;\nconst SERVICE_ACCOUNT = JSON.parse(Deno.env.get(\"FIREBASE_SERVICE_ACCOUNT\")!);\n\nlet cachedGcpToken: { token: string; exp: number } | null = null;\n\nconst NOTIF_STRINGS: Record string;\n bodyNoDate: string;\n}> = {\n it: {\n defaultTitle: \"punto! — Promemoria\",\n bodyWithDate: (d) => `Hai un promemoria per il ${d}`,\n bodyNoDate: \"Hai un promemoria in scadenza!\",\n },\n en: {\n defaultTitle: \"punto! — Reminder\",\n bodyWithDate: (d) => `You have a reminder for ${d}`,\n bodyNoDate: \"You have an upcoming reminder!\",\n },\n};\n\nconst COMPLETION_STRINGS: Record<\n string,\n { title: string; body: (name: string) => string }\n> = {\n it: {\n title: \"punto! — Promemoria evaso\",\n body: (name) => `${name} ha evaso un promemoria condiviso`,\n },\n en: {\n title: \"punto! — Reminder completed\",\n body: (name) => `${name} completed a shared reminder`,\n },\n};\n\n// ── GCP OAuth ───────────────────────────────────────────────────────────────\n\nasync function getGcpAccessToken(): Promise {\n const now = Math.floor(Date.now() / 1000);\n if (cachedGcpToken && cachedGcpToken.exp > now + 60) {\n return cachedGcpToken.token;\n }\n\n const pem = (SERVICE_ACCOUNT.private_key as string)\n .replace(/-----BEGIN PRIVATE KEY-----/g, \"\")\n .replace(/-----END PRIVATE KEY-----/g, \"\")\n .replace(/\\s+/g, \"\");\n const der = Uint8Array.from(atob(pem), (c) => c.charCodeAt(0));\n const key = await crypto.subtle.importKey(\n \"pkcs8\",\n der,\n { name: \"RSASSA-PKCS1-v1_5\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n\n const jwt = await new SignJWT({\n scope:\n \"https://www.googleapis.com/auth/datastore https://www.googleapis.com/auth/firebase.messaging\",\n })\n .setProtectedHeader({ alg: \"RS256\", typ: \"JWT\" })\n .setIssuer(SERVICE_ACCOUNT.client_email)\n .setAudience(\"https://oauth2.googleapis.com/token\")\n .setIssuedAt(now)\n .setExpirationTime(now + 3600)\n .sign(key);\n\n const resp = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n grant_type: \"urn:ietf:params:oauth:grant-type:jwt-bearer\",\n assertion: jwt,\n }),\n });\n if (!resp.ok) {\n throw new Error(`GCP token exchange failed: ${await resp.text()}`);\n }\n const { access_token, expires_in } = await resp.json();\n cachedGcpToken = { token: access_token, exp: now + expires_in };\n return access_token;\n}\n\n// ── Firestore Value encoder/decoder ─────────────────────────────────────────\n\nfunction fsFromJs(v: any): any {\n if (v === null || v === undefined) return { nullValue: null };\n if (typeof v === \"boolean\") return { booleanValue: v };\n if (typeof v === \"number\") {\n return Number.isInteger(v)\n ? { integerValue: String(v) }\n : { doubleValue: v };\n }\n if (typeof v === \"string\") return { stringValue: v };\n if (Array.isArray(v)) return { arrayValue: { values: v.map(fsFromJs) } };\n if (typeof v === \"object\") {\n const fields: any = {};\n for (const [k, val] of Object.entries(v)) fields[k] = fsFromJs(val);\n return { mapValue: { fields } };\n }\n return { nullValue: null };\n}\n\nfunction fsToJs(v: any): any {\n if (!v) return null;\n if (\"stringValue\" in v) return v.stringValue;\n if (\"integerValue\" in v) return Number(v.integerValue);\n if (\"doubleValue\" in v) return v.doubleValue;\n if (\"booleanValue\" in v) return v.booleanValue;\n if (\"nullValue\" in v) return null;\n if (\"timestampValue\" in v) return new Date(v.timestampValue).getTime();\n if (\"arrayValue\" in v) return (v.arrayValue.values ?? []).map(fsToJs);\n if (\"mapValue\" in v) {\n const out: any = {};\n for (const [k, val] of Object.entries(v.mapValue.fields ?? {})) {\n out[k] = fsToJs(val);\n }\n return out;\n }\n return null;\n}\n\nfunction fsDocToObj(doc: any): any {\n const out: any = { _id: doc.name.split(\"/\").pop(), _path: doc.name };\n for (const [k, v] of Object.entries(doc.fields ?? {})) out[k] = fsToJs(v);\n return out;\n}\n\n// ── Firestore REST ──────────────────────────────────────────────────────────\n\nconst FS_BASE =\n `https://firestore.googleapis.com/v1/projects/${FIREBASE_PROJECT_ID}/databases/(default)/documents`;\n\nasync function fsGet(token: string, path: string): Promise {\n const resp = await fetch(`${FS_BASE}/${path}`, {\n headers: { Authorization: `Bearer ${token}` },\n });\n if (resp.status === 404) return null;\n if (!resp.ok) {\n throw new Error(`fsGet ${path}: ${resp.status} ${await resp.text()}`);\n }\n return fsDocToObj(await resp.json());\n}\n\ntype Filter =\n | { fieldFilter: { field: { fieldPath: string }; op: string; value: any } }\n | { compositeFilter: { op: \"AND\"; filters: Filter[] } };\n\nasync function fsRunQuery(\n token: string,\n parent: string | null, // path della collection padre, o null per root\n collectionId: string,\n allDescendants: boolean,\n filter: Filter | null,\n): Promise {\n const url = parent ? `${FS_BASE}/${parent}:runQuery` : `${FS_BASE}:runQuery`;\n const query: any = {\n structuredQuery: {\n from: [{ collectionId, allDescendants }],\n },\n };\n if (filter) query.structuredQuery.where = filter;\n const resp = await fetch(url, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(query),\n });\n if (!resp.ok) {\n throw new Error(\n `fsRunQuery ${collectionId}: ${resp.status} ${await resp.text()}`,\n );\n }\n const results = await resp.json();\n const docs: any[] = [];\n for (const r of results) {\n if (r.document) docs.push(fsDocToObj(r.document));\n }\n return docs;\n}\n\n// PATCH con updateMask — aggiorna solo i field elencati, altri preservati\nasync function fsPatch(\n token: string,\n path: string,\n fields: Record,\n deleteFields: string[] = [],\n): Promise {\n const maskFields = [...Object.keys(fields), ...deleteFields];\n const qs = maskFields.map((m) =>\n `updateMask.fieldPaths=${encodeURIComponent(m)}`\n ).join(\"&\");\n const body = { fields: {} as any };\n for (const [k, v] of Object.entries(fields)) body.fields[k] = fsFromJs(v);\n // deleteFields omessi dal body → cancellati dal doc per come funziona updateMask\n const resp = await fetch(`${FS_BASE}/${path}?${qs}`, {\n method: \"PATCH\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(body),\n });\n if (!resp.ok) {\n throw new Error(`fsPatch ${path}: ${resp.status} ${await resp.text()}`);\n }\n}\n\nasync function fsDelete(token: string, path: string): Promise {\n const resp = await fetch(`${FS_BASE}/${path}`, {\n method: \"DELETE\",\n headers: { Authorization: `Bearer ${token}` },\n });\n if (!resp.ok && resp.status !== 404) {\n throw new Error(`fsDelete ${path}: ${resp.status} ${await resp.text()}`);\n }\n}\n\n// arrayRemove via commit API con transforms\nasync function fsArrayRemove(\n token: string,\n path: string,\n field: string,\n values: string[],\n): Promise {\n if (values.length === 0) return;\n const body = {\n writes: [\n {\n transform: {\n document:\n `projects/${FIREBASE_PROJECT_ID}/databases/(default)/documents/${path}`,\n fieldTransforms: [\n {\n fieldPath: field,\n removeAllFromArray: {\n values: values.map((v) => ({ stringValue: v })),\n },\n },\n ],\n },\n },\n ],\n };\n const resp = await fetch(\n `https://firestore.googleapis.com/v1/projects/${FIREBASE_PROJECT_ID}/databases/(default)/documents:commit`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(body),\n },\n );\n if (!resp.ok) {\n throw new Error(\n `fsArrayRemove ${path}.${field}: ${resp.status} ${await resp.text()}`,\n );\n }\n}\n\n// ── FCM ─────────────────────────────────────────────────────────────────────\n\ninterface FcmSendResult {\n ok: boolean;\n invalidToken: boolean;\n}\n\nasync function fcmSend(\n token: string,\n registrationToken: string,\n title: string,\n body: string,\n noteId: string,\n kind: \"reminder\" | \"completion\" = \"reminder\",\n): Promise {\n const url =\n `https://fcm.googleapis.com/v1/projects/${FIREBASE_PROJECT_ID}/messages:send`;\n const message = {\n message: {\n token: registrationToken,\n webpush: {\n notification: {\n title,\n body,\n icon: \"/icons/icon-192x192.png\",\n tag: kind === \"completion\" ? `completion-${noteId}` : noteId,\n data: { noteId, kind },\n },\n data: { title, body, noteId, kind },\n },\n },\n };\n const resp = await fetch(url, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(message),\n });\n if (resp.ok) return { ok: true, invalidToken: false };\n const errText = await resp.text();\n const invalid = resp.status === 404 || resp.status === 400 ||\n errText.includes(\"UNREGISTERED\") || errText.includes(\"INVALID_ARGUMENT\");\n return { ok: false, invalidToken: invalid };\n}\n\n// ── Business logic ──────────────────────────────────────────────────────────\n\nfunction calculateNextReminder(\n currentTime: number,\n recurrence: string,\n): number {\n const d = new Date(currentTime);\n switch (recurrence) {\n case \"daily\":\n d.setDate(d.getDate() + 1);\n break;\n case \"weekly\":\n d.setDate(d.getDate() + 7);\n break;\n case \"monthly\":\n d.setMonth(d.getMonth() + 1);\n break;\n case \"yearly\":\n d.setFullYear(d.getFullYear() + 1);\n break;\n }\n return d.getTime();\n}\n\nconst PGP_MARKER = \"-----BEGIN PGP MESSAGE-----\";\nconst isEncrypted = (val: any) =>\n typeof val === \"string\" && val.startsWith(PGP_MARKER);\n\nasync function loadUser(\n token: string,\n cache: Record<\n string,\n { tokens: string[]; notifTitleEnabled: boolean; language: string }\n >,\n uid: string,\n): Promise {\n if (cache[uid]) return;\n const userData = await fsGet(token, `users/${uid}`);\n cache[uid] = {\n tokens: userData?.fcmTokens ?? [],\n notifTitleEnabled: userData?.notifTitleEnabled === true,\n language: userData?.language ?? \"it\",\n };\n}\n\nasync function checkAndSendReminders(\n gcpToken: string,\n): Promise<{ sent: number; processed: number }> {\n const now = Date.now();\n\n // Query reminderStatus == 'pending'\n const pendingNotes = await fsRunQuery(gcpToken, null, \"notes\", false, {\n fieldFilter: {\n field: { fieldPath: \"reminderStatus\" },\n op: \"EQUAL\",\n value: { stringValue: \"pending\" },\n },\n });\n\n if (pendingNotes.length === 0) return { sent: 0, processed: 0 };\n\n // Snoozes attivi via collectionGroup\n const snoozeMap = new Map>();\n try {\n const snoozes = await fsRunQuery(gcpToken, null, \"reminderSnoozes\", true, {\n fieldFilter: {\n field: { fieldPath: \"snoozedUntil\" },\n op: \"GREATER_THAN\",\n value: { integerValue: String(now) },\n },\n });\n for (const s of snoozes) {\n // _path: projects/.../documents/notes/{noteId}/reminderSnoozes/{uid}\n const parts = s._path.split(\"/\");\n const noteIdx = parts.indexOf(\"notes\");\n const noteId = parts[noteIdx + 1];\n const uid = s._id;\n if (!snoozeMap.has(noteId)) snoozeMap.set(noteId, new Set());\n snoozeMap.get(noteId)!.add(uid);\n }\n } catch (e) {\n console.warn(\n \"[snooze] collectionGroup query failed, proceeding senza filter:\",\n (e as Error).message,\n );\n }\n\n const tokensCache: Record<\n string,\n { tokens: string[]; notifTitleEnabled: boolean; language: string }\n > = {};\n let sentCount = 0;\n let processed = 0;\n\n for (const note of pendingNotes) {\n const reminderMs = typeof note.reminderTime === \"number\"\n ? note.reminderTime\n : Number(note.reminderTime);\n if (!reminderMs || reminderMs > now) continue;\n processed++;\n\n const noteId = note._id;\n const ownerUid = note.uid;\n const snoozedUids = snoozeMap.get(noteId) ?? new Set();\n\n await loadUser(gcpToken, tokensCache, ownerUid);\n\n // Collaborators con editReminders:true (filtro lato client, REST non gestisce facilmente nested map filter)\n const collabUidTokenPairs: {\n uid: string;\n token: string;\n language: string;\n notifTitleEnabled: boolean;\n }[] = [];\n try {\n const collaborators = await fsRunQuery(\n gcpToken,\n `notes/${noteId}`,\n \"collaborators\",\n false,\n null,\n );\n for (const collab of collaborators) {\n const perms = collab.permissions ?? {};\n if (perms.editReminders !== true) continue;\n const collabUid = collab._id;\n if (snoozedUids.has(collabUid)) continue;\n await loadUser(gcpToken, tokensCache, collabUid);\n for (const t of tokensCache[collabUid].tokens) {\n collabUidTokenPairs.push({\n uid: collabUid,\n token: t,\n language: tokensCache[collabUid].language,\n notifTitleEnabled: tokensCache[collabUid].notifTitleEnabled,\n });\n }\n }\n } catch (e) {\n console.error(\n `[note ${noteId}] collab fetch failed:`,\n (e as Error).message,\n );\n }\n\n // Owner tokens se non snoozato\n const ownerPairs = snoozedUids.has(ownerUid)\n ? []\n : tokensCache[ownerUid].tokens.map((t) => ({\n uid: ownerUid,\n token: t,\n language: tokensCache[ownerUid].language,\n notifTitleEnabled: tokensCache[ownerUid].notifTitleEnabled,\n }));\n\n const allPairs = [...ownerPairs, ...collabUidTokenPairs];\n\n if (allPairs.length > 0) {\n const reminderDate = new Date(reminderMs).toLocaleString(\"it-IT\", {\n day: \"2-digit\",\n month: \"2-digit\",\n year: \"numeric\",\n hour: \"2-digit\",\n minute: \"2-digit\",\n timeZone: \"Europe/Rome\",\n });\n const rawTitle = note.title;\n\n // Invia un messaggio per destinatario (FCM v1 è 1:1, no multicast)\n const failedByUid: Record = {};\n const sends = allPairs.map(async (p) => {\n const strings = NOTIF_STRINGS[p.language] ?? NOTIF_STRINGS[\"it\"];\n const msgTitle =\n (p.notifTitleEnabled && rawTitle && !isEncrypted(rawTitle))\n ? rawTitle\n : strings.defaultTitle;\n const bodyText = strings.bodyWithDate(reminderDate);\n const result = await fcmSend(\n gcpToken,\n p.token,\n msgTitle,\n bodyText,\n noteId,\n \"reminder\",\n );\n if (!result.ok && result.invalidToken) {\n if (!failedByUid[p.uid]) failedByUid[p.uid] = [];\n failedByUid[p.uid].push(p.token);\n }\n return result.ok;\n });\n const results = await Promise.all(sends);\n if (results.some(Boolean)) sentCount++;\n\n // Cleanup token invalidi\n for (const [failUid, failTokens] of Object.entries(failedByUid)) {\n try {\n await fsArrayRemove(\n gcpToken,\n `users/${failUid}`,\n \"fcmTokens\",\n failTokens,\n );\n } catch (e) {\n console.error(\n `[cleanup] arrayRemove users/${failUid}:`,\n (e as Error).message,\n );\n }\n }\n }\n\n // Recurrence / sent transition\n const recurrence = note.recurrence ?? \"none\";\n const endDate = typeof note.recurrenceEndDate === \"number\"\n ? note.recurrenceEndDate\n : null;\n\n let updatedBlocks = note.blocks;\n if (Array.isArray(note.blocks)) {\n // Aggiorna reminder block se presente\n const nextTime = (recurrence !== \"none\")\n ? calculateNextReminder(reminderMs, recurrence)\n : null;\n const expired = nextTime !== null && endDate !== null &&\n nextTime > endDate;\n\n updatedBlocks = note.blocks.map((b: any) => {\n if (b.type !== \"reminder\") return b;\n if (recurrence === \"none\" || expired) return { ...b, status: \"sent\" };\n return { ...b, time: nextTime, status: \"pending\" };\n });\n }\n\n const patch: Record = { blocks: updatedBlocks };\n if (recurrence !== \"none\") {\n const nextTime = calculateNextReminder(reminderMs, recurrence);\n const expired = endDate !== null && nextTime > endDate;\n if (expired) {\n patch.reminderStatus = \"sent\";\n } else {\n patch.reminderStatus = \"pending\";\n patch.reminderTime = nextTime;\n }\n } else {\n patch.reminderStatus = \"sent\";\n }\n\n try {\n await fsPatch(gcpToken, `notes/${noteId}`, patch);\n } catch (e) {\n console.error(`[note ${noteId}] patch failed:`, (e as Error).message);\n }\n\n // Cleanup snoozes per questa istanza di reminder\n for (const snoozedUid of snoozedUids) {\n try {\n await fsDelete(\n gcpToken,\n `notes/${noteId}/reminderSnoozes/${snoozedUid}`,\n );\n } catch { /* best effort */ }\n }\n }\n\n return { sent: sentCount, processed };\n}\n\nasync function checkAndSendCompletions(\n gcpToken: string,\n): Promise<{ sent: number }> {\n const pending = await fsRunQuery(gcpToken, null, \"notes\", false, {\n fieldFilter: {\n field: { fieldPath: \"completionNotifyPending\" },\n op: \"EQUAL\",\n value: { booleanValue: true },\n },\n });\n\n if (pending.length === 0) return { sent: 0 };\n\n const userCache: Record = {};\n let sent = 0;\n\n for (const note of pending) {\n const noteId = note._id;\n const byUid: string = note.completionNotifyBy;\n const byName: string = note.completionNotifyByName || \"A collaborator\";\n const ownerUid: string = note.uid;\n const recipients = new Set([\n ownerUid,\n ...((note.collaboratorUids ?? []) as string[]),\n ]);\n recipients.delete(byUid);\n\n const sends: Promise[] = [];\n for (const uid of recipients) {\n if (!userCache[uid]) {\n const u = await fsGet(gcpToken, `users/${uid}`);\n userCache[uid] = {\n tokens: u?.fcmTokens ?? [],\n language: u?.language ?? \"it\",\n };\n }\n const strings = COMPLETION_STRINGS[userCache[uid].language] ??\n COMPLETION_STRINGS[\"it\"];\n for (const t of userCache[uid].tokens) {\n sends.push(\n fcmSend(\n gcpToken,\n t,\n strings.title,\n strings.body(byName),\n noteId,\n \"completion\",\n ),\n );\n }\n }\n await Promise.all(sends);\n if (sends.length > 0) sent++;\n\n // Reset flag\n try {\n await fsPatch(gcpToken, `notes/${noteId}`, {\n completionNotifyPending: false,\n }, [\n \"completionNotifyBy\",\n \"completionNotifyByName\",\n \"completionNotifyAt\",\n ]);\n } catch (e) {\n console.error(\n `[completion ${noteId}] reset failed:`,\n (e as Error).message,\n );\n }\n }\n\n return { sent };\n}\n\n// ── Scheduled entry point ──────────────────────────────────────────────────\n\nexport default async function () {\n const t0 = Date.now();\n console.log(`[${new Date().toISOString()}] scheduledReminders run`);\n try {\n const gcpToken = await getGcpAccessToken();\n const [rem, comp] = await Promise.all([\n checkAndSendReminders(gcpToken).catch((e) => {\n console.error(\"checkAndSendReminders error:\", e);\n return { sent: 0, processed: 0 };\n }),\n checkAndSendCompletions(gcpToken).catch((e) => {\n console.error(\"checkAndSendCompletions error:\", e);\n return { sent: 0 };\n }),\n ]);\n console.log(\n `done in ${\n Date.now() - t0\n }ms — reminders sent=${rem.sent} processed=${rem.processed}, ` +\n `completions sent=${comp.sent}`,\n );\n } catch (e) {\n console.error(\"scheduledReminders fatal:\", e);\n throw e;\n }\n}","deleted","label",[105],"permalink","https://www.val.town/x/jowood94/notifyCompletion/code/scheduled.ts","extension","actionData","errors"]