webhook

type AdmitCallback func(context.Context, AdmittedInvocation) error

type AdmittedInvocation struct {
	WebhookID            string
	UserID               string
	AgentID              string
	Provider             Provider
	WaitTimeoutSeconds   int32
	MaxRunTimeoutSeconds int32
	Authority            authz.Authority
}

type Candidate struct {
	WebhookID string
	// contains filtered or unexported fields
}

type Config struct {
	Store  Store
	Users  UserState
	Access UserAgentAccess
}

type CreateRequest struct {
	UserID               string
	Name                 string
	AgentID              string
	Provider             Provider
	IsEnabled            bool
	WaitTimeoutSeconds   int32
	MaxRunTimeoutSeconds int32
}

type IssueResult struct {
	Webhook    Webhook
	Capability string
}

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

type Provider string

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

type Store interface {
	Create(context.Context, credentialRecord) (credentialRecord, error)
	Get(context.Context, string, string) (credentialRecord, error)
	List(context.Context, string, int32, int32) ([]credentialRecord, error)
	// Update atomically applies only fields present in the owner-scoped request.
	Update(context.Context, UpdateRequest) (credentialRecord, error)
	Rotate(context.Context, string, string, string, credentialRecord) (credentialRecord, error)
	Delete(context.Context, string, string) (int64, error)
	ResolveByPublicID(context.Context, string) (credentialRecord, error)
	ResolveAdmitted(context.Context, string) (credentialRecord, error)
}

type UpdateRequest struct {
	ID                   string
	UserID               string
	Name                 *string
	AgentID              *string
	IsEnabled            *bool
	WaitTimeoutSeconds   *int32
	MaxRunTimeoutSeconds *int32
}

type UserAgentAccess interface {
	CanUseUser(context.Context, string, string) (bool, error)
}

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

type UserState interface {
	IsActive(context.Context, string) (bool, error)
}

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

type Webhook struct {
	ID                   string
	UserID               string
	AgentID              string
	Name                 string
	Provider             Provider
	IsEnabled            bool
	WaitTimeoutSeconds   int32
	MaxRunTimeoutSeconds int32
	TokenPublicID        string
	TokenLast4           string
	Revision             int64
	CreatedAt            time.Time
	UpdatedAt            time.Time
	RotatedAt            *time.Time
}