db

type Accounts struct {
	ID       sql.NullString
	Github   sql.NullString
	Facebook sql.NullString
	Google   sql.NullString

	User *User
}

type DB interface {
	GetUserByLogin(ctx context.Context, login string) (*User, error)
	GetAnyUserByLogin(ctx context.Context, login string) (*User, error)
	GetUserByID(ctx context.Context, id string) (*User, error)
	GetAnyUserByID(ctx context.Context, id string) (*User, error)
	GetUsersLoginID(ctx context.Context, ids []string) ([]User, error)
	CreateUser(ctx context.Context, user *User) error
	UpdateUser(ctx context.Context, user *User) error
	GetBlacklistedUsers(ctx context.Context, limit, offset int) ([]User, error)
	BlacklistUser(ctx context.Context, user *User) error
	UnBlacklistUser(ctx context.Context, user *User) error

	CreateProfile(ctx context.Context, profile *Profile) error
	GetProfileByID(ctx context.Context, id string) (*Profile, error)
	GetProfileByUser(ctx context.Context, user *User) (*Profile, error)
	UpdateProfile(ctx context.Context, profile *Profile) error
	GetAllProfiles(ctx context.Context, perPage, offset int) ([]UserProfileAccounts, error)

	GetUserByBoundAccount(ctx context.Context, service models.OAuthResource, accountID string) (*User, error)
	GetUserBoundAccounts(ctx context.Context, user *User) (*Accounts, error)
	BindAccount(ctx context.Context, user *User, service models.OAuthResource, accountID string) error
	DeleteBoundAccount(ctx context.Context, user *User, service models.OAuthResource) error

	BlacklistDomain(ctx context.Context, domain string, userID string) error
	UnBlacklistDomain(ctx context.Context, domain string) error
	IsDomainBlacklisted(ctx context.Context, domain string) (bool, error)
	GetBlacklistedDomain(ctx context.Context, domain string) (*DomainBlacklistEntry, error)
	GetBlacklistedDomainsList(ctx context.Context) ([]DomainBlacklistEntry, error)

	CreateLink(ctx context.Context, linkType models.LinkType, lifeTime time.Duration, user *User) (*Link, error)
	GetLinkForUser(ctx context.Context, linkType models.LinkType, user *User) (*Link, error)
	GetLinkFromString(ctx context.Context, strLink string) (*Link, error)
	UpdateLink(ctx context.Context, link *Link) error
	GetUserLinks(ctx context.Context, user *User) ([]Link, error)

	GetTokenObject(ctx context.Context, token string) (*Token, error)
	CreateToken(ctx context.Context, user *User, sessionID string) (*Token, error)
	GetTokenBySessionID(ctx context.Context, sessionID string) (*Token, error)
	DeleteToken(ctx context.Context, token string) error
	UpdateToken(ctx context.Context, token *Token) error

	GetGroup(ctx context.Context, groupID string) (*UserGroup, error)
	GetGroupMembers(ctx context.Context, groupID string) ([]UserGroupMember, error)
	GetUserGroupsIDsAccesses(ctx context.Context, userID string) (map[string]string, error)
	CreateGroup(ctx context.Context, group *UserGroup) error
	DeleteGroup(ctx context.Context, groupID string) error

	AddGroupMembers(ctx context.Context, member *UserGroupMember) error
	DeleteGroupMember(ctx context.Context, userID string, groupID string) error
	UpdateGroupMember(ctx context.Context, userID string, groupID string, access string) error
	CountGroupMembers(ctx context.Context, groupID string) (*uint, error)

	GetAnyUserByLoginWOContext(login string) (*User, error)
	CreateUserWOContext(user *User) error
	CreateProfileWOContext(profile *Profile) error
	UpdateUserWOContext(user *User) error
	// Perform operations inside transaction
	// Transaction commits if `f` returns nil error, rollbacks and forwards error otherwise
	// May return ErrTransactionBegin if transaction start failed,
	// ErrTransactionCommit if commit failed, ErrTransactionRollback if rollback failed
	Transactional(ctx context.Context, f func(ctx context.Context, tx DB) error) error

	io.Closer
}

type DomainBlacklistEntry struct {
	Domain    string         `db:"domain"`
	CreatedAt time.Time      `db:"created_at"`
	AddedBy   sql.NullString `db:"added_by"`
}

type Link struct {
	Link      string
	Type      models.LinkType
	CreatedAt time.Time
	ExpiredAt time.Time
	IsActive  bool
	SentAt    pq.NullTime

	User *User
}

type Profile struct {
	ID          sql.NullString
	Referral    sql.NullString
	Access      sql.NullString
	CreatedAt   pq.NullTime
	BlacklistAt pq.NullTime
	DeletedAt   pq.NullTime

	User *User

	Data map[string]interface{}
}

type Token struct {
	Token     string
	CreatedAt time.Time
	IsActive  bool
	SessionID string

	User *User
}

type User struct {
	ID            string `db:"id"`
	Login         string `db:"login"`
	PasswordHash  string `db:"password_hash"` // base64
	Salt          string `db:"salt"`          // base64
	Role          string `db:"role"`
	IsActive      bool   `db:"is_active"`
	IsDeleted     bool   `db:"is_deleted"`
	IsInBlacklist bool   `db:"is_in_blacklist"`
}

type UserGroup struct {
	ID         string      `db:"id"`
	Label      string      `db:"label"`
	OwnerID    string      `db:"owner_user_id"`
	OwnerLogin string      `db:"owner_login"`
	CreatedAt  pq.NullTime `db:"created_at"`
}

type UserGroupMember struct {
	ID      string      `db:"id"`
	GroupID string      `db:"group_id"`
	UserID  string      `db:"user_id"`
	Access  string      `db:"default_access"`
	AddedAt pq.NullTime `db:"added_at"`
}

type UserProfileAccounts struct {
	User     *User
	Profile  *Profile
	Accounts *Accounts
}