oracle.js

process.on('unhandledRejection', error => console.log('unhandledRejection', error.message));

const prompt = require('prompt');

const DiceResultsOracle = require('./build/contracts/DiceResultsOracle.json');
const contract = require('truffle-contract');

const Web3 = require('web3');

let web3;
if (typeof web3 !== 'undefined') {
    web3 = new Web3(web3.currentProvider);
} else {
    // set the provider you want from Web3.providers
    web3 = new Web3(new Web3.providers.HttpProvider("http://localhost:8545"));
}

// Truffle abstraction to interact with our deployed contract
const oracleContract = contract(DiceResultsOracle);
oracleContract.setProvider(web3.currentProvider);

// see https://github.com/trufflesuite/truffle-contract/issues/56#issuecomment-331084530
if (typeof oracleContract.currentProvider.sendAsync !== "function") {
    oracleContract.currentProvider.sendAsync = function () {
        return oracleContract.currentProvider.send.apply(
            oracleContract.currentProvider, arguments
        );
    };
}

console.log("--------------");
console.log("Oracle started, awaiting request to fetch real world data....!");
console.log("--------------\n");

// Get accounts from web3
web3.eth.getAccounts((err, accounts) => {
    oracleContract.deployed()
        .then((oracleInstance) => {

            /**
             * Subscribe to a request to capture an off chain data
             */
            oracleInstance.CaptureRealWorldData()
                .watch((err, event) => {

                    console.log("Received request to fetch real world data....!\n");

                    /**
                     * In here we interface with the real world e.g. blockchain / Web API's / IoT / Barcode & Sensors
                     */

                    // Launch prompt
                    prompt.start();

                    // Ask the user for some data -> Oracle Data Source
                    prompt.get(['throw1', 'throw2'], (err, result) => {
                        console.log(`You threw : [${result.throw1}] + [${result.throw2}]`);

                        // Update the Oracle - providing the real world value
                        // Same account which created the contract is the one who is resulting it
                        oracleInstance.setResult(result.throw1, result.throw2, {from: accounts[0]})
                    });
                });
        })
        .catch((err) => console.log(err));
}).catch((err) => console.log(err));