mirror of
https://github.com/stablyai/orca.git
synced 2026-10-01 00:02:10 +00:00
Jinwoo Hong
eb2f2d52ae
* refactor(cloud): share PostgreSQL schema startup between services * feat(cloud): add durable native push notification gateway * infra(push): define dedicated gateway resources and operational checks * fix(push): bound cross-host admission and simplify gateway configuration * fix(push): validate deploy configuration and preserve topic-error registrations
49 lines
1.5 KiB
TypeScript
49 lines
1.5 KiB
TypeScript
import { expect, it } from 'vitest'
|
|
import { createPushHostKeypair } from './host-challenge-answering.test-fixture.js'
|
|
import {
|
|
APNS_TOKEN,
|
|
createPushServerHarness,
|
|
notification
|
|
} from './push-server-harness.test-fixture.js'
|
|
|
|
it('delivers again after a topic error without re-registering the phone', async () => {
|
|
const h = await createPushServerHarness()
|
|
try {
|
|
const token = await h.signIn(createPushHostKeypair(71))
|
|
const registered = await h.post(
|
|
'/v1/devices',
|
|
{
|
|
v: 1,
|
|
deviceId: 'phone',
|
|
platform: 'ios',
|
|
token: APNS_TOKEN,
|
|
apnsEnvironment: 'sandbox'
|
|
},
|
|
token
|
|
)
|
|
const { registrationId } = (await registered.json()) as { registrationId: string }
|
|
h.setApnsResponse({ status: 400, body: JSON.stringify({ reason: 'DeviceTokenNotForTopic' }) })
|
|
for (const seq of [1, 2]) {
|
|
const sent = await h.post(
|
|
'/v1/send',
|
|
{
|
|
v: 1,
|
|
registrationIds: [registrationId],
|
|
notification: notification({ notificationId: `topic-${seq}`, notificationSeq: seq })
|
|
},
|
|
token
|
|
)
|
|
expect(await sent.json()).toEqual({ results: [{ registrationId, status: 'queued' }] })
|
|
await h.flushDeliveries()
|
|
if (seq === 1) {
|
|
expect(h.server.observability.consume().delivery_error).toBe(1)
|
|
h.setApnsResponse({ status: 200, body: '' })
|
|
}
|
|
}
|
|
expect(h.apnsRequests).toHaveLength(2)
|
|
expect(h.server.observability.consume().delivery_sent).toBe(1)
|
|
} finally {
|
|
await h.close()
|
|
}
|
|
})
|