support

func AuthService(t require.TestingT) *authorization.AuthService

func CreateBlueprint(t *testing.T, orgID uuid.UUID, nodes []models.Node, edges []models.Edge, outputChannels []models.BlueprintOutputChannel) *models.Blueprint

func CreateCanvas(t require.TestingT, orgID uuid.UUID, userID uuid.UUID, nodes []models.CanvasNode, edges []models.Edge) (*models.Canvas, []models.CanvasNode)

func CreateCanvasNodeExecution(
	t require.TestingT,
	canvasID uuid.UUID,
	nodeID string,
	rootEventID uuid.UUID,
	eventID uuid.UUID,
	parentExecutionID *uuid.UUID,
) *models.CanvasNodeExecution

func CreateIntegrationWithCapabilities(
	t require.TestingT,
	organizationID uuid.UUID,
	capabilities []models.CapabilityState,
) *models.Integration

func CreateNextNodeExecution(
	t require.TestingT,
	workflowID uuid.UUID,
	nodeID string,
	rootEventID uuid.UUID,
	eventID uuid.UUID,
	previous *uuid.UUID,
) *models.CanvasNodeExecution

func CreateNodeExecutionWithConfiguration(
	t require.TestingT,
	workflowID uuid.UUID,
	nodeID string,
	rootEventID uuid.UUID,
	eventID uuid.UUID,
	parentExecutionID *uuid.UUID,
	configuration map[string]any,
) *models.CanvasNodeExecution

func CreateOrganization(t require.TestingT, r *ResourceRegistry, userID uuid.UUID) *models.Organization

func CreateQueueItem(t require.TestingT, workflowID uuid.UUID, nodeID string, rootEventID uuid.UUID, eventID uuid.UUID) *models.CanvasNodeQueueItem

func CreateSecret(t *testing.T, r *ResourceRegistry, secretData map[string]string) (*models.Secret, error)

func CreateUser(t *testing.T, r *ResourceRegistry, organizationID uuid.UUID) *models.User

func EmitCanvasEventForNode(t require.TestingT, canvasID uuid.UUID, nodeID string, channel string, executionID *uuid.UUID) *models.CanvasEvent

func EmitCanvasEventForNodeWithData(
	t require.TestingT,
	canvasID uuid.UUID,
	nodeID string,
	channel string,
	executionID *uuid.UUID,
	data map[string]any,
) *models.CanvasEvent

func NewOIDCProvider() oidc.Provider

func RandomName(prefix string) string

func SetCanvasChangeManagementEnabled(t require.TestingT, canvasID uuid.UUID, enabled bool)

func VerifyCanvasEventsCount(t require.TestingT, canvasID uuid.UUID, expected int)

func VerifyCanvasNodeEventsCount(t require.TestingT, canvasID uuid.UUID, nodeID string, expected int)

func VerifyNodeExecutionKVCount(t require.TestingT, workflowID uuid.UUID, expected int)

func VerifyNodeExecutionsCount(t require.TestingT, workflowID uuid.UUID, expected int)

func VerifyNodeQueueCount(t require.TestingT, workflowID uuid.UUID, expected int)

func VerifyNodeRequestCount(t require.TestingT, workflowID uuid.UUID, expected int)