diff --git a/.changeset/dark-olives-fix.md b/.changeset/dark-olives-fix.md new file mode 100644 index 0000000000..2e488bb01e --- /dev/null +++ b/.changeset/dark-olives-fix.md @@ -0,0 +1,5 @@ +--- +"@workflow/world-vercel": patch +--- + +Update headers from x-workflow-run-id and x-workflow-step-id to x-vercel-workflow-run-id and x-vercel-workflow-step-id in order to align with header naming convention diff --git a/packages/world-vercel/src/queue.test.ts b/packages/world-vercel/src/queue.test.ts index b0a587fc69..b9097ef1f2 100644 --- a/packages/world-vercel/src/queue.test.ts +++ b/packages/world-vercel/src/queue.test.ts @@ -180,7 +180,7 @@ describe('createQueue', () => { } }); - it('should auto-inject x-workflow-run-id header for workflow payloads', async () => { + it('should auto-inject x-vercel-workflow-run-id header for workflow payloads', async () => { mockSend.mockResolvedValue({ messageId: 'msg-123' }); const originalEnv = process.env.VERCEL_DEPLOYMENT_ID; @@ -196,7 +196,7 @@ describe('createQueue', () => { expect(sendOpts).toEqual( expect.objectContaining({ headers: expect.objectContaining({ - 'x-workflow-run-id': 'wrun_abc123', + 'x-vercel-workflow-run-id': 'wrun_abc123', }), }) ); @@ -209,7 +209,7 @@ describe('createQueue', () => { } }); - it('should auto-inject x-workflow-run-id and x-workflow-step-id headers for step payloads', async () => { + it('should auto-inject x-vercel-workflow-run-id and x-vercel-workflow-step-id headers for step payloads', async () => { mockSend.mockResolvedValue({ messageId: 'msg-123' }); const originalEnv = process.env.VERCEL_DEPLOYMENT_ID; @@ -230,8 +230,8 @@ describe('createQueue', () => { expect(sendOpts).toEqual( expect.objectContaining({ headers: expect.objectContaining({ - 'x-workflow-run-id': 'wrun_abc123', - 'x-workflow-step-id': 'step_xyz789', + 'x-vercel-workflow-run-id': 'wrun_abc123', + 'x-vercel-workflow-step-id': 'step_xyz789', }), }) ); @@ -283,7 +283,7 @@ describe('createQueue', () => { { runId: 'wrun_abc123' }, { headers: { - 'x-workflow-run-id': 'wrun_override', + 'x-vercel-workflow-run-id': 'wrun_override', 'x-custom-header': 'custom-value', }, } @@ -293,7 +293,7 @@ describe('createQueue', () => { // send(topicName, payload, options) const sendOpts = mockSend.mock.calls[0][2]; expect(sendOpts.headers).toEqual({ - 'x-workflow-run-id': 'wrun_override', + 'x-vercel-workflow-run-id': 'wrun_override', 'x-custom-header': 'custom-value', }); } finally { @@ -550,7 +550,7 @@ describe('createQueue', () => { expect(mockSend).not.toHaveBeenCalled(); }); - it('should auto-inject x-workflow-run-id header on delayed re-enqueue', async () => { + it('should auto-inject x-vercel-workflow-run-id header on delayed re-enqueue', async () => { mockSend.mockResolvedValue({ messageId: 'new-msg-123' }); const handler = setupHandler({ timeoutSeconds: 300 }); @@ -569,7 +569,7 @@ describe('createQueue', () => { expect(sendOpts).toEqual( expect.objectContaining({ headers: expect.objectContaining({ - 'x-workflow-run-id': 'wrun_abc123', + 'x-vercel-workflow-run-id': 'wrun_abc123', }), }) ); @@ -601,8 +601,8 @@ describe('createQueue', () => { expect(sendOpts).toEqual( expect.objectContaining({ headers: expect.objectContaining({ - 'x-workflow-run-id': 'wrun_abc123', - 'x-workflow-step-id': 'step_xyz789', + 'x-vercel-workflow-run-id': 'wrun_abc123', + 'x-vercel-workflow-step-id': 'step_xyz789', }), }) ); diff --git a/packages/world-vercel/src/queue.ts b/packages/world-vercel/src/queue.ts index d0e89875c8..7e82527b01 100644 --- a/packages/world-vercel/src/queue.ts +++ b/packages/world-vercel/src/queue.ts @@ -62,13 +62,13 @@ function getHeadersFromPayload( const headers: Record = {}; if ('runId' in payload && typeof payload.runId === 'string') { - headers['x-workflow-run-id'] = payload.runId; + headers['x-vercel-workflow-run-id'] = payload.runId; } if ('workflowRunId' in payload && typeof payload.workflowRunId === 'string') { - headers['x-workflow-run-id'] = payload.workflowRunId; + headers['x-vercel-workflow-run-id'] = payload.workflowRunId; } if ('stepId' in payload && typeof payload.stepId === 'string') { - headers['x-workflow-step-id'] = payload.stepId; + headers['x-vercel-workflow-step-id'] = payload.stepId; } return Object.keys(headers).length > 0 ? headers : undefined;