contexts

May 4, 2026

Changes in this version

+ type CapabilityContext struct

+ func NewCapabilityContext(definitions []core.Capability, states []models.CapabilityState) *CapabilityContext

+ func (c *CapabilityContext) Available(capabilities ...string)

+ func (c *CapabilityContext) Clear()

+ func (c *CapabilityContext) Disable(capabilities ...string)

+ func (c *CapabilityContext) Enable(capabilities ...string)

+ func (c *CapabilityContext) IsRequested(capabilities ...string) bool

+ func (c *CapabilityContext) Request(capabilities ...string)

+ func (c *CapabilityContext) Requested() []string

+ func (c *CapabilityContext) States() []models.CapabilityState

+ func (c *CapabilityContext) Unavailable(capabilities ...string)

type IntegrationContext

+ func (c *IntegrationContext) LegacySetup() bool

+ func (c *IntegrationContext) Properties() core.IntegrationPropertyStorage

+ func (c *IntegrationContext) Secrets() core.IntegrationSecretStorage

+ type IntegrationPropertyStorage struct

+ func NewIntegrationPropertyStorage(integration *models.Integration) *IntegrationPropertyStorage

+ func (s *IntegrationPropertyStorage) Create(def core.IntegrationPropertyDefinition) error

+ func (s *IntegrationPropertyStorage) CreateMany(defs []core.IntegrationPropertyDefinition) error

+ func (s *IntegrationPropertyStorage) Delete(names ...string) error

+ func (s *IntegrationPropertyStorage) Get(name string) (any, error)

+ func (s *IntegrationPropertyStorage) GetString(name string) (string, error)

+ type IntegrationSecretStorage struct

+ func NewIntegrationSecretStorage(tx *gorm.DB, encryptor crypto.Encryptor, integration *models.Integration) *IntegrationSecretStorage

+ func (s *IntegrationSecretStorage) Create(def core.IntegrationSecretDefinition) error

+ func (s *IntegrationSecretStorage) CreateMany(defs []core.IntegrationSecretDefinition) error

+ func (s *IntegrationSecretStorage) Delete(name string) error

+ func (s *IntegrationSecretStorage) Get(name string) (string, error)

+ func (s *IntegrationSecretStorage) Update(name string, value string) error

Apr 27, 2026

Changes in this version

type NodeConfigurationBuilder

+ func (b *NodeConfigurationBuilder) WithRootPayload(payload any) *NodeConfigurationBuilder

Apr 17, 2026

Changes in this version

+ type AuthReader struct

+ func NewAuthReader(tx *gorm.DB, orgID uuid.UUID, authService authorization.Authorization, ...) *AuthReader

+ func (c *AuthReader) AuthenticatedUser() *core.User

+ func (c *AuthReader) GetGroup(name string) (*core.GroupRef, error)

+ func (c *AuthReader) GetRole(name string) (*core.RoleRef, error)

+ func (c *AuthReader) GetUser(id uuid.UUID) (*core.User, error)

+ func (c *AuthReader) HasRole(role string) (bool, error)

+ func (c *AuthReader) InGroup(group string) (bool, error)

Apr 13, 2026

Changes in this version

type AuthContext

+ func (c *AuthContext) GetGroup(name string) (*core.GroupRef, error)

+ func (c *AuthContext) GetRole(name string) (*core.RoleRef, error)

+ type ExpressionContext struct

+ func NewExpressionContext(configurationBuilder *NodeConfigurationBuilder) *ExpressionContext

+ func (c *ExpressionContext) Run(expression string) (any, error)

type NodeConfigurationBuilder

+ func (b *NodeConfigurationBuilder) ResolveTemplateExpressions(expression string) (any, error)

Mar 22, 2026

Changes in this version

type NotificationContext

+ func (c *NotificationContext) IsAvailable() bool

Mar 1, 2026

Changes in this version

+ type CanvasMemoryContext struct

+ func NewCanvasMemoryContext(tx *gorm.DB, canvasID uuid.UUID) *CanvasMemoryContext

+ func (c *CanvasMemoryContext) Add(namespace string, values any) error

+ func (c *CanvasMemoryContext) Delete(namespace string, matches map[string]any) ([]any, error)

+ func (c *CanvasMemoryContext) Find(namespace string, matches map[string]any) ([]any, error)

+ func (c *CanvasMemoryContext) FindFirst(namespace string, matches map[string]any) (any, error)

+ func (c *CanvasMemoryContext) Update(namespace string, matches map[string]any, values map[string]any) ([]any, error)

type NodeWebhookContext

+ func (c *NodeWebhookContext) SetSecret(secret []byte) error

Feb 22, 2026

Changes in this version

type IntegrationContext

+ func (c *IntegrationContext) FindSubscription(predicate func(core.IntegrationSubscriptionContext) bool) (core.IntegrationSubscriptionContext, error)

+ func (c *IntegrationContext) GetOptionalConfig(name string) ([]byte, error)

Feb 8, 2026

Changes in this version

+ const DefaultMaxPayloadSize

+ type SecretsContext struct

