diff --git a/internal/client/grpc/auth_client.go b/internal/client/grpc/auth_client.go index 26f9beb..0c72c2e 100644 --- a/internal/client/grpc/auth_client.go +++ b/internal/client/grpc/auth_client.go @@ -50,26 +50,27 @@ func (c *AuthClient) Logout(ctx context.Context, refreshToken string) error { return fmt.Errorf("not implemented: proto files not yet generated") } -// connectToService discovers and connects to a service instance. -func connectToService(ctx context.Context, reg registry.ServiceRegistry, serviceName string) (*grpc.ClientConn, error) { - instances, err := reg.Discover(ctx, serviceName) - if err != nil { - return nil, fmt.Errorf("failed to discover service %s: %w", serviceName, err) - } - - if len(instances) == 0 { - return nil, fmt.Errorf("no instances found for service %s", serviceName) - } - - // Use the first healthy instance (load balancing can be added later) - instance := instances[0] - address := fmt.Sprintf("%s:%d", instance.Address, instance.Port) - - // Create gRPC connection - conn, err := grpc.NewClient(address, grpc.WithTransportCredentials(insecure.NewCredentials())) - if err != nil { - return nil, fmt.Errorf("failed to connect to %s at %s: %w", serviceName, address, err) - } - - return conn, nil -} +// TODO: connectToService will be implemented when proto files are generated +// This function will discover and connect to a service instance via gRPC. +// func connectToService(ctx context.Context, reg registry.ServiceRegistry, serviceName string) (*grpc.ClientConn, error) { +// instances, err := reg.Discover(ctx, serviceName) +// if err != nil { +// return nil, fmt.Errorf("failed to discover service %s: %w", serviceName, err) +// } +// +// if len(instances) == 0 { +// return nil, fmt.Errorf("no instances found for service %s", serviceName) +// } +// +// // Use the first healthy instance (load balancing can be added later) +// instance := instances[0] +// address := fmt.Sprintf("%s:%d", instance.Address, instance.Port) +// +// // Create gRPC connection +// conn, err := grpc.NewClient(address, grpc.WithTransportCredentials(insecure.NewCredentials())) +// if err != nil { +// return nil, fmt.Errorf("failed to connect to %s at %s: %w", serviceName, address, err) +// } +// +// return conn, nil +// } diff --git a/internal/infra/database/client.go b/internal/infra/database/client.go index 90b2b73..fbbfa9f 100644 --- a/internal/infra/database/client.go +++ b/internal/infra/database/client.go @@ -97,7 +97,9 @@ func createSchemaIfNotExists(ctx context.Context, db *sql.DB, schemaName string) if err != nil { return err } - defer tx.Rollback() + defer func() { + _ = tx.Rollback() // Ignore error - if commit succeeded, rollback will error (expected) + }() // Check if schema exists var exists bool