getData.js

var container = require('rhea');
const https = require('https'); // or https for secure requests

let SERVICE_ACCOUNT_ID = "CHANGE TO YOUR SERVICE ACCOUNT ID";
let CLIENT_SECRET = "CHANGE TO YOU CLIENT SECRET";
let TENANT_ID = "CHANGE TO YOUR TENANT ID";
let AMQP_URL = "amqp://CHANGE/TO/YOUR/AMQP/URL";

let token = '';
const body = 'grant_type=client_credentials&client_id='+SERVICE_ACCOUNT_ID+'&client_secret='+CLIENT_SECRET+'&scope=https://servicebus.azure.net/.default';

const options = {
  hostname: 'login.microsoftonline.com',
  port: 443, // or 443 for https
  path: '/'+TENANT_ID+'/oauth2/v2.0/token',
  method: 'POST'
};

function renew_token() {
        get_token();
}

function get_token() {

        const req = https.request(options, (res) => {
          let data = '';

          res.on('data', (chunk) => {
            data += chunk;
          });

          res.on('end', () => {
            //console.log(data);
            token = JSON.parse(data).access_token;
            //console.log(token);
            send_token();
          });
        });

        req.on('error', (e) => {
          console.error(`problem with request: ${e.message}`);
        });

        req.write(body);
        req.end();
}


//// AMQP  ////

var host = "sb-duvproddistribution.servicebus.windows.net"
var port = 5671

var sender;
var connection;
var hasAuth = false

container.sasl_server_mechanisms.enable_anonymous();
container.reconnect = false;

function amqpConnect() {
        connection = container.connect({ port: port, host: host, hostname: host,  username: SERVICE_ACCOUNT_ID, transport:'tls', reconnect:false });
        sender = connection.open_sender('$cbs');
        connection.open_receiver('$cbs');
}

function send_token() {
        sender.send({
                reply_to:'http://localhost',
                application_properties:{
                        operation:'put-token',
                        type:'jwt',
                        name:'amqps://sb-duvproddistribution.servicebus.windows.net/'+AMQP_URL.split('/')[3]

                },
                message_id:1,
                body:token
        });
        console.log('token sent');
}


container.on('connection_open', function (context) {
    console.log('We are Connected!');
});
container.on('receiver_open', function (context) {
    console.log( "receiver_open");
});
container.on('sender_open', function (context) {
    console.log('sender_open');
    if( !hasAuth) {
        renew_token();
    }
});
container.on('message', function (context) {
    //console.log('got message '+JSON.stringify(context.message));
    if(context.message.application_properties.hasOwnProperty('status-code')) {
        //CBS-message
        let code = context.message.application_properties['status-code'];
        if(code >= 200 && code < 300) {
                console.log('signin success');
                if( !hasAuth) {
                        startListening();
                        setInterval(renew_token, 900000);
                        hasAuth = true;
                }
        }
        else
                console.log('signin failed!');
    }
    else {
        console.log('\nGot message:\nApplicationProps:\n'+JSON.stringify(context.message.application_properties));
        console.log('Body:\n'+JSON.stringify(context.message.body.content.toString('HEX')));
    }
});
container.on('sendable', function (context) {
    console.log('sendable');
});

function startListening() {
        let topic = AMQP_URL.split('/')[3]+'/subscriptions/'+AMQP_URL.split('/')[4];
        console.log('subscribing to: '+topic);
        connection.open_receiver(topic);
}



amqpConnect();