Skip to content
Snippets Groups Projects
Commit 41b24228 authored by Leonardo Christino's avatar Leonardo Christino
Browse files

fix logging

parent 40ad6bed
No related branches found
No related tags found
No related merge requests found
Pipeline #126441 failed
module schema-orchestrator module schema-orchestrator
go 1.16 go 1.18
require ( require (
git.science.uu.nl/graphpolaris/broker v0.0.0-20210913145737-76d174f4367a git.science.uu.nl/graphpolaris/broker v0.0.0-20210913145737-76d174f4367a
...@@ -16,3 +16,4 @@ require ( ...@@ -16,3 +16,4 @@ require (
google.golang.org/grpc v1.41.0 google.golang.org/grpc v1.41.0
google.golang.org/protobuf v1.25.0 google.golang.org/protobuf v1.25.0
) )
...@@ -8,10 +8,10 @@ package rpcdriver ...@@ -8,10 +8,10 @@ package rpcdriver
import ( import (
"context" "context"
"errors" "errors"
"log"
"os" "os"
"schema-orchestrator/internal/drivers/rpcdriver/databaseTypeService" "schema-orchestrator/internal/drivers/rpcdriver/databaseTypeService"
"github.com/rs/zerolog/log"
"google.golang.org/grpc" "google.golang.org/grpc"
) )
...@@ -29,24 +29,22 @@ func (driver *Driver) GetDatabaseType(clientID *string, databaseName *string) (* ...@@ -29,24 +29,22 @@ func (driver *Driver) GetDatabaseType(clientID *string, databaseName *string) (*
} }
conn, err := grpc.Dial(userManagementServiceAddress, grpc.WithInsecure()) conn, err := grpc.Dial(userManagementServiceAddress, grpc.WithInsecure())
if err != nil { if err != nil {
log.Println("ERROR connecting to user-management-service:9000") log.Error().AnErr("ERROR", err).Str("url", userManagementServiceAddress).Msg("ERROR connecting to user-management-service:9000")
log.Printf("ERROR %v", err)
return nil, err return nil, err
} }
defer conn.Close()
grpcClient := databaseTypeService.NewDatabaseTypeServiceClient(conn) grpcClient := databaseTypeService.NewDatabaseTypeServiceClient(conn)
response, err := grpcClient.GetDatabaseType(context.Background(), &databaseTypeService.DatabaseTypeRequest{ClientID: *clientID, DatabaseName: *databaseName}) response, err := grpcClient.GetDatabaseType(context.Background(), &databaseTypeService.DatabaseTypeRequest{ClientID: *clientID, DatabaseName: *databaseName})
if err != nil { if err != nil {
log.Println("ERROR querying to user-management-service:9000") log.Error().AnErr("ERROR", err).Str("url", userManagementServiceAddress).Msg("ERROR querying to user-management-service:9000")
log.Printf("ERROR %v", err)
return nil, err return nil, err
} else {
log.Info().Msg("Successfully retrieved database type")
} }
defer conn.Close()
var databaseType string var databaseType string
log.Printf("Responding with database type: %d", response.DatabaseType) // TODO: remove
switch response.DatabaseType { switch response.DatabaseType {
case databaseTypeService.DatabaseTypeResponse_ARANGODB: case databaseTypeService.DatabaseTypeResponse_ARANGODB:
databaseType = "arangodb" databaseType = "arangodb"
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment