models

package

v0.28.0 Latest Latest Go to latest Published: Jul 9, 2026 License: Apache-2.0 Imports: 26 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/superplanehq/superplane

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func AddCanvasMemory(canvasID uuid.UUID, namespace string, values any) error
func AddCanvasMemoryInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, values any) error
func AppendAgentSessionMessage(msg *AgentSessionMessage) error
func AppendAgentSessionMessageInTransaction(tx *gorm.DB, msg *AgentSessionMessage) error
func CalculateCanvasRunResultInTransaction(tx *gorm.DB, runID uuid.UUID) (string, error)
func CanvasMemoryNamespaceSource(canvasID uuid.UUID, namespace string) (string, error)
func CanvasMemoryNamespaceSourceInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string) (string, error)
func CanvasVersionToConsoleYML(canvasName string, canvasVersion *CanvasVersion) ([]byte, error)
func CheckCanvasExistence(tx *gorm.DB, orgID, id uuid.UUID) (bool, error)
func ClearTokenHashesForAccountInTransaction(tx *gorm.DB, accountID uuid.UUID) error
func CompletePendingActionRequestsInTransaction(tx *gorm.DB, installationID uuid.UUID, actionName string, parameters any) error
func CountActiveHumanUsersByOrganization(orgID string) (int64, error)
func CountActiveHumanUsersByOrganizationInTransaction(tx *gorm.DB, orgID string) (int64, error)
func CountActiveNodeExecutionsForRootEventInTransaction(tx *gorm.DB, rootEventID uuid.UUID) (int64, error)
func CountActiveUsersByOrganizationIDs(orgIDs []string) (map[string]int64, error)
func CountAgentSessionMessagesInTransaction(tx *gorm.DB, sessionID uuid.UUID) (int64, error)
func CountCanvasEvents(canvasID uuid.UUID, nodeID string) (int64, error)
func CountCanvasRuns(workflowID uuid.UUID, filters CanvasRunFilters) (int64, error)
func CountCanvasRunsInTransaction(tx *gorm.DB, workflowID uuid.UUID, filters CanvasRunFilters) (int64, error)
func CountCanvasVersionsInTransaction(tx *gorm.DB, workflowID uuid.UUID) (int64, error)
func CountCanvasesByOrganization(orgID string) (int64, error)
func CountCanvasesByOrganizationIDs(orgIDs []string) (map[string]int64, error)
func CountCanvasesByOrganizationInTransaction(tx *gorm.DB, orgID string) (int64, error)
func CountIntegrationsByOrganization(orgID string) (int64, error)
func CountIntegrationsByOrganizationInTransaction(tx *gorm.DB, orgID string) (int64, error)
func CountNodeExecutions(workflowID uuid.UUID, nodeID string, states []string, results []string) (int64, error)
func CountNodeQueueItems(workflowID uuid.UUID, nodeID string) (int64, error)
func CountNodeQueueItemsForRootEventInTransaction(tx *gorm.DB, rootEventID uuid.UUID) (int64, error)
func CountOrganizationsByBillingAccount(accountID string) (int64, error)
func CountOrganizationsByBillingAccountInTransaction(tx *gorm.DB, accountID string) (int64, error)
func CountPendingRequestsForExecutionsInTransaction(tx *gorm.DB, executionIDs []uuid.UUID) (int64, error)
func CountRecentMagicCodes(email string, since time.Time) (int64, error)
func CountRecentMagicCodesInTransaction(tx *gorm.DB, email string, since time.Time) (int64, error)
func CountRootCanvasEvents(canvasID uuid.UUID) (int64, error)
func CountRootCanvasEventsInTransaction(tx *gorm.DB, canvasID uuid.UUID) (int64, error)
func CountRunningExecutionsForNode(workflowID uuid.UUID, nodeID string) (int64, error)
func CountRunningExecutionsForNodeInTransaction(tx *gorm.DB, workflowID uuid.UUID, nodeID string) (int64, error)
func CreateAgentSessionInTransaction(tx *gorm.DB, session *AgentSession) error
func CreateNodeExecutionKVInTransaction(tx *gorm.DB, workflowID uuid.UUID, nodeID string, executionID uuid.UUID, ...) error
func CreateRepositorySeedFiles(repositoryID uuid.UUID, files []RepositorySeedFile) error
func CreateRepositorySeedFilesInTransaction(tx *gorm.DB, repositoryID uuid.UUID, files []RepositorySeedFile) error
func DeleteAgentSessionForUserCanvas(tx *gorm.DB, organizationID, userID, canvasID uuid.UUID) error
func DeleteAgentSessionsForCanvasInTransaction(tx *gorm.DB, organizationID, canvasID uuid.UUID) error
func DeleteAgentSessionsForOrganizationInTransaction(tx *gorm.DB, organizationID uuid.UUID) error
func DeleteCanvasFolder(organizationID, id uuid.UUID) error
func DeleteCanvasFolderInTransaction(tx *gorm.DB, organizationID, id uuid.UUID) error
func DeleteCanvasMemory(canvasID, memoryID uuid.UUID) error
func DeleteCanvasMemoryInTransaction(tx *gorm.DB, canvasID, memoryID uuid.UUID) error
func DeleteCanvasNode(tx *gorm.DB, node CanvasNode) error
func DeleteEmailSettings(provider string) error
func DeleteEmailSettingsInTransaction(tx *gorm.DB, provider string) error
func DeleteGroupMetadata(groupName, domainType, domainID string) error
func DeleteGroupMetadataInTransaction(tx *gorm.DB, groupName, domainType, domainID string) error
func DeleteIntegrationSubscriptionsForNodeInTransaction(tx *gorm.DB, workflowID uuid.UUID, nodeID string) error
func DeleteMetadataForOrganization(tx *gorm.DB, domainType, domainID string) error
func DeleteRepositorySeedFiles(repositoryID uuid.UUID) error
func DeleteRepositorySeedFilesInTransaction(tx *gorm.DB, repositoryID uuid.UUID) error
func DeleteRoleMetadata(roleName, domainType, domainID string) error
func DeleteRoleMetadataInTransaction(tx *gorm.DB, roleName, domainType, domainID string) error
func DeleteRootCanvasEventChainsInTransaction(tx *gorm.DB, rootEventIDs []uuid.UUID) error
func DemoteFromInstallationAdmin(accountID string) error
func DisableExperimentalFeature(orgID uuid.UUID, featureID string) error
func DisableExperimentalFeatureInTransaction(tx *gorm.DB, orgID uuid.UUID, featureID string) error
func DiscardStagedFilesForUser(db *gorm.DB, workflowID, userID uuid.UUID, paths []string) error
func EnableExperimentalFeature(orgID uuid.UUID, featureID string) error
func EnableExperimentalFeatureInTransaction(tx *gorm.DB, orgID uuid.UUID, featureID string) error
func FindCanvasVersionsByIDs(workflowID uuid.UUID, versionIDs []uuid.UUID) (map[uuid.UUID]*CanvasVersion, error)
func FindCanvasVersionsByIDsInTransaction(tx *gorm.DB, workflowID uuid.UUID, versionIDs []uuid.UUID) (map[uuid.UUID]*CanvasVersion, error)
func FindLatestNodeExecutionKVValueInTransaction(tx *gorm.DB, executionID uuid.UUID, key string) (string, error)
func FindLiveCanvasSpecInTransaction(tx *gorm.DB, workflowID uuid.UUID) ([]Node, []Edge, error)
func FindLiveCanvasSpecsByCanvasIDs(tx *gorm.DB, canvasIDs []uuid.UUID) (map[uuid.UUID]LiveCanvasSpec, error)
func FindRoleMetadataByNames(roleNames []string, domainType, domainID string) (map[string]*RoleMetadata, error)
func FindUserCanvasPreferencesForCanvases(tx *gorm.DB, organizationID uuid.UUID, userID uuid.UUID, canvasIDs []uuid.UUID) (map[uuid.UUID]UserCanvasPreference, error)
func FormatDomain(domainType, domainID string) string
func GenerateNodeID(blockName string, nodeName string) string
func GenerateUniqueNodeID(node Node, reservedIDs map[string]bool) string
func GetActiveOrganizationIDs() ([]string, error)
func GetInstallationID(tx *gorm.DB) (string, error)
func HardDeleteOrganization(id string) error
func HasExperimentalFeature(orgID uuid.UUID, featureID string) (bool, error)
func HasStagedFilesForUser(db *gorm.DB, workflowID, userID uuid.UUID) (bool, error)
func IncrementAndMaybeInvalidateCodes(email string, maxVerifyAttempts int) (bool, error)
func IncrementAndMaybeInvalidateCodesInTransaction(conn *gorm.DB, email string, maxVerifyAttempts int) (bool, error)
func InvalidateActiveMagicCodesInTransaction(tx *gorm.DB, email string) error
func IsAgentSessionStreaming(sessionID uuid.UUID) (bool, error)
func IsLiveCanvasVersion(tx *gorm.DB, canvas *Canvas, version *CanvasVersion) bool
func MapCanvasNameUniqueConstraintError(err error) error
func MarkAgentSessionContextReplayed(sessionID uuid.UUID) error
func MarkAgentSessionTokenUsageTracked(sessionID uuid.UUID, usage AgentSessionTokenUsage) error
func MarkOrganizationUsageLimitsSynced(orgID string, retentionWindowDays *int32, syncedAt time.Time) error
func MarkOrganizationUsageLimitsSyncedIfNewer(orgID string, retentionWindowDays *int32, syncedAt time.Time) (bool, error)
func MarkOrganizationUsageLimitsSyncedIfNewerInTransaction(tx *gorm.DB, orgID string, retentionWindowDays *int32, syncedAt time.Time) (bool, error)
func MarkOrganizationUsageLimitsSyncedIfNoNewerThan(orgID string, retentionWindowDays *int32, maxExistingSyncedAt time.Time, ...) (bool, error)
func MarkOrganizationUsageLimitsSyncedIfNoNewerThanInTransaction(tx *gorm.DB, orgID string, retentionWindowDays *int32, ...) (bool, error)
func MarkOrganizationUsageLimitsSyncedInTransaction(tx *gorm.DB, orgID string, retentionWindowDays *int32, syncedAt time.Time) error
func MarkOrganizationUsageSynced(orgID string, syncedAt time.Time) error
func MarkOrganizationUsageSyncedIfUnset(orgID string, syncedAt time.Time) error
func MarkOrganizationUsageSyncedIfUnsetInTransaction(tx *gorm.DB, orgID string, syncedAt time.Time) error
func MarkOrganizationUsageSyncedInTransaction(tx *gorm.DB, orgID string, syncedAt time.Time) error
func MarkOrganizationUsageSyncedWithLimitsIfNoNewerThan(orgID string, usageSyncedAt time.Time, retentionWindowDays *int32, ...) error
func MarkOrganizationUsageSyncedWithLimitsIfNoNewerThanInTransaction(tx *gorm.DB, orgID string, usageSyncedAt time.Time, retentionWindowDays *int32, ...) error
func MarkStagedFilePathDeleted(db *gorm.DB, workflowID, userID, baseVersionID, organizationID uuid.UUID, ...) error
func NodeTypeName(node Node) string
func PrefixGroup(groupName string) string
func PrefixRole(role string) string
func PrefixUser(userID string) string
func PromoteToInstallationAdmin(accountID string) error
func PromoteToLiveInTransaction(tx *gorm.DB, version *CanvasVersion, nodes []Node, edges []Edge) error
func ReplaceCanvasFolderMembershipInTransaction(tx *gorm.DB, organizationID, folderID uuid.UUID, canvasIDs []uuid.UUID) ([]Canvas, []Canvas, error)
func ReplaceManualCanvasMemoryNamespace(canvasID uuid.UUID, namespace string, entries []any) error
func ReplaceManualCanvasMemoryNamespaceInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, entries []any) error
func ResetStuckProvisioningWebhooks() (int64, error)
func ResolveExecutionErrors(workflowID uuid.UUID, executionIDs []uuid.UUID) error
func ResolveExecutionErrorsInTransaction(tx *gorm.DB, workflowID uuid.UUID, executionIDs []uuid.UUID) error
func SaveCanvasVersionInTransaction(tx *gorm.DB, version *CanvasVersion) error
func SaveInviteLink(tx *gorm.DB, inviteLink *OrganizationInviteLink) error
func SoftDeleteOrganization(id string) error
func SoftDeleteOrganizationInTransaction(tx *gorm.DB, id string) error
func TouchAgentSessionHeartbeat(sessionID uuid.UUID) error
func UnmarshalJSONValue(data []byte, value any) error
func UpdateAgentSessionProviderSessionInTransaction(tx *gorm.DB, sessionID uuid.UUID, ...) error
func UpdateAgentSessionStatus(sessionID uuid.UUID, status string) error
func UpdateAgentSessionStatusIfUnchanged(sessionID uuid.UUID, status string, unchangedSince *time.Time) (bool, error)
func UpdateAgentSessionStatusIfUnchangedInTransaction(tx *gorm.DB, sessionID uuid.UUID, status string, unchangedSince *time.Time) (bool, error)
func UpdateAgentSessionStatusInTransaction(tx *gorm.DB, sessionID uuid.UUID, status string) error
func UpdateCanvasFolderWithMembership(organizationID, id uuid.UUID, title, backgroundColor string, ...) (*CanvasFolder, []Canvas, error)
func UpdateInstallationMetadata(tx *gorm.DB, metadata *InstallationMetadata) error
func UpsertEmailSettings(settings *EmailSettings) error
func UpsertEmailSettingsInTransaction(tx *gorm.DB, settings *EmailSettings) error
func UpsertGroupMetadata(groupName, domainType, domainID, displayName, description string) error
func UpsertGroupMetadataInTransaction(tx *gorm.DB, groupName, domainType, domainID, displayName, description string) error
func UpsertRoleMetadata(roleName, domainType, domainID, displayName, description string) error
func UpsertRoleMetadataInTransaction(tx *gorm.DB, roleName, domainType, domainID, displayName, description string) error
func ValidateConsoleContent(panels []ConsolePanel, layout []ConsoleLayoutItem) error
func ValidateDomainType(domainType string) error
type Account
- func CreateAccount(name, email string) (*Account, error)
- func CreateAccountInTransaction(tx *gorm.DB, name, email string) (*Account, error)
- func FindAccountByEmail(email string) (*Account, error)
- func FindAccountByID(id string) (*Account, error)
- func FindAccountByProvider(provider, providerID string) (*Account, error)
- func ListAccounts(search string, limit, offset int, sortBy, sortDirection string) ([]Account, int64, error)
- func (a *Account) FindAccountProviderByID(provider, providerID string) (*AccountProvider, error)
- func (a *Account) GetAccountProvider(provider string) (*AccountProvider, error)
- func (a *Account) GetAccountProviders() ([]AccountProvider, error)
- func (a *Account) IsInstallationAdmin() bool
- func (a *Account) IsSessionFresh(issuedAt int64) bool
- func (a *Account) MarkPasswordChangedInTransaction(tx *gorm.DB, now time.Time) error
- func (a *Account) UpdateEmail(newEmail string) error
- func (a *Account) UpdateEmailForProvider(newEmail, provider, providerID string) error
type AccountMagicCode
- func CreateAccountMagicCode(email, codeHash string, expiresAt time.Time) (*AccountMagicCode, error)
- func CreateAccountMagicCodeInTransaction(tx *gorm.DB, email, codeHash string, expiresAt time.Time) (*AccountMagicCode, error)
- func FindValidAccountMagicCode(email, codeHash string, maxVerifyAttempts int) (*AccountMagicCode, error)
- func FindValidAccountMagicCodeInTransaction(tx *gorm.DB, email, codeHash string, maxVerifyAttempts int) (*AccountMagicCode, error)
- func (c *AccountMagicCode) MarkUsed() (bool, error)
- func (c *AccountMagicCode) MarkUsedInTransaction(tx *gorm.DB) (bool, error)
- func (AccountMagicCode) TableName() string
type AccountPasswordAuth
- func CreateAccountPasswordAuth(accountID uuid.UUID, passwordHash string) (*AccountPasswordAuth, error)
- func CreateAccountPasswordAuthInTransaction(tx *gorm.DB, accountID uuid.UUID, passwordHash string) (*AccountPasswordAuth, error)
- func FindAccountPasswordAuthByAccountID(accountID uuid.UUID) (*AccountPasswordAuth, error)
- func FindAccountPasswordAuthByAccountIDInTransaction(tx *gorm.DB, accountID uuid.UUID) (*AccountPasswordAuth, error)
- func (AccountPasswordAuth) TableName() string
- func (a *AccountPasswordAuth) UpdatePasswordHash(passwordHash string) error
- func (a *AccountPasswordAuth) UpdatePasswordHashInTransaction(tx *gorm.DB, passwordHash string) error
type AccountProvider
type AgentSession
- func FailStuckStreamingSessions(heartbeatCutoff, legacyCutoff time.Time) ([]AgentSession, error)
- func FindAgentSession(sessionID uuid.UUID) (*AgentSession, error)
- func FindAgentSessionByCanvasInTransaction(tx *gorm.DB, organizationID, userID, canvasID uuid.UUID) (*AgentSession, error)
- func FindAgentSessionForUser(organizationID, userID, sessionID uuid.UUID) (*AgentSession, error)
- func FindAgentSessionForUserInTransaction(tx *gorm.DB, organizationID, userID, sessionID uuid.UUID) (*AgentSession, error)
- func FindAgentSessionInTransaction(tx *gorm.DB, sessionID uuid.UUID) (*AgentSession, error)
- func ListAgentSessionsForCanvasInTransaction(tx *gorm.DB, organizationID, canvasID uuid.UUID) ([]AgentSession, error)
- func ListAgentSessionsForOrganizationInTransaction(tx *gorm.DB, organizationID uuid.UUID) ([]AgentSession, error)
- func LockAgentSessionInTransaction(tx *gorm.DB, sessionID uuid.UUID) (*AgentSession, error)
- func (AgentSession) TableName() string
type AgentSessionImage
type AgentSessionMessage
- func CloseOpenToolMessages(sessionID uuid.UUID) ([]AgentSessionMessage, error)
- func FindAgentSessionMessage(tx *gorm.DB, id uuid.UUID) (*AgentSessionMessage, error)
- func ListAgentSessionMessagesPage(sessionID uuid.UUID, before *AgentSessionMessage, limit int) ([]AgentSessionMessage, error)
- func (AgentSessionMessage) TableName() string
type AgentSessionTokenUsage
- func CalculateAgentSessionTokenUsageDelta(sessionID uuid.UUID, usage AgentSessionTokenUsage) (AgentSessionTokenUsage, bool, error)
- func (u AgentSessionTokenUsage) HasUsage() bool
type BrowserAction
type Canvas
- func FindCanvas(orgID, id uuid.UUID) (*Canvas, error)
- func FindCanvasByName(name string, organizationID uuid.UUID) (*Canvas, error)
- func FindCanvasByNameInTransaction(tx *gorm.DB, name string, organizationID uuid.UUID) (*Canvas, error)
- func FindCanvasInTransaction(tx *gorm.DB, orgID, id uuid.UUID) (*Canvas, error)
- func FindCanvasWithoutOrgScope(id uuid.UUID) (*Canvas, error)
- func FindCanvasWithoutOrgScopeInTransaction(tx *gorm.DB, id uuid.UUID) (*Canvas, error)
- func FindUnscopedCanvas(id uuid.UUID) (*Canvas, error)
- func FindUnscopedCanvasInTransaction(tx *gorm.DB, id uuid.UUID) (*Canvas, error)
- func ListCanvases(orgID string) ([]Canvas, error)
- func ListCanvasesPaginated(orgID, search string, limit, offset int) ([]Canvas, int64, error)
- func ListDeletedCanvases() ([]Canvas, error)
- func ListMaybeDeletedCanvasesByOrganizationInTransaction(tx *gorm.DB, orgID uuid.UUID) ([]Canvas, error)
- func LockCanvas(tx *gorm.DB, id uuid.UUID) (*Canvas, error)
- func LockCanvasForUpdate(tx *gorm.DB, organizationUUID, canvasID uuid.UUID) (*Canvas, error)
- func UpdateCanvasFolderMembership(organizationID, canvasID uuid.UUID, folderID *uuid.UUID) (*Canvas, error)
- func UpdateCanvasFolderMembershipInTransaction(tx *gorm.DB, organizationID, canvasID uuid.UUID, folderID *uuid.UUID) (*Canvas, error)
- func (c *Canvas) CreatePendingRepository(provider, providerRepoID string) (*Repository, error)
- func (c *Canvas) CreatePendingRepositoryInTransaction(tx *gorm.DB, provider, providerRepoID string) (*Repository, error)
- func (c *Canvas) FindNode(id string) (*CanvasNode, error)
- func (c *Canvas) SoftDelete() error
- func (c *Canvas) SoftDeleteInTransaction(tx *gorm.DB) error
- func (c *Canvas) TableName() string
type CanvasEvent
- func FindCanvasEvent(id uuid.UUID) (*CanvasEvent, error)
- func FindCanvasEventForCanvas(canvasID uuid.UUID, id uuid.UUID) (*CanvasEvent, error)
- func FindCanvasEventInTransaction(tx *gorm.DB, id uuid.UUID) (*CanvasEvent, error)
- func FindCanvasEvents(tx *gorm.DB, ids []string) ([]CanvasEvent, error)
- func FindCanvasEventsForExecutions(tx *gorm.DB, executionIDs []string) ([]CanvasEvent, error)
- func FindLastEventPerNode(tx *gorm.DB, canvasID uuid.UUID) ([]CanvasEvent, error)
- func ListCanvasEvents(canvasID uuid.UUID, nodeID string, limit int, before *time.Time) ([]CanvasEvent, error)
- func ListCanvasEventsByIDsInTransaction(tx *gorm.DB, ids []uuid.UUID) ([]CanvasEvent, error)
- func ListCanvasEventsForExecutionsInTransaction(tx *gorm.DB, executionIDs []uuid.UUID) ([]CanvasEvent, error)
- func ListPendingCanvasEvents() ([]CanvasEvent, error)
- func ListRootCanvasEvents(canvasID uuid.UUID, limit int, before *time.Time) ([]CanvasEvent, error)
- func ListRootCanvasEventsInTransaction(tx *gorm.DB, canvasID uuid.UUID, limit int, before *time.Time) ([]CanvasEvent, error)
- func LockCanvasEvent(tx *gorm.DB, id uuid.UUID) (*CanvasEvent, error)
- func LockExpiredRoutedRootCanvasEventsInTransaction(tx *gorm.DB, referenceTime time.Time, limit int) ([]CanvasEvent, error)
- func (e *CanvasEvent) BeforeCreate(tx *gorm.DB) error
- func (e *CanvasEvent) Routed() error
- func (e *CanvasEvent) RoutedInTransaction(tx *gorm.DB) error
- func (e *CanvasEvent) TableName() string
type CanvasFolder
- func CreateCanvasFolder(organizationID uuid.UUID, title, backgroundColor string) (*CanvasFolder, error)
- func CreateCanvasFolderInTransaction(tx *gorm.DB, organizationID uuid.UUID, title, backgroundColor string) (*CanvasFolder, error)
- func FindCanvasFolder(organizationID, id uuid.UUID) (*CanvasFolder, error)
- func FindCanvasFolderInTransaction(tx *gorm.DB, organizationID, id uuid.UUID) (*CanvasFolder, error)
- func ListCanvasFolders(organizationID uuid.UUID) ([]CanvasFolder, error)
- func ListCanvasFoldersInTransaction(tx *gorm.DB, organizationID uuid.UUID) ([]CanvasFolder, error)
- func MoveCanvasFolder(organizationID, id uuid.UUID, direction string) ([]CanvasFolder, error)
- func MoveCanvasFolderInTransaction(tx *gorm.DB, organizationID, id uuid.UUID, direction string) ([]CanvasFolder, error)
- func UpdateCanvasFolder(organizationID, id uuid.UUID, title, backgroundColor string) (*CanvasFolder, error)
- func UpdateCanvasFolderInTransaction(tx *gorm.DB, organizationID, id uuid.UUID, title, backgroundColor string) (*CanvasFolder, error)
- func (f *CanvasFolder) TableName() string
type CanvasMemory
- func AddCanvasMemoryRecordInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, values any) (CanvasMemory, error)
- func AddCanvasMemoryRecordWithSourceInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, values any, source string) (CanvasMemory, error)
- func DeleteCanvasMemoriesByNamespaceAndMatches(canvasID uuid.UUID, namespace string, matches map[string]any) ([]CanvasMemory, error)
- func DeleteCanvasMemoriesByNamespaceAndMatchesInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, matches map[string]any) ([]CanvasMemory, error)
- func FindFirstCanvasMemoryByNamespaceAndMatches(canvasID uuid.UUID, namespace string, matches map[string]any) (*CanvasMemory, error)
- func FindFirstCanvasMemoryByNamespaceAndMatchesInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, matches map[string]any) (*CanvasMemory, error)
- func ListCanvasMemories(canvasID uuid.UUID) ([]CanvasMemory, error)
- func ListCanvasMemoriesByNamespace(canvasID uuid.UUID, namespace string) ([]CanvasMemory, error)
- func ListCanvasMemoriesByNamespaceAndMatches(canvasID uuid.UUID, namespace string, matches map[string]any) ([]CanvasMemory, error)
- func ListCanvasMemoriesByNamespaceAndMatchesInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, matches map[string]any) ([]CanvasMemory, error)
- func ListCanvasMemoriesByNamespaceInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string) ([]CanvasMemory, error)
- func ListCanvasMemoriesInTransaction(tx *gorm.DB, canvasID uuid.UUID) ([]CanvasMemory, error)
- func UpdateCanvasMemoriesByNamespace(canvasID uuid.UUID, namespace string, values map[string]any) ([]CanvasMemory, error)
- func UpdateCanvasMemoriesByNamespaceAndMatches(canvasID uuid.UUID, namespace string, matches map[string]any, ...) ([]CanvasMemory, error)
- func UpdateCanvasMemoriesByNamespaceAndMatchesInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, matches map[string]any, ...) ([]CanvasMemory, error)
- func UpdateCanvasMemoriesByNamespaceInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, values map[string]any) ([]CanvasMemory, error)
- func (CanvasMemory) TableName() string
type CanvasNode
- func FindActiveWebhookNodes(webhookID uuid.UUID) ([]CanvasNode, error)
- func FindActiveWebhookNodesInTransaction(tx *gorm.DB, webhookID uuid.UUID) ([]CanvasNode, error)
- func FindCanvasNode(tx *gorm.DB, canvasID uuid.UUID, nodeID string) (*CanvasNode, error)
- func FindCanvasNodes(canvasID uuid.UUID) ([]CanvasNode, error)
- func FindCanvasNodesByIDs(tx *gorm.DB, canvasID uuid.UUID, nodeIDs []string) ([]CanvasNode, error)
- func FindCanvasNodesInTransaction(tx *gorm.DB, workflowID uuid.UUID) ([]CanvasNode, error)
- func FindCanvasNodesUnscoped(workflowID uuid.UUID) ([]CanvasNode, error)
- func FindCanvasNodesUnscopedInTransaction(tx *gorm.DB, workflowID uuid.UUID) ([]CanvasNode, error)
- func FindUnscopedCanvasNode(tx *gorm.DB, canvasID uuid.UUID, nodeID string) (*CanvasNode, error)
- func FindWebhookNodes(webhookID uuid.UUID) ([]CanvasNode, error)
- func FindWebhookNodesInTransaction(tx *gorm.DB, webhookID uuid.UUID) ([]CanvasNode, error)
- func ListCanvasNodesReady() ([]CanvasNode, error)
- func ListReadyTriggers() ([]CanvasNode, error)
- func LockCanvasNode(tx *gorm.DB, workflowID uuid.UUID, nodeId string) (*CanvasNode, error)
- func LockCanvasNodeForUpdate(tx *gorm.DB, workflowID uuid.UUID, nodeId string) (*CanvasNode, error)
- func (c *CanvasNode) ComponentName() string
- func (c *CanvasNode) CreateRequest(tx *gorm.DB, reqType string, spec NodeExecutionRequestSpec, runAt *time.Time) error
- func (c *CanvasNode) FirstQueueItem(tx *gorm.DB) (*CanvasNodeQueueItem, error)
- func (c *CanvasNode) TableName() string
- func (c *CanvasNode) UpdateState(tx *gorm.DB, state string) error
type CanvasNodeExecution
- func FindLastExecutionPerNode(tx *gorm.DB, workflowID uuid.UUID) ([]CanvasNodeExecution, error)
- func FindNodeExecution(workflowID, id uuid.UUID) (*CanvasNodeExecution, error)
- func FindNodeExecutionInTransaction(tx *gorm.DB, workflowID, id uuid.UUID) (*CanvasNodeExecution, error)
- func FindNodeExecutionWithNodeID(workflowID, id uuid.UUID, nodeID string) (*CanvasNodeExecution, error)
- func FindNodeExecutionWithNodeIDInTransaction(tx *gorm.DB, workflowID, id uuid.UUID, nodeID string) (*CanvasNodeExecution, error)
- func FindNodeExecutionsByIDs(workflowID uuid.UUID, executionIDs []uuid.UUID) ([]CanvasNodeExecution, error)
- func FindNodeExecutionsByIDsInTransaction(tx *gorm.DB, workflowID uuid.UUID, executionIDs []uuid.UUID) ([]CanvasNodeExecution, error)
- func FirstNodeExecutionByKVInTransaction(tx *gorm.DB, workflowID uuid.UUID, nodeID, key, value string) (*CanvasNodeExecution, error)
- func ListAllExecutionsForRootEvent(rootEventID uuid.UUID) ([]CanvasNodeExecution, error)
- func ListAllExecutionsForRootEventInTransaction(tx *gorm.DB, rootEventID uuid.UUID) ([]CanvasNodeExecution, error)
- func ListExecutionsForRunsInTransaction(tx *gorm.DB, workflowID uuid.UUID, runIDs []uuid.UUID) ([]CanvasNodeExecution, error)
- func ListNodeExecutions(workflowID uuid.UUID, nodeID string, states []string, results []string, ...) ([]CanvasNodeExecution, error)
- func ListParentExecutionsForRootEvents(canvasID uuid.UUID, rootEventIDs []uuid.UUID) ([]CanvasNodeExecution, error)
- func ListParentExecutionsForRootEventsInTransaction(tx *gorm.DB, canvasID uuid.UUID, rootEventIDs []uuid.UUID) ([]CanvasNodeExecution, error)
- func ListPendingNodeExecutions() ([]CanvasNodeExecution, error)
- func LockPendingNodeExecutionInActiveCanvas(tx *gorm.DB, id uuid.UUID) (*CanvasNodeExecution, error)
- func (e *CanvasNodeExecution) BeforeCreate(tx *gorm.DB) error
- func (e *CanvasNodeExecution) Cancel(cancelledBy *uuid.UUID) error
- func (e *CanvasNodeExecution) CancelInTransaction(tx *gorm.DB, cancelledBy *uuid.UUID) error
- func (e *CanvasNodeExecution) CreateRequest(tx *gorm.DB, reqType string, spec NodeExecutionRequestSpec, runAt *time.Time) error
- func (e *CanvasNodeExecution) EmitOutputsInTransaction(tx *gorm.DB, channelOutputs map[string][]any) ([]CanvasEvent, error)
- func (e *CanvasNodeExecution) Fail(reason, message string) error
- func (e *CanvasNodeExecution) FailInTransaction(tx *gorm.DB, reason, message string) error
- func (e *CanvasNodeExecution) GetInput(tx *gorm.DB) (any, error)
- func (e *CanvasNodeExecution) GetOutputs() ([]CanvasEvent, error)
- func (e *CanvasNodeExecution) GetOutputsInTransaction(tx *gorm.DB) ([]CanvasEvent, error)
- func (e *CanvasNodeExecution) GetPreviousExecutionID() string
- func (e *CanvasNodeExecution) Pass(outputs map[string][]any) ([]CanvasEvent, error)
- func (e *CanvasNodeExecution) PassInTransaction(tx *gorm.DB, channelOutputs map[string][]any) ([]CanvasEvent, error)
- func (e *CanvasNodeExecution) Start() error
- func (e *CanvasNodeExecution) StartInTransaction(tx *gorm.DB) error
- func (e *CanvasNodeExecution) TableName() string
type CanvasNodeExecutionKV
- func (c *CanvasNodeExecutionKV) TableName() string
type CanvasNodeQueueItem
- func FindNodeQueueItem(workflowID uuid.UUID, queueItemID uuid.UUID) (*CanvasNodeQueueItem, error)
- func ListNodeQueueItems(workflowID uuid.UUID, nodeID string, limit int, beforeTime *time.Time) ([]CanvasNodeQueueItem, error)
- func (i *CanvasNodeQueueItem) BeforeCreate(tx *gorm.DB) error
- func (i *CanvasNodeQueueItem) Delete(tx *gorm.DB) error
- func (i *CanvasNodeQueueItem) TableName() string
type CanvasNodeReference
- func ListIntegrationNodeReferences(integrationID uuid.UUID) ([]CanvasNodeReference, error)
- func (c *CanvasNodeReference) ComponentName() string
type CanvasNodeRequest
- func FindPendingRequestForNode(tx *gorm.DB, workflowID uuid.UUID, nodeID string) (*CanvasNodeRequest, error)
- func ListNodeRequests() ([]CanvasNodeRequest, error)
- func LockNodeRequest(tx *gorm.DB, id uuid.UUID) (*CanvasNodeRequest, error)
- func (r *CanvasNodeRequest) Complete(tx *gorm.DB) error
- func (r *CanvasNodeRequest) TableName() string
type CanvasRun
- func CreateCanvasRunInTransaction(tx *gorm.DB, workflowID uuid.UUID, state, result string) (*CanvasRun, error)
- func FindCanvasRunByRootEventInTransaction(tx *gorm.DB, rootEventID uuid.UUID) (*CanvasRun, error)
- func FindCanvasRunInTransaction(tx *gorm.DB, workflowID, runID uuid.UUID) (*CanvasRun, error)
- func FindOrCreateCanvasRunForRootEventInTransaction(tx *gorm.DB, rootEvent *CanvasEvent) (*CanvasRun, error)
- func ListCanvasRuns(workflowID uuid.UUID, limit int, beforeTime *time.Time, ...) ([]CanvasRun, error)
- func ListCanvasRunsInTransaction(tx *gorm.DB, workflowID uuid.UUID, limit int, beforeTime *time.Time, ...) ([]CanvasRun, error)
- func ListStartedCanvasRuns(limit int) ([]CanvasRun, error)
- func ListStartedCanvasRunsInTransaction(tx *gorm.DB, limit int) ([]CanvasRun, error)
- func LockCanvasRunInTransaction(tx *gorm.DB, runID uuid.UUID) (*CanvasRun, error)
- func (r *CanvasRun) TableName() string
type CanvasRunFilters
type CanvasVersion
- func CreateCommitVersionWithSpecInTransaction(tx *gorm.DB, canvasID uuid.UUID, userID uuid.UUID, commitMessage string, ...) (*CanvasVersion, error)
- func FindCanvasVersion(workflowID, versionID uuid.UUID) (*CanvasVersion, error)
- func FindCanvasVersionForUpdateInTransaction(tx *gorm.DB, workflowID, versionID uuid.UUID) (*CanvasVersion, error)
- func FindCanvasVersionInTransaction(tx *gorm.DB, workflowID, versionID uuid.UUID) (*CanvasVersion, error)
- func FindLatestCanvasVersion(workflowID uuid.UUID) (*CanvasVersion, error)
- func FindLatestCanvasVersionInTransaction(tx *gorm.DB, workflowID uuid.UUID) (*CanvasVersion, error)
- func FindLiveCanvasVersion(workflowID uuid.UUID) (*CanvasVersion, error)
- func FindLiveCanvasVersionByCanvasInTransaction(tx *gorm.DB, canvas *Canvas) (*CanvasVersion, error)
- func FindLiveCanvasVersionInTransaction(tx *gorm.DB, workflowID uuid.UUID) (*CanvasVersion, error)
- func FindVersionByCommitSHA(workflowID uuid.UUID, commitSHA string) (*CanvasVersion, error)
- func FindVersionByCommitSHAInTransaction(tx *gorm.DB, workflowID uuid.UUID, commitSHA string) (*CanvasVersion, error)
- func ListCanvasVersionHistoryInTransaction(tx *gorm.DB, workflowID uuid.UUID, limit int, before *time.Time) ([]CanvasVersion, error)
- func ListCanvasVersions(workflowID uuid.UUID) ([]CanvasVersion, error)
- func ListCanvasVersionsInTransaction(tx *gorm.DB, workflowID uuid.UUID) ([]CanvasVersion, error)
- func UpdateCanvasVersionConsoleInTransaction(tx *gorm.DB, version *CanvasVersion, panels []ConsolePanel, ...) (*CanvasVersion, error)
- func UpsertCanvasVersionConsole(canvasID uuid.UUID, panels []ConsolePanel, layout []ConsoleLayoutItem) (*CanvasVersion, error)
- func UpsertCanvasVersionConsoleInTransaction(tx *gorm.DB, canvasID uuid.UUID, panels []ConsolePanel, ...) (*CanvasVersion, error)
- func (c *CanvasVersion) TableName() string
type CapabilityState
type ComponentRef
type ConsoleLayoutItem
type ConsolePanel
type ConsoleYAML
- func ConsoleFromYML(raw []byte) (*ConsoleYAML, error)
- func (d *ConsoleYAML) Validate() error
type ConsoleYAMLMetadata
type ConsoleYAMLSpec
type Edge
type EmailSettings
- func FindEmailSettings(provider string) (*EmailSettings, error)
- func FindEmailSettingsInTransaction(tx *gorm.DB, provider string) (*EmailSettings, error)
type GroupMetadata
- func FindGroupMetadata(groupName, domainType, domainID string) (*GroupMetadata, error)
- func (gm *GroupMetadata) BeforeCreate(tx *gorm.DB) error
- func (gm *GroupMetadata) Create() error
- func (gm *GroupMetadata) CreateInTransaction(tx *gorm.DB) error
- func (gm *GroupMetadata) Update() error
- func (gm *GroupMetadata) UpdateInTransaction(tx *gorm.DB) error
type InstallationMetadata
- func GetInstallationMetadata(tx *gorm.DB) (*InstallationMetadata, error)
type Integration
- func CreateIntegration(id, orgID uuid.UUID, appName string, installationName string, ...) (*Integration, error)
- func FindIntegration(orgID, integrationID uuid.UUID) (*Integration, error)
- func FindIntegrationByName(orgID uuid.UUID, integrationName string) (*Integration, error)
- func FindIntegrationInTransaction(tx *gorm.DB, orgID, integrationID uuid.UUID) (*Integration, error)
- func FindMaybeDeletedIntegrationInTransaction(tx *gorm.DB, integrationID uuid.UUID) (*Integration, error)
- func FindUnscopedIntegration(integrationID uuid.UUID) (*Integration, error)
- func FindUnscopedIntegrationInTransaction(tx *gorm.DB, integrationID uuid.UUID) (*Integration, error)
- func ListDeletedIntegrations() ([]Integration, error)
- func ListIntegrations(db *gorm.DB, orgID uuid.UUID) ([]Integration, error)
- func ListMaybeDeletedIntegrationsByOrganizationInTransaction(tx *gorm.DB, orgID uuid.UUID) ([]Integration, error)
- func LockIntegration(tx *gorm.DB, ID uuid.UUID) (*Integration, error)
- func (a *Integration) CreateActionRequest(tx *gorm.DB, actionName string, parameters any, runAt *time.Time) error
- func (a *Integration) CreateSyncRequest(tx *gorm.DB, runAt *time.Time) error
- func (a *Integration) GetRequest(ID string) (*IntegrationRequest, error)
- func (a *Integration) HasCapabilityEnabled(name string) bool
- func (a *Integration) IsLegacy() bool
- func (a *Integration) ListRequests(reqType string) ([]IntegrationRequest, error)
- func (a *Integration) LockInTransaction(tx *gorm.DB) error
- func (a *Integration) SoftDelete() error
- func (a *Integration) SoftDeleteInTransaction(tx *gorm.DB) error
- func (a *Integration) TableName() string
type IntegrationInvokeAction
type IntegrationRequest
- func FindPendingRequestForIntegration(tx *gorm.DB, installationID uuid.UUID) (*IntegrationRequest, error)
- func LeaseIntegrationRequest(tx *gorm.DB, id uuid.UUID, lease time.Duration) (*IntegrationRequest, error)
- func ListIntegrationRequests() ([]IntegrationRequest, error)
- func (r *IntegrationRequest) Complete(tx *gorm.DB) error
- func (r *IntegrationRequest) TableName() string
type IntegrationRequestSpec
type IntegrationSecret
- func ListIntegrationSecrets(installationID uuid.UUID) ([]IntegrationSecret, error)
- func ListIntegrationSecretsInTransaction(tx *gorm.DB, installationID uuid.UUID) ([]IntegrationSecret, error)
- func (a *IntegrationSecret) TableName() string
type IntegrationSubscription
- func CreateIntegrationSubscription(node *CanvasNode, integration *Integration, configuration any) (*IntegrationSubscription, error)
- func CreateIntegrationSubscriptionInTransaction(tx *gorm.DB, node *CanvasNode, integration *Integration, configuration any) (*IntegrationSubscription, error)
- func (a *IntegrationSubscription) TableName() string
type InvokeAction
type JSONValue
- func NewJSONValue(data any) JSONValue
- func (j JSONValue) Data() any
- func (JSONValue) GormDBDataType(db *gorm.DB, _ *schema.Field) string
- func (JSONValue) GormDataType() string
- func (j JSONValue) GormValue(_ context.Context, db *gorm.DB) clause.Expr
- func (j JSONValue) MarshalJSON() ([]byte, error)
- func (j *JSONValue) Scan(value any) error
- func (j *JSONValue) UnmarshalJSON(data []byte) error
- func (j JSONValue) Value() (driver.Value, error)
type LiveCanvasSpec
type Node
type NodeExecutionRequestSpec
type NodeRef
type NodeSubscription
- func ListIntegrationSubscriptions(tx *gorm.DB, installationID uuid.UUID) ([]NodeSubscription, error)
type OpenCanvasRunWork
- func FindOpenCanvasRunWorkInTransaction(tx *gorm.DB, runID uuid.UUID) (*OpenCanvasRunWork, error)
type Organization
- func CreateOrganization(name, description string) (*Organization, error)
- func CreateOrganizationInTransaction(tx *gorm.DB, name, description string) (*Organization, error)
- func FindOrganizationByID(id string) (*Organization, error)
- func FindOrganizationByIDInTransaction(tx *gorm.DB, id string) (*Organization, error)
- func FindOrganizationByName(name string) (*Organization, error)
- func FindOrganizationsForAccount(email string) ([]Organization, error)
- func ListDeletedOrganizations() ([]Organization, error)
- func ListDeletedOrganizationsInTransaction(tx *gorm.DB) ([]Organization, error)
- func ListOrganizationsByIDs(ids []string) ([]Organization, error)
- func ListOrganizationsPendingUsageLimitsRefresh(staleBefore time.Time, limit int) ([]Organization, error)
- func ListOrganizationsPendingUsageLimitsRefreshInTransaction(tx *gorm.DB, staleBefore time.Time, limit int) ([]Organization, error)
- func ListOrganizationsPendingUsageSync(limit int) ([]Organization, error)
- func ListOrganizationsPendingUsageSyncInTransaction(tx *gorm.DB, limit int) ([]Organization, error)
- func LockDeletedOrganization(tx *gorm.DB, id uuid.UUID) (*Organization, error)
- func (o *Organization) HasExperimentalFeature(id string) bool
- func (o *Organization) IsProviderAllowed(provider string) bool
type OrganizationInviteLink
- func CreateInviteLink(tx *gorm.DB, organizationID uuid.UUID) (*OrganizationInviteLink, error)
- func FindInviteLinkByOrganizationID(tx *gorm.DB, organizationID string) (*OrganizationInviteLink, error)
- func FindInviteLinkByToken(tx *gorm.DB, token string) (*OrganizationInviteLink, error)
- func FindOrCreateInviteLink(tx *gorm.DB, organizationID uuid.UUID) (*OrganizationInviteLink, error)
type OrganizationWithCounts
- func ListAllOrganizations(search string, limit, offset int, sortBy, sortDirection string) ([]OrganizationWithCounts, int64, error)
type Position
type Repository
- func FindRepository(organizationID, canvasID uuid.UUID) (*Repository, error)
- func FindRepositoryInTransaction(tx *gorm.DB, canvasID uuid.UUID) (*Repository, error)
- func FindRepositoryUnscoped(canvasID uuid.UUID) (*Repository, error)
- func ListPendingRepositories(limit int) ([]Repository, error)
- func LockPendingRepository(tx *gorm.DB, id uuid.UUID) (*Repository, error)
- func (r *Repository) MarkError(tx *gorm.DB) error
- func (r *Repository) MarkReady(tx *gorm.DB) error
type RepositorySeedFile
- func ListRepositorySeedFiles(repositoryID uuid.UUID) ([]RepositorySeedFile, error)
- func ListRepositorySeedFilesInTransaction(tx *gorm.DB, repositoryID uuid.UUID) ([]RepositorySeedFile, error)
- func NewRepositorySeedFile(repositoryID uuid.UUID, path string, content []byte) *RepositorySeedFile
- func (RepositorySeedFile) TableName() string
type RoleMetadata
- func FindRoleMetadata(roleName, domainType, domainID string) (*RoleMetadata, error)
- func (rm *RoleMetadata) BeforeCreate(tx *gorm.DB) error
- func (rm *RoleMetadata) Create() error
- func (rm *RoleMetadata) CreateInTransaction(tx *gorm.DB) error
- func (rm *RoleMetadata) Update() error
- func (rm *RoleMetadata) UpdateInTransaction(tx *gorm.DB) error
type Secret
- func CreateSecret(name, provider, requesterID, domainType string, domainID uuid.UUID, ...) (*Secret, error)
- func FindSecretByID(domainType string, domainID uuid.UUID, id string) (*Secret, error)
- func FindSecretByIDInTransaction(tx *gorm.DB, domainType string, domainID uuid.UUID, id string) (*Secret, error)
- func FindSecretByName(domainType string, domainID uuid.UUID, name string) (*Secret, error)
- func FindSecretByNameInTransaction(tx *gorm.DB, domainType string, domainID uuid.UUID, name string) (*Secret, error)
- func ListSecrets(domainType string, domainID uuid.UUID) ([]Secret, error)
- func (s *Secret) Delete() error
- func (s *Secret) UpdateData(data []byte) (*Secret, error)
- func (s *Secret) UpdateNameAndData(tx *gorm.DB, name string, data []byte) (*Secret, error)
type SecretData
type SetupState
type TriggerRef
type User
- func CreateServiceAccount(tx *gorm.DB, orgID uuid.UUID, name string, description *string, ...) (*User, error)
- func CreateUser(orgID, accountID uuid.UUID, email, name string) (*User, error)
- func CreateUserInTransaction(tx *gorm.DB, orgID, accountID uuid.UUID, email, name string) (*User, error)
- func FindActiveUserByEmail(orgID, email string) (*User, error)
- func FindActiveUserByEmailInTransaction(tx *gorm.DB, orgID, email string) (*User, error)
- func FindActiveUserByID(orgID, id string) (*User, error)
- func FindActiveUserByIDInTransaction(tx *gorm.DB, orgID, id string) (*User, error)
- func FindActiveUserByTokenHash(tokenHash string) (*User, error)
- func FindActiveUserByTokenHashInTransaction(tx *gorm.DB, tokenHash string) (*User, error)
- func FindAnyUserByEmail(email string) (*User, error)
- func FindFirstHumanUserByOrganization(orgID string) (*User, error)
- func FindFirstHumanUserByOrganizationInTransaction(tx *gorm.DB, orgID string) (*User, error)
- func FindHumanUsersByIDs(ids []string) ([]User, error)
- func FindMaybeDeletedUserByEmail(orgID, email string) (*User, error)
- func FindMaybeDeletedUserByEmailInTransaction(tx *gorm.DB, orgID, email string) (*User, error)
- func FindMaybeDeletedUserByID(orgID, id string) (*User, error)
- func FindMaybeDeletedUserByIDInTransaction(tx *gorm.DB, orgID, id string) (*User, error)
- func FindMaybeDeletedUsersByIDs(tx *gorm.DB, ids []uuid.UUID) ([]User, error)
- func FindServiceAccountsByOrganization(db *gorm.DB, orgID string) ([]User, error)
- func FindUnscopedUserByID(id string) (*User, error)
- func FindUsersByIDs(ids []string) ([]User, error)
- func FindUsersByIDsInOrganization(db *gorm.DB, orgID string, ids []string) ([]User, error)
- func ListActiveUsersByID(orgID string, ids []string) ([]User, error)
- func ListActiveUsersByIDInTransaction(tx *gorm.DB, orgID string, ids []string) ([]User, error)
- func ListActiveUsersByOrganization(orgID, search string, limit, offset int) ([]User, int64, error)
- func ListAllActiveUsersInOrganization(orgID string) ([]User, error)
- func (u *User) Delete() error
- func (u *User) GetEmail() string
- func (u *User) IsServiceAccount() bool
- func (u *User) Restore() error
- func (u *User) RestoreInTransaction(tx *gorm.DB) error
- func (u *User) UpdateTokenHash(tokenHash string) error
type UserAccountProvider
- func FindUserAccountProviders(users []User) ([]UserAccountProvider, error)
type UserCanvasPreference
- func SetUserCanvasPreference(tx *gorm.DB, organizationID uuid.UUID, userID uuid.UUID, canvasID uuid.UUID, ...) (*UserCanvasPreference, error)
- func (p *UserCanvasPreference) TableName() string
type Webhook
- func FindWebhook(id uuid.UUID) (*Webhook, error)
- func FindWebhookInTransaction(tx *gorm.DB, id uuid.UUID) (*Webhook, error)
- func ListDeletedWebhooks() ([]Webhook, error)
- func ListIntegrationWebhooks(tx *gorm.DB, integrationID uuid.UUID) ([]Webhook, error)
- func ListPendingWebhooks() ([]Webhook, error)
- func ListUnscopedIntegrationWebhooks(tx *gorm.DB, integrationID uuid.UUID) ([]Webhook, error)
- func LockDeletedWebhook(tx *gorm.DB, ID uuid.UUID) (*Webhook, error)
- func LockWebhook(tx *gorm.DB, ID uuid.UUID) (*Webhook, error)
- func (w *Webhook) HasExceededRetries() bool
- func (w *Webhook) IncrementRetry(tx *gorm.DB) error
- func (w *Webhook) MarkFailed(tx *gorm.DB) error
- func (w *Webhook) MarkProvisioning(tx *gorm.DB) error
- func (w *Webhook) Ready(tx *gorm.DB) error
- func (w *Webhook) ReadyWithMetadata(tx *gorm.DB, metadata any) error
type WebhookResource
type WidgetRef
type WorkflowStagedFile
- func FindStagedFileForUser(db *gorm.DB, workflowID, userID uuid.UUID, path string) (*WorkflowStagedFile, error)
- func ListStagedFilesForUser(db *gorm.DB, workflowID, userID uuid.UUID) ([]WorkflowStagedFile, error)
- func UpsertStagedFile(db *gorm.DB, workflowID, userID, baseVersionID, organizationID uuid.UUID, ...) (*WorkflowStagedFile, error)
- func (WorkflowStagedFile) TableName() string

