diff options
author | 2023-09-24 16:32:09 -0700 | |
---|---|---|
committer | 2023-09-24 22:37:33 -0700 | |
commit | c0e954f19d707fef8ef8271636ec661634a4c4c7 (patch) | |
tree | 5aa052a048f470e233a454e5ad9071eed1fa37c0 /internal/storage/category.go | |
parent | 54cb8fa0286e4a2f1a81c32b5a89722d93b30bf7 (diff) | |
download | v2-c0e954f19d707fef8ef8271636ec661634a4c4c7.tar.gz v2-c0e954f19d707fef8ef8271636ec661634a4c4c7.tar.zst v2-c0e954f19d707fef8ef8271636ec661634a4c4c7.zip |
Implement structured logging using log/slog package
Diffstat (limited to 'internal/storage/category.go')
-rw-r--r-- | internal/storage/category.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/internal/storage/category.go b/internal/storage/category.go index 5ee8404b..285b3f97 100644 --- a/internal/storage/category.go +++ b/internal/storage/category.go @@ -238,7 +238,7 @@ func (s *Storage) RemoveCategory(userID, categoryID int64) error { func (s *Storage) RemoveAndReplaceCategoriesByName(userid int64, titles []string) error { tx, err := s.db.Begin() if err != nil { - return errors.New("unable to begin transaction") + return errors.New("store: unable to begin transaction") } titleParam := pq.Array(titles) @@ -247,11 +247,11 @@ func (s *Storage) RemoveAndReplaceCategoriesByName(userid int64, titles []string err = tx.QueryRow(query, userid, titleParam).Scan(&count) if err != nil { tx.Rollback() - return errors.New("unable to retrieve category count") + return errors.New("store: unable to retrieve category count") } if count < 1 { tx.Rollback() - return errors.New("at least 1 category must remain after deletion") + return errors.New("store: at least 1 category must remain after deletion") } query = ` @@ -268,14 +268,14 @@ func (s *Storage) RemoveAndReplaceCategoriesByName(userid int64, titles []string _, err = tx.Exec(query, userid, titleParam) if err != nil { tx.Rollback() - return fmt.Errorf("unable to replace categories: %v", err) + return fmt.Errorf("store: unable to replace categories: %v", err) } query = "DELETE FROM categories WHERE user_id = $1 AND title = ANY($2)" _, err = tx.Exec(query, userid, titleParam) if err != nil { tx.Rollback() - return fmt.Errorf("unable to delete categories: %v", err) + return fmt.Errorf("store: unable to delete categories: %v", err) } tx.Commit() return nil |