inventory

type CopyParameter struct {
	Files                []*ent.File
	DstMap               map[int][]*ent.File
	ExcludedMetadataKeys []string
}

type CreateDavAccountParams struct {
	UserID   int
	Name     string
	URI      string
	Password string
	Options  *boolset.BooleanSet
}

type CreateFileParameters struct {
	FileType            types.FileType
	Name                string
	Metadata            map[string]string
	MetadataPrivateMask map[string]bool
	IsSymbolic          bool
	StoragePolicyID     int
	*EntityParameters
}

type CreateFolderParameters struct {
	Owner               int
	Name                string
	IsSymbolic          bool
	Metadata            map[string]string
	MetadataPrivateMask map[string]bool
}

type CreateShareParams struct {
	Existed         *ent.Share
	Password        string
	RemainDownloads int
	Expires         *time.Time
	OwnerID         int
	FileID          int
	Props           *types.ShareProps
}

type CreateStoragePackArgs struct {
	UserID   int
	Name     string
	Size     int64
	ExpireAt time.Time
}

type DavAccountClient interface {
	TxOperator
	// List returns a list of dav accounts with the given args.
	List(ctx context.Context, args *ListDavAccountArgs) (*ListDavAccountResult, error)
	// Create creates a new dav account.
	Create(ctx context.Context, params *CreateDavAccountParams) (*ent.DavAccount, error)
	// Update updates a dav account.
	Update(ctx context.Context, id int, params *CreateDavAccountParams) (*ent.DavAccount, error)
	// GetByIDAndUserID returns the dav account with given id and user id.
	GetByIDAndUserID(ctx context.Context, id, userID int) (*ent.DavAccount, error)
	// Delete deletes the dav account.
	Delete(ctx context.Context, id int) error
}

type DeleteTaskArgs struct {
	NotAfter time.Time
	Types    []string
	Status   []task.Status
}

type DirectLinkClient interface {
	TxOperator
	// GetByNameID get direct link by name and id
	GetByNameID(ctx context.Context, id int, name string) (*ent.DirectLink, error)
	// GetByID get direct link by id
	GetByID(ctx context.Context, id int) (*ent.DirectLink, error)
	// Delete delete direct link by id
	Delete(ctx context.Context, id int) error
}

type EntityParameters struct {
	ModifiedAt      *time.Time
	OwnerID         int
	EntityType      types.EntityType
	StoragePolicyID int
	Source          string
	Size            int64
	UploadSessionID uuid.UUID
	Importing       bool
	EncryptMetadata *types.EncryptMetadata
}

type FileClient interface {
	TxOperator
	// GetByHashID returns a file by its hashID.
	GetByHashID(ctx context.Context, hashID string) (*ent.File, error)
	// GetParentFile returns the parent folder of a given file
	GetParentFile(ctx context.Context, root *ent.File, eagerLoading bool) (*ent.File, error)
	// Search file by name from a given root. eagerLoading indicates whether to load edges determined by ctx.
	GetChildFile(ctx context.Context, root *ent.File, ownerID int, child string, eagerLoading bool) (*ent.File, error)
	// Get all files under a given root
	GetChildFiles(ctx context.Context, args *ListFileParameters, ownerID int, roots ...*ent.File) (*ListFileResult, error)
	// Root returns the root folder of a given user
	Root(ctx context.Context, user *ent.User) (*ent.File, error)
	// CreateOrGetFolder creates a folder with given name under root, or return the existed one
	CreateFolder(ctx context.Context, root *ent.File, args *CreateFolderParameters) (*ent.File, error)
	// GetByIDs returns files with given IDs. The result is paginated. Caller should keep calling this until
	// returned next page is negative.
	GetByIDs(ctx context.Context, ids []int, page int) ([]*ent.File, int, error)
	// GetByID returns a file by its ID.
	GetByID(ctx context.Context, ids int) (*ent.File, error)
	// GetEntitiesByIDs returns entities with given IDs. The result is paginated. Caller should keep calling this until
	// returned next page is negative.
	GetEntitiesByIDs(ctx context.Context, ids []int, page int) ([]*ent.Entity, int, error)
	// GetEntityByID returns an entity by its ID.
	GetEntityByID(ctx context.Context, id int) (*ent.Entity, error)
	// Rename renames a file
	Rename(ctx context.Context, original *ent.File, newName string) (*ent.File, error)
	// SetParent sets parent of group of files
	SetParent(ctx context.Context, files []*ent.File, parent *ent.File) error
	// CreateFile creates a file with given parameters, returns created File, default Entity, and storage diff for owner.
	CreateFile(ctx context.Context, root *ent.File, args *CreateFileParameters) (*ent.File, *ent.Entity, StorageDiff, error)
	// UpgradePlaceholder upgrades a placeholder entity to a real version entity
	UpgradePlaceholder(ctx context.Context, file *ent.File, modifiedAt *time.Time, entityId int, entityType types.EntityType) error
	// RemoveMetadata removes metadata from a file
	RemoveMetadata(ctx context.Context, file *ent.File, keys ...string) error
	// CreateEntity creates an entity with given parameters, returns created Entity, and storage diff for owner.
	CreateEntity(ctx context.Context, file *ent.File, args *EntityParameters) (*ent.Entity, StorageDiff, error)
	// RemoveStaleEntities hard-delete stale placeholder entities
	RemoveStaleEntities(ctx context.Context, file *ent.File) (StorageDiff, error)
	// RemoveEntitiesByID hard-delete entities by IDs.
	RemoveEntitiesByID(ctx context.Context, ids ...int) (map[int]int64, error)
	// CapEntities caps the number of entities of a given file. The oldest entities will be unlinked
	// if entity count exceed limit.
	CapEntities(ctx context.Context, file *ent.File, owner *ent.User, max int, entityType types.EntityType) (StorageDiff, error)
	// UpsertMetadata update or insert metadata
	UpsertMetadata(ctx context.Context, file *ent.File, data map[string]string, privateMask map[string]bool) error
	// Copy copies a layer of file to its corresponding destination folder. dstMap is a map from src parent ID to dst parent Files.
	Copy(ctx context.Context, args *CopyParameter) (map[int][]*ent.File, StorageDiff, error)
	// Delete deletes a group of files (and related models) with given entity recycle option
	Delete(ctx context.Context, files []*ent.File, options *types.EntityProps) ([]*ent.Entity, StorageDiff, error)
	// StaleEntities returns stale entities of a given file. If ID is not provided, all entities
	// will be examined.
	StaleEntities(ctx context.Context, ids ...int) ([]*ent.Entity, error)
	// QueryMetadata load metadata of a given file
	QueryMetadata(ctx context.Context, root *ent.File) error
	// SoftDelete soft-deletes a file, also renaming it to a random name
	SoftDelete(ctx context.Context, file *ent.File) error
	// SetPrimaryEntity sets primary entity of a file
	SetPrimaryEntity(ctx context.Context, file *ent.File, entity *ent.Entity) error
	// UnlinkEntity unlinks an entity from a file
	UnlinkEntity(ctx context.Context, entity *ent.Entity, file *ent.File, owner *ent.User) (StorageDiff, error)
	// CreateDirectLink creates a direct link for a file
	CreateDirectLink(ctx context.Context, fileID int, name string, speed int, reuse bool) (*ent.DirectLink, error)
	// CountIndexableFiles counts files suitable for FTS indexing (non-empty name, has parent, is file type).
	CountIndexableFiles(ctx context.Context) (int, error)
	// ListIndexableFiles lists files suitable for FTS indexing, returning up to limit files
	// with ID strictly greater than afterID. Use afterID=0 to start from the beginning.
	ListIndexableFiles(ctx context.Context, afterID, limit int) ([]*ent.File, error)
	// CountByTimeRange counts files created in a given time range
	CountByTimeRange(ctx context.Context, start, end *time.Time) (int, error)
	// CountEntityByTimeRange counts entities created in a given time range
	CountEntityByTimeRange(ctx context.Context, start, end *time.Time) (int, error)
	// CountEntityByStoragePolicyID counts entities by storage policy ID
	CountEntityByStoragePolicyID(ctx context.Context, storagePolicyID int) (int, int, error)
	// IsStoragePolicyUsedByEntities checks if a storage policy is used by entities
	IsStoragePolicyUsedByEntities(ctx context.Context, policyID int) (bool, error)
	// DeleteByUser deletes all files by a given user
	DeleteByUser(ctx context.Context, uid int) error
	// FlattenListFiles list files ignoring hierarchy
	FlattenListFiles(ctx context.Context, args *FlattenListFileParameters) (*ListFileResult, error)
	// Update updates a file
	Update(ctx context.Context, file *ent.File) (*ent.File, error)
	// ListEntities lists entities
	ListEntities(ctx context.Context, args *ListEntityParameters) (*ListEntityResult, error)
	// UpdateProps updates props of a file
	UpdateProps(ctx context.Context, file *ent.File, props *types.FileProps) (*ent.File, error)
	// UpdateModifiedAt updates modified at of a file
	UpdateModifiedAt(ctx context.Context, file *ent.File, modifiedAt time.Time) error
	// DeleteAllMetadataByName deletes all metadata by a given name
	DeleteAllMetadataByName(ctx context.Context, name string) error
}

