[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_596":597,"_598":599},"routes/_app.x.$handle.$name",{"_98":97,"_31":43,"_107":88,"_26":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":24,"_122":123,"_124":57,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":24},"version",68,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":20,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","frontend/dashboard.html","latestPath","fileId","3e3ffb94-63ce-11f0-aa58-0224a6c84d84","name","dashboard.html","fileType","content","\n\n \n \n \n Bridge Dashboard\n \n \n \n

\n \n \n\n","createdAt",["D",1752839790686],"branchVersion","branchId","c4d19400-63b1-11f0-866e-0224a6c84d84","id","c4d11e94-63b1-11f0-866e-0224a6c84d84","atproto-to-fediverse",["D",1752827561082],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Syncing Bluesky posts to Mastodon - Prod","imageUrl","14049850-28c1-11f0-89c9-c7d0e2d9e1ea","pinnedFileId","2e2e3aac-63bc-11f0-8513-0224a6c84d84","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",1,"orgId","c04d51b2-a7dc-46ca-ad6f-52f47c2906a8","tursoName","c4d11e9463b111f0866e0224a6c84d84","tursoHostname","c4d11e9463b111f0866e0224a6c84d84-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789705907347],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},"branch",{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"isOwned",487,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","tijs","handle","displayName","Tijs","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yd2Nod2N0bE1MWFdEUlRYd083ZE5pbXJ1bDAifQ","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":591,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":592,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":593,"_82":594,"_84":595,"_86":24},"tree",[259,261,281,287,289,295,296,297,298,299,300,301,302,303,304],"files",[259,260,261,262,263,264,265,266,267,268,269,270,271,272,273,274,275,276,277,278,279,280,281,282,283,284,285,286,287,288,289,290,291,292,293,294,295,296,297,298,299,300,301,302,303,304],"counts",{"_249":151,"_250":61,"_251":196,"_252":253,"_254":255},"contents",[129,130,131,132,133,134,135,136,137,138,139,140,141,142,143],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":243,"_31":244,"_29":245,"_147":-5,"_39":40,"_38":246,"_149":57,"_36":247,"_13":151,"_33":224,"_34":-5,"_23":24,"_153":-5,"_26":248},{"_41":237,"_31":238,"_29":239,"_147":-5,"_39":40,"_38":240,"_149":57,"_36":241,"_13":151,"_33":224,"_34":-5,"_23":24,"_153":-5,"_26":242},{"_41":232,"_31":233,"_29":234,"_147":-5,"_39":40,"_38":61,"_149":57,"_36":235,"_13":151,"_33":224,"_34":-5,"_23":24,"_153":-5,"_26":236},{"_41":226,"_31":227,"_29":228,"_147":-5,"_39":40,"_38":229,"_149":57,"_36":230,"_13":151,"_33":224,"_34":-5,"_23":24,"_153":-5,"_26":231},{"_41":220,"_31":221,"_29":222,"_147":-5,"_39":40,"_38":196,"_149":57,"_36":223,"_13":151,"_33":224,"_34":-5,"_23":24,"_153":-5,"_26":225},{"_41":213,"_31":214,"_29":215,"_147":-5,"_39":40,"_38":216,"_149":57,"_36":217,"_13":61,"_33":20,"_34":218,"_23":24,"_153":-5,"_26":219},{"_41":206,"_31":207,"_29":208,"_147":-5,"_39":40,"_38":209,"_149":57,"_36":210,"_13":151,"_33":20,"_34":211,"_23":24,"_153":-5,"_26":212},{"_41":199,"_31":200,"_29":201,"_147":-5,"_39":40,"_38":202,"_149":24,"_36":203,"_13":151,"_33":20,"_34":204,"_23":24,"_153":-5,"_26":205},{"_41":191,"_31":192,"_29":193,"_147":-5,"_39":40,"_38":194,"_149":24,"_36":195,"_13":196,"_33":20,"_34":197,"_23":24,"_153":-5,"_26":198},{"_41":184,"_31":185,"_29":186,"_147":-5,"_39":40,"_38":187,"_149":24,"_36":188,"_13":61,"_33":20,"_34":189,"_23":24,"_153":-5,"_26":190},{"_41":177,"_31":178,"_29":179,"_147":-5,"_39":40,"_38":180,"_149":24,"_36":181,"_13":61,"_33":20,"_34":182,"_23":24,"_153":-5,"_26":183},{"_41":170,"_31":171,"_29":172,"_147":-5,"_39":40,"_38":173,"_149":24,"_36":174,"_13":151,"_33":20,"_34":175,"_23":24,"_153":-5,"_26":176},{"_41":162,"_31":163,"_29":164,"_147":-5,"_39":40,"_38":165,"_149":24,"_36":166,"_13":151,"_33":167,"_34":168,"_23":24,"_153":-5,"_26":169},{"_41":155,"_31":156,"_29":157,"_147":-5,"_39":40,"_38":158,"_149":24,"_36":159,"_13":151,"_33":20,"_34":160,"_23":24,"_153":-5,"_26":161},{"_41":144,"_31":145,"_29":146,"_147":-5,"_39":40,"_38":148,"_149":57,"_36":150,"_13":151,"_33":20,"_34":152,"_23":24,"_153":-5,"_26":154},"2df3ee92-63bc-11f0-8513-0224a6c84d84","val-town.md","2df3ef3c-63bc-11f0-8513-0224a6c84d84","parentId",12,"latest",["D",1752832032438],0,"You are an advanced assistant that helps programmers code on Val Town.\n\n## Core Guidelines\n\n- Ask clarifying questions when requirements are ambiguous\n- Provide complete, functional solutions rather than skeleton implementations\n- Test your logic against edge cases before presenting the final solution\n- Ensure all code follows Val Town's specific platform requirements\n- If a section of code that you're working on is getting too complex, consider\n refactoring it into subcomponents\n\n## Code Standards\n\n- Generate code in TypeScript or TSX\n- Add appropriate TypeScript types and interfaces for all data structures\n- Prefer official SDKs or libraries than writing API calls directly\n- Ask the user to supply API or library documentation if you are at all unsure\n about it\n- **Never bake in secrets into the code** - always use environment variables\n- Include comments explaining complex logic (avoid commenting obvious\n operations)\n- Follow modern ES6+ conventions and functional programming practices if\n possible\n\n## Types of triggers\n\n### 1. HTTP Trigger\n\n- Create web APIs and endpoints\n- Handle HTTP requests and responses\n- Example structure:\n\n```ts\nexport default async function (req: Request) {\n return new Response(\"Hello World\");\n}\n```\n\n### 2. Cron Triggers\n\n- Run on a schedule\n- Use cron expressions for timing\n- Example structure:\n\n```ts\nexport default async function () {\n // Scheduled task code\n}\n```\n\n### 3. Email Triggers\n\n- Process incoming emails\n- Handle email-based workflows\n- Example structure:\n\n```ts\nexport default async function (email: Email) {\n // Process email\n}\n```\n\n## Val Town Standard Libraries\n\nVal Town provides several hosted services and utility functions.\n\n### Blob Storage\n\n```ts\nimport { blob } from \"https://esm.town/v/std/blob\";\nawait blob.setJSON(\"myKey\", { hello: \"world\" });\nlet blobDemo = await blob.getJSON(\"myKey\");\nlet appKeys = await blob.list(\"app_\");\nawait blob.delete(\"myKey\");\n```\n\n### SQLite\n\n```ts\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nconst TABLE_NAME = \"todo_app_users_2\";\n// Create table - do this before usage and change table name when modifying schema\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL\n)`);\n// Query data\nconst result = await sqlite.execute(\n `SELECT * FROM ${TABLE_NAME} WHERE id = ?`,\n [1],\n);\n```\n\nNote: When changing a SQLite table's schema, change the table's name (e.g., add\n_2 or_3) to create a fresh table.\n\n### OpenAI\n\n```ts\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nconst openai = new OpenAI();\nconst completion = await openai.chat.completions.create({\n messages: [\n { role: \"user\", content: \"Say hello in a creative way\" },\n ],\n model: \"gpt-4o-mini\",\n max_tokens: 30,\n});\n```\n\n### Email\n\n```ts\nimport { email } from \"https://esm.town/v/std/email\";\n// By default emails the owner of the val\nawait email({\n subject: \"Hi\",\n text: \"Hi\",\n html: \"

Hi

\",\n});\n```\n\n## Val Town Utility Functions\n\nVal Town provides several utility functions to help with common project tasks.\n\n### Importing Utilities\n\nAlways import utilities with version pins to avoid breaking changes:\n\n```ts\nimport {\n readFile,\n serveFile,\n} from \"https://esm.town/v/std/utils@85-main/index.ts\";\n```\n\n### Available Utilities\n\n#### **serveFile** - Serve project files with proper content types\n\nFor example, in Hono:\n\n```ts\n// serve all files in frontend/ and shared/\napp.get(\"/frontend/*\", (c) => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", (c) => serveFile(c.req.path, import.meta.url));\n```\n\n#### **readFile** - Read files from within the project\n\n```ts\n// Read a file from the project\nconst fileContent = await readFile(\"/frontend/index.html\", import.meta.url);\n```\n\n#### **listFiles** - List all files in the project\n\n```ts\nconst files = await listFiles(import.meta.url);\n```\n\n## Val Town Platform Specifics\n\n- **Redirects:** Use\n `return new Response(null, { status: 302, headers: { Location: \"/place/to/redirect\" }})`\n instead of `Response.redirect` which is broken\n- **Images:** Avoid external images or base64 images. Use emojis, unicode\n symbols, or icon fonts/libraries instead\n- **AI Image:** To inline generate an AI image use:\n `

