artel_q

package
v1.0.13 Latest Latest
Warning

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

 Go to latest Published: Aug 7, 2026 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddVaultMemberParams 

type AddVaultMemberParams struct {
	VaultID uuid.UUID
	UserID  uuid.UUID
	Role    VaultRole
}

type ArtelPrompt 

type ArtelPrompt string
const (
	ArtelPromptPersonalVaultSetup ArtelPrompt = "personal_vault_setup"
)

func (*ArtelPrompt) Scan 

func (e *ArtelPrompt) Scan(src interface{}) error

type CouchAccount 

type CouchAccount struct {
	ID               uuid.UUID
	UserID           uuid.UUID
	CouchInstanceID  uuid.UUID
	CouchUsername    string
	CouchPasswordEnc []byte
	CreatedAt        time.Time
}

type CouchInstance 

type CouchInstance struct {
	ID          uuid.UUID
	Url         string
	Username    string
	PasswordEnc []byte
	CreatedAt   time.Time
	OwnerUserID uuid.NullUUID
}

type CreateByUsernameParams 

type CreateByUsernameParams struct {
	Username string
	PhotoUrl string
}

type CreateByUsernameRow 

type CreateByUsernameRow struct {
	ID           uuid.UUID
	Email        sql.NullString
	Username     string
	PhotoUrl     string
	PasswordHash string
	CreatedAt    time.Time
	UpdatedAt    time.Time
}

type CreateMcpKeyParams 

type CreateMcpKeyParams struct {
	ID         uuid.UUID
	VaultID    uuid.UUID
	UserID     uuid.UUID
	Name       string
	KeyHash    []byte
	KeyPreview string
}

type CreatePendingAuthCodeParams 

type CreatePendingAuthCodeParams struct {
	Code          string
	RawToken      string
	CodeChallenge string
	RedirectUri   string
	ClientID      string
	ExpiresAt     time.Time
}

type CreateSessionParams 

type CreateSessionParams struct {
	UserID           uuid.UUID
	Token            string
	ExpiresAt        time.Time
	RefreshToken     sql.NullString
	RefreshExpiresAt sql.NullTime
}

type CreateSessionRow 

type CreateSessionRow struct {
	ID               uuid.UUID
	UserID           uuid.UUID
	Token            string
	ExpiresAt        time.Time
	RefreshToken     sql.NullString
	RefreshExpiresAt sql.NullTime
	CreatedAt        time.Time
}

type CreateUserParams 

type CreateUserParams struct {
	Email        sql.NullString
	PasswordHash string
}

type CreateUserRow 

type CreateUserRow struct {
	ID           uuid.UUID
	Email        sql.NullString
	PasswordHash string
	CreatedAt    time.Time
	UpdatedAt    time.Time
}

type CreateVaultInviteParams 

type CreateVaultInviteParams struct {
	VaultID   uuid.UUID
	CreatedBy uuid.UUID
	Role      VaultRole
	Token     string
}

type CreateVaultParams 

type CreateVaultParams struct {
	UserID                uuid.UUID
	Name                  string
	CouchDbName           string
	CouchInstanceID       uuid.NullUUID
	Status                string
	LivesyncPassphraseEnc []byte
	S3InstanceID          uuid.NullUUID
	S3BucketName          sql.NullString
}

type CreateVaultRow 

type CreateVaultRow struct {
	ID                    uuid.UUID
	UserID                uuid.UUID
	Name                  string
	CouchDbName           string
	CouchInstanceID       uuid.NullUUID
	Status                string
	LivesyncPassphraseEnc []byte
	S3InstanceID          uuid.NullUUID
	S3BucketName          sql.NullString
	UseCouchdbForBinaries bool
	CreatedAt             time.Time
	IsPublic              bool
	Slug                  sql.NullString
}

type CreateWorkbenchParams 

type CreateWorkbenchParams struct {
	VaultID      uuid.UUID
	UserID       uuid.UUID
	VolumeName   string
	DockerHostID uuid.NullUUID
}

type DBTX 

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type DeleteExternalConnectionByIDParams 

type DeleteExternalConnectionByIDParams struct {
	ID     uuid.UUID
	UserID uuid.UUID
}

type DeleteExternalConnectionParams 

type DeleteExternalConnectionParams struct {
	UserID   uuid.UUID
	Provider string
}

type DeleteMcpConnectorParams 

type DeleteMcpConnectorParams struct {
	McpKeyID uuid.UUID
	McpName  string
}

type DeleteMcpSpreadsheetParams 

type DeleteMcpSpreadsheetParams struct {
	UserID        uuid.UUID
	SpreadsheetID string
}

type DockerHost 

type DockerHost struct {
	ID            uuid.UUID
	Url           string
	CreatedAt     time.Time
	CaCertEnc     []byte
	ClientCertEnc []byte
	ClientKeyEnc  []byte
}

type ExternalConnection 

type ExternalConnection struct {
	ID             uuid.UUID
	UserID         uuid.UUID
	Provider       string
	ProviderType   ExternalProviderType
	CredentialsEnc []byte
	Metadata       pqtype.NullRawMessage
	CreatedAt      time.Time
	UpdatedAt      time.Time
}

type ExternalProviderType 

type ExternalProviderType string
const (
	ExternalProviderTypeGoogleOauth ExternalProviderType = "google_oauth"
	ExternalProviderTypeApiKey      ExternalProviderType = "api_key"
	ExternalProviderTypePassword    ExternalProviderType = "password"
)

func (*ExternalProviderType) Scan 

func (e *ExternalProviderType) Scan(src interface{}) error

type GetCouchAccountByUserAndInstanceParams 

type GetCouchAccountByUserAndInstanceParams struct {
	UserID          uuid.UUID
	CouchInstanceID uuid.UUID
}

type GetCouchInstanceRow 

type GetCouchInstanceRow struct {
	ID        uuid.UUID
	Url       string
	Username  string
	CreatedAt time.Time
}

type GetCouchInstanceWithCredsRow 

type GetCouchInstanceWithCredsRow struct {
	ID          uuid.UUID
	Url         string
	Username    string
	PasswordEnc []byte
	CreatedAt   time.Time
}

type GetDockerHostRow 

type GetDockerHostRow struct {
	ID        uuid.UUID
	Url       string
	CreatedAt time.Time
}

type GetExternalConnectionByUserAndProviderParams 

type GetExternalConnectionByUserAndProviderParams struct {
	UserID   uuid.UUID
	Provider string
}

type GetMcpConnectorParams 

type GetMcpConnectorParams struct {
	McpKeyID uuid.UUID
	McpName  string
}

type GetMcpToolParams 

type GetMcpToolParams struct {
	McpName string
	Name    string
}

type GetS3InstanceRow 

type GetS3InstanceRow struct {
	ID        uuid.UUID
	Endpoint  string
	Region    string
	AccessKey string
	UseSsl    bool
	PathStyle bool
	CreatedAt time.Time
}

type GetS3InstanceWithCredsRow 

type GetS3InstanceWithCredsRow struct {
	ID           uuid.UUID
	Endpoint     string
	Region       string
	AccessKey    string
	SecretKeyEnc []byte
	UseSsl       bool
	PathStyle    bool
	CreatedAt    time.Time
}

type GetSessionByTokenRow 

type GetSessionByTokenRow struct {
	ID               uuid.UUID
	UserID           uuid.UUID
	Token            string
	ExpiresAt        time.Time
	RefreshToken     sql.NullString
	RefreshExpiresAt sql.NullTime
	CreatedAt        time.Time
}

type GetSessionWithUserRow 

type GetSessionWithUserRow struct {
	SessionID        uuid.UUID
	Token            string
	SessionExpiresAt time.Time
	SessionCreatedAt time.Time
	UserID           uuid.UUID
	Email            sql.NullString
	Username         string
	PhotoUrl         string
	PasswordHash     string
	UserCreatedAt    time.Time
	UserUpdatedAt    time.Time
}

type GetSubscriptionWithPlanRow 

type GetSubscriptionWithPlanRow struct {
	UserID                  uuid.UUID
	Active                  bool
	PlanKey                 string
	FeatureOverrides        json.RawMessage
	CouchQuotaOverrideBytes sql.NullInt64
	S3QuotaOverrideBytes    sql.NullInt64
	PlanCouchQuotaBytes     int64
	PlanS3QuotaBytes        int64
	PlanFeatures            json.RawMessage
}

type GetUserByEmailRow 

type GetUserByEmailRow struct {
	ID           uuid.UUID
	Email        sql.NullString
	PasswordHash string
	CreatedAt    time.Time
	UpdatedAt    time.Time
}

type GetUserByIDRow 

type GetUserByIDRow struct {
	ID           uuid.UUID
	Email        sql.NullString
	Username     string
	PhotoUrl     string
	PasswordHash string
	CreatedAt    time.Time
	UpdatedAt    time.Time
}

type GetUserByTelegramIdRow 

type GetUserByTelegramIdRow struct {
	ID           uuid.UUID
	Email        sql.NullString
	Username     string
	PasswordHash string
	CreatedAt    time.Time
	UpdatedAt    time.Time
}

type GetUserDetailsRow 

type GetUserDetailsRow struct {
	ID              uuid.UUID
	Username        string
	Email           sql.NullString
	PhotoUrl        string
	CreatedAt       time.Time
	UpdatedAt       time.Time
	PasswordHash    string
	IsAdministrator sql.NullBool
}

type GetVaultByIDRow 

type GetVaultByIDRow struct {
	ID                    uuid.UUID
	UserID                uuid.UUID
	Name                  string
	CouchDbName           string
	CouchInstanceID       uuid.NullUUID
	Status                string
	LivesyncPassphraseEnc []byte
	S3InstanceID          uuid.NullUUID
	S3BucketName          sql.NullString
	UseCouchdbForBinaries bool
	CreatedAt             time.Time
	IsPublic              bool
	Slug                  sql.NullString
}

type GetVaultByNameAndUserParams 

type GetVaultByNameAndUserParams struct {
	UserID uuid.UUID
	Name   string
}

type GetVaultByNameAndUserRow 

type GetVaultByNameAndUserRow struct {
	ID                    uuid.UUID
	UserID                uuid.UUID
	Name                  string
	CouchDbName           string
	CouchInstanceID       uuid.NullUUID
	Status                string
	LivesyncPassphraseEnc []byte
	S3InstanceID          uuid.NullUUID
	S3BucketName          sql.NullString
	UseCouchdbForBinaries bool
	CreatedAt             time.Time
	IsPublic              bool
	Slug                  sql.NullString
}

