repository

package

Go to main page

Versions in this module

v0

v0.0.16

Feb 11, 2026

v0.0.15

Feb 11, 2026

Changes in this version

type AuditRepository

+ func (r *AuditRepository) GetDistinctActions(ctx context.Context, filter *audit.AggregationFilter) ([]audit.DistinctValue, error)

+ func (r *AuditRepository) GetDistinctApps(ctx context.Context, filter *audit.AggregationFilter) ([]audit.DistinctValue, error)

+ func (r *AuditRepository) GetDistinctIPs(ctx context.Context, filter *audit.AggregationFilter) ([]audit.DistinctValue, error)

+ func (r *AuditRepository) GetDistinctOrganizations(ctx context.Context, filter *audit.AggregationFilter) ([]audit.DistinctValue, error)

+ func (r *AuditRepository) GetDistinctResources(ctx context.Context, filter *audit.AggregationFilter) ([]audit.DistinctValue, error)

+ func (r *AuditRepository) GetDistinctSources(ctx context.Context, filter *audit.AggregationFilter) ([]audit.DistinctValue, error)

+ func (r *AuditRepository) GetDistinctUsers(ctx context.Context, filter *audit.AggregationFilter) ([]audit.DistinctValue, error)

+ type DeviceCodeRepository struct

+ func NewDeviceCodeRepository(db *bun.DB) *DeviceCodeRepository

+ func (r *DeviceCodeRepository) AuthorizeDevice(ctx context.Context, userCode string, userID, sessionID xid.ID) error

+ func (r *DeviceCodeRepository) CountByAppAndEnv(ctx context.Context, appID, envID xid.ID) (int64, error)

+ func (r *DeviceCodeRepository) CountByAppEnvAndStatus(ctx context.Context, appID, envID xid.ID, status string) (int64, error)

+ func (r *DeviceCodeRepository) CountPending(ctx context.Context, clientID string) (int, error)

+ func (r *DeviceCodeRepository) Create(ctx context.Context, code *schema.DeviceCode) error

+ func (r *DeviceCodeRepository) DeleteBySession(ctx context.Context, sessionID xid.ID) error

+ func (r *DeviceCodeRepository) DeleteExpired(ctx context.Context) (int, error)

+ func (r *DeviceCodeRepository) DeleteOldConsumedCodes(ctx context.Context, olderThan time.Duration) (int, error)

+ func (r *DeviceCodeRepository) DenyDevice(ctx context.Context, userCode string) error

+ func (r *DeviceCodeRepository) FindByClientID(ctx context.Context, clientID string, limit int) ([]*schema.DeviceCode, error)

+ func (r *DeviceCodeRepository) FindByDeviceCode(ctx context.Context, deviceCode string) (*schema.DeviceCode, error)

+ func (r *DeviceCodeRepository) FindByDeviceCodeWithContext(ctx context.Context, deviceCode string, appID, envID xid.ID, orgID *xid.ID) (*schema.DeviceCode, error)

+ func (r *DeviceCodeRepository) FindByUserCode(ctx context.Context, userCode string) (*schema.DeviceCode, error)

+ func (r *DeviceCodeRepository) FindByUserID(ctx context.Context, userID xid.ID, limit int) ([]*schema.DeviceCode, error)

+ func (r *DeviceCodeRepository) ListByAppAndEnv(ctx context.Context, appID, envID xid.ID, page, pageSize int) ([]*schema.DeviceCode, error)

+ func (r *DeviceCodeRepository) ListByAppEnvAndStatus(ctx context.Context, appID, envID xid.ID, status string, page, pageSize int) ([]*schema.DeviceCode, error)

+ func (r *DeviceCodeRepository) MarkAsConsumed(ctx context.Context, deviceCode string) error

+ func (r *DeviceCodeRepository) Update(ctx context.Context, code *schema.DeviceCode) error

+ func (r *DeviceCodeRepository) UpdatePollInfo(ctx context.Context, deviceCode string) error

+ func (r *DeviceCodeRepository) UpdateStatus(ctx context.Context, deviceCode, status string) error

type OAuthClientRepository

+ func (r *OAuthClientRepository) CountByAppAndEnv(ctx context.Context, appID, envID xid.ID) (int64, error)

+ func (r *OAuthClientRepository) ListByAppAndEnv(ctx context.Context, appID, envID xid.ID, page, pageSize int) ([]*schema.OAuthClient, error)

type OAuthTokenRepository

+ func (r *OAuthTokenRepository) CountActiveByApp(ctx context.Context, appID xid.ID) (int64, error)

+ func (r *OAuthTokenRepository) CountActiveByClientID(ctx context.Context, clientID string) (int64, error)

+ func (r *OAuthTokenRepository) CountByApp(ctx context.Context, appID xid.ID) (int64, error)

+ func (r *OAuthTokenRepository) CountByAppAndType(ctx context.Context, appID xid.ID, tokenClass string) (int64, error)

+ func (r *OAuthTokenRepository) CountByAppBetween(ctx context.Context, appID xid.ID, start, end time.Time) (int64, error)

+ func (r *OAuthTokenRepository) CountByAppSince(ctx context.Context, appID xid.ID, since time.Time) (int64, error)

+ func (r *OAuthTokenRepository) CountByClientID(ctx context.Context, clientID string) (int64, error)

+ func (r *OAuthTokenRepository) CountByClientIDSince(ctx context.Context, clientID string, since time.Time) (int64, error)

+ func (r *OAuthTokenRepository) CountUniqueUsersByApp(ctx context.Context, appID xid.ID) (int64, error)

+ func (r *OAuthTokenRepository) CountUniqueUsersByClientID(ctx context.Context, clientID string) (int64, error)

+ func (r *OAuthTokenRepository) RevokeByClientID(ctx context.Context, clientID string) error

v0.0.14

Jan 4, 2026

v0.0.13

Jan 3, 2026

v0.0.12

Jan 3, 2026

v0.0.11

Jan 3, 2026

v0.0.10

Jan 3, 2026

v0.0.9

Jan 3, 2026

Changes in this version

type AuditRepository

+ func (r *AuditRepository) Count(ctx context.Context, filter *audit.ListEventsFilter) (int64, error)

+ func (r *AuditRepository) DeleteOlderThan(ctx context.Context, filter *audit.DeleteFilter, before time.Time) (int64, error)

+ func (r *AuditRepository) GetOldestEvent(ctx context.Context, filter *audit.ListEventsFilter) (*schema.AuditEvent, error)

+ func (r *AuditRepository) GetStatisticsByAction(ctx context.Context, filter *audit.StatisticsFilter) ([]*audit.ActionStatistic, error)

+ func (r *AuditRepository) GetStatisticsByActionAndUser(ctx context.Context, filter *audit.StatisticsFilter) ([]*audit.ActionUserStatistic, error)

+ func (r *AuditRepository) GetStatisticsByDate(ctx context.Context, filter *audit.StatisticsFilter) ([]*audit.DateStatistic, error)

+ func (r *AuditRepository) GetStatisticsByDay(ctx context.Context, filter *audit.StatisticsFilter) ([]*audit.DayStatistic, error)

+ func (r *AuditRepository) GetStatisticsByHour(ctx context.Context, filter *audit.StatisticsFilter) ([]*audit.HourStatistic, error)

+ func (r *AuditRepository) GetStatisticsByIPAddress(ctx context.Context, filter *audit.StatisticsFilter) ([]*audit.IPStatistic, error)

+ func (r *AuditRepository) GetStatisticsByResource(ctx context.Context, filter *audit.StatisticsFilter) ([]*audit.ResourceStatistic, error)

+ func (r *AuditRepository) GetStatisticsByResourceAndAction(ctx context.Context, filter *audit.StatisticsFilter) ([]*audit.ResourceActionStatistic, error)

+ func (r *AuditRepository) GetStatisticsByUser(ctx context.Context, filter *audit.StatisticsFilter) ([]*audit.UserStatistic, error)

+ func (r *AuditRepository) GetTimeSeries(ctx context.Context, filter *audit.TimeSeriesFilter) ([]*audit.TimeSeriesPoint, error)

