diff --git a/blueprints/api.py b/blueprints/api.py index c8bd3db..45cc598 100644 --- a/blueprints/api.py +++ b/blueprints/api.py @@ -32,7 +32,7 @@ from config import ID from config import JWT from config import MEDIA_CACHE from config import _drop_db -from core import activitypub +from core import feed from core.activitypub import activity_url from core.activitypub import post_to_outbox from core.meta import Box @@ -587,7 +587,7 @@ def api_debug() -> _Response: def api_stream() -> _Response: return Response( response=json.dumps( - activitypub.build_inbox_json_feed("/api/stream", request.args.get("cursor")) + feed.build_inbox_json_feed("/api/stream", request.args.get("cursor")) ), headers={"Content-Type": "application/json"}, ) diff --git a/core/indexes.py b/core/indexes.py index 00c91fd..9f5a7db 100644 --- a/core/indexes.py +++ b/core/indexes.py @@ -9,7 +9,9 @@ def create_indexes(): if "trash" not in DB.collection_names(): DB.create_collection("trash", capped=True, size=50 << 20) # 50 MB - DB.command("compact", "activities") + if "activities" in DB.collection_names(): + DB.command("compact", "activities") + DB.activities.create_index([(_meta(MetaKey.NOTIFICATION), pymongo.ASCENDING)]) DB.activities.create_index( [(_meta(MetaKey.NOTIFICATION_UNREAD), pymongo.ASCENDING)]