Merge pull request #12 from tiarebalbi/issue-11

Fix: Fixes #11

Author: tiarebalbi

infinitic-spring-boot-3-example/build.gradle.kts

@@ -0,0 +1,42 @@
+import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
+
+plugins {
+    id("org.springframework.boot") version "3.1.4"
+    id("io.spring.dependency-management") version "1.1.3"
+    kotlin("jvm") version "1.8.22"
+    kotlin("plugin.spring") version "1.8.22"
+}
+
+group = "com.tiarebalbi.example"
+version = "0.0.1-SNAPSHOT"
+extra["infiniticVersion"] = "0.11.6"
+
+java {
+    sourceCompatibility = JavaVersion.VERSION_17
+}
+
+repositories {
+    mavenCentral()
+}
+
+dependencies {
+    api(project(":infinitic-spring-boot-3-starter"))
+    implementation("io.infinitic:infinitic-inMemory:${project.extra["infiniticVersion"]}")
+    implementation("io.infinitic:infinitic-client:${project.extra["infiniticVersion"]}")
+    implementation("io.infinitic:infinitic-worker:${project.extra["infiniticVersion"]}")
+    implementation("org.springframework.boot:spring-boot-starter")
+    implementation("org.jetbrains.kotlin:kotlin-reflect")
+    annotationProcessor("org.springframework.boot:spring-boot-configuration-processor")
+    testImplementation("org.springframework.boot:spring-boot-starter-test")
+}
+
+tasks.withType<KotlinCompile> {
+    kotlinOptions {
+        freeCompilerArgs += "-Xjsr305=strict"
+        jvmTarget = "17"
+    }
+}
+
+tasks.withType<Test> {
+    useJUnitPlatform()
+}

infinitic-spring-boot-3-example/src/main/kotlin/com/tiarebalbi/example/InfiniticSpringBoot3ExampleApplication.kt

@@ -0,0 +1,24 @@
+package com.tiarebalbi.example
+
+import com.tiarebalbi.example.demo.DemoService
+import org.springframework.beans.factory.InitializingBean
+import org.springframework.boot.autoconfigure.SpringBootApplication
+import org.springframework.boot.runApplication
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+
+@SpringBootApplication
+class InfiniticSpringBoot3ExampleApplication
+
+fun main(args: Array<String>) {
+    runApplication<InfiniticSpringBoot3ExampleApplication>(*args)
+}
+
+@Configuration
+class Config {
+
+    @Bean
+    fun initService(demoService: DemoService) = InitializingBean {
+        demoService.runDemoFlow()
+    }
+}

infinitic-spring-boot-3-example/src/main/kotlin/com/tiarebalbi/example/demo/AnnotatedService.kt

@@ -0,0 +1,14 @@
+package com.tiarebalbi.example.demo
+
+import io.infinitic.annotations.Name
+
+@Name("annotatedService")
+interface AnnotatedService {
+    @Name("bar")
+    fun foo(str1: String, str2: String): String
+}
+
+@Suppress("unused")
+class AnnotatedServiceImpl : AnnotatedService {
+    override fun foo(str1: String, str2: String) = str1 + str2
+}

infinitic-spring-boot-3-example/src/main/kotlin/com/tiarebalbi/example/demo/AnnotatedWorkflow.kt

@@ -0,0 +1,25 @@
+package com.tiarebalbi.example.demo
+
+import io.infinitic.annotations.Name
+import io.infinitic.workflows.Workflow
+
+@Name("annotatedWorkflow")
+interface AnnotatedWorkflow {
+    @Name("bar")
+    fun concatABC(input: String): String
+}
+
+@Suppress("unused")
+class AnnotatedWorkflowImpl : Workflow(), AnnotatedWorkflow {
+    private val service = newService(AnnotatedService::class.java)
+
+    override fun concatABC(input: String): String {
+        var str = input
+
+        str = service.foo(str, "a")
+        str = service.foo(str, "b")
+        str = service.foo(str, "c")
+
+        return str // should be "${input}abc"
+    }
+}

