const spawn = require('child_process').spawn;
const path = require('path');
const zerorpc = require('zerorpc');
//console.log('zeropc 1 is: '+ zerorpc);

const Utils = require('./Utils.js');
//console.log(zerorpc);
//console.log('*********************************')

const TIMEOUT = 600; // in seconds (adjust as per how long your server calls can take)
const IP = '127.0.0.1';
const PORT = '4242';

class PythonConnector {
    static server() {
        if (!PythonConnector.connected) {
            console.log('PythonConnector – making a new connection to the python layer');
            PythonConnector.zerorpcProcess = spawn('python', ['-u', path.join(__dirname, 'PythonServer.py')]);
             PythonConnector.zerorpcProcess.stdout.on('data', function(data) {
            //     console.info('pythonnn:', data.toString());
            //     console.log('python:', data.toString());
            });
            // PythonConnector.zerorpcProcess.stderr.on('data', function(data) {
            //     console.error('python:', data.toString());
            // });
             PythonConnector.zerorpc = new zerorpc.Client({'timeout': TIMEOUT, 'heartbeatInterval': TIMEOUT*1000});
             PythonConnector.zerorpc.connect('tcp://' + IP + ':' + PORT);
            PythonConnector.connected = true;
        }
        return PythonConnector.zerorpc;
    }

    static async invoke(method, ...args) {
        try {
            //console.log('method is: '+ method);
            console.log('args is: '+ args);

            const zerorpc = PythonConnector.server();
            //console.log('zeropc 2 is: '+ zerorpc)
            return await Utils.promisify(zerorpc.invoke, zerorpc, method, ...args);
        }
        catch (e) {
            console.log('errorrrrrrr')
            return Promise.reject(e)
        }
    }
}

module.exports = PythonConnector;