release.js

#! /usr/bin/env node

const { exec, execSync } = require('child_process');
const os = require('os');
const axios = require('axios');
const http = require('http');
const fs = require('fs');
const child_process = require('child_process');
const { createHttpTerminator } = require('http-terminator');

if (process.argv.length < 5) {
    console.error(`This script requires three arguments (and one optional): 
        first - either dev (for development execution), prod-test (for production test), or prod (for production release),
        second - the token, 
        third - either "upload" or "server" to upload directly  to dataset service, or start  a server and send the address respectively
        fourth - optional arg is the IP of the selected interface.
        `);
    process.exit(1);
}

const release = process.argv[2];
const token = process.argv[3];
const meth = process.argv[4];
const selectedIp = process.argv[5];
const dsServer =  require(`./config-${release}.json`).datasetService;
let server = null;
let ip = null;
if (meth === "server") {
    const networkInterfaces = os.networkInterfaces();
    //console.log(networkInterfaces);
    // Connections that use a local address
    const localAddr = new Set(["127", "192"]);
    let interf = Object.values(networkInterfaces).flat().filter(e => e.internal === false 
        && e.family === 'IPv4' && !localAddr.has(e.address.substring(0, 3)));
    if (selectedIp) {
        console.log(`Searching for your own provided IP '${selectedIp}'...`);
        interf = interf.filter(e => e.address === selectedIp);
    }
    if (interf.length !== 1) {
        console.error(interf);
        throw new Error("too many or too few interfaces left after filtering, pass the IP of the network you want to use via the cmd arguments");
    }
    ip = interf[0].address;
    console.log(`Uploading from IP ${ip}`);

// const pyServerProc = exec('python3 -m http.server 3005', (err, stdout, stderr) => {
//     if (err) {
//       //some err occurred
//       console.error(err)
//     } else {
//      // the *entire* stdout and stderr (buffered)
//      console.log(`python server stdout: ${stdout}`);
//      console.log(`python server stderr: ${stderr}`);
//     }
//   });
//pyServerProc.stdout.on('data', data =>  console.log(data));


    server = http.createServer(function (req, response) {
        fs.readFile(`${__dirname}/build/build.zip`, function(error, content) {
            response.writeHead(200, { 'Content-Type': "application/zip" });
            response.end(content, 'utf-8');
        });
    }).listen(3005);
}
try {
    let res = child_process.spawnSync("bash",
        ["-c", 
        `cd ${__dirname} \
        && npm run build-${release} \
        && cd build \
        && zip -r ./build.zip ./*`
    ]
        , {
            stdio: 'inherit',
            encoding: 'utf-8'
        });
        console.log('status: ' + res.status);
        let data = null;
        let url = `${dsServer}/set-ui`;
        let  headers = { 
            devToken: token
        }
        if (meth === "server") {
            data = `http://${ip}:3005/build/build.zip`;
            
        } else if (meth === "upload") {
            data = new FormData();
            data.append("zip", new Blob([fs.readFileSync(`${__dirname}/build/build.zip`)]), "build.zip");
            url += "?method=fileInBody";
            headers['content-type'] = 'multipart/form-data';
        } else {
            throw new Error(`method '${meth}' not handled`);
        }
        
    var config = {
            method: 'post',
            url,
            headers,
            maxContentLength: Infinity,
            maxBodyLength: Infinity,
            data
            };
            
        axios(config)
            .then(function (response) {
                console.log(JSON.stringify(response.data));
            })
            .catch(function (error) {
                console.log(error);
            })
            .finally(() => {          
                if  (meth === "server") {    
                    console.log("Stopping py server");
                    //pyServerProc.kill();
                    const httpTerminator = createHttpTerminator({
                        server,
                    });
                    
                    httpTerminator.terminate();
                }
            });
} catch (e) {
    console.error(e);
}