type GetVaultBySlugRow 

type GetVaultBySlugRow struct {
	ID                    uuid.UUID
	UserID                uuid.UUID
	Name                  string
	CouchDbName           string
	CouchInstanceID       uuid.NullUUID
	Status                string
	LivesyncPassphraseEnc []byte
	S3InstanceID          uuid.NullUUID
	S3BucketName          sql.NullString
	UseCouchdbForBinaries bool
	CreatedAt             time.Time
	IsPublic              bool
	Slug                  sql.NullString
}

type GetVaultMembershipParams 

type GetVaultMembershipParams struct {
	VaultID uuid.UUID
	UserID  uuid.UUID
}

type IdentitiesTelegram 

type IdentitiesTelegram struct {
	ID         uuid.UUID
	UserID     uuid.UUID
	TelegramID string
	CreatedAt  time.Time
	UpdatedAt  time.Time
}

type InsertExternalConnectionParams 

type InsertExternalConnectionParams struct {
	UserID         uuid.UUID
	Provider       string
	ProviderType   ExternalProviderType
	CredentialsEnc []byte
	Metadata       pqtype.NullRawMessage
}

type InsertMcpConnectorParams 

type InsertMcpConnectorParams struct {
	McpKeyID             uuid.UUID
	McpName              string
	ExternalConnectionID uuid.UUID
}

type InsertMcpSpreadsheetParams 

type InsertMcpSpreadsheetParams struct {
	UserID               uuid.UUID
	ExternalConnectionID uuid.UUID
	SpreadsheetID        string
	Name                 string
}

type InsertTractParams 

type InsertTractParams struct {
	UserID      uuid.UUID
	Name        string
	Description string
	Enabled     bool
	Definition  json.RawMessage
}

type InsertTractRunParams 

type InsertTractRunParams struct {
	TractID       uuid.UUID
	TriggerID     uuid.NullUUID
	StartedBy     string
	TriggerOutput json.RawMessage
}

type InsertTractRunStepParams 

type InsertTractRunStepParams struct {
	RunID    uuid.UUID
	StepID   string
	StepName string
	StepType string
	Input    pqtype.NullRawMessage
}

type InsertTractTemplateParams 

type InsertTractTemplateParams struct {
	SourceTractID uuid.NullUUID
	OwnerID       uuid.NullUUID
	Name          string
	Description   string
	Definition    json.RawMessage
	Category      string
}

type InsertTriggerParams 

type InsertTriggerParams struct {
	UserID        uuid.UUID
	Name          string
	Kind          string
	Source        string
	Config        json.RawMessage
	PayloadSchema json.RawMessage
	SecretHash    []byte
	TokenSuffix   sql.NullString
	Matchers      json.RawMessage
	Enabled       bool
}

type InsertTriggerProviderLinkParams 

type InsertTriggerProviderLinkParams struct {
	TriggerID            uuid.UUID
	ExternalConnectionID uuid.UUID
}

type LinkTriggerToTractParams 

type LinkTriggerToTractParams struct {
	TractID   uuid.UUID
	TriggerID uuid.UUID
	Filters   json.RawMessage
}

type LinkVaultS3BucketParams 

type LinkVaultS3BucketParams struct {
	ID           uuid.UUID
	S3InstanceID uuid.NullUUID
	S3BucketName sql.NullString
}

type ListCouchInstancesRow 

type ListCouchInstancesRow struct {
	ID        uuid.UUID
	Url       string
	Username  string
	CreatedAt time.Time
}

type ListDockerHostsRow 

type ListDockerHostsRow struct {
	ID        uuid.UUID
	Url       string
	CreatedAt time.Time
}

type ListS3InstancesRow 

type ListS3InstancesRow struct {
	ID        uuid.UUID
	Endpoint  string
	Region    string
	AccessKey string
	UseSsl    bool
	PathStyle bool
	CreatedAt time.Time
}

type ListTractRunsByTractParams 

type ListTractRunsByTractParams struct {
	TractID uuid.UUID
	Limit   int32
}

type ListTriggerLinksByTractRow 

type ListTriggerLinksByTractRow struct {
	ID            uuid.UUID
	TriggerUuid   uuid.UUID
	UserID        uuid.UUID
	Name          string
	Kind          string
	Source        string
	Config        json.RawMessage
	PayloadSchema json.RawMessage
	SecretHash    []byte
	Enabled       bool
	CreatedAt     time.Time
	Matchers      json.RawMessage
	TokenSuffix   sql.NullString
	Filters       json.RawMessage
}

type ListTriggerLinksByTriggerRow 

type ListTriggerLinksByTriggerRow struct {
	ID          uuid.UUID
	UserID      uuid.UUID
	Name        string
	Description string
	Enabled     bool
	Definition  json.RawMessage
	CreatedAt   time.Time
	UpdatedAt   time.Time
	Filters     json.RawMessage
}

type ListVaultMembersWithUsersRow 

type ListVaultMembersWithUsersRow struct {
	ID        uuid.UUID
	VaultID   uuid.UUID
	UserID    uuid.UUID
	Role      VaultRole
	CreatedAt time.Time
	Email     sql.NullString
	Username  string
}

type ListVaultsByMembershipRow 

type ListVaultsByMembershipRow struct {
	ID                    uuid.UUID
	UserID                uuid.UUID
	Name                  string
	CouchDbName           string
	CouchInstanceID       uuid.NullUUID
	Status                string
	LivesyncPassphraseEnc []byte
	S3InstanceID          uuid.NullUUID
	S3BucketName          sql.NullString
	UseCouchdbForBinaries bool
	CreatedAt             time.Time
	IsPublic              bool
	Slug                  sql.NullString
	MemberRole            NullVaultRole
}

type MailServerSuggestion 

type MailServerSuggestion struct {
	Domain         string
	Smtp           string
	SmtpPort       int32
	Imap           string
	ImapPort       int32
	AppPasswordUrl sql.NullString
}

type MarkWorkbenchContainerCreatedParams 

type MarkWorkbenchContainerCreatedParams struct {
	VaultID     uuid.UUID
	ContainerID sql.NullString
}

type MarkWorkbenchRunningParams 

type MarkWorkbenchRunningParams struct {
	VaultID  uuid.UUID
	AuthMode NullWorkbenchAuthMode
}

type Mcp 

type Mcp struct {
	Name        string
	Author      string
	Description string
	CreatedAt   time.Time
	OwnerUserID uuid.NullUUID
	IsCommunity bool
}

type McpConnector 

type McpConnector struct {
	ID                   uuid.UUID
	McpKeyID             uuid.UUID
	McpName              string
	ExternalConnectionID uuid.UUID
	CreatedAt            time.Time
}

type McpKey 

type McpKey struct {
	ID             uuid.UUID
	VaultID        uuid.UUID
	UserID         uuid.UUID
	Name           string
	KeyHash        []byte
	KeyPreview     string
	CreatedAt      time.Time
	RevokedAt      sql.NullTime
	LastAccessedAt sql.NullTime
}

type McpSpreadsheet 

type McpSpreadsheet struct {
	ID                   uuid.UUID
	UserID               uuid.UUID
	ExternalConnectionID uuid.UUID
	SpreadsheetID        string
	Name                 string
	CreatedAt            time.Time
}

type McpTool 

type McpTool struct {
	ID           uuid.UUID
	McpName      string
	Name         string
	Description  string
	InputSchema  json.RawMessage
	OutputSchema json.RawMessage
	Action       json.RawMessage
	CreatedAt    time.Time
}

type NullArtelPrompt 

type NullArtelPrompt struct {
	ArtelPrompt ArtelPrompt
	Valid       bool // Valid is true if ArtelPrompt is not NULL
}

func (*NullArtelPrompt) Scan 

func (ns *NullArtelPrompt) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullArtelPrompt) Value 

func (ns NullArtelPrompt) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullExternalProviderType 

type NullExternalProviderType struct {
	ExternalProviderType ExternalProviderType
	Valid                bool // Valid is true if ExternalProviderType is not NULL
}

func (*NullExternalProviderType) Scan 

func (ns *NullExternalProviderType) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullExternalProviderType) Value 

func (ns NullExternalProviderType) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullTractRunStatus 

type NullTractRunStatus struct {
	TractRunStatus TractRunStatus
	Valid          bool // Valid is true if TractRunStatus is not NULL
}

func (*NullTractRunStatus) Scan 

func (ns *NullTractRunStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullTractRunStatus) Value 

func (ns NullTractRunStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullTractRunStepStatus 

type NullTractRunStepStatus struct {
	TractRunStepStatus TractRunStepStatus
	Valid              bool // Valid is true if TractRunStepStatus is not NULL
}

func (*NullTractRunStepStatus) Scan 

func (ns *NullTractRunStepStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullTractRunStepStatus) Value 

func (ns NullTractRunStepStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullVaultRole 

type NullVaultRole struct {
	VaultRole VaultRole
	Valid     bool // Valid is true if VaultRole is not NULL
}

func (*NullVaultRole) Scan 

func (ns *NullVaultRole) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullVaultRole) Value 

func (ns NullVaultRole) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullWorkbenchAuthMode 

type NullWorkbenchAuthMode struct {
	WorkbenchAuthMode WorkbenchAuthMode
	Valid             bool // Valid is true if WorkbenchAuthMode is not NULL
}

func (*NullWorkbenchAuthMode) Scan 

func (ns *NullWorkbenchAuthMode) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullWorkbenchAuthMode) Value 

func (ns NullWorkbenchAuthMode) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullWorkbenchStatus 

type NullWorkbenchStatus struct {
	WorkbenchStatus WorkbenchStatus
	Valid           bool // Valid is true if WorkbenchStatus is not NULL
}

func (*NullWorkbenchStatus) Scan 

func (ns *NullWorkbenchStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullWorkbenchStatus) Value 

