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 }