From ddd56f5c4747025c306bcab54692ffaed40e913e Mon Sep 17 00:00:00 2001
From: Kovid Goyal <kovid@kovidgoyal.net>
Date: Mon, 19 Jul 2021 12:00:04 +0530
Subject: [PATCH] Cleanup plugins_mirror.py

---
 setup/plugins_mirror.py | 69 ++++++++++++++++++++---------------------
 1 file changed, 34 insertions(+), 35 deletions(-)

diff --git a/setup/plugins_mirror.py b/setup/plugins_mirror.py
index f8ebee0091..9493f2929f 100644
--- a/setup/plugins_mirror.py
+++ b/setup/plugins_mirror.py
@@ -55,7 +55,6 @@ except Exception:
 USER_AGENT = 'calibre mirror'
 MR_URL = 'https://www.mobileread.com/forums/'
 IS_PRODUCTION = os.path.exists('/srv/plugins')
-WORKDIR = '/srv/plugins' if IS_PRODUCTION else '/t/plugins'
 PLUGINS = 'plugins.json.bz2'
 INDEX = MR_URL + 'showpost.php?p=1362767&postcount=1'
 # INDEX = 'file:///t/raw.html'
@@ -327,32 +326,36 @@ def parse_plugin(raw, names, zf):
     raise ValueError('Failed to find plugin class')
 
 
-def get_plugin_info(raw_zip):
+def get_plugin_init(zf):
     metadata = None
+    names = {x.decode('utf-8') if isinstance(x, bytes) else x : x for x in zf.namelist()}
+    inits = [x for x in names if x.rpartition('/')[-1] == '__init__.py']
+    inits.sort(key=lambda x:x.count('/'))
+    if inits and inits[0] == '__init__.py':
+        metadata = names[inits[0]]
+    else:
+        # Legacy plugin
+        for name, val in names.items():
+            if name.endswith('plugin.py'):
+                metadata = val
+                break
+    if metadata is None:
+        raise ValueError('No __init__.py found in plugin')
+    return zf.open(metadata).read(), names
+
+
+def get_plugin_info(raw_zip):
     with zipfile.ZipFile(io.BytesIO(raw_zip)) as zf:
-        names = {x.decode('utf-8') if isinstance(x, bytes) else x : x for x in zf.namelist()}
-        inits = [x for x in names if x.rpartition('/')[-1] == '__init__.py']
-        inits.sort(key=lambda x:x.count('/'))
-        if inits and inits[0] == '__init__.py':
-            metadata = names[inits[0]]
-        else:
-            # Legacy plugin
-            for name, val in names.items():
-                if name.endswith('plugin.py'):
-                    metadata = val
-                    break
-        if metadata is None:
-            raise ValueError('No __init__.py found in plugin')
-        raw = zf.open(metadata).read()
+        raw, names = get_plugin_init(zf)
         try:
             return parse_plugin(raw, names, zf)
         except (SyntaxError, TabError, IndentationError):
             with tempfile.NamedTemporaryFile(suffix='.zip') as f:
                 f.write(raw_zip)
                 f.flush()
-                p = subprocess.Popen(['python2', __file__, f.name], stdout=subprocess.PIPE, stdin=subprocess.PIPE)
-                stdout = p.communicate(json.dumps((raw, names)).encode('utf-8'))[0]
-                return json.loads(stdout)
+                res = subprocess.run(['python2', __file__, f.name], stdout=subprocess.PIPE)
+                if res.returncode == 0:
+                    return json.loads(res.stdout)
             raise
 
 
@@ -610,11 +613,11 @@ def update_stats():
     return stats
 
 
-def py2_parse(zipfile_path):
-    raw, names = json.loads(sys.stdin.read())
+def parse_single_plugin(zipfile_path):
     with zipfile.ZipFile(zipfile_path) as zf:
+        raw, names = get_plugin_init(zf)
         ans = parse_plugin(raw, names, zf)
-        sys.stdout.write(json.dump(ans, ensure_ascii=True))
+        sys.stdout.write(json.dumps(ans, ensure_ascii=True))
 
 
 def main():
@@ -623,20 +626,14 @@ def main():
         ' if specified on the command line'
     )
     p.add_argument('plugin_path', nargs='?', default='', help='Path to plugin zip file to parse')
+    WORKDIR = '/srv/plugins' if IS_PRODUCTION else '/t/plugins'
+    p.add_argument('-o', '--output-dir', default=WORKDIR, help='Where to place the mirrored plugins. Default is: ' + WORKDIR)
     args = p.parse_args()
     if args.plugin_path:
-        return py2_parse(args.plugin_path)
-    try:
-        os.chdir(WORKDIR)
-    except OSError as err:
-        if err.errno == errno.ENOENT:
-            try:
-                os.makedirs(WORKDIR)
-            except EnvironmentError:
-                pass
-            os.chdir(WORKDIR)
-        else:
-            raise
+        return parse_single_plugin(args.plugin_path)
+
+    os.makedirs(args.output_dir, exist_ok=True)
+    os.chdir(args.output_dir)
     if os.geteuid() == 0 and not singleinstance():
         print('Another instance of plugins-mirror is running', file=sys.stderr)
         raise SystemExit(1)
@@ -646,7 +643,9 @@ def main():
         plugins_index = load_plugins_index()
         plugins_index = fetch_plugins(plugins_index)
         create_index(plugins_index, stats)
-    except:
+    except KeyboardInterrupt:
+        raise SystemExit('Exiting on user interrupt')
+    except Exception:
         import traceback
         log('Failed to run at:', datetime.utcnow().isoformat())
         log(traceback.format_exc())