func (ns NullWorkbenchStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type PendingAuthCode 

type PendingAuthCode struct {
	Code          string
	RawToken      string
	CodeChallenge string
	RedirectUri   string
	ClientID      string
	ExpiresAt     time.Time
}

type PickLeastLoadedDockerHostRow 

type PickLeastLoadedDockerHostRow struct {
	ID        uuid.UUID
	Url       string
	CreatedAt time.Time
}

type PickOwnedCouchInstanceRow 

type PickOwnedCouchInstanceRow struct {
	ID          uuid.UUID
	Url         string
	Username    string
	PasswordEnc []byte
	CreatedAt   time.Time
}

type PickOwnedS3InstanceRow 

type PickOwnedS3InstanceRow struct {
	ID           uuid.UUID
	Endpoint     string
	Region       string
	AccessKey    string
	SecretKeyEnc []byte
	UseSsl       bool
	PathStyle    bool
	CreatedAt    time.Time
}

type Prompt 

type Prompt struct {
	ID     ArtelPrompt
	Prompt string
}

type PublishVaultParams 

type PublishVaultParams struct {
	ID   uuid.UUID
	Slug sql.NullString
}

type PublishVaultRow 

type PublishVaultRow struct {
	ID                    uuid.UUID
	UserID                uuid.UUID
	Name                  string
	CouchDbName           string
	CouchInstanceID       uuid.NullUUID
	Status                string
	LivesyncPassphraseEnc []byte
	S3InstanceID          uuid.NullUUID
	S3BucketName          sql.NullString
	UseCouchdbForBinaries bool
	CreatedAt             time.Time
	IsPublic              bool
	Slug                  sql.NullString
}

type Querier 

type Querier interface {
	AddVaultMember(ctx context.Context, arg AddVaultMemberParams) error
	CompleteSetup(ctx context.Context) error
	CouchInstanceExists(ctx context.Context) (bool, error)
	CreateByUsername(ctx context.Context, arg CreateByUsernameParams) (CreateByUsernameRow, error)
	CreateDefaultSubscription(ctx context.Context, userID uuid.UUID) error
	CreateDefaultUserPermissions(ctx context.Context, userID uuid.UUID) error
	CreateMcpKey(ctx context.Context, arg CreateMcpKeyParams) (McpKey, error)
	CreatePendingAuthCode(ctx context.Context, arg CreatePendingAuthCodeParams) error
	CreateSession(ctx context.Context, arg CreateSessionParams) (CreateSessionRow, error)
	CreateUser(ctx context.Context, arg CreateUserParams) (CreateUserRow, error)
	CreateVault(ctx context.Context, arg CreateVaultParams) (CreateVaultRow, error)
	CreateVaultInvite(ctx context.Context, arg CreateVaultInviteParams) (VaultInvite, error)
	CreateWorkbench(ctx context.Context, arg CreateWorkbenchParams) (Workbench, error)
	DeleteCouchAccount(ctx context.Context, id uuid.UUID) error
	DeleteCouchInstance(ctx context.Context, id uuid.UUID) error
	DeleteDockerHost(ctx context.Context, id uuid.UUID) error
	DeleteExpiredPendingAuthCodes(ctx context.Context) error
	DeleteExternalConnection(ctx context.Context, arg DeleteExternalConnectionParams) error
	DeleteExternalConnectionByID(ctx context.Context, arg DeleteExternalConnectionByIDParams) error
	DeleteMcpConnector(ctx context.Context, arg DeleteMcpConnectorParams) error
	DeleteMcpDefinition(ctx context.Context, name string) error
	DeleteMcpSpreadsheet(ctx context.Context, arg DeleteMcpSpreadsheetParams) error
	DeleteOwnedCouchInstanceIfUnreferenced(ctx context.Context, ownerUserID uuid.NullUUID) error
	DeleteOwnedS3InstanceIfUnreferenced(ctx context.Context, ownerUserID uuid.NullUUID) error
	DeletePendingAuthCode(ctx context.Context, code string) error
	DeleteS3Instance(ctx context.Context, id uuid.UUID) error
	DeleteSession(ctx context.Context, token string) error
	DeleteTract(ctx context.Context, id uuid.UUID) error
	DeleteTractTemplate(ctx context.Context, id uuid.UUID) error
	DeleteTrigger(ctx context.Context, id uuid.UUID) error
	DeleteUser(ctx context.Context, id uuid.UUID) error
	DeleteVault(ctx context.Context, id uuid.UUID) error
	DeleteWorkbench(ctx context.Context, vaultID uuid.UUID) error
	DockerHostExists(ctx context.Context) (bool, error)
	GetCouchAccountByUserAndInstance(ctx context.Context, arg GetCouchAccountByUserAndInstanceParams) (CouchAccount, error)
	GetCouchInstance(ctx context.Context, id uuid.UUID) (GetCouchInstanceRow, error)
	GetCouchInstanceWithCreds(ctx context.Context, id uuid.UUID) (GetCouchInstanceWithCredsRow, error)
	GetDockerHost(ctx context.Context, id uuid.UUID) (GetDockerHostRow, error)
	GetDockerHostWithCreds(ctx context.Context, id uuid.UUID) (DockerHost, error)
	GetExternalConnectionByID(ctx context.Context, id uuid.UUID) (ExternalConnection, error)
	GetExternalConnectionByUserAndProvider(ctx context.Context, arg GetExternalConnectionByUserAndProviderParams) (ExternalConnection, error)
	GetMcpConnector(ctx context.Context, arg GetMcpConnectorParams) (McpConnector, error)
	GetMcpDefinition(ctx context.Context, name string) (Mcp, error)
	GetMcpKeyByID(ctx context.Context, id uuid.UUID) (McpKey, error)
	GetMcpTool(ctx context.Context, arg GetMcpToolParams) (McpTool, error)
	GetPendingAuthCode(ctx context.Context, code string) (PendingAuthCode, error)
	GetS3Instance(ctx context.Context, id uuid.UUID) (GetS3InstanceRow, error)
	GetS3InstanceWithCreds(ctx context.Context, id uuid.UUID) (GetS3InstanceWithCredsRow, error)
	GetSessionByToken(ctx context.Context, token string) (GetSessionByTokenRow, error)
	GetSessionWithUser(ctx context.Context, token string) (GetSessionWithUserRow, error)
	GetSessionsByUserID(ctx context.Context, userID uuid.UUID) ([]Session, error)
	GetSubscriptionByUser(ctx context.Context, userID uuid.UUID) (Subscription, error)
	GetSubscriptionPlan(ctx context.Context, planKey string) (SubscriptionPlan, error)
	GetSubscriptionWithPlan(ctx context.Context, userID uuid.UUID) (GetSubscriptionWithPlanRow, error)
	GetSystemSettings(ctx context.Context) (SystemSetting, error)
	GetSystemSettingsForUpdate(ctx context.Context) (SystemSetting, error)
	GetTelegramPhotoUrlByUserId(ctx context.Context, id uuid.UUID) (string, error)
	GetTract(ctx context.Context, id uuid.UUID) (Tract, error)
	GetTractRun(ctx context.Context, id uuid.UUID) (TractRun, error)
	GetTractTemplate(ctx context.Context, id uuid.UUID) (TractTemplate, error)
	GetTrigger(ctx context.Context, id uuid.UUID) (Trigger, error)
	// Webhook routing lookup: the fired webhook only knows the trigger's rotatable routing id.
	GetTriggerByTriggerUuid(ctx context.Context, triggerUuid uuid.UUID) (Trigger, error)
	GetTriggerPresetByKey(ctx context.Context, key string) (TriggerPreset, error)
	GetUserByEmail(ctx context.Context, email sql.NullString) (GetUserByEmailRow, error)
	GetUserByID(ctx context.Context, id uuid.UUID) (GetUserByIDRow, error)
	GetUserByTelegramId(ctx context.Context, telegramID string) (GetUserByTelegramIdRow, error)
	// Feature flags and subscription state are no longer joined here — callers fetch those via
	// SubscriptionService.GetEffective, since they now come from a plan+override merge rather than
	// raw columns on this row.
	GetUserDetails(ctx context.Context, id uuid.UUID) (GetUserDetailsRow, error)
	GetUserPermissions(ctx context.Context, userID uuid.UUID) (UserPermission, error)
	GetVaultByID(ctx context.Context, id uuid.UUID) (GetVaultByIDRow, error)
	GetVaultByNameAndUser(ctx context.Context, arg GetVaultByNameAndUserParams) (GetVaultByNameAndUserRow, error)
	GetVaultBySlug(ctx context.Context, slug sql.NullString) (GetVaultBySlugRow, error)
	GetVaultInviteByToken(ctx context.Context, token string) (VaultInvite, error)
	GetVaultMembership(ctx context.Context, arg GetVaultMembershipParams) (VaultMember, error)
	GetWorkbenchByVaultID(ctx context.Context, vaultID uuid.UUID) (Workbench, error)
	IncrementTractTemplateInstallCount(ctx context.Context, id uuid.UUID) error
	InsertExternalConnection(ctx context.Context, arg InsertExternalConnectionParams) (ExternalConnection, error)
	InsertMcpConnector(ctx context.Context, arg InsertMcpConnectorParams) (McpConnector, error)
	InsertMcpSpreadsheet(ctx context.Context, arg InsertMcpSpreadsheetParams) (McpSpreadsheet, error)
	InsertTract(ctx context.Context, arg InsertTractParams) (Tract, error)
	InsertTractRun(ctx context.Context, arg InsertTractRunParams) (TractRun, error)
	InsertTractRunStep(ctx context.Context, arg InsertTractRunStepParams) (TractRunStep, error)
	InsertTractTemplate(ctx context.Context, arg InsertTractTemplateParams) (TractTemplate, error)
	InsertTrigger(ctx context.Context, arg InsertTriggerParams) (Trigger, error)
	InsertTriggerProviderLink(ctx context.Context, arg InsertTriggerProviderLinkParams) error
	LinkTriggerToTract(ctx context.Context, arg LinkTriggerToTractParams) error
	LinkVaultS3Bucket(ctx context.Context, arg LinkVaultS3BucketParams) error
	ListActiveMcpKeys(ctx context.Context, vaultID uuid.UUID) ([]McpKey, error)
	ListAllMcpTools(ctx context.Context) ([]McpTool, error)
	ListCouchAccountsByUser(ctx context.Context, userID uuid.UUID) ([]CouchAccount, error)
	ListCouchInstances(ctx context.Context) ([]ListCouchInstancesRow, error)
	ListDockerHosts(ctx context.Context) ([]ListDockerHostsRow, error)
	ListExternalConnectionsByUser(ctx context.Context, userID uuid.UUID) ([]ExternalConnection, error)
	ListMailServerSuggestions(ctx context.Context, dollar_1 sql.NullString) ([]MailServerSuggestion, error)
	ListMcpConnectorsByKey(ctx context.Context, mcpKeyID uuid.UUID) ([]McpConnector, error)
	ListMcpDefinitions(ctx context.Context) ([]Mcp, error)
	ListMcpKeysByUser(ctx context.Context, userID uuid.UUID) ([]McpKey, error)
	ListMcpKeysByVault(ctx context.Context, vaultID uuid.UUID) ([]McpKey, error)
	ListMcpSpreadsheetsByUser(ctx context.Context, userID uuid.UUID) ([]McpSpreadsheet, error)
	ListMcpToolsByMcpName(ctx context.Context, mcpName string) ([]McpTool, error)
	ListS3Instances(ctx context.Context) ([]ListS3InstancesRow, error)
	ListSubscriptionPlans(ctx context.Context) ([]SubscriptionPlan, error)
	ListTractRunStepsByRun(ctx context.Context, runID uuid.UUID) ([]TractRunStep, error)
	ListTractRunsByTract(ctx context.Context, arg ListTractRunsByTractParams) ([]TractRun, error)
	ListTractTemplates(ctx context.Context, dollar_1 string) ([]TractTemplate, error)
	ListTractTemplatesByOwner(ctx context.Context, ownerID uuid.NullUUID) ([]TractTemplate, error)
	ListTractsByUser(ctx context.Context, userID uuid.UUID) ([]Tract, error)
	// tractUuid's linked triggers, Trigger populated — the tract editor's "wired up triggers" view.
	ListTriggerLinksByTract(ctx context.Context, tractID uuid.UUID) ([]ListTriggerLinksByTractRow, error)
	// triggerUuid's linked tracts, Tract populated — the webhook handler's fan-out lookup.
	ListTriggerLinksByTrigger(ctx context.Context, triggerID uuid.UUID) ([]ListTriggerLinksByTriggerRow, error)
	ListTriggerPresets(ctx context.Context) ([]TriggerPreset, error)
	// The gitlab_webhook handler's fan-out lookup: every trigger sharing one provider connection.
	ListTriggersByExternalConnection(ctx context.Context, externalConnectionID uuid.UUID) ([]Trigger, error)
	ListTriggersByUser(ctx context.Context, userID uuid.UUID) ([]Trigger, error)
	ListVaultInvites(ctx context.Context, vaultID uuid.UUID) ([]VaultInvite, error)
	ListVaultMembers(ctx context.Context, vaultID uuid.UUID) ([]VaultMember, error)
	ListVaultMembersWithUsers(ctx context.Context, vaultID uuid.UUID) ([]ListVaultMembersWithUsersRow, error)
	ListVaultsByMembership(ctx context.Context, userID uuid.UUID) ([]ListVaultsByMembershipRow, error)
	MarkWorkbenchConfiguring(ctx context.Context, vaultID uuid.UUID) error
	MarkWorkbenchContainerCreated(ctx context.Context, arg MarkWorkbenchContainerCreatedParams) error
	MarkWorkbenchRemoved(ctx context.Context, vaultID uuid.UUID) error
	MarkWorkbenchRunning(ctx context.Context, arg MarkWorkbenchRunningParams) error
	MarkWorkbenchStopped(ctx context.Context, vaultID uuid.UUID) error
	PickLeastLoadedDockerHost(ctx context.Context) (PickLeastLoadedDockerHostRow, error)
	PickOwnedCouchInstance(ctx context.Context, ownerUserID uuid.NullUUID) (PickOwnedCouchInstanceRow, error)
	PickOwnedS3Instance(ctx context.Context, ownerUserID uuid.NullUUID) (PickOwnedS3InstanceRow, error)
	PublishVault(ctx context.Context, arg PublishVaultParams) (PublishVaultRow, error)
	RandomPickCouchInstance(ctx context.Context) (RandomPickCouchInstanceRow, error)
	RandomPickS3Instance(ctx context.Context) (RandomPickS3InstanceRow, error)
	RegisterCouchInstance(ctx context.Context, arg RegisterCouchInstanceParams) (uuid.UUID, error)
	RegisterDockerHost(ctx context.Context, arg RegisterDockerHostParams) (uuid.UUID, error)
	RegisterOwnedCouchInstance(ctx context.Context, arg RegisterOwnedCouchInstanceParams) (uuid.UUID, error)
	RegisterOwnedS3Instance(ctx context.Context, arg RegisterOwnedS3InstanceParams) (uuid.UUID, error)
	RegisterS3Instance(ctx context.Context, arg RegisterS3InstanceParams) (uuid.UUID, error)
	RemoveVaultMember(ctx context.Context, arg RemoveVaultMemberParams) error
	RevokeMcpKey(ctx context.Context, id uuid.UUID) error
	RevokeVaultInvite(ctx context.Context, id uuid.UUID) error
	RotateSession(ctx context.Context, arg RotateSessionParams) (RotateSessionRow, error)
	// Invalidates the trigger's current webhook URL/token by overwriting trigger_uuid,
	// secret_hash, and token_suffix in place, keyed by the trigger's stable primary key id.
	RotateTriggerSecret(ctx context.Context, arg RotateTriggerSecretParams) (Trigger, error)
	S3InstanceExists(ctx context.Context) (bool, error)
	SetMcpKeyAccess(ctx context.Context, arg SetMcpKeyAccessParams) error
	SetSetupToken(ctx context.Context, arg SetSetupTokenParams) error
	SetTractEnabled(ctx context.Context, arg SetTractEnabledParams) error
	SetTriggerEnabled(ctx context.Context, arg SetTriggerEnabledParams) error
	SetVaultLiveSyncPassphrase(ctx context.Context, arg SetVaultLiveSyncPassphraseParams) error
	SetVaultUseCouchDBForBinaries(ctx context.Context, arg SetVaultUseCouchDBForBinariesParams) error
	SweepStaleTractRunSteps(ctx context.Context, startedAt time.Time) error
	SweepStaleTractRuns(ctx context.Context, createdAt time.Time) error
	TouchMcpKeyLastAccessed(ctx context.Context, id uuid.UUID) error
	UnlinkTriggerFromTract(ctx context.Context, arg UnlinkTriggerFromTractParams) error
	UnlinkVaultS3Bucket(ctx context.Context, id uuid.UUID) error
	UnpublishVault(ctx context.Context, id uuid.UUID) error
	UpdateCouchAccountPassword(ctx context.Context, arg UpdateCouchAccountPasswordParams) error
	UpdateCouchInstance(ctx context.Context, arg UpdateCouchInstanceParams) error
	// ca_cert_enc/client_cert_enc/client_key_enc are three-way patch fields: the matching
	// update_* boolean is false when the caller didn't touch that cert (leave the stored value
	// alone), true with a NULL value when the caller cleared it, true with a value when the caller
	// set/replaced it. See internal/repository/pg/repos/dockerhosts/dockerhosts.go's Update.
	UpdateDockerHost(ctx context.Context, arg UpdateDockerHostParams) error
	UpdateS3Instance(ctx context.Context, arg UpdateS3InstanceParams) error
	UpdateSystemSettingsAuthMethods(ctx context.Context, arg UpdateSystemSettingsAuthMethodsParams) error
	UpdateSystemSettingsRegistrationMode(ctx context.Context, registrationMode string) error
	UpdateTract(ctx context.Context, arg UpdateTractParams) (Tract, error)
	UpdateTractRunStatus(ctx context.Context, arg UpdateTractRunStatusParams) error
	UpdateTractRunStepFinish(ctx context.Context, arg UpdateTractRunStepFinishParams) error
	UpdateUserPasswordHash(ctx context.Context, arg UpdateUserPasswordHashParams) error
	UpdateUserPhotoUrl(ctx context.Context, arg UpdateUserPhotoUrlParams) error
	UpdateVaultStatus(ctx context.Context, arg UpdateVaultStatusParams) error
	UpsertCouchAccount(ctx context.Context, arg UpsertCouchAccountParams) error
	UpsertExternalConnection(ctx context.Context, arg UpsertExternalConnectionParams) (ExternalConnection, error)
	UpsertMcpDefinition(ctx context.Context, arg UpsertMcpDefinitionParams) (Mcp, error)
	UpsertMcpTool(ctx context.Context, arg UpsertMcpToolParams) (McpTool, error)
	UpsertSubscription(ctx context.Context, arg UpsertSubscriptionParams) (Subscription, error)
	UpsertSubscriptionOverrides(ctx context.Context, arg UpsertSubscriptionOverridesParams) (Subscription, error)
	UpsertTelegramIdentity(ctx context.Context, arg UpsertTelegramIdentityParams) error
	UpsertUserPermissions(ctx context.Context, arg UpsertUserPermissionsParams) (UserPermission, error)
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) AddVaultMember 

func (q *Queries) AddVaultMember(ctx context.Context, arg AddVaultMemberParams) error

func (*Queries) CompleteSetup 

func (q *Queries) CompleteSetup(ctx context.Context) error

func (*Queries) CouchInstanceExists 

func (q *Queries) CouchInstanceExists(ctx context.Context) (bool, error)

func (*Queries) CreateByUsername 

func (q *Queries) CreateByUsername(ctx context.Context, arg CreateByUsernameParams) (CreateByUsernameRow, error)

func (*Queries) CreateDefaultSubscription 

func (q *Queries) CreateDefaultSubscription(ctx context.Context, userID uuid.UUID) error

func (*Queries) CreateDefaultUserPermissions 

func (q *Queries) CreateDefaultUserPermissions(ctx context.Context, userID uuid.UUID) error

func (*Queries) CreateMcpKey 

func (q *Queries) CreateMcpKey(ctx context.Context, arg CreateMcpKeyParams) (McpKey, error)

func (*Queries) CreatePendingAuthCode 

func (q *Queries) CreatePendingAuthCode(ctx context.Context, arg CreatePendingAuthCodeParams) error

func (*Queries) CreateSession 

func (q *Queries) CreateSession(ctx context.Context, arg CreateSessionParams) (CreateSessionRow, error)

func (*Queries) CreateUser 

func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) (CreateUserRow, error)

