IOTA Toll System

const Iota = require('@iota/core');

const iota = Iota.composeAPI({
provider: 'https://nodes.devnet.iota.org:443'
});


const vehicleSeed = 'VEHICLESEED';     // vehicle seed
const tollSeed = 'TOLLSEED';     // toll seed

const main = async () => {

  const receivingAddress = await iota.getNewAddress(tollSeed, {
    index: 2,
    total: 1
  });


  const transfers = [
    {
      value: 500,
      address: receivingAddress[0],
      tag: 'PAYTOLL'
    }
  ];


  console.log('Sending 500i to ' + receivingAddress);

  try {
    const trytes = await iota.prepareTransfers(vehicleSeed, transfers);

    const response = await iota.sendTrytes(trytes, 3, 9);

    console.log('Bundle sent');

    response.map(tx => console.log(tx));
  } catch (error) {
    console.log(error);
  }
}



main();

const createHttpClient = require('@iota/http-client').createHttpClient;
const createGetAccountData = require('@iota/core').createGetAccountData


const client = new createHttpClient({

    // replace with your IRI node address 
    // or connect to a Devnet node for testing: 'https://nodes.devnet.iota.org:443'

    provider: 'https://nodes.devnet.iota.org:443'
    //provider: 'http://localhost:14265'

})


const seed = 'PUEOTSEITFEVEWCWBTSIZM9NKRGJEIMXTULBACGFRQK9IMGICLBKW9TTEVSDQMGWKBXPVCBMMCXWMNPDX';
const tollSeed = '';
const vehicleSeed = '';

function getAccountData(seed) {
    const getAccountData = createGetAccountData(client)

    getAccountData(seed, { start: 0, end: 30, security: 2})
        .then(accountData => {
            const { addresses, inputs, transactions, balance } = accountData;
            console.log(addresses, inputs, transactions, balance);
        })
        .catch(error => {})
}






//getAccountData(seed)


var myArgs = process.argv.slice(2);
console.log('myArgs: ', myArgs);

switch (myArgs[0]) {
case 'toll':
    console.log('>>> toll wallet <<<')
    getAccountData(tollSeed)
    break;
case 'vehicle':
    console.log('>>> vehicle wallet <<<')
    getAccountData(vehicleSeed)
    break;
default:
    console.log('>>> vehicle wallet <<<')
    getAccountData(vehicleSeed)
}

const express = require('express')
const app = express()
const port = 9000

const turnled = require('./turn-led.js');
const paytoll = require('./pay-toll.js');

app.get('/', (req, res) => res.send('Hello IOTA!'))
app.get('/on', (req, res) => { res.send('Hello IOTA! on!'); turnled.run(true); } )
app.get('/off', (req, res) => { res.send('Hello IOTA! off!'); turnled.run(false); } )
app.get('/paytoll', (req, res) => { res.send('Hello IOTA! pay toll!'); paytoll.run(); } )

app.listen(port, () => console.log(`IOTA app listening on port ${port}!`))

const { createAccount }  = require('@iota/account')
const CDA = require('@iota/cda');

const turnled = require('./turn-led.js');

// Connect to a node;

const provider = 'https://nodes.devnet.iota.org:443';


const magnetLink = 'iota://PD9QTKAADVXT9QIGZAMAHPFIODAONVGVKHWRRZSQONJKCSDQKX9YVCN9GFELLIWMIEHLLQEOVLXN9PURBVROCHWZRF/?timeout_at=1576203208650&multi_use=1';
const { address, timeoutAt, multiUse, expectedAmount } = CDA.parseCDAMagnet(magnetLink);

console.log('Sending to:', address, timeoutAt, multiUse, expectedAmount);

const seed = 'VEHICLESEED';     // vehicle seed

const account = createAccount({
    seed,
    provider
});


function run() {

const cda = account.generateCDA({
    timeoutAt: Date.now() + 24 * 60 * 60 * 1000
})
.then(cda => {
    account.sendToCDA({
        address,
        timeoutAt,
        multiUse,
        expectedAmount,
        value: 150
})
.then((trytes) => {
    console.log('Successfully prepared transaction trytes:', trytes)

    turnled.run(true)
})
})

}   // end run function