Constants ¶

View Source

const (
	AgentSessionStatusIdle       = "idle"
	AgentSessionStatusStreaming  = "streaming"
	AgentSessionStatusFailed     = "failed"
	AgentSessionStatusTerminated = "terminated"
)

View Source

const (
	AgentMessageRoleUser      = "user"
	AgentMessageRoleAssistant = "assistant"
	AgentMessageRoleTool      = "tool"
	AgentMessageRoleSystem    = "system"

	AgentToolStatusStarted  = "started"
	AgentToolStatusFinished = "finished"
	AgentToolStatusFailed   = "failed"
)

View Source

const (
	CanvasEventStatePending = "pending"
	CanvasEventStateRouted  = "routed"
)

View Source

const (
	CanvasFolderColorBlue   = "blue"
	CanvasFolderColorGreen  = "green"
	CanvasFolderColorPurple = "purple"
	CanvasFolderColorSlate  = "slate"
	CanvasFolderColorOrange = "orange"
)

View Source

const (
	CanvasMemorySourceNode   = "node"
	CanvasMemorySourceManual = "manual"
)

View Source

const (
	CanvasNodeStateReady      = "ready"
	CanvasNodeStateProcessing = "processing"
	CanvasNodeStateError      = "error"

	NodeTypeTrigger   = "trigger"
	NodeTypeComponent = "component"
	NodeTypeWidget    = "widget"
)

