feat: 插件删除功能

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

@@ -43,6 +43,21 @@ class PluginsRouterGroup(group.RouterGroup):
             return self.success(data={
                 'task_id': wrapper.id
             })
+        
+        @self.route('/<author>/<plugin_name>', methods=['DELETE'])
+        async def _(author: str, plugin_name: str) -> str:
+            ctx = taskmgr.TaskContext.new()
+            wrapper = self.ap.task_mgr.create_user_task(
+                self.ap.plugin_mgr.uninstall_plugin(plugin_name, task_context=ctx),
+                kind="plugin-operation",
+                name=f'plugin-remove-{plugin_name}',
+                label=f'删除插件 {plugin_name}',
+                context=ctx
+            )
+
+            return self.success(data={
+                'task_id': wrapper.id
+            })
 
         @self.route('/reorder', methods=['PUT'])
         async def _() -> str:

pkg/plugin/installer.py

@@ -31,6 +31,7 @@ class PluginInstaller(metaclass=abc.ABCMeta):
     async def uninstall_plugin(
         self,
         plugin_name: str,
+        task_context: taskmgr.TaskContext = taskmgr.TaskContext.placeholder(),
     ):
         """卸载插件
         """

pkg/plugin/installers/github.py

@@ -119,6 +119,7 @@ class GitHubRepoInstaller(installer.PluginInstaller):
     async def uninstall_plugin(
         self,
         plugin_name: str,
+        task_context: taskmgr.TaskContext = taskmgr.TaskContext.placeholder(),
     ):
         """卸载插件
         """
@@ -127,7 +128,9 @@ class GitHubRepoInstaller(installer.PluginInstaller):
         if plugin_container is None:
             raise errors.PluginInstallerError('插件不存在或未成功加载')
         else:
-            shutil.rmtree(plugin_container.pkg_path)
+            task_context.trace("删除插件目录...", "uninstall-plugin")
+            await aioshutil.rmtree(plugin_container.pkg_path)
+            task_context.trace("完成, 重新加载以生效.", "uninstall-plugin")
 
     async def update_plugin(
         self,

pkg/plugin/manager.py

@@ -83,10 +83,11 @@ class PluginManager:
     async def uninstall_plugin(
         self,
         plugin_name: str,
+        task_context: taskmgr.TaskContext = taskmgr.TaskContext.placeholder(),
     ):
         """卸载插件
         """
-        await self.installer.uninstall_plugin(plugin_name)
+        await self.installer.uninstall_plugin(plugin_name, task_context)
 
         plugin_container = self.get_plugin_by_name(plugin_name)