rocketchat-bot.js

require('dotenv').load();
const { driver } = require('@rocket.chat/sdk');
let BotID;
start();

async function start() {
    const rooms = process.env.ROOMS.split(",");
    console.log(`Connecting to ${process.env.HOST} with ${process.env.USER}:${process.env.PASS}`)
    await driver.connect({host:process.env.HOST,username:process.env.USER,password:process.env.PASS,rooms,});
    const bot = await driver.login({username:process.env.USER,password:process.env.PASS});
    await driver.joinRooms(rooms);
    
    await driver.subscribeToMessages();
    await driver.reactToMessages((err,res,opts) => {
        if(err) throw err;
        try {
            const args = res.msg.slice(process.env.PREFIX.length).split(" ");
            const flags = [];
            res.content = res.msg;
            delete res.msg;
            onMessage(res,args,flags,opts);
        }catch(err) {
            throw err;
        }
    });
    botID = bot;
    await driver.sendToRoom("Hello i am alive",rooms[0])
}

async function onMessage(message, args, flags, options) {
    if(message.u._id === botID) return;
    console.log("args: " + args)
    const roomname = await driver.getRoomName(message.rid);
    if(message.content.toLowerCase().startsWith(process.env.PREFIX)) {
        await driver.sendToRoom(`Hello why you use me?\nCommand: \`${args[0]}\`\nArgs: \`${args.slice(1)}\``,roomname)
    }
}