book_repository.go

package repository

import (
	"context"

	"github.com/jmoiron/sqlx"
	"github.com/techwithmat/bookstore-api/internal/domain"
	"github.com/techwithmat/bookstore-api/pkg/utils/pagination"
)

type BooksRepo struct {
	db *sqlx.DB
}

func NewBookRepository(db *sqlx.DB) domain.BookRepository {
	return &BooksRepo{
		db: db,
	}
}

func (r *BooksRepo) GetAll(ctx context.Context, p *pagination.PaginationQuery) ([]domain.Books, error) {
	var books []domain.Books

	err := r.db.SelectContext(ctx, &books, getBooksQuery, p.Size, p.Page*p.Size)

	if err != nil {
		return nil, err
	}

	return books, nil
}

func (r *BooksRepo) GetByCategory(ctx context.Context, category string, p *pagination.PaginationQuery) ([]domain.Books, error) {
	var books []domain.Books

	err := r.db.SelectContext(ctx, &books, getBookByCategoryQuery, category, p.Size, p.Page*p.Size)

	if err != nil {
		return nil, err
	}

	return books, nil
}

func (r *BooksRepo) GetByID(ctx context.Context, id int64) (*domain.Book, error) {
	var book domain.Book

	err := r.db.GetContext(ctx, &book, getBookByIdQuery, id)

	if err != nil {
		return nil, err
	}

	return &book, nil
}

func (r *BooksRepo) InsertBook(ctx context.Context, book *domain.Book) (int64, error) {
	var id int64

	err := r.db.QueryRowContext(ctx, InsertBookQuery,
		book.Title,
		book.Subtitle,
		book.AboutTheBook,
		book.PageCount,
		book.Price,
		book.Image,
		book.Language,
		book.AuthorName,
		book.AuthorAvatar,
		book.CategoryId,
	).Scan(&id)

	return id, err
}

func (r *BooksRepo) DeleteBook(ctx context.Context, id int64) error {
	_, err := r.db.ExecContext(ctx, DeleteBookQuery, id)

	return err
}

func (r *BooksRepo) UpdateBook(ctx context.Context, id int64) error {
	return nil
}