func (*Queries) CreateVault 

func (q *Queries) CreateVault(ctx context.Context, arg CreateVaultParams) (CreateVaultRow, error)

func (*Queries) CreateVaultInvite 

func (q *Queries) CreateVaultInvite(ctx context.Context, arg CreateVaultInviteParams) (VaultInvite, error)

func (*Queries) CreateWorkbench 

func (q *Queries) CreateWorkbench(ctx context.Context, arg CreateWorkbenchParams) (Workbench, error)

func (*Queries) DeleteCouchAccount 

func (q *Queries) DeleteCouchAccount(ctx context.Context, id uuid.UUID) error

func (*Queries) DeleteCouchInstance 

func (q *Queries) DeleteCouchInstance(ctx context.Context, id uuid.UUID) error

func (*Queries) DeleteDockerHost 

func (q *Queries) DeleteDockerHost(ctx context.Context, id uuid.UUID) error

func (*Queries) DeleteExpiredPendingAuthCodes 

func (q *Queries) DeleteExpiredPendingAuthCodes(ctx context.Context) error

func (*Queries) DeleteExternalConnection 

func (q *Queries) DeleteExternalConnection(ctx context.Context, arg DeleteExternalConnectionParams) error

func (*Queries) DeleteExternalConnectionByID 

func (q *Queries) DeleteExternalConnectionByID(ctx context.Context, arg DeleteExternalConnectionByIDParams) error

