increment 1

Makefile

@@ -0,0 +1,7 @@
+build:
+	go build ./cmd/apiServer
+
+start:
+	./apiServer
+test:
+	go test -v --race --timeout 30s ./...

cmd/gophermart/main.go

@@ -1,3 +1,51 @@
 package main
 
-func main() {}
+import (
+	"context"
+	"github.com/gorilla/sessions"
+	"github.com/iRootPro/gophermart/extservice/accrual"
+	"github.com/iRootPro/gophermart/internal/apiserver"
+	"github.com/iRootPro/gophermart/internal/store/sqlstore"
+	"log"
+	"os"
+	"os/signal"
+	"time"
+)
+
+const sessionKey = "SECRET_KEY"
+
+func main() {
+	config := apiserver.NewConfig()
+
+	store := sqlstore.New()
+	if err := store.Open(config.DatabaseURI); err != nil {
+		log.Fatal(err)
+	}
+
+	if err := store.CreateTables(); err != nil {
+		log.Fatal(err)
+	}
+
+	accrualConfig := accrual.NewAccrualConfig(config.AccrualSystemAddress, config.LogLevel)
+	accrualService := accrual.NewAccrual(accrualConfig, store)
+
+	go accrualService.Run()
+
+	sessionsStore := sessions.NewCookieStore([]byte(sessionKey))
+	s := apiserver.NewAPIServer(config, store, sessionsStore)
+
+	go func() {
+		if err := s.Start(); err != nil {
+			log.Fatal(err)
+		}
+	}()
+
+	quit := make(chan os.Signal, 1)
+	signal.Notify(quit, os.Interrupt)
+	<-quit
+	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
+	defer cancel()
+	if err := s.Shutdown(ctx); err != nil {
+		log.Fatal(err)
+	}
+}

doc/README.md

@@ -0,0 +1,79 @@
+# Накопительная система лояльности «Гофермарт»
+
+**Система представляет собой HTTP API со следующими требованиями к бизнес-логике:**
+
++ регистрация, аутентификация и авторизация пользователей;
++ приём номеров заказов от зарегистрированных пользователей;
++ учёт и ведение списка переданных номеров заказов зарегистрированного пользователя;
++ учёт и ведение накопительного счёта зарегистрированного пользователя;
++ проверка принятых номеров заказов через систему расчёта баллов лояльности;
++ начисление за каждый подходящий номер заказа положенного вознаграждения на счёт лояльности пользователя.
+
+**Абстрактная схема взаимодействия с системой**
++ Пользователь регистрируется в системе лояльности «Гофермарт».
++ Пользователь совершает покупку в интернет-магазине «Гофермарт».
++ Заказ попадает в систему расчёта баллов лояльности.
++ Пользователь передаёт номер совершённого заказа в систему лояльности.
++ Система связывает номер заказа с пользователем и сверяет номер с системой расчёта баллов лояльности.
++ При наличии положительного расчёта баллов лояльности производится начисление баллов лояльности на счёт пользователя.
++ Пользователь списывает доступные баллы лояльности для частичной или полной оплаты последующих заказов в интернет-магазине «Гофермарт».
+
+Примечания:
++ пункт 2 представлен как гипотетический и не требует реализации в данной работе;
++ пункт 3 реализован в системе расчёта баллов лояльности и не требует реализации в данной работе.
+
+### Архитектура
+
+Система состоит из следующих компонентов:
+
+![Architecture](images/architecture.png)
+
+**Система расчета баллов лояльности**
+
+Система расчета баллов лояльности является внешним сервисом в доверенном контуре. Он работает по принципу чёрного ящика и недоступен для инспекции внешними клиентами. Система рассчитывает положенные баллы лояльности за совершённый заказ по сложным алгоритмам, которые могут меняться в любой момент времени.
+
+Внешнему потребителю доступна только информация о количестве положенных за конкретный заказ баллов лояльности. Причины наличия или отсутствия начислений внешнему потребителю неизвестны.
+
+#### Сущности:
+
+![Entities](images/entities.png)
+
+#### База данных:
+
+![Database](images/db.png)
+
+
+### Ошибки
+
+Все ошибки, возникающие в процессе работы системы, должны быть обработаны и корректно обработаны. В случае возникновения ошибки, система должна вернуть соответствующий код ошибки и описание ошибки.
+
+```json
+{
+  "code": 400,
+  "message": "неверный формат запрпоса"
+}
+```
+Ошибка | Status Code | Описание
+:---: |:-----------:| :---:
+ErrBadRequest |     400     |неверный формат запрпоса
+ErrInternal |     500     | внутренняя ошибка сервера
+ErrUserOrPasswordBad |     401     | неверный логин или пароль
+ErrUserBusy |     409     | логин уже занят
+ErrOrderAlreadyLoaded |     409     | номер заказа уже был загружен другим пользователем;
+ErrWrongOrderFormat |     422     | неверный формат заказа;
+ErrLowBalance |     402     | недостаточно баллов лояльности для оплаты заказа;
+ErrCountRequest |     429     | превышено количество запросов в секунду;
+
+### Конфигурация приложения
+
+Переменная окружения | Флаг командной стройки | Описание
+--------------------- |:----------------------:| :--------:
+RUN_ADDRESS           |           -a           | Адрес и порт для запуска приложения
+DATABASE_URI          |           -d           | URI для подключения к базе данных
+ACCRUAL_SYSTEM_ADDRESS|           -r           | Адрес системы расчёта баллов лояльности
+
+user (-balance, -withdrawn) 
+order (user_id, order_num, sum, status, type) = operations
+balance (user_id, balance) как кэш баланса
+
+Таблица взаимодействия (хендлеры) - диаграмма сервисов

