Transaction management #2
Conversation
This reverts commit 2749ddf.
Makefile
Outdated
| @@ -0,0 +1,56 @@ | |||
| #SHELL = /bin/bash | |||
| .PHONY: autotest dep test race lint gen cover statictest dev-up dev-down accrual dev-autotest | |||
There was a problem hiding this comment.
PHONY лучше прописывать отдельно перед каждым таргетом.
Будет легче разрешать конфликты при мерджах + при большом кол-ве таргетов становится неудобно поддерживать общий PHONY
config/app.go
Outdated
|
|
||
| type ( | ||
| App struct { | ||
| Address `env:"RUN_ADDRESS"` |
There was a problem hiding this comment.
Встраивание не для наследования полей, а для наследования поведения. Лучше делать обычные поля, т.к. встраивание может начать путать и приводить к ошибкам при вызове методов.
| } | ||
| } | ||
|
|
||
| func errorJSON(w http.ResponseWriter, err error, status int, logger logger.AppLogger) { |
There was a problem hiding this comment.
Статус лучше определять по типу ошибки с использованием конструкции errors.Is
There was a problem hiding this comment.
теперь все коды сопоставляются с ошибками
| Data interface{} `json:"data,omitempty"` | ||
| } | ||
|
|
||
| func writeJSON(w http.ResponseWriter, status int, contentType string, data any, logger logger.AppLogger, headers ...http.Header) { |
There was a problem hiding this comment.
Не стоит передавать сюда content-type, всегда будет json
| var ctx = context.Background() | ||
| var err error | ||
|
|
||
| orderNumberRaw, err = io.ReadAll(r.Body) |
There was a problem hiding this comment.
Нужно закрывать тело обязательно
internal/usecase/syncer/syncer.go
Outdated
| } | ||
|
|
||
| func (s *syncer) Run() error { | ||
| s.tick <- struct{}{} // init tick |
There was a problem hiding this comment.
Лучше использовать time.Ticker
There was a problem hiding this comment.
переписал с использованием time.Ticker
internal/usecase/syncer/syncer.go
Outdated
| } | ||
|
|
||
| func (s *syncer) Shutdown(ctx context.Context) error { | ||
| once.Do(func() { |
There was a problem hiding this comment.
once должна быть переменной syncer, а не модуля, т.к. исходя из дизайна ликеров может быть несколько
internal/usecase/syncer/syncer.go
Outdated
| } | ||
|
|
||
| func (s *syncer) sync() error { | ||
| orders, err := s.orderRepo.GetUnprocessed(context.TODO()) |
There was a problem hiding this comment.
Контекст TODO не должен присутствовать в итоговом коде
internal/models/user.go
Outdated
| type User struct { | ||
| Login string `json:"login" db:"login"` | ||
| Password string `json:"password" db:"password"` | ||
| Balance float64 `db:"balance"` |
There was a problem hiding this comment.
Не стоит работать с денежными единицами во float64. Из-за неточности арифметических операций могут потеряться копейки и быть юридические проблемы
There was a problem hiding this comment.
Теперь храню в
type Money struct {
Amount Amount
}
type Amount uint64
internal/usecase/syncer/syncer.go
Outdated
|
|
||
| // if the new status is valid for accrual - change user balance | ||
| if newStatus == "PROCESSED" { | ||
| user, err := s.userRepo.Get(ctx, models.User{Login: orders[i].User}) |
There was a problem hiding this comment.
Без установки блокировки возможна потеря списаний.
Например, когда пользователь запрашивает списание баллов и мы одновременно обрабатываем его заказ.
Необходимо выполнять списание баллов в транзакции.
There was a problem hiding this comment.
запихнул в транзакцию с использованием менеджера транзакций
No description provided.