[{"_1":2,"_577":-5,"_578":-5},"loaderData",{"_3":4,"_91":92,"_549":550},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":22,"_29":22,"_30":22,"_31":32,"_33":22},"auth",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"tokenType","session_token","sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","230fbbe1911b69d46be82b6db4e617b331d282a6","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":22,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":22,"_90":22},"__clerk_ssr_state",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":22,"_21":22,"_82":72,"_83":84,"_85":72,"_86":45,"_87":22,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_93":94,"_95":96,"_97":-7,"_98":72,"_99":-7,"_100":101,"_149":150,"_497":498,"_499":500,"_508":509,"_177":-5,"_543":-5,"_544":-5,"_545":22,"_546":22,"_547":548},"handle","liamh","name","google-calendar-linear-sync","branchName","path","version","project",{"_102":103,"_95":96,"_104":105,"_106":-5,"_107":22,"_108":109,"_110":111,"_112":113,"_14":114,"_115":-5,"_116":22,"_117":-5,"_118":119,"_16":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":130,"_133":134,"_136":137,"_148":22},"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",{"_93":94,"_131":132},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ydFZBdXhGVTFxTlJibTdQYmFHT2pRV1JHb2sifQ","org",{"_93":94,"_135":132},"avatar","branch",{"_99":138,"_95":43,"_102":139,"_140":103,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":96,"_147":94},174,"f8948e30-25e7-11f0-ab4c-569c3dd06744","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[151,182,282,425,434,443,452,461,470,478,487],{"_102":152,"_95":153,"_154":155,"_156":-5,"_157":139,"_158":159,"_160":161,"_104":162,"_99":32,"_163":164,"_165":-5,"_166":22,"_167":-5,"_168":169,"_98":181},"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",[170],{"_102":171,"_95":172,"_154":173,"_156":155,"_157":139,"_158":174,"_160":161,"_104":175,"_99":176,"_163":177,"_165":178,"_166":22,"_167":-5,"_168":179,"_98":180},"48860bb8-a846-11f0-a010-0224a6c84d84","settings.local.json","ec2054fa-644d-11f0-9b75-0224a6c84d84",172,["D",1760368026627],4,"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 \"Bash(rm:*)\",\n \"Bash(npx vt:*)\",\n \"Bash(vt deploy:*)\",\n \"Bash(vt push:*)\"\n ],\n \"deny\": []\n }\n}\n",[],[153,172],[153],{"_102":183,"_95":184,"_154":185,"_156":-5,"_157":139,"_158":186,"_160":161,"_104":187,"_99":32,"_163":164,"_165":-5,"_166":22,"_167":-5,"_168":188,"_98":281},"ebffba38-644d-11f0-95f7-0224a6c84d84","scripts","ebffbb00-644d-11f0-95f7-0224a6c84d84",89,["D",1752894628309],[189,198,209,218,227,236,245,254,263,272],{"_102":190,"_95":191,"_154":192,"_156":185,"_157":139,"_158":193,"_160":161,"_104":194,"_99":119,"_163":177,"_165":195,"_166":22,"_167":-5,"_168":196,"_98":197},"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",[],[184,191],{"_102":199,"_95":200,"_154":201,"_156":185,"_157":139,"_158":202,"_160":161,"_104":203,"_99":204,"_163":205,"_165":206,"_166":22,"_167":-5,"_168":207,"_98":208},"9020342c-98e1-11f0-b6da-0224a6c84d84","api-validator.ts","ec631038-644d-11f0-8cee-0224a6c84d84",165,["D",1758675500083],2,"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 * 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",[],[184,200],{"_102":210,"_95":211,"_154":212,"_156":185,"_157":139,"_158":213,"_160":161,"_104":214,"_99":32,"_163":205,"_165":215,"_166":22,"_167":-5,"_168":216,"_98":217},"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",[],[184,211],{"_102":219,"_95":220,"_154":221,"_156":185,"_157":139,"_158":222,"_160":161,"_104":223,"_99":32,"_163":205,"_165":224,"_166":22,"_167":-5,"_168":225,"_98":226},"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",[],[184,220],{"_102":228,"_95":229,"_154":230,"_156":185,"_157":139,"_158":231,"_160":161,"_104":232,"_99":119,"_163":205,"_165":233,"_166":22,"_167":-5,"_168":234,"_98":235},"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",[],[184,229],{"_102":237,"_95":238,"_154":239,"_156":185,"_157":139,"_158":240,"_160":161,"_104":241,"_99":119,"_163":205,"_165":242,"_166":22,"_167":-5,"_168":243,"_98":244},"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",[],[184,238],{"_102":246,"_95":247,"_154":248,"_156":185,"_157":139,"_158":249,"_160":161,"_104":250,"_99":119,"_163":205,"_165":251,"_166":22,"_167":-5,"_168":252,"_98":253},"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",[],[184,247],{"_102":255,"_95":256,"_154":257,"_156":185,"_157":139,"_158":258,"_160":161,"_104":259,"_99":119,"_163":205,"_165":260,"_166":22,"_167":-5,"_168":261,"_98":262},"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",[],[184,256],{"_102":264,"_95":265,"_154":266,"_156":185,"_157":139,"_158":267,"_160":161,"_104":268,"_99":119,"_163":205,"_165":269,"_166":22,"_167":-5,"_168":270,"_98":271},"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",[],[184,265],{"_102":273,"_95":274,"_154":275,"_156":185,"_157":139,"_158":276,"_160":161,"_104":277,"_99":32,"_163":205,"_165":278,"_166":22,"_167":-5,"_168":279,"_98":280},"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",[],[184,274],[184],{"_102":283,"_95":284,"_154":285,"_156":-5,"_157":139,"_158":286,"_160":161,"_104":287,"_99":32,"_163":164,"_165":-5,"_166":22,"_167":-5,"_168":288,"_98":424},"ec1206fc-644d-11f0-9a81-0224a6c84d84","src","ec1207f6-644d-11f0-9a81-0224a6c84d84",90,["D",1752894628427],[289,298,307,316,325,334,343,352,361,370,379,388,397,406,415],{"_102":290,"_95":291,"_154":292,"_156":285,"_157":139,"_158":293,"_160":161,"_104":294,"_99":119,"_163":205,"_165":295,"_166":22,"_167":-5,"_168":296,"_98":297},"6b761de0-6898-11f0-bffb-0224a6c84d84","actuator.test.ts","ecb6a20c-644d-11f0-a738-0224a6c84d84",158,["D",1753366429476],"/**\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 title?: 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 summary: title || event.summary, // Use provided title or original\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",[],[284,291],{"_102":299,"_95":300,"_154":301,"_156":285,"_157":139,"_158":302,"_160":161,"_104":303,"_99":176,"_163":205,"_165":304,"_166":22,"_167":-5,"_168":305,"_98":306},"488cd6d2-a846-11f0-8f03-0224a6c84d84","actuator.ts","ec54253c-644d-11f0-94e7-0224a6c84d84",173,["D",1760368026633],"/**\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 title?: 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 /**\n * Clean description by removing old Google Calendar event links\n */\n private cleanDescription(description: string): string {\n // Remove any existing Google Calendar event links from the description\n // This prevents accumulation of old event links during rollovers\n return description\n .split(\"\\n\")\n .filter((line) =>\n !line.includes(\"https://calendar.google.com/calendar/event?eid=\")\n )\n .join(\"\\n\")\n .trim();\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 \"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 const rawDescription = this.cleanDescription(item.description || \"\");\n\n // Build the clean description with Linear link\n let 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 = rawDescription\n ? `${linearLink}\\n\\n${rawDescription}`\n : linearLink;\n } else {\n description = rawDescription;\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 // Build description with Linear link\n const rawDescription = this.cleanDescription(item.description || \"\");\n\n // Build the clean description with Linear link\n let 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 = rawDescription\n ? `${linearLink}\\n\\n${rawDescription}`\n : linearLink;\n } else {\n description = rawDescription;\n }\n\n updates.description = description;\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 /**\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 // Clean up the description from old Google Calendar links\n const rawDescription = this.cleanDescription(item.description || \"\");\n\n // Build the clean description with Linear link\n let description = \"\";\n if (item.linearId) {\n const linearLink =\n `Linear issue: [${item.linearId}](https://linear.app/liamhorne/issue/${item.linearId})`;\n description = rawDescription\n ? `${linearLink}\\n\\n${rawDescription}`\n : linearLink;\n } else {\n description = rawDescription;\n }\n\n const event: Partial = {\n summary: item.title, // Already has correct prefix from diff\n 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 // Clean up the description from old Google Calendar links\n const rawDescription = this.cleanDescription(item.description || \"\");\n\n const linearLink =\n `Linear issue: [${createdIssue.id}](https://linear.app/liamhorne/issue/${createdIssue.id})`;\n const description = rawDescription\n ? `${linearLink}\\n\\n${rawDescription}`\n : linearLink;\n\n const updates: Partial = {\n summary: item.title, // Should already have 📥 prefix from item\n description,\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",[],[284,300],{"_102":308,"_95":309,"_154":310,"_156":285,"_157":139,"_158":311,"_160":161,"_104":312,"_99":119,"_163":205,"_165":313,"_166":22,"_167":-5,"_168":314,"_98":315},"6b6acbca-6898-11f0-9197-0224a6c84d84","api-clients.ts","ec808c58-644d-11f0-b6ab-0224a6c84d84",157,["D",1753366429402],"/**\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 title?: 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: title || originalEvent.summary, // Use provided title or original\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",[],[284,309],{"_102":317,"_95":318,"_154":319,"_156":285,"_157":139,"_158":320,"_160":161,"_104":321,"_99":204,"_163":205,"_165":322,"_166":22,"_167":-5,"_168":323,"_98":324},"8b4400b4-a052-11f0-b569-0224a6c84d84","diff.test.ts","ec90ac64-644d-11f0-89ff-0224a6c84d84",166,["D",1759493683252],"/**\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, 1);\n assertEquals(operations[0].type, \"patchGCalEvent\");\n assertEquals(\n operations[0].reason,\n \"Rescheduling overdue event to new time slot\",\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",[],[284,318],{"_102":326,"_95":327,"_154":328,"_156":285,"_157":139,"_158":138,"_160":161,"_104":329,"_99":330,"_163":205,"_165":331,"_166":22,"_167":-5,"_168":332,"_98":333},"48939b52-a846-11f0-8dbf-0224a6c84d84","diff.ts","ec769f5e-644d-11f0-a8e7-0224a6c84d84",["D",1760368026637],5,"/**\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 { addPrefix, CanonicalItem, Operation, PREFIXES } from \"./types.ts\";\nimport dayjs from \"npm:dayjs@1.11.10\";\nimport timezonePlugin 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(timezonePlugin);\n\nexport function diff(\n items: CanonicalItem[],\n timezone: string = \"America/New_York\",\n): Operation[] {\n const operations: Operation[] = [];\n\n for (const item of items) {\n const ops = generateOperationsForItem(item, timezone);\n operations.push(...ops);\n }\n\n return operations;\n}\n\nfunction generateOperationsForItem(\n item: CanonicalItem,\n _timezone: string,\n): 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 // Don't set default times here - let the actuator's smart scheduler handle it\n operations.push({\n type: \"createGCalEventAndUpdateLinear\",\n item: {\n ...item,\n title: addPrefix(item.title, PREFIXES.SCHEDULED),\n // Leave startTime and endTime as-is (could be undefined)\n // The actuator will use smart scheduling to find available slots\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 // Copy original event to history calendar with ⏳ prefix, then reschedule the original event\n if (item.gcalId) {\n operations.push({\n type: \"patchGCalEvent\",\n item: {\n ...item,\n // Don't set default times here - let the actuator's smart scheduler handle it\n // Remove startTime and endTime to trigger smart scheduling in actuator\n startTime: undefined,\n endTime: undefined,\n title: item.linearState === \"Scheduled\"\n ? addPrefix(item.title, PREFIXES.SCHEDULED)\n : item.title,\n },\n reason: \"Rescheduling overdue event to new time slot\",\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\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",[],[284,327],{"_102":335,"_95":336,"_154":337,"_156":285,"_157":139,"_158":338,"_160":161,"_104":339,"_99":204,"_163":205,"_165":340,"_166":22,"_167":-5,"_168":341,"_98":342},"6b5cb86e-6898-11f0-a980-0224a6c84d84","dry-run.ts","ec6ec7ca-644d-11f0-9a81-0224a6c84d84",154,["D",1753366429391],"/**\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 title?: 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 if (title) {\n console.log(` New Title: ${title}`);\n }\n\n // Return mock response\n return {\n id: `dry-run-copy-${Date.now()}`,\n summary: title || \"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",[],[284,336],{"_102":344,"_95":345,"_154":346,"_156":285,"_157":139,"_158":347,"_160":161,"_104":348,"_99":32,"_163":205,"_165":349,"_166":22,"_167":-5,"_168":350,"_98":351},"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",[],[284,345],{"_102":353,"_95":354,"_154":355,"_156":285,"_157":139,"_158":356,"_160":161,"_104":357,"_99":32,"_163":205,"_165":358,"_166":22,"_167":-5,"_168":359,"_98":360},"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",[],[284,354],{"_102":362,"_95":363,"_154":364,"_156":285,"_157":139,"_158":365,"_160":161,"_104":366,"_99":119,"_163":205,"_165":367,"_166":22,"_167":-5,"_168":368,"_98":369},"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",[],[284,363],{"_102":371,"_95":372,"_154":373,"_156":285,"_157":139,"_158":374,"_160":161,"_104":375,"_99":204,"_163":205,"_165":376,"_166":22,"_167":-5,"_168":377,"_98":378},"8ffb1fc0-98e1-11f0-a858-0224a6c84d84","scheduler.ts","ec69fb50-644d-11f0-a8e7-0224a6c84d84",161,["D",1758675499901],"/**\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 // Use middle-of-day scheduling: prefer 10 AM to 4 PM\n const preferredStart = Math.max(10, this.config.workingHours.startHour);\n const preferredEnd = Math.min(16, this.config.workingHours.endHour);\n\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 const preferredDayStart = date\n .hour(preferredStart)\n .minute(0)\n .second(0);\n\n const preferredDayEnd = date\n .hour(preferredEnd)\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 in preferred hours first (10 AM - 4 PM)\n if (dayEvents.length === 0) {\n // No events, use preferred start time\n return {\n startTime: preferredDayStart.toISOString(),\n endTime: preferredDayStart.add(durationMin, \"minutes\").toISOString(),\n };\n }\n\n // First, try to find slots within preferred hours\n const preferredSlot = this.findSlotInTimeRange(\n preferredDayStart,\n preferredDayEnd,\n durationMin,\n dayEvents,\n );\n if (preferredSlot) {\n return preferredSlot;\n }\n\n // If no preferred slot found, try full working day with better spacing\n const fullDaySlot = this.findSlotInTimeRange(\n dayStart,\n dayEnd,\n durationMin,\n dayEvents,\n );\n\n return fullDaySlot;\n }\n\n /**\n * Find an available slot within a specific time range\n */\n private findSlotInTimeRange(\n rangeStart: dayjs.Dayjs,\n rangeEnd: dayjs.Dayjs,\n durationMin: number,\n dayEvents: GCalEvent[],\n ): TimeSlot | null {\n // Add 15-minute buffer between events to prevent tight scheduling\n const BUFFER_MINUTES = 15;\n const totalDurationNeeded = durationMin + BUFFER_MINUTES;\n\n // Filter events that overlap with our time range\n const relevantEvents = dayEvents.filter((event) => {\n const eventStart = dayjs(event.start.dateTime);\n const eventEnd = dayjs(event.end.dateTime);\n return eventStart.isBefore(rangeEnd) && eventEnd.isAfter(rangeStart);\n });\n\n if (relevantEvents.length === 0) {\n // No events in range, use range start\n const endTime = rangeStart.add(durationMin, \"minutes\");\n if (endTime.isAfter(rangeEnd)) {\n return null; // Doesn't fit in range\n }\n return {\n startTime: rangeStart.toISOString(),\n endTime: endTime.toISOString(),\n };\n }\n\n // Try before first event\n const firstEventStart = dayjs(relevantEvents[0].start.dateTime);\n const spaceBeforeFirst = firstEventStart.diff(rangeStart, \"minutes\");\n if (spaceBeforeFirst >= totalDurationNeeded) {\n return {\n startTime: rangeStart.toISOString(),\n endTime: rangeStart.add(durationMin, \"minutes\").toISOString(),\n };\n }\n\n // Try gaps between events\n for (let i = 0; i < relevantEvents.length - 1; i++) {\n const currentEventEnd = dayjs(relevantEvents[i].end.dateTime);\n const nextEventStart = dayjs(relevantEvents[i + 1].start.dateTime);\n\n const potentialStart = currentEventEnd.add(BUFFER_MINUTES, \"minutes\");\n const potentialEnd = potentialStart.add(durationMin, \"minutes\");\n\n if (\n potentialEnd.add(BUFFER_MINUTES, \"minutes\").isBefore(nextEventStart)\n ) {\n return {\n startTime: potentialStart.toISOString(),\n endTime: potentialEnd.toISOString(),\n };\n }\n }\n\n // Try after last event\n const lastEventEnd = dayjs(\n relevantEvents[relevantEvents.length - 1].end.dateTime,\n );\n const potentialStart = lastEventEnd.add(BUFFER_MINUTES, \"minutes\");\n const potentialEnd = potentialStart.add(durationMin, \"minutes\");\n\n if (potentialEnd.isBefore(rangeEnd)) {\n return {\n startTime: potentialStart.toISOString(),\n endTime: potentialEnd.toISOString(),\n };\n }\n\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 // Use middle-of-day scheduling: prefer 10 AM to 4 PM\n const preferredStart = Math.max(10, this.config.workingHours.startHour);\n\n // Tomorrow at preferred time (default 10 AM) in configured timezone\n const startTime = dayjs()\n .tz(this.config.timezone)\n .add(1, \"day\")\n .hour(preferredStart)\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",[],[284,372],{"_102":380,"_95":381,"_154":382,"_156":285,"_157":139,"_158":383,"_160":161,"_104":384,"_99":32,"_163":205,"_165":385,"_166":22,"_167":-5,"_168":386,"_98":387},"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",[],[284,381],{"_102":389,"_95":390,"_154":391,"_156":285,"_157":139,"_158":392,"_160":161,"_104":393,"_99":32,"_163":205,"_165":394,"_166":22,"_167":-5,"_168":395,"_98":396},"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",[],[284,390],{"_102":398,"_95":399,"_154":400,"_156":285,"_157":139,"_158":401,"_160":161,"_104":402,"_99":119,"_163":205,"_165":403,"_166":22,"_167":-5,"_168":404,"_98":405},"8b50b016-a052-11f0-9090-0224a6c84d84","types.ts","ec95eaf8-644d-11f0-95f7-0224a6c84d84",169,["D",1759493683271],"/**\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 | \"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",[],[284,399],{"_102":407,"_95":408,"_154":409,"_156":285,"_157":139,"_158":410,"_160":161,"_104":411,"_99":119,"_163":205,"_165":412,"_166":22,"_167":-5,"_168":413,"_98":414},"6b672b82-6898-11f0-abfe-0224a6c84d84","worker.test.ts","eca39af4-644d-11f0-9cd5-0224a6c84d84",156,["D",1753366429434],"/**\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 title?: 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 summary: title || event.summary, // Use provided title or original\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",[],[284,408],{"_102":416,"_95":417,"_154":418,"_156":285,"_157":139,"_158":419,"_160":161,"_104":420,"_99":204,"_163":205,"_165":421,"_166":22,"_167":-5,"_168":422,"_98":423},"8b557d76-a052-11f0-baa6-0224a6c84d84","worker.ts","ecb3a23c-644d-11f0-9cd5-0224a6c84d84",170,["D",1759493683365],"/**\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, this.config.timezone);\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",[],[284,417],[284],{"_102":426,"_95":427,"_154":428,"_156":-5,"_157":139,"_158":429,"_160":161,"_104":430,"_99":32,"_163":177,"_165":431,"_166":22,"_167":-5,"_168":432,"_98":433},"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",[],[427],{"_102":435,"_95":436,"_154":437,"_156":-5,"_157":139,"_158":438,"_160":161,"_104":439,"_99":32,"_163":177,"_165":440,"_166":22,"_167":-5,"_168":441,"_98":442},"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/",[],[436],{"_102":444,"_95":445,"_154":446,"_156":-5,"_157":139,"_158":447,"_160":161,"_104":448,"_99":32,"_163":177,"_165":449,"_166":22,"_167":-5,"_168":450,"_98":451},"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",[],[445],{"_102":453,"_95":454,"_154":455,"_156":-5,"_157":139,"_158":456,"_160":161,"_104":457,"_99":119,"_163":177,"_165":458,"_166":22,"_167":-5,"_168":459,"_98":460},"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",[],[454],{"_102":462,"_95":463,"_154":464,"_156":-5,"_157":139,"_158":465,"_160":161,"_104":466,"_99":119,"_163":177,"_165":467,"_166":22,"_167":-5,"_168":468,"_98":469},"90005896-98e1-11f0-8a10-0224a6c84d84","DIAGRAM.md","b23f1a74-64c9-11f0-a379-0224a6c84d84",162,["D",1758675499902],"# 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\n",[],[463],{"_102":471,"_95":191,"_154":472,"_156":-5,"_157":139,"_158":473,"_160":161,"_104":474,"_99":176,"_163":177,"_165":475,"_166":22,"_167":-5,"_168":476,"_98":477},"b2847222-64c9-11f0-9b60-0224a6c84d84","9f866826-27cd-11f0-9c20-569c3dd06744",137,["D",1752947789360],"# 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",[],[191],{"_102":479,"_95":480,"_154":481,"_156":-5,"_157":139,"_158":482,"_160":161,"_104":483,"_99":119,"_163":177,"_165":484,"_166":22,"_167":-5,"_168":485,"_98":486},"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",[],[480],{"_102":488,"_95":489,"_154":490,"_156":-5,"_157":139,"_158":491,"_160":161,"_104":492,"_99":204,"_163":493,"_165":494,"_166":22,"_167":-5,"_168":495,"_98":496},"b2cc8fda-64c9-11f0-8eb6-0224a6c84d84","val-town-sync.cron.ts","ec40a6d8-644d-11f0-a535-0224a6c84d84",143,["D",1752947789934],"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",[],[489],"files",[151,170,182,189,198,209,218,227,236,245,254,263,272,282,289,298,307,316,325,334,343,352,361,370,379,388,397,406,415,425,434,443,452,461,470,478,487],"counts",{"_501":32,"_502":119,"_503":32,"_504":505},"pulls","branches","forks","envVars",{"_506":330,"_507":32},"count","emptyCount","contents",[510,513,516,519,522,525,528,531,534,537,540],{"_102":152,"_95":153,"_154":155,"_156":-5,"_157":139,"_158":159,"_160":161,"_104":511,"_99":32,"_163":164,"_165":-5,"_166":22,"_167":-5,"_98":512},["D",1752894628092],[153],{"_102":183,"_95":184,"_154":185,"_156":-5,"_157":139,"_158":186,"_160":161,"_104":514,"_99":32,"_163":164,"_165":-5,"_166":22,"_167":-5,"_98":515},["D",1752894628309],[184],{"_102":283,"_95":284,"_154":285,"_156":-5,"_157":139,"_158":286,"_160":161,"_104":517,"_99":32,"_163":164,"_165":-5,"_166":22,"_167":-5,"_98":518},["D",1752894628427],[284],{"_102":426,"_95":427,"_154":428,"_156":-5,"_157":139,"_158":429,"_160":161,"_104":520,"_99":32,"_163":177,"_165":431,"_166":22,"_167":-5,"_98":521},["D",1752894628739],[427],{"_102":435,"_95":436,"_154":437,"_156":-5,"_157":139,"_158":438,"_160":161,"_104":523,"_99":32,"_163":177,"_165":440,"_166":22,"_167":-5,"_98":524},["D",1752894628526],[436],{"_102":444,"_95":445,"_154":446,"_156":-5,"_157":139,"_158":447,"_160":161,"_104":526,"_99":32,"_163":177,"_165":449,"_166":22,"_167":-5,"_98":527},["D",1752894628792],[445],{"_102":453,"_95":454,"_154":455,"_156":-5,"_157":139,"_158":456,"_160":161,"_104":529,"_99":119,"_163":177,"_165":458,"_166":22,"_167":-5,"_98":530},["D",1752947790002],[454],{"_102":462,"_95":463,"_154":464,"_156":-5,"_157":139,"_158":465,"_160":161,"_104":532,"_99":119,"_163":177,"_165":467,"_166":22,"_167":-5,"_98":533},["D",1758675499902],[463],{"_102":471,"_95":191,"_154":472,"_156":-5,"_157":139,"_158":473,"_160":161,"_104":535,"_99":176,"_163":177,"_165":475,"_166":22,"_167":-5,"_98":536},["D",1752947789360],[191],{"_102":479,"_95":480,"_154":481,"_156":-5,"_157":139,"_158":482,"_160":161,"_104":538,"_99":119,"_163":177,"_165":484,"_166":22,"_167":-5,"_98":539},["D",1752947789247],[480],{"_102":488,"_95":489,"_154":490,"_156":-5,"_157":139,"_158":491,"_160":161,"_104":541,"_99":204,"_163":493,"_165":494,"_166":22,"_167":-5,"_98":542},["D",1752947789934],[489],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.environment-variables",{"_93":94,"_95":96,"_100":551,"_504":556},{"_102":103,"_95":96,"_104":552,"_106":-5,"_107":22,"_108":109,"_110":111,"_112":113,"_14":114,"_115":-5,"_116":22,"_117":-5,"_118":119,"_16":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":553,"_133":554,"_136":555,"_148":22},["D",1746033868658],{"_93":94,"_131":132},{"_93":94,"_135":132},{"_99":138,"_95":43,"_102":139,"_140":103,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":96,"_147":94},[557,563,567,571,574],{"_558":559,"_104":560,"_561":-5,"_110":72,"_562":22},"key","GCAL_HISTORY_CALENDAR_ID",["D",1752894892868],"updatedAt","isEmpty",{"_558":564,"_104":565,"_561":566,"_110":72,"_562":22},"LINEAR_TEAM_ID",["D",1752894864230],["D",1752895277562],{"_558":568,"_104":569,"_561":570,"_110":72,"_562":22},"GCAL_ID",["D",1746034606847],["D",1746380989924],{"_558":572,"_104":573,"_561":-5,"_110":72,"_562":22},"GOOGLE_SERVICE_ACCOUNT_JSON",["D",1746034574649],{"_558":575,"_104":576,"_561":-5,"_110":72,"_562":22},"LINEAR_API_KEY",["D",1746034031436],"actionData","errors"]