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(); // теперь идёт через авто-рефреш\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 { headers: { \"Content-Type\": \"text/html; charset=utf-8\" } },\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 { headers: { \"Content-Type\": \"application/json; charset=utf-8\" } },\n );\n } catch (e: any) {\n return new Response(\"Error: \" + (e?.message ?? String(e)), { status: 500 });\n }\n}","deleted","label",[98],"permalink","https://www.val.town/x/rdnvsk/System/code/SyncNotionToGCal.tsx","extension","actionData","errors"]