From 13be8d75de818fa49033a9c031d278b384ff832b Mon Sep 17 00:00:00 2001
From: pacnpal <183241239+pacnpal@users.noreply.github.com>
Date: Fri, 15 Nov 2024 00:56:56 +0000
Subject: [PATCH] fix: Ensure data directory exists for queue persistence

---
 videoarchiver/processor.py | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/videoarchiver/processor.py b/videoarchiver/processor.py
index 491fa3c..07a0651 100644
--- a/videoarchiver/processor.py
+++ b/videoarchiver/processor.py
@@ -8,6 +8,7 @@ from typing import List, Optional, Tuple, Callable, Any
 import asyncio
 import traceback
 from datetime import datetime
+from pathlib import Path
 
 from videoarchiver.utils.video_downloader import VideoDownloader
 from videoarchiver.utils.file_ops import secure_delete_file, cleanup_downloads
@@ -25,14 +26,16 @@ class VideoProcessor:
         self.components = components
         
         # Initialize enhanced queue manager with persistence and error recovery
-        queue_path = os.path.join(os.path.dirname(__file__), "data", "queue_state.json")
+        data_dir = Path(os.path.dirname(__file__)) / "data"
+        data_dir.mkdir(parents=True, exist_ok=True)
+        queue_path = data_dir / "queue_state.json"
         self.queue_manager = EnhancedVideoQueueManager(
             max_retries=3,
             retry_delay=5,
             max_queue_size=1000,
             cleanup_interval=1800,  # 30 minutes (reduced from 1 hour for more frequent cleanup)
             max_history_age=86400,  # 24 hours
-            persistence_path=queue_path
+            persistence_path=str(queue_path)
         )
 
         # Track failed downloads for cleanup