device token

api/services/synthea_integration.py

@@ -19,14 +19,39 @@ class SyntheaIntegrationService:
     """
     
     def __init__(self):
-        self.base_dir = Path(__file__).resolve().parent.parent.parent
-        self.synthea_dir = self.base_dir / "synthea"
-        self.output_dir = self.base_dir / "output" / "fhir"
+        # Use temp directory for containerized environments
+        import tempfile
+        import os
+        
+        # Try to use /tmp first (common in containers)
+        if os.access('/tmp', os.W_OK):
+            base_temp_dir = Path('/tmp')
+        else:
+            # Fallback to system temp directory
+            base_temp_dir = Path(tempfile.gettempdir())
+        
+        self.synthea_dir = base_temp_dir / "cps_synthea"
+        self.output_dir = base_temp_dir / "cps_fhir_output"
         self.synthea_jar_path = self.synthea_dir / "synthea-with-dependencies.jar"
         
-        # Ensure directories exist
-        self.synthea_dir.mkdir(exist_ok=True)
-        self.output_dir.mkdir(parents=True, exist_ok=True)
+        # Ensure directories exist with proper error handling
+        try:
+            self.synthea_dir.mkdir(exist_ok=True)
+            self.output_dir.mkdir(parents=True, exist_ok=True)
+            logger.info(f"✅ Using directories: synthea={self.synthea_dir}, output={self.output_dir}")
+        except PermissionError as e:
+            logger.error(f"❌ Permission denied creating directories: {e}")
+            # Fallback to current working directory
+            self.synthea_dir = Path.cwd() / "synthea_temp"
+            self.output_dir = Path.cwd() / "fhir_output_temp"
+            self.synthea_jar_path = self.synthea_dir / "synthea-with-dependencies.jar"
+            try:
+                self.synthea_dir.mkdir(exist_ok=True)
+                self.output_dir.mkdir(parents=True, exist_ok=True)
+                logger.info(f"✅ Using fallback directories: synthea={self.synthea_dir}, output={self.output_dir}")
+            except Exception as fallback_error:
+                logger.error(f"❌ Failed to create fallback directories: {fallback_error}")
+                raise
         
         # Synthea configuration
         self.default_config = {
@@ -386,6 +411,15 @@ class SyntheaIntegrationService:
         try:
             logger.info(f"🎯 Starting Synthea generation for {population} patients")
             
+            # Check if directories are accessible
+            try:
+                if not os.access(self.synthea_dir, os.W_OK) or not os.access(self.output_dir, os.W_OK):
+                    logger.warning("⚠️ Directories not accessible, falling back to mock data")
+                    return await self._generate_mock_patients(population, age_min, age_max, gender, location)
+            except Exception as dir_error:
+                logger.warning(f"⚠️ Directory access check failed: {dir_error}, falling back to mock data")
+                return await self._generate_mock_patients(population, age_min, age_max, gender, location)
+            
             # Try to use real Synthea first
             try:
                 # Download Synthea if needed
@@ -530,9 +564,21 @@ class SyntheaIntegrationService:
                 "practitioner_files": 0,
                 "total_size_mb": 0,
                 "synthea_available": False,
-                "java_available": False
+                "java_available": False,
+                "directories_accessible": False
             }
             
+            # Check if directories are accessible
+            try:
+                stats["directories_accessible"] = (
+                    self.synthea_dir.exists() and 
+                    self.output_dir.exists() and
+                    os.access(self.synthea_dir, os.W_OK) and
+                    os.access(self.output_dir, os.W_OK)
+                )
+            except Exception:
+                stats["directories_accessible"] = False
+            
             # Check if Java is available
             try:
                 java_check = await asyncio.create_subprocess_exec(
@@ -548,20 +594,34 @@ class SyntheaIntegrationService:
             # Check if Synthea JAR exists
             stats["synthea_available"] = self.synthea_jar_path.exists()
             
-            if self.output_dir.exists():
-                for file_path in self.output_dir.glob("*.json"):
-                    stats["total_files"] += 1
-                    stats["total_size_mb"] += file_path.stat().st_size / (1024 * 1024)
-                    
-                    if "hospitalInformation" in file_path.name:
-                        stats["hospital_files"] += 1
-                    elif "practitionerInformation" in file_path.name:
-                        stats["practitioner_files"] += 1
-                    else:
-                        stats["patient_files"] += 1
+            # Only try to count files if output directory exists and is accessible
+            if stats["directories_accessible"] and self.output_dir.exists():
+                try:
+                    for file_path in self.output_dir.glob("*.json"):
+                        stats["total_files"] += 1
+                        stats["total_size_mb"] += file_path.stat().st_size / (1024 * 1024)
+                        
+                        if "hospitalInformation" in file_path.name:
+                            stats["hospital_files"] += 1
+                        elif "practitionerInformation" in file_path.name:
+                            stats["practitioner_files"] += 1
+                        else:
+                            stats["patient_files"] += 1
+                except Exception as file_error:
+                    logger.warning(f"⚠️ Error accessing output directory files: {file_error}")
             
             return stats
             
         except Exception as e:
             logger.error(f"❌ Error getting Synthea statistics: {str(e)}")
-            return {"error": str(e)}
+            return {
+                "error": str(e),
+                "total_files": 0,
+                "patient_files": 0,
+                "hospital_files": 0,
+                "practitioner_files": 0,
+                "total_size_mb": 0,
+                "synthea_available": False,
+                "java_available": False,
+                "directories_accessible": False
+            }