module.exports = {
    run: function(o) { run(o) }
  }

var CryptoJS = require("crypto-js");

var hubname= 'IOTHUBNAME';
var expiresinmins = '60';
var signingkey = 'POLICYKEY';   // policy shared access key
var policyname = 'iothubowner';


function run(o) {
var resourceUri = encodeURIComponent(hubname + '.azure-devic.net'); 
var expiry = Math.ceil((Date.now() / 1000) + expiresinmins * 60); 
var uriExpiry = resourceUri + '\n' + expiry; 
var decodedKey = CryptoJS.enc.Base64.parse(signingkey); 
var signature = CryptoJS.HmacSHA256(uriExpiry, decodedKey); 
var encodedUri = encodeURIComponent(CryptoJS.enc.Base64.stringify(signature)); 


var token = "SharedAccessSignature sr=" + resourceUri + "&sig=" + encodedUri + "&se=" + expiry;

token += "&skn="+ policyname;



console.log("Shared Access Signature:" + token);

var myArgs = process.argv.slice(2);

console.log('myArgs[0]: ', myArgs[0]);
console.log('o: ', o);




var unirest = require("unirest");


var req = unirest("PATCH", "https://IOTHUBNAME.azure-devices.net/twins/DEVICENAME");


req.query({

  "api-version": "2018-06-30"

});



req.headers({

  "Authorization": token,

  "Content-Type": "application/json"

});



req.type("json");

req.send({

  "properties": {

    "desired": {

      "userLedRed": o 
      //"userLedRed": myArgs[0] == 'true'

    }

  }

});



req.end(function (res) {

  if (res.error) throw new Error(res.error);



  console.log(res.body);

});

} // end run function

module.exports = {
  run: function(o) { run(o) }
}

const { createAccount }  = require('@iota/account')

// Connect to a node;

const provider = 'https://nodes.devnet.iota.org:443';

//const seed = 'TOLLSYSTEMTOLLSYSTEMTOLLSYSTEMTOLLSYSTEMTOLLSYSTEMTOLLSYSTEMTOLLSYSTEMAAAAAAAAAAA';

const tollSeed = '';
const vehicleSeed = '';


function getTotalBalance(seed) {
    let account = createAccount({
        seed,
        provider
    });

    account.getTotalBalance()
    .then(balance => console.log(balance))    
}


var myArgs = process.argv.slice(2);
console.log('myArgs: ', myArgs);

switch (myArgs[0]) {
case 'toll':
    console.log('>>> toll wallet <<<')
    getTotalBalance(tollSeed)
    break;
case 'vehicle':
    console.log('>>> vehicle wallet <<<')
    getTotalBalance(vehicleSeed)
    break;
default:
    console.log('>>> vehicle wallet <<<')
    getTotalBalance(vehicleSeed)
}

const CDA = require('@iota/cda');
const { createAccount }  = require('@iota/account')


//const seed = 'PUEOTSEITFEVEWCWBTSIZM9NKRGJEIMXTULBACGFRQK9IMGICLBKW9TTEVSDQMGWKBXPVCBMMCXWMNPDX';
let seed = '';     // toll seed


// Connect to a node;

const provider = 'https://nodes.devnet.iota.org:443';

const account = createAccount({
      seed,
      provider

});

const cda = account
    .generateCDA({
        timeoutAt: Date.now() + 100 * 24 * 60 * 60 * 1000,     // expires in 100 days
        multiUse: true
    });


cda.then((cda) => {
    const magnetLink = CDA.serializeCDAMagnet(cda);
    // iota://MBREWACWIPRFJRDYYHAAME…AMOIDZCYKW/?timeout_at=1548337187&multi_use=1

    console.log(magnetLink);

});

const Gpio = require('onoff').Gpio;
const led = new Gpio(17, 'out');
const button = new Gpio(2, 'in', 'rising', {debounceTimeout: 10});

var request = require('request');


button.watch((err, value) => {
  if (err) {
    throw err;
  }

  led.writeSync(led.readSync() ^ 1);

  request
    .get('http://192.168.2.99:9000/paytoll')
    .on('error', function(err) {
      console.log(err)
    })

});

process.on('SIGINT', () => {
  led.unexport();
  button.unexport();
});