mirror of
https://github.com/langbot-app/LangBot.git
synced 2026-09-02 07:37:14 +00:00
增加多适配器支持,用于ws通道冲突时可用http适配器
This commit is contained in:
@@ -3,11 +3,13 @@ import logging
|
|||||||
|
|
||||||
# [必需] Mirai的配置
|
# [必需] Mirai的配置
|
||||||
# 请到配置mirai的步骤中的教程查看每个字段的信息
|
# 请到配置mirai的步骤中的教程查看每个字段的信息
|
||||||
|
# adapter: 选择适配器,目前支持HTTPAdapter和WebSocketAdapter
|
||||||
# host: 运行mirai的主机地址
|
# host: 运行mirai的主机地址
|
||||||
# port: 运行mirai的主机端口
|
# port: 运行mirai的主机端口
|
||||||
# verifyKey: mirai-api-http的verifyKey
|
# verifyKey: mirai-api-http的verifyKey
|
||||||
# qq: 机器人的QQ号
|
# qq: 机器人的QQ号
|
||||||
mirai_http_api_config = {
|
mirai_http_api_config = {
|
||||||
|
"adapter": "HTTPAdapter",
|
||||||
"host": "localhost",
|
"host": "localhost",
|
||||||
"port": 8080,
|
"port": 8080,
|
||||||
"verifyKey": "yirimirai",
|
"verifyKey": "yirimirai",
|
||||||
|
|||||||
+12
-2
@@ -4,7 +4,7 @@ import os
|
|||||||
import threading
|
import threading
|
||||||
|
|
||||||
import openai.error
|
import openai.error
|
||||||
from mirai import At, GroupMessage, MessageEvent, Mirai, Plain, StrangerMessage, WebSocketAdapter, FriendMessage, Image
|
from mirai import At, GroupMessage, MessageEvent, Mirai, Plain, StrangerMessage, WebSocketAdapter,HTTPAdapter, FriendMessage, Image
|
||||||
|
|
||||||
import config
|
import config
|
||||||
import pkg.openai.session
|
import pkg.openai.session
|
||||||
@@ -73,7 +73,8 @@ class QQBotManager:
|
|||||||
else:
|
else:
|
||||||
self.reply_filter = pkg.qqbot.filter.ReplyFilter([])
|
self.reply_filter = pkg.qqbot.filter.ReplyFilter([])
|
||||||
|
|
||||||
bot = Mirai(
|
if mirai_http_api_config['adapter'] == "WebSocketAdapter":
|
||||||
|
bot = Mirai(
|
||||||
qq=mirai_http_api_config['qq'],
|
qq=mirai_http_api_config['qq'],
|
||||||
adapter=WebSocketAdapter(
|
adapter=WebSocketAdapter(
|
||||||
verify_key=mirai_http_api_config['verifyKey'],
|
verify_key=mirai_http_api_config['verifyKey'],
|
||||||
@@ -81,6 +82,15 @@ class QQBotManager:
|
|||||||
port=mirai_http_api_config['port']
|
port=mirai_http_api_config['port']
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
elif mirai_http_api_config['adapter'] == "HTTPAdapter":
|
||||||
|
bot = Mirai(
|
||||||
|
qq=mirai_http_api_config['qq'],
|
||||||
|
adapter=HTTPAdapter(
|
||||||
|
verify_key=mirai_http_api_config['verifyKey'],
|
||||||
|
host=mirai_http_api_config['host'],
|
||||||
|
port=mirai_http_api_config['port']
|
||||||
|
)
|
||||||
|
)
|
||||||
|
|
||||||
@bot.on(FriendMessage)
|
@bot.on(FriendMessage)
|
||||||
async def on_friend_message(event: FriendMessage):
|
async def on_friend_message(event: FriendMessage):
|
||||||
|
|||||||
Reference in New Issue
Block a user