from django.core.management.base import BaseCommand

from api.services.integration.delivery import deliver_pending


class Command(BaseCommand):
    help = "Retry durable post-commit Kafka deliveries."

    def add_arguments(self, parser):
        parser.add_argument("--limit", type=int, default=100)

    def handle(self, *args, **options):
        delivered = deliver_pending(limit=options["limit"])
        self.stdout.write(f"published={delivered}")