mirror of
https://github.com/stablyai/orca.git
synced 2026-09-29 08:03:20 +00:00
* fix(push): bound the delivery claim and stop keeping finished batches * fix(push): bound claim scans to the notification TTL and document the queue * test(push): boot waits out a table writer for the queue indexes; queue stays correct without them * fix(push): share the claim lock so a previous-revision claim cannot re-lease a delivery During a deploy overlap the previous revision's claim scans under an exclusive push-worker-claim lock and re-reads the row without checking lease_until, so it could overwrite a lease this revision had just committed and send twice. The new claim now takes the same key shared: new claimers never block each other, and the previous claim waits until their leases commit before it scans. Droppable one release after every worker runs this revision. * fix(push): install one queue index at boot, not three push_batches_leased_device indexed lease_until, so every lease, renew and finish UPDATE lost heap-only eligibility and rewrote every index. push_batches_pending_due was unused: on a synthetic 902k-row table the candidate scan plans onto the existing (state, due_at) and expiry indexes with or without it. The per-device pending index stays; the head check and the busy anti-join use it. Fewer boot-time builds also shorten the SHARE lock the first boot takes on the table. * test(push): pin the claim's TTL scan bound and the server's worker connection cap Removing either guard left the suite green. The claim test captures every row the candidate scan returns and plants one row that only the TTL term excludes; the server test drives the real worker through createPushServer and fails when the request-connection reservation is unwired (peak 4 instead of 2). * fix(push): renew delivery leases outside the background connection cap Renew shared the single background slot with claim retries and prune batches, so a heartbeat could wait long enough for a lease to lapse and the delivery to be re-leased mid-send. It is a keyed one-row UPDATE, so request traffic cannot starve it on the ungated pool. * docs(push): describe the shared claim lock for mixed-revision deploys
165 lines
5.9 KiB
TypeScript
165 lines
5.9 KiB
TypeScript
import { PUSH_LIMITS } from '@orca-cloud/push-contract'
|
|
import { afterEach, beforeEach, describe, expect, it } from 'vitest'
|
|
import { createPushHostKeypair } from './host-challenge-answering.test-fixture.js'
|
|
import type { PushDatabase } from './push-database.js'
|
|
import { createPushServer } from './push-server.js'
|
|
import {
|
|
createPushServerHarness,
|
|
testPushConfig
|
|
} from './push-server-harness.test-fixture.js'
|
|
|
|
describe('push gateway authentication and device routes', () => {
|
|
let harness: Awaited<ReturnType<typeof createPushServerHarness>>
|
|
|
|
beforeEach(async () => {
|
|
harness = await createPushServerHarness()
|
|
})
|
|
|
|
afterEach(async () => {
|
|
await harness.close()
|
|
})
|
|
|
|
it('answers health unconditionally and ready from the database', async () => {
|
|
expect((await harness.server.app.request('/health')).status).toBe(200)
|
|
expect((await harness.server.app.request('/ready')).status).toBe(200)
|
|
})
|
|
|
|
it('reports not ready when the database is unreachable', async () => {
|
|
const unreachable: PushDatabase = {
|
|
dialect: 'sqlite',
|
|
query: async () => {
|
|
throw new Error('no connection')
|
|
},
|
|
transaction: async (operation) => await operation(unreachable),
|
|
lockQuotaScope: async () => undefined,
|
|
tryLockScope: async () => true,
|
|
tryLockSharedScope: async () => true,
|
|
close: async () => undefined
|
|
}
|
|
const broken = createPushServer(testPushConfig(), unreachable, {
|
|
fcmAccessToken: async () => 'token',
|
|
fcmTransport: async () => ({ status: 200, body: '{}' })
|
|
})
|
|
expect((await broken.app.request('/health')).status).toBe(200)
|
|
expect((await broken.app.request('/ready')).status).toBe(503)
|
|
await broken.worker.stop()
|
|
})
|
|
|
|
it('completes challenge, session, register, list, delete', async () => {
|
|
const sessionToken = await harness.signIn(createPushHostKeypair(11))
|
|
const registrationId = await harness.registerAndroid(sessionToken)
|
|
|
|
const list = await harness.authorized('/v1/devices', {}, sessionToken)
|
|
expect(await list.json()).toEqual({
|
|
devices: [{ registrationId, deviceId: 'device-1', platform: 'android', dead: false }]
|
|
})
|
|
|
|
const deleted = await harness.authorized(
|
|
`/v1/devices/${registrationId}`,
|
|
{ method: 'DELETE' },
|
|
sessionToken
|
|
)
|
|
expect(deleted.status).toBe(204)
|
|
expect(await harness.server.devices.findById(registrationId)).toBeNull()
|
|
})
|
|
|
|
it('refuses a request with no bearer, a bogus bearer, and an expired session', async () => {
|
|
const sessionToken = await harness.signIn(createPushHostKeypair(12))
|
|
expect((await harness.server.app.request('/v1/devices')).status).toBe(401)
|
|
const bogus = await harness.authorized('/v1/devices', {}, 'nonsense')
|
|
expect(bogus.status).toBe(401)
|
|
expect(await bogus.json()).toEqual({ error: 'invalid_token' })
|
|
|
|
harness.advanceClock(PUSH_LIMITS.sessionTtlMs + 1)
|
|
const expired = await harness.authorized('/v1/devices', {}, sessionToken)
|
|
expect(expired.status).toBe(401)
|
|
expect(await expired.json()).toEqual({ error: 'session_expired' })
|
|
})
|
|
|
|
it('refuses a replayed proof and an unknown challenge', async () => {
|
|
const host = createPushHostKeypair(13)
|
|
const challenge = await harness.issueChallenge(host)
|
|
const proof = harness.answer(challenge, host)
|
|
expect(
|
|
(
|
|
await harness.post('/v1/host/session', {
|
|
v: 1,
|
|
challengeId: challenge.challengeId,
|
|
proofB64: proof
|
|
})
|
|
).status
|
|
).toBe(200)
|
|
|
|
const replay = await harness.post('/v1/host/session', {
|
|
v: 1,
|
|
challengeId: challenge.challengeId,
|
|
proofB64: proof
|
|
})
|
|
expect(replay.status).toBe(401)
|
|
expect(await replay.json()).toEqual({ error: 'invalid_proof' })
|
|
|
|
const unknown = await harness.post('/v1/host/session', {
|
|
v: 1,
|
|
challengeId: 'no-such-challenge',
|
|
proofB64: proof
|
|
})
|
|
expect(await unknown.json()).toEqual({ error: 'invalid_challenge' })
|
|
})
|
|
|
|
it('never returns the host fingerprint on the challenge itself', async () => {
|
|
const challenge = await harness.issueChallenge(createPushHostKeypair(22))
|
|
expect(Object.keys(challenge).sort()).toEqual([
|
|
'challengeId',
|
|
'ciphertextB64',
|
|
'expiresAt',
|
|
'gatewayEphemeralPublicKeyB64',
|
|
'nonceB64'
|
|
])
|
|
})
|
|
|
|
it('lets only the owning host delete a registration', async () => {
|
|
const ownerToken = await harness.signIn(createPushHostKeypair(14))
|
|
const intruderToken = await harness.signIn(createPushHostKeypair(15))
|
|
const registrationId = await harness.registerAndroid(ownerToken)
|
|
|
|
const forbidden = await harness.authorized(
|
|
`/v1/devices/${registrationId}`,
|
|
{ method: 'DELETE' },
|
|
intruderToken
|
|
)
|
|
expect(forbidden.status).toBe(404)
|
|
expect(await forbidden.json()).toEqual({ error: 'not_found' })
|
|
expect(await harness.server.devices.findById(registrationId)).not.toBeNull()
|
|
})
|
|
|
|
it('replaces the token on a re-registration and keeps one registration id', async () => {
|
|
const sessionToken = await harness.signIn(createPushHostKeypair(23))
|
|
const first = await harness.registerAndroid(sessionToken)
|
|
const again = await harness.post(
|
|
'/v1/devices',
|
|
{
|
|
v: 1,
|
|
deviceId: 'device-1',
|
|
platform: 'android',
|
|
token: 'rotated_token:APA91b-newnewnewnewnewnewnewnewnewnew'
|
|
},
|
|
sessionToken
|
|
)
|
|
expect(await again.json()).toEqual({ registrationId: first })
|
|
expect(await harness.server.devices.findById(first)).toMatchObject({
|
|
token: 'rotated_token:APA91b-newnewnewnewnewnewnewnewnewnew'
|
|
})
|
|
})
|
|
|
|
it('rejects a malformed registration body', async () => {
|
|
const sessionToken = await harness.signIn(createPushHostKeypair(16))
|
|
const bad = await harness.post(
|
|
'/v1/devices',
|
|
{ v: 1, deviceId: 'device-1', platform: 'ios', token: 'not-hex' },
|
|
sessionToken
|
|
)
|
|
expect(bad.status).toBe(400)
|
|
expect(await bad.json()).toEqual({ error: 'invalid_request' })
|
|
})
|
|
})
|