// PaymentCommandBus.php — one interface, three production behaviours
//
// • #[Deduplicated] on a custom Command Bus is Ecotone Enterprise.
// • #[InstantRetry] and the error channel work on the standard Command Bus too.

use Ecotone\Modelling\Attribute\Deduplicated;
use Ecotone\Messaging\Attribute\Retry\InstantRetry;
use Ecotone\Modelling\CommandBus;

#[Deduplicated(expression: "headers['paymentId']")]
#[InstantRetry(retryTimes: 2, exceptions: [
    DatabaseConnectionFailure::class,
    OptimisticLockingException::class,
])]
interface PaymentCommandBus extends CommandBus {}

// StripeWebhookController.php — the gateway entry point

final class StripeWebhookController
{
    public function __construct(private PaymentCommandBus $payments) {}

    public function __invoke(StripeWebhook $hook): Response
    {
        $this->payments->send(
            new CapturePayment($hook->paymentId, $hook->amount),
            metadata: ['paymentId' => $hook->paymentId],
        );

        return new Response('', 204);
    }
}

// AsyncChannelConfiguration.php — outbox + execution channel as one logical channel

use Ecotone\Dbal\Configuration\CombinedMessageChannel;
use Ecotone\Dbal\DbalBackedMessageChannelBuilder;
use Ecotone\Amqp\AmqpBackedMessageChannelBuilder;
use Ecotone\Messaging\Attribute\ServiceContext;

final class AsyncChannelConfiguration
{
    #[ServiceContext]
    public function paymentsOutbox(): array
    {
        return [
            // Storage half: the outbox table, written in the business transaction.
            DbalBackedMessageChannelBuilder::create('payments_outbox'),

            // Execution half: the broker that workers actually consume from.
            AmqpBackedMessageChannelBuilder::create('payments_broker'),

            // Handlers reference 'payments'. Ecotone writes to payments_outbox
            // in the SAME DBAL transaction as the business state change, then
            // a poller drains the outbox into payments_broker for execution.
            CombinedMessageChannel::create(
                'payments',
                ['payments_outbox', 'payments_broker'],
            ),
        ];
    }
}

// PaymentCaptureHandler.php — the channel name binds the handler to the outbox

use Ecotone\Messaging\Attribute\Asynchronous;
use Ecotone\Modelling\Attribute\CommandHandler;

final class PaymentCaptureHandler
{
    #[Asynchronous('payments')]
    #[CommandHandler]
    public function capture(CapturePayment $command): void
    {
        // Business logic commits in the same transaction as the outbox row.
    }
}

// CapturePayment.php — the command, encrypted everywhere it travels

use Ecotone\DataProtection\Attribute\Sensitive;
use Ecotone\DataProtection\Attribute\WithEncryptionKey;

// The encryption key is resolved per-merchant from the message header,
// so deleting one merchant's key crypto-shreds their data only.
#[WithEncryptionKey(expression: "headers['merchantId']")]
final readonly class CapturePayment
{
    public function __construct(
        public string $paymentId,
        public int    $amount,
        #[Sensitive] public string $primaryAccountNumber,
        #[Sensitive] public string $cardholderName,
    ) {}
}