Lib.utils.EventClassifier

  1"""
  2事件分发器
  3"""
  4
  5from typing import TypedDict, NotRequired, Literal
  6
  7from ..core import EventManager, ListenerServer
  8from . import QQRichText, QQDataCacher, Logger
  9
 10logger = Logger.get_logger()
 11
 12
 13class Event(EventManager.Event):
 14    """
 15    事件类
 16    """
 17
 18    def __init__(self, event_data):
 19        self.event_data: dict = event_data
 20        self.time: int = self["time"]
 21        self.self_id: int = self["self_id"]
 22        self.post_type: str = self["post_type"]
 23
 24    def __getitem__(self, item):
 25        if item not in self.event_data:
 26            raise KeyError(f"{item} not in {self.event_data}")
 27        return self.event_data.get(item)
 28
 29    def get(self, key, default=None):
 30        """
 31        获取事件数据
 32        Args:
 33            key: 键
 34            default: 默认值
 35        Returns:
 36            None
 37        """
 38        return self.event_data.get(key, default)
 39
 40    def __contains__(self, other):
 41        return other in self.event_data
 42
 43    def __repr__(self):
 44        return str(self.event_data)
 45
 46    def logger(self):
 47        """
 48        发送事件日志
 49        """
 50        return False
 51
 52
 53class EventData(TypedDict):
 54    """
 55    事件数据
 56    """
 57    cls: Event
 58    post_type: str
 59    rules: dict
 60
 61
 62events: list[EventData] = []
 63
 64
 65def register_event(post_type: str, **other_rules):
 66    """
 67    注册事件
 68    Args:
 69        post_type: 事件类型
 70        other_rules: 其他规则
 71    Returns:
 72        None
 73    """
 74
 75    def decorator(cls):
 76        """
 77        Args:
 78            @param cls:
 79        Returns:
 80            None
 81        """
 82        data: EventData = {
 83            "cls": cls,
 84            "post_type": post_type,
 85            "rules": other_rules
 86        }
 87        events.append(data)
 88        return cls
 89
 90    return decorator
 91
 92
 93class SenderDict(TypedDict, total=False):
 94    """
 95    发送者数据
 96    """
 97    user_id: NotRequired[int]
 98    nickname: NotRequired[str]
 99    sex: NotRequired[Literal["male", "female", "unknown"]]
