fix: OECO cleanup 22 (#54)

* fix: found bug when using remote connectors

* fix: adding exists to the CQRS check

---------

Co-authored-by: Dimy Jeannot <>

Author: dimyjeannot

libs/partner/go/zap/main.go

@@ -17,6 +17,9 @@ type Binding struct {
 	Logger        *zap.Logger
 	SugaredLogger *zap.SugaredLogger
 
+	LoggerWrapper        *ZapLoggerWrapper
+	SugaredLoggerWrapper *ZapSugaredLoggerWrapper
+
 	configuration *Configuration
 }
 
@@ -53,8 +56,10 @@ func (b *Binding) Bind(_ context.Context, bindings *sdkv2alphalib.Bindings) *sdk
 				defer b.Logger.Sync() //nolint:errcheck
 
 				Bound = &Binding{
-					Logger:        b.Logger,
-					SugaredLogger: b.Logger.Sugar(),
+					Logger:               b.Logger,
+					SugaredLogger:        b.Logger.Sugar(),
+					LoggerWrapper:        NewZapLoggerWrapper(b.Logger),
+					SugaredLoggerWrapper: NewZapSugaredLoggerWrapper(b.Logger.Sugar()),
 
 					configuration: b.configuration,
 				}
@@ -78,3 +83,41 @@ func (b *Binding) Close() error {
 	fmt.Println("Closing the Uber Zap Logger Binding")
 	return nil
 }
+
+// ZapLoggerWrapper wraps a zap.Logger to implement log-compatible interfaces like Printf for structured logging.
+// It provides a convenient way to integrate zap.Logger into libraries expecting standard logging interfaces.
+type ZapLoggerWrapper struct {
+	logger *zap.Logger
+}
+
+// NewZapLoggerWrapper creates and returns a new instance of ZapLoggerWrapper using the provided zap.Logger instance.
+func NewZapLoggerWrapper(z *zap.Logger) *ZapLoggerWrapper {
+	return &ZapLoggerWrapper{
+		logger: z,
+	}
+}
+
+// Printf logs a formatted message at the INFO level using the zap.Logger instance.
+func (z *ZapLoggerWrapper) Printf(format string, v ...any) {
+	msg := fmt.Sprintf(format, v...)
+	z.logger.Info(msg)
+}
+
+// ZapSugaredLoggerWrapper is a wrapper around zap.SugaredLogger to provide custom logging functionalities.
+// It includes methods for structured and formatted logging leveraging the underlying zap.SugaredLogger instance.
+type ZapSugaredLoggerWrapper struct {
+	logger *zap.SugaredLogger
+}
+
+// NewZapSugaredLoggerWrapper initializes and returns a new ZapSugaredLoggerWrapper using the provided SugaredLogger instance.
+func NewZapSugaredLoggerWrapper(z *zap.SugaredLogger) *ZapSugaredLoggerWrapper {
+	return &ZapSugaredLoggerWrapper{
+		logger: z,
+	}
+}
+
+// Printf logs a formatted message at the Info level using the provided format and arguments.
+func (z *ZapSugaredLoggerWrapper) Printf(format string, v ...any) {
+	msg := fmt.Sprintf(format, v...)
+	z.logger.Info(msg)
+}

libs/plugins/protoc-gen-platform/languages/go/plugins/cli_methods/templates/file.go.tmpl

@@ -16,15 +16,12 @@ import (
     "github.com/spf13/cobra"
 {{ if ne (getApiOptionsNetwork . ) "overlay" -}}
     "net/http"
-    "github.com/openecosystems/ecosystem/libs/{{ $apiType }}/go/sdk/gen/platform/{{ $system.LowerCamelCase }}/{{ $versionLower }}"
-    "github.com/openecosystems/ecosystem/libs/{{ $apiType }}/go/sdk/gen/platform/{{ $system.LowerCamelCase }}/{{ $versionLower }}/{{ $system.LowerCamelCase }}{{ $versionLower }}pbconnect"
 {{ else -}}
-    "github.com/openecosystems/ecosystem/libs/{{ $apiType }}/go/sdk/gen/platform/{{ $system.LowerCamelCase }}/{{ $versionLower }}"
-    "github.com/openecosystems/ecosystem/libs/{{ $apiType }}/go/sdk/gen/platform/{{ $system.LowerCamelCase }}/{{ $versionLower }}/{{ $system.LowerCamelCase }}{{ $versionLower }}pbconnect"
 {{ end }}
 
 {{ range getImportPackages .File }}
-    //"{{ . }}"
+    "{{ . }}"
+    "{{ . }}/{{ $system.LowerCamelCase }}{{ $versionLower }}pbconnect"
 {{ end }}
 )
 

libs/plugins/protoc-gen-platform/shared/functions_cqrs.go

@@ -139,6 +139,8 @@ func (fns Functions) IsCQRSType(method pgs.Method) string {
 		return "query"
 	case options.CQRSType_CQRS_TYPE_QUERY_GET:
 		return "query"
+	case options.CQRSType_CQRS_TYPE_QUERY_EXISTS:
+		return "query"
 	case options.CQRSType_CQRS_TYPE_QUERY_CLIENT_STREAM:
 		return "query-client-stream"
 	case options.CQRSType_CQRS_TYPE_QUERY_SERVER_STREAM:
@@ -188,6 +190,8 @@ func (fns Functions) GetCQRSType(method pgs.Method) string {
 		return "list"
 	case options.CQRSType_CQRS_TYPE_QUERY_GET:
 		return "get"
+	case options.CQRSType_CQRS_TYPE_QUERY_EXISTS:
+		return "exists"
 	case options.CQRSType_CQRS_TYPE_QUERY_CLIENT_STREAM:
 		return "stream-client"
 	case options.CQRSType_CQRS_TYPE_QUERY_SERVER_STREAM:
@@ -216,6 +220,8 @@ func (fns Functions) ConvertCQRSTypeToString(t options.CQRSType) string {
 		return "Mutation"
 	case options.CQRSType_CQRS_TYPE_QUERY_LIST:
 		fallthrough
+	case options.CQRSType_CQRS_TYPE_QUERY_EXISTS:
+		fallthrough
 	case options.CQRSType_CQRS_TYPE_QUERY_STREAM:
 		fallthrough
 	case options.CQRSType_CQRS_TYPE_QUERY_CLIENT_STREAM: