[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_939":940,"_941":942},"routes/_app.x.$handle.$name",{"_98":97,"_33":45,"_107":88,"_28":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":27,"_122":123,"_124":27,"_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",{"_43":44,"_33":45,"_38":46,"_47":-5,"_48":27,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":27,"_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":27},"version",98,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":27,"_28":29,"_30":29},"file",{"_31":32,"_33":29,"_34":20,"_35":37,"_38":39,"_40":14,"_41":42,"_24":27},"previous",{"_31":32,"_33":29,"_34":20,"_35":36},"deleted",true,"deletedHere",false,"path","PLAN.md","latestPath","fileId","3f2a3840-4243-11f1-b8b5-42b51c65c3df","name","fileType","content","# fsq2pds — Foursquare/Swarm checkins → ATProto PDS\n\n## Context\n\nYou want a personal pipeline that mirrors your Swarm checkins into your Bluesky-hosted PDS as ATProto records, so your website at barryfrost.com can read them via the AT Proto API. The pipeline runs entirely on Val.Town's free tier (Deno) on a 15-minute cron — which happens to be the free-tier cron floor, so this is the right cadence regardless. State lives in Val.Town SQLite (per-val 10MB DB) for robust idempotency. Records use the `community.lexicon.location.fsq` struct (embedded, not referenced — that schema is an object meant to live inside other records) wrapped in a bespoke `com.barryfrost.checkin` record.\n\n## Decisions locked in (from clarifying Q&A)\n\n- **Source**: Foursquare/Swarm v2 API via OAuth2 user token (you have a dev account, will mint a token via one-time bootstrap).\n- **Polling, not Push API**: 15-min cron is fine for a website backfill latency; Push API adds a public webhook + signature verification. Skip unless we need sub-15-min freshness later.\n- **Backfill**: none. First run records \"launch timestamp\"; only checkins after that get synced.\n- **State**: Val.Town SQLite, val-scoped (`std/sqlite`). UNIQUE PK on FSQ checkin id is the idempotency primitive.\n- **Record contents**: `createdAt` + embedded `community.lexicon.location.fsq` + photos (uploaded as PDS blobs). No shout text, no categories. (Easy to add later — record schema is yours.)\n- **Edits/deletes in Swarm**: ignored. Records are write-once. If you delete a Swarm checkin you'll manually delete the PDS record.\n- **Lexicon NSID**: `com.barryfrost.checkin`.\n- **PDS**: `bsky.social`, app-password auth.\n\n## Architecture\n\n```\n┌─────────────────────────┐ every 15min ┌────────────────────┐\n│ Val.Town cron val │ ───────────────────▶ │ Foursquare v2 API │\n│ cron.ts │ GET users/self/ │ (oauth_token) │\n│ │ checkins?after=... └────────────────────┘\n│ │\n│ ┌──────────────┐ │ per new checkin\n│ │ SQLite │ ◀──▶ │ 1. fetch photo bytes (if any)\n│ │ seen_checkins│ │ 2. createSession on bsky.social\n│ │ sync_state │ │ 3. uploadBlob × N photos\n│ └──────────────┘ │ 4. createRecord (com.barryfrost.checkin)\n│ │ 5. insert seen_checkins row\n│ │\n│ │ ───────────────────▶ ┌────────────────────┐\n└─────────────────────────┘ │ bsky.social PDS │\n │ XRPC │\n └────────────────────┘\n```\n\n## File layout (Val.Town project, edited locally via `vt`)\n\n```\nfsq2pds/\n├── CLAUDE.md # session context for future Claude runs\n├── README.md # setup steps (token mint, env vars)\n├── deno.json # imports + tasks\n├── cron.ts # main cron entry point\n├── lib/\n│ ├── foursquare.ts # FSQ v2 client (checkins, photo URL build)\n│ ├── atproto.ts # bsky XRPC: createSession, uploadBlob, createRecord\n│ ├── db.ts # SQLite schema + helpers\n│ └── photos.ts # fetch photo bytes from FSQ photo prefix/suffix\n├── lexicons/\n│ └── com.barryfrost.checkin.json # lexicon doc (publishable to PDS later)\n└── bootstrap/\n └── fsq-oauth.ts # one-time local script to mint FSQ token\n```\n\n## Lexicon: `com.barryfrost.checkin`\n\n```json\n{\n \"lexicon\": 1,\n \"id\": \"com.barryfrost.checkin\",\n \"defs\": {\n \"main\": {\n \"type\": \"record\",\n \"key\": \"tid\",\n \"record\": {\n \"type\": \"object\",\n \"required\": [\"createdAt\", \"location\"],\n \"properties\": {\n \"createdAt\": { \"type\": \"string\", \"format\": \"datetime\" },\n \"location\": {\n \"type\": \"ref\",\n \"ref\": \"community.lexicon.location.fsq\"\n },\n \"photos\": {\n \"type\": \"array\",\n \"maxLength\": 8,\n \"items\": {\n \"type\": \"object\",\n \"required\": [\"image\"],\n \"properties\": {\n \"image\": {\n \"type\": \"blob\",\n \"accept\": [\"image/jpeg\", \"image/png\", \"image/webp\"],\n \"maxSize\": 1000000\n },\n \"alt\": { \"type\": \"string\", \"maxLength\": 1000 }\n }\n }\n }\n }\n }\n }\n }\n}\n```\n\nEmbedded location object inside each record looks like:\n```json\n{\n \"$type\": \"community.lexicon.location.fsq\",\n \"fsq_place_id\": \"\",\n \"name\": \"Blue Bottle Coffee\",\n \"latitude\": \"37.776\",\n \"longitude\": \"-122.418\"\n}\n```\n\nRecord `rkey` = TID derived from FSQ `createdAt` (gives chronological ordering for free).\n\n## SQLite schema\n\n```sql\nCREATE TABLE IF NOT EXISTS seen_checkins (\n fsq_id TEXT PRIMARY KEY,\n fsq_created_at INTEGER NOT NULL, -- unix seconds\n pds_at_uri TEXT NOT NULL,\n pds_cid TEXT NOT NULL,\n processed_at INTEGER NOT NULL DEFAULT (unixepoch())\n);\nCREATE INDEX IF NOT EXISTS idx_seen_created ON seen_checkins(fsq_created_at);\n\nCREATE TABLE IF NOT EXISTS sync_state (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL\n);\n-- 'cursor_ts' → unix sec; advance only after successful run\n-- 'launched_at' → unix sec; written once on first ever run, used as initial cursor\n```\n\nThe PRIMARY KEY on `fsq_id` is the durability anchor: even if FSQ returns a checkin twice, or a run dies after PDS write but before cursor advance, the `INSERT OR IGNORE` keeps things consistent.\n\n## Cron flow (cron.ts, runs every 15 min)\n\n1. Open SQLite, ensure schema.\n2. `cursor_ts = sync_state['cursor_ts']`. If null → set `launched_at = now()`, `cursor_ts = now()`, exit (next run does the work).\n3. Call FSQ: `GET /v2/users/self/checkins?oauth_token=…&v=20240101&afterTimestamp=&sort=oldestfirst&limit=50`.\n4. For each checkin (in order):\n - Skip if `fsq_id` already in `seen_checkins`.\n - Build `community.lexicon.location.fsq` from `venue` (id, name, lat/lng).\n - For each `photos.items[]`: fetch `${prefix}1024x1024${suffix}` (caps each photo at safe size; FSQ's \"original\" can exceed 1MB lex limit), keep bytes only if ≤ 1,000,000 bytes.\n - Lazily createSession (once per cron run); cache `accessJwt` in a module-scoped variable.\n - For each photo: `com.atproto.repo.uploadBlob` → blob ref.\n - `com.atproto.repo.createRecord` with `repo=`, `collection=com.barryfrost.checkin`, `rkey=`, `record={createdAt, location, photos}`.\n - On success: `INSERT OR IGNORE` into `seen_checkins`, advance in-memory `cursor_ts` to `max(cursor_ts, fsq_created_at)`.\n - On failure: log, do NOT advance cursor past this id, continue to next (or break — see \"Failure semantics\" below).\n5. Persist final `cursor_ts` to `sync_state`.\n\n### Failure semantics\n\n- Per-checkin try/catch. A failure on one checkin stops the run (so we don't skip past it) but the cursor stays at the last *successfully* processed checkin's timestamp. Next run picks up at the same point; idempotency on `fsq_id` ensures any partially-processed checkin (e.g. blobs uploaded but record not created) just retries cleanly — orphan blobs on the PDS are GC'd by Bluesky after a TTL.\n- Network/auth errors at the top of the run abort early, no state change.\n\n## Secrets (Val.Town env vars)\n\n| Name | Purpose |\n|---|---|\n| `FSQ_OAUTH_TOKEN` | Long-lived FSQ user token (minted via bootstrap, doesn't expire) |\n| `FSQ_API_VERSION` | e.g. `20240101` — the FSQ `v=` param |\n| `BSKY_HANDLE` | e.g. `barryfrost.com` or `barryfrost.bsky.social` |\n| `BSKY_APP_PASSWORD` | App password from bsky.app/settings/app-passwords |\n| `BSKY_PDS_URL` | `https://bsky.social` (default) |\n\n## Bootstrap (one-time, run locally)\n\n`bootstrap/fsq-oauth.ts` — small Deno script:\n1. Print FSQ authorize URL using `FSQ_CLIENT_ID` from env + redirect_uri `http://localhost:8765/callback`.\n2. Spin up a one-shot HTTP server on `:8765`, capture `?code=`.\n3. POST to `https://foursquare.com/oauth2/access_token` to exchange for `access_token`.\n4. Print the token to stdout — paste into Val.Town env var.\n\nThis stays local (not deployed) because it needs an interactive browser handoff and is one-time.\n\n## Maintenance & durability notes\n\n- **Token longevity**: FSQ OAuth user tokens don't expire (historically). Bluesky `accessJwt` expires in ~2h, but we createSession each cron run — one extra request, no refresh logic, no edge cases. Trade tiny request volume for zero state.\n- **Rate limits**: FSQ ≈ 500 req/h/user — we use 1 req per 15 min plus a few per checkin → trivial. Bluesky free is generous; one session + N writes per run is fine.\n- **Storage**: 10MB SQLite holds ~100k checkin rows easily. Photos go to PDS blob storage, not Val.Town.\n- **Photo size**: We pull the `1024x1024` FSQ variant (rather than `original`) to stay under the 1MB lex `maxSize`. If a photo still exceeds 1MB after fetch, skip it (record still gets created without that photo) and log.\n- **Cron drift / catch-up**: If Val.Town cron is paused for hours, the `afterTimestamp` cursor + 50-checkin page size means we replay the gap on resume. For longer outages, the run loops through pages until current.\n- **Observability**: Log per checkin (fsq_id → at-uri); inspect via Val.Town logs UI. SQLite `seen_checkins` is the audit trail.\n- **Single-user assumption**: All code assumes one operator. No multi-tenancy in schema or auth.\n\n## Critical files / external references\n\n- Val.Town SQLite: `import { sqlite } from \"https://esm.town/v/std/sqlite\"`.\n- Val.Town blob (not used here, but available): `https://esm.town/v/std/blob`.\n- FSQ v2 endpoint: `https://api.foursquare.com/v2/users/self/checkins`.\n- Bluesky XRPC: `https://bsky.social/xrpc/com.atproto.server.createSession`, `…/com.atproto.repo.uploadBlob`, `…/com.atproto.repo.createRecord`.\n- Lexicon to embed: `community.lexicon.location.fsq` (struct, NOT a record — embedded via `$type` field).\n\n## Verification\n\nEnd-to-end test plan once deployed:\n1. **Bootstrap**: run `bootstrap/fsq-oauth.ts` locally, paste token into Val.Town env.\n2. **First-run gating**: deploy cron, trigger manually once. Confirm `sync_state` rows for `launched_at` and `cursor_ts` exist; no records written yet.\n3. **Real checkin**: do a real Swarm checkin (with a photo). Wait ≤15 min for next cron tick (or trigger manually).\n4. **PDS verification**: open `https://pdsls.dev/at:///com.barryfrost.checkin` (or `https://atproto-browser.vercel.app/at//com.barryfrost.checkin`) — confirm record exists with embedded location and photo blob.\n5. **Idempotency**: trigger cron again immediately. Confirm no duplicate record (check PDS list, check SQLite has only one row for that fsq_id).\n6. **DB inspection**: Val.Town admin → SQLite → `SELECT * FROM seen_checkins ORDER BY fsq_created_at DESC LIMIT 5`.\n7. **Failure replay** (optional): manually delete the just-written PDS record, then `DELETE FROM seen_checkins WHERE fsq_id = '…'`, trigger cron — confirm it re-creates cleanly.\n\n## Teething issues (encountered during setup)\n\n- **FSQ token exchange uses GET, not POST**: Foursquare's `/oauth2/access_token` endpoint expects a GET request with query params, not a POST with a JSON body. `bootstrap/fsq-oauth.ts` was fixed accordingly. The `\"unsupported_grant_type\"` error is the symptom if you accidentally revert this.\n- **`vt push` requires prior `vt create`**: The `vt` CLI needs a `.vt` directory (created by `vt create`) before `vt push` works. On a fresh local clone, run `vt create` first to initialise the project, then `vt push`.\n- **`BSKY_PDS_URL` env var warning**: Val.Town warns about any `Deno.env.get(...)` reference that isn't set in env vars, even when the code has a fallback default. Suppress by adding `BSKY_PDS_URL` = `https://bsky.social` to Val.Town env vars. Functionally harmless either way.\n\n## Out of scope (v1)\n\n- Edits / deletes from Swarm (you'll manage manually).\n- Shout text, venue categories (easy to add to lexicon later — additive change, won't break existing records).\n- Push API webhook (revisit if 15-min latency feels too slow).\n- Publishing the lexicon doc itself to your PDS as `com.atproto.lexicon.schema` (nice-to-have, doesn't affect record validity).\n- Backfill of historical checkins.\n","# fsq2pds — Foursquare/Swarm checkins → ATProto PDS\n\n## Context\n\nYou want a personal pipeline that mirrors your Swarm checkins into your Bluesky-hosted PDS as ATProto records, so your website at barryfrost.com can read them via the AT Proto API. The pipeline runs entirely on Val.Town's free tier (Deno) on a 15-minute cron — which happens to be the free-tier cron floor, so this is the right cadence regardless. State lives in Val.Town SQLite (per-val 10MB DB) for robust idempotency. Records use the `community.lexicon.location.fsq` struct (embedded, not referenced — that schema is an object meant to live inside other records) wrapped in a bespoke `com.barryfrost.checkin` record.\n\n## Decisions locked in (from clarifying Q&A)\n\n- **Source**: Foursquare/Swarm v2 API via OAuth2 user token (you have a dev account, will mint a token via one-time bootstrap).\n- **Polling, not Push API**: 15-min cron is fine for a website backfill latency; Push API adds a public webhook + signature verification. Skip unless we need sub-15-min freshness later.\n- **Backfill**: none. First run records \"launch timestamp\"; only checkins after that get synced.\n- **State**: Val.Town SQLite, val-scoped (`std/sqlite`). UNIQUE PK on FSQ checkin id is the idempotency primitive.\n- **Record contents**: `createdAt` + embedded `community.lexicon.location.fsq` + photos (uploaded as PDS blobs). No shout text, no categories. (Easy to add later — record schema is yours.)\n- **Edits/deletes in Swarm**: ignored. Records are write-once. If you delete a Swarm checkin you'll manually delete the PDS record.\n- **Lexicon NSID**: `com.barryfrost.checkin`.\n- **PDS**: `bsky.social`, app-password auth.\n\n## Architecture\n\n```\n┌─────────────────────────┐ every 15min ┌────────────────────┐\n│ Val.Town cron val │ ───────────────────▶ │ Foursquare v2 API │\n│ cron.ts │ GET users/self/ │ (oauth_token) │\n│ │ checkins?after=... └────────────────────┘\n│ │\n│ ┌──────────────┐ │ per new checkin\n│ │ SQLite │ ◀──▶ │ 1. fetch photo bytes (if any)\n│ │ seen_checkins│ │ 2. createSession on bsky.social\n│ │ sync_state │ │ 3. uploadBlob × N photos\n│ └──────────────┘ │ 4. createRecord (com.barryfrost.checkin)\n│ │ 5. insert seen_checkins row\n│ │\n│ │ ───────────────────▶ ┌────────────────────┐\n└─────────────────────────┘ │ bsky.social PDS │\n │ XRPC │\n └────────────────────┘\n```\n\n## File layout (Val.Town project, edited locally via `vt`)\n\n```\nfsq2pds/\n├── CLAUDE.md # session context for future Claude runs\n├── README.md # setup steps (token mint, env vars)\n├── deno.json # imports + tasks\n├── cron.ts # main cron entry point\n├── lib/\n│ ├── foursquare.ts # FSQ v2 client (checkins, photo URL build)\n│ ├── atproto.ts # bsky XRPC: createSession, uploadBlob, createRecord\n│ ├── db.ts # SQLite schema + helpers\n│ └── photos.ts # fetch photo bytes from FSQ photo prefix/suffix\n├── lexicons/\n│ └── com.barryfrost.checkin.json # lexicon doc (publishable to PDS later)\n└── bootstrap/\n └── fsq-oauth.ts # one-time local script to mint FSQ token\n```\n\n## Lexicon: `com.barryfrost.checkin`\n\n```json\n{\n \"lexicon\": 1,\n \"id\": \"com.barryfrost.checkin\",\n \"defs\": {\n \"main\": {\n \"type\": \"record\",\n \"key\": \"tid\",\n \"record\": {\n \"type\": \"object\",\n \"required\": [\"createdAt\", \"location\"],\n \"properties\": {\n \"createdAt\": { \"type\": \"string\", \"format\": \"datetime\" },\n \"location\": {\n \"type\": \"ref\",\n \"ref\": \"community.lexicon.location.fsq\"\n },\n \"photos\": {\n \"type\": \"array\",\n \"maxLength\": 8,\n \"items\": {\n \"type\": \"object\",\n \"required\": [\"image\"],\n \"properties\": {\n \"image\": {\n \"type\": \"blob\",\n \"accept\": [\"image/jpeg\", \"image/png\", \"image/webp\"],\n \"maxSize\": 1000000\n },\n \"alt\": { \"type\": \"string\", \"maxLength\": 1000 }\n }\n }\n }\n }\n }\n }\n }\n}\n```\n\nEmbedded location object inside each record looks like:\n```json\n{\n \"$type\": \"community.lexicon.location.fsq\",\n \"fsq_place_id\": \"\",\n \"name\": \"Blue Bottle Coffee\",\n \"latitude\": \"37.776\",\n \"longitude\": \"-122.418\"\n}\n```\n\nRecord `rkey` = TID derived from FSQ `createdAt` (gives chronological ordering for free).\n\n## SQLite schema\n\n```sql\nCREATE TABLE IF NOT EXISTS seen_checkins (\n fsq_id TEXT PRIMARY KEY,\n fsq_created_at INTEGER NOT NULL, -- unix seconds\n pds_at_uri TEXT NOT NULL,\n pds_cid TEXT NOT NULL,\n processed_at INTEGER NOT NULL DEFAULT (unixepoch())\n);\nCREATE INDEX IF NOT EXISTS idx_seen_created ON seen_checkins(fsq_created_at);\n\nCREATE TABLE IF NOT EXISTS sync_state (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL\n);\n-- 'cursor_ts' → unix sec; advance only after successful run\n-- 'launched_at' → unix sec; written once on first ever run, used as initial cursor\n```\n\nThe PRIMARY KEY on `fsq_id` is the durability anchor: even if FSQ returns a checkin twice, or a run dies after PDS write but before cursor advance, the `INSERT OR IGNORE` keeps things consistent.\n\n## Cron flow (cron.ts, runs every 15 min)\n\n1. Open SQLite, ensure schema.\n2. `cursor_ts = sync_state['cursor_ts']`. If null → set `launched_at = now()`, `cursor_ts = now()`, exit (next run does the work).\n3. Call FSQ: `GET /v2/users/self/checkins?oauth_token=…&v=20240101&afterTimestamp=&sort=oldestfirst&limit=50`.\n4. For each checkin (in order):\n - Skip if `fsq_id` already in `seen_checkins`.\n - Build `community.lexicon.location.fsq` from `venue` (id, name, lat/lng).\n - For each `photos.items[]`: fetch `${prefix}1024x1024${suffix}` (caps each photo at safe size; FSQ's \"original\" can exceed 1MB lex limit), keep bytes only if ≤ 1,000,000 bytes.\n - Lazily createSession (once per cron run); cache `accessJwt` in a module-scoped variable.\n - For each photo: `com.atproto.repo.uploadBlob` → blob ref.\n - `com.atproto.repo.createRecord` with `repo=`, `collection=com.barryfrost.checkin`, `rkey=`, `record={createdAt, location, photos}`.\n - On success: `INSERT OR IGNORE` into `seen_checkins`, advance in-memory `cursor_ts` to `max(cursor_ts, fsq_created_at)`.\n - On failure: log, do NOT advance cursor past this id, continue to next (or break — see \"Failure semantics\" below).\n5. Persist final `cursor_ts` to `sync_state`.\n\n### Failure semantics\n\n- Per-checkin try/catch. A failure on one checkin stops the run (so we don't skip past it) but the cursor stays at the last *successfully* processed checkin's timestamp. Next run picks up at the same point; idempotency on `fsq_id` ensures any partially-processed checkin (e.g. blobs uploaded but record not created) just retries cleanly — orphan blobs on the PDS are GC'd by Bluesky after a TTL.\n- Network/auth errors at the top of the run abort early, no state change.\n\n## Secrets (Val.Town env vars)\n\n| Name | Purpose |\n|---|---|\n| `FSQ_OAUTH_TOKEN` | Long-lived FSQ user token (minted via bootstrap, doesn't expire) |\n| `FSQ_API_VERSION` | e.g. `20240101` — the FSQ `v=` param |\n| `BSKY_HANDLE` | e.g. `barryfrost.com` or `barryfrost.bsky.social` |\n| `BSKY_APP_PASSWORD` | App password from bsky.app/settings/app-passwords |\n| `BSKY_PDS_URL` | `https://bsky.social` (default) |\n\n## Bootstrap (one-time, run locally)\n\n`bootstrap/fsq-oauth.ts` — small Deno script:\n1. Print FSQ authorize URL using `FSQ_CLIENT_ID` from env + redirect_uri `http://localhost:8765/callback`.\n2. Spin up a one-shot HTTP server on `:8765`, capture `?code=`.\n3. POST to `https://foursquare.com/oauth2/access_token` to exchange for `access_token`.\n4. Print the token to stdout — paste into Val.Town env var.\n\nThis stays local (not deployed) because it needs an interactive browser handoff and is one-time.\n\n## Maintenance & durability notes\n\n- **Token longevity**: FSQ OAuth user tokens don't expire (historically). Bluesky `accessJwt` expires in ~2h, but we createSession each cron run — one extra request, no refresh logic, no edge cases. Trade tiny request volume for zero state.\n- **Rate limits**: FSQ ≈ 500 req/h/user — we use 1 req per 15 min plus a few per checkin → trivial. Bluesky free is generous; one session + N writes per run is fine.\n- **Storage**: 10MB SQLite holds ~100k checkin rows easily. Photos go to PDS blob storage, not Val.Town.\n- **Photo size**: We pull the `1024x1024` FSQ variant (rather than `original`) to stay under the 1MB lex `maxSize`. If a photo still exceeds 1MB after fetch, skip it (record still gets created without that photo) and log.\n- **Cron drift / catch-up**: If Val.Town cron is paused for hours, the `afterTimestamp` cursor + 50-checkin page size means we replay the gap on resume. For longer outages, the run loops through pages until current.\n- **Observability**: Log per checkin (fsq_id → at-uri); inspect via Val.Town logs UI. SQLite `seen_checkins` is the audit trail.\n- **Single-user assumption**: All code assumes one operator. No multi-tenancy in schema or auth.\n\n## Critical files / external references\n\n- Val.Town SQLite: `import { sqlite } from \"https://esm.town/v/std/sqlite\"`.\n- Val.Town blob (not used here, but available): `https://esm.town/v/std/blob`.\n- FSQ v2 endpoint: `https://api.foursquare.com/v2/users/self/checkins`.\n- Bluesky XRPC: `https://bsky.social/xrpc/com.atproto.server.createSession`, `…/com.atproto.repo.uploadBlob`, `…/com.atproto.repo.createRecord`.\n- Lexicon to embed: `community.lexicon.location.fsq` (struct, NOT a record — embedded via `$type` field).\n\n## Verification\n\nEnd-to-end test plan once deployed:\n1. **Bootstrap**: run `bootstrap/fsq-oauth.ts` locally, paste token into Val.Town env.\n2. **First-run gating**: deploy cron, trigger manually once. Confirm `sync_state` rows for `launched_at` and `cursor_ts` exist; no records written yet.\n3. **Real checkin**: do a real Swarm checkin (with a photo). Wait ≤15 min for next cron tick (or trigger manually).\n4. **PDS verification**: open `https://pdsls.dev/at:///com.barryfrost.checkin` (or `https://atproto-browser.vercel.app/at//com.barryfrost.checkin`) — confirm record exists with embedded location and photo blob.\n5. **Idempotency**: trigger cron again immediately. Confirm no duplicate record (check PDS list, check SQLite has only one row for that fsq_id).\n6. **DB inspection**: Val.Town admin → SQLite → `SELECT * FROM seen_checkins ORDER BY fsq_created_at DESC LIMIT 5`.\n7. **Failure replay** (optional): manually delete the just-written PDS record, then `DELETE FROM seen_checkins WHERE fsq_id = '…'`, trigger cron — confirm it re-creates cleanly.\n\n## Teething issues (encountered during setup)\n\n- **FSQ token exchange uses GET, not POST**: Foursquare's `/oauth2/access_token` endpoint expects a GET request with query params, not a POST with a JSON body. `bootstrap/fsq-oauth.ts` was fixed accordingly. The `\"unsupported_grant_type\"` error is the symptom if you accidentally revert this.\n- **`vt push` requires prior `vt create`**: The `vt` CLI needs a `.vt` directory (created by `vt create`) before `vt push` works. On a fresh local clone, run `vt create` first to initialise the project, then `vt push`.\n- **`BSKY_PDS_URL` env var warning**: Val.Town warns about any `Deno.env.get(...)` reference that isn't set in env vars, even when the code has a fallback default. Suppress by adding `BSKY_PDS_URL` = `https://bsky.social` to Val.Town env vars. Functionally harmless either way.\n- **FSQ `afterTimestamp` param is broken**: The original cron used `afterTimestamp` + `sort=oldestfirst` to filter server-side. The API returns `count: 1318, items: []` — non-zero count but empty items. Switched to fetching the 50 most recent checkins (default newest-first, no filter params) and filtering locally against the `cursor_ts` launch gate. Dedup via `seen_checkins` PRIMARY KEY handles idempotency. The `cursor_ts` value is now a fixed launch gate (never advanced), not a sliding cursor.\n\n## Out of scope (v1)\n\n- Edits / deletes from Swarm (you'll manage manually).\n- Shout text, venue categories (easy to add to lexicon later — additive change, won't break existing records).\n- Push API webhook (revisit if 15-min latency feels too slow).\n- Publishing the lexicon doc itself to your PDS as `com.atproto.lexicon.schema` (nice-to-have, doesn't affect record validity).\n- Backfill of historical checkins.\n","createdAt",["D",1777302675863],"branchVersion","branchId","3ddb19fa-4243-11f1-8011-42b51c65c3df","id","3dda5d80-4243-11f1-8011-42b51c65c3df","fsq2pds",["D",1777299199304],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Foursquare/Swarm checkins → ATProto PDS","imageUrl","60ee761a-2727-4820-a921-a3de0f67378e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","dc713b9c-8776-46e0-8027-faa0b9eae4af","tursoName","3dda5d80424311f1801142b51c65c3df","tursoHostname","3dda5d80424311f1801142b51c65c3df-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789499469860],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":27},"branch",{"_13":87,"_33":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",134,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","barryf","handle","displayName","Barry Frost","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ4Y3gxZ2p3ZkZydXhzM1lVTnAwekdLMXJBWSJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_33":45,"_38":934,"_47":-5,"_48":27,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":27,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":935,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":936,"_82":937,"_84":938,"_86":27},"tree",[224,226,299,302,304,309,310,311,312,313,314],"files",[224,225,226,227,228,229,230,231,232,233,234,235,236,237,238,239,240,241,242,243,244,245,246,247,248,249,250,251,252,253,254,255,256,257,258,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,305,306,307,308,309,310,311,312,313,314],"counts",{"_213":61,"_214":147,"_215":61,"_216":217,"_218":219},"contents",[129,130,131,132,133,134,135,136,137,138,139],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":208,"_33":209,"_31":210,"_143":-5,"_41":42,"_40":168,"_145":27,"_38":211,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_28":212},{"_43":202,"_33":203,"_31":204,"_143":-5,"_41":42,"_40":205,"_145":27,"_38":206,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_28":207},{"_43":197,"_33":198,"_31":199,"_143":-5,"_41":42,"_40":147,"_145":27,"_38":200,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_28":201},{"_43":191,"_33":192,"_31":193,"_143":-5,"_41":42,"_40":194,"_145":27,"_38":195,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_28":196},{"_43":184,"_33":185,"_31":186,"_143":-5,"_41":42,"_40":187,"_145":25,"_38":188,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_28":190},{"_43":177,"_33":178,"_31":179,"_143":-5,"_41":42,"_40":180,"_145":27,"_38":181,"_13":61,"_34":20,"_35":182,"_24":27,"_149":-5,"_28":183},{"_43":170,"_33":171,"_31":172,"_143":-5,"_41":42,"_40":173,"_145":27,"_38":174,"_13":61,"_34":20,"_35":175,"_24":27,"_149":-5,"_28":176},{"_43":166,"_33":29,"_31":32,"_143":-5,"_41":42,"_40":14,"_145":27,"_38":167,"_13":168,"_34":20,"_35":37,"_24":27,"_149":-5,"_28":169},{"_43":159,"_33":160,"_31":161,"_143":-5,"_41":42,"_40":162,"_145":27,"_38":163,"_13":61,"_34":20,"_35":164,"_24":27,"_149":-5,"_28":165},{"_43":151,"_33":152,"_31":153,"_143":-5,"_41":42,"_40":154,"_145":27,"_38":155,"_13":147,"_34":156,"_35":157,"_24":27,"_149":-5,"_28":158},{"_43":140,"_33":141,"_31":142,"_143":-5,"_41":42,"_40":144,"_145":27,"_38":146,"_13":147,"_34":20,"_35":148,"_24":27,"_149":-5,"_28":150},"55f415a2-424b-11f1-a519-42b51c65c3df","deno.json","3f00c4f6-4243-11f1-8240-42b51c65c3df","parentId",97,"latest",["D",1777302675629],1,"{\n \"tasks\": {\n \"bootstrap\": \"deno run --allow-env --allow-net bootstrap/fsq-oauth.ts\",\n \"publish-lexicon\": \"deno run --allow-env --allow-net --allow-read bootstrap/publish-lexicon.ts\"\n }\n}\n","label",[141],"a8d935b4-4245-11f1-8caf-42b51c65c3df","cron.ts","3f2214da-4243-11f1-8a8a-42b51c65c3df",20,["D",1777300237805],"interval","import {\n ensureSchema,\n getState,\n setState,\n hasCheckin,\n recordCheckin,\n} from \"./lib/db.ts\";\nimport { getCheckins } from \"./lib/foursquare.ts\";\nimport { fetchPhoto } from \"./lib/photos.ts\";\nimport { clearSession, getSession, uploadBlob, createRecord } from \"./lib/atproto.ts\";\n\nconst FSQ_OAUTH_TOKEN = Deno.env.get(\"FSQ_OAUTH_TOKEN\") ?? \"\";\nconst FSQ_API_VERSION = Deno.env.get(\"FSQ_API_VERSION\") ?? \"20240101\";\n\ninterface Interval {\n lastRunAt: Date | undefined;\n}\n\nexport default async function (_interval: Interval): Promise {\n if (!FSQ_OAUTH_TOKEN) {\n console.error(\"FSQ_OAUTH_TOKEN is not set\");\n return;\n }\n\n await ensureSchema();\n clearSession(); // fresh session each run; avoids stale JWT issues\n\n const cursorStr = await getState(\"cursor_ts\");\n\n // First ever run: record the launch time as our cursor and exit.\n // Sync will begin from this point on the next run.\n if (cursorStr === null) {\n const now = Math.floor(Date.now() / 1000);\n await setState(\"launched_at\", String(now));\n await setState(\"cursor_ts\", String(now));\n console.log(`First run: launch cursor set to ${new Date(now * 1000).toISOString()}`);\n return;\n }\n\n const launchTs = parseInt(cursorStr, 10);\n\n console.log(`Fetching recent checkins (launch cursor: ${new Date(launchTs * 1000).toISOString()})`);\n\n let checkins;\n try {\n checkins = await getCheckins(FSQ_OAUTH_TOKEN, FSQ_API_VERSION);\n } catch (err) {\n console.error(\"Failed to fetch checkins from Foursquare:\", err);\n return;\n }\n\n // Filter to checkins after our launch timestamp; FSQ returns newest-first\n const newCheckins = checkins.filter((c) => c.createdAt > launchTs);\n\n if (newCheckins.length === 0) {\n console.log(\"No new checkins\");\n return;\n }\n\n // Process oldest-first so records are written in chronological order\n newCheckins.reverse();\n\n console.log(`Processing ${newCheckins.length} checkin(s)`);\n\n let session;\n try {\n session = await getSession();\n } catch (err) {\n console.error(\"Failed to authenticate with PDS:\", err);\n return;\n }\n\n for (const checkin of newCheckins) {\n if (await hasCheckin(checkin.id)) {\n console.log(`Already synced: ${checkin.id}`);\n continue;\n }\n\n try {\n const location: Record = {\n \"$type\": \"community.lexicon.location.fsq\",\n fsq_place_id: checkin.venue.id,\n name: checkin.venue.name,\n };\n if (checkin.venue.location?.lat != null && checkin.venue.location?.lng != null) {\n location.latitude = String(checkin.venue.location.lat);\n location.longitude = String(checkin.venue.location.lng);\n }\n\n const photos: object[] = [];\n for (const photo of checkin.photos?.items ?? []) {\n const fetched = await fetchPhoto(photo);\n if (!fetched) continue;\n try {\n const blobRef = await uploadBlob(session, fetched.bytes, fetched.mimeType);\n photos.push({ image: blobRef });\n } catch (err) {\n // Non-fatal: checkin record still created without this photo\n console.warn(`Photo upload failed for checkin ${checkin.id}:`, err);\n }\n }\n\n const record: Record = {\n \"$type\": \"com.barryfrost.checkin\",\n createdAt: new Date(checkin.createdAt * 1000).toISOString(),\n location,\n };\n if (photos.length > 0) {\n record.photos = photos;\n }\n\n const { uri, cid } = await createRecord(\n session,\n \"com.barryfrost.checkin\",\n checkin.id, // FSQ checkin ID used as rkey — unique, valid chars, stable\n record,\n );\n\n await recordCheckin(checkin.id, checkin.createdAt, uri, cid);\n console.log(`Synced ${checkin.id} (${checkin.venue.name}) → ${uri}`);\n } catch (err) {\n console.error(`Failed to process checkin ${checkin.id}:`, err);\n // Stop here; seen_checkins dedup ensures next run replays this checkin cleanly\n break;\n }\n }\n\n}\n\n",[152],"3edd42f6-4243-11f1-a8c8-42b51c65c3df","README.md","3edd43be-4243-11f1-a8c8-42b51c65c3df",6,["D",1777299201001],"# fsq2pds\n\nSyncs your Foursquare/Swarm checkins to your ATProto PDS as `com.barryfrost.checkin` records. Runs on Val.Town's free tier as a 15-minute cron.\n\n## Setup\n\n### 1. Create a Foursquare developer app\n\n1. Go to https://foursquare.com/developers/ and create a new app.\n2. Add `http://localhost:8765/callback` as an allowed Redirect URI.\n3. Note your **Client ID** and **Client Secret**.\n\n### 2. Mint your OAuth token (one-time, local)\n\n```sh\nFSQ_CLIENT_ID= FSQ_CLIENT_SECRET= deno task bootstrap\n```\n\nA browser window will open. Log in and approve. The token is printed to your terminal — it doesn't expire.\n\n### 3. Create a Bluesky app password\n\n1. Go to https://bsky.app/settings/app-passwords\n2. Create a new app password named `fsq2pds`.\n\n### 4. Deploy to Val.Town\n\n1. Install the `vt` CLI: https://docs.val.town/cli/\n2. From this directory run `vt push` (or use the Val.Town editor to paste the files).\n3. Set these **environment variables** in Val.Town settings:\n\n | Variable | Value |\n |----------|-------|\n | `FSQ_OAUTH_TOKEN` | Token from step 2 |\n | `FSQ_API_VERSION` | `20240101` |\n | `BSKY_HANDLE` | Your Bluesky handle |\n | `BSKY_APP_PASSWORD` | App password from step 3 |\n\n4. Open `cron.ts` in Val.Town and add a **cron trigger** set to every 15 minutes.\n\n### 5. Verify\n\n1. **Trigger manually** (first run). It will set the sync cursor to now and exit — no records written yet. Check the logs for `First run: launch cursor set to ...`.\n2. **Check in on Swarm.**\n3. **Trigger again** (or wait up to 15 minutes). Check the logs for `Synced () → at://...`.\n4. **View your records** at:\n ```\n https://pdsls.dev/at:///com.barryfrost.checkin\n ```\n\n## Record shape\n\n```json\n{\n \"$type\": \"com.barryfrost.checkin\",\n \"createdAt\": \"2024-06-01T14:30:00.000Z\",\n \"location\": {\n \"$type\": \"community.lexicon.location.fsq\",\n \"fsq_place_id\": \"abc123def456\",\n \"name\": \"Blue Bottle Coffee\",\n \"latitude\": \"37.776\",\n \"longitude\": \"-122.418\"\n },\n \"photos\": [\n {\n \"image\": {\n \"$type\": \"blob\",\n \"ref\": { \"$link\": \"bafyrei...\" },\n \"mimeType\": \"image/jpeg\",\n \"size\": 245678\n }\n }\n ]\n}\n```\n\n## Notes\n\n- **Only new checkins** are synced. Nothing before the first run is imported.\n- **Photos**: fetched at FSQ's `1024x1024` size. Skipped if >1MB or unreachable.\n- **Edits/deletes**: not synced. Records are write-once. Delete PDS records manually if needed.\n- **If a run fails mid-way**, the cursor stays at the last successful checkin. The next run replays cleanly — duplicate protection is handled by the `seen_checkins` table.\n",[160],"561a12a2-424b-11f1-b750-42b51c65c3df",["D",1777302675863],2,[29],"3f327bb8-4243-11f1-8240-42b51c65c3df","CLAUDE.md","3f327c94-4243-11f1-8240-42b51c65c3df",16,["D",1777299201543],"# fsq2pds\n\nSyncs Foursquare/Swarm checkins to an ATProto PDS (bsky.social) as `com.barryfrost.checkin` records. Runs as a Val.Town cron val (Deno) every 15 minutes — the free-tier cron minimum.\n\n## File layout\n\n| File | Purpose |\n|------|---------|\n| `cron.ts` | Entry point; exported default function is the cron handler |\n| `lib/db.ts` | Val.Town SQLite helpers (schema, state, dedup) |\n| `lib/foursquare.ts` | Foursquare v2 API client |\n| `lib/atproto.ts` | Bluesky XRPC client (createSession, uploadBlob, createRecord) |\n| `lib/photos.ts` | Downloads FSQ photos, enforces 1MB size cap |\n| `lexicons/com.barryfrost.checkin.json` | Lexicon doc for the checkin record type |\n| `bootstrap/fsq-oauth.ts` | One-time local script to mint an FSQ OAuth token |\n\n## Required env vars (Val.Town secrets)\n\n| Var | Purpose |\n|-----|---------|\n| `FSQ_OAUTH_TOKEN` | Long-lived Foursquare user token (doesn't expire) |\n| `FSQ_API_VERSION` | FSQ API date-version param (e.g. `20240101`) |\n| `BSKY_HANDLE` | Bluesky handle (e.g. `barryfrost.com`) |\n| `BSKY_APP_PASSWORD` | Bluesky app password from bsky.app/settings/app-passwords |\n| `BSKY_PDS_URL` | PDS base URL (optional; defaults to `https://bsky.social`) |\n\n## Key design decisions\n\n- **Idempotency**: `seen_checkins` table with PRIMARY KEY on `fsq_id`. `INSERT OR IGNORE` means re-running is always safe.\n- **Cursor**: `sync_state` table holds `cursor_ts` (unix seconds). Advanced only after successful write.\n- **First run**: Sets cursor to NOW and exits immediately. Sync begins next run (prevents accidental historical import).\n- **rkey**: Uses FSQ checkin ID directly (hex string, valid AT Proto rkey chars, guaranteed unique).\n- **Photos**: Downloaded at FSQ's `1024x1024` size variant. Skipped silently if fetch fails or bytes > 1MB. Checkin record still created.\n- **Session**: `createSession` called at the start of each cron run. No refresh token logic.\n- **Edits/deletes**: Not synced. Records are write-once. Manually delete PDS records if needed.\n- **Backfill**: None. Only checkins after first-run timestamp are synced.\n\n## Lexicon\n\nRecord collection: `com.barryfrost.checkin` \nLocation embedded via `community.lexicon.location.fsq` (struct, not a separate record). \nRecord shape: `{ createdAt, location, photos? }`\n\n## Observability\n\n- Val.Town logs show per-checkin outcome: `Synced () → at://...`\n- SQLite `seen_checkins` is the audit trail; inspect via Val.Town admin panel.\n- `sync_state` holds `cursor_ts` and `launched_at`.\n",[171],"55017cde-424b-11f1-b792-42b51c65c3df",".gitignore","55017d92-424b-11f1-b792-42b51c65c3df",65,["D",1777302674034],".vt/\n.env\n.claude/\n",[178],"3eb4128c-4243-11f1-bd90-42b51c65c3df","lib","3eb4134a-4243-11f1-bd90-42b51c65c3df",4,["D",1777299200731],"directory",[185],"3e943124-4243-11f1-b1e3-42b51c65c3df","lexicons","3e9431e2-4243-11f1-b1e3-42b51c65c3df",3,["D",1777299200522],[192],"3e4b85e6-4243-11f1-8011-42b51c65c3df","bootstrap","3e4b86c2-4243-11f1-8011-42b51c65c3df",["D",1777299200039],[198],"4f951d8c-424b-11f1-8ed1-42b51c65c3df",".git","4f951e5e-424b-11f1-8ed1-42b51c65c3df",21,["D",1777302664629],[203],"3e707a68-4243-11f1-b8b5-42b51c65c3df",".claude","3e707b44-4243-11f1-b8b5-42b51c65c3df",["D",1777299200287],[209],"pulls","branches","forks","envVars",{"_220":222,"_223":61},"connections",{"_220":61,"_221":61},"count","unfilledCount",5,"emptyCount",{"_43":208,"_33":209,"_31":210,"_143":-5,"_41":42,"_40":168,"_145":27,"_38":931,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":932,"_28":933},{"_43":923,"_33":924,"_31":925,"_143":210,"_41":42,"_40":926,"_145":27,"_38":927,"_13":147,"_34":20,"_35":928,"_24":27,"_149":-5,"_316":929,"_28":930},{"_43":202,"_33":203,"_31":204,"_143":-5,"_41":42,"_40":205,"_145":27,"_38":920,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":921,"_28":922},{"_43":915,"_33":818,"_31":812,"_143":204,"_41":42,"_40":916,"_145":27,"_38":917,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":918,"_28":919},{"_43":907,"_33":908,"_31":909,"_143":812,"_41":42,"_40":910,"_145":27,"_38":911,"_13":61,"_34":20,"_35":912,"_24":27,"_149":-5,"_316":913,"_28":914},{"_43":899,"_33":900,"_31":901,"_143":812,"_41":42,"_40":902,"_145":27,"_38":903,"_13":61,"_34":20,"_35":904,"_24":27,"_149":-5,"_316":905,"_28":906},{"_43":891,"_33":892,"_31":893,"_143":812,"_41":42,"_40":894,"_145":27,"_38":895,"_13":61,"_34":20,"_35":896,"_24":27,"_149":-5,"_316":897,"_28":898},{"_43":883,"_33":884,"_31":885,"_143":812,"_41":42,"_40":886,"_145":27,"_38":887,"_13":61,"_34":20,"_35":888,"_24":27,"_149":-5,"_316":889,"_28":890},{"_43":875,"_33":876,"_31":877,"_143":812,"_41":42,"_40":878,"_145":27,"_38":879,"_13":61,"_34":20,"_35":880,"_24":27,"_149":-5,"_316":881,"_28":882},{"_43":867,"_33":868,"_31":869,"_143":812,"_41":42,"_40":870,"_145":27,"_38":871,"_13":61,"_34":20,"_35":872,"_24":27,"_149":-5,"_316":873,"_28":874},{"_43":859,"_33":860,"_31":861,"_143":812,"_41":42,"_40":862,"_145":27,"_38":863,"_13":61,"_34":20,"_35":864,"_24":27,"_149":-5,"_316":865,"_28":866},{"_43":851,"_33":852,"_31":853,"_143":812,"_41":42,"_40":854,"_145":27,"_38":855,"_13":61,"_34":20,"_35":856,"_24":27,"_149":-5,"_316":857,"_28":858},{"_43":843,"_33":844,"_31":845,"_143":812,"_41":42,"_40":846,"_145":27,"_38":847,"_13":61,"_34":20,"_35":848,"_24":27,"_149":-5,"_316":849,"_28":850},{"_43":835,"_33":836,"_31":837,"_143":812,"_41":42,"_40":838,"_145":27,"_38":839,"_13":61,"_34":20,"_35":840,"_24":27,"_149":-5,"_316":841,"_28":842},{"_43":827,"_33":828,"_31":829,"_143":812,"_41":42,"_40":830,"_145":27,"_38":831,"_13":61,"_34":20,"_35":832,"_24":27,"_149":-5,"_316":833,"_28":834},{"_43":819,"_33":820,"_31":821,"_143":812,"_41":42,"_40":822,"_145":27,"_38":823,"_13":61,"_34":20,"_35":824,"_24":27,"_149":-5,"_316":825,"_28":826},{"_43":809,"_33":810,"_31":811,"_143":812,"_41":42,"_40":813,"_145":27,"_38":814,"_13":61,"_34":20,"_35":815,"_24":27,"_149":-5,"_316":816,"_28":817},{"_43":804,"_33":496,"_31":798,"_143":204,"_41":42,"_40":805,"_145":27,"_38":806,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":807,"_28":808},{"_43":795,"_33":796,"_31":797,"_143":798,"_41":42,"_40":799,"_145":27,"_38":800,"_13":61,"_34":20,"_35":801,"_24":27,"_149":-5,"_316":802,"_28":803},{"_43":790,"_33":752,"_31":746,"_143":204,"_41":42,"_40":791,"_145":27,"_38":792,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":793,"_28":794},{"_43":785,"_33":446,"_31":768,"_143":746,"_41":42,"_40":786,"_145":27,"_38":787,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":788,"_28":789},{"_43":780,"_33":475,"_31":775,"_143":768,"_41":42,"_40":781,"_145":27,"_38":782,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":783,"_28":784},{"_43":773,"_33":88,"_31":774,"_143":775,"_41":42,"_40":776,"_145":27,"_38":777,"_13":61,"_34":20,"_35":749,"_24":27,"_149":-5,"_316":778,"_28":779},{"_43":767,"_33":455,"_31":762,"_143":768,"_41":42,"_40":769,"_145":27,"_38":770,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":771,"_28":772},{"_43":761,"_33":456,"_31":755,"_143":762,"_41":42,"_40":763,"_145":27,"_38":764,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":765,"_28":766},{"_43":753,"_33":88,"_31":754,"_143":755,"_41":42,"_40":756,"_145":27,"_38":757,"_13":61,"_34":20,"_35":758,"_24":27,"_149":-5,"_316":759,"_28":760},{"_43":744,"_33":415,"_31":745,"_143":746,"_41":42,"_40":747,"_145":27,"_38":748,"_13":61,"_34":20,"_35":749,"_24":27,"_149":-5,"_316":750,"_28":751},{"_43":739,"_33":494,"_31":489,"_143":204,"_41":42,"_40":740,"_145":27,"_38":741,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":742,"_28":743},{"_43":734,"_33":733,"_31":727,"_143":489,"_41":42,"_40":735,"_145":27,"_38":736,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":737,"_28":738},{"_43":724,"_33":725,"_31":726,"_143":727,"_41":42,"_40":728,"_145":27,"_38":729,"_13":61,"_34":20,"_35":730,"_24":27,"_149":-5,"_316":731,"_28":732},{"_43":717,"_33":718,"_31":719,"_143":489,"_41":42,"_40":720,"_145":27,"_38":721,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":722,"_28":723},{"_43":710,"_33":711,"_31":712,"_143":489,"_41":42,"_40":713,"_145":27,"_38":714,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":715,"_28":716},{"_43":703,"_33":704,"_31":705,"_143":489,"_41":42,"_40":706,"_145":27,"_38":707,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":708,"_28":709},{"_43":696,"_33":697,"_31":698,"_143":489,"_41":42,"_40":699,"_145":27,"_38":700,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":701,"_28":702},{"_43":689,"_33":690,"_31":691,"_143":489,"_41":42,"_40":692,"_145":27,"_38":693,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":694,"_28":695},{"_43":684,"_33":683,"_31":677,"_143":489,"_41":42,"_40":685,"_145":27,"_38":686,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":687,"_28":688},{"_43":674,"_33":675,"_31":676,"_143":677,"_41":42,"_40":678,"_145":27,"_38":679,"_13":61,"_34":20,"_35":680,"_24":27,"_149":-5,"_316":681,"_28":682},{"_43":667,"_33":668,"_31":669,"_143":489,"_41":42,"_40":670,"_145":27,"_38":671,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":672,"_28":673},{"_43":660,"_33":661,"_31":662,"_143":489,"_41":42,"_40":663,"_145":27,"_38":664,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":665,"_28":666},{"_43":653,"_33":654,"_31":655,"_143":489,"_41":42,"_40":656,"_145":27,"_38":657,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":658,"_28":659},{"_43":646,"_33":647,"_31":648,"_143":489,"_41":42,"_40":649,"_145":27,"_38":650,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":651,"_28":652},{"_43":639,"_33":640,"_31":641,"_143":489,"_41":42,"_40":642,"_145":27,"_38":643,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":644,"_28":645},{"_43":632,"_33":633,"_31":634,"_143":489,"_41":42,"_40":635,"_145":27,"_38":636,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":637,"_28":638},{"_43":625,"_33":626,"_31":627,"_143":489,"_41":42,"_40":628,"_145":27,"_38":629,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":630,"_28":631},{"_43":618,"_33":619,"_31":620,"_143":489,"_41":42,"_40":621,"_145":27,"_38":622,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":623,"_28":624},{"_43":611,"_33":612,"_31":613,"_143":489,"_41":42,"_40":614,"_145":27,"_38":615,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":616,"_28":617},{"_43":604,"_33":605,"_31":606,"_143":489,"_41":42,"_40":607,"_145":27,"_38":608,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":609,"_28":610},{"_43":599,"_33":598,"_31":592,"_143":489,"_41":42,"_40":600,"_145":27,"_38":601,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":602,"_28":603},{"_43":589,"_33":590,"_31":591,"_143":592,"_41":42,"_40":593,"_145":27,"_38":594,"_13":61,"_34":20,"_35":595,"_24":27,"_149":-5,"_316":596,"_28":597},{"_43":582,"_33":583,"_31":584,"_143":489,"_41":42,"_40":585,"_145":27,"_38":586,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":587,"_28":588},{"_43":577,"_33":576,"_31":570,"_143":489,"_41":42,"_40":578,"_145":27,"_38":579,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":580,"_28":581},{"_43":567,"_33":568,"_31":569,"_143":570,"_41":42,"_40":571,"_145":27,"_38":572,"_13":61,"_34":20,"_35":573,"_24":27,"_149":-5,"_316":574,"_28":575},{"_43":560,"_33":561,"_31":562,"_143":489,"_41":42,"_40":563,"_145":27,"_38":564,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":565,"_28":566},{"_43":555,"_33":554,"_31":548,"_143":489,"_41":42,"_40":556,"_145":27,"_38":557,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":558,"_28":559},{"_43":545,"_33":546,"_31":547,"_143":548,"_41":42,"_40":549,"_145":27,"_38":550,"_13":61,"_34":20,"_35":551,"_24":27,"_149":-5,"_316":552,"_28":553},{"_43":538,"_33":539,"_31":540,"_143":489,"_41":42,"_40":541,"_145":27,"_38":542,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":543,"_28":544},{"_43":533,"_33":532,"_31":526,"_143":489,"_41":42,"_40":534,"_145":27,"_38":535,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":536,"_28":537},{"_43":523,"_33":524,"_31":525,"_143":526,"_41":42,"_40":527,"_145":27,"_38":528,"_13":61,"_34":20,"_35":529,"_24":27,"_149":-5,"_316":530,"_28":531},{"_43":516,"_33":517,"_31":518,"_143":489,"_41":42,"_40":519,"_145":27,"_38":520,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":521,"_28":522},{"_43":509,"_33":510,"_31":511,"_143":489,"_41":42,"_40":512,"_145":27,"_38":513,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":514,"_28":515},{"_43":502,"_33":503,"_31":504,"_143":489,"_41":42,"_40":505,"_145":27,"_38":506,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":507,"_28":508},{"_43":495,"_33":496,"_31":497,"_143":489,"_41":42,"_40":498,"_145":27,"_38":499,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":500,"_28":501},{"_43":486,"_33":487,"_31":488,"_143":489,"_41":42,"_40":490,"_145":27,"_38":491,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":492,"_28":493},{"_43":481,"_33":446,"_31":441,"_143":204,"_41":42,"_40":482,"_145":27,"_38":483,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":484,"_28":485},{"_43":476,"_33":475,"_31":470,"_143":441,"_41":42,"_40":477,"_145":27,"_38":478,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":479,"_28":480},{"_43":468,"_33":88,"_31":469,"_143":470,"_41":42,"_40":471,"_145":27,"_38":472,"_13":61,"_34":20,"_35":452,"_24":27,"_149":-5,"_316":473,"_28":474},{"_43":463,"_33":455,"_31":458,"_143":441,"_41":42,"_40":464,"_145":27,"_38":465,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":466,"_28":467},{"_43":457,"_33":456,"_31":449,"_143":458,"_41":42,"_40":459,"_145":27,"_38":460,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":461,"_28":462},{"_43":447,"_33":88,"_31":448,"_143":449,"_41":42,"_40":450,"_145":27,"_38":451,"_13":61,"_34":20,"_35":452,"_24":27,"_149":-5,"_316":453,"_28":454},{"_43":438,"_33":439,"_31":440,"_143":441,"_41":42,"_40":442,"_145":27,"_38":443,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":444,"_28":445},{"_43":430,"_33":431,"_31":432,"_143":204,"_41":42,"_40":433,"_145":27,"_38":434,"_13":61,"_34":20,"_35":435,"_24":27,"_149":-5,"_316":436,"_28":437},{"_43":422,"_33":423,"_31":424,"_143":204,"_41":42,"_40":425,"_145":27,"_38":426,"_13":61,"_34":20,"_35":427,"_24":27,"_149":-5,"_316":428,"_28":429},{"_43":414,"_33":415,"_31":416,"_143":204,"_41":42,"_40":417,"_145":27,"_38":418,"_13":61,"_34":20,"_35":419,"_24":27,"_149":-5,"_316":420,"_28":421},{"_43":406,"_33":407,"_31":408,"_143":204,"_41":42,"_40":409,"_145":27,"_38":410,"_13":61,"_34":20,"_35":411,"_24":27,"_149":-5,"_316":412,"_28":413},{"_43":399,"_33":52,"_31":400,"_143":204,"_41":42,"_40":401,"_145":27,"_38":402,"_13":61,"_34":20,"_35":403,"_24":27,"_149":-5,"_316":404,"_28":405},{"_43":197,"_33":198,"_31":199,"_143":-5,"_41":42,"_40":147,"_145":27,"_38":396,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":397,"_28":398},{"_43":389,"_33":390,"_31":391,"_143":199,"_41":42,"_40":222,"_145":27,"_38":392,"_13":61,"_34":339,"_35":393,"_24":27,"_149":-5,"_316":394,"_28":395},{"_43":381,"_33":382,"_31":383,"_143":199,"_41":42,"_40":384,"_145":27,"_38":385,"_13":61,"_34":339,"_35":386,"_24":27,"_149":-5,"_316":387,"_28":388},{"_43":191,"_33":192,"_31":193,"_143":-5,"_41":42,"_40":194,"_145":27,"_38":378,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":379,"_28":380},{"_43":370,"_33":371,"_31":372,"_143":193,"_41":42,"_40":373,"_145":27,"_38":374,"_13":61,"_34":20,"_35":375,"_24":27,"_149":-5,"_316":376,"_28":377},{"_43":184,"_33":185,"_31":186,"_143":-5,"_41":42,"_40":187,"_145":25,"_38":367,"_13":61,"_34":189,"_35":-5,"_24":27,"_149":-5,"_316":368,"_28":369},{"_43":359,"_33":360,"_31":361,"_143":186,"_41":42,"_40":362,"_145":27,"_38":363,"_13":61,"_34":339,"_35":364,"_24":27,"_149":-5,"_316":365,"_28":366},{"_43":351,"_33":352,"_31":353,"_143":186,"_41":42,"_40":354,"_145":25,"_38":355,"_13":61,"_34":339,"_35":356,"_24":27,"_149":-5,"_316":357,"_28":358},{"_43":343,"_33":344,"_31":345,"_143":186,"_41":42,"_40":346,"_145":27,"_38":347,"_13":168,"_34":339,"_35":348,"_24":27,"_149":-5,"_316":349,"_28":350},{"_43":334,"_33":335,"_31":336,"_143":186,"_41":42,"_40":337,"_145":27,"_38":338,"_13":61,"_34":339,"_35":340,"_24":27,"_149":-5,"_316":341,"_28":342},{"_43":177,"_33":178,"_31":179,"_143":-5,"_41":42,"_40":180,"_145":27,"_38":331,"_13":61,"_34":20,"_35":182,"_24":27,"_149":-5,"_316":332,"_28":333},{"_43":170,"_33":171,"_31":172,"_143":-5,"_41":42,"_40":173,"_145":27,"_38":328,"_13":61,"_34":20,"_35":175,"_24":27,"_149":-5,"_316":329,"_28":330},{"_43":166,"_33":29,"_31":32,"_143":-5,"_41":42,"_40":14,"_145":27,"_38":325,"_13":168,"_34":20,"_35":37,"_24":27,"_149":-5,"_316":326,"_28":327},{"_43":159,"_33":160,"_31":161,"_143":-5,"_41":42,"_40":162,"_145":27,"_38":322,"_13":61,"_34":20,"_35":164,"_24":27,"_149":-5,"_316":323,"_28":324},{"_43":151,"_33":152,"_31":153,"_143":-5,"_41":42,"_40":154,"_145":27,"_38":319,"_13":147,"_34":156,"_35":157,"_24":27,"_149":-5,"_316":320,"_28":321},{"_43":140,"_33":141,"_31":142,"_143":-5,"_41":42,"_40":144,"_145":27,"_38":315,"_13":147,"_34":20,"_35":148,"_24":27,"_149":-5,"_316":317,"_28":318},["D",1777302675629],"children",[],[141],["D",1777300237805],[],[152],["D",1777299201001],[],[160],["D",1777302675863],[],[29],["D",1777299201543],[],[171],["D",1777302674034],[],[178],"3ef89970-4243-11f1-a8c8-42b51c65c3df","photos.ts","3ef89a10-4243-11f1-a8c8-42b51c65c3df",8,["D",1777299201181],"script","import { photoUrl, type FsqPhoto } from \"./foursquare.ts\";\n\nconst MAX_PHOTO_BYTES = 1_000_000;\n\nexport interface FetchedPhoto {\n bytes: Uint8Array;\n mimeType: string;\n}\n\nexport async function fetchPhoto(photo: FsqPhoto): Promise {\n const url = photoUrl(photo);\n try {\n const resp = await fetch(url);\n if (!resp.ok) {\n console.warn(`Photo fetch failed (${resp.status}): ${url}`);\n return null;\n }\n const bytes = new Uint8Array(await resp.arrayBuffer());\n if (bytes.byteLength > MAX_PHOTO_BYTES) {\n console.warn(`Photo too large (${bytes.byteLength} bytes), skipping: ${url}`);\n return null;\n }\n const mimeType = resp.headers.get(\"content-type\")?.split(\";\")[0].trim() ?? \"image/jpeg\";\n return { bytes, mimeType };\n } catch (err) {\n console.warn(`Photo fetch error for ${url}:`, err);\n return null;\n }\n}\n",[],[185,335],"a8c75600-4245-11f1-8caf-42b51c65c3df","foursquare.ts","3f1362aa-4243-11f1-a9ae-42b51c65c3df",19,["D",1777300237687],"const FSQ_API_BASE = \"https://api.foursquare.com/v2\";\n\nexport interface FsqPhoto {\n prefix: string;\n suffix: string;\n}\n\nexport interface FsqCheckin {\n id: string;\n createdAt: number; // unix seconds\n venue: {\n id: string;\n name: string;\n location?: {\n lat?: number;\n lng?: number;\n };\n };\n photos?: {\n count: number;\n items: FsqPhoto[];\n };\n}\n\nexport async function getCheckins(\n oauthToken: string,\n apiVersion: string,\n): Promise {\n const params = new URLSearchParams({\n oauth_token: oauthToken,\n v: apiVersion,\n limit: \"50\",\n });\n const resp = await fetch(`${FSQ_API_BASE}/users/self/checkins?${params}`);\n if (!resp.ok) {\n throw new Error(`FSQ API error ${resp.status}: ${await resp.text()}`);\n }\n const data = await resp.json();\n if (data.meta?.code !== 200) {\n throw new Error(`FSQ API returned non-200: ${JSON.stringify(data.meta)}`);\n }\n return (data.response?.checkins?.items ?? []) as FsqCheckin[];\n}\n\nexport function photoUrl(photo: FsqPhoto, size = \"1024x1024\"): string {\n return `${photo.prefix}${size}${photo.suffix}`;\n}\n",[],[185,344],"3f1dea7c-4243-11f1-8a98-42b51c65c3df","db.ts","3f1deb4e-4243-11f1-8a98-42b51c65c3df",13,["D",1777299201415],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport async function ensureSchema(): Promise {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS seen_checkins (\n fsq_id TEXT PRIMARY KEY,\n fsq_created_at INTEGER NOT NULL,\n pds_at_uri TEXT NOT NULL,\n pds_cid TEXT NOT NULL,\n processed_at INTEGER NOT NULL DEFAULT (unixepoch())\n )\n `);\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_seen_created ON seen_checkins(fsq_created_at)`,\n );\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sync_state (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL\n )\n `);\n}\n\nexport async function getState(key: string): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT value FROM sync_state WHERE key = ?\",\n args: [key],\n });\n return result.rows.length > 0 ? String(result.rows[0].value) : null;\n}\n\nexport async function setState(key: string, value: string): Promise {\n await sqlite.execute({\n sql: \"INSERT OR REPLACE INTO sync_state (key, value) VALUES (?, ?)\",\n args: [key, value],\n });\n}\n\nexport async function hasCheckin(fsqId: string): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT 1 FROM seen_checkins WHERE fsq_id = ?\",\n args: [fsqId],\n });\n return result.rows.length > 0;\n}\n\nexport async function recordCheckin(\n fsqId: string,\n fsqCreatedAt: number,\n pdsAtUri: string,\n pdsCid: string,\n): Promise {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO seen_checkins (fsq_id, fsq_created_at, pds_at_uri, pds_cid)\n VALUES (?, ?, ?, ?)`,\n args: [fsqId, fsqCreatedAt, pdsAtUri, pdsCid],\n });\n}\n",[],[185,352],"3f18edf6-4243-11f1-a8c8-42b51c65c3df","atproto.ts","3f18eea0-4243-11f1-a8c8-42b51c65c3df",12,["D",1777299201382],"const PDS_URL = Deno.env.get(\"BSKY_PDS_URL\") ?? \"https://bsky.social\";\n\ninterface Session {\n accessJwt: string;\n did: string;\n}\n\n// Module-scoped session cache; cleared on each cron invocation via clearSession()\nlet cachedSession: Session | null = null;\n\nexport function clearSession(): void {\n cachedSession = null;\n}\n\nexport async function getSession(): Promise {\n if (cachedSession) return cachedSession;\n const handle = Deno.env.get(\"BSKY_HANDLE\");\n const password = Deno.env.get(\"BSKY_APP_PASSWORD\");\n if (!handle || !password) {\n throw new Error(\"BSKY_HANDLE and BSKY_APP_PASSWORD env vars are required\");\n }\n const resp = await fetch(`${PDS_URL}/xrpc/com.atproto.server.createSession`, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ identifier: handle, password }),\n });\n if (!resp.ok) {\n throw new Error(`createSession failed (${resp.status}): ${await resp.text()}`);\n }\n const data = await resp.json();\n cachedSession = { accessJwt: data.accessJwt, did: data.did };\n return cachedSession;\n}\n\nexport async function uploadBlob(\n session: Session,\n bytes: Uint8Array,\n mimeType: string,\n): Promise

Success! You can close this tab and return to the terminal.

Diff · v98