+ func NewSecretsContext(tx *gorm.DB, organizationID uuid.UUID, encryptor crypto.Encryptor) *SecretsContext

+ func (c *SecretsContext) GetKey(secretName, keyName string) ([]byte, error)

Feb 1, 2026

Changes in this version

type IntegrationContext

+ func (c *IntegrationContext) Error(message string)

+ func (c *IntegrationContext) Ready()

+ func (c *IntegrationContext) ScheduleActionCall(actionName string, parameters any, interval time.Duration) error

Jan 27, 2026

Changes in this version

+ func NewIntegrationSubscriptionContext(tx *gorm.DB, registry *registry.Registry, ...) core.IntegrationSubscriptionContext

type IntegrationContext

+ func (c *IntegrationContext) GetConfig(name string) ([]byte, error)

+ func (c *IntegrationContext) GetMetadata() any

+ func (c *IntegrationContext) GetSecrets() ([]core.IntegrationSecret, error)

+ func (c *IntegrationContext) GetState() string

+ func (c *IntegrationContext) ID() uuid.UUID

+ func (c *IntegrationContext) ListSubscriptions() ([]core.IntegrationSubscriptionContext, error)

+ func (c *IntegrationContext) NewBrowserAction(action core.BrowserAction)

+ func (c *IntegrationContext) RemoveBrowserAction()

+ func (c *IntegrationContext) RequestWebhook(configuration any) error

+ func (c *IntegrationContext) ScheduleResync(interval time.Duration) error

+ func (c *IntegrationContext) SetMetadata(value any)

+ func (c *IntegrationContext) SetSecret(name string, value []byte) error

+ func (c *IntegrationContext) SetState(state, stateDescription string)

+ func (c *IntegrationContext) Subscribe(configuration any) (*uuid.UUID, error)

+ type IntegrationSubscriptionContext struct

+ func (c *IntegrationSubscriptionContext) Configuration() any

+ func (c *IntegrationSubscriptionContext) SendMessage(message any) error

Jan 26, 2026

Changes in this version

type NodeConfigurationBuilder

+ func (b *NodeConfigurationBuilder) WithNodeID(nodeID string) *NodeConfigurationBuilder

Jan 23, 2026

Changes in this version

type NodeConfigurationBuilder

+ func (b *NodeConfigurationBuilder) BuildExpressionEnv(expression string) (map[string]any, error)

Jan 21, 2026

Changes in this version

+ func NewAppSubscriptionContext(tx *gorm.DB, registry *registry.Registry, ...) core.AppSubscriptionContext

type AppInstallationContext

+ func (c *AppInstallationContext) ListSubscriptions() ([]core.AppSubscriptionContext, error)

+ func (c *AppInstallationContext) Subscribe(configuration any) (*uuid.UUID, error)

+ type AppSubscriptionContext struct

+ func (c *AppSubscriptionContext) Configuration() any

+ func (c *AppSubscriptionContext) SendMessage(message any) error

type NodeConfigurationBuilder

+ func (b *NodeConfigurationBuilder) BuildMessageChainForExpression(expression string) (map[string]any, error)

+ func (b *NodeConfigurationBuilder) WithConfigurationFields(fields []configuration.Field) *NodeConfigurationBuilder

Jan 15, 2026

Changes in this version

+ func NewHTTPContext(httpClient *http.Client) core.HTTPContext

+ type HTTPContext struct

+ func (c *HTTPContext) Do(request *http.Request) (*http.Response, error)

+ type NotificationContext struct

+ func NewNotificationContext(tx *gorm.DB, orgID, workflowID uuid.UUID) *NotificationContext

+ func (c *NotificationContext) Send(title, body, url, urlLabel string, receivers core.NotificationReceivers) error

Jan 7, 2026

Changes in this version

+ type NodeWebhookContext struct

+ func NewNodeWebhookContext(ctx context.Context, tx *gorm.DB, encryptor crypto.Encryptor, ...) *NodeWebhookContext

+ func (c *NodeWebhookContext) GetBaseURL() string

+ func (c *NodeWebhookContext) GetSecret() ([]byte, error)

+ func (c *NodeWebhookContext) ResetSecret() ([]byte, []byte, error)

+ func (c *NodeWebhookContext) Setup(options *core.WebhookSetupOptions) (string, error)

type WebhookContext

+ func (c *WebhookContext) GetConfiguration() any

+ func (c *WebhookContext) GetID() string

+ func (c *WebhookContext) GetMetadata() any

+ func (c *WebhookContext) GetURL() string

+ func (c *WebhookContext) SetSecret(secret []byte) error

Jan 6, 2026

Changes in this version

type AppInstallationContext

+ func (c *AppInstallationContext) ScheduleResync(interval time.Duration) error

Jan 6, 2026

Changes in this version

type WebhookContext

+ func (c *WebhookContext) GetBaseURL() string

+ func (c *WebhookContext) ResetSecret() ([]byte, []byte, error)

Dec 28, 2025

Changes in this version

+ func BuildProcessQueueContext(tx *gorm.DB, node *models.WorkflowNode, ...) (*core.ProcessQueueContext, error)

+ type AppInstallationContext struct