`\n- **Storage:** DO NOT use the Deno KV module for storage\n- **Browser APIs:** DO NOT use the `alert()`, `prompt()`, or `confirm()` methods\n- **Weather Data:** Use open-meteo for weather data (doesn't require API keys)\n unless otherwise specified\n- **Error Debugging:** Add\n `` to HTML to capture\n client-side errors\n- **Error Handling:** Only use try...catch when there's a clear local\n resolution; Avoid catches that merely log or return 500s. Let errors bubble up\n with full context\n- **Environment Variables:** Use `Deno.env.get('keyname')` when you need to, but\n generally prefer APIs that don't require keys\n- **Imports:** Use `https://esm.sh` for npm and Deno dependencies to ensure\n compatibility on server and browser\n- **Storage Strategy:** Only use backend storage if explicitly required; prefer\n simple static client-side sites\n- **React Configuration:** When using React libraries, pin versions with\n `?deps=react@18.2.0,react-dom@18.2.0` and start the file with\n `/** @jsxImportSource https://esm.sh/react@18.2.0 */`\n- Ensure all React dependencies and sub-dependencies are pinned to the same\n version\n- **Styling:** Default to using TailwindCSS via\n `` unless otherwise\n specified\n\n## Project Structure and Design Patterns\n\n### Recommended Directory Structure\n\n```\n├── backend/\n│ ├── database/\n│ │ ├── migrations.ts # Schema definitions\n│ │ ├── queries.ts # DB query functions\n│ │ └── README.md\n│ └── routes/ # Route modules\n│ ├── [route].ts\n│ └── static.ts # Static file serving\n│ ├── index.ts # Main entry point\n│ └── README.md\n├── frontend/\n│ ├── components/\n│ │ ├── App.tsx\n│ │ └── [Component].tsx\n│ ├── favicon.svg\n│ ├── index.html # Main HTML template\n│ ├── index.tsx # Frontend JS entry point\n│ ├── README.md\n│ └── style.css\n├── README.md\n└── shared/\n ├── README.md\n └── utils.ts # Shared types and functions\n```\n\n### Backend (Hono) Best Practices\n\n- Hono is the recommended API framework\n- Main entry point should be `backend/index.ts`\n- Do NOT use Hono serveStatic middleware\n- **Static asset serving:** Use the utility functions to read and serve project\n files:\n\n ```ts\n import { readFile, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\n\n // serve all files in frontend/ and shared/\n app.get(\"/frontend/*\", (c) => serveFile(c.req.path, import.meta.url));\n app.get(\"/shared/*\", (c) => serveFile(c.req.path, import.meta.url));\n\n // For index.html, often you'll want to bootstrap with initial data\n app.get(\"/\", async (c) => {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n\n // Inject data to avoid extra round-trips\n const initialData = await fetchInitialData();\n const dataScript = ``;\n\n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n });\n ```\n\n- Create RESTful API routes for CRUD operations\n- Always include this snippet at the top-level Hono app to re-throwing errors to\n see full stack traces:\n\n ```ts\n // Unwrap Hono errors to see original error details\n app.onError((err, c) => {\n throw err;\n });\n ```\n\n### Database Patterns\n\n- Run migrations on startup or comment out for performance\n- Change table names when modifying schemas rather than altering\n- Export clear query functions with proper TypeScript typing\n\n## Common Gotchas and Solutions\n\n1. **Environment Limitations:**\n - Val Town runs on Deno in a serverless context, not Node.js\n - Code in `shared/` must work in both frontend and backend environments\n - Cannot use `Deno` keyword in shared code\n - Use `https://esm.sh` for imports that work in both environments\n\n2. **SQLite Peculiarities:**\n - Limited support for ALTER TABLE operations\n - Create new tables with updated schemas and copy data when needed\n - Always run table creation before querying\n\n3. **React Configuration:**\n - All React dependencies must be pinned to 18.2.0\n - Always include `@jsxImportSource https://esm.sh/react@18.2.0` at the top of\n React files\n - Rendering issues often come from mismatched React versions\n\n4. **File Handling:**\n - Val Town only supports text files, not binary\n - Use the provided utilities to read files across branches and forks\n - For files in the project, use `readFile` helpers\n\n5. **API Design:**\n - `fetch` handler is the entry point for HTTP vals\n - Run the Hono app with\n `export default app.fetch // This is the entry point for HTTP vals`\n\n6. **Hono Peculiarities:**\n\n- NEVER EVER write this line:\n `import { serveStatic } from 'https://esm.sh/hono@3.11.7/middleware';`\n - Instead use:\n `import { readFile, serveFile } from \"https://esm.town/v/std/utils/index.ts\";`\n- NEVER EVER write this line:\n `import { cors } from \"https://esm.sh/@hono/cors@0.0.6\";`.\n - Val Town automatically handles CORS.\n- If you need cookies, use: import { deleteCookie, getCookie, setCookie } from\n \"npm:hono/cookie\";\n","label",[145],"2e0a95e8-63bc-11f0-824b-0224a6c84d84","deno.json","2e0a967e-63bc-11f0-824b-0224a6c84d84",16,["D",1752832032588],"{\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/348900b8b79f4a434cab4c74b3bc8d4d2fa8ee74/cli/schemas/config-file.v1.json\",\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": false,\n \"strict\": false,\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 },\n \"lint\": {\n \"files\": {\n \"include\": [\n \"deno:/https/esm.town/**/*\"\n ]\n },\n \"rules\": {\n \"exclude\": [\n \"no-explicit-any\"\n ]\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}\n",[156],"2e00e93a-63bc-11f0-a005-0224a6c84d84","cronjob.ts","2e00ea16-63bc-11f0-a005-0224a6c84d84",14,["D",1752832032444],"interval","import { SyncService } from \"./backend/services/sync-service.ts\";\nimport { runMigrations } from \"./backend/database/migrations.ts\";\n\n/**\n * Cron job for syncing posts from ATProto to Mastodon\n *\n * This function runs on a schedule (15 minutes for free tier)\n * and syncs posts for all configured users.\n */\nexport default async function () {\n console.log(\"Cron job started:\", new Date().toISOString());\n\n try {\n // Ensure database is initialized\n await runMigrations();\n\n // Sync posts for all users\n await SyncService.syncAllUsers();\n\n console.log(\"Cron job completed successfully\");\n } catch (error) {\n console.error(\"Cron job failed:\", error);\n\n // In a production environment, you might want to send an alert\n // or log to an external service here\n }\n}\n",[163],"1b00d43e-63bd-11f0-874b-0224a6c84d84","client-metadata.json.template","1b00d4fc-63bd-11f0-874b-0224a6c84d84",42,["D",1752832430068],"{\n \"client_id\": \"https://YOUR-VAL-URL.web.val.run/client-metadata.json\",\n \"client_name\": \"ATProto to Fediverse Bridge\",\n \"redirect_uris\": [\n \"https://YOUR-VAL-URL.web.val.run/api/oauth/atproto/callback\"\n ],\n \"scope\": \"atproto\",\n \"response_types\": [\"code\"],\n \"grant_types\": [\"authorization_code\", \"refresh_token\"],\n \"token_endpoint_auth_method\": \"none\",\n \"dpop_bound_access_tokens\": true\n}",[171],"b68a1ea8-63ca-11f0-9ea0-0224a6c84d84","client-metadata.json","1afa28c8-63bd-11f0-9f79-0224a6c84d84",56,["D",1752838274505],"{\n \"client_id\": \"https://tijs--2e2e3aac63bc11f085130224a6c84d84.web.val.run/client-metadata.json\",\n \"client_name\": \"ATProto to Fediverse Bridge\",\n \"redirect_uris\": [\n \"https://tijs--2e2e3aac63bc11f085130224a6c84d84.web.val.run/api/oauth/atproto/callback\"\n ],\n \"scope\": \"atproto transition:generic\",\n \"response_types\": [\"code\"],\n \"grant_types\": [\"authorization_code\", \"refresh_token\"],\n \"token_endpoint_auth_method\": \"none\",\n \"dpop_bound_access_tokens\": true\n}\n",[178],"b69a495e-63ca-11f0-a271-0224a6c84d84","client-metadata-short.json","1c23ceae-63ca-11f0-a131-0224a6c84d84",57,["D",1752838274648],"{\n \"client_id\": \"https://tijs--2e2e3aac63bc11f085130224a6c84d84.web.val.run/client\",\n \"client_name\": \"ATProto to Fediverse Bridge\",\n \"redirect_uris\": [\n \"https://tijs--2e2e3aac63bc11f085130224a6c84d84.web.val.run/api/oauth/atproto/callback\"\n ],\n \"scope\": \"atproto transition:generic\",\n \"response_types\": [\"code\"],\n \"grant_types\": [\"authorization_code\", \"refresh_token\"],\n \"token_endpoint_auth_method\": \"none\",\n \"dpop_bound_access_tokens\": true\n}",[185],"1b29dd0c-63bd-11f0-9d51-0224a6c84d84","README.md","2e6a3f84-63bc-11f0-8ba5-0224a6c84d84",44,["D",1752832430070],2,"# ATProto to Fediverse Bridge\n\nA single-user bridge service that automatically cross-posts from your Bluesky\naccount to your Mastodon account. Built specifically for\n[Val.town](https://val.town) with TypeScript and Deno.\n\n## What it does\n\n- **Connects your accounts**: Securely links your Bluesky and Mastodon accounts\n using OAuth\n- **Automatic syncing**: Checks for new Bluesky posts every 15 minutes and\n cross-posts them to Mastodon\n- **Smart transformations**: Converts Bluesky mentions (@handle.bsky.social) to\n profile links since they don't exist on Mastodon\n- **Media support**: Uploads images and videos from Bluesky to your Mastodon\n instance\n- **Duplicate prevention**: Tracks synced posts to avoid posting the same\n content twice\n- **Error handling**: Retries failed posts and logs errors for troubleshooting\n\n## Features\n\n✅ **OAuth authentication** for both Bluesky and Mastodon\\\n✅ **Media cross-posting** (images & videos)\\\n✅ **Mention transformation** (handles → profile links)\\\n✅ **Duplicate prevention** via content hashing\\\n✅ **Retry mechanism** with exponential backoff\\\n✅ **Error logging** and sync tracking\\\n✅ **Setup wizard** for easy configuration\n\n## Setup on Val.town\n\n### 1. Fork or Import Files\n\nCopy all files from this repository into your Val.town account. The project\nstructure should look like:\n\n```\n├── backend/\n│ ├── index.ts # Main HTTP handler\n│ ├── database/\n│ ├── routes/\n│ └── services/\n├── cronjob.ts # Cron job for syncing\n├── frontend/\n│ └── index.html # Setup wizard UI\n└── shared/\n └── types.ts # Shared interfaces\n```\n\n### 2. Configure Val.town Triggers\n\n**HTTP Trigger** (for the web interface and API):\n\n- Set `backend/index.ts` as an **HTTP val**\n- This serves the setup wizard and handles OAuth callbacks\n\n**Cron Trigger** (for automatic syncing):\n\n- Set `cronjob.ts` as a **Cron val**\n- Schedule: `*/15 * * * *` (every 15 minutes)\n- For paid accounts, you can use shorter intervals like `*/5 * * * *` (every 5\n minutes)\n\n### 3. Environment Variables\n\nSet these environment variables in your Val.town account:\n\n```bash\nATPROTO_CLIENT_ID=https://your-val-url.web.val.run/client-metadata.json\n```\n\nReplace `your-val-url` with your actual Val.town HTTP val URL. For example:\n`https://tijs--2e2e3aac63bc11f085130224a6c84d84.web.val.run/client-metadata.json`\n\nThe `client-metadata.json` file will be served by your HTTP val (see OAuth setup\nbelow).\n\n### 4. OAuth Setup\n\n#### For ATProto/Bluesky:\n\nCreate a `client-metadata.json` file in your project root by copying the\ntemplate:\n\n```bash\ncp client-metadata.json.template client-metadata.json\n```\n\nThen update the URLs in `client-metadata.json` to match your Val.town HTTP val\nURL:\n\n```json\n{\n \"client_id\": \"https://your-val-url.web.val.run/client-metadata.json\",\n \"client_name\": \"ATProto to Fediverse Bridge\",\n \"redirect_uris\": [\n \"https://your-val-url.web.val.run/api/oauth/atproto/callback\"\n ],\n \"scope\": \"atproto\",\n \"response_types\": [\"code\"],\n \"grant_types\": [\"authorization_code\", \"refresh_token\"],\n \"token_endpoint_auth_method\": \"none\",\n \"dpop_bound_access_tokens\": true\n}\n```\n\n#### For Mastodon:\n\nThe service automatically registers with your Mastodon instance during setup -\nno manual configuration needed.\n\n### 5. Initial Setup\n\n1. Visit your HTTP val URL (e.g., `https://your-val-url.web.val.run`)\n2. Click \"Get Started\" to begin the setup wizard\n3. Connect your Bluesky account by entering your handle\n4. Connect your Mastodon account by entering your instance URL\n5. Complete the setup\n\n## Usage\n\nOnce configured, the service runs automatically:\n\n1. **Every 15 minutes** (or your configured interval), the cron job runs\n2. It fetches new posts from your Bluesky account\n3. Transforms the content (mentions become profile links)\n4. Uploads any media to your Mastodon instance\n5. Creates the cross-post on Mastodon\n6. Logs the result for your review\n\n## What Gets Cross-Posted\n\n**✅ Included:**\n\n- Regular posts with text\n- Posts with images/videos\n- Posts with links and hashtags\n- Posts with mentions (converted to profile links)\n\n**❌ Excluded:**\n\n- Replies to other posts\n- Empty posts\n- Posts you've already cross-posted\n\n## Monitoring\n\nVisit your val's dashboard to see:\n\n- Setup status and account connections\n- Recent sync activity and statistics\n- Error logs for troubleshooting\n- Post sync history\n\n## Limitations\n\n- **Free Val.town accounts**: 15-minute minimum sync interval\n- **Bluesky media limits**: 1MB images, 100MB videos\n- **Mastodon compatibility**: Works with all Mastodon instances\n- **Single user**: Designed for personal use (one Bluesky → one Mastodon)\n\n## Troubleshooting\n\n**OAuth failures**: Check your client metadata URL is publicly accessible\\\n**Sync not working**: Verify both accounts are connected in the dashboard\\\n**Missing posts**: Check the sync logs for specific error messages\\\n**Media upload fails**: Bluesky/Mastodon may have different file size limits\n\n## Privacy & Security\n\n- All tokens are stored encrypted in SQLite\n- No data leaves your Val.town instance\n- OAuth follows security best practices\n- You can revoke access anytime from your account settings\n\n## Support\n\nThis is an open-source project. For issues or feature requests, check the\nrepository or Val.town community forums.\n\n---\n\n_Built with ❤️ for the decentralized social web_\n",[192],"2e862280-63bc-11f0-8a50-0224a6c84d84","CLAUDE.md","2e862348-63bc-11f0-8a50-0224a6c84d84",36,["D",1752832033326],"# CLAUDE.md\n\nThis file provides guidance to Claude Code (claude.ai/code) when working with\ncode in this repository.\n\n## Development Commands\n\n### Testing\n\n```bash\n# Run all tests\ndeno test --allow-import\n\n# Run specific test file\ndeno test --allow-import tests/sync-service.test.ts\ndeno test --allow-import tests/post-transformer.test.ts\ndeno test --allow-import tests/storage.test.ts\n\n# Run single test case\ndeno test --allow-import tests/sync-service.test.ts --filter \"should sync posts successfully\"\n```\n\n### Linting\n\n```bash\n# Lint all files\ndeno lint\n\n# Format code\ndeno fmt\n\n# Type check\ndeno check backend/index.ts\ndeno check cronjob.ts\n```\n\n### Val.town Deployment\n\n- Set `backend/index.ts` as HTTP val (serves web interface and API)\n- Set `cronjob.ts` as Cron val with schedule `*/15 * * * *` (every 15 minutes)\n\n## Workflow Recommendations\n\n- Make it a point to run deno lint, test and fmt after any big change\n\n## Architecture Overview\n\nThis is a **single-user bridge service** that cross-posts from Bluesky to\nMastodon, built specifically for Val.town with dependency injection for\ntestability.\n\n### Core Architecture Pattern\n\nThe codebase follows a **dependency injection pattern** with clear separation\nbetween:\n\n- **Interfaces** (`backend/interfaces/`) - Abstract contracts for storage and\n HTTP clients\n- **Implementations** (`backend/storage/`, `backend/services/`) - Concrete\n implementations\n- **Tests** (`tests/`) - Use in-memory mocks for fast, isolated testing\n\n### Key Architectural Components\n\n**Storage Layer**: Uses abstract `StorageProvider` interface with SQLite\nproduction implementation and in-memory test implementation. All database\noperations go through this abstraction.\n\n**HTTP Client Layer**: ATProto and Mastodon interactions are abstracted through\ninterfaces, allowing mock implementations for testing.\n\n**Service Layer**: `SyncService` accepts dependencies via constructor injection,\nmaking it fully testable without external dependencies.\n\n**OAuth Flow**: Two separate OAuth implementations (ATProto uses PKCE, Mastodon\nuses traditional OAuth2) handled in `backend/routes/oauth.ts`.\n\n### Data Flow\n\n1. **Setup**: User runs setup wizard → OAuth tokens stored in SQLite\n2. **Sync**: Cron job (`cronjob.ts`) → `SyncService.syncAllUsers()` → fetches\n posts from ATProto → transforms content → posts to Mastodon\n3. **Transformation**: `PostTransformer` converts Bluesky mentions to profile\n links since Mastodon handles don't exist cross-platform\n4. **Tracking**: Every post sync is tracked in database with status\n (pending/success/failed) and retry logic\n\n### File Structure Logic\n\n- `backend/index.ts` - Main HTTP server (Hono app) serving setup wizard and\n OAuth callbacks\n- `cronjob.ts` - Scheduled sync job (runs every 15 minutes)\n- `backend/services/sync-service-di.ts` - Main sync logic with dependency\n injection\n- `backend/interfaces/` - Abstract contracts for testability\n- `backend/storage/` - SQLite (production) and in-memory (testing)\n implementations\n- `shared/types.ts` - TypeScript interfaces shared between frontend and backend\n\n### Testing Strategy\n\nTests use **in-memory storage** and **mock HTTP clients** for fast, isolated\ntesting:\n\n- `InMemoryStorageProvider` - Full storage implementation in memory\n- `MockATProtoClient` / `MockMastodonClient` - Controllable mock API clients\n- Tests verify business logic without external dependencies\n\n### Val.town Specifics\n\nBuilt for Val.town's serverless environment:\n\n- Uses Val.town's SQLite hosting (`https://esm.town/v/stevekrouse/sqlite`)\n- Uses Val.town utility functions (`https://esm.town/v/std/utils`)\n- Follows Val.town's file serving patterns for static assets\n- Environment variables for OAuth configuration\n\n### OAuth Implementation Details\n\n**ATProto OAuth**: Uses PKCE flow with client metadata discovery. Client\nmetadata must be publicly accessible at `ATPROTO_CLIENT_ID` URL.\n\n**Mastodon OAuth**: Automatically registers app with user's Mastodon instance\nduring setup flow.\n\n### Content Transformation Logic\n\nThe `PostTransformer` handles the key business logic:\n\n- Converts `@handle.bsky.social` mentions to\n `https://bsky.app/profile/handle.bsky.social` links\n- Extracts and processes media (images/videos)\n- Generates content hashes for duplicate prevention\n- Handles ATProto facets (mentions, hashtags, links)\n\n### Error Handling & Retry Logic\n\nImplements exponential backoff retry mechanism:\n\n- 3 retry attempts by default\n- Base delay: 1 second, max delay: 30 seconds\n- Distinguishes between retryable (network, 5xx) and non-retryable errors\n- All errors logged to database for debugging\n",[200],"2e8cca22-63bc-11f0-b8b7-0224a6c84d84",".vtignore","2e8ccaea-63bc-11f0-b8b7-0224a6c84d84",37,["D",1752832033410],".git\n.vscode\n.cursorrules\n.DS_Store\nnode_modules\nvendor",[207],"1b0c78b6-63bd-11f0-a212-0224a6c84d84",".gitignore","2e78e3a4-63bc-11f0-9e6a-0224a6c84d84",43,["D",1752832430213],"# OS generated files\n.DS_Store\n.DS_Store?\n._*\n.Spotlight-V100\n.Trashes\nehthumbs.db\nThumbs.db\n\n# IDE/Editor files\n.vscode/\n.idea/\n*.swp\n*.swo\n*~\n.cursorrules\n\n# Node.js\nnode_modules/\nnpm-debug.log*\nyarn-debug.log*\nyarn-error.log*\npackage-lock.json\nyarn.lock\n\n# Deno\n.deno/\ndeno.lock\n\n# Environment files\n.env\n.env.local\n.env.production\n.env.test\n\n# Val.town specific\n.vt/\nvendor/\n\n# Logs\n*.log\nlogs/\n\n# Database files\n*.db\n*.sqlite\n*.sqlite3\n\n# Build outputs\ndist/\nbuild/\n*.tsbuildinfo\n\n# Test coverage\ncoverage/\n\n# Temporary files\n*.tmp\n*.temp\ntemp/\ntmp/\n\n# Git\n.git/\n\n# Local development\n.local/\nlocal/\n\n# Deployment-specific files\nclient-metadata.json",[214],"2d173b82-63bc-11f0-824b-0224a6c84d84","tests","2d173c22-63bc-11f0-824b-0224a6c84d84",["D",1752832030993],"directory",[221],"2d5cf2e4-63bc-11f0-9e6a-0224a6c84d84","shared","2d5cf38e-63bc-11f0-9e6a-0224a6c84d84",5,["D",1752832031448],[227],"2d00f20a-63bc-11f0-b053-0224a6c84d84","frontend","2d00f2be-63bc-11f0-b053-0224a6c84d84",["D",1752832030845],[233],"2d45a6fc-63bc-11f0-b229-0224a6c84d84","backend","2d45a7e2-63bc-11f0-b229-0224a6c84d84",4,["D",1752832031296],[238],"2d2d3496-63bc-11f0-b229-0224a6c84d84",".claude","2d2d3568-63bc-11f0-b229-0224a6c84d84",3,["D",1752832031136],[244],"pulls","branches","forks","envVars",{"_256":246,"_258":151},"connections",{"_256":151,"_257":151},"count","unfilledCount","emptyCount",{"_41":243,"_31":244,"_29":245,"_147":-5,"_39":40,"_38":246,"_149":57,"_36":588,"_13":151,"_33":224,"_34":-5,"_23":24,"_153":-5,"_306":589,"_26":590},{"_41":580,"_31":581,"_29":582,"_147":245,"_39":40,"_38":583,"_149":24,"_36":584,"_13":196,"_33":20,"_34":585,"_23":24,"_153":-5,"_306":586,"_26":587},{"_41":237,"_31":238,"_29":239,"_147":-5,"_39":40,"_38":240,"_149":57,"_36":577,"_13":151,"_33":224,"_34":-5,"_23":24,"_153":-5,"_306":578,"_26":579},{"_41":573,"_31":564,"_29":558,"_147":239,"_39":40,"_38":523,"_149":57,"_36":574,"_13":151,"_33":224,"_34":-5,"_23":24,"_153":-5,"_306":575,"_26":576},{"_41":565,"_31":566,"_29":567,"_147":558,"_39":40,"_38":568,"_149":24,"_36":569,"_13":151,"_33":341,"_34":570,"_23":24,"_153":-5,"_306":571,"_26":572},{"_41":555,"_31":556,"_29":557,"_147":558,"_39":40,"_38":559,"_149":24,"_36":560,"_13":151,"_33":341,"_34":561,"_23":24,"_153":-5,"_306":562,"_26":563},{"_41":550,"_31":541,"_29":535,"_147":239,"_39":40,"_38":551,"_149":57,"_36":552,"_13":151,"_33":224,"_34":-5,"_23":24,"_153":-5,"_306":553,"_26":554},{"_41":542,"_31":543,"_29":544,"_147":535,"_39":40,"_38":545,"_149":24,"_36":546,"_13":151,"_33":434,"_34":547,"_23":24,"_153":-5,"_306":548,"_26":549},{"_41":532,"_31":533,"_29":534,"_147":535,"_39":40,"_38":536,"_149":24,"_36":537,"_13":151,"_33":341,"_34":538,"_23":24,"_153":-5,"_306":539,"_26":540},{"_41":527,"_31":517,"_29":511,"_147":239,"_39":40,"_38":528,"_149":57,"_36":529,"_13":151,"_33":224,"_34":-5,"_23":24,"_153":-5,"_306":530,"_26":531},{"_41":518,"_31":519,"_29":520,"_147":511,"_39":40,"_38":521,"_149":24,"_36":522,"_13":523,"_33":341,"_34":524,"_23":24,"_153":-5,"_306":525,"_26":526},{"_41":508,"_31":509,"_29":510,"_147":511,"_39":40,"_38":512,"_149":24,"_36":513,"_13":151,"_33":341,"_34":514,"_23":24,"_153":-5,"_306":515,"_26":516},{"_41":503,"_31":470,"_29":464,"_147":239,"_39":40,"_38":504,"_149":57,"_36":505,"_13":151,"_33":224,"_34":-5,"_23":24,"_153":-5,"_306":506,"_26":507},{"_41":495,"_31":496,"_29":497,"_147":464,"_39":40,"_38":498,"_149":24,"_36":499,"_13":151,"_33":341,"_34":500,"_23":24,"_153":-5,"_306":501,"_26":502},{"_41":487,"_31":488,"_29":489,"_147":464,"_39":40,"_38":490,"_149":24,"_36":491,"_13":151,"_33":341,"_34":492,"_23":24,"_153":-5,"_306":493,"_26":494},{"_41":479,"_31":480,"_29":481,"_147":464,"_39":40,"_38":482,"_149":24,"_36":483,"_13":151,"_33":341,"_34":484,"_23":24,"_153":-5,"_306":485,"_26":486},{"_41":471,"_31":472,"_29":473,"_147":464,"_39":40,"_38":474,"_149":24,"_36":475,"_13":151,"_33":341,"_34":476,"_23":24,"_153":-5,"_306":477,"_26":478},{"_41":461,"_31":462,"_29":463,"_147":464,"_39":40,"_38":465,"_149":24,"_36":466,"_13":151,"_33":341,"_34":467,"_23":24,"_153":-5,"_306":468,"_26":469},{"_41":456,"_31":447,"_29":441,"_147":239,"_39":40,"_38":457,"_149":57,"_36":458,"_13":151,"_33":224,"_34":-5,"_23":24,"_153":-5,"_306":459,"_26":460},{"_41":448,"_31":449,"_29":450,"_147":441,"_39":40,"_38":451,"_149":24,"_36":452,"_13":151,"_33":341,"_34":453,"_23":24,"_153":-5,"_306":454,"_26":455},{"_41":438,"_31":439,"_29":440,"_147":441,"_39":40,"_38":442,"_149":24,"_36":443,"_13":151,"_33":341,"_34":444,"_23":24,"_153":-5,"_306":445,"_26":446},{"_41":430,"_31":431,"_29":55,"_147":239,"_39":40,"_38":432,"_149":24,"_36":433,"_13":240,"_33":434,"_34":435,"_23":24,"_153":43,"_306":436,"_26":437},{"_41":232,"_31":233,"_29":234,"_147":-5,"_39":40,"_38":61,"_149":57,"_36":427,"_13":151,"_33":224,"_34":-5,"_23":24,"_153":-5,"_306":428,"_26":429},{"_41":423,"_31":32,"_29":30,"_147":234,"_39":40,"_38":14,"_149":57,"_36":424,"_13":151,"_33":20,"_34":35,"_23":24,"_153":-5,"_306":425,"_26":426},{"_41":415,"_31":416,"_29":417,"_147":234,"_39":40,"_38":418,"_149":24,"_36":419,"_13":151,"_33":341,"_34":420,"_23":24,"_153":-5,"_306":421,"_26":422},{"_41":407,"_31":408,"_29":409,"_147":234,"_39":40,"_38":410,"_149":24,"_36":411,"_13":246,"_33":20,"_34":412,"_23":24,"_153":-5,"_306":413,"_26":414},{"_41":399,"_31":400,"_29":401,"_147":234,"_39":40,"_38":402,"_149":57,"_36":403,"_13":151,"_33":20,"_34":404,"_23":24,"_153":-5,"_306":405,"_26":406},{"_41":391,"_31":392,"_29":393,"_147":234,"_39":40,"_38":394,"_149":24,"_36":395,"_13":151,"_33":341,"_34":396,"_23":24,"_153":-5,"_306":397,"_26":398},{"_41":226,"_31":227,"_29":228,"_147":-5,"_39":40,"_38":229,"_149":57,"_36":388,"_13":151,"_33":224,"_34":-5,"_23":24,"_153":-5,"_306":389,"_26":390},{"_41":380,"_31":381,"_29":382,"_147":228,"_39":40,"_38":383,"_149":24,"_36":384,"_13":151,"_33":341,"_34":385,"_23":24,"_153":-5,"_306":386,"_26":387},{"_41":220,"_31":221,"_29":222,"_147":-5,"_39":40,"_38":196,"_149":57,"_36":377,"_13":151,"_33":224,"_34":-5,"_23":24,"_153":-5,"_306":378,"_26":379},{"_41":369,"_31":370,"_29":371,"_147":222,"_39":40,"_38":372,"_149":24,"_36":373,"_13":61,"_33":341,"_34":374,"_23":24,"_153":-5,"_306":375,"_26":376},{"_41":361,"_31":362,"_29":363,"_147":222,"_39":40,"_38":364,"_149":24,"_36":365,"_13":61,"_33":341,"_34":366,"_23":24,"_153":-5,"_306":367,"_26":368},{"_41":353,"_31":354,"_29":355,"_147":222,"_39":40,"_38":356,"_149":24,"_36":357,"_13":151,"_33":341,"_34":358,"_23":24,"_153":-5,"_306":359,"_26":360},{"_41":345,"_31":346,"_29":347,"_147":222,"_39":40,"_38":348,"_149":24,"_36":349,"_13":151,"_33":341,"_34":350,"_23":24,"_153":-5,"_306":351,"_26":352},{"_41":336,"_31":337,"_29":338,"_147":222,"_39":40,"_38":339,"_149":24,"_36":340,"_13":151,"_33":341,"_34":342,"_23":24,"_153":-5,"_306":343,"_26":344},{"_41":213,"_31":214,"_29":215,"_147":-5,"_39":40,"_38":216,"_149":57,"_36":333,"_13":61,"_33":20,"_34":218,"_23":24,"_153":-5,"_306":334,"_26":335},{"_41":206,"_31":207,"_29":208,"_147":-5,"_39":40,"_38":209,"_149":57,"_36":330,"_13":151,"_33":20,"_34":211,"_23":24,"_153":-5,"_306":331,"_26":332},{"_41":199,"_31":200,"_29":201,"_147":-5,"_39":40,"_38":202,"_149":24,"_36":327,"_13":151,"_33":20,"_34":204,"_23":24,"_153":-5,"_306":328,"_26":329},{"_41":191,"_31":192,"_29":193,"_147":-5,"_39":40,"_38":194,"_149":24,"_36":324,"_13":196,"_33":20,"_34":197,"_23":24,"_153":-5,"_306":325,"_26":326},{"_41":184,"_31":185,"_29":186,"_147":-5,"_39":40,"_38":187,"_149":24,"_36":321,"_13":61,"_33":20,"_34":189,"_23":24,"_153":-5,"_306":322,"_26":323},{"_41":177,"_31":178,"_29":179,"_147":-5,"_39":40,"_38":180,"_149":24,"_36":318,"_13":61,"_33":20,"_34":182,"_23":24,"_153":-5,"_306":319,"_26":320},{"_41":170,"_31":171,"_29":172,"_147":-5,"_39":40,"_38":173,"_149":24,"_36":315,"_13":151,"_33":20,"_34":175,"_23":24,"_153":-5,"_306":316,"_26":317},{"_41":162,"_31":163,"_29":164,"_147":-5,"_39":40,"_38":165,"_149":24,"_36":312,"_13":151,"_33":167,"_34":168,"_23":24,"_153":-5,"_306":313,"_26":314},{"_41":155,"_31":156,"_29":157,"_147":-5,"_39":40,"_38":158,"_149":24,"_36":309,"_13":151,"_33":20,"_34":160,"_23":24,"_153":-5,"_306":310,"_26":311},{"_41":144,"_31":145,"_29":146,"_147":-5,"_39":40,"_38":148,"_149":57,"_36":305,"_13":151,"_33":20,"_34":152,"_23":24,"_153":-5,"_306":307,"_26":308},["D",1752832032438],"children",[],[145],["D",1752832032588],[],[156],["D",1752832032444],[],[163],["D",1752832430068],[],[171],["D",1752838274505],[],[178],["D",1752838274648],[],[185],["D",1752832430070],[],[192],["D",1752832033326],[],[200],["D",1752832033410],[],[207],["D",1752832430213],[],[214],"2e0d9126-63bc-11f0-9abc-0224a6c84d84","sync-service.test.ts","2e0d91d0-63bc-11f0-9abc-0224a6c84d84",17,["D",1752832032444],"script","// Unit tests for SyncService using dependency injection\n\nimport { assertEquals } from \"https://deno.land/std@0.208.0/assert/mod.ts\";\nimport { InMemoryStorageProvider } from \"../backend/storage/memory-storage.ts\";\nimport { SyncService } from \"../backend/services/sync-service-di.ts\";\nimport {\n ATProtoHttpClient,\n MastodonHttpClient,\n} from \"../backend/interfaces/http-client.ts\";\nimport { ATProtoPost } from \"../shared/types.ts\";\n\n// Mock ATProto client\nclass MockATProtoClient implements ATProtoHttpClient {\n private posts: ATProtoPost[] = [];\n\n constructor(posts: ATProtoPost[] = []) {\n this.posts = posts;\n }\n\n fetchPosts(\n _params: { actor: string; limit: number; cursor?: string },\n ): Promise {\n return Promise.resolve({\n feed: this.posts.map((post) => ({ post })),\n cursor: undefined,\n });\n }\n\n getPost(uri: string): Promise {\n const post = this.posts.find((p) => p.uri === uri);\n return Promise.resolve(post ? { thread: { post } } : null);\n }\n\n getProfile(_actor: string): Promise {\n return Promise.resolve({ did: _actor, handle: \"test.bsky.social\" });\n }\n\n resolveHandle(_handle: string): Promise {\n return Promise.resolve({ did: \"did:plc:test\" });\n }\n\n getBlob(_did: string, cid: string): Promise {\n return Promise.resolve(`https://example.com/blob/${cid}`);\n }\n\n refreshToken(_refreshToken: string): Promise {\n return Promise.resolve({\n access_token: \"new_token\",\n refresh_token: \"new_refresh_token\",\n expires_in: 3600,\n });\n }\n}\n\n// Mock Mastodon client\nclass MockMastodonClient implements MastodonHttpClient {\n private shouldFail = false;\n private posts: any[] = [];\n\n setFailure(shouldFail: boolean) {\n this.shouldFail = shouldFail;\n }\n\n verifyCredentials(): Promise {\n return Promise.resolve({ id: \"1\", username: \"test\" });\n }\n\n getAccount(): Promise {\n return Promise.resolve({ id: \"1\", username: \"test\" });\n }\n\n getInstance(): Promise {\n return Promise.resolve({ title: \"Test Instance\" });\n }\n\n uploadMedia(_file: Blob, description?: string): Promise {\n if (this.shouldFail) {\n return Promise.reject(new Error(\"Media upload failed\"));\n }\n return Promise.resolve({\n id: \"media_123\",\n type: \"image\",\n url: \"https://example.com/media.jpg\",\n description,\n });\n }\n\n getMediaStatus(mediaId: string): Promise {\n return Promise.resolve({\n id: mediaId,\n url: \"https://example.com/media.jpg\",\n });\n }\n\n createPost(params: any): Promise {\n if (this.shouldFail) {\n return Promise.reject(new Error(\"Post creation failed\"));\n }\n\n const post = {\n id: String(this.posts.length + 1),\n uri: `https://example.com/posts/${this.posts.length + 1}`,\n url: `https://example.com/posts/${this.posts.length + 1}`,\n content: params.status,\n created_at: new Date().toISOString(),\n media_attachments: params.media_ids?.map((id: string) => ({ id })) || [],\n };\n\n this.posts.push(post);\n return Promise.resolve(post);\n }\n\n registerApp(_params: any): Promise {\n return Promise.resolve({\n client_id: \"test_client_id\",\n client_secret: \"test_client_secret\",\n });\n }\n\n exchangeCodeForToken(_params: any): Promise {\n return Promise.resolve({\n access_token: \"test_token\",\n token_type: \"Bearer\",\n scope: \"read write\",\n });\n }\n\n getCreatedPosts() {\n return this.posts;\n }\n}\n\n// Test helper to create sample ATProto post\nfunction createSamplePost(\n uri: string,\n text: string,\n createdAt: string,\n): ATProtoPost {\n return {\n uri,\n cid: \"test_cid\",\n author: {\n did: \"did:plc:test\",\n handle: \"test.bsky.social\",\n displayName: \"Test User\",\n },\n record: {\n text,\n createdAt,\n facets: [],\n },\n indexedAt: createdAt,\n };\n}\n\nDeno.test(\"SyncService - should sync posts successfully\", async () => {\n // Setup\n const storage = new InMemoryStorageProvider();\n await storage.initialize();\n\n const userId = \"test-user-1\";\n const _account = await storage.userAccounts.create(userId);\n await storage.userAccounts.update(userId, {\n setup_completed: true,\n atproto_access_token: \"token\",\n atproto_pds_url: \"https://bsky.social\",\n atproto_did: \"did:plc:test\",\n mastodon_access_token: \"token\",\n mastodon_instance_url: \"https://mastodon.social\",\n });\n\n await storage.settings.create(userId);\n\n // Create mock clients\n const now = new Date();\n const posts = [\n createSamplePost(\n \"at://did:plc:test/app.bsky.feed.post/1\",\n \"Hello world!\",\n now.toISOString(),\n ),\n createSamplePost(\n \"at://did:plc:test/app.bsky.feed.post/2\",\n \"Another post\",\n new Date(now.getTime() + 1000).toISOString(),\n ),\n ];\n\n const mockATProtoClient = new MockATProtoClient(posts);\n const mockMastodonClient = new MockMastodonClient();\n\n // Create service\n const syncService = new SyncService({\n storage,\n createATProtoClient: () => mockATProtoClient,\n createMastodonClient: () => mockMastodonClient,\n });\n\n // Execute\n const result = await syncService.syncUser(userId);\n\n // Verify\n assertEquals(result.success, true);\n assertEquals(result.postsProcessed, 2);\n assertEquals(result.postsSuccessful, 2);\n assertEquals(result.postsFailed, 0);\n\n // Check that posts were tracked\n const trackedPosts = await storage.postTracking.getRecent(userId);\n assertEquals(trackedPosts.length, 2);\n assertEquals(trackedPosts[0].sync_status, \"success\");\n assertEquals(trackedPosts[1].sync_status, \"success\");\n\n // Check that posts were created on Mastodon\n const mastodonPosts = mockMastodonClient.getCreatedPosts();\n assertEquals(mastodonPosts.length, 2);\n assertEquals(mastodonPosts[0].content, \"Hello world!\");\n assertEquals(mastodonPosts[1].content, \"Another post\");\n});\n\nDeno.test(\"SyncService - should handle post creation failures\", async () => {\n // Setup\n const storage = new InMemoryStorageProvider();\n await storage.initialize();\n\n const userId = \"test-user-2\";\n await storage.userAccounts.create(userId);\n await storage.userAccounts.update(userId, {\n setup_completed: true,\n atproto_access_token: \"token\",\n atproto_pds_url: \"https://bsky.social\",\n atproto_did: \"did:plc:test\",\n mastodon_access_token: \"token\",\n mastodon_instance_url: \"https://mastodon.social\",\n });\n\n await storage.settings.create(userId);\n\n // Create mock clients with failure\n const posts = [\n createSamplePost(\n \"at://did:plc:test/app.bsky.feed.post/1\",\n \"Hello world!\",\n new Date().toISOString(),\n ),\n ];\n\n const mockATProtoClient = new MockATProtoClient(posts);\n const mockMastodonClient = new MockMastodonClient();\n mockMastodonClient.setFailure(true); // Make it fail\n\n // Create service with no retries to speed up test\n const syncService = new SyncService({\n storage,\n createATProtoClient: () => mockATProtoClient,\n createMastodonClient: () => mockMastodonClient,\n retryConfig: {\n maxRetries: 0,\n baseDelay: 100,\n maxDelay: 1000,\n backoffFactor: 2,\n },\n });\n\n // Execute\n const result = await syncService.syncUser(userId);\n\n // Verify\n assertEquals(result.success, true); // Sync completes even with failures\n assertEquals(result.postsProcessed, 1);\n assertEquals(result.postsSuccessful, 0);\n assertEquals(result.postsFailed, 1);\n assertEquals(result.errors.length, 1);\n assertEquals(result.errors[0].message, \"Post creation failed\");\n\n // Check that post was marked as failed\n const failedPosts = await storage.postTracking.getFailed(userId);\n assertEquals(failedPosts.length, 1);\n assertEquals(failedPosts[0].sync_status, \"failed\");\n assertEquals(failedPosts[0].error_message, \"Post creation failed\");\n});\n\nDeno.test(\"SyncService - should skip posts that already exist\", async () => {\n // Setup\n const storage = new InMemoryStorageProvider();\n await storage.initialize();\n\n const userId = \"test-user-3\";\n await storage.userAccounts.create(userId);\n await storage.userAccounts.update(userId, {\n setup_completed: true,\n atproto_access_token: \"token\",\n atproto_pds_url: \"https://bsky.social\",\n atproto_did: \"did:plc:test\",\n mastodon_access_token: \"token\",\n mastodon_instance_url: \"https://mastodon.social\",\n });\n\n await storage.settings.create(userId);\n\n // Pre-create a post tracking record\n const postUri = \"at://did:plc:test/app.bsky.feed.post/1\";\n await storage.postTracking.create({\n user_id: userId,\n atproto_uri: postUri,\n atproto_cid: \"test_cid\",\n atproto_rkey: \"1\",\n content_hash: \"test_hash\",\n atproto_created_at: Date.now(),\n });\n\n // Create mock clients\n const posts = [\n createSamplePost(postUri, \"Hello world!\", new Date().toISOString()),\n ];\n\n const mockATProtoClient = new MockATProtoClient(posts);\n const mockMastodonClient = new MockMastodonClient();\n\n // Create service\n const syncService = new SyncService({\n storage,\n createATProtoClient: () => mockATProtoClient,\n createMastodonClient: () => mockMastodonClient,\n });\n\n // Execute\n const result = await syncService.syncUser(userId);\n\n // Verify\n assertEquals(result.success, true);\n assertEquals(result.postsProcessed, 1);\n assertEquals(result.postsSuccessful, 0); // Should be 0 because post was skipped\n assertEquals(result.postsFailed, 0);\n\n // Check that no new posts were created on Mastodon\n const mastodonPosts = mockMastodonClient.getCreatedPosts();\n assertEquals(mastodonPosts.length, 0);\n});\n\nDeno.test(\"SyncService - should handle missing user account\", async () => {\n // Setup\n const storage = new InMemoryStorageProvider();\n await storage.initialize();\n\n const mockATProtoClient = new MockATProtoClient();\n const mockMastodonClient = new MockMastodonClient();\n\n // Create service\n const syncService = new SyncService({\n storage,\n createATProtoClient: () => mockATProtoClient,\n createMastodonClient: () => mockMastodonClient,\n });\n\n // Execute\n const result = await syncService.syncUser(\"non-existent-user\");\n\n // Verify\n assertEquals(result.success, false);\n assertEquals(result.errors.length, 1);\n assertEquals(result.errors[0].message, \"User account not found\");\n});\n\nDeno.test(\"SyncService - should respect sync disabled setting\", async () => {\n // Setup\n const storage = new InMemoryStorageProvider();\n await storage.initialize();\n\n const userId = \"test-user-4\";\n await storage.userAccounts.create(userId);\n await storage.userAccounts.update(userId, {\n setup_completed: true,\n atproto_access_token: \"token\",\n atproto_pds_url: \"https://bsky.social\",\n atproto_did: \"did:plc:test\",\n mastodon_access_token: \"token\",\n mastodon_instance_url: \"https://mastodon.social\",\n });\n\n // Create settings with sync disabled\n await storage.settings.create(userId);\n await storage.settings.update(userId, { sync_enabled: false });\n\n // Create mock clients\n const posts = [\n createSamplePost(\n \"at://did:plc:test/app.bsky.feed.post/1\",\n \"Hello world!\",\n \"2024-01-01T10:00:00Z\",\n ),\n ];\n\n const mockATProtoClient = new MockATProtoClient(posts);\n const mockMastodonClient = new MockMastodonClient();\n\n // Create service\n const syncService = new SyncService({\n storage,\n createATProtoClient: () => mockATProtoClient,\n createMastodonClient: () => mockMastodonClient,\n });\n\n // Execute\n const result = await syncService.syncUser(userId);\n\n // Verify\n assertEquals(result.success, true);\n assertEquals(result.postsProcessed, 0); // Should be 0 because sync is disabled\n assertEquals(result.postsSuccessful, 0);\n assertEquals(result.postsFailed, 0);\n\n // Check that no posts were created on Mastodon\n const mastodonPosts = mockMastodonClient.getCreatedPosts();\n assertEquals(mastodonPosts.length, 0);\n});\n\n// Run tests: deno test --allow-read --allow-write tests/sync-service.test.ts\n",[],[221,337],"2e05b2bc-63bc-11f0-be89-0224a6c84d84","storage.test.ts","2e05b398-63bc-11f0-be89-0224a6c84d84",15,["D",1752832032543],"// Unit tests for storage implementations\n\nimport { assertEquals } from \"https://deno.land/std@0.208.0/assert/mod.ts\";\nimport { InMemoryStorageProvider } from \"../backend/storage/memory-storage.ts\";\n\nDeno.test(\"InMemoryStorageProvider - user accounts\", async () => {\n const storage = new InMemoryStorageProvider();\n await storage.initialize();\n\n // Test create\n const userId = \"test-user-1\";\n const account = await storage.userAccounts.create(userId);\n\n assertEquals(account.user_id, userId);\n assertEquals(account.setup_completed, false);\n assertEquals(typeof account.id, \"number\");\n assertEquals(typeof account.created_at, \"number\");\n assertEquals(typeof account.updated_at, \"number\");\n\n // Test get\n const retrieved = await storage.userAccounts.get(userId);\n assertEquals(retrieved?.user_id, userId);\n assertEquals(retrieved?.id, account.id);\n\n // Test update\n await new Promise((resolve) => setTimeout(resolve, 1)); // Ensure time difference\n await storage.userAccounts.update(userId, {\n setup_completed: true,\n atproto_handle: \"test.bsky.social\",\n });\n\n const updated = await storage.userAccounts.get(userId);\n assertEquals(updated?.setup_completed, true);\n assertEquals(updated?.atproto_handle, \"test.bsky.social\");\n assertEquals(updated?.updated_at >= account.updated_at, true);\n\n // Test getForSync\n const syncAccounts = await storage.userAccounts.getForSync();\n assertEquals(syncAccounts.length, 1);\n assertEquals(syncAccounts[0].user_id, userId);\n\n // Test get non-existent\n const nonExistent = await storage.userAccounts.get(\"non-existent\");\n assertEquals(nonExistent, null);\n});\n\nDeno.test(\"InMemoryStorageProvider - settings\", async () => {\n const storage = new InMemoryStorageProvider();\n await storage.initialize();\n\n // Test create\n const userId = \"test-user-2\";\n const settings = await storage.settings.create(userId);\n\n assertEquals(settings.user_id, userId);\n assertEquals(settings.sync_enabled, true);\n assertEquals(settings.sync_interval_minutes, 15);\n assertEquals(settings.skip_replies, true);\n assertEquals(settings.include_media, true);\n\n // Test get\n const retrieved = await storage.settings.get(userId);\n assertEquals(retrieved?.user_id, userId);\n assertEquals(retrieved?.sync_enabled, true);\n\n // Test update\n await storage.settings.update(userId, {\n sync_enabled: false,\n sync_interval_minutes: 30,\n });\n\n const updated = await storage.settings.get(userId);\n assertEquals(updated?.sync_enabled, false);\n assertEquals(updated?.sync_interval_minutes, 30);\n assertEquals(updated?.skip_replies, true); // Should remain unchanged\n\n // Test get non-existent\n const nonExistent = await storage.settings.get(\"non-existent\");\n assertEquals(nonExistent, null);\n});\n\nDeno.test(\"InMemoryStorageProvider - post tracking\", async () => {\n const storage = new InMemoryStorageProvider();\n await storage.initialize();\n\n const userId = \"test-user-3\";\n\n // Test create\n const postData = {\n user_id: userId,\n atproto_uri: \"at://did:plc:test/app.bsky.feed.post/1\",\n atproto_cid: \"test_cid\",\n atproto_rkey: \"1\",\n content_hash: \"hash123\",\n atproto_created_at: Date.now(),\n };\n\n const post = await storage.postTracking.create(postData);\n\n assertEquals(post.user_id, userId);\n assertEquals(post.atproto_uri, postData.atproto_uri);\n assertEquals(post.sync_status, \"pending\");\n assertEquals(post.retry_count, 0);\n assertEquals(post.max_retries, 3);\n\n // Test get\n const retrieved = await storage.postTracking.get(\n userId,\n postData.atproto_uri,\n );\n assertEquals(retrieved?.id, post.id);\n assertEquals(retrieved?.atproto_uri, postData.atproto_uri);\n\n // Test update\n await storage.postTracking.update(userId, postData.atproto_uri, {\n sync_status: \"success\",\n mastodon_id: \"mastodon_123\",\n mastodon_url: \"https://mastodon.social/posts/123\",\n synced_at: Date.now(),\n });\n\n const updated = await storage.postTracking.get(userId, postData.atproto_uri);\n assertEquals(updated?.sync_status, \"success\");\n assertEquals(updated?.mastodon_id, \"mastodon_123\");\n assertEquals(updated?.mastodon_url, \"https://mastodon.social/posts/123\");\n assertEquals(typeof updated?.synced_at, \"number\");\n\n // Test getPending\n const pendingPost = await storage.postTracking.create({\n user_id: userId,\n atproto_uri: \"at://did:plc:test/app.bsky.feed.post/2\",\n atproto_cid: \"test_cid_2\",\n atproto_rkey: \"2\",\n content_hash: \"hash456\",\n atproto_created_at: Date.now(),\n });\n\n const pending = await storage.postTracking.getPending(userId);\n assertEquals(pending.length, 1);\n assertEquals(pending[0].id, pendingPost.id);\n assertEquals(pending[0].sync_status, \"pending\");\n\n // Test getFailed\n await storage.postTracking.update(userId, pendingPost.atproto_uri, {\n sync_status: \"failed\",\n error_message: \"Test error\",\n });\n\n const failed = await storage.postTracking.getFailed(userId);\n assertEquals(failed.length, 1);\n assertEquals(failed[0].id, pendingPost.id);\n assertEquals(failed[0].sync_status, \"failed\");\n assertEquals(failed[0].error_message, \"Test error\");\n\n // Test getRecent\n const recent = await storage.postTracking.getRecent(userId);\n assertEquals(recent.length, 2);\n\n // Test getStats\n const stats = await storage.postTracking.getStats(userId);\n assertEquals(stats.total_posts, 2);\n assertEquals(stats.successful_posts, 1);\n assertEquals(stats.failed_posts, 1);\n assertEquals(stats.pending_posts, 0);\n assertEquals(typeof stats.last_sync, \"number\");\n\n // Test get non-existent\n const nonExistent = await storage.postTracking.get(\n \"non-existent\",\n \"non-existent\",\n );\n assertEquals(nonExistent, null);\n});\n\nDeno.test(\"InMemoryStorageProvider - sync logs\", async () => {\n const storage = new InMemoryStorageProvider();\n await storage.initialize();\n\n const userId = \"test-user-4\";\n\n // Test create\n const logData = {\n user_id: userId,\n sync_type: \"cron\" as const,\n posts_fetched: 5,\n posts_synced: 3,\n posts_failed: 2,\n posts_skipped: 0,\n duration_ms: 1500,\n cursor_end: \"cursor_123\",\n };\n\n const log = await storage.syncLogs.create(logData);\n\n assertEquals(log.user_id, userId);\n assertEquals(log.sync_type, \"cron\");\n assertEquals(log.posts_fetched, 5);\n assertEquals(log.posts_synced, 3);\n assertEquals(log.posts_failed, 2);\n assertEquals(log.duration_ms, 1500);\n assertEquals(log.cursor_end, \"cursor_123\");\n assertEquals(typeof log.created_at, \"number\");\n\n // Test create with error\n await new Promise((resolve) => setTimeout(resolve, 1)); // Ensure time difference\n const errorLogData = {\n user_id: userId,\n sync_type: \"manual\" as const,\n posts_fetched: 0,\n posts_synced: 0,\n posts_failed: 0,\n posts_skipped: 0,\n error_message: \"Test error occurred\",\n stack_trace: \"Error: Test error\\n at test.ts:123\",\n };\n\n const errorLog = await storage.syncLogs.create(errorLogData);\n assertEquals(errorLog.error_message, \"Test error occurred\");\n assertEquals(errorLog.stack_trace, \"Error: Test error\\n at test.ts:123\");\n\n // Test getRecent\n const recent = await storage.syncLogs.getRecent(userId);\n assertEquals(recent.length, 2);\n assertEquals(recent[0].id, errorLog.id); // Should be more recent\n assertEquals(recent[1].id, log.id);\n\n // Test getRecent with limit\n const recentLimited = await storage.syncLogs.getRecent(userId, 1);\n assertEquals(recentLimited.length, 1);\n assertEquals(recentLimited[0].id, errorLog.id);\n});\n\nDeno.test(\"InMemoryStorageProvider - test helpers\", async () => {\n const storage = new InMemoryStorageProvider();\n await storage.initialize();\n\n // Add some test data\n await storage.userAccounts.create(\"user1\");\n await storage.userAccounts.create(\"user2\");\n await storage.settings.create(\"user1\");\n await storage.postTracking.create({\n user_id: \"user1\",\n atproto_uri: \"at://test/1\",\n atproto_cid: \"cid1\",\n atproto_rkey: \"1\",\n content_hash: \"hash1\",\n atproto_created_at: Date.now(),\n });\n\n // Test size\n const size = storage.size();\n assertEquals(size.accounts, 2);\n assertEquals(size.settings, 1);\n assertEquals(size.posts, 1);\n assertEquals(size.logs, 0);\n\n // Test clear\n storage.clear();\n\n const sizeAfterClear = storage.size();\n assertEquals(sizeAfterClear.accounts, 0);\n assertEquals(sizeAfterClear.settings, 0);\n assertEquals(sizeAfterClear.posts, 0);\n assertEquals(sizeAfterClear.logs, 0);\n});\n\nDeno.test(\"InMemoryStorageProvider - concurrent operations\", async () => {\n const storage = new InMemoryStorageProvider();\n await storage.initialize();\n\n const userId = \"concurrent-user\";\n\n // Test concurrent user account operations\n const promises = [];\n for (let i = 0; i < 10; i++) {\n promises.push(storage.userAccounts.create(`${userId}-${i}`));\n }\n\n const accounts = await Promise.all(promises);\n assertEquals(accounts.length, 10);\n\n // Verify all accounts were created with unique IDs\n const ids = accounts.map((acc) => acc.id);\n const uniqueIds = new Set(ids);\n assertEquals(uniqueIds.size, 10);\n\n // Test concurrent updates\n const updatePromises = [];\n for (let i = 0; i < 10; i++) {\n updatePromises.push(\n storage.userAccounts.update(`${userId}-${i}`, {\n atproto_handle: `handle-${i}.bsky.social`,\n }),\n );\n }\n\n await Promise.all(updatePromises);\n\n // Verify all updates were applied\n for (let i = 0; i < 10; i++) {\n const account = await storage.userAccounts.get(`${userId}-${i}`);\n assertEquals(account?.atproto_handle, `handle-${i}.bsky.social`);\n }\n});\n\n// Run tests: deno test --allow-read --allow-write tests/storage.test.ts\n",[],[221,346],"2df9f1c0-63bc-11f0-9598-0224a6c84d84","post-transformer.test.ts","2df9f29c-63bc-11f0-9598-0224a6c84d84",13,["D",1752832032443],"// Unit tests for PostTransformer\n\nimport { assertEquals } from \"https://deno.land/std@0.208.0/assert/mod.ts\";\nimport { PostTransformer } from \"../backend/services/post-transformer.ts\";\nimport { ATProtoPost } from \"../shared/types.ts\";\n\n// Test helper to create sample ATProto post\nfunction createSamplePost(overrides: Partial = {}): ATProtoPost {\n return {\n uri: \"at://did:plc:test/app.bsky.feed.post/1\",\n cid: \"test_cid\",\n author: {\n did: \"did:plc:test\",\n handle: \"test.bsky.social\",\n displayName: \"Test User\",\n },\n record: {\n text: \"Hello world!\",\n createdAt: \"2024-01-01T10:00:00Z\",\n facets: [],\n },\n indexedAt: \"2024-01-01T10:00:00Z\",\n ...overrides,\n };\n}\n\nDeno.test(\"PostTransformer - should transform basic post\", () => {\n const post = createSamplePost();\n\n const result = PostTransformer.transformPost(post);\n\n assertEquals(result.text, \"Hello world!\");\n assertEquals(result.media.length, 0);\n assertEquals(result.mentions.length, 0);\n assertEquals(result.links.length, 0);\n assertEquals(result.hashtags.length, 0);\n});\n\nDeno.test(\"PostTransformer - should transform mentions to profile links\", () => {\n const post = createSamplePost({\n record: {\n text: \"Hello @alice.bsky.social!\",\n createdAt: \"2024-01-01T10:00:00Z\",\n facets: [{\n index: { byteStart: 6, byteEnd: 24 },\n features: [{\n $type: \"app.bsky.richtext.facet#mention\",\n did: \"did:plc:alice\",\n }],\n }],\n },\n });\n\n const result = PostTransformer.transformPost(post);\n\n assertEquals(\n result.text,\n \"Hello https://bsky.app/profile/alice.bsky.social!\",\n );\n assertEquals(result.mentions.length, 1);\n assertEquals(result.mentions[0].handle, \"alice.bsky.social\");\n assertEquals(\n result.mentions[0].profileUrl,\n \"https://bsky.app/profile/alice.bsky.social\",\n );\n});\n\nDeno.test(\"PostTransformer - should handle hashtags\", () => {\n const post = createSamplePost({\n record: {\n text: \"Hello #world!\",\n createdAt: \"2024-01-01T10:00:00Z\",\n facets: [{\n index: { byteStart: 6, byteEnd: 12 },\n features: [{\n $type: \"app.bsky.richtext.facet#tag\",\n tag: \"world\",\n }],\n }],\n },\n });\n\n const result = PostTransformer.transformPost(post);\n\n assertEquals(result.text, \"Hello #world!\");\n assertEquals(result.hashtags.length, 1);\n assertEquals(result.hashtags[0], \"world\");\n});\n\nDeno.test(\"PostTransformer - should handle links\", () => {\n const post = createSamplePost({\n record: {\n text: \"Check out https://example.com\",\n createdAt: \"2024-01-01T10:00:00Z\",\n facets: [{\n index: { byteStart: 10, byteEnd: 29 },\n features: [{\n $type: \"app.bsky.richtext.facet#link\",\n uri: \"https://example.com\",\n }],\n }],\n },\n });\n\n const result = PostTransformer.transformPost(post);\n\n assertEquals(result.text, \"Check out https://example.com\");\n assertEquals(result.links.length, 1);\n assertEquals(result.links[0].url, \"https://example.com\");\n assertEquals(result.links[0].displayText, \"https://example.com\");\n});\n\nDeno.test(\"PostTransformer - should handle image embeds\", () => {\n const post = createSamplePost({\n record: {\n text: \"Check out this image!\",\n createdAt: \"2024-01-01T10:00:00Z\",\n embed: {\n $type: \"app.bsky.embed.images\",\n images: [{\n alt: \"A beautiful sunset\",\n image: {\n ref: \"blob_ref_123\",\n mimeType: \"image/jpeg\",\n size: 1024000,\n },\n }],\n },\n },\n });\n\n const result = PostTransformer.transformPost(post);\n\n assertEquals(result.text, \"Check out this image!\");\n assertEquals(result.media.length, 1);\n assertEquals(result.media[0].type, \"image\");\n assertEquals(result.media[0].url, \"blob://blob_ref_123\");\n assertEquals(result.media[0].description, \"A beautiful sunset\");\n});\n\nDeno.test(\"PostTransformer - should handle video embeds\", () => {\n const post = createSamplePost({\n record: {\n text: \"Check out this video!\",\n createdAt: \"2024-01-01T10:00:00Z\",\n embed: {\n $type: \"app.bsky.embed.video\",\n video: {\n ref: \"blob_ref_456\",\n mimeType: \"video/mp4\",\n size: 5000000,\n },\n },\n },\n });\n\n const result = PostTransformer.transformPost(post);\n\n assertEquals(result.text, \"Check out this video!\");\n assertEquals(result.media.length, 1);\n assertEquals(result.media[0].type, \"video\");\n assertEquals(result.media[0].url, \"blob://blob_ref_456\");\n});\n\nDeno.test(\"PostTransformer - should generate consistent content hash\", () => {\n const post1 = createSamplePost();\n const post2 = createSamplePost();\n\n const hash1 = PostTransformer.generateContentHash(post1);\n const hash2 = PostTransformer.generateContentHash(post2);\n\n assertEquals(hash1, hash2);\n assertEquals(typeof hash1, \"string\");\n assertEquals(hash1.length > 0, true);\n});\n\nDeno.test(\"PostTransformer - should generate different hashes for different content\", () => {\n const post1 = createSamplePost({\n record: { text: \"Hello world!\", createdAt: \"2024-01-01T10:00:00Z\" },\n });\n const post2 = createSamplePost({\n record: { text: \"Different text!\", createdAt: \"2024-01-01T10:00:00Z\" },\n });\n\n const hash1 = PostTransformer.generateContentHash(post1);\n const hash2 = PostTransformer.generateContentHash(post2);\n\n assertEquals(hash1 !== hash2, true);\n});\n\nDeno.test(\"PostTransformer - should skip reply posts\", () => {\n const post = createSamplePost({\n record: {\n text: \"This is a reply\",\n createdAt: \"2024-01-01T10:00:00Z\",\n reply: {\n root: {\n uri: \"at://did:plc:test/app.bsky.feed.post/root\",\n cid: \"root_cid\",\n },\n parent: {\n uri: \"at://did:plc:test/app.bsky.feed.post/parent\",\n cid: \"parent_cid\",\n },\n },\n },\n });\n\n const shouldSkip = PostTransformer.shouldSkipPost(post);\n\n assertEquals(shouldSkip, true);\n});\n\nDeno.test(\"PostTransformer - should skip empty posts\", () => {\n const post = createSamplePost({\n record: {\n text: \"\",\n createdAt: \"2024-01-01T10:00:00Z\",\n },\n });\n\n const shouldSkip = PostTransformer.shouldSkipPost(post);\n\n assertEquals(shouldSkip, true);\n});\n\nDeno.test(\"PostTransformer - should not skip regular posts\", () => {\n const post = createSamplePost();\n\n const shouldSkip = PostTransformer.shouldSkipPost(post);\n\n assertEquals(shouldSkip, false);\n});\n\nDeno.test(\"PostTransformer - should format post for Mastodon\", () => {\n const transformation = {\n text: \"Hello world!\",\n media: [],\n mentions: [],\n links: [],\n hashtags: [],\n };\n\n const result = PostTransformer.formatForMastodon(transformation);\n\n assertEquals(result.status, \"Hello world!\");\n assertEquals(result.media.length, 0);\n});\n\nDeno.test(\"PostTransformer - should truncate long posts for Mastodon\", () => {\n const longText = \"A\".repeat(600); // Longer than 500 characters\n const transformation = {\n text: longText,\n media: [],\n mentions: [],\n links: [],\n hashtags: [],\n };\n\n const result = PostTransformer.formatForMastodon(transformation);\n\n assertEquals(result.status.length, 499);\n assertEquals(result.status.endsWith(\"...\"), true);\n});\n\nDeno.test(\"PostTransformer - should handle complex post with multiple facets\", () => {\n const post = createSamplePost({\n record: {\n text:\n \"Hello @alice.bsky.social! Check out #bluesky and visit https://example.com\",\n createdAt: \"2024-01-01T10:00:00Z\",\n facets: [\n {\n index: { byteStart: 6, byteEnd: 24 },\n features: [{\n $type: \"app.bsky.richtext.facet#mention\",\n did: \"did:plc:alice\",\n }],\n },\n {\n index: { byteStart: 35, byteEnd: 44 },\n features: [{\n $type: \"app.bsky.richtext.facet#tag\",\n tag: \"bluesky\",\n }],\n },\n {\n index: { byteStart: 55, byteEnd: 74 },\n features: [{\n $type: \"app.bsky.richtext.facet#link\",\n uri: \"https://example.com\",\n }],\n },\n ],\n },\n });\n\n const result = PostTransformer.transformPost(post);\n\n assertEquals(\n result.text,\n \"Hello https://bsky.app/profile/alice.bsky.social! Check out #bluesky and visit https://example.com\",\n );\n assertEquals(result.mentions.length, 1);\n assertEquals(result.mentions[0].handle, \"alice.bsky.social\");\n assertEquals(result.hashtags.length, 1);\n assertEquals(result.hashtags[0], \"bluesky\");\n assertEquals(result.links.length, 1);\n assertEquals(result.links[0].url, \"https://example.com\");\n});\n\n// Run tests: deno test --allow-read --allow-write tests/post-transformer.test.ts\n",[],[221,354],"70990402-63cc-11f0-8563-0224a6c84d84","oauth-flow.test.ts","2215883c-63cc-11f0-ae6d-0224a6c84d84",64,["D",1752839016159],"import { assertEquals, assertExists, assert } from \"https://deno.land/std@0.208.0/assert/mod.ts\";\n\n// Mock OAuth flow tests\nDeno.test(\"OAuth State Generation\", () => {\n function generateState(): string {\n return crypto.randomUUID();\n }\n \n const state1 = generateState();\n const state2 = generateState();\n \n // Should be valid UUIDs\n assert(state1.length === 36);\n assert(state2.length === 36);\n \n // Should be unique\n assert(state1 !== state2);\n \n // Should match UUID format\n const uuidPattern = /^[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}$/i;\n assert(uuidPattern.test(state1));\n assert(uuidPattern.test(state2));\n});\n\nDeno.test(\"Code Verifier Generation\", () => {\n function generateCodeVerifier(): string {\n const array = new Uint8Array(32);\n crypto.getRandomValues(array);\n return btoa(String.fromCharCode(...array))\n .replace(/\\+/g, \"-\")\n .replace(/\\//g, \"_\")\n .replace(/=/g, \"\");\n }\n \n const verifier1 = generateCodeVerifier();\n const verifier2 = generateCodeVerifier();\n \n // Should be base64url encoded\n assert(!verifier1.includes('='));\n assert(!verifier1.includes('+'));\n assert(!verifier1.includes('/'));\n \n // Should be unique\n assert(verifier1 !== verifier2);\n \n // Should be reasonable length (32 bytes base64url encoded)\n assert(verifier1.length > 40);\n});\n\nDeno.test(\"Code Challenge Generation\", async () => {\n async function generateCodeChallenge(verifier: string): Promise {\n const encoder = new TextEncoder();\n const data = encoder.encode(verifier);\n const digest = await crypto.subtle.digest(\"SHA-256\", data);\n return btoa(String.fromCharCode(...new Uint8Array(digest)))\n .replace(/\\+/g, \"-\")\n .replace(/\\//g, \"_\")\n .replace(/=/g, \"\");\n }\n \n const verifier = \"test-verifier-123\";\n const challenge1 = await generateCodeChallenge(verifier);\n const challenge2 = await generateCodeChallenge(verifier);\n \n // Should be deterministic\n assertEquals(challenge1, challenge2);\n \n // Should be base64url encoded\n assert(!challenge1.includes('='));\n assert(!challenge1.includes('+'));\n assert(!challenge1.includes('/'));\n \n // Should be 43 characters (32 bytes SHA-256 in base64url)\n assertEquals(challenge1.length, 43);\n});\n\nDeno.test(\"OAuth Authorization URL Construction\", () => {\n const baseUrl = \"https://example.com/oauth/authorize\";\n const authUrl = new URL(baseUrl);\n \n const params = {\n response_type: \"code\",\n client_id: \"test-client\",\n redirect_uri: \"https://app.example.com/callback\",\n scope: \"atproto transition:generic\",\n state: \"test-state\",\n code_challenge: \"test-challenge\",\n code_challenge_method: \"S256\"\n };\n \n Object.entries(params).forEach(([key, value]) => {\n authUrl.searchParams.set(key, value);\n });\n \n const urlString = authUrl.toString();\n \n // Should contain all required parameters\n assert(urlString.includes(\"response_type=code\"));\n assert(urlString.includes(\"client_id=test-client\"));\n assert(urlString.includes(\"scope=atproto+transition%3Ageneric\"));\n assert(urlString.includes(\"code_challenge_method=S256\"));\n});\n\nDeno.test(\"OAuth Token Exchange Parameters\", () => {\n const tokenParams = {\n grant_type: \"authorization_code\",\n code: \"test-code\",\n redirect_uri: \"https://app.example.com/callback\",\n client_id: \"test-client\",\n code_verifier: \"test-verifier\",\n };\n \n const formData = new URLSearchParams(tokenParams);\n const body = formData.toString();\n \n // Should contain all required parameters\n assert(body.includes(\"grant_type=authorization_code\"));\n assert(body.includes(\"code=test-code\"));\n assert(body.includes(\"redirect_uri=https%3A%2F%2Fapp.example.com%2Fcallback\"));\n assert(body.includes(\"client_id=test-client\"));\n assert(body.includes(\"code_verifier=test-verifier\"));\n});\n\nDeno.test(\"Cookie Security Settings\", () => {\n // Test that OAuth cookies have proper security settings\n const cookieOptions = {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\" as const,\n maxAge: 600, // 10 minutes\n };\n \n assertEquals(cookieOptions.httpOnly, true);\n assertEquals(cookieOptions.secure, true);\n assertEquals(cookieOptions.sameSite, \"Lax\");\n assertEquals(cookieOptions.maxAge, 600);\n});\n\nDeno.test(\"OAuth Error Handling\", () => {\n // Test error response structure\n const errorResponse = {\n error: \"invalid_request\",\n error_description: \"Missing required parameter\",\n };\n \n assertExists(errorResponse.error);\n assertExists(errorResponse.error_description);\n \n // Test error categorization\n const retryableErrors = [\"server_error\", \"temporarily_unavailable\"];\n const nonRetryableErrors = [\"invalid_request\", \"invalid_client\", \"unsupported_grant_type\"];\n \n assert(retryableErrors.includes(\"server_error\"));\n assert(nonRetryableErrors.includes(\"invalid_request\"));\n assert(!retryableErrors.includes(\"invalid_request\"));\n});\n\nDeno.test(\"DPoP Integration with OAuth\", async () => {\n // Test that DPoP keys are properly integrated into OAuth flow\n \n // Mock key generation\n const keyPair = await crypto.subtle.generateKey(\n { name: \"ECDSA\", namedCurve: \"P-256\" },\n true,\n [\"sign\", \"verify\"]\n );\n \n const publicJwk = await crypto.subtle.exportKey(\"jwk\", keyPair.publicKey);\n const privateJwk = await crypto.subtle.exportKey(\"jwk\", keyPair.privateKey);\n \n // Test key serialization for cookie storage\n const privateKeyStr = JSON.stringify(privateJwk);\n const publicKeyStr = JSON.stringify(publicJwk);\n \n // Should be serializable\n assertExists(privateKeyStr);\n assertExists(publicKeyStr);\n \n // Should be parseable\n const parsedPrivate = JSON.parse(privateKeyStr);\n const parsedPublic = JSON.parse(publicKeyStr);\n \n assertEquals(parsedPrivate.kty, \"EC\");\n assertEquals(parsedPublic.kty, \"EC\");\n assertEquals(parsedPrivate.crv, \"P-256\");\n assertEquals(parsedPublic.crv, \"P-256\");\n \n // Test key reimport\n const reimportedPrivate = await crypto.subtle.importKey(\n \"jwk\",\n parsedPrivate,\n { name: \"ECDSA\", namedCurve: \"P-256\" },\n false,\n [\"sign\"]\n );\n \n assertExists(reimportedPrivate);\n});\n\nDeno.test(\"OAuth Callback URL Parsing\", () => {\n // Test successful callback\n const successUrl = \"https://app.example.com/callback?code=test-code&state=test-state\";\n const successUrlObj = new URL(successUrl);\n \n const code = successUrlObj.searchParams.get(\"code\");\n const state = successUrlObj.searchParams.get(\"state\");\n \n assertEquals(code, \"test-code\");\n assertEquals(state, \"test-state\");\n \n // Test error callback\n const errorUrl = \"https://app.example.com/callback?error=access_denied&state=test-state\";\n const errorUrlObj = new URL(errorUrl);\n \n const error = errorUrlObj.searchParams.get(\"error\");\n const errorState = errorUrlObj.searchParams.get(\"state\");\n \n assertEquals(error, \"access_denied\");\n assertEquals(errorState, \"test-state\");\n});\n\nDeno.test(\"OAuth Session Management\", () => {\n // Test session data structure\n const sessionData = {\n state: \"test-state\",\n codeVerifier: \"test-verifier\",\n userId: \"test-user\",\n pdsUrl: \"https://pds.example.com\",\n dpopPrivateKey: \"serialized-key\",\n dpopPublicJwk: \"serialized-jwk\",\n };\n \n // All required fields should be present\n Object.values(sessionData).forEach(value => {\n assertExists(value);\n assert(typeof value === \"string\");\n });\n \n // Test session cleanup\n const cleanupSession = {\n state: \"\",\n codeVerifier: \"\",\n userId: \"\",\n pdsUrl: \"\",\n dpopPrivateKey: \"\",\n dpopPublicJwk: \"\",\n };\n \n Object.values(cleanupSession).forEach(value => {\n assertEquals(value, \"\");\n });\n});",[],[221,362],"70931baa-63cc-11f0-9639-0224a6c84d84","oauth-dpop.test.ts","2218b0ac-63cc-11f0-9bb3-0224a6c84d84",63,["D",1752839016155],"import { assertEquals, assertExists, assert } from \"https://deno.land/std@0.208.0/assert/mod.ts\";\n\n// Import the functions we need to test\n// We'll need to extract these from the oauth.ts file to make them testable\n\n// Mock the oauth functions for testing\nasync function generateDPoPKeyPair(): Promise<{\n publicKey: CryptoKey;\n privateKey: CryptoKey;\n jwk: JsonWebKey;\n}> {\n const keyPair = await crypto.subtle.generateKey(\n {\n name: \"ECDSA\",\n namedCurve: \"P-256\",\n },\n true,\n [\"sign\", \"verify\"]\n );\n \n const jwk = await crypto.subtle.exportKey(\"jwk\", keyPair.publicKey);\n \n return {\n publicKey: keyPair.publicKey,\n privateKey: keyPair.privateKey,\n jwk,\n };\n}\n\nfunction base64urlEncode(data: ArrayBuffer | Uint8Array): string {\n const uint8Array = data instanceof Uint8Array ? data : new Uint8Array(data);\n return btoa(String.fromCharCode(...uint8Array))\n .replace(/\\+/g, '-')\n .replace(/\\//g, '_')\n .replace(/=/g, '');\n}\n\nasync function createDPoPProof(\n privateKey: CryptoKey,\n jwk: JsonWebKey,\n method: string,\n url: string,\n nonce?: string\n): Promise {\n const header = {\n alg: \"ES256\",\n typ: \"dpop+jwt\",\n jwk: {\n kty: jwk.kty,\n crv: jwk.crv,\n x: jwk.x,\n y: jwk.y,\n },\n };\n \n const payload = {\n jti: crypto.randomUUID(),\n htm: method,\n htu: url,\n iat: Math.floor(Date.now() / 1000),\n ...(nonce && { nonce }),\n };\n \n // Encode header and payload\n const encodedHeader = base64urlEncode(new TextEncoder().encode(JSON.stringify(header)));\n const encodedPayload = base64urlEncode(new TextEncoder().encode(JSON.stringify(payload)));\n \n // Create the signing input\n const signingInput = `${encodedHeader}.${encodedPayload}`;\n \n // Sign using ECDSA with SHA-256\n const signature = await crypto.subtle.sign(\n { name: \"ECDSA\", hash: { name: \"SHA-256\" } },\n privateKey,\n new TextEncoder().encode(signingInput)\n );\n \n // Encode signature\n const encodedSignature = base64urlEncode(signature);\n \n return `${signingInput}.${encodedSignature}`;\n}\n\nfunction parseJWT(jwt: string): { header: any; payload: any; signature: string } {\n const parts = jwt.split('.');\n if (parts.length !== 3) {\n throw new Error('Invalid JWT format');\n }\n \n const header = JSON.parse(atob(parts[0].replace(/-/g, '+').replace(/_/g, '/')));\n const payload = JSON.parse(atob(parts[1].replace(/-/g, '+').replace(/_/g, '/')));\n \n return { header, payload, signature: parts[2] };\n}\n\nDeno.test(\"DPoP Key Generation\", async () => {\n const keyPair = await generateDPoPKeyPair();\n \n // Test that we get the expected structure\n assertExists(keyPair.publicKey);\n assertExists(keyPair.privateKey);\n assertExists(keyPair.jwk);\n \n // Test JWK properties\n assertEquals(keyPair.jwk.kty, \"EC\");\n assertEquals(keyPair.jwk.crv, \"P-256\");\n assertExists(keyPair.jwk.x);\n assertExists(keyPair.jwk.y);\n \n // Test that keys can be used for signing\n const testData = new TextEncoder().encode(\"test\");\n const signature = await crypto.subtle.sign(\n { name: \"ECDSA\", hash: { name: \"SHA-256\" } },\n keyPair.privateKey,\n testData\n );\n \n assertExists(signature);\n assert(signature.byteLength > 0);\n});\n\nDeno.test(\"Base64URL Encoding\", () => {\n // Test with Uint8Array\n const testData = new TextEncoder().encode(\"hello world\");\n const encoded = base64urlEncode(testData);\n \n // Should be base64url encoded (no padding, URL-safe characters)\n assert(!encoded.includes('='));\n assert(!encoded.includes('+'));\n assert(!encoded.includes('/'));\n \n // Test with ArrayBuffer\n const encoded2 = base64urlEncode(new Uint8Array(testData.buffer));\n assertEquals(encoded, encoded2);\n});\n\nDeno.test(\"DPoP JWT Creation\", async () => {\n const keyPair = await generateDPoPKeyPair();\n const method = \"POST\";\n const url = \"https://example.com/token\";\n \n const jwt = await createDPoPProof(keyPair.privateKey, keyPair.jwk, method, url);\n \n // Test JWT format\n const parts = jwt.split('.');\n assertEquals(parts.length, 3);\n \n // Parse and validate JWT\n const parsed = parseJWT(jwt);\n \n // Test header\n assertEquals(parsed.header.alg, \"ES256\");\n assertEquals(parsed.header.typ, \"dpop+jwt\");\n assertEquals(parsed.header.jwk.kty, \"EC\");\n assertEquals(parsed.header.jwk.crv, \"P-256\");\n assertExists(parsed.header.jwk.x);\n assertExists(parsed.header.jwk.y);\n \n // Test payload\n assertEquals(parsed.payload.htm, method);\n assertEquals(parsed.payload.htu, url);\n assertExists(parsed.payload.jti);\n assertExists(parsed.payload.iat);\n \n // Test that iat is reasonable (within last minute)\n const now = Math.floor(Date.now() / 1000);\n assert(parsed.payload.iat <= now);\n assert(parsed.payload.iat > now - 60);\n});\n\nDeno.test(\"DPoP JWT with Nonce\", async () => {\n const keyPair = await generateDPoPKeyPair();\n const method = \"POST\";\n const url = \"https://example.com/token\";\n const nonce = \"test-nonce-123\";\n \n const jwt = await createDPoPProof(keyPair.privateKey, keyPair.jwk, method, url, nonce);\n const parsed = parseJWT(jwt);\n \n assertEquals(parsed.payload.nonce, nonce);\n});\n\nDeno.test(\"DPoP JWT Signature Verification\", async () => {\n const keyPair = await generateDPoPKeyPair();\n const method = \"POST\";\n const url = \"https://example.com/token\";\n \n const jwt = await createDPoPProof(keyPair.privateKey, keyPair.jwk, method, url);\n const parts = jwt.split('.');\n \n // Verify signature\n const signingInput = `${parts[0]}.${parts[1]}`;\n const signature = new Uint8Array(\n atob(parts[2].replace(/-/g, '+').replace(/_/g, '/'))\n .split('')\n .map(c => c.charCodeAt(0))\n );\n \n const isValid = await crypto.subtle.verify(\n { name: \"ECDSA\", hash: { name: \"SHA-256\" } },\n keyPair.publicKey,\n signature,\n new TextEncoder().encode(signingInput)\n );\n \n assert(isValid);\n});\n\nDeno.test(\"DPoP JWT Unique JTI\", async () => {\n const keyPair = await generateDPoPKeyPair();\n const method = \"POST\";\n const url = \"https://example.com/token\";\n \n const jwt1 = await createDPoPProof(keyPair.privateKey, keyPair.jwk, method, url);\n const jwt2 = await createDPoPProof(keyPair.privateKey, keyPair.jwk, method, url);\n \n const parsed1 = parseJWT(jwt1);\n const parsed2 = parseJWT(jwt2);\n \n // JTI should be unique\n assert(parsed1.payload.jti !== parsed2.payload.jti);\n});\n\nDeno.test(\"DPoP Key Serialization\", async () => {\n const keyPair = await generateDPoPKeyPair();\n \n // Test that we can export and import the private key\n const privateKeyJwk = await crypto.subtle.exportKey(\"jwk\", keyPair.privateKey);\n \n const importedPrivateKey = await crypto.subtle.importKey(\n \"jwk\",\n privateKeyJwk,\n {\n name: \"ECDSA\",\n namedCurve: \"P-256\",\n },\n false,\n [\"sign\"]\n );\n \n // Test that imported key can sign\n const testData = new TextEncoder().encode(\"test\");\n const signature = await crypto.subtle.sign(\n { name: \"ECDSA\", hash: { name: \"SHA-256\" } },\n importedPrivateKey,\n testData\n );\n \n assertExists(signature);\n assert(signature.byteLength > 0);\n});\n\nDeno.test(\"DPoP JWT Different Methods and URLs\", async () => {\n const keyPair = await generateDPoPKeyPair();\n \n const testCases = [\n { method: \"GET\", url: \"https://example.com/api\" },\n { method: \"POST\", url: \"https://auth.example.com/token\" },\n { method: \"PUT\", url: \"https://api.example.com/data\" },\n ];\n \n for (const testCase of testCases) {\n const jwt = await createDPoPProof(keyPair.privateKey, keyPair.jwk, testCase.method, testCase.url);\n const parsed = parseJWT(jwt);\n \n assertEquals(parsed.payload.htm, testCase.method);\n assertEquals(parsed.payload.htu, testCase.url);\n }\n});\n\nDeno.test(\"DPoP Nonce Retry Flow\", async () => {\n const keyPair = await generateDPoPKeyPair();\n const method = \"POST\";\n const url = \"https://auth.example.com/token\";\n \n // First request without nonce\n const jwtWithoutNonce = await createDPoPProof(keyPair.privateKey, keyPair.jwk, method, url);\n const parsedWithoutNonce = parseJWT(jwtWithoutNonce);\n \n // Should not have nonce\n assertEquals(parsedWithoutNonce.payload.nonce, undefined);\n \n // Second request with nonce (simulating retry)\n const nonce = \"server-provided-nonce-123\";\n const jwtWithNonce = await createDPoPProof(keyPair.privateKey, keyPair.jwk, method, url, nonce);\n const parsedWithNonce = parseJWT(jwtWithNonce);\n \n // Should have nonce\n assertEquals(parsedWithNonce.payload.nonce, nonce);\n \n // Should have different JTI\n assert(parsedWithoutNonce.payload.jti !== parsedWithNonce.payload.jti);\n \n // Should have same method and URL\n assertEquals(parsedWithNonce.payload.htm, method);\n assertEquals(parsedWithNonce.payload.htu, url);\n});",[],[221,370],["D",1752832030993],[290,291,292,293,294],[221],"2e65b54a-63bc-11f0-8a50-0224a6c84d84","types.ts","2e65b5e0-63bc-11f0-8a50-0224a6c84d84",32,["D",1752832033172],"// Shared types for ATProto-to-Fediverse bridge\n\nexport interface ATProtoOAuthConfig {\n clientId: string; // https URL to client metadata\n redirectUri: string;\n scope: string;\n pdsUrl?: string; // Discovered from handle\n}\n\nexport interface MastodonOAuthConfig {\n instanceUrl: string;\n clientId: string;\n clientSecret: string;\n redirectUri: string;\n scope: string;\n}\n\nexport interface ATProtoPost {\n uri: string; // at:// URI\n cid: string;\n author: {\n did: string;\n handle: string;\n displayName?: string;\n avatar?: string;\n };\n record: {\n text: string;\n createdAt: string;\n embed?: {\n $type: string;\n images?: Array<{\n alt?: string;\n image: {\n ref: string;\n mimeType: string;\n size: number;\n };\n }>;\n video?: {\n ref: string;\n mimeType: string;\n size: number;\n };\n };\n facets?: Array<{\n index: {\n byteStart: number;\n byteEnd: number;\n };\n features: Array<{\n $type: string;\n did?: string; // for mentions\n uri?: string; // for links\n tag?: string; // for hashtags\n }>;\n }>;\n reply?: {\n root: { uri: string; cid: string };\n parent: { uri: string; cid: string };\n };\n };\n indexedAt: string;\n}\n\nexport interface MastodonPost {\n id: string;\n uri: string;\n url: string;\n content: string;\n created_at: string;\n media_attachments?: Array<{\n id: string;\n type: \"image\" | \"video\" | \"audio\";\n url: string;\n description?: string;\n }>;\n}\n\nexport interface MediaUpload {\n id: string;\n type: \"image\" | \"video\" | \"audio\";\n url: string;\n description?: string;\n}\n\nexport interface PostTransformation {\n text: string;\n media?: Array<{\n url: string;\n type: \"image\" | \"video\";\n description?: string;\n }>;\n mentions: Array<{\n handle: string;\n profileUrl: string;\n }>;\n links: Array<{\n url: string;\n displayText: string;\n }>;\n hashtags: string[];\n}\n\nexport interface SyncResult {\n success: boolean;\n postsProcessed: number;\n postsSuccessful: number;\n postsFailed: number;\n errors: Array<{\n postUri: string;\n message: string;\n retryable: boolean;\n }>;\n cursor?: string;\n}\n\nexport interface RetryConfig {\n maxRetries: number;\n baseDelay: number; // ms\n maxDelay: number; // ms\n backoffFactor: number;\n}\n\nexport interface BridgeConfig {\n atproto: ATProtoOAuthConfig;\n mastodon: MastodonOAuthConfig;\n sync: {\n enabled: boolean;\n intervalMinutes: number;\n batchSize: number;\n skipReplies: boolean;\n includeMedia: boolean;\n };\n retry: RetryConfig;\n}\n\nexport interface SetupStep {\n id: string;\n title: string;\n description: string;\n completed: boolean;\n error?: string;\n}\n\nexport interface SetupState {\n currentStep: number;\n steps: SetupStep[];\n userId: string;\n atprotoConnected: boolean;\n mastodonConnected: boolean;\n setupCompleted: boolean;\n}\n\nexport interface DashboardStats {\n totalPosts: number;\n successfulPosts: number;\n failedPosts: number;\n pendingPosts: number;\n lastSyncAt?: number;\n isConnected: boolean;\n syncEnabled: boolean;\n nextSyncAt?: number;\n}\n\nexport interface PostStatus {\n atprotoUri: string;\n atprotoCreatedAt: number;\n mastodonId?: string;\n mastodonUrl?: string;\n status: \"pending\" | \"success\" | \"failed\" | \"skipped\";\n errorMessage?: string;\n retryCount: number;\n syncedAt?: number;\n contentPreview: string;\n}\n",[],[227,381],["D",1752832031448],[288],[227],"9d3e7d78-63c9-11f0-8ff0-0224a6c84d84","setup.tsx","9d3e7e2c-63c9-11f0-8ff0-0224a6c84d84",51,["D",1752837802447],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState } from \"https://esm.sh/react@18.2.0\";\nimport ReactDOM from \"https://esm.sh/react-dom@18.2.0/client\";\n\ninterface SetupState {\n step: \"start\" | \"connecting-bluesky\" | \"connecting-mastodon\" | \"complete\";\n userId: string | null;\n error: string | null;\n loading: boolean;\n}\n\nfunction SetupApp() {\n const [state, setState] = useState({\n step: \"start\",\n userId: null,\n error: null,\n loading: false,\n });\n\n const [blueskyHandle, setBlueskyHandle] = useState(\"\");\n const [mastodonInstance, setMastodonInstance] = useState(\"\");\n\n const apiCall = async (endpoint: string, options: RequestInit = {}) => {\n const response = await fetch(`/api${endpoint}`, {\n headers: {\n \"Content-Type\": \"application/json\",\n ...options.headers,\n },\n ...options,\n });\n\n if (!response.ok) {\n const error = await response.json();\n throw new Error(error.error || \"API call failed\");\n }\n\n return response.json();\n };\n\n const startSetup = async () => {\n setState({ ...state, loading: true, error: null });\n try {\n const result = await apiCall(\"/setup/start\", { method: \"POST\" });\n setState({\n ...state,\n userId: result.userId,\n step: \"connecting-bluesky\",\n loading: false,\n });\n } catch (error) {\n setState({\n ...state,\n error: error.message,\n loading: false,\n });\n }\n };\n\n const connectBluesky = async () => {\n if (!blueskyHandle) {\n setState({ ...state, error: \"Please enter your Bluesky handle\" });\n return;\n }\n\n setState({ ...state, loading: true, error: null });\n try {\n const result = await apiCall(\n `/oauth/atproto/start?handle=${\n encodeURIComponent(blueskyHandle)\n }&user_id=${state.userId}`,\n );\n globalThis.location.href = result.authUrl;\n } catch (error) {\n setState({\n ...state,\n error: error.message,\n loading: false,\n });\n }\n };\n\n const connectMastodon = async () => {\n if (!mastodonInstance) {\n setState({ ...state, error: \"Please enter your Mastodon instance\" });\n return;\n }\n\n setState({ ...state, loading: true, error: null });\n try {\n const result = await apiCall(\n `/oauth/mastodon/start?instance_url=${\n encodeURIComponent(mastodonInstance)\n }&user_id=${state.userId}`,\n );\n globalThis.location.href = result.authUrl;\n } catch (error) {\n setState({\n ...state,\n error: error.message,\n loading: false,\n });\n }\n };\n\n const completeSetup = async () => {\n setState({ ...state, loading: true, error: null });\n try {\n await apiCall(`/setup/complete/${state.userId}`, { method: \"POST\" });\n globalThis.location.href = `/dashboard?user_id=${state.userId}`;\n } catch (error) {\n setState({\n ...state,\n error: error.message,\n loading: false,\n });\n }\n };\n\n // Check URL params for OAuth callbacks\n React.useEffect(() => {\n const params = new URLSearchParams(globalThis.location.search);\n const step = params.get(\"step\");\n const userId = params.get(\"user_id\");\n\n if (userId) {\n setState((prev) => ({ ...prev, userId }));\n }\n\n if (step === \"mastodon\") {\n setState((prev) => ({ ...prev, step: \"connecting-mastodon\" }));\n } else if (step === \"complete\") {\n setState((prev) => ({ ...prev, step: \"complete\" }));\n }\n }, []);\n\n return (\n