infinitic-spring-boot-3-example/src/main/kotlin/com/tiarebalbi/example/demo/DemoService.kt

@@ -0,0 +1,13 @@
+package com.tiarebalbi.example.demo
+
+import io.infinitic.clients.InfiniticClient
+import org.springframework.stereotype.Service
+
+@Service
+class DemoService(private val infiniticClient: InfiniticClient) {
+    fun runDemoFlow() {
+        val event = this.infiniticClient.newWorkflow(AnnotatedWorkflow::class.java)
+        val result = event.concatABC("Demo-")
+        println("Result: $result")
+    }
+}

infinitic-spring-boot-3-example/src/main/resources/application.properties

@@ -0,0 +1,10 @@
+# Enable auto-configure
+infinitic.enabled=true
+
+## Worker Setting
+infinitic.worker.enabled=true
+infinitic.worker.configuration=classpath:infinitic-worker.yml
+
+## Client Setting
+infinitic.client.enabled=true
+infinitic.client.configuration=classpath:infinitic-client.yml

infinitic-spring-boot-3-example/src/main/resources/infinitic-client.yml

@@ -0,0 +1,6 @@
+# Comment the line below to perform tests on a local Pulsar cluster
+transport: inMemory
+
+pulsar:
+  tenant: infinitic
+  namespace: dev

infinitic-spring-boot-3-example/src/main/resources/infinitic-worker.yml

@@ -0,0 +1,16 @@
+# Comment the line below to perform tests on a local Pulsar cluster
+transport: inMemory
+
+pulsar:
+  tenant: infinitic
+  namespace: dev
+
+services:
+  - name: annotatedService
+    class: com.tiarebalbi.example.demo.AnnotatedServiceImpl
+    concurrency: 5
+
+workflows:
+  - name: annotatedWorkflow
+    class: com.tiarebalbi.example.demo.AnnotatedWorkflowImpl
+    concurrency: 5

infinitic-spring-boot-3-starter/build.gradle.kts

@@ -3,8 +3,9 @@ import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
 
 
 plugins {
+    id("org.springframework.boot") version "3.1.4"
     id("com.github.ben-manes.versions") version "0.48.0"
-    id("org.springframework.boot") version "3.1.3"
+
     id("io.spring.dependency-management") version "1.1.3"
     id("org.jlleitschuh.gradle.ktlint") version "11.5.1"
     id("org.jetbrains.dokka") version "1.9.0"
@@ -16,7 +17,7 @@ plugins {
 }
 
 group = "com.tiarebalbi.infinitic"
-version = "1.0.0"
+version = "1.0.1"
 extra["infiniticVersion"] = "0.11.6"
 
 val bootJar: org.springframework.boot.gradle.tasks.bundling.BootJar by tasks
@@ -50,6 +51,12 @@ repositories {
     mavenCentral()
 }
 
+configurations {
+    compileOnly {
+        extendsFrom(configurations.annotationProcessor.get())
+    }
+}
+
 dependencies {
     implementation("io.infinitic:infinitic-client:${project.extra["infiniticVersion"]}")
     implementation("io.infinitic:infinitic-worker:${project.extra["infiniticVersion"]}")

infinitic-spring-boot-3-starter/src/main/kotlin/com/tiarebalbi/infinitic/spring/InfiniticAutoConfiguration.kt

@@ -6,6 +6,7 @@ import io.infinitic.workers.InfiniticWorker
 import io.infinitic.workers.config.WorkerConfig
 import org.slf4j.LoggerFactory
 import org.springframework.beans.factory.InitializingBean
+import org.springframework.boot.autoconfigure.AutoConfiguration
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty
 import org.springframework.boot.context.properties.EnableConfigurationProperties
@@ -45,6 +46,7 @@ import org.springframework.core.io.ResourceLoader
  * @param resourceLoader the ResourceLoader object used to load the client configuration file
  * @author tiare.balbi
  */
+@AutoConfiguration
 @Configuration
 @ConditionalOnProperty(
     name = ["infinitic.enabled"],