fix(asyncapi/v3): fix servers

pkg/asyncapi/v3/channel.go

@@ -27,7 +27,7 @@ type Channel struct {
 	Title        string                 `json:"title"`
 	Summary      string                 `json:"summary"`
 	Description  string                 `json:"description"`
-	Servers      []*Server              `json:"servers"`
+	Servers      []*Server              `json:"servers"` // Reference only
 	Parameters   map[string]*Parameter  `json:"parameters"`
 	Tags         []*Tag                 `json:"tags"`
 	ExternalDocs *ExternalDocumentation `json:"externalDocs"`
@@ -58,11 +58,6 @@ func (ch *Channel) generateMetadata(parentName, name string) error {
 		}
 	}
 
-	// Generate servers metadata
-	for i, srv := range ch.Servers {
-		srv.generateMetadata(ch.Name, "", &i)
-	}
-
 	// Generate parameters metadata
 	for name, param := range ch.Parameters {
 		param.generateMetadata(ch.Name, name)

pkg/asyncapi/v3/components.go

@@ -103,7 +103,7 @@ func (c *Components) setDependencies(spec Specification) error {
 func (c *Components) generateMetadataFromMaps() error {
 	// Generate metadata for servers
 	for name, entity := range c.Servers {
-		entity.generateMetadata("", name, nil)
+		entity.generateMetadata("", name)
 	}
 
 	// Generate metadata for channels

pkg/asyncapi/v3/server.go

@@ -27,14 +27,14 @@ type Server struct {
 }
 
 // generateMetadata generates metadata for the Server.
-func (srv *Server) generateMetadata(parentName, name string, number *int) {
+func (srv *Server) generateMetadata(parentName, name string) {
 	// Prevent modification if nil
 	if srv == nil {
 		return
 	}
 
 	// Set name
-	srv.Name = generateFullName(parentName, name, "Server", number)
+	srv.Name = generateFullName(parentName, name, "Server", nil)
 
 	// Generate variables metadata
 	for n, s := range srv.Variables {

pkg/asyncapi/v3/specification.go

@@ -28,7 +28,7 @@ type Specification struct {
 	Version            string                `json:"asyncapi"`
 	ID                 string                `json:"id"`
 	Info               Info                  `json:"info"`
-	Servers            []*Server             `json:"servers"`
+	Servers            map[string]*Server    `json:"servers"`
 	DefaultContentType string                `json:"defaultContentType"`
 	Channels           map[string]*Channel   `json:"channels"`
 	Operations         map[string]*Operation `json:"operations"`
@@ -105,8 +105,8 @@ func (s *Specification) generateMetadata() error {
 	}
 
 	// Generate servers metadata
-	for i, srv := range s.Servers {
-		srv.generateMetadata("", "Server", &i)
+	for name, srv := range s.Servers {
+		srv.generateMetadata("", name)
 	}
 
 	// Generate metadata for channels

test/v3/issues/209/asyncapi.yaml

@@ -0,0 +1,15 @@
+asyncapi: 3.0.0
+info:
+  title: Hello world application
+  version: '0.1.0'
+servers:
+  local:
+    host: localhost:9092
+    protocol: kafka
+    protocolVersion: '3.5'
+    description: Local Kafka broker
+  test:
+    host: test.k8s.cluster.local:9092
+    protocol: kafka
+    protocolVersion: '3.5'
+    description: Test environment K8S Kafka cluster

test/v3/issues/209/generate.go

@@ -0,0 +1,5 @@
+//go:generate go run ../../../../cmd/asyncapi-codegen -g types -p issue209 -i ./asyncapi.yaml -o ./asyncapi.gen.go
+
+package issue209
+
+// This is just to test that the generation is correct