Kotlin solution branch

core-api/pom.xml

@@ -11,17 +11,22 @@
 
     <artifactId>core-api</artifactId>
 
-    <properties>
-        <kotlin.version>1.7.20</kotlin.version>
-    </properties>
-
     <dependencies>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-data-jpa</artifactId>
             <scope>provided</scope>
         </dependency>
-
+        <dependency>
+            <groupId>org.jetbrains.kotlin</groupId>
+            <artifactId>kotlin-stdlib-jdk8</artifactId>
+            <version>${kotlin.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.jetbrains.kotlin</groupId>
+            <artifactId>kotlin-reflect</artifactId>
+            <version>${kotlin.version}</version>
+        </dependency>
     </dependencies>
 
-</project>
+</project>

core-api/src/main/kotlin/io/axoniq/demo/bikerental/coreapi/payment/PaymentStatus.kt

@@ -0,0 +1,17 @@
+package io.axoniq.demo.bikerental.coreapi.payment
+
+import jakarta.persistence.Entity
+import jakarta.persistence.Id
+
+@Entity
+data class PaymentStatus(
+    @Id var id: String,
+    val amount: Int,
+    val reference: String,
+    val status: Status = Status.PENDING,
+) {
+    fun approved() = this.copy(status = Status.APPROVED)
+    fun rejected() = this.copy(status = Status.REJECTED)
+
+    enum class Status { PENDING, APPROVED, REJECTED }
+}

core-api/src/main/kotlin/io/axoniq/demo/bikerental/coreapi/payment/payment-commands.kt

@@ -0,0 +1,17 @@
+package io.axoniq.demo.bikerental.coreapi.payment
+
+import org.axonframework.commandhandling.RoutingKey
+import org.axonframework.modelling.command.TargetAggregateIdentifier
+
+data class PreparePaymentCommand(
+    val amount: Int,
+    @RoutingKey val paymentReference: String
+)
+
+data class ConfirmPaymentCommand(
+    @TargetAggregateIdentifier val paymentId: String
+)
+
+data class RejectPaymentCommand(
+    @TargetAggregateIdentifier val paymentId: String
+)

core-api/src/main/kotlin/io/axoniq/demo/bikerental/coreapi/payment/payment-events.kt

@@ -0,0 +1,18 @@
+package io.axoniq.demo.bikerental.coreapi.payment
+
+data class PaymentConfirmedEvent(
+    val paymentId: String,
+    val paymentReference: String
+)
+
+data class PaymentPreparedEvent(
+    val paymentId: String,
+    val amount: Int,
+    val paymentReference: String
+)
+
+data class PaymentRejectedEvent(
+    val paymentId: String,
+    val paymentReference: String
+)
+

core-api/src/main/kotlin/io/axoniq/demo/bikerental/coreapi/rental/BikeStatus.kt

@@ -0,0 +1,44 @@
+package io.axoniq.demo.bikerental.coreapi.rental
+
+import jakarta.persistence.Entity
+import jakarta.persistence.Id
+
+@Entity
+data class BikeStatus(
+    @Id
+    var bikeId: String,
+    val bikeType: String,
+    val location: String,
+    val status: RentalStatus = RentalStatus.AVAILABLE,
+    val renter: String? = null,
+) {
+
+    fun returnedAt(location: String) = this.copy(
+        location = location,
+        status = RentalStatus.AVAILABLE,
+        renter = null
+    )
+
+    fun requestedBy(renter: String) = this.copy(
+        status = RentalStatus.REQUESTED,
+        renter = renter
+    )
+
+    fun rentedBy(renter: String) = this.copy(
+        status = RentalStatus.RENTED,
+        renter = renter
+    )
+
+    val description: String
+        get() = when (status) {
+            RentalStatus.RENTED -> "Bike $bikeId was rented by $renter in $location"
+            RentalStatus.AVAILABLE -> "Bike $bikeId is available for rental in $location."
+            RentalStatus.REQUESTED -> "Bike $bikeId is requested by $renter in $location"
+        }
+}
+
+enum class RentalStatus {
+    AVAILABLE,
+    REQUESTED,
+    RENTED
+}