Method executeTriggerNode

pkg/public/server.go:1227–1260

(ctx context.Context, body []byte, headers http.Header, node models.CanvasNode, onNewEvents func([]models.CanvasEvent))

}

func (s *Server) executeTriggerNode(ctx context.Context, body []byte, headers http.Header, node models.CanvasNode, onNewEvents func([]models.CanvasEvent)) (int, *core.WebhookResponseBody, error) {
	ref := node.Ref.Data()
	trigger, err := s.registry.GetTrigger(ref.Trigger.Name)
	if err != nil {
		return http.StatusInternalServerError, nil, fmt.Errorf("trigger not found: %w", err)
	}

	logger := logging.ForNode(node)
	tx := database.Conn()
	var integrationCtx core.IntegrationContext
	if node.AppInstallationID != nil {
		integration, integrationErr := models.FindUnscopedIntegrationInTransaction(tx, *node.AppInstallationID)
		if integrationErr != nil {
			return http.StatusInternalServerError, nil, integrationErr
		}

		logger = logging.WithIntegration(logger, *integration)
		integrationCtx = contexts.NewIntegrationContext(tx, &node, integration, s.encryptor, s.registry, onNewEvents)
	}

	return trigger.HandleWebhook(core.WebhookRequestContext{
		Body:          body,
		Headers:       headers,
		WorkflowID:    node.WorkflowID.String(),
		NodeID:        node.NodeID,
		Configuration: node.Configuration.Data(),
		Metadata:      contexts.NewNodeMetadataContext(tx, &node),
		Logger:        logger,
		HTTP:          s.registry.HTTPContext(),
		Webhook:       contexts.NewNodeWebhookContext(ctx, tx, s.encryptor, &node, s.BaseURL+s.BasePath),
		Events:        contexts.NewEventContext(tx, &node, onNewEvents),
		Integration:   integrationCtx,
	})
}

func (s *Server) executeActionNode(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) {
	ref := node.Ref.Data()