+ func (r *AuditRepository) GetUniqueIPCount(ctx context.Context, filter *audit.StatisticsFilter) (int64, error)

v0.0.8

Dec 31, 2025

Changes in this version

+ var ErrSearchNotSupported = audit.InvalidFilter("search", "full-text search not supported for this database")

type AuditRepository

+ func (r *AuditRepository) Search(ctx context.Context, query *audit.SearchQuery) (*audit.SearchResponse, error)

+ func (r *AuditRepository) SearchPostgreSQL(ctx context.Context, query *audit.SearchQuery) (*audit.SearchResponse, error)

+ func (r *AuditRepository) SearchSQLite(ctx context.Context, query *audit.SearchQuery) (*audit.SearchResponse, error)

v0.0.7

Dec 29, 2025

Changes in this version

+ func NewDatabaseRetryStorage(repo NotificationQueueRepository) notification.RetryStorage

+ type DatabaseRetryStorage struct

+ func (s *DatabaseRetryStorage) Delete(ctx context.Context, id xid.ID) error

+ func (s *DatabaseRetryStorage) Dequeue(ctx context.Context, limit int) ([]*notification.RetryItem, error)

+ func (s *DatabaseRetryStorage) Enqueue(ctx context.Context, item *notification.RetryItem) error

+ func (s *DatabaseRetryStorage) GetStats(ctx context.Context) (*notification.RetryStats, error)

+ func (s *DatabaseRetryStorage) MarkFailed(ctx context.Context, item *notification.RetryItem) error

+ func (s *DatabaseRetryStorage) Update(ctx context.Context, item *notification.RetryItem) error

+ type NotificationQueueRepository interface

+ CleanupOld func(ctx context.Context, olderThan time.Time) error

+ Delete func(ctx context.Context, id xid.ID) error

+ Dequeue func(ctx context.Context, limit int) ([]*schema.NotificationQueue, error)

+ Enqueue func(ctx context.Context, item *schema.NotificationQueue) error

+ GetByID func(ctx context.Context, id xid.ID) (*schema.NotificationQueue, error)

+ GetStats func(ctx context.Context) (*schema.NotificationQueueStats, error)

+ MarkFailed func(ctx context.Context, id xid.ID, lastError string) error

+ MarkSucceeded func(ctx context.Context, id xid.ID) error

+ Update func(ctx context.Context, item *schema.NotificationQueue) error

+ func NewNotificationQueueRepository(db *bun.DB) NotificationQueueRepository

type UserRoleRepository

+ func (r *UserRoleRepository) AssignAppLevel(ctx context.Context, userID, roleID, appID xid.ID) error

+ func (r *UserRoleRepository) AssignBatch(ctx context.Context, userID xid.ID, roleIDs []xid.ID, orgID xid.ID) error

+ func (r *UserRoleRepository) AssignBulk(ctx context.Context, userIDs []xid.ID, roleID xid.ID, orgID xid.ID) (map[xid.ID]error, error)

+ func (r *UserRoleRepository) ClearUserRolesInApp(ctx context.Context, userID, appID xid.ID) error

+ func (r *UserRoleRepository) ClearUserRolesInOrg(ctx context.Context, userID, orgID xid.ID) error

+ func (r *UserRoleRepository) CopyRoles(ctx context.Context, userID, sourceOrgID, targetOrgID xid.ID, roleIDs []xid.ID) error

+ func (r *UserRoleRepository) ListAllUserRolesInApp(ctx context.Context, appID, envID xid.ID) ([]schema.UserRole, error)

+ func (r *UserRoleRepository) ListAllUserRolesInOrg(ctx context.Context, orgID, envID xid.ID) ([]schema.UserRole, error)

+ func (r *UserRoleRepository) ListRolesForUserInApp(ctx context.Context, userID, appID, envID xid.ID) ([]schema.Role, error)

+ func (r *UserRoleRepository) ListRolesForUserInOrg(ctx context.Context, userID, orgID, envID xid.ID) ([]schema.Role, error)

+ func (r *UserRoleRepository) ReplaceUserRoles(ctx context.Context, userID, orgID xid.ID, newRoleIDs []xid.ID) error

+ func (r *UserRoleRepository) TransferRoles(ctx context.Context, userID, sourceOrgID, targetOrgID xid.ID, roleIDs []xid.ID) error

+ func (r *UserRoleRepository) UnassignBatch(ctx context.Context, userID xid.ID, roleIDs []xid.ID, orgID xid.ID) error

+ func (r *UserRoleRepository) UnassignBulk(ctx context.Context, userIDs []xid.ID, roleID xid.ID, orgID xid.ID) (map[xid.ID]error, error)

v0.0.6

Dec 17, 2025

Changes in this version

+ func NewVerificationRepository(db *bun.DB) *verificationRepository

type Repo

+ func (r *Repo) Verification() *verificationRepository

type Repository

+ Verification func() *verificationRepository

v0.0.5

Dec 12, 2025

Changes in this version

type RoleRepository

+ func (r *RoleRepository) FindByNameAppEnv(ctx context.Context, name string, appID, envID xid.ID) (*schema.Role, error)

+ func (r *RoleRepository) FindDuplicateRoles(ctx context.Context) ([]schema.Role, error)

v0.0.4

Dec 8, 2025

v0.0.3

Dec 8, 2025

Changes in this version

type Repo

+ func (r *Repo) RolePermission() *RolePermissionRepository

+ func (r *Repo) SocialProviderConfig() SocialProviderConfigRepository

type Repository

+ RolePermission func() *RolePermissionRepository

+ SocialProviderConfig func() SocialProviderConfigRepository

type SessionRepository

+ func (r *SessionRepository) FindSessionByRefreshToken(ctx context.Context, refreshToken string) (*schema.Session, error)

+ func (r *SessionRepository) RefreshSessionTokens(ctx context.Context, id xid.ID, newAccessToken string, ...) error

+ func (r *SessionRepository) UpdateSessionExpiry(ctx context.Context, id xid.ID, expiresAt time.Time) error

+ type SocialProviderConfigRepository interface

+ CountByEnvironment func(ctx context.Context, appID, envID xid.ID) (int, error)

+ Create func(ctx context.Context, config *schema.SocialProviderConfig) error

+ Delete func(ctx context.Context, id xid.ID) error

+ ExistsByProvider func(ctx context.Context, appID, envID xid.ID, providerName string) (bool, error)

+ FindByID func(ctx context.Context, id xid.ID) (*schema.SocialProviderConfig, error)

+ FindByProvider func(ctx context.Context, appID, envID xid.ID, providerName string) (*schema.SocialProviderConfig, error)

+ HardDelete func(ctx context.Context, id xid.ID) error

+ ListByEnvironment func(ctx context.Context, appID, envID xid.ID) ([]*schema.SocialProviderConfig, error)

+ ListEnabledByEnvironment func(ctx context.Context, appID, envID xid.ID) ([]*schema.SocialProviderConfig, error)

+ SetEnabled func(ctx context.Context, id xid.ID, enabled bool) error

+ Update func(ctx context.Context, config *schema.SocialProviderConfig) error

+ func NewSocialProviderConfigRepository(db *bun.DB) SocialProviderConfigRepository

v0.0.2

Nov 24, 2025

Changes in this version

type TeamRepository

+ func (r *TeamRepository) FindByExternalID(ctx context.Context, appID xid.ID, externalID string) (*schema.Team, error)

v0.0.1

Nov 20, 2025

Changes in this version

+ func NewEnvironmentRepository(db *bun.DB) *environmentRepository

+ func NewFormsRepository(db *bun.DB) forms.Repository

+ func NewNotificationRepository(db *bun.DB) notification.Repository

+ func NewWebhookRepository(db *bun.DB) webhook.Repository

+ type APIKeyRepository struct

+ func NewAPIKeyRepository(db *bun.DB) *APIKeyRepository

+ func (r *APIKeyRepository) CleanupExpiredAPIKeys(ctx context.Context) (int, error)

