Congratulations and question

[frederikhors]

Congratulations for your project.

Can I ask you how to deal with db transactions calls?

[jultabary]

Hi thanks 😄
You can implements your own CommandBus depending the framework you are using.
If you are in a SpringbootProjet : it can looks like something like this.

@Component
@Qualifier("transactionCommandBus")
public class TransactionCommandBus implements CommandBus {
         private CommandBus nextCommandBus;

         public TransactionCommandBus() {
         }
         
         @Transactionnal
         public List<Event> dispatch(Command command) {
                 return this.nextCommandBus.dispatch(command);
         }
         
         public void setNextCommandBus(CommandBus commandBus) {
                 this.nextCommandBus = commandBus;
         }
}

Then hen you will building the bus:

@Component
public class Application implements CommandBus, QueryBus {
       private CommandBus commandBus;
       private QueryBus queryBus;

       public Application(@Qualifier("transactionCommandBus") transactionCommandBus) {
            CommandBus commandDispatcher = new CommandDispatcher(.....);
            transactionCommandBus.setNextCommandBus(commandDispatcher);
            this.commandBus = transactionCommandBus;
            .....
      }

      public List<Event> dispatch(Command command) {
            return this.commandBus.dispatch(command);
      }
 
}

With a kind of commandBus like this all your "business" transaction (represents by CommandHandler) will be executed in a db transaction.

I will add an example in this repository.

[frederikhors]

Thank you. I'm using Rust. It would be awesome to have an example in Rust. :) ♥

[jultabary]

Have a look here , i have updated this example with a new command_bus wich handle database transaction.

[jultabary]

By the way, it should better to wrap the persistence transaction middleware by the logging middleware. And not the opposite.
I will fix it later

[frederikhors]

I will fix it later

Closed?

[jultabary]

Yes the sqlx rocket prject has been updated here.
Does it answer to your question 😄 ?

[frederikhors]

Thanks!