feat: create new annotation for classes that allows you to have multiple channels within

kotlin-asyncapi-annotation/src/main/kotlin/org/openfolder/kotlinasyncapi/annotation/AsyncApiComponent.kt

@@ -0,0 +1,5 @@
+package org.openfolder.kotlinasyncapi.annotation
+
+@Target(AnnotationTarget.CLASS)
+@AsyncApiAnnotation
+annotation class AsyncApiComponent

kotlin-asyncapi-annotation/src/main/kotlin/org/openfolder/kotlinasyncapi/annotation/channel/Channel.kt

@@ -4,7 +4,8 @@ import org.openfolder.kotlinasyncapi.annotation.AsyncApiAnnotation
 
 @Target(
     AnnotationTarget.CLASS,
-    AnnotationTarget.ANNOTATION_CLASS
+    AnnotationTarget.ANNOTATION_CLASS,
+    AnnotationTarget.FUNCTION
 )
 @AsyncApiAnnotation
 annotation class Channel(

kotlin-asyncapi-context/src/main/kotlin/org/openfolder/kotlinasyncapi/context/annotation/AnnotationProvider.kt

@@ -1,6 +1,7 @@
 package org.openfolder.kotlinasyncapi.context.annotation
 
 import org.openfolder.kotlinasyncapi.annotation.AsyncApiAnnotation
+import org.openfolder.kotlinasyncapi.annotation.AsyncApiComponent
 import org.openfolder.kotlinasyncapi.annotation.Schema
 import org.openfolder.kotlinasyncapi.annotation.channel.Channel
 import org.openfolder.kotlinasyncapi.annotation.channel.Message
@@ -31,7 +32,8 @@ class AnnotationProvider(
     private val scanner: AnnotationScanner,
     private val messageProcessor: AnnotationProcessor<Message, KClass<*>>,
     private val schemaProcessor: AnnotationProcessor<Schema, KClass<*>>,
-    private val channelProcessor: AnnotationProcessor<Channel, KClass<*>>
+    private val channelProcessor: AnnotationProcessor<Channel, KClass<*>>,
+    private val asyncApiComponentProcessor: AnnotationProcessor<AsyncApiComponent, KClass<*>>
 ) : AsyncApiContextProvider {
 
     private val componentToChannelMapping = mutableMapOf<String, String>()
@@ -81,6 +83,7 @@ class AnnotationProvider(
                         componentToChannelMapping[clazz.java.simpleName] =
                             annotation.value.takeIf { it.isNotEmpty() } ?: clazz.java.simpleName
                     }
+                    is AsyncApiComponent -> asyncApiComponentProcessor.process(annotation, clazz)
                     else -> null
                 }
             }

kotlin-asyncapi-context/src/main/kotlin/org/openfolder/kotlinasyncapi/context/annotation/processor/AsyncApiComponentProcessor.kt

@@ -0,0 +1,30 @@
+package org.openfolder.kotlinasyncapi.context.annotation.processor
+
+import org.openfolder.kotlinasyncapi.annotation.AsyncApiComponent
+import org.openfolder.kotlinasyncapi.annotation.channel.Channel
+import org.openfolder.kotlinasyncapi.annotation.channel.Publish
+import org.openfolder.kotlinasyncapi.annotation.channel.Subscribe
+import org.openfolder.kotlinasyncapi.model.component.Components
+import kotlin.reflect.KClass
+import kotlin.reflect.full.findAnnotation
+import kotlin.reflect.full.functions
+import kotlin.reflect.full.hasAnnotation
+
+class AsyncApiComponentProcessor : AnnotationProcessor<AsyncApiComponent, KClass<*>> {
+    override fun process(annotation: AsyncApiComponent, context: KClass<*>): Components {
+        return Components().apply {
+            channels {
+                context.functions.filter { it.hasAnnotation<Channel>() }.forEach { currentFunction ->
+                    currentFunction.findAnnotation<Channel>()!!.toChannel()
+                        .apply {
+                            subscribe = subscribe ?: currentFunction.findAnnotation<Subscribe>()?.toOperation()
+                            publish = publish ?: currentFunction.findAnnotation<Publish>()?.toOperation()
+                        }
+                        .also {
+                            put(currentFunction.name, it)
+                        }
+                }
+            }
+        }
+    }
+}

