Remove uploads gRPC & fix some bugs

.env.example

@@ -14,11 +14,5 @@ INTERNAL_API_TOKEN=""  # used for authenticating internal API requests (gives ac
 CAPTCHA_SITEKEY=
 CAPTCHA_SECRET=
 
-GRPC_AUTH_ADDRESS="0.0.0.0:5000"
-GRPC_AUTH_TOKEN=
-
-GRPC_UPLOADS_ADDRESS=
-GRPC_UPLOADS_TOKEN=
-
 CHAT_EMOJIS_LIMIT=250
 CHAT_STICKERS_LIMIT=50

database.py

@@ -6,7 +6,7 @@
 
 from utils import log
 
-CURRENT_DB_VERSION = 9
+CURRENT_DB_VERSION = 10
 
 # Create Redis connection
 log("Connecting to Redis...")
@@ -174,7 +174,21 @@
 
 # Create post reactions index
 try:
-    db.post_reactions.create_index([("_id.post_id", 1), ("_id.emoji", 1)])
+    db.post_reactions.create_index([("_id.post_id", pymongo.ASCENDING), ("_id.emoji", pymongo.ASCENDING)])
+except: pass
+
+# Create files indexes
+try:
+    db.files.create_index([("hash", pymongo.ASCENDING)], name="hash")
+except: pass
+try:
+    db.files.create_index([("uploaded_by", pymongo.ASCENDING)], name="uploaded_by")
+except: pass
+try:
+    db.files.create_index([
+        ("claimed", pymongo.ASCENDING),
+        ("uploaded_by", pymongo.ASCENDING)
+    ], name="unclaimed", partialFilterExpression={"claimed": False})
 except: pass
 
 
@@ -306,6 +320,16 @@ def get_total_pages(collection: str, query: dict, page_size: int = 25) -> int:
             "mfa_recovery_code": user["mfa_recovery_code"][:10]
         }})
 
+    # Post attachments
+    log("[Migrator] Converting post attachments")
+    updates = []
+    for post in db.posts.find({"attachments.id": {"$exists": True}}):
+        updates.append(pymongo.UpdateOne(
+            {"_id": post["_id"]},
+            {"$set": {"attachments": [attachment["id"] for attachment in post["attachments"]]}}
+        ))
+    db.posts.bulk_write(updates)
+
     db.config.update_one({"_id": "migration"}, {"$set": {"database": CURRENT_DB_VERSION}})
     log(f"[Migrator] Finished Migrating DB to version {CURRENT_DB_VERSION}")