+ func (r *APIKeyRepository) CountAPIKeys(ctx context.Context, appID xid.ID, envID *xid.ID, orgID *xid.ID, ...) (int, error)

+ func (r *APIKeyRepository) CreateAPIKey(ctx context.Context, apiKey *schema.APIKey) error

+ func (r *APIKeyRepository) DeactivateAPIKey(ctx context.Context, id xid.ID) error

+ func (r *APIKeyRepository) DeleteAPIKey(ctx context.Context, id xid.ID) error

+ func (r *APIKeyRepository) FindAPIKeyByID(ctx context.Context, id xid.ID) (*schema.APIKey, error)

+ func (r *APIKeyRepository) FindAPIKeyByPrefix(ctx context.Context, prefix string) (*schema.APIKey, error)

+ func (r *APIKeyRepository) ListAPIKeys(ctx context.Context, filter *apikey.ListAPIKeysFilter) (*pagination.PageResponse[*schema.APIKey], error)

+ func (r *APIKeyRepository) UpdateAPIKey(ctx context.Context, apiKey *schema.APIKey) error

+ func (r *APIKeyRepository) UpdateAPIKeyUsage(ctx context.Context, id xid.ID, ip, userAgent string) error

+ type APIKeyRoleRepository struct

+ func NewAPIKeyRoleRepository(db *bun.DB) *APIKeyRoleRepository

+ func (r *APIKeyRoleRepository) AssignRole(ctx context.Context, apiKeyID, roleID xid.ID, orgID *xid.ID, createdBy *xid.ID) error

+ func (r *APIKeyRoleRepository) BulkAssignRoles(ctx context.Context, apiKeyID xid.ID, roleIDs []xid.ID, orgID *xid.ID, ...) error

+ func (r *APIKeyRoleRepository) BulkUnassignRoles(ctx context.Context, apiKeyID xid.ID, roleIDs []xid.ID, orgID *xid.ID) error

+ func (r *APIKeyRoleRepository) GetAPIKeysWithRole(ctx context.Context, roleID xid.ID, orgID *xid.ID) ([]*schema.APIKey, error)

+ func (r *APIKeyRoleRepository) GetCreatorPermissions(ctx context.Context, creatorID xid.ID, orgID *xid.ID) ([]*schema.Permission, error)

+ func (r *APIKeyRoleRepository) GetCreatorRoles(ctx context.Context, creatorID xid.ID, orgID *xid.ID) ([]*schema.Role, error)

+ func (r *APIKeyRoleRepository) GetPermissions(ctx context.Context, apiKeyID xid.ID, orgID *xid.ID) ([]*schema.Permission, error)

+ func (r *APIKeyRoleRepository) GetRoles(ctx context.Context, apiKeyID xid.ID, orgID *xid.ID) ([]*schema.Role, error)

+ func (r *APIKeyRoleRepository) HasRole(ctx context.Context, apiKeyID, roleID xid.ID, orgID *xid.ID) (bool, error)

+ func (r *APIKeyRoleRepository) ReplaceRoles(ctx context.Context, apiKeyID xid.ID, roleIDs []xid.ID, orgID *xid.ID, ...) error

+ func (r *APIKeyRoleRepository) UnassignRole(ctx context.Context, apiKeyID, roleID xid.ID, orgID *xid.ID) error

+ type AppRepository struct

+ func NewAppRepository(db *bun.DB) *AppRepository

+ func (r *AppRepository) AddTeamMember(ctx context.Context, tm *schema.TeamMember) error

+ func (r *AppRepository) CountApps(ctx context.Context) (int, error)

+ func (r *AppRepository) CountMembers(ctx context.Context, appID xid.ID) (int, error)

+ func (r *AppRepository) CountTeamMembers(ctx context.Context, teamID xid.ID) (int, error)

+ func (r *AppRepository) CountTeams(ctx context.Context, appID xid.ID) (int, error)

+ func (r *AppRepository) CreateApp(ctx context.Context, app *schema.App) error

+ func (r *AppRepository) CreateInvitation(ctx context.Context, inv *schema.Invitation) error

+ func (r *AppRepository) CreateMember(ctx context.Context, member *schema.Member) error

+ func (r *AppRepository) CreateTeam(ctx context.Context, team *schema.Team) error

+ func (r *AppRepository) DeleteApp(ctx context.Context, id xid.ID) error

+ func (r *AppRepository) DeleteExpiredInvitations(ctx context.Context) (int, error)

+ func (r *AppRepository) DeleteInvitation(ctx context.Context, id xid.ID) error

+ func (r *AppRepository) DeleteMember(ctx context.Context, id xid.ID) error

+ func (r *AppRepository) DeleteTeam(ctx context.Context, id xid.ID) error

+ func (r *AppRepository) FindAppByID(ctx context.Context, id xid.ID) (*schema.App, error)

+ func (r *AppRepository) FindAppBySlug(ctx context.Context, slug string) (*schema.App, error)

+ func (r *AppRepository) FindInvitationByID(ctx context.Context, id xid.ID) (*schema.Invitation, error)

+ func (r *AppRepository) FindInvitationByToken(ctx context.Context, token string) (*schema.Invitation, error)

+ func (r *AppRepository) FindMember(ctx context.Context, appID, userID xid.ID) (*schema.Member, error)

+ func (r *AppRepository) FindMemberByID(ctx context.Context, id xid.ID) (*schema.Member, error)

+ func (r *AppRepository) FindTeamByID(ctx context.Context, id xid.ID) (*schema.Team, error)

+ func (r *AppRepository) FindTeamByName(ctx context.Context, appID xid.ID, name string) (*schema.Team, error)

+ func (r *AppRepository) GetPlatformApp(ctx context.Context) (*schema.App, error)

+ func (r *AppRepository) IsTeamMember(ctx context.Context, teamID, memberID xid.ID) (bool, error)

+ func (r *AppRepository) ListApps(ctx context.Context, filter *app.ListAppsFilter) (*pagination.PageResponse[*schema.App], error)

+ func (r *AppRepository) ListInvitations(ctx context.Context, filter *app.ListInvitationsFilter) (*pagination.PageResponse[*schema.Invitation], error)

+ func (r *AppRepository) ListMemberTeams(ctx context.Context, filter *app.ListMemberTeamsFilter) (*pagination.PageResponse[*schema.Team], error)

+ func (r *AppRepository) ListMembers(ctx context.Context, filter *app.ListMembersFilter) (*pagination.PageResponse[*schema.Member], error)

+ func (r *AppRepository) ListMembersByUser(ctx context.Context, userID xid.ID) ([]*schema.Member, error)

+ func (r *AppRepository) ListTeamMembers(ctx context.Context, filter *app.ListTeamMembersFilter) (*pagination.PageResponse[*schema.TeamMember], error)

+ func (r *AppRepository) ListTeams(ctx context.Context, filter *app.ListTeamsFilter) (*pagination.PageResponse[*schema.Team], error)

+ func (r *AppRepository) RemoveTeamMember(ctx context.Context, teamID, memberID xid.ID) error

+ func (r *AppRepository) UpdateApp(ctx context.Context, app *schema.App) error

+ func (r *AppRepository) UpdateInvitation(ctx context.Context, inv *schema.Invitation) error

+ func (r *AppRepository) UpdateMember(ctx context.Context, member *schema.Member) error

+ func (r *AppRepository) UpdateTeam(ctx context.Context, team *schema.Team) error

+ type AuditRepository struct

+ func NewAuditRepository(db *bun.DB) *AuditRepository

+ func (r *AuditRepository) Create(ctx context.Context, e *schema.AuditEvent) error

+ func (r *AuditRepository) Get(ctx context.Context, id xid.ID) (*schema.AuditEvent, error)

+ func (r *AuditRepository) List(ctx context.Context, filter *audit.ListEventsFilter) (*pagination.PageResponse[*schema.AuditEvent], error)

+ type AuthorizationCodeRepository struct

+ func NewAuthorizationCodeRepository(db *bun.DB) *AuthorizationCodeRepository