type FlattenListFileParameters struct {
	*PaginationArgs
	UserID          int
	Name            string
	StoragePolicyID int
	HasMetadata     string
	Shared          bool
	HasDirectLink   bool
}

type FsEventClient interface {
	TxOperator
	// Create a new FsEvent
	Create(ctx context.Context, uid int, subscriberId uuid.UUID, events ...string) error
	// Delete all FsEvents by subscriber
	DeleteBySubscriber(ctx context.Context, subscriberId uuid.UUID) error
	// Delete all FsEvents
	DeleteAll(ctx context.Context) error
	// Get all FsEvents by subscriber and user
	TakeBySubscriber(ctx context.Context, subscriberId uuid.UUID, userId int) ([]*ent.FsEvent, error)
}

type GroupClient interface {
	TxOperator
	// AnonymousGroup returns the anonymous group.
	AnonymousGroup(ctx context.Context) (*ent.Group, error)
	// ListAll returns all groups.
	ListAll(ctx context.Context) ([]*ent.Group, error)
	// GetByID returns the group by id.
	GetByID(ctx context.Context, id int) (*ent.Group, error)
	// ListGroups returns a list of groups with pagination.
	ListGroups(ctx context.Context, args *ListGroupParameters) (*ListGroupResult, error)
	// CountUsers returns the number of users in the group.
	CountUsers(ctx context.Context, id int) (int, error)
	// Upsert upserts a group.
	Upsert(ctx context.Context, group *ent.Group) (*ent.Group, error)
	// Delete deletes a group.
	Delete(ctx context.Context, id int) error
}

type ListDavAccountArgs struct {
	*PaginationArgs
	UserID int
}

type ListDavAccountResult struct {
	*PaginationResults
	Accounts []*ent.DavAccount
}

type ListEntityParameters struct {
	*PaginationArgs
	EntityType      *types.EntityType
	UserID          int
	StoragePolicyID int
}

type ListEntityResult struct {
	Entities []*ent.Entity
	*PaginationResults
}

type ListFileParameters struct {
	*PaginationArgs
	// Whether to mix folder with files in results, only applied to cursor pagination
	MixedType bool
	// Whether to include only folder in results, only applied to cursor pagination
	FolderOnly bool
	// SharedWithMe indicates whether to list files shared with the user
	SharedWithMe bool
	Search       *SearchFileParameters
}

