(ctx context.Context, body []byte, headers http.Header, node models.CanvasNode, onNewEvents func([]models.CanvasEvent), recordExecution func(workflowID, executionID uuid.UUID))
| 1217 | } |
| 1218 | |
| 1219 | func (s *Server) executeWebhookNode(ctx context.Context, body []byte, headers http.Header, node models.CanvasNode, onNewEvents func([]models.CanvasEvent), recordExecution func(workflowID, executionID uuid.UUID)) (int, *core.WebhookResponseBody, error) { |
| 1220 | if node.Type == models.NodeTypeTrigger { |
| 1221 | return s.executeTriggerNode(ctx, body, headers, node, onNewEvents) |
| 1222 | } |
| 1223 | |
| 1224 | return s.executeActionNode(ctx, body, headers, node, onNewEvents, recordExecution) |
| 1225 | } |
| 1226 | |
| 1227 | func (s *Server) executeTriggerNode(ctx context.Context, body []byte, headers http.Header, node models.CanvasNode, onNewEvents func([]models.CanvasEvent)) (int, *core.WebhookResponseBody, error) { |
| 1228 | ref := node.Ref.Data() |
no test coverage detected