AI/matrix-chatgpt-bot
1
0
Fork 0
mirror of https://github.com/matrixgpt/matrix-chatgpt-bot.git synced 2024-09-20 16:15:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #7 from bertybuttface/conversation-rebased

Browse Source 
Add support for ChatGPT conversations via Matrix threads
This commit is contained in:
bertybuttface 2022-12-29 03:42:44 +00:00 committed by GitHub
commit c949b37359
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 62 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

71
src/handlers.ts
View File

@ -1,8 +1,31 @@
import { ChatGPTAPIBrowser } from "chatgpt";
import { ChatGPTAPIBrowser, ChatResponse } from "chatgpt";
import { MatrixClient } from "matrix-bot-sdk";
import { matrixBotUsername, matrixPrefix } from "./config.js";
import { isEventAMessage } from "./utils.js";
/**
* Send a thread reply.
* @param client Matrix client
* @param param1 Object containing text, root_event_id and roomId. root_event_id is the event_id
* of the message the thread "replying" to.
*/
export async function sendThreadReply(client: MatrixClient, { text, root_event_id, roomId }: { text: string, root_event_id: string, roomId: string }): Promise<void> {
const content = {
body: text,
msgtype: "m.text",
"org.matrix.msc1767.text": text,
"m.relates_to": {
event_id: root_event_id,
is_falling_back: true,
"m.in_reply_to": {
"event_id": root_event_id
},
rel_type: "m.thread"
}
}
await client.sendEvent(roomId, "m.room.message", content);
}
/**
* Run when *any* room event is received. The bot only sends a message if needed.
* @param client
@ -38,20 +61,50 @@ Please add me to an unencrypted chat.`);
}
await client.sendReadReceipt(roomId, event.event_id);
await client.setTyping(roomId, true, 10000)
try {
// timeout after 2 minutes (which will also abort the underlying HTTP request)
const result = await chatGPT.sendMessage(question, {
timeoutMs: 2 * 60 * 1000
})
await client.setTyping(roomId, false, 500)
await client.sendText(roomId, `${result.response}`);
let chatGPTconversation: string[]
if (event.content["m.relates_to"] !== undefined) {
let storedValue = (client.storageProvider.readValue('gpt-' + event.content["m.relates_to"].event_id) as string)
if (storedValue !== undefined){
chatGPTconversation = storedValue.split(',')
} else {
console.log("Something went wrong with stored value, we couldn't split it ok.")
}
}
let storageKey = event.event_id // store event.event_id if we start a new thread.
console.log('Using event_id unless we find better.')
if (event.content["m.relates_to"] !== undefined) {
console.log('Using m.relates_to.event_id instead.')
if (event.content["m.relates_to"].event_id !== undefined){
storageKey = event.content["m.relates_to"].event_id // store m.relates_to.event_id if thread exists
}
}
let result: ChatResponse
if (chatGPTconversation !== undefined) {
result = await chatGPT.sendMessage(question, {
timeoutMs: 2 * 60 * 1000,
conversationId: chatGPTconversation[0],
parentMessageId: chatGPTconversation[1]
})
} else {
result = await chatGPT.sendMessage(question, {
timeoutMs: 2 * 60 * 1000,
})
}
try {
await client.setTyping(roomId, false, 500)
const sentMessage = await sendThreadReply(client, {text: `${result.response}`, roomId:roomId, root_event_id: storageKey})
await client.sendReadReceipt(roomId, event.event_id);
// TODO: check result actually has conversationId and messageId or else something has gone wrong.
client.storageProvider.storeValue('gpt-' + storageKey, result.conversationId + ',' + result.messageId + ',' + Date.now())
} catch (e) {
await client.setTyping(roomId, false, 500)
await client.sendText(roomId, `ChatGPT returned an error :(`);
await client.sendReadReceipt(roomId, event.event_id);
console.error("ChatGPS returned an error:");
console.error("ChatGPT returned an error:");
console.error(e);
}
}