type ListFileResult struct {
	Files     []*ent.File
	MixedType bool
	*PaginationResults
}

type ListGroupParameters struct {
	*PaginationArgs
}

type ListGroupResult struct {
	*PaginationResults
	Groups []*ent.Group
}

type ListNodeParameters struct {
	*PaginationArgs
	Status node.Status
}

type ListNodeResult struct {
	*PaginationResults
	Nodes []*ent.Node
}

type ListOAuthClientArgs struct {
	*PaginationArgs
	Name      string
	IsEnabled *bool
}

type ListOAuthClientResult struct {
	*PaginationResults
	Clients []*ent.OAuthClient
}

type ListPolicyParameters struct {
	*PaginationArgs
	Type types.PolicyType
}

type ListPolicyResult struct {
	*PaginationResults
	Policies []*ent.StoragePolicy
}

type ListShareArgs struct {
	*PaginationArgs
	UserID     int
	FileID     int
	PublicOnly bool
	ShareIDs   []int
}

type ListShareResult struct {
	*PaginationResults
	Shares []*ent.Share
}

type ListTaskArgs struct {
	*PaginationArgs
	Types         []string
	Status        []task.Status
	UserID        int
	CorrelationID *uuid.UUID
}

type ListTaskResult struct {
	*PaginationResults
	Tasks []*ent.Task
}

type ListUserParameters struct {
	*PaginationArgs
	GroupID int
	Status  user.Status
	Nick    string
	Email   string
}

type ListUserResult struct {
	*PaginationResults
	Users []*ent.User
}

type LoadDirectLinkFile struct{}

type LoadEntityFile struct{}

type LoadEntityStoragePolicy struct{}

type LoadEntityUser struct{}

type LoadFileDirectLink struct{}

type LoadFileEntity struct{}

type LoadFileMetadata struct{}

type LoadFilePublicMetadata struct{}

type LoadFileShare struct{}

type LoadFileUser struct{}

type LoadGroupPolicy struct{}

type LoadNodeStoragePolicy struct{}

type LoadOAuthGrantClient struct{}

type LoadShareFile struct{}

type LoadShareUser struct{}

type LoadStoragePolicyGroup struct{}

type LoadTaskUser struct{}

type LoadUserGroup struct{}

type LoadUserPasskey struct{}

type MailTemplateContent struct {
	Language        string
	EmailIsAutoSend string // Translation of `此邮件由系统自动发送。`

	ActiveTitle  string // Translation of `激活你的账号`
	ActiveDes    string // Translation of `请点击下方按钮确认你的电子邮箱并完成账号注册，此链接有效期为 24 小时。`
	ActiveButton string // Translation of `确认激活`

	ResetTitle  string // Translation of `重设密码`
	ResetDes    string // Translation of `请点击下方按钮重设你的密码，此链接有效期为 1 小时。`
	ResetButton string // Translation of `重设密码`
}

type MetadataFilter struct {
	Key   string
	Value string
	Exact bool
}

type NewUserArgs struct {
	Email         string
	Nick          string // Optional
	PlainPassword string
	Status        user.Status
	GroupID       int
	Avatar        string // Optional
	Language      string // Optional
}

type NodeClient interface {
	TxOperator
	// ListActiveNodes returns the active nodes.
	ListActiveNodes(ctx context.Context, subset []int) ([]*ent.Node, error)
	// ListNodes returns the nodes with pagination.
	ListNodes(ctx context.Context, args *ListNodeParameters) (*ListNodeResult, error)
	// GetNodeById returns the node by id.
	GetNodeById(ctx context.Context, id int) (*ent.Node, error)
	// GetNodeByIds returns the nodes by ids.
	GetNodeByIds(ctx context.Context, ids []int) ([]*ent.Node, error)
	// Upsert upserts a node.
	Upsert(ctx context.Context, n *ent.Node) (*ent.Node, error)
	// Delete deletes a node.
	Delete(ctx context.Context, id int) error
}

