base

.gitignore

@@ -4,6 +4,7 @@
 *.dll
 *.so
 *.dylib
+.env
 
 # Test binary, built with `go test -c`
 *.test

Model.drawio

@@ -0,0 +1 @@
+<mxfile host="app.diagrams.net" modified="2023-02-10T12:54:42.508Z" agent="5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 YaBrowser/22.11.3.824 Yowser/2.5 Safari/537.36" etag="pNeiifpsXXcWrRUfrPyx" version="20.8.16" type="device"><diagram name="Страница 1" id="UGf1RSKnL_w1raQG3yWh">7Zrfd5owFMf/Gh+3A0RQH6t2Xc+6s57jtnZPOxEi5ojEhVi1f/0SkyAQrNTij9P6JLkkF/jejzchlwboTZc3FM7G30mAooZjBcsG6Dccx7Zci/8Iy0pavLYnDSHFgeq0MQzwM9IjlXWOA5TkOjJCIoZneaNP4hj5LGeDlJJFvtuIRPmrzmCIDMPAh5FpfcABG0tr22lt7F8RDsf6yrbXkWemUHdWT5KMYUAWGRO4boAeJYTJo+myhyIhntZFjvuy5Wx6YxTFrMqAb9gP/hI/IC0WLn79xs83k4dPyssTjObqgXsRFg7lLbOV1mExxgwNZtAX7QWPdQN0x2wa8ZbND2Eyk+qP8BLxC3aVX0QZWm69YTuVgfODyBQxuuJd9ABPKafQsTuqvcgEQpnGmRhoG1ShD1PPG3X4gRLoFWI5hlgDRqgA6AzUAs6ZqQUMtX4liJ6jVMA7sVRNQ6o+ZJBbtvHFc8lMHPqrCMcBooALs0PIIZnznsHdMDVAfxJSYf0xZ9wNUvZE5mDbrUfsZnM3lzY4ptpuKZjJ+5S7jO3jyu0Zchv6oji4EnO1kDiCSYL9vJhUislbFm9xJejqUTQ+2y1XG/6sDZYNtKG/zPbvr3Rridmj8iuO5bg2aKv2ZphoZEfdI4q5JDyHZfwWjfLZUGCsKgoB5M9P5tRHu+dmBmmI2K5EawKRCbhbEm9toyiCDD/lb7cMAnWFe4LF8iDNpZ0Cb0WO5GOqUdnlScGRAS4oOJI6GI7WTKaPvT+mrQNiqujSmNoVEbVyiNqO+zKiZTiWcVsjoqAiolty1gXRVyHaPhyi+Szq7pVDX8bzBInRuVBXA3Wdg1Fn56lzqmKXz4s70mKN3DmXbHdE7vQO0EFm5Py6sfKErMZp9o4FXtVp9pLwagHP3BSrD7z8+0pl7rLY2eeW7y4vILVg5xwOu6rQuc4G0LJXifWsrV+y0xnY2/Fich7vIO6F0jooNbd166K0sBzcbzV4UhTdS8I8JormtvlbUSxDaitQTiul7YBMNd8HK1bekWO3j8uKuelfEyuv2QPZe7/lwDvNVRd674RFUGDRPW7eAmZFRBfdrScsyn53JLyNue8BDmNxwCMzQaJAxcgEifaIkin/KS2oMrRkeXBhxP0Iqvk1BD5dUWHCPoyu1IkpDgIxvEtRgp/hcO1KMDYTGqxVcbsNty98zRnRJStRvWKU31KPRERgGRNR1uqOcBQVTOqJ3/Q5QKFq29Txz+DneCX8Fael+ircZs0gDSRkDPrjddB+qqAxsv4T/JujRPQYcX0yJUcPTkUJMR4ms1SvDxhV1zl5VM1t9i1B4vH1JyLC0PdRkhRPy/+y/I/yW7F4TkmU4bYvRsVBQ3wnNEFZLj5q3F3XiDuoKe68ufnMSmbxzcdq4Po/</diagram></mxfile>

README.md

@@ -1,2 +1,61 @@
+Инструкция запуска:
 
+## Сборка proto файлов
 