\n Setup Your Bridge\n

\n Connect your Bluesky account to Mastodon for automatic cross-posting\n

\n\n {state.error && (\n

{state.error}

\n )}\n\n {state.step === \"start\" && (\n

\n \n {state.loading ? \"Starting...\" : \"Get Started\"}\n \n

\n )}\n\n {state.step === \"connecting-bluesky\" && (\n

Step 1: Connect Bluesky

\n Enter your Bluesky handle to connect your account\n

\n \n Bluesky Handle\n \n setBlueskyHandle(e.target.value)}\n placeholder=\"your-handle.bsky.social\"\n className=\"w-full p-3 border border-gray-300 rounded-lg focus:outline-none focus:ring-2 focus:ring-blue-500\"\n />\n

\n \n {state.loading ? \"Connecting...\" : \"Connect Bluesky Account\"}\n \n

\n )}\n\n {state.step === \"connecting-mastodon\" && (\n

\n Step 2: Connect Mastodon\n

\n Enter your Mastodon instance to connect your account\n

\n \n Mastodon Instance\n \n setMastodonInstance(e.target.value)}\n placeholder=\"mastodon.social\"\n className=\"w-full p-3 border border-gray-300 rounded-lg focus:outline-none focus:ring-2 focus:ring-blue-500\"\n />\n

