_1006_water_meter_filter.py 文件源码

def tg_water_meter(bot: telegram.Bot,
                   update: telegram.Update):
    if update.message:
        message: telegram.Message = update.message
    else:
        message: telegram.Message = update.edited_message

    tg_group_id = message.chat_id  # telegram group id
    forward_index = get_forward_index(tg_group_id=int(tg_group_id))
    logger.debug("Water meter processing")
    if message.forward_from_chat and message.forward_from_chat.type == 'channel':
        logger.debug("message is forward from channel")
        if update.message.forward_from_chat.id in global_vars.filter_list['channels']:
            logger.debug("message is blocked")
            global_vars.drive_mode_on(forward_index,
                                      tg_user=message.from_user,
                                      tg_group_id=tg_group_id,
                                      tg_message_id=message.message_id)
            raise DispatcherHandlerStop()

    message_text = ''
    if message.caption:
        message_text = message.caption
    elif message.text:
        message_text = message.text

    if not message_text:
        return

    for keyword in global_vars.filter_list['keywords']:
        if keyword in message_text:
            logger.debug("message is blocked")
            global_vars.drive_mode_on(forward_index,
                                      tg_user=message.from_user,
                                      tg_group_id=tg_group_id,
                                      tg_message_id=message.message_id)
            raise DispatcherHandlerStop()