add shopping list and tag management

internal/repository/list_item.go

@@ -0,0 +1,90 @@
+package repository
+
+import (
+	"database/sql"
+	"errors"
+	"time"
+
+	"git.juancwu.dev/juancwu/budgit/internal/model"
+	"github.com/jmoiron/sqlx"
+)
+
+var (
+	ErrListItemNotFound = errors.New("list item not found")
+)
+
+type ListItemRepository interface {
+	Create(item *model.ListItem) error
+	GetByID(id string) (*model.ListItem, error)
+	GetByListID(listID string) ([]*model.ListItem, error)
+	Update(item *model.ListItem) error
+	Delete(id string) error
+	DeleteByListID(listID string) error
+}
+
+type listItemRepository struct {
+	db *sqlx.DB
+}
+
+func NewListItemRepository(db *sqlx.DB) ListItemRepository {
+	return &listItemRepository{db: db}
+}
+
+func (r *listItemRepository) Create(item *model.ListItem) error {
+	query := `INSERT INTO list_items (id, list_id, name, is_checked, created_by, created_at, updated_at) VALUES ($1, $2, $3, $4, $5, $6, $7);`
+	_, err := r.db.Exec(query, item.ID, item.ListID, item.Name, item.IsChecked, item.CreatedBy, item.CreatedAt, item.UpdatedAt)
+	return err
+}
+
+func (r *listItemRepository) GetByID(id string) (*model.ListItem, error) {
+	item := &model.ListItem{}
+	query := `SELECT * FROM list_items WHERE id = $1;`
+	err := r.db.Get(item, query, id)
+	if err == sql.ErrNoRows {
+		return nil, ErrListItemNotFound
+	}
+	return item, err
+}
+
+func (r *listItemRepository) GetByListID(listID string) ([]*model.ListItem, error) {
+	var items []*model.ListItem
+	query := `SELECT * FROM list_items WHERE list_id = $1 ORDER BY created_at ASC;`
+	err := r.db.Select(&items, query, listID)
+	if err != nil {
+		return nil, err
+	}
+	return items, nil
+}
+
+func (r *listItemRepository) Update(item *model.ListItem) error {
+	item.UpdatedAt = time.Now()
+	query := `UPDATE list_items SET name = $1, is_checked = $2, updated_at = $3 WHERE id = $4;`
+	result, err := r.db.Exec(query, item.Name, item.IsChecked, item.UpdatedAt, item.ID)
+	if err != nil {
+		return err
+	}
+	rows, err := result.RowsAffected()
+	if err == nil && rows == 0 {
+		return ErrListItemNotFound
+	}
+	return err
+}
+
+func (r *listItemRepository) Delete(id string) error {
+	query := `DELETE FROM list_items WHERE id = $1;`
+	result, err := r.db.Exec(query, id)
+	if err != nil {
+		return err
+	}
+	rows, err := result.RowsAffected()
+	if err == nil && rows == 0 {
+		return ErrListItemNotFound
+	}
+	return err
+}
+
+func (r *listItemRepository) DeleteByListID(listID string) error {
+	query := `DELETE FROM list_items WHERE list_id = $1;`
+	_, err := r.db.Exec(query, listID)
+	return err
+}

internal/repository/shopping_list.go

@@ -0,0 +1,83 @@
+package repository
+
+import (
+	"database/sql"
+	"errors"
+	"time"
+
+	"git.juancwu.dev/juancwu/budgit/internal/model"
+	"github.com/jmoiron/sqlx"
+)
+
+var (
+	ErrShoppingListNotFound = errors.New("shopping list not found")
+)
+
+type ShoppingListRepository interface {
+	Create(list *model.ShoppingList) error
+	GetByID(id string) (*model.ShoppingList, error)
+	GetBySpaceID(spaceID string) ([]*model.ShoppingList, error)
+	Update(list *model.ShoppingList) error
+	Delete(id string) error
+}
+
+type shoppingListRepository struct {
+	db *sqlx.DB
+}
+
+func NewShoppingListRepository(db *sqlx.DB) ShoppingListRepository {
+	return &shoppingListRepository{db: db}
+}
+
+func (r *shoppingListRepository) Create(list *model.ShoppingList) error {
+	query := `INSERT INTO shopping_lists (id, space_id, name, created_at, updated_at) VALUES ($1, $2, $3, $4, $5);`
+	_, err := r.db.Exec(query, list.ID, list.SpaceID, list.Name, list.CreatedAt, list.UpdatedAt)
+	return err
+}
+
+func (r *shoppingListRepository) GetByID(id string) (*model.ShoppingList, error) {
+	list := &model.ShoppingList{}
+	query := `SELECT * FROM shopping_lists WHERE id = $1;`
+	err := r.db.Get(list, query, id)
+	if err == sql.ErrNoRows {
+		return nil, ErrShoppingListNotFound
+	}
+	return list, err
+}
+
+func (r *shoppingListRepository) GetBySpaceID(spaceID string) ([]*model.ShoppingList, error) {
+	var lists []*model.ShoppingList
+	query := `SELECT * FROM shopping_lists WHERE space_id = $1 ORDER BY created_at DESC;`
+	err := r.db.Select(&lists, query, spaceID)
+	if err != nil {
+		return nil, err
+	}
+	return lists, nil
+}
+
+func (r *shoppingListRepository) Update(list *model.ShoppingList) error {
+	list.UpdatedAt = time.Now()
+	query := `UPDATE shopping_lists SET name = $1, updated_at = $2 WHERE id = $3;`
+	result, err := r.db.Exec(query, list.Name, list.UpdatedAt, list.ID)
+	if err != nil {
+		return err
+	}
+	rows, err := result.RowsAffected()
+	if err == nil && rows == 0 {
+		return ErrShoppingListNotFound
+	}
+	return err
+}
+
+func (r *shoppingListRepository) Delete(id string) error {
+	query := `DELETE FROM shopping_lists WHERE id = $1;`
+	result, err := r.db.Exec(query, id)
+	if err != nil {
+		return err
+	}
+	rows, err := result.RowsAffected()
+	if err == nil && rows == 0 {
+		return ErrShoppingListNotFound
+	}
+	return err
+}

