Merge pull request #23 from capcom6/feature/privacy-hash

Hashed messages

Author: capcom6

api/swagger.json

@@ -390,6 +390,11 @@
                     "maxLength": 36,
                     "example": "PyDmBQZZXYmyxMwED8Fzy"
                 },
+                "isHashed": {
+                    "description": "Хэшировано",
+                    "type": "boolean",
+                    "example": false
+                },
                 "recipients": {
                     "description": "Детализация состояния по получателям",
                     "type": "array",
@@ -504,7 +509,7 @@
                     "example": "timeout"
                 },
                 "phoneNumber": {
-                    "description": "Номер телефона",
+                    "description": "Номер телефона или первые 16 символов SHA256",
                     "type": "string",
                     "minLength": 10,
                     "example": "79990001234"

api/swagger.yaml

@@ -58,6 +58,10 @@ definitions:
         example: PyDmBQZZXYmyxMwED8Fzy
         maxLength: 36
         type: string
+      isHashed:
+        description: Хэшировано
+        example: false
+        type: boolean
       recipients:
         description: Детализация состояния по получателям
         items:
@@ -144,7 +148,7 @@ definitions:
         example: timeout
         type: string
       phoneNumber:
-        description: Номер телефона
+        description: Номер телефона или первые 16 символов SHA256
         example: "79990001234"
         minLength: 10
         type: string

internal/infra/http/cli.go

@@ -3,33 +3,32 @@ package http
 import (
 	"context"
 
-	"github.com/gofiber/fiber/v2"
 	"go.uber.org/fx"
 	"go.uber.org/zap"
 )
 
 type RunServerParams struct {
 	fx.In
 
-	Config Config
-	App    *fiber.App
+	Server *Server
 	Logger *zap.Logger
 	LC     fx.Lifecycle
+	Shut   fx.Shutdowner
 }
 
 func Run(params RunServerParams) error {
-	go func() {
-		params.Logger.Info("Starting server...")
-
-		err := params.App.Listen(params.Config.Listen)
-		if err != nil {
-			params.Logger.Error("Error starting server", zap.Error(err))
-		}
-	}()
-
 	params.LC.Append(fx.Hook{
+		OnStart: func(context.Context) error {
+			go func() {
+				if err := params.Server.Start(); err != nil {
+					params.Logger.Error("Error starting server", zap.Error(err))
+					params.Shut.Shutdown()
+				}
+			}()
+			return nil
+		},
 		OnStop: func(ctx context.Context) error {
-			return params.App.ShutdownWithContext(ctx)
+			return params.Server.Stop(ctx)
 		},
 	})
 

internal/infra/http/module.go

@@ -11,9 +11,8 @@ var Module = fx.Module(
 	fx.Decorate(func(log *zap.Logger) *zap.Logger {
 		return log.Named("http")
 	}),
-	fx.Provide(
-		New,
-	),
+	fx.Provide(New),
+	fx.Provide(NewServer),
 )
 
 func init() {

internal/infra/http/server.go

@@ -0,0 +1,33 @@
+package http
+
+import (
+	"context"
+
+	"github.com/gofiber/fiber/v2"
+	"go.uber.org/zap"
+)
+
+type Server struct {
+	Config Config
+	App    *fiber.App
+	Logger *zap.Logger
+}
+
+func NewServer(config Config, app *fiber.App, logger *zap.Logger) *Server {
+	return &Server{
+		Config: config,
+		App:    app,
+		Logger: logger,
+	}
+}
+
+func (s *Server) Start() error {
+	s.Logger.Info("Starting server at " + s.Config.Listen + "...")
+
+	return s.App.Listen(s.Config.Listen)
+}
+
+func (s *Server) Stop(ctx context.Context) error {
+	defer s.Logger.Info("Server stopped")
+	return s.App.ShutdownWithContext(ctx)
+}

internal/sms-gateway/app.go

@@ -1,6 +1,9 @@
 package smsgateway
 
 import (
+	"context"
+	"sync"
+
 	appconfig "github.com/capcom6/sms-gateway/internal/config"
 	"github.com/capcom6/sms-gateway/internal/infra/cli"
 	"github.com/capcom6/sms-gateway/internal/infra/db"
@@ -33,7 +36,7 @@ var Module = fx.Module(
 )
 
 func Run() {
-	cli.DefaultCommand = "http:run"
+	cli.DefaultCommand = "start"
 	fx.New(
 		cli.GetModule(),
 		Module,
@@ -44,3 +47,57 @@ func Run() {
 		}),
 	).Run()
 }
+
+type StartParams struct {
+	fx.In
+
+	LC     fx.Lifecycle
+	Logger *zap.Logger
+	Shut   fx.Shutdowner
+
+	Server      *http.Server
+	HashingTask *tasks.HashingTask
+}
+
+func Start(p StartParams) error {
+	ctx, cancel := context.WithCancel(context.Background())
+	wg := &sync.WaitGroup{}
+	p.LC.Append(fx.Hook{
+		OnStart: func(_ context.Context) error {
+			wg.Add(1)
+
+			go func() {
+				defer wg.Done()
+				p.HashingTask.Run(ctx)
+			}()
+
+			wg.Add(1)
+			go func() {
+				defer wg.Done()
+				if err := p.Server.Start(); err != nil {
+					p.Logger.Error("Error starting server", zap.Error(err))
+					_ = p.Shut.Shutdown()
+				}
+			}()
+
+			p.Logger.Info("Service started")
+
+			return nil
+		},
+		OnStop: func(_ context.Context) error {
+			cancel()
+			_ = p.Server.Stop(ctx)
+			wg.Wait()
+
+			p.Logger.Info("Service stopped")
+
+			return nil
+		},
+	})
+
+	return nil
+}
+
+func init() {
+	cli.Register("start", Start)
+}

internal/sms-gateway/tasks/module.go

@@ -1,8 +1,6 @@
 package tasks
 
 import (
-	"context"
-
 	"go.uber.org/fx"
 	"go.uber.org/zap"
 )
@@ -12,26 +10,5 @@ var Module = fx.Module(
 	fx.Decorate(func(log *zap.Logger) *zap.Logger {
 		return log.Named("tasks")
 	}),
-	fx.Provide(
-		NewHashingTask,
-		fx.Private,
-	),
-	fx.Invoke(
-		func(lc fx.Lifecycle, task *HashingTask) error {
-			ctx, cancel := context.WithCancel(context.Background())
-
-			lc.Append(fx.Hook{
-				OnStart: func(_ context.Context) error {
-					go task.Run(ctx)
-					return nil
-				},
-				OnStop: func(_ context.Context) error {
-					cancel()
-					return nil
-				},
-			})
-
-			return nil
-		},
-	),
+	fx.Provide(NewHashingTask),
 )

pkg/smsgateway/domain.go

@@ -24,7 +24,7 @@ type Message struct {
 type MessageState struct {
 	ID         string           `json:"id,omitempty" validate:"omitempty,max=36" example:"PyDmBQZZXYmyxMwED8Fzy"` // Идентификатор
 	State      ProcessState     `json:"state" validate:"required" example:"Pending"`                              // Состояние
-	IsHashed   bool             `json:"isHashed" validate:"required" example:"false"`                             // Хэшировано
+	IsHashed   bool             `json:"isHashed" example:"false"`                                                 // Хэшировано
 	Recipients []RecipientState `json:"recipients" validate:"required,min=1,dive"`                                // Детализация состояния по получателям
 }