Compare commits
3 Commits
8b32397915
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
45c2aeea6d | ||
|
|
e16a4b44d5 | ||
|
|
871dbea460 |
58
index.js
58
index.js
@@ -1,5 +1,6 @@
|
|||||||
import * as dotenv from 'dotenv';
|
import * as dotenv from 'dotenv';
|
||||||
import { MatrixClient } from 'matrix-js-sdk';
|
import { MatrixClient } from 'matrix-js-sdk';
|
||||||
|
import { MemoryStore } from 'matrix-js-sdk/lib/store/memory.js';
|
||||||
import fs from 'fs';
|
import fs from 'fs';
|
||||||
|
|
||||||
dotenv.config();
|
dotenv.config();
|
||||||
@@ -9,6 +10,7 @@ console.log('🚀 Starting Ancestor Quote Bot...\n');
|
|||||||
const client = new MatrixClient({
|
const client = new MatrixClient({
|
||||||
accessToken: process.env.MATRIX_ACCESS_TOKEN,
|
accessToken: process.env.MATRIX_ACCESS_TOKEN,
|
||||||
baseUrl: process.env.MATRIX_HOME_SERVER,
|
baseUrl: process.env.MATRIX_HOME_SERVER,
|
||||||
|
store: new MemoryStore(),
|
||||||
});
|
});
|
||||||
|
|
||||||
function loadQuotes() {
|
function loadQuotes() {
|
||||||
@@ -67,11 +69,7 @@ function loadQuotes() {
|
|||||||
console.log('');
|
console.log('');
|
||||||
|
|
||||||
const cmd = (process.env.BOT_COMMAND || '!quote').toLowerCase();
|
const cmd = (process.env.BOT_COMMAND || '!quote').toLowerCase();
|
||||||
|
console.log(`🔊 Listening for command: "${cmd}"`);
|
||||||
// Diagnostic: log EVERY event the client receives, regardless of type.
|
|
||||||
client.on('event', (event) => {
|
|
||||||
console.log(`EVENT type="${event.getType()}" room=${event.getRoomId()} sender=${event.getSender()}`);
|
|
||||||
});
|
|
||||||
|
|
||||||
// Auto-accept invites so the bot can be invited into rooms.
|
// Auto-accept invites so the bot can be invited into rooms.
|
||||||
client.on('RoomMember.membership', (event, member) => {
|
client.on('RoomMember.membership', (event, member) => {
|
||||||
@@ -85,32 +83,50 @@ function loadQuotes() {
|
|||||||
});
|
});
|
||||||
|
|
||||||
// Respond to messages in any room this bot is a member of.
|
// Respond to messages in any room this bot is a member of.
|
||||||
// We use the low-level 'event' client event, which sync.js emits
|
|
||||||
// directly for every event in every room (not a re-emit).
|
|
||||||
client.on('event', (event) => {
|
client.on('event', (event) => {
|
||||||
if (event.getType() !== 'm.room.message') return;
|
const type = event.getType();
|
||||||
|
const eventRoomId = event.getRoomId();
|
||||||
|
|
||||||
|
// Encrypted rooms: the bot has no E2EE support, so command text
|
||||||
|
// never arrives as plaintext and cannot be read or answered.
|
||||||
|
if (type === 'm.room.encrypted') {
|
||||||
|
console.log(`🔒 [${eventRoomId}] encrypted message received. ` +
|
||||||
|
`The bot cannot read E2EE rooms; invite it to an unencrypted room instead.`);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (type !== 'm.room.message') return;
|
||||||
|
|
||||||
const sender = event.getSender();
|
const sender = event.getSender();
|
||||||
if (sender === userId) return;
|
if (sender === userId) return; // skip replies from ourselves
|
||||||
|
|
||||||
const room = client.getRoom(event.getRoomId());
|
const room = eventRoomId ? client.getRoom(eventRoomId) : null;
|
||||||
if (!room) return;
|
if (!room) {
|
||||||
|
console.log(`ℹ️ [debug] got m.room.message for unknown room: ${eventRoomId}`);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
const membership = room.getMyMembership();
|
const membership = room.getMyMembership();
|
||||||
if (membership !== 'join') return;
|
if (membership !== 'join') {
|
||||||
|
console.log(`ℹ️ [debug] [${room.roomId}] m.room.message while membership="${membership}" — not replying`);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
const content = event.getContent();
|
const content = event.getContent();
|
||||||
if (!content || typeof content.body !== 'string') return;
|
if (!content || typeof content.body !== 'string') {
|
||||||
|
console.log(`ℹ️ [debug] [${room.roomId}] m.room.message without text body`);
|
||||||
console.log(`✉️ [${room.roomId}] membership="${membership}" sender="${sender}" body="${content.body}"`);
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
const lower = content.body.toLowerCase().trim();
|
const lower = content.body.toLowerCase().trim();
|
||||||
if (lower === cmd || lower.startsWith(cmd + ' ')) {
|
const matches = lower === cmd || lower.startsWith(cmd + ' ');
|
||||||
const quote = quotes[Math.floor(Math.random() * quotes.length)];
|
console.log(`💬 [${room.roomId}] <${sender}> "${content.body}" (listening for "${cmd}", match=${matches})`);
|
||||||
client.sendTextMessage(room.roomId, quote)
|
if (!matches) return;
|
||||||
.then(() => console.log(`🎃 [${room.roomId}] ${quote}`))
|
|
||||||
.catch((err) => console.error('Failed to send quote:', err.message));
|
const quote = quotes[Math.floor(Math.random() * quotes.length)];
|
||||||
}
|
client.sendTextMessage(room.roomId, quote)
|
||||||
|
.then(() => console.log(`🎃 [${room.roomId}] ${quote}`))
|
||||||
|
.catch((err) => console.error('Failed to send quote:', err.message));
|
||||||
});
|
});
|
||||||
|
|
||||||
console.log('🤖 Bot is running!');
|
console.log('🤖 Bot is running!');
|
||||||
|
|||||||
Reference in New Issue
Block a user