View Source

const (
	CanvasNodeExecutionStatePending  = "pending"
	CanvasNodeExecutionStateStarted  = "started"
	CanvasNodeExecutionStateFinished = "finished"

	CanvasNodeExecutionResultPassed    = "passed"
	CanvasNodeExecutionResultFailed    = "failed"
	CanvasNodeExecutionResultCancelled = "cancelled"

	CanvasNodeExecutionResultReasonOk            = "ok"
	CanvasNodeExecutionResultReasonError         = "error"
	CanvasNodeExecutionResultReasonErrorResolved = "error_resolved"
)

View Source

const (
	NodeRequestTypeInvokeAction = "invoke-action"

	NodeExecutionRequestStatePending   = "pending"
	NodeExecutionRequestStateCompleted = "completed"
)

View Source

const (
	CanvasRunStateStarted  = "started"
	CanvasRunStateFinished = "finished"

	CanvasRunResultPassed    = "passed"
	CanvasRunResultFailed    = "failed"
	CanvasRunResultCancelled = "cancelled"
)

View Source

const (
	// ConsoleKind is the canonical YAML kind for canvas consoles (product name).
	ConsoleKind         = "Console"
	DashboardAPIVersion = "v1"

	ConsolePanelTypeMarkdown = "markdown"
	ConsolePanelTypeHTML     = "html"
	ConsolePanelTypeNode     = "node"
	ConsolePanelTypeNodes    = "nodes"
	ConsolePanelTypeTable    = "table"
	ConsolePanelTypeChart    = "chart"
	ConsolePanelTypeNumber   = "number"

	MaxConsolePanels       = 50
	MaxConsolePayloadBytes = 1024 * 1024
)

View Source

const (
	ProviderGitHub = "github"
	ProviderGoogle = "google"

	DomainTypeOrganization = "org"

	DisplayNameOwner  = "Owner"
	DisplayNameAdmin  = "Admin"
	DisplayNameViewer = "Viewer"

	RoleOrgOwner  = "org_owner"
	RoleOrgAdmin  = "org_admin"
	RoleOrgViewer = "org_viewer"

	// Role descriptions
	DescOrgOwner  = "Complete control over the organization including settings and deletion"
	DescOrgAdmin  = "Full management access to organization resources including canvases and users"
	DescOrgViewer = "Read-only access to organization resources"

	// Metadata descriptions
	MetaDescOrgOwner  = "Full control over organization settings, billing, and member management."
	MetaDescOrgAdmin  = "Can manage canvases, users, groups, and roles within the organization."
	MetaDescOrgViewer = "Read-only access to organization resources and information."

	// User types
	UserTypeHuman          = "human"
	UserTypeServiceAccount = "service_account"
)

View Source

const (
	IntegrationStatePending = "pending"
	IntegrationStateReady   = "ready"
	IntegrationStateError   = "error"
)

View Source

const (
	IntegrationRequestTypeSync         = "sync"
	IntegrationRequestTypeInvokeAction = "invoke-action"

	IntegrationRequestStatePending   = "pending"
	IntegrationRequestStateCompleted = "completed"
)

View Source

const (
	RepositoryStatusPending = "pending"
	RepositoryStatusReady   = "ready"
	RepositoryStatusError   = "error"
)

View Source

const (
	WebhookStatePending      = "pending"
	WebhookStateProvisioning = "provisioning"
	WebhookStateReady        = "ready"
	WebhookStateFailed       = "failed"
)

View Source

const EmailProviderSMTP = "smtp"

Variables ¶

View Source

var (
	ErrCanvasFolderTitleAlreadyExists     = errors.New("canvas folder title already exists")
	ErrCanvasFolderTitleRequired          = errors.New("canvas folder title is required")
	ErrCanvasFolderTitleTooLong           = errors.New("canvas folder title is too long")
	ErrCanvasFolderInvalidBackgroundColor = errors.New("invalid canvas folder background color")
	ErrCanvasFolderInvalidMoveDirection   = errors.New("invalid canvas folder move direction")
	ErrCanvasFolderCanvasNotFound         = errors.New("canvas not found")
)

View Source

var (
	ErrNameAlreadyUsed         = fmt.Errorf("name already used")
	ErrInvitationAlreadyExists = fmt.Errorf("invitation already exists")
)

View Source

var AllowedConsolePanelTypes = []string{
	ConsolePanelTypeMarkdown,
	ConsolePanelTypeHTML,
	ConsolePanelTypeNode,
	ConsolePanelTypeNodes,
	ConsolePanelTypeTable,
	ConsolePanelTypeChart,
	ConsolePanelTypeNumber,
}

AllowedConsolePanelTypes lists the panel `type` values accepted on import. Keep this list in lockstep with `web_src/src/pages/app/console/panelTypes.ts` — the frontend validators and per-type form editors rely on the same set.

View Source

var AllowedMarkdownRunSelects = []string{"latest", "latest_passed", "latest_failed"}

AllowedMarkdownRunSelects mirrors `MARKDOWN_RUN_SELECTS` on the FE.

View Source

var AllowedMarkdownVariableDirections = []string{"asc", "desc"}

AllowedMarkdownVariableDirections mirrors `MARKDOWN_VARIABLE_DIRECTIONS` on the FE.

View Source

var AllowedMarkdownVariableModes = []string{"single", "list"}

AllowedMarkdownVariableModes mirrors `MARKDOWN_VARIABLE_MODES` on the FE. `single` keeps the existing first-row behavior; `list` resolves the variable to every matching row so authors can use CEL list macros.

View Source

var CanvasFolderBackgroundColors = []string{
	CanvasFolderColorBlue,
	CanvasFolderColorGreen,
	CanvasFolderColorPurple,
	CanvasFolderColorSlate,
	CanvasFolderColorOrange,
}

View Source

var ErrAgentSessionNotFound = errors.New("agent session not found")

View Source

var ErrCanvasNameAlreadyExists = errors.New("canvas name already exists")

Functions ¶

func AddCanvasMemory ¶ added in v0.10.0

func AddCanvasMemory(canvasID uuid.UUID, namespace string, values any) error

func AddCanvasMemoryInTransaction ¶ added in v0.10.0

func AddCanvasMemoryInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, values any) error

func AppendAgentSessionMessage ¶ added in v0.21.0

func AppendAgentSessionMessage(msg *AgentSessionMessage) error

func AppendAgentSessionMessageInTransaction ¶ added in v0.21.0

func AppendAgentSessionMessageInTransaction(tx *gorm.DB, msg *AgentSessionMessage) error

AppendAgentSessionMessageInTransaction upserts by (session_id, provider_event_id) when ProviderEventID is set, so a re-delivered provider event updates the existing row instead of duplicating it.

func CalculateCanvasRunResultInTransaction ¶ added in v0.26.0

func CalculateCanvasRunResultInTransaction(tx *gorm.DB, runID uuid.UUID) (string, error)

func CanvasMemoryNamespaceSource ¶ added in v0.25.0

func CanvasMemoryNamespaceSource(canvasID uuid.UUID, namespace string) (string, error)

func CanvasMemoryNamespaceSourceInTransaction ¶ added in v0.25.0

func CanvasMemoryNamespaceSourceInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string) (string, error)

CanvasMemoryNamespaceSourceInTransaction returns the source associated with existing rows in a namespace, or empty string if the namespace has no rows.

func CanvasVersionToConsoleYML ¶ added in v0.25.0

func CanvasVersionToConsoleYML(canvasName string, canvasVersion *CanvasVersion) ([]byte, error)

CanvasVersionToConsoleYML serializes a stored dashboard into the canonical YAML representation with stable field ordering. Empty dashboards produce a valid empty spec.

func CheckCanvasExistence ¶ added in v0.26.0

func CheckCanvasExistence(tx *gorm.DB, orgID, id uuid.UUID) (bool, error)

func ClearTokenHashesForAccountInTransaction ¶ added in v0.21.0

func ClearTokenHashesForAccountInTransaction(tx *gorm.DB, accountID uuid.UUID) error

ClearTokenHashesForAccountInTransaction wipes the API token hash on every user that belongs to the given account. Combined with bumping the account's password_changed_at, this ensures that no previously issued credential (cookie, scoped JWT, or API token) keeps working after a password change.

func CompletePendingActionRequestsInTransaction ¶ added in v0.26.0

func CompletePendingActionRequestsInTransaction(tx *gorm.DB, installationID uuid.UUID, actionName string, parameters any) error

