[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_350":351,"_352":353},"routes/_app.x.$handle.$name",{"_99":98,"_31":44,"_108":89,"_26":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":24,"_123":124,"_125":24,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_31":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":24},"version",21,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","backend/storage/memory-storage.ts","latestPath","fileId","2e271092-63bc-11f0-a804-0224a6c84d84","name","memory-storage.ts","fileType","script","content","// 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","createdAt",["D",1752832032775],"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",{"_99":98,"_107":103},"org",{"_99":98,"_100":101,"_102":103,"_18":54,"_104":105,"_106":24},"branch",{"_13":88,"_31":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"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",{"_42":43,"_31":44,"_37":345,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":346,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":347,"_83":348,"_85":349,"_87":24},"tree",[204,206,215,217,218,222,223,224],"files",[204,205,206,207,208,209,210,211,212,213,214,215,216,217,218,219,220,221,222,223,224],"counts",{"_194":145,"_195":62,"_196":167,"_197":198,"_199":200},"contents",[130,131,132,133,134,135,136,137],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":188,"_31":189,"_29":190,"_141":-5,"_40":41,"_39":191,"_143":58,"_37":192,"_13":145,"_33":169,"_35":-5,"_23":24,"_147":-5,"_26":193},{"_42":182,"_31":183,"_29":184,"_141":-5,"_40":41,"_39":185,"_143":58,"_37":186,"_13":145,"_33":169,"_35":-5,"_23":24,"_147":-5,"_26":187},{"_42":177,"_31":178,"_29":179,"_141":-5,"_40":41,"_39":62,"_143":58,"_37":180,"_13":145,"_33":169,"_35":-5,"_23":24,"_147":-5,"_26":181},{"_42":171,"_31":172,"_29":173,"_141":-5,"_40":41,"_39":174,"_143":58,"_37":175,"_13":145,"_33":169,"_35":-5,"_23":24,"_147":-5,"_26":176},{"_42":164,"_31":165,"_29":166,"_141":-5,"_40":41,"_39":167,"_143":58,"_37":168,"_13":145,"_33":169,"_35":-5,"_23":24,"_147":-5,"_26":170},{"_42":156,"_31":157,"_29":158,"_141":-5,"_40":41,"_39":159,"_143":24,"_37":160,"_13":145,"_33":161,"_35":162,"_23":24,"_147":-5,"_26":163},{"_42":149,"_31":150,"_29":151,"_141":-5,"_40":41,"_39":152,"_143":24,"_37":153,"_13":145,"_33":20,"_35":154,"_23":24,"_147":-5,"_26":155},{"_42":138,"_31":139,"_29":140,"_141":-5,"_40":41,"_39":142,"_143":58,"_37":144,"_13":145,"_33":20,"_35":146,"_23":24,"_147":-5,"_26":148},"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",[139],"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",[150],"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",[157],"2d173b82-63bc-11f0-824b-0224a6c84d84","tests","2d173c22-63bc-11f0-824b-0224a6c84d84",2,["D",1752832030993],"directory",[165],"2d5cf2e4-63bc-11f0-9e6a-0224a6c84d84","shared","2d5cf38e-63bc-11f0-9e6a-0224a6c84d84",5,["D",1752832031448],[172],"2d00f20a-63bc-11f0-b053-0224a6c84d84","frontend","2d00f2be-63bc-11f0-b053-0224a6c84d84",["D",1752832030845],[178],"2d45a6fc-63bc-11f0-b229-0224a6c84d84","backend","2d45a7e2-63bc-11f0-b229-0224a6c84d84",4,["D",1752832031296],[183],"2d2d3496-63bc-11f0-b229-0224a6c84d84",".claude","2d2d3568-63bc-11f0-b229-0224a6c84d84",3,["D",1752832031136],[189],"pulls","branches","forks","envVars",{"_201":191,"_203":145},"connections",{"_201":145,"_202":145},"count","unfilledCount","emptyCount",{"_42":188,"_31":189,"_29":190,"_141":-5,"_40":41,"_39":191,"_143":58,"_37":342,"_13":145,"_33":169,"_35":-5,"_23":24,"_147":-5,"_226":343,"_26":344},{"_42":334,"_31":335,"_29":336,"_141":190,"_40":41,"_39":337,"_143":24,"_37":338,"_13":145,"_33":20,"_35":339,"_23":24,"_147":-5,"_226":340,"_26":341},{"_42":182,"_31":183,"_29":184,"_141":-5,"_40":41,"_39":185,"_143":58,"_37":331,"_13":145,"_33":169,"_35":-5,"_23":24,"_147":-5,"_226":332,"_26":333},{"_42":326,"_31":317,"_29":311,"_141":184,"_40":41,"_39":327,"_143":58,"_37":328,"_13":145,"_33":169,"_35":-5,"_23":24,"_147":-5,"_226":329,"_26":330},{"_42":318,"_31":319,"_29":320,"_141":311,"_40":41,"_39":321,"_143":24,"_37":322,"_13":145,"_33":34,"_35":323,"_23":24,"_147":-5,"_226":324,"_26":325},{"_42":308,"_31":309,"_29":310,"_141":311,"_40":41,"_39":312,"_143":24,"_37":313,"_13":145,"_33":34,"_35":314,"_23":24,"_147":-5,"_226":315,"_26":316},{"_42":301,"_31":302,"_29":303,"_141":184,"_40":41,"_39":304,"_143":58,"_37":305,"_13":145,"_33":169,"_35":-5,"_23":24,"_147":-5,"_226":306,"_26":307},{"_42":294,"_31":295,"_29":296,"_141":184,"_40":41,"_39":297,"_143":58,"_37":298,"_13":145,"_33":169,"_35":-5,"_23":24,"_147":-5,"_226":299,"_26":300},{"_42":287,"_31":288,"_29":289,"_141":184,"_40":41,"_39":290,"_143":58,"_37":291,"_13":145,"_33":169,"_35":-5,"_23":24,"_147":-5,"_226":292,"_26":293},{"_42":282,"_31":281,"_29":277,"_141":184,"_40":41,"_39":283,"_143":58,"_37":284,"_13":145,"_33":169,"_35":-5,"_23":24,"_147":-5,"_226":285,"_26":286},{"_42":276,"_31":32,"_29":30,"_141":277,"_40":41,"_39":14,"_143":24,"_37":278,"_13":145,"_33":34,"_35":36,"_23":24,"_147":-5,"_226":279,"_26":280},{"_42":177,"_31":178,"_29":179,"_141":-5,"_40":41,"_39":62,"_143":58,"_37":273,"_13":145,"_33":169,"_35":-5,"_23":24,"_147":-5,"_226":274,"_26":275},{"_42":265,"_31":266,"_29":267,"_141":179,"_40":41,"_39":268,"_143":24,"_37":269,"_13":145,"_33":20,"_35":270,"_23":24,"_147":-5,"_226":271,"_26":272},{"_42":171,"_31":172,"_29":173,"_141":-5,"_40":41,"_39":174,"_143":58,"_37":262,"_13":145,"_33":169,"_35":-5,"_23":24,"_147":-5,"_226":263,"_26":264},{"_42":164,"_31":165,"_29":166,"_141":-5,"_40":41,"_39":167,"_143":58,"_37":259,"_13":145,"_33":169,"_35":-5,"_23":24,"_147":-5,"_226":260,"_26":261},{"_42":251,"_31":252,"_29":253,"_141":166,"_40":41,"_39":254,"_143":24,"_37":255,"_13":145,"_33":34,"_35":256,"_23":24,"_147":-5,"_226":257,"_26":258},{"_42":243,"_31":244,"_29":245,"_141":166,"_40":41,"_39":246,"_143":24,"_37":247,"_13":145,"_33":34,"_35":248,"_23":24,"_147":-5,"_226":249,"_26":250},{"_42":235,"_31":236,"_29":237,"_141":166,"_40":41,"_39":238,"_143":24,"_37":239,"_13":145,"_33":34,"_35":240,"_23":24,"_147":-5,"_226":241,"_26":242},{"_42":156,"_31":157,"_29":158,"_141":-5,"_40":41,"_39":159,"_143":24,"_37":232,"_13":145,"_33":161,"_35":162,"_23":24,"_147":-5,"_226":233,"_26":234},{"_42":149,"_31":150,"_29":151,"_141":-5,"_40":41,"_39":152,"_143":24,"_37":229,"_13":145,"_33":20,"_35":154,"_23":24,"_147":-5,"_226":230,"_26":231},{"_42":138,"_31":139,"_29":140,"_141":-5,"_40":41,"_39":142,"_143":58,"_37":225,"_13":145,"_33":20,"_35":146,"_23":24,"_147":-5,"_226":227,"_26":228},["D",1752832032438],"children",[],[139],["D",1752832032588],[],[150],["D",1752832032444],[],[157],"2e0d9126-63bc-11f0-9abc-0224a6c84d84","sync-service.test.ts","2e0d91d0-63bc-11f0-9abc-0224a6c84d84",17,["D",1752832032444],"// 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",[],[165,236],"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",[],[165,244],"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",[],[165,252],["D",1752832030993],[219,220,221],[165],["D",1752832031448],[],[172],"2de5d76c-63bc-11f0-8513-0224a6c84d84","index.html","2de5d848-63bc-11f0-8513-0224a6c84d84",11,["D",1752832032345],"\n\n\n \n \n ATProto to Fediverse Bridge\n \n \n \n\n\n

