slaventius 2 years ago
parent 14ee880ea4
commit 4fee6063a0
  1. 2
      cmd/main.go
  2. 12
      internal/transport/grpc/grpc.go

@ -27,7 +27,7 @@ func main() {
}
//
fmt.Printf("authDBService up in %d port\n", config.App.Port)
fmt.Printf("authDBServer up (%s)\n", connStr)
eru := s.Serve(lis)
if eru != nil {
log.Fatal(eru)

@ -19,22 +19,22 @@ type user struct {
Confirmed bool
}
type gRPCServer struct {
type authDBServer struct {
mu sync.Mutex
users map[string]*user
api.UnimplementedAuthDBServer
id int32
}
func NewServer() *gRPCServer {
return &gRPCServer{
func NewServer() *authDBServer {
return &authDBServer{
mu: sync.Mutex{},
users: make(map[string]*user),
id: 0,
}
}
func (s *gRPCServer) Login(ctx context.Context, req *api.LoginRequest) (*api.LoginResponse, error) {
func (s *authDBServer) Login(ctx context.Context, req *api.LoginRequest) (*api.LoginResponse, error) {
s.mu.Lock()
defer s.mu.Unlock()
@ -59,7 +59,7 @@ func (s *gRPCServer) Login(ctx context.Context, req *api.LoginRequest) (*api.Log
}, nil
}
func (s *gRPCServer) Registration(ctx context.Context, req *api.RegistrationRequest) (*api.RegistrationResponse, error) {
func (s *authDBServer) Registration(ctx context.Context, req *api.RegistrationRequest) (*api.RegistrationResponse, error) {
s.mu.Lock()
defer s.mu.Unlock()
@ -115,7 +115,7 @@ func (s *gRPCServer) Registration(ctx context.Context, req *api.RegistrationRequ
}, nil
}
func (s *gRPCServer) Confirmation(ctx context.Context, req *api.ConfirmationRequest) (*api.ConfirmationResponse, error) {
func (s *authDBServer) Confirmation(ctx context.Context, req *api.ConfirmationRequest) (*api.ConfirmationResponse, error) {
s.mu.Lock()
defer s.mu.Unlock()

Loading…
Cancel
Save