CompletePendingActionRequestsInTransaction completes every pending invoke-action request for the installation that matches both the action name and the exact parameters. Matching on parameters keeps legitimately distinct calls (e.g. AWS provisionRule for different detail types) separate, while collapsing duplicate or self-rescheduling chains of the same action (#5386). Parameters are compared as jsonb, which is canonical and key-order-independent, against the same json.Marshal representation used when the request was created.

Matching rows are selected first (narrowed by the indexed app_installation_id/state/type columns) and then completed by primary key, so the write touches only the few matched rows rather than scanning on the jsonb predicate.

func CountActiveHumanUsersByOrganization ¶ added in v0.13.0

func CountActiveHumanUsersByOrganization(orgID string) (int64, error)

func CountActiveHumanUsersByOrganizationInTransaction ¶ added in v0.13.0

func CountActiveHumanUsersByOrganizationInTransaction(tx *gorm.DB, orgID string) (int64, error)

func CountActiveNodeExecutionsForRootEventInTransaction ¶ added in v0.13.0

func CountActiveNodeExecutionsForRootEventInTransaction(tx *gorm.DB, rootEventID uuid.UUID) (int64, error)

func CountActiveUsersByOrganizationIDs ¶ added in v0.0.18

func CountActiveUsersByOrganizationIDs(orgIDs []string) (map[string]int64, error)

func CountAgentSessionMessagesInTransaction ¶ added in v0.21.0

func CountAgentSessionMessagesInTransaction(tx *gorm.DB, sessionID uuid.UUID) (int64, error)

func CountCanvasEvents ¶ added in v0.6.0

func CountCanvasEvents(canvasID uuid.UUID, nodeID string) (int64, error)

func CountCanvasRuns ¶ added in v0.21.0

func CountCanvasRuns(workflowID uuid.UUID, filters CanvasRunFilters) (int64, error)

func CountCanvasRunsInTransaction ¶ added in v0.26.0

func CountCanvasRunsInTransaction(tx *gorm.DB, workflowID uuid.UUID, filters CanvasRunFilters) (int64, error)

func CountCanvasVersionsInTransaction ¶ added in v0.28.0

func CountCanvasVersionsInTransaction(tx *gorm.DB, workflowID uuid.UUID) (int64, error)

func CountCanvasesByOrganization ¶ added in v0.13.0

func CountCanvasesByOrganization(orgID string) (int64, error)

func CountCanvasesByOrganizationIDs ¶ added in v0.6.0

func CountCanvasesByOrganizationIDs(orgIDs []string) (map[string]int64, error)

func CountCanvasesByOrganizationInTransaction ¶ added in v0.13.0

func CountCanvasesByOrganizationInTransaction(tx *gorm.DB, orgID string) (int64, error)

func CountIntegrationsByOrganization ¶ added in v0.13.0

func CountIntegrationsByOrganization(orgID string) (int64, error)

func CountIntegrationsByOrganizationInTransaction ¶ added in v0.13.0

func CountIntegrationsByOrganizationInTransaction(tx *gorm.DB, orgID string) (int64, error)

func CountNodeExecutions ¶

func CountNodeExecutions(workflowID uuid.UUID, nodeID string, states []string, results []string) (int64, error)

func CountNodeQueueItems ¶

func CountNodeQueueItems(workflowID uuid.UUID, nodeID string) (int64, error)

func CountNodeQueueItemsForRootEventInTransaction ¶ added in v0.13.0

func CountNodeQueueItemsForRootEventInTransaction(tx *gorm.DB, rootEventID uuid.UUID) (int64, error)

func CountOrganizationsByBillingAccount ¶ added in v0.13.0

func CountOrganizationsByBillingAccount(accountID string) (int64, error)

func CountOrganizationsByBillingAccountInTransaction ¶ added in v0.13.0

func CountOrganizationsByBillingAccountInTransaction(tx *gorm.DB, accountID string) (int64, error)

func CountPendingRequestsForExecutionsInTransaction ¶ added in v0.13.0

func CountPendingRequestsForExecutionsInTransaction(tx *gorm.DB, executionIDs []uuid.UUID) (int64, error)

func CountRecentMagicCodes ¶ added in v0.14.0

func CountRecentMagicCodes(email string, since time.Time) (int64, error)

func CountRecentMagicCodesInTransaction ¶ added in v0.14.0

func CountRecentMagicCodesInTransaction(tx *gorm.DB, email string, since time.Time) (int64, error)

func CountRootCanvasEvents ¶ added in v0.6.0

func CountRootCanvasEvents(canvasID uuid.UUID) (int64, error)

func CountRootCanvasEventsInTransaction ¶ added in v0.26.0

func CountRootCanvasEventsInTransaction(tx *gorm.DB, canvasID uuid.UUID) (int64, error)

func CountRunningExecutionsForNode ¶ added in v0.6.0

func CountRunningExecutionsForNode(workflowID uuid.UUID, nodeID string) (int64, error)

func CountRunningExecutionsForNodeInTransaction ¶ added in v0.6.0

func CountRunningExecutionsForNodeInTransaction(tx *gorm.DB, workflowID uuid.UUID, nodeID string) (int64, error)

func CreateAgentSessionInTransaction ¶ added in v0.21.0

func CreateAgentSessionInTransaction(tx *gorm.DB, session *AgentSession) error

func CreateNodeExecutionKVInTransaction ¶ added in v0.6.0

func CreateNodeExecutionKVInTransaction(tx *gorm.DB, workflowID uuid.UUID, nodeID string, executionID uuid.UUID, key, value string) error

func CreateRepositorySeedFiles ¶ added in v0.27.0

func CreateRepositorySeedFiles(repositoryID uuid.UUID, files []RepositorySeedFile) error

func CreateRepositorySeedFilesInTransaction ¶ added in v0.27.0

func CreateRepositorySeedFilesInTransaction(tx *gorm.DB, repositoryID uuid.UUID, files []RepositorySeedFile) error

func DeleteAgentSessionForUserCanvas ¶ added in v0.28.0

func DeleteAgentSessionForUserCanvas(tx *gorm.DB, organizationID, userID, canvasID uuid.UUID) error

DeleteAgentSessionForUserCanvas takes an explicit *gorm.DB per the transaction guidelines (no InTransaction suffix / conn wrapper); pass a tx or database.DB(ctx).

func DeleteAgentSessionsForCanvasInTransaction ¶ added in v0.21.0

func DeleteAgentSessionsForCanvasInTransaction(tx *gorm.DB, organizationID, canvasID uuid.UUID) error

func DeleteAgentSessionsForOrganizationInTransaction ¶ added in v0.21.0

func DeleteAgentSessionsForOrganizationInTransaction(tx *gorm.DB, organizationID uuid.UUID) error

func DeleteCanvasFolder ¶ added in v0.20.0

func DeleteCanvasFolder(organizationID, id uuid.UUID) error

func DeleteCanvasFolderInTransaction ¶ added in v0.20.0

func DeleteCanvasFolderInTransaction(tx *gorm.DB, organizationID, id uuid.UUID) error

func DeleteCanvasMemory ¶ added in v0.10.0

func DeleteCanvasMemory(canvasID, memoryID uuid.UUID) error

func DeleteCanvasMemoryInTransaction ¶ added in v0.10.0

func DeleteCanvasMemoryInTransaction(tx *gorm.DB, canvasID, memoryID uuid.UUID) error

func DeleteCanvasNode ¶ added in v0.6.0

func DeleteCanvasNode(tx *gorm.DB, node CanvasNode) error

func DeleteEmailSettings ¶ added in v0.15.0

func DeleteEmailSettings(provider string) error

func DeleteEmailSettingsInTransaction ¶ added in v0.15.0

func DeleteEmailSettingsInTransaction(tx *gorm.DB, provider string) error

func DeleteGroupMetadata ¶

func DeleteGroupMetadata(groupName, domainType, domainID string) error

func DeleteGroupMetadataInTransaction ¶

func DeleteGroupMetadataInTransaction(tx *gorm.DB, groupName, domainType, domainID string) error

func DeleteIntegrationSubscriptionsForNodeInTransaction ¶ added in v0.6.0

func DeleteIntegrationSubscriptionsForNodeInTransaction(tx *gorm.DB, workflowID uuid.UUID, nodeID string) error

func DeleteMetadataForOrganization ¶

func DeleteMetadataForOrganization(tx *gorm.DB, domainType, domainID string) error

func DeleteRepositorySeedFiles ¶ added in v0.27.0

func DeleteRepositorySeedFiles(repositoryID uuid.UUID) error

func DeleteRepositorySeedFilesInTransaction ¶ added in v0.27.0

func DeleteRepositorySeedFilesInTransaction(tx *gorm.DB, repositoryID uuid.UUID) error

func DeleteRoleMetadata ¶

func DeleteRoleMetadata(roleName, domainType, domainID string) error

func DeleteRoleMetadataInTransaction ¶

func DeleteRoleMetadataInTransaction(tx *gorm.DB, roleName, domainType, domainID string) error

func DeleteRootCanvasEventChainsInTransaction ¶ added in v0.20.0

func DeleteRootCanvasEventChainsInTransaction(tx *gorm.DB, rootEventIDs []uuid.UUID) error

func DemoteFromInstallationAdmin ¶ added in v0.14.0

func DemoteFromInstallationAdmin(accountID string) error

func DisableExperimentalFeature ¶ added in v0.21.0

func DisableExperimentalFeature(orgID uuid.UUID, featureID string) error

DisableExperimentalFeature removes the given feature id from the organization's enabled set. Disabling an id that is not enabled is a no-op.

func DisableExperimentalFeatureInTransaction ¶ added in v0.21.0

func DisableExperimentalFeatureInTransaction(tx *gorm.DB, orgID uuid.UUID, featureID string) error

func DiscardStagedFilesForUser ¶ added in v0.28.0

func DiscardStagedFilesForUser(db *gorm.DB, workflowID, userID uuid.UUID, paths []string) error

func EnableExperimentalFeature ¶ added in v0.21.0

func EnableExperimentalFeature(orgID uuid.UUID, featureID string) error

EnableExperimentalFeature adds the given feature id to the organization's enabled set, deduping. The caller is responsible for validating that the feature id exists in the registry.

func EnableExperimentalFeatureInTransaction ¶ added in v0.21.0

func EnableExperimentalFeatureInTransaction(tx *gorm.DB, orgID uuid.UUID, featureID string) error

func FindCanvasVersionsByIDs ¶ added in v0.26.0

func FindCanvasVersionsByIDs(workflowID uuid.UUID, versionIDs []uuid.UUID) (map[uuid.UUID]*CanvasVersion, error)

func FindCanvasVersionsByIDsInTransaction ¶ added in v0.26.0

func FindCanvasVersionsByIDsInTransaction(
	tx *gorm.DB,
	workflowID uuid.UUID,
	versionIDs []uuid.UUID,
) (map[uuid.UUID]*CanvasVersion, error)

func FindLatestNodeExecutionKVValueInTransaction ¶ added in v0.22.0

func FindLatestNodeExecutionKVValueInTransaction(tx *gorm.DB, executionID uuid.UUID, key string) (string, error)

FindLatestNodeExecutionKVValueInTransaction returns the value from the newest row for this execution and key (by created_at, then id).

func FindLiveCanvasSpecInTransaction ¶ added in v0.11.0

func FindLiveCanvasSpecInTransaction(tx *gorm.DB, workflowID uuid.UUID) ([]Node, []Edge, error)

func FindLiveCanvasSpecsByCanvasIDs ¶ added in v0.28.0

func FindLiveCanvasSpecsByCanvasIDs(tx *gorm.DB, canvasIDs []uuid.UUID) (map[uuid.UUID]LiveCanvasSpec, error)

func FindRoleMetadataByNames ¶

func FindRoleMetadataByNames(roleNames []string, domainType, domainID string) (map[string]*RoleMetadata, error)

func FindUserCanvasPreferencesForCanvases ¶ added in v0.28.0

func FindUserCanvasPreferencesForCanvases(
	tx *gorm.DB,
	organizationID uuid.UUID,
	userID uuid.UUID,
	canvasIDs []uuid.UUID,
) (map[uuid.UUID]UserCanvasPreference, error)

func FormatDomain ¶

func FormatDomain(domainType, domainID string) string

func GenerateNodeID ¶ added in v0.0.43

func GenerateNodeID(blockName string, nodeName string) string

func GenerateUniqueNodeID ¶ added in v0.0.43

func GenerateUniqueNodeID(node Node, reservedIDs map[string]bool) string

func GetActiveOrganizationIDs ¶

func GetActiveOrganizationIDs() ([]string, error)

func GetInstallationID ¶ added in v0.1.0

func GetInstallationID(tx *gorm.DB) (string, error)

func HardDeleteOrganization ¶

func HardDeleteOrganization(id string) error

func HasExperimentalFeature ¶ added in v0.21.0

func HasExperimentalFeature(orgID uuid.UUID, featureID string) (bool, error)

HasExperimentalFeature reports whether the given feature id is active for the organization with the given id. Released features are reported true without loading the organization from the database.

func HasStagedFilesForUser ¶ added in v0.28.0

func HasStagedFilesForUser(db *gorm.DB, workflowID, userID uuid.UUID) (bool, error)

func IncrementAndMaybeInvalidateCodes ¶ added in v0.14.0

func IncrementAndMaybeInvalidateCodes(email string, maxVerifyAttempts int) (bool, error)

IncrementAndMaybeInvalidateCodes atomically increments verify_attempts on all active codes for the given email. If the threshold is reached, it invalidates all active codes in the same transaction. Returns true if codes were invalidated.

func IncrementAndMaybeInvalidateCodesInTransaction ¶ added in v0.14.0

func IncrementAndMaybeInvalidateCodesInTransaction(conn *gorm.DB, email string, maxVerifyAttempts int) (bool, error)

func InvalidateActiveMagicCodesInTransaction ¶ added in v0.14.0

func InvalidateActiveMagicCodesInTransaction(tx *gorm.DB, email string) error

func IsAgentSessionStreaming ¶ added in v0.26.0

func IsAgentSessionStreaming(sessionID uuid.UUID) (bool, error)

func IsLiveCanvasVersion ¶ added in v0.28.0

func IsLiveCanvasVersion(tx *gorm.DB, canvas *Canvas, version *CanvasVersion) bool

func MapCanvasNameUniqueConstraintError ¶ added in v0.19.0

func MapCanvasNameUniqueConstraintError(err error) error

func MarkAgentSessionContextReplayed ¶ added in v0.26.0

func MarkAgentSessionContextReplayed(sessionID uuid.UUID) error

func MarkAgentSessionTokenUsageTracked ¶ added in v0.27.0

func MarkAgentSessionTokenUsageTracked(sessionID uuid.UUID, usage AgentSessionTokenUsage) error

func MarkOrganizationUsageLimitsSynced ¶ added in v0.13.0

func MarkOrganizationUsageLimitsSynced(orgID string, retentionWindowDays *int32, syncedAt time.Time) error

func MarkOrganizationUsageLimitsSyncedIfNewer ¶ added in v0.13.0

func MarkOrganizationUsageLimitsSyncedIfNewer(orgID string, retentionWindowDays *int32, syncedAt time.Time) (bool, error)

func MarkOrganizationUsageLimitsSyncedIfNewerInTransaction ¶ added in v0.13.0

func MarkOrganizationUsageLimitsSyncedIfNewerInTransaction(
	tx *gorm.DB,
	orgID string,
	retentionWindowDays *int32,
	syncedAt time.Time,
) (bool, error)

func MarkOrganizationUsageLimitsSyncedIfNoNewerThan ¶ added in v0.13.0

func MarkOrganizationUsageLimitsSyncedIfNoNewerThan(
	orgID string,
	retentionWindowDays *int32,
	maxExistingSyncedAt time.Time,
	syncedAt time.Time,
) (bool, error)

func MarkOrganizationUsageLimitsSyncedIfNoNewerThanInTransaction ¶ added in v0.13.0

func MarkOrganizationUsageLimitsSyncedIfNoNewerThanInTransaction(
	tx *gorm.DB,
	orgID string,
	retentionWindowDays *int32,
	maxExistingSyncedAt time.Time,
	syncedAt time.Time,
) (bool, error)

func MarkOrganizationUsageLimitsSyncedInTransaction ¶ added in v0.13.0

func MarkOrganizationUsageLimitsSyncedInTransaction(
	tx *gorm.DB,
	orgID string,
	retentionWindowDays *int32,
	syncedAt time.Time,
) error

func MarkOrganizationUsageSynced ¶ added in v0.13.0

func MarkOrganizationUsageSynced(orgID string, syncedAt time.Time) error

func MarkOrganizationUsageSyncedIfUnset ¶ added in v0.13.0

func MarkOrganizationUsageSyncedIfUnset(orgID string, syncedAt time.Time) error

func MarkOrganizationUsageSyncedIfUnsetInTransaction ¶ added in v0.13.0

func MarkOrganizationUsageSyncedIfUnsetInTransaction(tx *gorm.DB, orgID string, syncedAt time.Time) error

func MarkOrganizationUsageSyncedInTransaction ¶ added in v0.13.0

func MarkOrganizationUsageSyncedInTransaction(tx *gorm.DB, orgID string, syncedAt time.Time) error

func MarkOrganizationUsageSyncedWithLimitsIfNoNewerThan ¶ added in v0.13.0

func MarkOrganizationUsageSyncedWithLimitsIfNoNewerThan(
	orgID string,
	usageSyncedAt time.Time,
	retentionWindowDays *int32,
	maxExistingLimitsSyncedAt time.Time,
	limitsSyncedAt time.Time,
) error

func MarkOrganizationUsageSyncedWithLimitsIfNoNewerThanInTransaction ¶ added in v0.13.0

func MarkOrganizationUsageSyncedWithLimitsIfNoNewerThanInTransaction(
	tx *gorm.DB,
	orgID string,
	usageSyncedAt time.Time,
	retentionWindowDays *int32,
	maxExistingLimitsSyncedAt time.Time,
	limitsSyncedAt time.Time,
) error

func MarkStagedFilePathDeleted ¶ added in v0.28.0

func MarkStagedFilePathDeleted(
	db *gorm.DB,
	workflowID, userID, baseVersionID, organizationID uuid.UUID,
	path string,
) error

func NodeTypeName ¶ added in v0.0.43

func NodeTypeName(node Node) string

func PrefixGroup ¶

func PrefixGroup(groupName string) string

func PrefixRole ¶

func PrefixRole(role string) string

func PrefixUser ¶

func PrefixUser(userID string) string

func PromoteToInstallationAdmin ¶ added in v0.14.0

func PromoteToInstallationAdmin(accountID string) error

func PromoteToLiveInTransaction ¶ added in v0.17.0

func PromoteToLiveInTransaction(tx *gorm.DB, version *CanvasVersion, nodes []Node, edges []Edge) error

func ReplaceCanvasFolderMembershipInTransaction ¶ added in v0.20.0

func ReplaceCanvasFolderMembershipInTransaction(tx *gorm.DB, organizationID, folderID uuid.UUID, canvasIDs []uuid.UUID) ([]Canvas, []Canvas, error)

func ReplaceManualCanvasMemoryNamespace ¶ added in v0.25.0

func ReplaceManualCanvasMemoryNamespace(canvasID uuid.UUID, namespace string, entries []any) error

func ReplaceManualCanvasMemoryNamespaceInTransaction ¶ added in v0.25.0

func ReplaceManualCanvasMemoryNamespaceInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, entries []any) error

ReplaceManualCanvasMemoryNamespaceInTransaction replaces all manual-source rows in a namespace with one row per entry. Used by both create (no existing rows) and update (existing manual rows). The caller is responsible for enforcing origin-lock before invoking this.

func ResetStuckProvisioningWebhooks ¶ added in v0.12.0

func ResetStuckProvisioningWebhooks() (int64, error)

ResetStuckProvisioningWebhooks resets webhooks that have been stuck in "provisioning" state back to "pending". This handles the edge case where the process crashes during the external API call (Phase 2).

func ResolveExecutionErrors ¶ added in v0.1.5

func ResolveExecutionErrors(workflowID uuid.UUID, executionIDs []uuid.UUID) error

func ResolveExecutionErrorsInTransaction ¶ added in v0.1.5

func ResolveExecutionErrorsInTransaction(tx *gorm.DB, workflowID uuid.UUID, executionIDs []uuid.UUID) error

func SaveCanvasVersionInTransaction ¶ added in v0.28.0

func SaveCanvasVersionInTransaction(tx *gorm.DB, version *CanvasVersion) error

func SaveInviteLink ¶ added in v0.0.43

func SaveInviteLink(tx *gorm.DB, inviteLink *OrganizationInviteLink) error

func SoftDeleteOrganization ¶

func SoftDeleteOrganization(id string) error

func SoftDeleteOrganizationInTransaction ¶

func SoftDeleteOrganizationInTransaction(tx *gorm.DB, id string) error

func TouchAgentSessionHeartbeat ¶ added in v0.26.0

func TouchAgentSessionHeartbeat(sessionID uuid.UUID) error

TouchAgentSessionHeartbeat uses UpdateColumn so updated_at stays put — it's the optimistic-concurrency key for the per-turn idle transition.

func UnmarshalJSONValue ¶ added in v0.23.0

func UnmarshalJSONValue(data []byte, value any) error

UnmarshalJSONValue decodes JSON into value using json.Number for numeric tokens and rejects payloads with multiple top-level values.

func UpdateAgentSessionProviderSessionInTransaction ¶ added in v0.26.0

func UpdateAgentSessionProviderSessionInTransaction(tx *gorm.DB, sessionID uuid.UUID, providerSessionID, toolSchemaRevision, status string) error

func UpdateAgentSessionStatus ¶ added in v0.21.0

func UpdateAgentSessionStatus(sessionID uuid.UUID, status string) error

func UpdateAgentSessionStatusIfUnchanged ¶ added in v0.26.0

func UpdateAgentSessionStatusIfUnchanged(sessionID uuid.UUID, status string, unchangedSince *time.Time) (bool, error)

func UpdateAgentSessionStatusIfUnchangedInTransaction ¶ added in v0.26.0

func UpdateAgentSessionStatusIfUnchangedInTransaction(tx *gorm.DB, sessionID uuid.UUID, status string, unchangedSince *time.Time) (bool, error)

func UpdateAgentSessionStatusInTransaction ¶ added in v0.21.0

func UpdateAgentSessionStatusInTransaction(tx *gorm.DB, sessionID uuid.UUID, status string) error

func UpdateCanvasFolderWithMembership ¶ added in v0.20.0

func UpdateCanvasFolderWithMembership(
	organizationID,
	id uuid.UUID,
	title,
	backgroundColor string,
	canvasIDs []uuid.UUID,
) (*CanvasFolder, []Canvas, error)

func UpdateInstallationMetadata ¶ added in v0.15.0

func UpdateInstallationMetadata(tx *gorm.DB, metadata *InstallationMetadata) error

func UpsertEmailSettings ¶ added in v0.0.43

func UpsertEmailSettings(settings *EmailSettings) error

func UpsertEmailSettingsInTransaction ¶ added in v0.0.43

func UpsertEmailSettingsInTransaction(tx *gorm.DB, settings *EmailSettings) error

func UpsertGroupMetadata ¶

func UpsertGroupMetadata(groupName, domainType, domainID, displayName, description string) error

func UpsertGroupMetadataInTransaction ¶

func UpsertGroupMetadataInTransaction(tx *gorm.DB, groupName, domainType, domainID, displayName, description string) error

func UpsertRoleMetadata ¶

func UpsertRoleMetadata(roleName, domainType, domainID, displayName, description string) error

func UpsertRoleMetadataInTransaction ¶

func UpsertRoleMetadataInTransaction(tx *gorm.DB, roleName, domainType, domainID, displayName, description string) error

func ValidateConsoleContent ¶ added in v0.25.0

func ValidateConsoleContent(panels []ConsolePanel, layout []ConsoleLayoutItem) error

ValidateDashboardContent enforces the shared validation rules used by both YAML import and the gRPC update endpoint. Keeping this in models means the rules live next to the persisted shape and stay consistent across surfaces.

func ValidateDomainType ¶

func ValidateDomainType(domainType string) error

Types ¶

type Account ¶

type Account struct {
	ID                uuid.UUID `gorm:"primary_key;default:uuid_generate_v4()"`
	Email             string
	Name              string
	InstallationAdmin bool `gorm:"default:false"`
	PasswordChangedAt *time.Time
	CreatedAt         *time.Time
	UpdatedAt         *time.Time
}

func CreateAccount ¶

func CreateAccount(name, email string) (*Account, error)

func CreateAccountInTransaction ¶

func CreateAccountInTransaction(tx *gorm.DB, name, email string) (*Account, error)

func FindAccountByEmail ¶