func (*Queries) DeleteMcpConnector 

func (q *Queries) DeleteMcpConnector(ctx context.Context, arg DeleteMcpConnectorParams) error

func (*Queries) DeleteMcpDefinition 

func (q *Queries) DeleteMcpDefinition(ctx context.Context, name string) error

func (*Queries) DeleteMcpSpreadsheet 

func (q *Queries) DeleteMcpSpreadsheet(ctx context.Context, arg DeleteMcpSpreadsheetParams) error

func (*Queries) DeleteOwnedCouchInstanceIfUnreferenced 

func (q *Queries) DeleteOwnedCouchInstanceIfUnreferenced(ctx context.Context, ownerUserID uuid.NullUUID) error

func (*Queries) DeleteOwnedS3InstanceIfUnreferenced 

func (q *Queries) DeleteOwnedS3InstanceIfUnreferenced(ctx context.Context, ownerUserID uuid.NullUUID) error

func (*Queries) DeletePendingAuthCode 

func (q *Queries) DeletePendingAuthCode(ctx context.Context, code string) error

func (*Queries) DeleteS3Instance 

func (q *Queries) DeleteS3Instance(ctx context.Context, id uuid.UUID) error

func (*Queries) DeleteSession 

func (q *Queries) DeleteSession(ctx context.Context, token string) error

func (*Queries) DeleteTract 

func (q *Queries) DeleteTract(ctx context.Context, id uuid.UUID) error

func (*Queries) DeleteTractTemplate 

func (q *Queries) DeleteTractTemplate(ctx context.Context, id uuid.UUID) error

func (*Queries) DeleteTrigger 

func (q *Queries) DeleteTrigger(ctx context.Context, id uuid.UUID) error

func (*Queries) DeleteUser 

func (q *Queries) DeleteUser(ctx context.Context, id uuid.UUID) error

func (*Queries) DeleteVault 

func (q *Queries) DeleteVault(ctx context.Context, id uuid.UUID) error

func (*Queries) DeleteWorkbench 

func (q *Queries) DeleteWorkbench(ctx context.Context, vaultID uuid.UUID) error

func (*Queries) DockerHostExists 

func (q *Queries) DockerHostExists(ctx context.Context) (bool, error)

func (*Queries) GetCouchAccountByUserAndInstance 

func (q *Queries) GetCouchAccountByUserAndInstance(ctx context.Context, arg GetCouchAccountByUserAndInstanceParams) (CouchAccount, error)

func (*Queries) GetCouchInstance 

func (q *Queries) GetCouchInstance(ctx context.Context, id uuid.UUID) (GetCouchInstanceRow, error)

func (*Queries) GetCouchInstanceWithCreds 

func (q *Queries) GetCouchInstanceWithCreds(ctx context.Context, id uuid.UUID) (GetCouchInstanceWithCredsRow, error)

func (*Queries) GetDockerHost 

func (q *Queries) GetDockerHost(ctx context.Context, id uuid.UUID) (GetDockerHostRow, error)

func (*Queries) GetDockerHostWithCreds 

func (q *Queries) GetDockerHostWithCreds(ctx context.Context, id uuid.UUID) (DockerHost, error)

func (*Queries) GetExternalConnectionByID 

func (q *Queries) GetExternalConnectionByID(ctx context.Context, id uuid.UUID) (ExternalConnection, error)

func (*Queries) GetExternalConnectionByUserAndProvider 

func (q *Queries) GetExternalConnectionByUserAndProvider(ctx context.Context, arg GetExternalConnectionByUserAndProviderParams) (ExternalConnection, error)

func (*Queries) GetMcpConnector 

func (q *Queries) GetMcpConnector(ctx context.Context, arg GetMcpConnectorParams) (McpConnector, error)

func (*Queries) GetMcpDefinition 

func (q *Queries) GetMcpDefinition(ctx context.Context, name string) (Mcp, error)

func (*Queries) GetMcpKeyByID 

func (q *Queries) GetMcpKeyByID(ctx context.Context, id uuid.UUID) (McpKey, error)

func (*Queries) GetMcpTool 

func (q *Queries) GetMcpTool(ctx context.Context, arg GetMcpToolParams) (McpTool, error)

func (*Queries) GetPendingAuthCode 

func (q *Queries) GetPendingAuthCode(ctx context.Context, code string) (PendingAuthCode, error)

func (*Queries) GetS3Instance 

func (q *Queries) GetS3Instance(ctx context.Context, id uuid.UUID) (GetS3InstanceRow, error)

func (*Queries) GetS3InstanceWithCreds 

func (q *Queries) GetS3InstanceWithCreds(ctx context.Context, id uuid.UUID) (GetS3InstanceWithCredsRow, error)

func (*Queries) GetSessionByToken 

func (q *Queries) GetSessionByToken(ctx context.Context, token string) (GetSessionByTokenRow, error)

func (*Queries) GetSessionWithUser 

func (q *Queries) GetSessionWithUser(ctx context.Context, token string) (GetSessionWithUserRow, error)

func (*Queries) GetSessionsByUserID 

func (q *Queries) GetSessionsByUserID(ctx context.Context, userID uuid.UUID) ([]Session, error)

func (*Queries) GetSubscriptionByUser 

func (q *Queries) GetSubscriptionByUser(ctx context.Context, userID uuid.UUID) (Subscription, error)

func (*Queries) GetSubscriptionPlan 

func (q *Queries) GetSubscriptionPlan(ctx context.Context, planKey string) (SubscriptionPlan, error)

func (*Queries) GetSubscriptionWithPlan 

func (q *Queries) GetSubscriptionWithPlan(ctx context.Context, userID uuid.UUID) (GetSubscriptionWithPlanRow, error)

func (*Queries) GetSystemSettings 

func (q *Queries) GetSystemSettings(ctx context.Context) (SystemSetting, error)

func (*Queries) GetSystemSettingsForUpdate 

func (q *Queries) GetSystemSettingsForUpdate(ctx context.Context) (SystemSetting, error)

func (*Queries) GetTelegramPhotoUrlByUserId 

func (q *Queries) GetTelegramPhotoUrlByUserId(ctx context.Context, id uuid.UUID) (string, error)

func (*Queries) GetTract 

func (q *Queries) GetTract(ctx context.Context, id uuid.UUID) (Tract, error)

func (*Queries) GetTractRun 

func (q *Queries) GetTractRun(ctx context.Context, id uuid.UUID) (TractRun, error)

func (*Queries) GetTractTemplate 

func (q *Queries) GetTractTemplate(ctx context.Context, id uuid.UUID) (TractTemplate, error)

func (*Queries) GetTrigger 

func (q *Queries) GetTrigger(ctx context.Context, id uuid.UUID) (Trigger, error)

func (*Queries) GetTriggerByTriggerUuid 

func (q *Queries) GetTriggerByTriggerUuid(ctx context.Context, triggerUuid uuid.UUID) (Trigger, error)

Webhook routing lookup: the fired webhook only knows the trigger's rotatable routing id.

func (*Queries) GetTriggerPresetByKey 

func (q *Queries) GetTriggerPresetByKey(ctx context.Context, key string) (TriggerPreset, error)

func (*Queries) GetUserByEmail 

func (q *Queries) GetUserByEmail(ctx context.Context, email sql.NullString) (GetUserByEmailRow, error)

func (*Queries) GetUserByID 

func (q *Queries) GetUserByID(ctx context.Context, id uuid.UUID) (GetUserByIDRow, error)

func (*Queries) GetUserByTelegramId 

func (q *Queries) GetUserByTelegramId(ctx context.Context, telegramID string) (GetUserByTelegramIdRow, error)

func (*Queries) GetUserDetails 

func (q *Queries) GetUserDetails(ctx context.Context, id uuid.UUID) (GetUserDetailsRow, error)

Feature flags and subscription state are no longer joined here — callers fetch those via SubscriptionService.GetEffective, since they now come from a plan+override merge rather than raw columns on this row.

func (*Queries) GetUserPermissions 

func (q *Queries) GetUserPermissions(ctx context.Context, userID uuid.UUID) (UserPermission, error)

func (*Queries) GetVaultByID 

func (q *Queries) GetVaultByID(ctx context.Context, id uuid.UUID) (GetVaultByIDRow, error)

func (*Queries) GetVaultByNameAndUser 

func (q *Queries) GetVaultByNameAndUser(ctx context.Context, arg GetVaultByNameAndUserParams) (GetVaultByNameAndUserRow, error)

func (*Queries) GetVaultBySlug 

func (q *Queries) GetVaultBySlug(ctx context.Context, slug sql.NullString) (GetVaultBySlugRow, error)

func (*Queries) GetVaultInviteByToken 

func (q *Queries) GetVaultInviteByToken(ctx context.Context, token string) (VaultInvite, error)

func (*Queries) GetVaultMembership 

func (q *Queries) GetVaultMembership(ctx context.Context, arg GetVaultMembershipParams) (VaultMember, error)

func (*Queries) GetWorkbenchByVaultID 

func (q *Queries) GetWorkbenchByVaultID(ctx context.Context, vaultID uuid.UUID) (Workbench, error)

func (*Queries) IncrementTractTemplateInstallCount 

func (q *Queries) IncrementTractTemplateInstallCount(ctx context.Context, id uuid.UUID) error

func (*Queries) InsertExternalConnection 

func (q *Queries) InsertExternalConnection(ctx context.Context, arg InsertExternalConnectionParams) (ExternalConnection, error)

func (*Queries) InsertMcpConnector 

func (q *Queries) InsertMcpConnector(ctx context.Context, arg InsertMcpConnectorParams) (McpConnector, error)

