package repositories

import (
	"context"
	"wm-backend/internal/mapper"
	"wm-backend/internal/models"
	db "wm-backend/sqlc_gen"

	"github.com/rs/zerolog/log"
)

func CreateShelve(ctx context.Context, queries *db.Queries, body models.Shelve) (models.Shelve, error) {
	result, err := queries.CreateShelve(ctx, *mapper.ToModelShelve(&body))
	if err != nil {
		return models.Shelve{}, err
	}
	return *mapper.ToDomainShelve(result), nil
}

func GetShelveByID(ctx context.Context, queries *db.Queries, id int64) (models.Shelve, error) {
	result, err := queries.GetShelveByID(ctx, id)
	if err != nil {
		return models.Shelve{}, err
	}
	return *mapper.ToDomainShelve(result), nil
}

func ListShelves(ctx context.Context, queries *db.Queries) ([]models.Shelve, error) {
	results, err := queries.ListShelves(ctx)
	if err != nil {
		return nil, err
	}
	var items []models.Shelve
	for _, r := range results {
		items = append(items, *mapper.ToDomainShelve(r))
	}
	return items, nil
}

func UpdateShelve(ctx context.Context, queries *db.Queries, body models.Shelve) (models.Shelve, error) {
	result, err := queries.UpdateShelve(ctx, *mapper.ToUpdateModelShelve(&body))
	if err != nil {
		return models.Shelve{}, err
	}
	return *mapper.ToDomainShelve(result), nil
}

func DeleteShelve(ctx context.Context, queries *db.Queries, id int64) (int64, error) {
	rowsAffected, err := queries.DeleteShelve(ctx, id)
	log.Info().Int64("id", id).Int64("rowsAffected", rowsAffected).Msg("Deleted shelve")
	if err != nil {
		return rowsAffected, err
	}
	return rowsAffected, nil
}