\n \n {state.loading ? \"Connecting...\" : \"Connect Mastodon Account\"}\n \n

\n )}\n\n {state.step === \"complete\" && (\n

Setup Complete!

\n ✓ Both accounts connected successfully\n

\n Your bridge is ready to start syncing posts from Bluesky to\n Mastodon.\n

\n \n {state.loading ? \"Completing...\" : \"Go to Dashboard\"}\n \n

\n )}\n

\n );\n}\n\n// Initialize React app\nconst root = ReactDOM.createRoot(document.getElementById(\"root\")!);\nroot.render();\n",[],[233,392],"9d293698-63c9-11f0-9e90-0224a6c84d84","setup.html","9d29376a-63c9-11f0-9e90-0224a6c84d84",49,["D",1752837802443],"\n\n \n \n \n Setup - ATProto to Fediverse Bridge\n \n \n \n \n

\n \n \n\n",[],[233,400],"3e367d8a-63ce-11f0-a837-0224a6c84d84","index.html","2de5d848-63bc-11f0-8513-0224a6c84d84",66,["D",1752839790658],"\n\n\n \n \n ATProto to Fediverse Bridge\n \n \n \n\n\n

\n \n \n\n",[],[233,408],"3e3a25c0-63ce-11f0-956b-0224a6c84d84","dashboard.tsx","3e3a267e-63ce-11f0-956b-0224a6c84d84",67,["D",1752839790670],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport ReactDOM from \"https://esm.sh/react-dom@18.2.0/client\";\n\ninterface DashboardData {\n user: {\n id: string;\n atproto_handle?: string;\n mastodon_username?: string;\n setup_completed: boolean;\n };\n settings: {\n sync_enabled: boolean;\n sync_interval_minutes: number;\n };\n stats: {\n posts_synced: number;\n last_sync: string | null;\n sync_errors: number;\n };\n recent_posts: Array<{\n id: string;\n atproto_uri: string;\n mastodon_url?: string;\n status: \"success\" | \"failed\" | \"pending\";\n created_at: string;\n error_message?: string;\n }>;\n}\n\nfunction Dashboard() {\n const [data, setData] = useState(null);\n const [loading, setLoading] = useState(true);\n const [error, setError] = useState(null);\n\n const userId = new URLSearchParams(globalThis.location.search).get(\"user_id\");\n\n useEffect(() => {\n if (!userId) {\n setError(\"User ID not found in URL\");\n setLoading(false);\n return;\n }\n\n fetchDashboardData();\n }, [userId]);\n\n const fetchDashboardData = async () => {\n try {\n setLoading(true);\n const response = await fetch(`/api/dashboard/${userId}`);\n\n if (!response.ok) {\n throw new Error(`Dashboard data fetch failed: ${response.status}`);\n }\n\n const dashboardData = await response.json();\n setData(dashboardData);\n } catch (error) {\n console.error(\"Dashboard fetch error:\", error);\n setError(error.message || \"Failed to load dashboard\");\n } finally {\n setLoading(false);\n }\n };\n\n const toggleSync = async () => {\n if (!data) return;\n\n try {\n const response = await fetch(`/api/settings/${userId}`, {\n method: \"PUT\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n sync_enabled: !data.settings.sync_enabled,\n }),\n });\n\n if (!response.ok) {\n throw new Error(\"Failed to update sync settings\");\n }\n\n // Refresh dashboard data\n await fetchDashboardData();\n } catch (error) {\n console.error(\"Toggle sync error:\", error);\n setError(error.message || \"Failed to toggle sync\");\n }\n };\n\n const triggerManualSync = async () => {\n try {\n const response = await fetch(`/api/sync/${userId}`, {\n method: \"POST\",\n });\n\n if (!response.ok) {\n throw new Error(\"Manual sync failed\");\n }\n\n // Refresh dashboard data after sync\n setTimeout(() => {\n fetchDashboardData();\n }, 2000);\n } catch (error) {\n console.error(\"Manual sync error:\", error);\n setError(error.message || \"Failed to trigger sync\");\n }\n };\n\n if (loading) {\n return (\n

\n Loading Dashboard...\n

\n Please wait while we load your data\n

