from __future__ import absolute_import, unicode_literals
import os
from celery import Celery

# Set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'mysite.settings')

app = Celery('mysite')

# Using a string here means the worker will not have to
# pickle the object when using Windows.
app.config_from_object('django.conf:settings', namespace='CELERY')

# Load task modules from all registered Django app configs.
app.autodiscover_tasks()

@app.task(bind=True)
def debug_task(self):
    print(f'Request: {self.request!r}')

# views.py
@login_required
@csrf_exempt
def delete_ticket_fields(request):
    if request.method == "POST":
        field_ids = request.POST.getlist("ids[]")
        print(f"Field IDs to delete: {field_ids}")
        for field_id in field_ids:
            field = get_object_or_404(TicketFields, id=field_id)
            print(f"Deleting field with ID: {field_id}")
            result = delete_ticket_field_task.delay(
                field.zendesk_instance.zendesk_instance_url,
                field.zendesk_instance.author.email,
                field.zendesk_instance.api_token,
                field.zd_id,
            )
            print(f"Task result: {result}")
            field.delete()
        return JsonResponse({"status": "success"})
    return JsonResponse({"status": "failed"}, status=400)

# tasks.py

@shared_task
def delete_ticket_field_task(zendesk_instance_url, author_email, api_token, field_id):
    try:
        logger.info(f"Starting task to delete field: {field_id}")
        response = zd_delete_ticket_field(zendesk_instance_url, author_email, api_token, field_id)
        if response.status_code == 204:
            TicketFields.objects.filter(zd_id=field_id).delete()
        logger.info(f"Task completed with status: {response.status_code}")
        return response.status_code
    except Exception as exc:
        logger.error(f"Error occurred: {exc}")
        raise self.retry(exc=exc, countdown=60)

CMD ["sh", "-c", "python manage.py migrate && python manage.py collectstatic --noinput && gunicorn mysite.wsgi:application --bind 0.0.0.0:8000 & celery -A mysite worker --loglevel=info --concurrency=8 & celery -A mysite beat --loglevel=info & tail -f /dev/null"]