userimport

type AuthenticatorService interface {
	New(ctx context.Context, spec *authenticator.Spec) (*authenticator.Info, error)
	Create(ctx context.Context, info *authenticator.Info, markVerified bool) error
	List(ctx context.Context, userID string, filters ...authenticator.Filter) ([]*authenticator.Info, error)
	Delete(ctx context.Context, info *authenticator.Info) error
}

type CustomAttributesService interface {
	UpdateCustomAttributesWithList(ctx context.Context, role accesscontrol.Role, userID string, l attrs.List) error
}

type Detail struct {
	Index    int                   `json:"index"`
	Record   Record                `json:"record,omitempty"`
	Outcome  Outcome               `json:"outcome,omitempty"`
	UserID   string                `json:"user_id,omitempty"`
	Warnings []Warning             `json:"warnings,omitempty"`
	Errors   []*apierrors.APIError `json:"errors,omitempty"`
}

type IdentityService interface {
	New(ctx context.Context, userID string, spec *identity.Spec, options identity.NewIdentityOptions) (*identity.Info, error)
	UpdateWithSpec(ctx context.Context, info *identity.Info, spec *identity.Spec, options identity.NewIdentityOptions) (*identity.Info, error)

	Create(ctx context.Context, info *identity.Info) error
	Delete(ctx context.Context, info *identity.Info) error
	Update(ctx context.Context, oldInfo *identity.Info, newInfo *identity.Info) error
	CheckDuplicated(ctx context.Context, info *identity.Info) (dup *identity.Info, err error)
	ListByClaim(ctx context.Context, name string, value string) ([]*identity.Info, error)
	ListByUser(ctx context.Context, userID string) ([]*identity.Info, error)
}

type Job struct {
	ID        string    `json:"id"`
	CreatedAt time.Time `json:"created_at"`
	TaskIDs   []string  `json:"task_ids"`
}

type JobManager struct {
	AppID config.AppID
	Clock clock.Clock

	AdminAPIFeatureConfig *config.AdminAPIFeatureConfig
	TaskProducer          TaskProducer
	UsageLimiter          UsageLimiter
	Store                 Store
}

type MFA map[string]interface{}

type Options struct {
	Upsert     bool
	Identifier string
}

type Outcome string

type Password map[string]interface{}

type Record map[string]interface{}

type Request struct {
	Upsert     bool   `json:"upsert,omitempty"`
	Identifier string `json:"identifier,omitempty"`
	// Records is json.RawMessage because we want to delay the deserialization until we actually process the record.
	Records []json.RawMessage `json:"records,omitempty"`
}

type Response struct {
	ID          string                `json:"id,omitempty"`
	CreatedAt   *time.Time            `json:"created_at,omitempty"`
	CompletedAt *time.Time            `json:"completed_at,omitempty"`
	Status      redisqueue.TaskStatus `json:"status,omitempty"`
	Error       *apierrors.APIError   `json:"error,omitempty"`
	Summary     *Summary              `json:"summary,omitempty"`
	Details     []Detail              `json:"details,omitempty"`
}

type Result struct {
	Summary *Summary `json:"summary,omitempty"`
	Details []Detail `json:"details,omitempty"`
}

type ReusedSchemaBuilders struct {
	Email             validation.SchemaBuilder
	PhoneNumber       validation.SchemaBuilder
	PreferredUsername validation.SchemaBuilder
	FamilyName        validation.SchemaBuilder
	GivenName         validation.SchemaBuilder
	MiddleName        validation.SchemaBuilder
	Name              validation.SchemaBuilder
	Nickname          validation.SchemaBuilder
	Picture           validation.SchemaBuilder
	Profile           validation.SchemaBuilder
	Website           validation.SchemaBuilder
	Gender            validation.SchemaBuilder
	Birthdate         validation.SchemaBuilder
	Zoneinfo          validation.SchemaBuilder
	Locale            validation.SchemaBuilder
	Address           validation.SchemaBuilder
}

type RolesGroupsCommands interface {
	ResetUserGroup(ctx context.Context, options *rolesgroups.ResetUserGroupOptions) error
	ResetUserRole(ctx context.Context, options *rolesgroups.ResetUserRoleOptions) error
}

type SearchReindexService interface {
	MarkUsersAsReindexRequiredInTx(ctx context.Context, userIDs []string) error
	EnqueueReindexUserTask(ctx context.Context, userID string) error
}

type StandardAttributesService interface {
	UpdateStandardAttributes(ctx context.Context, role accesscontrol.Role, userID string, stdAttrs map[string]interface{}) error
}

type Store interface {
	CreateJob(ctx context.Context, job *Job) error
	GetJob(ctx context.Context, jobID string) (*Job, error)
}

type StoreRedis struct {
	AppID config.AppID
	Redis *appredis.Handle
}

type Summary struct {
	Total    int `json:"total"`
	Inserted int `json:"inserted"`
	Updated  int `json:"updated"`
	Skipped  int `json:"skipped"`
	Failed   int `json:"failed"`
}

type TOTP map[string]interface{}

type TaskProducer interface {
	NewTask(appID string, input json.RawMessage, taskIDPrefix string) *redisqueue.Task
	EnqueueTask(ctx context.Context, task *redisqueue.Task) error
	GetTask(ctx context.Context, item *redisqueue.QueueItem) (*redisqueue.Task, error)
}

type UsageLimiter interface {
	ReserveN(ctx context.Context, name usage.LimitName, n int, config *config.UsageLimitConfig) (*usage.Reservation, error)
}

type UserCommands interface {
	Create(ctx context.Context, userID string) (*user.User, error)
	UpdateAccountStatus(ctx context.Context, userID string, accountStatus user.AccountStatusWithRefTime) error
}

type UserImportService struct {
	AppDatabase          *appdb.Handle
	LoginIDConfig        *config.LoginIDConfig
	Identities           IdentityService
	Authenticators       AuthenticatorService
	UserCommands         UserCommands
	UserQueries          UserQueries
	VerifiedClaims       VerifiedClaimService
	StandardAttributes   StandardAttributesService
	CustomAttributes     CustomAttributesService
	RolesGroupsCommands  RolesGroupsCommands
	SearchReindexService SearchReindexService
	Clock                clock.Clock
}

type UserQueries interface {
	GetRaw(ctx context.Context, userID string) (*user.User, error)
}

type VerifiedClaimService interface {
	NewVerifiedClaim(ctx context.Context, userID string, claimName string, claimValue string) *verification.Claim

	MarkClaimVerified(ctx context.Context, claim *verification.Claim) error
	GetClaims(ctx context.Context, userID string) ([]*verification.Claim, error)
	DeleteClaim(ctx context.Context, claim *verification.Claim) error
}

type Warning struct {
	Message string `json:"message,omitempty"`
}