func (*Queries) InsertMcpSpreadsheet 

func (q *Queries) InsertMcpSpreadsheet(ctx context.Context, arg InsertMcpSpreadsheetParams) (McpSpreadsheet, error)

func (*Queries) InsertTract 

func (q *Queries) InsertTract(ctx context.Context, arg InsertTractParams) (Tract, error)

func (*Queries) InsertTractRun 

func (q *Queries) InsertTractRun(ctx context.Context, arg InsertTractRunParams) (TractRun, error)

func (*Queries) InsertTractRunStep 

func (q *Queries) InsertTractRunStep(ctx context.Context, arg InsertTractRunStepParams) (TractRunStep, error)

func (*Queries) InsertTractTemplate 

func (q *Queries) InsertTractTemplate(ctx context.Context, arg InsertTractTemplateParams) (TractTemplate, error)

func (*Queries) InsertTrigger 

func (q *Queries) InsertTrigger(ctx context.Context, arg InsertTriggerParams) (Trigger, error)
func (q *Queries) InsertTriggerProviderLink(ctx context.Context, arg InsertTriggerProviderLinkParams) error

func (*Queries) LinkTriggerToTract 

func (q *Queries) LinkTriggerToTract(ctx context.Context, arg LinkTriggerToTractParams) error

func (*Queries) LinkVaultS3Bucket 

func (q *Queries) LinkVaultS3Bucket(ctx context.Context, arg LinkVaultS3BucketParams) error

func (*Queries) ListActiveMcpKeys 

func (q *Queries) ListActiveMcpKeys(ctx context.Context, vaultID uuid.UUID) ([]McpKey, error)

func (*Queries) ListAllMcpTools 

func (q *Queries) ListAllMcpTools(ctx context.Context) ([]McpTool, error)

func (*Queries) ListCouchAccountsByUser 

func (q *Queries) ListCouchAccountsByUser(ctx context.Context, userID uuid.UUID) ([]CouchAccount, error)

func (*Queries) ListCouchInstances 

func (q *Queries) ListCouchInstances(ctx context.Context) ([]ListCouchInstancesRow, error)

func (*Queries) ListDockerHosts 

func (q *Queries) ListDockerHosts(ctx context.Context) ([]ListDockerHostsRow, error)

func (*Queries) ListExternalConnectionsByUser 

func (q *Queries) ListExternalConnectionsByUser(ctx context.Context, userID uuid.UUID) ([]ExternalConnection, error)

func (*Queries) ListMailServerSuggestions 

func (q *Queries) ListMailServerSuggestions(ctx context.Context, dollar_1 sql.NullString) ([]MailServerSuggestion, error)

func (*Queries) ListMcpConnectorsByKey 

func (q *Queries) ListMcpConnectorsByKey(ctx context.Context, mcpKeyID uuid.UUID) ([]McpConnector, error)

func (*Queries) ListMcpDefinitions 

func (q *Queries) ListMcpDefinitions(ctx context.Context) ([]Mcp, error)

func (*Queries) ListMcpKeysByUser 

func (q *Queries) ListMcpKeysByUser(ctx context.Context, userID uuid.UUID) ([]McpKey, error)

func (*Queries) ListMcpKeysByVault 

func (q *Queries) ListMcpKeysByVault(ctx context.Context, vaultID uuid.UUID) ([]McpKey, error)

func (*Queries) ListMcpSpreadsheetsByUser 

func (q *Queries) ListMcpSpreadsheetsByUser(ctx context.Context, userID uuid.UUID) ([]McpSpreadsheet, error)

func (*Queries) ListMcpToolsByMcpName 

func (q *Queries) ListMcpToolsByMcpName(ctx context.Context, mcpName string) ([]McpTool, error)

func (*Queries) ListS3Instances 

func (q *Queries) ListS3Instances(ctx context.Context) ([]ListS3InstancesRow, error)

func (*Queries) ListSubscriptionPlans 

func (q *Queries) ListSubscriptionPlans(ctx context.Context) ([]SubscriptionPlan, error)

func (*Queries) ListTractRunStepsByRun 

func (q *Queries) ListTractRunStepsByRun(ctx context.Context, runID uuid.UUID) ([]TractRunStep, error)

func (*Queries) ListTractRunsByTract 

func (q *Queries) ListTractRunsByTract(ctx context.Context, arg ListTractRunsByTractParams) ([]TractRun, error)

func (*Queries) ListTractTemplates 

func (q *Queries) ListTractTemplates(ctx context.Context, dollar_1 string) ([]TractTemplate, error)

func (*Queries) ListTractTemplatesByOwner 

func (q *Queries) ListTractTemplatesByOwner(ctx context.Context, ownerID uuid.NullUUID) ([]TractTemplate, error)

func (*Queries) ListTractsByUser 

func (q *Queries) ListTractsByUser(ctx context.Context, userID uuid.UUID) ([]Tract, error)

func (*Queries) ListTriggerLinksByTract 

func (q *Queries) ListTriggerLinksByTract(ctx context.Context, tractID uuid.UUID) ([]ListTriggerLinksByTractRow, error)

tractUuid's linked triggers, Trigger populated — the tract editor's "wired up triggers" view.

func (*Queries) ListTriggerLinksByTrigger 

func (q *Queries) ListTriggerLinksByTrigger(ctx context.Context, triggerID uuid.UUID) ([]ListTriggerLinksByTriggerRow, error)

triggerUuid's linked tracts, Tract populated — the webhook handler's fan-out lookup.

func (*Queries) ListTriggerPresets 

func (q *Queries) ListTriggerPresets(ctx context.Context) ([]TriggerPreset, error)

func (*Queries) ListTriggersByExternalConnection 

func (q *Queries) ListTriggersByExternalConnection(ctx context.Context, externalConnectionID uuid.UUID) ([]Trigger, error)

The gitlab_webhook handler's fan-out lookup: every trigger sharing one provider connection.

func (*Queries) ListTriggersByUser 

func (q *Queries) ListTriggersByUser(ctx context.Context, userID uuid.UUID) ([]Trigger, error)

func (*Queries) ListVaultInvites 

func (q *Queries) ListVaultInvites(ctx context.Context, vaultID uuid.UUID) ([]VaultInvite, error)

func (*Queries) ListVaultMembers 

func (q *Queries) ListVaultMembers(ctx context.Context, vaultID uuid.UUID) ([]VaultMember, error)

func (*Queries) ListVaultMembersWithUsers 

func (q *Queries) ListVaultMembersWithUsers(ctx context.Context, vaultID uuid.UUID) ([]ListVaultMembersWithUsersRow, error)

func (*Queries) ListVaultsByMembership 

func (q *Queries) ListVaultsByMembership(ctx context.Context, userID uuid.UUID) ([]ListVaultsByMembershipRow, error)

func (*Queries) MarkWorkbenchConfiguring 

func (q *Queries) MarkWorkbenchConfiguring(ctx context.Context, vaultID uuid.UUID) error

func (*Queries) MarkWorkbenchContainerCreated 

func (q *Queries) MarkWorkbenchContainerCreated(ctx context.Context, arg MarkWorkbenchContainerCreatedParams) error

func (*Queries) MarkWorkbenchRemoved 

func (q *Queries) MarkWorkbenchRemoved(ctx context.Context, vaultID uuid.UUID) error

func (*Queries) MarkWorkbenchRunning 

func (q *Queries) MarkWorkbenchRunning(ctx context.Context, arg MarkWorkbenchRunningParams) error

func (*Queries) MarkWorkbenchStopped 

func (q *Queries) MarkWorkbenchStopped(ctx context.Context, vaultID uuid.UUID) error

func (*Queries) PickLeastLoadedDockerHost 

func (q *Queries) PickLeastLoadedDockerHost(ctx context.Context) (PickLeastLoadedDockerHostRow, error)

func (*Queries) PickOwnedCouchInstance 

func (q *Queries) PickOwnedCouchInstance(ctx context.Context, ownerUserID uuid.NullUUID) (PickOwnedCouchInstanceRow, error)

func (*Queries) PickOwnedS3Instance 

func (q *Queries) PickOwnedS3Instance(ctx context.Context, ownerUserID uuid.NullUUID) (PickOwnedS3InstanceRow, error)

func (*Queries) PublishVault 

func (q *Queries) PublishVault(ctx context.Context, arg PublishVaultParams) (PublishVaultRow, error)

func (*Queries) RandomPickCouchInstance 

func (q *Queries) RandomPickCouchInstance(ctx context.Context) (RandomPickCouchInstanceRow, error)

func (*Queries) RandomPickS3Instance 

func (q *Queries) RandomPickS3Instance(ctx context.Context) (RandomPickS3InstanceRow, error)

func (*Queries) RegisterCouchInstance 

func (q *Queries) RegisterCouchInstance(ctx context.Context, arg RegisterCouchInstanceParams) (uuid.UUID, error)

func (*Queries) RegisterDockerHost 

func (q *Queries) RegisterDockerHost(ctx context.Context, arg RegisterDockerHostParams) (uuid.UUID, error)

func (*Queries) RegisterOwnedCouchInstance 

func (q *Queries) RegisterOwnedCouchInstance(ctx context.Context, arg RegisterOwnedCouchInstanceParams) (uuid.UUID, error)

func (*Queries) RegisterOwnedS3Instance 

func (q *Queries) RegisterOwnedS3Instance(ctx context.Context, arg RegisterOwnedS3InstanceParams) (uuid.UUID, error)

func (*Queries) RegisterS3Instance 

func (q *Queries) RegisterS3Instance(ctx context.Context, arg RegisterS3InstanceParams) (uuid.UUID, error)

func (*Queries) RemoveVaultMember 

func (q *Queries) RemoveVaultMember(ctx context.Context, arg RemoveVaultMemberParams) error

func (*Queries) RevokeMcpKey 

func (q *Queries) RevokeMcpKey(ctx context.Context, id uuid.UUID) error

func (*Queries) RevokeVaultInvite 

func (q *Queries) RevokeVaultInvite(ctx context.Context, id uuid.UUID) error

func (*Queries) RotateSession 

func (q *Queries) RotateSession(ctx context.Context, arg RotateSessionParams) (RotateSessionRow, error)

func (*Queries) RotateTriggerSecret 

func (q *Queries) RotateTriggerSecret(ctx context.Context, arg RotateTriggerSecretParams) (Trigger, error)

