Reworked message format, added support for audio messages, made Message class #10

Merged
snxraven merged 20 commits from MiTask/LinkUp-P2P-Chat:main into main 2024-06-14 14:15:43 -04:00
3 changed files with 28 additions and 1 deletions
Showing only changes of commit 6cbfe34966 - Show all commits

View File

@ -39,7 +39,6 @@ loadCommands().then(commands => {
// We use Event Emitter here to handle new messages // We use Event Emitter here to handle new messages
bot.on('onMessage', (peer, message) => { bot.on('onMessage', (peer, message) => {
console.log(`Message received from ${message.peerName} at ${new Date(message.timestamp).toLocaleTimeString()}: ${message.message}`); console.log(`Message received from ${message.peerName} at ${new Date(message.timestamp).toLocaleTimeString()}: ${message.message}`);
console.log(message); console.log(message);
@ -64,6 +63,8 @@ loadCommands().then(commands => {
}); });
bot.joinChatRoom(process.env.LINKUP_ROOM_ID); bot.joinChatRoom(process.env.LINKUP_ROOM_ID);
bot.fetchAvatar(`https://avatar.iran.liara.run/username?username=${this.botName}&background=f4d9b2&color=FF9800&size=40`); // Debugging avatar
}).catch(error => { }).catch(error => {
console.error('Error loading commands:', error); console.error('Error loading commands:', error);
}); });

View File

@ -5,6 +5,7 @@ import TextMessage from "./TextMessage.js";
import FileMessage from "./FileMessage.js"; import FileMessage from "./FileMessage.js";
import AudioMessage from "./AudioMessage.js"; import AudioMessage from "./AudioMessage.js";
import Message from "./Message.js"; import Message from "./Message.js";
import IconMessage from "./IconMessage.js";
class Client extends EventEmitter { class Client extends EventEmitter {
constructor(botName) { constructor(botName) {
@ -37,6 +38,12 @@ class Client extends EventEmitter {
}); });
} }
async fetchAvatar(url) {
this.botAvatar = url;
const img = await fetch(url);
this.sendMessage(IconMessage.new(this, img));
}
setupSwarm() { setupSwarm() {
this.swarm.on('connection', (peer) => { this.swarm.on('connection', (peer) => {
peer.on('data', message => { peer.on('data', message => {

View File

@ -0,0 +1,19 @@
import Message from "./Message.js";
class IconMessage extends Message {
async constructor(peerName, avatarBuffer, topic, timestamp) {
super("icon", peerName, avatarBuffer, topic, timestamp);
}
toJsonString() {
return JSON.stringify({
...this.toJson()
});
}
static new(bot, avatarBuffer) {
return new IconMessage(bot.botName, avatarBuffer, bot.currentTopic, Date.now());
}
}
export default IconMessage;