fixed magzines, articles routing issue

debug_collections.py

@@ -0,0 +1,39 @@
+import asyncio
+import warnings
+# Filter warnings
+warnings.filterwarnings('ignore')
+
+from app.services.appwrite_db import get_appwrite_db
+from app.config import settings
+from appwrite.query import Query
+
+async def check_counts():
+    db = get_appwrite_db()
+    if not db.initialized:
+        print("DB not initialized")
+        return
+
+    print("\n" + "="*50)
+    print("DEBUG: MAGAZINE COLLECTION COUNTS")
+    print("="*50)
+
+    try:
+        main_mag = await db.tablesDB.list_rows(
+            database_id=settings.APPWRITE_DATABASE_ID,
+            collection_id=settings.APPWRITE_COLLECTION_ID,
+            queries=[Query.equal('category', 'magazines'), Query.limit(1)]
+        )
+        ded_mag = await db.tablesDB.list_rows(
+            database_id=settings.APPWRITE_DATABASE_ID,
+            collection_id=settings.APPWRITE_MAGAZINE_COLLECTION_ID,
+            queries=[Query.limit(1)]
+        )
+        print(f"Magazines (Main Collection):      {main_mag['total']}")
+        print(f"Magazines (Dedicated Collection): {ded_mag['total']}")
+    except Exception as e:
+        print(f"Error checking magazines: {e}")
+
+    print("="*50 + "\n")
+
+if __name__ == "__main__":
+    asyncio.run(check_counts())

inspect_magazine.py

@@ -0,0 +1,32 @@
+import asyncio
+import warnings
+warnings.filterwarnings('ignore')
+
+from app.services.appwrite_db import get_appwrite_db
+from app.config import settings
+from appwrite.query import Query
+
+async def inspect():
+    db = get_appwrite_db()
+    if not db.initialized:
+        print("DB not initialized")
+        return
+
+    print("Fetching one document from Dedicated Magazine Collection...")
+    try:
+        res = await db.tablesDB.list_rows(
+            database_id=settings.APPWRITE_DATABASE_ID,
+            collection_id=settings.APPWRITE_MAGAZINE_COLLECTION_ID,
+            queries=[Query.limit(1)]
+        )
+        if res['documents']:
+            doc = res['documents'][0]
+            print(f"CATEGORY_VALUE: '{doc.get('category')}'")
+            print(f"PUBLISHED_AT: '{doc.get('published_at')}'")
+        else:
+            print("No documents found.")
+    except Exception as e:
+        print(f"Error: {e}")
+
+if __name__ == "__main__":
+    asyncio.run(inspect())

simulate_backend_request.py

@@ -0,0 +1,46 @@
+import asyncio
+import warnings
+warnings.filterwarnings('ignore')
+
+from app.services.appwrite_db import get_appwrite_db
+from app.config import settings
+from appwrite.query import Query
+
+async def simulate():
+    db = get_appwrite_db()
+    
+    category = 'magazines'
+    queries = [
+        Query.equal('category', category),
+        Query.order_desc('published_at'),
+        Query.limit(21)
+    ]
+    
+    # Needs to match what news.py receives/sends
+    
+    print(f"Simulating request for category: {category}")
+    
+    # 1. Check strict routing
+    target_id = db.get_collection_id(category)
+    print(f"Target Collection ID: {target_id} (Expected for strict: {settings.APPWRITE_MAGAZINE_COLLECTION_ID})")
+    
+    if target_id == settings.APPWRITE_MAGAZINE_COLLECTION_ID:
+        print("Strict routing IS active (if you reverted it in code)")
+    else:
+        print("Strict routing IS NOT active (using main)")
+
+    # 2. Execute Query
+    try:
+        articles = await db.get_articles_with_queries(queries, category=category)
+        print(f"COUNT_ARTICLES: {len(articles)}")
+    except Exception as e:
+        print(f"ERROR: {e}")
+
+'''
+NOTE: You need to revert `appwrite_db.py` change 
+BEFORE running this to test strict routing!
+Currently it should use MAIN collection and likely return 0.
+'''
+
+if __name__ == "__main__":
+    asyncio.run(simulate())

verify_fix.py

@@ -0,0 +1,34 @@
+from app.services.appwrite_db import AppwriteDatabase
+from app.config import settings
+
+def verify_routing():
+    db = AppwriteDatabase()
+    
+    # 1. Verify Magazines Routing
+    mag_id = db.get_collection_id('magazines')
+    expected_mag_id = settings.APPWRITE_COLLECTION_ID
+    
+    print(f"Magazines Collection ID: {mag_id}")
+    print(f"Expected (Main):         {expected_mag_id}")
+    
+    if mag_id == expected_mag_id:
+        print("✅ Magazines routing CORRECT (Using Main DB)")
+    else:
+        print("❌ Magazines routing INCORRECT (Still using dedicated DB)")
+        
+    print("-" * 30)
+
+    # 2. Verify Medium Routing
+    med_id = db.get_collection_id('medium-article')
+    expected_med_id = settings.APPWRITE_MEDIUM_COLLECTION_ID
+    
+    print(f"Medium Collection ID:    {med_id}")
+    print(f"Expected (Dedicated):    {expected_med_id}")
+    
+    if med_id == expected_med_id:
+        print("✅ Medium routing CORRECT (Using Dedicated DB)")
+    else:
+        print("❌ Medium routing INCORRECT")
+
+if __name__ == "__main__":
+    verify_routing()