100    age: NotRequired[int]
101
102
103class PrivateDict(TypedDict, total=False):
104    """
105    私聊发送者数据
106    """
107    user_id: NotRequired[int]
108    nickname: NotRequired[str]
109    sex: NotRequired[Literal["male", "female", "unknown"]]
110    age: NotRequired[int]
111
112
113class GroupSenderDict(TypedDict, total=False):
114    """
115    群聊发送者数据
116    """
117    user_id: NotRequired[int]
118    nickname: NotRequired[str]
119    card: NotRequired[str]
120    sex: NotRequired[Literal["male", "female", "unknown"]]
121    age: NotRequired[int]
122    level: NotRequired[int]
123    role: NotRequired[Literal["owner", "admin", "member"]]
124    title: NotRequired[str]
125
126
127# 注册事件类
128@register_event("message")
129class MessageEvent(Event):
130    """
131    消息事件
132    """
133
134    def __init__(self, event_data):
135        super().__init__(event_data)
136        self.message_type = self["message_type"]
137        self.user_id: int = int(self["user_id"])
138        self.sub_type: str = self["sub_type"]
139        self.message: QQRichText.QQRichText = QQRichText.QQRichText(self["message"])
140        self.raw_message: str = self["raw_message"]
141        self.message_id: int = int(self["message_id"])
142        self.sender: SenderDict = self["sender"]
143
144
145@register_event("message", message_type="private")
146class PrivateMessageEvent(MessageEvent):
147    """
148    私聊消息事件
149    """
150
151    def __init__(self, event_data):
152        super().__init__(event_data)
153        self.sender: PrivateDict = self["sender"]
154
155    def logger(self):
156        if self.sub_type == "friend":
157            logger.info(
158                f"收到来自好友 "
159                f"{QQDataCacher.get_user_info(
160                    self.user_id,
161                    is_friend=True,
162                    **{k: v for k, v in self.sender.items() if k not in ['user_id']}
163                ).nickname}"
164                f"({self.user_id}) "
165                f"的消息: "
166                f"{self.message.render()}"
167                f"({self.message_id})"
168            )
169
170        elif self.sub_type == "group":
171            logger.info(
172                f"收到来自群 "
173                f"{QQDataCacher.get_group_info(self.get('group_id')).group_name}"
174                f"({self.get('group_id')})"
175                f" 内成员 "
176                f"{QQDataCacher.get_group_member_info(
177                    self.get('group_id'), self.user_id,
178                    **{k: v for k, v in self.sender.items() if k not in ['group_id', 'user_id']}
179                ).get_nickname()}"
180                f"({self.user_id}) "
181                f"的群临时会话消息: "
182                f"{self.message.render()}"
183                f"({self.message_id})"
184            )
185
186        elif self.sub_type == "other":
187            logger.info(
188                f"收到来自 "
189                f"{QQDataCacher.get_user_info(
190                    self.user_id,
191                    **{k: v for k, v in self.sender.items() if k not in ['user_id']}
192                ).nickname}"
193                f"({self.user_id}) "
194                f"的消息: "
195                f"{self.message.render()}"
196                f"({self.message_id})"
197            )
198
199        else:
200            return super().logger()
201
202
203@register_event("message", message_type="group")
204class GroupMessageEvent(MessageEvent):
205    """
206    群聊消息事件
207    """
208
209    def __init__(self, event_data):
210        super().__init__(event_data)
211        self.group_id: int = int(self["group_id"])
212        self.sender: GroupSenderDict = self["sender"]
213
214    def logger(self):
215        if self.sub_type == "normal":
216            logger.info(
217                f"收到来自群 "
218                f"{QQDataCacher.get_group_info(self.group_id).group_name}"
219                f"({self.group_id})"
220                f" 内成员 "
221                f"{QQDataCacher.get_group_member_info(
222                    self.group_id, self.user_id,
223                    **{k: v for k, v in self.sender.items()
224                       if k not in ['group_id', 'user_id']}).get_nickname()}"
225                f"({self.user_id}) "
226                f"的消息: "
227                f"{self.message.render(group_id=self.group_id)}"
228                f"({self.message_id})"
229            )
230
231        elif self.sub_type == "anonymous":
232            anonymous_data = self.get('anonymous', {})
233            anonymous_str = f"{QQDataCacher.get_user_info(anonymous_data['id']).nickname}"\
234                if anonymous_data else "匿名用户"
235            anonymous_detail = f"({anonymous_data['id']}; flag: {anonymous_data['flag']})" if anonymous_data else ""
236            logger.info(
237                f"收到来自群 "
238                f"{QQDataCacher.get_group_info(self.group_id).group_name}"
239                f"({self.group_id})"
240                f" 内 {anonymous_str}{anonymous_detail} "
241                f"的匿名消息: "
242                f"{self.message.render(group_id=self.group_id)}"
243                f"({self.message_id})"
244            )
245
246        elif self.sub_type == "notice":
247            logger.info(
248                f"收到来自群 "
249                f"{QQDataCacher.get_group_info(self.group_id).group_name}"
250                f"({self.group_id}) "
251                f"内的系统消息: "
252                f"{self.message.render(group_id=self.group_id)}"
253                f"({self.message_id})"
254            )
255
256        else:
257            return super().logger()
258
259
260@register_event("notice")
261class NoticeEvent(Event):
262    """
263    通知事件
264    """
265
266    def __init__(self, event_data):
267        super().__init__(event_data)
268        self.notice_type: str = self["notice_type"]
269
270
271class FileDict(TypedDict, total=False):
272    """
273    文件数据
274    """
275    id: str
276    name: str
277    size: int
278    busid: int
279
280
281@register_event("notice", notice_type="group_upload")
282class GroupUploadEvent(NoticeEvent):
283    """
284    群文件上传事件
285    """
286
287    def __init__(self, event_data):
288        super().__init__(event_data)
289        self.group_id: int = int(self["group_id"])
290        self.user_id: int = int(self["user_id"])
291        self.file: FileDict = self["file"]
292
293    def logger(self):
294        logger.info(
295            f"群 "
296            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
297            f"({self.group_id}) "
298            f"内成员 "
299            f"{QQDataCacher.get_group_member_info(self.group_id, self.user_id).get_nickname()} "
300            f"({self.user_id}) "
301            f"上传了文件: "
302            f"{self.file['name']}"
303            f"({self.file['id']})"
304        )
305
306
307@register_event("notice", notice_type="group_admin")
308class GroupAdminEvent(NoticeEvent):
309    """
310    群管理员变动事件
311    """
312
313    def __init__(self, event_data):
314        super().__init__(event_data)
315        self.group_id: int = int(self["group_id"])
316        self.user_id: int = int(self["user_id"])
317        self.sub_type: str = self["sub_type"]
318
319
320@register_event("notice", notice_type="group_admin", sub_type="set")
321class GroupSetAdminEvent(GroupAdminEvent):
322    """
323    群管理员被设置事件
324    """
325
326    def logger(self):
327        logger.info(
328            f"群 "
329            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
330            f"({self.group_id}) "
331            f"内 成员 "
332            f"{QQDataCacher.get_group_member_info(self.group_id, self.user_id).get_nickname()}"
333            f"({self.user_id}) "
334            f"被设置为管理员"
335        )
336
337
338@register_event("notice", notice_type="group_admin", sub_type="unset")
339class GroupUnsetAdminEvent(GroupAdminEvent):
340    """
341    群管理员被取消事件
342    """
343
344    def logger(self):
345        logger.info(
346            f"群 "
347            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
348            f"({self.group_id}) "
349            f"内 成员 "
350            f"{QQDataCacher.get_group_member_info(self.group_id, self.user_id).get_nickname()}"
351            f"({self.user_id}) "
352            f"被取消管理员"
353        )
354
355
356@register_event("notice", notice_type="group_decrease")
357class GroupDecreaseEvent(NoticeEvent):
358    """
359    群成员减少事件
360    """
361
362    def __init__(self, event_data):
363        super().__init__(event_data)
364        self.group_id: int = int(self["group_id"])
365        self.user_id: int = int(self["user_id"])
366        self.operator_id = int(self["operator_id"])
367        self.sub_type: str = self["sub_type"]
368
369
370@register_event("notice", notice_type="group_decrease", sub_type="leave")
371class GroupDecreaseLeaveEvent(GroupDecreaseEvent):
372    """
373    群成员离开事件
374    """
375
376    def logger(self):
377        logger.info(
378            f"群 "
379            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
380            f"({self.group_id}) "
381            f"内成员 "
382            f"{QQDataCacher.get_user_info(self.user_id).get_nickname()}"
383            f"({self.user_id}) "
384            f"退出了群聊"
385        )
386
387
388@register_event("notice", notice_type="group_decrease", sub_type="kick")
389class GroupDecreaseKickEvent(GroupDecreaseEvent):
390    """
391    群成员被踢事件
392    """
393
394    def logger(self):
395        logger.info(
396            f"群 "
397            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
398            f"({self.group_id}) "
399            f"内成员 "
400            f"{QQDataCacher.get_user_info(self.user_id).get_nickname()}"
401            f"({self.user_id}) "
402            f"被管理员 "
403            f"{QQDataCacher.get_group_member_info(self.group_id, self.operator_id).get_nickname()}"
404            f"({self.operator_id}) "
405            f"踢出了群聊"
406        )
407
408
409@register_event("notice", notice_type="group_decrease", sub_type="kick_me")
410class GroupDecreaseKickMeEvent(GroupDecreaseEvent):
411    """
412    机器人自己被移出事件
413    """
414
415    def logger(self):
416        logger.info(
417            f"群 "
418            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
419            f"({self.group_id}) "
420            f"内 "
421            f"{QQDataCacher.get_group_member_info(self.group_id, self.operator_id).get_nickname()}"
422            f"({self.operator_id}) "
423            f"将机器人踢出了群聊"
424        )
425
426
427@register_event("notice", notice_type="group_increase")
428class GroupIncreaseEvent(NoticeEvent):
429    """
430    群成员增加事件
431    """
432
433    def __init__(self, event_data):
434        super().__init__(event_data)
435        self.group_id: int = int(self["group_id"])
436        self.user_id: int = int(self["user_id"])
437        self.operator_id: int = int(self["operator_id"])
438        self.sub_type: str = self["sub_type"]
439
440
441@register_event("notice", notice_type="group_increase", sub_type="approve")
442class GroupIncreaseApproveEvent(GroupIncreaseEvent):
443    """
444    群成员同意入群事件
445    """
446
447    def logger(self):
448        logger.info(
449            f"群 "
450            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
451            f"({self.group_id}) "
452            f"内管理员 "
453            f"{QQDataCacher.get_group_member_info(self.group_id, self.operator_id).get_nickname()}"
454            f"({self.operator_id}) "
455            f"将 "
456            f"{QQDataCacher.get_user_info(self.user_id).get_nickname()}"
457            f"({self.user_id}) "
458            f"批准入群"
459        )
460
461
462@register_event("notice", notice_type="group_increase", sub_type="invite")
463class GroupIncreaseInviteEvent(GroupIncreaseEvent):
464    """
465    群成员被邀请入群事件
466    """
467
468    def logger(self):
469        logger.info(
470            f"群 "
471            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
472            f"({self.group_id}) "
473            f"内成员 "
474            f"{QQDataCacher.get_group_member_info(self.group_id, self.operator_id).get_nickname()}"
475            f"({self.user_id}) "
476            f"将 "
477            f"{QQDataCacher.get_user_info(self.user_id).get_nickname()}"
478            f"({self.operator_id}) "
479            f"邀请入群"
480        )
481
482
483@register_event("notice", notice_type="group_ban")
484class GroupBanEvent(NoticeEvent):
485    """
486    群禁言事件
487    """
488
489    def __init__(self, event_data):
490        super().__init__(event_data)
491        self.group_id: int = int(self["group_id"])
492        self.user_id: int = int(self["user_id"])
493        self.operator_id: int = int(self["operator_id"])
494        self.sub_type: str = self["sub_type"]
495        self.duration: int = int(self["duration"])
496
497
498@register_event("notice", notice_type="group_ban", sub_type="ban")
499class GroupBanSetEvent(GroupBanEvent):
500    """
501    群禁言被设置事件
502    """
503
504    def logger(self):
505        logger.info(
506            f"群 "
507            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
508            f"({self.group_id}) "
509            f"内成员 "
510            f"{QQDataCacher.get_group_member_info(self.group_id, self.user_id).get_nickname()}"
511            f"({self.user_id}) "
512            f"被管理员 "
513            f"{QQDataCacher.get_group_member_info(self.group_id, self.operator_id).get_nickname()}"
514            f"({self.operator_id}) "
515            f"禁言了: "
516            f"{self.duration}s"
517        )
518
519
520@register_event("notice", notice_type="group_ban", sub_type="lift_ban")
521class GroupBanLiftEvent(GroupBanEvent):
522    """
523    群禁言被解除事件
524    """
525
526    def logger(self):
527        logger.info(
528            f"群 "
529            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
530            f"({self.group_id}) "
531            f"内成员 "
532            f"{QQDataCacher.get_group_member_info(self.group_id, self.user_id).get_nickname()}"
533            f"({self.user_id}) "
534            f"被管理员 "
535            f"{QQDataCacher.get_group_member_info(self.group_id, self.operator_id).get_nickname()}"
536            f"({self.operator_id}) "
537            f"解除了禁言"
538        )
539
540
541@register_event("notice", notice_type="friend_add")
542class FriendAddEvent(NoticeEvent):
543    """
544    好友添加事件
545    """
546
547    def __init__(self, event_data):
548        super().__init__(event_data)
549        self.user_id: int = int(self["user_id"])
550
551    def logger(self):
552        logger.info(
553            f"好友 "
554            f"{QQDataCacher.get_user_info(self.user_id).get_nickname()}"
555            f"({self.user_id}) "
556            f"添加了机器人的好友"
557        )
558
559
560@register_event("notice", notice_type="group_recall")
561class GroupRecallEvent(NoticeEvent):
562    """
563    群消息撤回事件
564    """
565
566    def __init__(self, event_data):
567        super().__init__(event_data)
568        self.group_id: int = int(self["group_id"])
569        self.user_id: int = int(self["user_id"])
570        self.operator_id: int = int(self["operator_id"])
571        self.message_id: int = int(self["message_id"])
572
573    def logger(self):
574        if self.user_id == self.operator_id:
575            logger.info(
576                f"群 "
577                f"{QQDataCacher.get_group_info(self.group_id).group_name}"
578                f"({self.group_id}) "
579                f"内成员 "
580                f"{QQDataCacher.get_group_member_info(self.group_id, self.user_id).get_nickname()}"
581                f"({self.user_id}) "
582                f"撤回了消息: "
583                f"{self.message_id}"
584            )
585        else:
586            logger.info(
587                f"群 "
588                f"{QQDataCacher.get_group_info(self.group_id).group_name}"
589                f"({self.group_id}) "
590                f"内成员 "
591                f"{QQDataCacher.get_group_member_info(self.group_id, self.user_id).get_nickname()}"
592                f"({self.user_id}) "
593                f"被管理员 "
594                f"{QQDataCacher.get_group_member_info(self.group_id, self.operator_id).get_nickname()}"
595                f"({self.operator_id}) "
596                f"撤回了消息: "
597                f"{self.message_id}"
598            )
599
600
601@register_event("notice", notice_type="friend_recall")
602class FriendRecallEvent(NoticeEvent):
603    """
604    好友消息撤回事件
605    """
606
607    def __init__(self, event_data):
608        super().__init__(event_data)
609        self.user_id: int = int(self["user_id"])
610        self.message_id: int = int(self["message_id"])
611
612    def logger(self):
613        logger.info(
614            f"好友 "
615            f"{QQDataCacher.get_user_info(self.user_id).get_nickname()}"
616            f"({self.user_id}) "
617            f"撤回了消息: "
618            f"{self.message_id}"
619        )
620
621
622@register_event("notice", notice_type="notify", sub_type="poke")
623class GroupPokeEvent(NoticeEvent):
624    """
625    群戳一戳事件
626    """
627
628    def __init__(self, event_data):
629        super().__init__(event_data)
630        self.group_id: int = int(self["group_id"])
631        self.user_id: int = int(self["user_id"])
632        self.target_id: int = int(self["target_id"])
633
634    def logger(self):
635        logger.info(
636            f"群 "
637            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
638            f"({self.group_id}) "
639            f"内 "
640            f"{QQDataCacher.get_group_member_info(self.group_id, self.user_id).get_nickname()}"  # user_id is the poker
641            f"({self.user_id}) "
642            f"戳了戳 "
643            f"{QQDataCacher.get_group_member_info(self.group_id, self.target_id).get_nickname()}"  # target_id is pokered
644            f"({self.target_id})"
645        )
646
647
648@register_event("notice", notice_type="notify", sub_type="lucky_king")
649class GroupLuckyKingEvent(NoticeEvent):
650    """
651    群红包运气王事件
652    """
653
654    def __init__(self, event_data):
655        super().__init__(event_data)
656        self.group_id: int = int(self["group_id"])
657        self.user_id: int = int(self["user_id"])
658        self.target_id: int = int(self["target_id"])
659
660    def logger(self):
661        logger.info(
662            f"群 "
663            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
664            f"({self.group_id}) "
665            f"内 "
666            f"{QQDataCacher.get_group_member_info(self.group_id, self.user_id).get_nickname()}"  # user_id is lucky king
667            f"({self.user_id}) "
668            f"成为了 "
669            f"{QQDataCacher.get_group_member_info(self.group_id, self.target_id).get_nickname()}"  # target_id is sender
670            f"({self.target_id}) "
671            f"发送的红包的运气王"
672        )
673
674
675@register_event("notice", notice_type="notify", sub_type="honor")
676class GroupHonorEvent(NoticeEvent):
677    """
678    群荣誉变更事件
679    """
680
681    def __init__(self, event_data):
682        super().__init__(event_data)
683        self.group_id: int = int(self["group_id"])
684        self.user_id: int = int(self["user_id"])
685        self.honor_type: str = self["honor_type"]
686
687    def logger(self):
688        if self.honor_type not in ["talkative", "performer", "emotion"]:
689            logger.info(
690                f"群 "
691                f"{QQDataCacher.get_group_info(self.group_id).group_name}"
692                f"({self.group_id}) "
693                f"内 "
694                f"{QQDataCacher.get_group_member_info(self.group_id, self.user_id).get_nickname()}"
695                f"({self.user_id}) "
696                f"获得了未知荣誉: "
697                f"{self.honor_type}"
698            )
699        else:
700            super().logger()
701
702
703@register_event("notice", notice_type="notify", sub_type="honor", honor_type="talkative")
704class GroupTalkativeHonorEvent(GroupHonorEvent):
705    """
706    群龙王变更事件
707    """
708
709    def logger(self):
710        logger.info(
711            f"群 "
712            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
713            f"({self.group_id}) "
714            f"内 "
715            f"{QQDataCacher.get_group_member_info(self.group_id, self.user_id).get_nickname()}"
716            f"({self.user_id}) "
717            f"获得了群龙王称号"
718        )
719
720
721@register_event("notice", notice_type="notify", sub_type="honor", honor_type="performer")
722class GroupPerformerHonorEvent(GroupHonorEvent):
723    """
724    群群聊之火变更事件
725    """
726
727    def logger(self):
728        logger.info(
729            f"群 "
730            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
731            f"({self.group_id}) "
732            f"内 "
733            f"{QQDataCacher.get_group_member_info(self.group_id, self.user_id).get_nickname()}"
734            f"({self.user_id}) "
735            f"获得了群聊炽焰称号"
736        )
737
738
739@register_event("notice", notice_type="notify", sub_type="honor", honor_type="emotion")
740class GroupEmotionHonorEvent(GroupHonorEvent):
741    """
742    群表快乐源泉变更事件
743    """
744
745    def logger(self):
746        logger.info(
747            f"群 "
748            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
749            f"({self.group_id}) "
750            f"内 "
751            f"{QQDataCacher.get_group_member_info(self.group_id, self.user_id).get_nickname()}"
752            f"({self.user_id}) "
753            f"获得了快乐源泉称号"
754        )
755
756
757@register_event("request")
758class RequestEvent(Event):
759    """
760    请求事件
761    """
762
763    def __init__(self, event_data):
764        super().__init__(event_data)
765        self.request_type: str = self["request_type"]
766        self.comment: str = self["comment"]
767        self.flag: str = self["flag"]
768
769
770@register_event("request", request_type="friend")
771class FriendRequestEvent(RequestEvent):
772    """
773    加好友请求事件
774    """
775
776    def __init__(self, event_data):
777        super().__init__(event_data)
778        self.user_id: int = int(self["user_id"])
779
780    def logger(self):
781        logger.info(
782            f"{QQDataCacher.get_user_info(self.user_id).get_nickname()}"
783            f"({self.user_id})"
784            f"请求添加机器人为好友\n"
785            f"验证信息: {self.comment}\n"
786            f"flag: {self.flag}"
787        )
788
789
790@register_event("request", request_type="group")
791class GroupRequestEvent(RequestEvent):
792    """
793    加群请求事件
794    """
795
796    def __init__(self, event_data):
797        super().__init__(event_data)
798        self.sub_type: str = self["sub_type"]
799        self.group_id: int = int(self["group_id"])
800        self.user_id: int = int(self["user_id"])
801
802
803@register_event("request", request_type="group", sub_type="add")
804class GroupAddRequestEvent(GroupRequestEvent):
805    """
806    加群请求事件 - 添加
807    """
808
809    def logger(self):
810        logger.info(
811            f"{QQDataCacher.get_user_info(self.user_id).get_nickname()}"
812            f"({self.user_id})"
813            f"请求加入群 "
814            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
815            f"({self.group_id})\n"
816            f"验证信息: {self.comment}\n"
817            f"flag: {self.flag}"
818        )
819
820
821@register_event("request", request_type="group", sub_type="invite")
822class GroupInviteRequestEvent(GroupRequestEvent):
823    """
824    加群请求事件 - 邀请
825    """
826
827    def logger(self):
828        logger.info(
829            f"{QQDataCacher.get_group_member_info(self.group_id, self.user_id).get_nickname()}"
830            f"({self.user_id})"
831            f"邀请机器人加入群 "
832            f"{QQDataCacher.get_group_info(self.group_id).group_name}"
833        )
834
835
836@register_event("meta_event")
837class MetaEvent(Event):
838    """
839    元事件
840    """
841
842    def __init__(self, event_data):
843        super().__init__(event_data)
844        self.meta_event_type: str = self["meta_event_type"]
845
846
847@register_event("meta_event", meta_event_type="lifecycle")
848class LifecycleMetaEvent(MetaEvent):
849    """
850    元事件 - 生命周期
851    """
852
853    def __init__(self, event_data):
854        super().__init__(event_data)
855        self.sub_type: str = self["sub_type"]
856
857    def logger(self):
858        logger.info(
859            f"收到元事件: " + {
860                "enable": "OneBot 启用",
861                "disable": "OneBot 禁用",
862                "connect": "OneBot 连接成功"
863            }[self.sub_type]
864        )
865
866
867@register_event("meta_event", meta_event_type="lifecycle", sub_type="enable")
868class EnableMetaEvent(LifecycleMetaEvent):
869    """
870    元事件 - 生命周期 - OneBot 启用
871    """
872
873    def logger(self):
874        logger.info("收到元事件: OneBot 启用")
875
876
877@register_event("meta_event", meta_event_type="lifecycle", sub_type="disable")
878class DisableMetaEvent(LifecycleMetaEvent):
879    """
880    元事件 - 生命周期 - OneBot 禁用
881    """
882
883    def logger(self):
884        logger.info("收到元事件: OneBot 禁用")
885
886
887@register_event("meta_event", meta_event_type="lifecycle", sub_type="connect")
888class ConnectMetaEvent(LifecycleMetaEvent):
889    """
890    元事件 - 生命周期 - OneBot 连接成功
891    """
892
893    def logger(self):
894        logger.info("收到元事件: OneBot 连接成功")
895
896
897@register_event("meta_event", meta_event_type="heartbeat")
898class HeartbeatMetaEvent(MetaEvent):
899    """
900    元事件 - 心跳
901    """
902
903    def __init__(self, event_data):
904        super().__init__(event_data)
905        self.status: dict = self["status"]
906        self.interval: int = int(self["interval"])
907
908    def logger(self):
909        logger.debug(f"收到心跳包")
910
911
912@EventManager.event_listener(ListenerServer.EscalationEvent)
913def on_escalation(event_data):
914    """
915    事件分发器
916    Args:
917        event_data: 事件数据
918    Returns:
919        None
920    """
921    event_data = event_data.event_data
922    event = Event(event_data)
923    event_call_list = [event]
924    matched_event = False
925    for event_cls_data in events:
926        if (
927                event_data["post_type"] == event_cls_data['post_type'] and
928                all(k in event_data and event_data[k] == v for k, v in event_cls_data['rules'].items())
929        ):
930            event = event_cls_data['cls'](event_data)
931            if not matched_event:
932                if event.logger() is not False:
933                    matched_event = True
934            event_call_list.append(event)
935
936    if not matched_event:
937        logger.warning(f"未知的上报事件: {event_data}")
938
939    # 广播事件
940    for event in event_call_list:
941        event.call()