java-project/baiyue-firstleg
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

use PDA identity across downstream loading checks

Browse Source
This commit is contained in:
ouyangxq
2026-09-23 19:31:50 +08:00
parent b3b8ccaa18
commit 54a281b780
4 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scripts/admin-test-env-modules/manual-state-loading-pda.mjs
+1 -1
View File
@@ -37,7 +37,7 @@ async function ensureCompletionEvidence(context, chain, label) {
const form = new FormData()
form.append('file', new Blob([png], { type: 'image/png' }), `${label}-${evidenceType}.png`)
const rawUpload = await fetch(`${context.options.gateway}${uploadPath}`, {
method: 'POST', headers: { Accept: 'application/json', Authorization: `Bearer ${context.token}`,
method: 'POST', headers: { Accept: 'application/json', Authorization: `Bearer ${context.pdaToken || context.token}`,
'Idempotency-Key': operationId(context, `${label}-evidence-${evidenceType}`) },
body: form, signal: AbortSignal.timeout(60_000),
})
scripts/admin-test-env-modules/phase3-loading-finalize.mjs
+1 -1
View File
@@ -73,7 +73,7 @@ async function request(context, method, path, body, headers = {}) {
try {
const response = await fetch(`${context.options.gateway}${path}`, {
method,
headers: { Accept: 'application/json', Authorization: `Bearer ${context.token}`,
headers: { Accept: 'application/json', Authorization: `Bearer ${context.pdaToken && /\/pda-loading\/tasks\/\d+/.test(path) ? context.pdaToken : context.token}`,
...(body === undefined ? {} : { 'Content-Type': 'application/json; charset=utf-8' }), ...headers },
body: body === undefined ? undefined : JSON.stringify(body), signal: AbortSignal.timeout(60_000),
})
scripts/admin-test-env-modules/phase3-order-splitting.mjs
+3 -3
View File
@@ -45,13 +45,13 @@ function sameBookingTransport(left, right) {
return BOOKING_TRANSPORT_FIELDS.every((field) => left?.[field] === right?.[field])
}
async function request(context, method, path, body, headers = {}, token = context.token) {
async function request(context, method, path, body, headers = {}, token = undefined) {
try {
const response = await fetch(`${context.options.gateway}${path}`, {
method,
headers: {
Accept: 'application/json',
...(token ? { Authorization: `Bearer ${token}` } : {}),
...((token || (context.pdaToken && /\/pda-loading\/tasks\/\d+/.test(path) ? context.pdaToken : context.token)) ? { Authorization: `Bearer ${token || (context.pdaToken && /\/pda-loading\/tasks\/\d+/.test(path) ? context.pdaToken : context.token)}` } : {}),
...(body === undefined ? {} : { 'Content-Type': 'application/json; charset=utf-8' }),
...headers,
},
@@ -81,7 +81,7 @@ async function ensureCompletionEvidence(context, taskId, warehouseId, keyBase) {
const form = new FormData()
form.append('file', new Blob([png], { type: 'image/png' }), `${keyBase}-${evidenceType}.png`)
const rawUpload = await fetch(`${context.options.gateway}${uploadPath}`, {
method: 'POST', headers: { Accept: 'application/json', Authorization: `Bearer ${context.token}`,
method: 'POST', headers: { Accept: 'application/json', Authorization: `Bearer ${context.pdaToken || context.token}`,
'Idempotency-Key': `${keyBase}-evidence-${evidenceType}`.slice(0, 128) },
body: form, signal: AbortSignal.timeout(60_000),
})
scripts/admin-test-env-modules/phase3-pda-convergence.mjs
+1 -1
View File
@@ -11,7 +11,7 @@ export function buildPendingActions(task) {
async function request(context, method, path, body, headers = {}) {
try {
const response = await fetch(`${context.options.gateway}${path}`, { method,
headers: { Accept: 'application/json', Authorization: `Bearer ${context.token}`,
headers: { Accept: 'application/json', Authorization: `Bearer ${context.pdaToken && /\/pda-loading\/tasks\/\d+/.test(path) ? context.pdaToken : context.token}`,
...(body === undefined ? {} : { 'Content-Type': 'application/json; charset=utf-8' }), ...headers },
body: body === undefined ? undefined : JSON.stringify(body), signal: AbortSignal.timeout(60_000) })
const raw = await response.text(); let payload = null