( payload: WebhookExecutionPayload )
| 127 | } |
| 128 | |
| 129 | export function buildWebhookCorrelation( |
| 130 | payload: WebhookExecutionPayload |
| 131 | ): AsyncExecutionCorrelation { |
| 132 | const executionId = payload.executionId || generateId() |
| 133 | const requestId = payload.requestId || payload.correlation?.requestId || executionId.slice(0, 8) |
| 134 | |
| 135 | return { |
| 136 | executionId, |
| 137 | requestId, |
| 138 | source: 'webhook', |
| 139 | workflowId: payload.workflowId, |
| 140 | webhookId: payload.webhookId, |
| 141 | path: payload.path, |
| 142 | provider: payload.provider, |
| 143 | triggerType: payload.correlation?.triggerType || 'webhook', |
| 144 | } |
| 145 | } |
| 146 | |
| 147 | /** |
| 148 | * Process trigger outputs based on their schema definitions. |
no test coverage detected