From 1e1a763b245ebaca8caede46fcddc2363cfd6dc9 Mon Sep 17 00:00:00 2001 From: slaventius Date: Thu, 2 Feb 2023 18:30:41 +0300 Subject: [PATCH] * --- internal/transport/grpc/grpc.go | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/internal/transport/grpc/grpc.go b/internal/transport/grpc/grpc.go index 0b39243..4aae2f1 100644 --- a/internal/transport/grpc/grpc.go +++ b/internal/transport/grpc/grpc.go @@ -112,6 +112,9 @@ func (s *AuthDBServer) Registration(ctx context.Context, req *api.RegistrationRe return nil, eru } + // + log.Printf("send code %s to %s ...", user.msg.Code, user.msg.Email) + // err := s.kafkaWriter.WriteMessage([]byte(user.Login), value) if err != nil { @@ -120,9 +123,12 @@ func (s *AuthDBServer) Registration(ctx context.Context, req *api.RegistrationRe return nil, err } + // + log.Printf("send code %s to %s completed", user.msg.Code, user.msg.Email) + return &api.RegistrationResponse{ - Code: code, - Email: req.GetEmail(), + Code: user.msg.Code, + Email: user.msg.Email, }, nil }