+ func (r *AuthorizationCodeRepository) Create(ctx context.Context, code *schema.AuthorizationCode) error

+ func (r *AuthorizationCodeRepository) DeleteBySession(ctx context.Context, sessionID xid.ID) error

+ func (r *AuthorizationCodeRepository) DeleteExpired(ctx context.Context) error

+ func (r *AuthorizationCodeRepository) FindByCode(ctx context.Context, code string) (*schema.AuthorizationCode, error)

+ func (r *AuthorizationCodeRepository) FindByCodeWithContext(ctx context.Context, code string, appID, envID xid.ID, orgID *xid.ID) (*schema.AuthorizationCode, error)

+ func (r *AuthorizationCodeRepository) FindBySession(ctx context.Context, sessionID xid.ID) ([]*schema.AuthorizationCode, error)

+ func (r *AuthorizationCodeRepository) FindByUserAndClient(ctx context.Context, userID xid.ID, clientID string) ([]*schema.AuthorizationCode, error)

+ func (r *AuthorizationCodeRepository) MarkAsUsed(ctx context.Context, code string) error

+ type DeviceRepository struct

+ func NewDeviceRepository(db *bun.DB) *DeviceRepository

+ func (r *DeviceRepository) CountDevices(ctx context.Context, userID xid.ID) (int, error)

+ func (r *DeviceRepository) CreateDevice(ctx context.Context, d *schema.Device) error

+ func (r *DeviceRepository) DeleteDevice(ctx context.Context, id xid.ID) error

+ func (r *DeviceRepository) DeleteDeviceByFingerprint(ctx context.Context, userID xid.ID, fingerprint string) error

+ func (r *DeviceRepository) FindDeviceByFingerprint(ctx context.Context, userID xid.ID, fingerprint string) (*schema.Device, error)

+ func (r *DeviceRepository) FindDeviceByID(ctx context.Context, id xid.ID) (*schema.Device, error)

+ func (r *DeviceRepository) ListDevices(ctx context.Context, filter *device.ListDevicesFilter) (*pagination.PageResponse[*schema.Device], error)

+ func (r *DeviceRepository) UpdateDevice(ctx context.Context, d *schema.Device) error

+ type EmailOTPRepository struct

+ func NewEmailOTPRepository(db *bun.DB) *EmailOTPRepository

+ func (r *EmailOTPRepository) Consume(ctx context.Context, rec *schema.EmailOTP, now time.Time) error

+ func (r *EmailOTPRepository) Create(ctx context.Context, email, otp string, expiresAt time.Time) error

+ func (r *EmailOTPRepository) FindByEmail(ctx context.Context, email string, now time.Time) (*schema.EmailOTP, error)

+ func (r *EmailOTPRepository) IncrementAttempts(ctx context.Context, rec *schema.EmailOTP) error

+ type FormSubmissionStats struct

+ ByStatus map[string]int

+ Total int

+ type IdentityVerificationRepository struct

+ func NewIdentityVerificationRepository(db *bun.DB) *IdentityVerificationRepository

+ func (r *IdentityVerificationRepository) CountVerificationsByUser(ctx context.Context, appID xid.ID, userID xid.ID, since time.Time) (int, error)

+ func (r *IdentityVerificationRepository) CreateDocument(ctx context.Context, document *schema.IdentityVerificationDocument) error

+ func (r *IdentityVerificationRepository) CreateSession(ctx context.Context, session *schema.IdentityVerificationSession) error

+ func (r *IdentityVerificationRepository) CreateUserVerificationStatus(ctx context.Context, status *schema.UserVerificationStatus) error

+ func (r *IdentityVerificationRepository) CreateVerification(ctx context.Context, verification *schema.IdentityVerification) error

+ func (r *IdentityVerificationRepository) DeleteDocument(ctx context.Context, appID xid.ID, id string) error

+ func (r *IdentityVerificationRepository) DeleteSession(ctx context.Context, appID xid.ID, id string) error

+ func (r *IdentityVerificationRepository) DeleteUserVerificationStatus(ctx context.Context, appID xid.ID, orgID xid.ID, userID xid.ID) error

+ func (r *IdentityVerificationRepository) DeleteVerification(ctx context.Context, appID xid.ID, id string) error

+ func (r *IdentityVerificationRepository) GetBlockedUsers(ctx context.Context, appID xid.ID, limit, offset int) ([]*schema.UserVerificationStatus, error)

+ func (r *IdentityVerificationRepository) GetDocumentByID(ctx context.Context, appID xid.ID, id string) (*schema.IdentityVerificationDocument, error)

+ func (r *IdentityVerificationRepository) GetDocumentsByVerificationID(ctx context.Context, appID xid.ID, verificationID string) ([]*schema.IdentityVerificationDocument, error)

+ func (r *IdentityVerificationRepository) GetDocumentsForDeletion(ctx context.Context, appID xid.ID, before time.Time, limit int) ([]*schema.IdentityVerificationDocument, error)

+ func (r *IdentityVerificationRepository) GetExpiredSessions(ctx context.Context, appID xid.ID, before time.Time, limit int) ([]*schema.IdentityVerificationSession, error)

+ func (r *IdentityVerificationRepository) GetExpiredVerifications(ctx context.Context, appID xid.ID, before time.Time, limit int) ([]*schema.IdentityVerification, error)

+ func (r *IdentityVerificationRepository) GetLatestVerificationByUser(ctx context.Context, appID xid.ID, userID xid.ID) (*schema.IdentityVerification, error)

+ func (r *IdentityVerificationRepository) GetProviderStats(ctx context.Context, appID xid.ID, provider string, from, to time.Time) (map[string]interface{}, error)

+ func (r *IdentityVerificationRepository) GetSessionByID(ctx context.Context, appID xid.ID, id string) (*schema.IdentityVerificationSession, error)

+ func (r *IdentityVerificationRepository) GetSessionsByUserID(ctx context.Context, appID xid.ID, userID xid.ID, limit, offset int) ([]*schema.IdentityVerificationSession, error)

+ func (r *IdentityVerificationRepository) GetUserVerificationStatus(ctx context.Context, appID xid.ID, orgID xid.ID, userID xid.ID) (*schema.UserVerificationStatus, error)

+ func (r *IdentityVerificationRepository) GetUsersByVerificationLevel(ctx context.Context, appID xid.ID, level string, limit, offset int) ([]*schema.UserVerificationStatus, error)

+ func (r *IdentityVerificationRepository) GetUsersRequiringReverification(ctx context.Context, appID xid.ID, limit int) ([]*schema.UserVerificationStatus, error)

+ func (r *IdentityVerificationRepository) GetVerificationByID(ctx context.Context, appID xid.ID, id string) (*schema.IdentityVerification, error)

+ func (r *IdentityVerificationRepository) GetVerificationByProviderCheckID(ctx context.Context, appID xid.ID, providerCheckID string) (*schema.IdentityVerification, error)

+ func (r *IdentityVerificationRepository) GetVerificationStats(ctx context.Context, appID xid.ID, orgID xid.ID, from, to time.Time) (map[string]interface{}, error)

+ func (r *IdentityVerificationRepository) GetVerificationsByOrgID(ctx context.Context, appID xid.ID, orgID xid.ID, limit, offset int) ([]*schema.IdentityVerification, error)

+ func (r *IdentityVerificationRepository) GetVerificationsByStatus(ctx context.Context, appID xid.ID, status string, limit, offset int) ([]*schema.IdentityVerification, error)

+ func (r *IdentityVerificationRepository) GetVerificationsByType(ctx context.Context, appID xid.ID, verificationType string, limit, offset int) ([]*schema.IdentityVerification, error)

+ func (r *IdentityVerificationRepository) GetVerificationsByUserID(ctx context.Context, appID xid.ID, userID xid.ID, limit, offset int) ([]*schema.IdentityVerification, error)

+ func (r *IdentityVerificationRepository) UpdateDocument(ctx context.Context, document *schema.IdentityVerificationDocument) error

+ func (r *IdentityVerificationRepository) UpdateSession(ctx context.Context, session *schema.IdentityVerificationSession) error

+ func (r *IdentityVerificationRepository) UpdateUserVerificationStatus(ctx context.Context, status *schema.UserVerificationStatus) error

+ func (r *IdentityVerificationRepository) UpdateVerification(ctx context.Context, verification *schema.IdentityVerification) error

+ type ImpersonationRepository struct

+ func NewImpersonationRepository(db *bun.DB) *ImpersonationRepository

+ func (r *ImpersonationRepository) Create(ctx context.Context, session *schema.ImpersonationSession) error

+ func (r *ImpersonationRepository) CreateAuditEvent(ctx context.Context, event *schema.ImpersonationAuditEvent) error

+ func (r *ImpersonationRepository) ExpireOldSessions(ctx context.Context) (int, error)

+ func (r *ImpersonationRepository) Get(ctx context.Context, id xid.ID, appID xid.ID) (*schema.ImpersonationSession, error)

+ func (r *ImpersonationRepository) GetActive(ctx context.Context, impersonatorID xid.ID, appID xid.ID) (*schema.ImpersonationSession, error)

+ func (r *ImpersonationRepository) GetBySessionID(ctx context.Context, sessionID xid.ID) (*schema.ImpersonationSession, error)

+ func (r *ImpersonationRepository) ListAuditEvents(ctx context.Context, filter *impersonation.ListAuditEventsFilter) (*pagination.PageResponse[*schema.ImpersonationAuditEvent], error)

+ func (r *ImpersonationRepository) ListSessions(ctx context.Context, filter *impersonation.ListSessionsFilter) (*pagination.PageResponse[*schema.ImpersonationSession], error)

+ func (r *ImpersonationRepository) Update(ctx context.Context, session *schema.ImpersonationSession) error

+ type InvitationRepository struct

+ func NewInvitationRepository(db *bun.DB) *InvitationRepository

+ func (r *InvitationRepository) Create(ctx context.Context, invitation *schema.Invitation) error

+ func (r *InvitationRepository) Delete(ctx context.Context, id xid.ID) error

+ func (r *InvitationRepository) DeleteExpired(ctx context.Context) error

+ func (r *InvitationRepository) FindByID(ctx context.Context, id xid.ID) (*schema.Invitation, error)

+ func (r *InvitationRepository) FindByToken(ctx context.Context, token string) (*schema.Invitation, error)

+ func (r *InvitationRepository) ListByApp(ctx context.Context, appID xid.ID, limit, offset int) ([]*schema.Invitation, error)

+ func (r *InvitationRepository) Update(ctx context.Context, invitation *schema.Invitation) error

+ type JWTKeyRepository struct

+ func NewJWTKeyRepository(db *bun.DB) *JWTKeyRepository

+ func (r *JWTKeyRepository) CleanupExpiredJWTKeys(ctx context.Context) (int64, error)

+ func (r *JWTKeyRepository) CountJWTKeys(ctx context.Context, appID xid.ID) (int, error)

+ func (r *JWTKeyRepository) CreateJWTKey(ctx context.Context, key *schema.JWTKey) error

+ func (r *JWTKeyRepository) DeactivateJWTKey(ctx context.Context, id xid.ID) error

+ func (r *JWTKeyRepository) DeleteJWTKey(ctx context.Context, id xid.ID) error

+ func (r *JWTKeyRepository) FindJWTKeyByID(ctx context.Context, id xid.ID) (*schema.JWTKey, error)

+ func (r *JWTKeyRepository) FindJWTKeyByKeyID(ctx context.Context, keyID string, appID xid.ID) (*schema.JWTKey, error)

+ func (r *JWTKeyRepository) FindPlatformJWTKeyByKeyID(ctx context.Context, keyID string) (*schema.JWTKey, error)

+ func (r *JWTKeyRepository) ListJWTKeys(ctx context.Context, filter *jwt.ListJWTKeysFilter) (*pagination.PageResponse[*schema.JWTKey], error)

+ func (r *JWTKeyRepository) ListPlatformJWTKeys(ctx context.Context, filter *jwt.ListJWTKeysFilter) (*pagination.PageResponse[*schema.JWTKey], error)

+ func (r *JWTKeyRepository) UpdateJWTKey(ctx context.Context, key *schema.JWTKey) error

+ func (r *JWTKeyRepository) UpdateJWTKeyUsage(ctx context.Context, keyID string) error

+ type MFARepository struct

+ func NewMFARepository(db *bun.DB) *MFARepository

+ func (r *MFARepository) CleanupExpiredChallenges(ctx context.Context) (int, error)

+ func (r *MFARepository) CleanupExpiredDevices(ctx context.Context) (int, error)

+ func (r *MFARepository) CleanupExpiredSessions(ctx context.Context) (int, error)

+ func (r *MFARepository) CleanupOldAttempts(ctx context.Context, olderThan time.Time) (int, error)

+ func (r *MFARepository) CompleteSession(ctx context.Context, sessionID xid.ID) error

+ func (r *MFARepository) CountFailedAttempts(ctx context.Context, userID xid.ID, since time.Time) (int, error)

+ func (r *MFARepository) CreateAttempt(ctx context.Context, attempt *schema.MFAAttempt) error

+ func (r *MFARepository) CreateBypass(ctx context.Context, bypass *schema.MFABypass) error

+ func (r *MFARepository) CreateChallenge(ctx context.Context, challenge *schema.MFAChallenge) error

+ func (r *MFARepository) CreateFactor(ctx context.Context, factor *schema.MFAFactor) error

+ func (r *MFARepository) CreateRiskAssessment(ctx context.Context, assessment *schema.MFARiskAssessment) error

+ func (r *MFARepository) CreateSession(ctx context.Context, session *schema.MFASession) error

+ func (r *MFARepository) CreateTrustedDevice(ctx context.Context, device *schema.MFATrustedDevice) error

+ func (r *MFARepository) DB() *bun.DB

+ func (r *MFARepository) DeleteFactor(ctx context.Context, factorID xid.ID) error

+ func (r *MFARepository) DeleteTrustedDevice(ctx context.Context, deviceID xid.ID) error

+ func (r *MFARepository) GetActiveBypass(ctx context.Context, appID, userID xid.ID) (*schema.MFABypass, error)

+ func (r *MFARepository) GetChallenge(ctx context.Context, challengeID xid.ID) (*schema.MFAChallenge, error)

+ func (r *MFARepository) GetFactor(ctx context.Context, factorID xid.ID) (*schema.MFAFactor, error)

+ func (r *MFARepository) GetLatestRiskAssessment(ctx context.Context, userID xid.ID) (*schema.MFARiskAssessment, error)

+ func (r *MFARepository) GetPolicy(ctx context.Context, appID xid.ID, orgID *xid.ID) (*schema.MFAPolicy, error)

+ func (r *MFARepository) GetRecentAttempts(ctx context.Context, userID xid.ID, since time.Time) ([]*schema.MFAAttempt, error)

+ func (r *MFARepository) GetRiskAssessmentBySession(ctx context.Context, sessionID xid.ID) (*schema.MFARiskAssessment, error)

+ func (r *MFARepository) GetSession(ctx context.Context, sessionID xid.ID) (*schema.MFASession, error)

+ func (r *MFARepository) GetSessionByToken(ctx context.Context, token string) (*schema.MFASession, error)

+ func (r *MFARepository) GetTrustedDevice(ctx context.Context, userID xid.ID, deviceID string) (*schema.MFATrustedDevice, error)

+ func (r *MFARepository) IncrementChallengeAttempts(ctx context.Context, challengeID xid.ID) error

+ func (r *MFARepository) ListTrustedDevices(ctx context.Context, userID xid.ID) ([]*schema.MFATrustedDevice, error)

+ func (r *MFARepository) ListUserFactors(ctx context.Context, userID xid.ID, statusFilter ...string) ([]*schema.MFAFactor, error)

+ func (r *MFARepository) RevokeBypass(ctx context.Context, bypassID, revokedBy xid.ID) error

+ func (r *MFARepository) UpdateChallenge(ctx context.Context, challenge *schema.MFAChallenge) error

