package repositories

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

func CreateCabinet(ctx context.Context, queries *db.Queries, body models.Cabinet) (models.Cabinet, error) {
	result, err := queries.CreateCabinet(ctx, *mapper.ToModelCabinet(&body))
	if err != nil {
		return models.Cabinet{}, err
	}
	return *mapper.ToDomainCabinet(result), nil
}

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

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

func UpdateCabinet(ctx context.Context, queries *db.Queries, body models.Cabinet) (models.Cabinet, error) {
	result, err := queries.UpdateCabinet(ctx, *mapper.ToUpdateModelCabinet(&body))
	if err != nil {
		return models.Cabinet{}, err
	}
	return *mapper.ToDomainCabinet(result), nil
}

func DeleteCabinet(ctx context.Context, queries *db.Queries, id int64) (rowAffected int64, err error) {
	rowsAffected, err := queries.DeleteCabinet(ctx, id)
	if err != nil {
		return rowAffected, err
	}
	return rowsAffected, nil
}