优化

2026-08-27 16:17:11 +08:00
parent 0f2e201c38
commit 1db3e48506
4 changed files with 314 additions and 0 deletions
@@ -0,0 +1,108 @@
+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(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\)/)
+})