var http = require('http');
var jsforce = require('jsforce');

http.createServer(function (req, res) {
    var conn = new jsforce.Connection({
        loginUrl : 'https://test.salesforce.com'
    });
    conn.login('aaaaaaaaa', 'bbbbbbbbbb', function(err, userInfo) {
        if (err) { 
            return console.error(err); 
        }
        
        console.log('Connected to : ' + conn.instanceUrl);
        
        var records = [];
        conn.query("select * from tab")
        .on("record", function(record) {
            records.push(record);
        })
        .on("end", function() {
            //console.log("Total number of records fetched : " + records.length);
            res.writeHead(200, {'Content-Type': 'application/json'});
            res.end(JSON.stringify(records));
        })
        .on("error",function(err){
            console.error(err);
            res.writeHead(500, {'Content-Type': 'application/json'});
            res.end(err);
        })
        .run({ autoFetch : true });
    });
    
}).listen(8081);