+ func (r *MFARepository) UpdateDeviceLastUsed(ctx context.Context, deviceID xid.ID) error

+ func (r *MFARepository) UpdateFactor(ctx context.Context, factor *schema.MFAFactor) error

+ func (r *MFARepository) UpdateFactorLastUsed(ctx context.Context, factorID xid.ID) error

+ func (r *MFARepository) UpdateSession(ctx context.Context, session *schema.MFASession) error

+ func (r *MFARepository) UpdateTrustedDevice(ctx context.Context, device *schema.MFATrustedDevice) error

+ func (r *MFARepository) UpsertPolicy(ctx context.Context, policy *schema.MFAPolicy) error

+ type MagicLinkRepository struct

+ func NewMagicLinkRepository(db *bun.DB) *MagicLinkRepository

+ func (r *MagicLinkRepository) Consume(ctx context.Context, rec *schema.MagicLink, now time.Time) error

+ func (r *MagicLinkRepository) Create(ctx context.Context, email, token string, appID xid.ID, ...) error

+ func (r *MagicLinkRepository) FindByToken(ctx context.Context, token string, appID xid.ID, userOrganizationID *xid.ID, ...) (*schema.MagicLink, error)

+ type MemberRepository struct

+ func NewMemberRepository(db *bun.DB) *MemberRepository

+ func (r *MemberRepository) CountByApp(ctx context.Context, appID xid.ID) (int, error)

+ func (r *MemberRepository) Create(ctx context.Context, member *schema.Member) error

+ func (r *MemberRepository) Delete(ctx context.Context, id xid.ID) error

+ func (r *MemberRepository) DeleteByUserID(ctx context.Context, userID xid.ID) error

+ func (r *MemberRepository) FindByID(ctx context.Context, id xid.ID) (*schema.Member, error)

+ func (r *MemberRepository) FindByUserAndApp(ctx context.Context, userID, appID xid.ID) (*schema.Member, error)

+ func (r *MemberRepository) ListByApp(ctx context.Context, appID xid.ID, role *schema.MemberRole, ...) ([]*schema.Member, int64, error)

+ func (r *MemberRepository) ListByUser(ctx context.Context, userID xid.ID) ([]*schema.Member, error)

+ func (r *MemberRepository) Update(ctx context.Context, member *schema.Member) error

+ type OAuthClientRepository struct

+ func NewOAuthClientRepository(db *bun.DB) *OAuthClientRepository

+ func (r *OAuthClientRepository) Create(ctx context.Context, c *schema.OAuthClient) error

+ func (r *OAuthClientRepository) Delete(ctx context.Context, id xid.ID) error

+ func (r *OAuthClientRepository) ExistsByClientID(ctx context.Context, clientID string) (bool, error)

+ func (r *OAuthClientRepository) FindByClientID(ctx context.Context, clientID string) (*schema.OAuthClient, error)

+ func (r *OAuthClientRepository) FindByClientIDWithContext(ctx context.Context, appID, envID xid.ID, orgID *xid.ID, clientID string) (*schema.OAuthClient, error)

+ func (r *OAuthClientRepository) FindByID(ctx context.Context, id xid.ID) (*schema.OAuthClient, error)

+ func (r *OAuthClientRepository) ListByApp(ctx context.Context, appID, envID xid.ID, limit, offset int) ([]*schema.OAuthClient, int, error)

+ func (r *OAuthClientRepository) ListByOrg(ctx context.Context, appID, envID, orgID xid.ID, limit, offset int) ([]*schema.OAuthClient, int, error)

+ func (r *OAuthClientRepository) Update(ctx context.Context, c *schema.OAuthClient) error

+ type OAuthConsentRepository struct

+ func NewOAuthConsentRepository(db *bun.DB) *OAuthConsentRepository

+ func (r *OAuthConsentRepository) Create(ctx context.Context, consent *schema.OAuthConsent) error

+ func (r *OAuthConsentRepository) Delete(ctx context.Context, id xid.ID) error

+ func (r *OAuthConsentRepository) DeleteByUserAndClient(ctx context.Context, userID xid.ID, clientID string) error

+ func (r *OAuthConsentRepository) DeleteExpired(ctx context.Context) error

+ func (r *OAuthConsentRepository) FindByUserAndClient(ctx context.Context, userID xid.ID, clientID string, appID, envID xid.ID, ...) (*schema.OAuthConsent, error)

+ func (r *OAuthConsentRepository) HasValidConsent(ctx context.Context, userID xid.ID, clientID string, requiredScopes []string, ...) (bool, error)

+ func (r *OAuthConsentRepository) ListByUser(ctx context.Context, userID xid.ID, appID, envID xid.ID, orgID *xid.ID) ([]*schema.OAuthConsent, error)

+ func (r *OAuthConsentRepository) Update(ctx context.Context, consent *schema.OAuthConsent) error

+ type OAuthTokenRepository struct

+ func NewOAuthTokenRepository(db *bun.DB) *OAuthTokenRepository

+ func (r *OAuthTokenRepository) Create(ctx context.Context, token *schema.OAuthToken) error

+ func (r *OAuthTokenRepository) DeleteExpired(ctx context.Context) error

+ func (r *OAuthTokenRepository) FindByAccessToken(ctx context.Context, accessToken string) (*schema.OAuthToken, error)

+ func (r *OAuthTokenRepository) FindByJTI(ctx context.Context, jti string) (*schema.OAuthToken, error)

+ func (r *OAuthTokenRepository) FindByRefreshToken(ctx context.Context, refreshToken string) (*schema.OAuthToken, error)

+ func (r *OAuthTokenRepository) FindByUserAndClient(ctx context.Context, userID xid.ID, clientID string) ([]*schema.OAuthToken, error)

+ func (r *OAuthTokenRepository) FindByUserInOrg(ctx context.Context, userID xid.ID, appID, envID xid.ID, orgID *xid.ID) ([]*schema.OAuthToken, error)

+ func (r *OAuthTokenRepository) RevokeAllForClient(ctx context.Context, clientID string) error

+ func (r *OAuthTokenRepository) RevokeAllForUser(ctx context.Context, userID xid.ID, appID, envID xid.ID, orgID *xid.ID) error

+ func (r *OAuthTokenRepository) RevokeByJTI(ctx context.Context, jti string) error

+ func (r *OAuthTokenRepository) RevokeByRefreshToken(ctx context.Context, refreshToken string) error

+ func (r *OAuthTokenRepository) RevokeBySession(ctx context.Context, sessionID xid.ID) error

+ func (r *OAuthTokenRepository) RevokeToken(ctx context.Context, accessToken string) error

+ func (r *OAuthTokenRepository) Update(ctx context.Context, token *schema.OAuthToken) error

+ func (r *OAuthTokenRepository) UpdateRefreshToken(ctx context.Context, accessToken, newRefreshToken string, ...) error

+ type PermissionRepository struct

+ func NewPermissionRepository(db *bun.DB) *PermissionRepository

+ func (r *PermissionRepository) Create(ctx context.Context, perm *schema.Permission) error

+ func (r *PermissionRepository) CreateCustomPermission(ctx context.Context, name, description, category string, orgID xid.ID) (*schema.Permission, error)

+ func (r *PermissionRepository) Delete(ctx context.Context, permissionID xid.ID) error

+ func (r *PermissionRepository) FindByID(ctx context.Context, permissionID xid.ID) (*schema.Permission, error)

+ func (r *PermissionRepository) FindByName(ctx context.Context, name string, appID xid.ID, orgID *xid.ID) (*schema.Permission, error)

+ func (r *PermissionRepository) ListByApp(ctx context.Context, appID xid.ID) ([]*schema.Permission, error)

+ func (r *PermissionRepository) ListByCategory(ctx context.Context, category string, appID xid.ID) ([]*schema.Permission, error)

+ func (r *PermissionRepository) ListByOrg(ctx context.Context, orgID xid.ID) ([]*schema.Permission, error)

+ func (r *PermissionRepository) Update(ctx context.Context, perm *schema.Permission) error

