[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_171":172,"_173":174},"routes/_app.x.$handle.$name",{"_99":98,"_33":46,"_107":89,"_27":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":25,"_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",{"_44":45,"_33":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":-5,"_58":25,"_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":25},"version",46,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":30},"file",{"_31":32,"_33":28,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_31":32,"_33":28,"_34":35,"_36":37},"deleted",false,"deletedHere","path","migrate.ts","latestPath","main.ts","fileId","2cc54c0e-6673-11f1-9da2-1607ee4eb77e","name","fileType","script","content","import { blob as globalBlob } from \"https://esm.town/v/std/blob/global.ts\";\nimport { blob as scopedBlob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { ValTownBlobNotFoundError } from \"https://esm.town/v/std/ValTownBlobNotFoundError\";\n\n/** Per-key outcome of a migration run. */\nexport type BlobMigrationStatus =\n | \"migrated\"\n | \"skipped-exists\"\n | \"skipped-missing\"\n | \"dry-run\"\n | \"error\";\n\n/**\n * Per-key outcome of a blob migration.\n * @property key - The blob key being migrated.\n * @property status - The outcome status.\n * @property sourceDeleted - Whether the source blob was deleted from global storage (deleteSource).\n * @property error - Error message, present only when status === \"error\".\n */\nexport interface BlobMigrationResult {\n key: string;\n status: BlobMigrationStatus;\n sourceDeleted?: boolean;\n error?: string;\n}\n\n/**\n * Options for migrating blobs from global to scoped storage.\n * @property prefix - When true, targets are treated as prefixes; default false (explicit keys).\n * @property commit - When true, actually perform the migration; default false (dry-run).\n * @property overwrite - When true, overwrite keys already in scoped storage; default false.\n * @property deleteSource - When true, delete from global after successful copy (move); default false (copy).\n * @property onProgress - Optional callback invoked after each key is processed.\n */\nexport interface MigrateOptions {\n prefix?: boolean;\n commit?: boolean;\n overwrite?: boolean;\n deleteSource?: boolean;\n onProgress?: (result: BlobMigrationResult) => void;\n}\n\n/**\n * Summary of a blob migration run.\n * @property results - Per-key migration outcomes.\n * @property counts - Count of each status type.\n * @property dryRun - True when no writes/deletes were performed (commit was false).\n */\nexport interface MigrateSummary {\n results: BlobMigrationResult[];\n counts: Record;\n dryRun: boolean;\n}\n\n/** Returns true if a key already exists in scoped storage. */\nasync function existsInScoped(key: string): Promise {\n return (await scopedBlob.list(key)).some((e) => e.key === key);\n}\n\n/**\n * Migrate blobs from global storage to scoped storage.\n *\n * `targets` is interpreted as an explicit list of keys by default. When\n * `prefix` is true, each entry in `targets` is treated as a prefix and expanded\n * (via a prefix `list`) into the matching global keys before migration.\n *\n * Streams each blob's raw body, so it is safe for binary, text, and JSON data\n * alike. Keys are preserved exactly. Defaults are conservative: dry-run, no\n * overwrite, and copy (not move).\n */\nexport async function migrateBlobs(\n targets: string[],\n options: MigrateOptions = {},\n): Promise {\n const {\n prefix = false,\n commit = false,\n overwrite = false,\n deleteSource = false,\n onProgress,\n } = options;\n\n // Resolve the keys to migrate. When `prefix` is set, expand each prefix into\n // the matching global keys; otherwise treat `targets` as keys directly.\n let keys: string[];\n if (prefix) {\n const expanded: string[] = [];\n for (const p of targets) {\n const matches = (await globalBlob.list(p)).map((e) => e.key);\n expanded.push(...matches);\n }\n keys = expanded;\n } else {\n keys = targets;\n }\n\n const results: BlobMigrationResult[] = [];\n const uniqueKeys = [...new Set(keys)];\n\n for (const key of uniqueKeys) {\n const result = await migrateOne(key, { commit, overwrite, deleteSource });\n results.push(result);\n onProgress?.(result);\n }\n\n const counts = {\n \"migrated\": 0,\n \"skipped-exists\": 0,\n \"skipped-missing\": 0,\n \"dry-run\": 0,\n \"error\": 0,\n } as Record;\n for (const r of results) counts[r.status]++;\n\n return { results, counts, dryRun: !commit };\n}\n\nasync function migrateOne(\n key: string,\n opts: Required>,\n): Promise {\n try {\n // 1. Skip if it already exists in scoped storage (unless overwriting).\n if (!opts.overwrite && (await existsInScoped(key))) {\n return { key, status: \"skipped-exists\" };\n }\n\n // 2. Read from global storage. get() throws if the key is missing.\n let source: Response;\n try {\n source = await globalBlob.get(key);\n } catch (e) {\n if (e instanceof ValTownBlobNotFoundError) {\n return { key, status: \"skipped-missing\" };\n }\n throw e;\n }\n\n // 3. Dry-run: report what would happen without writing.\n if (!opts.commit) {\n // Drain the body so the connection isn't left hanging.\n await source.body?.cancel();\n return { key, status: \"dry-run\" };\n }\n\n // 4. Write the raw body to scoped storage (binary-safe).\n await scopedBlob.set(key, source.body ?? \"\");\n\n // 5. Optionally delete the source (move semantics).\n let sourceDeleted = false;\n if (opts.deleteSource) {\n await globalBlob.delete(key);\n sourceDeleted = true;\n }\n\n return { key, status: \"migrated\", sourceDeleted };\n } catch (e) {\n return {\n key,\n status: \"error\",\n error: e instanceof Error ? e.message : String(e),\n };\n }\n}","import { blob as globalBlob } from \"https://esm.town/v/std/blob/global.ts\";\nimport { blob as scopedBlob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { ValTownBlobNotFoundError } from \"https://esm.town/v/std/ValTownBlobNotFoundError\";\n\n/** Per-key outcome of a migration run. */\nexport type BlobMigrationStatus =\n | \"migrated\"\n | \"skipped-exists\"\n | \"skipped-missing\"\n | \"dry-run\"\n | \"error\";\n\n/**\n * Per-key outcome of a blob migration.\n * @property key - The blob key being migrated.\n * @property status - The outcome status.\n * @property sourceDeleted - Whether the source blob was deleted from global storage (deleteSource).\n * @property error - Error message, present only when status === \"error\".\n */\nexport interface BlobMigrationResult {\n key: string;\n status: BlobMigrationStatus;\n sourceDeleted?: boolean;\n error?: string;\n}\n\n/**\n * Options for migrating blobs from global to scoped storage.\n * @property prefix - When true, targets are treated as prefixes; default false (explicit keys).\n * @property commit - When true, actually perform the migration; default false (dry-run).\n * @property overwrite - When true, overwrite keys already in scoped storage; default false.\n * @property deleteSource - When true, delete from global after successful copy (move); default false (copy).\n * @property onProgress - Optional callback invoked after each key is processed.\n */\nexport interface MigrateOptions {\n prefix?: boolean;\n commit?: boolean;\n overwrite?: boolean;\n deleteSource?: boolean;\n onProgress?: (result: BlobMigrationResult) => void;\n}\n\n/**\n * Summary of a blob migration run.\n * @property results - Per-key migration outcomes.\n * @property counts - Count of each status type.\n * @property dryRun - True when no writes/deletes were performed (commit was false).\n */\nexport interface MigrateSummary {\n results: BlobMigrationResult[];\n counts: Record;\n dryRun: boolean;\n}\n\n/** Returns true if a key already exists in scoped storage. */\nasync function existsInScoped(key: string): Promise {\n return (await scopedBlob.list(key)).some((e) => e.key === key);\n}\n\n/**\n * Migrate blobs from global storage to scoped storage.\n *\n * `targets` is interpreted as an explicit list of keys by default. When\n * `prefix` is true, each entry in `targets` is treated as a prefix and expanded\n * (via a prefix `list`) into the matching global keys before migration.\n *\n * Streams each blob's raw body, so it is safe for binary, text, and JSON data\n * alike. Keys are preserved exactly. Defaults are conservative: dry-run, no\n * overwrite, and copy (not move).\n */\nexport async function migrateBlobs(\n targets: string[],\n options: MigrateOptions = {},\n): Promise {\n const {\n prefix = false,\n commit = false,\n overwrite = false,\n deleteSource = false,\n onProgress,\n } = options;\n\n // Resolve the keys to migrate. When `prefix` is set, expand each prefix into\n // the matching global keys; otherwise treat `targets` as keys directly.\n let keys: string[];\n if (prefix) {\n const expanded: string[] = [];\n for (const p of targets) {\n const matches = (await globalBlob.list(p)).map((e) => e.key);\n expanded.push(...matches);\n }\n keys = expanded;\n } else {\n keys = targets;\n }\n\n const results: BlobMigrationResult[] = [];\n const uniqueKeys = [...new Set(keys)];\n\n for (const key of uniqueKeys) {\n const result = await migrateOne(key, { commit, overwrite, deleteSource });\n results.push(result);\n onProgress?.(result);\n }\n\n const counts = {\n \"migrated\": 0,\n \"skipped-exists\": 0,\n \"skipped-missing\": 0,\n \"dry-run\": 0,\n \"error\": 0,\n } as Record;\n for (const r of results) counts[r.status]++;\n\n return { results, counts, dryRun: !commit };\n}\n\nasync function migrateOne(\n key: string,\n opts: Required>,\n): Promise {\n try {\n if (!opts.overwrite && (await existsInScoped(key))) {\n return { key, status: \"skipped-exists\" };\n }\n\n // 2. Read from global storage. get() throws if the key is missing.\n let source: Response;\n try {\n source = await globalBlob.get(key);\n } catch (e) {\n if (e instanceof ValTownBlobNotFoundError) {\n return { key, status: \"skipped-missing\" };\n }\n throw e;\n }\n\n // 3. Dry-run: report what would happen without writing.\n if (!opts.commit) {\n // Drain the body so the connection isn't left hanging.\n await source.body?.cancel();\n return { key, status: \"dry-run\" };\n }\n\n // 4. Write the raw body to scoped storage (binary-safe).\n await scopedBlob.set(key, source.body ?? \"\");\n\n // 5. Optionally delete the source (move semantics).\n let sourceDeleted = false;\n if (opts.deleteSource) {\n await globalBlob.delete(key);\n sourceDeleted = true;\n }\n\n return { key, status: \"migrated\", sourceDeleted };\n } catch (e) {\n return {\n key,\n status: \"error\",\n error: e instanceof Error ? e.message : String(e),\n };\n }\n}","createdAt",["D",1781279686474],"branchVersion","branchId","95e9756a-e4dc-4c32-ad4e-e6d718ef2b59","id","f8539a2a-bfcb-41d1-8d5a-2028c5f630a3","migrate-blob",["D",1781278028334],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Library to migrate selected blobs from global to scoped storage","imageUrl","5d1042a9-7b0b-499d-8a72-3a8ac7a4e185","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","5f80108f-7ca4-4327-b77b-089dbe4b5a82","tursoName","f8539a2abfcb41d18d5a2028c5f630a3","tursoHostname","f8539a2abfcb41d18d5a2028c5f630a3-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789494036282],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_106":102},"org",{"_99":98,"_100":-5,"_101":102,"_18":56,"_103":104,"_105":25},"branch",{"_13":88,"_33":89,"_44":43,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":46,"_97":98},"isOwned",63,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","nbbaier","handle","displayName","avatar","https://secure.gravatar.com/avatar/0129a541b7b3574e92c4afd06c5e32da&d=identicon","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_44":45,"_33":46,"_39":166,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":-5,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":167,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":168,"_83":169,"_85":170,"_87":25},"tree",[157,158],"files",[157,158],"counts",{"_146":62,"_147":148,"_149":62,"_150":151,"_152":153},"contents",[129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":138,"_33":139,"_31":140,"_132":-5,"_42":43,"_41":141,"_133":25,"_39":142,"_13":143,"_34":20,"_36":144,"_24":25,"_136":-5,"_27":145},{"_44":131,"_33":28,"_31":32,"_132":-5,"_42":43,"_41":14,"_133":25,"_39":134,"_13":135,"_34":35,"_36":38,"_24":25,"_136":-5,"_27":137},"5059af77-33ca-49e1-b4b4-d43aebe6792c","parentId","latest",["D",1781279686474],22,"label",[28],"86694747-73cd-405e-a356-13d9c01e2fb2","README.md","64d9b1b6-6673-11f1-9df3-1607ee4eb77e",42,["D",1781279597739],3,"# migrate-blob\n\nA small library to migrate a **specific list of blobs** from\n[global blob storage](https://esm.town/v/std/blob/global.ts) (account-wide,\nCloudflare R2) to [scoped blob storage](https://esm.town/v/std/blob/main.ts)\n(per-val, S3).\n\nMigration **streams the raw body** of each blob, so it is safe for binary,\ntext, and JSON alike, and **preserves keys exactly**. Defaults are\nconservative: dry-run, no overwrite, and copy (not move).\n\n## Library usage\n\nImport `migrateBlobs` from `migrate.ts`:\n\n```ts\nimport { migrateBlobs } from \"https://esm.town/v/nbbaier/migrate-blob/migrate.ts\";\n\nconst summary = await migrateBlobs([\"my-config\", \"images/logo.png\"], {\n commit: true, // default false (dry run)\n});\n\nconsole.log(summary.counts);\n// { migrated, \"skipped-exists\", \"skipped-missing\", \"dry-run\", error }\n```\n\n### `migrateBlobs(targets, options)`\n\n| Option | Default | Behavior |\n| -------------- | ------- | ------------------------------------------------------------------------ |\n| `prefix` | `false` | When `true`, targets are expanded as prefixes into global keys. |\n| `commit` | `false` | When `false`, nothing is written — only reports what *would* happen. |\n| `overwrite` | `false` | When `false`, keys already in scoped storage are skipped (idempotent). |\n| `deleteSource` | `false` | When `true`, deletes from global after a successful copy (i.e. a *move*). Ignored unless `commit`. |\n| `onProgress` | — | Callback `(result) => void` invoked after each key. |\n\nReturns a `MigrateSummary`: `{ results, counts, dryRun }`, where each result is\n`{ key, status, sourceDeleted?, error? }`.\n\n### Result statuses\n\n- `migrated` — copied from global to scoped.\n- `skipped-exists` — already present in scoped storage (re-run safe).\n- `skipped-missing` — not found in global storage.\n- `dry-run` — would have migrated, but `commit` was `false`.\n- `error` — see the `error` field.\n\n## How it works\n\n```mermaid\nflowchart LR\n A[\"migrateBlobs(targets)\"] --> B{exists in scoped?}\n B -- yes, no overwrite --> S[\"skipped-exists\"]\n B -- no --> C{exists in global?}\n C -- no --> M[\"skipped-missing\"]\n C -- yes --> D{commit?}\n D -- no --> R[\"dry-run\"]\n D -- yes --> E[\"stream global → scoped\"]\n E --> F{deleteSource?}\n F -- yes --> G[\"delete from global\"]\n F -- no --> H[\"migrated (copy)\"]\n G --> H\n```\n\n## Notes\n\n- Global and scoped blobs are stored separately; you can't reach one through\n the other's interface — hence this migration.\n- Keys can be up to 512 chars. Total storage counts toward your plan limit\n (1 GB on Pro); during a copy (not move) the data exists in *both* stores.\n",[139],"pulls","branches",1,"forks","envVars",{"_154":62,"_156":62},"connections",{"_154":62,"_155":62},"count","unfilledCount","emptyCount",{"_44":138,"_33":139,"_31":140,"_132":-5,"_42":43,"_41":141,"_133":25,"_39":163,"_13":143,"_34":20,"_36":144,"_24":25,"_136":-5,"_160":164,"_27":165},{"_44":131,"_33":28,"_31":32,"_132":-5,"_42":43,"_41":14,"_133":25,"_39":159,"_13":135,"_34":35,"_36":38,"_24":25,"_136":-5,"_160":161,"_27":162},["D",1781279686474],"children",[],[28],["D",1781279597739],[],[139],["D",1781278028334],["D",1789494036282],{"_99":98,"_106":102},{"_99":98,"_100":-5,"_101":102,"_18":56,"_103":104,"_105":25},{"_13":88,"_33":89,"_44":43,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":46,"_97":98},"ctx",{"_81":-5,"_126":204,"_205":206,"_207":208,"_209":25,"_210":25,"_211":25,"_212":213,"_214":-5,"_215":-7,"_216":-7,"_217":62,"_218":25,"_219":25,"_220":-5,"_221":25,"_222":25,"_223":25,"_224":-5},"ENV",{"_175":176,"_177":178,"_179":89,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v46