doc/diagrams/login.puml

@@ -0,0 +1,24 @@
+@startuml
+title
+Авторизация пользователя
+end title
+User -> Handler: POST /api/user/login
+note right
+{
+    "login": "<login>",
+    "password": "<password>"
+}
+end note
+Handler --> User: StatusCode: 400, bad request)
+Handler --> User: StatusCode: 500, internal error)
+Handler -> Usecases: login(username,password)
+
+Usecases -> Repository: login(username, password)
+Repository -> Repository: getPasswordByUser(username)
+Repository -> Usecases: password
+Usecases -> Usecases: comparePasswords(pass1, pass2)
+Usecases --> User: StatusCode: 401
+Usecases -> Usecases: setCookie
+Usecases --> User: StatusCode: 200, session: cookie
+
+@enduml

doc/diagrams/order.puml

@@ -0,0 +1,29 @@
+@startuml
+'https://plantuml.com/sequence-diagram
+
+title
+Загрузка номера заказа
+end title
+User -> Handler: POST /api/user/orders
+note right
+12345678903
+end note
+Handler --> User: StatusCode: 400, bad request)
+Handler --> User: StatusCode: 500, internal error)
+
+Handler -> Usecases: checkCookie(cookie)
+Usecases --> Handler: ErrUserOrPasswordBad
+Handler --> User: StatusCode: 401
+
+Usecases -> Usecases: checkOrder(number)
+Usecases -> Handler: ErrWrongOrderFormat
+Handler --> User: StatusCode: 422
+Usecases -> Repository: loadOrder(num)
+Repository -> Repository: checkExistOrderNum(num)
+Repository -> Usecases: ErrOrderAlreadyLoaded
+Usecases --> Handler: ErrOrderAlreadyLoaded
+Handler --> User: StatusCode: 200
+Usecases --> External_Service: putOrder(num)
+Usecases --> User: StatusCode: 202
+
+@enduml

doc/diagrams/register.puml

@@ -0,0 +1,35 @@
+@startuml
+'https://plantuml.com/sequence-diagram
+
+title
+Регистрация пользователя
+end title
+
+User -> Handler: POST /api/user/register
+note right
+{
+    "login": "<login>",
+    "password": "<password>"
+}
+end note
+Handler --> User: StatusCode: 500, bad request)
+
+Handler -> Usecases: register(username,password)
+
+Usecases -> Repository: register(username, password)
+Repository -> Repository: getUser
+Repository --> Usecases: ErrUserBusy
+
+Usecases --> Handler: ErrUserBusy
+
+Handler --> User: StatusCode: 409
+Repository -> Repository: createUser
+Repository -> Usecases: user_id
+Usecases -> UseCases: setCookie()
+
+Usecases -> Handler: user_id
+
+Handler -> User: StatusCode: 200, session: cookie
+
+@enduml
+

doc/register.txt

