[{"_1":2,"_180":-5,"_181":-5},"loaderData",{"_3":4,"_92":93},"root",{"_5":6,"_35":36,"_65":66},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20,"_34":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","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","adff7c7aeabd218801703bcdcaac3a168cba1c7b","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","API_URL","https://api.val.town","clerkState",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":46,"_72":73,"_74":73,"_75":20,"_76":73,"_77":73,"_78":73,"_79":73,"_80":81,"_90":20,"_91":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",{"_82":20,"_19":20,"_83":73,"_84":85,"_86":73,"_87":46,"_88":20,"_89":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_94":95,"_96":97,"_98":99,"_100":101,"_153":154,"_177":178,"_179":-5},"handle","lightweight","name","stainlessTodoSweeper","path","backend/services/notion/databases.ts","project",{"_102":103,"_96":97,"_104":105,"_106":-5,"_107":20,"_108":109,"_110":-5,"_111":-5,"_12":112,"_113":114,"_115":116,"_117":-5,"_118":-5,"_119":32,"_14":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":130,"_133":134,"_136":137,"_152":20},"id","0e73aa44-eb39-11f0-ad09-42dde27851f2","createdAt",["D",1767729073647],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","449588c0-326d-11f0-a80c-0741f032ef73","pinnedFileId","019b94dd-0e2e-7454-ae2d-536264a931a8","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","65f1d616-c14b-419c-88a0-e2308cab925b","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_94":95,"_131":132},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/aa289d5e-22db-464f-ba88-7288e2183b00/square512","org",{"_94":95,"_135":132,"_12":112},"avatar","branch",{"_138":139,"_96":44,"_102":140,"_141":103,"_142":143,"_144":145,"_146":109,"_147":148,"_149":120,"_150":97,"_151":95},"version",10,"0e785760-eb39-11f0-ad09-42dde27851f2","projectId","forkedBranchId","1cb4d65c-b360-11f0-bc6f-0224a6c84d84","forkedBranchVersion",262,"forkedProjectPrivacy","forkedProjectId","1cb13b14-b360-11f0-bc6f-0224a6c84d84","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_102":155,"_96":156,"_157":158,"_159":160,"_161":140,"_162":163,"_164":116,"_104":165,"_138":166,"_167":168,"_169":170,"_171":20,"_172":-5,"_98":173},"885f0c34-ec94-11f0-9044-42dde27851f2","databases.ts","fileId","019b94dd-0e2e-7454-ae2c-b09cb878775f","parentId","019b94dd-0e2e-7454-ae2c-cb9faf52e4e7","branchId","branchVersion",7,"latest",["D",1767878313548],1,"fileType","script","content","import { notion } from \"./index.ts\";\nimport { TODOS_PROPERTIES, PROJECTS_PROPERTIES } from \"../../utils/notionConfig.ts\";\n\n/**\n * Query a Notion database\n */\nexport async function queryNotionDatabase(databaseId: string, filter?: any, sorts?: any) {\n try {\n const response = await notion.databases.query({\n database_id: databaseId,\n filter: filter,\n sorts: sorts\n });\n\n return {\n success: true,\n data: response.results,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to query Notion database'\n };\n }\n}\n\n/**\n * Get a database by ID\n */\nexport async function getNotionDatabase(databaseId: string) {\n try {\n const database = await notion.databases.retrieve({ database_id: databaseId });\n\n return {\n success: true,\n data: database,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to fetch Notion database'\n };\n }\n}\n\n/**\n * Get all page IDs from a database\n * Used to cache project IDs for matching against link_mentions\n *\n * @param databaseId - Notion database ID\n * @returns Object with success, pageIds array (normalized, no hyphens), and error\n */\nexport async function getProjectPageIds(databaseId: string): Promise<{\n success: boolean;\n pageIds: string[];\n error: string | null;\n}> {\n try {\n const pageIds: string[] = [];\n let hasMore = true;\n let startCursor: string | undefined = undefined;\n\n while (hasMore) {\n const response = await notion.databases.query({\n database_id: databaseId,\n page_size: 100,\n start_cursor: startCursor\n });\n\n // Extract and normalize page IDs (remove hyphens for consistent comparison)\n for (const page of response.results) {\n const normalizedId = page.id.replace(/-/g, '');\n pageIds.push(normalizedId);\n }\n\n hasMore = response.has_more;\n startCursor = response.next_cursor ?? undefined;\n }\n\n return {\n success: true,\n pageIds,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n pageIds: [],\n error: err.message || 'Failed to fetch project page IDs'\n };\n }\n}\n\n/**\n * Get projects with their names, client names, and date ranges\n * Used for AI fuzzy matching and date-based disambiguation\n *\n * @param databaseId - Projects database ID\n * @returns Object with success, projects array, and error\n */\nexport async function getProjectsWithDetails(databaseId: string): Promise<{\n success: boolean;\n projects: Array<{\n id: string;\n name: string;\n groupName: string | null;\n dateStart: string | null;\n dateEnd: string | null;\n lastEditedTime: string;\n }>;\n error: string | null;\n}> {\n try {\n const projects: Array<{\n id: string;\n name: string;\n groupName: string | null;\n dateStart: string | null;\n dateEnd: string | null;\n lastEditedTime: string;\n }> = [];\n\n // Cache group names to avoid redundant API calls\n const groupCache: Map = new Map();\n\n let hasMore = true;\n let startCursor: string | undefined = undefined;\n\n while (hasMore) {\n const response = await notion.databases.query({\n database_id: databaseId,\n page_size: 100,\n start_cursor: startCursor\n });\n\n for (const page of response.results) {\n const pageAny = page as any;\n const properties = pageAny.properties || {};\n\n // Extract project name from title property\n let projectName = 'Untitled';\n for (const [key, value] of Object.entries(properties)) {\n if ((value as any).type === 'title') {\n const titleArray = (value as any).title || [];\n projectName = titleArray.map((t: any) => t.plain_text || '').join('') || 'Untitled';\n break;\n }\n }\n\n // Extract group name from groupBy relation (with caching)\n let groupName: string | null = null;\n const groupByRelation = properties[PROJECTS_PROPERTIES.groupBy];\n\n if (groupByRelation?.type === 'relation' && groupByRelation.relation?.length > 0) {\n const groupPageId = groupByRelation.relation[0].id;\n\n // Check cache first\n if (groupCache.has(groupPageId)) {\n groupName = groupCache.get(groupPageId) || null;\n } else {\n // Fetch the related page to get its title\n try {\n const groupPage = await notion.pages.retrieve({ page_id: groupPageId });\n const groupProps = (groupPage as any).properties || {};\n\n for (const [key, value] of Object.entries(groupProps)) {\n if ((value as any).type === 'title') {\n const titleArray = (value as any).title || [];\n groupName = titleArray.map((t: any) => t.plain_text || '').join('') || null;\n break;\n }\n }\n\n // Cache the result\n groupCache.set(groupPageId, groupName);\n } catch (err) {\n // Cache the failure too to avoid retrying\n groupCache.set(groupPageId, null);\n }\n }\n }\n\n // Extract dates from configured properties\n let dateStart: string | null = null;\n let dateEnd: string | null = null;\n\n if (PROJECTS_PROPERTIES.dateStart === PROJECTS_PROPERTIES.dateEnd) {\n // Same property = date range, read .start and .end\n const dateRangeProp = properties[PROJECTS_PROPERTIES.dateStart];\n if (dateRangeProp?.type === 'date' && dateRangeProp.date) {\n dateStart = dateRangeProp.date.start || null;\n dateEnd = dateRangeProp.date.end || null;\n }\n } else {\n // Different properties = separate dates, read .start from each\n const startProp = properties[PROJECTS_PROPERTIES.dateStart];\n const endProp = properties[PROJECTS_PROPERTIES.dateEnd];\n if (startProp?.type === 'date' && startProp.date) {\n dateStart = startProp.date.start || null;\n }\n if (endProp?.type === 'date' && endProp.date) {\n dateEnd = endProp.date.start || null;\n }\n }\n\n projects.push({\n id: page.id.replace(/-/g, ''), // Normalize ID\n name: projectName,\n groupName,\n dateStart,\n dateEnd,\n lastEditedTime: pageAny.last_edited_time\n });\n }\n\n hasMore = response.has_more;\n startCursor = response.next_cursor ?? undefined;\n }\n\n return {\n success: true,\n projects,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n projects: [],\n error: err.message || 'Failed to fetch projects with details'\n };\n }\n}\n\n/**\n * Get property names from a database schema\n * Used by health check to validate property mappings\n *\n * @param databaseId - Notion database ID\n * @returns Object with success, property names array, and error\n */\nexport async function getDatabasePropertyNames(databaseId: string): Promise<{\n success: boolean;\n properties: string[];\n error: string | null;\n}> {\n try {\n const database = await notion.databases.retrieve({ database_id: databaseId });\n const props = (database as any).properties || {};\n\n // Extract property names, excluding buttons (not data, just action triggers)\n const properties: string[] = [];\n for (const [name, value] of Object.entries(props)) {\n const type = (value as any).type;\n if (type !== 'button') {\n properties.push(name);\n }\n }\n\n return {\n success: true,\n properties,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n properties: [],\n error: err.message || 'Failed to fetch database properties'\n };\n }\n}\n\n/**\n * Get all page IDs and names from a database\n * Used for fuzzy name matching in relation mapping\n *\n * @param databaseId - Notion database ID\n * @returns Object with success, array of {id, name}, and error\n */\nexport async function getDatabasePageNames(databaseId: string): Promise<{\n success: boolean;\n pages: Array<{ id: string; name: string }>;\n error: string | null;\n}> {\n try {\n const pages: Array<{ id: string; name: string }> = [];\n let hasMore = true;\n let startCursor: string | undefined = undefined;\n\n while (hasMore) {\n const response = await notion.databases.query({\n database_id: databaseId,\n start_cursor: startCursor,\n page_size: 100\n });\n\n for (const page of response.results) {\n // Extract page ID (normalized, no hyphens)\n const id = page.id.replace(/-/g, '');\n\n // Extract page title from properties\n const props = (page as any).properties || {};\n let name = 'Untitled';\n\n // Find the title property\n for (const [, value] of Object.entries(props)) {\n const propAny = value as any;\n if (propAny.type === 'title' && propAny.title) {\n name = propAny.title.map((t: any) => t.plain_text || '').join('') || 'Untitled';\n break;\n }\n }\n\n pages.push({ id, name });\n }\n\n hasMore = response.has_more;\n startCursor = response.next_cursor || undefined;\n }\n\n return {\n success: true,\n pages,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n pages: [],\n error: err.message || 'Failed to fetch database page names'\n };\n }\n}\n\n/**\n * Query database for a page with specific Block ID\n */\nexport async function queryDatabaseByBlockId(databaseId: string, blockId: string) {\n try {\n const filter = {\n property: TODOS_PROPERTIES.blockId,\n rich_text: {\n equals: blockId\n }\n };\n\n const response = await notion.databases.query({\n database_id: databaseId,\n filter: filter\n });\n\n // Return first matching page or null\n const page = response.results.length > 0 ? response.results[0] : null;\n\n return {\n success: true,\n data: page,\n error: null\n };\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to query database by Block ID'\n };\n }\n}\n\n/**\n * Status property info for checkbox sync\n */\nexport interface StatusPropertyInfo {\n type: 'status' | 'select' | 'checkbox';\n doneName?: string; // Option name to use for \"done\" (not needed for checkbox type)\n}\n\n/**\n * Get status property info from database schema\n * Used for syncing checkbox state to a status/select/checkbox property\n *\n * @param databaseId - Notion database ID\n * @param propertyName - Name of the status property\n * @returns Status property info or null if not found/unsupported\n */\nexport async function getStatusPropertyInfo(\n databaseId: string,\n propertyName: string\n): Promise<{\n success: boolean;\n data: StatusPropertyInfo | null;\n error: string | null;\n}> {\n try {\n const database = await notion.databases.retrieve({ database_id: databaseId });\n const props = (database as any).properties || {};\n const property = props[propertyName];\n\n if (!property) {\n return {\n success: false,\n data: null,\n error: `Property \"${propertyName}\" not found in database schema`\n };\n }\n\n const propType = property.type;\n\n // Checkbox type - no options needed\n if (propType === 'checkbox') {\n return {\n success: true,\n data: { type: 'checkbox' },\n error: null\n };\n }\n\n // Status or select type - find \"done\" option\n if (propType === 'status' || propType === 'select') {\n const options = property[propType]?.options || [];\n\n // Look for \"done\" option (case-insensitive)\n const donePatterns = ['done', 'complete', 'completed', 'finished'];\n\n for (const option of options) {\n const optionNameLower = (option.name || '').toLowerCase();\n if (donePatterns.includes(optionNameLower)) {\n return {\n success: true,\n data: {\n type: propType,\n doneName: option.name\n },\n error: null\n };\n }\n }\n\n // No \"done\" option found\n const availableOptions = options.map((o: any) => o.name).join(', ');\n return {\n success: false,\n data: null,\n error: `No \"done\" option found in \"${propertyName}\". Available: ${availableOptions}`\n };\n }\n\n // Unsupported property type\n return {\n success: false,\n data: null,\n error: `Property \"${propertyName}\" has unsupported type: ${propType}`\n };\n\n } catch (err: any) {\n return {\n success: false,\n data: null,\n error: err.message || 'Failed to get status property info'\n };\n }\n}\n","deleted","label",[174,175,176,156],"backend","services","notion","permalink","https://www.val.town/x/lightweight/stainlessTodoSweeper/code/backend/services/notion/databases.ts","extension","actionData","errors"]