111 lines
5.1 KiB
JavaScript
111 lines
5.1 KiB
JavaScript
import assert from 'node:assert/strict'
|
|
import { readFileSync } from 'node:fs'
|
|
import test from 'node:test'
|
|
|
|
import {
|
|
EVENT_BRIDGE_RECOVERY_FIXTURE,
|
|
INTERNAL_TOKEN_COHORT_SERVICES,
|
|
recoveredEventBridgeFacts,
|
|
TEST_EVENT_BRIDGE_URLS,
|
|
validInternalTokenCohort,
|
|
validTestEventBridgeEnvironment,
|
|
} from './event-bridge-pending-recovery.mjs'
|
|
|
|
const read = (relativeUrl) => readFileSync(new URL(relativeUrl, import.meta.url), 'utf8')
|
|
const cnCompose = read('../../deploy/docker-compose.yml')
|
|
const overseasCompose = read('../../deploy/docker-compose.overseas.yml')
|
|
const deployBuilt = read('../../deploy/scripts/deploy-built-service.sh')
|
|
const deployServices = read('../../deploy/scripts/deploy-services.sh')
|
|
const crossRegionHttp = read('phase4-cross-region-events.mjs')
|
|
|
|
test('test bridge URLs use stable Compose DNS and internal port 9312 only', () => {
|
|
assert.deepEqual(TEST_EVENT_BRIDGE_URLS, {
|
|
LASTLEG_EVENT_BRIDGE_URL: 'http://event-bridge-overseas:9312',
|
|
FIRSTLEG_EVENT_BRIDGE_URL: 'http://event-bridge-cn:9312',
|
|
})
|
|
assert.equal(validTestEventBridgeEnvironment(TEST_EVENT_BRIDGE_URLS), true)
|
|
assert.equal(validTestEventBridgeEnvironment({
|
|
...TEST_EVENT_BRIDGE_URLS, LASTLEG_EVENT_BRIDGE_URL: 'http://172.31.198.8:9313',
|
|
}), false)
|
|
})
|
|
|
|
test('Compose wires both producers to the stable service aliases used by test env', () => {
|
|
assert.match(cnCompose, /LASTLEG_EVENT_BRIDGE_URL:\s*\$\{LASTLEG_EVENT_BRIDGE_URL\}/)
|
|
assert.match(overseasCompose,
|
|
/FIRSTLEG_EVENT_BRIDGE_URL:\s*\$\{CN_EVENT_BRIDGE_TARGET_URL:-http:\/\/event-bridge-cn:9312\}/)
|
|
assert.match(cnCompose, /aliases:\s*\[event-bridge-cn\]/)
|
|
assert.match(cnCompose,
|
|
/FINANCE_FEE_EVENT_CONSUMER_URL:\s*\$\{FINANCE_FEE_EVENT_CONSUMER_URL:-http:\/\/finance:9203\/internal\/finance\/v1\/business-fee-source-events\}/)
|
|
assert.match(overseasCompose, /aliases:\s*\[event-bridge-overseas\]/)
|
|
for (const source of [cnCompose, overseasCompose]) {
|
|
assert.doesNotMatch(source, /(?:LASTLEG|FIRSTLEG|CN)_EVENT_BRIDGE_URL:[^\n]*(?:\d{1,3}\.){3}\d{1,3}/)
|
|
assert.doesNotMatch(source, /(?:LASTLEG|FIRSTLEG|CN)_EVENT_BRIDGE_URL:[^\n]*:9313/)
|
|
}
|
|
})
|
|
|
|
test('all four recovery services inherit INTERNAL_SERVICE_TOKEN and deploy from one env file', () => {
|
|
assert.deepEqual(INTERNAL_TOKEN_COHORT_SERVICES, [
|
|
'firstleg', 'event-bridge-cn', 'event-bridge-overseas', 'lastleg-service',
|
|
])
|
|
assert.match(cnCompose, /x-common:\s*&common[\s\S]*INTERNAL_SERVICE_TOKEN:\s*\$\{INTERNAL_SERVICE_TOKEN\}/)
|
|
assert.match(overseasCompose,
|
|
/x-overseas-common:\s*&overseas-common[\s\S]*INTERNAL_SERVICE_TOKEN:\s*\$\{INTERNAL_SERVICE_TOKEN\}/)
|
|
assert.match(cnCompose, /firstleg:[\s\S]*<<:\s*\*common/)
|
|
assert.match(cnCompose, /event-bridge-service:[\s\S]*<<:\s*\*common/)
|
|
assert.match(overseasCompose, /lastleg-service:[\s\S]*<<:\s*\*overseas-common/)
|
|
assert.match(overseasCompose, /event-bridge-service:[\s\S]*<<:\s*\*overseas-common/)
|
|
for (const source of [deployBuilt, deployServices]) {
|
|
assert.match(source, /--env-file\s+"\$ENV_FILE"/)
|
|
}
|
|
assert.equal(validInternalTokenCohort({
|
|
firstleg: 'revision-20260827',
|
|
'event-bridge-cn': 'revision-20260827',
|
|
'event-bridge-overseas': 'revision-20260827',
|
|
'lastleg-service': 'revision-20260827',
|
|
}), true)
|
|
assert.equal(validInternalTokenCohort({
|
|
firstleg: 'revision-20260827',
|
|
'event-bridge-cn': 'revision-20260827',
|
|
'event-bridge-overseas': 'stale-revision',
|
|
'lastleg-service': 'revision-20260827',
|
|
}), false)
|
|
})
|
|
|
|
test('incident fixture records DNS recovery followed by retry81 token rejection', () => {
|
|
assert.deepEqual(EVENT_BRIDGE_RECOVERY_FIXTURE, {
|
|
customerCode: 'C10000000',
|
|
eventId: 'b569c7f6-3493-4a0f-a944-dd42698f183b',
|
|
initialOutboxStatus: 'PENDING',
|
|
initialRetryCount: 62,
|
|
failedTarget: '172.31.198.8:9313',
|
|
currentOutboxStatus: 'PENDING',
|
|
currentRetryCount: 81,
|
|
currentFailureCode: 'A0401',
|
|
currentFailureMessage: '内部服务令牌无效',
|
|
currentRequestId: '200edca3-428e-446d-977a-ca98a84dd704',
|
|
currentTraceId: 'e8e6d620c1cff40caa765e6968f89024',
|
|
dockerDnsProven: true,
|
|
})
|
|
})
|
|
|
|
test('post-rebuild convergence uses the original pending event with no replay or SQL repair', () => {
|
|
assert.equal(recoveredEventBridgeFacts({
|
|
firstlegOutboxStatus: 'SENT', overseasBridgeEventCount: 1,
|
|
lastlegInboxEventCount: 1, lastlegOrderCount: 1, cnBridgeDuplicateCount: 0,
|
|
manualReplayCount: 0, sqlMutationCount: 0,
|
|
}), true)
|
|
assert.equal(recoveredEventBridgeFacts({
|
|
firstlegOutboxStatus: 'SENT', overseasBridgeEventCount: 1,
|
|
lastlegInboxEventCount: 1, lastlegOrderCount: 2, cnBridgeDuplicateCount: 0,
|
|
manualReplayCount: 0, sqlMutationCount: 0,
|
|
}), false)
|
|
assert.equal(recoveredEventBridgeFacts({
|
|
firstlegOutboxStatus: 'SENT', overseasBridgeEventCount: 1,
|
|
lastlegInboxEventCount: 1, lastlegOrderCount: 1, cnBridgeDuplicateCount: 0,
|
|
manualReplayCount: 1, sqlMutationCount: 0,
|
|
}), false)
|
|
assert.match(crossRegionHttp, /const delivered = await poll/)
|
|
assert.match(crossRegionHttp, /deliveredRows\.length > 0/)
|
|
assert.match(crossRegionHttp, /sameIds\(delivered\.response\.body\?\.data, deliveredAgain\.body\?\.data\)/)
|
|
})
|