@@ -0,0 +1,16 @@
+title Регистрация пользователя
+
+participant Client
+participant handler
+participant usecase
+participant repository
+
+Client->handler: POST /api/user/register (register)
+note over Client,handler:{\n    "login": "<login>",\n    "password": "<password>"\n} 
+handler-->Client: Status Code 500
+handler->usecase: register
+usecase-->handler: user already exist
+handler-->Client:Status Code 409
+
+usecase->repository: register new user (register)
+repository->Client: Status Code 200

doc/register.zen

@@ -0,0 +1,13 @@
+@Starter(Client)
+Client->handlers: POST /api/users/register
+handlers.register(username, password) {
+    usecases.register(username, password) {
+        repository.register(username) {
+           repository.findOne(username)
+           if ("user exist") {
+                return "exist"
+           }
+
+        }
+    }
+}

extservice/accrual/accrual.go

@@ -0,0 +1,98 @@
+package accrual
+
+import (
+	"encoding/json"
+	"fmt"
+	"github.com/iRootPro/gophermart/internal/store/sqlstore"
+	"github.com/sirupsen/logrus"
+	"io"
+	"net/http"
+	"time"
+)
+
+type Accrual struct {
+	Config *Config
+	logger *logrus.Logger
+	store  *sqlstore.Store
+}
+
+type ResponseAccrual struct {
+	Order   string  `json:"order"`
+	Status  string  `json:"status"`
+	Accrual float64 `json:"accrual"`
+}
+
+func NewAccrual(config *Config, store *sqlstore.Store) *Accrual {
+	return &Accrual{
+		Config: config,
+		logger: logrus.New(),
+		store:  store,
+	}
+}
+
+func (a *Accrual) configureLogger() error {
+	level, err := logrus.ParseLevel(a.Config.LogLevel)
+	if err != nil {
+		return err
+	}
+	a.logger.SetLevel(level)
+	return nil
+}
+
+func (a *Accrual) Run() {
+	a.logger.Infoln("starting accrual service on address: ", a.Config.RunAddress)
+	for {
+		orders := a.store.Order().GetOrdersForUpgradeStatus()
+		if len(orders) == 0 {
+			continue
+		}
+
+		fmt.Println("ORDERS", orders)
+
+		for _, order := range orders {
+			response := a.GetOrder(order)
+			err := a.store.Order().UpdateStatus(response.Order, response.Accrual, response.Status)
+			if err != nil {
+				a.logger.Errorln("update status", err)
+			}
+
+			if response.Status == "PROCESSED" {
+				a.logger.Infoln("order: ", response.Order, " status: ", response.Status, " accrual: ", response.Accrual)
+				userID, err := a.store.Order().FindUserIDByOrder(response.Order)
+				if err != nil {
+					a.logger.Errorln("find user_id by order number", err)
+				}
+
+				err = a.store.Balance().UpdateCurrentByUserID(userID, response.Accrual)
+				if err != nil {
+					a.logger.Errorln("update balance", err)
+				}
+				a.logger.Infoln("update current balance for user_id: ", userID, " accrual: ", response.Accrual)
+			}
+
+		}
+		time.Sleep(a.Config.PoolingTimeout)
+	}
+}
+
+func (a *Accrual) GetOrder(orderNum string) ResponseAccrual {
+	resp, err := http.Get(a.Config.RunAddress + "/api/orders/" + orderNum)
+	if err != nil {
+		a.logger.Errorln("get /api/orders/{number}", err)
+	}
+
+	resBody, err := io.ReadAll(resp.Body)
+	if err != nil {
+		a.logger.Errorln("read from body", err)
+	}
+
+	defer resp.Body.Close()
+
+	response := ResponseAccrual{}
+	err = json.Unmarshal(resBody, &response)
+	if err != nil {
+		a.logger.Errorln("unmarshaling response from accrual", err)
+	}
+
+	return response
+}

extservice/accrual/config.go

@@ -0,0 +1,21 @@
+package accrual
+
+import (
+	"github.com/iRootPro/gophermart/internal/store/sqlstore"
+	"time"
+)
+
+type Config struct {
+	RunAddress     string
+	LogLevel       string
+	PoolingTimeout time.Duration
+	store          *sqlstore.Store
+}
+
+func NewAccrualConfig(address string, loglevel string) *Config {
+	return &Config{
+		RunAddress:     address,
+		LogLevel:       loglevel,
+		PoolingTimeout: 5 * time.Second,
+	}
+}