+ func NewAppInstallationContext(tx *gorm.DB, node *models.WorkflowNode, installation *models.AppInstallation, ...) *AppInstallationContext

+ func (c *AppInstallationContext) GetConfig(name string) ([]byte, error)

+ func (c *AppInstallationContext) GetMetadata() any

+ func (c *AppInstallationContext) GetSecrets() ([]core.InstallationSecret, error)

+ func (c *AppInstallationContext) GetState() string

+ func (c *AppInstallationContext) ID() uuid.UUID

+ func (c *AppInstallationContext) NewBrowserAction(action core.BrowserAction)

+ func (c *AppInstallationContext) RemoveBrowserAction()

+ func (c *AppInstallationContext) RequestWebhook(configuration any) error

+ func (c *AppInstallationContext) SetMetadata(value any)

+ func (c *AppInstallationContext) SetSecret(name string, value []byte) error

+ func (c *AppInstallationContext) SetState(state, stateDescription string)

+ type AuthContext struct

+ func NewAuthContext(tx *gorm.DB, orgID uuid.UUID, authService authorization.Authorization, ...) *AuthContext

+ func (c *AuthContext) AuthenticatedUser() *core.User

+ func (c *AuthContext) GetUser(id uuid.UUID) (*core.User, error)

+ func (c *AuthContext) HasRole(role string) (bool, error)

+ func (c *AuthContext) InGroup(group string) (bool, error)

+ type ConfigurationBuildError struct

+ Err error

+ Event *models.WorkflowEvent

+ Node *models.WorkflowNode

+ QueueItem *models.WorkflowNodeQueueItem

+ RootEventID uuid.UUID

+ func (e *ConfigurationBuildError) Error() string

+ func (e *ConfigurationBuildError) Unwrap() error

+ type EventContext struct

+ func NewEventContext(tx *gorm.DB, workflowNode *models.WorkflowNode) *EventContext

+ func (s *EventContext) Emit(payloadType string, payload any) error

+ type ExecutionMetadataContext struct

+ func NewExecutionMetadataContext(tx *gorm.DB, execution *models.WorkflowNodeExecution) *ExecutionMetadataContext

+ func (m *ExecutionMetadataContext) Get() any

+ func (m *ExecutionMetadataContext) Set(value any) error

+ type ExecutionRequestContext struct

+ func NewExecutionRequestContext(tx *gorm.DB, execution *models.WorkflowNodeExecution) *ExecutionRequestContext

+ func (c *ExecutionRequestContext) ScheduleActionCall(actionName string, parameters map[string]any, interval time.Duration) error

+ type ExecutionStateContext struct

+ func NewExecutionStateContext(tx *gorm.DB, execution *models.WorkflowNodeExecution) *ExecutionStateContext

+ func (s *ExecutionStateContext) Emit(channel, payloadType string, payloads []any) error

+ func (s *ExecutionStateContext) Fail(reason, message string) error

+ func (s *ExecutionStateContext) IsFinished() bool

+ func (s *ExecutionStateContext) Pass() error

+ func (s *ExecutionStateContext) SetKV(key, value string) error

+ type IntegrationContext struct

+ func NewIntegrationContext(tx *gorm.DB, registry *registry.Registry) *IntegrationContext

+ func (c *IntegrationContext) GetIntegration(ID string) (integrations.ResourceManager, error)

+ type NodeConfigurationBuilder struct

+ func NewNodeConfigurationBuilder(tx *gorm.DB, workflowID uuid.UUID) *NodeConfigurationBuilder

+ func (b *NodeConfigurationBuilder) Build(configuration map[string]any) (map[string]any, error)

+ func (b *NodeConfigurationBuilder) ForBlueprintNode(parentBlueprintNode *models.WorkflowNode) *NodeConfigurationBuilder

+ func (b *NodeConfigurationBuilder) ResolveExpression(expression string) (any, error)

+ func (b *NodeConfigurationBuilder) WithInput(input any) *NodeConfigurationBuilder

+ func (b *NodeConfigurationBuilder) WithPreviousExecution(previousExecutionID *uuid.UUID) *NodeConfigurationBuilder

+ func (b *NodeConfigurationBuilder) WithRootEvent(rootEventID *uuid.UUID) *NodeConfigurationBuilder

+ type NodeMetadataContext struct

+ func NewNodeMetadataContext(tx *gorm.DB, node *models.WorkflowNode) *NodeMetadataContext

+ func (m *NodeMetadataContext) Get() any

+ func (m *NodeMetadataContext) Set(value any) error

+ type NodeRequestContext struct

+ func NewNodeRequestContext(tx *gorm.DB, node *models.WorkflowNode) *NodeRequestContext

+ func (c *NodeRequestContext) ScheduleActionCall(actionName string, parameters map[string]any, interval time.Duration) error

+ type WebhookContext struct

+ func NewWebhookContext(ctx context.Context, tx *gorm.DB, encryptor crypto.Encryptor, ...) *WebhookContext

+ func (c *WebhookContext) GetSecret() ([]byte, error)

+ func (c *WebhookContext) Setup(options *core.WebhookSetupOptions) error