Notion ↔︎ Google Calendar — Report

Mode
diag=${d.mode.diag ? \"on\" : \"off\"}, dry=${\n d.mode.dry ? \"on\" : \"off\"\n }

Google token
${\n d.checks.google_token_ok ? badge(\"OK\", \"ok\") : badge(\"FAIL\", \"err\")\n }

Notion pages
${esc(d.checks.notion_pages)}

\n\n

Environment

NOTION_TOKEN
${\n d.checks.env.HAS_NOTION_TOKEN\n ? badge(\"set\", \"ok\")\n : badge(\"missing\", \"err\")\n }

NOTION_DB_ID
${\n d.checks.env.HAS_DB ? badge(\"set\", \"ok\") : badge(\"missing\", \"err\")\n }

GOOGLE_CLIENT_ID
${\n d.checks.env.HAS_GOOGLE_ID ? badge(\"set\", \"ok\") : badge(\"missing\", \"err\")\n }

GOOGLE_CLIENT_SECRET
${\n d.checks.env.HAS_GOOGLE_SECRET\n ? badge(\"set\", \"ok\")\n : badge(\"missing\", \"err\")\n }

GOOGLE_REFRESH_TOKEN
${\n d.checks.env.HAS_REFRESH ? badge(\"set\", \"ok\") : badge(\"missing\", \"err\")\n }

\n\n

Actions

\n \n \n ${\n rowsA || ``\n }\n

#	Notion ID	Action	EventID	Details
No actions

\n\n

Results

\n \n \n ${\n rowsR || ``\n }\n

#	Notion ID	Status	EventID	Link	Error
No results

\n`;\n }\n\n // ---------- RUN ----------\n const diag: any = {\n mode: { diag: DIAG, dry: DRY },\n checks: {},\n actions: [],\n results: [],\n };\n\n try {\n // preflight\n diag.checks.env = {\n HAS_NOTION_TOKEN: !!NOTION_TOKEN,\n HAS_DB: !!NOTION_DB_ID,\n HAS_GOOGLE_ID: !!GOOGLE_CLIENT_ID,\n HAS_GOOGLE_SECRET: !!GOOGLE_CLIENT_SECRET,\n HAS_REFRESH: !!GOOGLE_REFRESH_TOKEN,\n };\n\n const accessToken = await googleAccessToken(); // валидность refresh токена\n diag.checks.google_token_ok = true;\n\n const pages = await notionQueryAll();\n diag.checks.notion_pages = pages.length;\n\n const pageById = new Map(pages.map((p) => [p.id, p] as const));\n\n // дубликаты EventID в Notion — очищаем у всех, кроме самого свежего\n const byEventId = new Map();\n for (const p of pages) {\n const evId = pEventId(p);\n if (evId) {\n (byEventId.get(evId) ?? byEventId.set(evId, []).get(evId)!).push(p);\n }\n }\n for (const [evId, arr] of byEventId) {\n if (arr.length > 1) {\n const keep = [...arr].sort((a, b) =>\n Date.parse(b.last_edited_time) - Date.parse(a.last_edited_time)\n )[0];\n for (const p of arr) {\n if (p.id !== keep.id) {\n diag.actions.push({\n id: p.id,\n fix: \"duplicate_eventId_cleared\",\n eventId: evId,\n });\n await notionSetEventId(p.id, null);\n }\n }\n }\n }\n\n // cleanup Google → Notion\n const gEvents = await listAllNotionSourceEvents(accessToken);\n for (const ev of gEvents) {\n const notionId = ev?.extendedProperties?.private?.notionId as\n | string\n | undefined;\n if (!notionId) continue;\n\n let np = pageById.get(notionId);\n if (!np) {\n const pg = await notionGetPage(notionId);\n if ((pg as any).notFound) {\n diag.actions.push({\n id: notionId,\n cleanup: \"notion_deleted\",\n gEvent: ev.id,\n });\n await gcalDelete(accessToken, ev.id);\n continue;\n }\n np = pg;\n }\n\n const archived = (np as any).archived === true;\n const doneNow = pDone(np);\n const hasDate = !!pDate(np)?.start;\n\n if (archived || doneNow || !hasDate) {\n diag.actions.push({\n id: notionId,\n cleanup: archived ? \"archived\" : doneNow ? \"done\" : \"no-date\",\n gEvent: ev.id,\n });\n await gcalDelete(accessToken, ev.id);\n await notionSetEventId(notionId, null);\n }\n }\n\n // основной синк Notion → Google\n for (const p of pages) {\n try {\n const date = pDate(p);\n if (!date?.start) {\n diag.results.push({ id: p.id, skip: \"no-date\" });\n continue;\n }\n\n if (pDone(p)) {\n const curId = pEventId(p);\n if (curId) {\n diag.actions.push({\n id: p.id,\n action: \"delete_by_done\",\n eventId: curId,\n });\n await gcalDelete(accessToken, curId);\n await notionSetEventId(p.id, null);\n }\n diag.results.push({ id: p.id, status: \"done\" });\n continue;\n }\n\n const ev = await gcalUpsert(accessToken, p, pEventId(p), diag.actions);\n const newId = ev.id as string | undefined;\n if (newId && newId !== pEventId(p)) {\n diag.actions.push({\n id: p.id,\n action: \"set_eventId\",\n eventId: newId,\n });\n await notionSetEventId(p.id, newId);\n }\n\n diag.results.push({\n id: p.id,\n upserted: true,\n eventId: newId ?? pEventId(p),\n link: ev.htmlLink ?? undefined,\n });\n } catch (e: any) {\n diag.results.push({ id: p.id, error: e?.message ?? String(e) });\n }\n }\n\n if (REPORT) {\n return new Response(\n renderReport({ ...diag, mode: { ...diag.mode, report: true } }),\n {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n },\n );\n }\n if (DIAG) {\n return new Response(JSON.stringify(diag, null, 2), {\n headers: { \"Content-Type\": \"application/json; charset=utf-8\" },\n });\n }\n return new Response(\n JSON.stringify(\n {\n ok: true,\n count: diag.checks.notion_pages,\n actions: diag.actions,\n results: diag.results,\n },\n null,\n 2,\n ),\n {\n headers: { \"Content-Type\": \"application/json; charset=utf-8\" },\n },\n );\n } catch (e: any) {\n return new Response(\"Error: \" + (e?.message ?? String(e)), { status: 500 });\n }\n}",[],[150,170],{"_102":180,"_95":181,"_151":182,"_153":152,"_154":136,"_155":183,"_157":158,"_104":184,"_99":185,"_161":175,"_163":186,"_164":22,"_165":-5,"_166":187,"_98":188},"bd528016-83b6-11f0-b928-0224a6c84d84","SyncScheduler1.tsx","478cea0e-758f-11f0-b8a0-0224a6c84d84",89,["D",1756348133196],9,"export default async function (_i: Interval) {\n const url = \"https://rdnvsk--233524c6758c11f0be170224a6c84d84.web.val.run\"; // вставь точный адрес из Get link\n const res = await fetch(url, { method: \"GET\" });\n const body = await res.text();\n console.log(\"SyncNotionToGCal:\", res.status, body.slice(0, 200));\n return new Response(`Triggered: ${res.status}`);\n}",[],[150,181],{"_102":190,"_95":191,"_151":192,"_153":152,"_154":136,"_155":193,"_157":158,"_104":194,"_99":185,"_161":175,"_163":195,"_164":22,"_165":-5,"_166":196,"_98":197},"be8ba3ae-83b6-11f0-b40b-0224a6c84d84","gcal_cb.tsx","6d145dd8-7581-11f0-955f-0224a6c84d84",90,["D",1756348135250],"export default async function (req: Request): Promise {\n const code = new URL(req.url).searchParams.get(\"code\");\n if (!code) return new Response(\"Missing ?code\", { status: 400 });\n\n const client_id = Deno.env.get(\"GOOGLE_CLIENT_ID\")!;\n const client_secret = Deno.env.get(\"GOOGLE_CLIENT_SECRET\")!;\n const redirect_uri = Deno.env.get(\"GCAL_REDIRECT_URI\")!;\n\n const res = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n code,\n client_id,\n client_secret,\n redirect_uri,\n grant_type: \"authorization_code\",\n }),\n });\n\n const json = await res.json();\n if (!res.ok) {\n return new Response(\"Token error:\\n\" + JSON.stringify(json, null, 2), {\n status: 500,\n });\n }\n\n return new Response(\"REFRESH_TOKEN=\" + json.refresh_token, {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n}",[],[150,191],{"_102":199,"_95":200,"_151":201,"_153":152,"_154":136,"_155":202,"_157":158,"_104":203,"_99":185,"_161":175,"_163":204,"_164":22,"_165":-5,"_166":205,"_98":206},"bfbb4f4a-83b6-11f0-995b-0224a6c84d84","gcal_start.tsx","3a1b7218-7581-11f0-a3c2-0224a6c84d84",91,["D",1756348137236],"export default async function (req: Request): Promise {\n const cid = Deno.env.get(\"GOOGLE_CLIENT_ID\")!;\n const redirect_uri = Deno.env.get(\"GCAL_REDIRECT_URI\")!; // хеш-URL gcal_cb\n\n const scope = [\n \"https://www.googleapis.com/auth/calendar\",\n \"https://www.googleapis.com/auth/calendar.events\",\n ].join(\" \");\n\n const params = new URLSearchParams({\n client_id: cid,\n redirect_uri,\n response_type: \"code\",\n access_type: \"offline\",\n prompt: \"consent\",\n include_granted_scopes: \"true\",\n scope,\n });\n\n const url = \"https://accounts.google.com/o/oauth2/v2/auth?\" +\n params.toString();\n return new Response(`Continue with Google`, {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n}",[],[150,200],[150],{"_102":209,"_95":210,"_151":211,"_153":-5,"_154":136,"_155":212,"_157":158,"_104":213,"_99":214,"_161":215,"_163":216,"_164":22,"_165":-5,"_166":217,"_98":218},"a05e266a-8f2b-11f0-8bcc-0224a6c84d84","SyncNotionToGCal.tsx","233524c6-758c-11f0-be17-0224a6c84d84",104,["D",1757607798524],27,"http","// Notion ↔ Google Calendar sync\n// — upsert с самовосстановлением связи\n// — корректное переключение типа события (all-day ↔ timed) через PUT\n// — очистка при Done/удалении даты/архиве\n// — защита от копий (одинаковый EventID на разных страницах)\n// — fallback-поиск по названию+дате\n// — HTML-отчёт (?report=1), JSON-диагностика (?diag=1), dry-run (?dry=1)\n\nimport { getAccessToken } from \"./googleAuth.ts\"; // 👈 авто-рефреш токена\n\nexport default async function (req: Request): Promise {\n // ==== MODES ====\n const url = new URL(req.url);\n const DIAG = url.searchParams.get(\"diag\") === \"1\";\n const REPORT = url.searchParams.get(\"report\") === \"1\";\n const DRY = url.searchParams.get(\"dry\") === \"1\";\n\n // ==== ENV ====\n const NOTION_TOKEN = Deno.env.get(\"NOTION_TOKEN\")!;\n const NOTION_DB_ID = Deno.env.get(\"NOTION_DB_ID\")!;\n // ВАЖНО: версию API берём ТОЛЬКО из ENV (без дефолта).\n // В Val Town поставь: NOTION_VERSION=2025-09-03\n const NOTION_VERSION = Deno.env.get(\"NOTION_VERSION\")!;\n\n // ниже переменные оставляем ради диагностики (REPORT/DIAG)\n const GOOGLE_CLIENT_ID = Deno.env.get(\"GOOGLE_CLIENT_ID\")!;\n const GOOGLE_CLIENT_SECRET = Deno.env.get(\"GOOGLE_CLIENT_SECRET\")!;\n const GOOGLE_REFRESH_TOKEN = Deno.env.get(\"GOOGLE_REFRESH_TOKEN\")!;\n\n // ==== Notion property names ====\n const DATE_PROP = \"Date\";\n const TITLE_PROP = \"Name\";\n const DESC_PROP = \"Notic\";\n const DONE_PROP = \"Done\";\n const EVENTID_PROP = \"EventID\";\n\n // ---------- Notion helpers ----------\n async function notionQueryAll(): Promise {\n const out: any[] = [];\n let cursor: string | undefined;\n while (true) {\n const r = await fetch(\n `https://api.notion.com/v1/databases/${NOTION_DB_ID}/query`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${NOTION_TOKEN}`,\n \"Notion-Version\": NOTION_VERSION,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n start_cursor: cursor,\n page_size: 100,\n filter: { property: DATE_PROP, date: { is_not_empty: true } },\n sorts: [{ property: DATE_PROP, direction: \"ascending\" }],\n }),\n },\n );\n const j = await r.json();\n if (!r.ok) {\n throw new Error(`Notion query error ${r.status}: ${JSON.stringify(j)}`);\n }\n out.push(...(j.results ?? []));\n if (!j.has_more) break;\n cursor = j.next_cursor;\n }\n return out;\n }\n\n async function notionGetPage(pageId: string) {\n const r = await fetch(`https://api.notion.com/v1/pages/${pageId}`, {\n headers: {\n Authorization: `Bearer ${NOTION_TOKEN}`,\n \"Notion-Version\": NOTION_VERSION,\n },\n });\n if (r.status === 404) return { notFound: true } as const;\n const j = await r.json();\n if (!r.ok) {\n throw new Error(`Notion get page ${r.status}: ${JSON.stringify(j)}`);\n }\n return j as any;\n }\n\n function pTitle(p: any): string {\n try {\n return (p.properties[TITLE_PROP].title as any[]).map((t: any) =>\n t.plain_text\n ).join(\"\").trim() || \"Untitled\";\n } catch {\n return \"Untitled\";\n }\n }\n\n function pDesc(p: any): string {\n try {\n const pr = p.properties[DESC_PROP];\n if (!pr) return \"\";\n if (pr.type === \"rich_text\") {\n return (pr.rich_text as any[]).map((t: any) => t.plain_text).join(\"\")\n .trim();\n }\n if (pr.type === \"title\") {\n return (pr.title as any[]).map((t: any) => t.plain_text).join(\"\")\n .trim();\n }\n return \"\";\n } catch {\n return \"\";\n }\n }\n\n function pDate(\n p: any,\n ): { start: string; end?: string | null; time_zone?: string | null } | null {\n try {\n return p.properties[DATE_PROP].date ?? null;\n } catch {\n return null;\n }\n }\n\n function pDone(p: any): boolean {\n try {\n return !!p.properties[DONE_PROP]?.checkbox;\n } catch {\n return false;\n }\n }\n\n function pEventId(p: any): string | null {\n try {\n const prop = p.properties[EVENTID_PROP];\n if (!prop) return null;\n if (prop.type === \"rich_text\") {\n const txt = (prop.rich_text as any[]).map((t: any) => t.plain_text)\n .join(\"\").trim();\n return txt || null;\n }\n if (prop.type === \"title\") {\n const txt = (prop.title as any[]).map((t: any) => t.plain_text).join(\"\")\n .trim();\n return txt || null;\n }\n if ((prop as any).type === \"text\" && (prop as any).text) {\n const txt = ((prop as any).text as any[]).map((t: any) =>\n t.plain_text ?? \"\"\n ).join(\"\").trim();\n return txt || null;\n }\n return null;\n } catch {\n return null;\n }\n }\n\n function notionUrl(p: any) {\n return p.url as string;\n }\n\n async function notionSetEventId(pageId: string, eventId: string | null) {\n if (DRY) return;\n await fetch(`https://api.notion.com/v1/pages/${pageId}`, {\n method: \"PATCH\",\n headers: {\n Authorization: `Bearer ${NOTION_TOKEN}`,\n \"Notion-Version\": NOTION_VERSION,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n properties: {\n [EVENTID_PROP]: {\n rich_text: eventId\n ? [{ type: \"text\", text: { content: eventId } }]\n : [],\n },\n },\n }),\n }).catch(() => {});\n }\n\n // ---------- Google helpers ----------\n async function googleAccessToken(): Promise {\n return await getAccessToken();\n }\n\n function mapDate(\n d: { start: string; end?: string | null; time_zone?: string | null },\n ) {\n const hasTime = d.start.includes(\"T\");\n if (!hasTime) {\n const startDate = d.start.slice(0, 10);\n const endDate =\n (d.end ?? new Date(Date.parse(d.start) + 86400000).toISOString()).slice(\n 0,\n 10,\n );\n return { allDay: true as const, startDate, endDate };\n }\n const endIso = d.end ??\n new Date(Date.parse(d.start) + 3600000).toISOString();\n return {\n allDay: false as const,\n startDateTime: d.start,\n endDateTime: endIso,\n tz: d.time_zone ?? undefined,\n };\n }\n\n async function gcalDelete(accessToken: string, eventId: string) {\n if (DRY) return;\n const r = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/primary/events/${\n encodeURIComponent(eventId)\n }`,\n { method: \"DELETE\", headers: { Authorization: `Bearer ${accessToken}` } },\n );\n if (![200, 204, 404, 410].includes(r.status)) {\n const t = await r.text();\n throw new Error(`Google delete error ${r.status}: ${t}`);\n }\n }\n\n async function gcalGet(accessToken: string, eventId: string) {\n const r = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/primary/events/${\n encodeURIComponent(eventId)\n }`,\n { headers: { Authorization: `Bearer ${accessToken}` } },\n );\n if (r.status === 404 || r.status === 410) return null;\n const j = await r.json();\n if (!r.ok) {\n throw new Error(`Google get error ${r.status}: ${JSON.stringify(j)}`);\n }\n return j;\n }\n\n async function gcalFindByTitleAndDay(\n accessToken: string,\n summary: string,\n dayISO: string,\n ) {\n const timeMin = new Date(dayISO + \"T00:00:00.000Z\").toISOString();\n const timeMax = new Date(dayISO + \"T23:59:59.999Z\").toISOString();\n const u = new URL(\n \"https://www.googleapis.com/calendar/v3/calendars/primary/events\",\n );\n u.searchParams.set(\"singleEvents\", \"true\");\n u.searchParams.set(\"maxResults\", \"50\");\n u.searchParams.set(\"timeMin\", timeMin);\n u.searchParams.set(\"timeMax\", timeMax);\n const r = await fetch(u.toString(), {\n headers: { Authorization: `Bearer ${accessToken}` },\n });\n const j = await r.json();\n if (!r.ok) {\n throw new Error(`Google search error ${r.status}: ${JSON.stringify(j)}`);\n }\n const items: any[] = (j.items ?? []).filter((it) =>\n (it.summary ?? \"\").trim() === summary.trim()\n );\n return items.length === 1 ? items[0] : null;\n }\n\n // ---------- Upsert с учётом flip типа ----------\n async function gcalUpsert(\n accessToken: string,\n page: any,\n existingEventId: string | null,\n actions: any[],\n ) {\n const title = pTitle(page);\n const desc = pDesc(page);\n const date = pDate(page)!;\n const mapped = mapDate(date);\n const description = [desc, notionUrl(page)].filter(Boolean).join(\"\\n\\n\");\n\n const base: any = {\n summary: title,\n description,\n source: { title: \"Notion Page\", url: notionUrl(page) },\n extendedProperties: { private: { notionId: page.id, source: \"notion\" } },\n };\n if (mapped.allDay) {\n base.start = { date: mapped.startDate };\n base.end = { date: mapped.endDate || mapped.startDate };\n } else {\n base.start = { dateTime: mapped.startDateTime, timeZone: mapped.tz };\n base.end = { dateTime: mapped.endDateTime, timeZone: mapped.tz };\n }\n\n // A) проверка существующего ивента (копии/битый id)\n let cur: any | null = null;\n if (existingEventId) {\n cur = await gcalGet(accessToken, existingEventId).catch(() => null);\n if (cur) {\n const curNotionId = cur?.extendedProperties?.private?.notionId as\n | string\n | undefined;\n if (curNotionId && curNotionId !== page.id) {\n actions.push({\n id: page.id,\n fix: \"copied_eventId_removed\",\n eventId: existingEventId,\n });\n await notionSetEventId(page.id, null);\n existingEventId = null;\n cur = null;\n }\n } else {\n actions.push({\n id: page.id,\n fix: \"broken_eventId_removed\",\n eventId: existingEventId,\n });\n await notionSetEventId(page.id, null);\n existingEventId = null;\n }\n }\n\n // B) PATCH/PUT (если id ещё валиден)\n if (existingEventId && cur) {\n const wantAllDay = mapped.allDay;\n const haveAllDay = !!cur?.start?.date && !cur?.start?.dateTime;\n const method: \"PATCH\" | \"PUT\" = (wantAllDay !== haveAllDay)\n ? \"PUT\"\n : \"PATCH\";\n\n actions.push({\n id: page.id,\n action: method === \"PUT\" ? \"update(put_type_flip)\" : \"patch\",\n eventId: existingEventId,\n });\n\n if (!DRY) {\n const endpoint =\n `https://www.googleapis.com/calendar/v3/calendars/primary/events/${\n encodeURIComponent(existingEventId)\n }`;\n const resp = await fetch(endpoint, {\n method,\n headers: {\n Authorization: `Bearer ${accessToken}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(base),\n });\n if (resp.ok) return await resp.json();\n if (![404, 410, 403].includes(resp.status)) {\n const txt = await resp.text().catch(() => \"\");\n throw new Error(`Google ${method} error ${resp.status}: ${txt}`);\n }\n }\n existingEventId = null; // если не получилось — пойдём ниже по восстановлению\n }\n\n // C) поиск по notionId\n {\n const find = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/primary/events?privateExtendedProperty=${\n encodeURIComponent(\"notionId=\" + page.id)\n }`,\n { headers: { Authorization: `Bearer ${accessToken}` } },\n );\n if (!find.ok) {\n throw new Error(\n `Google list error ${find.status}: ${await find.text().catch(() =>\n \"\"\n )}`,\n );\n }\n const list = await find.json();\n const found = (list.items ?? [])[0];\n if (found?.id) {\n actions.push({\n id: page.id,\n action: \"patch(found)\",\n eventId: found.id,\n });\n if (!DRY) {\n const r = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/primary/events/${\n encodeURIComponent(found.id)\n }`,\n {\n method: \"PATCH\",\n headers: {\n Authorization: `Bearer ${accessToken}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(base),\n },\n );\n const j = await r.json();\n if (!r.ok) {\n throw new Error(\n `Google update(found) ${r.status}: ${JSON.stringify(j)}`,\n );\n }\n return j;\n }\n }\n }\n\n // D) fallback: название + день\n {\n const dayISO = mapped.allDay\n ? mapped.startDate\n : mapped.startDateTime.slice(0, 10);\n const guess = await gcalFindByTitleAndDay(accessToken, title, dayISO);\n if (guess) {\n const mergeBase = {\n ...base,\n extendedProperties: {\n private: {\n ...(guess.extendedProperties?.private ?? {}),\n notionId: page.id,\n source: \"notion\",\n },\n },\n };\n actions.push({\n id: page.id,\n action: \"attach(fallback)\",\n attachTo: guess.id,\n });\n if (!DRY) {\n const r = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/primary/events/${\n encodeURIComponent(guess.id)\n }`,\n {\n method: \"PATCH\",\n headers: {\n Authorization: `Bearer ${accessToken}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(mergeBase),\n },\n );\n const j = await r.json();\n if (!r.ok) {\n throw new Error(\n `Google attach error ${r.status}: ${JSON.stringify(j)}`,\n );\n }\n return j;\n }\n }\n }\n\n // E) INSERT\n actions.push({ id: page.id, action: \"insert\" });\n if (DRY) return { id: \"dry-insert\", htmlLink: \"\", ...base };\n const ins = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/primary/events`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${accessToken}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(base),\n },\n );\n const j = await ins.json();\n if (!ins.ok) {\n throw new Error(\n `Google insert error ${ins.status}: ${JSON.stringify(j)}`,\n );\n }\n return j;\n }\n\n async function listAllNotionSourceEvents(accessToken: string) {\n const items: any[] = [];\n let pageToken: string | undefined;\n do {\n const u = new URL(\n `https://www.googleapis.com/calendar/v3/calendars/primary/events`,\n );\n u.searchParams.set(\"privateExtendedProperty\", \"source=notion\");\n u.searchParams.set(\"maxResults\", \"2500\");\n u.searchParams.set(\"singleEvents\", \"true\");\n if (pageToken) u.searchParams.set(\"pageToken\", pageToken);\n const r = await fetch(u.toString(), {\n headers: { Authorization: `Bearer ${accessToken}` },\n });\n const j = await r.json();\n if (!r.ok) {\n throw new Error(`Google list(all) ${r.status}: ${JSON.stringify(j)}`);\n }\n items.push(...(j.items ?? []));\n pageToken = j.nextPageToken;\n } while (pageToken);\n return items;\n }\n\n // ---------- HTML helpers ----------\n const esc = (s: any) =>\n String(s ?? \"\")\n .replace(/&/g, \"&\").replace(//g, \">\")\n .replace(/\"/g, \""\").replace(/'/g, \"'\");\n\n const badge = (t: string, kind: \"ok\" | \"warn\" | \"err\" | \"mut\") => {\n const c = kind === \"ok\"\n ? \"#16a34a\"\n : kind === \"warn\"\n ? \"#ca8a04\"\n : kind === \"err\"\n ? \"#dc2626\"\n : \"#64748b\";\n return `${\n esc(t)\n }`;\n };\n\n function renderReport(d: any) {\n const rowsA = d.actions.map((a: any, i: number) =>\n `\n ${i + 1}\n ${esc(a.id)}\n ${\n a.cleanup\n ? badge(a.cleanup, \"mut\")\n : a.fix\n ? badge(a.fix, \"warn\")\n : a.action\n ? badge(a.action, \"ok\")\n : badge(\"note\", \"mut\")\n }\n ${a.eventId ? `${esc(a.eventId)}` : \"\"}\n ${a.attachTo ? `→ ${esc(a.attachTo)}` : \"\"}\n `\n ).join(\"\");\n\n const rowsR = d.results.map((r: any, i: number) =>\n `\n ${i + 1}\n ${esc(r.id)}\n ${\n r.error\n ? badge(\"error\", \"err\")\n : r.upserted\n ? badge(\"upserted\", \"ok\")\n : badge(esc(r.status ?? \"info\"), \"mut\")\n }\n ${r.eventId ? `${esc(r.eventId)}` : \"\"}\n ${\n r.link ? `open` : \"\"\n }\n ${r.error ? esc(r.error) : \"\"}\n `\n ).join(\"\");\n\n return `\n\nNotion ↔︎ Google Calendar Report\n\n\n

Notion ↔︎ Google Calendar — Report

Mode
diag=${d.mode.diag ? \"on\" : \"off\"}, dry=${\n d.mode.dry ? \"on\" : \"off\"\n }

Google token
${\n d.checks.google_token_ok ? badge(\"OK\", \"ok\") : badge(\"FAIL\", \"err\")\n }

Notion pages
${esc(d.checks.notion_pages)}

\n\n

Environment

NOTION_TOKEN
${\n d.checks.env.HAS_NOTION_TOKEN\n ? badge(\"set\", \"ok\")\n : badge(\"missing\", \"err\")\n }

NOTION_DB_ID
${\n d.checks.env.HAS_DB ? badge(\"set\", \"ok\") : badge(\"missing\", \"err\")\n }

GOOGLE_CLIENT_ID
${\n d.checks.env.HAS_GOOGLE_ID ? badge(\"set\", \"ok\") : badge(\"missing\", \"err\")\n }

GOOGLE_CLIENT_SECRET
${\n d.checks.env.HAS_GOOGLE_SECRET\n ? badge(\"set\", \"ok\")\n : badge(\"missing\", \"err\")\n }

GOOGLE_REFRESH_TOKEN
${\n d.checks.env.HAS_REFRESH ? badge(\"set\", \"ok\") : badge(\"missing\", \"err\")\n }

\n\n

Actions

\n \n \n ${\n rowsA || ``\n }\n

#	Notion ID	Action	EventID	Details
No actions

\n\n

Results

\n \n \n ${\n rowsR || ``\n }\n

#	Notion ID	Status	EventID	Link	Error
No results

Environment variables