Feature/axon example

jmolecules-axon/01-simple/pom.xml

@@ -0,0 +1,42 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <parent>
+    <groupId>org.jmolecules.examples</groupId>
+    <artifactId>jmolecules-examples-axon-root</artifactId>
+    <version>1.0.0-SNAPSHOT</version>
+    <relativePath>../pom.xml</relativePath>
+  </parent>
+
+  <name>jMolecules Examples - Axon Framework Simple</name>
+  <description>Simple Axon Framework Example using JMolecules</description>
+  <artifactId>jmolecules-axon-simple</artifactId>
+
+  <dependencies>
+    <!-- Axon Framework -->
+    <dependency>
+      <groupId>org.axonframework</groupId>
+      <artifactId>axon-modelling</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.axonframework</groupId>
+      <artifactId>axon-eventsourcing</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.axonframework</groupId>
+      <artifactId>axon-spring</artifactId>
+    </dependency>
+    <!-- Testing -->
+    <dependency>
+      <groupId>org.hamcrest</groupId>
+      <artifactId>hamcrest-core</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.slf4j</groupId>
+      <artifactId>slf4j-simple</artifactId>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+</project>

jmolecules-axon/src/main/java/org/jmolecules/example/axonframework/SampleQueryModel.java → jmolecules-axon/01-simple/src/main/java/org/jmolecules/example/axonframework/SampleQueryModel.java

@@ -25,6 +25,7 @@
 import org.axonframework.queryhandling.QueryHandler;
 import org.jmolecules.architecture.cqrs.annotation.QueryModel;
 import org.jmolecules.event.annotation.DomainEventHandler;
+import org.springframework.stereotype.Component;
 
 @Slf4j
 @QueryModel

jmolecules-axon/02-axonstyle-cqrs-es-bank/documentation/context-mapper/Context-Map.cml

@@ -0,0 +1,32 @@
+ContextMap AxonBank {
+    type = SYSTEM_LANDSCAPE
+    state = TO_BE
+
+    contains BankAccountContext
+}
+
+BoundedContext BankAccountContext {
+  Application {
+    Command CreateBankAccountCommand
+    Command DepositMoneyCommand
+    Command WithdrawMoneyCommand
+    Command CancelMoneyTransferCommand
+    Command CompleteMoneyTransferCommand
+    Command ReceiveMoneyTransferCommand
+    Command RequestMoneyTransferCommand
+  }
+  Aggregate BankAccount {
+    Entity BankAccountAggregate {
+      aggregateRoot
+    }
+    DomainEvent BankAccountCreatedEvent
+    DomainEvent MoneyDepositedEvent
+    DomainEvent MoneyWithdrawnEvent
+    DomainEvent MoneyTransferCancelledEvent
+    DomainEvent MoneyTransferCompletedEvent
+    DomainEvent MoneyTransferReceivedEvent
+    DomainEvent MoneyTransferredEvent
+    DomainEvent MoneyTransferRequestedEvent
+  }
+}
+

jmolecules-axon/02-axonstyle-cqrs-es-bank/pom.xml

@@ -0,0 +1,34 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <parent>
+    <groupId>org.jmolecules.examples</groupId>
+    <artifactId>jmolecules-examples-axon-root</artifactId>
+    <version>1.0.0-SNAPSHOT</version>
+    <relativePath>../pom.xml</relativePath>
+  </parent>
+
+  <name>jMolecules Examples - Axon Framework Bank Axon-Style/CQRS/ES</name>
+  <description>Axon Framework Spring-Boot Example using JMolecules applying Onion Architecture and CQRS/ES</description>
+  <artifactId>jmolecules-axon-style-cqrs-es-bank</artifactId>
+
+  <dependencies>
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-web</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.axonframework</groupId>
+      <artifactId>axon-spring-boot-starter</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>com.fasterxml.jackson.datatype</groupId>
+      <artifactId>jackson-datatype-jsr310</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.springdoc</groupId>
+      <artifactId>springdoc-openapi-starter-webmvc-ui</artifactId>
+    </dependency>
+  </dependencies>
+</project>

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/AxonBankApplication.java

@@ -0,0 +1,15 @@
+package org.jmolecules.example.axonframework;
+
+import io.swagger.v3.oas.annotations.OpenAPIDefinition;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+@OpenAPIDefinition
+public class AxonBankApplication {
+
+  public static void main(String[] args) {
+    SpringApplication.run(AxonBankApplication.class, args);
+  }
+
+}

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/application/package-info.java

