sui

backend/app.py

@@ -93,11 +93,11 @@ def create_app():
     app.executor = ThreadPoolExecutor(max_workers=4)
     
     # Register blueprints
-    from api.auth import auth_bp
-    from api.sources import sources_bp
-    from api.accounts import accounts_bp
-    from api.posts import posts_bp
-    from api.schedules import schedules_bp
+    from backend.api.auth import auth_bp
+    from backend.api.sources import sources_bp
+    from backend.api.accounts import accounts_bp
+    from backend.api.posts import posts_bp
+    from backend.api.schedules import schedules_bp
     
     app.register_blueprint(auth_bp, url_prefix='/api/auth')
     app.register_blueprint(sources_bp, url_prefix='/api/sources')
@@ -115,7 +115,7 @@ def create_app():
     def api_health_check():
         """Enhanced health check that includes database connection."""
         try:
-            from utils.database import check_database_connection
+            from backend.utils.database import check_database_connection
             db_connected = check_database_connection(app.supabase)
             return {
                 'status': 'healthy' if db_connected else 'degraded',

backend/celery_tasks/content_tasks.py

@@ -32,7 +32,7 @@ def generate_content_task(self, user_id: str, schedule_id: str, supabase_client_
         generated_content = content_service.generate_post_content(user_id)
         
         # Initialize Supabase client from config
-        from utils.database import init_supabase
+        from backend.utils.database import init_supabase
         supabase_client = init_supabase(
             supabase_client_config['SUPABASE_URL'], 
             supabase_client_config['SUPABASE_KEY']
@@ -106,7 +106,7 @@ def publish_post_task(self, schedule_id: str, supabase_client_config: dict):
         self.update_state(state='PROGRESS', meta={'status': 'Publishing post...'})
         
         # Initialize Supabase client from config
-        from utils.database import init_supabase
+        from backend.utils.database import init_supabase
         supabase_client = init_supabase(
             supabase_client_config['SUPABASE_URL'], 
             supabase_client_config['SUPABASE_KEY']
@@ -186,4 +186,4 @@ def publish_post_task(self, schedule_id: str, supabase_client_config: dict):
         return {
             'status': 'failure',
             'message': f'Error in publishing post: {str(e)}'
-        }
+        }