style: cleanup
This commit is contained in:
@@ -136,7 +136,5 @@ class GewechatPlatformEvent(AstrMessageEvent):
|
|||||||
|
|
||||||
async def send(self, message: MessageChain):
|
async def send(self, message: MessageChain):
|
||||||
to_wxid = self.message_obj.raw_message.get("to_wxid", None)
|
to_wxid = self.message_obj.raw_message.get("to_wxid", None)
|
||||||
await GewechatPlatformEvent.send_with_client(
|
await GewechatPlatformEvent.send_with_client(message, to_wxid, self.client)
|
||||||
message, to_wxid, self.client
|
|
||||||
)
|
|
||||||
await super().send(message)
|
await super().send(message)
|
||||||
|
|||||||
@@ -4,12 +4,10 @@ import os
|
|||||||
|
|
||||||
from astrbot.api.platform import Platform, AstrBotMessage, MessageType, PlatformMetadata
|
from astrbot.api.platform import Platform, AstrBotMessage, MessageType, PlatformMetadata
|
||||||
from astrbot.api.event import MessageChain
|
from astrbot.api.event import MessageChain
|
||||||
from astrbot.api import logger
|
|
||||||
from astrbot.core.platform.astr_message_event import MessageSesion
|
from astrbot.core.platform.astr_message_event import MessageSesion
|
||||||
from ...register import register_platform_adapter
|
from ...register import register_platform_adapter
|
||||||
from .gewechat_event import GewechatPlatformEvent
|
from .gewechat_event import GewechatPlatformEvent
|
||||||
from .client import SimpleGewechatClient
|
from .client import SimpleGewechatClient
|
||||||
from astrbot.core.message.components import Plain
|
|
||||||
|
|
||||||
if sys.version_info >= (3, 12):
|
if sys.version_info >= (3, 12):
|
||||||
from typing import override
|
from typing import override
|
||||||
|
|||||||
@@ -24,7 +24,7 @@ from astrbot.api.platform import register_platform_adapter
|
|||||||
from telegram import Update
|
from telegram import Update
|
||||||
from telegram.ext import ApplicationBuilder, ContextTypes, filters
|
from telegram.ext import ApplicationBuilder, ContextTypes, filters
|
||||||
from telegram.constants import ChatType
|
from telegram.constants import ChatType
|
||||||
from telegram.ext import MessageHandler as TelegramMessageHandler, CommandHandler
|
from telegram.ext import MessageHandler as TelegramMessageHandler
|
||||||
from .tg_event import TelegramPlatformEvent
|
from .tg_event import TelegramPlatformEvent
|
||||||
from astrbot.api import logger
|
from astrbot.api import logger
|
||||||
from telegram.ext import ExtBot
|
from telegram.ext import ExtBot
|
||||||
@@ -121,7 +121,9 @@ class TelegramPlatformAdapter(Platform):
|
|||||||
if update.message.entities:
|
if update.message.entities:
|
||||||
for entity in update.message.entities:
|
for entity in update.message.entities:
|
||||||
if entity.type == "mention":
|
if entity.type == "mention":
|
||||||
name = plain_text[entity.offset+1 : entity.offset + entity.length]
|
name = plain_text[
|
||||||
|
entity.offset + 1 : entity.offset + entity.length
|
||||||
|
]
|
||||||
message.message.append(At(qq=name, name=name))
|
message.message.append(At(qq=name, name=name))
|
||||||
plain_text = (
|
plain_text = (
|
||||||
plain_text[: entity.offset]
|
plain_text[: entity.offset]
|
||||||
|
|||||||
@@ -13,7 +13,7 @@ from astrbot.core.platform import (
|
|||||||
from astrbot.core.message.message_event_result import MessageChain
|
from astrbot.core.message.message_event_result import MessageChain
|
||||||
from astrbot.core.message.components import Plain, Image, Record # noqa: F403
|
from astrbot.core.message.components import Plain, Image, Record # noqa: F403
|
||||||
from astrbot import logger
|
from astrbot import logger
|
||||||
from astrbot.core import web_chat_queue, web_chat_back_queue
|
from astrbot.core import web_chat_queue
|
||||||
from .webchat_event import WebChatMessageEvent
|
from .webchat_event import WebChatMessageEvent
|
||||||
from astrbot.core.platform.astr_message_event import MessageSesion
|
from astrbot.core.platform.astr_message_event import MessageSesion
|
||||||
from ...register import register_platform_adapter
|
from ...register import register_platform_adapter
|
||||||
|
|||||||
@@ -9,6 +9,7 @@ from astrbot.core import web_chat_back_queue
|
|||||||
|
|
||||||
imgs_dir = "data/webchat/imgs"
|
imgs_dir = "data/webchat/imgs"
|
||||||
|
|
||||||
|
|
||||||
class WebChatMessageEvent(AstrMessageEvent):
|
class WebChatMessageEvent(AstrMessageEvent):
|
||||||
def __init__(self, message_str, message_obj, platform_meta, session_id):
|
def __init__(self, message_str, message_obj, platform_meta, session_id):
|
||||||
super().__init__(message_str, message_obj, platform_meta, session_id)
|
super().__init__(message_str, message_obj, platform_meta, session_id)
|
||||||
|
|||||||
@@ -139,7 +139,9 @@ class SessionWaiter:
|
|||||||
session.session_controller.stop(e)
|
session.session_controller.stop(e)
|
||||||
|
|
||||||
|
|
||||||
def session_waiter(session_id_param: str, timeout: int = 30, record_history_chains: bool = False):
|
def session_waiter(
|
||||||
|
session_id_param: str, timeout: int = 30, record_history_chains: bool = False
|
||||||
|
):
|
||||||
"""
|
"""
|
||||||
装饰器:自动将函数注册为 SessionWaiter 处理函数,并等待外部输入触发执行。
|
装饰器:自动将函数注册为 SessionWaiter 处理函数,并等待外部输入触发执行。
|
||||||
|
|
||||||
|
|||||||
@@ -19,7 +19,7 @@ class StaticFileRoute(Route):
|
|||||||
"/platforms",
|
"/platforms",
|
||||||
"/providers",
|
"/providers",
|
||||||
"/about",
|
"/about",
|
||||||
"/extension-marketplace"
|
"/extension-marketplace",
|
||||||
]
|
]
|
||||||
for i in index_:
|
for i in index_:
|
||||||
self.app.add_url_rule(i, view_func=self.index)
|
self.app.add_url_rule(i, view_func=self.index)
|
||||||
|
|||||||
@@ -25,7 +25,9 @@ class AstrBotDashboard:
|
|||||||
self.config = core_lifecycle.astrbot_config
|
self.config = core_lifecycle.astrbot_config
|
||||||
self.data_path = os.path.abspath(os.path.join(DATAPATH, "dist"))
|
self.data_path = os.path.abspath(os.path.join(DATAPATH, "dist"))
|
||||||
self.app = Quart("dashboard", static_folder=self.data_path, static_url_path="/")
|
self.app = Quart("dashboard", static_folder=self.data_path, static_url_path="/")
|
||||||
self.app.config['MAX_CONTENT_LENGTH'] = 128 * 1024 * 1024 # 将 Flask 允许的最大上传文件体大小设置为 128 MB
|
self.app.config["MAX_CONTENT_LENGTH"] = (
|
||||||
|
128 * 1024 * 1024
|
||||||
|
) # 将 Flask 允许的最大上传文件体大小设置为 128 MB
|
||||||
self.app.json.sort_keys = False
|
self.app.json.sort_keys = False
|
||||||
self.app.before_request(self.auth_middleware)
|
self.app.before_request(self.auth_middleware)
|
||||||
# token 用于验证请求
|
# token 用于验证请求
|
||||||
|
|||||||
Reference in New Issue
Block a user