@@ -0,0 +1,4 @@
+@ApplicationRing
+package org.jmolecules.example.axonframework.application;
+
+import org.jmolecules.architecture.onion.simplified.ApplicationRing;

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/domain/api/command/CreateBankAccountCommand.java

@@ -0,0 +1,14 @@
+package org.jmolecules.example.axonframework.domain.api.command;
+
+import org.axonframework.modelling.command.TargetAggregateIdentifier;
+import org.jmolecules.architecture.cqrs.annotation.Command;
+import org.jmolecules.ddd.annotation.Association;
+
+@Command(namespace = "axon.bank", name = "CreateBankAccountCommand")
+public record CreateBankAccountCommand(
+  @Association
+  String accountId,
+  int initialBalance
+) {
+  // empty
+}

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/domain/api/command/atm/DepositMoneyCommand.java

@@ -0,0 +1,13 @@
+package org.jmolecules.example.axonframework.domain.api.command.atm;
+
+import org.jmolecules.architecture.cqrs.annotation.Command;
+import org.jmolecules.ddd.annotation.Association;
+
+@Command(namespace = "axon.bank", name = "DepositMoneyCommand")
+public record DepositMoneyCommand(
+  @Association
+  String accountId,
+  int amount
+) {
+  // empty
+}

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/domain/api/command/atm/WithdrawMoneyCommand.java

@@ -0,0 +1,13 @@
+package org.jmolecules.example.axonframework.domain.api.command.atm;
+
+import org.jmolecules.architecture.cqrs.annotation.Command;
+import org.jmolecules.ddd.annotation.Association;
+
+@Command(namespace = "axon.bank", name = "WithdrawMoneyCommand")
+public record WithdrawMoneyCommand(
+  @Association
+  String accountId,
+  int amount
+) {
+  // empty
+}

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/domain/api/command/transfer/CancelMoneyTransferCommand.java

@@ -0,0 +1,18 @@
+package org.jmolecules.example.axonframework.domain.api.command.transfer;
+
+import org.jmolecules.architecture.cqrs.annotation.Command;
+import org.jmolecules.ddd.annotation.Association;
+
+@Command(namespace = "axon.bank", name = "CancelMoneyTransferCommand")
+public record CancelMoneyTransferCommand(
+
+  @Association
+  String sourceAccountId,
+
+  String moneyTransferId,
+
+  String reason
+
+) {
+
+}

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/domain/api/command/transfer/CompleteMoneyTransferCommand.java

@@ -0,0 +1,16 @@
+package org.jmolecules.example.axonframework.domain.api.command.transfer;
+
+import org.jmolecules.architecture.cqrs.annotation.Command;
+import org.jmolecules.ddd.annotation.Association;
+
+@Command(namespace = "axon.bank", name = "CompleteMoneyTransferCommand")
+public record CompleteMoneyTransferCommand(
+
+  @Association
+  String sourceAccountId,
+
+  String moneyTransferId
+
+) {
+
+}

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/domain/api/command/transfer/ReceiveMoneyTransferCommand.java

@@ -0,0 +1,19 @@
+package org.jmolecules.example.axonframework.domain.api.command.transfer;
+
+import org.jmolecules.architecture.cqrs.annotation.Command;
+import org.jmolecules.ddd.annotation.Association;
+
+/**
+ * Invoked by the saga, recipient is target account.
+ */
+@Command(namespace = "axon.bank", name = "ReceiveMoneyTransferCommand")
+public record ReceiveMoneyTransferCommand(
+  @Association
+  String targetAccountId,
+
+  String moneyTransferId,
+
+  int amount
+) {
+
+}

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/domain/api/command/transfer/RequestMoneyTransferCommand.java

@@ -0,0 +1,23 @@
+package org.jmolecules.example.axonframework.domain.api.command.transfer;
+
+import org.jmolecules.architecture.cqrs.annotation.Command;
+import org.jmolecules.ddd.annotation.Association;
+
+/**
+ * Received by the source account.
+ * Reserves amount for transfer and starts saga.
+ */
+@Command(namespace = "axon.bank", name = "RequestMoneyTransferCommand")
+public record RequestMoneyTransferCommand(
+
+  @Association
+  String sourceAccountId,
+
+  String targetAccountId,
+
+  int amount
+) {
+
+  // empty
+
+}

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/domain/api/exception/InsufficientBalanceException.java