\n );\n }\n\n if (error) {\n return (\n

Error

{error}

\n globalThis.location.href = \"/setup\"}\n className=\"bg-blue-600 text-white px-4 py-2 rounded-lg hover:bg-blue-700\"\n >\n Back to Setup\n \n

\n );\n }\n\n if (!data) {\n return (\n

\n No Data Available\n

\n );\n }\n\n return (\n

\n Bridge Dashboard\n

\n globalThis.location.href = \"/setup\"}\n className=\"text-blue-600 hover:text-blue-800\"\n >\n Back to Setup\n \n

\n\n {/* Connection Status */}\n

Account Connections

\n Bluesky\n \n {data.user.atproto_handle\n ? `@${data.user.atproto_handle}`\n : \"Not Connected\"}\n \n

\n Mastodon\n \n {data.user.mastodon_username\n ? `@${data.user.mastodon_username}`\n : \"Not Connected\"}\n \n

\n\n

Sync Settings

\n Auto Sync\n \n {data.settings.sync_enabled ? \"Enabled\" : \"Disabled\"}\n \n

\n Sync Interval\n \n {data.settings.sync_interval_minutes} minutes\n \n

\n\n {/* Stats */}\n

\n {data.stats.posts_synced}\n

Posts Synced

\n {data.stats.last_sync\n ? new Date(data.stats.last_sync).toLocaleDateString()\n : \"Never\"}\n

Last Sync

\n {data.stats.sync_errors}\n

Sync Errors

\n\n {/* Manual Sync */}\n

Manual Sync

\n Trigger a manual sync to check for new posts from Bluesky\n

\n \n Sync Now\n \n

\n\n {/* Recent Posts */}\n

Recent Posts

\n {data.recent_posts.length === 0\n ? (\n

\n No posts synced yet. Make a post on Bluesky to see it appear\n here!\n

\n )\n : (\n

\n {data.recent_posts.map((post) => (\n

\n \n {new Date(post.created_at).toLocaleString()}\n \n \n {post.status}\n \n

\n Bluesky: {post.atproto_uri}\n

\n {post.mastodon_url && (\n

\n Mastodon:\n \n {post.mastodon_url}\n \n

\n )}\n {post.error_message && (\n

\n Error: {post.error_message}\n

\n )}\n

\n ))}\n

\n )}\n

\n );\n}\n\n// Initialize React app\nconst root = ReactDOM.createRoot(document.getElementById(\"root\")!);\nroot.render();\n",[],[233,416],"3e3ffb08-63ce-11f0-aa58-0224a6c84d84",["D",1752839790686],[],[233,32],["D",1752832030845],[282,283,284,285,286],[233],"1c2ee3e8-63ca-11f0-9b65-0224a6c84d84","index.ts",54,["D",1752838015507],"http","import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport {\n readFile,\n serveFile,\n} from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { runMigrations } from \"./database/migrations.ts\";\nimport oauthRoutes from \"./routes/oauth.ts\";\nimport setupRoutes from \"./routes/setup.ts\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err, _c) => {\n throw err;\n});\n\n// Initialize database on startup\nawait runMigrations();\n\n// API routes\napp.route(\"/api/oauth\", oauthRoutes);\napp.route(\"/api/setup\", setupRoutes);\n\n// Health check endpoint\napp.get(\"/api/health\", (c) => {\n return c.json({\n status: \"healthy\",\n timestamp: new Date().toISOString(),\n service: \"atproto-to-fediverse-bridge\",\n });\n});\n\n// Debug endpoint to check environment variables\napp.get(\"/api/debug/env\", (c) => {\n const clientId = Deno.env.get(\"ATPROTO_CLIENT_ID\") || \"\";\n return c.json({\n clientId,\n clientIdLength: clientId.length,\n clientIdEncoded: encodeURIComponent(clientId),\n hasExtraChars: clientId.includes(\"+++\"),\n });\n});\n\n// Serve client metadata for ATProto OAuth\napp.get(\"/client-metadata.json\", async (c) => {\n const clientMetadata = await readFile(\n \"/client-metadata.json\",\n import.meta.url,\n );\n c.header(\"Content-Type\", \"application/json\");\n return c.body(clientMetadata);\n});\n\n// Alternative shorter client metadata endpoint\napp.get(\"/client\", async (c) => {\n const clientMetadata = await readFile(\n \"/client-metadata-short.json\",\n import.meta.url,\n );\n c.header(\"Content-Type\", \"application/json\");\n return c.body(clientMetadata);\n});\n\n// Serve static files\napp.get(\"/frontend/*\", (c) => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", (c) => serveFile(c.req.path, import.meta.url));\n\n// Serve main application\napp.get(\"/\", async (c) => {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n\n // Basic data injection for initial page load\n const initialData = {\n appName: \"ATProto-to-Fediverse Bridge\",\n version: \"1.0.0\",\n };\n\n const dataScript = ``;\n\n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n});\n\n// Setup wizard routes\napp.get(\"/setup\", async (c) => {\n const html = await readFile(\"/frontend/setup.html\", import.meta.url);\n return c.html(html);\n});\n\n// Dashboard route\napp.get(\"/dashboard\", async (c) => {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n\n // Inject dashboard-specific data\n const dashboardData = {\n mode: \"dashboard\",\n userId: c.req.query(\"user_id\") || null,\n };\n\n const dataScript = ``;\n\n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n});\n\n// This is the entry point for HTTP vals\nexport default app.fetch;\n",[],[238,431],"2e2a6760-63bc-11f0-bcef-0224a6c84d84","sqlite-storage.ts","2e2a6800-63bc-11f0-bcef-0224a6c84d84","2d8adc36-63bc-11f0-bd30-0224a6c84d84",22,["D",1752832032774],"// SQLite implementation of storage interfaces\n\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { runMigrations, TABLES } from \"../database/migrations.ts\";\nimport {\n PostTracking,\n PostTrackingStorage,\n Settings,\n SettingsStorage,\n StorageProvider,\n SyncLog,\n SyncLogStorage,\n SyncStats,\n UserAccount,\n UserAccountStorage,\n} from \"../interfaces/storage.ts\";\n\nexport class SQLiteUserAccountStorage implements UserAccountStorage {\n async create(userId: string): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${TABLES.USER_ACCOUNTS} (user_id) VALUES (?) RETURNING *`,\n [userId],\n );\n return result.rows[0] as UserAccount;\n }\n\n async get(userId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.USER_ACCOUNTS} WHERE user_id = ?`,\n [userId],\n );\n return result.rows[0] as UserAccount || null;\n }\n\n async update(userId: string, updates: Partial): Promise {\n const fields = Object.keys(updates).map((key) => `${key} = ?`).join(\", \");\n const values = Object.values(updates);\n\n await sqlite.execute(\n `UPDATE ${TABLES.USER_ACCOUNTS} SET ${fields}, updated_at = unixepoch() WHERE user_id = ?`,\n [...values, userId],\n );\n }\n\n async getForSync(): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.USER_ACCOUNTS} WHERE setup_completed = TRUE`,\n );\n return result.rows as UserAccount[];\n }\n}\n\nexport class SQLiteSettingsStorage implements SettingsStorage {\n async create(userId: string): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${TABLES.SETTINGS} (user_id) VALUES (?) RETURNING *`,\n [userId],\n );\n return result.rows[0] as Settings;\n }\n\n async get(userId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.SETTINGS} WHERE user_id = ?`,\n [userId],\n );\n return result.rows[0] as Settings || null;\n }\n\n async update(userId: string, updates: Partial): Promise {\n const fields = Object.keys(updates).map((key) => `${key} = ?`).join(\", \");\n const values = Object.values(updates);\n\n await sqlite.execute(\n `UPDATE ${TABLES.SETTINGS} SET ${fields}, updated_at = unixepoch() WHERE user_id = ?`,\n [...values, userId],\n );\n }\n}\n\nexport class SQLitePostTrackingStorage implements PostTrackingStorage {\n async create(data: {\n user_id: string;\n atproto_uri: string;\n atproto_cid: string;\n atproto_rkey: string;\n content_hash: string;\n atproto_created_at: number;\n }): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${TABLES.POST_TRACKING} \n (user_id, atproto_uri, atproto_cid, atproto_rkey, content_hash, atproto_created_at) \n VALUES (?, ?, ?, ?, ?, ?) RETURNING *`,\n [\n data.user_id,\n data.atproto_uri,\n data.atproto_cid,\n data.atproto_rkey,\n data.content_hash,\n data.atproto_created_at,\n ],\n );\n return result.rows[0] as PostTracking;\n }\n\n async get(userId: string, atprotoUri: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.POST_TRACKING} WHERE user_id = ? AND atproto_uri = ?`,\n [userId, atprotoUri],\n );\n return result.rows[0] as PostTracking || null;\n }\n\n async update(\n userId: string,\n atprotoUri: string,\n updates: Partial,\n ): Promise {\n const fields = Object.keys(updates).map((key) => `${key} = ?`).join(\", \");\n const values = Object.values(updates);\n\n await sqlite.execute(\n `UPDATE ${TABLES.POST_TRACKING} SET ${fields}, updated_at = unixepoch() WHERE user_id = ? AND atproto_uri = ?`,\n [...values, userId, atprotoUri],\n );\n }\n\n async getPending(userId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.POST_TRACKING} \n WHERE user_id = ? AND sync_status = 'pending' AND retry_count < max_retries\n ORDER BY atproto_created_at ASC`,\n [userId],\n );\n return result.rows as PostTracking[];\n }\n\n async getFailed(userId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.POST_TRACKING} \n WHERE user_id = ? AND sync_status = 'failed'\n ORDER BY updated_at DESC`,\n [userId],\n );\n return result.rows as PostTracking[];\n }\n\n async getRecent(userId: string, limit: number = 50): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.POST_TRACKING} \n WHERE user_id = ? \n ORDER BY atproto_created_at DESC \n LIMIT ?`,\n [userId, limit],\n );\n return result.rows as PostTracking[];\n }\n\n async getStats(userId: string): Promise {\n const result = await sqlite.execute(\n `\n SELECT \n COUNT(*) as total_posts,\n SUM(CASE WHEN sync_status = 'success' THEN 1 ELSE 0 END) as successful_posts,\n SUM(CASE WHEN sync_status = 'failed' THEN 1 ELSE 0 END) as failed_posts,\n SUM(CASE WHEN sync_status = 'pending' THEN 1 ELSE 0 END) as pending_posts,\n MAX(synced_at) as last_sync\n FROM ${TABLES.POST_TRACKING} \n WHERE user_id = ?\n `,\n [userId],\n );\n\n return result.rows[0] as SyncStats;\n }\n}\n\nexport class SQLiteSyncLogStorage implements SyncLogStorage {\n async create(data: {\n user_id: string;\n sync_type: \"manual\" | \"cron\" | \"webhook\";\n posts_fetched: number;\n posts_synced: number;\n posts_failed: number;\n posts_skipped: number;\n error_message?: string;\n stack_trace?: string;\n duration_ms?: number;\n cursor_start?: string;\n cursor_end?: string;\n }): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${TABLES.SYNC_LOGS} \n (user_id, sync_type, posts_fetched, posts_synced, posts_failed, posts_skipped, error_message, stack_trace, duration_ms, cursor_start, cursor_end) \n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) RETURNING *`,\n [\n data.user_id,\n data.sync_type,\n data.posts_fetched,\n data.posts_synced,\n data.posts_failed,\n data.posts_skipped,\n data.error_message,\n data.stack_trace,\n data.duration_ms,\n data.cursor_start,\n data.cursor_end,\n ],\n );\n return result.rows[0] as SyncLog;\n }\n\n async getRecent(userId: string, limit: number = 20): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.SYNC_LOGS} \n WHERE user_id = ? \n ORDER BY created_at DESC \n LIMIT ?`,\n [userId, limit],\n );\n return result.rows as SyncLog[];\n }\n}\n\nexport class SQLiteStorageProvider implements StorageProvider {\n public userAccounts: UserAccountStorage;\n public settings: SettingsStorage;\n public postTracking: PostTrackingStorage;\n public syncLogs: SyncLogStorage;\n\n constructor() {\n this.userAccounts = new SQLiteUserAccountStorage();\n this.settings = new SQLiteSettingsStorage();\n this.postTracking = new SQLitePostTrackingStorage();\n this.syncLogs = new SQLiteSyncLogStorage();\n }\n\n async initialize(): Promise {\n await runMigrations();\n }\n}\n",[],[238,447,439],"storage","2e270fe8-63bc-11f0-a804-0224a6c84d84","memory-storage.ts","2e271092-63bc-11f0-a804-0224a6c84d84",21,["D",1752832032775],"// In-memory implementation of storage interfaces for testing\n\nimport {\n PostTracking,\n PostTrackingStorage,\n Settings,\n SettingsStorage,\n StorageProvider,\n SyncLog,\n SyncLogStorage,\n SyncStats,\n UserAccount,\n UserAccountStorage,\n} from \"../interfaces/storage.ts\";\n\nexport class InMemoryUserAccountStorage implements UserAccountStorage {\n private accounts = new Map();\n private nextId = 1;\n\n create(userId: string): Promise {\n const account: UserAccount = {\n id: this.nextId++,\n user_id: userId,\n setup_completed: false,\n created_at: Date.now(),\n updated_at: Date.now(),\n };\n this.accounts.set(userId, account);\n return Promise.resolve(account);\n }\n\n get(userId: string): Promise {\n return Promise.resolve(this.accounts.get(userId) || null);\n }\n\n update(userId: string, updates: Partial): Promise {\n const account = this.accounts.get(userId);\n if (account) {\n Object.assign(account, updates, { updated_at: Date.now() });\n this.accounts.set(userId, account);\n }\n return Promise.resolve();\n }\n\n getForSync(): Promise {\n return Promise.resolve(\n Array.from(this.accounts.values()).filter((acc) => acc.setup_completed),\n );\n }\n\n // Test helpers\n clear(): void {\n this.accounts.clear();\n this.nextId = 1;\n }\n\n size(): number {\n return this.accounts.size;\n }\n}\n\nexport class InMemorySettingsStorage implements SettingsStorage {\n private settings = new Map();\n private nextId = 1;\n\n create(userId: string): Promise {\n const setting: Settings = {\n id: this.nextId++,\n user_id: userId,\n sync_enabled: true,\n sync_interval_minutes: 15,\n skip_replies: true,\n skip_mentions: false,\n skip_reposts: false,\n include_media: true,\n compress_images: false,\n created_at: Date.now(),\n updated_at: Date.now(),\n };\n this.settings.set(userId, setting);\n return Promise.resolve(setting);\n }\n\n get(userId: string): Promise {\n return Promise.resolve(this.settings.get(userId) || null);\n }\n\n update(userId: string, updates: Partial): Promise {\n const setting = this.settings.get(userId);\n if (setting) {\n Object.assign(setting, updates, { updated_at: Date.now() });\n this.settings.set(userId, setting);\n }\n return Promise.resolve();\n }\n\n // Test helpers\n clear(): void {\n this.settings.clear();\n this.nextId = 1;\n }\n\n size(): number {\n return this.settings.size;\n }\n}\n\nexport class InMemoryPostTrackingStorage implements PostTrackingStorage {\n private posts = new Map();\n private nextId = 1;\n\n private getKey(userId: string, atprotoUri: string): string {\n return `${userId}:${atprotoUri}`;\n }\n\n create(data: {\n user_id: string;\n atproto_uri: string;\n atproto_cid: string;\n atproto_rkey: string;\n content_hash: string;\n atproto_created_at: number;\n }): Promise {\n const post: PostTracking = {\n id: this.nextId++,\n user_id: data.user_id,\n atproto_uri: data.atproto_uri,\n atproto_cid: data.atproto_cid,\n atproto_rkey: data.atproto_rkey,\n content_hash: data.content_hash,\n sync_status: \"pending\",\n retry_count: 0,\n max_retries: 3,\n atproto_created_at: data.atproto_created_at,\n created_at: Date.now(),\n updated_at: Date.now(),\n };\n const key = this.getKey(data.user_id, data.atproto_uri);\n this.posts.set(key, post);\n return Promise.resolve(post);\n }\n\n get(userId: string, atprotoUri: string): Promise {\n const key = this.getKey(userId, atprotoUri);\n return Promise.resolve(this.posts.get(key) || null);\n }\n\n update(\n userId: string,\n atprotoUri: string,\n updates: Partial,\n ): Promise {\n const key = this.getKey(userId, atprotoUri);\n const post = this.posts.get(key);\n if (post) {\n Object.assign(post, updates, { updated_at: Date.now() });\n this.posts.set(key, post);\n }\n return Promise.resolve();\n }\n\n getPending(userId: string): Promise {\n return Promise.resolve(\n Array.from(this.posts.values())\n .filter((post) =>\n post.user_id === userId &&\n post.sync_status === \"pending\" &&\n post.retry_count < post.max_retries\n )\n .sort((a, b) => a.atproto_created_at - b.atproto_created_at),\n );\n }\n\n getFailed(userId: string): Promise {\n return Promise.resolve(\n Array.from(this.posts.values())\n .filter((post) =>\n post.user_id === userId && post.sync_status === \"failed\"\n )\n .sort((a, b) => b.updated_at - a.updated_at),\n );\n }\n\n getRecent(userId: string, limit: number = 50): Promise {\n return Promise.resolve(\n Array.from(this.posts.values())\n .filter((post) => post.user_id === userId)\n .sort((a, b) => b.atproto_created_at - a.atproto_created_at)\n .slice(0, limit),\n );\n }\n\n getStats(userId: string): Promise {\n const userPosts = Array.from(this.posts.values()).filter((post) =>\n post.user_id === userId\n );\n\n const stats = {\n total_posts: userPosts.length,\n successful_posts:\n userPosts.filter((p) => p.sync_status === \"success\").length,\n failed_posts: userPosts.filter((p) => p.sync_status === \"failed\").length,\n pending_posts:\n userPosts.filter((p) => p.sync_status === \"pending\").length,\n last_sync: userPosts\n .filter((p) => p.synced_at)\n .reduce((latest, post) => Math.max(latest, post.synced_at!), 0) || null,\n };\n\n return Promise.resolve(stats);\n }\n\n // Test helpers\n clear(): void {\n this.posts.clear();\n this.nextId = 1;\n }\n\n size(): number {\n return this.posts.size;\n }\n\n getAllByUser(userId: string): PostTracking[] {\n return Array.from(this.posts.values()).filter((post) =>\n post.user_id === userId\n );\n }\n}\n\nexport class InMemorySyncLogStorage implements SyncLogStorage {\n private logs = new Map();\n private nextId = 1;\n\n create(data: {\n user_id: string;\n sync_type: \"manual\" | \"cron\" | \"webhook\";\n posts_fetched: number;\n posts_synced: number;\n posts_failed: number;\n posts_skipped: number;\n error_message?: string;\n stack_trace?: string;\n duration_ms?: number;\n cursor_start?: string;\n cursor_end?: string;\n }): Promise {\n const log: SyncLog = {\n id: this.nextId++,\n user_id: data.user_id,\n sync_type: data.sync_type,\n posts_fetched: data.posts_fetched,\n posts_synced: data.posts_synced,\n posts_failed: data.posts_failed,\n posts_skipped: data.posts_skipped,\n error_message: data.error_message,\n stack_trace: data.stack_trace,\n duration_ms: data.duration_ms,\n cursor_start: data.cursor_start,\n cursor_end: data.cursor_end,\n created_at: Date.now(),\n };\n this.logs.set(log.id, log);\n return Promise.resolve(log);\n }\n\n getRecent(userId: string, limit: number = 20): Promise {\n return Promise.resolve(\n Array.from(this.logs.values())\n .filter((log) => log.user_id === userId)\n .sort((a, b) => b.created_at - a.created_at)\n .slice(0, limit),\n );\n }\n\n // Test helpers\n clear(): void {\n this.logs.clear();\n this.nextId = 1;\n }\n\n size(): number {\n return this.logs.size;\n }\n\n getAllByUser(userId: string): SyncLog[] {\n return Array.from(this.logs.values()).filter((log) =>\n log.user_id === userId\n );\n }\n}\n\nexport class InMemoryStorageProvider implements StorageProvider {\n public userAccounts: InMemoryUserAccountStorage;\n public settings: InMemorySettingsStorage;\n public postTracking: InMemoryPostTrackingStorage;\n public syncLogs: InMemorySyncLogStorage;\n\n constructor() {\n this.userAccounts = new InMemoryUserAccountStorage();\n this.settings = new InMemorySettingsStorage();\n this.postTracking = new InMemoryPostTrackingStorage();\n this.syncLogs = new InMemorySyncLogStorage();\n }\n\n initialize(): Promise {\n // No initialization needed for in-memory storage\n return Promise.resolve();\n }\n\n // Test helpers\n clear(): void {\n this.userAccounts.clear();\n this.settings.clear();\n this.postTracking.clear();\n this.syncLogs.clear();\n }\n\n size(): { accounts: number; settings: number; posts: number; logs: number } {\n return {\n accounts: this.userAccounts.size(),\n settings: this.settings.size(),\n posts: this.postTracking.size(),\n logs: this.syncLogs.size(),\n };\n }\n}\n",[],[238,447,449],"2d8adb6e-63bc-11f0-bd30-0224a6c84d84",7,["D",1752832031750],[278,279],[238,447],"2e4561aa-63bc-11f0-ab6c-0224a6c84d84","sync-service.ts","2e456286-63bc-11f0-ab6c-0224a6c84d84","2db6fbea-63bc-11f0-ab6c-0224a6c84d84",27,["D",1752832032971],"import { ATProtoClient } from \"./atproto-client.ts\";\nimport { MastodonClient } from \"./mastodon-client.ts\";\nimport { PostTransformer } from \"./post-transformer.ts\";\nimport {\n createPostTracking,\n createSyncLog,\n getPostTracking,\n getSettings,\n getUserAccountsForSync,\n updatePostTracking,\n updateUserAccount,\n} from \"../database/queries.ts\";\nimport { RetryConfig, SyncResult } from \"../../shared/types.ts\";\n\nexport class SyncService {\n private static readonly DEFAULT_RETRY_CONFIG: RetryConfig = {\n maxRetries: 3,\n baseDelay: 1000, // 1 second\n maxDelay: 30000, // 30 seconds\n backoffFactor: 2,\n };\n\n /**\n * Sync posts for all users\n */\n static async syncAllUsers(): Promise {\n const startTime = Date.now();\n console.log(\"Starting sync for all users...\");\n\n try {\n const userAccounts = await getUserAccountsForSync();\n console.log(`Found ${userAccounts.length} users to sync`);\n\n for (const account of userAccounts) {\n try {\n await this.syncUser(account.user_id);\n } catch (error) {\n console.error(`Failed to sync user ${account.user_id}:`, error);\n\n // Log the error\n await createSyncLog({\n user_id: account.user_id,\n sync_type: \"cron\",\n posts_fetched: 0,\n posts_synced: 0,\n posts_failed: 0,\n posts_skipped: 0,\n error_message: error instanceof Error\n ? error.message\n : \"Unknown error\",\n stack_trace: error instanceof Error ? error.stack : null,\n duration_ms: Date.now() - startTime,\n });\n }\n }\n } catch (error) {\n console.error(\"Global sync error:\", error);\n }\n\n console.log(`Sync completed in ${Date.now() - startTime}ms`);\n }\n\n /**\n * Sync posts for a specific user\n */\n static async syncUser(userId: string): Promise {\n const startTime = Date.now();\n const result: SyncResult = {\n success: false,\n postsProcessed: 0,\n postsSuccessful: 0,\n postsFailed: 0,\n errors: [],\n };\n\n try {\n const account = await getUserAccountsForSync().then((accounts) =>\n accounts.find((a) => a.user_id === userId)\n );\n\n if (!account) {\n throw new Error(\"User account not found or not properly configured\");\n }\n\n const settings = await getSettings(userId);\n if (!settings?.sync_enabled) {\n console.log(`Sync disabled for user ${userId}`);\n return { ...result, success: true };\n }\n\n // Initialize clients\n const atprotoClient = new ATProtoClient(\n account.atproto_pds_url!,\n account.atproto_access_token!,\n account.atproto_did!,\n );\n\n const mastodonClient = new MastodonClient(\n account.mastodon_instance_url!,\n account.mastodon_access_token!,\n );\n\n // Get posts since last sync\n const sinceTime = account.last_sync_at\n ? new Date(account.last_sync_at).toISOString()\n : new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString(); // 24 hours ago\n\n const { posts, cursor } = await atprotoClient.fetchPostsSince(\n sinceTime,\n 50,\n );\n result.postsProcessed = posts.length;\n\n console.log(`Found ${posts.length} posts for user ${userId}`);\n\n // Process each post\n for (const post of posts) {\n try {\n // Skip posts that should not be synced\n if (PostTransformer.shouldSkipPost(post)) {\n console.log(`Skipping post ${post.uri} (reply or empty)`);\n continue;\n }\n\n // Check if post already exists\n const existingPost = await getPostTracking(userId, post.uri);\n if (existingPost) {\n console.log(`Post ${post.uri} already tracked`);\n continue;\n }\n\n // Create tracking record\n const contentHash = PostTransformer.generateContentHash(post);\n const _tracking = await createPostTracking({\n user_id: userId,\n atproto_uri: post.uri,\n atproto_cid: post.cid,\n atproto_rkey: post.uri.split(\"/\").pop()!,\n content_hash: contentHash,\n atproto_created_at: new Date(post.record.createdAt).getTime(),\n });\n\n // Transform post\n const transformation = PostTransformer.transformPost(post);\n\n // Resolve blob URLs if needed\n const resolvedTransformation = await PostTransformer.resolveBlobUrls(\n transformation,\n account.atproto_pds_url!,\n account.atproto_access_token!,\n );\n\n // Cross-post to Mastodon with retry logic\n const mastodonPost = await this.crossPostWithRetry(\n mastodonClient,\n resolvedTransformation,\n this.DEFAULT_RETRY_CONFIG,\n );\n\n // Update tracking record\n await updatePostTracking(userId, post.uri, {\n mastodon_id: mastodonPost.id,\n mastodon_url: mastodonPost.url,\n sync_status: \"success\",\n synced_at: Date.now(),\n });\n\n result.postsSuccessful++;\n console.log(\n `Successfully synced post ${post.uri} to ${mastodonPost.url}`,\n );\n } catch (error) {\n result.postsFailed++;\n const errorMessage = error instanceof Error\n ? error.message\n : \"Unknown error\";\n\n result.errors.push({\n postUri: post.uri,\n message: errorMessage,\n retryable: this.isRetryableError(error),\n });\n\n // Update tracking record with error\n await updatePostTracking(userId, post.uri, {\n sync_status: \"failed\",\n error_message: errorMessage,\n retry_count: 0,\n });\n\n console.error(`Failed to sync post ${post.uri}:`, error);\n }\n }\n\n // Update last sync time and cursor\n await updateUserAccount(userId, {\n last_sync_at: Date.now(),\n last_sync_cursor: cursor,\n });\n\n result.success = true;\n result.cursor = cursor;\n } catch (error) {\n console.error(`User sync error for ${userId}:`, error);\n result.errors.push({\n postUri: \"general\",\n message: error instanceof Error ? error.message : \"Unknown error\",\n retryable: false,\n });\n }\n\n // Log sync operation\n await createSyncLog({\n user_id: userId,\n sync_type: \"cron\",\n posts_fetched: result.postsProcessed,\n posts_synced: result.postsSuccessful,\n posts_failed: result.postsFailed,\n posts_skipped: result.postsProcessed - result.postsSuccessful -\n result.postsFailed,\n error_message: result.errors.length > 0 ? result.errors[0].message : null,\n duration_ms: Date.now() - startTime,\n });\n\n return result;\n }\n\n /**\n * Cross-post to Mastodon with retry logic\n */\n private static async crossPostWithRetry(\n mastodonClient: MastodonClient,\n transformation: any,\n retryConfig: RetryConfig,\n ): Promise {\n let lastError: Error | null = null;\n\n for (let attempt = 0; attempt <= retryConfig.maxRetries; attempt++) {\n try {\n return await mastodonClient.crossPost(transformation);\n } catch (error) {\n lastError = error instanceof Error ? error : new Error(\"Unknown error\");\n\n if (attempt === retryConfig.maxRetries) {\n throw lastError;\n }\n\n if (!this.isRetryableError(error)) {\n throw lastError;\n }\n\n // Calculate delay with exponential backoff\n const delay = Math.min(\n retryConfig.baseDelay * Math.pow(retryConfig.backoffFactor, attempt),\n retryConfig.maxDelay,\n );\n\n console.log(`Retry attempt ${attempt + 1} in ${delay}ms`);\n await new Promise((resolve) => setTimeout(resolve, delay));\n }\n }\n\n throw lastError;\n }\n\n /**\n * Check if an error is retryable\n */\n private static isRetryableError(error: unknown): boolean {\n if (!(error instanceof Error)) return false;\n\n const message = error.message.toLowerCase();\n\n // Network errors\n if (\n message.includes(\"fetch\") || message.includes(\"network\") ||\n message.includes(\"timeout\")\n ) {\n return true;\n }\n\n // HTTP 5xx errors\n if (\n message.includes(\"500\") || message.includes(\"502\") ||\n message.includes(\"503\") || message.includes(\"504\")\n ) {\n return true;\n }\n\n // Rate limiting\n if (message.includes(\"429\") || message.includes(\"rate limit\")) {\n return true;\n }\n\n // Media processing errors\n if (message.includes(\"media processing\")) {\n return true;\n }\n\n return false;\n }\n\n /**\n * Retry failed posts for a user\n */\n static retryFailedPosts(_userId: string): Promise {\n // Implementation for retrying failed posts\n // This would fetch posts with sync_status = 'failed' and retry_count < max_retries\n // Similar to syncUser but focused on failed posts\n throw new Error(\"Not implemented yet\");\n }\n}\n",[],[238,470,462],"services","2e4e13e0-63bc-11f0-8513-0224a6c84d84","sync-service-di.ts","2e4e1494-63bc-11f0-8513-0224a6c84d84",28,["D",1752832033029],"// Dependency-injected sync service for better testability\n\nimport { StorageProvider } from \"../interfaces/storage.ts\";\nimport {\n ATProtoHttpClient,\n MastodonHttpClient,\n} from \"../interfaces/http-client.ts\";\nimport { PostTransformer } from \"./post-transformer.ts\";\nimport { ATProtoPost, RetryConfig, SyncResult } from \"../../shared/types.ts\";\n\nexport interface SyncServiceDependencies {\n storage: StorageProvider;\n createATProtoClient: (\n pdsUrl: string,\n accessToken: string,\n did: string,\n ) => ATProtoHttpClient;\n createMastodonClient: (\n instanceUrl: string,\n accessToken: string,\n ) => MastodonHttpClient;\n retryConfig?: RetryConfig;\n}\n\nexport class SyncService {\n private storage: StorageProvider;\n private createATProtoClient: (\n pdsUrl: string,\n accessToken: string,\n did: string,\n ) => ATProtoHttpClient;\n private createMastodonClient: (\n instanceUrl: string,\n accessToken: string,\n ) => MastodonHttpClient;\n private retryConfig: RetryConfig;\n\n constructor(dependencies: SyncServiceDependencies) {\n this.storage = dependencies.storage;\n this.createATProtoClient = dependencies.createATProtoClient;\n this.createMastodonClient = dependencies.createMastodonClient;\n this.retryConfig = dependencies.retryConfig || {\n maxRetries: 3,\n baseDelay: 1000,\n maxDelay: 30000,\n backoffFactor: 2,\n };\n }\n\n /**\n * Sync posts for all users\n */\n async syncAllUsers(): Promise {\n const startTime = Date.now();\n console.log(\"Starting sync for all users...\");\n\n try {\n const userAccounts = await this.storage.userAccounts.getForSync();\n console.log(`Found ${userAccounts.length} users to sync`);\n\n for (const account of userAccounts) {\n try {\n await this.syncUser(account.user_id);\n } catch (error) {\n console.error(`Failed to sync user ${account.user_id}:`, error);\n\n // Log the error\n await this.storage.syncLogs.create({\n user_id: account.user_id,\n sync_type: \"cron\",\n posts_fetched: 0,\n posts_synced: 0,\n posts_failed: 0,\n posts_skipped: 0,\n error_message: error instanceof Error\n ? error.message\n : \"Unknown error\",\n stack_trace: error instanceof Error ? error.stack : undefined,\n duration_ms: Date.now() - startTime,\n });\n }\n }\n } catch (error) {\n console.error(\"Global sync error:\", error);\n }\n\n console.log(`Sync completed in ${Date.now() - startTime}ms`);\n }\n\n /**\n * Sync posts for a specific user\n */\n async syncUser(userId: string): Promise {\n const startTime = Date.now();\n const result: SyncResult = {\n success: false,\n postsProcessed: 0,\n postsSuccessful: 0,\n postsFailed: 0,\n errors: [],\n };\n\n try {\n // Get user account\n const account = await this.storage.userAccounts.get(userId);\n if (!account) {\n throw new Error(\"User account not found\");\n }\n\n // Check if user has completed setup\n if (!account.setup_completed) {\n throw new Error(\"User setup not completed\");\n }\n\n // Get settings\n const settings = await this.storage.settings.get(userId);\n if (!settings?.sync_enabled) {\n console.log(`Sync disabled for user ${userId}`);\n return { ...result, success: true };\n }\n\n // Validate required tokens\n if (\n !account.atproto_access_token || !account.atproto_pds_url ||\n !account.atproto_did\n ) {\n throw new Error(\"Missing ATProto credentials\");\n }\n\n if (!account.mastodon_access_token || !account.mastodon_instance_url) {\n throw new Error(\"Missing Mastodon credentials\");\n }\n\n // Initialize clients\n const atprotoClient = this.createATProtoClient(\n account.atproto_pds_url,\n account.atproto_access_token,\n account.atproto_did,\n );\n\n const mastodonClient = this.createMastodonClient(\n account.mastodon_instance_url,\n account.mastodon_access_token,\n );\n\n // Get posts since last sync\n const sinceTime = account.last_sync_at\n ? new Date(account.last_sync_at).toISOString()\n : new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString(); // 24 hours ago\n\n const posts = await this.fetchPostsSince(\n atprotoClient,\n account.atproto_did,\n sinceTime,\n 50,\n );\n result.postsProcessed = posts.length;\n\n console.log(`Found ${posts.length} posts for user ${userId}`);\n\n // Process each post\n for (const post of posts) {\n try {\n // Skip posts that should not be synced\n if (PostTransformer.shouldSkipPost(post)) {\n console.log(`Skipping post ${post.uri} (reply or empty)`);\n continue;\n }\n\n // Check if post already exists\n const existingPost = await this.storage.postTracking.get(\n userId,\n post.uri,\n );\n if (existingPost) {\n console.log(`Post ${post.uri} already tracked`);\n continue;\n }\n\n // Create tracking record\n const contentHash = PostTransformer.generateContentHash(post);\n await this.storage.postTracking.create({\n user_id: userId,\n atproto_uri: post.uri,\n atproto_cid: post.cid,\n atproto_rkey: post.uri.split(\"/\").pop()!,\n content_hash: contentHash,\n atproto_created_at: new Date(post.record.createdAt).getTime(),\n });\n\n // Transform post\n const transformation = PostTransformer.transformPost(post);\n\n // Resolve blob URLs if needed\n const resolvedTransformation = await PostTransformer.resolveBlobUrls(\n transformation,\n account.atproto_pds_url,\n account.atproto_access_token,\n );\n\n // Cross-post to Mastodon with retry logic\n const mastodonPost = await this.crossPostWithRetry(\n mastodonClient,\n resolvedTransformation,\n );\n\n // Update tracking record\n await this.storage.postTracking.update(userId, post.uri, {\n mastodon_id: mastodonPost.id,\n mastodon_url: mastodonPost.url,\n sync_status: \"success\",\n synced_at: Date.now(),\n });\n\n result.postsSuccessful++;\n console.log(\n `Successfully synced post ${post.uri} to ${mastodonPost.url}`,\n );\n } catch (error) {\n result.postsFailed++;\n const errorMessage = error instanceof Error\n ? error.message\n : \"Unknown error\";\n\n result.errors.push({\n postUri: post.uri,\n message: errorMessage,\n retryable: this.isRetryableError(error),\n });\n\n // Update tracking record with error\n await this.storage.postTracking.update(userId, post.uri, {\n sync_status: \"failed\",\n error_message: errorMessage,\n retry_count: 0,\n });\n\n console.error(`Failed to sync post ${post.uri}:`, error);\n }\n }\n\n // Update last sync time\n await this.storage.userAccounts.update(userId, {\n last_sync_at: Date.now(),\n });\n\n result.success = true;\n } catch (error) {\n console.error(`User sync error for ${userId}:`, error);\n result.errors.push({\n postUri: \"general\",\n message: error instanceof Error ? error.message : \"Unknown error\",\n retryable: false,\n });\n }\n\n // Log sync operation\n await this.storage.syncLogs.create({\n user_id: userId,\n sync_type: \"cron\",\n posts_fetched: result.postsProcessed,\n posts_synced: result.postsSuccessful,\n posts_failed: result.postsFailed,\n posts_skipped: result.postsProcessed - result.postsSuccessful -\n result.postsFailed,\n error_message: result.errors.length > 0\n ? result.errors[0].message\n : undefined,\n duration_ms: Date.now() - startTime,\n });\n\n return result;\n }\n\n /**\n * Fetch posts since a specific time\n */\n private async fetchPostsSince(\n atprotoClient: ATProtoHttpClient,\n actorDid: string,\n sinceTime: string,\n limit: number = 50,\n ): Promise {\n // This is a simplified implementation\n // The actual implementation would need to handle pagination and filtering\n const response = await atprotoClient.fetchPosts({\n actor: actorDid,\n limit,\n cursor: undefined,\n });\n\n // Filter posts by time and transform to ATProtoPost format\n return response.feed\n .filter((item: any) => item.post.record.createdAt > sinceTime)\n .map((item: any) => ({\n uri: item.post.uri,\n cid: item.post.cid,\n author: item.post.author,\n record: item.post.record,\n indexedAt: item.post.indexedAt,\n }));\n }\n\n /**\n * Cross-post to Mastodon with retry logic\n */\n private async crossPostWithRetry(\n mastodonClient: MastodonHttpClient,\n transformation: any,\n ): Promise {\n let lastError: Error | null = null;\n\n for (let attempt = 0; attempt <= this.retryConfig.maxRetries; attempt++) {\n try {\n // Upload media if present\n const mediaIds: string[] = [];\n if (transformation.media.length > 0) {\n for (const media of transformation.media) {\n try {\n const uploadedMedia = await mastodonClient.uploadMedia(\n new Blob(), // This would be the actual media blob\n media.description,\n );\n mediaIds.push(uploadedMedia.id);\n } catch (error) {\n console.error(`Failed to upload media: ${media.url}`, error);\n }\n }\n }\n\n // Create the post\n const post = await mastodonClient.createPost({\n status: transformation.text,\n media_ids: mediaIds,\n visibility: \"public\",\n });\n\n return post;\n } catch (error) {\n lastError = error instanceof Error ? error : new Error(\"Unknown error\");\n\n if (attempt === this.retryConfig.maxRetries) {\n throw lastError;\n }\n\n if (!this.isRetryableError(error)) {\n throw lastError;\n }\n\n // Calculate delay with exponential backoff\n const delay = Math.min(\n this.retryConfig.baseDelay *\n Math.pow(this.retryConfig.backoffFactor, attempt),\n this.retryConfig.maxDelay,\n );\n\n console.log(`Retry attempt ${attempt + 1} in ${delay}ms`);\n await new Promise((resolve) => setTimeout(resolve, delay));\n }\n }\n\n throw lastError;\n }\n\n /**\n * Check if an error is retryable\n */\n private isRetryableError(error: unknown): boolean {\n if (!(error instanceof Error)) return false;\n\n const message = error.message.toLowerCase();\n\n // Network errors\n if (\n message.includes(\"fetch\") || message.includes(\"network\") ||\n message.includes(\"timeout\")\n ) {\n return true;\n }\n\n // HTTP 5xx errors\n if (\n message.includes(\"500\") || message.includes(\"502\") ||\n message.includes(\"503\") || message.includes(\"504\")\n ) {\n return true;\n }\n\n // Rate limiting\n if (message.includes(\"429\") || message.includes(\"rate limit\")) {\n return true;\n }\n\n // Media processing errors\n if (message.includes(\"media processing\")) {\n return true;\n }\n\n return false;\n }\n}\n",[],[238,470,472],"2e566c84-63bc-11f0-a804-0224a6c84d84","post-transformer.ts","2e566d2e-63bc-11f0-a804-0224a6c84d84",30,["D",1752832033085],"import { ATProtoPost, PostTransformation } from \"../../shared/types.ts\";\n\nexport class PostTransformer {\n /**\n * Transform an ATProto post to a format suitable for Mastodon\n */\n static transformPost(post: ATProtoPost): PostTransformation {\n const { record } = post;\n let text = record.text;\n const mentions: PostTransformation[\"mentions\"] = [];\n const links: PostTransformation[\"links\"] = [];\n const hashtags: string[] = [];\n const media: PostTransformation[\"media\"] = [];\n\n // Process facets (mentions, links, hashtags)\n if (record.facets) {\n // Sort facets by byteStart in descending order to avoid index shifting when replacing\n const sortedFacets = [...record.facets].sort((a, b) =>\n b.index.byteStart - a.index.byteStart\n );\n\n for (const facet of sortedFacets) {\n const { byteStart, byteEnd } = facet.index;\n const originalText = text.slice(byteStart, byteEnd);\n\n for (const feature of facet.features) {\n switch (feature.$type) {\n case \"app.bsky.richtext.facet#mention\":\n if (feature.did) {\n // Convert ATProto mention to Bluesky profile link\n const handle = originalText.replace(\"@\", \"\");\n const profileUrl = `https://bsky.app/profile/${handle}`;\n mentions.push({ handle, profileUrl });\n\n // Replace mention with profile link\n text = text.slice(0, byteStart) + profileUrl +\n text.slice(byteEnd);\n }\n break;\n\n case \"app.bsky.richtext.facet#link\":\n if (feature.uri) {\n links.push({\n url: feature.uri,\n displayText: originalText,\n });\n // Links are already in the text, no need to replace\n }\n break;\n\n case \"app.bsky.richtext.facet#tag\":\n if (feature.tag) {\n hashtags.push(feature.tag);\n // Hashtags are already in the text, no need to replace\n }\n break;\n }\n }\n }\n }\n\n // Process media embeds\n if (record.embed) {\n switch (record.embed.$type) {\n case \"app.bsky.embed.images\":\n if (record.embed.images) {\n for (const image of record.embed.images) {\n media.push({\n url: `blob://${image.image.ref}`, // Will be resolved to actual URL later\n type: \"image\",\n description: image.alt || \"\",\n });\n }\n }\n break;\n\n case \"app.bsky.embed.video\":\n if (record.embed.video) {\n media.push({\n url: `blob://${record.embed.video.ref}`, // Will be resolved to actual URL later\n type: \"video\",\n description: \"\",\n });\n }\n break;\n\n case \"app.bsky.embed.external\":\n // External links are handled by facets\n break;\n }\n }\n\n return {\n text: text.trim(),\n media,\n mentions,\n links,\n hashtags,\n };\n }\n\n /**\n * Generate a content hash for duplicate detection\n */\n static generateContentHash(post: ATProtoPost): string {\n const content = {\n text: post.record.text,\n createdAt: post.record.createdAt,\n author: post.author.did,\n embed: post.record.embed ? JSON.stringify(post.record.embed) : null,\n };\n\n return this.hashString(JSON.stringify(content));\n }\n\n /**\n * Simple hash function for content\n */\n private static hashString(str: string): string {\n let hash = 0;\n for (let i = 0; i < str.length; i++) {\n const char = str.charCodeAt(i);\n hash = ((hash << 5) - hash) + char;\n hash = hash & hash; // Convert to 32-bit integer\n }\n return hash.toString(16);\n }\n\n /**\n * Check if a post should be skipped (replies, etc.)\n */\n static shouldSkipPost(post: ATProtoPost): boolean {\n // Skip replies (posts with reply references)\n if (post.record.reply) {\n return true;\n }\n\n // Skip if post has no content\n if (!post.record.text.trim() && !post.record.embed) {\n return true;\n }\n\n return false;\n }\n\n /**\n * Resolve blob URLs to actual URLs\n */\n static async resolveBlobUrls(\n transformation: PostTransformation,\n pdsUrl: string,\n accessToken: string,\n ): Promise {\n const resolvedMedia = await Promise.all(\n transformation.media.map(async (item) => {\n if (item.url.startsWith(\"blob://\")) {\n const blobRef = item.url.replace(\"blob://\", \"\");\n try {\n // Get blob URL from PDS\n const response = await fetch(\n `${pdsUrl}/xrpc/com.atproto.sync.getBlob?did=${blobRef}`,\n {\n headers: {\n \"Authorization\": `Bearer ${accessToken}`,\n },\n },\n );\n\n if (response.ok) {\n return {\n ...item,\n url: response.url,\n };\n }\n } catch (error) {\n console.error(\"Failed to resolve blob URL:\", error);\n }\n }\n return item;\n }),\n );\n\n return {\n ...transformation,\n media: resolvedMedia,\n };\n }\n\n /**\n * Format post for Mastodon (respecting character limits)\n */\n static formatForMastodon(transformation: PostTransformation): {\n status: string;\n media: PostTransformation[\"media\"];\n } {\n let status = transformation.text;\n\n // Mastodon has a 500 character limit by default\n // If post is too long, truncate and add indication\n const maxLength = 500;\n if (status.length > maxLength) {\n status = status.substring(0, maxLength - 4) + \"...\";\n }\n\n return {\n status,\n media: transformation.media,\n };\n }\n}\n",[],[238,470,480],"2e538b54-63bc-11f0-8a50-0224a6c84d84","mastodon-client.ts","2e538bf4-63bc-11f0-8a50-0224a6c84d84",29,["D",1752832032912],"import {\n MastodonPost,\n MediaUpload,\n PostTransformation,\n} from \"../../shared/types.ts\";\n\nexport class MastodonClient {\n private instanceUrl: string;\n private accessToken: string;\n\n constructor(instanceUrl: string, accessToken: string) {\n this.instanceUrl = instanceUrl.replace(/\\/$/, \"\"); // Remove trailing slash\n this.accessToken = accessToken;\n }\n\n /**\n * Upload media to Mastodon\n */\n async uploadMedia(\n mediaUrl: string,\n mediaType: \"image\" | \"video\",\n description?: string,\n ): Promise {\n try {\n // Fetch media from source\n const mediaResponse = await fetch(mediaUrl);\n if (!mediaResponse.ok) {\n throw new Error(`Failed to fetch media: ${mediaResponse.status}`);\n }\n\n const mediaBlob = await mediaResponse.blob();\n\n // Create form data\n const formData = new FormData();\n formData.append(\"file\", mediaBlob);\n if (description) {\n formData.append(\"description\", description);\n }\n\n // Upload to Mastodon\n const uploadResponse = await fetch(`${this.instanceUrl}/api/v2/media`, {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${this.accessToken}`,\n },\n body: formData,\n });\n\n if (!uploadResponse.ok) {\n const errorText = await uploadResponse.text();\n throw new Error(\n `Media upload failed: ${uploadResponse.status} ${errorText}`,\n );\n }\n\n const mediaAttachment = await uploadResponse.json();\n\n // Wait for processing if needed (for videos)\n if (mediaType === \"video\" && mediaAttachment.url === null) {\n await this.waitForMediaProcessing(mediaAttachment.id);\n }\n\n return {\n id: mediaAttachment.id,\n type: mediaType,\n url: mediaAttachment.url,\n description: description,\n };\n } catch (error) {\n console.error(\"Media upload error:\", error);\n throw error;\n }\n }\n\n /**\n * Wait for media processing to complete\n */\n private async waitForMediaProcessing(\n mediaId: string,\n maxWaitTime = 30000,\n ): Promise {\n const startTime = Date.now();\n\n while (Date.now() - startTime < maxWaitTime) {\n try {\n const response = await fetch(\n `${this.instanceUrl}/api/v1/media/${mediaId}`,\n {\n headers: {\n \"Authorization\": `Bearer ${this.accessToken}`,\n },\n },\n );\n\n if (response.ok) {\n const media = await response.json();\n if (media.url) {\n return; // Processing complete\n }\n }\n\n // Wait 2 seconds before checking again\n await new Promise((resolve) => setTimeout(resolve, 2000));\n } catch (error) {\n console.error(\"Error checking media processing status:\", error);\n // Continue waiting\n }\n }\n\n throw new Error(\"Media processing timeout\");\n }\n\n /**\n * Create a post on Mastodon\n */\n async createPost(\n status: string,\n mediaIds: string[] = [],\n options: {\n visibility?: \"public\" | \"unlisted\" | \"private\" | \"direct\";\n sensitive?: boolean;\n spoilerText?: string;\n } = {},\n ): Promise {\n try {\n const requestBody: any = {\n status,\n visibility: options.visibility || \"public\",\n };\n\n if (mediaIds.length > 0) {\n requestBody.media_ids = mediaIds;\n }\n\n if (options.sensitive) {\n requestBody.sensitive = true;\n }\n\n if (options.spoilerText) {\n requestBody.spoiler_text = options.spoilerText;\n }\n\n const response = await fetch(`${this.instanceUrl}/api/v1/statuses`, {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${this.accessToken}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(requestBody),\n });\n\n if (!response.ok) {\n const errorText = await response.text();\n throw new Error(\n `Post creation failed: ${response.status} ${errorText}`,\n );\n }\n\n const post = await response.json();\n\n return {\n id: post.id,\n uri: post.uri,\n url: post.url,\n content: post.content,\n created_at: post.created_at,\n media_attachments: post.media_attachments,\n };\n } catch (error) {\n console.error(\"Post creation error:\", error);\n throw error;\n }\n }\n\n /**\n * Cross-post from transformed ATProto content\n */\n async crossPost(transformation: PostTransformation): Promise {\n try {\n const mediaIds: string[] = [];\n\n // Upload media if present\n if (transformation.media.length > 0) {\n for (const media of transformation.media) {\n try {\n const uploadedMedia = await this.uploadMedia(\n media.url,\n media.type,\n media.description,\n );\n mediaIds.push(uploadedMedia.id);\n } catch (error) {\n console.error(`Failed to upload media: ${media.url}`, error);\n // Continue with other media or without this one\n }\n }\n }\n\n // Format the post\n const { status } = this.formatPost(transformation);\n\n // Create the post\n const post = await this.createPost(status, mediaIds, {\n visibility: \"public\",\n });\n\n return post;\n } catch (error) {\n console.error(\"Cross-post error:\", error);\n throw error;\n }\n }\n\n /**\n * Format post content for Mastodon\n */\n private formatPost(transformation: PostTransformation): { status: string } {\n let status = transformation.text;\n\n // Mastodon character limit (typically 500, but can be configured per instance)\n const maxLength = 500;\n\n if (status.length > maxLength) {\n status = status.substring(0, maxLength - 4) + \"...\";\n }\n\n return { status };\n }\n\n /**\n * Verify credentials and test connection\n */\n async verifyCredentials(): Promise {\n try {\n const response = await fetch(\n `${this.instanceUrl}/api/v1/accounts/verify_credentials`,\n {\n headers: {\n \"Authorization\": `Bearer ${this.accessToken}`,\n },\n },\n );\n\n return response.ok;\n } catch (error) {\n console.error(\"Credential verification error:\", error);\n return false;\n }\n }\n\n /**\n * Get account information\n */\n async getAccount(): Promise {\n try {\n const response = await fetch(\n `${this.instanceUrl}/api/v1/accounts/verify_credentials`,\n {\n headers: {\n \"Authorization\": `Bearer ${this.accessToken}`,\n },\n },\n );\n\n if (!response.ok) {\n throw new Error(`Failed to get account: ${response.status}`);\n }\n\n return response.json();\n } catch (error) {\n console.error(\"Get account error:\", error);\n throw error;\n }\n }\n\n /**\n * Get instance information (for limits, etc.)\n */\n async getInstance(): Promise {\n try {\n const response = await fetch(`${this.instanceUrl}/api/v1/instance`);\n\n if (!response.ok) {\n throw new Error(`Failed to get instance info: ${response.status}`);\n }\n\n return response.json();\n } catch (error) {\n console.error(\"Get instance error:\", error);\n throw error;\n }\n }\n}\n",[],[238,470,488],"2e40456c-63bc-11f0-9f87-0224a6c84d84","atproto-client.ts","2e40462a-63bc-11f0-9f87-0224a6c84d84",26,["D",1752832032936],"import { ATProtoPost } from \"../../shared/types.ts\";\n\nexport class ATProtoClient {\n private pdsUrl: string;\n private accessToken: string;\n private did: string;\n\n constructor(pdsUrl: string, accessToken: string, did: string) {\n this.pdsUrl = pdsUrl.replace(/\\/$/, \"\"); // Remove trailing slash\n this.accessToken = accessToken;\n this.did = did;\n }\n\n /**\n * Fetch recent posts from the user's timeline\n */\n async fetchRecentPosts(\n limit: number = 50,\n cursor?: string,\n ): Promise<{ posts: ATProtoPost[]; cursor?: string }> {\n try {\n const params = new URLSearchParams({\n actor: this.did,\n limit: limit.toString(),\n });\n\n if (cursor) {\n params.set(\"cursor\", cursor);\n }\n\n const response = await fetch(\n `${this.pdsUrl}/xrpc/app.bsky.feed.getAuthorFeed?${params}`,\n {\n headers: {\n \"Authorization\": `Bearer ${this.accessToken}`,\n \"Accept\": \"application/json\",\n },\n },\n );\n\n if (!response.ok) {\n throw new Error(\n `Failed to fetch posts: ${response.status} ${response.statusText}`,\n );\n }\n\n const data = await response.json();\n\n // Transform the feed items to our ATProtoPost format\n const posts: ATProtoPost[] = data.feed.map((item: any) => ({\n uri: item.post.uri,\n cid: item.post.cid,\n author: {\n did: item.post.author.did,\n handle: item.post.author.handle,\n displayName: item.post.author.displayName,\n avatar: item.post.author.avatar,\n },\n record: {\n text: item.post.record.text,\n createdAt: item.post.record.createdAt,\n embed: item.post.record.embed,\n facets: item.post.record.facets,\n reply: item.post.record.reply,\n },\n indexedAt: item.post.indexedAt,\n }));\n\n return {\n posts,\n cursor: data.cursor,\n };\n } catch (error) {\n console.error(\"Fetch posts error:\", error);\n throw error;\n }\n }\n\n /**\n * Fetch posts since a specific timestamp\n */\n async fetchPostsSince(\n sinceTime: string,\n limit: number = 50,\n ): Promise<{ posts: ATProtoPost[]; cursor?: string }> {\n try {\n let allPosts: ATProtoPost[] = [];\n let cursor: string | undefined;\n let hasMore = true;\n\n while (hasMore && allPosts.length < limit) {\n const { posts, cursor: nextCursor } = await this.fetchRecentPosts(\n 50,\n cursor,\n );\n\n // Filter posts to only include those after sinceTime\n const newPosts = posts.filter((post) =>\n post.record.createdAt > sinceTime\n );\n\n allPosts = allPosts.concat(newPosts);\n cursor = nextCursor;\n\n // If we got fewer posts than requested, or if the oldest post is before sinceTime, we're done\n if (\n posts.length < 50 ||\n (posts.length > 0 &&\n posts[posts.length - 1].record.createdAt <= sinceTime)\n ) {\n hasMore = false;\n }\n }\n\n return {\n posts: allPosts.slice(0, limit),\n cursor,\n };\n } catch (error) {\n console.error(\"Fetch posts since error:\", error);\n throw error;\n }\n }\n\n /**\n * Get a specific post by URI\n */\n async getPost(uri: string): Promise {\n try {\n const response = await fetch(\n `${this.pdsUrl}/xrpc/app.bsky.feed.getPostThread?uri=${\n encodeURIComponent(uri)\n }`,\n {\n headers: {\n \"Authorization\": `Bearer ${this.accessToken}`,\n \"Accept\": \"application/json\",\n },\n },\n );\n\n if (!response.ok) {\n if (response.status === 404) {\n return null;\n }\n throw new Error(\n `Failed to fetch post: ${response.status} ${response.statusText}`,\n );\n }\n\n const data = await response.json();\n const post = data.thread.post;\n\n return {\n uri: post.uri,\n cid: post.cid,\n author: {\n did: post.author.did,\n handle: post.author.handle,\n displayName: post.author.displayName,\n avatar: post.author.avatar,\n },\n record: {\n text: post.record.text,\n createdAt: post.record.createdAt,\n embed: post.record.embed,\n facets: post.record.facets,\n reply: post.record.reply,\n },\n indexedAt: post.indexedAt,\n };\n } catch (error) {\n console.error(\"Get post error:\", error);\n throw error;\n }\n }\n\n /**\n * Resolve a blob reference to a URL\n */\n async resolveBlobUrl(blobRef: string): Promise {\n try {\n // ATProto blob URLs are typically constructed as:\n // https://pds.host/xrpc/com.atproto.sync.getBlob?did=USER_DID&cid=BLOB_CID\n const url =\n `${this.pdsUrl}/xrpc/com.atproto.sync.getBlob?did=${this.did}&cid=${blobRef}`;\n\n // Verify the blob exists\n const response = await fetch(url, {\n method: \"HEAD\",\n headers: {\n \"Authorization\": `Bearer ${this.accessToken}`,\n },\n });\n\n if (!response.ok) {\n throw new Error(`Blob not found: ${response.status}`);\n }\n\n return url;\n } catch (error) {\n console.error(\"Resolve blob URL error:\", error);\n throw error;\n }\n }\n\n /**\n * Get user profile information\n */\n async getProfile(): Promise {\n try {\n const response = await fetch(\n `${this.pdsUrl}/xrpc/app.bsky.actor.getProfile?actor=${this.did}`,\n {\n headers: {\n \"Authorization\": `Bearer ${this.accessToken}`,\n \"Accept\": \"application/json\",\n },\n },\n );\n\n if (!response.ok) {\n throw new Error(\n `Failed to get profile: ${response.status} ${response.statusText}`,\n );\n }\n\n return response.json();\n } catch (error) {\n console.error(\"Get profile error:\", error);\n throw error;\n }\n }\n\n /**\n * Verify credentials and test connection\n */\n async verifyCredentials(): Promise {\n try {\n const response = await fetch(\n `${this.pdsUrl}/xrpc/com.atproto.identity.resolveHandle?handle=${this.did}`,\n {\n headers: {\n \"Authorization\": `Bearer ${this.accessToken}`,\n },\n },\n );\n\n return response.ok;\n } catch (error) {\n console.error(\"Credential verification error:\", error);\n return false;\n }\n }\n\n /**\n * Refresh access token if needed\n */\n async refreshToken(refreshToken: string): Promise<{\n accessToken: string;\n refreshToken: string;\n expiresAt: number;\n }> {\n try {\n // Get authorization server metadata\n const authMetadata = await this.getAuthServerMetadata();\n\n const response = await fetch(authMetadata.token_endpoint, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Accept\": \"application/json\",\n },\n body: new URLSearchParams({\n grant_type: \"refresh_token\",\n refresh_token: refreshToken,\n client_id: Deno.env.get(\"ATPROTO_CLIENT_ID\") || \"\",\n }),\n });\n\n if (!response.ok) {\n throw new Error(`Token refresh failed: ${response.status}`);\n }\n\n const tokens = await response.json();\n\n return {\n accessToken: tokens.access_token,\n refreshToken: tokens.refresh_token,\n expiresAt: Date.now() + (tokens.expires_in * 1000),\n };\n } catch (error) {\n console.error(\"Token refresh error:\", error);\n throw error;\n }\n }\n\n /**\n * Get authorization server metadata\n */\n private async getAuthServerMetadata(): Promise {\n const response = await fetch(\n `${this.pdsUrl}/.well-known/oauth-authorization-server`,\n );\n if (!response.ok) {\n throw new Error(\n `Failed to fetch auth server metadata: ${response.status}`,\n );\n }\n return response.json();\n }\n}\n",[],[238,470,496],"2db6fb22-63bc-11f0-ab6c-0224a6c84d84",9,["D",1752832032039],[272,273,274,275,276],[238,470],"2e3b5548-63bc-11f0-a656-0224a6c84d84","setup.ts","2e3b5610-63bc-11f0-a656-0224a6c84d84","2da07cee-63bc-11f0-b6bc-0224a6c84d84",25,["D",1752832032895],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport {\n createDefaultSettings,\n createUserAccount,\n getUserAccount,\n updateUserAccount,\n} from \"../database/queries.ts\";\nimport { SetupState, SetupStep } from \"../../shared/types.ts\";\n\nconst setup = new Hono();\n\n// Generate a new user ID\nfunction generateUserId(): string {\n return crypto.randomUUID();\n}\n\n// Get setup state for a user\nasync function getSetupState(userId: string): Promise {\n const userAccount = await getUserAccount(userId);\n\n const steps: SetupStep[] = [\n {\n id: \"create-account\",\n title: \"Create Bridge Account\",\n description: \"Initialize your bridge account\",\n completed: !!userAccount,\n },\n {\n id: \"connect-bluesky\",\n title: \"Connect Bluesky Account\",\n description: \"Connect your Bluesky/ATProto account using OAuth\",\n completed: !!userAccount?.atproto_access_token,\n },\n {\n id: \"connect-mastodon\",\n title: \"Connect Mastodon Account\",\n description: \"Connect your Mastodon account using OAuth\",\n completed: !!userAccount?.mastodon_access_token,\n },\n {\n id: \"configure-sync\",\n title: \"Configure Sync Settings\",\n description: \"Set up your synchronization preferences\",\n completed: !!userAccount?.setup_completed,\n },\n ];\n\n const completedSteps = steps.filter((s) => s.completed).length;\n const currentStep = Math.min(completedSteps, steps.length - 1);\n\n return {\n currentStep,\n steps,\n userId,\n atprotoConnected: !!userAccount?.atproto_access_token,\n mastodonConnected: !!userAccount?.mastodon_access_token,\n setupCompleted: !!userAccount?.setup_completed,\n };\n}\n\n// Start setup - create new user account\nsetup.post(\"/start\", async (c) => {\n try {\n const userId = generateUserId();\n\n // Create new user account\n await createUserAccount(userId);\n\n // Create default settings\n await createDefaultSettings(userId);\n\n const setupState = await getSetupState(userId);\n\n return c.json({\n success: true,\n userId,\n setupState,\n });\n } catch (error) {\n console.error(\"Setup start error:\", error);\n return c.json({ error: \"Failed to start setup\" }, 500);\n }\n});\n\n// Get setup state\nsetup.get(\"/state/:userId\", async (c) => {\n const userId = c.req.param(\"userId\");\n\n try {\n const setupState = await getSetupState(userId);\n return c.json(setupState);\n } catch (error) {\n console.error(\"Setup state error:\", error);\n return c.json({ error: \"Failed to get setup state\" }, 500);\n }\n});\n\n// Complete setup\nsetup.post(\"/complete/:userId\", async (c) => {\n const userId = c.req.param(\"userId\");\n\n try {\n const userAccount = await getUserAccount(userId);\n\n if (!userAccount) {\n return c.json({ error: \"User account not found\" }, 404);\n }\n\n // Verify both accounts are connected\n if (\n !userAccount.atproto_access_token || !userAccount.mastodon_access_token\n ) {\n return c.json({\n error: \"Both accounts must be connected before completing setup\",\n }, 400);\n }\n\n // Mark setup as completed\n await updateUserAccount(userId, {\n setup_completed: true,\n });\n\n const setupState = await getSetupState(userId);\n\n return c.json({\n success: true,\n setupState,\n });\n } catch (error) {\n console.error(\"Setup complete error:\", error);\n return c.json({ error: \"Failed to complete setup\" }, 500);\n }\n});\n\n// Test connections\nsetup.post(\"/test-connections/:userId\", async (c) => {\n const userId = c.req.param(\"userId\");\n\n try {\n const userAccount = await getUserAccount(userId);\n\n if (!userAccount) {\n return c.json({ error: \"User account not found\" }, 404);\n }\n\n const results = {\n atproto: { connected: false, error: null as string | null },\n mastodon: { connected: false, error: null as string | null },\n };\n\n // Test ATProto connection\n if (userAccount.atproto_access_token && userAccount.atproto_pds_url) {\n try {\n const response = await fetch(\n `${userAccount.atproto_pds_url}/xrpc/com.atproto.identity.resolveHandle?handle=${userAccount.atproto_handle}`,\n {\n headers: {\n \"Authorization\": `Bearer ${userAccount.atproto_access_token}`,\n },\n },\n );\n\n if (response.ok) {\n results.atproto.connected = true;\n } else {\n results.atproto.error =\n `HTTP ${response.status}: ${response.statusText}`;\n }\n } catch (error) {\n results.atproto.error = error instanceof Error\n ? error.message\n : \"Unknown error\";\n }\n } else {\n results.atproto.error = \"No ATProto credentials found\";\n }\n\n // Test Mastodon connection\n if (\n userAccount.mastodon_access_token && userAccount.mastodon_instance_url\n ) {\n try {\n const response = await fetch(\n `${userAccount.mastodon_instance_url}/api/v1/accounts/verify_credentials`,\n {\n headers: {\n \"Authorization\": `Bearer ${userAccount.mastodon_access_token}`,\n },\n },\n );\n\n if (response.ok) {\n results.mastodon.connected = true;\n } else {\n results.mastodon.error =\n `HTTP ${response.status}: ${response.statusText}`;\n }\n } catch (error) {\n results.mastodon.error = error instanceof Error\n ? error.message\n : \"Unknown error\";\n }\n } else {\n results.mastodon.error = \"No Mastodon credentials found\";\n }\n\n return c.json(results);\n } catch (error) {\n console.error(\"Test connections error:\", error);\n return c.json({ error: \"Failed to test connections\" }, 500);\n }\n});\n\nexport default setup;\n",[],[238,517,509],"routes","70a38b34-63cc-11f0-8471-0224a6c84d84","oauth.ts","2e380294-63bc-11f0-ab6c-0224a6c84d84",65,["D",1752839016259],6,"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { getCookie, setCookie } from \"https://esm.sh/hono@3.11.7/cookie\";\nimport { getUserAccount, updateUserAccount } from \"../database/queries.ts\";\n\nconst oauth = new Hono();\n\n// Generate random state for OAuth security\nfunction generateState(): string {\n return crypto.randomUUID();\n}\n\n// Generate code verifier for PKCE\nfunction generateCodeVerifier(): string {\n const array = new Uint8Array(32);\n crypto.getRandomValues(array);\n return btoa(String.fromCharCode(...array))\n .replace(/\\+/g, \"-\")\n .replace(/\\//g, \"_\")\n .replace(/=/g, \"\");\n}\n\n// Generate code challenge from verifier\nasync function generateCodeChallenge(verifier: string): Promise {\n const encoder = new TextEncoder();\n const data = encoder.encode(verifier);\n const digest = await crypto.subtle.digest(\"SHA-256\", data);\n return btoa(String.fromCharCode(...new Uint8Array(digest)))\n .replace(/\\+/g, \"-\")\n .replace(/\\//g, \"_\")\n .replace(/=/g, \"\");\n}\n\n// Generate DPoP key pair\nasync function generateDPoPKeyPair(): Promise<{\n publicKey: CryptoKey;\n privateKey: CryptoKey;\n jwk: JsonWebKey;\n}> {\n const keyPair = await crypto.subtle.generateKey(\n {\n name: \"ECDSA\",\n namedCurve: \"P-256\",\n },\n true,\n [\"sign\", \"verify\"]\n );\n \n const jwk = await crypto.subtle.exportKey(\"jwk\", keyPair.publicKey);\n \n return {\n publicKey: keyPair.publicKey,\n privateKey: keyPair.privateKey,\n jwk,\n };\n}\n\n// Base64URL encode function\nfunction base64urlEncode(data: ArrayBuffer | Uint8Array): string {\n const uint8Array = data instanceof Uint8Array ? data : new Uint8Array(data);\n return btoa(String.fromCharCode(...uint8Array))\n .replace(/\\+/g, '-')\n .replace(/\\//g, '_')\n .replace(/=/g, '');\n}\n\n// Create DPoP proof JWT using Web Crypto API\nasync function createDPoPProof(\n privateKey: CryptoKey,\n jwk: JsonWebKey,\n method: string,\n url: string,\n nonce?: string\n): Promise {\n const header = {\n alg: \"ES256\",\n typ: \"dpop+jwt\",\n jwk: {\n kty: jwk.kty,\n crv: jwk.crv,\n x: jwk.x,\n y: jwk.y,\n },\n };\n \n const payload = {\n jti: crypto.randomUUID(),\n htm: method,\n htu: url,\n iat: Math.floor(Date.now() / 1000),\n ...(nonce && { nonce }),\n };\n \n // Encode header and payload\n const encodedHeader = base64urlEncode(new TextEncoder().encode(JSON.stringify(header)));\n const encodedPayload = base64urlEncode(new TextEncoder().encode(JSON.stringify(payload)));\n \n // Create the signing input\n const signingInput = `${encodedHeader}.${encodedPayload}`;\n \n // Sign using ECDSA with SHA-256\n const signature = await crypto.subtle.sign(\n { name: \"ECDSA\", hash: { name: \"SHA-256\" } },\n privateKey,\n new TextEncoder().encode(signingInput)\n );\n \n // Encode signature\n const encodedSignature = base64urlEncode(signature);\n \n return `${signingInput}.${encodedSignature}`;\n}\n\n// Discover PDS URL from handle\nasync function discoverPDS(handle: string): Promise {\n try {\n // Remove @ if present\n const cleanHandle = handle.replace(\"@\", \"\");\n\n // Try .well-known first\n const wellKnownUrl = `https://${cleanHandle}/.well-known/atproto-did`;\n const response = await fetch(wellKnownUrl);\n\n if (response.ok) {\n const didDoc = await response.json();\n const pdsEndpoint = didDoc.service?.find((s: any) =>\n s.type === \"AtprotoPersonalDataServer\"\n );\n if (pdsEndpoint) {\n return pdsEndpoint.serviceEndpoint;\n }\n }\n\n // Fallback to bsky.social for handles ending with bsky.social\n if (cleanHandle.endsWith(\".bsky.social\")) {\n return \"https://bsky.social\";\n }\n\n // Default fallback\n return \"https://bsky.social\";\n } catch (error) {\n console.error(\"PDS discovery failed:\", error);\n return \"https://bsky.social\";\n }\n}\n\n// Get authorization server metadata\nasync function getAuthServerMetadata(pdsUrl: string): Promise {\n const response = await fetch(\n `${pdsUrl}/.well-known/oauth-authorization-server`,\n );\n if (!response.ok) {\n throw new Error(`Failed to fetch auth server metadata: ${response.status}`);\n }\n return response.json();\n}\n\n// ATProto OAuth routes\noauth.get(\"/atproto/start\", async (c) => {\n const handle = c.req.query(\"handle\");\n const userId = c.req.query(\"user_id\");\n\n if (!handle || !userId) {\n return c.json({ error: \"Handle and user_id are required\" }, 400);\n }\n\n try {\n // Discover PDS URL\n const pdsUrl = await discoverPDS(handle);\n\n // Get authorization server metadata\n const authMetadata = await getAuthServerMetadata(pdsUrl);\n\n // Generate OAuth parameters\n const state = generateState();\n const codeVerifier = generateCodeVerifier();\n const codeChallenge = await generateCodeChallenge(codeVerifier);\n \n // Generate DPoP key pair\n const dpopKeyPair = await generateDPoPKeyPair();\n\n // Store OAuth state in cookies\n setCookie(c, \"oauth_state\", state, {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n maxAge: 600, // 10 minutes\n });\n setCookie(c, \"oauth_code_verifier\", codeVerifier, {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n maxAge: 600,\n });\n setCookie(c, \"oauth_user_id\", userId, {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n maxAge: 600,\n });\n setCookie(c, \"oauth_pds_url\", pdsUrl, {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n maxAge: 600,\n });\n \n // Store DPoP private key (we'll need to serialize it)\n const dpopPrivateKeyJwk = await crypto.subtle.exportKey(\"jwk\", dpopKeyPair.privateKey);\n setCookie(c, \"oauth_dpop_private_key\", JSON.stringify(dpopPrivateKeyJwk), {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n maxAge: 600,\n });\n setCookie(c, \"oauth_dpop_public_jwk\", JSON.stringify(dpopKeyPair.jwk), {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n maxAge: 600,\n });\n\n // Build authorization URL\n const authUrl = new URL(authMetadata.authorization_endpoint);\n authUrl.searchParams.set(\"response_type\", \"code\");\n authUrl.searchParams.set(\n \"client_id\",\n Deno.env.get(\"ATPROTO_CLIENT_ID\") || \"\",\n );\n authUrl.searchParams.set(\n \"redirect_uri\",\n `${c.req.url.split(\"/oauth\")[0]}/oauth/atproto/callback`,\n );\n authUrl.searchParams.set(\"scope\", \"atproto transition:generic\");\n authUrl.searchParams.set(\"state\", state);\n authUrl.searchParams.set(\"code_challenge\", codeChallenge);\n authUrl.searchParams.set(\"code_challenge_method\", \"S256\");\n\n return c.json({ authUrl: authUrl.toString() });\n } catch (error) {\n console.error(\"ATProto OAuth start error:\", error);\n return c.json({ error: \"Failed to start OAuth flow\" }, 500);\n }\n});\n\noauth.get(\"/atproto/callback\", async (c) => {\n const code = c.req.query(\"code\");\n const state = c.req.query(\"state\");\n const error = c.req.query(\"error\");\n\n if (error) {\n return c.json({ error: `OAuth error: ${error}` }, 400);\n }\n\n if (!code || !state) {\n return c.json({ error: \"Missing code or state\" }, 400);\n }\n\n // Verify state\n const storedState = getCookie(c, \"oauth_state\");\n if (state !== storedState) {\n return c.json({ error: \"Invalid state parameter\" }, 400);\n }\n\n try {\n const codeVerifier = getCookie(c, \"oauth_code_verifier\");\n const userId = getCookie(c, \"oauth_user_id\");\n const pdsUrl = getCookie(c, \"oauth_pds_url\");\n const dpopPrivateKeyJwkStr = getCookie(c, \"oauth_dpop_private_key\");\n const dpopPublicJwkStr = getCookie(c, \"oauth_dpop_public_jwk\");\n\n if (!codeVerifier || !userId || !pdsUrl || !dpopPrivateKeyJwkStr || !dpopPublicJwkStr) {\n return c.json({ error: \"Missing OAuth session data\" }, 400);\n }\n \n // Recreate DPoP key pair from stored JWK\n const dpopPrivateKeyJwk = JSON.parse(dpopPrivateKeyJwkStr);\n const dpopPublicJwk = JSON.parse(dpopPublicJwkStr);\n \n const dpopPrivateKey = await crypto.subtle.importKey(\n \"jwk\",\n dpopPrivateKeyJwk,\n {\n name: \"ECDSA\",\n namedCurve: \"P-256\",\n },\n false,\n [\"sign\"]\n );\n\n // Get authorization server metadata\n const authMetadata = await getAuthServerMetadata(pdsUrl);\n\n // Exchange code for tokens\n const tokenParams = {\n grant_type: \"authorization_code\",\n code: code,\n redirect_uri: `${c.req.url.split(\"/oauth\")[0]}/oauth/atproto/callback`,\n client_id: Deno.env.get(\"ATPROTO_CLIENT_ID\") || \"\",\n code_verifier: codeVerifier,\n };\n \n console.log(\"Token exchange params:\", {\n ...tokenParams,\n code_verifier: codeVerifier.substring(0, 10) + \"...\", // Log partial code verifier\n code: code.substring(0, 10) + \"...\", // Log partial code\n });\n \n // Create DPoP proof for token exchange\n const dpopProof = await createDPoPProof(\n dpopPrivateKey,\n dpopPublicJwk,\n \"POST\",\n authMetadata.token_endpoint\n );\n \n const tokenResponse = await fetch(authMetadata.token_endpoint, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Accept\": \"application/json\",\n \"DPoP\": dpopProof,\n },\n body: new URLSearchParams(tokenParams),\n });\n\n if (!tokenResponse.ok) {\n const errorData = await tokenResponse.json();\n console.error(\"Token exchange failed:\", errorData);\n \n // Check if server requires DPoP nonce\n if (errorData.error === \"use_dpop_nonce\") {\n console.log(\"Server requires DPoP nonce, retrying with nonce...\");\n \n // Extract nonce from DPoP-Nonce header\n const nonce = tokenResponse.headers.get(\"DPoP-Nonce\");\n if (!nonce) {\n return c.json({ \n error: \"Server requires nonce but none provided\",\n details: errorData \n }, 400);\n }\n \n // Create new DPoP proof with nonce\n const dpopProofWithNonce = await createDPoPProof(\n dpopPrivateKey,\n dpopPublicJwk,\n \"POST\",\n authMetadata.token_endpoint,\n nonce\n );\n \n // Retry token exchange with nonce\n const retryResponse = await fetch(authMetadata.token_endpoint, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Accept\": \"application/json\",\n \"DPoP\": dpopProofWithNonce,\n },\n body: new URLSearchParams(tokenParams),\n });\n \n if (!retryResponse.ok) {\n const retryErrorData = await retryResponse.json();\n console.error(\"Token exchange retry failed:\", retryErrorData);\n return c.json({ \n error: \"Token exchange failed after nonce retry\", \n details: retryErrorData,\n status: retryResponse.status \n }, 500);\n }\n \n // Use the retry response for the rest of the flow\n const tokens = await retryResponse.json();\n \n // Continue with the rest of the token processing...\n // Get user profile to extract DID and handle\n const profileResponse = await fetch(\n `${pdsUrl}/xrpc/com.atproto.identity.resolveHandle?handle=${tokens.handle}`,\n {\n headers: {\n \"Authorization\": `Bearer ${tokens.access_token}`,\n },\n },\n );\n\n let userProfile: any = {};\n if (profileResponse.ok) {\n userProfile = await profileResponse.json();\n }\n\n // Update user account with ATProto tokens\n await updateUserAccount(userId, {\n atproto_did: userProfile.did,\n atproto_pds_url: pdsUrl,\n atproto_handle: tokens.handle || userProfile.handle,\n atproto_access_token: tokens.access_token,\n atproto_refresh_token: tokens.refresh_token,\n atproto_token_expires_at: tokens.expires_in\n ? Date.now() + (tokens.expires_in * 1000)\n : undefined,\n });\n\n // Clear OAuth cookies\n setCookie(c, \"oauth_state\", \"\", { maxAge: 0 });\n setCookie(c, \"oauth_code_verifier\", \"\", { maxAge: 0 });\n setCookie(c, \"oauth_user_id\", \"\", { maxAge: 0 });\n setCookie(c, \"oauth_pds_url\", \"\", { maxAge: 0 });\n setCookie(c, \"oauth_dpop_private_key\", \"\", { maxAge: 0 });\n setCookie(c, \"oauth_dpop_public_jwk\", \"\", { maxAge: 0 });\n\n return new Response(null, {\n status: 302,\n headers: { Location: `/setup?step=mastodon&user_id=${userId}` },\n });\n }\n \n return c.json({ \n error: \"Token exchange failed\", \n details: errorData,\n status: tokenResponse.status \n }, 500);\n }\n\n const tokens = await tokenResponse.json();\n\n // Get user profile to extract DID and handle\n const profileResponse = await fetch(\n `${pdsUrl}/xrpc/com.atproto.identity.resolveHandle?handle=${tokens.handle}`,\n {\n headers: {\n \"Authorization\": `Bearer ${tokens.access_token}`,\n },\n },\n );\n\n let userProfile: any = {};\n if (profileResponse.ok) {\n userProfile = await profileResponse.json();\n }\n\n // Update user account with ATProto tokens\n await updateUserAccount(userId, {\n atproto_did: userProfile.did,\n atproto_pds_url: pdsUrl,\n atproto_handle: tokens.handle || userProfile.handle,\n atproto_access_token: tokens.access_token,\n atproto_refresh_token: tokens.refresh_token,\n atproto_token_expires_at: tokens.expires_in\n ? Date.now() + (tokens.expires_in * 1000)\n : undefined,\n });\n\n // Clear OAuth cookies\n setCookie(c, \"oauth_state\", \"\", { maxAge: 0 });\n setCookie(c, \"oauth_code_verifier\", \"\", { maxAge: 0 });\n setCookie(c, \"oauth_user_id\", \"\", { maxAge: 0 });\n setCookie(c, \"oauth_pds_url\", \"\", { maxAge: 0 });\n setCookie(c, \"oauth_dpop_private_key\", \"\", { maxAge: 0 });\n setCookie(c, \"oauth_dpop_public_jwk\", \"\", { maxAge: 0 });\n\n return new Response(null, {\n status: 302,\n headers: { Location: `/setup?step=mastodon&user_id=${userId}` },\n });\n } catch (error) {\n console.error(\"ATProto OAuth callback error:\", error);\n return c.json({ error: \"OAuth callback failed\" }, 500);\n }\n});\n\n// Mastodon OAuth routes\noauth.get(\"/mastodon/start\", async (c) => {\n const instanceUrl = c.req.query(\"instance_url\");\n const userId = c.req.query(\"user_id\");\n\n if (!instanceUrl || !userId) {\n return c.json({ error: \"Instance URL and user_id are required\" }, 400);\n }\n\n try {\n // Normalize instance URL\n const normalizedUrl = instanceUrl.startsWith(\"http\")\n ? instanceUrl\n : `https://${instanceUrl}`;\n\n // Register application with Mastodon instance\n const appResponse = await fetch(`${normalizedUrl}/api/v1/apps`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n client_name: \"ATProto-to-Fediverse Bridge\",\n redirect_uris: `${\n c.req.url.split(\"/oauth\")[0]\n }/oauth/mastodon/callback`,\n scopes: \"read write\",\n website: c.req.url.split(\"/oauth\")[0],\n }),\n });\n\n if (!appResponse.ok) {\n const errorData = await appResponse.text();\n console.error(\"Mastodon app registration failed:\", errorData);\n return c.json(\n { error: \"Failed to register with Mastodon instance\" },\n 500,\n );\n }\n\n const appData = await appResponse.json();\n\n // Store app credentials in user account\n await updateUserAccount(userId, {\n mastodon_instance_url: normalizedUrl,\n mastodon_client_id: appData.client_id,\n mastodon_client_secret: appData.client_secret,\n });\n\n // Generate OAuth parameters\n const state = generateState();\n\n // Store OAuth state in cookies\n setCookie(c, \"mastodon_oauth_state\", state, {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n maxAge: 600, // 10 minutes\n });\n setCookie(c, \"mastodon_oauth_user_id\", userId, {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n maxAge: 600,\n });\n\n // Build authorization URL\n const authUrl = new URL(`${normalizedUrl}/oauth/authorize`);\n authUrl.searchParams.set(\"response_type\", \"code\");\n authUrl.searchParams.set(\"client_id\", appData.client_id);\n authUrl.searchParams.set(\n \"redirect_uri\",\n `${c.req.url.split(\"/oauth\")[0]}/oauth/mastodon/callback`,\n );\n authUrl.searchParams.set(\"scope\", \"read write\");\n authUrl.searchParams.set(\"state\", state);\n\n return c.json({ authUrl: authUrl.toString() });\n } catch (error) {\n console.error(\"Mastodon OAuth start error:\", error);\n return c.json({ error: \"Failed to start OAuth flow\" }, 500);\n }\n});\n\noauth.get(\"/mastodon/callback\", async (c) => {\n const code = c.req.query(\"code\");\n const state = c.req.query(\"state\");\n const error = c.req.query(\"error\");\n\n if (error) {\n return c.json({ error: `OAuth error: ${error}` }, 400);\n }\n\n if (!code || !state) {\n return c.json({ error: \"Missing code or state\" }, 400);\n }\n\n // Verify state\n const storedState = getCookie(c, \"mastodon_oauth_state\");\n if (state !== storedState) {\n return c.json({ error: \"Invalid state parameter\" }, 400);\n }\n\n try {\n const userId = getCookie(c, \"mastodon_oauth_user_id\");\n if (!userId) {\n return c.json({ error: \"Missing user ID\" }, 400);\n }\n\n // Get user account to retrieve app credentials\n const userAccount = await getUserAccount(userId);\n if (\n !userAccount?.mastodon_client_id ||\n !userAccount?.mastodon_client_secret ||\n !userAccount?.mastodon_instance_url\n ) {\n return c.json({ error: \"Missing Mastodon app credentials\" }, 400);\n }\n\n // Exchange code for tokens\n const tokenResponse = await fetch(\n `${userAccount.mastodon_instance_url}/oauth/token`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Accept\": \"application/json\",\n },\n body: new URLSearchParams({\n grant_type: \"authorization_code\",\n code: code,\n redirect_uri: `${\n c.req.url.split(\"/oauth\")[0]\n }/oauth/mastodon/callback`,\n client_id: userAccount.mastodon_client_id,\n client_secret: userAccount.mastodon_client_secret,\n }),\n },\n );\n\n if (!tokenResponse.ok) {\n const errorData = await tokenResponse.json();\n console.error(\"Mastodon token exchange failed:\", errorData);\n return c.json({ error: \"Token exchange failed\" }, 500);\n }\n\n const tokens = await tokenResponse.json();\n\n // Get user profile\n const profileResponse = await fetch(\n `${userAccount.mastodon_instance_url}/api/v1/accounts/verify_credentials`,\n {\n headers: {\n \"Authorization\": `Bearer ${tokens.access_token}`,\n },\n },\n );\n\n let userProfile: any = {};\n if (profileResponse.ok) {\n userProfile = await profileResponse.json();\n }\n\n // Update user account with Mastodon tokens\n await updateUserAccount(userId, {\n mastodon_access_token: tokens.access_token,\n mastodon_username: userProfile.username || userProfile.acct,\n setup_completed: true, // Both accounts are now connected\n });\n\n // Clear OAuth cookies\n setCookie(c, \"mastodon_oauth_state\", \"\", { maxAge: 0 });\n setCookie(c, \"mastodon_oauth_user_id\", \"\", { maxAge: 0 });\n\n return new Response(null, {\n status: 302,\n headers: { Location: `/setup?step=complete&user_id=${userId}` },\n });\n } catch (error) {\n console.error(\"Mastodon OAuth callback error:\", error);\n return c.json({ error: \"OAuth callback failed\" }, 500);\n }\n});\n\nexport default oauth;\n",[],[238,517,519],"2da07c58-63bc-11f0-b6bc-0224a6c84d84",8,["D",1752832031891],[269,270],[238,517],"2e6f696e-63bc-11f0-9598-0224a6c84d84","storage.ts","2e6f6a18-63bc-11f0-9598-0224a6c84d84","2dcdc15e-63bc-11f0-9abc-0224a6c84d84",34,["D",1752832033085],"// Abstract storage interfaces for dependency injection and testability\n\nexport interface UserAccount {\n id: number;\n user_id: string;\n atproto_did?: string;\n atproto_pds_url?: string;\n atproto_handle?: string;\n atproto_access_token?: string;\n atproto_refresh_token?: string;\n atproto_token_expires_at?: number;\n mastodon_instance_url?: string;\n mastodon_username?: string;\n mastodon_access_token?: string;\n mastodon_client_id?: string;\n mastodon_client_secret?: string;\n setup_completed: boolean;\n last_sync_at?: number;\n last_sync_cursor?: string;\n created_at: number;\n updated_at: number;\n}\n\nexport interface PostTracking {\n id: number;\n user_id: string;\n atproto_uri: string;\n atproto_cid: string;\n atproto_rkey: string;\n mastodon_id?: string;\n mastodon_url?: string;\n content_hash: string;\n sync_status: \"pending\" | \"success\" | \"failed\" | \"skipped\";\n error_message?: string;\n retry_count: number;\n max_retries: number;\n atproto_created_at: number;\n synced_at?: number;\n created_at: number;\n updated_at: number;\n}\n\nexport interface Settings {\n id: number;\n user_id: string;\n sync_enabled: boolean;\n sync_interval_minutes: number;\n skip_replies: boolean;\n skip_mentions: boolean;\n skip_reposts: boolean;\n include_media: boolean;\n compress_images: boolean;\n created_at: number;\n updated_at: number;\n}\n\nexport interface SyncLog {\n id: number;\n user_id: string;\n sync_type: \"manual\" | \"cron\" | \"webhook\";\n posts_fetched: number;\n posts_synced: number;\n posts_failed: number;\n posts_skipped: number;\n error_message?: string;\n stack_trace?: string;\n duration_ms?: number;\n cursor_start?: string;\n cursor_end?: string;\n created_at: number;\n}\n\nexport interface SyncStats {\n total_posts: number;\n successful_posts: number;\n failed_posts: number;\n pending_posts: number;\n last_sync: number | null;\n}\n\n// Storage interface for user accounts\nexport interface UserAccountStorage {\n create(userId: string): Promise;\n get(userId: string): Promise;\n update(userId: string, updates: Partial): Promise;\n getForSync(): Promise;\n}\n\n// Storage interface for settings\nexport interface SettingsStorage {\n create(userId: string): Promise;\n get(userId: string): Promise;\n update(userId: string, updates: Partial): Promise;\n}\n\n// Storage interface for post tracking\nexport interface PostTrackingStorage {\n create(data: {\n user_id: string;\n atproto_uri: string;\n atproto_cid: string;\n atproto_rkey: string;\n content_hash: string;\n atproto_created_at: number;\n }): Promise;\n get(userId: string, atprotoUri: string): Promise;\n update(\n userId: string,\n atprotoUri: string,\n updates: Partial,\n ): Promise;\n getPending(userId: string): Promise;\n getFailed(userId: string): Promise;\n getRecent(userId: string, limit?: number): Promise;\n getStats(userId: string): Promise;\n}\n\n// Storage interface for sync logs\nexport interface SyncLogStorage {\n create(data: {\n user_id: string;\n sync_type: \"manual\" | \"cron\" | \"webhook\";\n posts_fetched: number;\n posts_synced: number;\n posts_failed: number;\n posts_skipped: number;\n error_message?: string;\n stack_trace?: string;\n duration_ms?: number;\n cursor_start?: string;\n cursor_end?: string;\n }): Promise;\n getRecent(userId: string, limit?: number): Promise;\n}\n\n// Combined storage interface\nexport interface StorageProvider {\n userAccounts: UserAccountStorage;\n settings: SettingsStorage;\n postTracking: PostTrackingStorage;\n syncLogs: SyncLogStorage;\n\n // Initialize storage (run migrations, etc.)\n initialize(): Promise;\n}\n",[],[238,541,533],"interfaces","2e609f1a-63bc-11f0-a656-0224a6c84d84","http-client.ts","2e609fd8-63bc-11f0-a656-0224a6c84d84",31,["D",1752832033116],"// HTTP client interfaces for external API calls (testable)\n\nexport interface HttpResponse {\n ok: boolean;\n status: number;\n statusText: string;\n headers: Record;\n url: string;\n json(): Promise;\n text(): Promise;\n blob(): Promise;\n}\n\nexport interface HttpClient {\n get(url: string, options?: {\n headers?: Record;\n timeout?: number;\n }): Promise;\n\n post(url: string, options?: {\n headers?: Record;\n body?: string | FormData;\n timeout?: number;\n }): Promise;\n\n put(url: string, options?: {\n headers?: Record;\n body?: string | FormData;\n timeout?: number;\n }): Promise;\n\n head(url: string, options?: {\n headers?: Record;\n timeout?: number;\n }): Promise;\n}\n\n// ATProto-specific client interface\nexport interface ATProtoHttpClient {\n fetchPosts(params: {\n actor: string;\n limit: number;\n cursor?: string;\n }): Promise;\n\n getPost(uri: string): Promise;\n\n getProfile(actor: string): Promise;\n\n resolveHandle(handle: string): Promise;\n\n getBlob(did: string, cid: string): Promise;\n\n refreshToken(refreshToken: string): Promise<{\n access_token: string;\n refresh_token: string;\n expires_in: number;\n }>;\n}\n\n// Mastodon-specific client interface\nexport interface MastodonHttpClient {\n verifyCredentials(): Promise;\n\n getAccount(): Promise;\n\n getInstance(): Promise;\n\n uploadMedia(file: Blob, description?: string): Promise<{\n id: string;\n type: string;\n url: string;\n description?: string;\n }>;\n\n getMediaStatus(mediaId: string): Promise;\n\n createPost(params: {\n status: string;\n media_ids?: string[];\n visibility?: string;\n sensitive?: boolean;\n spoiler_text?: string;\n }): Promise;\n\n registerApp(params: {\n client_name: string;\n redirect_uris: string;\n scopes: string;\n website?: string;\n }): Promise<{\n client_id: string;\n client_secret: string;\n }>;\n\n exchangeCodeForToken(params: {\n code: string;\n redirect_uri: string;\n client_id: string;\n client_secret: string;\n }): Promise<{\n access_token: string;\n token_type: string;\n scope: string;\n }>;\n}\n\n// OAuth client interface\nexport interface OAuthClient {\n getAuthorizationUrl(params: {\n client_id: string;\n redirect_uri: string;\n scope: string;\n state: string;\n code_challenge?: string;\n code_challenge_method?: string;\n }): string;\n\n exchangeCodeForToken(params: {\n code: string;\n redirect_uri: string;\n client_id: string;\n client_secret?: string;\n code_verifier?: string;\n }): Promise<{\n access_token: string;\n refresh_token?: string;\n expires_in?: number;\n token_type: string;\n scope: string;\n }>;\n}\n",[],[238,541,543],"2dcdc082-63bc-11f0-9abc-0224a6c84d84",10,["D",1752832032185],[266,267],[238,541],"2e23decc-63bc-11f0-be89-0224a6c84d84","queries.ts","2e23df9e-63bc-11f0-be89-0224a6c84d84","2d732582-63bc-11f0-922f-0224a6c84d84",20,["D",1752832032675],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { TABLES } from \"./migrations.ts\";\n\nexport interface UserAccount {\n id: number;\n user_id: string;\n atproto_did?: string;\n atproto_pds_url?: string;\n atproto_handle?: string;\n atproto_access_token?: string;\n atproto_refresh_token?: string;\n atproto_token_expires_at?: number;\n mastodon_instance_url?: string;\n mastodon_username?: string;\n mastodon_access_token?: string;\n mastodon_client_id?: string;\n mastodon_client_secret?: string;\n setup_completed: boolean;\n last_sync_at?: number;\n last_sync_cursor?: string;\n created_at: number;\n updated_at: number;\n}\n\nexport interface PostTracking {\n id: number;\n user_id: string;\n atproto_uri: string;\n atproto_cid: string;\n atproto_rkey: string;\n mastodon_id?: string;\n mastodon_url?: string;\n content_hash: string;\n sync_status: \"pending\" | \"success\" | \"failed\" | \"skipped\";\n error_message?: string;\n retry_count: number;\n max_retries: number;\n atproto_created_at: number;\n synced_at?: number;\n created_at: number;\n updated_at: number;\n}\n\nexport interface SyncLog {\n id: number;\n user_id: string;\n sync_type: \"manual\" | \"cron\" | \"webhook\";\n posts_fetched: number;\n posts_synced: number;\n posts_failed: number;\n posts_skipped: number;\n error_message?: string;\n stack_trace?: string;\n duration_ms?: number;\n cursor_start?: string;\n cursor_end?: string;\n created_at: number;\n}\n\nexport interface Settings {\n id: number;\n user_id: string;\n sync_enabled: boolean;\n sync_interval_minutes: number;\n skip_replies: boolean;\n skip_mentions: boolean;\n skip_reposts: boolean;\n include_media: boolean;\n compress_images: boolean;\n created_at: number;\n updated_at: number;\n}\n\n// User Account queries\nexport async function createUserAccount(userId: string): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${TABLES.USER_ACCOUNTS} (user_id) VALUES (?) RETURNING *`,\n [userId],\n );\n return result.rows[0] as UserAccount;\n}\n\nexport async function getUserAccount(\n userId: string,\n): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.USER_ACCOUNTS} WHERE user_id = ?`,\n [userId],\n );\n return result.rows[0] as UserAccount || null;\n}\n\nexport async function updateUserAccount(\n userId: string,\n updates: Partial,\n): Promise {\n const fields = Object.keys(updates).map((key) => `${key} = ?`).join(\", \");\n const values = Object.values(updates);\n\n await sqlite.execute(\n `UPDATE ${TABLES.USER_ACCOUNTS} SET ${fields}, updated_at = unixepoch() WHERE user_id = ?`,\n [...values, userId],\n );\n}\n\nexport async function getUserAccountsForSync(): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.USER_ACCOUNTS} WHERE setup_completed = TRUE`,\n );\n return result.rows as UserAccount[];\n}\n\n// Settings queries\nexport async function createDefaultSettings(userId: string): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${TABLES.SETTINGS} (user_id) VALUES (?) RETURNING *`,\n [userId],\n );\n return result.rows[0] as Settings;\n}\n\nexport async function getSettings(userId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.SETTINGS} WHERE user_id = ?`,\n [userId],\n );\n return result.rows[0] as Settings || null;\n}\n\nexport async function updateSettings(\n userId: string,\n updates: Partial,\n): Promise {\n const fields = Object.keys(updates).map((key) => `${key} = ?`).join(\", \");\n const values = Object.values(updates);\n\n await sqlite.execute(\n `UPDATE ${TABLES.SETTINGS} SET ${fields}, updated_at = unixepoch() WHERE user_id = ?`,\n [...values, userId],\n );\n}\n\n// Post tracking queries\nexport async function createPostTracking(data: {\n user_id: string;\n atproto_uri: string;\n atproto_cid: string;\n atproto_rkey: string;\n content_hash: string;\n atproto_created_at: number;\n}): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${TABLES.POST_TRACKING} \n (user_id, atproto_uri, atproto_cid, atproto_rkey, content_hash, atproto_created_at) \n VALUES (?, ?, ?, ?, ?, ?) RETURNING *`,\n [\n data.user_id,\n data.atproto_uri,\n data.atproto_cid,\n data.atproto_rkey,\n data.content_hash,\n data.atproto_created_at,\n ],\n );\n return result.rows[0] as PostTracking;\n}\n\nexport async function getPostTracking(\n userId: string,\n atprotoUri: string,\n): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.POST_TRACKING} WHERE user_id = ? AND atproto_uri = ?`,\n [userId, atprotoUri],\n );\n return result.rows[0] as PostTracking || null;\n}\n\nexport async function updatePostTracking(\n userId: string,\n atprotoUri: string,\n updates: Partial,\n): Promise {\n const fields = Object.keys(updates).map((key) => `${key} = ?`).join(\", \");\n const values = Object.values(updates);\n\n await sqlite.execute(\n `UPDATE ${TABLES.POST_TRACKING} SET ${fields}, updated_at = unixepoch() WHERE user_id = ? AND atproto_uri = ?`,\n [...values, userId, atprotoUri],\n );\n}\n\nexport async function getPendingPosts(userId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.POST_TRACKING} \n WHERE user_id = ? AND sync_status = 'pending' AND retry_count < max_retries\n ORDER BY atproto_created_at ASC`,\n [userId],\n );\n return result.rows as PostTracking[];\n}\n\nexport async function getFailedPosts(userId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.POST_TRACKING} \n WHERE user_id = ? AND sync_status = 'failed'\n ORDER BY updated_at DESC`,\n [userId],\n );\n return result.rows as PostTracking[];\n}\n\nexport async function getRecentPosts(\n userId: string,\n limit: number = 50,\n): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.POST_TRACKING} \n WHERE user_id = ? \n ORDER BY atproto_created_at DESC \n LIMIT ?`,\n [userId, limit],\n );\n return result.rows as PostTracking[];\n}\n\n// Sync log queries\nexport async function createSyncLog(data: {\n user_id: string;\n sync_type: \"manual\" | \"cron\" | \"webhook\";\n posts_fetched: number;\n posts_synced: number;\n posts_failed: number;\n posts_skipped: number;\n error_message?: string;\n stack_trace?: string;\n duration_ms?: number;\n cursor_start?: string;\n cursor_end?: string;\n}): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${TABLES.SYNC_LOGS} \n (user_id, sync_type, posts_fetched, posts_synced, posts_failed, posts_skipped, error_message, stack_trace, duration_ms, cursor_start, cursor_end) \n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) RETURNING *`,\n [\n data.user_id,\n data.sync_type,\n data.posts_fetched,\n data.posts_synced,\n data.posts_failed,\n data.posts_skipped,\n data.error_message,\n data.stack_trace,\n data.duration_ms,\n data.cursor_start,\n data.cursor_end,\n ],\n );\n return result.rows[0] as SyncLog;\n}\n\nexport async function getRecentSyncLogs(\n userId: string,\n limit: number = 20,\n): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.SYNC_LOGS} \n WHERE user_id = ? \n ORDER BY created_at DESC \n LIMIT ?`,\n [userId, limit],\n );\n return result.rows as SyncLog[];\n}\n\nexport async function getSyncStats(userId: string): Promise<{\n total_posts: number;\n successful_posts: number;\n failed_posts: number;\n pending_posts: number;\n last_sync: number | null;\n}> {\n const result = await sqlite.execute(\n `\n SELECT \n COUNT(*) as total_posts,\n SUM(CASE WHEN sync_status = 'success' THEN 1 ELSE 0 END) as successful_posts,\n SUM(CASE WHEN sync_status = 'failed' THEN 1 ELSE 0 END) as failed_posts,\n SUM(CASE WHEN sync_status = 'pending' THEN 1 ELSE 0 END) as pending_posts,\n MAX(synced_at) as last_sync\n FROM ${TABLES.POST_TRACKING} \n WHERE user_id = ?\n `,\n [userId],\n );\n\n return result.rows[0] as any;\n}\n",[],[238,564,556],"database","2e1bf748-63bc-11f0-a656-0224a6c84d84","migrations.ts","2e1bf824-63bc-11f0-a656-0224a6c84d84",19,["D",1752832032701],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\n// Database schema for ATProto-to-Fediverse bridge\nexport const TABLES = {\n USER_ACCOUNTS: \"bridge_user_accounts_v1\",\n SYNC_LOGS: \"bridge_sync_logs_v1\",\n POST_TRACKING: \"bridge_post_tracking_v1\",\n SETTINGS: \"bridge_settings_v1\",\n};\n\nexport async function runMigrations() {\n // User accounts table - stores OAuth tokens and account info\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.USER_ACCOUNTS} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id TEXT UNIQUE NOT NULL, -- Generated UUID for this bridge user\n \n -- Bluesky/ATProto account\n atproto_did TEXT,\n atproto_pds_url TEXT,\n atproto_handle TEXT,\n atproto_access_token TEXT,\n atproto_refresh_token TEXT,\n atproto_token_expires_at INTEGER,\n \n -- Mastodon account\n mastodon_instance_url TEXT,\n mastodon_username TEXT,\n mastodon_access_token TEXT,\n mastodon_client_id TEXT,\n mastodon_client_secret TEXT,\n \n -- Status tracking\n setup_completed BOOLEAN DEFAULT FALSE,\n last_sync_at INTEGER,\n last_sync_cursor TEXT, -- ATProto cursor for pagination\n \n created_at INTEGER DEFAULT (unixepoch()),\n updated_at INTEGER DEFAULT (unixepoch())\n )\n `);\n\n // Settings table - user preferences and configuration\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.SETTINGS} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id TEXT NOT NULL,\n \n -- Sync settings\n sync_enabled BOOLEAN DEFAULT TRUE,\n sync_interval_minutes INTEGER DEFAULT 15, -- 15 min for free tier\n \n -- Post filtering (for future versions)\n skip_replies BOOLEAN DEFAULT TRUE,\n skip_mentions BOOLEAN DEFAULT FALSE,\n skip_reposts BOOLEAN DEFAULT FALSE,\n \n -- Media handling\n include_media BOOLEAN DEFAULT TRUE,\n compress_images BOOLEAN DEFAULT FALSE,\n \n created_at INTEGER DEFAULT (unixepoch()),\n updated_at INTEGER DEFAULT (unixepoch()),\n \n FOREIGN KEY (user_id) REFERENCES ${TABLES.USER_ACCOUNTS}(user_id)\n )\n `);\n\n // Post tracking table - prevent duplicate posts and track sync status\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.POST_TRACKING} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id TEXT NOT NULL,\n \n -- Bluesky post identifiers\n atproto_uri TEXT NOT NULL, -- at:// URI\n atproto_cid TEXT NOT NULL, -- Content ID\n atproto_rkey TEXT NOT NULL, -- Record key\n \n -- Mastodon post identifiers\n mastodon_id TEXT, -- Mastodon post ID (null if failed)\n mastodon_url TEXT, -- Mastodon post URL\n \n -- Content hash for duplicate detection\n content_hash TEXT NOT NULL,\n \n -- Status tracking\n sync_status TEXT CHECK(sync_status IN ('pending', 'success', 'failed', 'skipped')) DEFAULT 'pending',\n error_message TEXT,\n retry_count INTEGER DEFAULT 0,\n max_retries INTEGER DEFAULT 3,\n \n -- Timestamps\n atproto_created_at INTEGER NOT NULL,\n synced_at INTEGER,\n created_at INTEGER DEFAULT (unixepoch()),\n updated_at INTEGER DEFAULT (unixepoch()),\n \n FOREIGN KEY (user_id) REFERENCES ${TABLES.USER_ACCOUNTS}(user_id),\n UNIQUE(user_id, atproto_uri)\n )\n `);\n\n // Sync logs table - track sync operations and errors\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.SYNC_LOGS} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id TEXT NOT NULL,\n \n -- Sync operation details\n sync_type TEXT CHECK(sync_type IN ('manual', 'cron', 'webhook')) DEFAULT 'cron',\n posts_fetched INTEGER DEFAULT 0,\n posts_synced INTEGER DEFAULT 0,\n posts_failed INTEGER DEFAULT 0,\n posts_skipped INTEGER DEFAULT 0,\n \n -- Error tracking\n error_message TEXT,\n stack_trace TEXT,\n \n -- Performance metrics\n duration_ms INTEGER,\n cursor_start TEXT,\n cursor_end TEXT,\n \n created_at INTEGER DEFAULT (unixepoch()),\n \n FOREIGN KEY (user_id) REFERENCES ${TABLES.USER_ACCOUNTS}(user_id)\n )\n `);\n\n // Create indexes for performance\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_user_accounts_user_id ON ${TABLES.USER_ACCOUNTS}(user_id)`,\n );\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_post_tracking_user_id ON ${TABLES.POST_TRACKING}(user_id)`,\n );\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_post_tracking_status ON ${TABLES.POST_TRACKING}(sync_status)`,\n );\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_post_tracking_atproto_uri ON ${TABLES.POST_TRACKING}(atproto_uri)`,\n );\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_sync_logs_user_id ON ${TABLES.SYNC_LOGS}(user_id)`,\n );\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_sync_logs_created_at ON ${TABLES.SYNC_LOGS}(created_at)`,\n );\n}\n",[],[238,564,566],"2d7324e2-63bc-11f0-922f-0224a6c84d84",["D",1752832031595],[263,264],[238,564],["D",1752832031296],[262,265,268,271,277,280],[238],"9d25ba04-63c9-11f0-80c1-0224a6c84d84","settings.local.json","2e17a2ec-63bc-11f0-8513-0224a6c84d84",48,["D",1752837802442],"{\n \"permissions\": {\n \"allow\": [\n \"Bash(deno test:*)\",\n \"Bash(deno lint:*)\",\n \"Bash(deno fmt:*)\",\n \"Bash(deno check:*)\",\n \"Bash(curl:*)\",\n \"Bash(rm:*)\"\n ],\n \"deny\": []\n }\n}\n",[],[244,581],["D",1752832031136],[260],[244],["D",1752827561082],["D",1789705907347],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"ctx",{"_80":-5,"_126":629,"_630":631,"_632":633,"_634":24,"_635":24,"_636":24,"_637":57,"_638":-5,"_639":-7,"_640":-7,"_641":151,"_642":24,"_643":24,"_644":-5,"_645":24,"_646":24,"_647":24,"_648":-5},"ENV",{"_600":601,"_602":603,"_604":88,"_605":606,"_607":608,"_609":610,"_611":612,"_613":614,"_615":616,"_617":618,"_619":620,"_621":622,"_623":624,"_625":626,"_627":628},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","71c1b20804b3232a7e513be260cfffc1932a9e97","RENDER_GIT_BRANCH","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","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v68