type OAuthClientClient interface {
	TxOperator
	// GetByGUID returns the OAuth client by its GUID (client_id).
	GetByGUID(ctx context.Context, guid string) (*ent.OAuthClient, error)
	// GetByGUIDWithGrants returns the OAuth client by its GUID (client_id) with the grants for the user.
	GetByGUIDWithGrants(ctx context.Context, guid string, uid int) (*ent.OAuthClient, error)
	// UpsertGrant creates or updates an OAuth grant for a user and client.
	UpsertGrant(ctx context.Context, userID, clientID int, scopes []string) error
	// UpdateGrantLastUsedAt updates the last used at for an OAuth grant for a user and client.
	UpdateGrantLastUsedAt(ctx context.Context, userID, clientID int) error
	// DeleteGrantByUserAndClientGUID deletes an OAuth grant for a user by the client GUID.
	// Returns true if the grant was deleted, false if it was not found.
	DeleteGrantByUserAndClientGUID(ctx context.Context, userID int, clientGUID string) (bool, error)
	// List returns a paginated list of OAuth clients.
	List(ctx context.Context, args *ListOAuthClientArgs) (*ListOAuthClientResult, error)
	// GetByID returns the OAuth client by its ID.
	GetByID(ctx context.Context, id int) (*ent.OAuthClient, error)
	// Create creates a new OAuth client.
	Create(ctx context.Context, client *ent.OAuthClient) (*ent.OAuthClient, error)
	// Update updates an existing OAuth client.
	Update(ctx context.Context, client *ent.OAuthClient) (*ent.OAuthClient, error)
	// Delete deletes an OAuth client by its ID.
	Delete(ctx context.Context, id int) error
	// CountGrants returns the number of grants for an OAuth client.
	CountGrants(ctx context.Context, id int) (int, error)
	// GetGrantsByUserID returns the OAuth grants for a user.
	GetGrantsByUserID(ctx context.Context, userID int) ([]*ent.OAuthGrant, error)
}

type OrderDirection string

type PageToken struct {
	Time          *time.Time `json:"time,omitempty"`
	ID            int        `json:"-"`
	IDHash        string     `json:"id,omitempty"`
	String        string     `json:"string,omitempty"`
	Int           int        `json:"int,omitempty"`
	StartWithFile bool       `json:"start_with_file,omitempty"`
}

type PaginationArgs struct {
	UseCursorPagination bool
	Page                int
	PageToken           string
	PageSize            int
	OrderBy             string
	Order               OrderDirection
}

type PaginationResults struct {
	Page          int    `json:"page"`
	PageSize      int    `json:"page_size"`
	TotalItems    int    `json:"total_items,omitempty"`
	NextPageToken string `json:"next_token,omitempty"`
	IsCursor      bool   `json:"is_cursor,omitempty"`
}

type Patch struct {
	Name       string
	EndVersion string
	Func       PatchFunc
}

type PatchFunc func(l logging.Logger, client *ent.Client, ctx context.Context) error

type RelocateEntityParameter struct {
	Entity                   *ent.Entity
	NewSource                string
	ParentFiles              []int
	PrimaryEntityParentFiles []int
}

type SearchFileParameters struct {
	Name []string
	// NameOperatorOr is true if the name should match any of the given names, false if all of them
	NameOperatorOr bool
	Metadata       []MetadataFilter
	Type           *types.FileType
	UseFullText    bool
	CaseFolding    bool
	Category       string
	SizeGte        int64
	SizeLte        int64
	CreatedAtGte   *time.Time
	CreatedAtLte   *time.Time
	UpdatedAtGte   *time.Time
	UpdatedAtLte   *time.Time
}