kotlin-asyncapi-context/src/test/kotlin/org/openfolder/kotlinasyncapi/context/annotation/processor/AsyncApiComponentProcessorTest.kt

@@ -0,0 +1,62 @@
+package org.openfolder.kotlinasyncapi.context.annotation.processor
+
+import org.junit.jupiter.api.Test
+import org.openfolder.kotlinasyncapi.annotation.AsyncApiComponent
+import org.openfolder.kotlinasyncapi.annotation.channel.Channel
+import org.openfolder.kotlinasyncapi.annotation.channel.Message
+import org.openfolder.kotlinasyncapi.annotation.channel.Parameter
+import org.openfolder.kotlinasyncapi.annotation.channel.SecurityRequirement
+import org.openfolder.kotlinasyncapi.annotation.channel.Subscribe
+import org.openfolder.kotlinasyncapi.context.TestUtils.assertJsonEquals
+import org.openfolder.kotlinasyncapi.context.TestUtils.json
+import kotlin.reflect.full.findAnnotation
+
+internal class AsyncApiComponentProcessorTest {
+
+    private val processor = AsyncApiComponentProcessor()
+
+    @Test
+    fun `should process async api documentation annotation on class`() {
+        val payload = TestChannelFunction::class
+        val annotation = payload.findAnnotation<AsyncApiComponent>()!!
+
+        val expected = json("annotation/async_api_documentation_component.json")
+        val actual = json(processor.process(annotation, payload))
+
+        assertJsonEquals(expected, actual)
+    }
+
+
+    @AsyncApiComponent
+    class TestChannelFunction {
+        @Channel(
+            value = "some/{parameter}/channel",
+            description = "testDescription",
+            servers = ["dev"],
+            parameters = [
+                Parameter(
+                    value = "parameter",
+                    description = "testDescription"
+                )
+            ]
+        )
+        @Subscribe(
+            operationId = "testOperationId",
+            security = [
+                SecurityRequirement(
+                    key = "petstore_auth",
+                    values = ["write:pets", "read:pets"]
+                )
+            ],
+            message = Message(TestSubscribeMessage::class)
+        )
+        fun testSubscribe() {}
+    }
+
+    @Message
+    data class TestSubscribeMessage(
+        val id: Int = 0,
+        val name: String,
+        val isTest: Boolean
+    )
+}

kotlin-asyncapi-context/src/test/resources/annotation/async_api_documentation_component.json

@@ -0,0 +1,22 @@
+{
+  "channels" : {
+    "testSubscribe" : {
+      "description" : "testDescription",
+      "servers" : [ "dev" ],
+      "subscribe" : {
+        "operationId" : "testOperationId",
+        "security" : [ {
+          "petstore_auth" : [ "write:pets", "read:pets" ]
+        } ],
+        "message" : {
+          "$ref" : "#/components/messages/TestSubscribeMessage"
+        }
+      },
+      "parameters" : {
+        "parameter" : {
+          "description" : "testDescription"
+        }
+      }
+    }
+  }
+}

kotlin-asyncapi-ktor/src/main/kotlin/org/openfolder/kotlinasyncapi/ktor/AsyncApiModule.kt

@@ -14,6 +14,7 @@ import org.openfolder.kotlinasyncapi.context.PackageInfoProvider
 import org.openfolder.kotlinasyncapi.context.ResourceProvider
 import org.openfolder.kotlinasyncapi.context.annotation.AnnotationProvider
 import org.openfolder.kotlinasyncapi.context.annotation.DefaultAnnotationScanner
+import org.openfolder.kotlinasyncapi.context.annotation.processor.AsyncApiComponentProcessor
 import org.openfolder.kotlinasyncapi.context.annotation.processor.ChannelProcessor
 import org.openfolder.kotlinasyncapi.context.annotation.processor.MessageProcessor
 import org.openfolder.kotlinasyncapi.context.annotation.processor.SchemaProcessor
