base

.gitignore

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

README.md

@@ -1,2 +1,41 @@
+Инструкция запуска:
 
+## Сборка 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`
+
+`ADDR|--a` - Адрес сервера. По умолчанию `:1234`
+`DATA_BASE_DSN|--d` - Адрес базы данных. По умолчанию `postgres://zzman:@localhost:5432/postgres`
+
+Команда для запуска `go run ./cmd/userServer/main`
+
+## Запуск `Storage` приложения
+
+# Config
+
+`.env|console flag`
+
+`ADDR|--a` - Адрес сервера. По умолчанию `:5678`
+`USER_SERVICE_ADDR|--ua` - Адрес `User` сервера. По умолчанию `:1234`
+`DATA_BASE_DSN|d` - Адрес базы данных. По умолчанию `postgres://zzman:@localhost:5432/postgres`
+
+Команда для запуска `go run ./cmd/storageServer/main`
+
+## Сценарий работы
+
+`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,124 @@
 package main
 
-func logIn() {
+import (
+	"bufio"
+	"context"
+	"flag"
+	"fmt"
+	"io/ioutil"
+	"log"
+	"os"
+	"strings"
+
+	"github.com/GermanVor/data-keeper/internal/common"
+	"github.com/joho/godotenv"
+	"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 = ""
+)
+
+func init() {
+	godotenv.Load(".env")
+
+	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")
 }
 
+var (
+	loginComm  = "l"
+	signInComm = "s"
+)
+
 func main() {
-	logIn()
+	flag.Parse()
+
+	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")
+	}
+
+	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))
+
+	ctx := context.Background()
+	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())
+				return
+			}
+		}
+
+		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())
+		return
+	}
+
+	client.Start(reader, ctx)
 }