Invalidates the trigger's current webhook URL/token by overwriting trigger_uuid, secret_hash, and token_suffix in place, keyed by the trigger's stable primary key id.

func (*Queries) S3InstanceExists 

func (q *Queries) S3InstanceExists(ctx context.Context) (bool, error)

func (*Queries) SetMcpKeyAccess 

func (q *Queries) SetMcpKeyAccess(ctx context.Context, arg SetMcpKeyAccessParams) error

func (*Queries) SetSetupToken 

func (q *Queries) SetSetupToken(ctx context.Context, arg SetSetupTokenParams) error

func (*Queries) SetTractEnabled 

func (q *Queries) SetTractEnabled(ctx context.Context, arg SetTractEnabledParams) error

func (*Queries) SetTriggerEnabled 

func (q *Queries) SetTriggerEnabled(ctx context.Context, arg SetTriggerEnabledParams) error

func (*Queries) SetVaultLiveSyncPassphrase 

func (q *Queries) SetVaultLiveSyncPassphrase(ctx context.Context, arg SetVaultLiveSyncPassphraseParams) error

func (*Queries) SetVaultUseCouchDBForBinaries 

func (q *Queries) SetVaultUseCouchDBForBinaries(ctx context.Context, arg SetVaultUseCouchDBForBinariesParams) error

func (*Queries) SweepStaleTractRunSteps 

func (q *Queries) SweepStaleTractRunSteps(ctx context.Context, startedAt time.Time) error

func (*Queries) SweepStaleTractRuns 

func (q *Queries) SweepStaleTractRuns(ctx context.Context, createdAt time.Time) error

func (*Queries) TouchMcpKeyLastAccessed 

func (q *Queries) TouchMcpKeyLastAccessed(ctx context.Context, id uuid.UUID) error

func (*Queries) UnlinkTriggerFromTract 

func (q *Queries) UnlinkTriggerFromTract(ctx context.Context, arg UnlinkTriggerFromTractParams) error

func (*Queries) UnlinkVaultS3Bucket 

func (q *Queries) UnlinkVaultS3Bucket(ctx context.Context, id uuid.UUID) error

func (*Queries) UnpublishVault 

func (q *Queries) UnpublishVault(ctx context.Context, id uuid.UUID) error

func (*Queries) UpdateCouchAccountPassword 

func (q *Queries) UpdateCouchAccountPassword(ctx context.Context, arg UpdateCouchAccountPasswordParams) error

func (*Queries) UpdateCouchInstance 

func (q *Queries) UpdateCouchInstance(ctx context.Context, arg UpdateCouchInstanceParams) error

func (*Queries) UpdateDockerHost 

func (q *Queries) UpdateDockerHost(ctx context.Context, arg UpdateDockerHostParams) error

ca_cert_enc/client_cert_enc/client_key_enc are three-way patch fields: the matching update_* boolean is false when the caller didn't touch that cert (leave the stored value alone), true with a NULL value when the caller cleared it, true with a value when the caller set/replaced it. See internal/repository/pg/repos/dockerhosts/dockerhosts.go's Update.

func (*Queries) UpdateS3Instance 

func (q *Queries) UpdateS3Instance(ctx context.Context, arg UpdateS3InstanceParams) error

func (*Queries) UpdateSystemSettingsAuthMethods 

func (q *Queries) UpdateSystemSettingsAuthMethods(ctx context.Context, arg UpdateSystemSettingsAuthMethodsParams) error

func (*Queries) UpdateSystemSettingsRegistrationMode 

func (q *Queries) UpdateSystemSettingsRegistrationMode(ctx context.Context, registrationMode string) error

func (*Queries) UpdateTract 

func (q *Queries) UpdateTract(ctx context.Context, arg UpdateTractParams) (Tract, error)

func (*Queries) UpdateTractRunStatus 

func (q *Queries) UpdateTractRunStatus(ctx context.Context, arg UpdateTractRunStatusParams) error

func (*Queries) UpdateTractRunStepFinish 

func (q *Queries) UpdateTractRunStepFinish(ctx context.Context, arg UpdateTractRunStepFinishParams) error

func (*Queries) UpdateUserPasswordHash 

func (q *Queries) UpdateUserPasswordHash(ctx context.Context, arg UpdateUserPasswordHashParams) error

func (*Queries) UpdateUserPhotoUrl 

func (q *Queries) UpdateUserPhotoUrl(ctx context.Context, arg UpdateUserPhotoUrlParams) error

func (*Queries) UpdateVaultStatus 

func (q *Queries) UpdateVaultStatus(ctx context.Context, arg UpdateVaultStatusParams) error

func (*Queries) UpsertCouchAccount 

func (q *Queries) UpsertCouchAccount(ctx context.Context, arg UpsertCouchAccountParams) error

func (*Queries) UpsertExternalConnection 

func (q *Queries) UpsertExternalConnection(ctx context.Context, arg UpsertExternalConnectionParams) (ExternalConnection, error)

func (*Queries) UpsertMcpDefinition 

func (q *Queries) UpsertMcpDefinition(ctx context.Context, arg UpsertMcpDefinitionParams) (Mcp, error)

func (*Queries) UpsertMcpTool 

func (q *Queries) UpsertMcpTool(ctx context.Context, arg UpsertMcpToolParams) (McpTool, error)

func (*Queries) UpsertSubscription 

func (q *Queries) UpsertSubscription(ctx context.Context, arg UpsertSubscriptionParams) (Subscription, error)

func (*Queries) UpsertSubscriptionOverrides 

func (q *Queries) UpsertSubscriptionOverrides(ctx context.Context, arg UpsertSubscriptionOverridesParams) (Subscription, error)

func (*Queries) UpsertTelegramIdentity 

func (q *Queries) UpsertTelegramIdentity(ctx context.Context, arg UpsertTelegramIdentityParams) error

func (*Queries) UpsertUserPermissions 

func (q *Queries) UpsertUserPermissions(ctx context.Context, arg UpsertUserPermissionsParams) (UserPermission, error)

func (*Queries) WithTx 

func (q *Queries) WithTx(tx *sql.Tx) *Queries

type RandomPickCouchInstanceRow 

type RandomPickCouchInstanceRow struct {
	ID          uuid.UUID
	Url         string
	Username    string
	PasswordEnc []byte
	CreatedAt   time.Time
}

type RandomPickS3InstanceRow 

type RandomPickS3InstanceRow struct {
	ID           uuid.UUID
	Endpoint     string
	Region       string
	AccessKey    string
	SecretKeyEnc []byte
	UseSsl       bool
	PathStyle    bool
	CreatedAt    time.Time
}

type RegisterCouchInstanceParams 

type RegisterCouchInstanceParams struct {
	Url         string
	Username    string
	PasswordEnc []byte
}

type RegisterDockerHostParams 

type RegisterDockerHostParams struct {
	Url           string
	CaCertEnc     []byte
	ClientCertEnc []byte
	ClientKeyEnc  []byte
}

type RegisterOwnedCouchInstanceParams 

type RegisterOwnedCouchInstanceParams struct {
	Url         string
	Username    string
	PasswordEnc []byte
	OwnerUserID uuid.NullUUID
}

type RegisterOwnedS3InstanceParams 

type RegisterOwnedS3InstanceParams struct {
	Endpoint     string
	Region       string
	AccessKey    string
	SecretKeyEnc []byte
	UseSsl       bool
	PathStyle    bool
	OwnerUserID  uuid.NullUUID
}

type RegisterS3InstanceParams 

type RegisterS3InstanceParams struct {
	Endpoint     string
	Region       string
	AccessKey    string
	SecretKeyEnc []byte
	UseSsl       bool
	PathStyle    bool
}

type RemoveVaultMemberParams 

type RemoveVaultMemberParams struct {
	VaultID uuid.UUID
	UserID  uuid.UUID
}

type RotateSessionParams 

type RotateSessionParams struct {
	RefreshToken     sql.NullString
	Token            string
	ExpiresAt        time.Time
	RefreshToken_2   sql.NullString
	RefreshExpiresAt sql.NullTime
}

type RotateSessionRow 

type RotateSessionRow struct {
	ID               uuid.UUID
	UserID           uuid.UUID
	Token            string
	ExpiresAt        time.Time
	RefreshToken     sql.NullString
	RefreshExpiresAt sql.NullTime
	CreatedAt        time.Time
}

type RotateTriggerSecretParams 

type RotateTriggerSecretParams struct {
	ID          uuid.UUID
	TriggerUuid uuid.UUID
	SecretHash  []byte
	TokenSuffix sql.NullString
}

type S3Instance 

type S3Instance struct {
	ID           uuid.UUID
	Endpoint     string
	Region       string
	AccessKey    string
	SecretKeyEnc []byte
	UseSsl       bool
	PathStyle    bool
	CreatedAt    time.Time
	OwnerUserID  uuid.NullUUID
}

type Session 

type Session struct {
	ID               uuid.UUID
	UserID           uuid.UUID
	Token            string
	ExpiresAt        time.Time
	CreatedAt        time.Time
	RefreshToken     sql.NullString
	RefreshExpiresAt sql.NullTime
}

type SetMcpKeyAccessParams 

type SetMcpKeyAccessParams struct {
	ID      uuid.UUID
	VaultID uuid.UUID
	UserID  uuid.UUID
}

type SetSetupTokenParams 

type SetSetupTokenParams struct {
	SetupTokenHash     sql.NullString
	SetupTokenIssuedAt sql.NullTime
}

type SetTractEnabledParams 

type SetTractEnabledParams struct {
	ID      uuid.UUID
	Enabled bool
}

type SetTriggerEnabledParams 

type SetTriggerEnabledParams struct {
	ID      uuid.UUID
	Enabled bool
}

type SetVaultLiveSyncPassphraseParams 

type SetVaultLiveSyncPassphraseParams struct {
	ID                    uuid.UUID
	LivesyncPassphraseEnc []byte
}

type SetVaultUseCouchDBForBinariesParams 

type SetVaultUseCouchDBForBinariesParams struct {
	ID                    uuid.UUID
	UseCouchdbForBinaries bool
}

type Subscription 

type Subscription struct {
	UserID                  uuid.UUID
	Active                  bool
	PlanKey                 string
	FeatureOverrides        json.RawMessage
	CouchQuotaOverrideBytes sql.NullInt64
	S3QuotaOverrideBytes    sql.NullInt64
}

type SubscriptionPlan 