type SettingClient interface {
	TxOperator
	// Get gets a setting value from DB, returns error if setting cannot be found.
	Get(ctx context.Context, name string) (string, error)
	// Set sets a setting value to DB.
	Set(ctx context.Context, settings map[string]string) error
	// Gets gets multiple setting values from DB, returns error if any setting cannot be found.
	Gets(ctx context.Context, names []string) (map[string]string, error)
}

type ShareClient interface {
	TxOperator
	// GetByIDs returns the shares with given ids.
	GetByIDs(ctx context.Context, ids []int) ([]*ent.Share, error)
	// GetByID returns the share with given id.
	GetByID(ctx context.Context, id int) (*ent.Share, error)
	// GetByIDUser returns the share with given id and user id.
	GetByIDUser(ctx context.Context, id, uid int) (*ent.Share, error)
	// GetByHashID returns the share with given hash id.
	GetByHashID(ctx context.Context, idRaw string) (*ent.Share, error)
	// Upsert creates or update a new share record.
	Upsert(ctx context.Context, params *CreateShareParams) (*ent.Share, error)
	// Viewed increase the view count of the share.
	Viewed(ctx context.Context, share *ent.Share) error
	// Downloaded increase the download count of the share.
	Downloaded(ctx context.Context, share *ent.Share) error
	// Delete deletes the share.
	Delete(ctx context.Context, shareId int) error
	// List returns a list of shares with the given args.
	List(ctx context.Context, args *ListShareArgs) (*ListShareResult, error)
	// CountByTimeRange counts the number of shares created in the given time range.
	CountByTimeRange(ctx context.Context, start, end *time.Time) (int, error)
	// DeleteBatch deletes the shares with the given ids.
	DeleteBatch(ctx context.Context, shareIds []int) error
}

type SkipStoragePolicyCache struct{}

type StorageDiff map[int]int64

type StoragePolicyClient interface {
	TxOperator
	// GetByGroup returns the storage policies of the group.
	GetByGroup(ctx context.Context, group *ent.Group) (*ent.StoragePolicy, error)
	// GetPolicyByID returns the storage policy by id.
	GetPolicyByID(ctx context.Context, id int) (*ent.StoragePolicy, error)
	// UpdateAccessKey updates the access key of the storage policy. It also clear related cache in KV.
	UpdateAccessKey(ctx context.Context, policy *ent.StoragePolicy, token string) error
	// ListPolicyByType returns the storage policies by type.
	ListPolicyByType(ctx context.Context, t types.PolicyType) ([]*ent.StoragePolicy, error)
	// ListPolicies returns the storage policies with pagination.
	ListPolicies(ctx context.Context, args *ListPolicyParameters) (*ListPolicyResult, error)
	// Upsert upserts the storage policy.
	Upsert(ctx context.Context, policy *ent.StoragePolicy) (*ent.StoragePolicy, error)
	// Delete deletes the storage policy.
	Delete(ctx context.Context, policy *ent.StoragePolicy) error
}

type TaskArgs struct {
	Status        task.Status
	Type          string
	PublicState   *types.TaskPublicState
	PrivateState  string
	OwnerID       int
	CorrelationID uuid.UUID
}

type TaskClient interface {
	TxOperator
	// New creates a new task with the given args.
	New(ctx context.Context, task *TaskArgs) (*ent.Task, error)
	// Update updates the task with the given args.
	Update(ctx context.Context, task *ent.Task, args *TaskArgs) (*ent.Task, error)
	// GetPendingTasks returns all pending tasks of given type.
	GetPendingTasks(ctx context.Context, taskType ...string) ([]*ent.Task, error)
	// GetTaskByID returns the task with the given ID.
	GetTaskByID(ctx context.Context, taskID int) (*ent.Task, error)
	// SetCompleteByID sets the task with the given ID to complete.
	SetCompleteByID(ctx context.Context, taskID int) error
	// List returns a list of tasks with the given args.
	List(ctx context.Context, args *ListTaskArgs) (*ListTaskResult, error)
	// DeleteByIDs deletes the tasks with the given IDs.
	DeleteByIDs(ctx context.Context, ids ...int) error
	// DeleteBy deletes the tasks with the given args.
	DeleteBy(ctx context.Context, args *DeleteTaskArgs) error
}

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

