This commit is contained in:
2025-02-18 22:11:35 +01:00
parent a1d7833c1d
commit 99be4cbab2

View File

@@ -93,7 +93,7 @@ class MessageEvent(BaseModel):
async def get_completion(message: str): async def get_completion(message: str) -> str:
async with AsyncClient() as client: async with AsyncClient() as client:
response = await client.post( response = await client.post(
"https://openrouter.ai/api/v1/chat/completions", "https://openrouter.ai/api/v1/chat/completions",
@@ -143,15 +143,16 @@ class MessagesProc:
try: try:
completion = await get_completion(event.message.text) completion = await get_completion(event.message.text)
if not completion: max_length = 255
completion = "Пошел нахуй!" completion_parts = [completion[i:i + max_length] for i in range(0, len(completion), max_length)]
await twitch.send_chat_message( for part in completion_parts:
event.broadcaster_user_id, await twitch.send_chat_message(
config.TWITCH_ADMIN_USER_ID, event.broadcaster_user_id,
completion, config.TWITCH_ADMIN_USER_ID,
reply_parent_message_id=event.message_id part,
) reply_parent_message_id=event.message_id
)
except Exception as e: except Exception as e:
logger.error(f"Failed to get completion: {e}") logger.error(f"Failed to get completion: {e}")