Tim Wundenberg
b13712b0df
Some checks failed
Build and Push Docker Image / Build-And-Push-Docker-Image (push) Failing after 1m13s
97 lines
2.3 KiB
Go
97 lines
2.3 KiB
Go
package tag
|
|
|
|
import (
|
|
"context"
|
|
"log/slog"
|
|
"spend-sparrow/internal/core"
|
|
|
|
"github.com/google/uuid"
|
|
"github.com/jmoiron/sqlx"
|
|
)
|
|
|
|
type Db interface {
|
|
Insert(ctx context.Context, tag Tag) (*Tag, error)
|
|
Update(ctx context.Context, tag Tag) (*Tag, error)
|
|
Delete(ctx context.Context, userId uuid.UUID, id uuid.UUID) error
|
|
Get(ctx context.Context, userId uuid.UUID, id uuid.UUID) (*Tag, error)
|
|
GetAll(ctx context.Context, userId uuid.UUID) ([]Tag, error)
|
|
}
|
|
|
|
type DbSqlite struct {
|
|
db *sqlx.DB
|
|
}
|
|
|
|
func NewDbSqlite(db *sqlx.DB) *DbSqlite {
|
|
return &DbSqlite{db: db}
|
|
}
|
|
|
|
func (db DbSqlite) Insert(ctx context.Context, tag Tag) (*Tag, error) {
|
|
r, err := db.db.ExecContext(ctx, `
|
|
INSERT INTO tag (id, user_id, name, created_at, created_by, updated_at, updated_by)
|
|
VALUES (?, ?, ?, ?, ?, ?, ?)`,
|
|
tag.Id, tag.UserId, tag.Name, tag.CreatedAt, tag.CreatedBy, tag.UpdatedAt, tag.UpdatedBy,
|
|
)
|
|
err = core.TransformAndLogDbError(ctx, "tag", r, err)
|
|
if err != nil {
|
|
return nil, core.ErrInternal
|
|
}
|
|
|
|
return db.Get(ctx, tag.UserId, tag.Id)
|
|
}
|
|
|
|
func (db DbSqlite) Update(ctx context.Context, tag Tag) (*Tag, error) {
|
|
_, err := db.db.ExecContext(ctx, `
|
|
UPDATE tag
|
|
SET name = ?,
|
|
updated_at = ?,
|
|
updated_by = ?
|
|
WHERE user_id = ?
|
|
AND id = ?`,
|
|
tag.Name, tag.UpdatedAt, tag.UpdatedBy, tag.UserId, tag.Id)
|
|
|
|
if err != nil {
|
|
slog.ErrorContext(ctx, "SQL error UpdateUser", "err", err)
|
|
return nil, core.ErrInternal
|
|
}
|
|
|
|
return db.Get(ctx, tag.UserId, tag.Id)
|
|
}
|
|
|
|
func (db DbSqlite) Delete(ctx context.Context, userId uuid.UUID, id uuid.UUID) error {
|
|
r, err := db.db.ExecContext(
|
|
ctx,
|
|
"DELETE FROM tag WHERE user_id = ? AND id = ?",
|
|
userId,
|
|
id)
|
|
err = core.TransformAndLogDbError(ctx, "tag", r, err)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (db DbSqlite) Get(ctx context.Context, userId uuid.UUID, id uuid.UUID) (*Tag, error) {
|
|
var tag Tag
|
|
err := db.db.Get(&tag, "SELECT * FROM tag WHERE id = ? AND user_id = ?", id, userId)
|
|
|
|
if err != nil {
|
|
slog.ErrorContext(ctx, "Could not get tag", "err", err)
|
|
return nil, core.ErrInternal
|
|
}
|
|
|
|
return &tag, nil
|
|
}
|
|
|
|
func (db DbSqlite) GetAll(ctx context.Context, userId uuid.UUID) ([]Tag, error) {
|
|
var tags []Tag
|
|
err := db.db.Select(&tags, "SELECT * FROM tag WHERE user_id = ?", userId)
|
|
|
|
if err != nil {
|
|
slog.ErrorContext(ctx, "Could not GetAll tag", "err", err)
|
|
return nil, core.ErrInternal
|
|
}
|
|
|
|
return tags, nil
|
|
}
|