squeezelite-esp32/components/wifi-manager/webapp/webpack/webpack.dev.js

/* eslint-disable  */
var path = require('path');
const bodyParser = require('body-parser')
const { config } = require('process');
const HtmlWebPackPlugin = require('html-webpack-plugin');
const { Command } = require('commander');
let  cmdLines= { };
var { parseArgsStringToArgv } = require('string-argv');
const PORT = 5000;

const data = {
    messages: require("../mock/messages.json"),
    messagequeue: require("../mock/messages.json"),
    message_queue_sequence: [],
    status_queue_sequence:[],
    message_queue_sequence_post_empty: null,
    status_queue_sequence_post_empty: null,
    commands: require("../mock/commands.json"),
    scan: require("../mock/scan.json"),
    ap: require("../mock/ap.json"),
    config: require("../mock/config.json"),
    statusdefinition: require("../mock/statusdefinition.json"),
    status: require("../mock/status.json"),
    messages_ota_fail: require("../mock/messages_ota_fail.json"),
    messages_ota_flash: require("../mock/messages_ota_flash.json"),
    messages_ota: require("../mock/messages_ota.json"),
    rebooting: false,
    reboottime: Date.now(),
    devServer:{}

};
const messagingTypes= {
	MESSAGING_INFO : 'MESSAGING_INFO',
	MESSAGING_WARNING : 'MESSAGING_WARNING',
	MESSAGING_ERROR : 'MESSAGING_ERROR'
};
const messagingClass= {
	MESSAGING_CLASS_OTA : 'MESSAGING_CLASS_OTA',
	MESSAGING_CLASS_SYSTEM : 'MESSAGING_CLASS_SYSTEM',
	MESSAGING_CLASS_STATS : 'MESSAGING_CLASS_STATS',
	MESSAGING_CLASS_CFGCMD: 'MESSAGING_CLASS_CFGCMD',
	MESSAGING_CLASS_BT: 'MESSAGING_CLASS_BT'
} ;

function rebooting(){
    let duration=10000;
    console.log(`Simulating a reboot of ${duration}ms`);
    data.reboottime = Date.now() + duration;
    data.rebooting=true;
    setTimeout(() => {  
        data.rebooting=false; 
        console.log("Reboot completed!"); 
    }, duration);
}
function sleep(milliseconds) {
    const date = Date.now();
    let currentDate = null;
    do {
      currentDate = Date.now();
    } while (currentDate - date < milliseconds);
  }
function waitForReboot(){
    while(Date.now() < data.reboottime){
        sleep(500);
        console.log(`Waiting for reboot to finish.`);
    }
}

function requeueMessages(){
    data.messagequeue = [];
    data.messagequeue.push(...data.messages);
    console.log(`Re-queued ${data.messages.length} messages. Total queue length is: ${data.messagequeue.length}`);
}
function sendMessaging(cmdname,msgtype,msgClass,msg){
    let message_txt=`${cmdname}\n${msg}`;
    var d = new Date();
    var n = d.getMilliseconds();
    data.messagequeue.push({
        message:	message_txt,
        type:	msgtype,
        class:	msgClass,
        sent_time:	n,
        current_time:	n});
    console.log(`Queued message ~${data.messagequeue.length} type ${msgtype}, class ${msgClass}: ${message_txt}`);
}
Array.prototype.filter = function(fun /*, thisp*/) {
    var len = this.length >>> 0;
    if (typeof fun != "function")
      throw new TypeError();

    var res = [];
    var thisp = arguments[1];
    for (var i = 0; i < len; i++) {
      if (i in this) {
        var val = this[i];
        if (fun.call(thisp, val, i, this))
          res.push(val);
      }
    }
    return res;
  };
for(const cmdIdx in data.commands.commands){
    const cmd = data.commands.commands[cmdIdx];
    //console.log(`Creating command structure for ${cmd.name}`);
    cmdLines[cmd.name] = {
        cmd: new Command(),
    };
    cmdLines[cmd.name].cmd
        .storeOptionsAsProperties(true)
        .name(cmd.name)
        .exitOverride();
    for(const argIdx in cmd.argtable){
        const arg=cmd.argtable[argIdx];
        const optstr=((arg.shortopts?'-'+arg.shortopts:'')+ 
        (arg.shortopts && arg.longopts?', ':'')+
        (arg.longopts?'--'+arg.longopts:'') + 
        (arg.hasvalue?`${(arg.shortopts || arg.longopts?' ':'')}<${arg.datatype.replace(/[<>]/gm,'')}>`:''));
        //console.log(`   Option: ${optstr}, Glossary: ${arg.glossary}`);
        if(arg.remark) continue;
        if(arg.mincount>0){
            cmdLines[cmd.name].cmd.requiredOption( optstr,arg.glossary);
        }
        else {
            cmdLines[cmd.name].cmd.option( optstr,arg.glossary);
        }
    }
}
const connectReturnCode = {
    UPDATE_CONNECTION_OK : 0, 
      UPDATE_FAILED_ATTEMPT : 1,
      UPDATE_USER_DISCONNECT : 2,
      UPDATE_LOST_CONNECTION : 3,
      UPDATE_FAILED_ATTEMPT_AND_RESTORE : 4
  }
module.exports ={
    entry: {
        test: './src/test.ts'
        
    },
    devServer: {
        static: {
            directory: path.resolve(__dirname, './dist'),
            staticOptions: {},
            // Don't be confused with `devMiddleware.publicPath`, it is `publicPath` for static directory
            // Can be:
            // publicPath: ['/static-public-path-one/', '/static-public-path-two/'],
            publicPath: "/",
            // Can be:
            // serveIndex: {} (options for the `serveIndex` option you can find https://github.com/expressjs/serve-index)
            serveIndex: true,
            // Can be:
            // watch: {} (options for the `watch` option you can find https://github.com/paulmillr/chokidar)
            watch: true,
          },        
        devMiddleware: {
            publicPath: "/",

          },
        open: true,
        compress: true,
        port: PORT, 
        host: '0.0.0.0',
        allowedHosts: "all",
        headers: {'Access-Control-Allow-Origin': '*',    'Accept-Encoding': 'identity'},
    client: {
        logging: "verbose",
        // Can be used only for `errors`/`warnings`
        //
        // overlay: {
        //   errors: true,
        //   warnings: true,
        // }
        overlay: true,
        progress: true,
      },
      onListening: function (devServer) {
        if (!devServer) {
          throw new Error('webpack-dev-server is not defined');
        }
  
        const PORT = devServer.server.address().port;

        // get the path to the test page
        const compiler = devServer.compiler;
        const entry = compiler.options.entry;
        const testEntry = entry['test'].import[0];
        const testPath = testEntry.replace('./src/', '').replace('.ts', '.html');
  
        // open the test page
        import('open').then((open) => open.default(`http://localhost:${PORT}/${testPath}`));
  

      },

        onBeforeSetupMiddleware: function (devServer) {
            data.devServer=devServer;
            devServer.app.use(bodyParser.json()) // for parsing application/json
            devServer.app.use(bodyParser.urlencoded({ extended: true })) // for parsing application/x-www-form-urlencoded
            devServer.app.get('/ap.json', function(req, res) {  waitForReboot(); res.json( data.ap ); });
            devServer.app.get('/scan.json', function(req, res) { waitForReboot(); res.json( data.scan ); });
            devServer.app.get('/config.json', function(req, res) { 
                waitForReboot();
                if(data.status.recovery==1 && (data.status.mock_old_recovery??'')!==''){
                    res.json( data.config.config ); 
                    console.log('Mock old recovery - return config structure without gpio');
                }
                else {
                    res.json( data.config ); 
                }
            });

            devServer.app.get('/status.json', function(req, res) { 
                waitForReboot();
                if(data.status_queue_sequence.length>0){
                    const curstatus = JSON.parse(data.status_queue_sequence_queue_sequence.shift());
                    data.status.ota_pct=curstatus.ota_pct??0;
                    data.status.ota_dsc=curstatus.ota_dsc??'';
                    console.log(`Mock firmware update @${data.status.ota_pct}%, ${data.status.ota_dsc}`)
                }
                else if (data.status_queue_sequence_post_empty){
                    data.status_queue_sequence_post_emptyy();
                    console.log(`Mock old firmware update: simulating a restart`);
                    data.status_queue_sequence_post_empty = null;
                }
                else if(data.status.ota_pct!=undefined || data.status.ota_dsc!=undefined) {
                    if(data.status.ota_pct!=undefined) delete data.status.ota_pct;
                    if(data.status.ota_dsc!=undefined) delete data.status.ota_dsc;
                }
                if(data.status.message) delete data.status.message;
                if(data.status.recovery==1 && (data.status.mock_old_recovery??'')!==''){
                    if(data.message_queue_sequence.length>0){
                        
                        const msgpayload = JSON.parse(data.message_queue_sequence.shift());
                        data.status.message = msgpayload.message??'';
                        console.log(`Mocking recovery, setting status message to ${data.status.message}`)
                    }
                    else if (data.message_queue_sequence_post_empty){
                        data.message_queue_sequence_post_empty();
                        data.message_queue_sequence_post_empty = null;
                    }
                }                                
                res.json( data.status ); 
            });
            devServer.app.get('/plugins/SqueezeESP32/firmware/-99', function(req, res) { 
                waitForReboot();
                let has_proxy=  data.status.mock_plugin_has_proxy ?? 'n';
                const statusCode='xy'.includes((has_proxy).toLowerCase())?200:500;
                console.log(`Checking if plugin has proxy enabled with option mock_plugin_has_proxy = ${data.status.mock_plugin_has_proxy}. Returning status ${statusCode} `);
                res.status(statusCode ).json(); 
            });
            devServer.app.get('/messages.json', function(req, res) { 
                waitForReboot();
                if(data.status.recovery==1 && (data.status.mock_old_recovery??'')!==''){
                    console.log('Mocking old recovery, with no commands backend' );
                    res.status(404).end(); 
                    return;
                }
                if(data.message_queue_sequence.length>0){
                    data.messagequeue.push(data.message_queue_sequence.shift());
                }
                else if (data.message_queue_sequence_post_empty){
                    data.message_queue_sequence_post_empty();
                    data.message_queue_sequence_post_empty = null;
                }
                res.json( data.messagequeue ) ; 
                data.messagequeue=[];
            });
            
            devServer.app.get('/statusdefinition.json', function(req, res) { 
                waitForReboot();
                res.json( data.statusdefinition ); 
            });
            devServer.app.get('/commands.json', function(req, res) { 
                waitForReboot();
                if(data.status.recovery==1 && (data.status.mock_old_recovery??'')!==''){
                    console.log('Mocking old recovery, with no commands backend' );
                    res.status(404).end(); 
                }
                else {
                    res.json( data.commands ); 
                }
                
            });
            devServer.app.post('/commands.json', function(req, res) { 
                waitForReboot();
                if(data.status.recovery==1 && (data.status.mock_old_recovery??'')!==''){
                    console.log('Mocking old recovery, with no commands backend' );
                    res.status(404).end(); 
                    return;
                }
                console.log(req.body.command);
                try {
                    const cmdName=req.body.command.split(" ")[0];
                    const args=parseArgsStringToArgv(req.body.command,'node ');
                    let cmd=cmdLines[cmdName].cmd;
                    if(cmd){
                        for (const property in cmd.opts()) {
                            delete cmd[property];
                        }
                        cmd.parse(args);
                        const msg=`Received Options: ${JSON.stringify(cmd.opts())}\n`;
                        console.log('Options: ', cmd.opts());
                        console.log('Remaining arguments: ', cmd.args);
                        sendMessaging(cmdName,messagingTypes.MESSAGING_INFO,messagingClass.MESSAGING_CLASS_CFGCMD,msg);
                    }                    
                } catch (error) {
                    console.error(error);
                }
                res.json( { 'Result' : 'Success' } ); 
            });
            devServer.app.post('/config.json', function(req, res) { 
                waitForReboot();
                var fwurl='';
                console.log(`Processing config.json with request body: ${req.body}`);
                console.log(data.config.config);
                for (const property in req.body.config) {
                    console.log(`${property}: ${req.body.config[property].value}`);
                    if(property=='fwurl'){
                        fwurl=req.body.config[property].value;
                    }
                    else {
                        if(data.config.config[property]=== undefined){
                            console.log(`Added config value ${property} [${req.body.config[property].value}]`);
                            data.config.config[property] = {value: req.body.config[property].value};
                        }
                        else if (data.config.config[property].value!=req.body.config[property].value){
                            console.log(`Updated config value ${property}\n     From: ${data.config.config[property].value}\n     To: ${req.body.config[property].value}]`);
                            data.config.config[property].value=req.body.config[property].value;
                        }
                    }

                  }
                res.json( {"result" : "OK" }); 
                if(fwurl!=='' ){
                    const ota_msg_list= ((data.status.mock_fail_fw_update ?? '')!=='')?data.messages_ota_fail:data.messages_ota;
                    if(data.status.recovery!=1) {
                        // we're not yet in recovery. Simulate reboot to recovery 
                        data.status.recovery=1;
                        if((data.status.mock_old_recovery??'')===''){
                            // older recovery partitions possibly aren't 
                            // sending messages
                            requeueMessages();
                        }
                        
                    }
                    
                    var targetQueue='message_queue_sequence';
                    var targetPostEmpty='message_queue_sequence_post_empty';
                    if((data.status.mock_old_recovery??'')!==''){
                            console.log('Mocking old firmware flashing mechanism.  Starting!');
                            targetQueue='status_queue_sequence';
                            targetPostEmpty='status_queue_sequence_post_empty';
                    }
                    console.log(`queuing ${ota_msg_list.length} ota messages `);
                    data[targetQueue].push(...ota_msg_list);
                    data[targetPostEmpty] = function(){
                        data.status.recovery=0;
                        requeueMessages();
                    }
                }
            });
            devServer.app.post('/status.json', function(req, res) { 
                waitForReboot();
                for (const property in req.body.status) {
                    if(data.status[property]=== undefined){
                        console.log(`Added status value ${property} [${req.body.status[property]}]`);
                        data.status[property] = {value: req.body.status[property]};
                    }
                    else if (data.status[property]!==req.body.status[property]){
                        console.log(`Updated status value ${property}\nFrom: ${data.status[property]}\nTo: ${req.body.status[property]}`);
                        data.status[property]=req.body.status[property];
                    }
                }
                res.json( {"result" : "OK" } ); 
            });            
            devServer.app.post('/connect.json', function(req, res) { 
                waitForReboot();
                setTimeout(function(r){
                if(r.body.ssid.search('fail')>=0){
                    if(data.status.ssid){
                        // in this case, the same ssid will be reused - the ESP32 would restore its previous state on failure
                        data.status.urc=connectReturnCode.UPDATE_FAILED_ATTEMPT_AND_RESTORE;
                    }
                    else {
                        data.status.urc=connectReturnCode.UPDATE_FAILED_ATTEMPT;
                    }
                }
                else {
                    data.status.ssid=r.body.ssid;
                    data.status.urc=connectReturnCode.UPDATE_CONNECTION_OK;
                }
                }, 1000, req);
                res.json( {"result" : "OK" } );
             });
            devServer.app.post('/reboot_ota.json', function(req, res) { 
                waitForReboot();
                data.status.recovery=0;
                requeueMessages();
                rebooting();
                res.json( {"result" : "OK" } ); 
            });
            devServer.app.post('/reboot.json', function(req, res) { 
                waitForReboot();
                res.json( {"result" : "OK" } ); 
                rebooting();
                requeueMessages();
            });
            devServer.app.post('/recovery.json', function(req, res) { 
                waitForReboot();
                if((data.status.mock_fail_recovery ?? '')!==''){
                    res.status(404).end(); 
                }
                else {
                    data.status.recovery=1;
                    requeueMessages();
                    rebooting();
                    res.json( {"result" : "OK" } ); 
                }                
            });
            devServer.app.post('/flash.json', function(req, res) { 
                waitForReboot();
                if(data.status.recovery>0){
                    if((data.status.mock_fail_fw_update ?? '')!=='' || (data.status.mock_old_recovery??'')!==''){
                        console.log('Old recovery mock, or fw fail requested' );
                        res.status(404).end(); 
                    }
                    else {
                        console.log(`queuing ${data.messages_ota_flash.length} flash ota messages `);
                        data.message_queue_sequence.push(...data.messages_ota_flash);
                        data.message_queue_sequence_post_empty = function(){
                            data.status.recovery=0;
                            rebooting();
                            requeueMessages();
                        }   
                        res.json({"result" : "OK" });                  
                    }
                    
                }
                else {
                    res.status(404).end(); 
                }  
            });                  
            devServer.app.delete('/connect.json', function(req, res) { 
                waitForReboot();
                data.status.ssid='';
                res.json({"result" : "OK" }); });
            devServer.app.get('/reboot', function(req, res) {
                waitForReboot();
                res.json({"result" : "OK" }); });
        },
    },
    plugins: [

        new HtmlWebPackPlugin({
            title: 'SqueezeESP32-test',
            template: './src/test.ejs',
            filename: 'test.html',
            minify: false,
            inject: 'body',
            excludeChunks: ['index','main'],
        })

    ],
}