type SubscriptionPlan struct {
	PlanKey         string
	CouchQuotaBytes int64
	S3QuotaBytes    int64
	Features        json.RawMessage
	CreatedAt       time.Time
	UpdatedAt       time.Time
}

type SystemSetting 

type SystemSetting struct {
	ID                  int16
	SetupCompleted      bool
	PasswordAuthEnabled bool
	TelegramAuthEnabled bool
	RegistrationMode    string
	SetupTokenHash      sql.NullString
	SetupTokenIssuedAt  sql.NullTime
	CreatedAt           time.Time
	UpdatedAt           time.Time
}

type Tract 

type Tract struct {
	ID          uuid.UUID
	UserID      uuid.UUID
	Name        string
	Description string
	Enabled     bool
	Definition  json.RawMessage
	CreatedAt   time.Time
	UpdatedAt   time.Time
}

type TractRun 

type TractRun struct {
	ID            uuid.UUID
	TractID       uuid.UUID
	TriggerID     uuid.NullUUID
	StartedBy     string
	Status        TractRunStatus
	TriggerOutput json.RawMessage
	Error         sql.NullString
	CreatedAt     time.Time
	UpdatedAt     time.Time
}

type TractRunStatus 

type TractRunStatus string
const (
	TractRunStatusRunning TractRunStatus = "running"
	TractRunStatusDone    TractRunStatus = "done"
	TractRunStatusFailed  TractRunStatus = "failed"
)

func (*TractRunStatus) Scan 

func (e *TractRunStatus) Scan(src interface{}) error

type TractRunStep 

type TractRunStep struct {
	ID         uuid.UUID
	RunID      uuid.UUID
	StepID     string
	StepName   string
	StepType   string
	Input      pqtype.NullRawMessage
	Output     pqtype.NullRawMessage
	Status     TractRunStepStatus
	Error      sql.NullString
	StartedAt  time.Time
	FinishedAt sql.NullTime
}

type TractRunStepStatus 

type TractRunStepStatus string
const (
	TractRunStepStatusRunning TractRunStepStatus = "running"
	TractRunStepStatusDone    TractRunStepStatus = "done"
	TractRunStepStatusFailed  TractRunStepStatus = "failed"
)

func (*TractRunStepStatus) Scan 

func (e *TractRunStepStatus) Scan(src interface{}) error

type TractTemplate 

type TractTemplate struct {
	ID            uuid.UUID
	SourceTractID uuid.NullUUID
	OwnerID       uuid.NullUUID
	Name          string
	Description   string
	Definition    json.RawMessage
	Category      string
	InstallCount  int32
	PublishedAt   time.Time
	UpdatedAt     time.Time
}
type TractTriggerLink struct {
	TractID   uuid.UUID
	TriggerID uuid.UUID
	Filters   json.RawMessage
	CreatedAt time.Time
}

type Trigger 

type Trigger struct {
	ID            uuid.UUID
	TriggerUuid   uuid.UUID
	UserID        uuid.UUID
	Name          string
	Kind          string
	Source        string
	Config        json.RawMessage
	PayloadSchema json.RawMessage
	SecretHash    []byte
	Enabled       bool
	CreatedAt     time.Time
	Matchers      json.RawMessage
	TokenSuffix   sql.NullString
}

type TriggerPreset 

type TriggerPreset struct {
	Key             string
	Category        string
	Label           string
	Description     string
	Provider        sql.NullString
	PayloadSchema   json.RawMessage
	DefaultMatchers json.RawMessage
	CreatedAt       time.Time
}
type TriggerProviderLink struct {
	TriggerID            uuid.UUID
	ExternalConnectionID uuid.UUID
	CreatedAt            time.Time
}

type UnlinkTriggerFromTractParams 

type UnlinkTriggerFromTractParams struct {
	TriggerID uuid.UUID
	TractID   uuid.UUID
}

type UpdateCouchAccountPasswordParams 

type UpdateCouchAccountPasswordParams struct {
	CouchUsername    string
	CouchInstanceID  uuid.UUID
	CouchPasswordEnc []byte
}

type UpdateCouchInstanceParams 

type UpdateCouchInstanceParams struct {
	ID          uuid.UUID
	Url         string
	Username    string
	PasswordEnc []byte
}

type UpdateDockerHostParams 

type UpdateDockerHostParams struct {
	ID               uuid.UUID
	Url              string
	UpdateCaCert     bool
	CaCertEnc        []byte
	UpdateClientCert bool
	ClientCertEnc    []byte
	UpdateClientKey  bool
	ClientKeyEnc     []byte
}

type UpdateS3InstanceParams 

type UpdateS3InstanceParams struct {
	ID           uuid.UUID
	Endpoint     string
	Region       string
	AccessKey    string
	SecretKeyEnc []byte
	UseSsl       bool
	PathStyle    bool
}

type UpdateSystemSettingsAuthMethodsParams 

type UpdateSystemSettingsAuthMethodsParams struct {
	PasswordAuthEnabled bool
	TelegramAuthEnabled bool
}

type UpdateTractParams 

type UpdateTractParams struct {
	ID          uuid.UUID
	Name        string
	Description string
	Definition  json.RawMessage
}

type UpdateTractRunStatusParams 

type UpdateTractRunStatusParams struct {
	ID     uuid.UUID
	Status TractRunStatus
	Error  sql.NullString
}

type UpdateTractRunStepFinishParams 

type UpdateTractRunStepFinishParams struct {
	ID     uuid.UUID
	Output pqtype.NullRawMessage
	Status TractRunStepStatus
	Error  sql.NullString
}

type UpdateUserPasswordHashParams 

type UpdateUserPasswordHashParams struct {
	ID           uuid.UUID
	PasswordHash string
}

type UpdateUserPhotoUrlParams 

type UpdateUserPhotoUrlParams struct {
	ID       uuid.UUID
	PhotoUrl string
}

type UpdateVaultStatusParams 

type UpdateVaultStatusParams struct {
	ID     uuid.UUID
	Status string
}

type UpsertCouchAccountParams 

type UpsertCouchAccountParams struct {
	UserID           uuid.UUID
	CouchInstanceID  uuid.UUID
	CouchUsername    string
	CouchPasswordEnc []byte
}

type UpsertExternalConnectionParams 

type UpsertExternalConnectionParams struct {
	UserID         uuid.UUID
	Provider       string
	ProviderType   ExternalProviderType
	CredentialsEnc []byte
	Metadata       pqtype.NullRawMessage
}

type UpsertMcpDefinitionParams 

type UpsertMcpDefinitionParams struct {
	Name        string
	Author      string
	Description string
	OwnerUserID uuid.NullUUID
	IsCommunity bool
}

type UpsertMcpToolParams 

type UpsertMcpToolParams struct {
	McpName      string
	Name         string
	Description  string
	InputSchema  json.RawMessage
	OutputSchema json.RawMessage
	Action       json.RawMessage
}

type UpsertSubscriptionOverridesParams 

type UpsertSubscriptionOverridesParams struct {
	UserID                  uuid.UUID
	PlanKey                 string
	FeatureOverrides        json.RawMessage
	CouchQuotaOverrideBytes sql.NullInt64
	S3QuotaOverrideBytes    sql.NullInt64
}

type UpsertSubscriptionParams 

type UpsertSubscriptionParams struct {
	UserID uuid.UUID
	Active bool
}

type UpsertTelegramIdentityParams 

type UpsertTelegramIdentityParams struct {
	UserID     uuid.UUID
	TelegramID string
}

type UpsertUserPermissionsParams 

type UpsertUserPermissionsParams struct {
	UserID          uuid.UUID
	IsAdministrator bool
}

type User 

type User struct {
	ID           uuid.UUID
	Email        sql.NullString
	CreatedAt    time.Time
	UpdatedAt    time.Time
	PasswordHash string
	Username     string
	PhotoUrl     string
}

type UserPermission 

type UserPermission struct {
	UserID          uuid.UUID
	IsAdministrator bool
}

type Vault 

type Vault struct {
	ID                    uuid.UUID
	UserID                uuid.UUID
	Name                  string
	CouchDbName           string
	CreatedAt             time.Time
	CouchInstanceID       uuid.NullUUID
	Status                string
	LivesyncPassphraseEnc []byte
	S3InstanceID          uuid.NullUUID
	S3BucketName          sql.NullString
	UseCouchdbForBinaries bool
	IsPublic              bool
	Slug                  sql.NullString
}

type VaultInvite 

type VaultInvite struct {
	ID        uuid.UUID
	VaultID   uuid.UUID
	CreatedBy uuid.UUID
	Role      VaultRole
	Token     string
	RevokedAt sql.NullTime
	CreatedAt time.Time
}

type VaultMember 

type VaultMember struct {
	ID        uuid.UUID
	VaultID   uuid.UUID
	UserID    uuid.UUID
	Role      VaultRole
	CreatedAt time.Time
}

type VaultRole 

type VaultRole string
const (
	VaultRoleOwner      VaultRole = "owner"
	VaultRoleReader     VaultRole = "reader"
	VaultRoleMaintainer VaultRole = "maintainer"
)

func (*VaultRole) Scan 

func (e *VaultRole) Scan(src interface{}) error

type Workbench 

type Workbench struct {
	ID           uuid.UUID
	VaultID      uuid.UUID
	UserID       uuid.UUID
	Status       WorkbenchStatus
	AuthMode     NullWorkbenchAuthMode
	ContainerID  sql.NullString
	VolumeName   string
	CreatedAt    time.Time
	StartedAt    sql.NullTime
	StoppedAt    sql.NullTime
	DockerHostID uuid.NullUUID
}

type WorkbenchAuthMode 

type WorkbenchAuthMode string
const (
	WorkbenchAuthModeApiKey            WorkbenchAuthMode = "api_key"
	WorkbenchAuthModeSubscriptionLogin WorkbenchAuthMode = "subscription_login"
)

func (*WorkbenchAuthMode) Scan 

func (e *WorkbenchAuthMode) Scan(src interface{}) error

type WorkbenchStatus 

type WorkbenchStatus string
const (
	WorkbenchStatusCreated     WorkbenchStatus = "created"
	WorkbenchStatusRunning     WorkbenchStatus = "running"
	WorkbenchStatusStopped     WorkbenchStatus = "stopped"
	WorkbenchStatusRemoved     WorkbenchStatus = "removed"
	WorkbenchStatusConfiguring WorkbenchStatus = "configuring"
)

func (*WorkbenchStatus) Scan 

func (e *WorkbenchStatus) Scan(src interface{}) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.