func FindAccountByEmail(email string) (*Account, error)

func FindAccountByID ¶

func FindAccountByID(id string) (*Account, error)

func FindAccountByProvider ¶

func FindAccountByProvider(provider, providerID string) (*Account, error)

func ListAccounts ¶ added in v0.14.0

func ListAccounts(search string, limit, offset int, sortBy, sortDirection string) ([]Account, int64, error)

func (*Account) FindAccountProviderByID ¶

func (a *Account) FindAccountProviderByID(provider, providerID string) (*AccountProvider, error)

func (*Account) GetAccountProvider ¶

func (a *Account) GetAccountProvider(provider string) (*AccountProvider, error)

func (*Account) GetAccountProviders ¶

func (a *Account) GetAccountProviders() ([]AccountProvider, error)

func (*Account) IsInstallationAdmin ¶ added in v0.14.0

func (a *Account) IsInstallationAdmin() bool

func (*Account) IsSessionFresh ¶ added in v0.21.0

func (a *Account) IsSessionFresh(issuedAt int64) bool

IsSessionFresh reports whether a token issued at the given Unix timestamp is still valid relative to the most recent password change. Tokens issued strictly before PasswordChangedAt are considered stale.

func (*Account) MarkPasswordChangedInTransaction ¶ added in v0.21.0

func (a *Account) MarkPasswordChangedInTransaction(tx *gorm.DB, now time.Time) error

MarkPasswordChangedInTransaction stamps the password rotation time on the account. Used together with rotating the password hash and clearing API tokens to invalidate every existing session for the account.

func (*Account) UpdateEmail ¶

func (a *Account) UpdateEmail(newEmail string) error

func (*Account) UpdateEmailForProvider ¶

func (a *Account) UpdateEmailForProvider(newEmail, provider, providerID string) error

type AccountMagicCode ¶ added in v0.14.0

type AccountMagicCode struct {
	ID             uuid.UUID  `gorm:"type:uuid;primary_key;default:gen_random_uuid()"`
	Email          string     `gorm:"type:varchar(255);not null"`
	CodeHash       string     `gorm:"type:varchar(64);not null"`
	ExpiresAt      time.Time  `gorm:"not null"`
	UsedAt         *time.Time `gorm:"default:null"`
	VerifyAttempts int        `gorm:"not null;default:0"`
	CreatedAt      time.Time
}

func CreateAccountMagicCode ¶ added in v0.14.0

func CreateAccountMagicCode(email, codeHash string, expiresAt time.Time) (*AccountMagicCode, error)

func CreateAccountMagicCodeInTransaction ¶ added in v0.14.0

func CreateAccountMagicCodeInTransaction(tx *gorm.DB, email, codeHash string, expiresAt time.Time) (*AccountMagicCode, error)

func FindValidAccountMagicCode ¶ added in v0.14.0

func FindValidAccountMagicCode(email, codeHash string, maxVerifyAttempts int) (*AccountMagicCode, error)

func FindValidAccountMagicCodeInTransaction ¶ added in v0.14.0

func FindValidAccountMagicCodeInTransaction(tx *gorm.DB, email, codeHash string, maxVerifyAttempts int) (*AccountMagicCode, error)

func (*AccountMagicCode) MarkUsed ¶ added in v0.14.0

func (c *AccountMagicCode) MarkUsed() (bool, error)

func (*AccountMagicCode) MarkUsedInTransaction ¶ added in v0.14.0

func (c *AccountMagicCode) MarkUsedInTransaction(tx *gorm.DB) (bool, error)

MarkUsedInTransaction atomically marks the code as used only if it hasn't been used yet. Returns true if the code was successfully marked, false if it was already used by a concurrent request.

func (AccountMagicCode) TableName ¶ added in v0.14.0

func (AccountMagicCode) TableName() string

type AccountPasswordAuth ¶ added in v0.0.18

type AccountPasswordAuth struct {
	ID           uuid.UUID `gorm:"type:uuid;primary_key;default:gen_random_uuid()"`
	AccountID    uuid.UUID
	PasswordHash string
	CreatedAt    time.Time
	UpdatedAt    time.Time
}

func CreateAccountPasswordAuth ¶ added in v0.0.18

func CreateAccountPasswordAuth(accountID uuid.UUID, passwordHash string) (*AccountPasswordAuth, error)

func CreateAccountPasswordAuthInTransaction ¶ added in v0.0.18

func CreateAccountPasswordAuthInTransaction(tx *gorm.DB, accountID uuid.UUID, passwordHash string) (*AccountPasswordAuth, error)

func FindAccountPasswordAuthByAccountID ¶ added in v0.0.18

func FindAccountPasswordAuthByAccountID(accountID uuid.UUID) (*AccountPasswordAuth, error)

func FindAccountPasswordAuthByAccountIDInTransaction ¶ added in v0.0.18

func FindAccountPasswordAuthByAccountIDInTransaction(tx *gorm.DB, accountID uuid.UUID) (*AccountPasswordAuth, error)

func (AccountPasswordAuth) TableName ¶ added in v0.0.18

func (AccountPasswordAuth) TableName() string

func (*AccountPasswordAuth) UpdatePasswordHash ¶ added in v0.0.18

func (a *AccountPasswordAuth) UpdatePasswordHash(passwordHash string) error

func (*AccountPasswordAuth) UpdatePasswordHashInTransaction ¶ added in v0.0.18

func (a *AccountPasswordAuth) UpdatePasswordHashInTransaction(tx *gorm.DB, passwordHash string) error

type AccountProvider ¶

type AccountProvider struct {
	ID             uuid.UUID `gorm:"type:uuid;primary_key;default:gen_random_uuid()"`
	AccountID      uuid.UUID
	Provider       string
	ProviderID     string
	Username       string
	Email          string
	Name           string
	AvatarURL      string
	AccessToken    string
	RefreshToken   string
	TokenExpiresAt *time.Time
	CreatedAt      time.Time
	UpdatedAt      time.Time
}

type AgentSession ¶ added in v0.21.0

type AgentSession struct {
	ID                           uuid.UUID `gorm:"primaryKey;default:uuid_generate_v4()"`
	OrganizationID               uuid.UUID
	UserID                       uuid.UUID
	CanvasID                     uuid.UUID
	Provider                     string
	ProviderSessionID            string
	AgentToolSchemaRevision      string
	TrackedUsageInputTokens      int64
	TrackedUsageOutputTokens     int64
	TrackedUsageCacheReadTokens  int64
	TrackedUsageCacheWriteTokens int64
	TrackedUsageTotalTokens      int64
	TrackedUsageInitialized      bool `gorm:"default:true"`
	Status                       string
	LastActiveAt                 *time.Time
	HeartbeatAt                  *time.Time
	ContextReplayedAt            *time.Time
	CreatedAt                    *time.Time
	UpdatedAt                    *time.Time
}

func FailStuckStreamingSessions ¶ added in v0.21.0

func FailStuckStreamingSessions(heartbeatCutoff, legacyCutoff time.Time) ([]AgentSession, error)

FailStuckStreamingSessions flags leaked streaming rows. Heartbeated rows use heartbeatCutoff (tight); rows with no heartbeat yet — pre-heartbeat binaries, or new turns before the worker's first tick — fall back to updated_at with legacyCutoff (loose, sized above agentStreamTimeout).

func FindAgentSession ¶ added in v0.21.0

func FindAgentSession(sessionID uuid.UUID) (*AgentSession, error)

func FindAgentSessionByCanvasInTransaction ¶ added in v0.21.0

func FindAgentSessionByCanvasInTransaction(tx *gorm.DB, organizationID, userID, canvasID uuid.UUID) (*AgentSession, error)

func FindAgentSessionForUser ¶ added in v0.21.0

func FindAgentSessionForUser(organizationID, userID, sessionID uuid.UUID) (*AgentSession, error)

func FindAgentSessionForUserInTransaction ¶ added in v0.21.0

func FindAgentSessionForUserInTransaction(tx *gorm.DB, organizationID, userID, sessionID uuid.UUID) (*AgentSession, error)

FindAgentSessionForUserInTransaction enforces ownership: sessions are private per user, so a session is invisible to anyone but its creator.

func FindAgentSessionInTransaction ¶ added in v0.21.0

func FindAgentSessionInTransaction(tx *gorm.DB, sessionID uuid.UUID) (*AgentSession, error)

func ListAgentSessionsForCanvasInTransaction ¶ added in v0.21.0

func ListAgentSessionsForCanvasInTransaction(tx *gorm.DB, organizationID, canvasID uuid.UUID) ([]AgentSession, error)

func ListAgentSessionsForOrganizationInTransaction ¶ added in v0.21.0

func ListAgentSessionsForOrganizationInTransaction(tx *gorm.DB, organizationID uuid.UUID) ([]AgentSession, error)

func LockAgentSessionInTransaction ¶ added in v0.26.0

func LockAgentSessionInTransaction(tx *gorm.DB, sessionID uuid.UUID) (*AgentSession, error)

func (AgentSession) TableName ¶ added in v0.21.0

func (AgentSession) TableName() string

type AgentSessionImage ¶ added in v0.26.0

type AgentSessionImage struct {
	MediaType string `json:"media_type"`
	Data      string `json:"data"`
}

AgentSessionImage is a base64-encoded image attached to a user message.

type AgentSessionMessage ¶ added in v0.21.0

type AgentSessionMessage struct {
	ID              uuid.UUID `gorm:"primaryKey;default:uuid_generate_v4()"`
	SessionID       uuid.UUID
	ProviderEventID string
	Role            string
	Content         string
	ToolCallID      string
	ToolName        string
	ToolStatus      string
	Images          datatypes.JSONSlice[AgentSessionImage]
	CreatedAt       *time.Time
}

func CloseOpenToolMessages ¶ added in v0.21.0

func CloseOpenToolMessages(sessionID uuid.UUID) ([]AgentSessionMessage, error)

CloseOpenToolMessages flips lingering "started" tool rows to "finished" and returns them, so callers can broadcast the closure.

func FindAgentSessionMessage ¶ added in v0.26.0

func FindAgentSessionMessage(tx *gorm.DB, id uuid.UUID) (*AgentSessionMessage, error)

func ListAgentSessionMessagesPage ¶ added in v0.21.0

func ListAgentSessionMessagesPage(sessionID uuid.UUID, before *AgentSessionMessage, limit int) ([]AgentSessionMessage, error)

ListAgentSessionMessagesPage returns up to `limit` messages strictly older than `before` (or the most recent `limit` when `before` is nil), in chronological order (oldest-first). Used for tail-paginated chat scroll.

func (AgentSessionMessage) TableName ¶ added in v0.21.0

func (AgentSessionMessage) TableName() string

type AgentSessionTokenUsage ¶ added in v0.27.0

type AgentSessionTokenUsage struct {
	InputTokens      int64
	OutputTokens     int64
	CacheReadTokens  int64
	CacheWriteTokens int64
	TotalTokens      int64
}

func CalculateAgentSessionTokenUsageDelta ¶ added in v0.27.0

func CalculateAgentSessionTokenUsageDelta(sessionID uuid.UUID, usage AgentSessionTokenUsage) (AgentSessionTokenUsage, bool, error)

func (AgentSessionTokenUsage) HasUsage ¶ added in v0.27.0

func (u AgentSessionTokenUsage) HasUsage() bool

type BrowserAction ¶

type BrowserAction struct {
	URL         string
	Method      string
	FormFields  map[string]string
	Description string
}

type Canvas ¶ added in v0.6.0

type Canvas struct {
	ID             uuid.UUID
	OrganizationID uuid.UUID
	LiveVersionID  *uuid.UUID
	CanvasFolderID *uuid.UUID `gorm:"column:folder_id"`
	Name           string
	Description    string
	CreatedBy      *uuid.UUID
	CreatedAt      *time.Time
	UpdatedAt      *time.Time
	DeletedAt      gorm.DeletedAt `gorm:"index"`
}

func FindCanvas ¶ added in v0.6.0

func FindCanvas(orgID, id uuid.UUID) (*Canvas, error)

func FindCanvasByName ¶ added in v0.6.0

func FindCanvasByName(name string, organizationID uuid.UUID) (*Canvas, error)

func FindCanvasByNameInTransaction ¶ added in v0.19.0

func FindCanvasByNameInTransaction(tx *gorm.DB, name string, organizationID uuid.UUID) (*Canvas, error)

func FindCanvasInTransaction ¶ added in v0.6.0

func FindCanvasInTransaction(tx *gorm.DB, orgID, id uuid.UUID) (*Canvas, error)

func FindCanvasWithoutOrgScope ¶ added in v0.6.0

func FindCanvasWithoutOrgScope(id uuid.UUID) (*Canvas, error)

func FindCanvasWithoutOrgScopeInTransaction ¶ added in v0.6.0

func FindCanvasWithoutOrgScopeInTransaction(tx *gorm.DB, id uuid.UUID) (*Canvas, error)

func FindUnscopedCanvas ¶ added in v0.6.0

func FindUnscopedCanvas(id uuid.UUID) (*Canvas, error)

func FindUnscopedCanvasInTransaction ¶ added in v0.6.0

func FindUnscopedCanvasInTransaction(tx *gorm.DB, id uuid.UUID) (*Canvas, error)

func ListCanvases ¶ added in v0.6.0

func ListCanvases(orgID string) ([]Canvas, error)

func ListCanvasesPaginated ¶ added in v0.14.0

func ListCanvasesPaginated(orgID, search string, limit, offset int) ([]Canvas, int64, error)

func ListDeletedCanvases ¶ added in v0.6.0

func ListDeletedCanvases() ([]Canvas, error)

func ListMaybeDeletedCanvasesByOrganizationInTransaction ¶ added in v0.13.0

func ListMaybeDeletedCanvasesByOrganizationInTransaction(tx *gorm.DB, orgID uuid.UUID) ([]Canvas, error)

func LockCanvas ¶ added in v0.6.0

func LockCanvas(tx *gorm.DB, id uuid.UUID) (*Canvas, error)

func LockCanvasForUpdate ¶ added in v0.28.0

func LockCanvasForUpdate(tx *gorm.DB, organizationUUID, canvasID uuid.UUID) (*Canvas, error)

func UpdateCanvasFolderMembership ¶ added in v0.20.0

func UpdateCanvasFolderMembership(organizationID, canvasID uuid.UUID, folderID *uuid.UUID) (*Canvas, error)

func UpdateCanvasFolderMembershipInTransaction ¶ added in v0.20.0

func UpdateCanvasFolderMembershipInTransaction(tx *gorm.DB, organizationID, canvasID uuid.UUID, folderID *uuid.UUID) (*Canvas, error)

func (*Canvas) CreatePendingRepository ¶ added in v0.24.0

func (c *Canvas) CreatePendingRepository(provider, providerRepoID string) (*Repository, error)

func (*Canvas) CreatePendingRepositoryInTransaction ¶ added in v0.24.0

func (c *Canvas) CreatePendingRepositoryInTransaction(tx *gorm.DB, provider, providerRepoID string) (*Repository, error)

func (*Canvas) FindNode ¶ added in v0.6.0

func (c *Canvas) FindNode(id string) (*CanvasNode, error)

func (*Canvas) SoftDelete ¶ added in v0.6.0

func (c *Canvas) SoftDelete() error

func (*Canvas) SoftDeleteInTransaction ¶ added in v0.6.0

func (c *Canvas) SoftDeleteInTransaction(tx *gorm.DB) error

func (*Canvas) TableName ¶ added in v0.6.0

func (c *Canvas) TableName() string

type CanvasEvent ¶ added in v0.6.0

type CanvasEvent struct {
	ID          uuid.UUID `gorm:"primaryKey;default:uuid_generate_v4()"`
	WorkflowID  uuid.UUID
	NodeID      string
	Channel     string
	CustomName  *string
	Data        JSONValue
	ExecutionID *uuid.UUID
	RunID       uuid.UUID
	State       string
	CreatedAt   *time.Time
}

func FindCanvasEvent ¶ added in v0.6.0

func FindCanvasEvent(id uuid.UUID) (*CanvasEvent, error)

func FindCanvasEventForCanvas ¶ added in v0.6.0

func FindCanvasEventForCanvas(canvasID uuid.UUID, id uuid.UUID) (*CanvasEvent, error)

func FindCanvasEventInTransaction ¶ added in v0.6.0

func FindCanvasEventInTransaction(tx *gorm.DB, id uuid.UUID) (*CanvasEvent, error)

func FindCanvasEvents ¶ added in v0.6.0

func FindCanvasEvents(tx *gorm.DB, ids []string) ([]CanvasEvent, error)

func FindCanvasEventsForExecutions ¶ added in v0.6.0

func FindCanvasEventsForExecutions(tx *gorm.DB, executionIDs []string) ([]CanvasEvent, error)

func FindLastEventPerNode ¶

func FindLastEventPerNode(tx *gorm.DB, canvasID uuid.UUID) ([]CanvasEvent, error)

FindLastEventPerNode finds the most recent event for each node in a workflow. Only returns events for nodes that have not been deleted.

func ListCanvasEvents ¶ added in v0.6.0

func ListCanvasEvents(canvasID uuid.UUID, nodeID string, limit int, before *time.Time) ([]CanvasEvent, error)

func ListCanvasEventsByIDsInTransaction ¶ added in v0.25.1

func ListCanvasEventsByIDsInTransaction(tx *gorm.DB, ids []uuid.UUID) ([]CanvasEvent, error)

func ListCanvasEventsForExecutionsInTransaction ¶ added in v0.6.0

func ListCanvasEventsForExecutionsInTransaction(tx *gorm.DB, executionIDs []uuid.UUID) ([]CanvasEvent, error)

func ListPendingCanvasEvents ¶ added in v0.6.0

func ListPendingCanvasEvents() ([]CanvasEvent, error)

func ListRootCanvasEvents ¶ added in v0.6.0

func ListRootCanvasEvents(canvasID uuid.UUID, limit int, before *time.Time) ([]CanvasEvent, error)

func ListRootCanvasEventsInTransaction ¶ added in v0.26.0

func ListRootCanvasEventsInTransaction(tx *gorm.DB, canvasID uuid.UUID, limit int, before *time.Time) ([]CanvasEvent, error)

func LockCanvasEvent ¶ added in v0.6.0

func LockCanvasEvent(tx *gorm.DB, id uuid.UUID) (*CanvasEvent, error)

func LockExpiredRoutedRootCanvasEventsInTransaction ¶ added in v0.20.0

func LockExpiredRoutedRootCanvasEventsInTransaction(tx *gorm.DB, referenceTime time.Time, limit int) ([]CanvasEvent, error)

func (*CanvasEvent) BeforeCreate ¶ added in v0.21.0

func (e *CanvasEvent) BeforeCreate(tx *gorm.DB) error

func (*CanvasEvent) Routed ¶ added in v0.6.0

func (e *CanvasEvent) Routed() error

func (*CanvasEvent) RoutedInTransaction ¶ added in v0.6.0

func (e *CanvasEvent) RoutedInTransaction(tx *gorm.DB) error

func (*CanvasEvent) TableName ¶ added in v0.6.0

func (e *CanvasEvent) TableName() string

type CanvasFolder ¶ added in v0.20.0

type CanvasFolder struct {
	ID              uuid.UUID
	OrganizationID  uuid.UUID
	Title           string
	BackgroundColor string
	SortOrder       int64
	CreatedAt       *time.Time
	UpdatedAt       *time.Time
	Canvases        []Canvas `gorm:"foreignKey:CanvasFolderID"`
}

func CreateCanvasFolder ¶ added in v0.20.0

func CreateCanvasFolder(organizationID uuid.UUID, title, backgroundColor string) (*CanvasFolder, error)

func CreateCanvasFolderInTransaction ¶ added in v0.20.0

func CreateCanvasFolderInTransaction(tx *gorm.DB, organizationID uuid.UUID, title, backgroundColor string) (*CanvasFolder, error)

func FindCanvasFolder ¶ added in v0.20.0

func FindCanvasFolder(organizationID, id uuid.UUID) (*CanvasFolder, error)

func FindCanvasFolderInTransaction ¶ added in v0.20.0

func FindCanvasFolderInTransaction(tx *gorm.DB, organizationID, id uuid.UUID) (*CanvasFolder, error)

func ListCanvasFolders ¶ added in v0.20.0

func ListCanvasFolders(organizationID uuid.UUID) ([]CanvasFolder, error)

func ListCanvasFoldersInTransaction ¶ added in v0.20.0

func ListCanvasFoldersInTransaction(tx *gorm.DB, organizationID uuid.UUID) ([]CanvasFolder, error)

func MoveCanvasFolder ¶ added in v0.20.0

func MoveCanvasFolder(organizationID, id uuid.UUID, direction string) ([]CanvasFolder, error)

func MoveCanvasFolderInTransaction ¶ added in v0.20.0

func MoveCanvasFolderInTransaction(tx *gorm.DB, organizationID, id uuid.UUID, direction string) ([]CanvasFolder, error)

func UpdateCanvasFolder ¶ added in v0.20.0

func UpdateCanvasFolder(organizationID, id uuid.UUID, title, backgroundColor string) (*CanvasFolder, error)

func UpdateCanvasFolderInTransaction ¶ added in v0.20.0

func UpdateCanvasFolderInTransaction(tx *gorm.DB, organizationID, id uuid.UUID, title, backgroundColor string) (*CanvasFolder, error)

func (*CanvasFolder) TableName ¶ added in v0.20.0

func (f *CanvasFolder) TableName() string

type CanvasMemory ¶ added in v0.10.0

