[{"_1":2,"_760":-5,"_761":-5},"loaderData",{"_3":4,"_96":97,"_545":546,"_759":-5},"root",{"_5":6,"_33":34,"_65":66},"ctx",{"_7":8,"_19":20,"_21":-5,"_22":23,"_24":25,"_26":27,"_28":27,"_29":27,"_30":31,"_32":27},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","environmentVariableKeys",[],"user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers",false,"preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_35":36,"_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","5beacca5973a0e52781e0b9acd2cb00f05badfe7","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","WORKER_FINGERPRINT","963e45ace5b0a45db0aea6fd292ac66b","clerkState",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":44,"_72":73,"_74":73,"_75":27,"_76":73,"_77":73,"_78":73,"_79":73,"_80":73,"_81":73,"_82":73,"_83":73,"_84":85,"_94":27,"_95":27},"__clerk_ssr_state",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__signInForceRedirectUrl","__signUpForceRedirectUrl","__signInFallbackRedirectUrl","__signUpFallbackRedirectUrl","__clerk_debug",{"_86":27,"_87":73,"_88":89,"_90":73,"_91":44,"_92":27,"_93":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_98":99,"_100":101,"_102":42,"_103":73,"_104":-7,"_105":106,"_150":151,"_497":498,"_499":500,"_506":507,"_176":-5,"_541":-5,"_542":-5,"_543":27,"_544":27},"handle","liamh","name","google-calendar-linear-sync","branchName","path","version","project",{"_107":108,"_100":101,"_109":110,"_111":-5,"_112":27,"_113":114,"_115":116,"_117":118,"_12":119,"_120":-5,"_121":27,"_122":-5,"_123":124,"_14":125,"_126":127,"_128":127,"_129":130,"_131":130,"_132":130,"_133":127,"_134":127,"_21":135,"_138":139,"_149":27},"id","f8942846-25e7-11f0-ab4c-569c3dd06744","createdAt",["D",1746033868658],"deletedAt","legacyEnvVars","privacy","public","description","Bidirectional sync for Linear issues and Google Calendar events","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/67f68327-50ce-4f9c-2732-c233ac1ed200/square512","b7fc6d10-f2e9-11ef-89a3-8735e07158f4","pinnedFileId","pinPreview","screenshotVersion","likeCount",1,"8238ec37-fbe0-436e-84ae-8442da6b5a1d","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_98":99,"_136":137},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ydFZBdXhGVTFxTlJibTdQYmFHT2pRV1JHb2sifQ","branch",{"_104":140,"_100":42,"_107":141,"_142":108,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":101,"_148":99},152,"f8948e30-25e7-11f0-ab4c-569c3dd06744","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectUserId","projectName","userHandle","isOwned","tree",[152,181,280,423,432,441,450,459,468,477,486],{"_107":153,"_100":154,"_155":156,"_157":-5,"_158":141,"_159":160,"_161":162,"_109":163,"_104":31,"_164":165,"_166":-5,"_167":27,"_168":-5,"_169":170,"_103":180},"ebdf7084-644d-11f0-a41b-0224a6c84d84",".claude","fileId","ebdf712e-644d-11f0-a41b-0224a6c84d84","parentId","branchId","branchVersion",87,"latest",true,["D",1752894628092],"fileType","directory","content","deleted","label","children",[171],{"_107":172,"_100":173,"_155":174,"_157":156,"_158":141,"_159":140,"_161":162,"_109":175,"_104":124,"_164":176,"_166":177,"_167":27,"_168":-5,"_169":178,"_103":179},"b31218fc-64c9-11f0-a379-0224a6c84d84","settings.local.json","ec2054fa-644d-11f0-9b75-0224a6c84d84",["D",1752947789103],"file","{\n \"permissions\": {\n \"allow\": [\n \"Bash(deno test:*)\",\n \"Bash(ls:*)\",\n \"Bash(export:*)\",\n \"Bash(mkdir:*)\",\n \"Bash(mv:*)\",\n \"Bash(deno check:*)\",\n \"Bash(timeout:*)\",\n \"Bash(find:*)\",\n \"Bash(deno run:*)\",\n \"Bash(node:*)\",\n \"Bash(git init:*)\",\n \"Bash(sed:*)\",\n \"Bash(deno:*)\",\n \"Bash(git add:*)\",\n \"Bash(git push:*)\",\n \"Bash(git commit:*)\"\n ],\n \"deny\": []\n }\n}",[],[154,173],[154],{"_107":182,"_100":183,"_155":184,"_157":-5,"_158":141,"_159":185,"_161":162,"_109":186,"_104":31,"_164":165,"_166":-5,"_167":27,"_168":-5,"_169":187,"_103":279},"ebffba38-644d-11f0-95f7-0224a6c84d84","scripts","ebffbb00-644d-11f0-95f7-0224a6c84d84",89,["D",1752894628309],[188,197,207,216,225,234,243,252,261,270],{"_107":189,"_100":190,"_155":191,"_157":184,"_158":141,"_159":192,"_161":162,"_109":193,"_104":124,"_164":176,"_166":194,"_167":27,"_168":-5,"_169":195,"_103":196},"b295eafc-64c9-11f0-b3cf-0224a6c84d84","README.md","ec30ce66-644d-11f0-a244-0224a6c84d84",139,["D",1752947789577],"# Scripts\n\nUtilities and tools for the Google Calendar ↔ Linear sync system.\n\n## Prerequisites\n\nCreate a `.env` file with your credentials:\n\n```bash\ncp .env.example .env\n# Edit .env with your actual API keys:\n\nLINEAR_API_KEY=\"your-api-key\"\nLINEAR_TEAM_ID=\"your-team-id\"\nGOOGLE_SERVICE_ACCOUNT_JSON=\"base64-encoded-json\"\nGCAL_CALENDAR_ID=\"your-calendar-id\"\n```\n\n## Development Tasks\n\nUse `deno task` commands for all development operations:\n\n```bash\ndeno task check # Check environment configuration\ndeno task validate # Validate API structure and mock compatibility\ndeno task dry-run # Run sync logic with real data (no changes made)\ndeno task setup # Show Val Town configuration guide\ndeno task test # Run unit tests\ndeno task sync # Run production sync\n```\n\n## Debug Scripts\n\n### Show Google Calendar Events\n\n```bash\ndeno run --allow-env --allow-net scripts/show-gcal.ts\n```\n\nShows all GCal events with linking metadata.\n\n### Show Linear Issues\n\n```bash\ndeno run --allow-env --allow-net scripts/show-linear.ts\n```\n\nShows targeted Linear issues with calendar metadata.\n\n### Show Canonical Items\n\n```bash\ndeno run --allow-env --allow-net scripts/show-canonical.ts\n```\n\nShows the projector output - canonical items from Linear + GCal data.\n\n### Show Complete Data Flow\n\n```bash\ndeno run --allow-env --allow-net scripts/show-all.ts\n```\n\nComplete analysis showing GCal → Linear → Canonical flow with statistics.\n\n## Utility Tools\n\n### API Validator\n\n```bash\n# Used by CLI, can also be imported\nimport { validateApis } from \"./api-validator.ts\";\n```\n\nValidates that mock data structures match real API responses.\n\n### Val Town Configuration\n\n```bash\n# Used by CLI, can also be imported\nimport { getValTownConfig } from \"./val-town-config.ts\";\n```\n\nHelpers for Val Town environment setup and configuration.\n\n## Debugging Workflow\n\n1. **Environment check**: `deno task check`\n2. **API validation**: `deno task validate`\n3. **Dry run test**: `deno task dry-run`\n4. **Check raw data**: Use `show-gcal.ts` and `show-linear.ts`\n5. **Verify linking**: Use `show-canonical.ts`\n6. **Full analysis**: Use `show-all.ts`\n\nThis helps quickly identify:\n\n- Environment configuration issues\n- API structure mismatches\n- Missing linking metadata\n- Unexpected phase classifications\n- Items that should be linked but aren't\n- Overall sync system health\n",[],[183,190],{"_107":198,"_100":199,"_155":200,"_157":184,"_158":141,"_159":201,"_161":162,"_109":202,"_104":124,"_164":203,"_166":204,"_167":27,"_168":-5,"_169":205,"_103":206},"b22508fa-64c9-11f0-98a9-0224a6c84d84","api-validator.ts","ec631038-644d-11f0-8cee-0224a6c84d84",132,["D",1752947788832],"script","/**\n * API Validator: Fetches sample data from real APIs and validates mock structures\n * Used to ensure our mock data matches real API responses\n */\n\nimport { GCalEvent, LinearIssue } from \"../src/types.ts\";\nimport { RealGCalApiClient, RealLinearApiClient } from \"../src/api-clients.ts\";\n\nexport interface ValidationConfig {\n linearApiKey: string;\n linearTeamId: string;\n googleServiceAccountJson: string; // Base64 encoded service account JSON\n gcalCalendarId: string;\n}\n\nexport interface ValidationResult {\n success: boolean;\n errors: string[];\n linearSample?: LinearIssue;\n gcalSample?: GCalEvent;\n mockValidation: {\n linearStructureValid: boolean;\n gcalStructureValid: boolean;\n missingLinearFields: string[];\n missingGCalFields: string[];\n };\n}\n\nexport class ApiValidator {\n constructor(private config: ValidationConfig) {}\n\n /**\n * Validate both APIs and check mock compatibility\n */\n async validateApis(): Promise {\n const result: ValidationResult = {\n success: false,\n errors: [],\n mockValidation: {\n linearStructureValid: true,\n gcalStructureValid: true,\n missingLinearFields: [],\n missingGCalFields: [],\n },\n };\n\n try {\n console.log(\"🔍 Validating Linear API...\");\n const linearSample = await this.fetchLinearSample();\n result.linearSample = linearSample;\n\n console.log(\"🔍 Validating Google Calendar API...\");\n const gcalSample = await this.fetchGCalSample();\n result.gcalSample = gcalSample;\n\n console.log(\"🔍 Validating mock structures...\");\n result.mockValidation = this.validateMockStructures(\n linearSample,\n gcalSample,\n );\n\n result.success = result.mockValidation.linearStructureValid &&\n result.mockValidation.gcalStructureValid;\n\n if (result.success) {\n console.log(\"✅ All API validations passed!\");\n } else {\n console.log(\"❌ API validation failed\");\n }\n } catch (error) {\n result.errors.push(\n error instanceof Error ? error.message : String(error),\n );\n console.error(\"🚨 API validation error:\", error);\n }\n\n return result;\n }\n\n /**\n * Fetch a sample Linear issue\n */\n private async fetchLinearSample(): Promise {\n const linearClient = new RealLinearApiClient({\n apiKey: this.config.linearApiKey,\n teamId: this.config.linearTeamId,\n });\n\n const issues = await linearClient.getIssues(this.config.linearTeamId);\n\n if (issues.length === 0) {\n throw new Error(\"No Linear issues found for validation\");\n }\n\n return issues[0];\n }\n\n /**\n * Fetch a sample Google Calendar event\n */\n private async fetchGCalSample(): Promise {\n const gcalClient = new RealGCalApiClient({\n serviceAccountJson: this.config.googleServiceAccountJson,\n calendarId: this.config.gcalCalendarId,\n });\n\n const events = await gcalClient.getEvents(\n this.config.gcalCalendarId,\n new Date().toISOString(),\n new Date(Date.now() + 7 * 24 * 60 * 60 * 1000).toISOString(),\n );\n\n if (events.length === 0) {\n throw new Error(\"No Google Calendar events found for validation\");\n }\n\n return events[0];\n }\n\n\n /**\n * Validate that our mock structures match real API responses\n */\n private validateMockStructures(\n linearSample: LinearIssue,\n gcalSample: GCalEvent,\n ): ValidationResult[\"mockValidation\"] {\n const result = {\n linearStructureValid: true,\n gcalStructureValid: true,\n missingLinearFields: [] as string[],\n missingGCalFields: [] as string[],\n };\n\n // Check Linear issue structure\n const expectedLinearFields = [\"id\", \"title\", \"state\"];\n for (const field of expectedLinearFields) {\n if (!(field in linearSample)) {\n result.missingLinearFields.push(field);\n result.linearStructureValid = false;\n }\n }\n\n // Check GCal event structure\n const expectedGCalFields = [\"id\", \"summary\", \"start\", \"end\", \"status\"];\n for (const field of expectedGCalFields) {\n if (!(field in gcalSample)) {\n result.missingGCalFields.push(field);\n result.gcalStructureValid = false;\n }\n }\n\n // Log structure comparison\n console.log(\"📋 Linear API Structure:\");\n console.log(JSON.stringify(linearSample, null, 2));\n\n console.log(\"📋 Google Calendar API Structure:\");\n console.log(JSON.stringify(gcalSample, null, 2));\n\n return result;\n }\n\n /**\n * Print detailed API comparison report\n */\n printValidationReport(result: ValidationResult): void {\n console.log(\"\\n📊 API Validation Report\");\n console.log(\"========================\");\n\n console.log(`\\n✅ Overall Success: ${result.success}`);\n\n if (result.errors.length > 0) {\n console.log(\"\\n❌ Errors:\");\n result.errors.forEach((error) => console.log(` - ${error}`));\n }\n\n console.log(`\\n📋 Linear API:`);\n console.log(\n ` Structure Valid: ${result.mockValidation.linearStructureValid}`,\n );\n if (result.mockValidation.missingLinearFields.length > 0) {\n console.log(\n ` Missing Fields: ${\n result.mockValidation.missingLinearFields.join(\", \")\n }`,\n );\n }\n\n console.log(`\\n📅 Google Calendar API:`);\n console.log(\n ` Structure Valid: ${result.mockValidation.gcalStructureValid}`,\n );\n if (result.mockValidation.missingGCalFields.length > 0) {\n console.log(\n ` Missing Fields: ${\n result.mockValidation.missingGCalFields.join(\", \")\n }`,\n );\n }\n\n if (result.linearSample) {\n console.log(`\\n📝 Sample Linear Issue:`);\n console.log(` ID: ${result.linearSample.id}`);\n console.log(` Title: ${result.linearSample.title}`);\n console.log(` State: ${result.linearSample.state}`);\n console.log(` Estimate: ${result.linearSample.estimate || \"None\"}`);\n }\n\n if (result.gcalSample) {\n console.log(`\\n📅 Sample Calendar Event:`);\n console.log(` ID: ${result.gcalSample.id}`);\n console.log(` Title: ${result.gcalSample.summary}`);\n console.log(` Start: ${result.gcalSample.start.dateTime}`);\n console.log(` Status: ${result.gcalSample.status}`);\n }\n }\n}\n\n/**\n * Standalone validation function for easy CLI usage\n */\nexport async function validateApis(\n config: ValidationConfig,\n): Promise {\n const validator = new ApiValidator(config);\n const result = await validator.validateApis();\n validator.printValidationReport(result);\n return result;\n}\n",[],[183,199],{"_107":208,"_100":209,"_155":210,"_157":184,"_158":141,"_159":211,"_161":162,"_109":212,"_104":31,"_164":203,"_166":213,"_167":27,"_168":-5,"_169":214,"_103":215},"b2e14d58-64c9-11f0-944d-0224a6c84d84","check.ts","b2e14e16-64c9-11f0-944d-0224a6c84d84",146,["D",1752947789229],"/**\n * Environment configuration checker\n */\n\nimport { checkEnvironment, getValTownConfig } from \"./val-town-config.ts\";\n\nfunction main() {\n console.log(\"🔍 Checking environment configuration...\\n\");\n\n const check = checkEnvironment();\n\n if (check.valid) {\n console.log(\"✅ All required environment variables are set!\");\n } else {\n console.log(\"❌ Missing required environment variables:\");\n check.missing.forEach((key) => console.log(` - ${key}`));\n console.log(\"\\nRun `deno task setup` for configuration guide.\");\n Deno.exit(1);\n }\n\n if (check.warnings.length > 0) {\n console.log(\"\\n⚠️ Warnings:\");\n check.warnings.forEach((warning) => console.log(` - ${warning}`));\n }\n\n const config = getValTownConfig();\n console.log(\"\\n📋 Current Configuration:\");\n console.log(` Timezone: ${config.timezone}`);\n console.log(\n ` Working Hours: ${config.workingHours.startHour}:00 - ${config.workingHours.endHour}:00`,\n );\n console.log(` Max Items: ${config.maxItemsToProcess}`);\n console.log(` Validate APIs: ${config.validateApiStructure}`);\n console.log(` Verbose Logging: ${config.verboseLogging}`);\n}\n\nif (import.meta.main) {\n main();\n}\n",[],[183,209],{"_107":217,"_100":218,"_155":219,"_157":184,"_158":141,"_159":220,"_161":162,"_109":221,"_104":31,"_164":203,"_166":222,"_167":27,"_168":-5,"_169":223,"_103":224},"b24d84d8-64c9-11f0-b9a9-0224a6c84d84","setup.ts","b24d85be-64c9-11f0-b9a9-0224a6c84d84",136,["D",1752947788920],"/**\n * Setup guide for Val Town configuration\n */\n\nimport { printValTownSetupGuide } from \"./val-town-config.ts\";\n\nfunction main() {\n printValTownSetupGuide();\n}\n\nif (import.meta.main) {\n main();\n}\n",[],[183,218],{"_107":226,"_100":227,"_155":228,"_157":184,"_158":141,"_159":229,"_161":162,"_109":230,"_104":124,"_164":203,"_166":231,"_167":27,"_168":-5,"_169":232,"_103":233},"b30a8696-64c9-11f0-b4f3-0224a6c84d84","show-all.ts","ec373396-644d-11f0-9d1c-0224a6c84d84",151,["D",1752947789695],"/**\n * Run with: deno run --allow-env --allow-net --env-file=.env scripts/show-all.ts\n */\n\n/**\n * Show All Data - Complete overview of GCal → Linear → Canonical flow\n */\n\nimport { RealGCalApiClient, RealLinearApiClient } from \"../src/api-clients.ts\";\nimport { project } from \"../src/projector.ts\";\nimport { parseCalendarMetadataFromDescription } from \"../src/metadata-parser.ts\";\n\nconst linearClient = new RealLinearApiClient({\n apiKey: Deno.env.get(\"LINEAR_API_KEY\")!,\n teamId: Deno.env.get(\"LINEAR_TEAM_ID\")!,\n});\n\nconst gcalClient = new RealGCalApiClient({\n serviceAccountJson: Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")!,\n calendarId: Deno.env.get(\"GCAL_CALENDAR_ID\")!,\n});\n\nconsole.log(\"🔄 Complete Data Flow Analysis\\n\");\n\n// Fetch GCal events first to get Linear IDs to query\nconst gcalEvents = await gcalClient.getEvents(\n Deno.env.get(\"GCAL_CALENDAR_ID\")!,\n \"\",\n \"\",\n);\n\n// Extract Linear IDs referenced by GCal events\nconst referencedLinearIds = gcalEvents\n .map((event) => event.extendedProperties?.private?.linearIssueId)\n .filter(Boolean) as string[];\n\n// Fetch targeted Linear issues (referenced + scheduled)\nconst linearIssues = await linearClient.getTargetedIssues(\n Deno.env.get(\"LINEAR_TEAM_ID\")!,\n referencedLinearIds,\n);\n\nconst result = project({\n linearIssues,\n gcalEvents,\n now: new Date(),\n});\n\n// Linking analysis\nconst gcalWithLinearId = gcalEvents.filter((e) =>\n e.extendedProperties?.private?.linearIssueId\n);\nconst linearWithMetadata = linearIssues.filter((i) =>\n parseCalendarMetadataFromDescription(i.description || \"\")\n);\nconst linkedCanonical = result.items.filter((i) => i.linearId && i.gcalId);\n\nconsole.log(\"🔄 Complete Data Flow Analysis\\n\");\n\n// Data flow summary\nconsole.log(\"📊 Data Flow Summary:\");\nconsole.log(`📅 Google Calendar: ${gcalEvents.length} events`);\nconsole.log(`📋 Linear Issues: ${linearIssues.length} issues`);\nconsole.log(`🎯 Canonical Items: ${result.items.length} items\\n`);\n\n// Linking analysis table\nconsole.log(\"🔗 Linking Analysis:\");\nconst linkingData = [\n {\n Source: \"GCal Events\",\n Items: gcalEvents.length,\n \"With Links\": gcalWithLinearId.length,\n \"Link Rate\": `${\n ((gcalWithLinearId.length / gcalEvents.length) * 100).toFixed(1)\n }%`,\n },\n {\n Source: \"Linear Issues\",\n Items: linearIssues.length,\n \"With Links\": linearWithMetadata.length,\n \"Link Rate\": `${\n ((linearWithMetadata.length / linearIssues.length) * 100).toFixed(1)\n }%`,\n },\n {\n Source: \"Canonical Items\",\n Items: result.items.length,\n \"With Links\": linkedCanonical.length,\n \"Link Rate\": `${\n ((linkedCanonical.length / result.items.length) * 100).toFixed(1)\n }%`,\n },\n];\nconsole.table(linkingData);\n\n// Top linked items\nif (linkedCanonical.length > 0) {\n console.log(\"\\n🏆 Top 50 Linked Items:\");\n const topLinkedItems = linkedCanonical\n .slice(0, 50)\n .map((item) => ({\n Title: item.title?.substring(0, 35) +\n (item.title && item.title.length > 35 ? \"...\" : \"\"),\n Phase: item.phase,\n \"Linear State\": item.linearState || \"\",\n \"Start Time\": item.startTime\n ? new Date(item.startTime).toISOString().substring(0, 16)\n : \"\",\n }));\n console.table(topLinkedItems);\n}\n\n// Phase breakdown\nconst phaseCounts = result.items.reduce((acc, item) => {\n acc[item.phase] = (acc[item.phase] || 0) + 1;\n return acc;\n}, {} as Record);\n\nconsole.log(\"\\n📈 Phase Breakdown:\");\nconst phaseData = [\n {\n Phase: \"active\",\n Count: phaseCounts.active || 0,\n Description: \"Linked and syncing\",\n },\n {\n Phase: \"completed\",\n Count: phaseCounts.completed || 0,\n Description: \"Done/Canceled/Failed\",\n },\n {\n Phase: \"overdue\",\n Count: phaseCounts.overdue || 0,\n Description: \"Past deadline\",\n },\n {\n Phase: \"eventOnly\",\n Count: phaseCounts.eventOnly || 0,\n Description: \"GCal event without Linear\",\n },\n {\n Phase: \"linearOnly\",\n Count: phaseCounts.linearOnly || 0,\n Description: \"Linear issue without GCal\",\n },\n];\nconsole.table(phaseData);\n\nconsole.log(\"\\n🎯 Key Metrics:\");\nconsole.log(\n `- Linking success rate: ${\n ((linkedCanonical.length / result.items.length) * 100).toFixed(1)\n }%`,\n);\nconsole.log(\n `- GCal events needing Linear issues: ${phaseCounts.eventOnly || 0}`,\n);\nconsole.log(\n `- Linear issues needing GCal events: ${\n result.items.filter((i) =>\n i.phase === \"linearOnly\" && i.linearState === \"Scheduled\"\n ).length\n }`,\n);\nconsole.log(`- Active syncing pairs: ${phaseCounts.active || 0}`);\n",[],[183,227],{"_107":235,"_100":236,"_155":237,"_157":184,"_158":141,"_159":238,"_161":162,"_109":239,"_104":124,"_164":203,"_166":240,"_167":27,"_168":-5,"_169":241,"_103":242},"b2c4b31e-64c9-11f0-9138-0224a6c84d84","show-canonical.ts","ec3a72f4-644d-11f0-9751-0224a6c84d84",142,["D",1752947789881],"/**\n * Run with: deno run --allow-env --allow-net --env-file=.env scripts/show-canonical.ts\n */\n\n/**\n * Show Canonical Items - See the projector output after processing Linear + GCal data\n */\n\nimport { RealGCalApiClient, RealLinearApiClient } from \"../src/api-clients.ts\";\nimport { project } from \"../src/projector.ts\";\n\nconst linearClient = new RealLinearApiClient({\n apiKey: Deno.env.get(\"LINEAR_API_KEY\")!,\n teamId: Deno.env.get(\"LINEAR_TEAM_ID\")!,\n});\n\nconst gcalClient = new RealGCalApiClient({\n serviceAccountJson: Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")!,\n calendarId: Deno.env.get(\"GCAL_CALENDAR_ID\")!,\n});\n\nconsole.log(\"🎯 Fetching data and projecting canonical items...\\n\");\n\n// Fetch GCal events first to get Linear IDs to query\nconst gcalEvents = await gcalClient.getEvents(\n Deno.env.get(\"GCAL_CALENDAR_ID\")!,\n \"\",\n \"\",\n);\n\n// Extract Linear IDs referenced by GCal events\nconst referencedLinearIds = gcalEvents\n .map((event) => event.extendedProperties?.private?.linearIssueId)\n .filter(Boolean) as string[];\n\nconsole.log(\n `🔍 Found ${referencedLinearIds.length} Linear IDs referenced by GCal events`,\n);\nconsole.log(`📅 Found ${gcalEvents.length} GCal events total`);\n\n// Fetch targeted Linear issues (referenced + scheduled)\nconst linearIssues = await linearClient.getTargetedIssues(\n Deno.env.get(\"LINEAR_TEAM_ID\")!,\n referencedLinearIds,\n);\n\nconst result = project({\n linearIssues,\n gcalEvents,\n now: new Date(),\n});\n\nconsole.log(`🎯 Canonical Items (${result.items.length} total)\\n`);\n\nconst tableData = result.items\n .sort((a, b) => {\n // Sort by phase, then by title\n if (a.phase !== b.phase) {\n const phaseOrder = [\n \"active\",\n \"completed\",\n \"overdue\",\n \"eventOnly\",\n \"linearOnly\",\n ];\n return phaseOrder.indexOf(a.phase) - phaseOrder.indexOf(b.phase);\n }\n return a.title.localeCompare(b.title);\n })\n .map((item) => ({\n Title: item.title?.substring(0, 40) +\n (item.title && item.title.length > 40 ? \"...\" : \"\"),\n Phase: item.phase,\n \"Has Linear\": item.linearId ? \"✅\" : \"\",\n \"Has GCal\": item.gcalId ? \"✅\" : \"\",\n \"Start Time\": item.startTime\n ? new Date(item.startTime).toISOString().substring(0, 16)\n : \"\",\n }));\n\nconsole.table(tableData);\n\nconst phaseCounts = result.items.reduce((acc, item) => {\n acc[item.phase] = (acc[item.phase] || 0) + 1;\n return acc;\n}, {} as Record);\n\nconsole.log(\"\\n📊 Phase Summary:\");\nObject.entries(phaseCounts).forEach(([phase, count]) => {\n console.log(`- ${phase}: ${count}`);\n});\n\nconsole.log(\"\\n🔗 Linking Summary:\");\nconsole.log(\n `- Items with both Linear & GCal: ${\n result.items.filter((i) => i.linearId && i.gcalId).length\n }`,\n);\nconsole.log(\n `- eventOnly (GCal without Linear): ${\n result.items.filter((i) => i.phase === \"eventOnly\").length\n }`,\n);\nconsole.log(\n `- linearOnly (Linear without GCal): ${\n result.items.filter((i) => i.phase === \"linearOnly\").length\n }`,\n);\nconsole.log(`- Total canonical items: ${result.items.length}`);\n",[],[183,236],{"_107":244,"_100":245,"_155":246,"_157":184,"_158":141,"_159":247,"_161":162,"_109":248,"_104":124,"_164":203,"_166":249,"_167":27,"_168":-5,"_169":250,"_103":251},"b2be8fca-64c9-11f0-87c8-0224a6c84d84","show-gcal.ts","ec3487c2-644d-11f0-bc6b-0224a6c84d84",141,["D",1752947789762],"/**\n * Run with: deno run --allow-env --allow-net --env-file=.env scripts/show-gcal.ts\n */\n\n/**\n * Show GCal Events - Simple CLI to see what the API returns from Google Calendar\n */\n\nimport { RealGCalApiClient } from \"../src/api-clients.ts\";\n\nconst gcalClient = new RealGCalApiClient({\n serviceAccountJson: Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")!,\n calendarId: Deno.env.get(\"GCAL_CALENDAR_ID\")!,\n});\n\nconsole.log(\"📅 Fetching Google Calendar Events...\\n\");\n\nconst events = await gcalClient.getEvents(\n Deno.env.get(\"GCAL_CALENDAR_ID\")!,\n \"\",\n \"\",\n);\n\nconsole.log(`📅 Google Calendar Events (${events.length} total)\\n`);\n\nconst tableData = events.map((event) => {\n return {\n Summary: event.summary?.substring(0, 40) +\n (event.summary && event.summary.length > 40 ? \"...\" : \"\"),\n Start: event.start.dateTime\n ? new Date(event.start.dateTime).toISOString().substring(0, 16)\n : \"N/A\",\n \"Linear ID\": event.extendedProperties?.private?.linearIssueId\n ? event.extendedProperties.private.linearIssueId.substring(0, 8) + \"...\"\n : \"\",\n UID: event.extendedProperties?.private?.uid\n ? event.extendedProperties.private.uid.substring(0, 8) + \"...\"\n : \"\",\n };\n});\n\nconsole.table(tableData);\n\nconsole.log(\"\\n🔗 Linking Summary:\");\nconsole.log(\n `- Events with linearIssueId: ${\n events.filter((e) => e.extendedProperties?.private?.linearIssueId).length\n }`,\n);\nconsole.log(\n `- Events with UID: ${\n events.filter((e) => e.extendedProperties?.private?.uid).length\n }`,\n);\nconsole.log(`- Total events: ${events.length}`);\n",[],[183,245],{"_107":253,"_100":254,"_155":255,"_157":184,"_158":141,"_159":256,"_161":162,"_109":257,"_104":124,"_164":203,"_166":258,"_167":27,"_168":-5,"_169":259,"_103":260},"b28ba45c-64c9-11f0-8940-0224a6c84d84","show-linear.ts","ec24e01a-644d-11f0-9853-0224a6c84d84",138,["D",1752947789510],"/**\n * Run with: deno run --allow-env --allow-net --env-file=.env scripts/show-linear.ts\n */\n\n/**\n * Show Linear Issues - Simple CLI to see what the API returns from Linear\n */\n\nimport { RealLinearApiClient } from \"../src/api-clients.ts\";\nimport { parseCalendarMetadataFromDescription } from \"../src/metadata-parser.ts\";\n\nconst linearClient = new RealLinearApiClient({\n apiKey: Deno.env.get(\"LINEAR_API_KEY\")!,\n teamId: Deno.env.get(\"LINEAR_TEAM_ID\")!,\n});\n\nconsole.log(\"📋 Fetching Linear Issues...\\n\");\n\nconst issues = await linearClient.getTargetedIssues(\n Deno.env.get(\"LINEAR_TEAM_ID\")!,\n [],\n);\n\nconsole.log(`📋 Linear Issues (${issues.length} total)\\n`);\n\nconst tableData = issues.map((issue) => {\n const metadata = parseCalendarMetadataFromDescription(\n issue.description || \"\",\n );\n return {\n Title: issue.title?.substring(0, 40) +\n (issue.title && issue.title.length > 40 ? \"...\" : \"\"),\n State: issue.state,\n \"Target Date\": issue.targetDate\n ? new Date(issue.targetDate).toISOString().substring(0, 10)\n : \"\",\n \"GCal ID\": metadata?.gcalId ? metadata.gcalId.substring(0, 12) + \"...\" : \"\",\n \"Has Metadata\": metadata ? \"✅\" : \"\",\n };\n});\n\nconsole.table(tableData);\n\nconsole.log(\"\\n📊 Metadata Summary:\");\nconsole.log(\n `- Issues with calendar metadata: ${\n issues.filter((i) =>\n parseCalendarMetadataFromDescription(i.description || \"\")\n ).length\n }`,\n);\nconsole.log(\n `- Scheduled issues: ${issues.filter((i) => i.state === \"Scheduled\").length}`,\n);\nconsole.log(\n `- Done issues: ${issues.filter((i) => i.state === \"Done\").length}`,\n);\nconsole.log(`- Total issues: ${issues.length}`);\n",[],[183,254],{"_107":262,"_100":263,"_155":264,"_157":184,"_158":141,"_159":265,"_161":162,"_109":266,"_104":124,"_164":203,"_166":267,"_167":27,"_168":-5,"_169":268,"_103":269},"b23941da-64c9-11f0-8361-0224a6c84d84","val-town-config.ts","ec9e5b7a-644d-11f0-95f7-0224a6c84d84",134,["D",1752947788862],"/**\n * Val Town Configuration\n * Configuration helpers for running in Val Town environment with secrets\n */\n\nimport { DryRunConfig } from \"../src/dry-run.ts\";\nimport { ValidationConfig } from \"./api-validator.ts\";\n\n/**\n * Get configuration from Val Town environment variables\n * These should be set as secrets in your Val Town account\n */\nexport function getValTownConfig(): DryRunConfig {\n // Check if we're in Val Town environment\n const isValTown = typeof globalThis.fetch !== \"undefined\" &&\n typeof Deno !== \"undefined\" &&\n Deno.env.get(\"DENO_DEPLOYMENT_ID\");\n\n if (isValTown) {\n console.log(\"🏔️ Running in Val Town environment\");\n } else {\n console.log(\"💻 Running in local environment\");\n }\n\n // Required secrets from Val Town\n const linearApiKey = Deno.env.get(\"LINEAR_API_KEY\");\n const linearTeamId = Deno.env.get(\"LINEAR_TEAM_ID\");\n const googleServiceAccountJson = Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\");\n const gcalCalendarId = Deno.env.get(\"GCAL_CALENDAR_ID\");\n\n // Validate required environment variables\n const missing = [];\n if (!linearApiKey) missing.push(\"LINEAR_API_KEY\");\n if (!linearTeamId) missing.push(\"LINEAR_TEAM_ID\");\n if (!googleServiceAccountJson) missing.push(\"GOOGLE_SERVICE_ACCOUNT_JSON\");\n if (!gcalCalendarId) missing.push(\"GCAL_CALENDAR_ID\");\n\n if (missing.length > 0) {\n throw new Error(\n `Missing required environment variables: ${missing.join(\", \")}`,\n );\n }\n\n // Optional configuration with defaults\n const config: DryRunConfig = {\n // API credentials\n linearApiKey: linearApiKey!,\n linearTeamId: linearTeamId!,\n googleServiceAccountJson: googleServiceAccountJson!,\n gcalCalendarId: gcalCalendarId!,\n gcalHistoryCalendarId: Deno.env.get(\"GCAL_HISTORY_CALENDAR_ID\"),\n\n // Sync configuration\n timezone: Deno.env.get(\"TIMEZONE\") || \"America/New_York\",\n workingHours: {\n startHour: parseInt(Deno.env.get(\"WORK_START_HOUR\") || \"9\"),\n endHour: parseInt(Deno.env.get(\"WORK_END_HOUR\") || \"17\"),\n workingDays: [1, 2, 3, 4, 5], // Monday-Friday\n },\n lookbackDays: parseInt(Deno.env.get(\"LOOKBACK_DAYS\") || \"2\"),\n lookaheadDays: parseInt(Deno.env.get(\"LOOKAHEAD_DAYS\") || \"14\"),\n\n // Dry run specific options\n validateApiStructure: Deno.env.get(\"VALIDATE_API_STRUCTURE\") !== \"false\",\n maxItemsToProcess: parseInt(Deno.env.get(\"MAX_ITEMS_TO_PROCESS\") || \"50\"),\n verboseLogging: Deno.env.get(\"VERBOSE_LOGGING\") === \"true\",\n };\n\n return config;\n}\n\n/**\n * Get validation config for API structure validation\n */\nexport function getValidationConfig(): ValidationConfig {\n const linearApiKey = Deno.env.get(\"LINEAR_API_KEY\");\n const linearTeamId = Deno.env.get(\"LINEAR_TEAM_ID\");\n const googleServiceAccountJson = Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\");\n const gcalCalendarId = Deno.env.get(\"GCAL_CALENDAR_ID\");\n\n if (\n !linearApiKey || !linearTeamId || !googleServiceAccountJson ||\n !gcalCalendarId\n ) {\n throw new Error(\"Missing required API credentials for validation\");\n }\n\n return {\n linearApiKey,\n linearTeamId,\n googleServiceAccountJson,\n gcalCalendarId,\n };\n}\n\n/**\n * Print configuration guide for setting up Val Town secrets\n */\nexport function printValTownSetupGuide(): void {\n console.log(\"\\n\" + \"=\".repeat(60));\n console.log(\"🏔️ VAL TOWN SETUP GUIDE\");\n console.log(\"=\".repeat(60));\n\n console.log(\"\\n📋 Required Secrets (set these in your Val Town settings):\");\n console.log(\"\");\n console.log(\"1. LINEAR_API_KEY\");\n console.log(\" • Go to: https://linear.app/settings/api\");\n console.log(\" • Create new Personal API Key\");\n console.log(\" • Copy the key\");\n console.log(\"\");\n console.log(\"2. LINEAR_TEAM_ID\");\n console.log(\" • In Linear, go to your team settings\");\n console.log(\" • Copy the team ID from the URL or settings\");\n console.log(\"\");\n console.log(\"3. GOOGLE_SERVICE_ACCOUNT_JSON\");\n console.log(\n \" • Go to: https://console.cloud.google.com/iam-admin/serviceaccounts\",\n );\n console.log(\" • Create service account with Calendar API access\");\n console.log(\" • Download JSON key file\");\n console.log(\n \" • Base64 encode the entire JSON: `base64 -i service-account.json`\",\n );\n console.log(\" • Use the base64 string as the secret value\");\n console.log(\"\");\n console.log(\"4. GCAL_CALENDAR_ID\");\n console.log(\" • Open Google Calendar\");\n console.log(\" • Go to calendar settings\");\n console.log(\" • Copy the Calendar ID (looks like email@gmail.com)\");\n\n console.log(\"\\n⚙️ Optional Configuration:\");\n console.log(\n \" • GCAL_HISTORY_CALENDAR_ID: For storing overdue event copies\",\n );\n console.log(' • TIMEZONE: Default \"America/New_York\"');\n console.log(\" • WORK_START_HOUR: Default 9 (9 AM)\");\n console.log(\" • WORK_END_HOUR: Default 17 (5 PM)\");\n console.log(\" • VALIDATE_API_STRUCTURE: Default true\");\n console.log(\" • MAX_ITEMS_TO_PROCESS: Default 50\");\n console.log(\" • VERBOSE_LOGGING: Default false\");\n\n console.log(\"\\n🔒 Setting Secrets in Val Town:\");\n console.log(\" 1. Go to your Val Town dashboard\");\n console.log(' 2. Click on \"Environment Variables\" or \"Secrets\"');\n console.log(\" 3. Add each required secret with its value\");\n console.log(\" 4. Make sure the val has access to these secrets\");\n\n console.log(\"\\n✅ Test Your Setup:\");\n console.log(\" Run validateApis() first to check API access\");\n console.log(\" Then run a dry sync to see what would happen\");\n\n console.log(\"\\n\" + \"=\".repeat(60));\n}\n\n/**\n * Check if all required environment variables are set\n */\nexport function checkEnvironment(): {\n valid: boolean;\n missing: string[];\n warnings: string[];\n} {\n const required = [\n \"LINEAR_API_KEY\",\n \"LINEAR_TEAM_ID\",\n \"GOOGLE_SERVICE_ACCOUNT_JSON\",\n \"GCAL_CALENDAR_ID\",\n ];\n\n const optional = [\n \"GCAL_HISTORY_CALENDAR_ID\",\n \"TIMEZONE\",\n \"WORK_START_HOUR\",\n \"WORK_END_HOUR\",\n ];\n\n const missing = required.filter((key) => !Deno.env.get(key));\n const warnings = optional.filter((key) => !Deno.env.get(key))\n .map((key) => `${key} not set, using default`);\n\n return {\n valid: missing.length === 0,\n missing,\n warnings,\n };\n}\n",[],[183,263],{"_107":271,"_100":272,"_155":273,"_157":184,"_158":141,"_159":274,"_161":162,"_109":275,"_104":31,"_164":203,"_166":276,"_167":27,"_168":-5,"_169":277,"_103":278},"b22c0a2e-64c9-11f0-8d88-0224a6c84d84","validate.ts","b22c0b00-64c9-11f0-8d88-0224a6c84d84",133,["D",1752947788880],"/**\n * API structure validator\n */\n\nimport { validateApis } from \"./api-validator.ts\";\nimport { getValidationConfig } from \"./val-town-config.ts\";\n\nasync function main() {\n console.log(\"🔍 Validating API structure and mock compatibility...\\n\");\n\n try {\n const config = getValidationConfig();\n const result = await validateApis(config);\n\n if (result.success) {\n console.log(\n \"\\n🎉 Validation successful! Your mock data structures are compatible with the real APIs.\",\n );\n } else {\n console.log(\"\\n⚠️ Validation issues found. Check the details above.\");\n Deno.exit(1);\n }\n } catch (error) {\n console.error(\n \"\\n❌ Validation failed:\",\n error instanceof Error ? error.message : String(error),\n );\n Deno.exit(1);\n }\n}\n\nif (import.meta.main) {\n await main();\n}\n",[],[183,272],[183],{"_107":281,"_100":282,"_155":283,"_157":-5,"_158":141,"_159":284,"_161":162,"_109":285,"_104":31,"_164":165,"_166":-5,"_167":27,"_168":-5,"_169":286,"_103":422},"ec1206fc-644d-11f0-9a81-0224a6c84d84","src","ec1207f6-644d-11f0-9a81-0224a6c84d84",90,["D",1752894628427],[287,296,305,314,323,332,341,350,359,368,377,386,395,404,413],{"_107":288,"_100":289,"_155":290,"_157":283,"_158":141,"_159":291,"_161":162,"_109":292,"_104":31,"_164":203,"_166":293,"_167":27,"_168":-5,"_169":294,"_103":295},"ecb6a0e0-644d-11f0-a738-0224a6c84d84","actuator.test.ts","ecb6a20c-644d-11f0-a738-0224a6c84d84",120,["D",1752894629472],"/**\n * Tests for the actuator module\n */\n\nimport {\n assertEquals,\n assertExists,\n} from \"https://deno.land/std@0.220.1/assert/mod.ts\";\nimport { Actuator } from \"./actuator.ts\";\nimport { CanonicalItem, GCalEvent, LinearIssue, SyncConfig } from \"./types.ts\";\n\n// Enhanced mock clients for actuator testing\nclass MockLinearApiClient {\n private issues: LinearIssue[] = [];\n private nextId = 1;\n\n async createIssue(issue: Partial): Promise {\n const newIssue: LinearIssue = {\n id: `linear-${this.nextId++}`,\n title: issue.title || \"Untitled\",\n description: issue.description,\n state: issue.state || \"Triage\",\n targetDate: issue.targetDate,\n estimate: issue.estimate,\n };\n this.issues.push(newIssue);\n return newIssue;\n }\n\n async updateIssue(\n id: string,\n updates: Partial,\n ): Promise {\n const issue = this.issues.find((i) => i.id === id);\n if (!issue) throw new Error(`Issue ${id} not found`);\n\n Object.assign(issue, updates);\n return issue;\n }\n\n getIssues(_teamId: string): Promise {\n return Promise.resolve([...this.issues]);\n }\n\n getTargetedIssues(\n _teamId: string,\n referencedIds: string[],\n ): Promise {\n // Mock: return referenced issues + scheduled issues\n const referencedIssues = this.issues.filter((i) =>\n referencedIds.includes(i.id)\n );\n const scheduledIssues = this.issues.filter((i) => i.state === \"Scheduled\");\n\n // Merge, avoiding duplicates\n const seen = new Set();\n const result: LinearIssue[] = [];\n\n for (const issue of [...referencedIssues, ...scheduledIssues]) {\n if (!seen.has(issue.id)) {\n seen.add(issue.id);\n result.push(issue);\n }\n }\n\n return Promise.resolve(result);\n }\n\n // Test helpers\n getCreatedIssues(): LinearIssue[] {\n return [...this.issues];\n }\n\n reset(): void {\n this.issues = [];\n this.nextId = 1;\n }\n}\n\nclass MockGCalApiClient {\n private events: GCalEvent[] = [];\n private nextId = 1;\n\n createEvent(event: Partial): Promise {\n const newEvent: GCalEvent = {\n id: `gcal-${this.nextId++}`,\n summary: event.summary || \"Untitled\",\n description: event.description,\n start: event.start || { dateTime: \"2024-01-01T12:00:00Z\" },\n end: event.end || { dateTime: \"2024-01-01T13:00:00Z\" },\n extendedProperties: event.extendedProperties,\n status: event.status || \"confirmed\",\n };\n this.events.push(newEvent);\n return Promise.resolve(newEvent);\n }\n\n updateEvent(id: string, updates: Partial): Promise {\n const event = this.events.find((e) => e.id === id);\n if (!event) throw new Error(`Event ${id} not found`);\n\n Object.assign(event, updates);\n return Promise.resolve(event);\n }\n\n getEvents(\n _calendarId: string,\n _timeMin: string,\n _timeMax: string,\n ): Promise {\n return Promise.resolve([...this.events]);\n }\n\n copyEventToCalendar(\n eventId: string,\n _targetCalendarId: string,\n ): Promise {\n const event = this.events.find((e) => e.id === eventId);\n if (!event) throw new Error(`Event ${eventId} not found`);\n\n return this.createEvent({\n ...event,\n id: undefined, // Will get new ID\n });\n }\n\n // Test helpers\n getCreatedEvents(): GCalEvent[] {\n return [...this.events];\n }\n\n reset(): void {\n this.events = [];\n this.nextId = 1;\n }\n}\n\nfunction createTestConfig(): SyncConfig {\n return {\n linearApiKey: \"test-key\",\n linearTeamId: \"test-team\",\n gcalCalendarId: \"test-cal\",\n gcalHistoryCalendarId: \"test-history-cal\",\n timezone: \"America/New_York\",\n workingHours: {\n startHour: 9,\n endHour: 17,\n workingDays: [1, 2, 3, 4, 5],\n },\n lookbackDays: 2,\n lookaheadDays: 14,\n };\n}\n\nDeno.test(\"Actuator createLinearIssue operation\", async () => {\n const config = createTestConfig();\n const linearClient = new MockLinearApiClient();\n const gcalClient = new MockGCalApiClient();\n\n const actuator = new Actuator({\n linear: linearClient,\n gcal: gcalClient,\n }, config);\n\n const item: CanonicalItem = {\n uid: \"test-uid-123\",\n title: \"Test Task\",\n description: \"A test task from GCal\",\n startTime: \"2024-01-01T14:00:00Z\",\n endTime: \"2024-01-01T15:00:00Z\",\n durationMin: 60,\n estimate: \"M\",\n gcalId: \"gcal-1\",\n phase: \"eventOnly\",\n lastModified: \"2024-01-01T12:00:00Z\",\n };\n\n const operations = [{\n type: \"createLinearIssue\" as const,\n item,\n reason: \"Test creation\",\n }];\n\n const results = await actuator.execute(operations);\n\n assertEquals(results.length, 1);\n assertEquals(results[0].success, true);\n assertEquals(results[0].error, null);\n\n const createdIssues = linearClient.getCreatedIssues();\n assertEquals(createdIssues.length, 1);\n assertEquals(createdIssues[0].title, \"📥\\u202FTest Task\");\n assertEquals(createdIssues[0].state, \"Triage\");\n assertEquals(createdIssues[0].estimate, 3); // M = 3 points\n // Check that calendar metadata is in description\n assertExists(createdIssues[0].description);\n assertEquals(\n createdIssues[0].description?.includes(\"GoogleCalEventId:gcal-1\"),\n true,\n );\n});\n\nDeno.test(\"Actuator createGCalEvent operation\", async () => {\n const config = createTestConfig();\n const linearClient = new MockLinearApiClient();\n const gcalClient = new MockGCalApiClient();\n\n const actuator = new Actuator({\n linear: linearClient,\n gcal: gcalClient,\n }, config);\n\n const item: CanonicalItem = {\n uid: \"test-uid-456\",\n title: \"Scheduled Task\",\n description: \"A scheduled Linear task\",\n startTime: \"2024-01-02T10:00:00Z\",\n endTime: \"2024-01-02T10:30:00Z\",\n durationMin: 30,\n estimate: \"S\",\n linearId: \"linear-1\",\n phase: \"linearOnly\",\n lastModified: \"2024-01-01T12:00:00Z\",\n };\n\n const operations = [{\n type: \"createGCalEvent\" as const,\n item,\n reason: \"Test GCal creation\",\n }];\n\n const results = await actuator.execute(operations);\n\n assertEquals(results.length, 1);\n assertEquals(results[0].success, true);\n\n const createdEvents = gcalClient.getCreatedEvents();\n assertEquals(createdEvents.length, 1);\n assertEquals(createdEvents[0].summary, \"📅\\u202FScheduled Task\");\n assertEquals(createdEvents[0].start.dateTime, \"2024-01-02T10:00:00Z\");\n assertEquals(createdEvents[0].end.dateTime, \"2024-01-02T10:30:00Z\");\n assertEquals(\n createdEvents[0].extendedProperties?.private?.uid,\n \"test-uid-456\",\n );\n assertEquals(\n createdEvents[0].extendedProperties?.private?.linearIssueId,\n \"linear-1\",\n );\n});\n\nDeno.test(\"Actuator patchGCalEvent operation\", async () => {\n const config = createTestConfig();\n const linearClient = new MockLinearApiClient();\n const gcalClient = new MockGCalApiClient();\n\n // Create an existing event first\n const existingEvent = await gcalClient.createEvent({\n summary: \"Old Title\",\n start: { dateTime: \"2024-01-01T14:00:00Z\" },\n end: { dateTime: \"2024-01-01T15:00:00Z\" },\n });\n\n const actuator = new Actuator({\n linear: linearClient,\n gcal: gcalClient,\n }, config);\n\n const item: CanonicalItem = {\n uid: \"test-uid-789\",\n title: \"✅\\u202FCompleted Task\",\n description: \"Task is now complete\",\n gcalId: existingEvent.id,\n linearId: \"linear-1\",\n phase: \"completed\",\n lastModified: \"2024-01-01T12:00:00Z\",\n };\n\n const operations = [{\n type: \"patchGCalEvent\" as const,\n item,\n reason: \"Mark as completed\",\n }];\n\n const results = await actuator.execute(operations);\n\n assertEquals(results.length, 1);\n assertEquals(results[0].success, true);\n\n const events = gcalClient.getCreatedEvents();\n const updatedEvent = events.find((e) => e.id === existingEvent.id);\n assertEquals(updatedEvent?.summary, \"✅\\u202FCompleted Task\");\n assertEquals(updatedEvent?.extendedProperties?.private?.uid, \"test-uid-789\");\n});\n\nDeno.test(\"Actuator createRescheduledEvent operation\", async () => {\n const config = createTestConfig();\n const linearClient = new MockLinearApiClient();\n const gcalClient = new MockGCalApiClient();\n\n const actuator = new Actuator({\n linear: linearClient,\n gcal: gcalClient,\n }, config);\n\n const item: CanonicalItem = {\n uid: \"test-uid-overdue\",\n title: \"📅\\u202FOverdue Task\",\n description: \"Task that went overdue\",\n startTime: \"2024-01-03T11:00:00Z\",\n endTime: \"2024-01-03T12:00:00Z\",\n durationMin: 60,\n estimate: \"M\",\n linearId: \"linear-overdue\",\n gcalId: \"gcal-overdue\",\n phase: \"overdue\",\n lastModified: \"2024-01-01T12:00:00Z\",\n };\n\n const operations = [{\n type: \"createRescheduledEvent\" as const,\n item,\n reason: \"Reschedule overdue task\",\n }];\n\n const results = await actuator.execute(operations);\n\n assertEquals(results.length, 1);\n assertEquals(results[0].success, true);\n\n const events = gcalClient.getCreatedEvents();\n assertEquals(events.length, 1);\n assertEquals(events[0].summary, \"📅\\u202FOverdue Task\");\n assertEquals(events[0].extendedProperties?.private?.uid, \"test-uid-overdue\");\n assertEquals(\n events[0].extendedProperties?.private?.linearIssueId,\n \"linear-overdue\",\n );\n});\n\nDeno.test(\"Actuator handles operation errors gracefully\", async () => {\n const config = createTestConfig();\n const linearClient = new MockLinearApiClient();\n const gcalClient = new MockGCalApiClient();\n\n const actuator = new Actuator({\n linear: linearClient,\n gcal: gcalClient,\n }, config);\n\n const item: CanonicalItem = {\n uid: \"test-uid-error\",\n title: \"Error Task\",\n // Missing gcalId for patch operation\n phase: \"completed\",\n lastModified: \"2024-01-01T12:00:00Z\",\n };\n\n const operations = [{\n type: \"patchGCalEvent\" as const,\n item,\n reason: \"This should fail\",\n }];\n\n const results = await actuator.execute(operations);\n\n assertEquals(results.length, 1);\n assertEquals(results[0].success, false);\n assertEquals(results[0].result, null);\n assertExists(results[0].error);\n assertEquals(results[0].error, \"Cannot patch GCal event without gcalId\");\n});\n\nDeno.test(\"Actuator processes multiple operations\", async () => {\n const config = createTestConfig();\n const linearClient = new MockLinearApiClient();\n const gcalClient = new MockGCalApiClient();\n\n const actuator = new Actuator({\n linear: linearClient,\n gcal: gcalClient,\n }, config);\n\n const operations = [\n {\n type: \"createLinearIssue\" as const,\n item: {\n uid: \"uid-1\",\n title: \"Task 1\",\n gcalId: \"gcal-1\",\n phase: \"eventOnly\" as const,\n lastModified: \"2024-01-01T12:00:00Z\",\n },\n reason: \"Create Linear issue 1\",\n },\n {\n type: \"createGCalEvent\" as const,\n item: {\n uid: \"uid-2\",\n title: \"Task 2\",\n startTime: \"2024-01-02T10:00:00Z\",\n endTime: \"2024-01-02T10:30:00Z\",\n linearId: \"linear-2\",\n phase: \"linearOnly\" as const,\n lastModified: \"2024-01-01T12:00:00Z\",\n },\n reason: \"Create GCal event 1\",\n },\n ];\n\n const results = await actuator.execute(operations);\n\n assertEquals(results.length, 2);\n assertEquals(results.every((r) => r.success), true);\n\n const createdIssues = linearClient.getCreatedIssues();\n const createdEvents = gcalClient.getCreatedEvents();\n\n assertEquals(createdIssues.length, 1);\n assertEquals(createdEvents.length, 1);\n\n assertEquals(createdIssues[0].title, \"📥\\u202FTask 1\");\n assertEquals(createdEvents[0].summary, \"📅\\u202FTask 2\");\n});\n",[],[282,289],{"_107":297,"_100":298,"_155":299,"_157":283,"_158":141,"_159":300,"_161":162,"_109":301,"_104":31,"_164":203,"_166":302,"_167":27,"_168":-5,"_169":303,"_103":304},"ec542474-644d-11f0-94e7-0224a6c84d84","actuator.ts","ec54253c-644d-11f0-94e7-0224a6c84d84",102,["D",1752894628851],"/**\n * Actuator: Executes operations via Linear & Calendar APIs\n * Performs idempotent API calls to make external reality match canonical truth\n */\n\nimport {\n addPrefix,\n CanonicalItem,\n estimateToPoints,\n GCalEvent,\n LinearIssue,\n Operation,\n PREFIXES,\n SyncConfig,\n} from \"./types.ts\";\nimport { SmartScheduler } from \"./scheduler.ts\";\n\nexport interface ApiClients {\n linear: LinearApiClient;\n gcal: GCalApiClient;\n}\n\nexport interface LinearApiClient {\n createIssue(issue: Partial): Promise;\n updateIssue(id: string, updates: Partial): Promise;\n getIssues(teamId: string): Promise;\n getTargetedIssues(\n teamId: string,\n referencedIds: string[],\n ): Promise;\n}\n\nexport interface GCalApiClient {\n createEvent(event: Partial): Promise;\n updateEvent(id: string, updates: Partial): Promise;\n getEvents(\n calendarId: string,\n timeMin: string,\n timeMax: string,\n ): Promise;\n copyEventToCalendar(\n eventId: string,\n targetCalendarId: string,\n ): Promise;\n}\n\nexport class Actuator {\n private scheduler: SmartScheduler;\n\n constructor(\n private clients: ApiClients,\n private config: SyncConfig,\n ) {\n this.scheduler = new SmartScheduler(config);\n }\n\n async execute(operations: Operation[]): Promise {\n const results: ExecutionResult[] = [];\n\n for (const operation of operations) {\n try {\n const result = await this.executeOperation(operation);\n results.push({\n operation,\n success: true,\n result,\n error: null,\n });\n } catch (error) {\n results.push({\n operation,\n success: false,\n result: null,\n error: error instanceof Error ? error.message : String(error),\n });\n }\n }\n\n return results;\n }\n\n private async executeOperation(\n operation: Operation,\n ): Promise {\n switch (operation.type) {\n case \"createLinearIssue\":\n return this.createLinearIssue(operation.item);\n\n case \"createGCalEvent\":\n return this.createGCalEvent(operation.item);\n\n case \"patchGCalEvent\":\n return this.patchGCalEvent(operation.item);\n\n case \"patchLinearIssue\":\n return this.patchLinearIssue(operation.item);\n\n case \"copyEventToHistory\":\n return this.copyEventToHistory(operation.item);\n\n case \"createRescheduledEvent\":\n return this.createRescheduledEvent(operation.item);\n\n case \"createLinearIssueAndUpdateGCal\":\n return this.createLinearIssueAndUpdateGCal(operation.item);\n\n case \"createGCalEventAndUpdateLinear\":\n return this.createGCalEventAndUpdateLinear(operation.item);\n\n case \"noop\":\n return null;\n\n default:\n throw new Error(`Unknown operation type: ${(operation as any).type}`);\n }\n }\n\n private async createLinearIssue(item: CanonicalItem): Promise {\n // Include calendar metadata in description for linking\n let description = item.description || \"\";\n if (item.gcalId && item.startTime && item.durationMin) {\n const metadata =\n ` GoogleCalEventId:${item.gcalId} | Start:${item.startTime} | DurMin:${item.durationMin}`;\n description = description ? `${metadata}\\n\\n${description}` : metadata;\n }\n\n const issue: Partial = {\n title: addPrefix(item.title, PREFIXES.TRIAGE),\n description,\n state: \"Triage\",\n targetDate: item.startTime,\n estimate: item.estimate ? estimateToPoints(item.estimate) : 2, // Default to S (2 points)\n };\n\n return this.clients.linear.createIssue(issue);\n }\n\n private async createGCalEvent(item: CanonicalItem): Promise {\n let startTime = item.startTime;\n let endTime = item.endTime;\n\n // For Linear scheduled tasks, always create timed events (never all-day)\n // Use smart scheduling if times aren't set or if we have a date-only Linear target date\n const needsScheduling = !startTime || !endTime ||\n (startTime && startTime.length === 10);\n\n if (needsScheduling) {\n const existingEvents = await this.clients.gcal.getEvents(\n this.config.gcalCalendarId,\n \"\", // Will use default timeframes\n \"\",\n );\n\n const slot = await this.scheduler.findNextAvailableSlot(\n {\n estimate: item.estimate || \"S\",\n title: item.title,\n // If we have a date-only target date, use it as preferred date\n preferredDate: startTime && startTime.length === 10\n ? startTime\n : undefined,\n },\n existingEvents,\n );\n\n startTime = slot.startTime;\n endTime = slot.endTime;\n }\n\n // Always create timed events for Linear tasks (never all-day)\n let description = item.description || \"\";\n\n // Add Linear link to GCal description for easy navigation\n if (item.linearId) {\n const linearLink =\n `Linear issue: [${item.linearId}](https://linear.app/liamhorne/issue/${item.linearId})`;\n description = description\n ? `${linearLink}\\n\\n${description}`\n : linearLink;\n }\n\n const event: Partial = {\n summary: addPrefix(item.title, PREFIXES.SCHEDULED),\n description,\n start: { dateTime: startTime },\n end: { dateTime: endTime },\n extendedProperties: {\n private: {\n uid: item.uid,\n linearIssueId: item.linearId,\n },\n },\n status: \"confirmed\",\n };\n\n return this.clients.gcal.createEvent(event);\n }\n\n private async patchGCalEvent(item: CanonicalItem): Promise {\n if (!item.gcalId) {\n throw new Error(\"Cannot patch GCal event without gcalId\");\n }\n\n const updates: Partial = {\n summary: item.title,\n };\n\n // Add description if present\n if (item.description !== undefined) {\n updates.description = item.description;\n }\n\n // Add timing if present\n if (item.startTime && item.endTime) {\n updates.start = { dateTime: item.startTime };\n updates.end = { dateTime: item.endTime };\n }\n\n // Ensure UID is preserved/set\n updates.extendedProperties = {\n private: {\n uid: item.uid,\n linearIssueId: item.linearId,\n },\n };\n\n return this.clients.gcal.updateEvent(item.gcalId, updates);\n }\n\n private async patchLinearIssue(item: CanonicalItem): Promise {\n if (!item.linearId) {\n throw new Error(\"Cannot patch Linear issue without linearId\");\n }\n\n // Include calendar metadata in description for linking\n let description = item.description || \"\";\n if (item.gcalId && item.startTime && item.durationMin) {\n const metadata =\n ` GoogleCalEventId:${item.gcalId} | Start:${item.startTime} | DurMin:${item.durationMin}`;\n description = description ? `${metadata}\\n\\n${description}` : metadata;\n }\n\n const updates: Partial = {\n title: item.title,\n description,\n state: item.linearState,\n targetDate: item.startTime,\n };\n\n return this.clients.linear.updateIssue(item.linearId, updates);\n }\n\n private async copyEventToHistory(\n item: CanonicalItem,\n ): Promise {\n if (!item.gcalId || !this.config.gcalHistoryCalendarId) {\n return null; // No history calendar configured\n }\n\n return this.clients.gcal.copyEventToCalendar(\n item.gcalId,\n this.config.gcalHistoryCalendarId,\n );\n }\n\n /**\n * Creates a new Google Calendar event for overdue items.\n * This is used when a task goes overdue - we mark the original event as \"worked on\" (⏳)\n * and create this new event to continue tracking the task.\n */\n private async createRescheduledEvent(\n item: CanonicalItem,\n ): Promise {\n let startTime = item.startTime;\n let endTime = item.endTime;\n\n // Use smart scheduling for rescheduled events\n if (!startTime || !endTime) {\n const existingEvents = await this.clients.gcal.getEvents(\n this.config.gcalCalendarId,\n \"\", // Will use default timeframes\n \"\",\n );\n\n const slot = await this.scheduler.findNextAvailableSlot(\n {\n estimate: item.estimate || \"S\",\n title: item.title,\n preferredDate: undefined, // Let scheduler find next available\n },\n existingEvents,\n );\n\n startTime = slot.startTime;\n endTime = slot.endTime;\n }\n\n const event: Partial = {\n summary: item.title, // Already has correct prefix from diff\n description: item.description,\n start: { dateTime: startTime },\n end: { dateTime: endTime },\n extendedProperties: {\n private: {\n uid: item.uid, // Same UID to maintain linkage\n linearIssueId: item.linearId,\n },\n },\n status: \"confirmed\",\n };\n\n return this.clients.gcal.createEvent(event);\n }\n\n /**\n * Combined operation: Create Linear issue first, then update GCal event with link\n * This ensures the GCal event gets updated with the Linear issue ID and proper title/description\n */\n private async createLinearIssueAndUpdateGCal(\n item: CanonicalItem,\n ): Promise {\n // Step 1: Create the Linear issue\n const createdIssue = await this.createLinearIssue(item);\n\n // Step 2: Update the GCal event with the new Linear issue ID and title\n if (item.gcalId) {\n const updates: Partial = {\n summary: item.title, // Should already have 📥 prefix from item\n description:\n `Linear issue: [${createdIssue.id}](https://linear.app/liamhorne/issue/${createdIssue.id})`,\n extendedProperties: {\n private: {\n uid: item.uid,\n linearIssueId: createdIssue.id,\n },\n },\n };\n\n try {\n await this.clients.gcal.updateEvent(item.gcalId, updates);\n console.log(\n `✅ Updated GCal event \"${item.title}\" with Linear issue link`,\n );\n } catch (error) {\n console.warn(`⚠️ Failed to update GCal event: ${error}`);\n // Don't fail the whole operation if GCal update fails\n }\n }\n\n return createdIssue;\n }\n\n /**\n * Combined operation: Create GCal event first, then update Linear issue with link\n * This ensures the Linear issue gets updated with the calendar event ID and proper metadata\n */\n private async createGCalEventAndUpdateLinear(\n item: CanonicalItem,\n ): Promise {\n // Step 1: Create the GCal event\n const createdEvent = await this.createGCalEvent(item);\n\n // Step 2: Update the Linear issue with the new GCal event ID and metadata\n if (item.linearId) {\n // Include calendar metadata in description for linking\n let description = item.description || \"\";\n if (createdEvent.id && item.startTime && item.durationMin) {\n const metadata =\n ` GoogleCalEventId:${createdEvent.id} | Start:${item.startTime} | DurMin:${item.durationMin}`;\n description = description ? `${metadata}\\n\\n${description}` : metadata;\n }\n\n const updates: Partial = {\n description,\n // Keep other fields unchanged, just add the calendar link\n targetDate: item.startTime,\n };\n\n try {\n await this.clients.linear.updateIssue(item.linearId, updates);\n console.log(\n `✅ Updated Linear issue \"${item.title}\" with calendar event link`,\n );\n } catch (error) {\n console.warn(`⚠️ Failed to update Linear issue: ${error}`);\n // Don't fail the whole operation if Linear update fails\n }\n }\n\n return createdEvent;\n }\n}\n\nexport interface ExecutionResult {\n operation: Operation;\n success: boolean;\n result: LinearIssue | GCalEvent | null;\n error: string | null;\n}\n",[],[282,298],{"_107":306,"_100":307,"_155":308,"_157":283,"_158":141,"_159":309,"_161":162,"_109":310,"_104":31,"_164":203,"_166":311,"_167":27,"_168":-5,"_169":312,"_103":313},"ec808b7c-644d-11f0-b6ab-0224a6c84d84","api-clients.ts","ec808c58-644d-11f0-b6ab-0224a6c84d84",109,["D",1752894629120],"/**\n * Real API Clients for Linear and Google Calendar\n * Production implementations that talk to actual APIs\n */\n\nimport { GCalApiClient, LinearApiClient } from \"./actuator.ts\";\nimport { GCalEvent, LinearIssue } from \"./types.ts\";\n\nexport interface RealLinearConfig {\n apiKey: string;\n teamId: string;\n}\n\nexport interface RealGCalConfig {\n serviceAccountJson: string; // Base64 encoded\n calendarId: string;\n}\n\n/**\n * Real Linear API client using GraphQL\n */\nexport class RealLinearApiClient implements LinearApiClient {\n constructor(private config: RealLinearConfig) {}\n\n async createIssue(issue: Partial): Promise {\n const mutation = `\n mutation CreateIssue($input: IssueCreateInput!) {\n issueCreate(input: $input) {\n success\n issue {\n id\n title\n description\n state {\n name\n }\n estimate\n dueDate\n team {\n id\n }\n }\n }\n }\n `;\n\n const input = {\n teamId: this.config.teamId,\n title: issue.title,\n description: issue.description,\n stateId: await this.getStateId(issue.state || \"Triage\"),\n estimate: issue.estimate,\n dueDate: issue.targetDate,\n };\n\n const response = await this.graphqlRequest(mutation, { input });\n\n if (!response.data?.issueCreate?.success) {\n throw new Error(\"Failed to create Linear issue\");\n }\n\n const createdIssue = response.data.issueCreate.issue;\n\n // Custom fields not needed - using description metadata instead\n\n return this.formatLinearIssue(createdIssue);\n }\n\n async updateIssue(\n id: string,\n updates: Partial,\n ): Promise {\n const mutation = `\n mutation UpdateIssue($id: String!, $input: IssueUpdateInput!) {\n issueUpdate(id: $id, input: $input) {\n success\n issue {\n id\n title\n description\n state {\n name\n }\n estimate\n dueDate\n team {\n id\n }\n }\n }\n }\n `;\n\n const input: any = {};\n\n if (updates.title) input.title = updates.title;\n if (updates.description !== undefined) {\n input.description = updates.description;\n }\n if (updates.state) input.stateId = await this.getStateId(updates.state);\n if (updates.estimate !== undefined) input.estimate = updates.estimate;\n if (updates.targetDate !== undefined) input.dueDate = updates.targetDate;\n\n const response = await this.graphqlRequest(mutation, { id, input });\n\n if (!response.data?.issueUpdate?.success) {\n throw new Error(\"Failed to update Linear issue\");\n }\n\n // Custom fields not needed - using description metadata instead\n\n return this.formatLinearIssue(response.data.issueUpdate.issue);\n }\n\n getIssues(teamId: string): Promise {\n // Legacy method - use getTargetedIssues instead\n return this.getTargetedIssues(teamId, []);\n }\n\n async getTargetedIssues(\n teamId: string,\n referencedIds: string[],\n ): Promise {\n const issues: LinearIssue[] = [];\n\n // 1. Fetch specific issues referenced by GCal events\n if (referencedIds.length > 0) {\n console.log(\n `🔍 Fetching ${referencedIds.length} issues referenced by GCal events...`,\n );\n\n for (const issueId of referencedIds) {\n try {\n const issue = await this.getSingleIssue(issueId);\n if (issue) {\n issues.push(issue);\n }\n } catch (error) {\n console.warn(\n `⚠️ Failed to fetch referenced issue ${issueId}:`,\n error,\n );\n }\n }\n }\n\n // 2. Fetch all \"Scheduled\" issues\n console.log(\"🔍 Fetching all Scheduled issues...\");\n const scheduledIssues = await this.getScheduledIssues(teamId);\n\n // Merge, avoiding duplicates\n const existingIds = new Set(issues.map((i) => i.id));\n for (const issue of scheduledIssues) {\n if (!existingIds.has(issue.id)) {\n issues.push(issue);\n }\n }\n\n console.log(\n `📋 Fetched ${issues.length} targeted Linear issues (${referencedIds.length} referenced + ${scheduledIssues.length} scheduled, ${\n issues.length - referencedIds.length - scheduledIssues.length\n } overlapping)`,\n );\n\n return issues;\n }\n\n private async getSingleIssue(issueId: string): Promise {\n const query = `\n query GetIssue($issueId: String!) {\n issue(id: $issueId) {\n id\n title\n description\n state {\n name\n }\n estimate\n dueDate\n team {\n id\n }\n }\n }\n `;\n\n const response = await this.graphqlRequest(query, { issueId });\n const issue = response.data?.issue;\n\n return issue ? this.formatLinearIssue(issue) : null;\n }\n\n private async getScheduledIssues(_teamId: string): Promise {\n const query = `\n query GetScheduledIssues {\n issues(first: 100, filter: { state: { name: { eq: \"Scheduled\" } } }) {\n nodes {\n id\n title\n description\n state {\n name\n }\n estimate\n dueDate\n team {\n id\n }\n }\n }\n }\n `;\n\n const response = await this.graphqlRequest(query, {});\n const issues = response.data?.issues?.nodes || [];\n\n return issues.map((issue: any) => this.formatLinearIssue(issue));\n }\n\n private async graphqlRequest(query: string, variables: any): Promise {\n const response = await fetch(\"https://api.linear.app/graphql\", {\n method: \"POST\",\n headers: {\n \"Authorization\": this.config.apiKey,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ query, variables }),\n });\n\n if (!response.ok) {\n throw new Error(\n `Linear API error: ${response.status} ${response.statusText}`,\n );\n }\n\n const data = await response.json();\n\n if (data.errors) {\n throw new Error(\n `Linear GraphQL error: ${\n data.errors.map((e: any) => e.message).join(\", \")\n }`,\n );\n }\n\n return data;\n }\n\n private async getStateId(stateName: string): Promise {\n const query = `\n query GetStates($teamId: String!) {\n team(id: $teamId) {\n states {\n nodes {\n id\n name\n }\n }\n }\n }\n `;\n\n const response = await this.graphqlRequest(query, {\n teamId: this.config.teamId,\n });\n const states = response.data?.team?.states?.nodes || [];\n const state = states.find((s: any) => s.name === stateName);\n\n if (!state) {\n throw new Error(`State \"${stateName}\" not found`);\n }\n\n return state.id;\n }\n\n private formatLinearIssue(issue: any): LinearIssue {\n return {\n id: issue.id,\n title: issue.title,\n description: issue.description,\n state: issue.state.name,\n targetDate: issue.dueDate,\n estimate: issue.estimate,\n };\n }\n}\n\n/**\n * Real Google Calendar API client\n */\nexport class RealGCalApiClient implements GCalApiClient {\n private accessToken?: string;\n private tokenExpiry?: number;\n\n constructor(private config: RealGCalConfig) {}\n\n async createEvent(event: Partial): Promise {\n await this.ensureAccessToken();\n\n const response = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${\n encodeURIComponent(this.config.calendarId)\n }/events`,\n {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${this.accessToken}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n summary: event.summary,\n description: event.description,\n start: event.start,\n end: event.end,\n extendedProperties: event.extendedProperties,\n status: event.status || \"confirmed\",\n }),\n },\n );\n\n if (!response.ok) {\n const errorBody = await response.text();\n throw new Error(\n `Google Calendar API error: ${response.status} ${response.statusText} - ${errorBody}`,\n );\n }\n\n const createdEvent = await response.json();\n return this.formatGCalEvent(createdEvent);\n }\n\n async updateEvent(\n id: string,\n updates: Partial,\n ): Promise {\n await this.ensureAccessToken();\n\n const response = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${\n encodeURIComponent(this.config.calendarId)\n }/events/${id}`,\n {\n method: \"PATCH\",\n headers: {\n \"Authorization\": `Bearer ${this.accessToken}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n summary: updates.summary,\n description: updates.description,\n start: updates.start,\n end: updates.end,\n extendedProperties: updates.extendedProperties,\n status: updates.status,\n }),\n },\n );\n\n if (!response.ok) {\n const errorBody = await response.text();\n throw new Error(\n `Google Calendar API error: ${response.status} ${response.statusText} - ${errorBody}`,\n );\n }\n\n const updatedEvent = await response.json();\n return this.formatGCalEvent(updatedEvent);\n }\n\n async getEvents(\n calendarId: string,\n timeMin: string,\n timeMax: string,\n ): Promise {\n await this.ensureAccessToken();\n\n const params = new URLSearchParams({\n timeMin: timeMin ||\n new Date(Date.now() - 2 * 24 * 60 * 60 * 1000).toISOString(),\n timeMax: timeMax ||\n new Date(Date.now() + 14 * 24 * 60 * 60 * 1000).toISOString(),\n maxResults: \"100\",\n singleEvents: \"true\",\n orderBy: \"startTime\",\n });\n\n const response = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${\n encodeURIComponent(calendarId)\n }/events?${params}`,\n {\n headers: {\n \"Authorization\": `Bearer ${this.accessToken}`,\n },\n },\n );\n\n if (!response.ok) {\n const errorBody = await response.text();\n throw new Error(\n `Google Calendar API error: ${response.status} ${response.statusText} - ${errorBody}`,\n );\n }\n\n const data = await response.json();\n const events = data.items || [];\n\n return events.map((event: any) => this.formatGCalEvent(event));\n }\n\n async copyEventToCalendar(\n eventId: string,\n targetCalendarId: string,\n ): Promise {\n await this.ensureAccessToken();\n\n // First get the original event\n const getResponse = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${\n encodeURIComponent(this.config.calendarId)\n }/events/${eventId}`,\n {\n headers: {\n \"Authorization\": `Bearer ${this.accessToken}`,\n },\n },\n );\n\n if (!getResponse.ok) {\n throw new Error(`Failed to get event for copying: ${getResponse.status}`);\n }\n\n const originalEvent = await getResponse.json();\n\n // Create a copy in the target calendar\n const copyResponse = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${\n encodeURIComponent(targetCalendarId)\n }/events`,\n {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${this.accessToken}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n summary: originalEvent.summary,\n description: originalEvent.description,\n start: originalEvent.start,\n end: originalEvent.end,\n extendedProperties: originalEvent.extendedProperties,\n }),\n },\n );\n\n if (!copyResponse.ok) {\n throw new Error(`Failed to copy event: ${copyResponse.status}`);\n }\n\n const copiedEvent = await copyResponse.json();\n return this.formatGCalEvent(copiedEvent);\n }\n\n private async ensureAccessToken(): Promise {\n if (this.accessToken && this.tokenExpiry && Date.now() < this.tokenExpiry) {\n return; // Token is still valid\n }\n\n // Decode service account - handle both base64 encoded and plain JSON\n let serviceAccountJson: string;\n try {\n // Try to decode as base64 first\n serviceAccountJson = atob(this.config.serviceAccountJson);\n } catch {\n // If base64 decode fails, assume it's already plain JSON\n serviceAccountJson = this.config.serviceAccountJson;\n }\n\n const serviceAccount = JSON.parse(serviceAccountJson);\n\n // Create JWT (simplified - would need proper crypto in production)\n const jwt = await this.createJWT(serviceAccount);\n\n // Exchange JWT for access token\n const response = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n },\n body: new URLSearchParams({\n grant_type: \"urn:ietf:params:oauth:grant-type:jwt-bearer\",\n assertion: jwt,\n }),\n });\n\n if (!response.ok) {\n throw new Error(`Failed to get access token: ${response.status}`);\n }\n\n const tokenData = await response.json();\n this.accessToken = tokenData.access_token;\n this.tokenExpiry = Date.now() + (tokenData.expires_in * 1000);\n }\n\n private async createJWT(serviceAccount: any): Promise {\n const header = {\n alg: \"RS256\",\n typ: \"JWT\",\n };\n\n const now = Math.floor(Date.now() / 1000);\n const payload = {\n iss: serviceAccount.client_email,\n scope: \"https://www.googleapis.com/auth/calendar\",\n aud: \"https://oauth2.googleapis.com/token\",\n exp: now + 3600,\n iat: now,\n };\n\n const encodedHeader = this.base64UrlEncode(JSON.stringify(header));\n const encodedPayload = this.base64UrlEncode(JSON.stringify(payload));\n const message = `${encodedHeader}.${encodedPayload}`;\n\n try {\n // Import the private key\n const privateKeyPem = serviceAccount.private_key;\n const privateKey = await this.importPrivateKey(privateKeyPem);\n\n // Sign the message\n const signature = await crypto.subtle.sign(\n \"RSASSA-PKCS1-v1_5\",\n privateKey,\n new TextEncoder().encode(message),\n );\n\n const encodedSignature = this.base64UrlEncode(signature);\n return `${message}.${encodedSignature}`;\n } catch (error) {\n console.error(\"JWT signing failed:\", error);\n throw new Error(\n \"Failed to create JWT: \" +\n (error instanceof Error ? error.message : String(error)),\n );\n }\n }\n\n private base64UrlEncode(data: string | ArrayBuffer): string {\n let base64: string;\n if (typeof data === \"string\") {\n base64 = btoa(data);\n } else {\n base64 = btoa(String.fromCharCode(...new Uint8Array(data)));\n }\n return base64.replace(/\\+/g, \"-\").replace(/\\//g, \"_\").replace(/=/g, \"\");\n }\n\n private async importPrivateKey(pem: string): Promise {\n // Remove header and footer and whitespace\n const pemContents = pem\n .replace(/-----BEGIN PRIVATE KEY-----/g, \"\")\n .replace(/-----END PRIVATE KEY-----/g, \"\")\n .replace(/\\s/g, \"\");\n\n // Convert to binary\n const binaryDer = atob(pemContents);\n const der = new Uint8Array(binaryDer.length);\n for (let i = 0; i < binaryDer.length; i++) {\n der[i] = binaryDer.charCodeAt(i);\n }\n\n return await crypto.subtle.importKey(\n \"pkcs8\",\n der,\n {\n name: \"RSASSA-PKCS1-v1_5\",\n hash: \"SHA-256\",\n },\n false,\n [\"sign\"],\n );\n }\n\n private formatGCalEvent(event: any): GCalEvent {\n return {\n id: event.id,\n summary: event.summary || \"Untitled\",\n description: event.description,\n start: {\n dateTime: event.start.dateTime,\n date: event.start.date,\n },\n end: {\n dateTime: event.end.dateTime,\n date: event.end.date,\n },\n extendedProperties: event.extendedProperties,\n status: event.status || \"confirmed\",\n };\n }\n}\n",[],[282,307],{"_107":315,"_100":316,"_155":317,"_157":283,"_158":141,"_159":318,"_161":162,"_109":319,"_104":31,"_164":203,"_166":320,"_167":27,"_168":-5,"_169":321,"_103":322},"ec90ab7e-644d-11f0-89ff-0224a6c84d84","diff.test.ts","ec90ac64-644d-11f0-89ff-0224a6c84d84",113,["D",1752894629248],"/**\n * Tests for the diff engine\n */\n\nimport { assertEquals } from \"https://deno.land/std@0.220.1/assert/mod.ts\";\nimport { diff, validateTransition } from \"./diff.ts\";\nimport { CanonicalItem } from \"./types.ts\";\n\nDeno.test(\"diff generates createLinearIssue for eventOnly items\", () => {\n const item: CanonicalItem = {\n uid: \"test-uid\",\n title: \"Meeting with client\",\n phase: \"eventOnly\",\n gcalId: \"gcal-1\",\n startTime: \"2024-01-01T14:00:00Z\",\n endTime: \"2024-01-01T15:00:00Z\",\n lastModified: \"2024-01-01T12:00:00Z\",\n };\n\n const operations = diff([item]);\n\n assertEquals(operations.length, 1);\n assertEquals(operations[0].type, \"createLinearIssueAndUpdateGCal\");\n assertEquals(\n operations[0].reason,\n \"New GCal event needs Linear issue and title update\",\n );\n assertEquals(operations[0].item.linearState, \"Triage\");\n});\n\nDeno.test(\"diff generates createGCalEvent for scheduled linearOnly items\", () => {\n const item: CanonicalItem = {\n uid: \"test-uid\",\n title: \"Work on feature\",\n phase: \"linearOnly\",\n linearId: \"linear-1\",\n linearState: \"Scheduled\",\n lastModified: \"2024-01-01T12:00:00Z\",\n };\n\n const operations = diff([item]);\n\n assertEquals(operations.length, 1);\n assertEquals(operations[0].type, \"createGCalEventAndUpdateLinear\");\n assertEquals(\n operations[0].reason,\n \"Scheduled Linear issue needs GCal event and metadata linking\",\n );\n});\n\nDeno.test(\"diff does not generate operations for non-scheduled linearOnly items\", () => {\n const item: CanonicalItem = {\n uid: \"test-uid\",\n title: \"Backlog item\",\n phase: \"linearOnly\",\n linearId: \"linear-1\",\n linearState: \"Triage\",\n lastModified: \"2024-01-01T12:00:00Z\",\n };\n\n const operations = diff([item]);\n\n assertEquals(operations.length, 0);\n});\n\nDeno.test(\"diff generates patchGCalEvent for completed items\", () => {\n const item: CanonicalItem = {\n uid: \"test-uid\",\n title: \"Completed task\",\n phase: \"completed\",\n linearId: \"linear-1\",\n gcalId: \"gcal-1\",\n linearState: \"Done\",\n lastModified: \"2024-01-01T12:00:00Z\",\n };\n\n const operations = diff([item]);\n\n assertEquals(operations.length, 1);\n assertEquals(operations[0].type, \"patchGCalEvent\");\n assertEquals(operations[0].reason, \"Linear issue marked as Done\");\n});\n\nDeno.test(\"diff generates overdue operations\", () => {\n const item: CanonicalItem = {\n uid: \"test-uid\",\n title: \"Overdue task\",\n phase: \"overdue\",\n linearId: \"linear-1\",\n gcalId: \"gcal-1\",\n linearState: \"Scheduled\",\n lastModified: \"2024-01-01T12:00:00Z\",\n };\n\n const operations = diff([item]);\n\n assertEquals(operations.length, 2);\n assertEquals(operations[0].type, \"patchGCalEvent\");\n assertEquals(\n operations[0].reason,\n \"Marking original event as worked on (⏳)\",\n );\n assertEquals(operations[1].type, \"createRescheduledEvent\");\n assertEquals(\n operations[1].reason,\n \"Creating new event to continue tracking overdue item\",\n );\n});\n\nDeno.test(\"validateTransition works correctly\", () => {\n // Valid transitions\n assertEquals(validateTransition(\"eventOnly\", \"active\"), true);\n assertEquals(validateTransition(\"linearOnly\", \"active\"), true);\n assertEquals(validateTransition(\"active\", \"completed\"), true);\n assertEquals(validateTransition(\"active\", \"overdue\"), true);\n assertEquals(validateTransition(\"active\", \"active\"), true);\n assertEquals(validateTransition(\"overdue\", \"active\"), true);\n\n // Invalid transitions\n assertEquals(validateTransition(\"completed\", \"active\"), false);\n assertEquals(validateTransition(\"eventOnly\", \"completed\"), false);\n assertEquals(validateTransition(\"linearOnly\", \"overdue\"), false);\n});\n\nDeno.test(\"diff handles multiple items correctly\", () => {\n const items: CanonicalItem[] = [\n {\n uid: \"uid-1\",\n title: \"Event only item\",\n phase: \"eventOnly\",\n gcalId: \"gcal-1\",\n lastModified: \"2024-01-01T12:00:00Z\",\n },\n {\n uid: \"uid-2\",\n title: \"Linear only item\",\n phase: \"linearOnly\",\n linearId: \"linear-1\",\n linearState: \"Scheduled\",\n lastModified: \"2024-01-01T12:00:00Z\",\n },\n {\n uid: \"uid-3\",\n title: \"Active item\",\n phase: \"active\",\n linearId: \"linear-2\",\n gcalId: \"gcal-2\",\n lastModified: \"2024-01-01T12:00:00Z\",\n },\n ];\n\n const operations = diff(items);\n\n // Should generate operations for eventOnly and linearOnly\n assertEquals(operations.length, 2);\n\n const types = operations.map((op) => op.type);\n assertEquals(types.includes(\"createLinearIssueAndUpdateGCal\"), true);\n assertEquals(types.includes(\"createGCalEventAndUpdateLinear\"), true);\n});\n",[],[282,316],{"_107":324,"_100":325,"_155":326,"_157":283,"_158":141,"_159":327,"_161":162,"_109":328,"_104":124,"_164":203,"_166":329,"_167":27,"_168":-5,"_169":330,"_103":331},"5673e74a-644e-11f0-9c95-0224a6c84d84","diff.ts","ec769f5e-644d-11f0-a8e7-0224a6c84d84",129,["D",1752894806565],"/**\n * Diff Engine: Converts phase transitions into minimal idempotent operations\n * Pure function that takes canonical items and produces operations to execute\n */\n\nimport {\n addPrefix,\n CanonicalItem,\n estimateToDuration,\n Operation,\n PREFIXES,\n} from \"./types.ts\";\nimport dayjs from \"npm:dayjs@1.11.10\";\n\nexport function diff(items: CanonicalItem[]): Operation[] {\n const operations: Operation[] = [];\n\n for (const item of items) {\n const ops = generateOperationsForItem(item);\n operations.push(...ops);\n }\n\n return operations;\n}\n\nfunction generateOperationsForItem(item: CanonicalItem): Operation[] {\n const operations: Operation[] = [];\n\n switch (item.phase) {\n case \"eventOnly\":\n // Transition 1: eventOnly → active\n // GCal event has no UID match in Linear\n operations.push({\n type: \"createLinearIssueAndUpdateGCal\",\n item: {\n ...item,\n linearState: \"Triage\",\n title: addPrefix(item.title, PREFIXES.TRIAGE),\n },\n reason: \"New GCal event needs Linear issue and title update\",\n });\n break;\n\n case \"linearOnly\":\n // Transition 2: linearOnly → active\n // Linear issue enters \"Scheduled\", has no GCal twin\n if (item.linearState === \"Scheduled\") {\n const startTime = item.startTime || getDefaultStartTime();\n const endTime = getDefaultEndTime(startTime, item.estimate);\n\n operations.push({\n type: \"createGCalEventAndUpdateLinear\",\n item: {\n ...item,\n title: addPrefix(item.title, PREFIXES.SCHEDULED),\n startTime,\n endTime,\n },\n reason:\n \"Scheduled Linear issue needs GCal event and metadata linking\",\n });\n }\n break;\n\n case \"active\": {\n // Transition 5: active → active (metadata sync)\n // Check if we need to sync title, description, or time changes\n const syncOps = generateMetadataSyncOperations(item);\n operations.push(...syncOps);\n break;\n }\n\n case \"completed\":\n // Transition 3: active → completed\n // Linear state becomes Done/Canceled/Failed\n if (item.gcalId && item.linearState) {\n const prefix = getCompletionPrefix(item.linearState);\n const expectedTitle = addPrefix(item.title, prefix);\n\n // Only patch if the current GCal title doesn't already have the correct prefix\n if (item.currentGCalTitle !== expectedTitle) {\n operations.push({\n type: \"patchGCalEvent\",\n item: {\n ...item,\n title: expectedTitle,\n },\n reason: `Linear issue marked as ${item.linearState}`,\n });\n }\n }\n break;\n\n case \"overdue\":\n // Transition 4: active → overdue\n // Mark original event as \"worked on\" and create new event for continued tracking\n if (item.gcalId) {\n operations.push(\n {\n type: \"patchGCalEvent\",\n item: {\n ...item,\n title: addPrefix(item.title, PREFIXES.WORKED),\n },\n reason: \"Marking original event as worked on (⏳)\",\n },\n {\n type: \"createRescheduledEvent\",\n item: {\n ...item,\n // New event should get default scheduling\n startTime: getDefaultStartTime(),\n endTime: getDefaultEndTime(getDefaultStartTime(), item.estimate),\n // Keep original prefix based on Linear state\n title: item.linearState === \"Scheduled\"\n ? addPrefix(item.title, PREFIXES.SCHEDULED)\n : item.title,\n },\n reason: \"Creating new event to continue tracking overdue item\",\n },\n );\n }\n break;\n\n default:\n // No operation needed\n break;\n }\n\n return operations;\n}\n\nfunction generateMetadataSyncOperations(item: CanonicalItem): Operation[] {\n const operations: Operation[] = [];\n\n // For active items, we may need to sync metadata between systems\n // This is a simplified version - in reality we'd need to compare\n // the current state of both systems to detect changes\n\n // Title conflicts: Linear wins (already resolved in projector)\n // Time conflicts: Calendar wins (already resolved in projector)\n // Description conflicts: newest updatedAt wins (simplified here)\n\n // For now, we'll generate sync operations based on what's missing\n if (item.linearId && !item.gcalId) {\n // Linear exists but no GCal - should create\n operations.push({\n type: \"createGCalEvent\",\n item,\n reason: \"Sync missing GCal event for Linear issue\",\n });\n }\n\n if (item.gcalId && !item.linearId) {\n // GCal exists but no Linear - should create\n operations.push({\n type: \"createLinearIssue\",\n item,\n reason: \"Sync missing Linear issue for GCal event\",\n });\n }\n\n return operations;\n}\n\nfunction getCompletionPrefix(state: string): string {\n switch (state) {\n case \"Done\":\n return PREFIXES.DONE;\n case \"Canceled\":\n return PREFIXES.CANCELED;\n case \"Failed\":\n return PREFIXES.FAILED;\n default:\n return PREFIXES.DONE; // fallback\n }\n}\n\nfunction getDefaultStartTime(): string {\n // Default to tomorrow at 9 AM\n return dayjs().add(1, \"day\").hour(9).minute(0).second(0).toISOString();\n}\n\nfunction getDefaultEndTime(startTime: string, estimate: string = \"S\"): string {\n // Use estimate-based duration instead of fixed 1 hour\n const duration = estimateToDuration(estimate as any) || 30;\n return dayjs(startTime).add(duration, \"minutes\").toISOString();\n}\n\n// Phase transition validator (for testing)\nexport function validateTransition(\n fromPhase: CanonicalItem[\"phase\"],\n toPhase: CanonicalItem[\"phase\"],\n): boolean {\n const validTransitions: Record<\n CanonicalItem[\"phase\"],\n CanonicalItem[\"phase\"][]\n > = {\n eventOnly: [\"active\"],\n linearOnly: [\"active\"],\n active: [\"active\", \"completed\", \"overdue\"],\n completed: [], // terminal state\n overdue: [\"active\"], // can be rescheduled\n };\n\n return validTransitions[fromPhase]?.includes(toPhase) ?? false;\n}\n",[],[282,325],{"_107":333,"_100":334,"_155":335,"_157":283,"_158":141,"_159":336,"_161":162,"_109":337,"_104":124,"_164":203,"_166":338,"_167":27,"_168":-5,"_169":339,"_103":340},"b2de70ec-64c9-11f0-98a9-0224a6c84d84","dry-run.ts","ec6ec7ca-644d-11f0-9a81-0224a6c84d84",145,["D",1752947790051],"/**\n * Dry Run Mode: Test with real production data without making changes\n * Fetches real data, runs sync logic, but only logs what would happen\n */\n\nimport { SyncWorker } from \"./worker.ts\";\nimport { SyncConfig, SyncResult } from \"./types.ts\";\nimport { RealGCalApiClient, RealLinearApiClient } from \"./api-clients.ts\";\nimport { validateApis, ValidationConfig } from \"../scripts/api-validator.ts\";\n\nexport interface DryRunConfig extends SyncConfig {\n // Real API credentials\n linearApiKey: string;\n linearTeamId: string;\n googleServiceAccountJson: string;\n gcalCalendarId: string;\n\n // Dry run options\n validateApiStructure: boolean;\n maxItemsToProcess: number;\n verboseLogging: boolean;\n}\n\nexport interface DryRunResult extends SyncResult {\n dryRun: true;\n validation?: {\n apiStructureValid: boolean;\n mockCompatible: boolean;\n errors: string[];\n };\n wouldExecute: {\n operations: Array<{\n type: string;\n reason: string;\n itemTitle: string;\n details: string;\n }>;\n summary: {\n createLinearIssues: number;\n createGCalEvents: number;\n updateOperations: number;\n totalChanges: number;\n };\n };\n}\n\n/**\n * Dry Run API Clients - Read real data but don't make changes\n */\nclass DryRunLinearClient extends RealLinearApiClient {\n override async createIssue(issue: any): Promise {\n console.log(\"🔍 [DRY RUN] Would create Linear issue:\");\n console.log(` Title: ${issue.title}`);\n console.log(` State: ${issue.state}`);\n console.log(` Estimate: ${issue.estimate} points`);\n console.log(` Target Date: ${issue.targetDate || \"None\"}`);\n\n // Return mock response\n return {\n id: `dry-run-linear-${Date.now()}`,\n title: issue.title,\n description: issue.description,\n state: issue.state,\n targetDate: issue.targetDate,\n estimate: issue.estimate,\n customFields: issue.customFields,\n };\n }\n\n override async updateIssue(id: string, updates: any): Promise {\n console.log(\"🔍 [DRY RUN] Would update Linear issue:\");\n console.log(` ID: ${id}`);\n console.log(` Updates:`, JSON.stringify(updates, null, 2));\n\n // Return mock response\n return {\n id,\n ...updates,\n };\n }\n}\n\nclass DryRunGCalClient extends RealGCalApiClient {\n override async createEvent(event: any): Promise {\n console.log(\"🔍 [DRY RUN] Would create Google Calendar event:\");\n console.log(` Summary: ${event.summary}`);\n console.log(` Start: ${event.start?.dateTime}`);\n console.log(` End: ${event.end?.dateTime}`);\n console.log(` Description: ${event.description || \"None\"}`);\n\n // Return mock response\n return {\n id: `dry-run-gcal-${Date.now()}`,\n summary: event.summary,\n description: event.description,\n start: event.start,\n end: event.end,\n extendedProperties: event.extendedProperties,\n status: event.status || \"confirmed\",\n };\n }\n\n override async updateEvent(id: string, updates: any): Promise {\n console.log(\"🔍 [DRY RUN] Would update Google Calendar event:\");\n console.log(` ID: ${id}`);\n console.log(` Updates:`, JSON.stringify(updates, null, 2));\n\n // Return mock response\n return {\n id,\n ...updates,\n };\n }\n\n override async copyEventToCalendar(\n eventId: string,\n targetCalendarId: string,\n ): Promise {\n console.log(\"🔍 [DRY RUN] Would copy event to history calendar:\");\n console.log(` Event ID: ${eventId}`);\n console.log(` Target Calendar: ${targetCalendarId}`);\n\n // Return mock response\n return {\n id: `dry-run-copy-${Date.now()}`,\n summary: \"Copied Event\",\n };\n }\n}\n\nexport class DryRunWorker {\n constructor(private config: DryRunConfig) {}\n\n async runDrySync(): Promise {\n console.log(\"🚀 Starting DRY RUN sync with real production data...\");\n console.log(\"📊 Configuration:\");\n console.log(` Timezone: ${this.config.timezone}`);\n console.log(` Max Items: ${this.config.maxItemsToProcess}`);\n console.log(` Validate APIs: ${this.config.validateApiStructure}`);\n\n let validation: DryRunResult[\"validation\"] | undefined;\n\n // Step 1: Validate API structure if requested\n if (this.config.validateApiStructure) {\n console.log(\"\\n🔍 Step 1: Validating API structure...\");\n\n const validationConfig: ValidationConfig = {\n linearApiKey: this.config.linearApiKey,\n linearTeamId: this.config.linearTeamId,\n googleServiceAccountJson: this.config.googleServiceAccountJson,\n gcalCalendarId: this.config.gcalCalendarId,\n };\n\n try {\n const validationResult = await validateApis(validationConfig);\n validation = {\n apiStructureValid: validationResult.success,\n mockCompatible:\n validationResult.mockValidation.linearStructureValid &&\n validationResult.mockValidation.gcalStructureValid,\n errors: validationResult.errors,\n };\n } catch (error) {\n validation = {\n apiStructureValid: false,\n mockCompatible: false,\n errors: [error instanceof Error ? error.message : String(error)],\n };\n }\n }\n\n // Step 2: Create clients (read real data, but dry-run writes)\n const realLinearClient = new RealLinearApiClient({\n apiKey: this.config.linearApiKey,\n teamId: this.config.linearTeamId,\n });\n\n const realGCalClient = new RealGCalApiClient({\n serviceAccountJson: this.config.googleServiceAccountJson,\n calendarId: this.config.gcalCalendarId,\n });\n\n const dryRunLinearClient = new DryRunLinearClient({\n apiKey: this.config.linearApiKey,\n teamId: this.config.linearTeamId,\n });\n\n const dryRunGCalClient = new DryRunGCalClient({\n serviceAccountJson: this.config.googleServiceAccountJson,\n calendarId: this.config.gcalCalendarId,\n });\n\n // Step 3: Fetch real data\n console.log(\"\\n📊 Step 2: Fetching real production data...\");\n\n const [linearIssues, gcalEvents] = await Promise.all([\n realLinearClient.getIssues(this.config.linearTeamId),\n realGCalClient.getEvents(this.config.gcalCalendarId, \"\", \"\"),\n ]);\n\n console.log(` Found ${linearIssues.length} Linear issues`);\n console.log(` Found ${gcalEvents.length} Google Calendar events`);\n\n // Limit items if configured\n const limitedLinearIssues = linearIssues.slice(\n 0,\n this.config.maxItemsToProcess,\n );\n const limitedGCalEvents = gcalEvents.slice(\n 0,\n this.config.maxItemsToProcess,\n );\n\n if (this.config.verboseLogging) {\n console.log(\"\\n📋 Sample Linear Issues:\");\n limitedLinearIssues.slice(0, 3).forEach((issue) => {\n console.log(` - ${issue.title} (${issue.state})`);\n });\n\n console.log(\"\\n📅 Sample Calendar Events:\");\n limitedGCalEvents.slice(0, 3).forEach((event) => {\n console.log(` - ${event.summary} (${event.start.dateTime})`);\n });\n }\n\n // Step 4: Run sync logic with dry-run clients\n console.log(\"\\n⚙️ Step 3: Running sync logic (DRY RUN)...\");\n\n const syncWorker = new SyncWorker(this.config, {\n linear: dryRunLinearClient,\n gcal: dryRunGCalClient,\n });\n\n const syncResult = await syncWorker.sync();\n\n // Step 5: Analyze what would happen\n const wouldExecute = this.analyzePotentialChanges(syncResult);\n\n console.log(\"\\n📊 Step 4: Analysis complete!\");\n console.log(\n ` Would execute ${wouldExecute.summary.totalChanges} total operations`,\n );\n console.log(\n ` Linear issues to create: ${wouldExecute.summary.createLinearIssues}`,\n );\n console.log(\n ` Calendar events to create: ${wouldExecute.summary.createGCalEvents}`,\n );\n console.log(\n ` Update operations: ${wouldExecute.summary.updateOperations}`,\n );\n\n return {\n ...syncResult,\n dryRun: true,\n validation,\n wouldExecute,\n };\n }\n\n private analyzePotentialChanges(\n syncResult: SyncResult,\n ): DryRunResult[\"wouldExecute\"] {\n const operations = syncResult.operationsExecuted.map((op) => ({\n type: op.type,\n reason: op.reason,\n itemTitle: op.item.title,\n details: this.formatOperationDetails(op),\n }));\n\n const summary = {\n createLinearIssues:\n operations.filter((op) => op.type === \"createLinearIssue\").length,\n createGCalEvents:\n operations.filter((op) => op.type === \"createGCalEvent\").length,\n updateOperations:\n operations.filter((op) =>\n op.type.includes(\"patch\") || op.type.includes(\"update\")\n ).length,\n totalChanges: operations.length,\n };\n\n return { operations, summary };\n }\n\n private formatOperationDetails(operation: any): string {\n switch (operation.type) {\n case \"createLinearIssue\":\n return `Create \"${operation.item.title}\" in Triage state`;\n case \"createGCalEvent\":\n return `Schedule \"${operation.item.title}\" for ${operation.item.startTime}`;\n case \"patchGCalEvent\":\n return `Update calendar event title to \"${operation.item.title}\"`;\n case \"createRescheduledEvent\":\n return `Reschedule overdue item \"${operation.item.title}\"`;\n default:\n return `Execute ${operation.type} operation`;\n }\n }\n\n printDryRunSummary(result: DryRunResult): void {\n console.log(\"\\n\" + \"=\".repeat(60));\n console.log(\"🎯 DRY RUN SUMMARY\");\n console.log(\"=\".repeat(60));\n\n if (result.validation) {\n console.log(\"\\n📋 API Validation:\");\n console.log(\n ` Structure Valid: ${\n result.validation.apiStructureValid ? \"✅\" : \"❌\"\n }`,\n );\n console.log(\n ` Mock Compatible: ${result.validation.mockCompatible ? \"✅\" : \"❌\"}`,\n );\n if (result.validation.errors.length > 0) {\n console.log(\" Errors:\", result.validation.errors.join(\", \"));\n }\n }\n\n console.log(\"\\n📊 Sync Analysis:\");\n console.log(` Items Processed: ${result.itemsProcessed}`);\n console.log(` Duration: ${result.duration}ms`);\n console.log(` Errors: ${result.errors.length}`);\n\n console.log(\"\\n🎯 Would Execute:\");\n console.log(\n ` 📥 Create Linear Issues: ${result.wouldExecute.summary.createLinearIssues}`,\n );\n console.log(\n ` 📅 Create Calendar Events: ${result.wouldExecute.summary.createGCalEvents}`,\n );\n console.log(\n ` ✏️ Update Operations: ${result.wouldExecute.summary.updateOperations}`,\n );\n console.log(\n ` 📊 Total Changes: ${result.wouldExecute.summary.totalChanges}`,\n );\n\n if (result.wouldExecute.operations.length > 0) {\n console.log(\"\\n📝 Detailed Operations:\");\n result.wouldExecute.operations.forEach((op, i) => {\n console.log(` ${i + 1}. ${op.type}: ${op.details}`);\n console.log(` Reason: ${op.reason}`);\n });\n }\n\n if (result.errors.length > 0) {\n console.log(\"\\n❌ Errors:\");\n result.errors.forEach((error) => console.log(` - ${error}`));\n }\n\n console.log(\"\\n✅ Dry run complete - no actual changes were made!\");\n }\n}\n\n/**\n * Standalone function for easy CLI usage\n */\nexport async function runDrySync(config: DryRunConfig): Promise {\n const worker = new DryRunWorker(config);\n const result = await worker.runDrySync();\n worker.printDryRunSummary(result);\n return result;\n}\n",[],[282,334],{"_107":342,"_100":343,"_155":344,"_157":283,"_158":141,"_159":345,"_161":162,"_109":346,"_104":31,"_164":203,"_166":347,"_167":27,"_168":-5,"_169":348,"_103":349},"ec9abc68-644d-11f0-b182-0224a6c84d84","metadata-parser.ts","ec9abd44-644d-11f0-b182-0224a6c84d84",115,["D",1752894629323],"/**\n * Metadata parsing utilities for extracting linking information\n * from descriptions and other text fields\n */\n\nexport interface ParsedLinearLink {\n issueId: string;\n issueKey: string;\n url: string;\n}\n\nexport interface ParsedCalendarMetadata {\n gcalId: string;\n startTime: string;\n durationMin: number;\n}\n\n/**\n * Extract Linear issue information from calendar event description\n * Looks for patterns like: \"Linear issue: https://linear.app/liamhorne/issue/LIAM-1545\"\n */\nexport function parseLinearLinkFromDescription(\n description?: string,\n): ParsedLinearLink | null {\n if (!description) return null;\n\n // Pattern: Linear issue: https://linear.app/{team}/issue/{ISSUE-KEY}\n const linearUrlPattern =\n /Linear issue:\\s*https:\\/\\/linear\\.app\\/[^\\/]+\\/issue\\/([A-Z]+-\\d+)/i;\n const match = description.match(linearUrlPattern);\n\n if (match) {\n const issueKey = match[1];\n // Extract just the ID part (the number after the dash)\n const idMatch = issueKey.match(/[A-Z]+-(\\d+)/);\n const issueId = idMatch ? idMatch[1] : issueKey;\n\n return {\n issueId,\n issueKey,\n url: match[0].replace(\"Linear issue: \", \"\").trim(),\n };\n }\n\n return null;\n}\n\n/**\n * Extract Google Calendar metadata from Linear issue description\n * Looks for patterns like: \" GoogleCalEventId:abc123 | Start:2025-07-19T00:45:00.000Z | DurMin:30\"\n */\nexport function parseCalendarMetadataFromDescription(\n description?: string,\n): ParsedCalendarMetadata | null {\n if (!description) return null;\n\n // Pattern: GoogleCalEventId:xxx | Start:xxx | DurMin:xxx\n const metadataPattern =\n /\\s*GoogleCalEventId:([^\\s|]+)\\s*\\|\\s*Start:([^\\s|]+)\\s*\\|\\s*DurMin:(\\d+)/i;\n const match = description.match(metadataPattern);\n\n if (match) {\n return {\n gcalId: match[1],\n startTime: match[2],\n durationMin: parseInt(match[3], 10),\n };\n }\n\n return null;\n}\n\n/**\n * Extract ALL Google Calendar metadata entries from Linear issue description\n * Returns array of all calendar sync metadata found\n */\nexport function parseAllCalendarMetadataFromDescription(\n description?: string,\n): ParsedCalendarMetadata[] {\n if (!description) return [];\n\n const results: ParsedCalendarMetadata[] = [];\n const metadataPattern =\n /\\s*GoogleCalEventId:([^\\s|]+)\\s*\\|\\s*Start:([^\\s|]+)\\s*\\|\\s*DurMin:(\\d+)/gi;\n\n let match;\n while ((match = metadataPattern.exec(description)) !== null) {\n results.push({\n gcalId: match[1],\n startTime: match[2],\n durationMin: parseInt(match[3], 10),\n });\n }\n\n return results;\n}\n\n/**\n * Extract Linear issue ID from various description formats\n * Handles both full URLs and simpler formats\n */\nexport function extractLinearIdFromText(text?: string): string | null {\n if (!text) return null;\n\n // Try full URL format first\n const linkInfo = parseLinearLinkFromDescription(text);\n if (linkInfo) {\n return linkInfo.issueKey;\n }\n\n // Try issue key format: LIAM-1545\n const issueKeyPattern = /([A-Z]+-\\d+)/;\n const match = text.match(issueKeyPattern);\n if (match) {\n return match[1];\n }\n\n return null;\n}\n\n/**\n * Extract Google Calendar event ID from Linear description\n */\nexport function extractGCalIdFromDescription(\n description?: string,\n): string | null {\n const metadata = parseCalendarMetadataFromDescription(description);\n return metadata?.gcalId || null;\n}\n\n/**\n * Check if a calendar event is linked to a specific Linear issue\n */\nexport function isEventLinkedToLinearIssue(\n event: { description?: string },\n issueKey: string,\n): boolean {\n const linkInfo = parseLinearLinkFromDescription(event.description);\n return linkInfo?.issueKey === issueKey;\n}\n\n/**\n * Check if a Linear issue is linked to a specific calendar event\n */\nexport function isIssueLinkedToCalendarEvent(\n issue: { description?: string },\n eventId: string,\n): boolean {\n const metadata = parseCalendarMetadataFromDescription(issue.description);\n return metadata?.gcalId === eventId;\n}\n",[],[282,343],{"_107":351,"_100":352,"_155":353,"_157":283,"_158":141,"_159":354,"_161":162,"_109":355,"_104":31,"_164":203,"_166":356,"_167":27,"_168":-5,"_169":357,"_103":358},"ec7b538c-644d-11f0-a38f-0224a6c84d84","projector.test.ts","ec7b544a-644d-11f0-a38f-0224a6c84d84",108,["D",1752894628962],"/**\n * Tests for the projector module\n */\n\nimport {\n assertEquals,\n assertExists,\n} from \"https://deno.land/std@0.220.1/assert/mod.ts\";\nimport { project } from \"./projector.ts\";\nimport { GCalEvent, LinearIssue } from \"./types.ts\";\n\nDeno.test(\"project handles empty inputs\", () => {\n const result = project({\n linearIssues: [],\n gcalEvents: [],\n now: new Date(\"2024-01-01T12:00:00Z\"),\n });\n\n assertEquals(result.items.length, 0);\n assertEquals(result.orphanedLinearIssues.length, 0);\n assertEquals(result.orphanedGCalEvents.length, 0);\n});\n\nDeno.test(\"project creates eventOnly item for orphaned GCal event\", () => {\n const gcalEvent: GCalEvent = {\n id: \"gcal-1\",\n summary: \"Meeting with client\",\n start: { dateTime: \"2024-01-01T14:00:00Z\" },\n end: { dateTime: \"2024-01-01T15:00:00Z\" },\n status: \"confirmed\",\n };\n\n const result = project({\n linearIssues: [],\n gcalEvents: [gcalEvent],\n now: new Date(\"2024-01-01T12:00:00Z\"),\n });\n\n assertEquals(result.items.length, 1);\n assertEquals(result.items[0].phase, \"eventOnly\");\n assertEquals(result.items[0].title, \"Meeting with client\");\n assertEquals(result.items[0].gcalId, \"gcal-1\");\n assertEquals(result.items[0].linearId, undefined);\n assertExists(result.items[0].uid);\n});\n\nDeno.test(\"project creates linearOnly item for orphaned Linear issue\", () => {\n const linearIssue: LinearIssue = {\n id: \"linear-1\",\n title: \"Fix bug in auth\",\n state: \"Triage\",\n };\n\n const result = project({\n linearIssues: [linearIssue],\n gcalEvents: [],\n now: new Date(\"2024-01-01T12:00:00Z\"),\n });\n\n assertEquals(result.items.length, 1);\n assertEquals(result.items[0].phase, \"linearOnly\");\n assertEquals(result.items[0].title, \"Fix bug in auth\");\n assertEquals(result.items[0].linearId, \"linear-1\");\n assertEquals(result.items[0].gcalId, undefined);\n assertExists(result.items[0].uid);\n});\n\nDeno.test(\"project creates active item for linked items\", () => {\n const uid = \"test-uid-123\";\n\n const linearIssue: LinearIssue = {\n id: \"linear-1\",\n title: \"📅\\u202FWork on presentation\",\n state: \"Scheduled\",\n description:\n \" GoogleCalEventId:gcal-1 | Start:2024-01-01T14:00:00Z | DurMin:120\",\n };\n\n const gcalEvent: GCalEvent = {\n id: \"gcal-1\",\n summary: \"📅\\u202FWork on presentation\",\n start: { dateTime: \"2024-01-01T14:00:00Z\" },\n end: { dateTime: \"2024-01-01T16:00:00Z\" },\n status: \"confirmed\",\n extendedProperties: {\n private: {\n uid: uid,\n linearIssueId: \"linear-1\",\n },\n },\n };\n\n const result = project({\n linearIssues: [linearIssue],\n gcalEvents: [gcalEvent],\n now: new Date(\"2024-01-01T12:00:00Z\"),\n });\n\n assertEquals(result.items.length, 1);\n assertEquals(result.items[0].phase, \"active\");\n assertEquals(result.items[0].title, \"Work on presentation\"); // prefix stripped\n assertEquals(result.items[0].linearId, \"linear-1\");\n assertEquals(result.items[0].gcalId, \"gcal-1\");\n assertEquals(result.items[0].uid, uid);\n});\n\nDeno.test(\"project creates completed item for done Linear issue\", () => {\n const uid = \"test-uid-123\";\n\n const linearIssue: LinearIssue = {\n id: \"linear-1\",\n title: \"✅\\u202FCompleted task\",\n state: \"Done\",\n description:\n \" GoogleCalEventId:gcal-1 | Start:2024-01-01T14:00:00Z | DurMin:120\",\n };\n\n const gcalEvent: GCalEvent = {\n id: \"gcal-1\",\n summary: \"✅\\u202FCompleted task\",\n start: { dateTime: \"2024-01-01T14:00:00Z\" },\n end: { dateTime: \"2024-01-01T16:00:00Z\" },\n status: \"confirmed\",\n extendedProperties: {\n private: {\n uid: uid,\n linearIssueId: \"linear-1\",\n },\n },\n };\n\n const result = project({\n linearIssues: [linearIssue],\n gcalEvents: [gcalEvent],\n now: new Date(\"2024-01-01T12:00:00Z\"),\n });\n\n assertEquals(result.items.length, 1);\n assertEquals(result.items[0].phase, \"completed\");\n assertEquals(result.items[0].linearState, \"Done\");\n});\n\nDeno.test(\"project creates overdue item for old events\", () => {\n const uid = \"test-uid-123\";\n\n const linearIssue: LinearIssue = {\n id: \"linear-1\",\n title: \"Old active task\",\n state: \"Scheduled\",\n description:\n \" GoogleCalEventId:gcal-1 | Start:2024-01-01T14:00:00Z | DurMin:120\",\n };\n\n const gcalEvent: GCalEvent = {\n id: \"gcal-1\",\n summary: \"Old active task\",\n start: { dateTime: \"2024-01-01T14:00:00Z\" },\n end: { dateTime: \"2024-01-01T16:00:00Z\" }, // Ended 2 days ago\n status: \"confirmed\",\n extendedProperties: {\n private: {\n uid: uid,\n linearIssueId: \"linear-1\",\n },\n },\n };\n\n const result = project({\n linearIssues: [linearIssue],\n gcalEvents: [gcalEvent],\n now: new Date(\"2024-01-03T12:00:00Z\"), // 2 days later\n });\n\n assertEquals(result.items.length, 1);\n assertEquals(result.items[0].phase, \"overdue\");\n});\n",[],[282,352],{"_107":360,"_100":361,"_155":362,"_157":283,"_158":141,"_159":363,"_161":162,"_109":364,"_104":124,"_164":203,"_166":365,"_167":27,"_168":-5,"_169":366,"_103":367},"564461aa-644e-11f0-9812-0224a6c84d84","projector.ts","ec897d22-644d-11f0-94e7-0224a6c84d84",126,["D",1752894806592],"/**\n * Projector: Converts external snapshots into canonical truth\n * This is a pure function that takes Linear issues and GCal events\n * and produces a unified view of all items with stable UIDs\n */\n\nimport {\n CanonicalItem,\n durationToEstimate,\n ESTIMATE_DURATIONS,\n GCalEvent,\n LinearEstimate,\n LinearIssue,\n Phase,\n pointsToEstimate,\n stripPrefix,\n} from \"./types.ts\";\nimport { v4 as uuidv4 } from \"npm:uuid@9.0.0\";\nimport dayjs from \"npm:dayjs@1.11.10\";\nimport {\n extractLinearIdFromText,\n parseAllCalendarMetadataFromDescription,\n parseLinearLinkFromDescription,\n} from \"./metadata-parser.ts\";\n\ninterface ProjectorInput {\n linearIssues: LinearIssue[];\n gcalEvents: GCalEvent[];\n now: Date;\n}\n\ninterface ProjectorOutput {\n items: CanonicalItem[];\n orphanedLinearIssues: LinearIssue[];\n orphanedGCalEvents: GCalEvent[];\n}\n\nexport function project(input: ProjectorInput): ProjectorOutput {\n const { linearIssues, gcalEvents, now } = input;\n const items: CanonicalItem[] = [];\n const processedLinearIds = new Set();\n const processedGCalIds = new Set();\n\n // Index Linear issues by GCal ID (parsed from description)\n const linearByGCalId = new Map();\n const linearByIssueKey = new Map();\n\n for (const issue of linearIssues) {\n // Parse ALL calendar metadata from Linear issue description\n const allCalMetadata = parseAllCalendarMetadataFromDescription(\n issue.description,\n );\n for (const calMetadata of allCalMetadata) {\n linearByGCalId.set(calMetadata.gcalId, issue);\n }\n\n // Index by issue key for reverse lookup (LIAM-1545, etc.)\n const issueKey = extractLinearIdFromText(issue.id);\n if (issueKey) {\n linearByIssueKey.set(issueKey, issue);\n }\n\n // Also try extracting from title if it contains issue key\n const titleKey = extractLinearIdFromText(issue.title);\n if (titleKey) {\n linearByIssueKey.set(titleKey, issue);\n }\n }\n\n // Index GCal events by Linear ID (from extendedProperties)\n const gcalByLinearId = new Map();\n const gcalByLinearKey = new Map();\n\n for (const event of gcalEvents) {\n // Use extendedProperties for GCal→Linear linking\n if (event.extendedProperties?.private?.linearIssueId) {\n gcalByLinearId.set(event.extendedProperties.private.linearIssueId, event);\n }\n\n // Parse Linear link from description (for backup linking)\n const linearLink = parseLinearLinkFromDescription(event.description);\n if (linearLink) {\n gcalByLinearKey.set(linearLink.issueKey, event);\n gcalByLinearId.set(linearLink.issueId, event);\n }\n }\n\n // Process paired items: GCal events linked to Linear issues via extendedProperties\n for (const [linearId, gcalEvent] of gcalByLinearId) {\n const linkedLinearIssue = linearIssues.find((i) => i.id === linearId);\n\n if (\n linkedLinearIssue && !processedLinearIds.has(linkedLinearIssue.id) &&\n !processedGCalIds.has(gcalEvent.id)\n ) {\n processedLinearIds.add(linkedLinearIssue.id);\n processedGCalIds.add(gcalEvent.id);\n\n const uid = gcalEvent.extendedProperties?.private?.uid || generateUid();\n\n const item = createCanonicalItem({\n uid,\n linearIssue: linkedLinearIssue,\n gcalEvent: gcalEvent,\n now,\n });\n\n items.push(item);\n }\n }\n\n // Process paired items: Linear issues linked to GCal events via description metadata\n for (const [gcalId, linearIssue] of linearByGCalId) {\n const linkedGCalEvent = gcalEvents.find((e) => e.id === gcalId);\n\n if (\n linkedGCalEvent && !processedLinearIds.has(linearIssue.id) &&\n !processedGCalIds.has(linkedGCalEvent.id)\n ) {\n // Calendar event exists - create paired item\n processedLinearIds.add(linearIssue.id);\n processedGCalIds.add(linkedGCalEvent.id);\n\n const uid = linkedGCalEvent.extendedProperties?.private?.uid ||\n generateUid();\n\n const item = createCanonicalItem({\n uid,\n linearIssue: linearIssue,\n gcalEvent: linkedGCalEvent,\n now,\n });\n\n items.push(item);\n } else if (!linkedGCalEvent && !processedLinearIds.has(linearIssue.id)) {\n // Calendar event was deleted but Linear issue still has metadata - treat as linearOnly\n processedLinearIds.add(linearIssue.id);\n\n const uid = generateUid();\n\n const item = createCanonicalItem({\n uid,\n linearIssue: linearIssue,\n gcalEvent: null, // No calendar event\n now,\n });\n\n items.push(item);\n }\n }\n\n // Process unpaired Linear issues\n for (const issue of linearIssues) {\n if (!processedLinearIds.has(issue.id)) {\n // Orphaned Linear issue - no GCal event links to it\n const uid = generateUid();\n const item = createCanonicalItem({\n uid,\n linearIssue: issue,\n gcalEvent: null,\n now,\n });\n\n items.push(item);\n processedLinearIds.add(issue.id);\n }\n }\n\n // Process unpaired GCal events\n for (const event of gcalEvents) {\n if (!processedGCalIds.has(event.id)) {\n // Orphaned GCal event - no Linear issue links to it\n const uid = event.extendedProperties?.private?.uid || generateUid();\n const item = createCanonicalItem({\n uid,\n linearIssue: null,\n gcalEvent: event,\n now,\n });\n\n items.push(item);\n processedGCalIds.add(event.id);\n }\n }\n\n // Collect truly orphaned items (shouldn't happen but defensive)\n const orphanedLinearIssues = linearIssues.filter((i) =>\n !processedLinearIds.has(i.id)\n );\n const orphanedGCalEvents = gcalEvents.filter((e) =>\n !processedGCalIds.has(e.id)\n );\n\n return {\n items,\n orphanedLinearIssues,\n orphanedGCalEvents,\n };\n}\n\ninterface CanonicalItemParams {\n uid: string;\n linearIssue: LinearIssue | null;\n gcalEvent: GCalEvent | null;\n now: Date;\n}\n\nfunction createCanonicalItem(params: CanonicalItemParams): CanonicalItem {\n const { uid, linearIssue, gcalEvent, now } = params;\n\n // Title: Linear wins if present, otherwise GCal\n const title = linearIssue\n ? stripPrefix(linearIssue.title)\n : gcalEvent\n ? stripPrefix(gcalEvent.summary)\n : \"Untitled\";\n\n // Description: newest updatedAt wins (not available in current types, so Linear wins)\n const description = linearIssue?.description || gcalEvent?.description;\n\n // Start/End: Calendar wins if present, handle both date and dateTime formats\n const startTime = gcalEvent?.start.dateTime || gcalEvent?.start.date ||\n linearIssue?.targetDate;\n const endTime = gcalEvent?.end.dateTime || gcalEvent?.end.date;\n\n // Duration and Estimate handling\n let durationMin: number | undefined;\n let estimate: LinearEstimate | undefined;\n\n if (gcalEvent && startTime && endTime) {\n // Calculate duration from GCal event\n durationMin = dayjs(endTime).diff(dayjs(startTime), \"minutes\");\n // Convert GCal duration to Linear estimate (don't change GCal duration)\n estimate = durationToEstimate(durationMin);\n }\n\n // If Linear has an estimate, use it (Linear wins for estimates)\n if (linearIssue?.estimate) {\n estimate = pointsToEstimate(linearIssue.estimate);\n // If no GCal duration but we have Linear estimate, use estimate duration\n if (!durationMin) {\n durationMin = ESTIMATE_DURATIONS[estimate];\n }\n }\n\n // Default to 'S' (30 min) if no estimate found\n if (!estimate) {\n estimate = \"S\";\n durationMin = durationMin || 30;\n }\n\n // Last modified: use current time as fallback\n const lastModified = dayjs(now).toISOString();\n\n // Classify phase\n const phase = classifyPhase({\n linearIssue,\n gcalEvent,\n endTime,\n now,\n });\n\n return {\n uid,\n title,\n description,\n startTime,\n endTime,\n durationMin,\n estimate,\n linearId: linearIssue?.id,\n gcalId: gcalEvent?.id,\n linearState: linearIssue?.state,\n phase,\n lastModified,\n\n // Store original titles for idempotency checks\n currentGCalTitle: gcalEvent?.summary,\n currentLinearTitle: linearIssue?.title,\n };\n}\n\ninterface PhaseClassificationParams {\n linearIssue: LinearIssue | null;\n gcalEvent: GCalEvent | null;\n _startTime?: string;\n endTime?: string;\n now: Date;\n}\n\nfunction classifyPhase(params: PhaseClassificationParams): Phase {\n const { linearIssue, gcalEvent, endTime, now } = params;\n\n // EventOnly: GCal event without Linear match\n if (gcalEvent && !linearIssue) {\n return \"eventOnly\";\n }\n\n // LinearOnly: Linear issue without GCal match\n if (linearIssue && !gcalEvent) {\n return \"linearOnly\";\n }\n\n // Both exist - check for completion\n if (linearIssue && gcalEvent) {\n // Completed: Linear state is Done/Canceled/Failed\n if ([\"Done\", \"Canceled\", \"Failed\"].includes(linearIssue.state)) {\n return \"completed\";\n }\n\n // Overdue: event ended more than 24h ago and Linear still active\n if (endTime) {\n const eventEnd = dayjs(endTime);\n const hoursAgo = dayjs(now).diff(eventEnd, \"hours\");\n if (hoursAgo > 24 && linearIssue.state !== \"Done\") {\n return \"overdue\";\n }\n }\n\n // Active: linked and syncing\n return \"active\";\n }\n\n // Default fallback\n return \"active\";\n}\n\nfunction generateUid(): string {\n return uuidv4();\n}\n",[],[282,361],{"_107":369,"_100":370,"_155":371,"_157":283,"_158":141,"_159":372,"_161":162,"_109":373,"_104":124,"_164":203,"_166":374,"_167":27,"_168":-5,"_169":375,"_103":376},"563ef224-644e-11f0-a411-0224a6c84d84","scheduler.ts","ec69fb50-644d-11f0-a8e7-0224a6c84d84",125,["D",1752894806557],"/**\n * Smart Scheduler: Finds optimal time slots for new events\n * Considers working hours, existing events, and avoids conflicts\n */\n\nimport {\n estimateToDuration,\n GCalEvent,\n LinearEstimate,\n SyncConfig,\n} from \"./types.ts\";\nimport dayjs from \"npm:dayjs@1.11.10\";\nimport timezone from \"npm:dayjs@1.11.10/plugin/timezone.js\";\nimport utc from \"npm:dayjs@1.11.10/plugin/utc.js\";\n\ndayjs.extend(utc);\ndayjs.extend(timezone);\n\nexport interface TimeSlot {\n startTime: string; // ISO datetime\n endTime: string; // ISO datetime\n}\n\nexport interface SchedulingRequest {\n estimate: LinearEstimate;\n preferredDate?: string; // ISO date, if user has preference\n title: string; // For logging/debugging\n}\n\nexport class SmartScheduler {\n constructor(private config: SyncConfig) {}\n\n /**\n * Find the next available time slot for a new event\n */\n findNextAvailableSlot(\n request: SchedulingRequest,\n existingEvents: GCalEvent[],\n ): TimeSlot {\n const durationMin = estimateToDuration(request.estimate);\n\n // Start searching from preferred date (if in future) or tomorrow\n const now = dayjs().tz(this.config.timezone);\n const tomorrow = now.add(1, \"day\");\n\n const startSearchDate = request.preferredDate\n ? dayjs(request.preferredDate).tz(this.config.timezone).isAfter(now)\n ? dayjs(request.preferredDate).tz(this.config.timezone)\n : tomorrow // Use tomorrow if preferred date is in the past\n : tomorrow;\n\n // Search up to 14 days ahead\n const maxSearchDate = startSearchDate.add(14, \"days\");\n\n let currentDate = startSearchDate.startOf(\"day\");\n\n while (currentDate.isBefore(maxSearchDate)) {\n // Skip weekends if not in working days\n if (!this.config.workingHours.workingDays.includes(currentDate.day())) {\n currentDate = currentDate.add(1, \"day\");\n continue;\n }\n\n const slot = this.findSlotOnDate(\n currentDate,\n durationMin,\n existingEvents,\n );\n if (slot) {\n console.log(`📅 Scheduled \"${request.title}\" for ${slot.startTime}`);\n return slot;\n }\n\n currentDate = currentDate.add(1, \"day\");\n }\n\n // Fallback: schedule anyway at end of search period\n const fallbackStart = maxSearchDate\n .hour(this.config.workingHours.startHour)\n .minute(0)\n .second(0);\n\n console.warn(\n `⚠️ No available slots found for \"${request.title}\", using fallback`,\n );\n\n return {\n startTime: fallbackStart.toISOString(),\n endTime: fallbackStart.add(durationMin, \"minutes\").toISOString(),\n };\n }\n\n /**\n * Find an available slot on a specific date\n */\n private findSlotOnDate(\n date: dayjs.Dayjs,\n durationMin: number,\n existingEvents: GCalEvent[],\n ): TimeSlot | null {\n const dayStart = date\n .hour(this.config.workingHours.startHour)\n .minute(0)\n .second(0);\n\n const dayEnd = date\n .hour(this.config.workingHours.endHour)\n .minute(0)\n .second(0);\n\n // Get events for this day and sort by start time\n const dayEvents = this.getEventsForDate(date, existingEvents)\n .sort((a, b) =>\n dayjs(a.start.dateTime).valueOf() - dayjs(b.start.dateTime).valueOf()\n );\n\n // Try to find a slot before the first event\n if (dayEvents.length === 0) {\n // No events, use start of day\n return {\n startTime: dayStart.toISOString(),\n endTime: dayStart.add(durationMin, \"minutes\").toISOString(),\n };\n }\n\n const firstEventStart = dayjs(dayEvents[0].start.dateTime);\n if (firstEventStart.diff(dayStart, \"minutes\") >= durationMin) {\n // Fits before first event\n return {\n startTime: dayStart.toISOString(),\n endTime: dayStart.add(durationMin, \"minutes\").toISOString(),\n };\n }\n\n // Try to find gaps between events\n for (let i = 0; i < dayEvents.length - 1; i++) {\n const currentEventEnd = dayjs(dayEvents[i].end.dateTime);\n const nextEventStart = dayjs(dayEvents[i + 1].start.dateTime);\n\n const gapMinutes = nextEventStart.diff(currentEventEnd, \"minutes\");\n if (gapMinutes >= durationMin) {\n // Found a gap that fits\n return {\n startTime: currentEventEnd.toISOString(),\n endTime: currentEventEnd.add(durationMin, \"minutes\").toISOString(),\n };\n }\n }\n\n // Try after the last event\n const lastEventEnd = dayjs(dayEvents[dayEvents.length - 1].end.dateTime);\n const remainingMinutes = dayEnd.diff(lastEventEnd, \"minutes\");\n\n if (remainingMinutes >= durationMin) {\n return {\n startTime: lastEventEnd.toISOString(),\n endTime: lastEventEnd.add(durationMin, \"minutes\").toISOString(),\n };\n }\n\n // No slot found on this day\n return null;\n }\n\n /**\n * Get all events that occur on a specific date\n */\n private getEventsForDate(\n date: dayjs.Dayjs,\n events: GCalEvent[],\n ): GCalEvent[] {\n const dateStr = date.format(\"YYYY-MM-DD\");\n\n return events.filter((event) => {\n const eventStart = dayjs(event.start.dateTime);\n const eventEnd = dayjs(event.end.dateTime);\n\n // Event overlaps with this date\n return eventStart.format(\"YYYY-MM-DD\") === dateStr ||\n eventEnd.format(\"YYYY-MM-DD\") === dateStr ||\n (eventStart.isBefore(date.startOf(\"day\")) &&\n eventEnd.isAfter(date.endOf(\"day\")));\n });\n }\n\n /**\n * Generate default time slot for immediate scheduling\n * Used as fallback when smart scheduling isn't needed\n */\n getDefaultTimeSlot(estimate: LinearEstimate = \"S\"): TimeSlot {\n const durationMin = estimateToDuration(estimate);\n\n // Tomorrow at 9 AM in configured timezone\n const startTime = dayjs()\n .tz(this.config.timezone)\n .add(1, \"day\")\n .hour(this.config.workingHours.startHour)\n .minute(0)\n .second(0);\n\n return {\n startTime: startTime.toISOString(),\n endTime: startTime.add(durationMin, \"minutes\").toISOString(),\n };\n }\n\n /**\n * Check if a time slot conflicts with existing events\n */\n hasConflict(slot: TimeSlot, existingEvents: GCalEvent[]): boolean {\n const slotStart = dayjs(slot.startTime);\n const slotEnd = dayjs(slot.endTime);\n\n return existingEvents.some((event) => {\n const eventStart = dayjs(event.start.dateTime);\n const eventEnd = dayjs(event.end.dateTime);\n\n // Check for overlap\n return slotStart.isBefore(eventEnd) && slotEnd.isAfter(eventStart);\n });\n }\n}\n",[],[282,370],{"_107":378,"_100":379,"_155":380,"_157":283,"_158":141,"_159":381,"_161":162,"_109":382,"_104":31,"_164":203,"_166":383,"_167":27,"_168":-5,"_169":384,"_103":385},"ecb0fe7e-644d-11f0-95f7-0224a6c84d84","sync.ts","ecb0ff50-644d-11f0-95f7-0224a6c84d84",118,["D",1752894629471],"/**\n * Unified sync script with --dry-run support\n * Run with: deno run --allow-env --allow-net --env-file=.env src/sync.ts [--dry-run]\n */\n\nimport { SyncWorker } from \"./worker.ts\";\nimport { SyncConfig } from \"./types.ts\";\nimport { RealGCalApiClient, RealLinearApiClient } from \"./api-clients.ts\";\nimport { DryRunConfig, runDrySync } from \"./dry-run.ts\";\n\nfunction getConfig(): SyncConfig {\n return {\n linearApiKey: Deno.env.get(\"LINEAR_API_KEY\") || \"\",\n linearTeamId: Deno.env.get(\"LINEAR_TEAM_ID\") || \"\",\n gcalCalendarId: Deno.env.get(\"GCAL_CALENDAR_ID\") || \"\",\n gcalHistoryCalendarId: Deno.env.get(\"GCAL_HISTORY_CALENDAR_ID\"),\n timezone: Deno.env.get(\"TIMEZONE\") || \"America/New_York\",\n workingHours: {\n startHour: parseInt(Deno.env.get(\"WORK_START_HOUR\") || \"9\"),\n endHour: parseInt(Deno.env.get(\"WORK_END_HOUR\") || \"17\"),\n workingDays: [1, 2, 3, 4, 5], // Monday-Friday\n },\n lookbackDays: parseInt(Deno.env.get(\"LOOKBACK_DAYS\") || \"2\"),\n lookaheadDays: parseInt(Deno.env.get(\"LOOKAHEAD_DAYS\") || \"14\"),\n };\n}\n\nfunction getDryRunConfig(): DryRunConfig {\n const baseConfig = getConfig();\n return {\n ...baseConfig,\n googleServiceAccountJson: Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\") || \"\",\n validateApiStructure: true,\n maxItemsToProcess: 50,\n verboseLogging: false,\n };\n}\n\nasync function runRealSync() {\n console.log(\"🚀 Starting Google Calendar ↔ Linear sync...\");\n\n const config = getConfig();\n\n // Validate configuration\n if (!config.linearApiKey || !config.linearTeamId) {\n console.error(\"❌ Missing required Linear API credentials\");\n console.error(\" Required: LINEAR_API_KEY, LINEAR_TEAM_ID\");\n Deno.exit(1);\n }\n\n if (!config.gcalCalendarId || !Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")) {\n console.error(\"❌ Missing required Google Calendar credentials\");\n console.error(\" Required: GCAL_CALENDAR_ID, GOOGLE_SERVICE_ACCOUNT_JSON\");\n Deno.exit(1);\n }\n\n try {\n // Create API clients\n const clients = {\n linear: new RealLinearApiClient({\n apiKey: config.linearApiKey,\n teamId: config.linearTeamId,\n }),\n gcal: new RealGCalApiClient({\n serviceAccountJson: Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")!,\n calendarId: config.gcalCalendarId,\n }),\n };\n\n // Create and run sync worker\n const worker = new SyncWorker(config, clients);\n const result = await worker.sync();\n\n // Log results\n console.log(\"✅ Sync completed successfully\");\n console.log(\n `📊 Processed ${result.itemsProcessed} items in ${result.duration}ms`,\n );\n console.log(`⚡ Executed ${result.operationsExecuted.length} operations`);\n\n if (result.operationsExecuted.length > 0) {\n console.log(\"\\n📝 Operations executed:\");\n result.operationsExecuted.forEach((op, i) => {\n console.log(` ${i + 1}. ${op.type}: ${op.reason} (${op.item.title})`);\n });\n }\n\n if (result.errors.length > 0) {\n console.warn(`\\n⚠️ ${result.errors.length} errors occurred:`);\n result.errors.forEach((error) => console.warn(` ${error}`));\n Deno.exit(1);\n }\n } catch (error) {\n console.error(\"❌ Sync failed:\", error);\n Deno.exit(1);\n }\n}\n\nasync function main() {\n const args = Deno.args;\n const isDryRun = args.includes(\"--dry-run\") || args.includes(\"-d\");\n\n if (isDryRun) {\n console.log(\"🎯 Running in DRY RUN mode - no changes will be made\\n\");\n const config = getDryRunConfig();\n const result = await runDrySync(config);\n\n if (result.errors.length === 0) {\n console.log(\"\\n🎉 Dry run completed successfully!\");\n if (result.wouldExecute.summary.totalChanges > 0) {\n console.log(\n `💡 Run without --dry-run to execute ${result.wouldExecute.summary.totalChanges} operations`,\n );\n } else {\n console.log(\"💡 No operations needed - everything is in sync!\");\n }\n } else {\n console.log(\"\\n⚠️ Dry run completed with errors - check configuration\");\n Deno.exit(1);\n }\n } else {\n await runRealSync();\n }\n}\n\n// Show usage if no environment variables are set\nfunction showUsage() {\n console.log(\"Usage:\");\n console.log(\n \" deno run --allow-env --allow-net --env-file=.env src/sync.ts # Run real sync\",\n );\n console.log(\n \" deno run --allow-env --allow-net --env-file=.env src/sync.ts --dry-run # Dry run mode\",\n );\n console.log(\"\");\n console.log(\"Environment variables required:\");\n console.log(\" LINEAR_API_KEY, LINEAR_TEAM_ID\");\n console.log(\" GOOGLE_SERVICE_ACCOUNT_JSON, GCAL_CALENDAR_ID\");\n console.log(\" GCAL_HISTORY_CALENDAR_ID (optional)\");\n}\n\n// Run if this is the main module\nif (import.meta.main) {\n // Check if help is requested\n if (Deno.args.includes(\"--help\") || Deno.args.includes(\"-h\")) {\n showUsage();\n Deno.exit(0);\n }\n\n // Check if basic environment variables are set\n if (\n !Deno.env.get(\"LINEAR_API_KEY\") &&\n !Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")\n ) {\n console.log(\"🚀 Google Calendar ↔ Linear Sync\\n\");\n console.log(\"❌ No environment variables detected\");\n console.log(\"\");\n showUsage();\n Deno.exit(1);\n }\n\n await main();\n}\n",[],[282,379],{"_107":387,"_100":388,"_155":389,"_157":283,"_158":141,"_159":390,"_161":162,"_109":391,"_104":31,"_164":203,"_166":392,"_167":27,"_168":-5,"_169":393,"_103":394},"ec8d0b86-644d-11f0-b182-0224a6c84d84","types.test.ts","ec8d0c30-644d-11f0-b182-0224a6c84d84",112,["D",1752894629157],"/**\n * Tests for types and utility functions\n */\n\nimport { assertEquals } from \"https://deno.land/std@0.220.1/assert/mod.ts\";\nimport { addPrefix, PREFIXES, stripPrefix } from \"./types.ts\";\n\nDeno.test(\"stripPrefix removes emoji prefixes correctly\", () => {\n assertEquals(stripPrefix(\"📥\\u202FMy Task\"), \"My Task\");\n assertEquals(stripPrefix(\"📅\\u202FScheduled Task\"), \"Scheduled Task\");\n assertEquals(stripPrefix(\"✅\\u202FCompleted Task\"), \"Completed Task\");\n assertEquals(stripPrefix(\"🚫\\u202FCanceled Task\"), \"Canceled Task\");\n assertEquals(stripPrefix(\"❌\\u202FFailed Task\"), \"Failed Task\");\n\n // Should handle tasks without prefixes\n assertEquals(stripPrefix(\"Plain Task\"), \"Plain Task\");\n\n // Should handle empty strings\n assertEquals(stripPrefix(\"\"), \"\");\n});\n\nDeno.test(\"addPrefix adds correct prefixes\", () => {\n assertEquals(addPrefix(\"My Task\", PREFIXES.TRIAGE), \"📥\\u202FMy Task\");\n assertEquals(addPrefix(\"My Task\", PREFIXES.SCHEDULED), \"📅\\u202FMy Task\");\n assertEquals(addPrefix(\"My Task\", PREFIXES.DONE), \"✅\\u202FMy Task\");\n assertEquals(addPrefix(\"My Task\", PREFIXES.CANCELED), \"🚫\\u202FMy Task\");\n assertEquals(addPrefix(\"My Task\", PREFIXES.FAILED), \"❌\\u202FMy Task\");\n});\n\nDeno.test(\"addPrefix strips existing prefix before adding new one\", () => {\n const taskWithPrefix = \"📥\\u202FExisting Task\";\n assertEquals(\n addPrefix(taskWithPrefix, PREFIXES.DONE),\n \"✅\\u202FExisting Task\",\n );\n});\n\n// Import additional functions for testing\nimport {\n durationToEstimate,\n estimateToDuration,\n estimateToPoints,\n pointsToEstimate,\n} from \"./types.ts\";\n\nDeno.test(\"durationToEstimate maps correctly\", () => {\n assertEquals(durationToEstimate(10), \"XS\"); // ≤22min → XS\n assertEquals(durationToEstimate(22), \"XS\");\n assertEquals(durationToEstimate(30), \"S\"); // ≤45min → S\n assertEquals(durationToEstimate(45), \"S\");\n assertEquals(durationToEstimate(60), \"M\"); // ≤90min → M\n assertEquals(durationToEstimate(90), \"M\");\n assertEquals(durationToEstimate(120), \"L\"); // ≤180min → L\n assertEquals(durationToEstimate(180), \"L\");\n assertEquals(durationToEstimate(240), \"XL\"); // >180min → XL\n assertEquals(durationToEstimate(300), \"XL\");\n});\n\nDeno.test(\"estimateToDuration maps correctly\", () => {\n assertEquals(estimateToDuration(\"XS\"), 15);\n assertEquals(estimateToDuration(\"S\"), 30);\n assertEquals(estimateToDuration(\"M\"), 60);\n assertEquals(estimateToDuration(\"L\"), 120);\n assertEquals(estimateToDuration(\"XL\"), 240);\n});\n\nDeno.test(\"pointsToEstimate maps correctly\", () => {\n assertEquals(pointsToEstimate(1), \"XS\");\n assertEquals(pointsToEstimate(2), \"S\");\n assertEquals(pointsToEstimate(3), \"M\");\n assertEquals(pointsToEstimate(5), \"L\");\n assertEquals(pointsToEstimate(8), \"XL\");\n assertEquals(pointsToEstimate(99), \"S\"); // Unknown defaults to S\n});\n\nDeno.test(\"estimateToPoints maps correctly\", () => {\n assertEquals(estimateToPoints(\"XS\"), 1);\n assertEquals(estimateToPoints(\"S\"), 2);\n assertEquals(estimateToPoints(\"M\"), 3);\n assertEquals(estimateToPoints(\"L\"), 5);\n assertEquals(estimateToPoints(\"XL\"), 8);\n});\n",[],[282,388],{"_107":396,"_100":397,"_155":398,"_157":283,"_158":141,"_159":399,"_161":162,"_109":400,"_104":31,"_164":203,"_166":401,"_167":27,"_168":-5,"_169":402,"_103":403},"ec95ea1c-644d-11f0-95f7-0224a6c84d84","types.ts","ec95eaf8-644d-11f0-95f7-0224a6c84d84",114,["D",1752894629294],"/**\n * Core data models for the sync worker based on spec\n */\n\n// Google Calendar event structure\nexport interface GCalEvent {\n id: string;\n summary: string;\n description?: string;\n start: { dateTime?: string; date?: string };\n end: { dateTime?: string; date?: string };\n extendedProperties?: {\n private?: {\n uid?: string;\n linearId?: string;\n linearIssueId?: string;\n };\n };\n status: \"confirmed\" | \"cancelled\";\n}\n\n// Linear estimate sizes\nexport type LinearEstimate = \"XS\" | \"S\" | \"M\" | \"L\" | \"XL\";\n\n// Linear issue structure\nexport interface LinearIssue {\n id: string;\n title: string;\n description?: string;\n state: \"Triage\" | \"Scheduled\" | \"Done\" | \"Canceled\" | \"Failed\";\n targetDate?: string; // ISO date-time\n estimate?: number; // Points (1=XS, 2=S, 3=M, 5=L, 8=XL)\n // Note: Linear API doesn't support custom fields - use description metadata instead\n}\n\n// Canonical item that represents unified state\nexport interface CanonicalItem {\n uid: string; // Stable identifier that links across systems\n title: string; // Without prefix\n description?: string;\n startTime?: string; // ISO date-time\n endTime?: string; // ISO date-time\n durationMin?: number; // Duration in minutes\n estimate?: LinearEstimate; // XS, S, M, L, XL\n linearId?: string;\n gcalId?: string;\n linearState?: LinearIssue[\"state\"];\n phase: Phase;\n lastModified: string; // For conflict resolution\n\n // Original titles for idempotency checks\n currentGCalTitle?: string; // Current GCal event title (with any existing prefix)\n currentLinearTitle?: string; // Current Linear issue title (with any existing prefix)\n}\n\n// Five phases as per spec\nexport type Phase =\n | \"eventOnly\" // GCal event without Linear match\n | \"linearOnly\" // Linear issue without GCal match\n | \"active\" // Linked and syncing\n | \"completed\" // Linear done/canceled/failed\n | \"overdue\"; // Past deadline but still active\n\n// Operations that can be performed\nexport interface Operation {\n type: OperationType;\n item: CanonicalItem;\n reason: string;\n}\n\nexport type OperationType =\n | \"createLinearIssue\"\n | \"createGCalEvent\"\n | \"patchGCalEvent\"\n | \"patchLinearIssue\"\n | \"copyEventToHistory\"\n | \"createRescheduledEvent\" // New operation for overdue items\n | \"createLinearIssueAndUpdateGCal\" // Combined operation for eventOnly items\n | \"createGCalEventAndUpdateLinear\" // Combined operation for linearOnly items\n | \"noop\";\n\n// Title prefixes as per spec\nexport const PREFIXES = {\n TRIAGE: \"📥\\u202F\", // Narrow no-break space\n SCHEDULED: \"📅\\u202F\",\n DONE: \"✅\\u202F\",\n CANCELED: \"🚫\\u202F\",\n FAILED: \"❌\\u202F\",\n WORKED: \"⏳\\u202F\", // For overdue items that were worked on\n} as const;\n\n// Utility to strip any prefix from title\nexport function stripPrefix(title: string): string {\n // Remove any emoji + narrow no-break space pattern\n // More comprehensive emoji range\n return title.replace(\n /^[\\u{1F300}-\\u{1F9FF}\\u{2600}-\\u{26FF}\\u{2700}-\\u{27BF}]\\u202F/u,\n \"\",\n ).trim();\n}\n\n// Utility to add prefix to title\nexport function addPrefix(title: string, prefix: string): string {\n const cleanTitle = stripPrefix(title);\n return `${prefix}${cleanTitle}`;\n}\n\n// Duration mapping for Linear estimates\nexport const ESTIMATE_DURATIONS = {\n XS: 15, // 15 minutes\n S: 30, // 30 minutes\n M: 60, // 1 hour\n L: 120, // 2 hours\n XL: 240, // 4 hours\n} as const;\n\n// Linear points to estimate mapping\nexport const POINTS_TO_ESTIMATE: Record = {\n 1: \"XS\",\n 2: \"S\",\n 3: \"M\",\n 5: \"L\",\n 8: \"XL\",\n};\n\nexport const ESTIMATE_TO_POINTS: Record = {\n XS: 1,\n S: 2,\n M: 3,\n L: 5,\n XL: 8,\n};\n\n// Convert calendar duration to closest Linear estimate\nexport function durationToEstimate(durationMin: number): LinearEstimate {\n if (durationMin <= 22) return \"XS\"; // ≤22min → XS (15min)\n if (durationMin <= 45) return \"S\"; // ≤45min → S (30min)\n if (durationMin <= 90) return \"M\"; // ≤90min → M (60min)\n if (durationMin <= 180) return \"L\"; // ≤180min → L (120min)\n return \"XL\"; // >180min → XL (240min)\n}\n\n// Convert Linear estimate to duration in minutes\nexport function estimateToDuration(estimate: LinearEstimate): number {\n return ESTIMATE_DURATIONS[estimate];\n}\n\n// Convert Linear points to estimate\nexport function pointsToEstimate(points: number): LinearEstimate {\n return POINTS_TO_ESTIMATE[points] || \"S\"; // Default to S\n}\n\n// Convert estimate to Linear points\nexport function estimateToPoints(estimate: LinearEstimate): number {\n return ESTIMATE_TO_POINTS[estimate];\n}\n\n// Working hours configuration\nexport interface WorkingHours {\n startHour: number; // 24-hour format (e.g., 9 for 9 AM)\n endHour: number; // 24-hour format (e.g., 17 for 5 PM)\n workingDays: number[]; // 0=Sunday, 1=Monday, etc. [1,2,3,4,5] for weekdays\n}\n\n// Configuration for the sync worker\nexport interface SyncConfig {\n linearApiKey: string;\n linearTeamId: string;\n gcalCalendarId: string;\n gcalHistoryCalendarId?: string; // For overdue items\n timezone: string; // e.g., \"America/New_York\" for EST\n workingHours: WorkingHours;\n lookbackDays: number;\n lookaheadDays: number;\n}\n\n// Result of a sync operation\nexport interface SyncResult {\n timestamp: string;\n itemsProcessed: number;\n operationsExecuted: Operation[];\n errors: string[];\n duration: number; // milliseconds\n}\n",[],[282,397],{"_107":405,"_100":406,"_155":407,"_157":283,"_158":141,"_159":408,"_161":162,"_109":409,"_104":31,"_164":203,"_166":410,"_167":27,"_168":-5,"_169":411,"_103":412},"eca399e6-644d-11f0-9cd5-0224a6c84d84","worker.test.ts","eca39af4-644d-11f0-9cd5-0224a6c84d84",117,["D",1752894629344],"/**\n * Integration tests for the sync worker\n */\n\nimport {\n assertEquals,\n assertExists,\n} from \"https://deno.land/std@0.220.1/assert/mod.ts\";\nimport { SyncWorker } from \"./worker.ts\";\nimport { GCalEvent, LinearIssue, SyncConfig } from \"./types.ts\";\nimport { GCalApiClient, LinearApiClient } from \"./actuator.ts\";\n\n// Mock API clients for testing\nclass MockLinearApiClient implements LinearApiClient {\n private issues: LinearIssue[] = [];\n private nextId = 1;\n\n constructor(initialIssues: LinearIssue[] = []) {\n this.issues = [...initialIssues];\n }\n\n createIssue(issue: Partial): Promise {\n const newIssue: LinearIssue = {\n id: `linear-${this.nextId++}`,\n title: issue.title || \"Untitled\",\n description: issue.description,\n state: issue.state || \"Triage\",\n targetDate: issue.targetDate,\n };\n this.issues.push(newIssue);\n return Promise.resolve(newIssue);\n }\n\n updateIssue(id: string, updates: Partial): Promise {\n const issue = this.issues.find((i) => i.id === id);\n if (!issue) throw new Error(`Issue ${id} not found`);\n\n Object.assign(issue, updates);\n return Promise.resolve(issue);\n }\n\n getIssues(_teamId: string): Promise {\n return Promise.resolve([...this.issues]);\n }\n\n getTargetedIssues(\n _teamId: string,\n referencedIds: string[],\n ): Promise {\n // Mock: return referenced issues + scheduled issues\n const referencedIssues = this.issues.filter((i) =>\n referencedIds.includes(i.id)\n );\n const scheduledIssues = this.issues.filter((i) => i.state === \"Scheduled\");\n\n // Merge, avoiding duplicates\n const seen = new Set();\n const result: LinearIssue[] = [];\n\n for (const issue of [...referencedIssues, ...scheduledIssues]) {\n if (!seen.has(issue.id)) {\n seen.add(issue.id);\n result.push(issue);\n }\n }\n\n return Promise.resolve(result);\n }\n\n // Test helper\n getIssuesSync(): LinearIssue[] {\n return [...this.issues];\n }\n}\n\nclass MockGCalApiClient implements GCalApiClient {\n private events: GCalEvent[] = [];\n private nextId = 1;\n\n constructor(initialEvents: GCalEvent[] = []) {\n this.events = [...initialEvents];\n }\n\n createEvent(event: Partial): Promise {\n const newEvent: GCalEvent = {\n id: `gcal-${this.nextId++}`,\n summary: event.summary || \"Untitled\",\n description: event.description,\n start: event.start || { dateTime: \"2024-01-01T12:00:00Z\" },\n end: event.end || { dateTime: \"2024-01-01T13:00:00Z\" },\n extendedProperties: event.extendedProperties,\n status: event.status || \"confirmed\",\n };\n this.events.push(newEvent);\n return Promise.resolve(newEvent);\n }\n\n updateEvent(id: string, updates: Partial): Promise {\n const event = this.events.find((e) => e.id === id);\n if (!event) throw new Error(`Event ${id} not found`);\n\n Object.assign(event, updates);\n return Promise.resolve(event);\n }\n\n getEvents(\n _calendarId: string,\n _timeMin: string,\n _timeMax: string,\n ): Promise {\n return Promise.resolve([...this.events]);\n }\n\n copyEventToCalendar(\n eventId: string,\n _targetCalendarId: string,\n ): Promise {\n const event = this.events.find((e) => e.id === eventId);\n if (!event) throw new Error(`Event ${eventId} not found`);\n\n return this.createEvent({\n ...event,\n id: undefined, // Will get new ID\n });\n }\n\n // Test helper\n getEventsSync(): GCalEvent[] {\n return [...this.events];\n }\n}\n\nfunction createTestConfig(): SyncConfig {\n return {\n linearApiKey: \"test-key\",\n linearTeamId: \"test-team\",\n gcalCalendarId: \"test-cal\",\n gcalHistoryCalendarId: \"test-history-cal\",\n timezone: \"America/New_York\",\n workingHours: {\n startHour: 9,\n endHour: 17,\n workingDays: [1, 2, 3, 4, 5],\n },\n lookbackDays: 2,\n lookaheadDays: 14,\n };\n}\n\nDeno.test(\"SyncWorker handles empty state correctly\", async () => {\n const config = createTestConfig();\n const linearClient = new MockLinearApiClient();\n const gcalClient = new MockGCalApiClient();\n\n const worker = new SyncWorker(config, {\n linear: linearClient,\n gcal: gcalClient,\n });\n\n const result = await worker.sync();\n\n assertEquals(result.itemsProcessed, 0);\n assertEquals(result.operationsExecuted.length, 0);\n assertEquals(result.errors.length, 0);\n assertExists(result.timestamp);\n assertEquals(typeof result.duration, \"number\");\n});\n\nDeno.test(\"SyncWorker creates Linear issue for orphaned GCal event\", async () => {\n const config = createTestConfig();\n const linearClient = new MockLinearApiClient();\n const gcalClient = new MockGCalApiClient([\n {\n id: \"gcal-1\",\n summary: \"Team meeting\",\n start: { dateTime: \"2024-01-01T14:00:00Z\" },\n end: { dateTime: \"2024-01-01T15:00:00Z\" },\n status: \"confirmed\",\n },\n ]);\n\n const worker = new SyncWorker(config, {\n linear: linearClient,\n gcal: gcalClient,\n });\n\n const result = await worker.sync();\n\n assertEquals(result.itemsProcessed, 1);\n assertEquals(result.operationsExecuted.length, 1);\n assertEquals(\n result.operationsExecuted[0].type,\n \"createLinearIssueAndUpdateGCal\",\n );\n assertEquals(result.errors.length, 0);\n\n // Verify Linear issue was created\n const issues = linearClient.getIssuesSync();\n assertEquals(issues.length, 1);\n assertEquals(issues[0].title, \"📥\\u202FTeam meeting\");\n assertEquals(issues[0].state, \"Triage\");\n // Check that calendar metadata is in description\n assertExists(issues[0].description);\n});\n\nDeno.test(\"SyncWorker creates GCal event for scheduled Linear issue\", async () => {\n const config = createTestConfig();\n const linearClient = new MockLinearApiClient([\n {\n id: \"linear-1\",\n title: \"Work on presentation\",\n state: \"Scheduled\",\n targetDate: \"2024-01-01T14:00:00Z\",\n },\n ]);\n const gcalClient = new MockGCalApiClient();\n\n const worker = new SyncWorker(config, {\n linear: linearClient,\n gcal: gcalClient,\n });\n\n const result = await worker.sync();\n\n assertEquals(result.itemsProcessed, 1);\n assertEquals(result.operationsExecuted.length, 1);\n assertEquals(\n result.operationsExecuted[0].type,\n \"createGCalEventAndUpdateLinear\",\n );\n assertEquals(result.errors.length, 0);\n\n // Verify GCal event was created\n const events = gcalClient.getEventsSync();\n assertEquals(events.length, 1);\n assertEquals(events[0].summary, \"📅\\u202FWork on presentation\");\n assertExists(events[0].extendedProperties?.private?.uid);\n});\n\nDeno.test(\"SyncWorker handles completed Linear issue\", async () => {\n const uid = \"test-uid-123\";\n\n const config = createTestConfig();\n const linearClient = new MockLinearApiClient([\n {\n id: \"linear-1\",\n title: \"✅\\u202FCompleted task\",\n state: \"Done\",\n description:\n \" GoogleCalEventId:gcal-1 | Start:2024-01-01T14:00:00Z | DurMin:60\",\n },\n ]);\n const gcalClient = new MockGCalApiClient([\n {\n id: \"gcal-1\",\n summary: \"Old task title\",\n start: { dateTime: \"2024-01-01T14:00:00Z\" },\n end: { dateTime: \"2024-01-01T15:00:00Z\" },\n status: \"confirmed\",\n extendedProperties: {\n private: {\n uid: uid,\n linearIssueId: \"linear-1\",\n },\n },\n },\n ]);\n\n const worker = new SyncWorker(config, {\n linear: linearClient,\n gcal: gcalClient,\n });\n\n const result = await worker.sync();\n\n assertEquals(result.itemsProcessed, 1);\n assertEquals(result.operationsExecuted.length, 1);\n assertEquals(result.operationsExecuted[0].type, \"patchGCalEvent\");\n assertEquals(result.errors.length, 0);\n\n // Verify GCal event was updated\n const events = gcalClient.getEventsSync();\n assertEquals(events.length, 1);\n assertEquals(events[0].summary, \"✅\\u202FCompleted task\");\n});\n\nDeno.test(\"SyncWorker handles multiple items with different phases\", async () => {\n const config = createTestConfig();\n\n // Setup initial state with various scenarios\n const linearClient = new MockLinearApiClient([\n {\n id: \"linear-1\",\n title: \"Scheduled task\",\n state: \"Scheduled\",\n targetDate: \"2024-01-01T14:00:00Z\",\n },\n {\n id: \"linear-2\",\n title: \"Completed task\",\n state: \"Done\",\n description:\n \" GoogleCalEventId:gcal-2 | Start:2024-01-01T14:00:00Z | DurMin:60\",\n },\n ]);\n\n const gcalClient = new MockGCalApiClient([\n {\n id: \"gcal-1\",\n summary: \"Orphaned meeting\",\n start: { dateTime: \"2024-01-01T16:00:00Z\" },\n end: { dateTime: \"2024-01-01T17:00:00Z\" },\n status: \"confirmed\",\n },\n {\n id: \"gcal-2\",\n summary: \"Old title for completed\",\n start: { dateTime: \"2024-01-01T18:00:00Z\" },\n end: { dateTime: \"2024-01-01T19:00:00Z\" },\n status: \"confirmed\",\n extendedProperties: {\n private: {\n uid: \"uid-2\",\n linearIssueId: \"linear-2\",\n },\n },\n },\n ]);\n\n const worker = new SyncWorker(config, {\n linear: linearClient,\n gcal: gcalClient,\n });\n\n const result = await worker.sync();\n\n assertEquals(result.itemsProcessed, 3);\n assertEquals(result.errors.length, 0);\n\n // Should have operations for:\n // 1. Create Linear for orphaned GCal\n // 2. Create GCal for scheduled Linear\n // 3. Patch GCal for completed Linear\n assertEquals(result.operationsExecuted.length, 3);\n\n const operationTypes = result.operationsExecuted.map((op) => op.type);\n assertEquals(operationTypes.includes(\"createLinearIssueAndUpdateGCal\"), true);\n assertEquals(operationTypes.includes(\"createGCalEventAndUpdateLinear\"), true);\n assertEquals(operationTypes.includes(\"patchGCalEvent\"), true);\n});\n",[],[282,406],{"_107":414,"_100":415,"_155":416,"_157":283,"_158":141,"_159":417,"_161":162,"_109":418,"_104":124,"_164":203,"_166":419,"_167":27,"_168":-5,"_169":420,"_103":421},"31cf4f38-644e-11f0-86a3-0224a6c84d84","worker.ts","ecb3a23c-644d-11f0-9cd5-0224a6c84d84",124,["D",1752894745426],"/**\n * Sync Worker: Main orchestrator implementing the DRL pattern\n * Observe → Project → Diff → Actuate → Repeat\n */\n\nimport { GCalEvent, LinearIssue, SyncConfig, SyncResult } from \"./types.ts\";\nimport { project } from \"./projector.ts\";\nimport { diff } from \"./diff.ts\";\nimport { Actuator, ApiClients } from \"./actuator.ts\";\nimport dayjs from \"npm:dayjs@1.11.10\";\n\nexport class SyncWorker {\n private actuator: Actuator;\n\n constructor(\n private config: SyncConfig,\n private clients: ApiClients,\n ) {\n this.actuator = new Actuator(clients, config);\n }\n\n /**\n * Main sync operation following DRL pattern:\n * 1. Observe: fetch current snapshots\n * 2. Project: create canonical truth\n * 3. Diff: compute required operations\n * 4. Actuate: execute operations\n */\n async sync(): Promise {\n const startTime = Date.now();\n const now = new Date();\n\n try {\n console.log(\"🔄 Starting sync operation...\");\n\n // 1. OBSERVE: Fetch current snapshots (GCal first, then targeted Linear)\n console.log(\"📊 Fetching external data...\");\n\n // Fetch GCal events first to get Linear IDs to query\n const gcalEvents = await this.fetchGCalEvents();\n\n // Extract Linear IDs referenced by GCal events\n const referencedLinearIds = gcalEvents\n .map((event) => event.extendedProperties?.private?.linearIssueId)\n .filter(Boolean) as string[];\n\n // Fetch targeted Linear issues (referenced + scheduled)\n const linearIssues = await this.fetchLinearIssues(referencedLinearIds);\n\n console.log(\n `📋 Found ${linearIssues.length} Linear issues (${referencedLinearIds.length} referenced), ${gcalEvents.length} GCal events`,\n );\n\n // 2. PROJECT: Create canonical truth\n console.log(\"🎯 Projecting canonical items...\");\n const projection = project({\n linearIssues,\n gcalEvents,\n now,\n });\n\n console.log(`📦 Created ${projection.items.length} canonical items`);\n if (projection.orphanedLinearIssues.length > 0) {\n console.warn(\n `⚠️ ${projection.orphanedLinearIssues.length} orphaned Linear issues`,\n );\n }\n if (projection.orphanedGCalEvents.length > 0) {\n console.warn(\n `⚠️ ${projection.orphanedGCalEvents.length} orphaned GCal events`,\n );\n }\n\n // 3. DIFF: Compute required operations\n console.log(\"🔍 Computing operations...\");\n const operations = diff(projection.items);\n\n console.log(`⚡ Generated ${operations.length} operations`);\n this.logOperations(operations);\n\n // 4. ACTUATE: Execute operations\n console.log(\"🚀 Executing operations...\");\n const results = await this.actuator.execute(operations);\n\n const successCount = results.filter((r) => r.success).length;\n const errorCount = results.filter((r) => !r.success).length;\n\n console.log(\n `✅ ${successCount} operations succeeded, ❌ ${errorCount} failed`,\n );\n\n // Collect errors\n const errors = results\n .filter((r) => !r.success)\n .map((r) => r.error || \"Unknown error\");\n\n const duration = Date.now() - startTime;\n\n return {\n timestamp: dayjs(now).toISOString(),\n itemsProcessed: projection.items.length,\n operationsExecuted: operations,\n errors,\n duration,\n };\n } catch (error) {\n const duration = Date.now() - startTime;\n\n return {\n timestamp: dayjs(now).toISOString(),\n itemsProcessed: 0,\n operationsExecuted: [],\n errors: [error instanceof Error ? error.message : String(error)],\n duration,\n };\n }\n }\n\n private fetchLinearIssues(\n referencedIds: string[] = [],\n ): Promise {\n return this.clients.linear.getTargetedIssues(\n this.config.linearTeamId,\n referencedIds,\n );\n }\n\n private fetchGCalEvents(): Promise {\n // Fetch last 2 days + forward 2 weeks as requested\n const timeMin = dayjs()\n .subtract(2, \"days\")\n .startOf(\"day\")\n .toISOString();\n\n const timeMax = dayjs()\n .add(14, \"days\")\n .endOf(\"day\")\n .toISOString();\n\n return this.clients.gcal.getEvents(\n this.config.gcalCalendarId,\n timeMin,\n timeMax,\n );\n }\n\n private logOperations(\n operations: typeof diff extends (...args: any[]) => infer R ? R : never,\n ): void {\n const byType = operations.reduce((acc, op) => {\n acc[op.type] = (acc[op.type] || 0) + 1;\n return acc;\n }, {} as Record);\n\n console.log(\"📋 Operations breakdown:\", byType);\n\n // Log details for debugging\n for (const op of operations) {\n console.log(` ${op.type}: ${op.reason} (${op.item.title})`);\n }\n }\n}\n",[],[282,415],[282],{"_107":424,"_100":425,"_155":426,"_157":-5,"_158":141,"_159":427,"_161":162,"_109":428,"_104":31,"_164":176,"_166":429,"_167":27,"_168":-5,"_169":430,"_103":431},"ec489fa0-644d-11f0-b11e-0224a6c84d84",".env.example","ec48a086-644d-11f0-b11e-0224a6c84d84",100,["D",1752894628739],"# Google Calendar Linear Sync Configuration\n# Copy this file to .env and fill in your values\n\n# Linear API Configuration\nLINEAR_API_KEY=lin_api_your_key_here\nLINEAR_TEAM_ID=your-team-id-here\n\n# Google Calendar API Configuration \nGOOGLE_SERVICE_ACCOUNT_JSON=base64_encoded_service_account_json_here\nGCAL_CALENDAR_ID=your_calendar_id_here\n\n# Optional: History calendar for overdue items\nGCAL_HISTORY_CALENDAR_ID=your_history_calendar_id_here",[],[425],{"_107":433,"_100":434,"_155":435,"_157":-5,"_158":141,"_159":436,"_161":162,"_109":437,"_104":31,"_164":176,"_166":438,"_167":27,"_168":-5,"_169":439,"_103":440},"ec2c9ecc-644d-11f0-b85a-0224a6c84d84",".gitignore","ec2c9f8a-644d-11f0-b85a-0224a6c84d84",94,["D",1752894628526],"# Environment files with secrets\n.env\n\n# Debug and temporary files\ndebug-*.js\ntest-*.js\n*-temp.ts\n*-temp.js\n\n# Logs\n*.log\n\n# OS files\n.DS_Store\nThumbs.db\n\n# IDE files\n.vscode/\n.idea/\n*.swp\n*.swo\n\n# Backup directories\nbackup/",[],[434],{"_107":442,"_100":443,"_155":444,"_157":-5,"_158":141,"_159":445,"_161":162,"_109":446,"_104":31,"_164":176,"_166":447,"_167":27,"_168":-5,"_169":448,"_103":449},"ec4e9d60-644d-11f0-a535-0224a6c84d84",".vtignore","ec4e9e32-644d-11f0-a535-0224a6c84d84",101,["D",1752894628792],".git\n.vscode\n.cursorrules\n.DS_Store\nnode_modules\nvendor",[],[443],{"_107":451,"_100":452,"_155":453,"_157":-5,"_158":141,"_159":454,"_161":162,"_109":455,"_104":124,"_164":176,"_166":456,"_167":27,"_168":-5,"_169":457,"_103":458},"b2d64f84-64c9-11f0-bbb5-0224a6c84d84","CLAUDE.md","ec5cc3cc-644d-11f0-a738-0224a6c84d84",144,["D",1752947790002],"# CLAUDE.md\n\nThis file provides guidance to Claude Code (claude.ai/code) when working with code in this repository.\n\n## Development Commands\n\n**Test**: `deno task test`\n**Sync**: `deno task sync`\n**Dry Run**: `deno task dry-run`\n**Check Environment**: `deno task check`\n**Validate APIs**: `deno task validate`\n**Setup Guide**: `deno task setup`\n**Format**: `deno fmt` (configured for 2-space indents, 80-char lines, semicolons)\n**Lint**: `deno lint`\n\nAvailable deno tasks:\n\n- `deno task test` - Run unit tests\n- `deno task sync` - Run real sync with production data\n- `deno task dry-run` - Run sync with real data in dry-run mode (no changes made)\n- `deno task check` - Check environment configuration\n- `deno task validate` - Validate API structure and mock compatibility\n- `deno task setup` - Show Val Town configuration guide\n\n## Architecture Overview\n\nThis is a **bidirectional sync system** between Linear issues and Google Calendar events using the **Declarative Reconciliation Loop (DRL)** pattern. The system follows a strict **Observe → Project → Diff → Actuate** cycle.\n\n### Core Components\n\n- **Worker** (`src/worker.ts`): Main orchestrator that coordinates the sync process\n- **Projector** (`src/projector.ts`): Converts external data into canonical items\n- **Diff Engine** (`src/diff.ts`): Computes operations needed to reach desired state\n- **Actuator** (`src/actuator.ts`): Executes operations against external APIs\n- **API Clients** (`src/api-clients.ts`): Handle Linear and Google Calendar API communication\n\n### DRL Pattern Implementation\n\nThe sync operates in 4 phases:\n\n1. **Observe**: Fetch current snapshots from Linear and Google Calendar APIs\n2. **Project**: Create canonical truth using deterministic, side-effect-free functions\n3. **Diff**: Compare canonical state with external reality to compute minimal operations\n4. **Actuate**: Execute idempotent API calls until external systems match canonical truth\n\n### Phase Transitions\n\nThe system recognizes 5 phases with specific transition rules:\n\n| Phase | Description | Triggers |\n| ------------ | ---------------------------------- | --------------------------- |\n| `eventOnly` | GCal event without Linear match | New calendar event created |\n| `linearOnly` | Linear issue without GCal match | Issue marked as \"Scheduled\" |\n| `active` | Linked and syncing | Both systems have records |\n| `completed` | Linear marked done/canceled/failed | State change in Linear |\n| `overdue` | Past deadline but still active | >24h after event end |\n\n### Key Technical Details\n\n- **Stateless**: No database required; all state lives in remote systems via UID linkages\n- **Metadata Format**: Bidirectional linking via `extendedProperties` (GCal) and description metadata (Linear)\n- **Val Town Platform**: Built for Val Town deployment with specific constraints\n- **Time Handling**: Uses dayjs with timezone support, 24-hour windows for state transitions\n- **Dependencies**: googleapis, graphql-request, dayjs, uuid (imported via deno.json)\n\n### Configuration Structure\n\nThe system expects environment variables:\n\n- `LINEAR_API_KEY`: Linear API token\n- `LINEAR_TEAM_ID`: Linear team identifier\n- `GOOGLE_SERVICE_ACCOUNT_JSON`: Base64-encoded Google service account JSON\n- `GCAL_CALENDAR_ID`: Primary calendar ID\n- `GCAL_HISTORY_CALENDAR_ID`: (Optional) Calendar for overdue items\n- `TIMEZONE`: Timezone for operations (default: America/New_York)\n\n### Testing\n\nAll core logic (worker, projector, diff, actuator) has comprehensive unit tests with 31 test cases total. Tests use Deno's built-in test framework with mocked API responses to ensure deterministic behavior.\n\n### File Structure\n\n```\nsrc/\n├── types.ts # Core data models and interfaces\n├── projector.ts # Observe → Project (create canonical truth)\n├── diff.ts # Project → Diff (compute operations)\n├── actuator.ts # Diff → Actuate (execute operations)\n├── worker.ts # Main sync orchestrator\n├── api-clients.ts # Linear and Google Calendar API clients\n├── main.ts # Entry point for sync execution\n├── dry-run.ts # Dry run mode for testing\n└── *.test.ts # Comprehensive test suite\n\nscripts/\n├── check.ts # Environment configuration checker\n├── validate.ts # API structure validator\n├── setup.ts # Val Town setup guide\n├── show-*.ts # Debug scripts for data inspection\n├── api-validator.ts # API structure validation\n├── val-town-config.ts # Val Town deployment helpers\n└── README.md # Script documentation\n```\n\n### Debugging and Utilities\n\n- **Development Tasks**: Use `deno task` commands for environment checks, API validation, and testing\n- **Debug Scripts**: Helper scripts in `scripts/` directory for data inspection:\n - `show-gcal.ts` - View Google Calendar events\n - `show-linear.ts` - View Linear issues\n - `show-canonical.ts` - View canonical projection\n - `show-all.ts` - Complete data flow analysis\n- **Val Town Deployment**: Use `scripts/val-town-config.ts` for deployment helpers\n",[],[452],{"_107":460,"_100":461,"_155":462,"_157":-5,"_158":141,"_159":463,"_161":162,"_109":464,"_104":31,"_164":176,"_166":465,"_167":27,"_168":-5,"_169":466,"_103":467},"b23f19ca-64c9-11f0-a379-0224a6c84d84","DIAGRAM.md","b23f1a74-64c9-11f0-a379-0224a6c84d84",135,["D",1752947788834],"# Google Calendar ↔ Linear Sync Architecture\n\nThis document visualizes the bidirectional sync system architecture using the **Declarative Reconciliation Loop (DRL)** pattern.\n\n## Main Sync Flow\n\n```mermaid\nsequenceDiagram\n participant User\n participant Worker as SyncWorker\n participant Linear as Linear API\n participant GCal as Google Calendar API\n participant Projector\n participant Diff as Diff Engine\n participant Actuator\n\n User->>Worker: deno task sync\n \n Note over Worker: 1. OBSERVE Phase\n Worker->>Linear: getIssues(teamId)\n Linear-->>Worker: LinearIssue[]\n Worker->>GCal: getEvents(calendarId, timeRange)\n GCal-->>Worker: GCalEvent[]\n \n Note over Worker: 2. PROJECT Phase\n Worker->>Projector: project(linearIssues, gcalEvents)\n Projector->>Projector: Parse metadata links\n Projector->>Projector: Classify into phases\n Projector-->>Worker: CanonicalItem[]\n \n Note over Worker: 3. DIFF Phase\n Worker->>Diff: diff(canonicalItems)\n Diff->>Diff: Analyze phase transitions\n Diff->>Diff: Generate operations\n Diff-->>Worker: Operation[]\n \n Note over Worker: 4. ACTUATE Phase\n Worker->>Actuator: execute(operations)\n \n loop For each operation\n alt Create Linear Issue\n Actuator->>Linear: createIssue()\n Linear-->>Actuator: LinearIssue\n Actuator->>GCal: updateEvent(addMetadata)\n else Create GCal Event\n Actuator->>GCal: createEvent()\n GCal-->>Actuator: GCalEvent\n Actuator->>Linear: updateIssue(addMetadata)\n else Update Status\n Actuator->>GCal: updateEvent(prefix)\n end\n end\n \n Actuator-->>Worker: SyncResult\n Worker-->>User: ✅ Sync completed\n```\n\n## Phase Transition Logic\n\n```mermaid\nstateDiagram-v2\n [*] --> eventOnly: New GCal event\n [*] --> linearOnly: New Linear issue\n \n eventOnly --> active: Create Linear issue (📥 Triage)\n linearOnly --> active: Create GCal event (📅 Scheduled)\n \n active --> completed: Linear state = Done/Canceled/Failed\n active --> overdue: >24h past event end\n active --> active: Metadata sync\n \n completed --> [*]: Update GCal prefix (✅/🚫/❌)\n overdue --> [*]: Archive with ⏳ prefix\n \n note right of eventOnly\n 📥 GCal event without\n Linear match\n end note\n \n note right of linearOnly\n 📅 Linear issue marked\n as \"Scheduled\"\n end note\n \n note right of active\n 🔄 Both systems have\n linked records\n end note\n \n note right of completed\n ✅ Linear marked as\n Done/Canceled/Failed\n end note\n \n note right of overdue\n ⏳ Past deadline but\n still tracking\n end note\n```\n\n## Data Flow Architecture\n\n```mermaid\nflowchart TD\n A[Linear Issues] --> P[Projector]\n B[Google Calendar Events] --> P\n \n P --> C1[eventOnly Items]\n P --> C2[linearOnly Items] \n P --> C3[active Items]\n P --> C4[completed Items]\n P --> C5[overdue Items]\n \n C1 --> D[Diff Engine]\n C2 --> D\n C3 --> D\n C4 --> D\n C5 --> D\n \n D --> O1[createLinearIssue]\n D --> O2[createGCalEvent]\n D --> O3[patchGCalEvent]\n D --> O4[createRescheduledEvent]\n \n O1 --> Act[Actuator]\n O2 --> Act\n O3 --> Act\n O4 --> Act\n \n Act --> LA[Linear API]\n Act --> GA[Google Calendar API]\n \n LA --> LU[📥 Issues Created/Updated]\n GA --> GU[📅 Events Created/Updated]\n \n style P fill:#e1f5fe\n style D fill:#f3e5f5\n style Act fill:#e8f5e8\n style LA fill:#fff3e0\n style GA fill:#fce4ec\n```\n\n## Metadata Linking System\n\n```mermaid\nsequenceDiagram\n participant L as Linear Issue\n participant M as Metadata Parser\n participant G as GCal Event\n \n Note over L,G: Bidirectional Linking via Metadata\n \n L->>M: description with metadata\n Note right of M:
GoogleCalEventId:abc123
Start:2025-07-19T10:00:00Z
DurMin:30\n \n G->>M: extendedProperties\n Note left of M: extendedProperties.private:
{ linearIssueId: \"issue-123\" }\n \n M->>M: Parse and validate links\n M-->>L: Linked to GCal event abc123\n M-->>G: Linked to Linear issue-123\n \n Note over L,G: Creates canonical truth for sync decisions\n```\n\n## Development Workflow\n\n```mermaid\nflowchart LR\n Dev[Developer] --> Check{deno task check}\n Check --> |✅ Valid| Validate{deno task validate}\n Check --> |❌ Missing vars| Setup[deno task setup]\n Setup --> Check\n \n Validate --> |✅ APIs work| DryRun[deno task dry-run]\n Validate --> |❌ API issues| Fix[Fix credentials]\n Fix --> Validate\n \n DryRun --> |✅ Safe| Sync[deno task sync]\n DryRun --> |❌ Issues| Debug[Check operations]\n Debug --> DryRun\n \n Sync --> |✅ Success| Monitor[Monitor results]\n Sync --> |❌ Errors| Debug\n \n style Check fill:#e3f2fd\n style Validate fill:#f3e5f5\n style DryRun fill:#e8f5e8\n style Sync fill:#fff3e0\n```\n\n## Key Design Principles\n\n- **Stateless**: No database required; all state lives in remote systems via UID linkages\n- **Deterministic**: Pure functions ensure identical inputs always produce identical outputs \n- **Idempotent**: Operations can be safely retried without side effects\n- **Minimal**: Only necessary changes are made to external systems\n- **Observable**: Clear phase classifications and operation logging for debugging",[],[461],{"_107":469,"_100":190,"_155":470,"_157":-5,"_158":141,"_159":471,"_161":162,"_109":472,"_104":473,"_164":176,"_166":474,"_167":27,"_168":-5,"_169":475,"_103":476},"b2847222-64c9-11f0-9b60-0224a6c84d84","9f866826-27cd-11f0-9c20-569c3dd06744",137,["D",1752947789360],4,"# Google Calendar ↔ Linear Sync Worker\n\nA stateless, deterministic sync worker implementing the **Declarative Reconciliation Loop (DRL)** pattern to bidirectionally sync Google Calendar events and Linear issues.\n\n## Architecture Overview\n\nThis refactored implementation follows a strict **Observe → Project → Diff → Actuate** pattern:\n\n1. **Observe**: Fetch current snapshots from Linear and Google Calendar APIs\n2. **Project**: Create a canonical truth using deterministic, side-effect-free functions\n3. **Diff**: Compare canonical state with external reality to compute minimal operations\n4. **Actuate**: Execute idempotent API calls until external systems match canonical truth\n\n### Key Design Principles\n\n- **Stateless**: No database required; all state lives in remote systems via UID linkages\n- **Deterministic**: Pure functions ensure identical inputs always produce identical outputs\n- **Idempotent**: Operations can be safely retried without side effects\n- **Minimal**: Only necessary changes are made to external systems\n\n## Core Data Models\n\n### Google Calendar Event (`GCalEvent`)\n\n```typescript\ninterface GCalEvent {\n id: string; // Primary key (never edited)\n summary: string; // Prefix + human title\n description?: string; // Freeform notes\n start: { dateTime: string }; // ISO 8601 UTC\n end: { dateTime: string }; // ISO 8601 UTC\n extendedProperties?: {\n private?: {\n uid?: string; // Canonical UID linking to Linear\n linearIssueId?: string; // Back-pointer to Linear issue\n };\n };\n status: \"confirmed\" | \"cancelled\";\n}\n```\n\n### Linear Issue (`LinearIssue`)\n\n```typescript\ninterface LinearIssue {\n id: string; // Primary key\n title: string; // Prefix + human title\n description?: string; // Long notes + calendar metadata\n state: \"Triage\" | \"Scheduled\" | \"Done\" | \"Canceled\" | \"Failed\";\n targetDate?: string; // ISO 8601 datetime\n // Note: Linear API doesn't support custom fields - use description metadata instead\n}\n```\n\n### Canonical Item (`CanonicalItem`)\n\nThe unified representation that bridges both systems:\n\n```typescript\ninterface CanonicalItem {\n uid: string; // Stable identifier across systems\n title: string; // Clean title (no prefix)\n description?: string;\n startTime?: string; // ISO 8601\n endTime?: string; // ISO 8601\n linearId?: string;\n gcalId?: string;\n linearState?: LinearIssue[\"state\"];\n phase: Phase; // Current lifecycle phase\n lastModified: string; // For conflict resolution\n}\n```\n\n## Phase Transitions\n\nThe system recognizes 5 phases with specific transition rules:\n\n| Phase | Description | Triggers |\n| ------------ | ---------------------------------- | --------------------------- |\n| `eventOnly` | GCal event without Linear match | New calendar event created |\n| `linearOnly` | Linear issue without GCal match | Issue marked as \"Scheduled\" |\n| `active` | Linked and syncing | Both systems have records |\n| `completed` | Linear marked done/canceled/failed | State change in Linear |\n| `overdue` | Past deadline but still active | >24h after event end |\n\n### Transition Actions\n\n| From → To | Trigger | Action | Result Prefix |\n| --------------------- | ----------------------------------- | ----------------------------------------------- | ------------- |\n| `eventOnly → active` | GCal event exists | Create Linear issue (Triage) | 📥 |\n| `linearOnly → active` | Linear state = \"Scheduled\" | Create GCal event | 📅 |\n| `active → completed` | Linear state = Done/Canceled/Failed | Update GCal title | ✅/🚫/❌ |\n| `active → overdue` | >24h past event end | Mark original as worked (⏳) + create new event | ⏳ + 📅 |\n\n### Prefix Meanings\n\n- **📥 Triage**: New items from Google Calendar awaiting review\n- **📅 Scheduled**: Items scheduled for specific times\n- **✅ Done**: Completed items\n- **🚫 Canceled**: Canceled items\n- **❌ Failed**: Failed items\n- **⏳ Worked**: Original events that went overdue (shows work was done)\n\n| `active → active` | Title/time/description change | Sync metadata | (unchanged) |\n\n## Bidirectional Linking\n\nThe system uses two linking mechanisms:\n\n1. **GCal → Linear**: `extendedProperties.private.linearIssueId` in calendar events\n2. **Linear → GCal**: Description metadata ` GoogleCalEventId:xyz` in Linear issues\n\nThis approach works because:\n\n- Google Calendar API supports `extendedProperties` for metadata storage\n- Linear API doesn't support custom fields, so we embed metadata in descriptions\n- Both systems preserve their metadata across updates\n\n## Conflict Resolution\n\n- **Title**: Linear wins (source of truth for task names)\n- **Start/End Times**: Calendar wins (source of truth for scheduling)\n- **Description**: Newest `updatedAt` wins (simplified to Linear in current implementation)\n\n## File Structure\n\n```\nsrc/\n├── types.ts # Core data models and interfaces\n├── projector.ts # Observe → Project (create canonical truth)\n├── diff.ts # Project → Diff (compute operations)\n├── actuator.ts # Diff → Actuate (execute operations)\n├── worker.ts # Main sync orchestrator\n├── main.ts # Entry point with configuration\n├── dry-run.ts # Dry run mode for testing\n└── *.test.ts # Comprehensive test suite\n\nscripts/\n├── check.ts # Environment configuration checker\n├── validate.ts # API structure validator\n├── setup.ts # Val Town setup guide\n├── show-*.ts # Debug scripts for data inspection\n├── api-validator.ts # API structure validation\n├── val-town-config.ts # Val Town deployment helpers\n└── README.md # Script documentation\n```\n\n## Usage\n\n### Development Tasks\n\n```bash\n# Check environment and configuration\ndeno task check\n\n# Validate API structure\ndeno task validate\n\n# Test sync logic with real data (no changes)\ndeno task dry-run\n\n# Show setup guide for Val Town\ndeno task setup\n\n# Run unit tests\ndeno task test\n```\n\n### Running Tests\n\n```bash\ndeno task test\n```\n\n### Running Sync\n\n```bash\n# Create .env file with your credentials\ncp .env.example .env\n# Edit .env with your actual API keys\n\n# Run sync\ndeno task sync\n\n# Or run with dry-run mode first\ndeno task dry-run\n```\n\n#### Environment Variables\n\nCreate a `.env` file with:\n\n```bash\nLINEAR_API_KEY=\"your-linear-api-key\"\nLINEAR_TEAM_ID=\"your-team-id\"\nGOOGLE_SERVICE_ACCOUNT_JSON=\"base64-encoded-service-account\"\nGCAL_CALENDAR_ID=\"your-calendar-id\"\n```\n\n### Debug Scripts\n\n```bash\n# View Google Calendar events\ndeno run --allow-env --allow-net scripts/show-gcal.ts\n\n# View Linear issues\ndeno run --allow-env --allow-net scripts/show-linear.ts\n\n# View canonical projection\ndeno run --allow-env --allow-net scripts/show-canonical.ts\n\n# Complete data flow analysis\ndeno run --allow-env --allow-net scripts/show-all.ts\n```\n\n### Configuration\n\nThe worker is configured via environment variables:\n\n- `LINEAR_API_KEY`: Linear API token\n- `LINEAR_TEAM_ID`: Linear team identifier\n- `GOOGLE_SERVICE_ACCOUNT_JSON`: Base64-encoded Google service account JSON\n- `GCAL_CALENDAR_ID`: Primary calendar ID\n- `GCAL_HISTORY_CALENDAR_ID`: (Optional) Calendar for overdue items\n- `TIMEZONE`: Timezone for operations (default: America/New_York)\n- `LOOKBACK_DAYS`: Days to look back (default: 2)\n- `LOOKAHEAD_DAYS`: Days to look ahead (default: 14)\n\n## Performance Characteristics\n\n- **Latency**: < 5 seconds for 10,000 items (per spec requirement)\n- **Memory**: Stateless operation, minimal memory footprint\n- **Network**: Batched API calls, efficient pagination\n- **Reliability**: Idempotent operations survive failures\n\n## Testing Strategy\n\nThe test suite covers:\n\n- **Unit tests**: Individual functions (types, projector, diff)\n- **Integration tests**: Full sync workflows with mock APIs\n- **Determinism**: Identical inputs produce identical outputs\n- **Idempotence**: Operations can be safely retried\n- **Performance**: Validates < 5s execution time\n\n## Extending the System\n\nThe DRL pattern makes it easy to:\n\n1. Add new external systems (e.g., Notion) by implementing new projectors/actuators\n2. Add new phase transitions by updating the diff engine\n3. Add new conflict resolution rules in the projector\n4. Add webhook triggers by replacing the cron scheduler\n\n## Migration from Legacy\n\nThe original implementation has been moved to `backup/` and key concepts have been preserved:\n\n- Bidirectional sync logic\n- State machine approach (now phase-based)\n- Metadata embedding for linkage\n- Prefix-based visual indicators\n\nThe new implementation is more robust, testable, and maintainable while preserving all original functionality.\n",[],[190],{"_107":478,"_100":479,"_155":480,"_157":-5,"_158":141,"_159":481,"_161":162,"_109":482,"_104":124,"_164":176,"_166":483,"_167":27,"_168":-5,"_169":484,"_103":485},"b2aa48da-64c9-11f0-8348-0224a6c84d84","deno.json","ece3dd08-644d-11f0-bbc1-0224a6c84d84",140,["D",1752947789247],"{\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/348900b8b79f4a434cab4c74b3bc8d4d2fa8ee74/cli/schemas/config-file.v1.json\",\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": true,\n \"strict\": true,\n \"types\": [\n \"https://www.val.town/types/valtown.d.ts\"\n ],\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ],\n \"noImplicitReturns\": true,\n \"noImplicitThis\": true,\n \"noUnusedLocals\": true,\n \"noUnusedParameters\": true\n },\n \"lint\": {\n \"include\": [\n \"src/**/*.ts\",\n \"scripts/**/*.ts\"\n ],\n \"rules\": {\n \"exclude\": [\n \"no-explicit-any\",\n \"require-await\"\n ],\n \"tags\": [\"recommended\"]\n }\n },\n \"node_modules_dir\": false,\n \"experimental\": {\n \"unstable-node-globals\": true,\n \"unstable-temporal\": true,\n \"unstable-worker-options\": true,\n \"unstable-sloppy-imports\": true\n },\n \"tasks\": {\n \"test\": \"deno test --allow-env --allow-net --allow-import src/*.test.ts\",\n \"sync\": \"deno run --allow-env --allow-net --env-file=.env src/sync.ts\",\n \"dry-run\": \"deno run --allow-env --allow-net --env-file=.env src/sync.ts --dry-run\",\n \"check\": \"deno run --allow-env --allow-net --env-file=.env scripts/check.ts\",\n \"validate\": \"deno run --allow-env --allow-net --env-file=.env scripts/validate.ts\",\n \"setup\": \"deno run --allow-env scripts/setup.ts\"\n },\n \"imports\": {\n \"dayjs\": \"npm:dayjs@1.11.10\",\n \"dayjs/\": \"npm:dayjs@1.11.10/\",\n \"googleapis\": \"npm:googleapis@130\",\n \"graphql-request\": \"npm:graphql-request@6\",\n \"uuid\": \"npm:uuid@9.0.0\"\n },\n \"fmt\": {\n \"useTabs\": false,\n \"lineWidth\": 80,\n \"indentWidth\": 2,\n \"semiColons\": true,\n \"singleQuote\": false,\n \"proseWrap\": \"preserve\"\n }\n}\n",[],[479],{"_107":487,"_100":488,"_155":489,"_157":-5,"_158":141,"_159":490,"_161":162,"_109":491,"_104":492,"_164":493,"_166":494,"_167":27,"_168":-5,"_169":495,"_103":496},"b2cc8fda-64c9-11f0-8eb6-0224a6c84d84","val-town-sync.cron.ts","ec40a6d8-644d-11f0-a535-0224a6c84d84",143,["D",1752947789934],2,"interval","/**\n * Google Calendar ↔ Linear Sync - Val Town Cron Job (DRL Architecture)\n * Uses the new Declarative Reconciliation Loop pattern\n * Runs every 5 minutes to keep calendars and issues in sync\n */\n\nimport { SyncWorker } from \"./src/worker.ts\";\nimport { RealGCalApiClient, RealLinearApiClient } from \"./src/api-clients.ts\";\nimport type { SyncConfig } from \"./src/types.ts\";\n\n// @cron */5 * * * *\nexport default async function syncLinearGCal() {\n console.log(\"🚀 Val Town: Google Calendar ↔ Linear sync (DRL) starting...\");\n\n const config: SyncConfig = {\n linearApiKey: Deno.env.get(\"LINEAR_API_KEY\") || \"\",\n linearTeamId: Deno.env.get(\"LINEAR_TEAM_ID\") || \"\",\n gcalCalendarId: Deno.env.get(\"GCAL_ID\") || \"\", // Using GCAL_ID to match your existing env\n gcalHistoryCalendarId: Deno.env.get(\"GCAL_HISTORY_CALENDAR_ID\"),\n timezone: \"America/New_York\", // Matching your existing config\n workingHours: {\n startHour: 9,\n endHour: 17,\n workingDays: [1, 2, 3, 4, 5], // Monday-Friday\n },\n lookbackDays: 2,\n lookaheadDays: 21, // Matching your existing 21-day window\n };\n\n // Validate configuration\n if (!config.linearApiKey || !config.linearTeamId) {\n console.error(\n \"❌ Missing Linear credentials: LINEAR_API_KEY, LINEAR_TEAM_ID\",\n );\n return;\n }\n\n if (!config.gcalCalendarId || !Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")) {\n console.error(\n \"❌ Missing Google Calendar credentials: GCAL_ID, GOOGLE_SERVICE_ACCOUNT_JSON\",\n );\n return;\n }\n\n try {\n // Create API clients\n const clients = {\n linear: new RealLinearApiClient({\n apiKey: config.linearApiKey,\n teamId: config.linearTeamId,\n }),\n gcal: new RealGCalApiClient({\n serviceAccountJson: Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")!,\n calendarId: config.gcalCalendarId,\n }),\n };\n\n // Create and run sync worker\n const worker = new SyncWorker(config, clients);\n const result = await worker.sync();\n\n // Log results in a format similar to your existing script\n const stats = {\n itemsProcessed: result.itemsProcessed,\n operationsExecuted: result.operationsExecuted.length,\n errors: result.errors.length,\n duration: `${result.duration}ms`,\n };\n\n // Operations breakdown\n const opsByType = result.operationsExecuted.reduce((acc, op) => {\n acc[op.type] = (acc[op.type] || 0) + 1;\n return acc;\n }, {} as Record);\n\n console.table([stats]);\n\n if (Object.keys(opsByType).length > 0) {\n console.log(\"📋 Operations breakdown:\");\n console.table([opsByType]);\n }\n\n if (result.operationsExecuted.length > 0) {\n console.log(\"📝 Operations executed:\");\n result.operationsExecuted.forEach((op, i) => {\n console.log(` ${i + 1}. ${op.type}: ${op.reason} (${op.item.title})`);\n });\n }\n\n if (result.errors.length > 0) {\n console.warn(`⚠️ ${result.errors.length} errors occurred:`);\n result.errors.forEach((error) => console.warn(` ${error}`));\n } else {\n console.log(\"✅ Sync completed successfully\");\n }\n } catch (error) {\n console.error(\"❌ Sync failed:\", error);\n // Don't throw in Val Town - just log and continue\n }\n}\n",[],[488],"files",[152,171,181,188,197,207,216,225,234,243,252,261,270,280,287,296,305,314,323,332,341,350,359,368,377,386,395,404,413,423,432,441,450,459,468,477,486],"counts",{"_501":31,"_502":124,"_503":31,"_504":505},"pulls","branches","forks","envVars",5,"contents",[508,511,514,517,520,523,526,529,532,535,538],{"_107":153,"_100":154,"_155":156,"_157":-5,"_158":141,"_159":160,"_161":162,"_109":509,"_104":31,"_164":165,"_166":-5,"_167":27,"_168":-5,"_103":510},["D",1752894628092],[154],{"_107":182,"_100":183,"_155":184,"_157":-5,"_158":141,"_159":185,"_161":162,"_109":512,"_104":31,"_164":165,"_166":-5,"_167":27,"_168":-5,"_103":513},["D",1752894628309],[183],{"_107":281,"_100":282,"_155":283,"_157":-5,"_158":141,"_159":284,"_161":162,"_109":515,"_104":31,"_164":165,"_166":-5,"_167":27,"_168":-5,"_103":516},["D",1752894628427],[282],{"_107":424,"_100":425,"_155":426,"_157":-5,"_158":141,"_159":427,"_161":162,"_109":518,"_104":31,"_164":176,"_166":429,"_167":27,"_168":-5,"_103":519},["D",1752894628739],[425],{"_107":433,"_100":434,"_155":435,"_157":-5,"_158":141,"_159":436,"_161":162,"_109":521,"_104":31,"_164":176,"_166":438,"_167":27,"_168":-5,"_103":522},["D",1752894628526],[434],{"_107":442,"_100":443,"_155":444,"_157":-5,"_158":141,"_159":445,"_161":162,"_109":524,"_104":31,"_164":176,"_166":447,"_167":27,"_168":-5,"_103":525},["D",1752894628792],[443],{"_107":451,"_100":452,"_155":453,"_157":-5,"_158":141,"_159":454,"_161":162,"_109":527,"_104":124,"_164":176,"_166":456,"_167":27,"_168":-5,"_103":528},["D",1752947790002],[452],{"_107":460,"_100":461,"_155":462,"_157":-5,"_158":141,"_159":463,"_161":162,"_109":530,"_104":31,"_164":176,"_166":465,"_167":27,"_168":-5,"_103":531},["D",1752947788834],[461],{"_107":469,"_100":190,"_155":470,"_157":-5,"_158":141,"_159":471,"_161":162,"_109":533,"_104":473,"_164":176,"_166":474,"_167":27,"_168":-5,"_103":534},["D",1752947789360],[190],{"_107":478,"_100":479,"_155":480,"_157":-5,"_158":141,"_159":481,"_161":162,"_109":536,"_104":124,"_164":176,"_166":483,"_167":27,"_168":-5,"_103":537},["D",1752947789247],[479],{"_107":487,"_100":488,"_155":489,"_157":-5,"_158":141,"_159":490,"_161":162,"_109":539,"_104":492,"_164":493,"_166":494,"_167":27,"_168":-5,"_103":540},["D",1752947789934],[488],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","routes/_app.x.$handle.$name.branch.$branch.history",{"_98":99,"_100":101,"_102":42,"_105":547,"_551":552,"_757":31,"_758":162},{"_107":108,"_100":101,"_109":548,"_111":-5,"_112":27,"_113":114,"_115":116,"_117":118,"_12":119,"_120":-5,"_121":27,"_122":-5,"_123":124,"_14":125,"_126":127,"_128":127,"_129":130,"_131":130,"_132":130,"_133":127,"_134":127,"_21":549,"_138":550,"_149":27},["D",1746033868658],{"_98":99,"_136":137},{"_104":140,"_100":42,"_107":141,"_142":108,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":101,"_148":99},"history",[553,558,563,573,583,592,602,607,612,617,622,627,632,637,642,647,652,657,662,667,672,677,685,695,700,707,714,719,724,729,737,748],{"_155":174,"_104":140,"_109":554,"_158":141,"_497":555},["D",1752947789103],[556],{"_107":172,"_158":141,"_155":174,"_100":173,"_166":177,"_164":176,"_104":124,"_157":156,"_109":554,"_159":140,"_168":-5,"_161":162,"_167":27,"_103":557},[154,173],{"_155":228,"_104":229,"_109":559,"_158":141,"_497":560},["D",1752947789695],[561],{"_107":226,"_158":141,"_155":228,"_100":227,"_166":231,"_164":203,"_104":124,"_157":184,"_109":559,"_159":229,"_168":-5,"_161":162,"_167":27,"_103":562},[183,227],{"_155":564,"_104":565,"_109":566,"_158":141,"_497":567},"ec85b23c-644d-11f0-8445-0224a6c84d84",150,["D",1752947790236],[568],{"_107":569,"_158":141,"_155":564,"_100":570,"_166":571,"_164":203,"_104":124,"_157":283,"_109":566,"_159":565,"_168":-5,"_161":162,"_167":162,"_103":572},"b2ffe402-64c9-11f0-829a-0224a6c84d84","cli.ts","/**\n * CLI for running validations and dry runs\n * Usage: deno run --allow-env --allow-net --allow-import src/cli.ts [command]\n */\n\nimport { validateApis } from \"./api-validator.ts\";\nimport { runDrySync } from \"./dry-run.ts\";\nimport {\n checkEnvironment,\n getValidationConfig,\n getValTownConfig,\n printValTownSetupGuide,\n} from \"./val-town-config.ts\";\n\nasync function main() {\n const args = Deno.args;\n const command = args[0] || \"help\";\n\n console.log(\"🚀 Google Calendar ↔ Linear Sync CLI\");\n console.log(\"=====================================\\n\");\n\n try {\n switch (command) {\n case \"check\":\n checkCommand();\n break;\n\n case \"validate\":\n await validateCommand();\n break;\n\n case \"dry-run\":\n await dryRunCommand();\n break;\n\n case \"setup\":\n setupCommand();\n break;\n\n case \"test\":\n await testCommand();\n break;\n\n case \"help\":\n default:\n helpCommand();\n break;\n }\n } catch (error) {\n console.error(\n \"\\n❌ Error:\",\n error instanceof Error ? error.message : String(error),\n );\n Deno.exit(1);\n }\n}\n\nfunction checkCommand() {\n console.log(\"🔍 Checking environment configuration...\\n\");\n\n const check = checkEnvironment();\n\n if (check.valid) {\n console.log(\"✅ All required environment variables are set!\");\n } else {\n console.log(\"❌ Missing required environment variables:\");\n check.missing.forEach((key) => console.log(` - ${key}`));\n console.log(\"\\nRun `deno run src/cli.ts setup` for configuration guide.\");\n return;\n }\n\n if (check.warnings.length > 0) {\n console.log(\"\\n⚠️ Warnings:\");\n check.warnings.forEach((warning) => console.log(` - ${warning}`));\n }\n\n const config = getValTownConfig();\n console.log(\"\\n📋 Current Configuration:\");\n console.log(` Timezone: ${config.timezone}`);\n console.log(\n ` Working Hours: ${config.workingHours.startHour}:00 - ${config.workingHours.endHour}:00`,\n );\n console.log(` Max Items: ${config.maxItemsToProcess}`);\n console.log(` Validate APIs: ${config.validateApiStructure}`);\n console.log(` Verbose Logging: ${config.verboseLogging}`);\n}\n\nasync function validateCommand() {\n console.log(\"🔍 Validating API structure and mock compatibility...\\n\");\n\n const config = getValidationConfig();\n const result = await validateApis(config);\n\n if (result.success) {\n console.log(\n \"\\n🎉 Validation successful! Your mock data structures are compatible with the real APIs.\",\n );\n } else {\n console.log(\"\\n⚠️ Validation issues found. Check the details above.\");\n }\n}\n\nasync function dryRunCommand() {\n console.log(\"🎯 Running dry sync with real production data...\\n\");\n\n const config = getValTownConfig();\n const result = await runDrySync(config);\n\n if (result.errors.length === 0) {\n console.log(\"\\n🎉 Dry run completed successfully!\");\n console.log(\n `Would make ${result.wouldExecute.summary.totalChanges} changes if run for real.`,\n );\n } else {\n console.log(\n \"\\n⚠️ Dry run completed with errors. Check the details above.\",\n );\n }\n}\n\nfunction setupCommand() {\n printValTownSetupGuide();\n}\n\nasync function testCommand() {\n console.log(\"🧪 Running comprehensive test suite...\\n\");\n\n console.log(\"1. Environment check...\");\n checkCommand();\n\n console.log(\"\\n2. API validation...\");\n await validateCommand();\n\n console.log(\"\\n3. Dry run...\");\n await dryRunCommand();\n\n console.log(\"\\n✅ All tests completed!\");\n}\n\nfunction helpCommand() {\n console.log(\"Available commands:\");\n console.log(\"\");\n console.log(\"📋 check - Check environment configuration\");\n console.log(\"🔍 validate - Validate API structure and mock compatibility\");\n console.log(\n \"🎯 dry-run - Run sync logic with real data (no changes made)\",\n );\n console.log(\"⚙️ setup - Show Val Town configuration guide\");\n console.log(\"🧪 test - Run all validation tests\");\n console.log(\"❓ help - Show this help message\");\n console.log(\"\");\n console.log(\"Examples:\");\n console.log(\n \" deno run --allow-env --allow-net --allow-import src/cli.ts check\",\n );\n console.log(\n \" deno run --allow-env --allow-net --allow-import src/cli.ts validate\",\n );\n console.log(\n \" deno run --allow-env --allow-net --allow-import src/cli.ts dry-run\",\n );\n console.log(\"\");\n console.log(\"Environment variables needed:\");\n console.log(\n \" LINEAR_API_KEY, LINEAR_TEAM_ID, GOOGLE_SERVICE_ACCOUNT_JSON, GCAL_CALENDAR_ID\",\n );\n console.log(\"\");\n console.log(\"For setup instructions: `deno run src/cli.ts setup`\");\n}\n\n// Run the CLI\nif (import.meta.main) {\n await main();\n}\n",[282,570],{"_155":574,"_104":575,"_109":576,"_158":141,"_497":577},"ec29a3c0-644d-11f0-9c99-0224a6c84d84",149,["D",1752947790198],[578],{"_107":579,"_158":141,"_155":574,"_100":580,"_166":581,"_164":203,"_104":124,"_157":-5,"_109":576,"_159":575,"_168":-5,"_161":162,"_167":162,"_103":582},"b2fa9006-64c9-11f0-89d3-0224a6c84d84","standalone-val-town-sync.ts","/**\n * Google Calendar ↔ Linear Sync - Standalone Val Town Version\n * Complete DRL-based sync in a single file for easy Val Town deployment\n * @cron */5 * * * *\n */\n\n// Import all dependencies (you'll need to upload the src/ files to Val Town first)\nimport { SyncWorker } from \"./src/worker.ts\";\nimport { RealGCalApiClient, RealLinearApiClient } from \"./src/api-clients.ts\";\nimport type { SyncConfig } from \"./src/types.ts\";\n\nexport default async function main() {\n console.log(\"🚀 Google Calendar ↔ Linear sync starting...\");\n \n const config: SyncConfig = {\n linearApiKey: Deno.env.get(\"LINEAR_API_KEY\") || \"\",\n linearTeamId: Deno.env.get(\"LINEAR_TEAM_ID\") || \"\",\n gcalCalendarId: Deno.env.get(\"GCAL_CALENDAR_ID\") || Deno.env.get(\"GCAL_ID\") || \"\",\n gcalHistoryCalendarId: Deno.env.get(\"GCAL_HISTORY_CALENDAR_ID\"),\n timezone: Deno.env.get(\"TIMEZONE\") || \"America/New_York\",\n workingHours: {\n startHour: parseInt(Deno.env.get(\"WORK_START_HOUR\") || \"9\"),\n endHour: parseInt(Deno.env.get(\"WORK_END_HOUR\") || \"17\"),\n workingDays: [1, 2, 3, 4, 5], // Monday-Friday\n },\n lookbackDays: parseInt(Deno.env.get(\"LOOKBACK_DAYS\") || \"2\"),\n lookaheadDays: parseInt(Deno.env.get(\"LOOKAHEAD_DAYS\") || \"21\"),\n };\n\n // Validate configuration\n if (!config.linearApiKey || !config.linearTeamId) {\n console.error(\"❌ Missing Linear credentials\");\n console.error(\" Required: LINEAR_API_KEY, LINEAR_TEAM_ID\");\n return;\n }\n\n if (!config.gcalCalendarId || !Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")) {\n console.error(\"❌ Missing Google Calendar credentials\");\n console.error(\" Required: GCAL_CALENDAR_ID (or GCAL_ID), GOOGLE_SERVICE_ACCOUNT_JSON\");\n return;\n }\n\n try {\n // Create API clients\n const clients = {\n linear: new RealLinearApiClient({\n apiKey: config.linearApiKey,\n teamId: config.linearTeamId,\n }),\n gcal: new RealGCalApiClient({\n serviceAccountJson: Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")!,\n calendarId: config.gcalCalendarId,\n }),\n };\n\n // Create and run sync worker\n const worker = new SyncWorker(config, clients);\n const result = await worker.sync();\n\n // Display results\n const stats = {\n itemsProcessed: result.itemsProcessed,\n operationsExecuted: result.operationsExecuted.length,\n errors: result.errors.length,\n duration: `${result.duration}ms`,\n };\n\n console.table([stats]);\n\n // Operations breakdown\n const opsByType = result.operationsExecuted.reduce((acc, op) => {\n acc[op.type] = (acc[op.type] || 0) + 1;\n return acc;\n }, {} as Record);\n\n if (Object.keys(opsByType).length > 0) {\n console.log(\"📋 Operations breakdown:\");\n console.table([opsByType]);\n }\n\n if (result.operationsExecuted.length > 0) {\n console.log(\"📝 Operations executed:\");\n result.operationsExecuted.forEach((op, i) => {\n console.log(` ${i + 1}. ${op.type}: ${op.reason}`);\n });\n }\n\n if (result.errors.length > 0) {\n console.warn(`⚠️ ${result.errors.length} errors occurred:`);\n result.errors.forEach((error) => console.warn(` ${error}`));\n } else {\n console.log(\"✅ Sync completed successfully\");\n }\n\n } catch (error) {\n console.error(\"❌ Sync failed:\", error);\n }\n}",[580],{"_155":584,"_104":585,"_109":586,"_158":141,"_497":587},"ebf1ea20-644d-11f0-a1f9-0224a6c84d84",148,["D",1752947790197],[588],{"_107":589,"_158":141,"_155":584,"_100":590,"_166":-5,"_164":165,"_104":124,"_157":-5,"_109":586,"_159":585,"_168":-5,"_161":162,"_167":162,"_103":591},"b2f4782e-64c9-11f0-b83d-0224a6c84d84","linear-gcal-bidirectional-sync",[590],{"_155":593,"_104":594,"_109":595,"_158":141,"_497":596},"56573b7c-644e-11f0-8f7c-0224a6c84d84",147,["D",1752947790132],[597],{"_107":598,"_158":141,"_155":593,"_100":599,"_166":600,"_164":203,"_104":124,"_157":-5,"_109":595,"_159":594,"_168":-5,"_161":162,"_167":162,"_103":601},"b2eb02d0-64c9-11f0-89d3-0224a6c84d84","test-sync.ts","/**\n * Test sync file for Val Town - minimal version to test imports\n */\n\nimport dayjs from \"npm:dayjs@1.11.10\";\nimport { v4 as uuidv4 } from \"npm:uuid@9.0.0\";\n\nexport default async function testSync() {\n console.log(\"🚀 Testing Val Town sync imports...\");\n \n try {\n // Test dayjs\n const now = dayjs();\n console.log(`✅ dayjs working: ${now.format()}`);\n \n // Test uuid \n const id = uuidv4();\n console.log(`✅ uuid working: ${id}`);\n \n console.log(\"✅ All imports working correctly!\");\n return { success: true, timestamp: now.toISOString(), testId: id };\n \n } catch (error) {\n console.error(\"❌ Import test failed:\", error);\n return { success: false, error: String(error) };\n }\n}",[599],{"_155":210,"_104":211,"_109":603,"_158":141,"_497":604},["D",1752947789229],[605],{"_107":208,"_158":141,"_155":210,"_100":209,"_166":213,"_164":203,"_104":31,"_157":184,"_109":603,"_159":211,"_168":-5,"_161":162,"_167":27,"_103":606},[183,209],{"_155":335,"_104":336,"_109":608,"_158":141,"_497":609},["D",1752947790051],[610],{"_107":333,"_158":141,"_155":335,"_100":334,"_166":338,"_164":203,"_104":124,"_157":283,"_109":608,"_159":336,"_168":-5,"_161":162,"_167":27,"_103":611},[282,334],{"_155":453,"_104":454,"_109":613,"_158":141,"_497":614},["D",1752947790002],[615],{"_107":451,"_158":141,"_155":453,"_100":452,"_166":456,"_164":176,"_104":124,"_157":-5,"_109":613,"_159":454,"_168":-5,"_161":162,"_167":27,"_103":616},[452],{"_155":489,"_104":490,"_109":618,"_158":141,"_497":619},["D",1752947789934],[620],{"_107":487,"_158":141,"_155":489,"_100":488,"_166":494,"_164":493,"_104":492,"_157":-5,"_109":618,"_159":490,"_168":-5,"_161":162,"_167":27,"_103":621},[488],{"_155":237,"_104":238,"_109":623,"_158":141,"_497":624},["D",1752947789881],[625],{"_107":235,"_158":141,"_155":237,"_100":236,"_166":240,"_164":203,"_104":124,"_157":184,"_109":623,"_159":238,"_168":-5,"_161":162,"_167":27,"_103":626},[183,236],{"_155":246,"_104":247,"_109":628,"_158":141,"_497":629},["D",1752947789762],[630],{"_107":244,"_158":141,"_155":246,"_100":245,"_166":249,"_164":203,"_104":124,"_157":184,"_109":628,"_159":247,"_168":-5,"_161":162,"_167":27,"_103":631},[183,245],{"_155":480,"_104":481,"_109":633,"_158":141,"_497":634},["D",1752947789247],[635],{"_107":478,"_158":141,"_155":480,"_100":479,"_166":483,"_164":176,"_104":124,"_157":-5,"_109":633,"_159":481,"_168":-5,"_161":162,"_167":27,"_103":636},[479],{"_155":191,"_104":192,"_109":638,"_158":141,"_497":639},["D",1752947789577],[640],{"_107":189,"_158":141,"_155":191,"_100":190,"_166":194,"_164":176,"_104":124,"_157":184,"_109":638,"_159":192,"_168":-5,"_161":162,"_167":27,"_103":641},[183,190],{"_155":255,"_104":256,"_109":643,"_158":141,"_497":644},["D",1752947789510],[645],{"_107":253,"_158":141,"_155":255,"_100":254,"_166":258,"_164":203,"_104":124,"_157":184,"_109":643,"_159":256,"_168":-5,"_161":162,"_167":27,"_103":646},[183,254],{"_155":470,"_104":471,"_109":648,"_158":141,"_497":649},["D",1752947789360],[650],{"_107":469,"_158":141,"_155":470,"_100":190,"_166":474,"_164":176,"_104":473,"_157":-5,"_109":648,"_159":471,"_168":-5,"_161":162,"_167":27,"_103":651},[190],{"_155":219,"_104":220,"_109":653,"_158":141,"_497":654},["D",1752947788920],[655],{"_107":217,"_158":141,"_155":219,"_100":218,"_166":222,"_164":203,"_104":31,"_157":184,"_109":653,"_159":220,"_168":-5,"_161":162,"_167":27,"_103":656},[183,218],{"_155":462,"_104":463,"_109":658,"_158":141,"_497":659},["D",1752947788834],[660],{"_107":460,"_158":141,"_155":462,"_100":461,"_166":465,"_164":176,"_104":31,"_157":-5,"_109":658,"_159":463,"_168":-5,"_161":162,"_167":27,"_103":661},[461],{"_155":264,"_104":265,"_109":663,"_158":141,"_497":664},["D",1752947788862],[665],{"_107":262,"_158":141,"_155":264,"_100":263,"_166":267,"_164":203,"_104":124,"_157":184,"_109":663,"_159":265,"_168":-5,"_161":162,"_167":27,"_103":666},[183,263],{"_155":273,"_104":274,"_109":668,"_158":141,"_497":669},["D",1752947788880],[670],{"_107":271,"_158":141,"_155":273,"_100":272,"_166":276,"_164":203,"_104":31,"_157":184,"_109":668,"_159":274,"_168":-5,"_161":162,"_167":27,"_103":671},[183,272],{"_155":200,"_104":201,"_109":673,"_158":141,"_497":674},["D",1752947788832],[675],{"_107":198,"_158":141,"_155":200,"_100":199,"_166":204,"_164":203,"_104":124,"_157":184,"_109":673,"_159":201,"_168":-5,"_161":162,"_167":27,"_103":676},[183,199],{"_155":489,"_104":678,"_109":679,"_158":141,"_497":680},131,["D",1752894868106],[681],{"_107":682,"_158":141,"_155":489,"_100":488,"_166":683,"_164":493,"_104":124,"_157":-5,"_109":679,"_159":678,"_168":-5,"_161":27,"_167":27,"_103":684},"7aef03c0-644e-11f0-b879-0224a6c84d84","/**\n * Google Calendar ↔ Linear Sync - Val Town Cron Job (DRL Architecture)\n * Uses the new Declarative Reconciliation Loop pattern\n * Runs every 5 minutes to keep calendars and issues in sync\n */\n\nimport { SyncWorker } from \"./src/worker.ts\";\nimport { RealGCalApiClient, RealLinearApiClient } from \"./src/api-clients.ts\";\nimport type { SyncConfig } from \"./src/types.ts\";\n\n// @cron */5 * * * *\nexport default async function syncLinearGCal() {\n console.log(\"🚀 Val Town: Google Calendar ↔ Linear sync (DRL) starting...\");\n \n const config: SyncConfig = {\n linearApiKey: Deno.env.get(\"LINEAR_API_KEY\") || \"\",\n linearTeamId: Deno.env.get(\"LINEAR_TEAM_ID\") || \"\",\n gcalCalendarId: Deno.env.get(\"GCAL_ID\") || \"\", // Using GCAL_ID to match your existing env\n gcalHistoryCalendarId: Deno.env.get(\"GCAL_HISTORY_CALENDAR_ID\"),\n timezone: \"America/New_York\", // Matching your existing config\n workingHours: {\n startHour: 9,\n endHour: 17,\n workingDays: [1, 2, 3, 4, 5], // Monday-Friday\n },\n lookbackDays: 2,\n lookaheadDays: 21, // Matching your existing 21-day window\n };\n\n // Validate configuration\n if (!config.linearApiKey || !config.linearTeamId) {\n console.error(\"❌ Missing Linear credentials: LINEAR_API_KEY, LINEAR_TEAM_ID\");\n return;\n }\n\n if (!config.gcalCalendarId || !Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")) {\n console.error(\"❌ Missing Google Calendar credentials: GCAL_ID, GOOGLE_SERVICE_ACCOUNT_JSON\");\n return;\n }\n\n try {\n // Create API clients\n const clients = {\n linear: new RealLinearApiClient({\n apiKey: config.linearApiKey,\n teamId: config.linearTeamId,\n }),\n gcal: new RealGCalApiClient({\n serviceAccountJson: Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")!,\n calendarId: config.gcalCalendarId,\n }),\n };\n\n // Create and run sync worker\n const worker = new SyncWorker(config, clients);\n const result = await worker.sync();\n\n // Log results in a format similar to your existing script\n const stats = {\n itemsProcessed: result.itemsProcessed,\n operationsExecuted: result.operationsExecuted.length,\n errors: result.errors.length,\n duration: `${result.duration}ms`,\n };\n\n // Operations breakdown\n const opsByType = result.operationsExecuted.reduce((acc, op) => {\n acc[op.type] = (acc[op.type] || 0) + 1;\n return acc;\n }, {} as Record);\n\n console.table([stats]);\n \n if (Object.keys(opsByType).length > 0) {\n console.log(\"📋 Operations breakdown:\");\n console.table([opsByType]);\n }\n\n if (result.operationsExecuted.length > 0) {\n console.log(\"📝 Operations executed:\");\n result.operationsExecuted.forEach((op, i) => {\n console.log(` ${i + 1}. ${op.type}: ${op.reason} (${op.item.title})`);\n });\n }\n\n if (result.errors.length > 0) {\n console.warn(`⚠️ ${result.errors.length} errors occurred:`);\n result.errors.forEach((error) => console.warn(` ${error}`));\n } else {\n console.log(\"✅ Sync completed successfully\");\n }\n\n } catch (error) {\n console.error(\"❌ Sync failed:\", error);\n // Don't throw in Val Town - just log and continue\n }\n}",[488],{"_155":686,"_104":687,"_109":688,"_158":141,"_497":689},"564ac522-644e-11f0-b06b-0224a6c84d84",130,["D",1752894825358],[690],{"_107":691,"_158":141,"_155":686,"_100":692,"_166":693,"_164":493,"_104":124,"_157":-5,"_109":688,"_159":687,"_168":-5,"_161":162,"_167":162,"_103":694},"6173e672-644e-11f0-8acd-0224a6c84d84","main-sync.cron.ts","/**\n * Google Calendar ↔ Linear Sync - Val Town Cron Job (Fixed Imports)\n * @cron */5 * * * *\n */\n\nimport { SyncWorker } from \"./src/worker.ts\";\nimport { RealGCalApiClient, RealLinearApiClient } from \"./src/api-clients.ts\";\nimport type { SyncConfig } from \"./src/types.ts\";\n\nexport default async function syncLinearGCal() {\n console.log(\"🚀 Google Calendar ↔ Linear sync starting...\");\n \n const config: SyncConfig = {\n linearApiKey: Deno.env.get(\"LINEAR_API_KEY\") || \"\",\n linearTeamId: Deno.env.get(\"LINEAR_TEAM_ID\") || \"\",\n gcalCalendarId: Deno.env.get(\"GCAL_CALENDAR_ID\") || Deno.env.get(\"GCAL_ID\") || \"\",\n gcalHistoryCalendarId: Deno.env.get(\"GCAL_HISTORY_CALENDAR_ID\"),\n timezone: Deno.env.get(\"TIMEZONE\") || \"America/New_York\",\n workingHours: {\n startHour: parseInt(Deno.env.get(\"WORK_START_HOUR\") || \"9\"),\n endHour: parseInt(Deno.env.get(\"WORK_END_HOUR\") || \"17\"),\n workingDays: [1, 2, 3, 4, 5], // Monday-Friday\n },\n lookbackDays: parseInt(Deno.env.get(\"LOOKBACK_DAYS\") || \"2\"),\n lookaheadDays: parseInt(Deno.env.get(\"LOOKAHEAD_DAYS\") || \"21\"),\n };\n\n // Validate configuration\n if (!config.linearApiKey || !config.linearTeamId) {\n console.error(\"❌ Missing Linear credentials: LINEAR_API_KEY, LINEAR_TEAM_ID\");\n return;\n }\n\n if (!config.gcalCalendarId || !Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")) {\n console.error(\"❌ Missing Google Calendar credentials: GCAL_CALENDAR_ID (or GCAL_ID), GOOGLE_SERVICE_ACCOUNT_JSON\");\n return;\n }\n\n try {\n // Create API clients\n const clients = {\n linear: new RealLinearApiClient({\n apiKey: config.linearApiKey,\n teamId: config.linearTeamId,\n }),\n gcal: new RealGCalApiClient({\n serviceAccountJson: Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")!,\n calendarId: config.gcalCalendarId,\n }),\n };\n\n // Create and run sync worker\n const worker = new SyncWorker(config, clients);\n const result = await worker.sync();\n\n // Display results in console.table format like the original\n const stats = {\n itemsProcessed: result.itemsProcessed,\n operationsExecuted: result.operationsExecuted.length,\n errors: result.errors.length,\n duration: `${result.duration}ms`,\n };\n\n console.table([stats]);\n\n // Operations breakdown\n const opsByType = result.operationsExecuted.reduce((acc, op) => {\n acc[op.type] = (acc[op.type] || 0) + 1;\n return acc;\n }, {} as Record);\n\n if (Object.keys(opsByType).length > 0) {\n console.log(\"📋 Operations breakdown:\");\n console.table([opsByType]);\n }\n\n if (result.operationsExecuted.length > 0) {\n console.log(\"📝 Operations executed:\");\n result.operationsExecuted.forEach((op, i) => {\n console.log(` ${i + 1}. ${op.type}: ${op.reason}`);\n });\n }\n\n if (result.errors.length > 0) {\n console.warn(`⚠️ ${result.errors.length} errors occurred:`);\n result.errors.forEach((error) => console.warn(` ${error}`));\n } else {\n console.log(\"✅ Sync completed successfully\");\n }\n\n } catch (error) {\n console.error(\"❌ Sync failed:\", error);\n // Don't throw in Val Town - just log the error\n }\n}",[692],{"_155":326,"_104":327,"_109":696,"_158":141,"_497":697},["D",1752894806565],[698],{"_107":324,"_158":141,"_155":326,"_100":325,"_166":329,"_164":203,"_104":124,"_157":283,"_109":696,"_159":327,"_168":-5,"_161":162,"_167":27,"_103":699},[282,325],{"_155":593,"_104":701,"_109":702,"_158":141,"_497":703},128,["D",1752894806562],[704],{"_107":705,"_158":141,"_155":593,"_100":599,"_166":600,"_164":203,"_104":31,"_157":-5,"_109":702,"_159":701,"_168":-5,"_161":27,"_167":27,"_103":706},"56573ae6-644e-11f0-8f7c-0224a6c84d84",[599],{"_155":686,"_104":708,"_109":709,"_158":141,"_497":710},127,["D",1752894806560],[711],{"_107":712,"_158":141,"_155":686,"_100":692,"_166":693,"_164":493,"_104":31,"_157":-5,"_109":709,"_159":708,"_168":-5,"_161":27,"_167":27,"_103":713},"564ac45a-644e-11f0-b06b-0224a6c84d84",[692],{"_155":362,"_104":363,"_109":715,"_158":141,"_497":716},["D",1752894806592],[717],{"_107":360,"_158":141,"_155":362,"_100":361,"_166":365,"_164":203,"_104":124,"_157":283,"_109":715,"_159":363,"_168":-5,"_161":162,"_167":27,"_103":718},[282,361],{"_155":371,"_104":372,"_109":720,"_158":141,"_497":721},["D",1752894806557],[722],{"_107":369,"_158":141,"_155":371,"_100":370,"_166":374,"_164":203,"_104":124,"_157":283,"_109":720,"_159":372,"_168":-5,"_161":162,"_167":27,"_103":723},[282,370],{"_155":416,"_104":417,"_109":725,"_158":141,"_497":726},["D",1752894745426],[727],{"_107":414,"_158":141,"_155":416,"_100":415,"_166":419,"_164":203,"_104":124,"_157":283,"_109":725,"_159":417,"_168":-5,"_161":162,"_167":27,"_103":728},[282,415],{"_155":480,"_104":730,"_109":731,"_158":141,"_497":732},123,["D",1752894628526],[733],{"_107":734,"_158":141,"_155":480,"_100":479,"_166":735,"_164":176,"_104":31,"_157":-5,"_109":731,"_159":730,"_168":-5,"_161":27,"_167":27,"_103":736},"ece3dc22-644d-11f0-bbc1-0224a6c84d84","{\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/348900b8b79f4a434cab4c74b3bc8d4d2fa8ee74/cli/schemas/config-file.v1.json\",\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": true,\n \"strict\": true,\n \"types\": [\n \"https://www.val.town/types/valtown.d.ts\"\n ],\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ],\n \"noImplicitReturns\": true,\n \"noImplicitThis\": true,\n \"noUnusedLocals\": true,\n \"noUnusedParameters\": true\n },\n \"lint\": {\n \"include\": [\n \"src/**/*.ts\"\n ],\n \"rules\": {\n \"exclude\": [\n \"no-explicit-any\",\n \"require-await\"\n ],\n \"tags\": [\"recommended\"]\n }\n },\n \"node_modules_dir\": false,\n \"experimental\": {\n \"unstable-node-globals\": true,\n \"unstable-temporal\": true,\n \"unstable-worker-options\": true,\n \"unstable-sloppy-imports\": true\n },\n \"tasks\": {\n \"test\": \"deno test --allow-env --allow-net --allow-import src/*.test.ts\",\n \"sync\": \"deno run --allow-env --allow-net --allow-import --env-file=.env src/sync.ts\",\n \"cli\": \"deno run --allow-env --allow-net --allow-import src/cli.ts\",\n \"check\": \"deno run --allow-env --allow-net --allow-import src/cli.ts check\",\n \"validate\": \"deno run --allow-env --allow-net --allow-import src/cli.ts validate\",\n \"dry-run\": \"deno run --allow-env --allow-net --allow-import src/cli.ts dry-run\",\n \"setup-guide\": \"deno run --allow-env src/cli.ts setup\"\n },\n \"imports\": {\n \"dayjs\": \"npm:dayjs@1.11.10\",\n \"dayjs/\": \"npm:dayjs@1.11.10/\",\n \"googleapis\": \"npm:googleapis@130\",\n \"graphql-request\": \"npm:graphql-request@6\",\n \"uuid\": \"npm:uuid@9.0.0\"\n },\n \"fmt\": {\n \"useTabs\": false,\n \"lineWidth\": 80,\n \"indentWidth\": 2,\n \"semiColons\": true,\n \"singleQuote\": false,\n \"proseWrap\": \"preserve\"\n }\n}\n",[479],{"_155":738,"_104":739,"_109":740,"_158":141,"_497":741},"05c5b80e-25e8-11f0-b042-569c3dd06744",122,["D",1752894629554],[742],{"_107":743,"_158":141,"_155":738,"_100":744,"_166":745,"_164":493,"_104":746,"_157":-5,"_109":740,"_159":739,"_168":-5,"_161":162,"_167":162,"_103":747},"ecbff5f0-644d-11f0-a38f-0224a6c84d84","main.ts","/***********************************************************************\n * Linear ↔︎ Google Calendar two‑way sync (Val Town)\n * – Keeps exactly one active yellow event per Linear issue (plus one grey historic)\n * – Dedups Calendar events by issueId & metadata\n * – Adds missing events, reschedules overdue, updates prefixes/metadata\n * – JSON log lines + console.table stats\n ***********************************************************************/\n\nimport dayjs from \"npm:dayjs@1.11.10\";\nimport isSameOrAfter from \"npm:dayjs@1.11.10/plugin/isSameOrAfter.js\";\nimport timezone from \"npm:dayjs@1.11.10/plugin/timezone.js\";\nimport utc from \"npm:dayjs@1.11.10/plugin/utc.js\";\nimport { google } from \"npm:googleapis@130\";\nimport { gql, GraphQLClient } from \"npm:graphql-request@6\";\n\ndayjs.extend(utc);\ndayjs.extend(timezone);\ndayjs.extend(isSameOrAfter);\n\n/*──────────────── CONFIG ────────────────*/\nconst PREFIX: Record = {\n Done: \"✅ \",\n Todo: \"☑️ \",\n Scheduled: \"📅 \",\n \"In Progress\": \"🟡 \",\n Waiting: \"⌛ \",\n Triage: \"📥 \",\n Backlog: \"📋 \",\n Failed: \"❌ \",\n Canceled: \"🚫 \",\n};\nconst FALLBACK_PREFIX = \"☑️ \";\nconst PREFIX_RE = /^(?:✅ |☑️ |📅 |⌛ |🟡 |📥 |📋 |❌ |🚫 )/;\n\nconst ENV = {\n tz: \"America/New_York\",\n linear: Deno.env.get(\"LINEAR_API_KEY\")!,\n gcalId: Deno.env.get(\"GCAL_ID\")!,\n gCreds: JSON.parse(Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")!),\n};\n\n/*──────────────── LOGGER ────────────────*/\ntype LogT =\n | \"START\"\n | \"FETCH\"\n | \"DEDUP\"\n | \"RECON\"\n | \"PROMOTE\"\n | \"RESCHED\"\n | \"ADD\"\n | \"EDIT\"\n | \"DONE\";\nfunction log(type: LogT, msg: string, details: Record = {}) {\n console.log(\n JSON.stringify(\n { ts: new Date().toISOString(), type, msg, ...details },\n null,\n 2,\n ),\n );\n}\n\n/*──────────────── STATS ────────────────*/\nconst stats = {\n issuesTracked: 0,\n eventsSeen: 0,\n adds: 0,\n edits: 0,\n reschedules: 0,\n apiCalls: 0,\n};\nfunction bump(k: keyof typeof stats, n = 1) {\n stats[k] += n;\n}\nfunction counted(p: Promise) {\n bump(\"apiCalls\");\n return p;\n}\n\n/*──────────────── CLIENTS ────────────────*/\nconst linear = new GraphQLClient(\"https://api.linear.app/graphql\", {\n headers: { Authorization: ENV.linear },\n});\nconst calendar = google.calendar({\n version: \"v3\",\n auth: new google.auth.JWT(\n ENV.gCreds.client_email,\n undefined,\n ENV.gCreds.private_key,\n [\"https://www.googleapis.com/auth/calendar\"],\n ),\n});\n\n/*──────────────── HELPERS ────────────────*/\nconst metaLine = (s: string, d: number, id = \"\") =>\n ` GoogleCalEventId:${id} | Start:${s} | DurMin:${d}`;\nconst insertMeta = (d: string, l: string) =>\n //.test(d)\n ? d.replace(/.*$/m, l)\n : `${d}\\n\\n${l}`;\nconst stripLinear = (d: string) => d.replace(/^Linear issue: .*$/gm, \"\").trim();\nconst ensureLink = (d: string, u: string) => {\n const c = stripLinear(d);\n return c.includes(`Linear issue: ${u}`)\n ? c\n : `${c}\\n\\nLinear issue: ${u}`.trim();\n};\nconst getStartISO = (e: gapi.client.calendar.Event) =>\n dayjs(e.start!.dateTime || e.start!.date).toISOString();\nconst durationMin = (e: gapi.client.calendar.Event) =>\n dayjs(e.end!.dateTime || e.end!.date).diff(\n dayjs(e.start!.dateTime || e.start!.date),\n \"minute\",\n );\nconst prefixFor = (s: string) => PREFIX[s] ?? FALLBACK_PREFIX;\nconst addPrefix = (t: string, p: string) => p + t.replace(PREFIX_RE, \"\");\nconst estFromDur = (\n m: number,\n) => (m <= 15 ? 1 : m === 30 ? 2 : m < 180 ? 3 : 4);\nconst todayISODate = () => dayjs().tz(ENV.tz).format(\"YYYY-MM-DD\");\nconst metaKey = (d?: string) =>\n d?.match(/Start:[^|]+\\|\\s*DurMin:\\d+/)?.[0].replace(/\\s+/g, \"\") ?? null;\nconst linearId = (e: gapi.client.calendar.Event) =>\n e.extendedProperties?.[\"private\"]?.linearIssueId as string | undefined;\n\n/*──────────────── DEDUPLICATION ────────────────*/\nasync function deduplicateEvents(events: gapi.client.calendar.Event[]) {\n const before = events.length;\n const todayStart = dayjs().tz(ENV.tz).startOf(\"day\");\n const keep = new Set();\n\n /* group by Linear issueId */\n const byIssue: Record = {};\n for (const ev of events) {\n const id = linearId(ev);\n if (id) (byIssue[id] ??= []).push(ev);\n }\n for (const arr of Object.values(byIssue)) {\n if (arr.length === 1) {\n keep.add(arr[0].id!);\n continue;\n }\n arr.sort((a, b) =>\n dayjs(getStartISO(a)).valueOf() - dayjs(getStartISO(b)).valueOf()\n );\n const future = arr.find((e) =>\n dayjs(getStartISO(e)).isSameOrAfter(todayStart)\n ) ?? arr[0];\n const past = arr.find((e) => dayjs(getStartISO(e)).isBefore(todayStart));\n if (future) keep.add(future.id!);\n if (past) keep.add(past.id!);\n }\n\n /* group by calendar‑sync metadata signature */\n const byMeta: Record = {};\n for (const ev of events) {\n const key = metaKey(ev.description);\n if (key) (byMeta[key] ??= []).push(ev);\n }\n for (const arr of Object.values(byMeta)) {\n if (arr.length > 1) keep.add(arr[0].id!); // keep first, drop duplicates\n }\n\n /* keep any event that is \"new\" (no Linear link *and* no meta line) */\n for (const ev of events) {\n if (!linearId(ev) && !metaKey(ev.description)) keep.add(ev.id!);\n }\n\n const result: gapi.client.calendar.Event[] = [];\n for (const ev of events) {\n if (keep.has(ev.id!)) {\n result.push(ev);\n continue;\n }\n await counted(\n calendar.events.delete({ calendarId: ENV.gcalId, eventId: ev.id! }),\n );\n bump(\"edits\");\n log(\"EDIT\", \"removed duplicate calendar event\", {\n event: ev.summary,\n eventId: ev.id,\n });\n }\n log(\"DEDUP\", \"deduplicated events\", { before, after: result.length });\n return result;\n}\n\n/*──────────────── RECONCILE ────────────────*/\nasync function reconcileIssueEvent(issue: any, ev: gapi.client.calendar.Event) {\n log(\"RECON\", \"reconciling issue & event\", {\n issueId: issue.id,\n eventId: ev.id,\n });\n const evStart = getStartISO(ev),\n evDur = durationMin(ev);\n const m = (issue.description ?? \"\").match(\n /Start:([^|]+)\\s*\\|\\s*DurMin:(\\d+)/,\n );\n const recStart = m?.[1].trim() ?? \"\",\n recDur = m ? parseInt(m[2]) : evDur;\n const sameInstant = (a: string, b: string) =>\n dayjs(a).millisecond(0).valueOf() === dayjs(b).millisecond(0).valueOf();\n const dupLink = (txt: string) =>\n (txt.match(new RegExp(`Linear issue: ${issue.url}`, \"g\")) ?? []).length > 1;\n\n const needsDesc = dupLink(ev.description ?? \"\") ||\n !sameInstant(evStart, recStart) ||\n evDur !== recDur;\n const needsSum =\n !(ev.summary?.startsWith(prefixFor(issue.state.name)) ?? false);\n if (!needsDesc && !needsSum) return;\n\n const newMeta = metaLine(evStart, evDur, ev.id!);\n const newIssueDesc = insertMeta(\n ensureLink(issue.description ?? \"\", issue.url),\n newMeta,\n );\n const newEventDesc = insertMeta(\n ensureLink(ev.description ?? \"\", issue.url),\n newMeta,\n );\n const newSummary = needsSum\n ? addPrefix(issue.title, prefixFor(issue.state.name))\n : undefined;\n\n if (needsDesc) {\n await counted(\n linear.request(\n gql`mutation($id:String!,$d:String!,$e:Int!){issueUpdate(id:$id,input:{description:$d,estimate:$e}){success}}`,\n { id: issue.id, d: newIssueDesc, e: estFromDur(evDur) },\n ),\n );\n }\n await counted(\n calendar.events.patch({\n calendarId: ENV.gcalId,\n eventId: ev.id!,\n requestBody: {\n description: needsDesc ? newEventDesc : undefined,\n summary: newSummary,\n },\n }),\n );\n bump(\"edits\");\n}\n\n/*──────────────── ORCHESTRATOR ────────────────*/\n// @cron */5 * * * *\nexport default async function syncLinearGCal() {\n log(\"START\", \"sync begin\");\n const today = dayjs().tz(ENV.tz);\n const base = today.hour(12).minute(0).second(0).millisecond(0);\n\n /*──────── fetch triage workflow state ───────*/\n const { workflowStates } = await counted(\n linear.request(\n gql`query{workflowStates(filter:{name:{eq:\"Triage\"}},first:1){nodes{id team{id}}}}`,\n ),\n );\n const triage = workflowStates.nodes[0];\n\n /*──────── fetch calendar events ───────*/\n const listResp = await counted(\n calendar.events.list({\n calendarId: ENV.gcalId,\n timeMin: today.subtract(2, \"day\").startOf(\"day\").toISOString(),\n timeMax: today.add(21, \"day\").endOf(\"day\").toISOString(),\n singleEvents: true,\n showDeleted: false,\n maxResults: 2500,\n }),\n );\n let events = listResp.data.items ?? [];\n log(\"FETCH\", \"fetched calendar events\", { count: events.length });\n\n /*──────── deduplicate ───────*/\n events = await deduplicateEvents(events);\n stats.eventsSeen = events.length;\n\n const linked = events.filter((e) => linearId(e));\n const yellow = events.filter((e) =>\n !linearId(e) &&\n dayjs(getStartISO(e)).tz(ENV.tz).isSameOrAfter(\n today.subtract(1, \"day\").startOf(\"day\"),\n )\n );\n const linkedIds = linked.map((e) => linearId(e)!);\n\n /*──────── fetch Linear issues ───────*/\n const { issues } = await counted(\n linear.request(\n gql`query($ids:[ID!]){issues(filter:{or:[{id:{in:$ids}}, {state:{name:{eq:\"Scheduled\"}}, completedAt:{null:true}}]},first:250){nodes{id title description estimate url state{name}}}}`,\n { ids: linkedIds.length ? linkedIds : [] },\n ),\n );\n log(\"FETCH\", \"fetched Linear issues\", { count: issues.nodes.length });\n stats.issuesTracked = issues.nodes.length;\n\n const issueById = Object.fromEntries(issues.nodes.map((i) => [i.id, i]));\n const eventByIssue = Object.fromEntries(linked.map((e) => [linearId(e)!, e]));\n\n let slot =\n events.filter((e) =>\n dayjs(getStartISO(e)).tz(ENV.tz).isSame(base) ||\n dayjs(getStartISO(e)).tz(ENV.tz).isAfter(base)\n ).length;\n\n /*──────── promote yellow events ───────*/\n if (triage) {\n log(\"PROMOTE\", \"scanning for new yellow events\");\n const due = todayISODate();\n for (const ev of yellow) {\n const dur = durationMin(ev);\n const clean = ev.summary\n ? ev.summary.replace(PREFIX_RE, \"\")\n : \"Calendar Event\";\n const body = `${stripLinear(ev.description ?? \"\")}\n\nGoogle Calendar link: ${ev.htmlLink}`;\n const { issueCreate } = await counted(\n linear.request(\n gql`mutation($in:IssueCreateInput!){issueCreate(input:$in){issue{id url state{name}}}}`,\n {\n in: {\n title: clean,\n description: body,\n teamId: triage.team.id,\n stateId: triage.id,\n estimate: estFromDur(dur),\n dueDate: due,\n priority: 2,\n },\n },\n ),\n );\n const issue = issueCreate.issue;\n await counted(\n calendar.events.patch({\n calendarId: ENV.gcalId,\n eventId: ev.id!,\n requestBody: {\n summary: addPrefix(clean, prefixFor(issue.state.name)),\n extendedProperties: { \"private\": { linearIssueId: issue.id } },\n },\n }),\n );\n log(\"PROMOTE\", \"promoted yellow event\", {\n eventId: ev.id,\n issueId: issue.id,\n });\n issueById[issue.id] = issue;\n eventByIssue[issue.id] = ev;\n bump(\"adds\");\n }\n }\n\n /*──────── reschedule overdue ───────*/\n for (const ev of linked) {\n const issue = issueById[linearId(ev)!];\n if (!issue) continue;\n if ([\"Done\", \"Failed\", \"Canceled\"].includes(issue.state.name)) continue;\n if (dayjs(getStartISO(ev)).tz(ENV.tz).isBefore(today.startOf(\"day\"))) {\n const dur = durationMin(ev);\n const newStart = base.add(slot * 30, \"minute\").toISOString();\n slot++;\n await counted(\n calendar.events.patch({\n calendarId: ENV.gcalId,\n eventId: ev.id!,\n requestBody: {\n description: ev.description\n ? ev.description.replace(/.*$/m, \"\")\n : \"\",\n extendedProperties: { \"private\": {} },\n },\n }),\n );\n const created = await counted(\n calendar.events.insert({\n calendarId: ENV.gcalId,\n requestBody: {\n summary: addPrefix(issue.title, prefixFor(issue.state.name)),\n description: insertMeta(\n ensureLink(issue.description ?? \"\", issue.url),\n metaLine(newStart, dur, \"\"),\n ),\n start: { dateTime: newStart },\n end: { dateTime: dayjs(newStart).add(dur, \"minute\").toISOString() },\n extendedProperties: { \"private\": { linearIssueId: issue.id } },\n },\n }),\n );\n await counted(\n linear.request(\n gql`mutation($id:String!,$d:String!){issueUpdate(id:$id,input:{description:$d}){success}}`,\n {\n id: issue.id,\n d: insertMeta(\n ensureLink(issue.description ?? \"\", issue.url),\n metaLine(newStart, dur, created.data.id!),\n ),\n },\n ),\n );\n bump(\"reschedules\");\n log(\"RESCHED\", \"rescheduled overdue event\", {\n issueId: issue.id,\n oldEventId: ev.id,\n newEventId: created.data.id,\n });\n eventByIssue[issue.id] = created.data;\n }\n }\n\n /*──────── create missing events for Scheduled ───────*/\n for (const issue of issues.nodes) {\n let ev = eventByIssue[issue.id];\n\n if (!ev && issue.state.name === \"Scheduled\") {\n const dur = issue.estimate ? issue.estimate * 15 : 30;\n const start = base.add(slot * 30, \"minute\").toISOString();\n slot++;\n const body = insertMeta(\n ensureLink(issue.description ?? \"\", issue.url),\n metaLine(start, dur, \"\"),\n );\n const created = await counted(\n calendar.events.insert({\n calendarId: ENV.gcalId,\n requestBody: {\n summary: addPrefix(issue.title, prefixFor(issue.state.name)),\n description: body,\n start: { dateTime: start },\n end: { dateTime: dayjs(start).add(dur, \"minute\").toISOString() },\n extendedProperties: { \"private\": { linearIssueId: issue.id } },\n },\n }),\n );\n log(\"ADD\", \"created calendar event for Scheduled issue\", {\n issueId: issue.id,\n eventId: created.data.id,\n start,\n durMin: dur,\n });\n\n await counted(\n linear.request(\n gql`mutation($id:String!,$d:String!){issueUpdate(id:$id,input:{description:$d}){success}}`,\n {\n id: issue.id,\n d: insertMeta(\n issue.description ?? \"\",\n metaLine(start, dur, created.data.id!),\n ),\n },\n ),\n );\n\n bump(\"adds\");\n ev = created.data;\n eventByIssue[issue.id] = ev;\n }\n\n if (ev) await reconcileIssueEvent(issue, ev);\n }\n\n /*──────── summary ───────*/\n console.table([\n {\n issues: stats.issuesTracked,\n events: stats.eventsSeen,\n adds: stats.adds,\n edits: stats.edits,\n reschedules: stats.reschedules,\n apiCalls: stats.apiCalls,\n },\n ]);\n log(\"DONE\", \"sync complete\");\n}",83,[744],{"_155":470,"_104":749,"_109":750,"_158":141,"_497":751},121,["D",1752894629496],[752],{"_107":753,"_158":141,"_155":470,"_100":190,"_166":754,"_164":176,"_104":755,"_157":-5,"_109":750,"_159":749,"_168":-5,"_161":27,"_167":27,"_103":756},"ecbb42a8-644d-11f0-9a23-0224a6c84d84","# Google Calendar ↔ Linear Sync Worker\n\nA stateless, deterministic sync worker implementing the **Declarative Reconciliation Loop (DRL)** pattern to bidirectionally sync Google Calendar events and Linear issues.\n\n## Architecture Overview\n\nThis refactored implementation follows a strict **Observe → Project → Diff → Actuate** pattern:\n\n1. **Observe**: Fetch current snapshots from Linear and Google Calendar APIs\n2. **Project**: Create a canonical truth using deterministic, side-effect-free functions\n3. **Diff**: Compare canonical state with external reality to compute minimal operations\n4. **Actuate**: Execute idempotent API calls until external systems match canonical truth\n\n### Key Design Principles\n\n- **Stateless**: No database required; all state lives in remote systems via UID linkages\n- **Deterministic**: Pure functions ensure identical inputs always produce identical outputs\n- **Idempotent**: Operations can be safely retried without side effects\n- **Minimal**: Only necessary changes are made to external systems\n\n## Core Data Models\n\n### Google Calendar Event (`GCalEvent`)\n\n```typescript\ninterface GCalEvent {\n id: string; // Primary key (never edited)\n summary: string; // Prefix + human title\n description?: string; // Freeform notes\n start: { dateTime: string }; // ISO 8601 UTC\n end: { dateTime: string }; // ISO 8601 UTC\n extendedProperties?: {\n private?: {\n uid?: string; // Canonical UID linking to Linear\n linearIssueId?: string; // Back-pointer to Linear issue\n };\n };\n status: \"confirmed\" | \"cancelled\";\n}\n```\n\n### Linear Issue (`LinearIssue`)\n\n```typescript\ninterface LinearIssue {\n id: string; // Primary key\n title: string; // Prefix + human title\n description?: string; // Long notes + calendar metadata\n state: \"Triage\" | \"Scheduled\" | \"Done\" | \"Canceled\" | \"Failed\";\n targetDate?: string; // ISO 8601 datetime\n // Note: Linear API doesn't support custom fields - use description metadata instead\n}\n```\n\n### Canonical Item (`CanonicalItem`)\n\nThe unified representation that bridges both systems:\n\n```typescript\ninterface CanonicalItem {\n uid: string; // Stable identifier across systems\n title: string; // Clean title (no prefix)\n description?: string;\n startTime?: string; // ISO 8601\n endTime?: string; // ISO 8601\n linearId?: string;\n gcalId?: string;\n linearState?: LinearIssue[\"state\"];\n phase: Phase; // Current lifecycle phase\n lastModified: string; // For conflict resolution\n}\n```\n\n## Phase Transitions\n\nThe system recognizes 5 phases with specific transition rules:\n\n| Phase | Description | Triggers |\n| ------------ | ---------------------------------- | --------------------------- |\n| `eventOnly` | GCal event without Linear match | New calendar event created |\n| `linearOnly` | Linear issue without GCal match | Issue marked as \"Scheduled\" |\n| `active` | Linked and syncing | Both systems have records |\n| `completed` | Linear marked done/canceled/failed | State change in Linear |\n| `overdue` | Past deadline but still active | >24h after event end |\n\n### Transition Actions\n\n| From → To | Trigger | Action | Result Prefix |\n| --------------------- | ----------------------------------- | ----------------------------------------------- | ------------- |\n| `eventOnly → active` | GCal event exists | Create Linear issue (Triage) | 📥 |\n| `linearOnly → active` | Linear state = \"Scheduled\" | Create GCal event | 📅 |\n| `active → completed` | Linear state = Done/Canceled/Failed | Update GCal title | ✅/🚫/❌ |\n| `active → overdue` | >24h past event end | Mark original as worked (⏳) + create new event | ⏳ + 📅 |\n\n### Prefix Meanings\n\n- **📥 Triage**: New items from Google Calendar awaiting review\n- **📅 Scheduled**: Items scheduled for specific times\n- **✅ Done**: Completed items\n- **🚫 Canceled**: Canceled items\n- **❌ Failed**: Failed items\n- **⏳ Worked**: Original events that went overdue (shows work was done)\n\n| `active → active` | Title/time/description change | Sync metadata | (unchanged) |\n\n## Bidirectional Linking\n\nThe system uses two linking mechanisms:\n\n1. **GCal → Linear**: `extendedProperties.private.linearIssueId` in calendar events\n2. **Linear → GCal**: Description metadata ` GoogleCalEventId:xyz` in Linear issues\n\nThis approach works because:\n\n- Google Calendar API supports `extendedProperties` for metadata storage\n- Linear API doesn't support custom fields, so we embed metadata in descriptions\n- Both systems preserve their metadata across updates\n\n## Conflict Resolution\n\n- **Title**: Linear wins (source of truth for task names)\n- **Start/End Times**: Calendar wins (source of truth for scheduling)\n- **Description**: Newest `updatedAt` wins (simplified to Linear in current implementation)\n\n## File Structure\n\n```\nsrc/\n├── types.ts # Core data models and interfaces\n├── projector.ts # Observe → Project (create canonical truth)\n├── diff.ts # Project → Diff (compute operations)\n├── actuator.ts # Diff → Actuate (execute operations)\n├── worker.ts # Main sync orchestrator\n├── main.ts # Entry point with configuration\n└── *.test.ts # Comprehensive test suite\n```\n\n## Usage\n\n### Running Tests\n\n```bash\ndeno test --allow-env --allow-net --allow-import src/*.test.ts\n```\n\n### Running Sync\n\n```bash\n# Set environment variables\nexport LINEAR_API_KEY=\"your-linear-api-key\"\nexport LINEAR_TEAM_ID=\"your-team-id\"\nexport GCAL_API_KEY=\"your-google-api-key\"\nexport GCAL_CALENDAR_ID=\"your-calendar-id\"\n\n# Run sync\ndeno run --allow-env --allow-net src/main.ts\n```\n\n### Configuration\n\nThe worker is configured via environment variables:\n\n- `LINEAR_API_KEY`: Linear API token\n- `LINEAR_TEAM_ID`: Linear team identifier\n- `GCAL_API_KEY`: Google Calendar API key\n- `GCAL_CALENDAR_ID`: Primary calendar ID\n- `GCAL_HISTORY_CALENDAR_ID`: (Optional) Calendar for overdue items\n- `TIMEZONE`: Timezone for operations (default: UTC)\n- `LOOKBACK_DAYS`: Days to look back (default: 30)\n- `LOOKAHEAD_DAYS`: Days to look ahead (default: 90)\n\n## Performance Characteristics\n\n- **Latency**: < 5 seconds for 10,000 items (per spec requirement)\n- **Memory**: Stateless operation, minimal memory footprint\n- **Network**: Batched API calls, efficient pagination\n- **Reliability**: Idempotent operations survive failures\n\n## Testing Strategy\n\nThe test suite covers:\n\n- **Unit tests**: Individual functions (types, projector, diff)\n- **Integration tests**: Full sync workflows with mock APIs\n- **Determinism**: Identical inputs produce identical outputs\n- **Idempotence**: Operations can be safely retried\n- **Performance**: Validates < 5s execution time\n\n## Extending the System\n\nThe DRL pattern makes it easy to:\n\n1. Add new external systems (e.g., Notion) by implementing new projectors/actuators\n2. Add new phase transitions by updating the diff engine\n3. Add new conflict resolution rules in the projector\n4. Add webhook triggers by replacing the cron scheduler\n\n## Migration from Legacy\n\nThe original implementation has been moved to `backup/` and key concepts have been preserved:\n\n- Bidirectional sync logic\n- State machine approach (now phase-based)\n- Metadata embedding for linkage\n- Prefix-based visual indicators\n\nThe new implementation is more robust, testable, and maintainable while preserving all original functionality.\n",3,[190],"page","hasNext","routes/_app","actionData","errors"]