6bf8bebf51
CI / Test and Build (push) Failing after 1s
CI / Migrate Dev DB (push) Has been skipped
CI / Migrate DB (push) Has been skipped
CodeQL / Analyze actions (push) Has been cancelled
CodeQL / Analyze javascript-typescript (push) Has been cancelled
CI / Detect Version (push) Has been cancelled
CI / Detect Desktop Changes (push) Has been cancelled
CI / Build AMD64 (blacksmith-2vcpu-ubuntu-2404, ./docker/cron.Dockerfile, ubuntu-latest, ghcr.io/simstudioai/cron) (push) Has been cancelled
CI / Build AMD64 (blacksmith-2vcpu-ubuntu-2404, ./docker/db.Dockerfile, ECR_MIGRATIONS, ubuntu-latest, ghcr.io/simstudioai/migrations) (push) Has been cancelled
CI / Build AMD64 (blacksmith-4vcpu-ubuntu-2404, ./docker/pii.Dockerfile, ECR_PII, ubuntu-latest, ghcr.io/simstudioai/pii) (push) Has been cancelled
CI / Build AMD64 (blacksmith-4vcpu-ubuntu-2404, ./docker/realtime.Dockerfile, ECR_REALTIME, ubuntu-latest, ghcr.io/simstudioai/realtime) (push) Has been cancelled
CI / Build AMD64 (blacksmith-8vcpu-ubuntu-2404, ./docker/app.Dockerfile, ECR_APP, linux-x64-8-core, ghcr.io/simstudioai/simstudio) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (blacksmith-4vcpu-ubuntu-2404-arm, ./docker/cron.Dockerfile, ubuntu-24.04-arm, ghcr.io/simstudioai/cron) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (blacksmith-4vcpu-ubuntu-2404-arm, ./docker/db.Dockerfile, ubuntu-24.04-arm, ghcr.io/simstudioai/migrations) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (blacksmith-4vcpu-ubuntu-2404-arm, ./docker/pii.Dockerfile, ubuntu-24.04-arm, ghcr.io/simstudioai/pii) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (blacksmith-4vcpu-ubuntu-2404-arm, ./docker/realtime.Dockerfile, ubuntu-24.04-arm, ghcr.io/simstudioai/realtime) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (blacksmith-8vcpu-ubuntu-2404-arm, ./docker/app.Dockerfile, linux-arm64-8-core, ghcr.io/simstudioai/simstudio) (push) Has been cancelled
CI / Check Docs Changes (push) Has been cancelled
Publish CLI Package / publish-npm (push) Has been cancelled
Publish Python SDK / publish-pypi (push) Has been cancelled
CI / Deploy Trigger.dev (Dev) (push) Has been cancelled
Helm Chart / Lint, test, and validate chart (push) Has been cancelled
Helm Chart / Chart version bumped (push) Has been cancelled
Publish TypeScript SDK / publish-npm (push) Has been cancelled
CI / Build Dev ECR (blacksmith-8vcpu-ubuntu-2404, ./docker/app.Dockerfile, ECR_APP, linux-x64-8-core) (push) Has been cancelled
CI / Promote Images (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/cron) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/migrations) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/pii) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/realtime) (push) Has been cancelled
CI / Build Dev ECR (blacksmith-2vcpu-ubuntu-2404, ./docker/db.Dockerfile, ECR_MIGRATIONS, ubuntu-latest) (push) Has been cancelled
CI / Build Dev ECR (blacksmith-4vcpu-ubuntu-2404, ./docker/pii.Dockerfile, ECR_PII, ubuntu-latest) (push) Has been cancelled
CI / Build Dev ECR (blacksmith-4vcpu-ubuntu-2404, ./docker/realtime.Dockerfile, ECR_REALTIME, ubuntu-latest) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/simstudio) (push) Has been cancelled
CI / Process Docs (push) Has been cancelled
CI / Create GitHub Release (push) Has been cancelled
CI / Check Desktop Signing Secrets (push) Has been cancelled
CI / Desktop Release (push) Has been cancelled
CI / Create Desktop Prerelease (push) Has been cancelled
CI / Desktop Prerelease Build (push) Has been cancelled
CI / Publish Desktop Prerelease (push) Has been cancelled
CI / Prune Desktop Prereleases (push) Has been cancelled
Helm Chart / Install on kind and run helm test (push) Has been cancelled
79 lines
2.9 KiB
TypeScript
79 lines
2.9 KiB
TypeScript
/**
|
|
* @vitest-environment node
|
|
*
|
|
* Opaque cursor encode/decode and the cursor↔sort binding. A cursor encodes a
|
|
* position in one specific ordering; replaying it under any other ordering
|
|
* silently pages the wrong sequence, so binding violations must throw
|
|
* CURSOR_SORT_CONFLICT rather than return wrong rows.
|
|
*/
|
|
import { describe, expect, it } from 'vitest'
|
|
import { TableQueryValidationError } from '@/lib/table/errors'
|
|
import {
|
|
assertCursorSortBinding,
|
|
canonicalSortKey,
|
|
decodeCursor,
|
|
encodeCursor,
|
|
} from '@/lib/table/rows/cursor'
|
|
|
|
const ROW = { id: 'row_1', orderKey: 'a1' }
|
|
|
|
describe('cursor↔sort binding (bugbot round 2)', () => {
|
|
it('stamps an offset cursor with the sort it was minted under', () => {
|
|
const token = encodeCursor({
|
|
lastRow: { id: 'row_1', orderKey: null },
|
|
keysetValid: false,
|
|
nextOffset: 100,
|
|
sort: { col_a: 'desc' },
|
|
})
|
|
const decoded = decodeCursor(token)
|
|
expect(decoded.offset).toBe(100)
|
|
expect(decoded.sortKey).toBe(canonicalSortKey({ col_a: 'desc' }))
|
|
})
|
|
|
|
it('accepts replay under the identical sort', () => {
|
|
const decoded = { offset: 100, sortKey: canonicalSortKey({ col_a: 'desc' }) }
|
|
expect(() => assertCursorSortBinding(decoded, { col_a: 'desc' })).not.toThrow()
|
|
})
|
|
|
|
it('rejects replay under a DIFFERENT sort', () => {
|
|
const decoded = { offset: 100, sortKey: canonicalSortKey({ col_a: 'desc' }) }
|
|
for (const sort of [{ col_a: 'asc' as const }, { col_b: 'desc' as const }, undefined]) {
|
|
expect(() => assertCursorSortBinding(decoded, sort)).toThrow(TableQueryValidationError)
|
|
try {
|
|
assertCursorSortBinding(decoded, sort)
|
|
} catch (e) {
|
|
expect((e as TableQueryValidationError).code).toBe('CURSOR_SORT_CONFLICT')
|
|
}
|
|
}
|
|
})
|
|
|
|
it('rejects adding a sort to an unsorted offset cursor', () => {
|
|
const token = encodeCursor({
|
|
lastRow: { id: 'row_1', orderKey: null },
|
|
keysetValid: false,
|
|
nextOffset: 50,
|
|
})
|
|
const decoded = decodeCursor(token)
|
|
expect(decoded.sortKey).toBeUndefined()
|
|
expect(() => assertCursorSortBinding(decoded, { col_a: 'asc' })).toThrow(
|
|
/different sort|sorted query/
|
|
)
|
|
expect(() => assertCursorSortBinding(decoded, undefined)).not.toThrow()
|
|
})
|
|
|
|
it('keyset cursors stay default-order only and never carry a sort stamp', () => {
|
|
const token = encodeCursor({ lastRow: ROW, keysetValid: true, nextOffset: 10 })
|
|
const decoded = decodeCursor(token)
|
|
expect(decoded.after).toEqual({ orderKey: 'a1', id: 'row_1' })
|
|
expect(decoded.sortKey).toBeUndefined()
|
|
expect(() => assertCursorSortBinding(decoded, { col_a: 'asc' })).toThrow(/sorted query/)
|
|
expect(() => assertCursorSortBinding(decoded, undefined)).not.toThrow()
|
|
})
|
|
|
|
it('sort key order is significant (priority is part of the identity)', () => {
|
|
expect(canonicalSortKey({ a: 'asc', b: 'desc' })).not.toBe(
|
|
canonicalSortKey({ b: 'desc', a: 'asc' })
|
|
)
|
|
})
|
|
})
|