[{"_1":2,"_546":-5,"_547":-5},"loaderData",{"_3":4,"_20":21,"_32":33,"_545":-5},"root",{"_5":6,"_7":8,"_9":10,"_11":12,"_13":12,"_14":12,"_15":-7,"_16":17,"_18":19},"locale","en-US","hasLegacySpacetimeAuthProject",false,"stargazersCount",25532,"isAnnouncementVisible",true,"shopEnabled","hasSubmodules","sessionUserInfo","latestRelease","v2.14","amplitudeApiKey","1fcca7d2562cf5632b1007694b99cf2d","routes/_marketing.llm-benchmarks",{"_22":23,"_27":28,"_30":26,"_31":29},"languages",[24,25,26],"csharp","rust","typescript","modes",[29],"guidelines","lang","mode","routes/_marketing.llm-benchmarks.evals",{"_34":35},"categories",{"_36":37,"_118":119,"_170":171,"_212":213,"_244":245,"_291":292,"_333":334,"_370":371,"_407":408,"_424":425,"_466":467,"_483":484},"basics",[38,48,53,58,63,68,73,78,83,88,93,98,103,108,113],{"_39":40,"_41":36,"_42":43,"_44":45,"_46":47},"id","t_000_empty_reducers","category","title","Empty Reducers","description","Write a SpacetimeDB backend module in TypeScript that defines a table and these five empty reducers.\n\nTABLES\n- empty_table (private)\n - Fields:\n - id: number (i32, primary key)\n\nREDUCERS\n- emptyReducerNoArgs: no arguments\n- emptyReducerWithInt: count:number (i32)\n- emptyReducerWithString: name:string\n- emptyReducerWithTwoArgs: count:number (i32), name:string\n- emptyReducerWithThreeArgs: active:boolean, ratio:number (f32), label:string","goldenAnswer","import { schema, table, t } from 'spacetimedb/server';\n\nconst empty_table = table({ name: 'empty_table' }, { id: t.i32().primaryKey() });\n\nconst spacetimedb = schema({ empty_table });\nexport default spacetimedb;\n\nexport const emptyReducerNoArgs = spacetimedb.reducer({}, ctx => {\n});\n\nexport const emptyReducerWithInt = spacetimedb.reducer({ count: t.i32() }, (ctx, { count }) => {\n});\n\nexport const emptyReducerWithString = spacetimedb.reducer({ name: t.string() }, (ctx, { name }) => {\n});\n\nexport const emptyReducerWithTwoArgs = spacetimedb.reducer({ count: t.i32(), name: t.string() }, (ctx, { count, name }) => {\n});\n\nexport const emptyReducerWithThreeArgs = spacetimedb.reducer({ active: t.bool(), ratio: t.f32(), label: t.string() }, (ctx, { active, ratio, label }) => {\n});\n",{"_39":49,"_41":36,"_42":50,"_44":51,"_46":52},"t_001_basic_tables","Basic Tables","Write a SpacetimeDB backend module in TypeScript that defines three tables with basic columns.\n\nTABLES\n- user (private)\n - Fields:\n - id: number (i32, primary key)\n - name: string\n - age: number (i32)\n - active: boolean\n\n- product (private)\n - Fields:\n - id: number (i32, primary key)\n - title: string\n - price: number (f32)\n - inStock: boolean\n\n- note (private)\n - Fields:\n - id: number (i32, primary key)\n - body: string\n - rating: bigint (i64)\n - pinned: boolean","import { table, schema, t } from 'spacetimedb/server';\n\nconst user = table({\n name: 'user',\n}, {\n id: t.i32().primaryKey(),\n name: t.string(),\n age: t.i32(),\n active: t.bool(),\n});\n\nconst product = table({\n name: 'product',\n}, {\n id: t.i32().primaryKey(),\n title: t.string(),\n price: t.f32(),\n inStock: t.bool(),\n});\n\nconst note = table({\n name: 'note',\n}, {\n id: t.i32().primaryKey(),\n body: t.string(),\n rating: t.i64(),\n pinned: t.bool(),\n});\n\nconst spacetimedb = schema({ user, product, note });\nexport default spacetimedb;\n",{"_39":54,"_41":36,"_42":55,"_44":56,"_46":57},"t_002_scheduled_table","Scheduled Table","Write a SpacetimeDB backend module in TypeScript that defines a scheduled table and a scheduled reducer.\n\nTABLE\n- tick_timer (private)\n - Fields:\n - scheduledId: bigint (u64, primary key, auto-increment)\n - scheduledAt: ScheduleAt\n - Scheduled: tick reducer, interval of 50ms\n\nREDUCERS\n- tick: scheduled reducer that receives the tick_timer row\n- init: when the module is first published, insert initial scheduled row with 50ms interval","import { ScheduleAt } from 'spacetimedb';\nimport { table, schema, t } from 'spacetimedb/server';\n\nconst tick_timer = table({\n name: 'tick_timer',\n scheduled: (): any => tick,\n}, {\n scheduledId: t.u64().primaryKey().autoInc(),\n scheduledAt: t.scheduleAt(),\n});\n\nconst spacetimedb = schema({ tick_timer });\nexport default spacetimedb;\n\nexport const tick = spacetimedb.reducer({ timer: tick_timer.rowType }, (ctx, { timer }) => {\n});\n\nexport const init = spacetimedb.init(ctx => {\n ctx.db.tick_timer.insert({\n scheduledId: 0n,\n scheduledAt: ScheduleAt.interval(50_000n),\n });\n});\n",{"_39":59,"_41":36,"_42":60,"_44":61,"_46":62},"t_003_struct_in_table","Struct In Table","Write a SpacetimeDB backend module in TypeScript that defines a struct type and uses it in a table.\n\nTYPES\n- Position\n - x: number (i32)\n - y: number (i32)\n\nTABLE\n- entity (private)\n - Fields:\n - id: number (i32, primary key)\n - pos: Position","import { table, schema, t } from 'spacetimedb/server';\n\nconst Position = t.object('Position', {\n x: t.i32(),\n y: t.i32(),\n});\n\nconst entity = table({\n name: 'entity',\n}, {\n id: t.i32().primaryKey(),\n pos: Position,\n});\n\nconst spacetimedb = schema({ entity });\nexport default spacetimedb;\n",{"_39":64,"_41":36,"_42":65,"_44":66,"_46":67},"t_004_insert","Insert","Write a SpacetimeDB backend module in TypeScript that defines one table and a reducer that inserts a row.\n\nTABLE\n- user (public)\n - Fields:\n - id: number (i32, primary key)\n - name: string\n - age: number (i32)\n - active: boolean\n\nREDUCERS\n- insertUser: given id:number, name:string, age:number, active:boolean, insert exactly one row into user\n - (id=id, name=name, age=age, active=active)","import { table, schema, t } from 'spacetimedb/server';\n\nconst user = table(\n {\n name: 'user',\n public: true,\n },\n {\n id: t.i32().primaryKey(),\n name: t.string(),\n age: t.i32(),\n active: t.bool(),\n }\n);\n\nconst spacetimedb = schema({ user });\nexport default spacetimedb;\n\nexport const insertUser = spacetimedb.reducer(\n { id: t.i32(), name: t.string(), age: t.i32(), active: t.bool() },\n (ctx, { id, name, age, active }) => {\n ctx.db.user.insert({ id, name, age, active });\n }\n);\n",{"_39":69,"_41":36,"_42":70,"_44":71,"_46":72},"t_005_update","Update","Write a SpacetimeDB backend module in TypeScript that defines one table and two reducers: one that inserts a row and one that updates a row.\n\nTABLE\n- user (public)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - name: string\n - age: number (i32)\n - active: boolean\n\nREDUCERS\n- insertUser: given name:string, age:number, active:boolean, insert a new row (id is auto-assigned)\n- updateUser: given id:bigint, name:string, age:number, active:boolean, update the row with matching id\n - (id=id, name=name, age=age, active=active)","import { table, schema, t } from 'spacetimedb/server';\n\nconst user = table(\n {\n name: 'user',\n public: true,\n },\n {\n id: t.u64().primaryKey().autoInc(),\n name: t.string(),\n age: t.i32(),\n active: t.bool(),\n }\n);\n\nconst spacetimedb = schema({ user });\nexport default spacetimedb;\n\nexport const insertUser = spacetimedb.reducer(\n { name: t.string(), age: t.i32(), active: t.bool() },\n (ctx, { name, age, active }) => {\n ctx.db.user.insert({ id: 0n, name, age, active });\n }\n);\n\nexport const updateUser = spacetimedb.reducer(\n { id: t.u64(), name: t.string(), age: t.i32(), active: t.bool() },\n (ctx, { id, name, age, active }) => {\n ctx.db.user.id.update({ id, name, age, active });\n }\n);\n",{"_39":74,"_41":36,"_42":75,"_44":76,"_46":77},"t_006_delete","Delete","Write a SpacetimeDB backend module in TypeScript that defines one table and two reducers: one that inserts a row and one that deletes a row.\n\nTABLE\n- user (public)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - name: string\n - age: number (i32)\n - active: boolean\n\nREDUCERS\n- insertUser: given name:string, age:number, active:boolean, insert a new row (id is auto-assigned)\n- deleteUser: given id:bigint, delete the row with matching id","import { table, schema, t } from 'spacetimedb/server';\n\nconst user = table(\n {\n name: 'user',\n public: true,\n },\n {\n id: t.u64().primaryKey().autoInc(),\n name: t.string(),\n age: t.i32(),\n active: t.bool(),\n }\n);\n\nconst spacetimedb = schema({ user });\nexport default spacetimedb;\n\nexport const insertUser = spacetimedb.reducer(\n { name: t.string(), age: t.i32(), active: t.bool() },\n (ctx, { name, age, active }) => {\n ctx.db.user.insert({ id: 0n, name, age, active });\n }\n);\n\nexport const deleteUser = spacetimedb.reducer(\n { id: t.u64() },\n (ctx, { id }) => {\n ctx.db.user.id.delete(id);\n }\n);\n",{"_39":79,"_41":36,"_42":80,"_44":81,"_46":82},"t_007_crud","Crud","Write a SpacetimeDB backend module in TypeScript that defines one table and a reducer that performs insert, update, and delete in one call.\n\nTABLE\n- user (public)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - name: string\n - age: number (i32)\n - active: boolean\n\nREDUCERS\n- crud: no arguments, performs the following operations in order:\n 1. Insert (name=\"Alice\", age=30, active=true) — id is auto-assigned\n 2. Insert (name=\"Bob\", age=22, active=false) — id is auto-assigned\n 3. Update row with id=1 to (name=\"Alice2\", age=31, active=false)\n 4. Delete row with id=2","import { table, schema, t } from 'spacetimedb/server';\n\nconst user = table(\n {\n name: 'user',\n public: true,\n },\n {\n id: t.u64().primaryKey().autoInc(),\n name: t.string(),\n age: t.i32(),\n active: t.bool(),\n }\n);\n\nconst spacetimedb = schema({ user });\nexport default spacetimedb;\n\nexport const crud = spacetimedb.reducer(ctx => {\n ctx.db.user.insert({ id: 0n, name: 'Alice', age: 30, active: true });\n ctx.db.user.insert({ id: 0n, name: 'Bob', age: 22, active: false });\n ctx.db.user.id.update({ id: 1n, name: 'Alice2', age: 31, active: false });\n ctx.db.user.id.delete(2n);\n});\n",{"_39":84,"_41":36,"_42":85,"_44":86,"_46":87},"t_008_index_lookup","Index Lookup","Write a SpacetimeDB backend module in TypeScript that defines two tables and two reducers: one that inserts a user row, and one that looks up a row by primary-key index and writes a projection to another table.\n\nTABLES\n- user (private)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - name: string\n - age: number (i32)\n - active: boolean\n\n- result (public)\n - Fields:\n - id: bigint (u64, primary key)\n - name: string\n\nREDUCERS\n- insertUser: given name:string, age:number, active:boolean, insert a new row into user (id is auto-assigned)\n- lookupUserName: given id:bigint, find user by id, insert projection (id, name) into result table","import { table, schema, t } from 'spacetimedb/server';\n\nconst user = table(\n {\n name: 'user',\n },\n {\n id: t.u64().primaryKey().autoInc(),\n name: t.string(),\n age: t.i32(),\n active: t.bool(),\n }\n);\n\nconst result = table(\n {\n name: 'result',\n public: true,\n },\n {\n id: t.u64().primaryKey(),\n name: t.string(),\n }\n);\n\nconst spacetimedb = schema({ user, result });\nexport default spacetimedb;\n\nexport const insertUser = spacetimedb.reducer(\n { name: t.string(), age: t.i32(), active: t.bool() },\n (ctx, { name, age, active }) => {\n ctx.db.user.insert({ id: 0n, name, age, active });\n }\n);\n\nexport const lookupUserName = spacetimedb.reducer(\n { id: t.u64() },\n (ctx, { id }) => {\n const u = ctx.db.user.id.find(id);\n if (u) {\n ctx.db.result.insert({ id: u.id, name: u.name });\n }\n }\n);\n",{"_39":89,"_41":36,"_42":90,"_44":91,"_46":92},"t_009_init","Init","Write a SpacetimeDB backend module in TypeScript that defines one table and an init reducer that seeds rows on database initialization.\n\nTABLE\n- user (public)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - name: string\n - age: number (i32)\n - active: boolean\n\nREDUCERS\n- init: insert exactly two rows on database initialization (IDs are auto-assigned):\n 1. (name=\"Alice\", age=30, active=true)\n 2. (name=\"Bob\", age=22, active=false)","import { table, schema, t } from 'spacetimedb/server';\n\nconst user = table(\n {\n name: 'user',\n public: true,\n },\n {\n id: t.u64().primaryKey().autoInc(),\n name: t.string(),\n age: t.i32(),\n active: t.bool(),\n }\n);\n\nconst spacetimedb = schema({ user });\nexport default spacetimedb;\n\nexport const init = spacetimedb.init(ctx => {\n ctx.db.user.insert({ id: 0n, name: 'Alice', age: 30, active: true });\n ctx.db.user.insert({ id: 0n, name: 'Bob', age: 22, active: false });\n});\n",{"_39":94,"_41":36,"_42":95,"_44":96,"_46":97},"t_010_connect","Connect","Write a SpacetimeDB backend module in TypeScript that defines one table and two reducers for client lifecycle events.\n\nTABLE\n- event (private)\n - Fields:\n - id: bigint (u64, primary key, auto-increment)\n - kind: string\n\nLIFECYCLE HOOKS\n- onConnect: when a client connects, insert event with kind=\"connected\"\n- onDisconnect: when a client disconnects, insert event with kind=\"disconnected\"","import { table, schema, t } from 'spacetimedb/server';\n\nconst event = table(\n {\n name: 'event',\n },\n {\n id: t.u64().primaryKey().autoInc(),\n kind: t.string(),\n }\n);\n\nconst spacetimedb = schema({ event });\nexport default spacetimedb;\n\nexport const onConnect = spacetimedb.clientConnected(ctx => {\n ctx.db.event.insert({ id: 0n, kind: 'connected' });\n});\n\nexport const onDisconnect = spacetimedb.clientDisconnected(ctx => {\n ctx.db.event.insert({ id: 0n, kind: 'disconnected' });\n});\n",{"_39":99,"_41":36,"_42":100,"_44":101,"_46":102},"t_011_helper_function","Helper Function","Write a SpacetimeDB backend module in TypeScript that defines a table, a non-reducer helper function, and a reducer that uses the helper.\n\nTABLE\n- result (public)\n - Fields:\n - id: number (i32, primary key)\n - sum: number (i32)\n\nHELPER FUNCTION\n- add(a: number, b: number): number - returns a + b\n\nREDUCERS\n- computeSum: given id:number (i32), a:number (i32), b:number (i32), insert row with sum=add(a,b)","import { table, schema, t } from 'spacetimedb/server';\n\nconst result = table({\n name: 'result',\n public: true,\n}, {\n id: t.i32().primaryKey(),\n sum: t.i32(),\n});\n\nconst spacetimedb = schema({ result });\nexport default spacetimedb;\n\nfunction add(a: number, b: number): number {\n return a + b;\n}\n\nexport const computeSum = spacetimedb.reducer({ id: t.i32(), a: t.i32(), b: t.i32() },\n (ctx, { id, a, b }) => {\n ctx.db.result.insert({ id, sum: add(a, b) });\n }\n);\n",{"_39":104,"_41":36,"_42":105,"_44":106,"_46":107},"t_038_schedule_at_time","Schedule At Time","Write a SpacetimeDB backend module in TypeScript that schedules a one-shot reducer to fire at a specific future time.\n\nTABLE\n- reminder (private)\n - Fields:\n - scheduledId: u64 (primary key, auto-increment)\n - scheduledAt: scheduleAt\n - message: string\n - Scheduling: scheduled to call the send_reminder reducer\n\nREDUCERS\n- send_reminder: scheduled reducer triggered by reminder (receives a reminder row argument, does nothing)\n- init: when the module is first published, insert one row into reminder scheduling send_reminder to fire 60 seconds in the future using ScheduleAt.time","import { ScheduleAt } from 'spacetimedb';\nimport { schema, table, t } from 'spacetimedb/server';\n\nconst reminder = table({\n name: 'reminder',\n scheduled: (): any => sendReminder,\n}, {\n scheduledId: t.u64().primaryKey().autoInc(),\n scheduledAt: t.scheduleAt(),\n message: t.string(),\n});\n\nconst spacetimedb = schema({ reminder });\nexport default spacetimedb;\n\nexport const sendReminder = spacetimedb.reducer(\n { timer: reminder.rowType },\n (_ctx, _args) => {}\n);\n\nexport const init = spacetimedb.init(ctx => {\n const fireAt = ctx.timestamp.microsSinceUnixEpoch + 60_000_000n;\n ctx.db.reminder.insert({\n scheduledId: 0n,\n scheduledAt: ScheduleAt.time(fireAt),\n message: 'Hello!',\n });\n});\n",{"_39":109,"_41":36,"_42":110,"_44":111,"_46":112},"t_039_cancel_schedule","Cancel Schedule","Write a SpacetimeDB backend module in TypeScript that schedules a reducer and allows canceling it before it fires.\n\nTABLE\n- cleanup_job (private)\n - Fields:\n - scheduledId: u64 (primary key, auto-increment)\n - scheduledAt: scheduleAt\n - Scheduling: scheduled to call the run_cleanup reducer\n\nREDUCERS\n- run_cleanup: scheduled reducer triggered by cleanup_job (receives a cleanup_job row argument, does nothing)\n- init: when the module is first published, insert one row into cleanup_job with a 60-second interval (60_000_000n microseconds)\n- cancel_cleanup(ctx, { scheduledId: u64 }): deletes the cleanup_job row with the given scheduledId, canceling the pending scheduled call","import { ScheduleAt } from 'spacetimedb';\nimport { schema, table, t } from 'spacetimedb/server';\n\nconst cleanup_job = table({\n name: 'cleanup_job',\n scheduled: (): any => runCleanup,\n}, {\n scheduledId: t.u64().primaryKey().autoInc(),\n scheduledAt: t.scheduleAt(),\n});\n\nconst spacetimedb = schema({ cleanup_job });\nexport default spacetimedb;\n\nexport const runCleanup = spacetimedb.reducer(\n { timer: cleanup_job.rowType },\n (_ctx, _args) => {}\n);\n\nexport const init = spacetimedb.init(ctx => {\n ctx.db.cleanup_job.insert({\n scheduledId: 0n,\n scheduledAt: ScheduleAt.interval(60_000_000n),\n });\n});\n\nexport const cancelCleanup = spacetimedb.reducer(\n { scheduledId: t.u64() },\n (ctx, { scheduledId }) => {\n ctx.db.cleanup_job.scheduledId.delete(scheduledId);\n }\n);\n",{"_39":114,"_41":36,"_42":115,"_44":116,"_46":117},"t_040_lifecycle_player","Lifecycle Player","Write a SpacetimeDB backend module in TypeScript that maintains a table of currently connected players using lifecycle reducers.\n\nTABLE\n- online_player (public)\n - Fields:\n - identity: identity (primary key)\n - connectedAt: timestamp\n\nREDUCERS\n- clientConnected: lifecycle reducer that inserts an online_player row with the caller's identity and the current time as connectedAt\n- clientDisconnected: lifecycle reducer that deletes the online_player row for the caller's identity","import { schema, table, t } from 'spacetimedb/server';\n\nconst online_player = table({\n name: 'online_player',\n public: true,\n}, {\n identity: t.identity().primaryKey(),\n connectedAt: t.timestamp(),\n});\n\nconst spacetimedb = schema({ online_player });\nexport default spacetimedb;\n\nexport const clientConnected = spacetimedb.clientConnected(ctx => {\n ctx.db.online_player.insert({\n identity: ctx.sender,\n connectedAt: ctx.timestamp,\n });\n});\n\nexport const clientDisconnected = spacetimedb.clientDisconnected(ctx => {\n ctx.db.online_player.identity.delete(ctx.sender);\n});\n","schema",[120,125,130,135,140,145,150,155,160,165],{"_39":121,"_41":118,"_42":122,"_44":123,"_46":124},"t_012_spacetime_product_type","Spacetime Product Type","Write a SpacetimeDB backend module in TypeScript that defines a product type and uses it in a table.\n\nTYPES\n- Score\n - left: number (i32)\n - right: number (i32)\n\nTABLE\n- result (public)\n - Fields:\n - id: number (i32, primary key)\n - value: Score\n\nREDUCERS\n- setScore: given id:number, left:number, right:number, insert row with value=Score{left, right}","import { table, schema, t } from 'spacetimedb/server';\n\nconst Score = t.object('Score', {\n left: t.i32(),\n right: t.i32(),\n});\n\nconst result = table({\n name: 'result',\n public: true,\n}, {\n id: t.i32().primaryKey(),\n value: Score,\n});\n\nconst spacetimedb = schema({ result });\nexport default spacetimedb;\n\nexport const setScore = spacetimedb.reducer({ id: t.i32(), left: t.i32(), right: t.i32() },\n (ctx, { id, left, right }) => {\n ctx.db.result.insert({ id, value: { left, right } });\n }\n);\n",{"_39":126,"_41":118,"_42":127,"_44":128,"_46":129},"t_013_spacetime_sum_type","Spacetime Sum Type","Write a SpacetimeDB backend module in TypeScript that defines a new sum type and uses it in a table.\n\nTYPES\n- Rect\n - width: number (i32)\n - height: number (i32)\n- Shape (sum type / enum)\n - circle: number (i32 radius)\n - rectangle: Rect\n\nTABLE\n- result (public)\n - Fields:\n - id: number (i32, primary key)\n - value: Shape\n\nREDUCERS\n- setCircle: given id:number, radius:number, insert row with value=Shape.circle(radius)","import { table, schema, t } from 'spacetimedb/server';\n\nconst Rect = t.object('Rect', {\n width: t.i32(),\n height: t.i32(),\n});\n\nconst Shape = t.enum('Shape', {\n circle: t.i32(),\n rectangle: Rect,\n});\n\nconst result = table(\n {\n name: 'result',\n public: true,\n },\n {\n id: t.i32().primaryKey(),\n value: Shape,\n }\n);\n\nconst spacetimedb = schema({ result });\nexport default spacetimedb;\n\nexport const setCircle = spacetimedb.reducer(\n { id: t.i32(), radius: t.i32() },\n (ctx, { id, radius }) => {\n ctx.db.result.insert({ id, value: { tag: 'circle', value: radius } });\n }\n);\n",{"_39":131,"_41":118,"_42":132,"_44":133,"_46":134},"t_014_elementary_columns","Elementary Columns","Write a SpacetimeDB backend module in TypeScript that defines one table and seeds one row.\n\nTABLE\n- primitive (public)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - count: number (i32)\n - total: bigint (i64)\n - price: number (f32)\n - ratio: number (f64)\n - active: boolean\n - name: string\n\nREDUCERS\n- seed: insert one row with all field types (id is auto-assigned):\n - (count=2, total=3000000000, price=1.5, ratio=2.25, active=true, name=\"Alice\")","import { table, schema, t } from 'spacetimedb/server';\n\nconst primitive = table(\n {\n name: 'primitive',\n public: true,\n },\n {\n id: t.u64().primaryKey().autoInc(),\n count: t.i32(),\n total: t.i64(),\n price: t.f32(),\n ratio: t.f64(),\n active: t.bool(),\n name: t.string(),\n }\n);\n\nconst spacetimedb = schema({ primitive });\nexport default spacetimedb;\n\nexport const seed = spacetimedb.reducer(ctx => {\n ctx.db.primitive.insert({\n id: 0n,\n count: 2,\n total: 3000000000n,\n price: 1.5,\n ratio: 2.25,\n active: true,\n name: 'Alice',\n });\n});\n",{"_39":136,"_41":118,"_42":137,"_44":138,"_46":139},"t_015_product_type_columns","Product Type Columns","Write a SpacetimeDB backend module in TypeScript that defines product types and uses them as columns in a table.\n\nTYPES\n- Address\n - street: string\n - zip: number (i32)\n- Position\n - x: number (i32)\n - y: number (i32)\n\nTABLE\n- profile (public)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - home: Address\n - work: Address\n - pos: Position\n\nREDUCERS\n- seed: insert one row with all nested types (id is auto-assigned):\n - home: { street: \"1 Main\", zip: 11111 }\n - work: { street: \"2 Broad\", zip: 22222 }\n - pos: { x: 7, y: 9 }","import { table, schema, t } from 'spacetimedb/server';\n\nconst Address = t.object('Address', {\n street: t.string(),\n zip: t.i32(),\n});\n\nconst Position = t.object('Position', {\n x: t.i32(),\n y: t.i32(),\n});\n\nconst profile = table(\n {\n name: 'profile',\n public: true,\n },\n {\n id: t.u64().primaryKey().autoInc(),\n home: Address,\n work: Address,\n pos: Position,\n }\n);\n\nconst spacetimedb = schema({ profile });\nexport default spacetimedb;\n\nexport const seed = spacetimedb.reducer(ctx => {\n ctx.db.profile.insert({\n id: 0n,\n home: { street: '1 Main', zip: 11111 },\n work: { street: '2 Broad', zip: 22222 },\n pos: { x: 7, y: 9 },\n });\n});\n",{"_39":141,"_41":118,"_42":142,"_44":143,"_46":144},"t_016_sum_type_columns","Sum Type Columns","Write a SpacetimeDB backend module in TypeScript that defines a sum type and uses it in multiple table columns.\n\nTYPES\n- Rect\n - width: number (i32)\n - height: number (i32)\n- Shape (sum type / enum)\n - circle: number (i32 radius)\n - rectangle: Rect\n\nTABLE\n- drawing (public)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - a: Shape\n - b: Shape\n\nREDUCERS\n- seed: insert one row with two Shape values (id is auto-assigned):\n - a: Shape.circle(10)\n - b: Shape.rectangle({ width: 4, height: 6 })","import { table, schema, t } from 'spacetimedb/server';\n\nconst Rect = t.object('Rect', {\n width: t.i32(),\n height: t.i32(),\n});\n\nconst Shape = t.enum('Shape', {\n circle: t.i32(),\n rectangle: Rect,\n});\n\nconst drawing = table({\n name: 'drawing',\n public: true,\n}, {\n id: t.u64().primaryKey().autoInc(),\n a: Shape,\n b: Shape,\n});\n\nconst spacetimedb = schema({ drawing });\nexport default spacetimedb;\n\nexport const seed = spacetimedb.reducer(\n ctx => {\n ctx.db.drawing.insert({\n id: 0n,\n a: { tag: 'circle', value: 10 },\n b: { tag: 'rectangle', value: { width: 4, height: 6 } },\n });\n }\n);\n",{"_39":146,"_41":118,"_42":147,"_44":148,"_46":149},"t_017_scheduled_columns","Scheduled Columns","Write a SpacetimeDB backend module in TypeScript that defines a scheduled table and seeds one schedule entry.\n\nTABLE\n- tick_timer (public)\n - Fields:\n - scheduledId: bigint (u64, primary key, auto-increment)\n - scheduledAt: ScheduleAt\n - Scheduled: tick reducer, interval of 50ms\n\nREDUCERS\n- tick: scheduled reducer that receives the tick_timer row\n- init: when the module is first published, insert initial scheduled row with 50ms interval","import { ScheduleAt } from 'spacetimedb';\nimport { table, schema, t } from 'spacetimedb/server';\n\nconst tick_timer = table(\n {\n name: 'tick_timer',\n public: true,\n scheduled: (): any => tick,\n },\n {\n scheduledId: t.u64().primaryKey().autoInc(),\n scheduledAt: t.scheduleAt(),\n }\n);\n\nconst spacetimedb = schema({ tick_timer });\nexport default spacetimedb;\n\nexport const tick = spacetimedb.reducer(\n { schedule: tick_timer.rowType },\n (ctx, { schedule }) => {}\n);\n\nexport const init = spacetimedb.init(ctx => {\n ctx.db.tick_timer.insert({\n scheduledId: 0n,\n scheduledAt: ScheduleAt.interval(50_000n),\n });\n});\n",{"_39":151,"_41":118,"_42":152,"_44":153,"_46":154},"t_018_constraints","Constraints","Write a SpacetimeDB backend module in TypeScript that defines one table and seeds two rows.\n\nTABLE\n- account (public)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - email: string (unique)\n - name: string\n - Index: byName (btree on name)\n\nREDUCERS\n- seed: insert two rows (IDs are auto-assigned):\n - (email=\"a@example.com\", name=\"Alice\")\n - (email=\"b@example.com\", name=\"Bob\")","import { table, schema, t } from 'spacetimedb/server';\n\nconst account = table({\n name: 'account',\n public: true,\n indexes: [{ accessor: 'byName', algorithm: 'btree', columns: ['name'] }],\n}, {\n id: t.u64().primaryKey().autoInc(),\n email: t.string().unique(),\n name: t.string(),\n});\n\nconst spacetimedb = schema({ account });\nexport default spacetimedb;\n\nexport const seed = spacetimedb.reducer(\n ctx => {\n ctx.db.account.insert({ id: 0n, email: \"a@example.com\", name: \"Alice\" });\n ctx.db.account.insert({ id: 0n, email: \"b@example.com\", name: \"Bob\" });\n }\n);\n",{"_39":156,"_41":118,"_42":157,"_44":158,"_46":159},"t_019_many_to_many","Many To Many","Write a SpacetimeDB backend module in TypeScript that defines three tables modeling a many-to-many relationship and seeds rows.\n\nTABLES\n- user (private)\n - Fields:\n - userId: bigint (u64, primary key, autoInc)\n - name: string\n\n- group (private)\n - Fields:\n - groupId: bigint (u64, primary key, autoInc)\n - title: string\n\n- membership (public)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - userId: bigint (u64)\n - groupId: bigint (u64)\n - Indexes:\n - byUser (btree on userId)\n - byGroup (btree on groupId)\n\nREDUCERS\n- seed: insert users, groups, and memberships (IDs are auto-assigned):\n - user: (\"Alice\"), (\"Bob\")\n - group: (\"Admin\"), (\"Dev\")\n - membership: (userId=1, groupId=1), (userId=1, groupId=2), (userId=2, groupId=2)","import { table, schema, t } from 'spacetimedb/server';\n\nconst user = table(\n {\n name: 'user',\n },\n {\n userId: t.u64().primaryKey().autoInc(),\n name: t.string(),\n }\n);\n\nconst group = table(\n {\n name: 'group',\n },\n {\n groupId: t.u64().primaryKey().autoInc(),\n title: t.string(),\n }\n);\n\nconst membership = table(\n {\n name: 'membership',\n public: true,\n indexes: [\n { accessor: 'byUser', algorithm: 'btree', columns: ['userId'] },\n { accessor: 'byGroup', algorithm: 'btree', columns: ['groupId'] },\n ],\n },\n {\n id: t.u64().primaryKey().autoInc(),\n userId: t.u64(),\n groupId: t.u64(),\n }\n);\n\nconst spacetimedb = schema({ user, group, membership });\nexport default spacetimedb;\n\nexport const seed = spacetimedb.reducer(ctx => {\n ctx.db.user.insert({ userId: 0n, name: 'Alice' });\n ctx.db.user.insert({ userId: 0n, name: 'Bob' });\n\n ctx.db.group.insert({ groupId: 0n, title: 'Admin' });\n ctx.db.group.insert({ groupId: 0n, title: 'Dev' });\n\n ctx.db.membership.insert({ id: 0n, userId: 1n, groupId: 1n });\n ctx.db.membership.insert({ id: 0n, userId: 1n, groupId: 2n });\n ctx.db.membership.insert({ id: 0n, userId: 2n, groupId: 2n });\n});\n",{"_39":161,"_41":118,"_42":162,"_44":163,"_46":164},"t_020_ecs","Ecs","Write a SpacetimeDB backend module in TypeScript that models a minimal ECS and computes next positions.\n\nTABLES\n- entity (private)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n\n- position (public)\n - Fields:\n - entityId: number (i32, primary key) — NOT autoInc, this is a foreign key to entity\n - x: number (i32)\n - y: number (i32)\n\n- velocity (private)\n - Fields:\n - entityId: number (i32, primary key) — NOT autoInc, this is a foreign key to entity\n - vx: number (i32)\n - vy: number (i32)\n\n- next_position (public)\n - Fields:\n - entityId: number (i32, primary key) — NOT autoInc, this is a foreign key to entity\n - x: number (i32)\n - y: number (i32)\n\nREDUCERS\n- seed: insert 2 entities with positions and velocities (entity IDs are auto-assigned):\n - Entity 1: position(0,0), velocity(1,0)\n - Entity 2: position(10,0), velocity(-2,3)\n\n- step: for each position, find velocity, compute next position (x+vx, y+vy), upsert to next_position","import { table, schema, t } from 'spacetimedb/server';\n\nconst entity = table(\n {\n name: 'entity',\n },\n {\n id: t.u64().primaryKey().autoInc(),\n }\n);\n\nconst position = table(\n {\n name: 'position',\n public: true,\n },\n {\n entityId: t.i32().primaryKey(),\n x: t.i32(),\n y: t.i32(),\n }\n);\n\nconst velocity = table(\n {\n name: 'velocity',\n },\n {\n entityId: t.i32().primaryKey(),\n vx: t.i32(),\n vy: t.i32(),\n }\n);\n\nconst next_position = table(\n {\n name: 'next_position',\n public: true,\n },\n {\n entityId: t.i32().primaryKey(),\n x: t.i32(),\n y: t.i32(),\n }\n);\n\nconst spacetimedb = schema({ entity, position, velocity, next_position });\nexport default spacetimedb;\n\nexport const seed = spacetimedb.reducer(ctx => {\n ctx.db.entity.insert({ id: 0n });\n ctx.db.entity.insert({ id: 0n });\n\n ctx.db.position.insert({ entityId: 1, x: 0, y: 0 });\n ctx.db.position.insert({ entityId: 2, x: 10, y: 0 });\n\n ctx.db.velocity.insert({ entityId: 1, vx: 1, vy: 0 });\n ctx.db.velocity.insert({ entityId: 2, vx: -2, vy: 3 });\n});\n\nexport const step = spacetimedb.reducer(ctx => {\n for (const p of ctx.db.position.iter()) {\n const v = ctx.db.velocity.entityId.find(p.entityId);\n if (v) {\n const np = {\n entityId: p.entityId,\n x: p.x + v.vx,\n y: p.y + v.vy,\n };\n\n if (ctx.db.next_position.entityId.find(p.entityId)) {\n ctx.db.next_position.entityId.update(np);\n } else {\n ctx.db.next_position.insert(np);\n }\n }\n }\n});\n",{"_39":166,"_41":118,"_42":167,"_44":168,"_46":169},"t_021_multi_column_index","Multi Column Index","Write a SpacetimeDB backend module in TypeScript that defines one table with a multi-column B-Tree index and seeds rows.\n\nTABLE\n- log (public)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - userId: number (i32)\n - day: number (i32)\n - message: string\n - Index: byUserDay (btree on userId, day)\n\nREDUCERS\n- seed: insert three rows (IDs are auto-assigned):\n - (userId=7, day=1, message=\"a\")\n - (userId=7, day=2, message=\"b\")\n - (userId=9, day=1, message=\"c\")","import { table, schema, t } from 'spacetimedb/server';\n\nconst log = table({\n name: 'log',\n public: true,\n indexes: [{ accessor: 'byUserDay', algorithm: 'btree', columns: ['userId', 'day'] }],\n}, {\n id: t.u64().primaryKey().autoInc(),\n userId: t.i32(),\n day: t.i32(),\n message: t.string(),\n});\n\nconst spacetimedb = schema({ log });\nexport default spacetimedb;\n\nexport const seed = spacetimedb.reducer(\n ctx => {\n ctx.db.log.insert({ id: 0n, userId: 7, day: 1, message: \"a\" });\n ctx.db.log.insert({ id: 0n, userId: 7, day: 2, message: \"b\" });\n ctx.db.log.insert({ id: 0n, userId: 9, day: 1, message: \"c\" });\n }\n);\n","queries",[172,177,182,187,192,197,202,207],{"_39":173,"_41":170,"_42":174,"_44":175,"_46":176},"t_022_view_basic","View Basic","Write a SpacetimeDB backend module in TypeScript that defines a public anonymous view over a table.\n\nTABLE\n- announcement (public)\n - Fields:\n - id: u64 (primary key, auto-increment)\n - message: string\n - active: bool (btree index)\n\nVIEW\n- activeAnnouncements (anonymousView, public)\n - Returns: array of announcement rows\n - Body: return all rows where active == true using the btree index filter","import { schema, table, t } from 'spacetimedb/server';\n\nconst announcement = table({\n name: 'announcement',\n public: true,\n}, {\n id: t.u64().primaryKey().autoInc(),\n message: t.string(),\n active: t.bool().index('btree'),\n});\n\nconst spacetimedb = schema({ announcement });\nexport default spacetimedb;\n\nexport const activeAnnouncements = spacetimedb.anonymousView(\n { name: 'active_announcements', public: true },\n t.array(announcement.rowType),\n (ctx) => {\n return Array.from(ctx.db.announcement.active.filter(true));\n }\n);\n",{"_39":178,"_41":170,"_42":179,"_44":180,"_46":181},"t_023_view_per_user","View Per User","Write a SpacetimeDB backend module in TypeScript that defines a table of user profiles and a per-user view that returns only the calling user's profile.\n\nThe module defines no reducers.\n\nTABLES\n- profile\n - public table\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - identity: Identity (unique)\n - name: string\n - bio: string\n\nVIEWS\n- my_profile\n - per-user view, not an anonymous one\n - public\n - Returns: option of profile row (the single profile matching the caller's identity, or undefined)\n - Logic: find the profile by the identity column matching the caller's identity","import { schema, table, t } from 'spacetimedb/server';\n\nconst profile = table({\n name: 'profile',\n public: true,\n}, {\n id: t.u64().primaryKey().autoInc(),\n identity: t.identity().unique(),\n name: t.string(),\n bio: t.string(),\n});\n\nconst spacetimedb = schema({ profile });\nexport default spacetimedb;\n\nexport const my_profile = spacetimedb.view(\n { name: 'my_profile', public: true },\n t.option(profile.rowType),\n (ctx) => {\n return ctx.db.profile.identity.find(ctx.sender) ?? undefined;\n }\n);\n",{"_39":183,"_41":170,"_42":184,"_44":185,"_46":186},"t_032_range_query","Range Query","Write a SpacetimeDB backend module in TypeScript that defines a product table with a BTree-indexed price column, a result table, and a reducer that filters products within a price range and writes matches to the result table.\n\nTABLES\n- product (private)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - name: string\n - price: number (u32, index btree)\n\n- price_range_result (private)\n - Fields:\n - productId: bigint (u64, primary key)\n - name: string\n - price: number (u32)\n\nREDUCERS\n- find_in_price_range(ctx, { minPrice: number (u32), maxPrice: number (u32) })\n - Iterate all products\n - For each product where price >= minPrice AND price <= maxPrice, insert a price_range_result row","import { schema, table, t } from 'spacetimedb/server';\n\nconst product = table({\n name: 'product',\n}, {\n id: t.u64().primaryKey().autoInc(),\n name: t.string(),\n price: t.u32().index('btree'),\n});\n\nconst price_range_result = table({\n name: 'price_range_result',\n}, {\n productId: t.u64().primaryKey(),\n name: t.string(),\n price: t.u32(),\n});\n\nconst spacetimedb = schema({ product, price_range_result });\nexport default spacetimedb;\n\nexport const find_in_price_range = spacetimedb.reducer(\n { minPrice: t.u32(), maxPrice: t.u32() },\n (ctx, { minPrice, maxPrice }) => {\n for (const p of ctx.db.product.iter()) {\n if (p.price >= minPrice && p.price <= maxPrice) {\n ctx.db.price_range_result.insert({\n productId: p.id,\n name: p.name,\n price: p.price,\n });\n }\n }\n }\n);\n",{"_39":188,"_41":170,"_42":189,"_44":190,"_46":191},"t_033_sort_and_limit","Sort And Limit","Write a SpacetimeDB backend module in TypeScript that defines a player table with scores, a leaderboard result table, and a reducer that finds the top N players by score (descending) and writes them to the result table.\n\nTABLES\n- player (private)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - name: string\n - score: bigint (u64)\n\n- leaderboard (private)\n - Fields:\n - rank: number (u32, primary key)\n - playerName: string\n - score: bigint (u64)\n\nREDUCERS\n- build_leaderboard(ctx, { limit: number (u32) })\n - Order players by score, highest first\n - Take the first `limit` entries\n - Insert each into leaderboard with rank starting at 1","import { schema, table, t } from 'spacetimedb/server';\n\nconst player = table({\n name: 'player',\n}, {\n id: t.u64().primaryKey().autoInc(),\n name: t.string(),\n score: t.u64(),\n});\n\nconst leaderboard = table({\n name: 'leaderboard',\n}, {\n rank: t.u32().primaryKey(),\n playerName: t.string(),\n score: t.u64(),\n});\n\nconst spacetimedb = schema({ player, leaderboard });\nexport default spacetimedb;\n\nexport const build_leaderboard = spacetimedb.reducer(\n { limit: t.u32() },\n (ctx, { limit }) => {\n const players = Array.from(ctx.db.player.iter());\n players.sort((a, b) => (b.score > a.score ? 1 : b.score < a.score ? -1 : 0));\n\n for (let i = 0; i < Math.min(limit, players.length); i++) {\n const p = players[i];\n ctx.db.leaderboard.insert({\n rank: i + 1,\n playerName: p.name,\n score: p.score,\n });\n }\n }\n);\n",{"_39":193,"_41":170,"_42":194,"_44":195,"_46":196},"t_034_find_first","Find First","Write a SpacetimeDB backend module in TypeScript that defines a task table and a result table, with a reducer that finds the first incomplete task and writes it to the result table.\n\nTABLES\n- task (private)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - title: string\n - completed: boolean\n\n- first_incomplete (private)\n - Fields:\n - taskId: bigint (u64, primary key)\n - title: string\n\nREDUCERS\n- find_first_incomplete(ctx)\n - Iterate through the task table\n - Find the first task where completed is false\n - If found, insert it into first_incomplete","import { schema, table, t } from 'spacetimedb/server';\n\nconst task = table({\n name: 'task',\n}, {\n id: t.u64().primaryKey().autoInc(),\n title: t.string(),\n completed: t.bool(),\n});\n\nconst first_incomplete = table({\n name: 'first_incomplete',\n}, {\n taskId: t.u64().primaryKey(),\n title: t.string(),\n});\n\nconst spacetimedb = schema({ task, first_incomplete });\nexport default spacetimedb;\n\nexport const find_first_incomplete = spacetimedb.reducer(\n (ctx) => {\n for (const t of ctx.db.task.iter()) {\n if (!t.completed) {\n ctx.db.first_incomplete.insert({\n taskId: t.id,\n title: t.title,\n });\n return;\n }\n }\n }\n);\n",{"_39":198,"_41":170,"_42":199,"_44":200,"_46":201},"t_035_select_distinct","Select Distinct","Write a SpacetimeDB backend module in TypeScript that defines an order table and a result table, with a reducer that collects all distinct category values from orders into the result table.\n\nTABLES\n- order (private)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - category: string\n - amount: number (u32)\n\n- distinct_category (private)\n - Fields:\n - category: string (primary key)\n\nREDUCERS\n- collect_distinct_categories(ctx)\n - Iterate all orders\n - Collect unique category values\n - Insert each unique category into distinct_category","import { schema, table, t } from 'spacetimedb/server';\n\nconst order = table({\n name: 'order',\n}, {\n id: t.u64().primaryKey().autoInc(),\n category: t.string(),\n amount: t.u32(),\n});\n\nconst distinct_category = table({\n name: 'distinct_category',\n}, {\n category: t.string().primaryKey(),\n});\n\nconst spacetimedb = schema({ order, distinct_category });\nexport default spacetimedb;\n\nexport const collect_distinct_categories = spacetimedb.reducer(\n (ctx) => {\n const categories = new Set();\n for (const o of ctx.db.order.iter()) {\n categories.add(o.category);\n }\n for (const category of categories) {\n ctx.db.distinct_category.insert({ category });\n }\n }\n);\n",{"_39":203,"_41":170,"_42":204,"_44":205,"_46":206},"t_036_count_without_collect","Count Without Collect","Write a SpacetimeDB backend module in TypeScript that defines a user table and a stats table, with a reducer that counts total users and active users without collecting into an array.\n\nTABLES\n- user (private)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - name: string\n - active: boolean\n\n- user_stats (private)\n - Fields:\n - key: string (primary key)\n - count: bigint (u64)\n\nREDUCERS\n- compute_user_counts(ctx)\n - Count total users without collecting them into an array first\n - Count active users the same way\n - Insert a user_stats row with key=\"total\" and the total count\n - Insert a user_stats row with key=\"active\" and the active count","import { schema, table, t } from 'spacetimedb/server';\n\nconst user = table({\n name: 'user',\n}, {\n id: t.u64().primaryKey().autoInc(),\n name: t.string(),\n active: t.bool(),\n});\n\nconst user_stats = table({\n name: 'user_stats',\n}, {\n key: t.string().primaryKey(),\n count: t.u64(),\n});\n\nconst spacetimedb = schema({ user, user_stats });\nexport default spacetimedb;\n\nexport const compute_user_counts = spacetimedb.reducer(\n (ctx) => {\n let total = 0n;\n let active = 0n;\n for (const u of ctx.db.user.iter()) {\n total += 1n;\n if (u.active) {\n active += 1n;\n }\n }\n\n ctx.db.user_stats.insert({ key: 'total', count: total });\n ctx.db.user_stats.insert({ key: 'active', count: active });\n }\n);\n",{"_39":208,"_41":170,"_42":209,"_44":210,"_46":211},"t_037_multi_column_filter","Multi Column Filter","Write a SpacetimeDB backend module in TypeScript that defines an event log table with a multi-column BTree index and a result table, with a reducer that filters events by both category and severity level.\n\nTABLES\n- event_log (private)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - category: string\n - severity: number (u32)\n - message: string\n - Index: multi-column btree index on (category, severity)\n\n- filtered_event (private)\n - Fields:\n - eventId: bigint (u64, primary key)\n - message: string\n\nREDUCERS\n- filter_events(ctx, { category: string, severity: number (u32) })\n - Iterate all event_log rows\n - For each row where category matches AND severity matches, insert into filtered_event","import { schema, table, t } from 'spacetimedb/server';\n\nconst event_log = table({\n name: 'event_log',\n indexes: [{ accessor: 'byCategorySeverity', algorithm: 'btree', columns: ['category', 'severity'] }],\n}, {\n id: t.u64().primaryKey().autoInc(),\n category: t.string(),\n severity: t.u32(),\n message: t.string(),\n});\n\nconst filtered_event = table({\n name: 'filtered_event',\n}, {\n eventId: t.u64().primaryKey(),\n message: t.string(),\n});\n\nconst spacetimedb = schema({ event_log, filtered_event });\nexport default spacetimedb;\n\nexport const filter_events = spacetimedb.reducer(\n { category: t.string(), severity: t.u32() },\n (ctx, { category, severity }) => {\n for (const e of ctx.db.event_log.iter()) {\n if (e.category === category && e.severity === severity) {\n ctx.db.filtered_event.insert({\n eventId: e.id,\n message: e.message,\n });\n }\n }\n }\n);\n","data_modeling",[214,219,224,229,234,239],{"_39":215,"_41":212,"_42":216,"_44":217,"_46":218},"t_024_event_table","Event Table","Write a SpacetimeDB backend module in TypeScript that defines an event table for damage notifications and a reducer that publishes events to it.\n\nTABLES\n- damage_event\n - public event table (rows exist only for the duration of the transaction, set event: true)\n - Fields:\n - entityId: bigint (u64)\n - damage: number (u32)\n - source: string\n\nREDUCERS\n- deal_damage(ctx, { entityId: bigint (u64), damage: number (u32), source: string })\n - Insert a row into the damage_event event table","import { schema, table, t } from 'spacetimedb/server';\n\nconst damage_event = table({\n name: 'damage_event',\n public: true,\n event: true,\n}, {\n entityId: t.u64(),\n damage: t.u32(),\n source: t.string(),\n});\n\nconst spacetimedb = schema({ damage_event });\nexport default spacetimedb;\n\nexport const deal_damage = spacetimedb.reducer(\n { entityId: t.u64(), damage: t.u32(), source: t.string() },\n (ctx, { entityId, damage, source }) => {\n ctx.db.damage_event.insert({ entityId, damage, source });\n }\n);\n",{"_39":220,"_41":212,"_42":221,"_44":222,"_46":223},"t_025_optional_fields","Optional Fields","Write a SpacetimeDB backend module in TypeScript that defines a table with optional (nullable) fields and a reducer that inserts rows with and without optional values.\n\nTABLES\n- player (private)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - name: string\n - nickname: optional string\n - highScore: optional number (u32)\n\nREDUCERS\n- create_player(ctx, { name: string, nickname: optional string, highScore: optional number (u32) })\n - Insert a player row, passing through the optional fields as-is","import { schema, table, t } from 'spacetimedb/server';\n\nconst player = table({\n name: 'player',\n}, {\n id: t.u64().primaryKey().autoInc(),\n name: t.string(),\n nickname: t.option(t.string()),\n highScore: t.option(t.u32()),\n});\n\nconst spacetimedb = schema({ player });\nexport default spacetimedb;\n\nexport const create_player = spacetimedb.reducer(\n { name: t.string(), nickname: t.option(t.string()), highScore: t.option(t.u32()) },\n (ctx, { name, nickname, highScore }) => {\n ctx.db.player.insert({\n id: 0n,\n name,\n nickname,\n highScore,\n });\n }\n);\n",{"_39":225,"_41":212,"_42":226,"_44":227,"_46":228},"t_028_cascade_delete","Cascade Delete","Write a SpacetimeDB backend module in TypeScript that defines an author table and a post table with a foreign key, and a reducer that deletes an author along with all their posts.\n\nTABLES\n- author (private)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - name: string\n\n- post (private)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - authorId: bigint (u64, index btree)\n - title: string\n\nREDUCERS\n- delete_author(ctx, { authorId: bigint (u64) })\n - First, iterate all posts with matching authorId and delete each one\n - Then delete the author by id","import { schema, table, t } from 'spacetimedb/server';\n\nconst author = table({\n name: 'author',\n}, {\n id: t.u64().primaryKey().autoInc(),\n name: t.string(),\n});\n\nconst post = table({\n name: 'post',\n}, {\n id: t.u64().primaryKey().autoInc(),\n authorId: t.u64().index('btree'),\n title: t.string(),\n});\n\nconst spacetimedb = schema({ author, post });\nexport default spacetimedb;\n\nexport const delete_author = spacetimedb.reducer(\n { authorId: t.u64() },\n (ctx, { authorId }) => {\n // Delete all posts by this author\n for (const p of ctx.db.post.authorId.filter(authorId)) {\n ctx.db.post.id.delete(p.id);\n }\n // Delete the author\n ctx.db.author.id.delete(authorId);\n }\n);\n",{"_39":230,"_41":212,"_42":231,"_44":232,"_46":233},"t_029_filter_and_aggregate","Filter And Aggregate","Write a SpacetimeDB backend module in TypeScript that defines an order table and a stats table, with a reducer that computes aggregate statistics from filtered orders.\n\nTABLES\n- order (private)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - category: string (index btree)\n - amount: bigint (u64)\n - fulfilled: boolean\n\n- category_stats (private)\n - Fields:\n - category: string (primary key)\n - totalAmount: bigint (u64)\n - orderCount: number (u32)\n\nREDUCERS\n- compute_stats(ctx, { category: string })\n - Filter all orders matching the given category\n - Count the number of matching orders and sum their amounts\n - Insert (or update if exists) a category_stats row with the results","import { schema, table, t } from 'spacetimedb/server';\n\nconst order = table({\n name: 'order',\n}, {\n id: t.u64().primaryKey().autoInc(),\n category: t.string().index('btree'),\n amount: t.u64(),\n fulfilled: t.bool(),\n});\n\nconst category_stats = table({\n name: 'category_stats',\n}, {\n category: t.string().primaryKey(),\n totalAmount: t.u64(),\n orderCount: t.u32(),\n});\n\nconst spacetimedb = schema({ order, category_stats });\nexport default spacetimedb;\n\nexport const compute_stats = spacetimedb.reducer(\n { category: t.string() },\n (ctx, { category }) => {\n let totalAmount = 0n;\n let orderCount = 0;\n\n for (const o of ctx.db.order.category.filter(category)) {\n totalAmount += o.amount;\n orderCount += 1;\n }\n\n // Upsert: delete existing then insert\n ctx.db.category_stats.category.delete(category);\n ctx.db.category_stats.insert({\n category,\n totalAmount,\n orderCount,\n });\n }\n);\n",{"_39":235,"_41":212,"_42":236,"_44":237,"_46":238},"t_030_two_table_join","Two Table Join","Write a SpacetimeDB backend module in TypeScript that defines a customer table, an order table with a foreign key to customer, and a denormalized result table. Include a reducer that joins the two tables and writes results.\n\nTABLES\n- customer (private)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - name: string\n\n- order (private)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - customerId: bigint (u64, index btree)\n - product: string\n - amount: number (u32)\n\n- order_detail (private)\n - Fields:\n - orderId: bigint (u64, primary key)\n - customerName: string\n - product: string\n - amount: number (u32)\n\nREDUCERS\n- build_order_details(ctx)\n - Iterate all orders\n - For each order, look up the customer by customerId\n - If the customer is found, insert an order_detail row with the joined data","import { schema, table, t } from 'spacetimedb/server';\n\nconst customer = table({\n name: 'customer',\n}, {\n id: t.u64().primaryKey().autoInc(),\n name: t.string(),\n});\n\nconst order = table({\n name: 'order',\n}, {\n id: t.u64().primaryKey().autoInc(),\n customerId: t.u64().index('btree'),\n product: t.string(),\n amount: t.u32(),\n});\n\nconst order_detail = table({\n name: 'order_detail',\n}, {\n orderId: t.u64().primaryKey(),\n customerName: t.string(),\n product: t.string(),\n amount: t.u32(),\n});\n\nconst spacetimedb = schema({ customer, order, order_detail });\nexport default spacetimedb;\n\nexport const build_order_details = spacetimedb.reducer(\n (ctx) => {\n for (const o of ctx.db.order.iter()) {\n const c = ctx.db.customer.id.find(o.customerId);\n if (c) {\n ctx.db.order_detail.insert({\n orderId: o.id,\n customerName: c.name,\n product: o.product,\n amount: o.amount,\n });\n }\n }\n }\n);\n",{"_39":240,"_41":212,"_42":241,"_44":242,"_46":243},"t_031_unique_constraint","Unique Constraint","Write a SpacetimeDB backend module in TypeScript that defines a table with a unique constraint on a non-primary-key column and a reducer that inserts rows.\n\nTABLES\n- account (private)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - email: string (unique)\n - displayName: string\n\nREDUCERS\n- create_account(ctx, { email: string, displayName: string })\n - Insert an account row with the given email and displayName","import { schema, table, t } from 'spacetimedb/server';\n\nconst account = table({\n name: 'account',\n}, {\n id: t.u64().primaryKey().autoInc(),\n email: t.string().unique(),\n displayName: t.string(),\n});\n\nconst spacetimedb = schema({ account });\nexport default spacetimedb;\n\nexport const create_account = spacetimedb.reducer(\n { email: t.string(), displayName: t.string() },\n (ctx, { email, displayName }) => {\n ctx.db.account.insert({\n id: 0n,\n email,\n displayName,\n });\n }\n);\n","auth",[246,251,256,261,266,271,276,281,286],{"_39":247,"_41":244,"_42":248,"_44":249,"_46":250},"t_026_auth_identity_check","Auth Identity Check","Write a SpacetimeDB backend module in TypeScript that defines a table of messages owned by users, and reducers that enforce ownership using the caller's identity.\n\nTABLES\n- message\n - public table\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - owner: Identity (index btree)\n - text: string\n\nREDUCERS\n- create_message(ctx, { text: string })\n - Insert a new message with owner set to the caller's identity\n\n- delete_message(ctx, { id: bigint (u64) })\n - Find the message by id\n - If not found, fail with \"not found\"\n - If the message's owner does not equal the caller's identity, fail with \"unauthorized\"\n - Otherwise, delete the message","import { schema, table, t } from 'spacetimedb/server';\n\nconst message = table({\n name: 'message',\n public: true,\n}, {\n id: t.u64().primaryKey().autoInc(),\n owner: t.identity().index('btree'),\n text: t.string(),\n});\n\nconst spacetimedb = schema({ message });\nexport default spacetimedb;\n\nexport const create_message = spacetimedb.reducer(\n { text: t.string() },\n (ctx, { text }) => {\n ctx.db.message.insert({\n id: 0n,\n owner: ctx.sender,\n text,\n });\n }\n);\n\nexport const delete_message = spacetimedb.reducer(\n { id: t.u64() },\n (ctx, { id }) => {\n const msg = ctx.db.message.id.find(id);\n if (!msg) {\n throw new Error(\"not found\");\n }\n if (!msg.owner.equals(ctx.sender)) {\n throw new Error(\"unauthorized\");\n }\n ctx.db.message.id.delete(id);\n }\n);\n",{"_39":252,"_41":244,"_42":253,"_44":254,"_46":255},"t_027_private_vs_public_table","Private Vs Public Table","Write a SpacetimeDB backend module in TypeScript that defines a private table for sensitive data and a public table for client-visible data, with a reducer that copies safe fields from private to public.\n\nTABLES\n- user_internal\n - private table (do not set public: true)\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - name: string\n - email: string\n - passwordHash: string\n\n- user_public\n - public table (set public: true)\n - Fields:\n - id: bigint (u64, primary key)\n - name: string\n\nREDUCERS\n- register_user(ctx, { name: string, email: string, passwordHash: string })\n - Insert into user_internal\n - Also insert into user_public with just the id and name (safe fields only)","import { schema, table, t } from 'spacetimedb/server';\n\nconst user_internal = table({\n name: 'user_internal',\n}, {\n id: t.u64().primaryKey().autoInc(),\n name: t.string(),\n email: t.string(),\n passwordHash: t.string(),\n});\n\nconst user_public = table({\n name: 'user_public',\n public: true,\n}, {\n id: t.u64().primaryKey(),\n name: t.string(),\n});\n\nconst spacetimedb = schema({ user_internal, user_public });\nexport default spacetimedb;\n\nexport const register_user = spacetimedb.reducer(\n { name: t.string(), email: t.string(), passwordHash: t.string() },\n (ctx, { name, email, passwordHash }) => {\n const internal = ctx.db.user_internal.insert({\n id: 0n,\n name,\n email,\n passwordHash,\n });\n ctx.db.user_public.insert({\n id: internal.id,\n name,\n });\n }\n);\n",{"_39":257,"_41":244,"_42":258,"_44":259,"_46":260},"t_041_registered_user_gate","Registered User Gate","Write a SpacetimeDB backend module in TypeScript that gates actions behind a registration check.\n\nTABLES\n- user\n - private table\n - Fields:\n - identity: Identity (primary key)\n - name: string\n\n- message\n - public table\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - sender: Identity (index btree)\n - text: string\n\nREDUCERS\n- register(ctx, { name: string })\n - If a user row already exists for the caller's identity, fail with \"already registered\"\n - Otherwise insert a new user with identity = the caller's identity and the given name\n\n- post_message(ctx, { text: string })\n - If no user row exists for the caller's identity, fail with \"not registered\"\n - Otherwise insert a message with sender = the caller's identity and the given text","import { schema, table, t } from 'spacetimedb/server';\n\nconst user = table({\n name: 'user',\n}, {\n identity: t.identity().primaryKey(),\n name: t.string(),\n});\n\nconst message = table({\n name: 'message',\n public: true,\n}, {\n id: t.u64().primaryKey().autoInc(),\n sender: t.identity().index('btree'),\n text: t.string(),\n});\n\nconst spacetimedb = schema({ user, message });\nexport default spacetimedb;\n\nexport const register = spacetimedb.reducer(\n { name: t.string() },\n (ctx, { name }) => {\n if (ctx.db.user.identity.find(ctx.sender)) {\n throw new Error('already registered');\n }\n ctx.db.user.insert({ identity: ctx.sender, name });\n }\n);\n\nexport const post_message = spacetimedb.reducer(\n { text: t.string() },\n (ctx, { text }) => {\n if (!ctx.db.user.identity.find(ctx.sender)) {\n throw new Error('not registered');\n }\n ctx.db.message.insert({ id: 0n, sender: ctx.sender, text });\n }\n);\n",{"_39":262,"_41":244,"_42":263,"_44":264,"_46":265},"t_042_admin_bootstrap","Admin Bootstrap","Write a SpacetimeDB backend module in TypeScript that implements a one-time admin bootstrap pattern.\n\nTABLES\n- config\n - private table\n - Fields:\n - id: number (u32, primary key)\n - admin: Identity\n\n- admin_log\n - public table\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - action: string\n\nREDUCERS\n- bootstrap_admin(ctx)\n - If a config row already exists (id = 0), fail with \"already bootstrapped\"\n - Otherwise insert config { id: 0, admin: the caller's identity }\n\n- admin_action(ctx, { action: string })\n - Load the config row with id = 0; if missing, fail with \"not bootstrapped\"\n - If the caller's identity does not equal config.admin, fail with \"not admin\"\n - Insert an admin_log row with the given action","import { schema, table, t } from 'spacetimedb/server';\n\nconst config = table({\n name: 'config',\n}, {\n id: t.u32().primaryKey(),\n admin: t.identity(),\n});\n\nconst admin_log = table({\n name: 'admin_log',\n public: true,\n}, {\n id: t.u64().primaryKey().autoInc(),\n action: t.string(),\n});\n\nconst spacetimedb = schema({ config, admin_log });\nexport default spacetimedb;\n\nexport const bootstrap_admin = spacetimedb.reducer(\n {},\n (ctx) => {\n if (ctx.db.config.id.find(0)) {\n throw new Error('already bootstrapped');\n }\n ctx.db.config.insert({ id: 0, admin: ctx.sender });\n }\n);\n\nexport const admin_action = spacetimedb.reducer(\n { action: t.string() },\n (ctx, { action }) => {\n const config = ctx.db.config.id.find(0);\n if (!config) throw new Error('not bootstrapped');\n if (!config.admin.equals(ctx.sender)) throw new Error('not admin');\n ctx.db.admin_log.insert({ id: 0n, action });\n }\n);\n",{"_39":267,"_41":244,"_42":268,"_44":269,"_46":270},"t_043_role_based_access","Role Based Access","Write a SpacetimeDB backend module in TypeScript that implements role-based access control.\n\nTABLES\n- user\n - private table\n - Fields:\n - identity: Identity (primary key)\n - role: string (\"admin\" or \"member\")\n\nREDUCERS\n- register(ctx)\n - If a user row already exists for the caller's identity, fail with \"already registered\"\n - Insert user { identity: the caller's identity, role: \"member\" }\n\n- promote(ctx, { target: Identity })\n - Load the user row for the caller's identity; if missing, fail with \"not registered\"\n - If the caller's role is not \"admin\", fail with \"not admin\"\n - Load the user row for target; if missing, fail with \"target not registered\"\n - Update that row's role to \"admin\"\n\n- member_action(ctx)\n - Load the user row for the caller's identity; if missing, fail with \"not registered\"\n\n- admin_action(ctx)\n - Load the user row for the caller's identity; if missing, fail with \"not registered\"\n - If the role is not \"admin\", fail with \"not admin\"","import { schema, table, t } from 'spacetimedb/server';\n\nconst user = table({\n name: 'user',\n}, {\n identity: t.identity().primaryKey(),\n role: t.string(),\n});\n\nconst spacetimedb = schema({ user });\nexport default spacetimedb;\n\nexport const register = spacetimedb.reducer(\n {},\n (ctx) => {\n if (ctx.db.user.identity.find(ctx.sender)) {\n throw new Error('already registered');\n }\n ctx.db.user.insert({ identity: ctx.sender, role: 'member' });\n }\n);\n\nexport const promote = spacetimedb.reducer(\n { target: t.identity() },\n (ctx, { target }) => {\n const caller = ctx.db.user.identity.find(ctx.sender);\n if (!caller) throw new Error('not registered');\n if (caller.role !== 'admin') throw new Error('not admin');\n const targetUser = ctx.db.user.identity.find(target);\n if (!targetUser) throw new Error('target not registered');\n ctx.db.user.identity.update({ ...targetUser, role: 'admin' });\n }\n);\n\nexport const member_action = spacetimedb.reducer(\n {},\n (ctx) => {\n if (!ctx.db.user.identity.find(ctx.sender)) throw new Error('not registered');\n }\n);\n\nexport const admin_action = spacetimedb.reducer(\n {},\n (ctx) => {\n const user = ctx.db.user.identity.find(ctx.sender);\n if (!user) throw new Error('not registered');\n if (user.role !== 'admin') throw new Error('not admin');\n }\n);\n",{"_39":272,"_41":244,"_42":273,"_44":274,"_46":275},"t_044_ban_list","Ban List","Write a SpacetimeDB backend module in TypeScript that implements a ban list enforced on game entry.\n\nTABLES\n- admin\n - private table\n - Fields:\n - identity: Identity (primary key)\n\n- banned\n - private table\n - Fields:\n - identity: Identity (primary key)\n\n- player\n - public table\n - Fields:\n - identity: Identity (primary key)\n - name: string\n\nREDUCERS\n- add_admin(ctx, { target: Identity })\n - If the caller's identity is not in the admin table, fail with \"not admin\"\n - Insert { identity: target } into admin (ignore if already present)\n\n- ban_player(ctx, { target: Identity })\n - If the caller's identity is not in the admin table, fail with \"not admin\"\n - Insert { identity: target } into banned\n - Remove the player row for target if one exists\n\n- join_game(ctx, { name: string })\n - If the caller's identity is in the banned table, fail with \"banned\"\n - If a player row already exists for the caller's identity, fail with \"already in game\"\n - Insert player { identity: the caller's identity, name }","import { schema, table, t } from 'spacetimedb/server';\n\nconst admin = table({\n name: 'admin',\n}, {\n identity: t.identity().primaryKey(),\n});\n\nconst banned = table({\n name: 'banned',\n}, {\n identity: t.identity().primaryKey(),\n});\n\nconst player = table({\n name: 'player',\n public: true,\n}, {\n identity: t.identity().primaryKey(),\n name: t.string(),\n});\n\nconst spacetimedb = schema({ admin, banned, player });\nexport default spacetimedb;\n\nexport const add_admin = spacetimedb.reducer(\n { target: t.identity() },\n (ctx, { target }) => {\n if (!ctx.db.admin.identity.find(ctx.sender)) throw new Error('not admin');\n try { ctx.db.admin.insert({ identity: target }); } catch {}\n }\n);\n\nexport const ban_player = spacetimedb.reducer(\n { target: t.identity() },\n (ctx, { target }) => {\n if (!ctx.db.admin.identity.find(ctx.sender)) throw new Error('not admin');\n ctx.db.banned.insert({ identity: target });\n if (ctx.db.player.identity.find(target)) {\n ctx.db.player.identity.delete(target);\n }\n }\n);\n\nexport const join_game = spacetimedb.reducer(\n { name: t.string() },\n (ctx, { name }) => {\n if (ctx.db.banned.identity.find(ctx.sender)) throw new Error('banned');\n if (ctx.db.player.identity.find(ctx.sender)) throw new Error('already in game');\n ctx.db.player.insert({ identity: ctx.sender, name });\n }\n);\n",{"_39":277,"_41":244,"_42":278,"_44":279,"_46":280},"t_045_rate_limit","Rate Limit","Write a SpacetimeDB backend module in TypeScript that enforces per-identity rate limiting.\n\nTABLES\n- rate_limit\n - private table\n - Fields:\n - identity: Identity (primary key)\n - last_call_us: bigint (u64, microsecond timestamp of the last allowed call)\n\n- action_log\n - public table\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - identity: Identity\n - payload: string\n\nREDUCERS\n- limited_action(ctx, { payload: string })\n - Get the current time in microseconds\n - Look up the rate_limit row for the caller's identity\n - If a row exists and (now - last_call_us) < 1_000_000n, fail with \"rate limited\"\n - Insert or update the rate_limit row with last_call_us = now\n - Insert an action_log row with identity = the caller's identity and the given payload","import { schema, table, t } from 'spacetimedb/server';\n\nconst rate_limit = table({\n name: 'rate_limit',\n}, {\n identity: t.identity().primaryKey(),\n last_call_us: t.u64(),\n});\n\nconst action_log = table({\n name: 'action_log',\n public: true,\n}, {\n id: t.u64().primaryKey().autoInc(),\n identity: t.identity(),\n payload: t.string(),\n});\n\nconst spacetimedb = schema({ rate_limit, action_log });\nexport default spacetimedb;\n\nexport const limited_action = spacetimedb.reducer(\n { payload: t.string() },\n (ctx, { payload }) => {\n const now = BigInt(ctx.timestamp.microsSinceUnixEpoch);\n const entry = ctx.db.rate_limit.identity.find(ctx.sender);\n if (entry) {\n if (now - entry.last_call_us < 1_000_000n) throw new Error('rate limited');\n ctx.db.rate_limit.identity.update({ ...entry, last_call_us: now });\n } else {\n ctx.db.rate_limit.insert({ identity: ctx.sender, last_call_us: now });\n }\n ctx.db.action_log.insert({ id: 0n, identity: ctx.sender, payload });\n }\n);\n",{"_39":282,"_41":244,"_42":283,"_44":284,"_46":285},"t_046_shared_document","Shared Document","Write a SpacetimeDB backend module in TypeScript that implements document ownership and explicit sharing.\n\nTABLES\n- document\n - public table\n - Fields:\n - id: bigint (u64, primary key, autoInc)\n - owner: Identity (index btree)\n - title: string\n\n- document_share\n - public table\n - Fields:\n - document_id: bigint (u64, index btree)\n - shared_with: Identity (index btree)\n\nREDUCERS\n- create_document(ctx, { title: string })\n - Insert a document with owner = the caller's identity and the given title\n\n- share_document(ctx, { document_id: bigint (u64), target: Identity })\n - Load the document by id; if missing, fail with \"not found\"\n - If document.owner != the caller's identity, fail with \"not owner\"\n - Insert a document_share { document_id, shared_with: target }\n\n- edit_document(ctx, { document_id: bigint (u64), new_title: string })\n - Load the document by id; if missing, fail with \"not found\"\n - The caller is authorized if they are the owner OR if a document_share row exists\n with matching document_id and shared_with == the caller's identity\n - If neither condition is true, fail with \"unauthorized\"\n - Update the document's title to new_title","import { schema, table, t } from 'spacetimedb/server';\n\nconst document = table({\n name: 'document',\n public: true,\n}, {\n id: t.u64().primaryKey().autoInc(),\n owner: t.identity().index('btree'),\n title: t.string(),\n});\n\nconst document_share = table({\n name: 'document_share',\n public: true,\n}, {\n document_id: t.u64().index('btree'),\n shared_with: t.identity().index('btree'),\n});\n\nconst spacetimedb = schema({ document, document_share });\nexport default spacetimedb;\n\nexport const create_document = spacetimedb.reducer(\n { title: t.string() },\n (ctx, { title }) => {\n ctx.db.document.insert({ id: 0n, owner: ctx.sender, title });\n }\n);\n\nexport const share_document = spacetimedb.reducer(\n { document_id: t.u64(), target: t.identity() },\n (ctx, { document_id, target }) => {\n const doc = ctx.db.document.id.find(document_id);\n if (!doc) throw new Error('not found');\n if (!doc.owner.equals(ctx.sender)) throw new Error('not owner');\n ctx.db.document_share.insert({ document_id, shared_with: target });\n }\n);\n\nexport const edit_document = spacetimedb.reducer(\n { document_id: t.u64(), new_title: t.string() },\n (ctx, { document_id, new_title }) => {\n const doc = ctx.db.document.id.find(document_id);\n if (!doc) throw new Error('not found');\n const isOwner = doc.owner.equals(ctx.sender);\n const isShared = [...ctx.db.document_share.document_id.filter(document_id)]\n .some(s => s.shared_with.equals(ctx.sender));\n if (!isOwner && !isShared) throw new Error('unauthorized');\n ctx.db.document.id.update({ ...doc, title: new_title });\n }\n);\n",{"_39":287,"_41":244,"_42":288,"_44":289,"_46":290},"t_068_secure_projection","Secure Projection","Write a SpacetimeDB backend module in TypeScript that exposes a safe per-user projection of private rows.\n\nTYPES\n- SafeNote\n - id: u64\n - title: string\n\nTABLE\n- secret_note (private)\n - Fields:\n - id: u64 (primary key)\n - owner: Identity (btree index)\n - title: string\n - secretBody: string\n\nREDUCERS\n- seed_private_note()\n - Insert id 1 for the caller\n - Set title to \"Visible title\"\n - Set secretBody to \"never expose this\"\n\nVIEW\n- my_safe_note (per-user, public)\n - Return an array of SafeNote for only the caller\n - Never expose owner or secretBody","import { schema, table, t } from 'spacetimedb/server';\n\nconst secretNote = table({ name: 'secret_note' }, {\n id: t.u64().primaryKey(),\n owner: t.identity().index('btree'),\n title: t.string(),\n secretBody: t.string(),\n});\nconst SafeNote = t.row('SafeNoteRow', { id: t.u64(), title: t.string() });\nconst spacetimedb = schema({ secretNote });\nexport default spacetimedb;\n\nexport const seed_private_note = spacetimedb.reducer(ctx => {\n ctx.db.secretNote.insert({ id: 1n, owner: ctx.sender, title: 'Visible title', secretBody: 'never expose this' });\n});\n\nexport const my_safe_note = spacetimedb.view(\n { name: 'my_safe_note', public: true }, t.array(SafeNote),\n ctx => Array.from(ctx.db.secretNote.owner.filter(ctx.sender)).map(note => ({ id: note.id, title: note.title }))\n);\n","tables",[293,298,303,308,313,318,323,328],{"_39":294,"_41":291,"_42":295,"_44":296,"_46":297},"t_047_normalized_collection","Normalized Collection","Write a SpacetimeDB backend module in TypeScript that models an unbounded child collection with normalized tables.\n\nTABLES\n- collection_owner (public)\n - id: u64 (primary key, auto increment)\n - name: string\n- child_item (public)\n - id: u64 (primary key, auto increment)\n - ownerId: u64\n - value: string\n - index byOwner: btree(ownerId)\n\nDo not store child items in an array on collection_owner. No reducers are required.","import { schema, table, t } from 'spacetimedb/server';\n\nconst collectionOwner = table(\n { name: 'collection_owner', public: true },\n {\n id: t.u64().primaryKey().autoInc(),\n name: t.string(),\n }\n);\n\nconst childItem = table(\n {\n name: 'child_item',\n public: true,\n indexes: [{ accessor: 'byOwner', algorithm: 'btree', columns: ['ownerId'] }],\n },\n {\n id: t.u64().primaryKey().autoInc(),\n ownerId: t.u64(),\n value: t.string(),\n }\n);\n\nexport default schema({ collectionOwner, childItem });\n",{"_39":299,"_41":291,"_42":300,"_44":301,"_46":302},"t_048_heartbeat_isolation","Heartbeat Isolation","Write a SpacetimeDB backend module in TypeScript that separates stable profile data from frequently updated connection presence.\n\nTABLES\n- user_profile (public)\n - identity: Identity (primary key)\n - displayName: string\n - createdAt: Timestamp\n- connection_presence (public)\n - connectionId: ConnectionId (primary key)\n - userIdentity: Identity\n - lastHeartbeat: Timestamp\n - online: boolean\n - index byUser: btree(userIdentity)\n\nDo not put lastHeartbeat or online on user_profile. No reducers are required.","import { schema, table, t } from 'spacetimedb/server';\n\nconst userProfile = table(\n { name: 'user_profile', public: true },\n {\n identity: t.identity().primaryKey(),\n displayName: t.string(),\n createdAt: t.timestamp(),\n }\n);\n\nconst connectionPresence = table(\n {\n name: 'connection_presence',\n public: true,\n indexes: [{ accessor: 'byUser', algorithm: 'btree', columns: ['userIdentity'] }],\n },\n {\n connectionId: t.connectionId().primaryKey(),\n userIdentity: t.identity(),\n lastHeartbeat: t.timestamp(),\n online: t.bool(),\n }\n);\n\nexport default schema({ userProfile, connectionPresence });\n",{"_39":304,"_41":291,"_42":305,"_44":306,"_46":307},"t_049_binary_storage","Binary Storage","Write a SpacetimeDB backend module in TypeScript that stores binary content and its metadata.\n\nTABLE\n- blob_record (public)\n - Fields:\n - id: u64 (primary key, auto-increment)\n - owner: Identity (btree index byOwner)\n - filename: string\n - mimeType: string\n - size: u64\n - data: u8 array\n\nREDUCERS\n- store_blob(filename: string, mimeType: string, data: u8 array)\n - Store the caller's identity as owner\n - Derive size from the byte length\n - Insert the bytes unchanged","import { schema, table, t } from 'spacetimedb/server';\n\nconst blobRecord = table(\n {\n name: 'blob_record',\n public: true,\n indexes: [{ accessor: 'byOwner', algorithm: 'btree', columns: ['owner'] }],\n },\n {\n id: t.u64().primaryKey().autoInc(),\n owner: t.identity(),\n filename: t.string(),\n mimeType: t.string(),\n size: t.u64(),\n data: t.array(t.u8()),\n }\n);\n\nconst spacetimedb = schema({ blobRecord });\nexport default spacetimedb;\n\nexport const store_blob = spacetimedb.reducer(\n { filename: t.string(), mimeType: t.string(), data: t.array(t.u8()) },\n (ctx, { filename, mimeType, data }) => {\n ctx.db.blobRecord.insert({\n id: 0n,\n owner: ctx.sender,\n filename,\n mimeType,\n size: BigInt(data.length),\n data,\n });\n }\n);\n",{"_39":309,"_41":291,"_42":310,"_44":311,"_46":312},"t_050_normalized_schema","Normalized Schema","Write a SpacetimeDB backend module in TypeScript that normalizes organization data into three related tables.\n\nTABLES\n- organization (public)\n - id: u64 (primary key, auto increment)\n - name: string\n- department (public)\n - id: u64 (primary key, auto increment)\n - organizationId: u64\n - name: string\n - index byOrganization: btree(organizationId)\n- employee (public)\n - id: u64 (primary key, auto increment)\n - departmentId: u64\n - name: string\n - index byDepartment: btree(departmentId)\n\nDo not use nested arrays. No reducers are required.","import { schema, table, t } from 'spacetimedb/server';\n\nconst organization = table(\n { name: 'organization', public: true },\n { id: t.u64().primaryKey().autoInc(), name: t.string() }\n);\n\nconst department = table(\n {\n name: 'department',\n public: true,\n indexes: [{ accessor: 'byOrganization', algorithm: 'btree', columns: ['organizationId'] }],\n },\n {\n id: t.u64().primaryKey().autoInc(),\n organizationId: t.u64(),\n name: t.string(),\n }\n);\n\nconst employee = table(\n {\n name: 'employee',\n public: true,\n indexes: [{ accessor: 'byDepartment', algorithm: 'btree', columns: ['departmentId'] }],\n },\n {\n id: t.u64().primaryKey().autoInc(),\n departmentId: t.u64(),\n name: t.string(),\n }\n);\n\nexport default schema({ organization, department, employee });\n",{"_39":314,"_41":291,"_42":315,"_44":316,"_46":317},"t_051_denormalized_index","Denormalized Index","Write a SpacetimeDB backend module in TypeScript that maintains an indexed denormalized category slug on products.\n\nTABLES\n- category (public)\n - Fields:\n - id: u64 (primary key)\n - slug: string\n- product (public)\n - Fields:\n - id: u64 (primary key)\n - categoryId: u64 (btree index byCategory)\n - categorySlug: string (btree index byCategorySlug)\n - name: string\n\nREDUCERS\n- create_category(id: u64, slug: string)\n- create_product(id: u64, categoryId: u64, name: string)\n - Copy the current category slug into categorySlug\n- rename_category(id: u64, newSlug: string)\n - Update the category slug\n - Update every related product so categorySlug stays synchronized","import { schema, table, t } from 'spacetimedb/server';\n\nconst category = table(\n { name: 'category', public: true },\n { id: t.u64().primaryKey(), slug: t.string() }\n);\n\nconst product = table(\n {\n name: 'product',\n public: true,\n indexes: [\n { accessor: 'byCategory', algorithm: 'btree', columns: ['categoryId'] },\n { accessor: 'byCategorySlug', algorithm: 'btree', columns: ['categorySlug'] },\n ],\n },\n {\n id: t.u64().primaryKey(),\n categoryId: t.u64(),\n categorySlug: t.string(),\n name: t.string(),\n }\n);\n\nconst spacetimedb = schema({ category, product });\nexport default spacetimedb;\n\nexport const create_category = spacetimedb.reducer(\n { id: t.u64(), slug: t.string() },\n (ctx, { id, slug }) => ctx.db.category.insert({ id, slug })\n);\n\nexport const create_product = spacetimedb.reducer(\n { id: t.u64(), categoryId: t.u64(), name: t.string() },\n (ctx, { id, categoryId, name }) => {\n const found = ctx.db.category.id.find(categoryId);\n if (!found) throw new Error('category not found');\n ctx.db.product.insert({ id, categoryId, categorySlug: found.slug, name });\n }\n);\n\nexport const rename_category = spacetimedb.reducer(\n { id: t.u64(), newSlug: t.string() },\n (ctx, { id, newSlug }) => {\n const found = ctx.db.category.id.find(id);\n if (!found) throw new Error('category not found');\n ctx.db.category.id.update({ ...found, slug: newSlug });\n for (const existing of ctx.db.product.byCategory.filter(id)) {\n ctx.db.product.id.update({ ...existing, categorySlug: newSlug });\n }\n }\n);\n",{"_39":319,"_41":291,"_42":320,"_44":321,"_46":322},"t_052_autoinc_reference","Autoinc Reference","Write a SpacetimeDB backend module in TypeScript that safely creates related rows with an auto-incremented parent ID.\n\nTABLES\n- parent (public)\n - Fields:\n - id: u64 (primary key, auto-increment)\n - name: string\n- child (public)\n - Fields:\n - id: u64 (primary key, auto-increment)\n - parentId: u64 (btree index byParent)\n - name: string\n\nREDUCERS\n- create_family(parentName: string, childNames: string array)\n - Insert the parent, then insert every child using the ID actually assigned to that parent","import { schema, table, t } from 'spacetimedb/server';\n\nconst parent = table(\n { name: 'parent', public: true },\n { id: t.u64().primaryKey().autoInc(), name: t.string() }\n);\n\nconst child = table(\n {\n name: 'child',\n public: true,\n indexes: [{ accessor: 'byParent', algorithm: 'btree', columns: ['parentId'] }],\n },\n { id: t.u64().primaryKey().autoInc(), parentId: t.u64(), name: t.string() }\n);\n\nconst spacetimedb = schema({ parent, child });\nexport default spacetimedb;\n\nexport const create_family = spacetimedb.reducer(\n { parentName: t.string(), childNames: t.array(t.string()) },\n (ctx, { parentName, childNames }) => {\n const insertedParent = ctx.db.parent.insert({ id: 0n, name: parentName });\n for (const name of childNames) {\n ctx.db.child.insert({ id: 0n, parentId: insertedParent.id, name });\n }\n }\n);\n",{"_39":324,"_41":291,"_42":325,"_44":326,"_46":327},"t_053_default_values","Default Values","Update the existing SpacetimeDB backend module in TypeScript to add a migration-safe default value.\n\nTABLE\n- widget (public)\n - Preserve the existing table and fields\n - Keep id: u64 as the primary key\n - Add enabled: bool as the trailing field\n - Give enabled a default value of true\n\nREDUCERS\n- Preserve seed and touch without renaming them\n- Update new widget values to set enabled to true\n\nMIGRATION\n- A compatible republish must backfill existing rows","import { schema, table, t } from 'spacetimedb/server';\n\nconst widget = table(\n { name: 'widget', public: true },\n { id: t.u64().primaryKey(), name: t.string(), enabled: t.bool().default(true) }\n);\n\nconst spacetimedb = schema({ widget });\nexport default spacetimedb;\n\nexport const seed = spacetimedb.reducer(ctx => {\n ctx.db.widget.insert({ id: 1n, name: 'legacy', enabled: true });\n});\n\nexport const touch = spacetimedb.reducer(_ctx => {});\n",{"_39":329,"_41":291,"_42":330,"_44":331,"_46":332},"t_054_special_types","Special Types","Write a SpacetimeDB backend module in TypeScript defining one public table with special value types.\n\nTABLE\n- special_value (public)\n - Fields:\n - id: u64 (primary key)\n - uuid: Uuid\n - connectionId: ConnectionId\n - duration: TimeDuration\n - unsigned128: u128\n - signed128: i128\n - unsigned256: u256\n - signed256: i256\n\nNo reducers are required.","import { schema, table, t } from 'spacetimedb/server';\n\nconst specialValue = table(\n { name: 'special_value', public: true },\n {\n id: t.u64().primaryKey(),\n uuid: t.uuid(),\n connectionId: t.connectionId(),\n duration: t.timeDuration(),\n unsigned128: t.u128(),\n signed128: t.i128(),\n unsigned256: t.u256(),\n signed256: t.i256(),\n }\n);\n\nexport default schema({ specialValue });\n","reducers",[335,340,345,350,355,360,365],{"_39":336,"_41":333,"_42":337,"_44":338,"_46":339},"t_055_atomic_idempotent_transfer","Atomic Idempotent Transfer","Write a SpacetimeDB backend module in TypeScript that performs atomic, idempotent transfers between accounts.\n\nTABLES\n- account (public)\n - Fields:\n - id: u64 (primary key)\n - balance: i64\n- transfer_request (public)\n - Fields:\n - requestId: string (primary key)\n - fromId: u64\n - toId: u64\n - amount: i64\n\nREDUCERS\n- create_account(id: u64, balance: i64)\n - Insert an account with the supplied values\n- transfer(requestId: string, fromId: u64, toId: u64, amount: i64)\n - Fail with an error if amount is not positive, fromId equals toId, either account does not exist, or the source balance is below amount\n - Update both account balances atomically\n - Record requestId in transfer_request\n - If requestId is already recorded, make no changes","import { schema, table, t, SenderError } from 'spacetimedb/server';\n\nconst account = table(\n { name: 'account', public: true },\n { id: t.u64().primaryKey(), balance: t.i64() }\n);\nconst transferRequest = table(\n { name: 'transfer_request', public: true },\n {\n requestId: t.string().primaryKey(),\n fromId: t.u64(),\n toId: t.u64(),\n amount: t.i64(),\n }\n);\nconst spacetimedb = schema({ account, transferRequest });\nexport default spacetimedb;\n\nexport const create_account = spacetimedb.reducer(\n { id: t.u64(), balance: t.i64() },\n (ctx, { id, balance }) => ctx.db.account.insert({ id, balance })\n);\n\nexport const transfer = spacetimedb.reducer(\n { requestId: t.string(), fromId: t.u64(), toId: t.u64(), amount: t.i64() },\n (ctx, { requestId, fromId, toId, amount }) => {\n if (ctx.db.transferRequest.requestId.find(requestId)) return;\n if (amount <= 0n || fromId === toId)\n throw new SenderError('invalid transfer');\n const from = ctx.db.account.id.find(fromId);\n const to = ctx.db.account.id.find(toId);\n if (!from || !to) throw new SenderError('account not found');\n if (from.balance < amount) throw new SenderError('insufficient balance');\n ctx.db.account.id.update({ ...from, balance: from.balance - amount });\n ctx.db.account.id.update({ ...to, balance: to.balance + amount });\n ctx.db.transferRequest.insert({ requestId, fromId, toId, amount });\n }\n);\n",{"_39":341,"_41":333,"_42":342,"_44":343,"_46":344},"t_056_nested_update","Nested Update","Write a SpacetimeDB backend module in TypeScript that stores and updates nested profile preferences.\n\nTYPES\n- Preferences\n - theme: string\n - emailNotifications: boolean\n - timezone: string\n\nTABLE\n- profile (public)\n - Fields:\n - id: u64 (primary key)\n - preferences: Preferences\n\nREDUCERS\n- create_profile(id: u64, theme: string, emailNotifications: boolean, timezone: string)\n - Insert a profile with all three preference fields\n- update_theme(id: u64, theme: string)\n - Change only preferences.theme\n - Preserve preferences.emailNotifications and preferences.timezone","import { schema, table, t } from 'spacetimedb/server';\n\nconst Preferences = t.object('Preferences', {\n theme: t.string(),\n emailNotifications: t.bool(),\n timezone: t.string(),\n});\nconst profile = table(\n { name: 'profile', public: true },\n { id: t.u64().primaryKey(), preferences: Preferences }\n);\nconst spacetimedb = schema({ profile });\nexport default spacetimedb;\n\nexport const create_profile = spacetimedb.reducer(\n { id: t.u64(), theme: t.string(), emailNotifications: t.bool(), timezone: t.string() },\n (ctx, args) => ctx.db.profile.insert({ id: args.id, preferences: {\n theme: args.theme, emailNotifications: args.emailNotifications, timezone: args.timezone,\n } })\n);\n\nexport const update_theme = spacetimedb.reducer(\n { id: t.u64(), theme: t.string() },\n (ctx, { id, theme }) => {\n const found = ctx.db.profile.id.find(id);\n if (!found) throw new Error('profile not found');\n ctx.db.profile.id.update({\n ...found,\n preferences: { ...found.preferences, theme },\n });\n }\n);\n",{"_39":346,"_41":333,"_42":347,"_44":348,"_46":349},"t_057_nested_cascade_delete","Nested Cascade Delete","Write a SpacetimeDB backend module in TypeScript that performs a nested cascade delete across normalized tables.\n\nTABLES\n- workspace (public)\n - Fields:\n - id: u64 (primary key)\n- project (public)\n - Fields:\n - id: u64 (primary key)\n - workspaceId: u64 (btree index)\n- task_item (public)\n - Fields:\n - id: u64 (primary key)\n - projectId: u64 (btree index)\n- task_note (public)\n - Fields:\n - id: u64 (primary key)\n - taskId: u64 (btree index)\n\nREDUCERS\n- seed()\n - Create two independent workspace -> project -> task_item -> task_note chains using IDs 1 and 2\n- delete_workspace(id: u64)\n - Delete the selected workspace and every level of its descendants\n - Preserve the unrelated chain","import { schema, table, t } from 'spacetimedb/server';\n\nconst workspace = table({ name: 'workspace', public: true }, { id: t.u64().primaryKey() });\nconst project = table({ name: 'project', public: true }, { id: t.u64().primaryKey(), workspaceId: t.u64().index('btree') });\nconst taskItem = table({ name: 'task_item', public: true }, { id: t.u64().primaryKey(), projectId: t.u64().index('btree') });\nconst taskNote = table({ name: 'task_note', public: true }, { id: t.u64().primaryKey(), taskId: t.u64().index('btree') });\nconst spacetimedb = schema({ workspace, project, taskItem, taskNote });\nexport default spacetimedb;\n\nexport const seed = spacetimedb.reducer(ctx => {\n for (const id of [1n, 2n]) {\n ctx.db.workspace.insert({ id });\n ctx.db.project.insert({ id, workspaceId: id });\n ctx.db.taskItem.insert({ id, projectId: id });\n ctx.db.taskNote.insert({ id, taskId: id });\n }\n});\n\nexport const delete_workspace = spacetimedb.reducer({ id: t.u64() }, (ctx, { id }) => {\n for (const project of [...ctx.db.project.workspaceId.filter(id)]) {\n for (const task of [...ctx.db.taskItem.projectId.filter(project.id)]) {\n for (const note of [...ctx.db.taskNote.taskId.filter(task.id)]) ctx.db.taskNote.id.delete(note.id);\n ctx.db.taskItem.id.delete(task.id);\n }\n ctx.db.project.id.delete(project.id);\n }\n ctx.db.workspace.id.delete(id);\n});\n",{"_39":351,"_41":333,"_42":352,"_44":353,"_46":354},"t_058_batched_delete","Batched Delete","Write a SpacetimeDB backend module in TypeScript that deletes a logical group in scheduled batches of at most two rows.\n\nTABLES\n- work_item (public)\n - Fields:\n - id: u64 (primary key)\n - groupId: u64 (btree index)\n- delete_job (private, scheduled for runDeleteBatch)\n - Fields:\n - scheduledId: u64 (primary key, auto-increment)\n - scheduledAt: ScheduleAt\n - groupId: u64\n\nREDUCERS\n- seed_group(groupId: u64, count: u32)\n - Assign deterministic unique id values to the inserted rows\n- request_delete(groupId: u64)\n- runDeleteBatch(timer: delete_job row) (scheduled reducer)\n - Delete at most two work_item rows matching the scheduled groupId\n - If matching rows remain, enqueue another one-shot delete_job","import { ScheduleAt } from 'spacetimedb';\nimport { schema, table, t } from 'spacetimedb/server';\nimport type { InferSchema, ReducerCtx } from 'spacetimedb/server';\n\nconst workItem = table(\n { name: 'work_item', public: true },\n { id: t.u64().primaryKey(), groupId: t.u64().index('btree') }\n);\nconst deleteJob = table(\n { name: 'delete_job', scheduled: (): any => runDeleteBatch },\n { scheduledId: t.u64().primaryKey().autoInc(), scheduledAt: t.scheduleAt(), groupId: t.u64() }\n);\nconst spacetimedb = schema({ workItem, deleteJob });\nexport default spacetimedb;\ntype Ctx = ReducerCtx>;\n\nfunction enqueue(ctx: Ctx, groupId: bigint) {\n ctx.db.deleteJob.insert({\n scheduledId: 0n,\n scheduledAt: ScheduleAt.time(ctx.timestamp.microsSinceUnixEpoch + 1_000n),\n groupId,\n });\n}\n\nexport const seed_group = spacetimedb.reducer({ groupId: t.u64(), count: t.u32() }, (ctx, { groupId, count }) => {\n for (let offset = 0; offset < count; offset++) ctx.db.workItem.insert({ id: groupId * 100n + BigInt(offset), groupId });\n});\nexport const request_delete = spacetimedb.reducer({ groupId: t.u64() }, (ctx, { groupId }) => enqueue(ctx, groupId));\nexport const runDeleteBatch = spacetimedb.reducer({ timer: deleteJob.rowType }, (ctx, { timer }) => {\n let deleted = 0;\n for (const row of ctx.db.workItem.groupId.filter(timer.groupId)) {\n if (deleted === 2) break;\n ctx.db.workItem.id.delete(row.id);\n deleted++;\n }\n if (ctx.db.workItem.groupId.filter(timer.groupId)[Symbol.iterator]().next().done === false) enqueue(ctx, timer.groupId);\n});\n",{"_39":356,"_41":333,"_42":357,"_44":358,"_46":359},"t_059_deterministic_context","Deterministic Context","Write a SpacetimeDB backend module in TypeScript that records deterministic reducer time and randomness.\n\nTABLE\n- generated_value (public)\n - Fields:\n - id: u64 (primary key, auto-increment)\n - createdAt: Timestamp\n - randomValue: i64\n\nREDUCERS\n- generate()\n - Store the reducer context timestamp in createdAt\n - Store a random integer from the reducer context RNG in randomValue\n - Do not use Date, Math.random, or a separately seeded RNG","import { schema, table, t } from 'spacetimedb/server';\n\nconst generatedValue = table(\n { name: 'generated_value', public: true },\n { id: t.u64().primaryKey().autoInc(), createdAt: t.timestamp(), randomValue: t.i64() }\n);\nconst spacetimedb = schema({ generatedValue });\nexport default spacetimedb;\n\nexport const generate = spacetimedb.reducer(ctx => {\n ctx.db.generatedValue.insert({\n id: 0n,\n createdAt: ctx.timestamp,\n randomValue: BigInt(ctx.random.integerInRange(1, Number.MAX_SAFE_INTEGER)),\n });\n});\n",{"_39":361,"_41":333,"_42":362,"_44":363,"_46":364},"t_060_reducer_result_table","Reducer Result Table","Write a SpacetimeDB backend module in TypeScript that writes reducer results to a table.\n\nTABLE\n- command_result (public)\n - Fields:\n - requestId: string (primary key)\n - success: boolean\n - message: string\n\nREDUCERS\n- run_command(requestId: string, value: i32)\n - Reducers do not return application data\n - Insert a command_result row with success set to true\n - Set message to \"value=\" using the supplied value","import { schema, table, t } from 'spacetimedb/server';\n\nconst commandResult = table(\n { name: 'command_result', public: true },\n { requestId: t.string().primaryKey(), success: t.bool(), message: t.string() }\n);\nconst spacetimedb = schema({ commandResult });\nexport default spacetimedb;\n\nexport const run_command = spacetimedb.reducer(\n { requestId: t.string(), value: t.i32() },\n (ctx, { requestId, value }) => ctx.db.commandResult.insert({\n requestId,\n success: true,\n message: `value=${value}`,\n })\n);\n",{"_39":366,"_41":333,"_42":367,"_44":368,"_46":369},"t_102_caller_error_message","Caller Error Message","Write a SpacetimeDB backend module in TypeScript whose reducer reports a failure back to its caller.\n\nTABLE\n- item (public)\n - Fields:\n - id: bigint (u64, primary key)\n - name: string\n\nREDUCERS\n- add_item(ctx, { id: bigint (u64), name: string })\n - If name is empty, fail so that the caller receives the exact text \"name required\"\n - Otherwise insert the item","import { schema, SenderError, table, t } from 'spacetimedb/server';\n\nconst item = table(\n { name: 'item', public: true },\n { id: t.u64().primaryKey(), name: t.string() }\n);\nconst spacetimedb = schema({ item });\nexport default spacetimedb;\n\nexport const add_item = spacetimedb.reducer(\n { id: t.u64(), name: t.string() },\n (ctx, { id, name }) => {\n if (name === '') {\n throw new SenderError('name required');\n }\n ctx.db.item.insert({ id, name });\n }\n);\n","views",[372,377,382,387,392,397,402],{"_39":373,"_41":370,"_42":374,"_44":375,"_46":376},"t_061_three_table_join","Three Table Join","Write a SpacetimeDB backend module in TypeScript that defines a public view joining three normalized tables.\n\nTABLES\n- customer (public)\n - Fields:\n - id: u64 (primary key)\n - name: string\n- purchase (public)\n - Fields:\n - id: u64 (primary key)\n - customerId: u64 (btree index)\n- line_item (public)\n - Fields:\n - id: u64 (primary key)\n - purchaseId: u64 (btree index)\n - sku: string\n - visible: bool (btree index)\n\nREDUCERS\n- seed()\n - Insert one complete visible customer -> purchase -> line_item chain\n - Use customer id 1 named \"Ada\"\n - Use purchase id 10 for customer 1\n - Use visible line_item id 100 for purchase 10 with sku \"SKU-1\"\n\nVIEW\n- order_line_detail (anonymous procedural, public)\n - Returns rows with lineId: u64, customerName: string, and sku: string\n - Return only rows connected through matching customer, purchase, and line-item IDs","import { schema, table, t } from 'spacetimedb/server';\nconst customer = table({ name: 'customer', public: true }, { id: t.u64().primaryKey(), name: t.string() });\nconst purchase = table({ name: 'purchase', public: true }, { id: t.u64().primaryKey(), customerId: t.u64().index('btree') });\nconst lineItem = table({ name: 'line_item', public: true }, { id: t.u64().primaryKey(), purchaseId: t.u64().index('btree'), sku: t.string(), visible: t.bool().index('btree') });\nconst OrderLineDetail = t.row('ThreeTableJoinRow', { lineId: t.u64(), customerName: t.string(), sku: t.string() });\nconst spacetimedb = schema({ customer, purchase, lineItem }); export default spacetimedb;\nexport const seed = spacetimedb.reducer(ctx => { ctx.db.customer.insert({ id: 1n, name: 'Ada' }); ctx.db.purchase.insert({ id: 10n, customerId: 1n }); ctx.db.lineItem.insert({ id: 100n, purchaseId: 10n, sku: 'SKU-1', visible: true }); });\nexport const order_line_detail = spacetimedb.anonymousView({ name: 'order_line_detail', public: true }, t.array(OrderLineDetail), ctx => {\n const rows: Array<{ lineId: bigint; customerName: string; sku: string }> = []; for (const line of ctx.db.lineItem.visible.filter(true)) { const purchase = ctx.db.purchase.id.find(line.purchaseId); if (!purchase) continue; const customer = ctx.db.customer.id.find(purchase.customerId); if (customer) rows.push({ lineId: line.id, customerName: customer.name, sku: line.sku }); } return rows;\n});\n",{"_39":378,"_41":370,"_42":379,"_44":380,"_46":381},"t_062_semijoin_intersection","Semijoin Intersection","Write a SpacetimeDB backend module in TypeScript that defines a query-builder semijoin view.\n\nTABLES\n- member (public)\n - Fields:\n - id: u64 (primary key)\n - name: string\n- eligibility (public)\n - Fields:\n - id: u64 (primary key)\n - memberId: u64 (btree index)\n\nREDUCERS\n- seed()\n - Insert member 1 named \"Ada\" and member 2 named \"Grace\"\n - Insert eligibility id 10 for only member 1\n\nVIEW\n- eligible_member (public, non-anonymous query-builder)\n - Use a semijoin\n - Return members only when a matching eligibility row exists","import { schema, table, t } from 'spacetimedb/server';\n\nconst member = table({ name: 'member', public: true }, { id: t.u64().primaryKey(), name: t.string() });\nconst eligibility = table({ name: 'eligibility', public: true }, { id: t.u64().primaryKey(), memberId: t.u64().index('btree') });\nconst spacetimedb = schema({ member, eligibility });\nexport default spacetimedb;\nexport const seed = spacetimedb.reducer(ctx => {\n ctx.db.member.insert({ id: 1n, name: 'Ada' }); ctx.db.member.insert({ id: 2n, name: 'Grace' });\n ctx.db.eligibility.insert({ id: 10n, memberId: 1n });\n});\nexport const eligible_member = spacetimedb.view(\n { name: 'eligible_member', public: true }, t.array(member.rowType),\n ctx => ctx.from.eligibility.rightSemijoin(ctx.from.member, (eligibility, member) => eligibility.memberId.eq(member.id))\n);\n",{"_39":383,"_41":370,"_42":384,"_44":385,"_46":386},"t_063_timestamp_window","Timestamp Window","Write a SpacetimeDB backend module in TypeScript that defines a procedural view over an inclusive timestamp range.\n\nTABLE\n- event (public)\n - Fields:\n - id: u64 (primary key)\n - occurredAt: Timestamp (btree index)\n - label: string\n\nREDUCERS\n- seed()\n - Insert events at 100, 200, 300, 400, and 500 microseconds after the Unix epoch\n - Assign ids 1 through 5 in timestamp order\n - Set each label to \"event-{microseconds}\", such as \"event-100\"\n\nVIEW\n- window_event (anonymous procedural, public)\n - Use the occurredAt index\n - Return the inclusive range from 200 through 400 microseconds\n - Return rows in ascending occurredAt order","import { Timestamp } from 'spacetimedb';\nimport { Range, schema, table, t } from 'spacetimedb/server';\n\nconst event = table({ name: 'event', public: true }, {\n id: t.u64().primaryKey(),\n occurredAt: t.timestamp().index('btree'),\n label: t.string(),\n});\n\nconst spacetimedb = schema({ event });\nexport default spacetimedb;\n\nexport const seed = spacetimedb.reducer(ctx => {\n [100n, 200n, 300n, 400n, 500n].forEach((micros, index) => {\n ctx.db.event.insert({ id: BigInt(index + 1), occurredAt: new Timestamp(micros), label: `event-${micros}` });\n });\n});\n\nexport const window_event = spacetimedb.anonymousView(\n { name: 'window_event', public: true },\n t.array(event.rowType),\n ctx => Array.from(ctx.db.event.occurredAt.filter(new Range(\n { tag: 'included', value: new Timestamp(200n) },\n { tag: 'included', value: new Timestamp(400n) },\n )))\n);\n",{"_39":388,"_41":370,"_42":389,"_44":390,"_46":391},"t_064_index_and_filter","Index And Filter","Write a SpacetimeDB backend module in TypeScript that defines a procedural view using an index and additional filters.\n\nTABLE\n- content (public)\n - Fields:\n - id: u64 (primary key)\n - category: string (btree index)\n - active: boolean\n - score: i32\n\nREDUCERS\n- seed()\n - Insert id 1 with category \"news\", active true, and score 20\n - Insert id 2 with category \"news\", active false, and score 20\n - Insert id 3 with category \"news\", active true, and score 5\n - Insert id 4 with category \"sports\", active true, and score 20\n\nVIEW\n- featured_content (anonymous procedural, public)\n - First use the category index for \"news\"\n - Then return only active rows with score at least 10","import { schema, table, t } from 'spacetimedb/server';\nconst content = table({ name: 'content', public: true }, { id: t.u64().primaryKey(), category: t.string().index('btree'), active: t.bool(), score: t.i32() });\nconst spacetimedb = schema({ content }); export default spacetimedb;\nexport const seed = spacetimedb.reducer(ctx => {\n ctx.db.content.insert({ id: 1n, category: 'news', active: true, score: 20 });\n ctx.db.content.insert({ id: 2n, category: 'news', active: false, score: 20 });\n ctx.db.content.insert({ id: 3n, category: 'news', active: true, score: 5 });\n ctx.db.content.insert({ id: 4n, category: 'sports', active: true, score: 20 });\n});\nexport const featured_content = spacetimedb.anonymousView(\n { name: 'featured_content', public: true }, t.array(content.rowType),\n ctx => Array.from(ctx.db.content.category.filter('news')).filter(row => row.active && row.score >= 10)\n);\n",{"_39":393,"_41":370,"_42":394,"_44":395,"_46":396},"t_065_materialized_aggregate","Materialized Aggregate","Write a SpacetimeDB backend module in TypeScript that maintains and exposes a materialized aggregate.\n\nTABLES\n- sale (public)\n - Fields:\n - id: u64 (primary key)\n - category: string\n - amount: i64\n- category_total (public)\n - Fields:\n - category: string (primary key)\n - totalAmount: i64\n - saleCount: u64\n\nREDUCERS\n- exercise()\n - Also export set_sale(id: u64, category: string, amount: i64) and remove_sale(id: u64)\n - These reducers must update arbitrary sales and totals, not just the exercise data\n - Setting an existing sale replaces its category and amount; removing a missing sale is a no-op\n - Zero and negative amounts are valid; remove a category only when its last sale is removed\n - Keep category_total transactionally synchronized when a sale is inserted, changed, moved between categories, or deleted\n - Insert books sales with ids 1 and 2 and amounts 10 and 20\n - Update the second books sale to 25\n - Insert and then delete a games sale with id 3\n - Delete the first books sale\n\nVIEW\n- category_summary (public, non-anonymous query-builder)\n - Expose all category_total rows\n - After exercise, the only row is books with totalAmount 25 and saleCount 1","import { schema, table, t } from 'spacetimedb/server';\nimport type { InferSchema, ReducerCtx } from 'spacetimedb/server';\n\nconst sale = table(\n { name: 'sale', public: true },\n {\n id: t.u64().primaryKey(),\n category: t.string(),\n amount: t.i64(),\n }\n);\nconst categoryTotal = table(\n { name: 'category_total', public: true },\n {\n category: t.string().primaryKey(),\n totalAmount: t.i64(),\n saleCount: t.u64(),\n }\n);\nconst spacetimedb = schema({ sale, categoryTotal });\nexport default spacetimedb;\n\ntype Ctx = ReducerCtx>;\n\nfunction addToTotal(ctx: Ctx, category: string, amount: bigint) {\n const total = ctx.db.categoryTotal.category.find(category);\n if (total)\n ctx.db.categoryTotal.category.update({\n ...total,\n totalAmount: total.totalAmount + amount,\n saleCount: total.saleCount + 1n,\n });\n else\n ctx.db.categoryTotal.insert({\n category,\n totalAmount: amount,\n saleCount: 1n,\n });\n}\n\nfunction removeFromTotal(ctx: Ctx, category: string, amount: bigint) {\n const total = ctx.db.categoryTotal.category.find(category);\n if (!total) throw new Error('missing category total');\n if (total.saleCount === 1n) ctx.db.categoryTotal.category.delete(category);\n else\n ctx.db.categoryTotal.category.update({\n ...total,\n totalAmount: total.totalAmount - amount,\n saleCount: total.saleCount - 1n,\n });\n}\n\nfunction upsertSale(\n ctx: Ctx,\n row: { id: bigint; category: string; amount: bigint }\n) {\n const old = ctx.db.sale.id.find(row.id);\n if (old) {\n removeFromTotal(ctx, old.category, old.amount);\n ctx.db.sale.id.update(row);\n } else ctx.db.sale.insert(row);\n addToTotal(ctx, row.category, row.amount);\n}\n\nfunction deleteSale(ctx: Ctx, id: bigint) {\n const old = ctx.db.sale.id.find(id);\n if (!old) return;\n ctx.db.sale.id.delete(id);\n removeFromTotal(ctx, old.category, old.amount);\n}\n\nexport const set_sale = spacetimedb.reducer(\n { id: t.u64(), category: t.string(), amount: t.i64() },\n (ctx, row) => upsertSale(ctx, row)\n);\nexport const remove_sale = spacetimedb.reducer({ id: t.u64() }, (ctx, { id }) =>\n deleteSale(ctx, id)\n);\n\nexport const exercise = spacetimedb.reducer(ctx => {\n upsertSale(ctx, { id: 1n, category: 'books', amount: 10n });\n upsertSale(ctx, { id: 2n, category: 'books', amount: 20n });\n upsertSale(ctx, { id: 2n, category: 'books', amount: 25n });\n upsertSale(ctx, { id: 3n, category: 'games', amount: 40n });\n deleteSale(ctx, 3n);\n deleteSale(ctx, 1n);\n});\n\nexport const category_summary = spacetimedb.view(\n { name: 'category_summary', public: true },\n t.array(categoryTotal.rowType),\n ctx => ctx.from.categoryTotal\n);\n",{"_39":398,"_41":370,"_42":399,"_44":400,"_46":401},"t_066_query_builder_view","Query Builder View","Write a SpacetimeDB backend module in TypeScript that defines a query-builder filter view.\n\nTABLE\n- ticket (public)\n - Fields:\n - id: u64 (primary key)\n - status: string (btree index)\n - title: string\n\nREDUCERS\n- seed()\n - Insert open ticket id 1 titled \"A\"\n - Insert closed ticket id 2 titled \"B\"\n\nVIEW\n- open_ticket (public, non-anonymous query-builder)\n - Return the query-builder filter for status \"open\"\n - Do not materialize rows manually","import { schema, table, t } from 'spacetimedb/server';\nconst ticket = table({ name: 'ticket', public: true }, { id: t.u64().primaryKey(), status: t.string().index('btree'), title: t.string() });\nconst spacetimedb = schema({ ticket }); export default spacetimedb;\nexport const seed = spacetimedb.reducer(ctx => { ctx.db.ticket.insert({ id: 1n, status: 'open', title: 'A' }); ctx.db.ticket.insert({ id: 2n, status: 'closed', title: 'B' }); });\nexport const open_ticket = spacetimedb.view({ name: 'open_ticket', public: true }, t.array(ticket.rowType), ctx => ctx.from.ticket.where(ticket => ticket.status.eq('open')));\n",{"_39":403,"_41":370,"_42":404,"_44":405,"_46":406},"t_067_view_primary_key","View Primary Key","Write a SpacetimeDB backend module in TypeScript that defines a procedural view with a primary key.\n\nTABLE\n- source_row (public)\n - Fields:\n - id: u64 (primary key)\n - value: string\n - visible: boolean (btree index)\n\nREDUCERS\n- seed()\n - Insert row 1 with value \"shown\" and visible true\n - Insert row 2 with value \"hidden\" and visible false\n\nVIEW\n- source_view (anonymous procedural, public)\n - Return visible source_row rows\n - The returned row type declares id as its primary key","import { schema, table, t } from 'spacetimedb/server';\nconst SourceViewRow = t.row('SourceViewRow', { id: t.u64().primaryKey(), value: t.string(), visible: t.bool().index('btree') });\nconst sourceRow = table({ name: 'source_row', public: true }, SourceViewRow);\nconst spacetimedb = schema({ sourceRow }); export default spacetimedb;\nexport const seed = spacetimedb.reducer(ctx => {\n ctx.db.sourceRow.insert({ id: 1n, value: 'shown', visible: true });\n ctx.db.sourceRow.insert({ id: 2n, value: 'hidden', visible: false });\n});\nexport const source_view = spacetimedb.anonymousView({ name: 'source_view', public: true }, t.array(SourceViewRow), ctx => Array.from(ctx.db.sourceRow.visible.filter(true)));\n","lifecycle",[409,414,419],{"_39":410,"_41":407,"_42":411,"_44":412,"_46":413},"t_069_scheduled_materialization","Scheduled Materialization","Write a SpacetimeDB backend module in TypeScript that refreshes materialized state through a scheduled reducer.\n\nTABLES\n- materialized_state (public)\n - Fields:\n - id: u64 (primary key)\n - status: string\n - version: u64\n - refreshedAt: Timestamp\n- refresh_job (private, scheduled for refreshMaterialized)\n - Fields, in this order:\n - scheduledId: u64 (primary key, auto-increment)\n - scheduledAt: ScheduleAt\n - stateId: u64\n\nREDUCERS\n- start_refresh()\n - Write id 1 with status \"pending\", version 0, and refreshedAt at the Unix epoch\n - Schedule state 1 for one millisecond later\n- refreshMaterialized(job: refresh_job row) (scheduled reducer)\n - Update state 1 to status \"ready\" and version 1\n - Replace refreshedAt with the scheduled reducer timestamp\n - Complete without any further client call","import { ScheduleAt, Timestamp } from 'spacetimedb';\nimport { schema, table, t } from 'spacetimedb/server';\n\nconst materializedState = table({ name: 'materialized_state', public: true }, {\n id: t.u64().primaryKey(), status: t.string(), version: t.u64(), refreshedAt: t.timestamp(),\n});\nconst refreshJob = table({ name: 'refresh_job', scheduled: (): any => refreshMaterialized }, {\n scheduledId: t.u64().primaryKey().autoInc(), scheduledAt: t.scheduleAt(), stateId: t.u64(),\n});\nconst spacetimedb = schema({ materializedState, refreshJob });\nexport default spacetimedb;\n\nexport const start_refresh = spacetimedb.reducer(ctx => {\n const pending = { id: 1n, status: 'pending', version: 0n, refreshedAt: new Timestamp(0n) };\n if (ctx.db.materializedState.id.find(1n)) ctx.db.materializedState.id.update(pending);\n else ctx.db.materializedState.insert(pending);\n ctx.db.refreshJob.insert({\n scheduledId: 0n, scheduledAt: ScheduleAt.time(ctx.timestamp.microsSinceUnixEpoch + 1_000n), stateId: 1n,\n });\n});\n\nexport const refreshMaterialized = spacetimedb.reducer({ job: refreshJob.rowType }, (ctx, { job }) => {\n const state = ctx.db.materializedState.id.find(job.stateId);\n if (!state) throw new Error('materialized state missing');\n ctx.db.materializedState.id.update({ ...state, status: 'ready', version: 1n, refreshedAt: ctx.timestamp });\n});\n",{"_39":415,"_41":407,"_42":416,"_44":417,"_46":418},"t_070_connection_scoped_presence","Connection Scoped Presence","Write a SpacetimeDB backend module in TypeScript that tracks presence separately for each connection.\n\nTABLE\n- presence_session (public)\n - Fields:\n - connectionId: ConnectionId (primary key)\n - identity: Identity (btree index)\n - connectedAt: Timestamp\n\nLIFECYCLE HOOKS\n- clientConnected\n - Export with this exact identifier\n - Insert one row for the connected connection\n- clientDisconnected\n - Export with this exact identifier\n - Delete only the disconnected connection's row\n\nREDUCERS\n- exercise_presence()\n - Insert synthetic connection IDs 1 and 2 for the caller\n - Use the 128-bit numeric values 1 and 2\n - Remove connection ID 1\n - Leave connection ID 2 intact","import { ConnectionId } from 'spacetimedb';\nimport { schema, table, t } from 'spacetimedb/server';\nimport type { InferSchema, ReducerCtx } from 'spacetimedb/server';\n\nconst presenceSession = table({ name: 'presence_session', public: true }, {\n connectionId: t.connectionId().primaryKey(), identity: t.identity().index('btree'), connectedAt: t.timestamp(),\n});\nconst spacetimedb = schema({ presenceSession });\nexport default spacetimedb;\ntype Ctx = ReducerCtx>;\n\nfunction addSession(ctx: Ctx, connectionId: ConnectionId) {\n ctx.db.presenceSession.insert({ connectionId, identity: ctx.sender, connectedAt: ctx.timestamp });\n}\nfunction removeSession(ctx: Ctx, connectionId: ConnectionId) { ctx.db.presenceSession.connectionId.delete(connectionId); }\n\nexport const clientConnected = spacetimedb.clientConnected(ctx => {\n if (!ctx.connectionId) throw new Error('connection id missing');\n addSession(ctx, ctx.connectionId);\n});\nexport const clientDisconnected = spacetimedb.clientDisconnected(ctx => {\n if (!ctx.connectionId) throw new Error('connection id missing');\n removeSession(ctx, ctx.connectionId);\n});\nexport const exercise_presence = spacetimedb.reducer(ctx => {\n const first = new ConnectionId(1n);\n const second = new ConnectionId(2n);\n addSession(ctx, first);\n addSession(ctx, second);\n removeSession(ctx, first);\n});\n",{"_39":420,"_41":407,"_42":421,"_44":422,"_46":423},"t_071_scheduled_private","Scheduled Private","Write a SpacetimeDB backend module in TypeScript with a private scheduled table that is not client-callable.\n\nTABLES\n- job_result (public)\n - Fields:\n - id: u64 (primary key)\n - status: string\n- private_job (private, scheduled for runPrivateJob)\n - Fields, in this order:\n - scheduledId: u64 (primary key, auto-increment)\n - scheduledAt: ScheduleAt\n - resultId: u64\n\nREDUCERS\n- enqueue_private(id: u64)\n - Write job_result status \"queued\"\n - Schedule that id for one millisecond later\n- runPrivateJob(job: private_job row) (scheduled reducer)\n - Must be scheduler-only and not client-callable\n - Update the matching job_result status to \"complete\"","import { ScheduleAt } from 'spacetimedb';\nimport { schema, table, t } from 'spacetimedb/server';\n\nconst jobResult = table({ name: 'job_result', public: true }, {\n id: t.u64().primaryKey(), status: t.string(),\n});\nconst privateJob = table({ name: 'private_job', scheduled: (): any => runPrivateJob }, {\n scheduledId: t.u64().primaryKey().autoInc(), scheduledAt: t.scheduleAt(), resultId: t.u64(),\n});\nconst spacetimedb = schema({ jobResult, privateJob });\nexport default spacetimedb;\n\nexport const enqueue_private = spacetimedb.reducer({ id: t.u64() }, (ctx, { id }) => {\n ctx.db.jobResult.insert({ id, status: 'queued' });\n ctx.db.privateJob.insert({\n scheduledId: 0n, scheduledAt: ScheduleAt.time(ctx.timestamp.microsSinceUnixEpoch + 1_000n), resultId: id,\n });\n});\n\nexport const runPrivateJob = spacetimedb.reducer({ job: privateJob.rowType }, (ctx, { job }) => {\n const result = ctx.db.jobResult.id.find(job.resultId);\n if (!result) throw new Error('job result missing');\n ctx.db.jobResult.id.update({ ...result, status: 'complete' });\n});\n","procedures",[426,431,436,441,446,451,456,461],{"_39":427,"_41":424,"_42":428,"_44":429,"_46":430},"t_072_procedure_return","Procedure Return","Write a SpacetimeDB backend module in TypeScript that defines a procedure with a typed return value.\n\nThe module defines no tables.\n\nTYPES\n- Summary\n - total: u32\n - label: string\n\nPROCEDURE\n- calculate_summary(lhs: u32, rhs: u32) -> Summary\n - Return total as lhs + rhs\n - Return label as \"calculated\"","import { schema, t } from 'spacetimedb/server';\n\nconst Summary = t.object('Summary', { total: t.u32(), label: t.string() });\nconst spacetimedb = schema({});\nexport default spacetimedb;\n\nexport const calculate_summary = spacetimedb.procedure(\n { lhs: t.u32(), rhs: t.u32() }, Summary,\n (_ctx, { lhs, rhs }) => ({ total: lhs + rhs, label: 'calculated' })\n);\n",{"_39":432,"_41":424,"_42":433,"_44":434,"_46":435},"t_073_http_fetch","Http Fetch","Write a SpacetimeDB backend module in TypeScript that performs outbound HTTP in a procedure.\n\nTYPES\n- FetchSummary\n - status: u16\n - htmlContentType: bool\n - hasExampleDomain: bool\n\nPROCEDURE\n- fetch_page_summary(url: string) -> FetchSummary\n - Perform an outbound GET to the supplied public URL\n - Set status from the response status\n - Set htmlContentType based on whether Content-Type contains \"text/html\"\n - Set hasExampleDomain based on whether the body contains \"Example Domain\"","import { schema, t } from 'spacetimedb/server';\n\nconst FetchSummary = t.object('FetchSummary', {\n status: t.u16(), htmlContentType: t.bool(), hasExampleDomain: t.bool(),\n});\nconst spacetimedb = schema({});\nexport default spacetimedb;\n\nexport const fetch_page_summary = spacetimedb.procedure(\n { url: t.string() }, FetchSummary,\n (ctx, { url }) => {\n const response = ctx.http.fetch(url);\n return {\n status: response.status,\n htmlContentType: (response.headers.get('content-type') ?? '').includes('text/html'),\n hasExampleDomain: response.text().includes('Example Domain'),\n };\n }\n);\n",{"_39":437,"_41":424,"_42":438,"_44":439,"_46":440},"t_074_fetch_and_store","Fetch And Store","Write a SpacetimeDB backend module in TypeScript that fetches external data before storing a result in a transaction.\n\nTABLE\n- fetched_record (public)\n - Fields:\n - id: u64 (primary key)\n - status: u16\n - validBody: bool\n\nPROCEDURE\n- fetch_and_store(url: string) -> unit\n - Perform an outbound GET to the supplied public URL before opening a transaction\n - Inside a short transaction, store id 1 and the response status\n - Set validBody based on whether the response body contains \"Example Domain\"","import { schema, table, t } from 'spacetimedb/server';\n\nconst fetchedRecord = table({ name: 'fetched_record', public: true }, {\n id: t.u64().primaryKey(), status: t.u16(), validBody: t.bool(),\n});\nconst spacetimedb = schema({ fetchedRecord });\nexport default spacetimedb;\n\nexport const fetch_and_store = spacetimedb.procedure(\n { url: t.string() }, t.unit(),\n (ctx, { url }) => {\n const response = ctx.http.fetch(url);\n const status = response.status;\n const validBody = response.text().includes('Example Domain');\n ctx.withTx(tx => tx.db.fetchedRecord.insert({ id: 1n, status, validBody }));\n return {};\n }\n);\n",{"_39":442,"_41":424,"_42":443,"_44":444,"_46":445},"t_075_scheduled_procedure","Scheduled Procedure","Write a SpacetimeDB backend module in TypeScript that schedules a procedure which writes inside a transaction.\n\nTABLES\n- procedure_result (public)\n - Fields:\n - id: u64 (primary key)\n - value: u32\n- procedure_job (private, scheduled for runScheduledProcedure)\n - Fields, in this order:\n - scheduledId: u64 (primary key, auto-increment)\n - scheduledAt: ScheduleAt\n - id: u64\n - lhs: u32\n - rhs: u32\n\nREDUCERS\n- schedule_procedure(id: u64, lhs: u32, rhs: u32)\n - Enqueue runScheduledProcedure for one millisecond later\n\nPROCEDURE\n- runScheduledProcedure(job: procedure_job row) -> unit (scheduled procedure)\n - Open a transaction\n - Insert id and value lhs + rhs into procedure_result","import { ScheduleAt } from 'spacetimedb';\nimport { schema, table, t } from 'spacetimedb/server';\n\nconst procedureResult = table({ name: 'procedure_result', public: true }, {\n id: t.u64().primaryKey(), value: t.u32(),\n});\nconst procedureJob = table({ name: 'procedure_job', scheduled: (): any => runScheduledProcedure }, {\n scheduledId: t.u64().primaryKey().autoInc(), scheduledAt: t.scheduleAt(),\n id: t.u64(), lhs: t.u32(), rhs: t.u32(),\n});\nconst spacetimedb = schema({ procedureResult, procedureJob });\nexport default spacetimedb;\n\nexport const schedule_procedure = spacetimedb.reducer(\n { id: t.u64(), lhs: t.u32(), rhs: t.u32() },\n (ctx, { id, lhs, rhs }) => ctx.db.procedureJob.insert({\n scheduledId: 0n, scheduledAt: ScheduleAt.time(ctx.timestamp.microsSinceUnixEpoch + 1_000n), id, lhs, rhs,\n })\n);\n\nexport const runScheduledProcedure = spacetimedb.procedure(\n { job: procedureJob.rowType }, t.unit(),\n (ctx, { job }) => {\n ctx.withTx(tx => tx.db.procedureResult.insert({ id: job.id, value: job.lhs + job.rhs }));\n return {};\n }\n);\n",{"_39":447,"_41":424,"_42":448,"_44":449,"_46":450},"t_076_http_handler","Http Handler","Write a SpacetimeDB backend module in TypeScript that defines and routes an inbound HTTP handler.\n\nThe module defines no tables.\n\nHANDLER\n- POST /echo\n - Read the request body\n - Return status 201\n - Return Content-Type text/plain\n - Return body \"echo:\" followed by the input body\n\nROUTER\n- Register the POST /echo handler through an HTTP router","import { Router, SyncResponse, schema } from 'spacetimedb/server';\n\nconst spacetimedb = schema({});\nexport default spacetimedb;\n\nexport const echo = spacetimedb.httpHandler((_ctx, request) =>\n new SyncResponse(`echo:${request.text()}`, { status: 201, headers: { 'content-type': 'text/plain' } })\n);\nexport const routes = spacetimedb.httpRouter(new Router().post('/echo', echo));\n",{"_39":452,"_41":424,"_42":453,"_44":454,"_46":455},"t_077_http_router","Http Router","Write a SpacetimeDB backend module in TypeScript that routes two HTTP methods on the same path.\n\nThe module defines no tables.\n\nHANDLERS\n- GET /items\n - Return status 200\n - Return body \"list\"\n- POST /items\n - Read the request body\n - Return status 201\n - Return body \"created:\" followed by the request body\n\nROUTER\n- Register both handlers for /items\n- Reject unsupported methods on /items\n- Reject unknown paths","import { Router, SyncResponse, schema } from 'spacetimedb/server';\n\nconst spacetimedb = schema({});\nexport default spacetimedb;\n\nexport const listItems = spacetimedb.httpHandler((_ctx, _request) => new SyncResponse('list'));\nexport const createItem = spacetimedb.httpHandler((_ctx, request) =>\n new SyncResponse(`created:${request.text()}`, { status: 201 })\n);\nexport const routes = spacetimedb.httpRouter(\n new Router().get('/items', listItems).post('/items', createItem)\n);\n",{"_39":457,"_41":424,"_42":458,"_44":459,"_46":460},"t_078_idempotent_webhook","Idempotent Webhook","Write a SpacetimeDB backend module in TypeScript that handles idempotent, ordered webhook events.\n\nTABLES\n- processed_event (private)\n - Fields:\n - eventId: string (primary key)\n- webhook_state (public)\n - Fields:\n - key: string (primary key)\n - lastSequence: u64\n - value: string\n\nHANDLER\n- POST /webhook\n - Accept a pipe-delimited body: event_id|sequence|value\n - Store state under key \"account\"\n - For a newly applied event, return status 200 and body \"applied\"\n - For a duplicate eventId, return status 200 and body \"duplicate\" without applying twice\n - When sequence is not newer, return status 200 and body \"stale\" without replacing state\n\nROUTER\n- Register POST /webhook through an HTTP router","import { Router, SyncResponse, schema, table, t } from 'spacetimedb/server';\n\nconst processedEvent = table({ name: 'processed_event' }, { eventId: t.string().primaryKey() });\nconst webhookState = table({ name: 'webhook_state', public: true }, {\n key: t.string().primaryKey(), lastSequence: t.u64(), value: t.string(),\n});\nconst spacetimedb = schema({ processedEvent, webhookState });\nexport default spacetimedb;\n\nexport const webhook = spacetimedb.httpHandler((ctx, request) => {\n const parts = request.text().split('|', 3);\n if (parts.length !== 3) return new SyncResponse('invalid', { status: 400 });\n const [eventId, sequenceText, value] = parts;\n const sequence = BigInt(sequenceText);\n const outcome = ctx.withTx(tx => {\n if (tx.db.processedEvent.eventId.find(eventId)) return 'duplicate';\n tx.db.processedEvent.insert({ eventId });\n const state = tx.db.webhookState.key.find('account');\n if (state) {\n if (sequence <= state.lastSequence) return 'stale';\n tx.db.webhookState.key.update({ ...state, lastSequence: sequence, value });\n } else tx.db.webhookState.insert({ key: 'account', lastSequence: sequence, value });\n return 'applied';\n });\n return new SyncResponse(outcome);\n});\nexport const routes = spacetimedb.httpRouter(new Router().post('/webhook', webhook));\n",{"_39":462,"_41":424,"_42":463,"_44":464,"_46":465},"t_079_external_upload_flow","External Upload Flow","Write a SpacetimeDB backend module in TypeScript that exposes an upload route and an external upload procedure.\n\nTABLE\n- uploaded_asset (public)\n - Fields:\n - id: u64 (primary key)\n - url: string\n - size: u64\n - status: u16\n - responseBodyPresent: bool\n\nHANDLER\n- POST /upload\n - Return status 201\n - Return body \"https://files.local/object-1\"\n\nPROCEDURE\n- upload_and_register(uploadUrl: string, data: u8[]) -> string\n - POST the binary data to the supplied public URL\n - Require a successful response\n - Open a transaction and store id 1, the supplied URL, the byte length, the response status, and whether the response body is non-empty\n - Return the supplied URL\n\nROUTER\n- Register POST /upload through an HTTP router","import { Router, SyncResponse, schema, table, t } from 'spacetimedb/server';\n\nconst uploadedAsset = table({ name: 'uploaded_asset', public: true }, {\n id: t.u64().primaryKey(), url: t.string(), size: t.u64(), status: t.u16(), responseBodyPresent: t.bool(),\n});\nconst spacetimedb = schema({ uploadedAsset });\nexport default spacetimedb;\n\nexport const upload = spacetimedb.httpHandler((_ctx, _request) =>\n new SyncResponse('https://files.local/object-1', { status: 201 })\n);\nexport const routes = spacetimedb.httpRouter(new Router().post('/upload', upload));\n\nexport const upload_and_register = spacetimedb.procedure(\n { uploadUrl: t.string(), data: t.array(t.u8()) }, t.string(),\n (ctx, { uploadUrl, data }) => {\n const response = ctx.http.fetch(\n uploadUrl,\n { method: 'POST', headers: { 'content-type': 'application/octet-stream' }, body: new Uint8Array(data) }\n );\n if (response.status < 200 || response.status >= 300) throw new Error(`upload failed: ${response.status}`);\n const responseBodyPresent = response.bytes().length > 0;\n ctx.withTx(tx => tx.db.uploadedAsset.insert({\n id: 1n, url: uploadUrl, size: BigInt(data.length), status: response.status, responseBodyPresent,\n }));\n return uploadUrl;\n }\n);\n","migrations",[468,473,478],{"_39":469,"_41":466,"_42":470,"_44":471,"_46":472},"t_080_automatic_migration","Automatic Migration","Update the existing SpacetimeDB backend module in TypeScript with a compatible schema change.\n\nTABLES\n- product (public)\n - Preserve the existing table and its fields\n- category (public)\n - Fields:\n - id: u64 (primary key)\n - label: string\n\nREDUCERS\n- Preserve seed and touch\n- create_category(id: u64, label: string)\n - Insert a category with the supplied values\n\nMIGRATION\n- The populated product table must survive a normal republish without deleting data","import { schema, table, t } from 'spacetimedb/server';\n\nconst product = table(\n { name: 'product', public: true },\n { id: t.u64().primaryKey(), name: t.string() }\n);\nconst category = table(\n { name: 'category', public: true },\n { id: t.u64().primaryKey(), label: t.string() }\n);\nconst spacetimedb = schema({ product, category });\nexport default spacetimedb;\n\nexport const seed = spacetimedb.reducer(ctx => {\n ctx.db.product.insert({ id: 1n, name: 'legacy' });\n});\nexport const touch = spacetimedb.reducer(_ctx => {});\nexport const create_category = spacetimedb.reducer(\n { id: t.u64(), label: t.string() },\n (ctx, { id, label }) => ctx.db.category.insert({ id, label })\n);\n",{"_39":474,"_41":466,"_42":475,"_44":476,"_46":477},"t_081_incremental_migration","Incremental Migration","Update the existing SpacetimeDB backend module in TypeScript with an incremental migration.\n\nTABLES\n- legacy_item (public)\n - Preserve the existing table and fields\n- item_v2 (public)\n - Fields:\n - id: u64 (primary key)\n - value: string\n - version: u32\n\nREDUCERS\n- Preserve seed\n- migrate()\n - Be idempotent\n - Copy missing legacy_item rows into item_v2 with version 2\n- dual_write(id: u64, value: string)\n - Write the same new item to both tables\n - Set version 2 in item_v2","import { schema, table, t } from 'spacetimedb/server';\n\nconst legacyItem = table(\n { name: 'legacy_item', public: true },\n { id: t.u64().primaryKey(), value: t.string() }\n);\nconst itemV2 = table(\n { name: 'item_v2', public: true },\n { id: t.u64().primaryKey(), value: t.string(), version: t.u32() }\n);\nconst spacetimedb = schema({ legacyItem, itemV2 });\nexport default spacetimedb;\n\nexport const seed = spacetimedb.reducer(ctx => {\n ctx.db.legacyItem.insert({ id: 1n, value: 'old' });\n});\n\nexport const migrate = spacetimedb.reducer(ctx => {\n for (const row of ctx.db.legacyItem.iter()) {\n if (!ctx.db.itemV2.id.find(row.id)) {\n ctx.db.itemV2.insert({ id: row.id, value: row.value, version: 2 });\n }\n }\n});\n\nexport const dual_write = spacetimedb.reducer(\n { id: t.u64(), value: t.string() },\n (ctx, { id, value }) => {\n ctx.db.legacyItem.insert({ id, value });\n ctx.db.itemV2.insert({ id, value, version: 2 });\n }\n);\n",{"_39":479,"_41":466,"_42":480,"_44":481,"_46":482},"t_082_hot_swap_compatibility","Hot Swap Compatibility","Update the existing SpacetimeDB backend module in TypeScript through a compatible republish.\n\nTABLES\n- counter (public)\n - Preserve the existing table and its exact fields\n- release (private)\n - Fields:\n - version: u32 (primary key)\n\nREDUCERS\n- Preserve seed\n- Preserve increment without renaming it or changing its signature\n- record_release(version: u32)\n\nMIGRATION\n- Existing counter data must remain usable after republish\n- The existing server API must remain usable after republish","import { schema, table, t } from 'spacetimedb/server';\n\nconst counter = table(\n { name: 'counter', public: true },\n { id: t.u64().primaryKey(), value: t.i64() }\n);\nconst release = table(\n { name: 'release' },\n { version: t.u32().primaryKey() }\n);\nconst spacetimedb = schema({ counter, release });\nexport default spacetimedb;\n\nexport const seed = spacetimedb.reducer(ctx => {\n ctx.db.counter.insert({ id: 1n, value: 1n });\n});\nexport const increment = spacetimedb.reducer(\n { id: t.u64(), amount: t.i64() },\n (ctx, { id, amount }) => {\n const row = ctx.db.counter.id.find(id);\n if (!row) throw new Error('counter');\n ctx.db.counter.id.update({ ...row, value: row.value + amount });\n }\n);\nexport const record_release = spacetimedb.reducer(\n { version: t.u32() },\n (ctx, { version }) => ctx.db.release.insert({ version })\n);\n","advanced",[485,490,495,500,505,510,515,520,525,530,535,540],{"_39":486,"_41":483,"_42":487,"_44":488,"_46":489},"t_083_atomic_reservation","Atomic Reservation","Write a SpacetimeDB backend module in TypeScript that reserves two products atomically. Return only the module source.\n\nReserve two distinct products atomically. A request ID identifies the entire payload. Exact replay is a no-op; reuse with different payload is an error. Validate quantities and products before accepting. No overselling, partial deductions, or failed-request receipts are allowed. Use the exact error text stated below.\n\nTables (the first field is the primary key):\n- public stock: id: u64 (bigint), available: i64 (bigint)\n- public reservation: requestId: string, firstId: u64 (bigint), firstQty: i64 (bigint), secondId: u64 (bigint), secondQty: i64 (bigint)\n\nReducers (argument order is part of the contract):\n- add_stock(id: u64 (bigint), available: i64 (bigint)): Insert a new product. Reject a negative quantity with 'invalid stock'.\n- reserve(requestId: string, firstId: u64 (bigint), firstQty: i64 (bigint), secondId: u64 (bigint), secondQty: i64 (bigint)): Exact replay returns success without changes. Changed replay: 'request conflict'. New request requires a nonempty ID, distinct products and positive quantities ('invalid reservation'); both products must exist ('missing product') and have enough stock ('insufficient stock'). Deduct both quantities and record the payload in one transaction.\n\nDo not add an exercise reducer or seed data automatically. All operations must work for arbitrary inputs, not just one example. Failed operations must leave every table unchanged.","import { schema, table, t, SenderError } from 'spacetimedb/server';\n\nconst stock = table(\n { name: 'stock', public: true },\n {\n id: t.u64().primaryKey(),\n available: t.i64(),\n }\n);\nconst reservation = table(\n { name: 'reservation', public: true },\n {\n requestId: t.string().primaryKey(),\n firstId: t.u64(),\n firstQty: t.i64(),\n secondId: t.u64(),\n secondQty: t.i64(),\n }\n);\nconst spacetimedb = schema({ stock, reservation });\nexport default spacetimedb;\n\nexport const add_stock = spacetimedb.reducer(\n { id: t.u64(), available: t.i64() },\n (ctx, { id, available }) => {\n if (available < 0n) throw new SenderError('invalid stock');\n ctx.db.stock.insert({ id, available });\n }\n);\n\nexport const reserve = spacetimedb.reducer(\n {\n requestId: t.string(),\n firstId: t.u64(),\n firstQty: t.i64(),\n secondId: t.u64(),\n secondQty: t.i64(),\n },\n (ctx, { requestId, firstId, firstQty, secondId, secondQty }) => {\n const old = ctx.db.reservation.requestId.find(requestId);\n if (old) {\n if (\n old.firstId !== firstId ||\n old.firstQty !== firstQty ||\n old.secondId !== secondId ||\n old.secondQty !== secondQty\n )\n throw new SenderError('request conflict');\n return;\n }\n if (!requestId || firstId === secondId || firstQty <= 0n || secondQty <= 0n)\n throw new SenderError('invalid reservation');\n const first = ctx.db.stock.id.find(firstId),\n second = ctx.db.stock.id.find(secondId);\n if (!first || !second) throw new SenderError('missing product');\n if (first.available < firstQty || second.available < secondQty)\n throw new SenderError('insufficient stock');\n ctx.db.stock.id.update({ ...first, available: first.available - firstQty });\n ctx.db.stock.id.update({\n ...second,\n available: second.available - secondQty,\n });\n ctx.db.reservation.insert({\n requestId,\n firstId,\n firstQty,\n secondId,\n secondQty,\n });\n }\n);\n",{"_39":491,"_41":483,"_42":492,"_44":493,"_46":494},"t_084_stable_pagination","Stable Pagination","Write a SpacetimeDB backend module in TypeScript that serves stable paginated audit logs. Return only the module source.\n\nImplement a tenant-scoped audit-log page. The ordering key is (occurredAt, id), ascending. The exclusive cursor is that pair; never use timestamp alone. Only rows for the requested tenant with visible=true can enter a page. Apply filtering BEFORE the limit. The page table is a test adapter: replace it on each read_page call; it is not a per-client cache. No native pagination API or scan-cost guarantee is assumed.\n\nTables (the first field is the primary key):\n- public audit_entry: id: u64 (bigint), tenant: string, occurredAt: u64 (bigint), visible: bool\n- public page_entry: position: u64 (bigint), entryId: u64 (bigint), occurredAt: u64 (bigint)\n\nReducers (argument order is part of the contract):\n- add_entry(id: u64 (bigint), tenant: string, occurredAt: u64 (bigint), visible: bool): Insert the supplied audit entry.\n- read_page(tenant: string, afterTime: u64 (bigint), afterId: u64 (bigint), limit: u64 (bigint)): Reject limits outside 1..=10 with 'invalid limit', preserving the previous page. Otherwise replace page_entry with matching entries strictly after the cursor, sorted by the pair, at most limit rows. Positions start at 0 and are consecutive. Empty pages clear old results. Audit rows are never changed.\n\nDo not add an exercise reducer or seed data automatically. All operations must work for arbitrary inputs, not just one example. Failed operations must leave every table unchanged.","import { schema, table, t, SenderError } from 'spacetimedb/server';\n\nconst auditEntry = table(\n { name: 'audit_entry', public: true },\n {\n id: t.u64().primaryKey(),\n tenant: t.string(),\n occurredAt: t.u64(),\n visible: t.bool(),\n }\n);\nconst pageEntry = table(\n { name: 'page_entry', public: true },\n {\n position: t.u64().primaryKey(),\n entryId: t.u64(),\n occurredAt: t.u64(),\n }\n);\nconst spacetimedb = schema({ auditEntry, pageEntry });\nexport default spacetimedb;\n\nexport const add_entry = spacetimedb.reducer(\n { id: t.u64(), tenant: t.string(), occurredAt: t.u64(), visible: t.bool() },\n (ctx, { id, tenant, occurredAt, visible }) => {\n ctx.db.auditEntry.insert({ id, tenant, occurredAt, visible });\n }\n);\n\nexport const read_page = spacetimedb.reducer(\n { tenant: t.string(), afterTime: t.u64(), afterId: t.u64(), limit: t.u64() },\n (ctx, { tenant, afterTime, afterId, limit }) => {\n if (limit === 0n || limit > 10n) throw new SenderError('invalid limit');\n const rows = [...ctx.db.auditEntry.iter()].filter(\n r =>\n r.tenant === tenant &&\n r.visible &&\n (r.occurredAt > afterTime ||\n (r.occurredAt === afterTime && r.id > afterId))\n );\n rows.sort((a, b) =>\n a.occurredAt < b.occurredAt\n ? -1\n : a.occurredAt > b.occurredAt\n ? 1\n : a.id < b.id\n ? -1\n : a.id > b.id\n ? 1\n : 0\n );\n for (const old of ctx.db.pageEntry.iter())\n ctx.db.pageEntry.position.delete(old.position);\n rows.slice(0, Number(limit)).forEach((r, i) =>\n ctx.db.pageEntry.insert({\n position: BigInt(i),\n entryId: r.id,\n occurredAt: r.occurredAt,\n })\n );\n }\n);\n",{"_39":496,"_41":483,"_42":497,"_44":498,"_46":499},"t_085_online_backfill","Online Backfill","Write a SpacetimeDB backend module in TypeScript that runs a resumable online backfill. Return only the module source.\n\nImplement a resumable online backfill while writes and deletes continue. The legacy table is authoritative. Capture and apply are separate transactions, so a captured snapshot can become stale. Keep tombstones in legacy_item; never resurrect a deleted item. This task tests the data migration algorithm inside one module, not deployment schema conversion.\n\nTables (the first field is the primary key):\n- public legacy_item: id: u64 (bigint), value: string, revision: u64 (bigint), deleted: bool\n- public backfill_snapshot: id: u64 (bigint), value: string, revision: u64 (bigint), deleted: bool\n- public item_v2: id: u64 (bigint), value: string, revision: u64 (bigint)\n\nReducers (argument order is part of the contract):\n- write_item(id: u64 (bigint), value: string): Insert or update the legacy row, incrementing its revision (start at 1) and clearing deleted. Dual-write the same value and revision to item_v2. IDs may be reused after deletion.\n- seed_legacy(id: u64 (bigint), value: string): Insert a legacy-only row at revision 1 with deleted=false. Used only to prepare pre-migration data. Do not write item_v2.\n- delete_item(id: u64 (bigint)): If legacy exists and is not deleted, increment revision, mark deleted and remove item_v2. Repeated deletion or missing ID is a no-op.\n- capture_batch(afterId: u64 (bigint), limit: u64 (bigint)): Reject limit outside 1..=10 with 'invalid limit'. Replace backfill_snapshot with at most limit legacy rows with id>after_id, ordered by id. Capture tombstones too. Do not modify source or destination.\n- apply_batch(): For each captured ID, reconcile item_v2 with the CURRENT authoritative legacy row, not the stale captured contents. Delete destination tombstones; upsert current live rows. Leave snapshots intact so retries are safe. Do not touch IDs outside the captured batch.\n\nDo not add an exercise reducer or seed data automatically. All operations must work for arbitrary inputs, not just one example. Failed operations must leave every table unchanged.","import { schema, table, t, SenderError } from 'spacetimedb/server';\n\nconst legacyItem = table(\n { name: 'legacy_item', public: true },\n {\n id: t.u64().primaryKey(),\n value: t.string(),\n revision: t.u64(),\n deleted: t.bool(),\n }\n);\nconst backfillSnapshot = table(\n { name: 'backfill_snapshot', public: true },\n {\n id: t.u64().primaryKey(),\n value: t.string(),\n revision: t.u64(),\n deleted: t.bool(),\n }\n);\nconst itemV2 = table(\n { name: 'item_v2', public: true },\n {\n id: t.u64().primaryKey(),\n value: t.string(),\n revision: t.u64(),\n }\n);\nconst spacetimedb = schema({ legacyItem, backfillSnapshot, itemV2 });\nexport default spacetimedb;\n\nexport const write_item = spacetimedb.reducer(\n { id: t.u64(), value: t.string() },\n (ctx, { id, value }) => {\n const revision = (ctx.db.legacyItem.id.find(id)?.revision ?? 0n) + 1n;\n const row = { id, value, revision, deleted: false };\n if (ctx.db.legacyItem.id.find(id)) ctx.db.legacyItem.id.update(row);\n else ctx.db.legacyItem.insert(row);\n const next = { id, value, revision };\n if (ctx.db.itemV2.id.find(id)) ctx.db.itemV2.id.update(next);\n else ctx.db.itemV2.insert(next);\n }\n);\n\nexport const seed_legacy = spacetimedb.reducer(\n { id: t.u64(), value: t.string() },\n (ctx, { id, value }) => {\n ctx.db.legacyItem.insert({ id, value, revision: 1n, deleted: false });\n }\n);\n\nexport const delete_item = spacetimedb.reducer(\n { id: t.u64() },\n (ctx, { id }) => {\n const row = ctx.db.legacyItem.id.find(id);\n if (row && !row.deleted) {\n ctx.db.legacyItem.id.update({\n ...row,\n revision: row.revision + 1n,\n deleted: true,\n });\n ctx.db.itemV2.id.delete(id);\n }\n }\n);\n\nexport const capture_batch = spacetimedb.reducer(\n { afterId: t.u64(), limit: t.u64() },\n (ctx, { afterId, limit }) => {\n if (limit === 0n || limit > 10n) throw new SenderError('invalid limit');\n const rows = [...ctx.db.legacyItem.iter()]\n .filter(r => r.id > afterId)\n .sort((a, b) => (a.id < b.id ? -1 : 1))\n .slice(0, Number(limit));\n for (const row of ctx.db.backfillSnapshot.iter())\n ctx.db.backfillSnapshot.id.delete(row.id);\n for (const row of rows) ctx.db.backfillSnapshot.insert(row);\n }\n);\n\nexport const apply_batch = spacetimedb.reducer({}, (ctx, {}) => {\n for (const snapshot of ctx.db.backfillSnapshot.iter()) {\n const r = ctx.db.legacyItem.id.find(snapshot.id);\n if (!r) throw new SenderError('missing source');\n if (r.deleted) ctx.db.itemV2.id.delete(r.id);\n else {\n const next = { id: r.id, value: r.value, revision: r.revision };\n if (ctx.db.itemV2.id.find(r.id)) ctx.db.itemV2.id.update(next);\n else ctx.db.itemV2.insert(next);\n }\n }\n});\n",{"_39":501,"_41":483,"_42":502,"_44":503,"_46":504},"t_086_incremental_totals","Incremental Totals","Write a SpacetimeDB backend module in TypeScript that maintains category totals incrementally. Return only the module source.\n\nMaintain category totals after arbitrary sale inserts, updates, moves and deletes. A category row exists exactly when its saleCount is nonzero, even if totalAmount is zero. Negative and zero sale amounts are valid. All source and aggregate changes must be atomic. This is a correctness test, not a scan-cost benchmark.\n\nTables (the first field is the primary key):\n- public sale: id: u64 (bigint), category: string, amount: i64 (bigint)\n- public category_total: category: string, totalAmount: i64 (bigint), saleCount: u64 (bigint)\n\nReducers (argument order is part of the contract):\n- set_sale(id: u64 (bigint), category: string, amount: i64 (bigint)): Insert or replace a sale. Remove its old contribution and add its new contribution. Reject empty category with 'invalid category'.\n- remove_sale(id: u64 (bigint)): Delete a sale and its contribution. Missing IDs are a no-op. Remove a category only when its last sale is deleted.\n\nDo not add an exercise reducer or seed data automatically. All operations must work for arbitrary inputs, not just one example. Failed operations must leave every table unchanged.","import { schema, table, t, SenderError } from 'spacetimedb/server';\nimport type { InferSchema, ReducerCtx } from 'spacetimedb/server';\nconst sale = table(\n { name: 'sale', public: true },\n {\n id: t.u64().primaryKey(),\n category: t.string(),\n amount: t.i64(),\n }\n);\nconst categoryTotal = table(\n { name: 'category_total', public: true },\n {\n category: t.string().primaryKey(),\n totalAmount: t.i64(),\n saleCount: t.u64(),\n }\n);\nconst spacetimedb = schema({ sale, categoryTotal });\nexport default spacetimedb;\n\nfunction adjust(\n ctx: ReducerCtx>,\n category: string,\n amount: bigint,\n adding: boolean\n) {\n const total = ctx.db.categoryTotal.category.find(category) ?? {\n category,\n totalAmount: 0n,\n saleCount: 0n,\n };\n const next = {\n category,\n totalAmount: total.totalAmount + (adding ? amount : -amount),\n saleCount: total.saleCount + (adding ? 1n : -1n),\n };\n ctx.db.categoryTotal.category.delete(category);\n if (next.saleCount > 0n) ctx.db.categoryTotal.insert(next);\n}\nexport const set_sale = spacetimedb.reducer(\n { id: t.u64(), category: t.string(), amount: t.i64() },\n (ctx, { id, category, amount }) => {\n if (!category) throw new SenderError('invalid category');\n const old = ctx.db.sale.id.find(id);\n if (old) {\n adjust(ctx, old.category, old.amount, false);\n ctx.db.sale.id.delete(id);\n }\n ctx.db.sale.insert({ id, category, amount });\n adjust(ctx, category, amount, true);\n }\n);\n\nexport const remove_sale = spacetimedb.reducer(\n { id: t.u64() },\n (ctx, { id }) => {\n const old = ctx.db.sale.id.find(id);\n if (old) {\n ctx.db.sale.id.delete(id);\n adjust(ctx, old.category, old.amount, false);\n }\n }\n);\n",{"_39":506,"_41":483,"_42":507,"_44":508,"_46":509},"t_087_webhook_ordering","Webhook Ordering","Write a SpacetimeDB backend module in TypeScript that handles out-of-order webhook events. Return only the module source.\n\nImplement POST /webhook with plain-text body account|eventId|sequence|value (exactly four fields). Account, eventId and value must be nonempty. Sequence must contain only ASCII decimal digits, fit u64, and be positive. Malformed input returns HTTP 400 body 'invalid' without any writes. Valid input returns HTTP 200. In one transaction, check the event ID globally: exact replay returns 'duplicate'; reuse with a different account, sequence or value returns 'conflict', without changes. For a new event, insert a receipt even if its sequence is stale. If sequence is greater than that account's last sequence, update state and return 'applied'; otherwise return 'stale'. Accounts advance independently. Response bodies must contain exactly those words.\n\nTables (the first field is the primary key):\n- public webhook_receipt: eventId: string, account: string, sequence: u64 (bigint), value: string\n- public webhook_account: account: string, sequence: u64 (bigint), value: string\n\nExport only the HTTP handler and router; no reducers are required.\nDo not add an exercise reducer or seed data automatically. All operations must work for arbitrary inputs, not just one example. Failed operations must leave every table unchanged.","import { schema, table, t } from 'spacetimedb/server';\nimport { Router, SyncResponse } from 'spacetimedb/server';\nconst webhookReceipt = table(\n { name: 'webhook_receipt', public: true },\n {\n eventId: t.string().primaryKey(),\n account: t.string(),\n sequence: t.u64(),\n value: t.string(),\n }\n);\nconst webhookAccount = table(\n { name: 'webhook_account', public: true },\n {\n account: t.string().primaryKey(),\n sequence: t.u64(),\n value: t.string(),\n }\n);\nconst spacetimedb = schema({ webhookReceipt, webhookAccount });\nexport default spacetimedb;\n\nexport const webhook = spacetimedb.httpHandler((ctx, request) => {\n const p = request.text().split('|');\n if (p.length !== 4 || p.some(s => !s) || !/^[0-9]+$/.test(p[2]))\n return new SyncResponse('invalid', { status: 400 });\n const sequence = BigInt(p[2]);\n if (sequence <= 0n || sequence > 18446744073709551615n)\n return new SyncResponse('invalid', { status: 400 });\n const [account, eventId, , value] = p;\n const result = ctx.withTx(tx => {\n const old = tx.db.webhookReceipt.eventId.find(eventId);\n if (old)\n return old.account === account &&\n old.sequence === sequence &&\n old.value === value\n ? 'duplicate'\n : 'conflict';\n tx.db.webhookReceipt.insert({ eventId, account, sequence, value });\n const state = tx.db.webhookAccount.account.find(account);\n if (state) {\n if (sequence <= state.sequence) return 'stale';\n tx.db.webhookAccount.account.update({ account, sequence, value });\n } else tx.db.webhookAccount.insert({ account, sequence, value });\n return 'applied';\n });\n return new SyncResponse(result);\n});\nexport const routes = spacetimedb.httpRouter(\n new Router().post('/webhook', webhook)\n);\n",{"_39":511,"_41":483,"_42":512,"_44":513,"_46":514},"t_088_lease_fencing","Lease Fencing","Write a SpacetimeDB backend module in TypeScript that leases jobs with fencing tokens. Return only the module source.\n\nImplement a leased job with monotonically increasing fencing tokens. Use the server transaction timestamp, in microseconds, for all expiry checks. A completion must match the current worker and token AND arrive before expiry. Reclaiming an expired lease increments the token. No caller-supplied current time. Workers are opaque labels in this test; authentication is tested separately.\n\nTables (the first field is the primary key):\n- public leased_job: id: u64 (bigint), worker: string, generation: u64 (bigint), expiresAt: i64 (bigint), done: bool, result: string\n\nReducers (argument order is part of the contract):\n- create_job(id: u64 (bigint)): Insert an unclaimed job: worker/result empty, generation/expiry=0, done=false.\n- claim(id: u64 (bigint), worker: string, leaseMs: u64 (bigint)): Require nonempty worker and lease_ms in 1..=60000 ('invalid lease'), existing job ('missing job'), not done ('already done'), and unclaimed or expired ('lease busy'). Increment generation, set worker and expiresAt=server_now+lease_ms*1000.\n- complete(id: u64 (bigint), worker: string, generation: u64 (bigint), result: string): Require existing job ('missing job'). Exact replay of an already successful completion is a no-op, even after expiry. Any other completion of a done job fails ('already done'). For pending jobs, require nonempty matching worker, positive matching generation and server_now {\n ctx.db.leasedJob.insert({\n id,\n worker: '',\n generation: 0n,\n expiresAt: 0n,\n done: false,\n result: '',\n });\n }\n);\n\nexport const claim = spacetimedb.reducer(\n { id: t.u64(), worker: t.string(), leaseMs: t.u64() },\n (ctx, { id, worker, leaseMs }) => {\n if (!worker || leaseMs === 0n || leaseMs > 60000n)\n throw new SenderError('invalid lease');\n const now = ctx.timestamp.microsSinceUnixEpoch;\n const row = ctx.db.leasedJob.id.find(id);\n if (!row) throw new SenderError('missing job');\n if (row.done) throw new SenderError('already done');\n if (row.worker && now < row.expiresAt) throw new SenderError('lease busy');\n ctx.db.leasedJob.id.update({\n ...row,\n worker,\n generation: row.generation + 1n,\n expiresAt: now + leaseMs * 1000n,\n });\n }\n);\n\nexport const complete = spacetimedb.reducer(\n { id: t.u64(), worker: t.string(), generation: t.u64(), result: t.string() },\n (ctx, { id, worker, generation, result }) => {\n const row = ctx.db.leasedJob.id.find(id);\n if (!row) throw new SenderError('missing job');\n if (row.done) {\n if (\n row.worker === worker &&\n row.generation === generation &&\n row.result === result\n )\n return;\n throw new SenderError('already done');\n }\n if (\n !worker ||\n generation === 0n ||\n row.worker !== worker ||\n row.generation !== generation ||\n ctx.timestamp.microsSinceUnixEpoch >= row.expiresAt\n )\n throw new SenderError('stale lease');\n ctx.db.leasedJob.id.update({ ...row, done: true, result });\n }\n);\n",{"_39":516,"_41":483,"_42":517,"_44":518,"_46":519},"t_089_cancel_reschedule","Cancel Reschedule","Write a SpacetimeDB backend module in TypeScript that manages renewable reservations with scheduled expiry. Return only the module source.\n\nImplement renewable reservations with scheduled expiry. An old timer must never expire a newer generation. Cancellation is durable and must also invalidate old timers. Do not remove old timers when renewing or cancelling: let them execute and record their outcome, which makes stale-callback behavior observable. Only the scheduler may invoke expire_reservation; external calls must be rejected. Native private-callback rejection is valid; an explicit identity guard must report 'scheduler only'.\n\nTables (the first field is the primary key):\n- public timed_reservation: id: u64 (bigint), generation: u64 (bigint), status: string\n- private expiry_job: scheduledId: u64 (bigint), scheduledAt: ScheduleAt, reservationId: u64 (bigint), generation: u64 (bigint)\n- public expiry_result: scheduledId: u64 (bigint), reservationId: u64 (bigint), generation: u64 (bigint), applied: bool\n\nReducers (argument order is part of the contract):\n- renew(id: u64 (bigint), delayMs: u64 (bigint)): Require delay_ms in 1..=60000 ('invalid delay'). Insert or update the reservation to active, increment generation (start at 1), and insert a new private expiry_job for server_now+delay_ms. Always use a one-shot ScheduleAt time.\n- cancel(id: u64 (bigint)): Missing or already cancelled is a no-op. Otherwise increment generation and set cancelled. Do not delete scheduled jobs.\n\nexpiry_job has an auto-increment primary key and schedules expire_reservation(job: ExpiryJob). The callback checks scheduler identity first. It sets expired only if the current reservation is active and has the job's generation. Insert exactly one expiry_result per executed job with whether it changed the reservation. If the job already has a result, do nothing. Never trust externally supplied callback arguments.\nDo not add an exercise reducer or seed data automatically. All operations must work for arbitrary inputs, not just one example. Failed operations must leave every table unchanged.","import { schema, table, t, SenderError } from 'spacetimedb/server';\nimport { ScheduleAt } from 'spacetimedb';\nconst timedReservation = table(\n { name: 'timed_reservation', public: true },\n {\n id: t.u64().primaryKey(),\n generation: t.u64(),\n status: t.string(),\n }\n);\nconst expiryJob = table(\n { name: 'expiry_job', scheduled: (): any => expire_reservation },\n {\n scheduledId: t.u64().primaryKey().autoInc(),\n scheduledAt: t.scheduleAt(),\n reservationId: t.u64(),\n generation: t.u64(),\n }\n);\nconst expiryResult = table(\n { name: 'expiry_result', public: true },\n {\n scheduledId: t.u64().primaryKey(),\n reservationId: t.u64(),\n generation: t.u64(),\n applied: t.bool(),\n }\n);\nconst spacetimedb = schema({ timedReservation, expiryJob, expiryResult });\nexport default spacetimedb;\n\nexport const renew = spacetimedb.reducer(\n { id: t.u64(), delayMs: t.u64() },\n (ctx, { id, delayMs }) => {\n if (delayMs === 0n || delayMs > 60000n)\n throw new SenderError('invalid delay');\n const generation =\n (ctx.db.timedReservation.id.find(id)?.generation ?? 0n) + 1n;\n const next = { id, generation, status: 'active' };\n if (ctx.db.timedReservation.id.find(id))\n ctx.db.timedReservation.id.update(next);\n else ctx.db.timedReservation.insert(next);\n ctx.db.expiryJob.insert({\n scheduledId: 0n,\n scheduledAt: ScheduleAt.time(\n ctx.timestamp.microsSinceUnixEpoch + delayMs * 1000n\n ),\n reservationId: id,\n generation,\n });\n }\n);\n\nexport const cancel = spacetimedb.reducer({ id: t.u64() }, (ctx, { id }) => {\n const row = ctx.db.timedReservation.id.find(id);\n if (row && row.status !== 'cancelled')\n ctx.db.timedReservation.id.update({\n ...row,\n generation: row.generation + 1n,\n status: 'cancelled',\n });\n});\n\nexport const expire_reservation = spacetimedb.reducer(\n { job: expiryJob.rowType },\n (ctx, { job }) => {\n if (!ctx.sender.isEqual(ctx.databaseIdentity))\n throw new SenderError('scheduler only');\n if (ctx.db.expiryResult.scheduledId.find(job.scheduledId)) return;\n const row = ctx.db.timedReservation.id.find(job.reservationId);\n const applied =\n !!row && row.status === 'active' && row.generation === job.generation;\n if (applied)\n ctx.db.timedReservation.id.update({ ...row!, status: 'expired' });\n ctx.db.expiryResult.insert({\n scheduledId: job.scheduledId,\n reservationId: job.reservationId,\n generation: job.generation,\n applied,\n });\n }\n);\n",{"_39":521,"_41":483,"_42":522,"_44":523,"_46":524},"t_090_transactional_quota","Transactional Quota","Write a SpacetimeDB backend module in TypeScript that enforces a per-identity transactional quota. Return only the module source.\n\nImplement a per-identity lifetime quota of 3 accepted units. The sender, not a caller-supplied identity, owns each request. This is a transaction/quota test, not a timed-window rate limiter. Invalid requests and failed transactions must not consume quota or reserve request IDs. Exact replay is a no-op; changing owner or amount for an existing request ID is a conflict.\n\nTables (the first field is the primary key):\n- public quota: owner: Identity, used: u64 (bigint)\n- public accepted_request: requestId: string, owner: Identity, units: u64 (bigint)\n\nReducers (argument order is part of the contract):\n- submit(requestId: string, units: i64 (bigint)): If request ID exists, identical owner+units returns success; otherwise fail 'request conflict'. For new IDs, require nonempty request ID and units>0 ('invalid request'). Require used+units<=3 ('quota exceeded'), starting at used=0. Insert request and update quota atomically.\n\nDo not add an exercise reducer or seed data automatically. All operations must work for arbitrary inputs, not just one example. Failed operations must leave every table unchanged.","import { schema, table, t, SenderError } from 'spacetimedb/server';\n\nconst quota = table(\n { name: 'quota', public: true },\n {\n owner: t.identity().primaryKey(),\n used: t.u64(),\n }\n);\nconst acceptedRequest = table(\n { name: 'accepted_request', public: true },\n {\n requestId: t.string().primaryKey(),\n owner: t.identity(),\n units: t.u64(),\n }\n);\nconst spacetimedb = schema({ quota, acceptedRequest });\nexport default spacetimedb;\n\nexport const submit = spacetimedb.reducer(\n { requestId: t.string(), units: t.i64() },\n (ctx, { requestId, units }) => {\n const owner = ctx.sender,\n old = ctx.db.acceptedRequest.requestId.find(requestId);\n if (old) {\n if (old.owner.isEqual(owner) && old.units === units) return;\n throw new SenderError('request conflict');\n }\n if (!requestId || units <= 0n) throw new SenderError('invalid request');\n const used = ctx.db.quota.owner.find(owner)?.used ?? 0n;\n if (units > 3n - used) throw new SenderError('quota exceeded');\n const next = { owner, used: used + units };\n if (ctx.db.quota.owner.find(owner)) ctx.db.quota.owner.update(next);\n else ctx.db.quota.insert(next);\n ctx.db.acceptedRequest.insert({ requestId, owner, units });\n }\n);\n",{"_39":526,"_41":483,"_42":527,"_44":528,"_46":529},"t_091_scheduled_queue","Scheduled Queue","Write a SpacetimeDB backend module in TypeScript that runs a scheduled job queue with durable completion state. Return only the module source.\n\nImplement a scheduled job queue with durable completion state. A failed job must not stop other jobs. A business failure (negative input) is recorded as failed; it must not throw and lose its status. Duplicate submissions must not run a job twice. The scheduled callback must reject direct external calls. Native private-callback rejection is valid; an explicit identity guard must report 'scheduler only'.\n\nTables (the first field is the primary key):\n- public queued_work: id: u64 (bigint), input: i64 (bigint), status: string, attempts: u64 (bigint)\n- public work_effect: id: u64 (bigint), value: i64 (bigint)\n- private work_timer: scheduledId: u64 (bigint), scheduledAt: ScheduleAt, workId: u64 (bigint)\n\nReducers (argument order is part of the contract):\n- enqueue(id: u64 (bigint), input: i64 (bigint)): Exact existing id+input is a no-op even after completion or failure. Changed input fails 'request conflict'. New input must be within -1000000..=1000000 ('invalid input'). Insert queued_work with status='queued', attempts=0, and one timer due after 1ms.\n\nwork_timer uses an auto-increment primary key and schedules execute_work(job: WorkTimer). For a queued job only, increment attempts once; negative input sets status='failed' without an effect. Otherwise insert work_effect(id,input*2) and set status='complete' in the same transaction. Missing or already terminal jobs are no-ops. Do not delete queued_work rows.\nDo not add an exercise reducer or seed data automatically. All operations must work for arbitrary inputs, not just one example. Failed operations must leave every table unchanged.","import { schema, table, t, SenderError } from 'spacetimedb/server';\nimport { ScheduleAt } from 'spacetimedb';\nconst queuedWork = table(\n { name: 'queued_work', public: true },\n {\n id: t.u64().primaryKey(),\n input: t.i64(),\n status: t.string(),\n attempts: t.u64(),\n }\n);\nconst workEffect = table(\n { name: 'work_effect', public: true },\n {\n id: t.u64().primaryKey(),\n value: t.i64(),\n }\n);\nconst workTimer = table(\n { name: 'work_timer', scheduled: (): any => execute_work },\n {\n scheduledId: t.u64().primaryKey().autoInc(),\n scheduledAt: t.scheduleAt(),\n workId: t.u64(),\n }\n);\nconst spacetimedb = schema({ queuedWork, workEffect, workTimer });\nexport default spacetimedb;\n\nexport const enqueue = spacetimedb.reducer(\n { id: t.u64(), input: t.i64() },\n (ctx, { id, input }) => {\n const old = ctx.db.queuedWork.id.find(id);\n if (old) {\n if (old.input === input) return;\n throw new SenderError('request conflict');\n }\n if (input < -1000000n || input > 1000000n)\n throw new SenderError('invalid input');\n ctx.db.queuedWork.insert({ id, input, status: 'queued', attempts: 0n });\n ctx.db.workTimer.insert({\n scheduledId: 0n,\n scheduledAt: ScheduleAt.time(ctx.timestamp.microsSinceUnixEpoch + 1000n),\n workId: id,\n });\n }\n);\n\nexport const execute_work = spacetimedb.reducer(\n { job: workTimer.rowType },\n (ctx, { job }) => {\n if (!ctx.sender.isEqual(ctx.databaseIdentity))\n throw new SenderError('scheduler only');\n const row = ctx.db.queuedWork.id.find(job.workId);\n if (!row || row.status !== 'queued') return;\n if (row.input >= 0n)\n ctx.db.workEffect.insert({ id: row.id, value: row.input * 2n });\n ctx.db.queuedWork.id.update({\n ...row,\n attempts: row.attempts + 1n,\n status: row.input < 0n ? 'failed' : 'complete',\n });\n }\n);\n",{"_39":531,"_41":483,"_42":532,"_44":533,"_46":534},"t_092_procedure_cache","Procedure Cache","Write a SpacetimeDB backend module in TypeScript that caches an external service in a procedure. Return only the module source.\n\nImplement a persistent cache for an external text-generating service. Cache identity is the exact (product, language) pair, NOT TTL or URL, and must not collide when either string contains punctuation. Procedure fetch_cached(product:string, language:string, ttl_ms:u64, url:string) returns a string. If product/language is empty or ttl_ms>60000, return 'invalid input' without HTTP or writes. For ttl_ms>0, return a nonexpired cached value without HTTP. Expired/missing entries cause one HTTP GET to url outside a transaction. On HTTP/network failure return 'upstream error' without changing the cache. On HTTP 200, cache the complete response text with expiry server_now+ttl_ms*1000, and return it. ttl_ms=0 always fetches but never reads or changes cache rows. Use the server clock. Requests in this test are sequential; request coalescing is not required.\n\nTables (the first field is the primary key):\n- public cache_entry: id: u64 (bigint), product: string, language: string, value: string, expiresAt: i64 (bigint)\n\ncache_entry.id is auto-increment. At most one row may exist per exact product/language pair; update expired rows instead of accumulating duplicates. No cache seed reducers. GET endpoints are controlled local test servers.\nDo not add an exercise reducer or seed data automatically. All operations must work for arbitrary inputs, not just one example. Failed operations must leave every table unchanged.","import { schema, table, t } from 'spacetimedb/server';\n\nconst cacheEntry = table(\n { name: 'cache_entry', public: true },\n {\n id: t.u64().primaryKey().autoInc(),\n product: t.string(),\n language: t.string(),\n value: t.string(),\n expiresAt: t.i64(),\n }\n);\nconst spacetimedb = schema({ cacheEntry });\nexport default spacetimedb;\n\nexport const fetch_cached = spacetimedb.procedure(\n {\n product: t.string(),\n language: t.string(),\n ttlMs: t.u64(),\n url: t.string(),\n },\n t.string(),\n (ctx, { product, language, ttlMs, url }) => {\n if (!product || !language || ttlMs > 60000n) return 'invalid input';\n const now = ctx.timestamp.microsSinceUnixEpoch;\n if (ttlMs > 0n) {\n const cached = ctx.withTx(tx =>\n [...tx.db.cacheEntry.iter()].find(\n r =>\n r.product === product &&\n r.language === language &&\n r.expiresAt > now\n )\n );\n if (cached) return cached.value;\n }\n let value: string;\n try {\n const response = ctx.http.fetch(url);\n if (response.status !== 200) return 'upstream error';\n value = response.text();\n } catch {\n return 'upstream error';\n }\n if (ttlMs > 0n)\n ctx.withTx(tx => {\n const old = [...tx.db.cacheEntry.iter()].find(\n r => r.product === product && r.language === language\n );\n const next = {\n id: old?.id ?? 0n,\n product,\n language,\n value,\n expiresAt: tx.timestamp.microsSinceUnixEpoch + ttlMs * 1000n,\n };\n if (old) tx.db.cacheEntry.id.update(next);\n else tx.db.cacheEntry.insert(next);\n });\n return value;\n }\n);\n",{"_39":536,"_41":483,"_42":537,"_44":538,"_46":539},"t_093_permission_revocation","Permission Revocation","Write a SpacetimeDB backend module in TypeScript that shares a private document with revocable permissions. Return only the module source.\n\nImplement one shared private document (ID 1). Its first writer becomes its permanent owner. Only that owner can change its text or reader permissions. Authorized users can query and subscribe to a safe projection. Revocation must remove the document from an existing reader subscription and block future content updates. Do not use row-level security. Keep both source tables private and never expose secretBody in the public view.\n\nTables (the first field is the primary key):\n- private private_document: id: u64 (bigint), owner: Identity, title: string, secretBody: string\n- private read_access: reader: Identity, enabled: bool\n\nReducers (argument order is part of the contract):\n- set_document(title: string, secretBody: string): Create document ID 1 with sender as owner, or update it if sender is owner. Any other sender fails 'owner only'. Preserve ownership.\n- set_access(reader: Identity, enabled: bool): Require an existing document whose owner is sender ('owner only'). Insert or update the reader's permission. Disabling a reader does not remove the owner's own access.\n\nDefine SafeDocument with id:u64 and title:string only. Public sender-aware view visible_document returns an array of SafeDocument: the single document when sender is owner or read_access[sender].enabled is true, otherwise empty. Use indexed lookups so permission changes are tracked as view dependencies. Do not add public source tables or diagnostic reducers.\nDo not add an exercise reducer or seed data automatically. All operations must work for arbitrary inputs, not just one example. Failed operations must leave every table unchanged.","import { schema, table, t, SenderError } from 'spacetimedb/server';\n\nconst privateDocument = table(\n { name: 'private_document' },\n {\n id: t.u64().primaryKey(),\n owner: t.identity(),\n title: t.string(),\n secretBody: t.string(),\n }\n);\nconst readAccess = table(\n { name: 'read_access' },\n {\n reader: t.identity().primaryKey(),\n enabled: t.bool(),\n }\n);\nconst spacetimedb = schema({ privateDocument, readAccess });\nexport default spacetimedb;\n\nexport const set_document = spacetimedb.reducer(\n { title: t.string(), secretBody: t.string() },\n (ctx, { title, secretBody }) => {\n const row = ctx.db.privateDocument.id.find(1n);\n if (row) {\n if (!row.owner.isEqual(ctx.sender)) throw new SenderError('owner only');\n ctx.db.privateDocument.id.update({ ...row, title, secretBody });\n } else\n ctx.db.privateDocument.insert({\n id: 1n,\n owner: ctx.sender,\n title,\n secretBody,\n });\n }\n);\n\nexport const set_access = spacetimedb.reducer(\n { reader: t.identity(), enabled: t.bool() },\n (ctx, { reader, enabled }) => {\n const row = ctx.db.privateDocument.id.find(1n);\n if (!row || !row.owner.isEqual(ctx.sender))\n throw new SenderError('owner only');\n const access = { reader, enabled };\n if (ctx.db.readAccess.reader.find(reader))\n ctx.db.readAccess.reader.update(access);\n else ctx.db.readAccess.insert(access);\n }\n);\n\nconst SafeDocument = t.row('SafeDocument', { id: t.u64(), title: t.string() });\nexport const visible_document = spacetimedb.view(\n { name: 'visible_document', public: true },\n t.array(SafeDocument),\n ctx => {\n const row = ctx.db.privateDocument.id.find(1n);\n const allowed = ctx.db.readAccess.reader.find(ctx.sender)?.enabled ?? false;\n return row && (row.owner.isEqual(ctx.sender) || allowed)\n ? [{ id: row.id, title: row.title }]\n : [];\n }\n);\n",{"_39":541,"_41":483,"_42":542,"_44":543,"_46":544},"t_094_multi_session_presence","Multi Session Presence","Write a SpacetimeDB backend module in TypeScript that tracks presence across multiple sessions. Return only the module source.\n\nTrack real connection lifecycle events. One identity may have multiple simultaneous connections. Disconnecting one connection must not mark its other connections offline. Reconnect must rebuild presence without leaving stale sessions. Do not add seed or exercise reducers. The grader opens actual WebSockets with shared and distinct credentials.\n\nTables (the first field is the primary key):\n- public live_session: connectionId: ConnectionId, owner: Identity\n- public online_user: owner: Identity, connections: u64 (bigint)\n\nWhen a client connects, insert a live_session using its connection ID and identity, and increment that identity's online_user count (insert at 1). When a client disconnects, remove exactly that connection if it exists, decrement its owner's count, and delete online_user only when the count reaches zero. A missing session is a no-op. Both changes are transactional.\nDo not add an exercise reducer or seed data automatically. All operations must work for arbitrary inputs, not just one example. Failed operations must leave every table unchanged.","import { schema, table, t, SenderError } from 'spacetimedb/server';\n\nconst liveSession = table(\n { name: 'live_session', public: true },\n {\n connectionId: t.connectionId().primaryKey(),\n owner: t.identity(),\n }\n);\nconst onlineUser = table(\n { name: 'online_user', public: true },\n {\n owner: t.identity().primaryKey(),\n connections: t.u64(),\n }\n);\nconst spacetimedb = schema({ liveSession, onlineUser });\nexport default spacetimedb;\n\nexport const clientConnected = spacetimedb.clientConnected(ctx => {\n const connectionId = ctx.connectionId;\n if (!connectionId) throw new SenderError('connection missing');\n const owner = ctx.sender;\n ctx.db.liveSession.insert({ connectionId, owner });\n const row = ctx.db.onlineUser.owner.find(owner);\n if (row)\n ctx.db.onlineUser.owner.update({\n ...row,\n connections: row.connections + 1n,\n });\n else ctx.db.onlineUser.insert({ owner, connections: 1n });\n});\nexport const clientDisconnected = spacetimedb.clientDisconnected(ctx => {\n const connectionId = ctx.connectionId;\n if (!connectionId) throw new SenderError('connection missing');\n const session = ctx.db.liveSession.connectionId.find(connectionId);\n if (!session) return;\n ctx.db.liveSession.connectionId.delete(connectionId);\n const row = ctx.db.onlineUser.owner.find(session.owner);\n if (row) {\n if (row.connections === 1n) ctx.db.onlineUser.owner.delete(session.owner);\n else\n ctx.db.onlineUser.owner.update({\n ...row,\n connections: row.connections - 1n,\n });\n }\n});\n","routes/_marketing","actionData","errors"]

LLM Benchmarks

Evals

basics

schema

queries

data modeling

auth

tables

reducers

views

lifecycle

procedures

migrations

advanced