+ type PhoneRepository struct

+ func NewPhoneRepository(db *bun.DB) *PhoneRepository

+ func (r *PhoneRepository) Consume(ctx context.Context, rec *schema.PhoneVerification, now time.Time) error

+ func (r *PhoneRepository) Create(ctx context.Context, phone, code string, appID xid.ID, ...) error

+ func (r *PhoneRepository) FindByPhone(ctx context.Context, phone string, appID xid.ID, userOrganizationID *xid.ID, ...) (*schema.PhoneVerification, error)

+ func (r *PhoneRepository) IncrementAttempts(ctx context.Context, rec *schema.PhoneVerification) error

+ type PolicyRepository struct

+ func NewPolicyRepository(db *bun.DB) *PolicyRepository

+ func (r *PolicyRepository) Create(ctx context.Context, expression string) error

+ func (r *PolicyRepository) Delete(ctx context.Context, id xid.ID) error

+ func (r *PolicyRepository) List(ctx context.Context) ([]schema.Policy, error)

+ func (r *PolicyRepository) ListAll(ctx context.Context) ([]string, error)

+ func (r *PolicyRepository) Update(ctx context.Context, id xid.ID, expression string) error

+ type Repo struct

+ func (r *Repo) APIKey() *APIKeyRepository

+ func (r *Repo) App() *AppRepository

+ func (r *Repo) Audit() *AuditRepository

+ func (r *Repo) AuthorizationCode() *AuthorizationCodeRepository

+ func (r *Repo) Device() *DeviceRepository

+ func (r *Repo) EmailOTP() *EmailOTPRepository

+ func (r *Repo) Environment() environment.Repository

+ func (r *Repo) Forms() forms.Repository

+ func (r *Repo) IdentityVerification() *IdentityVerificationRepository

+ func (r *Repo) Impersonation() *ImpersonationRepository

+ func (r *Repo) JWTKey() *JWTKeyRepository

+ func (r *Repo) MFA() *MFARepository

+ func (r *Repo) MagicLink() *MagicLinkRepository

+ func (r *Repo) Notification() notification.Repository

+ func (r *Repo) OAuthClient() *OAuthClientRepository

+ func (r *Repo) OAuthToken() *OAuthTokenRepository

+ func (r *Repo) Organization() organization.OrganizationRepository

+ func (r *Repo) OrganizationInvitation() organization.InvitationRepository

+ func (r *Repo) OrganizationMember() organization.MemberRepository

+ func (r *Repo) OrganizationTeam() organization.TeamRepository

+ func (r *Repo) Permission() *PermissionRepository

+ func (r *Repo) Phone() *PhoneRepository

+ func (r *Repo) Policy() *PolicyRepository

+ func (r *Repo) Role() *RoleRepository

+ func (r *Repo) SSOProvider() *SSOProviderRepository

+ func (r *Repo) Security() *SecurityRepository

+ func (r *Repo) Session() *SessionRepository

+ func (r *Repo) SocialAccount() SocialAccountRepository

+ func (r *Repo) TwoFA() *TwoFARepository

+ func (r *Repo) User() *UserRepository

+ func (r *Repo) UserBan() *UserBanRepository

+ func (r *Repo) UserRole() *UserRoleRepository

+ func (r *Repo) Webhook() webhook.Repository

+ type Repository interface

+ APIKey func() *APIKeyRepository

+ App func() *AppRepository

+ Audit func() *AuditRepository

+ AuthorizationCode func() *AuthorizationCodeRepository

+ Device func() *DeviceRepository

+ EmailOTP func() *EmailOTPRepository

+ Environment func() environment.Repository

+ Forms func() forms.Repository

+ IdentityVerification func() *IdentityVerificationRepository

+ Impersonation func() *ImpersonationRepository

+ JWTKey func() *JWTKeyRepository

+ MFA func() *MFARepository

+ MagicLink func() *MagicLinkRepository

+ Notification func() notification.Repository

+ OAuthClient func() *OAuthClientRepository

+ OAuthToken func() *OAuthTokenRepository

+ Organization func() organization.OrganizationRepository

+ OrganizationInvitation func() organization.InvitationRepository

+ OrganizationMember func() organization.MemberRepository

+ OrganizationTeam func() organization.TeamRepository

+ Permission func() *PermissionRepository

+ Phone func() *PhoneRepository

+ Policy func() *PolicyRepository

+ Role func() *RoleRepository

+ SSOProvider func() *SSOProviderRepository

+ Security func() *SecurityRepository

+ Session func() *SessionRepository

+ SocialAccount func() SocialAccountRepository

+ TwoFA func() *TwoFARepository

+ User func() *UserRepository

+ UserBan func() *UserBanRepository

+ UserRole func() *UserRoleRepository

+ Webhook func() webhook.Repository

+ func NewRepo(db *bun.DB) Repository

+ type RolePermissionRepository struct

+ func NewRolePermissionRepository(db *bun.DB) *RolePermissionRepository

+ func (r *RolePermissionRepository) AssignPermission(ctx context.Context, roleID, permissionID xid.ID) error

+ func (r *RolePermissionRepository) GetPermissionRoles(ctx context.Context, permissionID xid.ID) ([]*schema.Role, error)

+ func (r *RolePermissionRepository) GetRolePermissions(ctx context.Context, roleID xid.ID) ([]*schema.Permission, error)

+ func (r *RolePermissionRepository) ReplaceRolePermissions(ctx context.Context, roleID xid.ID, permissionIDs []xid.ID) error

+ func (r *RolePermissionRepository) UnassignPermission(ctx context.Context, roleID, permissionID xid.ID) error

+ type RoleRepository struct

+ func NewRoleRepository(db *bun.DB) *RoleRepository

+ func (r *RoleRepository) CloneRole(ctx context.Context, templateID xid.ID, orgID xid.ID, customName *string) (*schema.Role, error)

+ func (r *RoleRepository) Create(ctx context.Context, role *schema.Role) error

+ func (r *RoleRepository) Delete(ctx context.Context, roleID xid.ID) error

+ func (r *RoleRepository) FindByID(ctx context.Context, roleID xid.ID) (*schema.Role, error)

+ func (r *RoleRepository) FindByNameAndApp(ctx context.Context, name string, appID xid.ID) (*schema.Role, error)

+ func (r *RoleRepository) GetOrgRoleWithPermissions(ctx context.Context, roleID xid.ID) (*schema.Role, error)

+ func (r *RoleRepository) GetOrgRoles(ctx context.Context, orgID xid.ID) ([]*schema.Role, error)

+ func (r *RoleRepository) GetOwnerRole(ctx context.Context, appID xid.ID) (*schema.Role, error)

+ func (r *RoleRepository) GetRoleTemplates(ctx context.Context, appID xid.ID) ([]*schema.Role, error)

+ func (r *RoleRepository) ListByOrg(ctx context.Context, orgID *string) ([]schema.Role, error)

+ func (r *RoleRepository) Update(ctx context.Context, role *schema.Role) error

+ type SSOProviderRepository struct

+ func NewSSOProviderRepository(db *bun.DB) *SSOProviderRepository

+ func (r *SSOProviderRepository) Create(ctx context.Context, p *schema.SSOProvider) error

+ func (r *SSOProviderRepository) Delete(ctx context.Context, id xid.ID) error

+ func (r *SSOProviderRepository) FindByDomain(ctx context.Context, domain string) ([]*schema.SSOProvider, error)

+ func (r *SSOProviderRepository) FindByProviderID(ctx context.Context, providerID string) (*schema.SSOProvider, error)

+ func (r *SSOProviderRepository) List(ctx context.Context) ([]*schema.SSOProvider, error)

+ func (r *SSOProviderRepository) Upsert(ctx context.Context, p *schema.SSOProvider) error

+ type SecurityRepository struct

+ func NewSecurityRepository(db *bun.DB) *SecurityRepository

+ func (r *SecurityRepository) Create(ctx context.Context, e *core.SecurityEvent) error

+ type SessionRepository struct

+ func NewSessionRepository(db *bun.DB) *SessionRepository

