start.js

'use strict';

const
    Stratum = require('./libs/class.Stratum'),
    ChainParams = require('./libs/const.ChainParams');

const stratum = new Stratum({
    chainParams: ChainParams.REGTEST, // Use ChainParams.MAIN for main net, ChainParams.TESTNET for testnet
    coinbaseAddress: 'TC6qME2GhepR7656DgsR72pkQDmhfTDbtV',
    blockBrand: '/@mintpond/ref-stratum/',
    host: "0.0.0.0",
    port: {
        number: 3000,
        diff: 10
    },
    rpc: {
        host: '127.0.0.1',
        port: 8888,
        user: 'rpcuser',
        password: 'x'
    },
    jobUpdateInterval: 55,
    blockPollIntervalMs: 250
});

stratum.init();

stratum.on(Stratum.EVENT_CLIENT_CONNECT, ev => {
    console.log(`Client connected: ${ev.client.socket.remoteAddress}`);
});

stratum.on(Stratum.EVENT_CLIENT_DISCONNECT, ev => {
    console.log(`Client disconnected: ${ev.client.socket.remoteAddress} ${ev.reason}`);
});

stratum.on(Stratum.EVENT_SHARE_SUBMITTED, ev => {
    if (ev.share.isValidBlock) {
        console.log(`Valid block submitted by ${ev.share.client.workerName}`)
    }
    else if (ev.share.isValidShare) {
        console.log(`Valid share submitted by ${ev.share.client.workerName}`)
    }
    else {
        console.log(`Invalid share submitted by ${ev.share.client.workerName} ${ev.share.error.message}`)
    }
});

// Make sure Error can be JSON serialized
if (!Error.prototype.toJSON) {
    Error.prototype.toJSON = function () {
        const jsonObj = {};

        Object.getOwnPropertyNames(this).forEach(key => {
            jsonObj[key] = this[key];
        }, this);

        return jsonObj;
    }
}