support

package
v0.0.16 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 29, 2025 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AuthService

func AuthService(t *testing.T) *authorization.AuthService

func CreateBlueprint

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

func CreateNextNodeExecution

func CreateNextNodeExecution(
	t *testing.T,
	workflowID uuid.UUID,
	nodeID string,
	rootEventID uuid.UUID,
	eventID uuid.UUID,
	previous *uuid.UUID,
) *models.WorkflowNodeExecution

func CreateNodeExecutionWithConfiguration

func CreateNodeExecutionWithConfiguration(
	t *testing.T,
	workflowID uuid.UUID,
	nodeID string,
	rootEventID uuid.UUID,
	eventID uuid.UUID,
	parentExecutionID *uuid.UUID,
	configuration map[string]any,
) *models.WorkflowNodeExecution

func CreateOrganization

func CreateOrganization(t *testing.T, r *ResourceRegistry, userID uuid.UUID) *models.Organization

func CreateSecret

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

func CreateUser

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

func CreateWorkflow

func CreateWorkflow(t *testing.T, orgID uuid.UUID, userID uuid.UUID, nodes []models.WorkflowNode, edges []models.Edge) (*models.Workflow, []models.WorkflowNode)

func CreateWorkflowNodeExecution

func CreateWorkflowNodeExecution(
	t *testing.T,
	workflowID uuid.UUID,
	nodeID string,
	rootEventID uuid.UUID,
	eventID uuid.UUID,
	parentExecutionID *uuid.UUID,
) *models.WorkflowNodeExecution

func CreateWorkflowQueueItem

func CreateWorkflowQueueItem(t *testing.T, workflowID uuid.UUID, nodeID string, rootEventID uuid.UUID, eventID uuid.UUID) *models.WorkflowNodeQueueItem

func EmitWorkflowEventForNode

func EmitWorkflowEventForNode(t *testing.T, workflowID uuid.UUID, nodeID string, channel string, executionID *uuid.UUID) *models.WorkflowEvent

func EmitWorkflowEventForNodeWithData

func EmitWorkflowEventForNodeWithData(
	t *testing.T,
	workflowID uuid.UUID,
	nodeID string,
	channel string,
	executionID *uuid.UUID,
	data map[string]any,
) *models.WorkflowEvent

func RandomName

func RandomName(prefix string) string

func VerifyWorkflowEventsCount

func VerifyWorkflowEventsCount(t *testing.T, workflowID uuid.UUID, expected int)

func VerifyWorkflowNodeExecutionKVCount

func VerifyWorkflowNodeExecutionKVCount(t *testing.T, workflowID uuid.UUID, expected int)

func VerifyWorkflowNodeExecutionsCount

func VerifyWorkflowNodeExecutionsCount(t *testing.T, workflowID uuid.UUID, expected int)

func VerifyWorkflowNodeQueueCount

func VerifyWorkflowNodeQueueCount(t *testing.T, workflowID uuid.UUID, expected int)

func VerifyWorkflowNodeRequestCount

func VerifyWorkflowNodeRequestCount(t *testing.T, workflowID uuid.UUID, expected int)

Types

type DummyApplication

type DummyApplication struct {
	// contains filtered or unexported fields
}

func NewDummyApplication

func NewDummyApplication(onSync func(ctx core.SyncContext) error) *DummyApplication

func (*DummyApplication) CleanupWebhook

func (t *DummyApplication) CleanupWebhook(ctx core.AppInstallationContext, options core.WebhookOptions) error

func (*DummyApplication) CompareWebhookConfig

func (t *DummyApplication) CompareWebhookConfig(a, b any) (bool, error)

func (*DummyApplication) Components

func (t *DummyApplication) Components() []core.Component

func (*DummyApplication) Configuration

func (t *DummyApplication) Configuration() []configuration.Field

func (*DummyApplication) Description

func (t *DummyApplication) Description() string

func (*DummyApplication) HandleRequest

func (t *DummyApplication) HandleRequest(ctx core.HTTPRequestContext)

func (*DummyApplication) Icon

func (t *DummyApplication) Icon() string

func (*DummyApplication) Label

func (t *DummyApplication) Label() string

func (*DummyApplication) Name

func (t *DummyApplication) Name() string

func (*DummyApplication) SetupWebhook

func (t *DummyApplication) SetupWebhook(ctx core.AppInstallationContext, options core.WebhookOptions) (any, error)

func (*DummyApplication) Sync

func (t *DummyApplication) Sync(ctx core.SyncContext) error

func (*DummyApplication) Triggers

func (t *DummyApplication) Triggers() []core.Trigger

type ResourceRegistry

type ResourceRegistry struct {
	User         uuid.UUID
	UserModel    *models.User
	Organization *models.Organization
	Account      *models.Account
	Integration  *models.Integration
	Encryptor    crypto.Encryptor
	AuthService  *authorization.AuthService
	Registry     *registry.Registry
}

func Setup

func Setup(t *testing.T) *ResourceRegistry

func SetupWithOptions

func SetupWithOptions(t *testing.T, options SetupOptions) *ResourceRegistry

func (*ResourceRegistry) Close

func (r *ResourceRegistry) Close()

type SetupOptions

type SetupOptions struct {
	Source    bool
	Stage     bool
	Approvals int
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL