style: 🎨 fix crlf -> lf for real this time, using .gitattributes

Add a .gitattributes file to permanentyl fix crlf issues. For explanantion: https://adaptivepatchwork.com/2012/03/01/mind-the-end-of-your-line/#the-new-system
refactor: ♻️ replace add with vec3.offset
2021-03-24 15:07:45 +05:00 · 2021-03-24 00:40:54 +05:00 · 2021-03-23 23:10:58 +05:00
6 changed files with 525 additions and 513 deletions
--- a/.gitattributes
+++ b/.gitattributes
@ -0,0 +1,16 @@
+# See this article for reference: https://help.github.com/articles/dealing-with-line-endings/
+# Refreshing repo after line ending change:
+# https://help.github.com/articles/dealing-with-line-endings/#refreshing-a-repository-after-changing-line-endings
+
+# Handle line endings automatically for files detected as text
+# and leave all files detected as binary untouched.
+* text=auto
+
+#
+# The above will handle all files NOT found below
+#
+# These files are text and should be normalized (Convert crlf => lf)
+# Use lf as eol for these files
+*.js    text eol=lf
+*.ts    text eol=lf
+*.json  text eol=lf
--- a/.gitignore
+++ b/.gitignore
@ -1,31 +1,31 @@
-# See https://help.github.com/articles/ignoring-files/ for more about ignoring files.
-
-# dependencies
-/node_modules
-/.pnp
-.pnp.js
-
-# testing
-/coverage
-
-# production
-/build
-/data
-
-# misc
-.DS_Store
-.env
-.env.local
-.env.development.local
-.env.test.local
-.env.production.local
-/lib/**/*.old
-/lib/**/*.bak
-
-npm-debug.log*
-yarn-debug.log*
-yarn-error.log*
-
-# Editor
-*.swp
+# See https://help.github.com/articles/ignoring-files/ for more about ignoring files.
+
+# dependencies
+/node_modules
+/.pnp
+.pnp.js
+
+# testing
+/coverage
+
+# production
+/build
+/data
+
+# misc
+.DS_Store
+.env
+.env.local
+.env.development.local
+.env.test.local
+.env.production.local
+/lib/**/*.old
+/lib/**/*.bak
+
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+
+# Editor
+*.swp
 *.swo
--- a/lib/index.js
+++ b/lib/index.js
@ -88,7 +88,6 @@ fs.watch('./lib/plugins', reloadplugin)
 cfg.bot = bot
 // TODO better name, or switch to array
 cfg.botAddressPrefix = '!'
-cfg.botAddressRegex = new RegExp(`^${bot.username} (${cfg.botAddressPrefix}.+)`)
 cfg.quiet = true


