var jsforce = require('jsforce'),
    util = require('util'),
    fs = require('fs');

var username = '<your username>';
var password = '<your password>';

var conn = new jsforce.Connection({
    loginUrl: 'https://login.salesforce.com',
    version: '48.0',
});

conn.login(username, password, function (err, userInfo) {
    console.log('>login');
    if (err) {
        return console.error(err);
    }
    console.log('token:' + conn.accessToken);
    console.log('url:' + conn.instanceUrl);
    // logged in user property
    console.log("User ID: " + userInfo.id);
    console.log("Org ID: " + userInfo.organizationId);
  
    conn.streaming.topic("/event/AccountChangeEvent").subscribe(function (message) {
        //var buildingId = message.payload.Building_ID__c;
        console.log("payload:", message.payload);
    });

    conn.streaming.topic("/event/Building_Created__e").subscribe(function (message) {
        var buildingId = message.payload.Building_ID__c;
        console.log("Building ID", buildingId);
    });
});

let i = 0;
setInterval(() => {
    // console.log('Infinite Loop Test interval n:', i++);
}, 2000)
console.log('end');

// Create an instance of the event and store it in the newsEvent variable
Building_Created__e newsEvent = new Building_Created__e(Building_ID__c = '123456481450');
// Call method to publish events
Database.SaveResult sr = EventBus.publish(newsEvent);
// Inspect publishing result 
if (sr.isSuccess()) {
      System.debug('Successfully published event.');
} else {
    for(Database.Error err : sr.getErrors()) {
    System.debug('Error returned: ' +
              err.getStatusCode() +
              ' - ' +
              err.getMessage());
    }
}