type CanvasMemory struct {
	ID        uuid.UUID `gorm:"type:uuid;primary_key;default:gen_random_uuid()"`
	CreatedAt time.Time
	UpdatedAt time.Time
	CanvasID  uuid.UUID
	Namespace string
	Values    datatypes.JSONType[any]
	Source    string
}

func AddCanvasMemoryRecordInTransaction ¶ added in v0.23.0

func AddCanvasMemoryRecordInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, values any) (CanvasMemory, error)

func AddCanvasMemoryRecordWithSourceInTransaction ¶ added in v0.25.0

func AddCanvasMemoryRecordWithSourceInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, values any, source string) (CanvasMemory, error)

func DeleteCanvasMemoriesByNamespaceAndMatches ¶ added in v0.10.0

func DeleteCanvasMemoriesByNamespaceAndMatches(canvasID uuid.UUID, namespace string, matches map[string]any) ([]CanvasMemory, error)

func DeleteCanvasMemoriesByNamespaceAndMatchesInTransaction ¶ added in v0.10.0

func DeleteCanvasMemoriesByNamespaceAndMatchesInTransaction(
	tx *gorm.DB,
	canvasID uuid.UUID,
	namespace string,
	matches map[string]any,
) ([]CanvasMemory, error)

func FindFirstCanvasMemoryByNamespaceAndMatches ¶ added in v0.10.0

func FindFirstCanvasMemoryByNamespaceAndMatches(canvasID uuid.UUID, namespace string, matches map[string]any) (*CanvasMemory, error)

func FindFirstCanvasMemoryByNamespaceAndMatchesInTransaction ¶ added in v0.10.0

func FindFirstCanvasMemoryByNamespaceAndMatchesInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, matches map[string]any) (*CanvasMemory, error)

func ListCanvasMemories ¶ added in v0.10.0

func ListCanvasMemories(canvasID uuid.UUID) ([]CanvasMemory, error)

func ListCanvasMemoriesByNamespace ¶ added in v0.10.0

func ListCanvasMemoriesByNamespace(canvasID uuid.UUID, namespace string) ([]CanvasMemory, error)

func ListCanvasMemoriesByNamespaceAndMatches ¶ added in v0.10.0

func ListCanvasMemoriesByNamespaceAndMatches(canvasID uuid.UUID, namespace string, matches map[string]any) ([]CanvasMemory, error)

func ListCanvasMemoriesByNamespaceAndMatchesInTransaction ¶ added in v0.10.0

func ListCanvasMemoriesByNamespaceAndMatchesInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string, matches map[string]any) ([]CanvasMemory, error)

func ListCanvasMemoriesByNamespaceInTransaction ¶ added in v0.10.0

func ListCanvasMemoriesByNamespaceInTransaction(tx *gorm.DB, canvasID uuid.UUID, namespace string) ([]CanvasMemory, error)

func ListCanvasMemoriesInTransaction ¶ added in v0.10.0

func ListCanvasMemoriesInTransaction(tx *gorm.DB, canvasID uuid.UUID) ([]CanvasMemory, error)

func UpdateCanvasMemoriesByNamespace ¶ added in v0.23.0

func UpdateCanvasMemoriesByNamespace(canvasID uuid.UUID, namespace string, values map[string]any) ([]CanvasMemory, error)

func UpdateCanvasMemoriesByNamespaceAndMatches ¶ added in v0.10.0

func UpdateCanvasMemoriesByNamespaceAndMatches(canvasID uuid.UUID, namespace string, matches map[string]any, values map[string]any) ([]CanvasMemory, error)

func UpdateCanvasMemoriesByNamespaceAndMatchesInTransaction ¶ added in v0.10.0

func UpdateCanvasMemoriesByNamespaceAndMatchesInTransaction(
	tx *gorm.DB,
	canvasID uuid.UUID,
	namespace string,
	matches map[string]any,
	values map[string]any,
) ([]CanvasMemory, error)

func UpdateCanvasMemoriesByNamespaceInTransaction ¶ added in v0.23.0

func UpdateCanvasMemoriesByNamespaceInTransaction(
	tx *gorm.DB,
	canvasID uuid.UUID,
	namespace string,
	values map[string]any,
) ([]CanvasMemory, error)

func (CanvasMemory) TableName ¶ added in v0.10.0

func (CanvasMemory) TableName() string

type CanvasNode ¶ added in v0.6.0

type CanvasNode struct {
	WorkflowID        uuid.UUID `gorm:"primaryKey"`
	NodeID            string    `gorm:"primaryKey"`
	Name              string
	State             string
	StateReason       *string
	Type              string
	Position          datatypes.JSONType[Position]
	Ref               datatypes.JSONType[NodeRef]
	Configuration     datatypes.JSONType[map[string]any]
	Metadata          datatypes.JSONType[map[string]any]
	IsCollapsed       bool
	WebhookID         *uuid.UUID
	AppInstallationID *uuid.UUID
	CreatedAt         *time.Time
	UpdatedAt         *time.Time
	DeletedAt         gorm.DeletedAt `gorm:"index"`
}

func FindActiveWebhookNodes ¶ added in v0.20.0

func FindActiveWebhookNodes(webhookID uuid.UUID) ([]CanvasNode, error)

func FindActiveWebhookNodesInTransaction ¶ added in v0.20.0

func FindActiveWebhookNodesInTransaction(tx *gorm.DB, webhookID uuid.UUID) ([]CanvasNode, error)

func FindCanvasNode ¶ added in v0.6.0

func FindCanvasNode(tx *gorm.DB, canvasID uuid.UUID, nodeID string) (*CanvasNode, error)

func FindCanvasNodes ¶ added in v0.6.0

func FindCanvasNodes(canvasID uuid.UUID) ([]CanvasNode, error)

func FindCanvasNodesByIDs ¶ added in v0.6.0

func FindCanvasNodesByIDs(tx *gorm.DB, canvasID uuid.UUID, nodeIDs []string) ([]CanvasNode, error)

func FindCanvasNodesInTransaction ¶ added in v0.6.0

func FindCanvasNodesInTransaction(tx *gorm.DB, workflowID uuid.UUID) ([]CanvasNode, error)

func FindCanvasNodesUnscoped ¶ added in v0.6.0

func FindCanvasNodesUnscoped(workflowID uuid.UUID) ([]CanvasNode, error)

func FindCanvasNodesUnscopedInTransaction ¶ added in v0.6.0

func FindCanvasNodesUnscopedInTransaction(tx *gorm.DB, workflowID uuid.UUID) ([]CanvasNode, error)

func FindUnscopedCanvasNode ¶ added in v0.27.0

func FindUnscopedCanvasNode(tx *gorm.DB, canvasID uuid.UUID, nodeID string) (*CanvasNode, error)

func FindWebhookNodes ¶

func FindWebhookNodes(webhookID uuid.UUID) ([]CanvasNode, error)

func FindWebhookNodesInTransaction ¶

func FindWebhookNodesInTransaction(tx *gorm.DB, webhookID uuid.UUID) ([]CanvasNode, error)

func ListCanvasNodesReady ¶ added in v0.6.0

func ListCanvasNodesReady() ([]CanvasNode, error)

func ListReadyTriggers ¶

func ListReadyTriggers() ([]CanvasNode, error)

func LockCanvasNode ¶ added in v0.6.0

func LockCanvasNode(tx *gorm.DB, workflowID uuid.UUID, nodeId string) (*CanvasNode, error)

func LockCanvasNodeForUpdate ¶ added in v0.6.0

func LockCanvasNodeForUpdate(tx *gorm.DB, workflowID uuid.UUID, nodeId string) (*CanvasNode, error)

func (*CanvasNode) ComponentName ¶ added in v0.26.0

func (c *CanvasNode) ComponentName() string

func (*CanvasNode) CreateRequest ¶ added in v0.6.0

func (c *CanvasNode) CreateRequest(tx *gorm.DB, reqType string, spec NodeExecutionRequestSpec, runAt *time.Time) error

func (*CanvasNode) FirstQueueItem ¶ added in v0.6.0

func (c *CanvasNode) FirstQueueItem(tx *gorm.DB) (*CanvasNodeQueueItem, error)

func (*CanvasNode) TableName ¶ added in v0.6.0

func (c *CanvasNode) TableName() string

func (*CanvasNode) UpdateState ¶ added in v0.6.0

func (c *CanvasNode) UpdateState(tx *gorm.DB, state string) error

type CanvasNodeExecution ¶ added in v0.6.0

type CanvasNodeExecution struct {
	ID         uuid.UUID `gorm:"primaryKey;default:uuid_generate_v4()"`
	WorkflowID uuid.UUID
	NodeID     string
	CreatedAt  *time.Time
	UpdatedAt  *time.Time

	//
	// Reference to the root WorkflowEvent record that started
	// this whole execution chain.
	//
	// This gives us an easy way to find all the executions
	// for that event with a simple query.
	//
	RootEventID uuid.UUID
	RunID       uuid.UUID

	//
	// Reference to the previous execution.
	// This is what allows us to build execution chains,
	// from any execution.
	//
	PreviousExecutionID *uuid.UUID

	//
	// The reference to a WorkflowEvent record,
	// which holds the input for this execution.
	//
	EventID uuid.UUID

	//
	// State management fields.
	//
	State         string
	Result        string
	ResultReason  string
	ResultMessage string
	CancelledBy   *uuid.UUID

	//
	// Components can store metadata about each execution here.
	// This allows them to control the behavior of each execution.
	//
	Metadata datatypes.JSONType[map[string]any]

	//
	// The configuration is copied from the node.
	// This enables us to allow node configuration updates
	// while executions are running.
	// Only new executions will use the new node configuration.
	//
	Configuration datatypes.JSONType[map[string]any]
}

func FindLastExecutionPerNode ¶

func FindLastExecutionPerNode(tx *gorm.DB, workflowID uuid.UUID) ([]CanvasNodeExecution, error)

FindLastExecutionPerNode finds the most recent execution for each node in a workflow. Only returns executions for nodes that have not been deleted.

func FindNodeExecution ¶

func FindNodeExecution(workflowID, id uuid.UUID) (*CanvasNodeExecution, error)

func FindNodeExecutionInTransaction ¶

func FindNodeExecutionInTransaction(tx *gorm.DB, workflowID, id uuid.UUID) (*CanvasNodeExecution, error)

func FindNodeExecutionWithNodeID ¶

func FindNodeExecutionWithNodeID(workflowID, id uuid.UUID, nodeID string) (*CanvasNodeExecution, error)

func FindNodeExecutionWithNodeIDInTransaction ¶

func FindNodeExecutionWithNodeIDInTransaction(tx *gorm.DB, workflowID, id uuid.UUID, nodeID string) (*CanvasNodeExecution, error)

func FindNodeExecutionsByIDs ¶ added in v0.1.5

func FindNodeExecutionsByIDs(workflowID uuid.UUID, executionIDs []uuid.UUID) ([]CanvasNodeExecution, error)

func FindNodeExecutionsByIDsInTransaction ¶ added in v0.1.5

func FindNodeExecutionsByIDsInTransaction(tx *gorm.DB, workflowID uuid.UUID, executionIDs []uuid.UUID) ([]CanvasNodeExecution, error)

func FirstNodeExecutionByKVInTransaction ¶

func FirstNodeExecutionByKVInTransaction(tx *gorm.DB, workflowID uuid.UUID, nodeID, key, value string) (*CanvasNodeExecution, error)

func ListAllExecutionsForRootEvent ¶ added in v0.15.0

func ListAllExecutionsForRootEvent(rootEventID uuid.UUID) ([]CanvasNodeExecution, error)

func ListAllExecutionsForRootEventInTransaction ¶ added in v0.15.0

func ListAllExecutionsForRootEventInTransaction(tx *gorm.DB, rootEventID uuid.UUID) ([]CanvasNodeExecution, error)

func ListExecutionsForRunsInTransaction ¶ added in v0.26.0

func ListExecutionsForRunsInTransaction(tx *gorm.DB, workflowID uuid.UUID, runIDs []uuid.UUID) ([]CanvasNodeExecution, error)

func ListNodeExecutions ¶

func ListNodeExecutions(workflowID uuid.UUID, nodeID string, states []string, results []string, limit int, beforeTime *time.Time) ([]CanvasNodeExecution, error)

func ListParentExecutionsForRootEvents ¶ added in v0.15.0

func ListParentExecutionsForRootEvents(canvasID uuid.UUID, rootEventIDs []uuid.UUID) ([]CanvasNodeExecution, error)

func ListParentExecutionsForRootEventsInTransaction ¶ added in v0.15.0

func ListParentExecutionsForRootEventsInTransaction(tx *gorm.DB, canvasID uuid.UUID, rootEventIDs []uuid.UUID) ([]CanvasNodeExecution, error)

func ListPendingNodeExecutions ¶

func ListPendingNodeExecutions() ([]CanvasNodeExecution, error)

func LockPendingNodeExecutionInActiveCanvas ¶ added in v0.20.0

func LockPendingNodeExecutionInActiveCanvas(tx *gorm.DB, id uuid.UUID) (*CanvasNodeExecution, error)

func (*CanvasNodeExecution) BeforeCreate ¶ added in v0.21.0

func (e *CanvasNodeExecution) BeforeCreate(tx *gorm.DB) error

func (*CanvasNodeExecution) Cancel ¶ added in v0.6.0

func (e *CanvasNodeExecution) Cancel(cancelledBy *uuid.UUID) error

func (*CanvasNodeExecution) CancelInTransaction ¶ added in v0.6.0

func (e *CanvasNodeExecution) CancelInTransaction(tx *gorm.DB, cancelledBy *uuid.UUID) error

func (*CanvasNodeExecution) CreateRequest ¶ added in v0.6.0

func (e *CanvasNodeExecution) CreateRequest(tx *gorm.DB, reqType string, spec NodeExecutionRequestSpec, runAt *time.Time) error

func (*CanvasNodeExecution) EmitOutputsInTransaction ¶ added in v0.26.0

func (e *CanvasNodeExecution) EmitOutputsInTransaction(tx *gorm.DB, channelOutputs map[string][]any) ([]CanvasEvent, error)

func (*CanvasNodeExecution) Fail ¶ added in v0.6.0

func (e *CanvasNodeExecution) Fail(reason, message string) error

func (*CanvasNodeExecution) FailInTransaction ¶ added in v0.6.0

func (e *CanvasNodeExecution) FailInTransaction(tx *gorm.DB, reason, message string) error

func (*CanvasNodeExecution) GetInput ¶ added in v0.6.0

func (e *CanvasNodeExecution) GetInput(tx *gorm.DB) (any, error)

func (*CanvasNodeExecution) GetOutputs ¶ added in v0.6.0

func (e *CanvasNodeExecution) GetOutputs() ([]CanvasEvent, error)

func (*CanvasNodeExecution) GetOutputsInTransaction ¶ added in v0.6.0

func (e *CanvasNodeExecution) GetOutputsInTransaction(tx *gorm.DB) ([]CanvasEvent, error)

func (*CanvasNodeExecution) GetPreviousExecutionID ¶ added in v0.6.0

func (e *CanvasNodeExecution) GetPreviousExecutionID() string

func (*CanvasNodeExecution) Pass ¶ added in v0.6.0

func (e *CanvasNodeExecution) Pass(outputs map[string][]any) ([]CanvasEvent, error)

func (*CanvasNodeExecution) PassInTransaction ¶ added in v0.6.0

func (e *CanvasNodeExecution) PassInTransaction(tx *gorm.DB, channelOutputs map[string][]any) ([]CanvasEvent, error)

func (*CanvasNodeExecution) Start ¶ added in v0.6.0

func (e *CanvasNodeExecution) Start() error

func (*CanvasNodeExecution) StartInTransaction ¶ added in v0.6.0

func (e *CanvasNodeExecution) StartInTransaction(tx *gorm.DB) error

func (*CanvasNodeExecution) TableName ¶ added in v0.6.0

func (e *CanvasNodeExecution) TableName() string

type CanvasNodeExecutionKV ¶ added in v0.6.0

type CanvasNodeExecutionKV struct {
	ID          uuid.UUID `gorm:"type:uuid;primaryKey;default:gen_random_uuid()"`
	WorkflowID  uuid.UUID `gorm:"type:uuid;not null"`
	NodeID      string    `gorm:"type:varchar(128);not null"`
	ExecutionID uuid.UUID `gorm:"type:uuid;not null"`
	Key         string    `gorm:"type:text;not null"`
	Value       string    `gorm:"type:text;not null"`
	CreatedAt   *time.Time
}

func (*CanvasNodeExecutionKV) TableName ¶ added in v0.6.0

func (c *CanvasNodeExecutionKV) TableName() string

type CanvasNodeQueueItem ¶ added in v0.6.0

type CanvasNodeQueueItem struct {
	ID         uuid.UUID `gorm:"primaryKey;default:uuid_generate_v4()"`
	WorkflowID uuid.UUID
	NodeID     string
	CreatedAt  *time.Time

	//
	// Reference to the root WorkflowEvent record that started
	// this whole execution chain.
	//
	// This gives us an easy way to find all the queue items
	// for that event with a simple query.
	//
	RootEventID uuid.UUID
	RootEvent   *CanvasEvent `gorm:"foreignKey:RootEventID"`
	RunID       uuid.UUID

	//
	// The reference to a CanvasEvent record,
	// which holds the input for this queue item.
	//
	EventID uuid.UUID
}

func FindNodeQueueItem ¶

func FindNodeQueueItem(workflowID uuid.UUID, queueItemID uuid.UUID) (*CanvasNodeQueueItem, error)

func ListNodeQueueItems ¶

func ListNodeQueueItems(workflowID uuid.UUID, nodeID string, limit int, beforeTime *time.Time) ([]CanvasNodeQueueItem, error)

func (*CanvasNodeQueueItem) BeforeCreate ¶ added in v0.21.0

func (i *CanvasNodeQueueItem) BeforeCreate(tx *gorm.DB) error

func (*CanvasNodeQueueItem) Delete ¶ added in v0.6.0

func (i *CanvasNodeQueueItem) Delete(tx *gorm.DB) error

func (*CanvasNodeQueueItem) TableName ¶ added in v0.6.0

func (i *CanvasNodeQueueItem) TableName() string

type CanvasNodeReference ¶ added in v0.7.0

type CanvasNodeReference struct {
	CanvasID   uuid.UUID
	CanvasName string
	NodeID     string
	NodeName   string
	NodeType   string
	NodeRef    datatypes.JSONType[NodeRef]
}

func ListIntegrationNodeReferences ¶ added in v0.6.0

func ListIntegrationNodeReferences(integrationID uuid.UUID) ([]CanvasNodeReference, error)

func (*CanvasNodeReference) ComponentName ¶ added in v0.20.0

func (c *CanvasNodeReference) ComponentName() string

type CanvasNodeRequest ¶ added in v0.6.0

type CanvasNodeRequest struct {
	ID          uuid.UUID
	WorkflowID  uuid.UUID
	NodeID      string
	ExecutionID *uuid.UUID
	State       string
	Type        string
	Spec        datatypes.JSONType[NodeExecutionRequestSpec]
	RunAt       time.Time
	CreatedAt   time.Time
	UpdatedAt   time.Time
}

func FindPendingRequestForNode ¶

func FindPendingRequestForNode(tx *gorm.DB, workflowID uuid.UUID, nodeID string) (*CanvasNodeRequest, error)

func ListNodeRequests ¶

func ListNodeRequests() ([]CanvasNodeRequest, error)

func LockNodeRequest ¶

func LockNodeRequest(tx *gorm.DB, id uuid.UUID) (*CanvasNodeRequest, error)

func (*CanvasNodeRequest) Complete ¶ added in v0.6.0

func (r *CanvasNodeRequest) Complete(tx *gorm.DB) error

func (*CanvasNodeRequest) TableName ¶ added in v0.6.0

func (r *CanvasNodeRequest) TableName() string

type CanvasRun ¶ added in v0.21.0

type CanvasRun struct {
	ID         uuid.UUID `gorm:"primaryKey;default:uuid_generate_v4()"`
	WorkflowID uuid.UUID
	VersionID  uuid.UUID
	State      string
	Result     string
	CreatedAt  *time.Time
	UpdatedAt  *time.Time
	FinishedAt *time.Time
}

func CreateCanvasRunInTransaction ¶ added in v0.21.0

func CreateCanvasRunInTransaction(tx *gorm.DB, workflowID uuid.UUID, state, result string) (*CanvasRun, error)

func FindCanvasRunByRootEventInTransaction ¶ added in v0.21.0

func FindCanvasRunByRootEventInTransaction(tx *gorm.DB, rootEventID uuid.UUID) (*CanvasRun, error)

func FindCanvasRunInTransaction ¶ added in v0.21.0

func FindCanvasRunInTransaction(tx *gorm.DB, workflowID, runID uuid.UUID) (*CanvasRun, error)

func FindOrCreateCanvasRunForRootEventInTransaction ¶ added in v0.21.0

func FindOrCreateCanvasRunForRootEventInTransaction(tx *gorm.DB, rootEvent *CanvasEvent) (*CanvasRun, error)

func ListCanvasRuns ¶ added in v0.21.0

func ListCanvasRuns(workflowID uuid.UUID, limit int, beforeTime *time.Time, filters CanvasRunFilters) ([]CanvasRun, error)

func ListCanvasRunsInTransaction ¶ added in v0.26.0

func ListCanvasRunsInTransaction(tx *gorm.DB, workflowID uuid.UUID, limit int, beforeTime *time.Time, filters CanvasRunFilters) ([]CanvasRun, error)

func ListStartedCanvasRuns ¶ added in v0.26.0

func ListStartedCanvasRuns(limit int) ([]CanvasRun, error)

