563 lines
22 KiB
JavaScript
563 lines
22 KiB
JavaScript
const v = require('vec3')
|
|
let mcData
|
|
|
|
let cfg = {}
|
|
let bot = {}
|
|
// bot.chatAddPattern(new RegExp(`^hi|hello ${bot.username}`, "i"), 'greet', "General greeting")
|
|
|
|
function todo() {
|
|
cfg.quiet && console.warn("not implemented") || bot.chat("not implemented yet")
|
|
}
|
|
|
|
function checkBlockExists(name) {
|
|
if (mcData.blocksByName[name] === undefined) {
|
|
bot.chat(`${name} is not a block name`)
|
|
return false
|
|
} else {
|
|
return true
|
|
}
|
|
}
|
|
function checkItemExists(name) {
|
|
if (mcData.itemsByName[name] === undefined) {
|
|
bot.chat(`${name} is not an item name`)
|
|
return false
|
|
} else {
|
|
return true
|
|
}
|
|
}
|
|
|
|
const events = {
|
|
whisper: function command_whisper(username, _botusername, message, ...history) {
|
|
if ([bot.username, "me"].includes(username)) return // whisper back from server (afk msges, etc)
|
|
if (/^gossip/.test(message)) return
|
|
if (username === cfg.admin) {
|
|
console.info("whispered command", _botusername, message)
|
|
message = message.replace("\\", "@")
|
|
if (message.startsWith(cfg.botAddressPrefix)) {
|
|
command(username, message)
|
|
} else {
|
|
bot.chat(message)
|
|
// bot.chat("/" + message)
|
|
}
|
|
} else {
|
|
bot.whisper(cfg.admin, `gossip ${username}: ${message}`)
|
|
console.info(username, "whispered", _botusername, message)
|
|
}
|
|
}
|
|
, chat: command
|
|
, kicked: function rejoin(reason, loggedIn) {
|
|
console.warn(reason, loggedIn && "logged_in")
|
|
if (reason.extra && reason.extra[0].text === "Server closed") {
|
|
bot.quit()
|
|
bot.end()
|
|
// TODO implement all startup features (maybe refactor all into a single function / module?)
|
|
setTimeout((bot, cfg) => {
|
|
bot = mineflayer.createBot(cfg.botOptions)
|
|
}, 15 * 60 * 1000, bot, cfg);
|
|
}
|
|
}
|
|
// , message: systemMessage
|
|
, messagestr: function systemMessageStr(...args) { console.log("cmd msgstr:", ...args) }
|
|
, "chat:web": commandWeb
|
|
}
|
|
|
|
function systemMessage(...args) {
|
|
if (args[0]?.text) return
|
|
const metadata = (args[0]?.extra || args[0]?.with)?.map(v => v.text)
|
|
console.log(
|
|
"cmd msg:",
|
|
args[0]?.text || args[0]?.translate,
|
|
args[0]?.extra?.length || args[0]?.with?.length || Object.keys(args[0]?.json).length - 1,
|
|
metadata.length > 0 && metadata || args[0],
|
|
args.slice(1)
|
|
)
|
|
}
|
|
|
|
function commandWeb([[mode, username, message]]) {
|
|
// console.log("web msg:", mode, username, message)
|
|
message && command(username, message)
|
|
}
|
|
|
|
function _clientSystemMessage(...args) {
|
|
console.log("cmd chat:", args[0]?.message, args[0]?.extra?.length, args[0]?.extra, args[0], args.slice(1))
|
|
}
|
|
|
|
const events_registered = []
|
|
|
|
function command(username, message) {
|
|
// TODO better name, maybe an array?
|
|
cfg.botAddressPrefix = cfg.botAddressPrefix || "!"
|
|
|
|
function fuzzyRespond(responses, probability = 1, timeout = 1) {
|
|
if (Math.random() < probability) {
|
|
const response = responses[Math.floor(Math.random() * responses.length)]
|
|
return setTimeout(() => bot.chat(response), timeout * Math.random() * 1000)
|
|
}
|
|
}
|
|
|
|
function swingArm(swung = 3) {
|
|
if (swung > 0) {
|
|
setTimeout(swingArm, 500 * Math.random(), --swung)
|
|
bot.swingArm()
|
|
}
|
|
}
|
|
|
|
if (username === bot.username && !message.startsWith(cfg.botAddressPrefix)) return
|
|
|
|
const player = bot.players[username] ? bot.players[username].entity : null
|
|
|
|
if (message.startsWith("zzz")) {
|
|
bot.chat("/afk")
|
|
cfg.plugins.sleeper.sleep()
|
|
// if(cfg)
|
|
return
|
|
}
|
|
|
|
|
|
if (message.startsWith(cfg.botAddressPrefix) || cfg.botAddressRegex.test(message)) {
|
|
message = cfg.botAddressRegex.test(message) ? cfg.botAddressRegex.exec(message)[1] : message
|
|
console.log(message)
|
|
// remove `!`
|
|
message = message.startsWith(cfg.botAddressPrefix) ? message.slice(cfg.botAddressPrefix.length) : message
|
|
|
|
// TODO command dispatchEvent, for aliases
|
|
function subcommand(message) {
|
|
const message_parts = message.split(/\s+/)
|
|
|
|
switch (message_parts[0]) {
|
|
case "stop":
|
|
bot.pathfinder && bot.pathfinder.setGoal(null)
|
|
bot.stopDigging()
|
|
bot.chat("ok")
|
|
break;
|
|
|
|
case "mute":
|
|
case "quiet":
|
|
case "silent":
|
|
cfg.quiet = !cfg.quiet
|
|
cfg.quiet || bot.chat(`ok, ${cfg.quiet ? "" : "not "}being ${message_parts[0]}`)
|
|
break;
|
|
// case "follow":
|
|
// // if(username === cfg.admin)
|
|
// cfg.stateMachines.follow.transitions[4].trigger()
|
|
// // cfg.stateMachines.follow.transitions[1].trigger()
|
|
// break;
|
|
// case "stay":
|
|
// // if(username === cfg.admin)
|
|
// cfg.stateMachines.follow.transitions[3].trigger()
|
|
// break;
|
|
case "echo":
|
|
// bot.chat(message_parts[1])
|
|
// bot.chat(message.slice(1))
|
|
cfg.quiet && bot.whisper(username, message) || bot.chat(message)
|
|
break;
|
|
case "autosleep":
|
|
case "sleep":
|
|
message_parts[1] = message_parts[0] == "autosleep" ? "auto" : message_parts[1]
|
|
switch (message_parts[1]) {
|
|
case "auto":
|
|
cfg.sleep.auto = !cfg.sleep.auto
|
|
bot.chat(`ok, ${cfg.sleep.auto ? "" : "not "}auto sleeping`)
|
|
bot.chat("/afk")
|
|
break;
|
|
case "silent":
|
|
case "quiet":
|
|
cfg.sleep.quiet = !cfg.sleep.quiet
|
|
bot.chat(`ok, ${cfg.sleep.quiet ? "" : "not "}sleeping quietly`)
|
|
break;
|
|
case "timeout":
|
|
if (!message_parts[2]) {
|
|
bot.chat(`sleeping every ${Math.round(cfg.sleep.timeout / 60 / 1000)}mins`)
|
|
return
|
|
}
|
|
const timeout = parseFloat(message_parts[2], 10)
|
|
if (timeout) {
|
|
cfg.sleep.timeout = timeout * 60 * 1000
|
|
cfg.sleep.timeoutFn = null
|
|
cfg.plugins.sleeper.sleep(true) //reset timer
|
|
bot.chat(`ok, next sleep attempt in ${timeout}mins`)
|
|
break;
|
|
}
|
|
default:
|
|
bot.chat(`usage: !sleep [auto | quiet | timeout <mins>], or zzz for manual sleep`)
|
|
break;
|
|
}
|
|
break; //todo; needed?
|
|
case "zzz":
|
|
cfg.plugins.sleeper.sleep()
|
|
case "afk":
|
|
bot.chat("/afk")
|
|
break;
|
|
case "awaken":
|
|
case "wake":
|
|
case "wakeup":
|
|
cfg.plugins.sleeper.wake()
|
|
break;
|
|
case "autoeat":
|
|
case "eat":
|
|
switch (message_parts[1]) {
|
|
case "auto":
|
|
cfg.eat.auto = !cfg.eat.auto
|
|
bot.chat(`ok, ${cfg.eat.auto ? "" : "not "}auto eating `)
|
|
break;
|
|
case "at":
|
|
case "set":
|
|
const amount = parseInt(message_parts[2], 10)
|
|
if (amount < 20 && amount > 0) {
|
|
cfg.eat.startAt = amount
|
|
cfg.eat.quiet || bot.chat(`ok, eating when hunger at ${amount}`)
|
|
}
|
|
break
|
|
case "silent":
|
|
case "quiet":
|
|
cfg.eat.quiet = !!!cfg.eat.quiet
|
|
break;
|
|
default:
|
|
cfg.plugins.eater.eat((err) => { if (err) { bot.chat(err.message) } })
|
|
// bot.chat(`usage: !sleep [auto | quiet | timeout <mins>], or zzz for manual sleep`)
|
|
break;
|
|
}
|
|
break;
|
|
|
|
case "follow":
|
|
switch (message_parts.length) {
|
|
case 1:
|
|
subcommand("go follow me")
|
|
break;
|
|
|
|
default:
|
|
subcommand("go " + message)
|
|
break;
|
|
}
|
|
break;
|
|
case "come":
|
|
switch (message_parts[1]) {
|
|
case "close":
|
|
case "closer":
|
|
subcommand("go follow close")
|
|
break
|
|
case "up":
|
|
case "down":
|
|
cfg.plugins.mover.moveY(player.position)
|
|
break
|
|
default:
|
|
subcommand("go follow once")
|
|
}
|
|
break;
|
|
case "ride":
|
|
case "mount":
|
|
cfg.plugins.mover.command(message_parts)
|
|
break
|
|
case "unride":
|
|
case "getoff":
|
|
case "unmount":
|
|
case "dismount":
|
|
bot.dismount()
|
|
bot.vehicle = void 0
|
|
break
|
|
case "move":
|
|
case "go":
|
|
cfg.plugins.mover.command(message_parts.slice(1), player)
|
|
break;
|
|
|
|
case "attack":
|
|
case "rage":
|
|
case "ragemode":
|
|
case "guard":
|
|
switch (message_parts.length) {
|
|
case 1:
|
|
if (!player) {
|
|
bot.chat("can't see you.")
|
|
return
|
|
}
|
|
bot.chat('for glory!')
|
|
cfg.plugins.guard.guardArea(player.position)
|
|
break
|
|
case 2:
|
|
switch (message_parts[1]) {
|
|
case "self":
|
|
cfg.guard.self = !cfg.guard.self
|
|
bot.chat(`ok, ${cfg.guard.self ? "no longer being altruistic" : "self sacrifice!"}`)
|
|
return;
|
|
case "stop":
|
|
cfg.plugins.guard.stopGuarding()
|
|
bot.chat('no longer guarding this area.')
|
|
return;
|
|
|
|
default:
|
|
break;
|
|
}
|
|
default:
|
|
bot.chat("don't know wym")
|
|
}
|
|
// entity = new BehaviorGetClosestEntity(bot, bot.nearestEntity(), a => EntityFilters().MobsOnly(a))
|
|
// if (entity) {
|
|
// bot.attack(entity, true)
|
|
// } else {
|
|
// bot.chat('no nearby entities')
|
|
// }
|
|
// // bot.attack(new BehaviorGetClosestEntity(bot, {}, EntityFilters().MobsOnly()))
|
|
break;
|
|
case "find":
|
|
switch (message_parts.length) {
|
|
case 2:
|
|
cfg.plugins.finder.findBlocks(message_parts[1])
|
|
break
|
|
|
|
default:
|
|
break;
|
|
}
|
|
break
|
|
// TODO move look (and maybe find) to informer plugin?
|
|
case "look":
|
|
case "lookat":
|
|
// const coords = v(message_parts.splice(1))
|
|
switch (message_parts.length) {
|
|
case 1:
|
|
bot.lookAt(bot.nearestEntity().position)
|
|
break
|
|
case 2:
|
|
switch (message_parts[1]) {
|
|
case "me":
|
|
if (player) {
|
|
bot.lookAt(player.position.offset(0, 1, 0))
|
|
} else {
|
|
cfg.quiet || bot.chat("can't see you")
|
|
}
|
|
break;
|
|
|
|
case "this":
|
|
// TODO lookat the block the user is looking at
|
|
// Currently looks player position
|
|
if (player) {
|
|
bot.lookAt(player.position)
|
|
} else {
|
|
cfg.quiet || bot.chat("can't see you")
|
|
}
|
|
break
|
|
default:
|
|
const aPlayer = bot.players[message_parts[2]] ? bot.players[message_parts[2]].entity : null
|
|
if (aPlayer) bot.lookAt(aPlayer.position.offset(0, 1, 0))
|
|
break;
|
|
}
|
|
break
|
|
case 3:
|
|
todo()
|
|
// bot.lookAt({})
|
|
break
|
|
case 4:
|
|
//TODO more checks
|
|
bot.lookAt(v(message_parts.splice(1)))
|
|
break
|
|
default:
|
|
break
|
|
}
|
|
break
|
|
case "info":
|
|
cfg.plugins.informer.command(message_parts.splice(1), player)
|
|
break
|
|
// case "use":
|
|
// bot.useOn(bot.nearestEntity())
|
|
// break;
|
|
|
|
// // TODO move all inventory related tasks into inventory.js
|
|
case "craft":
|
|
cfg.plugins.inventory.craftItem(message_parts[1])
|
|
break
|
|
// case "give":
|
|
// // switch (message_parts[1]) {
|
|
// // case "hand":
|
|
// // case "right":
|
|
// // break;
|
|
// // case "left":
|
|
// // break;
|
|
// // // case "slot":
|
|
// // default:
|
|
// // let slot = parseInt(message_parts[1])
|
|
// // if (!isNaN(slot)) {
|
|
|
|
// // } else {
|
|
|
|
// // }
|
|
// // break;
|
|
// // }
|
|
// // break;
|
|
// case "take":
|
|
// // TODO take only what's requested, then throw all the rest
|
|
// // TODO take all
|
|
|
|
// TODO move subcommands to cfg.plugins.inventory.itemByName
|
|
case "toss":
|
|
case "drop":
|
|
if (!message_parts[1]) { return false } // FIXME, works but ugly
|
|
if (!mcData.findItemOrBlockByName(message_parts[1])) {
|
|
console.log("doesn't exist:", message_parts[1])
|
|
cfg.quiet || bot.chat(`item doesn't exist: ${message_parts[1]}`)
|
|
return false
|
|
}
|
|
const item = cfg.plugins.inventory.itemByName(message_parts[1])
|
|
if (!item) {
|
|
console.log("don't have:", message_parts[1])
|
|
cfg.quiet || bot.chat(`don't have item: ${message_parts[1]}`)
|
|
return false
|
|
}
|
|
switch (message_parts.length) {
|
|
case 2:
|
|
bot.tossStack(
|
|
item,
|
|
(err) => {
|
|
if (err) {
|
|
console.error(err)
|
|
cfg.quiet || bot.chat(err.message)
|
|
}
|
|
}
|
|
)
|
|
break
|
|
case 3:
|
|
const amount = parseInt(message_parts[2])
|
|
bot.toss(
|
|
item.type,
|
|
null, //metadata
|
|
amount,
|
|
(err) => {
|
|
if (err) {
|
|
console.error(err)
|
|
cfg.quiet || bot.chat(err.message)
|
|
}
|
|
}
|
|
)
|
|
break
|
|
default:
|
|
break
|
|
}
|
|
break;
|
|
case "sm":
|
|
case "step":
|
|
cfg.plugins.statemachine?.command?.(
|
|
message_parts[0] == "sm" ? message_parts.slice(1) : message_parts, player
|
|
)
|
|
// TODO refactor into plugin detection and command exec function
|
|
// safecommand(plugin_name, message_parts, player)
|
|
// message_parts includes command?
|
|
|| bot.chat("statemachine plugin not loaded")
|
|
break
|
|
case "location":
|
|
// TODO put in /lib/location
|
|
switch (message_parts[1]) {
|
|
case "add":
|
|
case "record":
|
|
|
|
break;
|
|
|
|
default:
|
|
break;
|
|
}
|
|
case "where":
|
|
case "where?":
|
|
// TODO put in /lib/location
|
|
console.log(bot.entity.position)
|
|
if (cfg.mods.includes(username)) //anarchy
|
|
bot.chat(
|
|
bot.game.dimension.split(":", 2)[1].replace("_", " ")
|
|
+ " " + bot.entity.position.floored().toString()
|
|
)
|
|
break;
|
|
case "warp":
|
|
// if (message_parts[1] == "spawn")
|
|
// if (cfg.mods.includes(username)) //anarchy
|
|
bot.chat("/" + message)
|
|
break;
|
|
|
|
default:
|
|
if (cfg.mods.includes(username))
|
|
bot.chat("/" + message)
|
|
break;
|
|
|
|
}
|
|
}
|
|
subcommand(message)
|
|
} else {
|
|
// TODO, maybe extract to a new function `fuzzychat`?, so can address direct messages
|
|
switch (message) {
|
|
case "wassup":
|
|
case "what's cooking":
|
|
case "what's new":
|
|
case "what's up":
|
|
case "whats cooking":
|
|
case "whats new":
|
|
case "whats up":
|
|
case "sup":
|
|
case "suh":
|
|
fuzzyRespond([
|
|
"jus chilin", "nothin", "random stuff"
|
|
], 0.3, 3)
|
|
case "hi":
|
|
case "hey":
|
|
case "hello":
|
|
case "ola":
|
|
case "howdy":
|
|
case "heyo":
|
|
case "yo":
|
|
if (player) bot.lookAt(player.position.offset(0, 1, 0))
|
|
|
|
// TODO sneak
|
|
// function swingArm() {
|
|
// if (swung > 0) {
|
|
// setTimeout(swing, 500 * Math.random())
|
|
// bot.p()
|
|
// swung--
|
|
// }
|
|
// }
|
|
|
|
setTimeout(swingArm, 1000, 4) // or sneak greating
|
|
return
|
|
case "F":
|
|
return fuzzyRespond(["F"], 0.9, 1)
|
|
case "RIP":
|
|
return fuzzyRespond(["F", "oh no"], 0.3, 2)
|
|
case "69":
|
|
case "cool":
|
|
Math.random() < 0.5 && bot.chat("nice!")
|
|
return
|
|
case "awesome":
|
|
case "superb":
|
|
case "nice":
|
|
case "nice!":
|
|
return fuzzyRespond(["cool", "very nice!"], 0.3, 5)
|
|
case "good bot":
|
|
return fuzzyRespond(["thanks", "why, thank you!", ":)", "(:", "you're too kind!"], 1, 5)
|
|
case "bad bot":
|
|
case "not nice":
|
|
return fuzzyRespond([":(", "):", "sorry"], 0.1, 10)
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
const load = (config) => {
|
|
cfg = config
|
|
bot = cfg.bot
|
|
|
|
mcData = bot.mcData || (bot.mcData = require('minecraft-data')(bot.version))
|
|
for (const [key, fn] of Object.entries(events)) {
|
|
events_registered.push(
|
|
bot.on(key, fn)
|
|
)
|
|
}
|
|
|
|
// bot._client.on("chat", _clientSystemMessage)
|
|
}
|
|
|
|
const unload = () => {
|
|
console.log("events_registered:", events_registered.length, "of", bot._eventsCount)
|
|
for (const [key, fn] of Object.entries(events)) {
|
|
bot.off(key, fn)
|
|
events_registered.shift()
|
|
}
|
|
console.log("events_registered:", bot._eventsCount)
|
|
|
|
// bot._client.off("chat", _clientSystemMessage)
|
|
}
|
|
|
|
module.exports = { load, unload, events_registered, command } |