feat: 插件安装支持

pkg/api/http/controller/groups/plugins.py

@@ -49,3 +49,21 @@ class PluginsRouterGroup(group.RouterGroup):
             data = await quart.request.json
             await self.ap.plugin_mgr.reorder_plugins(data.get('plugins'))
             return self.success()
+        
+        @self.route('/install/github', methods=['POST'])
+        async def _() -> str:
+            data = await quart.request.json
+            
+            ctx = taskmgr.TaskContext.new()
+            short_source_str = data['source'][-8:]
+            wrapper = self.ap.task_mgr.create_user_task(
+                self.ap.plugin_mgr.install_plugin(data['source'], task_context=ctx),
+                kind="plugin-operation",
+                name=f'plugin-install-github',
+                label=f'安装插件 ...{short_source_str}',
+                context=ctx
+            )
+
+            return self.success(data={
+                'task_id': wrapper.id
+            })

pkg/plugin/installer.py

@@ -21,6 +21,7 @@ class PluginInstaller(metaclass=abc.ABCMeta):
     async def install_plugin(
         self,
         plugin_source: str,
+        task_context: taskmgr.TaskContext = taskmgr.TaskContext.placeholder(),
     ):
         """安装插件
         """

pkg/plugin/manager.py

@@ -65,10 +65,11 @@ class PluginManager:
     async def install_plugin(
         self,
         plugin_source: str,
+        task_context: taskmgr.TaskContext = taskmgr.TaskContext.placeholder(),
     ):
         """安装插件
         """
-        await self.installer.install_plugin(plugin_source)
+        await self.installer.install_plugin(plugin_source, task_context)
 
         await self.ap.ctr_mgr.plugin.post_install_record(
             {