feat: adding support to generate unified go sdk clients

Author: Dimy Jeannot

go/oeco-sdk/v2beta/CHANGELOG.md

@@ -2,25 +2,25 @@
 
 ### 🩹 Fixes
 
-- removing the nats server name random digits. Needs to be predictable when in cluster mode ([921bbe6](https://github.com/openecosystems/ecosystem/commit/921bbe6))
+-   removing the nats server name random digits. Needs to be predictable when in cluster mode ([921bbe6](https://github.com/openecosystems/ecosystem/commit/921bbe6))
 
 ### ❤️ Thank You
 
-- Dimy Jeannot
+-   Dimy Jeannot
 
 ## 0.22.0 (2025-10-08)
 
 ### 🚀 Features
 
-- adding conditional support for nats clustering; better logging; ([e179b70](https://github.com/openecosystems/ecosystem/commit/e179b70))
+-   adding conditional support for nats clustering; better logging; ([e179b70](https://github.com/openecosystems/ecosystem/commit/e179b70))
 
 ### 🩹 Fixes
 
-- removing the nats server name random digits. Needs to be predictable when in cluster mode ([8556170](https://github.com/openecosystems/ecosystem/commit/8556170))
+-   removing the nats server name random digits. Needs to be predictable when in cluster mode ([8556170](https://github.com/openecosystems/ecosystem/commit/8556170))
 
 ### ❤️ Thank You
 
-- Dimy Jeannot
+-   Dimy Jeannot
 
 ## 0.21.2 (2025-10-03)
 

go/oeco-sdk/v2beta/bindings/nats/listener.go

@@ -130,9 +130,9 @@ func ListenForMultiplexedRequests(_ context.Context, listener SpecEventListener)
 }
 
 // RespondToMultiplexedRequest processes an inbound message, modifies the provided message, and sends a response through NATS.
-func RespondToMultiplexedRequest(_ context.Context, message *ListenerMessage) {
+func RespondToMultiplexedRequest(ctx context.Context, message *ListenerMessage) {
 	log := *zaploggerv1.Bound.Logger
-	jsc := *Bound.JetStreamContext
+	js := *Bound.JetStream
 	nm := *message.NatsMessage
 
 	if message.Spec == nil {
@@ -197,12 +197,13 @@ func RespondToMultiplexedRequest(_ context.Context, message *ListenerMessage) {
 	}
 
 	go func() {
-		_, err = jsc.Publish(subject, specBytes)
+		_, err = js.Publish(ctx, subject, specBytes)
 		if err != nil {
 			message.Spec.SpecError = sdkv2betalib.ErrServerInternal.WithSpecDetail(message.Spec).WithInternalErrorDetail(errors.New("found error when publishing to jetstream subject: "+subject), err).ToStatus()
 			respond(&nm, message.Spec)
 			return
 		}
+		log.Info("Published to jetstream subject: " + subject)
 	}()
 
 	respond(&nm, message.Spec)

go/oeco-sdk/v2beta/bindings/nats/registry.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"reflect"
 	"time"
 
 	"github.com/nats-io/nats.go"
@@ -49,6 +50,57 @@ func RegisterEventStreams(environmentName string, streams []jetstream.StreamConf
 	}
 }
 
+func createOrUpdateStream2(cfg jetstream.StreamConfig) error {
+	js := *Bound.JetStream
+	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+	defer cancel()
+
+	info, err := js.Stream(ctx, cfg.Name)
+	if err != nil {
+		// Stream not found — create new
+		if errors.Is(err, jetstream.ErrStreamNotFound) {
+			fmt.Println("Creating stream:", cfg.Name)
+			if _, err := js.CreateOrUpdateStream(ctx, cfg); err != nil {
+				return fmt.Errorf("failed to create stream %s: %w", cfg.Name, err)
+			}
+			return nil
+		}
+		// Any other error
+		return fmt.Errorf("error fetching stream info for %s: %w", cfg.Name, err)
+	}
+
+	// Compare existing config with desired config
+	_cfg := info.CachedInfo().Config
+	if !streamConfigsEqual(&_cfg, &cfg) {
+		fmt.Printf("Updating stream %s (config has changed)\n", cfg.Name)
+		if _, err := js.CreateOrUpdateStream(ctx, cfg); err != nil {
+			return fmt.Errorf("failed to update stream %s: %w", cfg.Name, err)
+		}
+	} else {
+		fmt.Printf("Stream %s is up to date, no changes needed\n", cfg.Name)
+	}
+
+	return nil
+}
+
+func streamConfigsEqual(a, b *jetstream.StreamConfig) bool {
+	// ignore zero values (JetStream may fill defaults)
+	cleanA := normalizeStreamConfig(a)
+	cleanB := normalizeStreamConfig(b)
+	return reflect.DeepEqual(cleanA, cleanB)
+}
+
+func normalizeStreamConfig(cfg *jetstream.StreamConfig) *jetstream.StreamConfig {
+	c := *cfg
+	if c.MaxAge == 0 {
+		c.MaxAge = 0
+	}
+	if c.MaxMsgs == 0 {
+		c.MaxMsgs = -1
+	}
+	return &c
+}
+
 // createOrUpdateStream creates a new stream or updates an existing one using the provided StreamConfig.
 func createOrUpdateStream(cfg jetstream.StreamConfig) error {
 	// Check if stream exists

go/oeco-sdk/v2beta/configuration.go

@@ -20,11 +20,9 @@ import (
 	"github.com/iancoleman/strcase"
 	"github.com/joho/godotenv"
 	"github.com/mitchellh/mapstructure"
-	"github.com/spf13/viper"
-	"google.golang.org/protobuf/proto"
-
 	specv2pb "github.com/openecosystems/ecosystem/go/oeco-sdk/v2beta/gen/platform/spec/v2"
 	typev2pb "github.com/openecosystems/ecosystem/go/oeco-sdk/v2beta/gen/platform/type/v2"
+	"github.com/spf13/viper"
 )
 
 const (
@@ -211,13 +209,13 @@ func initializeConfigurer(opts ...ConfigurationProviderOption) (*Configurer, err
 		ctx = strings.TrimSpace(string(file))
 
 		if ctx == "" {
-			// Set the oeco workspace in the "default" file
-			err = filesystem.WriteFile(DefaultContextFile, []byte(OecoContextFileName), os.ModePerm)
+			// Set the adino workspace in the "default" file
+			err = filesystem.WriteFile(DefaultContextFile, []byte(AdinoContextFileName), os.ModePerm)
 			if err != nil {
 				return nil, errors.New("internal error: Cannot create default context")
 			}
 
-			_, err = createDefaultContextSettings(OecoContextFileName, DefaultCIDR)
+			_, err = createDefaultContextSettings(AdinoContextFileName, DefaultCIDR)
 			if err != nil {
 				return nil, err
 			}
@@ -237,15 +235,12 @@ func initializeConfigurer(opts ...ConfigurationProviderOption) (*Configurer, err
 func createDefaultContextSettings(ecosystemName string, cidr string) (*specv2pb.SpecSettings, error) {
 	// TODO: Sanitize ecosystemName
 
-	ip, ipnet, err := net.ParseCIDR(cidr)
+	_, _, err := net.ParseCIDR(cidr)
 	if err != nil {
 		fmt.Println("SpecError:", err)
 		return nil, err
 	}
 
-	fmt.Println("IP:", ip.String())
-	fmt.Println("Subnet Mask:", ipnet.Mask)
-
 	fs := NewFileSystem()
 	contextFile := filepath.Join(ContextDirectory, ecosystemName)
 
@@ -302,12 +297,12 @@ func createDefaultContextSettings(ecosystemName string, cidr string) (*specv2pb.
 		Systems: []*specv2pb.SpecSystem{&configurationSystem, &iamSystem},
 	}
 
-	settingBytes, err := proto.Marshal(&settings)
+	yaml, err := ProtoToYAML(&settings)
 	if err != nil {
 		return nil, err
 	}
 
-	err = fs.WriteFile(OecoContextFile+"."+ConfigurationExtension, settingBytes, os.ModePerm)
+	err = fs.WriteFile(AdinoContextFile+"."+ConfigurationExtension, []byte(yaml), os.ModePerm)
 	if err != nil {
 		return nil, errors.New("internal error: Cannot write ecosystem settings file")
 	}

go/oeco-sdk/v2beta/filesystem.go

@@ -39,14 +39,14 @@ type FileSystem struct {
 // ConfigurationDirectoryName specifies the directory name for configuration storage.
 // ConnectorDirectoryName specifies the directory name for connector storage.
 const (
-	HomeDirectoryName          = ".config/oeco"
+	HomeDirectoryName          = ".config/adino"
 	ConfigurationName          = "config"
 	ConfigurationExtension     = "yaml"
 	LogDirectoryName           = "logs"
 	LogExtension               = "log"
 	TmpDirectoryName           = "tmp"
 	ContextDirectoryName       = "context"
-	OecoContextFileName        = "oeco"
+	AdinoContextFileName       = "adino"
 	DefaultContextFileName     = "default"
 	CredentialDirectoryName    = "credentials"
 	RegistryDirectoryName      = "registry"
@@ -80,9 +80,9 @@ var (
 	ConfigurationDirectory = filepath.Join(HomeDirectory, ConfigurationDirectoryName)
 	ConnectorDirectory     = filepath.Join(HomeDirectory, ConnectorDirectoryName)
 	RegistryCacheDirectory = filepath.Join(RegistryDirectory, RegistryCacheDirectoryName)
-	OecoContextFile        = filepath.Join(ContextDirectory, OecoContextFileName)
+	AdinoContextFile       = filepath.Join(ContextDirectory, AdinoContextFileName)
 	DefaultContextFile     = filepath.Join(ContextDirectory, DefaultContextFileName)
-	OecoLogFile            = filepath.Join(LogDirectory, OecoContextFileName+"."+LogExtension)
+	OecoLogFile            = filepath.Join(LogDirectory, AdinoContextFileName+"."+LogExtension)
 	Filesystem             *FileSystem
 )
 

go/oeco-sdk/v2beta/gen/platform/spec/v2/spec_settings.pb.go

@@ -41,7 +41,6 @@ type Server struct {
 	NetListener             *net.Listener
 
 	options          *serverOptions
-	publicGRPCServer *http.Server
 	publicHTTPServer *http.Server
 	meshHTTPServer   *http.Server
 	// err     error
@@ -215,7 +214,6 @@ func (server *Server) listenAndServe(ln *net.Listener) (httpServerErr chan error
 		return
 	}
 
-	publicGrpcEndpoint := settings.Platform.GetGrpcEndpoint()
 	publicEndpoint := settings.Platform.GetEndpoint()
 	meshEndpoint := settings.Platform.Mesh.GetEndpoint()
 
@@ -252,16 +250,6 @@ func (server *Server) listenAndServe(ln *net.Listener) (httpServerErr chan error
 	server.MeshHTTPServerHandler = meshMux
 	meshMux.Handle("/", server.MeshServiceHandler)
 
-	publicGRPCServer := &http.Server{
-		Addr: publicGrpcEndpoint,
-		// Use h2c so we can serve HTTP/2 without TLS.
-		Handler:      h2c.NewHandler(edgeRouter(publicMux), server.PublicConnectHTTPServer),
-		ReadTimeout:  5 * time.Second,  // Time allowed to read the request
-		WriteTimeout: 10 * time.Second, // Time allowed to write the response
-		IdleTimeout:  15 * time.Second, // Time for keep-alive connections
-	}
-	server.publicGRPCServer = publicGRPCServer
-
 	publicHTTPServer := &http.Server{
 		Addr: publicEndpoint,
 		// Use h2c so we can serve HTTP/2 without TLS.
@@ -288,12 +276,7 @@ func (server *Server) listenAndServe(ln *net.Listener) (httpServerErr chan error
 		go func() {
 			_httpServerErr <- server.publicHTTPServer.ListenAndServe()
 		}()
-		fmt.Println("Public HTTP1.1/HTTP2.0/Connect listening on " + settings.Platform.Endpoint)
-
-		go func() {
-			_httpServerErr <- server.publicGRPCServer.ListenAndServe()
-		}()
-		fmt.Println("Public gRPC listening on " + settings.Platform.GrpcEndpoint)
+		fmt.Println("Public HTTP1.1/HTTP2.0/gRPC/gRPC-Web/Connect listening on " + settings.Platform.Endpoint)
 	}
 
 	if server.MeshConnectHTTPServer != nil {
@@ -338,10 +321,6 @@ func (server *Server) Shutdown() {
 		if err := server.publicHTTPServer.Shutdown(ctx); err != nil {
 			fmt.Println("Public server shutdown error:", err)
 		}
-
-		if err := server.publicGRPCServer.Shutdown(ctx); err != nil {
-			fmt.Println("Public gRPC server shutdown error:", err)
-		}
 	}
 
 	if server.MeshConnectHTTPServer != nil {