Factor out thumbnail()

synapse/rest/media/v1/base_resource.py

@@ -225,41 +225,44 @@ def _get_thumbnail_requirements(self, media_type):
         else:
             return ()
 
-    @defer.inlineCallbacks
-    def _generate_local_exact_thumbnail(self, media_id, t_width, t_height,
-                                        t_method, t_type):
-        input_path = self.filepaths.local_media_filepath(media_id)
+    def _generate_thumbnail(self, input_path, t_path, t_width, t_height,
+                            t_method, t_type):
+        thumbnailer = Thumbnailer(input_path)
+        m_width = thumbnailer.width
+        m_height = thumbnailer.height
 
-        def thumbnail():
-            thumbnailer = Thumbnailer(input_path)
-            m_width = thumbnailer.width
-            m_height = thumbnailer.height
+        if m_width * m_height >= self.max_image_pixels:
+            logger.info(
+                "Image too large to thumbnail %r x %r > %r",
+                m_width, m_height, self.max_image_pixels
+            )
+            return
 
-            if m_width * m_height >= self.max_image_pixels:
-                logger.info(
-                    "Image too large to thumbnail %r x %r > %r",
-                    m_width, m_height, self.max_image_pixels
-                )
-                return
+        if t_method == "crop":
+            t_len = thumbnailer.crop(t_path, t_width, t_height, t_type)
+        elif t_method == "scale":
+            t_len = thumbnailer.scale(t_path, t_width, t_height, t_type)
+        else:
+            t_len = None
 
-            t_path = self.filepaths.local_media_thumbnail(
-                media_id, t_width, t_height, t_type, t_method
-            )
-            self._makedirs(t_path)
+        return t_len
 
-            if t_method == "crop":
-                t_len = thumbnailer.crop(t_path, t_width, t_height, t_type)
-            elif t_method == "scale":
-                t_len = thumbnailer.scale(t_path, t_width, t_height, t_type)
-            else:
-                t_len = None
+    @defer.inlineCallbacks
+    def _generate_local_exact_thumbnail(self, media_id, t_width, t_height,
+                                        t_method, t_type):
+        input_path = self.filepaths.local_media_filepath(media_id)
 
-            return t_len, t_path
+        t_path = self.filepaths.local_media_thumbnail(
+            media_id, t_width, t_height, t_type, t_method
+        )
+        self._makedirs(t_path)
 
-        res = yield threads.deferToThread(thumbnail)
+        t_len = yield threads.deferToThread(
+            self._generate_thumbnail,
+            input_path, t_path, t_width, t_height, t_method, t_type
+        )
 
-        if res:
-            t_len, t_path = res
+        if t_len:
             yield self.store.store_local_thumbnail(
                 media_id, t_width, t_height, t_type, t_method, t_len
             )
@@ -271,36 +274,17 @@ def _generate_remote_exact_thumbnail(self, server_name, file_id, media_id,
                                          t_width, t_height, t_method, t_type):
         input_path = self.filepaths.remote_media_filepath(server_name, file_id)
 
-        def thumbnail():
-            thumbnailer = Thumbnailer(input_path)
-            m_width = thumbnailer.width
-            m_height = thumbnailer.height
-
-            if m_width * m_height >= self.max_image_pixels:
-                logger.info(
-                    "Image too large to thumbnail %r x %r > %r",
-                    m_width, m_height, self.max_image_pixels
-                )
-                return
-
-            t_path = self.filepaths.remote_media_thumbnail(
-                server_name, file_id, t_width, t_height, t_type, t_method
-            )
-            self._makedirs(t_path)
-
-            if t_method == "crop":
-                t_len = thumbnailer.crop(t_path, t_width, t_height, t_type)
-            elif t_method == "scale":
-                t_len = thumbnailer.scale(t_path, t_width, t_height, t_type)
-            else:
-                t_len = None
-
-            return t_path, t_len
+        t_path = self.filepaths.remote_media_thumbnail(
+            server_name, file_id, t_width, t_height, t_type, t_method
+        )
+        self._makedirs(t_path)
 
-        res = yield threads.deferToThread(thumbnail)
+        t_len = yield threads.deferToThread(
+            self._generate_thumbnail,
+            input_path, t_path, t_width, t_height, t_method, t_type
+        )
 
-        if res:
-            t_path, t_len = res
+        if t_len:
             yield self.store.store_remote_media_thumbnail(
                 server_name, media_id, file_id,
                 t_width, t_height, t_type, t_method, t_len