53 lines
1.7 KiB
Python
53 lines
1.7 KiB
Python
#!/usr/bin/env python3
|
|
"""
|
|
Subprocess wrapper for FastDL operations to avoid asyncio event loop conflicts.
|
|
This runs FastDL operations in a completely isolated subprocess.
|
|
|
|
Supports both single content_type (backward compatible) and multi content_types mode.
|
|
"""
|
|
|
|
import sys
|
|
import json
|
|
from pathlib import Path
|
|
|
|
# Add parent directory to path
|
|
sys.path.insert(0, str(Path(__file__).parent.parent))
|
|
|
|
from wrappers.base_subprocess_wrapper import create_download_wrapper, create_download_wrapper_multi
|
|
|
|
|
|
def create_fastdl_downloader(config, unified_db):
|
|
"""Factory function to create a FastDL downloader instance."""
|
|
from modules.fastdl_module import FastDLDownloader
|
|
|
|
# When defer_database is set (paid content mode), skip FastDL's own dedup
|
|
# checks — the caller handles dedup via its own known_ids filtering.
|
|
use_db = not config.get('defer_database', False)
|
|
|
|
return FastDLDownloader(
|
|
headless=config.get('headless', True),
|
|
show_progress=True,
|
|
use_database=use_db,
|
|
log_callback=None, # Module uses universal logger, no callback needed
|
|
unified_db=unified_db,
|
|
high_res=config.get('high_res', False)
|
|
)
|
|
|
|
|
|
# Create download functions using the factories
|
|
run_fastdl_download = create_download_wrapper("FastDL", "fastdl", create_fastdl_downloader)
|
|
run_fastdl_download_multi = create_download_wrapper_multi("FastDL", "fastdl", create_fastdl_downloader)
|
|
|
|
|
|
if __name__ == '__main__':
|
|
config_json = sys.stdin.read()
|
|
config = json.loads(config_json)
|
|
|
|
if 'content_types' in config:
|
|
result = run_fastdl_download_multi(config)
|
|
else:
|
|
result = run_fastdl_download(config)
|
|
|
|
print(json.dumps(result))
|
|
sys.exit(0 if result.get('status') == 'success' else 1)
|