// SubscriptionSaga.php — the lifecycle begins inside the saga itself

use Ecotone\Modelling\Attribute\Saga;
use Ecotone\Modelling\Attribute\Identifier;
use Ecotone\Modelling\Attribute\CommandHandler;
use Ecotone\Modelling\Attribute\EventHandler;
use Ecotone\Modelling\WithEvents;
use Ecotone\Messaging\Scheduling\Delayed;

#[Saga]
final class SubscriptionSaga
{
    use WithEvents;

    private SubscriptionStatus $status = SubscriptionStatus::Active;

    private function __construct(
        #[Identifier] private string     $subscriptionId,
        private \DateTimeImmutable      $expiresAt,
    ) {
        // The saga's own lifecycle is the first event it produces.
        $this->recordThat(new SubscriptionCreated($subscriptionId, $expiresAt));
    }

    #[CommandHandler]
    public static function create(CreateSubscription $command): self
    {
        return new self($command->subscriptionId, $command->expiresAt);
    }

    // One day before expiry — try to renew
    #[Delayed(expression: "payload.expiresAt.modify('-1 day')")]
    #[EventHandler]
    public function renew(SubscriptionCreated $event, CommandBus $bus): void
    {
        if ($this->status === SubscriptionStatus::Active) {
            $bus->send(new AttemptRenewal($this->subscriptionId));
        }
    }

    // At expiry — terminate if still active
    #[Delayed(expression: "payload.expiresAt")]
    #[EventHandler]
    public function expire(SubscriptionCreated $event): void
    {
        if ($this->status === SubscriptionStatus::Active) {
            $this->status = SubscriptionStatus::Expired;
            $this->recordThat(new SubscriptionTerminated($this->subscriptionId, 'Expired'));
        }
    }
}

// Consume the Java-produced topic directly; retry and DLQ are attributes,
// not bridging code each PHP service has to re-implement.

use Ecotone\Kafka\Attribute\KafkaConsumer;
use Ecotone\Messaging\Attribute\Retry\InstantRetry;
use Ecotone\Messaging\Attribute\ErrorChannel;

final class SubscriptionEventConsumer
{
    #[KafkaConsumer(endpointId: 'php_subscriptions', topics: ['subscription.activated.v1'])]
    #[InstantRetry(retryTimes: 3, exceptions: [DatabaseConnectionFailure::class])]
    #[ErrorChannel('dbal_dead_letter')]
    public function onActivated(SubscriptionActivated $event): void
    {
        // Activate the PHP side: kick off the welcome saga, update the read
        // model, publish an internal domain event — your code, not a bridge.
    }
}

// SubscriptionUsageProjection.php — partitioned by aggregate, rebuilds in parallel

use Ecotone\Projecting\Attribute\ProjectionV2;
use Ecotone\Projecting\Attribute\FromAggregateStream;
use Ecotone\Projecting\Attribute\Partitioned;

#[ProjectionV2('subscription_usage')]
#[FromAggregateStream(Subscription::class)]
#[Partitioned(partitions: 60)]
final class SubscriptionUsageProjection
{
    #[EventHandler] public function onActivated(SubscriptionActivated $e): void { /* ... */ }
    #[EventHandler] public function onRenewed(SubscriptionRenewed $e): void   { /* ... */ }
    #[EventHandler] public function onExpired(SubscriptionExpired $e): void   { /* ... */ }
}