119 lines
4.1 KiB
JavaScript
119 lines
4.1 KiB
JavaScript
import * as dotenv from 'dotenv';
|
|
import { MatrixClient } from 'matrix-js-sdk';
|
|
import fs from 'fs';
|
|
|
|
dotenv.config();
|
|
|
|
console.log('🚀 Starting Ancestor Quote Bot...\n');
|
|
|
|
const client = new MatrixClient({
|
|
accessToken: process.env.MATRIX_ACCESS_TOKEN,
|
|
baseUrl: process.env.MATRIX_HOME_SERVER,
|
|
});
|
|
|
|
function loadQuotes() {
|
|
try {
|
|
const quotesFile = './quotes.json';
|
|
if (fs.existsSync(quotesFile)) {
|
|
return JSON.parse(fs.readFileSync(quotesFile, 'utf8'));
|
|
}
|
|
} catch (err) {
|
|
console.error('Error loading quotes:', err.message);
|
|
}
|
|
return [];
|
|
}
|
|
|
|
(async () => {
|
|
const quotes = loadQuotes();
|
|
|
|
if (quotes.length === 0) {
|
|
console.error('❌ No quotes found! Please ensure quotes.json is present.');
|
|
process.exit(1);
|
|
}
|
|
|
|
console.log(`✅ Loaded ${quotes.length} Ancestor quotes`);
|
|
|
|
const token = process.env.MATRIX_ACCESS_TOKEN;
|
|
const server = process.env.MATRIX_HOME_SERVER;
|
|
|
|
if (!token || !server) {
|
|
console.error('❌ Missing required environment variables!');
|
|
console.error(' Required: MATRIX_ACCESS_TOKEN, MATRIX_HOME_SERVER');
|
|
console.error(' See .env.example for guidance.');
|
|
process.exit(1);
|
|
}
|
|
console.log(`🏠 Server: ${server}`);
|
|
|
|
try {
|
|
const whoami = await client.whoami();
|
|
const userId = whoami.user_id;
|
|
|
|
if (!userId || !userId.startsWith('@')) {
|
|
console.error(`❌ whoami returned invalid user ID: ${userId}`);
|
|
process.exit(1);
|
|
}
|
|
|
|
client.credentials.userId = userId;
|
|
console.log(`👤 Bot Identity: ${userId}`);
|
|
|
|
await client.startClient();
|
|
console.log('✅ MatrixClient connected and authenticated\n');
|
|
|
|
const cmd = (process.env.BOT_COMMAND || '!quote').toLowerCase();
|
|
|
|
// Auto-accept invites so the bot can be invited into rooms.
|
|
client.on('RoomMember.membership', (event, member) => {
|
|
if (member.userId === userId && member.membership === 'invite') {
|
|
const roomId = event.getRoomId();
|
|
console.log(`📩 Invited to ${roomId}, joining...`);
|
|
client.joinRoom(roomId).catch((err) => {
|
|
console.error('Failed to join room:', err.message);
|
|
});
|
|
}
|
|
});
|
|
|
|
// 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) => {
|
|
if (event.getType() !== 'm.room.message') return;
|
|
|
|
const sender = event.getSender();
|
|
if (sender === userId) return;
|
|
|
|
const room = client.getRoom(event.getRoomId());
|
|
if (!room) return;
|
|
|
|
const membership = room.getMyMembership();
|
|
if (membership !== 'join') return;
|
|
|
|
const content = event.getContent();
|
|
if (!content || typeof content.body !== 'string') return;
|
|
|
|
console.log(`✉️ [${room.roomId}] membership="${membership}" sender="${sender}" body="${content.body}"`);
|
|
|
|
const lower = content.body.toLowerCase().trim();
|
|
if (lower === cmd || lower.startsWith(cmd + ' ')) {
|
|
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(` Invite this bot to a room and type ${process.env.BOT_COMMAND || '!quote'} to get an Ancestor quote.\n`);
|
|
|
|
} catch (err) {
|
|
console.error('❌ Fatal error starting bot:', err.message);
|
|
console.error(err.stack);
|
|
process.exit(1);
|
|
}
|
|
|
|
process.on('unhandledRejection', (reason, promise) => {
|
|
console.error('🚨 Unhandled rejection:', reason?.message || reason);
|
|
process.exit(1);
|
|
});
|
|
|
|
setInterval(() => {}, 60000);
|
|
})(); |