From be82fb14d517fcea7edaa70511de78d53d31a6f7 Mon Sep 17 00:00:00 2001
From: slaventius <slaventius@mail.ru>
Date: Wed, 1 Mar 2023 14:36:53 +0300
Subject: [PATCH] *

---
 internal/authDB.go | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/internal/authDB.go b/internal/authDB.go
index b4c602c..3924e17 100644
--- a/internal/authDB.go
+++ b/internal/authDB.go
@@ -122,7 +122,7 @@ func (s *AuthDBServer) Registration(ctx context.Context, req *api.RegistrationRe
 	}
 
 	// TODO
-	_, era := json.Marshal(customer.MessageRegistration)
+	value, era := json.Marshal(customer.MessageRegistration)
 	if era != nil {
 		return nil, era
 	}
@@ -131,12 +131,12 @@ func (s *AuthDBServer) Registration(ctx context.Context, req *api.RegistrationRe
 	s.logger.Printf("publication code %s to %s ...", customer.MessageRegistration.Code, customer.MessageRegistration.Email)
 
 	// Отправим уведомление о необходимости подтверждения
-	// err := s.kafkaWriter.WriteMessage([]byte(customer.Login), value)
-	// if err != nil {
-	// 	s.logger.Error(err)
+	err := s.kafkaWriter.WriteMessage([]byte(customer.Login), value)
+	if err != nil {
+		s.logger.Error(err)
 
-	// 	return nil, err
-	// }
+		return nil, err
+	}
 
 	//
 	s.logger.Printf("publication code %s to %s completed", customer.MessageRegistration.Code, customer.MessageRegistration.Email)