\n \n \n\n",[],[178,266],["D",1752832030845],[216],[178],"2e270fe8-63bc-11f0-a804-0224a6c84d84","2d8adc36-63bc-11f0-bd30-0224a6c84d84",["D",1752832032775],[],[183,281,32],"storage","2d8adb6e-63bc-11f0-bd30-0224a6c84d84",7,["D",1752832031750],[214],[183,281],"2db6fb22-63bc-11f0-ab6c-0224a6c84d84","services","2db6fbea-63bc-11f0-ab6c-0224a6c84d84",9,["D",1752832032039],[],[183,288],"2da07c58-63bc-11f0-b6bc-0224a6c84d84","routes","2da07cee-63bc-11f0-b6bc-0224a6c84d84",8,["D",1752832031891],[],[183,295],"2dcdc082-63bc-11f0-9abc-0224a6c84d84","interfaces","2dcdc15e-63bc-11f0-9abc-0224a6c84d84",10,["D",1752832032185],[],[183,302],"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",[],[183,317,309],"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",[],[183,317,319],"2d7324e2-63bc-11f0-922f-0224a6c84d84",6,["D",1752832031595],[208,209],[183,317],["D",1752832031296],[207,210,211,212,213],[183],"2e17a21a-63bc-11f0-8513-0224a6c84d84","settings.local.json","2e17a2ec-63bc-11f0-8513-0224a6c84d84",18,["D",1752832032672],"{\n \"permissions\": {\n \"allow\": [\n \"Bash(deno test:*)\",\n \"Bash(deno lint:*)\",\n \"Bash(deno fmt:*)\",\n \"Bash(deno check:*)\"\n ],\n \"deny\": []\n }\n}\n",[],[189,335],["D",1752832031136],[205],[189],["D",1752827561082],["D",1789705907347],{"_99":98,"_107":103},{"_99":98,"_100":101,"_102":103,"_18":54,"_104":105,"_106":24},{"_13":88,"_31":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"ctx",{"_81":-5,"_127":383,"_384":385,"_386":387,"_388":24,"_389":24,"_390":24,"_391":58,"_392":-5,"_393":-7,"_394":-7,"_395":145,"_396":24,"_397":24,"_398":-5,"_399":24,"_400":24,"_401":24,"_402":-5},"ENV",{"_354":355,"_356":357,"_358":89,"_359":360,"_361":362,"_363":364,"_365":366,"_367":368,"_369":370,"_371":372,"_373":374,"_375":376,"_377":378,"_379":380,"_381":382},"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 · v21