Merge pull request #7 from rtmelsov/develop

feat: добавлены данные из env

Author: rtmelsov

.env.dev

@@ -1,12 +1,18 @@
 AK_ENV=prod
-AK_GRPC_ADDR=0.0.0.0:3200
+GRPC_ADDR=127.0.0.1:8080
+AK_GRPC_ADDR=127.0.0.1:8080
 
-# строка подключения к Postgres (пример)
-AK_POSTGRES_DSN=postgres://admin:[email protected]:5432/adv?sslmode=disable
+# Postgres DSN (одинаковое значение под разными именами)
+DB_DSN=postgres://admin:[email protected]:5432/adv?sslmode=disable
+DSN=postgres://admin:[email protected]:5432/adv?sslmode=disable
+DATABASE_URL=postgres://admin:[email protected]:5432/adv?sslmode=disable
+AK_POSTGRES_DSN=postgres://admin:[email protected]:5432/adv?sslmode=disable
+AK_DSN=postgres://admin:[email protected]:5432/adv?sslmode=disable
 
-# куда складывать файлы пользователей
+# хранилище файлов
+FILES_DIR=/opt/adv-keeper/data
 AK_STORAGE_DIR=/opt/adv-keeper/data
 
-# опционально
+# логирование
 AK_LOG_LEVEL=info
-
+LOG_LEVEL=info

cmd/server/main.go

@@ -2,10 +2,10 @@ package main
 
 import (
 	"database/sql"
-	"fmt"
 	"google.golang.org/grpc/reflection"
 	"log"
 	"net"
+	"os"
 
 	commonv1 "github.com/rtmelsov/adv-keeper/gen/go/proto/common/v1"
 	filev1 "github.com/rtmelsov/adv-keeper/gen/go/proto/file/v1"
@@ -18,12 +18,17 @@ import (
 )
 
 func main() {
+	dsn := os.Getenv("DB_DSN")
+	if dsn == "" {
+		log.Fatal("DB_DSN is required")
+	}
+	addr := os.Getenv("GRPC_ADDR")
+	if addr == "" {
+		addr = "127.0.0.1:8080"
+	}
 	// получаем урл бд
-	dsn := "postgres://postgres@localhost:5432/dbname?sslmode=disable"
-
-	fmt.Println("dsn", dsn)
 
-	lis, err := net.Listen("tcp", "127.0.0.1:8080")
+	lis, err := net.Listen("tcp", addr)
 	if err != nil {
 		log.Fatal(err)
 	}

internal/file/service.go

@@ -25,7 +25,13 @@ type FileServer struct {
 	uploadDir string
 }
 
-func New(q *db.Queries) *FileServer { return &FileServer{Q: q, uploadDir: "var/"} }
+func New(q *db.Queries) *FileServer {
+	filesDir := os.Getenv("FILES_DIR")
+	if filesDir == "" {
+		filesDir = "./data"
+	}
+	return &FileServer{Q: q, uploadDir: filesDir}
+}
 
 func (s *FileServer) Upload(stream filev1.FileService_UploadServer) error {
 	var (