+ func (r *SessionRepository) CleanupExpiredSessions(ctx context.Context) (int, error)

+ func (r *SessionRepository) CountSessions(ctx context.Context, appID xid.ID, userID *xid.ID) (int, error)

+ func (r *SessionRepository) CreateSession(ctx context.Context, s *schema.Session) error

+ func (r *SessionRepository) FindSessionByID(ctx context.Context, id xid.ID) (*schema.Session, error)

+ func (r *SessionRepository) FindSessionByToken(ctx context.Context, token string) (*schema.Session, error)

+ func (r *SessionRepository) ListSessions(ctx context.Context, filter *session.ListSessionsFilter) (*pagination.PageResponse[*schema.Session], error)

+ func (r *SessionRepository) RevokeSession(ctx context.Context, token string) error

+ func (r *SessionRepository) RevokeSessionByID(ctx context.Context, id xid.ID) error

+ type SocialAccountRepository interface

+ Create func(ctx context.Context, account *schema.SocialAccount) error

+ Delete func(ctx context.Context, id xid.ID) error

+ FindByID func(ctx context.Context, id xid.ID) (*schema.SocialAccount, error)

+ FindByProviderAndProviderID func(ctx context.Context, provider, providerID string, appID xid.ID, ...) (*schema.SocialAccount, error)

+ FindByUser func(ctx context.Context, userID xid.ID) ([]*schema.SocialAccount, error)

+ FindByUserAndProvider func(ctx context.Context, userID xid.ID, provider string) (*schema.SocialAccount, error)

+ Unlink func(ctx context.Context, userID xid.ID, provider string) error

+ Update func(ctx context.Context, account *schema.SocialAccount) error

+ func NewSocialAccountRepository(db *bun.DB) SocialAccountRepository

+ type TeamRepository struct

+ func NewTeamRepository(db *bun.DB) *TeamRepository

+ func (r *TeamRepository) AddMember(ctx context.Context, teamID, memberID xid.ID, role string) error

+ func (r *TeamRepository) CountByApp(ctx context.Context, appID xid.ID) (int, error)

+ func (r *TeamRepository) CountTeamMembers(ctx context.Context, teamID xid.ID) (int, error)

+ func (r *TeamRepository) Create(ctx context.Context, team *schema.Team) error

+ func (r *TeamRepository) Delete(ctx context.Context, id xid.ID) error

+ func (r *TeamRepository) FindByID(ctx context.Context, id xid.ID) (*schema.Team, error)

+ func (r *TeamRepository) ListByApp(ctx context.Context, appID xid.ID, limit, offset int) ([]*schema.Team, int64, error)

+ func (r *TeamRepository) ListMembers(ctx context.Context, teamID xid.ID) ([]*schema.Member, error)

+ func (r *TeamRepository) RemoveMember(ctx context.Context, teamID, memberID xid.ID) error

+ func (r *TeamRepository) Update(ctx context.Context, team *schema.Team) error

+ type TwoFARepository struct

+ func NewTwoFARepository(db *bun.DB) *TwoFARepository

+ func (r *TwoFARepository) CreateBackupCodes(ctx context.Context, userID xid.ID, hashes []string) error

+ func (r *TwoFARepository) CreateOTPCode(ctx context.Context, userID xid.ID, codeHash string, expiresAt time.Time) error

+ func (r *TwoFARepository) DB() *bun.DB

+ func (r *TwoFARepository) DisableSecret(ctx context.Context, userID xid.ID) error

+ func (r *TwoFARepository) GetSecret(ctx context.Context, userID xid.ID) (*schema.TwoFASecret, error)

+ func (r *TwoFARepository) IsTrustedDevice(ctx context.Context, userID xid.ID, deviceID string, now time.Time) (bool, error)

+ func (r *TwoFARepository) MarkTrustedDevice(ctx context.Context, userID xid.ID, deviceID string, expiresAt time.Time) error

+ func (r *TwoFARepository) UpsertSecret(ctx context.Context, userID xid.ID, method, secret string, enabled bool) error

+ func (r *TwoFARepository) VerifyAndUseBackupCode(ctx context.Context, userID xid.ID, hash string) (bool, error)

+ func (r *TwoFARepository) VerifyOTPCode(ctx context.Context, userID xid.ID, codeHash string, now time.Time, ...) (bool, error)

+ type UserBanRepository struct

+ func NewUserBanRepository(db *bun.DB) *UserBanRepository

+ func (r *UserBanRepository) CreateBan(ctx context.Context, ban *schema.UserBan) error

+ func (r *UserBanRepository) FindActiveBan(ctx context.Context, userID string) (*schema.UserBan, error)

+ func (r *UserBanRepository) FindBanByID(ctx context.Context, banID string) (*schema.UserBan, error)

+ func (r *UserBanRepository) FindBansByUser(ctx context.Context, userID string) ([]*schema.UserBan, error)

+ func (r *UserBanRepository) UpdateBan(ctx context.Context, ban *schema.UserBan) error

+ type UserRepository struct

+ func NewUserRepository(db *bun.DB) *UserRepository

+ func (r *UserRepository) CountUsers(ctx context.Context, filter *core.CountUsersFilter) (int, error)

+ func (r *UserRepository) Create(ctx context.Context, user *schema.User) error

+ func (r *UserRepository) Delete(ctx context.Context, id xid.ID) error

+ func (r *UserRepository) FindByAppAndEmail(ctx context.Context, appID xid.ID, email string) (*schema.User, error)

+ func (r *UserRepository) FindByEmail(ctx context.Context, email string) (*schema.User, error)

+ func (r *UserRepository) FindByID(ctx context.Context, id xid.ID) (*schema.User, error)

+ func (r *UserRepository) FindByUsername(ctx context.Context, username string) (*schema.User, error)

+ func (r *UserRepository) ListUsers(ctx context.Context, filter *core.ListUsersFilter) (*pagination.PageResponse[*schema.User], error)

+ func (r *UserRepository) Update(ctx context.Context, user *schema.User) error

+ type UserRoleRepository struct

+ func NewUserRoleRepository(db *bun.DB) *UserRoleRepository

+ func (r *UserRoleRepository) Assign(ctx context.Context, userID, roleID, orgID xid.ID) error

+ func (r *UserRoleRepository) ListRolesForUser(ctx context.Context, userID xid.ID, orgID *xid.ID) ([]schema.Role, error)

+ func (r *UserRoleRepository) Unassign(ctx context.Context, userID, roleID, orgID xid.ID) error

+ type UsernameRepository struct

+ func NewUsernameRepository(db *bun.DB) *UsernameRepository

+ func (r *UsernameRepository) CheckPasswordInHistory(ctx context.Context, userID xid.ID, password string, limit int) (bool, error)

+ func (r *UsernameRepository) CleanupExpiredLockouts(ctx context.Context) error

+ func (r *UsernameRepository) CleanupOldFailedAttempts(ctx context.Context, before time.Time) error

+ func (r *UsernameRepository) CleanupOldPasswordHistory(ctx context.Context, userID xid.ID, keepCount int) error

+ func (r *UsernameRepository) ClearFailedAttempts(ctx context.Context, username string, appID xid.ID) error

+ func (r *UsernameRepository) GetFailedAttempts(ctx context.Context, username string, appID xid.ID, since time.Time) (int, error)

+ func (r *UsernameRepository) GetPasswordHistory(ctx context.Context, userID xid.ID, limit int) ([]string, error)

+ func (r *UsernameRepository) IsAccountLocked(ctx context.Context, userID xid.ID) (bool, *time.Time, error)

+ func (r *UsernameRepository) LockAccount(ctx context.Context, userID xid.ID, duration time.Duration, reason string) error

+ func (r *UsernameRepository) RecordFailedAttempt(ctx context.Context, username string, appID xid.ID, ip, ua string) error

+ func (r *UsernameRepository) SavePasswordHistory(ctx context.Context, userID xid.ID, passwordHash string) error

+ func (r *UsernameRepository) UnlockAccount(ctx context.Context, userID xid.ID) error

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