Fix: resolve syntax errors in index.js and improve error handling
This commit is contained in:
42
index.js
42
index.js
@@ -32,8 +32,7 @@ function loadQuotes() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
console.log(`✅ Loaded ${quotes.length} Ancestor quotes`);
|
console.log(`✅ Loaded ${quotes.length} Ancestor quotes`);
|
||||||
|
|
||||||
// Validate environment variables first
|
|
||||||
const token = process.env.MATRIX_ACCESS_TOKEN;
|
const token = process.env.MATRIX_ACCESS_TOKEN;
|
||||||
const server = process.env.MATRIX_HOME_SERVER;
|
const server = process.env.MATRIX_HOME_SERVER;
|
||||||
|
|
||||||
@@ -44,19 +43,17 @@ function loadQuotes() {
|
|||||||
process.exit(1);
|
process.exit(1);
|
||||||
}
|
}
|
||||||
console.log(`🏠 Server: ${server}`);
|
console.log(`🏠 Server: ${server}`);
|
||||||
|
|
||||||
try {
|
try {
|
||||||
await client.startClient();
|
await client.startClient();
|
||||||
console.log('✅ MatrixClient connected and authenticated\n');
|
console.log('✅ MatrixClient connected and authenticated\n');
|
||||||
|
|
||||||
let lastSentMessage = null;
|
let lastSentMessage = null;
|
||||||
|
|
||||||
// Listen for all membership events from homeserver
|
|
||||||
client.on('RoomMember#joined', async (member) => {
|
client.on('RoomMember#joined', async (member) => {
|
||||||
const room = member.room;
|
const room = member.room;
|
||||||
console.log(`✅ Joined room: ${room.getCanonicalRoomName() || room.roomId}`);
|
console.log(`✅ Joined room: ${room.getCanonicalRoomName() || room.roomId}`);
|
||||||
|
|
||||||
// Add message listener to this room
|
|
||||||
room.on('EventMessage', async (event, stateEvent) => {
|
room.on('EventMessage', async (event, stateEvent) => {
|
||||||
const content = event.getContent();
|
const content = event.getContent();
|
||||||
if (!content || !content.body) return;
|
if (!content || !content.body) return;
|
||||||
@@ -77,14 +74,12 @@ function loadQuotes() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
// Handle leaving the room
|
|
||||||
member.room.on('RoomMember#left', () => {
|
member.room.on('RoomMember#left', () => {
|
||||||
console.log(`ℹ️ Left room: ${member.room.getCanonicalRoomName() || member.room.roomId}`);
|
console.log(`ℹ️ Left room: ${member.room.getCanonicalRoomName() || member.room.roomId}`);
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
// Also listen to messages from all known rooms (for cases where client is already joined)
|
|
||||||
client.on('EventMessage', async (event, stateEvent) => {
|
client.on('EventMessage', async (event, stateEvent) => {
|
||||||
const room = event.sender.room;
|
const room = event.sender.room;
|
||||||
const content = event.getContent();
|
const content = event.getContent();
|
||||||
@@ -93,7 +88,6 @@ function loadQuotes() {
|
|||||||
const body = content.body.toLowerCase().trim();
|
const body = content.body.toLowerCase().trim();
|
||||||
const cmd = (process.env.BOT_COMMAND || '!quote').toLowerCase();
|
const cmd = (process.env.BOT_COMMAND || '!quote').toLowerCase();
|
||||||
|
|
||||||
// Only respond in rooms where we're a member
|
|
||||||
const roomMembers = await room.getJoinedMemberCount();
|
const roomMembers = await room.getJoinedMemberCount();
|
||||||
if (roomMembers > 0 && room.getMyMembership()) {
|
if (roomMembers > 0 && room.getMyMembership()) {
|
||||||
if (body === cmd || body.startsWith(cmd)) {
|
if (body === cmd || body.startsWith(cmd)) {
|
||||||
@@ -110,26 +104,20 @@ function loadQuotes() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
console.log('🤖 Bot is running!');
|
|
||||||
console.log(' Invite this bot to a Matrix room and type to get an Ancestor quote.\n');
|
|
||||||
|
|
||||||
} catch (err) {
|
console.log('🤖 Bot is running!');
|
||||||
console.error('Fatal error:', err.message);
|
console.log(' Invite this bot to a Matrix room and type !quote to get an Ancestor quote.\n');
|
||||||
process.exit(1);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Add global error handler to catch any unhandled errors
|
|
||||||
process.on('unhandledRejection', (reason, promise) => {
|
|
||||||
console.error('🚨 Unhandled rejection:', reason?.message || reason);
|
|
||||||
process.exit(1);
|
|
||||||
});
|
|
||||||
|
|
||||||
// Keep the process alive
|
|
||||||
setInterval(() => {}, 60000);
|
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
console.error('❌ Fatal error starting bot:', err.message);
|
console.error('❌ Fatal error starting bot:', err.message);
|
||||||
console.error(err.stack);
|
console.error(err.stack);
|
||||||
process.exit(1);
|
process.exit(1);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
process.on('unhandledRejection', (reason, promise) => {
|
||||||
|
console.error('🚨 Unhandled rejection:', reason?.message || reason);
|
||||||
|
process.exit(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
setInterval(() => {}, 60000);
|
||||||
})();
|
})();
|
||||||
|
|||||||
Reference in New Issue
Block a user