@@ -0,0 +1,14 @@
+package org.jmolecules.example.axonframework.domain.api.exception;
+
+
+public class InsufficientBalanceException extends RuntimeException{
+
+  public InsufficientBalanceException(String accountId, int currentBalance, int withdrawAmount, int minAmount) {
+    super(String.format("BankAccount[id=%s, currentBalance=%d]: Withdrawal of amount=%d not allowed, would subceed min. balance of %d",
+                        accountId,
+                        currentBalance,
+                        withdrawAmount,
+                        minAmount
+    ));
+  }
+}

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/domain/api/exception/MaximumBalanceExceededException.java

@@ -0,0 +1,13 @@
+package org.jmolecules.example.axonframework.domain.api.exception;
+public class MaximumBalanceExceededException extends RuntimeException {
+
+
+  public MaximumBalanceExceededException(String accountId, int currentBalance, int depositAmount, int maxAmount) {
+    super(String.format("BankAccount[id=%s, currentBalance=%d]: Deposit of amount=%d not allowed, would exceed max. balance of %d",
+      accountId,
+      currentBalance,
+      depositAmount,
+      maxAmount
+    ));
+  }
+}

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/domain/api/query/CurrentBalanceQuery.java

@@ -0,0 +1,13 @@
+package org.jmolecules.example.axonframework.domain.api.query;
+
+import org.axonframework.messaging.responsetypes.ResponseType;
+import org.axonframework.messaging.responsetypes.ResponseTypes;
+
+import java.util.Optional;
+
+
+public record CurrentBalanceQuery(
+  String accountId
+) {
+  public static ResponseType<Optional<CurrentBalanceResponse>> RESPONSE_TYPE = ResponseTypes.optionalInstanceOf(CurrentBalanceResponse.class);
+}

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/domain/api/query/CurrentBalanceResponse.java

@@ -0,0 +1,8 @@
+package org.jmolecules.example.axonframework.domain.api.query;
+
+public record CurrentBalanceResponse(
+  String accountId,
+  int currentBalance
+) {
+  // empty
+}

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/domain/api/query/MoneyTransfer.java

@@ -0,0 +1,20 @@
+package org.jmolecules.example.axonframework.domain.api.query;
+
+public record MoneyTransfer(
+  String moneyTransferId,
+  String sourceAccountId,
+  String targetAccountId,
+  int amount,
+  Boolean success,
+  String message
+) {
+
+  public MoneyTransfer(String moneyTransferId, String sourceAccountId, String targetAccountId, int amount) {
+    this(moneyTransferId, sourceAccountId, targetAccountId, amount, null, null);
+  }
+
+  public MoneyTransfer(String moneyTransferId, String sourceAccountId, String targetAccountId, int amount, String message) {
+    this(moneyTransferId, sourceAccountId, targetAccountId, amount, message == null, message);
+  }
+
+}

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/domain/api/query/MoneyTransferByIdQuery.java

@@ -0,0 +1,12 @@
+package org.jmolecules.example.axonframework.domain.api.query;
+
+import org.axonframework.messaging.responsetypes.ResponseType;
+import org.axonframework.messaging.responsetypes.ResponseTypes;
+
+import java.util.Optional;
+
+public record MoneyTransferByIdQuery(String moneyTransferId) {
+
+  public static final ResponseType<Optional<MoneyTransfer>> RESPONSE_TYPE = ResponseTypes.optionalInstanceOf(MoneyTransfer.class);
+
+}

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/domain/api/query/MoneyTransfersQuery.java

@@ -0,0 +1,12 @@
+package org.jmolecules.example.axonframework.domain.api.query;
+
+import org.axonframework.messaging.responsetypes.ResponseType;
+import org.axonframework.messaging.responsetypes.ResponseTypes;
+
+public record MoneyTransfersQuery(String accountId) {
+  public static final ResponseType<MoneyTransfersResponse> RESPONSE_TYPE = ResponseTypes.instanceOf(MoneyTransfersResponse.class);
+
+  public MoneyTransfersQuery() {
+    this(null);
+  }
+}

jmolecules-axon/02-axonstyle-cqrs-es-bank/src/main/java/org/jmolecules/example/axonframework/domain/api/query/MoneyTransfersResponse.java

@@ -0,0 +1,12 @@
+package org.jmolecules.example.axonframework.domain.api.query;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+
+public record MoneyTransfersResponse(List<MoneyTransfer> moneyTransfers) {
+
+  public MoneyTransfersResponse(Collection<MoneyTransfer> moneyTransfers) {
+    this(new ArrayList<>(moneyTransfers));
+  }
+}