func ListStartedCanvasRunsInTransaction ¶ added in v0.26.0

func ListStartedCanvasRunsInTransaction(tx *gorm.DB, limit int) ([]CanvasRun, error)

func LockCanvasRunInTransaction ¶ added in v0.26.0

func LockCanvasRunInTransaction(tx *gorm.DB, runID uuid.UUID) (*CanvasRun, error)

func (*CanvasRun) TableName ¶ added in v0.21.0

func (r *CanvasRun) TableName() string

type CanvasRunFilters ¶ added in v0.21.0

type CanvasRunFilters struct {
	States  []string
	Results []string
}

type CanvasVersion ¶ added in v0.11.0

type CanvasVersion struct {
	ID            uuid.UUID
	WorkflowID    uuid.UUID
	OwnerID       *uuid.UUID
	CommitMessage string
	Nodes         datatypes.JSONSlice[Node]
	Edges         datatypes.JSONSlice[Edge]
	ConsolePanels datatypes.JSONType[[]ConsolePanel]
	ConsoleLayout datatypes.JSONType[[]ConsoleLayoutItem]
	CommitSHA     string
	CreatedAt     *time.Time
	UpdatedAt     *time.Time
}

func CreateCommitVersionWithSpecInTransaction ¶ added in v0.28.0

func CreateCommitVersionWithSpecInTransaction(
	tx *gorm.DB,
	canvasID uuid.UUID,
	userID uuid.UUID,
	commitMessage string,
	nodes []Node,
	edges []Edge,
) (*CanvasVersion, error)

func FindCanvasVersion ¶ added in v0.11.0

func FindCanvasVersion(workflowID, versionID uuid.UUID) (*CanvasVersion, error)

func FindCanvasVersionForUpdateInTransaction ¶ added in v0.17.0

func FindCanvasVersionForUpdateInTransaction(tx *gorm.DB, workflowID, versionID uuid.UUID) (*CanvasVersion, error)

func FindCanvasVersionInTransaction ¶ added in v0.11.0

func FindCanvasVersionInTransaction(tx *gorm.DB, workflowID, versionID uuid.UUID) (*CanvasVersion, error)

func FindLatestCanvasVersion ¶ added in v0.28.0

func FindLatestCanvasVersion(workflowID uuid.UUID) (*CanvasVersion, error)

func FindLatestCanvasVersionInTransaction ¶ added in v0.28.0

func FindLatestCanvasVersionInTransaction(tx *gorm.DB, workflowID uuid.UUID) (*CanvasVersion, error)

func FindLiveCanvasVersion ¶ added in v0.26.0

func FindLiveCanvasVersion(workflowID uuid.UUID) (*CanvasVersion, error)

func FindLiveCanvasVersionByCanvasInTransaction ¶ added in v0.11.0

func FindLiveCanvasVersionByCanvasInTransaction(tx *gorm.DB, canvas *Canvas) (*CanvasVersion, error)

func FindLiveCanvasVersionInTransaction ¶ added in v0.11.0

func FindLiveCanvasVersionInTransaction(tx *gorm.DB, workflowID uuid.UUID) (*CanvasVersion, error)

func FindVersionByCommitSHA ¶ added in v0.26.0

func FindVersionByCommitSHA(workflowID uuid.UUID, commitSHA string) (*CanvasVersion, error)

func FindVersionByCommitSHAInTransaction ¶ added in v0.26.0

func FindVersionByCommitSHAInTransaction(tx *gorm.DB, workflowID uuid.UUID, commitSHA string) (*CanvasVersion, error)

func ListCanvasVersionHistoryInTransaction ¶ added in v0.28.0

func ListCanvasVersionHistoryInTransaction(
	tx *gorm.DB,
	workflowID uuid.UUID,
	limit int,
	before *time.Time,
) ([]CanvasVersion, error)

func ListCanvasVersions ¶ added in v0.11.0

func ListCanvasVersions(workflowID uuid.UUID) ([]CanvasVersion, error)

func ListCanvasVersionsInTransaction ¶ added in v0.11.0

func ListCanvasVersionsInTransaction(tx *gorm.DB, workflowID uuid.UUID) ([]CanvasVersion, error)

func UpdateCanvasVersionConsoleInTransaction ¶ added in v0.25.0

func UpdateCanvasVersionConsoleInTransaction(
	tx *gorm.DB,
	version *CanvasVersion,
	panels []ConsolePanel,
	layout []ConsoleLayoutItem,
) (*CanvasVersion, error)

func UpsertCanvasVersionConsole ¶ added in v0.25.0

func UpsertCanvasVersionConsole(canvasID uuid.UUID, panels []ConsolePanel, layout []ConsoleLayoutItem) (*CanvasVersion, error)

func UpsertCanvasVersionConsoleInTransaction ¶ added in v0.25.0

func UpsertCanvasVersionConsoleInTransaction(
	tx *gorm.DB,
	canvasID uuid.UUID,
	panels []ConsolePanel,
	layout []ConsoleLayoutItem,
) (*CanvasVersion, error)

func (*CanvasVersion) TableName ¶ added in v0.11.0

func (c *CanvasVersion) TableName() string

type CapabilityState ¶ added in v0.19.0

type CapabilityState struct {
	Name   string                          `json:"name"`
	State  core.IntegrationCapabilityState `json:"state"`
	Reason *string                         `json:"reason,omitempty"`
}

type ComponentRef ¶

type ComponentRef struct {
	Name string `json:"name"`
}

type ConsoleLayoutItem ¶ added in v0.25.0

type ConsoleLayoutItem struct {
	I    string `json:"i"`
	X    int    `json:"x"`
	Y    int    `json:"y"`
	W    int    `json:"w"`
	H    int    `json:"h"`
	MinW *int   `json:"minW,omitempty"`
	MinH *int   `json:"minH,omitempty"`
}

type ConsolePanel ¶ added in v0.25.0

type ConsolePanel struct {
	ID      string         `json:"id"`
	Type    string         `json:"type"`
	Content map[string]any `json:"content"`
}

type ConsoleYAML ¶ added in v0.25.0

type ConsoleYAML struct {
	APIVersion string              `json:"apiVersion" yaml:"apiVersion"`
	Kind       string              `json:"kind" yaml:"kind"`
	Metadata   ConsoleYAMLMetadata `json:"metadata" yaml:"metadata"`
	Spec       ConsoleYAMLSpec     `json:"spec" yaml:"spec"`
}

ConsoleYAML is the canonical YAML representation of a console.

Import is replace-all: it overwrites every panel and layout entry for the console. Export is deterministic: identical consoles produce identical YAML bytes regardless of how the underlying maps were ordered in memory.

func ConsoleFromYML ¶ added in v0.25.0

func ConsoleFromYML(raw []byte) (*ConsoleYAML, error)

ConsoleFromYML parses raw YAML bytes into a validated ConsoleYAML. The parser is strict: unknown top-level fields are rejected, panel content must be an object, and the configured limits apply.

func (*ConsoleYAML) Validate ¶ added in v0.25.0

func (d *ConsoleYAML) Validate() error

Validate enforces the structural and size invariants of a dashboard import.

type ConsoleYAMLMetadata ¶ added in v0.25.0

type ConsoleYAMLMetadata struct {
	CanvasID string `json:"canvasId,omitempty" yaml:"canvasId,omitempty"`
	Name     string `json:"name,omitempty" yaml:"name,omitempty"`
}

ConsoleYAMLMetadata is informational only. `canvasId` is ignored on import; `name` is used solely for display/filename purposes.

type ConsoleYAMLSpec ¶ added in v0.25.0

type ConsoleYAMLSpec struct {
	Panels []ConsolePanel      `json:"panels" yaml:"panels"`
	Layout []ConsoleLayoutItem `json:"layout" yaml:"layout"`
}

DashboardYAMLSpec carries the persisted dashboard shape (panels + layout) while keeping a stable, deterministic field ordering on export.

type Edge ¶

type Edge struct {
	SourceID string `json:"source_id"`
	TargetID string `json:"target_id"`
	Channel  string `json:"channel"`
}

type EmailSettings ¶ added in v0.0.43

type EmailSettings struct {
	ID            uuid.UUID `gorm:"type:uuid;primary_key;default:uuid_generate_v4()"`
	Provider      string    `gorm:"type:varchar(50);uniqueIndex"`
	SMTPHost      string
	SMTPPort      int
	SMTPUsername  string
	SMTPPassword  []byte
	SMTPFromName  string
	SMTPFromEmail string
	SMTPUseTLS    bool
	CreatedAt     time.Time
	UpdatedAt     time.Time
}

func FindEmailSettings ¶ added in v0.0.43

func FindEmailSettings(provider string) (*EmailSettings, error)

func FindEmailSettingsInTransaction ¶ added in v0.0.43

func FindEmailSettingsInTransaction(tx *gorm.DB, provider string) (*EmailSettings, error)

type GroupMetadata ¶

type GroupMetadata struct {
	ID          uuid.UUID `json:"id" gorm:"type:uuid;primary_key;default:gen_random_uuid()"`
	GroupName   string    `json:"group_name" gorm:"not null;index"`
	DomainType  string    `json:"domain_type" gorm:"not null;index"`
	DomainID    string    `json:"domain_id" gorm:"not null;index"`
	DisplayName string    `json:"display_name" gorm:"not null"`
	Description string    `json:"description"`
	CreatedAt   time.Time `json:"created_at"`
	UpdatedAt   time.Time `json:"updated_at"`
}

func FindGroupMetadata ¶

func FindGroupMetadata(groupName, domainType, domainID string) (*GroupMetadata, error)

func (*GroupMetadata) BeforeCreate ¶

func (gm *GroupMetadata) BeforeCreate(tx *gorm.DB) error

func (*GroupMetadata) Create ¶

func (gm *GroupMetadata) Create() error

func (*GroupMetadata) CreateInTransaction ¶

func (gm *GroupMetadata) CreateInTransaction(tx *gorm.DB) error

func (*GroupMetadata) Update ¶

func (gm *GroupMetadata) Update() error

func (*GroupMetadata) UpdateInTransaction ¶

func (gm *GroupMetadata) UpdateInTransaction(tx *gorm.DB) error

type InstallationMetadata ¶ added in v0.1.0

type InstallationMetadata struct {
	ID                        int    `gorm:"primary_key"`
	InstallationID            string `gorm:"type:varchar(64)"`
	AllowPrivateNetworkAccess bool
	SignupsEnabled            bool
	CreatedAt                 time.Time
	UpdatedAt                 time.Time
}

func GetInstallationMetadata ¶ added in v0.15.0

func GetInstallationMetadata(tx *gorm.DB) (*InstallationMetadata, error)

type Integration ¶

type Integration struct {
	ID               uuid.UUID `gorm:"primary_key;default:uuid_generate_v4()"`
	OrganizationID   uuid.UUID
	AppName          string
	InstallationName string
	State            string
	StateDescription string
	CreatedAt        *time.Time
	UpdatedAt        *time.Time
	DeletedAt        gorm.DeletedAt `gorm:"index"`

	//
	// These are fields used by the old integrations.
	// Should be removed once all integration implementations
	// are migrated to use core.IntegrationSetupProvider
	//
	Configuration datatypes.JSONType[map[string]any]
	Metadata      datatypes.JSONType[map[string]any]
	BrowserAction *datatypes.JSONType[BrowserAction]

	//
	// Fields required for integrations set up using core.IntegrationSetupProvider
	// All integrations should use this
	//
	SetupState   *datatypes.JSONType[SetupState]
	Properties   datatypes.JSONSlice[core.IntegrationPropertyDefinition]
	Capabilities datatypes.JSONSlice[CapabilityState]
}

func CreateIntegration ¶

func CreateIntegration(id, orgID uuid.UUID, appName string, installationName string, config map[string]any) (*Integration, error)

func FindIntegration ¶ added in v0.6.0

func FindIntegration(orgID, integrationID uuid.UUID) (*Integration, error)

func FindIntegrationByName ¶

func FindIntegrationByName(orgID uuid.UUID, integrationName string) (*Integration, error)

func FindIntegrationInTransaction ¶ added in v0.17.0

func FindIntegrationInTransaction(tx *gorm.DB, orgID, integrationID uuid.UUID) (*Integration, error)

func FindMaybeDeletedIntegrationInTransaction ¶ added in v0.6.0

func FindMaybeDeletedIntegrationInTransaction(tx *gorm.DB, integrationID uuid.UUID) (*Integration, error)

func FindUnscopedIntegration ¶ added in v0.6.0

func FindUnscopedIntegration(integrationID uuid.UUID) (*Integration, error)

func FindUnscopedIntegrationInTransaction ¶ added in v0.6.0

func FindUnscopedIntegrationInTransaction(tx *gorm.DB, integrationID uuid.UUID) (*Integration, error)

func ListDeletedIntegrations ¶ added in v0.6.0

func ListDeletedIntegrations() ([]Integration, error)

func ListIntegrations ¶

func ListIntegrations(db *gorm.DB, orgID uuid.UUID) ([]Integration, error)

func ListMaybeDeletedIntegrationsByOrganizationInTransaction ¶ added in v0.13.0

func ListMaybeDeletedIntegrationsByOrganizationInTransaction(tx *gorm.DB, orgID uuid.UUID) ([]Integration, error)

func LockIntegration ¶ added in v0.6.0

func LockIntegration(tx *gorm.DB, ID uuid.UUID) (*Integration, error)

func (*Integration) CreateActionRequest ¶ added in v0.6.0

func (a *Integration) CreateActionRequest(tx *gorm.DB, actionName string, parameters any, runAt *time.Time) error

func (*Integration) CreateSyncRequest ¶ added in v0.6.0

func (a *Integration) CreateSyncRequest(tx *gorm.DB, runAt *time.Time) error

func (*Integration) GetRequest ¶ added in v0.6.0

func (a *Integration) GetRequest(ID string) (*IntegrationRequest, error)

func (*Integration) HasCapabilityEnabled ¶ added in v0.20.0

func (a *Integration) HasCapabilityEnabled(name string) bool

func (*Integration) IsLegacy ¶ added in v0.20.0

func (a *Integration) IsLegacy() bool

func (*Integration) ListRequests ¶ added in v0.6.0

func (a *Integration) ListRequests(reqType string) ([]IntegrationRequest, error)

func (*Integration) LockInTransaction ¶ added in v0.26.0

func (a *Integration) LockInTransaction(tx *gorm.DB) error