internal/repository/tag.go

@@ -0,0 +1,96 @@
+package repository
+
+import (
+	"database/sql"
+	"errors"
+	"strings"
+	"time"
+
+	"git.juancwu.dev/juancwu/budgit/internal/model"
+	"github.com/jmoiron/sqlx"
+)
+
+var (
+	ErrTagNotFound        = errors.New("tag not found")
+	ErrDuplicateTagName   = errors.New("tag with that name already exists in this space")
+)
+
+type TagRepository interface {
+	Create(tag *model.Tag) error
+	GetByID(id string) (*model.Tag, error)
+	GetBySpaceID(spaceID string) ([]*model.Tag, error)
+	Update(tag *model.Tag) error
+	Delete(id string) error
+}
+
+type tagRepository struct {
+	db *sqlx.DB
+}
+
+func NewTagRepository(db *sqlx.DB) TagRepository {
+	return &tagRepository{db: db}
+}
+
+func (r *tagRepository) Create(tag *model.Tag) error {
+	query := `INSERT INTO tags (id, space_id, name, color, created_at, updated_at) VALUES ($1, $2, $3, $4, $5, $6);`
+	_, err := r.db.Exec(query, tag.ID, tag.SpaceID, tag.Name, tag.Color, tag.CreatedAt, tag.UpdatedAt)
+	if err != nil {
+		errStr := err.Error()
+		if strings.Contains(errStr, "UNIQUE constraint failed") || strings.Contains(errStr, "duplicate key value") {
+			return ErrDuplicateTagName
+		}
+		return err
+	}
+	return nil
+}
+
+func (r *tagRepository) GetByID(id string) (*model.Tag, error) {
+	tag := &model.Tag{}
+	query := `SELECT * FROM tags WHERE id = $1;`
+	err := r.db.Get(tag, query, id)
+	if err == sql.ErrNoRows {
+		return nil, ErrTagNotFound
+	}
+	return tag, err
+}
+
+func (r *tagRepository) GetBySpaceID(spaceID string) ([]*model.Tag, error) {
+	var tags []*model.Tag
+	query := `SELECT * FROM tags WHERE space_id = $1 ORDER BY name ASC;`
+	err := r.db.Select(&tags, query, spaceID)
+	if err != nil {
+		return nil, err
+	}
+	return tags, nil
+}
+
+func (r *tagRepository) Update(tag *model.Tag) error {
+	tag.UpdatedAt = time.Now()
+	query := `UPDATE tags SET name = $1, color = $2, updated_at = $3 WHERE id = $4;`
+	result, err := r.db.Exec(query, tag.Name, tag.Color, tag.UpdatedAt, tag.ID)
+	if err != nil {
+		errStr := err.Error()
+		if strings.Contains(errStr, "UNIQUE constraint failed") || strings.Contains(errStr, "duplicate key value") {
+			return ErrDuplicateTagName
+		}
+		return err
+	}
+	rows, err := result.RowsAffected()
+	if err == nil && rows == 0 {
+		return ErrTagNotFound
+	}
+	return err
+}
+
+func (r *tagRepository) Delete(id string) error {
+	query := `DELETE FROM tags WHERE id = $1;`
+	result, err := r.db.Exec(query, id)
+	if err != nil {
+		return err
+	}
+	rows, err := result.RowsAffected()
+	if err == nil && rows == 0 {
+		return ErrTagNotFound
+	}
+	return err
+}