fixup! media/create: add /create endpoint

Signed-off-by: Sumner Evans <[email protected]>

synapse/media/media_repository.py

@@ -84,6 +84,7 @@ def __init__(self, hs: "HomeServer"):
         self.max_upload_size = hs.config.media.max_upload_size
         self.max_image_pixels = hs.config.media.max_image_pixels
         self.unused_expiration_time = hs.config.media.unused_expiration_time
+        self.max_pending_media_uploads = hs.config.media.max_pending_media_uploads
 
         Thumbnailer.set_limits(self.max_image_pixels)
 
@@ -211,14 +212,11 @@ async def create_media_id(self, auth_user: UserID) -> Tuple[str, int]:
         return f"mxc://{self.server_name}/{media_id}", now + self.unused_expiration_time
 
     @trace
-    async def reached_pending_media_limit(
-        self, auth_user: UserID, limit: int
-    ) -> Tuple[bool, int]:
+    async def reached_pending_media_limit(self, auth_user: UserID) -> Tuple[bool, int]:
         """Check if the user is over the limit for pending media uploads.
 
         Args:
             auth_user: The user_id of the uploader
-            limit: The maximum number of pending media uploads a user is allowed to have
 
         Returns:
             A tuple with a boolean and an integer indicating whether the user has too
@@ -228,7 +226,7 @@ async def reached_pending_media_limit(
         pending, first_expiration_ts = await self.store.count_pending_media(
             user_id=auth_user
         )
-        return pending >= limit, first_expiration_ts
+        return pending >= self.max_pending_media_uploads, first_expiration_ts
 
     @trace
     async def verify_can_upload(self, media_id: str, auth_user: UserID) -> None:

synapse/rest/media/create_resource.py

@@ -59,9 +59,7 @@ async def _async_render_POST(self, request: SynapseRequest) -> None:
         (
             reached_pending_limit,
             first_expiration_ts,
-        ) = await self.media_repo.reached_pending_media_limit(
-            requester.user, self.max_pending_media_uploads
-        )
+        ) = await self.media_repo.reached_pending_media_limit(requester.user)
         if reached_pending_limit:
             raise LimitExceededError(
                 limiter_name="max_pending_media_uploads",