package mongo

import (
	"context"

	"github.com/cuigh/swirl/dao"
	"go.mongodb.org/mongo-driver/bson"
	"go.mongodb.org/mongo-driver/mongo"
)

const User = "user"

func (d *Dao) UserCount(ctx context.Context) (int, error) {
	count, err := d.db.Collection(User).CountDocuments(ctx, bson.M{})
	return int(count), err
}

func (d *Dao) UserCreate(ctx context.Context, user *dao.User) (err error) {
	return d.create(ctx, User, user)
}

func (d *Dao) UserUpdate(ctx context.Context, user *dao.User) (err error) {
	update := bson.M{
		"$set": bson.M{
			"name":       user.Name,
			"login_name": user.LoginName,
			"email":      user.Email,
			"admin":      user.Admin,
			"type":       user.Type,
			"roles":      user.Roles,
			"tokens":     user.Tokens,
			"updated_at": user.UpdatedAt,
			"updated_by": user.UpdatedBy,
		},
	}
	return d.update(ctx, User, user.ID, update)
}

func (d *Dao) UserUpdateStatus(ctx context.Context, user *dao.User) (err error) {
	update := bson.M{
		"$set": bson.M{
			"status":     user.Status,
			"updated_at": user.UpdatedAt,
			"updated_by": user.UpdatedBy,
		},
	}
	return d.update(ctx, User, user.ID, update)
}

func (d *Dao) UserDelete(ctx context.Context, id string) (err error) {
	return d.delete(ctx, User, id)
}

func (d *Dao) UserSearch(ctx context.Context, args *dao.UserSearchArgs) (users []*dao.User, count int, err error) {
	filter := bson.M{}
	if args.Name != "" {
		filter["name"] = args.Name
	}
	if args.LoginName != "" {
		filter["login_name"] = args.LoginName
	}
	if args.Admin {
		filter["admin"] = true
	}
	if args.Status >= 0 {
		filter["status"] = args.Status
	}
	opts := searchOptions{filter: filter, pageIndex: args.PageIndex, pageSize: args.PageSize}
	users = []*dao.User{}
	count, err = d.search(ctx, User, opts, &users)
	return
}

func (d *Dao) UserGet(ctx context.Context, id string) (user *dao.User, err error) {
	user = &dao.User{}
	found, err := d.find(ctx, User, id, user)
	if !found {
		return nil, err
	}
	return
}

func (d *Dao) UserGetByName(ctx context.Context, loginName string) (user *dao.User, err error) {
	user = &dao.User{}
	err = d.db.Collection(User).FindOne(ctx, bson.M{"login_name": loginName}).Decode(user)
	if err == mongo.ErrNoDocuments {
		return nil, nil
	} else if err != nil {
		return nil, err
	}
	return
}

func (d *Dao) UserGetByToken(ctx context.Context, token string) (user *dao.User, err error) {
	user = &dao.User{}
	err = d.db.Collection(User).FindOne(ctx, bson.M{"tokens.value": token}).Decode(user)
	if err == mongo.ErrNoDocuments {
		return nil, nil
	} else if err != nil {
		return nil, err
	}
	return
}

func (d *Dao) UserUpdateProfile(ctx context.Context, user *dao.User) (err error) {
	update := bson.M{
		"$set": bson.M{
			"name":       user.Name,
			"login_name": user.LoginName,
			"email":      user.Email,
			"tokens":     user.Tokens,
			"updated_at": user.UpdatedAt,
			"updated_by": user.UpdatedBy,
		},
	}
	return d.update(ctx, User, user.ID, update)
}

func (d *Dao) UserUpdatePassword(ctx context.Context, user *dao.User) (err error) {
	update := bson.M{
		"$set": bson.M{
			"password":   user.Password,
			"salt":       user.Salt,
			"updated_at": user.UpdatedAt,
			"updated_by": user.UpdatedBy,
		},
	}
	return d.update(ctx, User, user.ID, update)
}