feat: setting plugin config

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

@@ -17,17 +17,6 @@ class PluginsRouterGroup(group.RouterGroup):
 
             return self.success(data={'plugins': plugins})
 
-        @self.route(
-            '/<author>/<plugin_name>/toggle',
-            methods=['PUT'],
-            auth_type=group.AuthType.USER_TOKEN,
-        )
-        async def _(author: str, plugin_name: str) -> str:
-            data = await quart.request.json
-            target_enabled = data.get('target_enabled')
-            await self.ap.plugin_mgr.update_plugin_switch(plugin_name, target_enabled)
-            return self.success()
-
         @self.route(
             '/<author>/<plugin_name>/upgrade',
             methods=['POST'],
@@ -76,21 +65,16 @@ class PluginsRouterGroup(group.RouterGroup):
             plugin = await self.ap.plugin_connector.get_plugin_info(author, plugin_name)
             if plugin is None:
                 return self.http_status(404, -1, 'plugin not found')
+
             if quart.request.method == 'GET':
                 return self.success(data={'config': plugin['plugin_config']})
             elif quart.request.method == 'PUT':
                 data = await quart.request.json
 
-                await self.ap.plugin_mgr.set_plugin_config(plugin, data)
+                await self.ap.plugin_connector.set_plugin_config(author, plugin_name, data)
 
                 return self.success(data={})
 
-        @self.route('/reorder', methods=['PUT'], auth_type=group.AuthType.USER_TOKEN)
-        async def _() -> str:
-            data = await quart.request.json
-            await self.ap.plugin_mgr.reorder_plugins(data.get('plugins'))
-            return self.success()
-
         @self.route('/install/github', methods=['POST'], auth_type=group.AuthType.USER_TOKEN)
         async def _() -> str:
             data = await quart.request.json

pkg/plugin/connector.py

@@ -150,6 +150,9 @@ class PluginRuntimeConnector:
     async def get_plugin_info(self, author: str, plugin_name: str) -> dict[str, Any]:
         return await self.handler.get_plugin_info(author, plugin_name)
 
+    async def set_plugin_config(self, plugin_author: str, plugin_name: str, config: dict[str, Any]) -> dict[str, Any]:
+        return await self.handler.set_plugin_config(plugin_author, plugin_name, config)
+
     async def emit_event(
         self,
         event: events.BaseEventModel,

pkg/plugin/handler.py

@@ -486,6 +486,29 @@ class RuntimeConnectionHandler(handler.Handler):
         )
         return result['plugin']
 
+    async def set_plugin_config(self, plugin_author: str, plugin_name: str, config: dict[str, Any]) -> dict[str, Any]:
+        """Set plugin config"""
+        # update plugin setting
+        await self.ap.persistence_mgr.execute_async(
+            sqlalchemy.update(persistence_plugin.PluginSetting)
+            .where(persistence_plugin.PluginSetting.plugin_author == plugin_author)
+            .where(persistence_plugin.PluginSetting.plugin_name == plugin_name)
+            .values(config=config)
+        )
+
+        # restart plugin
+        gen = self.call_action_generator(
+            LangBotToRuntimeAction.RESTART_PLUGIN,
+            {
+                'plugin_author': plugin_author,
+                'plugin_name': plugin_name,
+            },
+        )
+        async for ret in gen:
+            pass
+
+        return {}
+
     async def emit_event(
         self,
         event_context: dict[str, Any],