@@ -52,6 +53,8 @@ class AsyncApiModule(
 
     private val channelProcessor = ChannelProcessor()
 
+    private val asyncApiComponentProcessor = AsyncApiComponentProcessor()
+
     private val annotationScanner = DefaultAnnotationScanner()
 
     private val annotationProvider = with(configuration) {
@@ -62,6 +65,7 @@ class AsyncApiModule(
             messageProcessor = messageProcessor,
             schemaProcessor = schemaProcessor,
             channelProcessor = channelProcessor,
+            asyncApiComponentProcessor = asyncApiComponentProcessor
         )
     }
 

kotlin-asyncapi-spring-web/pom.xml

@@ -32,7 +32,7 @@
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-autoconfigure</artifactId>
-            <version>[2.6.4,2.7.17], [3.2.0,)</version>
+            <version>[2.6.4,2.7.17], [3.2.0,3.3.5]</version>
         </dependency>
         <dependency>
             <groupId>org.jetbrains.kotlin</groupId>

kotlin-asyncapi-spring-web/src/main/kotlin/org/openfolder/kotlinasyncapi/springweb/AsyncApiAutoConfiguration.kt

@@ -1,5 +1,6 @@
 package org.openfolder.kotlinasyncapi.springweb
 
+import org.openfolder.kotlinasyncapi.annotation.AsyncApiComponent
 import kotlin.reflect.KClass
 import kotlin.script.experimental.host.toScriptSource
 import kotlin.script.experimental.jvmhost.BasicJvmScriptingHost
@@ -13,9 +14,10 @@ import org.openfolder.kotlinasyncapi.context.annotation.AnnotationProvider
 import org.openfolder.kotlinasyncapi.context.annotation.AnnotationScanner
 import org.openfolder.kotlinasyncapi.context.annotation.DefaultAnnotationScanner
 import org.openfolder.kotlinasyncapi.context.annotation.processor.AnnotationProcessor
-import org.openfolder.kotlinasyncapi.context.annotation.processor.ChannelProcessor
+import org.openfolder.kotlinasyncapi.context.annotation.processor.AsyncApiComponentProcessor
 import org.openfolder.kotlinasyncapi.context.annotation.processor.MessageProcessor
 import org.openfolder.kotlinasyncapi.context.annotation.processor.SchemaProcessor
+import org.openfolder.kotlinasyncapi.context.annotation.processor.ChannelProcessor
 import org.openfolder.kotlinasyncapi.context.service.AsyncApiExtension
 import org.openfolder.kotlinasyncapi.context.service.AsyncApiSerializer
 import org.openfolder.kotlinasyncapi.context.service.AsyncApiService
@@ -102,6 +104,10 @@ internal open class AsyncApiAnnotationAutoConfiguration {
     open fun channelProcessor() =
         ChannelProcessor()
 
+    @Bean
+    open fun asyncApiDocumentationProcessor() =
+        AsyncApiComponentProcessor()
+
     @Bean
     open fun annotationScanner() =
         DefaultAnnotationScanner()
@@ -112,14 +118,16 @@ internal open class AsyncApiAnnotationAutoConfiguration {
         scanner: AnnotationScanner,
         messageProcessor: AnnotationProcessor<Message, KClass<*>>,
         schemaProcessor: AnnotationProcessor<Schema, KClass<*>>,
-        channelProcessor: AnnotationProcessor<Channel, KClass<*>>
+        channelClassProcessor: AnnotationProcessor<Channel, KClass<*>>,
+        asyncApiComponentProcessor: AnnotationProcessor<AsyncApiComponent, KClass<*>>
     ) = packageFromContext(context)?.let {
         AnnotationProvider(
             applicationPackage = it,
             scanner = scanner,
             messageProcessor = messageProcessor,
             schemaProcessor = schemaProcessor,
-            channelProcessor = channelProcessor,
+            channelProcessor = channelClassProcessor,
+            asyncApiComponentProcessor = asyncApiComponentProcessor,
         )
     }