type TxCtx struct{}

type TxOperator interface {
	SetClient(newClient *ent.Client) TxOperator
	GetClient() *ent.Client
}

type UserClient interface {
	TxOperator
	// New creates a new user. If user email registered, existed User will be returned.
	Create(ctx context.Context, args *NewUserArgs) (*ent.User, error)
	// GetByEmail get the user with given email, user status is ignored.
	GetByEmail(ctx context.Context, email string) (*ent.User, error)
	// GetByID get user by its ID, user status is ignored.
	GetByID(ctx context.Context, id int) (*ent.User, error)
	// GetActiveByID get user by its ID, only active user will be returned.
	GetActiveByID(ctx context.Context, id int) (*ent.User, error)
	// SetStatus Set user to given status
	SetStatus(ctx context.Context, u *ent.User, status user.Status) (*ent.User, error)
	// AnonymousUser returns the anonymous user.
	AnonymousUser(ctx context.Context) (*ent.User, error)
	// GetLoginUserByID returns the login user by its ID. It emits some errors and fallback to anonymous user.
	GetLoginUserByID(ctx context.Context, uid int) (*ent.User, error)
	// GetLoginUserByEmail returns the login user by its WebDAV credentials.
	GetActiveByDavAccount(ctx context.Context, email, pwd string) (*ent.User, error)
	// SaveSettings saves user settings.
	SaveSettings(ctx context.Context, u *ent.User) error
	// SearchActive search active users by Email or nickname.
	SearchActive(ctx context.Context, limit int, keyword string) ([]*ent.User, error)
	// ApplyStorageDiff apply storage diff to user.
	ApplyStorageDiff(ctx context.Context, diffs StorageDiff) error
	// UpdateAvatar updates user avatar.
	UpdateAvatar(ctx context.Context, u *ent.User, avatar string) (*ent.User, error)
	// UpdateNickname updates user nickname.
	UpdateNickname(ctx context.Context, u *ent.User, name string) (*ent.User, error)
	// UpdatePassword updates user password.
	UpdatePassword(ctx context.Context, u *ent.User, newPassword string) (*ent.User, error)
	// UpdateTwoFASecret updates user two factor secret.
	UpdateTwoFASecret(ctx context.Context, u *ent.User, secret string) (*ent.User, error)
	// ListPasskeys list user's passkeys.
	ListPasskeys(ctx context.Context, uid int) ([]*ent.Passkey, error)
	// AddPasskey add passkey to user.
	AddPasskey(ctx context.Context, uid int, name string, credential *webauthn.Credential) (*ent.Passkey, error)
	// RemovePasskey remove passkey from user.
	RemovePasskey(ctx context.Context, uid int, keyId string) error
	// MarkPasskeyUsed updates passkey used at.
	MarkPasskeyUsed(ctx context.Context, uid int, keyId string) error
	// CountByTimeRange count users by time range. Will return all records if start or end is nil.
	CountByTimeRange(ctx context.Context, start, end *time.Time) (int, error)
	// ListUsers list users with pagination.
	ListUsers(ctx context.Context, args *ListUserParameters) (*ListUserResult, error)
	// Upsert upserts a user.
	Upsert(ctx context.Context, u *ent.User, password, twoFa string) (*ent.User, error)
	// Delete deletes a user.
	Delete(ctx context.Context, uid int) error
	// CalculateStorage calculate user's storage from scratch and update user's storage.
	CalculateStorage(ctx context.Context, uid int) (int64, error)
}

type UserCtx struct{}

type UserIDCtx struct{}