support

package
v0.18.0 Latest Latest
Warning

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

Go to latest
Published: Apr 27, 2026 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateBlueprint

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

func CreateCanvas added in v0.6.0

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

func CreateCanvasNodeExecution added in v0.6.0

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

func CreateNextNodeExecution

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

func CreateNodeExecutionWithConfiguration

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

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

func CreateQueueItem added in v0.6.0

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

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 EmitCanvasEventForNode added in v0.6.0

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

func EmitCanvasEventForNodeWithData added in v0.6.0

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

func NewOIDCProvider added in v0.1.1

func NewOIDCProvider() oidc.Provider

func RandomName

func RandomName(prefix string) string

func VerifyCanvasEventsCount added in v0.6.0

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

func VerifyCanvasNodeEventsCount added in v0.7.0

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

func VerifyNodeExecutionKVCount added in v0.6.0

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

func VerifyNodeExecutionsCount added in v0.6.0

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

func VerifyNodeQueueCount added in v0.6.0

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

func VerifyNodeRequestCount added in v0.6.0

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

Types

type ResourceRegistry

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

func Setup

func SetupWithOptions

func SetupWithOptions(t require.TestingT, options SetupOptions) *ResourceRegistry

func (*ResourceRegistry) Close

func (r *ResourceRegistry) Close()

type SetupOptions

type SetupOptions struct {
	Source    bool
	Stage     bool
	Approvals int
}

type TestOIDCProvider added in v0.1.1

type TestOIDCProvider struct{}

func (*TestOIDCProvider) PublicJWKs added in v0.1.1

func (p *TestOIDCProvider) PublicJWKs() []oidc.PublicJWK

func (*TestOIDCProvider) Sign added in v0.1.1

func (p *TestOIDCProvider) Sign(subject string, duration time.Duration, audience string, additionalClaims map[string]any) (string, error)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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