mirror of
https://github.com/djdevin/recflare.git
synced 2026-09-08 14:41:28 -07:00
1256 lines
52 KiB
TypeScript
1256 lines
52 KiB
TypeScript
import { adminSecretsStore, env, SELF } from 'cloudflare:test'
|
|
import { beforeAll, describe, expect, it } from 'vitest'
|
|
|
|
import '../../rooms.app'
|
|
|
|
import {
|
|
createRoomInstance,
|
|
getRoomInstance,
|
|
PRESENCE_SCHEMA_DDL,
|
|
ROOM_INSTANCE_SCHEMA_DDL,
|
|
ROOM_SCHEMA_DDL,
|
|
} from '@repo/domain'
|
|
|
|
import importRooms from '../../../static/ImportRooms.json'
|
|
|
|
import type { Env } from '../../context'
|
|
|
|
declare module 'cloudflare:test' {
|
|
interface ProvidedEnv extends Env {}
|
|
}
|
|
|
|
const ORIGIN = 'https://example.com'
|
|
|
|
// Mint a token the way the `auth` worker does, signing with the shared test key seeded into the JWT_SECRET store.
|
|
const TEST_SECRET = 'test-signing-key'
|
|
function b64url(input: ArrayBuffer | string): string {
|
|
const bytes = typeof input === 'string' ? new TextEncoder().encode(input) : new Uint8Array(input)
|
|
let binary = ''
|
|
for (const byte of bytes) binary += String.fromCharCode(byte)
|
|
return btoa(binary).replace(/\+/g, '-').replace(/\//g, '_').replace(/=+$/, '')
|
|
}
|
|
async function bearer(sub: string): Promise<Record<string, string>> {
|
|
const now = Math.floor(Date.now() / 1000)
|
|
const signingInput = `${b64url(JSON.stringify({ alg: 'HS256', typ: 'JWT' }))}.${b64url(
|
|
JSON.stringify({ sub, exp: now + 3600 })
|
|
)}`
|
|
const key = await crypto.subtle.importKey(
|
|
'raw',
|
|
new TextEncoder().encode(TEST_SECRET),
|
|
{ name: 'HMAC', hash: 'SHA-256' },
|
|
false,
|
|
['sign']
|
|
)
|
|
const sig = await crypto.subtle.sign('HMAC', key, new TextEncoder().encode(signingInput))
|
|
return { Authorization: `Bearer ${signingInput}.${b64url(sig)}` }
|
|
}
|
|
|
|
// Apply the schema + seed the imported rooms into the test D1 (mirrors the migrations).
|
|
beforeAll(async () => {
|
|
// Seed the shared JWT signing key into the local Secrets Store so .get() resolves.
|
|
await adminSecretsStore(env.JWT_SECRET).create('test-signing-key')
|
|
for (const stmt of ROOM_SCHEMA_DDL) await env.DB.prepare(stmt).run()
|
|
for (const stmt of ROOM_INSTANCE_SCHEMA_DDL) await env.DB.prepare(stmt).run()
|
|
// Presence table (read by the photon access-token handler).
|
|
for (const stmt of PRESENCE_SCHEMA_DDL) await env.DB.prepare(stmt).run()
|
|
const insert = env.DB.prepare('INSERT OR IGNORE INTO room (data) VALUES (?1)')
|
|
await env.DB.batch(importRooms.map((r) => insert.bind(JSON.stringify(r))))
|
|
})
|
|
|
|
describe('rooms endpoints', () => {
|
|
it('GET / reports service status', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/`)
|
|
expect(res.status).toBe(200)
|
|
expect(await res.json()).toEqual({ service: 'rooms', status: 'ok' })
|
|
})
|
|
|
|
it('GET /rooms/1 returns the seeded dorm with its SubRoom scene', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/1?include=1325`)
|
|
expect(res.status).toBe(200)
|
|
const body = (await res.json()) as {
|
|
RoomId: number
|
|
Name: string
|
|
IsDorm: boolean
|
|
SubRooms: Array<{ UnitySceneId: string }>
|
|
}
|
|
expect(body).toMatchObject({ RoomId: 1, Name: 'DormRoom', IsDorm: true })
|
|
expect(body.SubRooms[0].UnitySceneId).toBe('76d98498-60a1-430c-ab76-b54a29b7a163')
|
|
})
|
|
|
|
it('GET /rooms/:id 404s for a room not in D1', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/99999`)
|
|
expect(res.status).toBe(404)
|
|
})
|
|
|
|
it('GET /rooms?name= resolves a real room case-insensitively', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms?name=reccenter`)
|
|
expect(res.status).toBe(200)
|
|
expect(await res.json()).toMatchObject({ Name: 'RecCenter' })
|
|
})
|
|
|
|
it('GET /rooms?name= returns {} when nothing matches', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms?name=NoSuchRoomHere`)
|
|
expect(await res.json()).toEqual({})
|
|
})
|
|
|
|
it('GET /rooms with no id or name returns 400', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms`)
|
|
expect(res.status).toBe(400)
|
|
})
|
|
|
|
it('GET /rooms/bulk?id= returns the matching rooms', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/bulk?id=1,2`)
|
|
expect(res.status).toBe(200)
|
|
const body = (await res.json()) as Array<{ RoomId: number; Name: string }>
|
|
expect(body.map((r) => r.Name).sort()).toEqual(['DormRoom', 'RecCenter'])
|
|
})
|
|
|
|
it('GET /rooms/bulk?name=RecCenter returns [RecCenter]', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/bulk?name=RecCenter`)
|
|
const body = (await res.json()) as Array<{ Name: string }>
|
|
expect(body.map((r) => r.Name)).toEqual(['RecCenter'])
|
|
})
|
|
|
|
it('GET /rooms/ownedby/me is auth-gated and scoped to the caller', async () => {
|
|
// No token → 401, no stub-account fallback (would otherwise leak account 1).
|
|
const noAuth = await SELF.fetch(`${ORIGIN}/rooms/ownedby/me`)
|
|
expect(noAuth.status).toBe(401)
|
|
// Account 1 owns all the seeded rooms, but the dorm is excluded here.
|
|
const mine = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/ownedby/me`, { headers: await bearer('1') })
|
|
).json()) as Array<{ RoomId: number; IsDorm?: boolean }>
|
|
expect(mine.length).toBe(importRooms.filter((r) => r.IsDorm !== true).length)
|
|
// The dorm (RoomId 1) is auto-provisioned, so it never appears.
|
|
expect(mine.some((r) => r.RoomId === 1 || r.IsDorm === true)).toBe(false)
|
|
// A different account owns none of them.
|
|
const other = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/ownedby/me`, { headers: await bearer('999') })
|
|
).json()) as unknown[]
|
|
expect(other).toEqual([])
|
|
})
|
|
|
|
it('GET /rooms/ownedby/:id returns an account public rooms (no auth)', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/ownedby/1`)
|
|
expect(res.status).toBe(200)
|
|
const body = (await res.json()) as Array<{
|
|
RoomId: number
|
|
Accessibility: number
|
|
IsDorm?: boolean
|
|
CreatorAccountId: number
|
|
}>
|
|
expect(body.length).toBeGreaterThan(0)
|
|
// Only public, non-dorm rooms owned by account 1 — the private dorm (RoomId 1)
|
|
// is excluded.
|
|
expect(
|
|
body.every((r) => r.Accessibility === 1 && r.IsDorm !== true && r.CreatorAccountId === 1)
|
|
).toBe(true)
|
|
expect(body.some((r) => r.RoomId === 1)).toBe(false)
|
|
|
|
// An account that owns no public rooms → empty array.
|
|
expect(await (await SELF.fetch(`${ORIGIN}/rooms/ownedby/999`)).json()).toEqual([])
|
|
})
|
|
|
|
it('GET /rooms/search returns a paginated { Results, TotalResults }', async () => {
|
|
// Name-term search resolves a known public room.
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/search?query=reccenter&skip=0&take=100`)
|
|
expect(res.status).toBe(200)
|
|
const body = (await res.json()) as { Results: Array<{ Name: string }>; TotalResults: number }
|
|
expect(body.TotalResults).toBeGreaterThanOrEqual(1)
|
|
expect(body.Results.some((r) => r.Name === 'RecCenter')).toBe(true)
|
|
})
|
|
|
|
it('GET /rooms/search excludes dorms and respects pagination shape', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/search?query=dormroom`)
|
|
expect(res.status).toBe(200)
|
|
const body = (await res.json()) as { Results: unknown[]; TotalResults: number }
|
|
// The dorm is non-public/dorm, so a name search for it returns nothing.
|
|
expect(body).toEqual({ Results: [], TotalResults: 0 })
|
|
})
|
|
|
|
it('GET /rooms/search?query=#tag returns 200 (tag search)', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/search?query=%23Quest+%23recroomoriginal`)
|
|
expect(res.status).toBe(200)
|
|
const body = (await res.json()) as { Results: unknown[]; TotalResults: number }
|
|
expect(Array.isArray(body.Results)).toBe(true)
|
|
expect(typeof body.TotalResults).toBe('number')
|
|
})
|
|
|
|
it('GET /rooms/search aliases #recroomoriginal to the rro tag', async () => {
|
|
// Rooms are tagged `rro`, not `recroomoriginal` — the alias bridges them.
|
|
const aliased = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/search?query=%23recroomoriginal`)
|
|
).json()) as { TotalResults: number }
|
|
const direct = (await (await SELF.fetch(`${ORIGIN}/rooms/search?query=%23rro`)).json()) as {
|
|
TotalResults: number
|
|
}
|
|
expect(aliased.TotalResults).toBe(direct.TotalResults)
|
|
expect(aliased.TotalResults).toBeGreaterThan(0)
|
|
})
|
|
|
|
it('GET /rooms/favoritedby/me returns a bare array of the caller favorited rooms (auth-scoped)', async () => {
|
|
const headers = await bearer('777')
|
|
|
|
// Auth-gated — no token is a 401, never account 1's favorites.
|
|
expect((await SELF.fetch(`${ORIGIN}/rooms/favoritedby/me`)).status).toBe(401)
|
|
|
|
// No favorites yet → empty array.
|
|
const empty = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/favoritedby/me`, { headers })
|
|
).json()) as unknown[]
|
|
expect(empty).toEqual([])
|
|
|
|
// Favorite two real rooms, then they come back.
|
|
for (const id of [2, 12]) {
|
|
await SELF.fetch(`${ORIGIN}/rooms/${id}/interactionby/me/favorite`, {
|
|
method: 'PUT',
|
|
headers,
|
|
})
|
|
}
|
|
const body = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/favoritedby/me?skip=0&take=100`, { headers })
|
|
).json()) as Array<{ RoomId: number }>
|
|
expect(body.map((r) => r.RoomId).sort((a, b) => a - b)).toEqual([2, 12])
|
|
|
|
// Un-favoriting one drops it from the list.
|
|
await SELF.fetch(`${ORIGIN}/rooms/2/interactionby/me/favorite`, { method: 'PUT', headers })
|
|
const afterUnfav = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/favoritedby/me`, { headers })
|
|
).json()) as Array<{ RoomId: number }>
|
|
expect(afterUnfav.map((r) => r.RoomId)).toEqual([12])
|
|
|
|
// Scoped per player — a different account sees none.
|
|
const other = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/favoritedby/me`, { headers: await bearer('778') })
|
|
).json()) as unknown[]
|
|
expect(other).toEqual([])
|
|
})
|
|
|
|
it('GET /rooms/visitedby/me returns a bare array of rooms the caller has interacted with (auth-scoped)', async () => {
|
|
const headers = await bearer('779')
|
|
|
|
// No interactions yet → empty array.
|
|
const empty = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/visitedby/me`, { headers })
|
|
).json()) as unknown[]
|
|
expect(empty).toEqual([])
|
|
|
|
// Interacting (cheer/favorite) records a last-visit on those rooms.
|
|
await SELF.fetch(`${ORIGIN}/rooms/2/interactionby/me/cheer`, { method: 'PUT', headers })
|
|
await SELF.fetch(`${ORIGIN}/rooms/12/interactionby/me/favorite`, { method: 'PUT', headers })
|
|
|
|
const body = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/visitedby/me?skip=0&take=100`, { headers })
|
|
).json()) as Array<{ RoomId: number }>
|
|
expect(body.map((r) => r.RoomId).sort((a, b) => a - b)).toEqual([2, 12])
|
|
|
|
// Un-cheering still counts as visited (the interaction row persists).
|
|
await SELF.fetch(`${ORIGIN}/rooms/2/interactionby/me/cheer`, { method: 'PUT', headers })
|
|
const afterUncheer = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/visitedby/me`, { headers })
|
|
).json()) as unknown[]
|
|
expect(afterUncheer.length).toBe(2)
|
|
|
|
// Scoped per player — a different account sees none.
|
|
const other = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/visitedby/me`, { headers: await bearer('780') })
|
|
).json()) as unknown[]
|
|
expect(other).toEqual([])
|
|
})
|
|
|
|
it('GET /rooms/hot returns a paginated { Results, TotalResults } of public rooms', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/hot?skip=0&take=100`)
|
|
expect(res.status).toBe(200)
|
|
const body = (await res.json()) as {
|
|
Results: Array<{ RoomId: number; IsDorm?: boolean }>
|
|
TotalResults: number
|
|
}
|
|
expect(body.Results.length).toBeGreaterThan(0)
|
|
expect(body.TotalResults).toBeGreaterThanOrEqual(body.Results.length)
|
|
// The dorm (RoomId 1) is non-public, so it's never in the feed.
|
|
expect(body.Results.some((r) => r.RoomId === 1 || r.IsDorm === true)).toBe(false)
|
|
})
|
|
|
|
it('GET /rooms/hot?tag=rro filters to rro-tagged rooms', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/hot?tag=rro&skip=0&take=100`)
|
|
expect(res.status).toBe(200)
|
|
const body = (await res.json()) as {
|
|
Results: Array<{ Name: string; Tags?: Array<{ Tag: string }> }>
|
|
TotalResults: number
|
|
}
|
|
expect(body.Results.length).toBeGreaterThan(0)
|
|
// Every result carries the rro tag, and a known rro room is present.
|
|
expect(body.Results.every((r) => (r.Tags ?? []).some((t) => t.Tag === 'rro'))).toBe(true)
|
|
expect(body.Results.some((r) => r.Name === 'RecCenter')).toBe(true)
|
|
})
|
|
|
|
it('GET /rooms/hot respects take pagination (TotalResults is the full count)', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/hot?tag=rro&skip=0&take=2`)
|
|
const body = (await res.json()) as { Results: unknown[]; TotalResults: number }
|
|
expect(body.Results.length).toBeLessThanOrEqual(2)
|
|
expect(body.TotalResults).toBeGreaterThan(body.Results.length)
|
|
})
|
|
|
|
it('GET /rooms/hot aliases #recroomoriginal to the rro tag', async () => {
|
|
const aliased = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/hot?tag=recroomoriginal`)
|
|
).json()) as { TotalResults: number }
|
|
const direct = (await (await SELF.fetch(`${ORIGIN}/rooms/hot?tag=rro`)).json()) as {
|
|
TotalResults: number
|
|
}
|
|
expect(aliased.TotalResults).toBe(direct.TotalResults)
|
|
expect(aliased.TotalResults).toBeGreaterThan(0)
|
|
})
|
|
|
|
it('GET /rooms/base returns a bare array of base/template rooms (incl. non-public)', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/base`)
|
|
expect(res.status).toBe(200)
|
|
const body = (await res.json()) as Array<{
|
|
RoomId: number
|
|
Accessibility: number
|
|
Tags?: Array<{ Tag: string }>
|
|
}>
|
|
expect(Array.isArray(body)).toBe(true)
|
|
expect(body.length).toBeGreaterThan(0)
|
|
// Every result carries the `base` tag.
|
|
expect(body.every((r) => (r.Tags ?? []).some((t) => t.Tag === 'base'))).toBe(true)
|
|
// Includes rooms that aren't publicly listed (Accessibility != 1) — base
|
|
// rooms bypass the public filter the feeds use.
|
|
expect(body.some((r) => r.Accessibility !== 1)).toBe(true)
|
|
})
|
|
|
|
it('GET /rooms/base respects take pagination', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/base?skip=0&take=5`)
|
|
const body = (await res.json()) as unknown[]
|
|
expect(body.length).toBeLessThanOrEqual(5)
|
|
})
|
|
|
|
it('GET /rooms/recommendations returns a bare array of public rooms (split-test params ignored)', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/recommendations?splitTestId=1&splitTestValue=5`)
|
|
expect(res.status).toBe(200)
|
|
const body = (await res.json()) as Array<{ RoomId: number; IsDorm?: boolean }>
|
|
expect(Array.isArray(body)).toBe(true)
|
|
expect(body.length).toBeGreaterThan(0)
|
|
// The dorm (RoomId 1) is non-public, so it's never recommended.
|
|
expect(body.some((r) => r.RoomId === 1 || r.IsDorm === true)).toBe(false)
|
|
|
|
// The split-test params don't change the result.
|
|
const plain = (await (await SELF.fetch(`${ORIGIN}/rooms/recommendations`)).json()) as Array<{
|
|
RoomId: number
|
|
}>
|
|
expect(plain.map((r) => r.RoomId)).toEqual(body.map((r) => r.RoomId))
|
|
})
|
|
|
|
it('GET /rooms/recommendations respects take pagination', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/recommendations?skip=0&take=3`)
|
|
const body = (await res.json()) as unknown[]
|
|
expect(body.length).toBeLessThanOrEqual(3)
|
|
})
|
|
|
|
it('GET /featuredrooms/current returns a featured-room group of public rooms', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/featuredrooms/current`)
|
|
expect(res.status).toBe(200)
|
|
const body = (await res.json()) as {
|
|
FeaturedRoomGroupId: number
|
|
name: string
|
|
StartAt: string
|
|
EndAt: string
|
|
Rooms: Array<{ RoomId: number; RoomName: string; ImageName: string }>
|
|
}
|
|
expect(body.FeaturedRoomGroupId).toBe(1)
|
|
expect(body.name).toBe('Featured Rooms')
|
|
expect(body.Rooms.length).toBeGreaterThan(0)
|
|
// Compact projection carries name + image, not the full room blob.
|
|
expect(body.Rooms.every((r) => typeof r.RoomName === 'string')).toBe(true)
|
|
// The dorm (RoomId 1) is non-public, so it's never featured.
|
|
expect(body.Rooms.some((r) => r.RoomId === 1)).toBe(false)
|
|
})
|
|
|
|
it('GET /rooms/:id/similar returns { Results, TotalResults } of tag-sharing rooms (excluding self)', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/2/similar`)
|
|
expect(res.status).toBe(200)
|
|
const body = (await res.json()) as {
|
|
Results: Array<{ RoomId: number; Tags?: Array<{ Tag: string }> }>
|
|
TotalResults: number
|
|
}
|
|
expect(body.Results.length).toBeGreaterThan(0)
|
|
expect(body.TotalResults).toBeGreaterThanOrEqual(body.Results.length)
|
|
// Never includes the target room itself.
|
|
expect(body.Results.some((r) => r.RoomId === 2)).toBe(false)
|
|
// Every result shares the `rro` tag RecCenter (room 2) carries.
|
|
expect(body.Results.every((r) => (r.Tags ?? []).some((t) => t.Tag === 'rro'))).toBe(true)
|
|
})
|
|
|
|
it('GET /rooms/:id/similar respects take pagination', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/2/similar?skip=0&take=3`)
|
|
const body = (await res.json()) as { Results: unknown[]; TotalResults: number }
|
|
expect(body.Results.length).toBeLessThanOrEqual(3)
|
|
expect(body.TotalResults).toBeGreaterThan(body.Results.length)
|
|
})
|
|
|
|
it('GET /rooms/:id/similar returns an empty result for a room not in D1', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/99999/similar`)
|
|
expect(res.status).toBe(200)
|
|
expect(await res.json()).toEqual({ Results: [], TotalResults: 0 })
|
|
})
|
|
|
|
it('POST /rooms/:id/clone clones a base room into a new owned room', async () => {
|
|
const headers = {
|
|
...(await bearer('801')),
|
|
'Content-Type': 'application/x-www-form-urlencoded',
|
|
}
|
|
const post = async (id: number, name: string) =>
|
|
(await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/${id}/clone`, {
|
|
method: 'POST',
|
|
headers,
|
|
body: new URLSearchParams({ name }).toString(),
|
|
})
|
|
).json()) as {
|
|
success: boolean
|
|
error: string
|
|
value: {
|
|
RoomId: number
|
|
Name: string
|
|
CreatorAccountId: number
|
|
Tags?: Array<{ Tag: string }>
|
|
IsRRO: boolean
|
|
Roles: Array<{ AccountId: number; Role: number; InvitedRole: number }>
|
|
} | null
|
|
}
|
|
|
|
// Clone MakerRoom (base, RoomId 24) → a fresh room owned by the caller (801).
|
|
const ok = await post(24, 'MyMakerClone')
|
|
expect(ok.success).toBe(true)
|
|
expect(ok.error).toBe('')
|
|
expect(ok.value).not.toBeNull()
|
|
expect(ok.value!.Name).toBe('MyMakerClone')
|
|
expect(ok.value!.CreatorAccountId).toBe(801)
|
|
expect(ok.value!.RoomId).toBeGreaterThan(51)
|
|
// The clone starts fresh with no tags — none of the source's tags (including
|
|
// the `base` template tag) carry over.
|
|
expect(ok.value!.Tags).toEqual([])
|
|
// IsRRO is cleared so the client doesn't render a virtual "RRO" tag on the clone.
|
|
expect(ok.value!.IsRRO).toBe(false)
|
|
// Ownership is reset to the cloner: sole owner (Role 255), and none of the
|
|
// source base room's roles (accounts 1/2) carry over.
|
|
expect(ok.value!.Roles).toEqual([
|
|
{ AccountId: 801, Role: 255, LastChangedByAccountId: null, InvitedRole: 0 },
|
|
])
|
|
|
|
// It persists and is fetchable by its new id.
|
|
const fetched = (await (await SELF.fetch(`${ORIGIN}/rooms/${ok.value!.RoomId}`)).json()) as {
|
|
Name: string
|
|
}
|
|
expect(fetched.Name).toBe('MyMakerClone')
|
|
|
|
// Duplicate name is rejected.
|
|
const dup = await post(24, 'MyMakerClone')
|
|
expect(dup).toMatchObject({ success: false, value: null })
|
|
expect(dup.error).toMatch(/already exists/i)
|
|
})
|
|
|
|
it('POST /rooms/:id/clone requires auth (401, no account-1 fallback)', async () => {
|
|
// No Authorization header → hard 401, and nothing is created.
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/24/clone`, {
|
|
method: 'POST',
|
|
headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
|
|
body: new URLSearchParams({ name: 'UnauthedClone' }).toString(),
|
|
})
|
|
expect(res.status).toBe(401)
|
|
expect(await res.json()).toMatchObject({ success: false, value: null })
|
|
|
|
// An invalid/garbage token is also rejected.
|
|
const bad = await SELF.fetch(`${ORIGIN}/rooms/24/clone`, {
|
|
method: 'POST',
|
|
headers: {
|
|
Authorization: 'Bearer not.a.jwt',
|
|
'Content-Type': 'application/x-www-form-urlencoded',
|
|
},
|
|
body: new URLSearchParams({ name: 'UnauthedClone' }).toString(),
|
|
})
|
|
expect(bad.status).toBe(401)
|
|
|
|
// The room was never created.
|
|
const lookup = await SELF.fetch(`${ORIGIN}/rooms?name=UnauthedClone`)
|
|
expect(await lookup.json()).toEqual({})
|
|
})
|
|
|
|
it('POST /rooms/:id/clone validates name and cloneability', async () => {
|
|
const headers = {
|
|
...(await bearer('802')),
|
|
'Content-Type': 'application/x-www-form-urlencoded',
|
|
}
|
|
const post = async (id: number, body?: string) =>
|
|
(await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/${id}/clone`, { method: 'POST', headers, body })
|
|
).json()) as { success: boolean; error: string; value: unknown }
|
|
|
|
// Missing name.
|
|
const noName = await post(24, new URLSearchParams({ name: '' }).toString())
|
|
expect(noName).toMatchObject({ success: false, value: null })
|
|
expect(noName.error).toMatch(/must enter a name/i)
|
|
|
|
// The dorm (RoomId 1) disallows cloning.
|
|
const notCloneable = await post(1, new URLSearchParams({ name: 'CannotCloneDorm' }).toString())
|
|
expect(notCloneable).toMatchObject({ success: false, value: null })
|
|
expect(notCloneable.error).toMatch(/can't clone/i)
|
|
|
|
// A source room not in D1.
|
|
const missing = await post(99999, new URLSearchParams({ name: 'CloneOfNothing' }).toString())
|
|
expect(missing).toMatchObject({ success: false, value: null })
|
|
})
|
|
|
|
const putForm = async (path: string, fields: Record<string, string>, sub?: string) =>
|
|
SELF.fetch(`${ORIGIN}${path}`, {
|
|
method: 'PUT',
|
|
headers: {
|
|
...(sub ? await bearer(sub) : {}),
|
|
'Content-Type': 'application/x-www-form-urlencoded',
|
|
},
|
|
body: new URLSearchParams(fields).toString(),
|
|
})
|
|
|
|
// Room-mutation envelope helper (PascalCase `{ Success, Value, ErrorId, Error }` —
|
|
// used by name/image/description).
|
|
type RoomResult = {
|
|
Success: boolean
|
|
Value: unknown
|
|
ErrorId: string | null
|
|
Error: string | null
|
|
}
|
|
const bodyOf = async (res: Response) => (await res.json()) as RoomResult
|
|
|
|
// Lowercase `{ success, error, value }` envelope — used by tags/clone and the
|
|
// roles/warning/cloning/restrictions room-settings mutations (value = updated room).
|
|
type RoomEnv = { success: boolean; error: string; value: Record<string, unknown> | null }
|
|
const envOf = async (res: Response) => (await res.json()) as RoomEnv
|
|
|
|
it('PUT /rooms/:id/description is auth-gated, owner-only, and persists', async () => {
|
|
// No token → 401 (auth gate).
|
|
expect((await putForm('/rooms/2/description', { description: 'x' })).status).toBe(401)
|
|
// Not the owner (RecCenter is owned by account 1) → 200 envelope, Success:false.
|
|
expect(
|
|
await bodyOf(await putForm('/rooms/2/description', { description: 'x' }, '999'))
|
|
).toMatchObject({ Success: false, ErrorId: 'Rooms.NotOwner' })
|
|
// Unknown room → Rooms.DoesntExist envelope.
|
|
expect(
|
|
await bodyOf(await putForm('/rooms/99999/description', { description: 'x' }, '1'))
|
|
).toMatchObject({
|
|
Success: false,
|
|
ErrorId: 'Rooms.DoesntExist',
|
|
Error: 'This room does not exist!',
|
|
})
|
|
|
|
// Owner updates it, and it persists.
|
|
const ok = await putForm('/rooms/2/description', { description: 'blah blah blah' }, '1')
|
|
expect(ok.status).toBe(200)
|
|
expect(await bodyOf(ok)).toMatchObject({
|
|
Success: true,
|
|
Value: null,
|
|
ErrorId: null,
|
|
Error: null,
|
|
})
|
|
const room = (await (await SELF.fetch(`${ORIGIN}/rooms/2`)).json()) as { Description: string }
|
|
expect(room.Description).toBe('blah blah blah')
|
|
})
|
|
|
|
it('PUT /rooms/:id/image is auth-gated, owner-only, and persists', async () => {
|
|
const imageName = '644064b03bd64a8291cde284629e9ca9.jpg'
|
|
// No token → 401 (auth gate).
|
|
expect((await putForm('/rooms/2/image', { imageName })).status).toBe(401)
|
|
// Not the owner (RecCenter is owned by account 1) → 200 envelope, Success:false.
|
|
expect(await bodyOf(await putForm('/rooms/2/image', { imageName }, '999'))).toMatchObject({
|
|
Success: false,
|
|
ErrorId: 'Rooms.NotOwner',
|
|
})
|
|
// Unknown room → Rooms.DoesntExist envelope.
|
|
expect(await bodyOf(await putForm('/rooms/99999/image', { imageName }, '1'))).toMatchObject({
|
|
Success: false,
|
|
ErrorId: 'Rooms.DoesntExist',
|
|
})
|
|
// Empty image → Success:false.
|
|
expect(await bodyOf(await putForm('/rooms/2/image', { imageName: ' ' }, '1'))).toMatchObject({
|
|
Success: false,
|
|
ErrorId: 'Rooms.InvalidImage',
|
|
})
|
|
|
|
// Owner sets it, and it persists.
|
|
const ok = await putForm('/rooms/2/image', { imageName }, '1')
|
|
expect(ok.status).toBe(200)
|
|
expect(await bodyOf(ok)).toMatchObject({ Success: true })
|
|
const room = (await (await SELF.fetch(`${ORIGIN}/rooms/2`)).json()) as { ImageName: string }
|
|
expect(room.ImageName).toBe(imageName)
|
|
})
|
|
|
|
it('PUT /rooms/:id/roles/:accountId is auth-gated, owner/co-owner-only, and persists', async () => {
|
|
const rolesOf = async (): Promise<Array<{ AccountId: number; Role: number }>> => {
|
|
const room = (await (await SELF.fetch(`${ORIGIN}/rooms/2`)).json()) as {
|
|
Roles?: Array<{ AccountId: number; Role: number }>
|
|
}
|
|
return room.Roles ?? []
|
|
}
|
|
|
|
// No token → 401 (auth gate).
|
|
expect((await putForm('/rooms/2/roles/5', { role: '20' })).status).toBe(401)
|
|
// A valid token but no role on the room (RecCenter is owned by account 1, with
|
|
// account 2 as co-owner) → 403.
|
|
expect((await putForm('/rooms/2/roles/5', { role: '20' }, '999')).status).toBe(403)
|
|
// Unknown room → failure envelope.
|
|
expect(await envOf(await putForm('/rooms/99999/roles/5', { role: '20' }, '1'))).toMatchObject({
|
|
success: false,
|
|
error: 'This room does not exist!',
|
|
})
|
|
// Non-numeric role → failure envelope.
|
|
expect(await envOf(await putForm('/rooms/2/roles/5', { role: 'nope' }, '1'))).toMatchObject({
|
|
success: false,
|
|
})
|
|
|
|
// Owner sets account 5's role to 20, adding a new Roles entry that persists. The
|
|
// success envelope carries the updated room as `value`.
|
|
const ok = await putForm('/rooms/2/roles/5', { role: '20' }, '1')
|
|
expect(ok.status).toBe(200)
|
|
const okBody = await envOf(ok)
|
|
expect(okBody).toMatchObject({ success: true, error: '' })
|
|
expect((okBody.value?.Roles as Array<{ AccountId: number; Role: number }>)).toContainEqual(
|
|
expect.objectContaining({ AccountId: 5, Role: 20 })
|
|
)
|
|
expect(await rolesOf()).toContainEqual(expect.objectContaining({ AccountId: 5, Role: 20 }))
|
|
|
|
// The co-owner (account 2, Role 30) may also change it — updating the existing
|
|
// entry in place rather than adding a duplicate.
|
|
const byCoOwner = await putForm('/rooms/2/roles/5', { role: '10' }, '2')
|
|
expect(byCoOwner.status).toBe(200)
|
|
const roles = await rolesOf()
|
|
expect(roles.filter((r) => r.AccountId === 5)).toHaveLength(1)
|
|
expect(roles).toContainEqual(expect.objectContaining({ AccountId: 5, Role: 10 }))
|
|
// The seeded co-owner (account 2) is left intact.
|
|
expect(roles).toContainEqual(expect.objectContaining({ AccountId: 2, Role: 30 }))
|
|
})
|
|
|
|
it('PUT /rooms/:id/warning is auth-gated, owner/co-owner-only, and persists', async () => {
|
|
// No token → 401 (auth gate).
|
|
expect((await putForm('/rooms/2/warning', { warningMask: '2' })).status).toBe(401)
|
|
// A valid token but no role on the room → 403.
|
|
expect((await putForm('/rooms/2/warning', { warningMask: '2' }, '999')).status).toBe(403)
|
|
// Unknown room → failure envelope.
|
|
expect(
|
|
await envOf(await putForm('/rooms/99999/warning', { warningMask: '2' }, '1'))
|
|
).toMatchObject({ success: false, error: 'This room does not exist!' })
|
|
// Non-numeric mask → failure envelope.
|
|
expect(await envOf(await putForm('/rooms/2/warning', { warningMask: 'x' }, '1'))).toMatchObject(
|
|
{ success: false }
|
|
)
|
|
|
|
// Owner sets it, and it persists as an integer (not 2.0). The success envelope
|
|
// carries the updated room as `value`.
|
|
const ok = await putForm('/rooms/2/warning', { warningMask: '2' }, '1')
|
|
expect(ok.status).toBe(200)
|
|
const okBody = await envOf(ok)
|
|
expect(okBody).toMatchObject({ success: true, error: '' })
|
|
expect(okBody.value?.WarningMask).toBe(2)
|
|
const raw = await env.DB.prepare('SELECT data FROM room WHERE room_id = ?1')
|
|
.bind(2)
|
|
.first<{ data: string }>()
|
|
expect(raw!.data).toContain('"WarningMask":2')
|
|
expect(raw!.data).not.toContain('"WarningMask":2.0')
|
|
const room = (await (await SELF.fetch(`${ORIGIN}/rooms/2`)).json()) as { WarningMask: number }
|
|
expect(room.WarningMask).toBe(2)
|
|
|
|
// The mask can carry an optional free-text CustomWarning alongside it.
|
|
const custom = await envOf(
|
|
await putForm('/rooms/2/warning', { warningMask: '63', customWarning: 'slfkjsdf' }, '1')
|
|
)
|
|
expect(custom).toMatchObject({ success: true })
|
|
expect(custom.value).toMatchObject({ WarningMask: 63, CustomWarning: 'slfkjsdf' })
|
|
const withCustom = (await (await SELF.fetch(`${ORIGIN}/rooms/2`)).json()) as {
|
|
WarningMask: number
|
|
CustomWarning: string
|
|
}
|
|
expect(withCustom).toMatchObject({ WarningMask: 63, CustomWarning: 'slfkjsdf' })
|
|
|
|
// Omitting customWarning leaves the existing text untouched (partial update).
|
|
await putForm('/rooms/2/warning', { warningMask: '7' }, '1')
|
|
const kept = (await (await SELF.fetch(`${ORIGIN}/rooms/2`)).json()) as { CustomWarning: string }
|
|
expect(kept.CustomWarning).toBe('slfkjsdf')
|
|
|
|
// The co-owner (account 2, Role 30) may also set it.
|
|
expect((await putForm('/rooms/2/warning', { warningMask: '4' }, '2')).status).toBe(200)
|
|
})
|
|
|
|
it('PUT /rooms/:id/cloning is auth-gated, owner/co-owner-only, and persists a JSON boolean', async () => {
|
|
// No token → 401.
|
|
expect((await putForm('/rooms/2/cloning', { cloningAllowed: 'False' })).status).toBe(401)
|
|
// A valid token but no role on the room → 403.
|
|
expect(
|
|
(await putForm('/rooms/2/cloning', { cloningAllowed: 'False' }, '999')).status
|
|
).toBe(403)
|
|
// Unknown room → failure envelope.
|
|
expect(
|
|
await envOf(await putForm('/rooms/99999/cloning', { cloningAllowed: 'False' }, '1'))
|
|
).toMatchObject({ success: false, error: 'This room does not exist!' })
|
|
|
|
// Owner disables cloning; it persists as a real JSON boolean (not 0/1). The
|
|
// success envelope carries the updated room as `value`.
|
|
const disabled = await envOf(await putForm('/rooms/2/cloning', { cloningAllowed: 'False' }, '1'))
|
|
expect(disabled).toMatchObject({ success: true, error: '' })
|
|
expect(disabled.value?.CloningAllowed).toBe(false)
|
|
const raw = await env.DB.prepare('SELECT data FROM room WHERE room_id = ?1')
|
|
.bind(2)
|
|
.first<{ data: string }>()
|
|
expect(raw!.data).toContain('"CloningAllowed":false')
|
|
const room = (await (await SELF.fetch(`${ORIGIN}/rooms/2`)).json()) as { CloningAllowed: boolean }
|
|
expect(room.CloningAllowed).toBe(false)
|
|
|
|
// The co-owner (account 2) may re-enable it.
|
|
await putForm('/rooms/2/cloning', { cloningAllowed: 'True' }, '2')
|
|
const reenabled = (await (await SELF.fetch(`${ORIGIN}/rooms/2`)).json()) as {
|
|
CloningAllowed: boolean
|
|
}
|
|
expect(reenabled.CloningAllowed).toBe(true)
|
|
})
|
|
|
|
it('PUT /rooms/:id/restrictions sets the Supports* flags present in the body', async () => {
|
|
// No token → 401; a valid token with no role → 403.
|
|
expect((await putForm('/rooms/2/restrictions', { supportsScreens: 'True' })).status).toBe(401)
|
|
expect(
|
|
(await putForm('/rooms/2/restrictions', { supportsScreens: 'True' }, '999')).status
|
|
).toBe(403)
|
|
|
|
// The exact client body: a mix of True/False across a subset of the flags.
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/2/restrictions`, {
|
|
method: 'PUT',
|
|
headers: { ...(await bearer('1')), 'Content-Type': 'application/x-www-form-urlencoded' },
|
|
body: 'supportsScreens=True&supportsWalkVR=True&supportsTeleportVR=False&supportsJuniors=True',
|
|
})
|
|
expect(res.status).toBe(200)
|
|
// The success envelope carries the updated room as `value`.
|
|
const env2 = await envOf(res)
|
|
expect(env2).toMatchObject({ success: true, error: '' })
|
|
expect(env2.value).toMatchObject({
|
|
SupportsScreens: true,
|
|
SupportsWalkVR: true,
|
|
SupportsTeleportVR: false,
|
|
SupportsJuniors: true,
|
|
})
|
|
|
|
const room = (await (await SELF.fetch(`${ORIGIN}/rooms/2`)).json()) as {
|
|
SupportsScreens: boolean
|
|
SupportsWalkVR: boolean
|
|
SupportsTeleportVR: boolean
|
|
SupportsJuniors: boolean
|
|
SupportsMobile: boolean
|
|
}
|
|
expect(room.SupportsScreens).toBe(true)
|
|
expect(room.SupportsWalkVR).toBe(true)
|
|
expect(room.SupportsTeleportVR).toBe(false)
|
|
expect(room.SupportsJuniors).toBe(true)
|
|
// A flag not in the body is left unchanged (still a boolean, not dropped).
|
|
expect(typeof room.SupportsMobile).toBe('boolean')
|
|
})
|
|
|
|
it('PUT /rooms/:id/loadscreen appends a load screen (auth-gated, owner/co-owner-only)', async () => {
|
|
const screensOf = async (): Promise<Array<Record<string, unknown>>> => {
|
|
const room = (await (await SELF.fetch(`${ORIGIN}/rooms/2`)).json()) as {
|
|
LoadScreens?: Array<Record<string, unknown>>
|
|
}
|
|
return room.LoadScreens ?? []
|
|
}
|
|
|
|
// No token → 401; a valid token with no role → 403.
|
|
expect((await putForm('/rooms/2/loadscreen', { imageName: 'a.jpg' })).status).toBe(401)
|
|
expect((await putForm('/rooms/2/loadscreen', { imageName: 'a.jpg' }, '999')).status).toBe(403)
|
|
// Unknown room → failure envelope.
|
|
expect(
|
|
await envOf(await putForm('/rooms/99999/loadscreen', { imageName: 'a.jpg' }, '1'))
|
|
).toMatchObject({ success: false, error: 'This room does not exist!' })
|
|
// Missing image → failure envelope.
|
|
expect(await envOf(await putForm('/rooms/2/loadscreen', { title: 'x' }, '1'))).toMatchObject({
|
|
success: false,
|
|
})
|
|
|
|
const before = (await screensOf()).length
|
|
|
|
// Owner adds one (imageName + title + subtitle) — appended, and the success
|
|
// envelope carries the updated room.
|
|
const added = await envOf(
|
|
await putForm(
|
|
'/rooms/2/loadscreen',
|
|
{ imageName: 'sharecamera/2026-07-15/abc.jpg', title: 'asdf', subtitle: 'sdf' },
|
|
'1'
|
|
)
|
|
)
|
|
expect(added).toMatchObject({ success: true })
|
|
expect(added.value?.LoadScreens as unknown[]).toContainEqual({
|
|
ImageName: 'sharecamera/2026-07-15/abc.jpg',
|
|
Title: 'asdf',
|
|
Subtitle: 'sdf',
|
|
})
|
|
expect(await screensOf()).toHaveLength(before + 1)
|
|
|
|
// A second call appends rather than replacing; title/subtitle default to empty.
|
|
const co = await envOf(await putForm('/rooms/2/loadscreen', { imageName: 'second.jpg' }, '2'))
|
|
expect(co).toMatchObject({ success: true })
|
|
expect(await screensOf()).toHaveLength(before + 2)
|
|
expect(await screensOf()).toContainEqual({ ImageName: 'second.jpg', Title: '', Subtitle: '' })
|
|
})
|
|
|
|
it('PUT /rooms/:id/accessibility sets the room-level Accessibility (auth-gated, owner/co-owner-only)', async () => {
|
|
// No token → 401; a valid token with no role → 403.
|
|
expect((await putForm('/rooms/2/accessibility', { accessibility: '1' })).status).toBe(401)
|
|
expect((await putForm('/rooms/2/accessibility', { accessibility: '1' }, '999')).status).toBe(403)
|
|
// Unknown room → failure envelope.
|
|
expect(
|
|
await envOf(await putForm('/rooms/99999/accessibility', { accessibility: '1' }, '1'))
|
|
).toMatchObject({ success: false, error: 'This room does not exist!' })
|
|
// Non-numeric → failure envelope.
|
|
expect(
|
|
await envOf(await putForm('/rooms/2/accessibility', { accessibility: 'x' }, '1'))
|
|
).toMatchObject({ success: false })
|
|
|
|
// Owner sets it (0 = Private); the success envelope carries the updated room.
|
|
const priv = await envOf(await putForm('/rooms/2/accessibility', { accessibility: '0' }, '1'))
|
|
expect(priv).toMatchObject({ success: true, error: '' })
|
|
expect(priv.value?.Accessibility).toBe(0)
|
|
const room = (await (await SELF.fetch(`${ORIGIN}/rooms/2`)).json()) as { Accessibility: number }
|
|
expect(room.Accessibility).toBe(0)
|
|
|
|
// The co-owner (account 2) may set it back to public (1).
|
|
const pub = await envOf(await putForm('/rooms/2/accessibility', { accessibility: '1' }, '2'))
|
|
expect(pub.value?.Accessibility).toBe(1)
|
|
})
|
|
|
|
it('GET /rooms/:id/subrooms/:sid/data returns the subroom descriptor (404 when unknown)', async () => {
|
|
// Room 2 has SubRoomId 2 in the seed.
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/2/subrooms/2/data`)
|
|
expect(res.status).toBe(200)
|
|
expect((await res.json()) as { SubRoomId: number }).toMatchObject({ SubRoomId: 2 })
|
|
|
|
// Unknown subroom → 404.
|
|
expect((await SELF.fetch(`${ORIGIN}/rooms/2/subrooms/9999/data`)).status).toBe(404)
|
|
// Unknown room → 404.
|
|
expect((await SELF.fetch(`${ORIGIN}/rooms/99999/subrooms/2/data`)).status).toBe(404)
|
|
})
|
|
|
|
it('POST /rooms/:id/subrooms/:sid/data is auth-gated, owner-only, and saves the blobs', async () => {
|
|
const save = {
|
|
UnityAssetId: null,
|
|
RoomData: { Filename: '5c618c920f6247efb8327e327d0b4417', Hash: null, OwnershipProof: null },
|
|
SubRoomData: {
|
|
Filename: 'a84167b16796452ab70ee8a6a5b1dc5f',
|
|
Hash: null,
|
|
OwnershipProof: null,
|
|
},
|
|
InventionUsage: 'CAE=',
|
|
PersistenceVersion: 41,
|
|
Description: 'mydescription here',
|
|
AutoPublish: true,
|
|
}
|
|
// No token → 401.
|
|
expect(
|
|
(
|
|
await SELF.fetch(`${ORIGIN}/rooms/2/subrooms/2/data`, {
|
|
method: 'POST',
|
|
headers: { 'Content-Type': 'application/json' },
|
|
body: JSON.stringify(save),
|
|
})
|
|
).status
|
|
).toBe(401)
|
|
|
|
const authed = async (roomId: number, subRoomId: number, sub = '1') =>
|
|
SELF.fetch(`${ORIGIN}/rooms/${roomId}/subrooms/${subRoomId}/data`, {
|
|
method: 'POST',
|
|
headers: { 'Content-Type': 'application/json', ...(await bearer(sub)) },
|
|
body: JSON.stringify(save),
|
|
})
|
|
|
|
// A valid token but no role on the room → 403.
|
|
expect((await authed(2, 2, '999')).status).toBe(403)
|
|
// The response uses the PascalCase `{ Success, Value, ErrorId, Error }` envelope.
|
|
// Unknown room → DoesntExist.
|
|
expect(await bodyOf(await authed(99999, 2, '1'))).toMatchObject({
|
|
Success: false,
|
|
ErrorId: 'Rooms.DoesntExist',
|
|
})
|
|
|
|
// Owner saves → 200 with the saved SUBROOM as the bare body (no envelope),
|
|
// carrying the new blobs and populated creator.
|
|
const ok = await authed(2, 2, '1')
|
|
expect(ok.status).toBe(200)
|
|
expect(await bodyOf(ok)).toMatchObject({
|
|
SubRoomId: 2,
|
|
DataBlob: 'a84167b16796452ab70ee8a6a5b1dc5f',
|
|
RoomDataBlob: '5c618c920f6247efb8327e327d0b4417',
|
|
CreatorAccountId: 1,
|
|
PersistenceVersion: 41,
|
|
})
|
|
|
|
// It also persists — the GET returns the subroom with the new blob + creator.
|
|
const sub = (await (await SELF.fetch(`${ORIGIN}/rooms/2/subrooms/2/data`)).json()) as {
|
|
SubRoomId: number
|
|
DataBlob: string
|
|
CreatorAccountId: number
|
|
}
|
|
expect(sub).toMatchObject({
|
|
SubRoomId: 2,
|
|
DataBlob: 'a84167b16796452ab70ee8a6a5b1dc5f',
|
|
CreatorAccountId: 1,
|
|
})
|
|
const room = (await (await SELF.fetch(`${ORIGIN}/rooms/2`)).json()) as {
|
|
Description: string
|
|
PersistenceVersion: number
|
|
}
|
|
expect(room.Description).toBe('mydescription here')
|
|
expect(room.PersistenceVersion).toBe(41)
|
|
|
|
// A CoOwner (account 2 holds Role 30 in the seeded rooms) may also save — 200
|
|
// with the subroom body. The creator stays account 1 (not clobbered).
|
|
const coOwner = await authed(2, 2, '2')
|
|
expect(coOwner.status).toBe(200)
|
|
expect(await bodyOf(coOwner)).toMatchObject({ SubRoomId: 2, CreatorAccountId: 1 })
|
|
})
|
|
|
|
it('PUT /rooms/:id/tags is auth-gated, owner-only, and toggles (add/remove)', async () => {
|
|
// The lowercase `{ success, error, value }` envelope this endpoint returns.
|
|
type TagResult = { success: boolean; error: string; value: { Tags?: Array<{ Tag: string }> } | null }
|
|
const envOf = async (res: Response) => (await res.json()) as TagResult
|
|
const tagsIn = (r: TagResult) => (r.value?.Tags ?? []).map((t) => t.Tag)
|
|
|
|
// No token → 401.
|
|
expect((await putForm('/rooms/2/tags', { tag: 'quest' })).status).toBe(401)
|
|
// Not the owner → failure envelope.
|
|
expect(await envOf(await putForm('/rooms/2/tags', { tag: 'quest' }, '999'))).toMatchObject({
|
|
success: false,
|
|
error: 'You are not the owner of this room!',
|
|
})
|
|
// Unknown room → failure envelope.
|
|
expect(await envOf(await putForm('/rooms/99999/tags', { tag: 'quest' }, '1'))).toMatchObject({
|
|
success: false,
|
|
error: 'This room does not exist!',
|
|
})
|
|
// Empty tag → failure envelope.
|
|
expect(await envOf(await putForm('/rooms/2/tags', { tag: ' ' }, '1'))).toMatchObject({
|
|
success: false,
|
|
error: 'You must provide a tag!',
|
|
})
|
|
|
|
// Owner adds a non-main tag → success envelope carries the updated room.
|
|
const added = await envOf(await putForm('/rooms/2/tags', { tag: 'spooky' }, '1'))
|
|
expect(added).toMatchObject({ success: true, error: '' })
|
|
expect(tagsIn(added)).toContain('spooky')
|
|
|
|
// The same call again toggles it back off (no delete endpoint).
|
|
const removed = await envOf(await putForm('/rooms/2/tags', { tag: 'SPOOKY' }, '1'))
|
|
expect(tagsIn(removed)).not.toContain('spooky')
|
|
|
|
// Main tags are radio buttons: setting one clears any other main tag, but
|
|
// leaves non-main tags alone.
|
|
await putForm('/rooms/2/tags', { tag: 'campfire' }, '1') // non-main, stays put
|
|
const pvp = await envOf(await putForm('/rooms/2/tags', { tag: 'pvp' }, '1'))
|
|
expect(tagsIn(pvp)).toEqual(expect.arrayContaining(['pvp', 'campfire']))
|
|
|
|
const quest = await envOf(await putForm('/rooms/2/tags', { tag: 'quest' }, '1'))
|
|
expect(tagsIn(quest)).toContain('quest')
|
|
expect(tagsIn(quest)).not.toContain('pvp') // the previous main tag was cleared
|
|
expect(tagsIn(quest)).toContain('campfire') // non-main tag untouched
|
|
|
|
// Toggling the current main tag off just removes it (no other change).
|
|
const off = await envOf(await putForm('/rooms/2/tags', { tag: 'quest' }, '1'))
|
|
expect(tagsIn(off)).not.toContain('quest')
|
|
expect(tagsIn(off)).toContain('campfire')
|
|
})
|
|
|
|
it('PUT /rooms/:id/name is auth-gated, owner-only, unique, and persists', async () => {
|
|
// No token → 401 (auth gate).
|
|
expect((await putForm('/rooms/2/name', { name: 'Whatever' })).status).toBe(401)
|
|
// Wrong owner / unknown room → Success:false envelopes.
|
|
expect(await bodyOf(await putForm('/rooms/2/name', { name: 'Whatever' }, '999'))).toMatchObject(
|
|
{
|
|
Success: false,
|
|
ErrorId: 'Rooms.NotOwner',
|
|
}
|
|
)
|
|
expect(
|
|
await bodyOf(await putForm('/rooms/99999/name', { name: 'Whatever' }, '1'))
|
|
).toMatchObject({
|
|
Success: false,
|
|
ErrorId: 'Rooms.DoesntExist',
|
|
})
|
|
// Empty name → Success:false.
|
|
expect(await bodyOf(await putForm('/rooms/2/name', { name: ' ' }, '1'))).toMatchObject({
|
|
Success: false,
|
|
ErrorId: 'Rooms.InvalidName',
|
|
})
|
|
// A name already used by a different room (GoldenTrophy is room 12).
|
|
expect(
|
|
await bodyOf(await putForm('/rooms/2/name', { name: 'GoldenTrophy' }, '1'))
|
|
).toMatchObject({
|
|
Success: false,
|
|
ErrorId: 'Rooms.AlreadyExists',
|
|
Error: 'A room with that name already exists!',
|
|
})
|
|
|
|
// Owner renames to a free name, and it persists (findable by the new name).
|
|
const ok = await putForm('/rooms/2/name', { name: 'RenamedCenter' }, '1')
|
|
expect(await bodyOf(ok)).toMatchObject({ Success: true })
|
|
const room = (await (await SELF.fetch(`${ORIGIN}/rooms?name=RenamedCenter`)).json()) as {
|
|
RoomId: number
|
|
}
|
|
expect(room.RoomId).toBe(2)
|
|
})
|
|
|
|
it('room_instance: create + read round-trips and hides JsonIgnore fields', async () => {
|
|
const created = await createRoomInstance(env.DB, {
|
|
ownerAccountId: 5,
|
|
roomId: 2,
|
|
subRoomId: 3,
|
|
photonRoomId: crypto.randomUUID(),
|
|
name: '^RecCenter',
|
|
maxCapacity: 20,
|
|
isPrivate: true,
|
|
encryptVoiceChat: true,
|
|
})
|
|
// The DB assigns a sequential id, mapped to `roomInstanceId` in the DTO.
|
|
expect(created.roomInstanceId).toBeGreaterThan(0)
|
|
expect(created.roomId).toBe(2)
|
|
expect(created.isPrivate).toBe(true)
|
|
expect(created.EncryptVoiceChat).toBe(true) // PascalCase JSON key, per the C#
|
|
|
|
// Reads back identically; JsonIgnore columns are not in the DTO.
|
|
const fetched = await getRoomInstance(env.DB, created.roomInstanceId)
|
|
expect(fetched).toEqual(created)
|
|
expect('ownerAccountId' in (fetched as object)).toBe(false)
|
|
expect('dataBlob' in (fetched as object)).toBe(false)
|
|
expect('allowNewUsers' in (fetched as object)).toBe(false)
|
|
})
|
|
|
|
it('GET /photon_access_token 401s without a token', async () => {
|
|
for (const path of ['/photon_access_token', '/roomserver/photon_access_token']) {
|
|
const res = await SELF.fetch(`${ORIGIN}${path}`)
|
|
expect(res.status).toBe(401)
|
|
}
|
|
})
|
|
|
|
it('GET /photon_access_token (bare + /roomserver) returns permissions + presence instance', async () => {
|
|
// Seed the caller's presence so RoomInstanceId reflects their current instance.
|
|
await env.DB.prepare('INSERT OR REPLACE INTO presence (data) VALUES (?1)')
|
|
.bind(
|
|
JSON.stringify({
|
|
accountId: 777,
|
|
roomInstance: { roomInstanceId: 1000042 },
|
|
expiresAt: Math.floor(Date.now() / 1000) + 900,
|
|
})
|
|
)
|
|
.run()
|
|
const headers = await bearer('777')
|
|
for (const path of ['/photon_access_token', '/roomserver/photon_access_token']) {
|
|
const res = await SELF.fetch(`${ORIGIN}${path}`, { headers })
|
|
expect(res.status).toBe(200)
|
|
const body = (await res.json()) as {
|
|
Permissions: Array<{ Permission: string; Role: number }>
|
|
PhotonAccessToken: string
|
|
RoomInstanceId: number | null
|
|
}
|
|
expect(body.Permissions.length).toBe(11)
|
|
expect(body.RoomInstanceId).toBe(1000042)
|
|
// A non-dev account does NOT get the global (Role 0) maker pen.
|
|
expect(
|
|
body.Permissions.some((p) => p.Permission === 'CAN_USE_MAKER_PEN' && p.Role === 0)
|
|
).toBe(false)
|
|
}
|
|
})
|
|
|
|
it('GET /photon_access_token returns null RoomInstanceId when the caller has no presence', async () => {
|
|
const res = await SELF.fetch(`${ORIGIN}/photon_access_token`, { headers: await bearer('888') })
|
|
expect(res.status).toBe(200)
|
|
expect(((await res.json()) as { RoomInstanceId: number | null }).RoomInstanceId).toBeNull()
|
|
})
|
|
|
|
it('GET /photon_access_token grants the global maker pen to dev accounts (1/2/3)', async () => {
|
|
for (const sub of ['1', '2', '3']) {
|
|
const res = await SELF.fetch(`${ORIGIN}/photon_access_token`, { headers: await bearer(sub) })
|
|
expect(res.status).toBe(200)
|
|
const body = (await res.json()) as {
|
|
Permissions: Array<{ Permission: string; Role: number; Override: boolean }>
|
|
}
|
|
// The global maker pen is prepended → first entry, Role 0, Override true.
|
|
expect(body.Permissions[0]).toMatchObject({
|
|
Permission: 'CAN_USE_MAKER_PEN',
|
|
Role: 0,
|
|
Override: true,
|
|
})
|
|
expect(body.Permissions.length).toBe(12)
|
|
}
|
|
})
|
|
|
|
it('interaction: defaults to false, cheer/favorite toggle and persist', async () => {
|
|
type Interaction = { Cheered: boolean; Favorited: boolean; LastVisitedAt: string }
|
|
const headers = await bearer('555')
|
|
const get = async () =>
|
|
(await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/12/interactionby/me`, { headers })
|
|
).json()) as Interaction
|
|
const put = async (action: 'cheer' | 'favorite') =>
|
|
(await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/12/interactionby/me/${action}`, {
|
|
method: 'PUT',
|
|
headers,
|
|
})
|
|
).json()) as Interaction
|
|
|
|
// No row yet → both false.
|
|
expect(await get()).toMatchObject({ Cheered: false, Favorited: false })
|
|
|
|
// Cheer on, then favorite on.
|
|
expect(await put('cheer')).toMatchObject({ Cheered: true, Favorited: false })
|
|
expect(await put('favorite')).toMatchObject({ Cheered: true, Favorited: true })
|
|
// Persisted across a fresh GET.
|
|
expect(await get()).toMatchObject({ Cheered: true, Favorited: true })
|
|
|
|
// Toggling again flips back.
|
|
expect(await put('cheer')).toMatchObject({ Cheered: false, Favorited: true })
|
|
|
|
// Scoped per player — a different account starts fresh.
|
|
const other = await bearer('556')
|
|
const otherGet = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/12/interactionby/me`, { headers: other })
|
|
).json()) as Interaction
|
|
expect(otherGet).toMatchObject({ Cheered: false, Favorited: false })
|
|
})
|
|
|
|
it('DELETE /rooms/:id/interactionby/me/cheer clears the cheer (auth-gated, idempotent)', async () => {
|
|
type Interaction = { Cheered: boolean; Favorited: boolean }
|
|
const headers = await bearer('557')
|
|
const del = () =>
|
|
SELF.fetch(`${ORIGIN}/rooms/12/interactionby/me/cheer`, { method: 'DELETE', headers })
|
|
|
|
// No token → 401.
|
|
expect(
|
|
(await SELF.fetch(`${ORIGIN}/rooms/12/interactionby/me/cheer`, { method: 'DELETE' })).status
|
|
).toBe(401)
|
|
|
|
// Cheer + favorite on, then DELETE clears only the cheer (favorite untouched).
|
|
await SELF.fetch(`${ORIGIN}/rooms/12/interactionby/me/cheer`, { method: 'PUT', headers })
|
|
await SELF.fetch(`${ORIGIN}/rooms/12/interactionby/me/favorite`, { method: 'PUT', headers })
|
|
expect(await (await del()).json()).toMatchObject({ Cheered: false, Favorited: true })
|
|
|
|
// Idempotent — a second DELETE stays cleared.
|
|
expect(await (await del()).json()).toMatchObject({ Cheered: false, Favorited: true })
|
|
|
|
// Idempotent on a never-interacted room, and it doesn't create a visited row.
|
|
const fresh = await bearer('558')
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/2/interactionby/me/cheer`, {
|
|
method: 'DELETE',
|
|
headers: fresh,
|
|
})
|
|
expect(await res.json()).toMatchObject({ Cheered: false, Favorited: false })
|
|
const visited = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/visitedby/me`, { headers: fresh })
|
|
).json()) as unknown[]
|
|
expect(visited).toEqual([])
|
|
})
|
|
|
|
it('DELETE /rooms/:id/interactionby/me/favorite clears the favorite (auth-gated, idempotent)', async () => {
|
|
const headers = await bearer('559')
|
|
const del = () =>
|
|
SELF.fetch(`${ORIGIN}/rooms/12/interactionby/me/favorite`, { method: 'DELETE', headers })
|
|
|
|
// No token → 401.
|
|
expect(
|
|
(await SELF.fetch(`${ORIGIN}/rooms/12/interactionby/me/favorite`, { method: 'DELETE' }))
|
|
.status
|
|
).toBe(401)
|
|
|
|
// Favorite + cheer on, then DELETE clears only the favorite (cheer untouched).
|
|
await SELF.fetch(`${ORIGIN}/rooms/12/interactionby/me/favorite`, { method: 'PUT', headers })
|
|
await SELF.fetch(`${ORIGIN}/rooms/12/interactionby/me/cheer`, { method: 'PUT', headers })
|
|
expect(await (await del()).json()).toMatchObject({ Cheered: true, Favorited: false })
|
|
// It drops out of the caller's favorited list.
|
|
const favs = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/favoritedby/me`, { headers })
|
|
).json()) as unknown[]
|
|
expect(favs).toEqual([])
|
|
|
|
// Idempotent — a second DELETE stays cleared.
|
|
expect(await (await del()).json()).toMatchObject({ Cheered: true, Favorited: false })
|
|
|
|
// Idempotent on a never-interacted room, without creating a visited row.
|
|
const fresh = await bearer('560')
|
|
const res = await SELF.fetch(`${ORIGIN}/rooms/2/interactionby/me/favorite`, {
|
|
method: 'DELETE',
|
|
headers: fresh,
|
|
})
|
|
expect(await res.json()).toMatchObject({ Cheered: false, Favorited: false })
|
|
const visited = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/visitedby/me`, { headers: fresh })
|
|
).json()) as unknown[]
|
|
expect(visited).toEqual([])
|
|
})
|
|
|
|
it('PUT /rooms/:id/subrooms/:sid/modify is auth-gated, owner-only, and persists subroom settings', async () => {
|
|
const fields = { name: 'My Cool Subroom', accessibility: '1', maxPlayers: '20' }
|
|
// No token → 401 (auth gate).
|
|
expect((await putForm('/rooms/2/subrooms/2/modify', fields)).status).toBe(401)
|
|
// Not the owner (room 2 is owned by account 1) → NotOwner.
|
|
expect(await bodyOf(await putForm('/rooms/2/subrooms/2/modify', fields, '999'))).toMatchObject({
|
|
Success: false,
|
|
ErrorId: 'Rooms.NotOwner',
|
|
})
|
|
// Unknown room → DoesntExist.
|
|
expect(
|
|
await bodyOf(await putForm('/rooms/99999/subrooms/2/modify', fields, '1'))
|
|
).toMatchObject({ Success: false, ErrorId: 'Rooms.DoesntExist' })
|
|
// Unknown subroom → DoesntExist.
|
|
expect(await bodyOf(await putForm('/rooms/2/subrooms/9999/modify', fields, '1'))).toMatchObject(
|
|
{ Success: false, ErrorId: 'Rooms.DoesntExist' }
|
|
)
|
|
// Empty name → InvalidName.
|
|
expect(
|
|
await bodyOf(await putForm('/rooms/2/subrooms/2/modify', { ...fields, name: ' ' }, '1'))
|
|
).toMatchObject({ Success: false, ErrorId: 'Rooms.InvalidName' })
|
|
|
|
// Owner updates the subroom → Success, and it persists on the subroom descriptor.
|
|
const ok = await putForm('/rooms/2/subrooms/2/modify', fields, '1')
|
|
expect(ok.status).toBe(200)
|
|
expect(await bodyOf(ok)).toMatchObject({ Success: true })
|
|
const sub = (await (await SELF.fetch(`${ORIGIN}/rooms/2/subrooms/2/data`)).json()) as {
|
|
Name: string
|
|
Accessibility: number
|
|
MaxPlayers: number
|
|
}
|
|
expect(sub).toMatchObject({ Name: 'My Cool Subroom', Accessibility: 1, MaxPlayers: 20 })
|
|
})
|
|
|
|
it('POST /rooms/:id/subrooms/:sid/clone is auth-gated, owner-only, and copies the subroom', async () => {
|
|
const clone = async (roomId: number, subRoomId: number, sub?: string) =>
|
|
SELF.fetch(`${ORIGIN}/rooms/${roomId}/subrooms/${subRoomId}/clone`, {
|
|
method: 'POST',
|
|
headers: sub ? await bearer(sub) : {},
|
|
})
|
|
const envelope = async (res: Response) =>
|
|
(await res.json()) as {
|
|
success: boolean
|
|
error: string
|
|
value: { SubRoomId: number; CreatorAccountId: number } | null
|
|
}
|
|
|
|
// No token → 401.
|
|
expect((await clone(2, 2)).status).toBe(401)
|
|
// Not the owner → success:false envelope.
|
|
expect((await envelope(await clone(2, 2, '999'))).success).toBe(false)
|
|
// Unknown subroom → success:false envelope.
|
|
expect((await envelope(await clone(2, 9999, '1'))).success).toBe(false)
|
|
|
|
// Owner clones → success, a fresh SubRoomId owned by the caller, fetchable on the room.
|
|
const res = await clone(2, 2, '1')
|
|
expect(res.status).toBe(200)
|
|
const body = await envelope(res)
|
|
expect(body.success).toBe(true)
|
|
expect(body.value?.SubRoomId).not.toBe(2)
|
|
expect(body.value?.CreatorAccountId).toBe(1)
|
|
const fetched = (await (
|
|
await SELF.fetch(`${ORIGIN}/rooms/2/subrooms/${body.value?.SubRoomId}/data`)
|
|
).json()) as { SubRoomId: number }
|
|
expect(fetched.SubRoomId).toBe(body.value?.SubRoomId)
|
|
})
|
|
})
|