@ -110,6 +109,7 @@ bot.once("spawn", () => {
    }

    cfg.plugins = plugins
+    cfg.botAddressRegex = new RegExp(`^${bot.username} (${cfg.botAddressPrefix}.+)`)

    for (const plugin of Object.values(plugins)) {
        try {
--- a/lib/plugins/command.js
+++ b/lib/plugins/command.js
@ -30,11 +30,10 @@ const events = {
    whisper: function command_whisper(username, message) {
        if ([bot.username, "me"].includes(username)) return
        if (/^gossip/.test(message)) return
-        // if (/^!/.test(message) && username === cfg.admin){
        if (username === cfg.admin) {
            message = message.replace("\\", "@")
            console.info("whispered command", message)
-            if (/^!/.test(message)) {
+            if (message.startsWith(cfg.botAddressPrefix)) {
                command(username, message)
            } else {
                bot.chat(message)
@ -297,7 +296,7 @@ function command(username, message) {
                            switch (message_parts[1]) {
                                case "me":
                                    if (player) {
-                                        bot.lookAt((new v.Vec3(0, 1, 0)).add(player.position))
+                                        bot.lookAt(player.position.offset(0, 1, 0))
                                    } else {
                                        cfg.quiet || bot.chat("can't see you")
                                    }
@ -314,7 +313,7 @@ function command(username, message) {
                                    break
                                default:
                                    const aPlayer = bot.players[message_parts[2]] ? bot.players[message_parts[2]].entity : null
-                                    if (aPlayer) bot.lookAt((new v.Vec3(0, 1, 0)).add(aPlayer.position))
+                                    if (aPlayer) bot.lookAt(aPlayer.position.offset(0, 1, 0))
                                    break;
                            }
                            break
@ -475,7 +474,7 @@ function command(username, message) {
            case "howdy":
            case "heyo":
            case "yo":
-                if (player) bot.lookAt((new v.Vec3(0, 1, 0)).add(player.position))
+                if (player) bot.lookAt(player.position.offset(0, 1, 0))

                // TODO sneak
                // function swingArm() {
--- a/lib/plugins/guard.js
+++ b/lib/plugins/guard.js
@ -71,9 +71,7 @@ function lookForMobs() {
        bot.pvp.attack(entityEnemy)
    } else if (entityEnemy) {
        bot.lookAt(
-            // (new v.Vec3(0, 1, 0)).add(
            entityEnemy.position
-            // )
        )
        cfg.quiet || bot.chat("AH! A creeper! They creep me out!")
    }
--- a/lib/plugins/statemachine.js
+++ b/lib/plugins/statemachine.js
@ -1,476 +1,475 @@
-// import { createMachine, interpret, InterpreterStatus } from "xstate";
-const { createMachine, interpret, InterpreterStatus } = require('xstate');
-// import { access, mkdir, writeFile, readFile } from "fs";
-const { access, mkdir, writeFile, readFile } = require('fs');
-const v = require('vec3'); // for look dummy action, maybe not needed in future
-// ANGRAM_PREFIX='MINECRAFT'
-const { MINECRAFT_DATA_FOLDER } = process.env || require("dotenv-packed").parseEnv().parsed;
-const storage_dir = MINECRAFT_DATA_FOLDER || './data/' + "/sm/";
-// import { createBot } from "mineflayer"
-// let { pathfinder, Movements, goals } = require('mineflayer-pathfinder')
-// let cfg
-// let bot = createBot({ username: 'statebot' })
-let bot;
-let quiet;
-let updateRate = 20;
-const machines = {
-    list: {},
-    running: {},
-};
-let webserver;
-let cfg = {
-    statemachine: {
-        webserver: null,
-        // quiet: true,
-        quiet: quiet,
-        list: {},
-        running: {},
-        draft: null,
-        recent: null,
-        // debug: null,
-        debug: true,
-        updateRate: updateRate
-    }
-    // FIXME temp variables to satisfy typescript autocomplete
-    // , quiet: null
-    ,
-    bot: bot,
-    plugins: { statemachine: null }
-};
-// Edit your machine(s) here
-function init(smName = "dummy", webserver) {
-    access(storage_dir, err => {
-        if (err?.code === 'ENOENT') {
-            mkdir(storage_dir, e => e && console.warn("sm init: create dir", e));
-        }
-        else if (err) {
-            console.warn("sm init: create dir", err);
-        }
-    });
-    // const machine = newSM(smName)
-    // machine.states.idle.on.TOGGLE = "start"
-    // machine.states.start.on.TOGGLE = "idle"
-    const machine = createMachine({
-        id: smName,
-        initial: "idle",
-        states: {
-            idle: {
-                on: { TOGGLE: "start", NEXT: "start", PREV: "look", STOP: "finish" }
-            },
-            start: {
-                on: { TOGGLE: "look", NEXT: "look", PREV: "idle" },
-                entry: 'lookAtPlayerOnce',
-            },
-            look: {
-                on: { TOGGLE: "idle", NEXT: "idle", PREV: "start" },
-                // entry: ['look', 'blah']
-                // entry: 'lookAtPlayerOnce',
-                activities: 'lookAtPlayer',
-                meta: { debug: true }
-            },
-            finish: {
-                type: 'final'
-            },
-        },
-        on: { START: '.start', STOP: '.idle' },
-        meta: { debug: true },
-        context: { player: null, rate: updateRate },
-    }, {
-        actions: {
-            // action implementation
-            lookAtPlayerOnce: (context, event) => {
-                const player = context?.player || bot.nearestEntity(entity => entity.type === 'player');
-                if (player.position || player.entity) {
-                    context.player = player;
-                    bot.lookAt((new v.Vec3(0, 1, 0)).add((player.entity || player).position));
-                }
-            }
-        },
-        activities: {
-            lookAtPlayer: (context, event) => {
-                const player = context?.player || bot.nearestEntity(entity => entity.type === 'player');
-                // TODO  check every event?
-                if (player.position || player.entity) {
-                    context.player = player;
-                    function looks() {
-                        bot.lookAt((new v.Vec3(0, 1, 0)).add((player.entity || player).position));
-                    }
-                    bot.on("time", looks);
-                    return () => bot.off("time", looks);
-                }
-            }
-        },
-        delays: {
-            /* ... */
-        },
-        guards: {
-            /* ... */
-        },
-        services: {
-            /* ... */
-        }
-    });
-    console.log("sm init: machine", machine);
-    const service = runSM(saveSM(machine));
-    if (service?.send) {
-        setTimeout(service.send, 200, "TOGGLE");
-        // setTimeout(service.send, 400, "TOGGLE")
-    }
-    else {
-        console.warn("sm init: service", service);
-    }
-}
-function newSM(smName = "sm_" + Object.keys(cfg.statemachine.list).length) {
-    smName = smName.replace(/\s+/, '_');
-    if (cfg.statemachine.list[smName]) {
-        console.warn("sm exists", smName);
-        quiet || bot.chat(`sm ${smName} already exists, edit or use another name instead`);
-        return;
-    }
-    const machine = createMachine({
-        id: smName,
-        initial: "start",
-        // TODO use history states for PAUSE and RESUME
-        states: { idle: { on: { START: "start" } }, start: { on: { STOP: "idle" } } }
-    });
-    cfg.statemachine.draft = machine;
-    return machine;
-}
-function saveSM(machine = cfg.statemachine.draft) {
-    if (!machine?.id) {
-        console.warn("sm save: invalid", machine);
-        quiet || bot.chat("sm: couldn't save, invalid");
-        return;
-    }
-    // TODO do tests and validation
-    // 1. ensure default states [start, idle]
-    // 2. ensure closed cycle from start to idle
-    cfg.statemachine.list[machine.id] = machine;
-    if (machine.id === cfg.statemachine.draft?.id) {
-        cfg.statemachine.draft = null;
-    }
-    writeFile(
-        // TODO
-        // `${storage_dir}/${player}/${machine.id}.json`
-        `${storage_dir}/${machine.id}.json`,
-        // TODO decide which data to store
-        // https://xstate.js.org/docs/guides/states.html#persisting-state
-        // JSON.stringify(machine.toJSON),
-        // JSON.stringify(machine.states.toJSON), // + activities, delays, etc
-        JSON.stringify({ config: machine.config, context: machine.context }), e => e && console.log("sm load sm: write file", e));
-    // return run ? runSM(machine) : machine
-    return machine;
-}
-function loadSM(name, run = true) {
-    //: StateMachine<any, any, any> {
-    readFile(
-        // readFileSync(
-        // TODO
-        // `${storage_dir}/${player}/${machine.id}.json`
-        `${storage_dir}/${name}.json`, afterRead
-        // JSON.stringify(machine.toJSON),
-    );
-    function afterRead(err, jsonString) {
-        if (err) {
-            console.warn("sm load sm: read file", err);
-            return;
-        }
-        else {
-            const machine = createMachine(JSON.parse(jsonString).config);
-            // TODO do tests and validation
-            // 1. ensure default states [start, idle]
-            // 2. ensure closed cycle from start to idle
-            cfg.statemachine.list[machine.id] = machine;
-            if (machine.id === cfg.statemachine.draft?.id) {
-                cfg.statemachine.draft = machine;
-            }
-            if (run) {
-                runSM(machine);
-            }
-        }
-    }
-    // return run ? runSM(machine) : machine
-    // return machine
-}
-// function isInterpreter(SMorService: StateMachine<any, any, any> | Interpreter<any>): SMorService is Interpreter<any> {
-//   return (SMorService as Interpreter<any>).start !== undefined;
-// }
-function getSM(name = cfg.statemachine.draft || cfg.statemachine.recent, asService = false, quiet = false) {
-    const machine = typeof name === "string" ? cfg.statemachine.list[name]
-        : name;
-    if (!machine) {
-        console.warn("sm get: doesn't exist", name);
-        cfg.statemachine.quiet || bot.chat(`sm ${name} doesn't exist`);
-        return;
-    }
-    if (asService) {
-        const service = cfg.statemachine.running[machine?.id];
-        if (!service) {
-            quiet || console.warn("sm get: already stopped", machine);
-            quiet || cfg.statemachine.quiet || bot.chat(`sm ${machine?.id} isn't running`);
-            return interpret(machine);
-        }
-        return service;
-    }
-    else {
-        // return machine.machine ? machine.machine : machine
-        return machine;
-    }
-}
-function runSM(name = getSM(undefined, undefined, true), player // or supervisor?
-    , restart = false) {
-    if (!name)
-        return;
-    const service = getSM(name, true, true);
-    if (!service)
-        return;
-    const machine = service.machine;
-    if (!machine)
-        return;
-    switch (service.status) {
-        case InterpreterStatus.Running:
-            if (!restart) {
-                console.warn("sm run: already running", service.id);
-                quiet || bot.chat(`sm ${service.id} already running`);
-                return service;
-            }
-            stopSM(machine);
-        case InterpreterStatus.NotStarted:
-        case InterpreterStatus.Stopped:
-            break;
-        default:
-            console.warn("sm run: unknown status:", service.status, service);
-            return;
-            break;
-    }
-    if (cfg.statemachine.debug || machine.meta?.debug) {
-        service.onTransition((state) => {
-            quiet || bot.chat(`sm trans: ${machine.id}, ${state.value}`);
-            quiet || state.meta?.debug && bot.chat(`sm next events: ${machine.id}, ${state.nextEvents}`);
-            console.log("sm debug: trans", state.value, state);
-        }).onDone((done) => {
-            quiet || bot.chat(`sm done: ${machine.id}, ${done}`);
-            console.log("sm debug: done", done.data, done);
-        });
-    }
-    cfg.statemachine.running[machine.id] = service;
-    cfg.statemachine.recent = machine;
-    service.start();
-    // // TODO check if idle state is different (maybe?)
-    console.log("sm run", service.state.value === machine.initialState.value, service.state);
-    console.log("sm run", service.state !== machine.initialState, machine.initialState);
-    // return machine
-    return service;
-}
-function stopSM(name = getSM(), quiet = false) {
-    let service = getSM(name, true, quiet);
-    if (!service)
-        return;
-    const machine = service.machine;
-    switch (service.status) {
-        case InterpreterStatus.NotStarted:
-        case InterpreterStatus.Stopped:
-            console.log("sm stop status", service.status, service.id, cfg.statemachine.running[service.id]);
-        // TODO check if any bugs
-        case InterpreterStatus.Running:
-            break;
-        default:
-            console.warn("sm stop: unknown status:", service.status);
-            break;
-    }
-    service?.stop?.();
-    cfg.statemachine.running[machine.id] = null;
-    delete cfg.statemachine.running[machine.id];
-    // return machine
-    return service;
-}
-function actionSM(action, name = getSM()) {
-    if (!action) {
-        return console.warn("sm action", action);
-    }
-    let service = getSM(name, true, true);
-    if (service.status !== InterpreterStatus.Running)
-        return;
-    // const machine = service.machine
-    service.send(action.toLowerCase());
-}
-function stepSM(command = "", ...message_parts) {
-    let service = getSM(undefined, true);
-    if (!service)
-        return;
-    if (!service.send) {
-        console.warn("sm step: can't send", service.machine);
-        // TODO start a temporary service to interpret
-        quiet || bot.chat("sm: step doesn't support machines that aren't running yet");
-        return;
-    }
-    if (service?.status !== InterpreterStatus.Running) {
-        console.warn("sm step: machine not running, attempting start", service);
-        runSM;
-    }
-    // const machine = service.machine
-    switch (command) {
-        case "edit":
-            // maybe `edit <type>`, like `add`?
-            // where type:
-            // context
-            // action
-            // timeout | all timeout
-            break;
-        case "undo":
-            break;
-        case "del":
-            break;
-        case "p":
-        case "prev":
-            service?.send("PREV");
-            break;
-        case "add":
-        // maybe `add <type>`?
-        // where type:
-        // context
-        // action
-        // timeout
-        case "new":
-            break;
-        // case "with":
-        //   console.log(this)
-        //   stepSM(getSM(message_parts[0], true, true), ...message_parts.slice(1))
-        //   break;
-        case "help":
-            quiet || bot.chat("![sm ]step [ p(rev) | n(ext) ]");
-            break;
-        case "n":
-        case "next":
-        default:
-            service?.send("NEXT");
-            quiet || bot.chat("stepped");
-            break;
-    }
-}
-function tickSM(time = bot.time.timeOfDay, rate = 20) {
-    if (time % rate !== 0) {
-        return;
-    }
-    console.log("sm tick", rate, time);
-}
-function debugSM(name = getSM()) {
-    if (!name)
-        return;
-    let service = getSM(name, true);
-    if (!service)
-        return;
-    const machine = service.machine;
-    machine.meta.debug = !!!machine.meta.debug;
-    console.info("sm debug", machine.meta, service, machine);
-    cfg.statemachine.quiet || machine.meta.debug && bot.chat("sm debug: " + machine.id);
-}
-function command(message_parts) {
-    const message_parts2 = message_parts.slice(1);
-    switch (message_parts[0]) {
-        case "add":
-            command(["new"].concat(message_parts2));
-            break;
-        case "finish":
-        case "done":
-        case "end":
-            command(["save"].concat(message_parts2));
-            break;
-        case "do":
-        case "load":
-        case "start":
-            command(["run"].concat(message_parts2));
-            break;
-        case "debug":
-            switch (message_parts[1]) {
-                case "sm":
-                case "global":
-                case "meta":
-                    cfg.statemachine.debug = !!!cfg.statemachine.debug;
-                    quiet || bot.chat(`sm debug: ${cfg.statemachine.debug}`);
-                    break;
-            }
-        case "new":
-        case "save":
-        case "run":
-        case "step":
-        case "stop":
-        // temp
-        case "action":
-            switch (message_parts2.length) {
-                case 0:
-                    console.warn(`sm ${message_parts[0]}: no name, using defaults`);
-                case 1:
-                    // FIXME `this` doesn't work always
-                    (this.runSM && this || cfg.plugins.statemachine)[message_parts[0] + "SM"](...message_parts2);
-                    break;
-                default:
-                    if (["action"].includes(message_parts[0])) {
-                        (this.runSM && this || cfg.plugins.statemachine)[message_parts[0] + "SM"](...message_parts2);
-                    }
-                    else {
-                        console.warn(`sm ${message_parts[0]}: more than 1 arg passed`, message_parts2);
-                    }
-                    break;
-            }
-            break;
-        case "undo":
-            break;
-        case "list":
-        case "status":
-            // TODO current/recent, updateRate
-            const { list, running } = cfg.statemachine;
-            console.log("sm list", running, list);
-            quiet || bot.chat(`${Object.keys(running).length} of ${Object.keys(list).length} active: ${Object.keys(running)}`
-                + (message_parts[1] === "all" ? `${Object.keys(list)}` : ''));
-            break;
-        case "quiet":
-            quiet = cfg.statemachine.quiet = !!!cfg.statemachine.quiet;
-            quiet || bot.chat(`sm: ${cfg.statemachine.quiet ? "" : "not "}being quiet`);
-            break;
-        default:
-            // TODO general helper from declarative commands object
-            quiet || bot.chat(`sm help: !sm [new | step| save | run | list | quiet | debug]`);
-            console.warn("sm unknown command", message_parts);
-            break;
-    }
-    return true;
-}
-function load(config) {
-    webserver = cfg.statemachine.webserver = config.statemachine?.webserver || webserver;
-    config.statemachine = cfg.statemachine || {
-        webserver: null,
-        // quiet: true,
-        quiet: false,
-        list: {},
-        running: {},
-        draft: null,
-        recent: null,
-        // debug: null,
-        debug: true,
-        updateRate: updateRate
-    };
-    cfg = config;
-    bot = cfg.bot;
-    // pathfinder = bot.pathfinder || bot.loadPlugin(require('mineflayer-pathfinder').pathfinder)
-    // mcData = bot.mcData || (bot.mcData = require('minecraft-data')(bot.version))
-    init(undefined, webserver);
-    updateRate = cfg.statemachine.updateRate || updateRate;
-    bot.on('time', tickSM);
-    // bot.once('time', tickSM, 5)
-    console.log("sm load", cfg.statemachine);
-}
-function unload() {
-    const { list, running } = cfg.statemachine;
-    bot.off('time', tickSM);
-    Object.keys(running).forEach(sm => {
-        stopSM(sm);
-    });
-    // delete cfg.statemachine;
-    cfg.statemachine = null;
-    console.log("sm unload: deleted", cfg.statemachine);
-}
-module.exports = {
-    load, unload, command, init,
-    newSM, saveSM, loadSM, runSM, stopSM, actionSM, stepSM, debugSM
+// import { createMachine, interpret, InterpreterStatus } from "xstate";
+const { createMachine, interpret, InterpreterStatus } = require('xstate');
+// import { access, mkdir, writeFile, readFile } from "fs";
+const { access, mkdir, writeFile, readFile } = require('fs');
+// ANGRAM_PREFIX='MINECRAFT'
+const { MINECRAFT_DATA_FOLDER } = process.env || require("dotenv-packed").parseEnv().parsed;
+const storage_dir = MINECRAFT_DATA_FOLDER || './data/' + "/sm/";
+// import { createBot } from "mineflayer"
+// let { pathfinder, Movements, goals } = require('mineflayer-pathfinder')
+// let cfg
+// let bot = createBot({ username: 'statebot' })
+let bot;
+let quiet;
+let updateRate = 20;
+const machines = {
+    list: {},
+    running: {},
+};
+let webserver;
+let cfg = {
+    statemachine: {
+        webserver: null,
+        // quiet: true,
+        quiet: quiet,
+        list: {},
+        running: {},
+        draft: null,
+        recent: null,
+        // debug: null,
+        debug: true,
+        updateRate: updateRate
+    }
+    // FIXME temp variables to satisfy typescript autocomplete
+    // , quiet: null
+    ,
+    bot: bot,
+    plugins: { statemachine: null }
+};
+// Edit your machine(s) here
+function init(smName = "dummy", webserver) {
+    access(storage_dir, err => {
+        if (err?.code === 'ENOENT') {
+            mkdir(storage_dir, e => e && console.warn("sm init: create dir", e));
+        }
+        else if (err) {
+            console.warn("sm init: create dir", err);
+        }
+    });
+    // const machine = newSM(smName)
+    // machine.states.idle.on.TOGGLE = "start"
+    // machine.states.start.on.TOGGLE = "idle"
+    const machine = createMachine({
+        id: smName,
+        initial: "idle",
+        states: {
+            idle: {
+                on: { TOGGLE: "start", NEXT: "start", PREV: "look", STOP: "finish" }
+            },
+            start: {
+                on: { TOGGLE: "look", NEXT: "look", PREV: "idle" },
+                entry: 'lookAtPlayerOnce',
+            },
+            look: {
+                on: { TOGGLE: "idle", NEXT: "idle", PREV: "start" },
+                // entry: ['look', 'blah']
+                // entry: 'lookAtPlayerOnce',
+                activities: 'lookAtPlayer',
+                meta: { debug: true }
+            },
+            finish: {
+                type: 'final'
+            },
+        },
+        on: { START: '.start', STOP: '.idle' },
+        meta: { debug: true },
+        context: { player: null, rate: updateRate },
+    }, {
+        actions: {
+            // action implementation
+            lookAtPlayerOnce: (context, event) => {
+                const player = context?.player || bot.nearestEntity(entity => entity.type === 'player');
+                if (player.position || player.entity) {
+                    context.player = player;
+                    bot.lookAt((player.entity || player).position.offset(0, 1, 0));
+                }
+            }
+        },
+        activities: {
+            lookAtPlayer: (context, event) => {
+                const player = context?.player || bot.nearestEntity(entity => entity.type === 'player');
+                // TODO  check every event?
+                if (player.position || player.entity) {
+                    context.player = player;
+                    function looks() {
+                        bot.lookAt((player.entity || player).position.offset(0, 1, 0));
+                    }
+                    bot.on("time", looks);
+                    return () => bot.off("time", looks);
+                }
+            }
+        },
+        delays: {
+            /* ... */
+        },
+        guards: {
+            /* ... */
+        },
+        services: {
+            /* ... */
+        }
+    });
+    console.log("sm init: machine", machine);
+    const service = runSM(saveSM(machine));
+    if (service?.send) {
+        setTimeout(service.send, 200, "TOGGLE");
+        // setTimeout(service.send, 400, "TOGGLE")
+    }
+    else {
+        console.warn("sm init: service", service);
+    }
+}
+function newSM(smName = "sm_" + Object.keys(cfg.statemachine.list).length) {
+    smName = smName.replace(/\s+/, '_');
+    if (cfg.statemachine.list[smName]) {
+        console.warn("sm exists", smName);
+        quiet || bot.chat(`sm ${smName} already exists, edit or use another name instead`);
+        return;
+    }
+    const machine = createMachine({
+        id: smName,
+        initial: "start",
+        // TODO use history states for PAUSE and RESUME
+        states: { idle: { on: { START: "start" } }, start: { on: { STOP: "idle" } } }
+    });
+    cfg.statemachine.draft = machine;
+    return machine;
+}
+function saveSM(machine = cfg.statemachine.draft) {
+    if (!machine?.id) {
+        console.warn("sm save: invalid", machine);
+        quiet || bot.chat("sm: couldn't save, invalid");
+        return;
+    }
+    // TODO do tests and validation
+    // 1. ensure default states [start, idle]
+    // 2. ensure closed cycle from start to idle
+    cfg.statemachine.list[machine.id] = machine;
+    if (machine.id === cfg.statemachine.draft?.id) {
+        cfg.statemachine.draft = null;
+    }
+    writeFile(
+        // TODO
+        // `${storage_dir}/${player}/${machine.id}.json`
+        `${storage_dir}/${machine.id}.json`,
+        // TODO decide which data to store
+        // https://xstate.js.org/docs/guides/states.html#persisting-state
+        // JSON.stringify(machine.toJSON),
+        // JSON.stringify(machine.states.toJSON), // + activities, delays, etc
+        JSON.stringify({ config: machine.config, context: machine.context }), e => e && console.log("sm load sm: write file", e));
+    // return run ? runSM(machine) : machine
+    return machine;
+}
+function loadSM(name, run = true) {
+    //: StateMachine<any, any, any> {
+    readFile(
+        // readFileSync(
+        // TODO
+        // `${storage_dir}/${player}/${machine.id}.json`
+        `${storage_dir}/${name}.json`, afterRead
+        // JSON.stringify(machine.toJSON),
+    );
+    function afterRead(err, jsonString) {
+        if (err) {
+            console.warn("sm load sm: read file", err);
+            return;
+        }
+        else {
+            const machine = createMachine(JSON.parse(jsonString).config);
+            // TODO do tests and validation
+            // 1. ensure default states [start, idle]
+            // 2. ensure closed cycle from start to idle
+            cfg.statemachine.list[machine.id] = machine;
+            if (machine.id === cfg.statemachine.draft?.id) {
+                cfg.statemachine.draft = machine;
+            }
+            if (run) {
+                runSM(machine);
+            }
+        }
+    }
+    // return run ? runSM(machine) : machine
+    // return machine
+}
+// function isInterpreter(SMorService: StateMachine<any, any, any> | Interpreter<any>): SMorService is Interpreter<any> {
+//   return (SMorService as Interpreter<any>).start !== undefined;
+// }
+function getSM(name = cfg.statemachine.draft || cfg.statemachine.recent, asService = false, quiet = false) {
+    const machine = typeof name === "string" ? cfg.statemachine.list[name]
+        : name;
+    if (!machine) {
+        console.warn("sm get: doesn't exist", name);
+        cfg.statemachine.quiet || bot.chat(`sm ${name} doesn't exist`);
+        return;
+    }
+    if (asService) {
+        const service = cfg.statemachine.running[machine?.id];
+        if (!service) {
+            quiet || console.warn("sm get: already stopped", machine);
+            quiet || cfg.statemachine.quiet || bot.chat(`sm ${machine?.id} isn't running`);
+            return interpret(machine);
+        }
+        return service;
+    }
+    else {
+        // return machine.machine ? machine.machine : machine
+        return machine;
+    }
+}
+function runSM(name = getSM(undefined, undefined, true), player // or supervisor?
+    , restart = false) {
+    if (!name)
+        return;
+    const service = getSM(name, true, true);
+    if (!service)
+        return;
+    const machine = service.machine;
+    if (!machine)
+        return;
+    switch (service.status) {
+        case InterpreterStatus.Running:
+            if (!restart) {
+                console.warn("sm run: already running", service.id);
+                quiet || bot.chat(`sm ${service.id} already running`);
+                return service;
+            }
+            stopSM(machine);
+        case InterpreterStatus.NotStarted:
+        case InterpreterStatus.Stopped:
+            break;
+        default:
+            console.warn("sm run: unknown status:", service.status, service);
+            return;
+            break;
+    }
+    if (cfg.statemachine.debug || machine.meta?.debug) {
+        service.onTransition((state) => {
+            quiet || bot.chat(`sm trans: ${machine.id}, ${state.value}`);
+            quiet || state.meta?.debug && bot.chat(`sm next events: ${machine.id}, ${state.nextEvents}`);
+            console.log("sm debug: trans", state.value, state);
+        }).onDone((done) => {
+            quiet || bot.chat(`sm done: ${machine.id}, ${done}`);
+            console.log("sm debug: done", done.data, done);
+        });
+    }
+    cfg.statemachine.running[machine.id] = service;
+    cfg.statemachine.recent = machine;
+    service.start();
+    // // TODO check if idle state is different (maybe?)
+    console.log("sm run", service.state.value === machine.initialState.value, service.state);
+    console.log("sm run", service.state !== machine.initialState, machine.initialState);
+    // return machine
+    return service;
+}
+function stopSM(name = getSM(), quiet = false) {
+    let service = getSM(name, true, quiet);
+    if (!service)
+        return;
+    const machine = service.machine;
+    switch (service.status) {
+        case InterpreterStatus.NotStarted:
+        case InterpreterStatus.Stopped:
+            console.log("sm stop status", service.status, service.id, cfg.statemachine.running[service.id]);
+        // TODO check if any bugs
+        case InterpreterStatus.Running:
+            break;
+        default:
+            console.warn("sm stop: unknown status:", service.status);
+            break;
+    }
+    service?.stop?.();
+    cfg.statemachine.running[machine.id] = null;
+    delete cfg.statemachine.running[machine.id];
+    // return machine
+    return service;
+}
+function actionSM(action, name = getSM()) {
+    if (!action) {
+        return console.warn("sm action", action);
+    }
+    let service = getSM(name, true, true);
+    if (service.status !== InterpreterStatus.Running)
+        return;
+    // const machine = service.machine
+    service.send(action.toLowerCase());
+}
+function stepSM(command = "", ...message_parts) {
+    let service = getSM(undefined, true);
+    if (!service)
+        return;
+    if (!service.send) {
+        console.warn("sm step: can't send", service.machine);
+        // TODO start a temporary service to interpret
+        quiet || bot.chat("sm: step doesn't support machines that aren't running yet");
+        return;
+    }
+    if (service?.status !== InterpreterStatus.Running) {
+        console.warn("sm step: machine not running, attempting start", service);
+        runSM;
+    }
+    // const machine = service.machine
+    switch (command) {
+        case "edit":
+            // maybe `edit <type>`, like `add`?
+            // where type:
+            // context
+            // action
+            // timeout | all timeout
+            break;
+        case "undo":
+            break;
+        case "del":
+            break;
+        case "p":
+        case "prev":
+            service?.send("PREV");
+            break;
+        case "add":
+        // maybe `add <type>`?
+        // where type:
+        // context
+        // action
+        // timeout
+        case "new":
+            break;
+        // case "with":
+        //   console.log(this)
+        //   stepSM(getSM(message_parts[0], true, true), ...message_parts.slice(1))
+        //   break;
+        case "help":
+            quiet || bot.chat("![sm ]step [ p(rev) | n(ext) ]");
+            break;
+        case "n":
+        case "next":
+        default:
+            service?.send("NEXT");
+            quiet || bot.chat("stepped");
+            break;
+    }
+}
+function tickSM(time = bot.time.timeOfDay, rate = 20) {
+    if (time % rate !== 0) {
+        return;
+    }
+    console.log("sm tick", rate, time);
+}
+function debugSM(name = getSM()) {
+    if (!name)
+        return;
+    let service = getSM(name, true);
+    if (!service)
+        return;
+    const machine = service.machine;
+    machine.meta.debug = !!!machine.meta.debug;
+    console.info("sm debug", machine.meta, service, machine);
+    cfg.statemachine.quiet || machine.meta.debug && bot.chat("sm debug: " + machine.id);
+}
+function command(message_parts) {
+    const message_parts2 = message_parts.slice(1);
+    switch (message_parts[0]) {
+        case "add":
+            command(["new"].concat(message_parts2));
+            break;
+        case "finish":
+        case "done":
+        case "end":
+            command(["save"].concat(message_parts2));
+            break;
+        case "do":
+        case "load":
+        case "start":
+            command(["run"].concat(message_parts2));
+            break;
+        case "debug":
+            switch (message_parts[1]) {
+                case "sm":
+                case "global":
+                case "meta":
+                    cfg.statemachine.debug = !!!cfg.statemachine.debug;
+                    quiet || bot.chat(`sm debug: ${cfg.statemachine.debug}`);
+                    break;
+            }
+        case "new":
+        case "save":
+        case "run":
+        case "step":
+        case "stop":
+        // temp
+        case "action":
+            switch (message_parts2.length) {
+                case 0:
+                    console.warn(`sm ${message_parts[0]}: no name, using defaults`);
+                case 1:
+                    // FIXME `this` doesn't work always
+                    (this.runSM && this || cfg.plugins.statemachine)[message_parts[0] + "SM"](...message_parts2);
+                    break;
+                default:
+                    if (["action"].includes(message_parts[0])) {
+                        (this.runSM && this || cfg.plugins.statemachine)[message_parts[0] + "SM"](...message_parts2);
+                    }
+                    else {
+                        console.warn(`sm ${message_parts[0]}: more than 1 arg passed`, message_parts2);
+                    }
+                    break;
+            }
+            break;
+        case "undo":
+            break;
+        case "list":
+        case "status":
+            // TODO current/recent, updateRate
+            const { list, running } = cfg.statemachine;
+            console.log("sm list", running, list);
+            quiet || bot.chat(`${Object.keys(running).length} of ${Object.keys(list).length} active: ${Object.keys(running)}`
+                + (message_parts[1] === "all" ? `${Object.keys(list)}` : ''));
+            break;
+        case "quiet":
+            quiet = cfg.statemachine.quiet = !!!cfg.statemachine.quiet;
+            quiet || bot.chat(`sm: ${cfg.statemachine.quiet ? "" : "not "}being quiet`);
+            break;
+        default:
+            // TODO general helper from declarative commands object
+            quiet || bot.chat(`sm help: !sm [new | step| save | run | list | quiet | debug]`);
+            console.warn("sm unknown command", message_parts);
+            break;
+    }
+    return true;
+}
+function load(config) {
+    webserver = cfg.statemachine.webserver = config.statemachine?.webserver || webserver;
+    config.statemachine = cfg.statemachine || {
+        webserver: null,
+        // quiet: true,
+        quiet: false,
+        list: {},
+        running: {},
+        draft: null,
+        recent: null,
+        // debug: null,
+        debug: true,
+        updateRate: updateRate
+    };
+    cfg = config;
+    bot = cfg.bot;
+    // pathfinder = bot.pathfinder || bot.loadPlugin(require('mineflayer-pathfinder').pathfinder)
+    // mcData = bot.mcData || (bot.mcData = require('minecraft-data')(bot.version))
+    init(undefined, webserver);
+    updateRate = cfg.statemachine.updateRate || updateRate;
+    bot.on('time', tickSM);
+    // bot.once('time', tickSM, 5)
+    console.log("sm load", cfg.statemachine);
+}
+function unload() {
+    const { list, running } = cfg.statemachine;
+    bot.off('time', tickSM);
+    Object.keys(running).forEach(sm => {
+        stopSM(sm);
+    });
+    // delete cfg.statemachine;
+    cfg.statemachine = null;
+    console.log("sm unload: deleted", cfg.statemachine);
+}
+module.exports = {
+    load, unload, command, init,
+    newSM, saveSM, loadSM, runSM, stopSM, actionSM, stepSM, debugSM
 };
Author	SHA1	Message	Date
jay	aded1e4193	style: 🎨 fix crlf -> lf for real this time, using .gitattributes Add a .gitattributes file to permanentyl fix crlf issues. For explanantion: https://adaptivepatchwork.com/2012/03/01/mind-the-end-of-your-line/#the-new-system	2021-03-24 15:07:45 +05:00
jay	60394e38eb	refactor: ♻️ replace `add` with `vec3.offset` This avoids having to import and creat a `new vec3.v()`	2021-03-24 00:40:54 +05:00
jay	22490f7ec1	fix(command): 🐛 fix bot address regex returning undefined Waits till spawn to make sure `bot.username` is definitely initialized	2021-03-23 23:10:58 +05:00