继续声明管理员的最高权限

cmds.py

@@ -64,9 +64,8 @@ def cmds(app, data):
                             action="store_true")
         parser.add_argument('-g', '--group', help='组名')
         parser.add_argument('-m', '--command', help='命令名')
-        parser.add_argument('-au', '--adduser', help='添加用户到组',
+        parser.add_argument('-au', '--adduser', help='添加用户/群到组',
                             action="store_true")
-        parser.add_argument('-u', '--user', help='用户QQ号')
 
         args = parser.parse_args(sqt.args)
         e: AsyncEnforcer = sqt.app.ctx.e
@@ -80,9 +79,9 @@ def cmds(app, data):
             else:
                 msg = Message(content='缺失参数，请使用-h查看帮助', room_id=sqt.room_id)
         if args.adduser:
-            if args.user and args.group:
+            if args.group:
-                if await e.add_role_for_user(args.user, args.group):
+                if await e.add_role_for_user(str(sqt.room_id), args.group):
-                    msg = Message(content=f'添加成功：g, {args.user}, {args.group}', room_id=sqt.room_id)
+                    msg = Message(content=f'添加成功：g, {sqt.room_id}, {args.group}', room_id=sqt.room_id)
                 else:
                     msg = Message(content='添加失败，用户已在组内或其它错误', room_id=sqt.room_id)
             else:
@@ -94,5 +93,6 @@ def cmds(app, data):
             if msg == '':
                 msg = Message(content='参数错误，请使用-h查看帮助', room_id=sqt.room_id)
             await sqt.app.ctx.sio.emit('sendMessage', msg.to_json())
+        await e.save_policy()
 
     return sio_decorator

sio_model.py

@@ -3,7 +3,7 @@ from dataclasses import dataclass
 from functools import wraps
 from typing import Optional, List, Union, Literal, Dict, Any
 
-from casbin import Enforcer
+from casbin import Enforcer, AsyncEnforcer
 from pydantic import BaseModel, Field, model_validator
 from sanic import Sanic
 from sanic.log import logger
@@ -117,22 +117,25 @@ class SioDecorator:
             room_id = self.data['roomId']
 
             if sender_id != self.app.ctx.sio_config.self_id:
-                parser = ArgumentParser(self._cmd[0])
+                e: AsyncEnforcer = self.app.ctx.e
+                if (e.enforce(str(room_id), self._cmd[0][1:]) or
+                        (await e.has_role_for_user(str(sender_id), 'admin'))):
+                    parser = ArgumentParser(self._cmd[0])
 
-                sqt = SioRequest(app=self.app,
+                    sqt = SioRequest(app=self.app,
-                                 parser=parser,
+                                     parser=parser,
-                                 args=self._cmd[1:],
+                                     args=self._cmd[1:],
-                                 key=self._cmd[0],
+                                     key=self._cmd[0],
-                                 sender_id=sender_id,
+                                     sender_id=sender_id,
-                                 sender_name=sender_name,
+                                     sender_name=sender_name,
-                                 content=self._content,
+                                     content=self._content,
-                                 room_id=room_id,
+                                     room_id=room_id,
-                                 data=self.data)
+                                     data=self.data)
-                try:
+                    try:
-                    await func(sqt)
+                        await func(sqt)
-                except PrintMessage as e:
+                    except PrintMessage as e:
-                    msg = Message(content=str(e), room_id=room_id)
+                        msg = Message(content=str(e), room_id=room_id)
-                    await self.app.ctx.sio.emit('sendMessage', msg.to_json())
+                        await self.app.ctx.sio.emit('sendMessage', msg.to_json())
 
 
 @dataclass