d7f6228d7f
- تفعيل مكون SummarizePdf لإنشاء ملخصات PDF باستخدام الذكاء الاصطناعي. - تفعيل مكون TranslatePdf لترجمة محتوى PDF إلى لغات متعددة. - تفعيل مكون TableExtractor لاستخراج الجداول من ملفات PDF. - تحديث الصفحة الرئيسية والتوجيه ليشمل الأدوات الجديدة. - إضافة ترجمات للأدوات الجديدة باللغات الإنجليزية والعربية والفرنسية. - توسيع أنواع واجهة برمجة التطبيقات (API) لدعم الميزات الجديدة المتعلقة بمعالجة ملفات PDF. --feat: Initialize frontend with React, Vite, and Tailwind CSS - Set up main entry point for React application. - Create About, Home, NotFound, Privacy, and Terms pages with SEO support. - Implement API service for file uploads and task management. - Add global styles using Tailwind CSS. - Create utility functions for SEO and text processing. - Configure Vite for development and production builds. - Set up Nginx configuration for serving frontend and backend. - Add scripts for cleanup of expired files and sitemap generation. - Implement deployment script for production environment.
89 lines
3.0 KiB
Python
89 lines
3.0 KiB
Python
"""Celery tasks for QR code generation."""
|
|
import os
|
|
import logging
|
|
|
|
from flask import current_app
|
|
|
|
from app.extensions import celery
|
|
from app.services.qrcode_service import generate_qr_code, QRCodeError
|
|
from app.services.storage_service import storage
|
|
from app.services.task_tracking_service import finalize_task_tracking
|
|
from app.utils.sanitizer import cleanup_task_files
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
def _cleanup(task_id: str):
|
|
cleanup_task_files(task_id, keep_outputs=not storage.use_s3)
|
|
|
|
|
|
@celery.task(bind=True, name="app.tasks.qrcode_tasks.generate_qr_task")
|
|
def generate_qr_task(
|
|
self,
|
|
task_id: str,
|
|
data: str,
|
|
size: int = 300,
|
|
output_format: str = "png",
|
|
user_id: int | None = None,
|
|
usage_source: str = "web",
|
|
api_key_id: int | None = None,
|
|
):
|
|
"""Generate a QR code image."""
|
|
output_dir = os.path.join(current_app.config["OUTPUT_FOLDER"], task_id)
|
|
os.makedirs(output_dir, exist_ok=True)
|
|
output_path = os.path.join(output_dir, f"{task_id}.{output_format}")
|
|
|
|
try:
|
|
self.update_state(state="PROCESSING", meta={"step": "Generating QR code..."})
|
|
|
|
stats = generate_qr_code(data, output_path, size, output_format)
|
|
|
|
self.update_state(state="PROCESSING", meta={"step": "Uploading result..."})
|
|
s3_key = storage.upload_file(output_path, task_id, folder="outputs")
|
|
|
|
download_name = f"qrcode.{output_format}"
|
|
download_url = storage.generate_presigned_url(s3_key, original_filename=download_name)
|
|
|
|
result = {
|
|
"status": "completed",
|
|
"download_url": download_url,
|
|
"filename": download_name,
|
|
"output_size": stats["output_size"],
|
|
"width": stats["width"],
|
|
"height": stats["height"],
|
|
}
|
|
|
|
logger.info(f"Task {task_id}: QR code generated")
|
|
finalize_task_tracking(
|
|
user_id=user_id, tool="qr-code",
|
|
original_filename="qrcode", result=result,
|
|
usage_source=usage_source, api_key_id=api_key_id,
|
|
celery_task_id=self.request.id,
|
|
)
|
|
_cleanup(task_id)
|
|
return result
|
|
|
|
except QRCodeError as e:
|
|
logger.error(f"Task {task_id}: {e}")
|
|
result = {"status": "failed", "error": str(e)}
|
|
finalize_task_tracking(
|
|
user_id=user_id, tool="qr-code",
|
|
original_filename="qrcode", result=result,
|
|
usage_source=usage_source, api_key_id=api_key_id,
|
|
celery_task_id=self.request.id,
|
|
)
|
|
_cleanup(task_id)
|
|
return result
|
|
|
|
except Exception as e:
|
|
logger.error(f"Task {task_id}: Unexpected error — {e}")
|
|
result = {"status": "failed", "error": "An unexpected error occurred."}
|
|
finalize_task_tracking(
|
|
user_id=user_id, tool="qr-code",
|
|
original_filename="qrcode", result=result,
|
|
usage_source=usage_source, api_key_id=api_key_id,
|
|
celery_task_id=self.request.id,
|
|
)
|
|
_cleanup(task_id)
|
|
return result
|