+`protoc --go_out=. --go_opt=paths=source_relative --go-grpc_out=. --go-grpc_opt=paths=source_relative proto/datakeeper/data_keeper_service.proto`
+
+`protoc --go_out=. --go_opt=paths=source_relative --go-grpc_out=. --go-grpc_opt=paths=source_relative proto/user/user_service.proto`
+
+## Запуск `User` приложения
+
+### Config
+
+`.env|console flag`
+
+`--p` - Путь до `.env` файла. По умолчанию `.env`
+`ADDR|--a` - Адрес сервера. По умолчанию `:1234`
+`DATA_BASE_DSN|--d` - Адрес базы данных. По умолчанию `postgres://zzman:@localhost:5432/postgres`
+
+Команда для запуска `go run ./cmd/userServer/main`
+
+## Запуск `Storage` приложения
+
+### Config
+
+`.env|console flag`
+
+`--p` - Путь до `.env` файла. По умолчанию `.env`
+`ADDR|--a` - Адрес сервера. По умолчанию `:5678`
+`USER_SERVICE_ADDR|--ua` - Адрес `User` сервера. По умолчанию `:1234`
+`DATA_BASE_DSN|d` - Адрес базы данных. По умолчанию `postgres://zzman:@localhost:5432/postgres`
+
+Команда для запуска `go run ./cmd/storageServer/main`
+
+## Запуск `Client` приложения
+
+### Config
+
+`.env|console flag`
+`--p` - Путь до `.env` файла. По умолчанию `.env`
+`ADDR|--a` - Адрес `Storage` сервера. По умолчанию `:5678`
+`USER_SERVICE_ADDR|--ua` - Адрес `User` сервера. По умолчанию `:1234`
+`SECRET_PATH|--s` - Путь до файла с серкретом.
+
+## Запуск всего приложения
+
+-   Запускаем `User`
+-   Запускаем `Storage`
+-   Запускаем `Client`
+
+## Сценарий работы
+
+[Cхема](Model.jpg)
+
+`User` сервер обращается к базе данных `users`.
+Для добавления нового пользователя необходимо добавить в таблицу запись с установленным полем `secret`.
+Например следующей командой `INSERT INTO users (secret) VALUES ('уникальный_секрет_пользователя')`.
+
+После того как поднят сервер `User` необходимо запустить сервер `Storage`.
+`Storage` сервер обращается к `User` серверу для аутетификации пользователей.
+
+Команда для запуска `Client` приложения `go run ./cmd/client/main`

cmd/client/main.go

@@ -1,8 +1,130 @@
 package main
 
-func logIn() {
+import (
+	"bufio"
+	"context"
+	"flag"
+	"fmt"
+	"io/ioutil"
+	"log"
+	"os"
+	"strings"
+
+	"github.com/GermanVor/data-keeper/internal/common"
+	"golang.org/x/crypto/ssh/terminal"
+
+	"github.com/GermanVor/data-keeper/cmd/client/rpc"
+)
+
+var (
+	addr            = common.DEFAULT_STORAGE_SERVICE_ADDR
+	userAddr        = common.DEFAULT_USER_SERVICE_ADDR
+	secretValue     = common.DEFAULT_USER_SECRET
+	secretValuePath = ""
+	envFilePath     = common.DEFAULT_ENV_PATH
+)
+
+func initConfig() {
+	common.LoadEnvFile(&envFilePath, envFilePath)
+
+	if envAddr, ok := os.LookupEnv("ADDR"); ok {
+		addr = envAddr
+	}
+
+	if envUserAddr, ok := os.LookupEnv("USER_SERVICE_ADDR"); ok {
+		userAddr = envUserAddr
+	}
+
+	if envSecretValuePath, ok := os.LookupEnv("SECRET_PATH"); ok {
+		secretValuePath = envSecretValuePath
+	}
+
+	flag.StringVar(&addr, "a", addr, "address of the service")
+	flag.StringVar(&userAddr, "ua", userAddr, "address of the user service")
+	flag.StringVar(&secretValuePath, "s", secretValuePath, "path to the file with secret")
+	flag.Parse()
 }
 
+var (
+	loginComm  = "l"
+	signInComm = "s"
+)
+
 func main() {
-	logIn()
+	initConfig()
+
+	client, err := rpc.Init(userAddr, addr)
+	if err != nil {
+		fmt.Println(err.Error())
+		return
+	}
+
+	reader := bufio.NewReader(os.Stdin)
+
+	ans := ""
+	for {
+		fmt.Print("Shell you login (" + loginComm + ") or sign (" + signInComm + ") in ?: ")
+		ans, _ = reader.ReadString('\n')
+		ans = strings.TrimSpace(ans)
+
+		if ans == loginComm || ans == signInComm {
+			break
+		}
+
+		fmt.Println("Unknown command", ans, "Try again")
+	}
+
+	ctx := context.Background()
+
+	for {
+		fmt.Print("Enter login: ")
+		login, _ := reader.ReadString('\n')
+		login = strings.TrimSpace(login)
+
+		fmt.Print("Enter password: ")
+		bytePassword, err := terminal.ReadPassword(0)
+		if err != nil {
+			fmt.Println(err.Error())
+			return
+		}
+
+		password := strings.TrimSpace(string(bytePassword))
+
+		if ans == signInComm {
+			fmt.Print("\nEnter email: ")
+			email, _ := reader.ReadString('\n')
+
+			if secretValuePath != "" {
+				if secretFromFile, err := ioutil.ReadFile(secretValuePath); err == nil {
+					secretValue = string(secretFromFile[:])
+				} else {
+					log.Println(err.Error())
+					continue
+				}
+			}
+
+			fmt.Println(login, password, email)
+
+			err = client.SignIn(ctx, &rpc.SignIn{
+				Login:    login,
+				Password: password,
+				Email:    email,
+				Secret:   secretValue,
+			})
+		} else {
+			err = client.LogIn(ctx, &rpc.LogIn{
+				Login:    login,
+				Password: password,
+			})
+		}
+
+		if err != nil {
+			fmt.Println(err.Error())
+			continue
+		}
+
+		break
+	}
+
+	client.Start(reader, ctx)
 }