Merge pull request #347 from aiven/byashimov-NEX-1845-add-kafka-topic-list-v2

feat: `ServiceKafkaTopicListV2` endpoint

Author: vmyroslav

config.yaml

@@ -191,6 +191,7 @@ KafkaTopic:
   - ServiceKafkaTopicDelete
   - ServiceKafkaTopicGet
   - ServiceKafkaTopicList
+  - ServiceKafkaTopicListV2
   - ServiceKafkaTopicMessageList
   - ServiceKafkaTopicMessageProduce
   - ServiceKafkaTopicUpdate

generator/models.go

@@ -109,9 +109,11 @@ func (p *Path) Comment() *jen.Statement {
 	c := jen.Comment(s)
 	c.Line().Comment(fmt.Sprintf("%s %s", p.Method, p.Path))
 
-	if p.Tags[0] == "" {
+	switch {
+	case p.Tags == nil:
+	case p.Tags[0] == "":
 		c.Line().Comment(fmt.Sprintf("%s/#operation/%s", docSite, p.OperationID))
-	} else {
+	default:
 		c.Line().Comment(fmt.Sprintf("%s/#tag/%s/operation/%s", docSite, p.Tags[0], p.OperationID))
 	}
 
@@ -579,7 +581,7 @@ func getEnumName(s *Schema) string {
 	return s.name
 }
 
-var camelFinder = regexp.MustCompile("[A-Z]+[a-z]+")
+var camelFinder = regexp.MustCompile("[A-Z]+[0-9a-z]+")
 
 // dedupCamelName removes duplicates: KafkaAclKafkaAcl -> KafkaAcl
 func dedupCamelName(src string) string {

handler/kafkatopic/kafkatopic.go

@@ -12,7 +12,27 @@ paths:
         - $ref: "#/components/parameters/service_name"
         - $ref: "#/components/parameters/service_kafka_quota_user"
         - $ref: "#/components/parameters/service_kafka_quota_client_id"
-
+  /v2/project/{project}/service/{service_name}/topic:
+    post:
+      summary: List Kafka topics V2
+      description: Retrieves a list of Kafka topics for a specific service. Experimental endpoint.
+      operationId: ServiceKafkaTopicListV2
+      parameters:
+        - $ref: "#/components/parameters/project"
+        - $ref: "#/components/parameters/service_name"
+      requestBody:
+        required: true
+        content:
+          application/json:
+            schema:
+              $ref: "#/components/schemas/ServiceKafkaTopicListV2Request"
+      responses:
+        "200":
+          description: Successful response
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/ServiceKafkaTopicListV2Response"
 components:
   schemas:
     ServiceKafkaConnectCreateConnectorRequestBody:
@@ -339,6 +359,22 @@ components:
       properties:
         project_vpc_id:
           nullable: true
+    ServiceKafkaTopicListV2Request:
+      type: object
+      required:
+        - topic_names
+      properties:
+        topic_names:
+          type: array
+          items:
+            type: string
+    ServiceKafkaTopicListV2Response:
+      type: object
+      properties:
+        topics:
+          type: array
+          items:
+            $ref: "#/components/schemas/ServiceKafkaTopicGetResponse/properties/topic"
   parameters:
     service_kafka_quota_user:
       in: query