From 208f75aebed620819640c4d6ba892fe234726abe Mon Sep 17 00:00:00 2001
From: "slaventius@odnookno.info" <slaventius@odnookno.info>
Date: Fri, 10 Feb 2023 17:22:39 +0300
Subject: [PATCH] *

---
 go.mod                                        |  1 +
 go.sum                                        |  2 ++
 internal/authPostman.go                       | 24 +++++++------------
 .../test3k/umate/pkg/kafka/auth.kafka.go      | 11 +++++++++
 vendor/modules.txt                            |  3 +++
 5 files changed, 25 insertions(+), 16 deletions(-)
 create mode 100644 vendor/git.slaventius.ru/test3k/umate/pkg/kafka/auth.kafka.go

diff --git a/go.mod b/go.mod
index d2abd0a..0641d67 100644
--- a/go.mod
+++ b/go.mod
@@ -9,6 +9,7 @@ require (
 )
 
 require (
+	git.slaventius.ru/test3k/umate v0.0.0-20230210135137-2a136bab1671 // indirect
 	github.com/klauspost/compress v1.15.9 // indirect
 	github.com/pierrec/lz4/v4 v4.1.15 // indirect
 )
diff --git a/go.sum b/go.sum
index 1ecc951..a8e893c 100644
--- a/go.sum
+++ b/go.sum
@@ -1,3 +1,5 @@
+git.slaventius.ru/test3k/umate v0.0.0-20230210135137-2a136bab1671 h1:1WTule5cBHN2k43VwgmhU5leN+spRiGXU0Lhr7wRbOw=
+git.slaventius.ru/test3k/umate v0.0.0-20230210135137-2a136bab1671/go.mod h1:zC+pjeBAFo0eLwPt+vBrdyt1ObAPU+HMfDG12vXLjBA=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
diff --git a/internal/authPostman.go b/internal/authPostman.go
index 3cc6ad9..b4e26d9 100644
--- a/internal/authPostman.go
+++ b/internal/authPostman.go
@@ -13,17 +13,9 @@ import (
 
 	// telegram "git.slaventius.ru/test3k/authPostman/internal/transport/telegram"
 	smtp "git.slaventius.ru/test3k/authPostman/internal/transport/smtp"
+	api "git.slaventius.ru/test3k/umate/pkg/kafka"
 )
 
-const (
-	topicRegistrations string = "registrations" // Топик для регистраций
-)
-
-type msg struct {
-	Code  string
-	Email string
-}
-
 type AuthPostmanServer struct {
 	ctx         context.Context
 	kafkaReader *kafka.KafkaReader
@@ -35,7 +27,7 @@ func NewServer(ctx context.Context, config *config.Config) *AuthPostmanServer {
 
 	return &AuthPostmanServer{
 		ctx:         ctx,
-		kafkaReader: kafka.NewReader(ctx, config, topicRegistrations, address...),
+		kafkaReader: kafka.NewReader(ctx, config, api.TopicRegistrations, address...),
 		config:      config,
 	}
 }
@@ -56,17 +48,17 @@ func (s *AuthPostmanServer) ReadMessage(offset int64) error {
 		}
 
 		// Декодируем сообщение
-		amsg := msg{}
-		erk := json.Unmarshal(m.Value, &amsg)
+		msg := api.MessageRegistration{}
+		erk := json.Unmarshal(m.Value, &msg)
 		if erk != nil {
 			return erk
 		}
 
 		//
-		log.Printf("send code %s to %s ...", amsg.Code, amsg.Email)
+		log.Printf("send code %s to %s ...", msg.Code, msg.Email)
 
 		//
-		text := fmt.Sprintf("Confirmation code %v", amsg.Code)
+		text := fmt.Sprintf("Confirmation code %v", msg.Code)
 		// postman := telegram.NewService(s.config.Telegram.ChatToken)
 		// message := postman.NewMessage(s.config.Telegram.ChatID, text)
 		// ers := postman.SendMessage(message)
@@ -78,7 +70,7 @@ func (s *AuthPostmanServer) ReadMessage(offset int64) error {
 
 		//
 		message := smtp.NewMessage("Confirmation code", text)
-		message.AppendRecipient(amsg.Email)
+		message.AppendRecipient(msg.Email)
 
 		//
 		smtpSender := smtp.NewService(s.config.Smtp.Host, s.config.Smtp.Port, s.config.Smtp.Sender, s.config.Smtp.Password)
@@ -86,7 +78,7 @@ func (s *AuthPostmanServer) ReadMessage(offset int64) error {
 		if ers != nil {
 			log.Print(ers)
 		} else {
-			log.Printf("send code %s to %s completed", amsg.Code, amsg.Email)
+			log.Printf("send code %s to %s completed", msg.Code, msg.Email)
 		}
 	}
 }
diff --git a/vendor/git.slaventius.ru/test3k/umate/pkg/kafka/auth.kafka.go b/vendor/git.slaventius.ru/test3k/umate/pkg/kafka/auth.kafka.go
new file mode 100644
index 0000000..0874640
--- /dev/null
+++ b/vendor/git.slaventius.ru/test3k/umate/pkg/kafka/auth.kafka.go
@@ -0,0 +1,11 @@
+package kafka
+
+const (
+	TopicRegistrations string = "registrations" // Топик для регистраций
+)
+
+// Структура сообщения передаваемого при регистрации
+type MessageRegistration struct {
+	Code  string
+	Email string
+}
diff --git a/vendor/modules.txt b/vendor/modules.txt
index 3fd9ac0..ee3acdc 100644
--- a/vendor/modules.txt
+++ b/vendor/modules.txt
@@ -1,3 +1,6 @@
+# git.slaventius.ru/test3k/umate v0.0.0-20230210135137-2a136bab1671
+## explicit; go 1.19
+git.slaventius.ru/test3k/umate/pkg/kafka
 # github.com/go-telegram-bot-api/telegram-bot-api/v5 v5.5.1
 ## explicit; go 1.16
 github.com/go-telegram-bot-api/telegram-bot-api/v5