LockInTransaction takes a row-level FOR UPDATE lock on the installation, serializing concurrent request scheduling for it. ScheduleActionCall relies on this so its complete+create always observes successors created by other workers processing the same installation in parallel (#5386); without it, READ COMMITTED snapshots let each transaction insert a successor the others cannot see, leaving multiple chains that never drain.

func (*Integration) SoftDelete ¶ added in v0.6.0

func (a *Integration) SoftDelete() error

func (*Integration) SoftDeleteInTransaction ¶ added in v0.6.0

func (a *Integration) SoftDeleteInTransaction(tx *gorm.DB) error

func (*Integration) TableName ¶ added in v0.6.0

func (a *Integration) TableName() string

type IntegrationInvokeAction ¶ added in v0.6.0

type IntegrationInvokeAction struct {
	ActionName string `json:"action_name"`
	Parameters any    `json:"parameters"`
}

type IntegrationRequest ¶ added in v0.6.0

type IntegrationRequest struct {
	ID                uuid.UUID
	AppInstallationID uuid.UUID
	State             string
	Type              string
	Spec              datatypes.JSONType[IntegrationRequestSpec]
	RunAt             time.Time
	CreatedAt         time.Time
	UpdatedAt         time.Time
}

func FindPendingRequestForIntegration ¶ added in v0.6.0

func FindPendingRequestForIntegration(tx *gorm.DB, installationID uuid.UUID) (*IntegrationRequest, error)

func LeaseIntegrationRequest ¶ added in v0.26.0

func LeaseIntegrationRequest(tx *gorm.DB, id uuid.UUID, lease time.Duration) (*IntegrationRequest, error)

LeaseIntegrationRequest atomically leases a due pending request for processing. It locks the row with SKIP LOCKED, gated on the request being pending and due (run_at <= now), then pushes run_at past the work window. The poll loop only lists due pending requests, so the leased request drops out until either it is completed or the lease expires - at which point it becomes due again and is retried automatically, with no separate state or reset mechanism.

func ListIntegrationRequests ¶ added in v0.6.0

func ListIntegrationRequests() ([]IntegrationRequest, error)

func (*IntegrationRequest) Complete ¶ added in v0.6.0

func (r *IntegrationRequest) Complete(tx *gorm.DB) error

func (*IntegrationRequest) TableName ¶ added in v0.6.0

func (r *IntegrationRequest) TableName() string

type IntegrationRequestSpec ¶ added in v0.6.0

type IntegrationRequestSpec struct {
	InvokeAction *IntegrationInvokeAction `json:"invoke_action,omitempty"`
}

type IntegrationSecret ¶ added in v0.6.0

type IntegrationSecret struct {
	ID             uuid.UUID `gorm:"primary_key;default:uuid_generate_v4()"`
	OrganizationID uuid.UUID
	InstallationID uuid.UUID
	Name           string
	Label          string
	Description    string
	Value          []byte
	Editable       bool
	CreatedAt      *time.Time
	UpdatedAt      *time.Time
}

func ListIntegrationSecrets ¶ added in v0.19.0

func ListIntegrationSecrets(installationID uuid.UUID) ([]IntegrationSecret, error)

func ListIntegrationSecretsInTransaction ¶ added in v0.19.0

func ListIntegrationSecretsInTransaction(tx *gorm.DB, installationID uuid.UUID) ([]IntegrationSecret, error)

func (*IntegrationSecret) TableName ¶ added in v0.6.0

func (a *IntegrationSecret) TableName() string

type IntegrationSubscription ¶ added in v0.6.0

type IntegrationSubscription struct {
	ID             uuid.UUID `gorm:"primary_key;default:uuid_generate_v4()"`
	InstallationID uuid.UUID
	WorkflowID     uuid.UUID
	NodeID         string
	Configuration  datatypes.JSONType[any]
	CreatedAt      *time.Time
	UpdatedAt      *time.Time
}

func CreateIntegrationSubscription ¶ added in v0.6.0

func CreateIntegrationSubscription(node *CanvasNode, integration *Integration, configuration any) (*IntegrationSubscription, error)

func CreateIntegrationSubscriptionInTransaction ¶ added in v0.6.0

func CreateIntegrationSubscriptionInTransaction(tx *gorm.DB, node *CanvasNode, integration *Integration, configuration any) (*IntegrationSubscription, error)

func (*IntegrationSubscription) TableName ¶ added in v0.6.0

func (a *IntegrationSubscription) TableName() string

type InvokeAction ¶

type InvokeAction struct {
	ActionName string         `json:"action_name"`
	Parameters map[string]any `json:"parameters"`
}

type JSONValue ¶ added in v0.23.0

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

JSONValue stores arbitrary JSON while preserving JSON number tokens as json.Number when decoding (DB scan, API ingress, and in-memory UnmarshalJSON). Writes marshal the stored value as-is, so tokens survive round-trips once ingress avoids float64.

func NewJSONValue ¶ added in v0.23.0

func NewJSONValue(data any) JSONValue

func (JSONValue) Data ¶ added in v0.23.0

func (j JSONValue) Data() any

func (JSONValue) GormDBDataType ¶ added in v0.23.0

func (JSONValue) GormDBDataType(db *gorm.DB, _ *schema.Field) string

func (JSONValue) GormDataType ¶ added in v0.23.0

func (JSONValue) GormDataType() string

func (JSONValue) GormValue ¶ added in v0.23.0

func (j JSONValue) GormValue(_ context.Context, db *gorm.DB) clause.Expr

func (JSONValue) MarshalJSON ¶ added in v0.23.0

func (j JSONValue) MarshalJSON() ([]byte, error)

func (*JSONValue) Scan ¶ added in v0.23.0

func (j *JSONValue) Scan(value any) error

func (*JSONValue) UnmarshalJSON ¶ added in v0.23.0

func (j *JSONValue) UnmarshalJSON(data []byte) error

func (JSONValue) Value ¶ added in v0.23.0

func (j JSONValue) Value() (driver.Value, error)

type LiveCanvasSpec ¶ added in v0.28.0

type LiveCanvasSpec struct {
	Nodes []Node
	Edges []Edge
}

type Node ¶

type Node struct {
	ID             string         `json:"id"`
	Name           string         `json:"name"`
	Type           string         `json:"type"`
	Ref            NodeRef        `json:"ref"`
	Configuration  map[string]any `json:"configuration"`
	Metadata       map[string]any `json:"metadata"`
	Position       Position       `json:"position"`
	IsCollapsed    bool           `json:"isCollapsed"`
	IntegrationID  *string        `json:"integrationId,omitempty"`
	ErrorMessage   *string        `json:"errorMessage,omitempty"`
	WarningMessage *string        `json:"warningMessage,omitempty"`
}

type NodeExecutionRequestSpec ¶

type NodeExecutionRequestSpec struct {
	InvokeAction *InvokeAction `json:"invoke_action,omitempty"`
}

type NodeRef ¶

type NodeRef struct {
	Component *ComponentRef `json:"component,omitempty"`
	Trigger   *TriggerRef   `json:"trigger,omitempty"`
	Widget    *WidgetRef    `json:"widget,omitempty"`
}

type NodeSubscription ¶ added in v0.0.45

type NodeSubscription struct {
	WorkflowID    uuid.UUID
	NodeID        string
	NodeType      string
	NodeRef       datatypes.JSONType[NodeRef]
	Configuration datatypes.JSONType[any]
}

func ListIntegrationSubscriptions ¶ added in v0.6.0

func ListIntegrationSubscriptions(tx *gorm.DB, installationID uuid.UUID) ([]NodeSubscription, error)

type OpenCanvasRunWork ¶ added in v0.26.0

type OpenCanvasRunWork struct {
	HasActiveExecutions bool
	HasQueueItems       bool
	HasPendingEvents    bool
}

func FindOpenCanvasRunWorkInTransaction ¶ added in v0.26.0

func FindOpenCanvasRunWorkInTransaction(tx *gorm.DB, runID uuid.UUID) (*OpenCanvasRunWork, error)

type Organization ¶

type Organization struct {
	ID                          uuid.UUID `gorm:"primary_key;default:uuid_generate_v4()"`
	Name                        string    `gorm:"uniqueIndex"`
	Description                 string
	AllowedProviders            datatypes.JSONSlice[string]
	EnabledExperimentalFeatures datatypes.JSONSlice[string]
	UsageSyncedAt               *time.Time
	UsageRetentionWindowDays    *int32
	UsageLimitsSyncedAt         *time.Time
	CreatedAt                   *time.Time
	UpdatedAt                   *time.Time
	DeletedAt                   gorm.DeletedAt `gorm:"index"`
}

func CreateOrganization ¶

func CreateOrganization(name, description string) (*Organization, error)

func CreateOrganizationInTransaction ¶

func CreateOrganizationInTransaction(tx *gorm.DB, name, description string) (*Organization, error)

func FindOrganizationByID ¶

func FindOrganizationByID(id string) (*Organization, error)

func FindOrganizationByIDInTransaction ¶ added in v0.11.0

func FindOrganizationByIDInTransaction(tx *gorm.DB, id string) (*Organization, error)

func FindOrganizationByName ¶

func FindOrganizationByName(name string) (*Organization, error)

func FindOrganizationsForAccount ¶

func FindOrganizationsForAccount(email string) ([]Organization, error)

func ListDeletedOrganizations ¶ added in v0.13.0

func ListDeletedOrganizations() ([]Organization, error)

func ListDeletedOrganizationsInTransaction ¶ added in v0.13.0

func ListDeletedOrganizationsInTransaction(tx *gorm.DB) ([]Organization, error)

func ListOrganizationsByIDs ¶

func ListOrganizationsByIDs(ids []string) ([]Organization, error)

func ListOrganizationsPendingUsageLimitsRefresh ¶ added in v0.13.0

func ListOrganizationsPendingUsageLimitsRefresh(staleBefore time.Time, limit int) ([]Organization, error)

func ListOrganizationsPendingUsageLimitsRefreshInTransaction ¶ added in v0.13.0

func ListOrganizationsPendingUsageLimitsRefreshInTransaction(
	tx *gorm.DB,
	staleBefore time.Time,
	limit int,
) ([]Organization, error)

func ListOrganizationsPendingUsageSync ¶ added in v0.13.0

func ListOrganizationsPendingUsageSync(limit int) ([]Organization, error)

func ListOrganizationsPendingUsageSyncInTransaction ¶ added in v0.13.0

func ListOrganizationsPendingUsageSyncInTransaction(tx *gorm.DB, limit int) ([]Organization, error)

func LockDeletedOrganization ¶ added in v0.13.0

func LockDeletedOrganization(tx *gorm.DB, id uuid.UUID) (*Organization, error)

func (*Organization) HasExperimentalFeature ¶ added in v0.21.0

func (o *Organization) HasExperimentalFeature(id string) bool

HasExperimentalFeature reports whether the given feature id is active for this organization. Released features (per the features registry) are always considered active regardless of per-organization state.

func (*Organization) IsProviderAllowed ¶

func (o *Organization) IsProviderAllowed(provider string) bool

type OrganizationInviteLink ¶ added in v0.0.43

type OrganizationInviteLink struct {
	ID             uuid.UUID `gorm:"type:uuid;primary_key;default:gen_random_uuid()"`
	OrganizationID uuid.UUID `gorm:"uniqueIndex"`
	Token          uuid.UUID `gorm:"type:uuid;uniqueIndex"`
	Enabled        bool
	CreatedAt      time.Time
	UpdatedAt      time.Time
}

func CreateInviteLink ¶ added in v0.0.43

func CreateInviteLink(tx *gorm.DB, organizationID uuid.UUID) (*OrganizationInviteLink, error)

func FindInviteLinkByOrganizationID ¶ added in v0.0.43

func FindInviteLinkByOrganizationID(tx *gorm.DB, organizationID string) (*OrganizationInviteLink, error)

func FindInviteLinkByToken ¶ added in v0.0.43

func FindInviteLinkByToken(tx *gorm.DB, token string) (*OrganizationInviteLink, error)

func FindOrCreateInviteLink ¶ added in v0.28.0

func FindOrCreateInviteLink(tx *gorm.DB, organizationID uuid.UUID) (*OrganizationInviteLink, error)

type OrganizationWithCounts ¶ added in v0.16.0

type OrganizationWithCounts struct {
	Organization
	CanvasCount int64 `gorm:"column:canvas_count"`
	MemberCount int64 `gorm:"column:member_count"`
}

func ListAllOrganizations ¶ added in v0.14.0

func ListAllOrganizations(search string, limit, offset int, sortBy, sortDirection string) ([]OrganizationWithCounts, int64, error)

type Position ¶

type Position struct {
	X int `json:"x"`
	Y int `json:"y"`
}

type Repository ¶ added in v0.24.0

type Repository struct {
	ID             uuid.UUID `gorm:"type:uuid;primaryKey;default:uuid_generate_v4()"`
	CanvasID       uuid.UUID
	OrganizationID uuid.UUID
	Provider       string
	RepoID         string
	Status         string
	CreatedAt      time.Time
	UpdatedAt      time.Time
}

func FindRepository ¶ added in v0.24.0

func FindRepository(organizationID, canvasID uuid.UUID) (*Repository, error)

func FindRepositoryInTransaction ¶ added in v0.24.0

func FindRepositoryInTransaction(tx *gorm.DB, canvasID uuid.UUID) (*Repository, error)

func FindRepositoryUnscoped ¶ added in v0.24.0

func FindRepositoryUnscoped(canvasID uuid.UUID) (*Repository, error)

func ListPendingRepositories ¶ added in v0.24.0

func ListPendingRepositories(limit int) ([]Repository, error)

func LockPendingRepository ¶ added in v0.24.0

func LockPendingRepository(tx *gorm.DB, id uuid.UUID) (*Repository, error)

func (*Repository) MarkError ¶ added in v0.24.0

func (r *Repository) MarkError(tx *gorm.DB) error

func (*Repository) MarkReady ¶ added in v0.24.0

func (r *Repository) MarkReady(tx *gorm.DB) error

type RepositorySeedFile ¶ added in v0.27.0

type RepositorySeedFile struct {
	ID           uuid.UUID `gorm:"type:uuid;primaryKey;default:uuid_generate_v4()"`
	RepositoryID uuid.UUID
	Path         string
	Content      []byte
	CreatedAt    time.Time
}

RepositorySeedFile stores a file extracted from an installable app repository so the canvas repository provisioner can commit it as part of the repository's initial content. Rows are deleted after a successful commit (see workers/repository_provisioner.go).

func ListRepositorySeedFiles ¶ added in v0.27.0

func ListRepositorySeedFiles(repositoryID uuid.UUID) ([]RepositorySeedFile, error)

func ListRepositorySeedFilesInTransaction ¶ added in v0.27.0

func ListRepositorySeedFilesInTransaction(tx *gorm.DB, repositoryID uuid.UUID) ([]RepositorySeedFile, error)

func NewRepositorySeedFile ¶ added in v0.27.0

func NewRepositorySeedFile(repositoryID uuid.UUID, path string, content []byte) *RepositorySeedFile

func (RepositorySeedFile) TableName ¶ added in v0.27.0

func (RepositorySeedFile) TableName() string

type RoleMetadata ¶

type RoleMetadata struct {
	ID          uuid.UUID `json:"id" gorm:"type:uuid;primary_key;default:gen_random_uuid()"`
	RoleName    string    `json:"role_name" gorm:"not null;index"`
	DomainType  string    `json:"domain_type" gorm:"not null;index"`
	DomainID    string    `json:"domain_id" gorm:"not null;index"`
	DisplayName string    `json:"display_name" gorm:"not null"`
	Description string    `json:"description"`
	CreatedAt   time.Time `json:"created_at"`
	UpdatedAt   time.Time `json:"updated_at"`
}

func FindRoleMetadata ¶

func FindRoleMetadata(roleName, domainType, domainID string) (*RoleMetadata, error)

func (*RoleMetadata) BeforeCreate ¶

func (rm *RoleMetadata) BeforeCreate(tx *gorm.DB) error

func (*RoleMetadata) Create ¶

func (rm *RoleMetadata) Create() error

func (*RoleMetadata) CreateInTransaction ¶

func (rm *RoleMetadata) CreateInTransaction(tx *gorm.DB) error

func (*RoleMetadata) Update ¶

func (rm *RoleMetadata) Update() error

func (*RoleMetadata) UpdateInTransaction ¶

func (rm *RoleMetadata) UpdateInTransaction(tx *gorm.DB) error

type Secret ¶

type Secret struct {
	ID         uuid.UUID `gorm:"primary_key;default:uuid_generate_v4()"`
	DomainType string
	DomainID   uuid.UUID
	Name       string
	CreatedAt  *time.Time
	CreatedBy  uuid.UUID
	UpdatedAt  *time.Time
	Provider   string
	Data       []byte
}

func CreateSecret ¶

func CreateSecret(name, provider, requesterID, domainType string, domainID uuid.UUID, data []byte) (*Secret, error)

func FindSecretByID ¶

func FindSecretByID(domainType string, domainID uuid.UUID, id string) (*Secret, error)

func FindSecretByIDInTransaction ¶ added in v0.7.0

func FindSecretByIDInTransaction(tx *gorm.DB, domainType string, domainID uuid.UUID, id string) (*Secret, error)

func FindSecretByName ¶

func FindSecretByName(domainType string, domainID uuid.UUID, name string) (*Secret, error)

func FindSecretByNameInTransaction ¶

func FindSecretByNameInTransaction(tx *gorm.DB, domainType string, domainID uuid.UUID, name string) (*Secret, error)

func ListSecrets ¶

func ListSecrets(domainType string, domainID uuid.UUID) ([]Secret, error)

func (*Secret) Delete ¶

func (s *Secret) Delete() error

func (*Secret) UpdateData ¶

func (s *Secret) UpdateData(data []byte) (*Secret, error)

func (*Secret) UpdateNameAndData ¶ added in v0.28.0

func (s *Secret) UpdateNameAndData(tx *gorm.DB, name string, data []byte) (*Secret, error)

type SecretData ¶

type SecretData struct {
	Local map[string]string `json:"local"`
}

type SetupState ¶ added in v0.19.0

type SetupState struct {
	CurrentStep   *core.SetupStep  `json:"current_step,omitempty"`
	PreviousSteps []core.SetupStep `json:"previous_steps,omitempty"`
}

type TriggerRef ¶

type TriggerRef struct {
	Name string `json:"name"`
}

type User ¶

type User struct {
	ID             uuid.UUID `gorm:"type:uuid;primary_key;default:gen_random_uuid()"`
	OrganizationID uuid.UUID
	AccountID      *uuid.UUID
	Email          *string
	Name           string
	Type           string
	Description    *string
	CreatedBy      *uuid.UUID
	TokenHash      string
	CreatedAt      time.Time
	UpdatedAt      time.Time
	DeletedAt      gorm.DeletedAt
}

func CreateServiceAccount ¶ added in v0.9.0

func CreateServiceAccount(tx *gorm.DB, orgID uuid.UUID, name string, description *string, createdBy uuid.UUID) (*User, error)

func CreateUser ¶

func CreateUser(orgID, accountID uuid.UUID, email, name string) (*User, error)

func CreateUserInTransaction ¶

func CreateUserInTransaction(tx *gorm.DB, orgID, accountID uuid.UUID, email, name string) (*User, error)

func FindActiveUserByEmail ¶

func FindActiveUserByEmail(orgID, email string) (*User, error)

func FindActiveUserByEmailInTransaction ¶ added in v0.26.0

func FindActiveUserByEmailInTransaction(tx *gorm.DB, orgID, email string) (*User, error)

func FindActiveUserByID ¶

func FindActiveUserByID(orgID, id string) (*User, error)

func FindActiveUserByIDInTransaction ¶

func FindActiveUserByIDInTransaction(tx *gorm.DB, orgID, id string) (*User, error)

func FindActiveUserByTokenHash ¶

func FindActiveUserByTokenHash(tokenHash string) (*User, error)

func FindActiveUserByTokenHashInTransaction ¶ added in v0.26.0

func FindActiveUserByTokenHashInTransaction(tx *gorm.DB, tokenHash string) (*User, error)

func FindAnyUserByEmail ¶

func FindAnyUserByEmail(email string) (*User, error)

func FindFirstHumanUserByOrganization ¶ added in v0.13.0

func FindFirstHumanUserByOrganization(orgID string) (*User, error)

func FindFirstHumanUserByOrganizationInTransaction ¶ added in v0.13.0

func FindFirstHumanUserByOrganizationInTransaction(tx *gorm.DB, orgID string) (*User, error)

func FindHumanUsersByIDs ¶ added in v0.9.0

func FindHumanUsersByIDs(ids []string) ([]User, error)

func FindMaybeDeletedUserByEmail ¶

func FindMaybeDeletedUserByEmail(orgID, email string) (*User, error)

func FindMaybeDeletedUserByEmailInTransaction ¶ added in v0.0.43

func FindMaybeDeletedUserByEmailInTransaction(tx *gorm.DB, orgID, email string) (*User, error)

func FindMaybeDeletedUserByID ¶

func FindMaybeDeletedUserByID(orgID, id string) (*User, error)

NOTE: this method returns soft deleted users too. Make sure you really need to use it this one, and not FindActiveUserByID instead.

func FindMaybeDeletedUserByIDInTransaction ¶ added in v0.26.0

func FindMaybeDeletedUserByIDInTransaction(tx *gorm.DB, orgID, id string) (*User, error)

func FindMaybeDeletedUsersByIDs ¶ added in v0.0.43

func FindMaybeDeletedUsersByIDs(tx *gorm.DB, ids []uuid.UUID) ([]User, error)

func FindServiceAccountsByOrganization ¶ added in v0.9.0

func FindServiceAccountsByOrganization(db *gorm.DB, orgID string) ([]User, error)

func FindUnscopedUserByID ¶

func FindUnscopedUserByID(id string) (*User, error)

func FindUsersByIDs ¶ added in v0.9.0

func FindUsersByIDs(ids []string) ([]User, error)

func FindUsersByIDsInOrganization ¶ added in v0.19.0

func FindUsersByIDsInOrganization(db *gorm.DB, orgID string, ids []string) ([]User, error)

func ListActiveUsersByID ¶ added in v0.0.43

func ListActiveUsersByID(orgID string, ids []string) ([]User, error)

func ListActiveUsersByIDInTransaction ¶ added in v0.0.43

func ListActiveUsersByIDInTransaction(tx *gorm.DB, orgID string, ids []string) ([]User, error)

func ListActiveUsersByOrganization ¶ added in v0.14.0

func ListActiveUsersByOrganization(orgID, search string, limit, offset int) ([]User, int64, error)

func ListAllActiveUsersInOrganization ¶ added in v0.16.0

func ListAllActiveUsersInOrganization(orgID string) ([]User, error)

func (*User) Delete ¶

func (u *User) Delete() error

func (*User) GetEmail ¶ added in v0.9.0

func (u *User) GetEmail() string

func (*User) IsServiceAccount ¶ added in v0.9.0

func (u *User) IsServiceAccount() bool

func (*User) Restore ¶

func (u *User) Restore() error

func (*User) RestoreInTransaction ¶

func (u *User) RestoreInTransaction(tx *gorm.DB) error

func (*User) UpdateTokenHash ¶

func (u *User) UpdateTokenHash(tokenHash string) error

type UserAccountProvider ¶ added in v0.16.0

type UserAccountProvider struct {
	AccountProvider
	UserID string
}

func FindUserAccountProviders ¶ added in v0.16.0

func FindUserAccountProviders(users []User) ([]UserAccountProvider, error)

type UserCanvasPreference ¶ added in v0.28.0

type UserCanvasPreference struct {
	OrganizationID uuid.UUID `gorm:"primaryKey"`
	UserID         uuid.UUID `gorm:"primaryKey"`
	CanvasID       uuid.UUID `gorm:"primaryKey"`
	PinnedAt       *time.Time
	StarredAt      *time.Time
	CreatedAt      time.Time
	UpdatedAt      time.Time
}

func SetUserCanvasPreference ¶ added in v0.28.0

func SetUserCanvasPreference(
	tx *gorm.DB,
	organizationID uuid.UUID,
	userID uuid.UUID,
	canvasID uuid.UUID,
	pinned *bool,
	starred *bool,
) (*UserCanvasPreference, error)

func (*UserCanvasPreference) TableName ¶ added in v0.28.0

func (p *UserCanvasPreference) TableName() string

type Webhook ¶

type Webhook struct {
	ID                uuid.UUID `gorm:"primary_key;default:uuid_generate_v4()"`
	State             string
	Secret            []byte
	Configuration     datatypes.JSONType[any]
	Metadata          datatypes.JSONType[any]
	AppInstallationID *uuid.UUID
	RetryCount        int `gorm:"default:0"`
	MaxRetries        int `gorm:"default:3"`
	CreatedAt         *time.Time
	UpdatedAt         *time.Time
	DeletedAt         gorm.DeletedAt `gorm:"index"`
}

func FindWebhook ¶

func FindWebhook(id uuid.UUID) (*Webhook, error)

func FindWebhookInTransaction ¶

func FindWebhookInTransaction(tx *gorm.DB, id uuid.UUID) (*Webhook, error)

func ListDeletedWebhooks ¶

func ListDeletedWebhooks() ([]Webhook, error)

func ListIntegrationWebhooks ¶ added in v0.6.0

func ListIntegrationWebhooks(tx *gorm.DB, integrationID uuid.UUID) ([]Webhook, error)

func ListPendingWebhooks ¶

func ListPendingWebhooks() ([]Webhook, error)

func ListUnscopedIntegrationWebhooks ¶ added in v0.6.0

func ListUnscopedIntegrationWebhooks(tx *gorm.DB, integrationID uuid.UUID) ([]Webhook, error)

func LockDeletedWebhook ¶ added in v0.12.0

func LockDeletedWebhook(tx *gorm.DB, ID uuid.UUID) (*Webhook, error)

LockDeletedWebhook acquires a row-level lock on a soft-deleted webhook regardless of its state. Used by WebhookCleanupWorker to clean up webhooks that were in any state (ready, failed, etc.) when deleted.

func LockWebhook ¶

func LockWebhook(tx *gorm.DB, ID uuid.UUID) (*Webhook, error)

func (*Webhook) HasExceededRetries ¶

func (w *Webhook) HasExceededRetries() bool

func (*Webhook) IncrementRetry ¶

func (w *Webhook) IncrementRetry(tx *gorm.DB) error

func (*Webhook) MarkFailed ¶

func (w *Webhook) MarkFailed(tx *gorm.DB) error

func (*Webhook) MarkProvisioning ¶ added in v0.12.0

func (w *Webhook) MarkProvisioning(tx *gorm.DB) error

func (*Webhook) Ready ¶

func (w *Webhook) Ready(tx *gorm.DB) error

func (*Webhook) ReadyWithMetadata ¶

func (w *Webhook) ReadyWithMetadata(tx *gorm.DB, metadata any) error

type WebhookResource ¶

type WebhookResource struct {
	Type string `json:"type"`
	ID   string `json:"id"`
	Name string `json:"name"`
}

type WidgetRef ¶ added in v0.0.18

type WidgetRef struct {
	Name string `json:"name"`
}

type WorkflowStagedFile ¶ added in v0.28.0

type WorkflowStagedFile struct {
	ID             uuid.UUID `gorm:"type:uuid;primaryKey;default:uuid_generate_v4()"`
	OrganizationID uuid.UUID `gorm:"type:uuid;not null"`
	WorkflowID     uuid.UUID `gorm:"type:uuid;not null"`
	UserID         uuid.UUID `gorm:"type:uuid;not null"`
	BaseVersionID  uuid.UUID `gorm:"type:uuid;not null"`
	Path           string    `gorm:"type:text;not null"`
	Content        string    `gorm:"type:text;not null;default:''"`
	UpdatedAt      time.Time `gorm:"not null"`

	//
	// Deleted marks a staged file removal (row kept). Effective read returns empty
	// content when true. DiscardWorkflowStaging hard-deletes rows to revert staging.
	//
	Deleted bool `gorm:"not null;default:false"`
}

func FindStagedFileForUser ¶ added in v0.28.0

func FindStagedFileForUser(db *gorm.DB, workflowID, userID uuid.UUID, path string) (*WorkflowStagedFile, error)

func ListStagedFilesForUser ¶ added in v0.28.0

func ListStagedFilesForUser(db *gorm.DB, workflowID, userID uuid.UUID) ([]WorkflowStagedFile, error)

func UpsertStagedFile ¶ added in v0.28.0

func UpsertStagedFile(
	db *gorm.DB,
	workflowID, userID, baseVersionID, organizationID uuid.UUID,
	path, content string,
) (*WorkflowStagedFile, error)

func (WorkflowStagedFile) TableName ¶ added in v0.28.0

func (WorkflowStagedFile) TableName() string

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