Refactor aggregate module

[dgafka]

Why is this change proposed?

• This removes multiple abstractions for different way of saving (It was complicating reasoning about system)
• Introduces generic way of saving Aggregate and introduce Aggregate Definition (holding all information about Aggregate configuration)
• Refactor lower test that were bound to existing design to use Ecotone Lite (was testing implementation, not end user behaviour and automatically broke with refactor)

Description of Changes

Pull Request Contribution Terms

• I have read and agree to the contribution terms outlined in CONTRIBUTING.

[dgafka]

New implementation able to handle resolving aggregate instance, storing it in repo and publishing events.

[dgafka]

This class resolve aggregates that are needed to be saved. No need for RESULT_AGGREGATE header anymore, as it will cover different scenarios to find out what is to be saved based on incoming message.

[lifinsky]

Will this somehow affect current implementations? When, for example, built-in repository with doctrine entity manager are used.

We also use repository interface additionally to in-built event sourcing repository. For, example:

interface CardRepositoryInterface
{
    #[Repository]
    public function getById(Uuid $id): Card; // event sourcing aggregate
}

Will this still work?
@dgafka

[lifinsky]

@dgafka after update to latest version this code stopped working (used it for testing the issue with outbox and amqp):

    #[CommandHandler(self::PREPARE_TICKET_TICKET)]
    public static function prepare(PrepareTicket $command): array
    {
        return [new TicketWasPrepared($command->ticketId ?: Uuid::uuid4()->toString(), $command->ticketType, $command->description)];
    }

    #[CommandHandler(self::CANCEL_TICKET)]
    public function cancel(): array
    {
        if ($this->isCancelled) {
            return [];
        }

        return [new TicketWasCancelled($this->ticketId)];
    }

    #[EventSourcingHandler]
    public function applyTicketWasPrepared(TicketWasPrepared $event): void
    {
        $this->ticketId    = $event->ticketId;
        $this->isCancelled = false;
        $this->isAssigned  = false;
    }

    #[Asynchronous('backoffice_db_amqp')] // combined channel
    #[EventHandler(endpointId: 'ticket.wasPrepared')]
    public function cancelAfterPrepare(TicketWasPrepared $event, #[Reference] CommandBus $commandBus): void
    {
        $commandBus->sendWithRouting(Ticket::CANCEL_TICKET, metadata: ['aggregate.id' => $event->ticketId]);
    }

In amqp consumer get exception:
Pure event sourced aggregate should return iterable of events, but got string in AggregateResolver

[lifinsky]

@dgafka after update to latest version this code stopped working (used it for testing the issue with outbox and amqp):

    #[CommandHandler(self::PREPARE_TICKET_TICKET)]
    public static function prepare(PrepareTicket $command): array
    {
        return [new TicketWasPrepared($command->ticketId ?: Uuid::uuid4()->toString(), $command->ticketType, $command->description)];
    }

    #[CommandHandler(self::CANCEL_TICKET)]
    public function cancel(): array
    {
        if ($this->isCancelled) {
            return [];
        }

        return [new TicketWasCancelled($this->ticketId)];
    }

    #[EventSourcingHandler]
    public function applyTicketWasPrepared(TicketWasPrepared $event): void
    {
        $this->ticketId    = $event->ticketId;
        $this->isCancelled = false;
        $this->isAssigned  = false;
    }

    #[Asynchronous('backoffice_db_amqp')] // combined channel
    #[EventHandler(endpointId: 'ticket.wasPrepared')]
    public function cancelAfterPrepare(TicketWasPrepared $event, #[Reference] CommandBus $commandBus): void
    {
        $commandBus->sendWithRouting(Ticket::CANCEL_TICKET, metadata: ['aggregate.id' => $event->ticketId]);
    }

In amqp consumer get exception: Pure event sourced aggregate should return iterable of events, but got string in AggregateResolver

it still works with this code:

    #[Asynchronous('backoffice_outbox')]
    #[EventHandler(endpointId: 'ticket.wasPrepared')]
    public function cancelAfterPrepare(TicketWasPrepared $event): array
    {
        return $this->cancel();
    }

But it seems to me dangerous if something that previously worked stops working.

[dgafka]

@lifinsky that was not expected behaviour to use with Pure ES. It did work but not by intention.
But it make sense to make it possible, so that's unblocked and covered with test scenario to avoid B/C now (#430)