anyToJSON/anyToJSON.js at master · lastlegion/anyToJSON · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
var fs = require('fs');
//var db = require("odbc")()
var csvLib = require("csv");
var http = require("http")


//
//## odbc(path, callback)
// - **options**: specifies the file path
// - **callback**: the callback function

function odbc(options, callback){
  var cn = options.cn;
  var table = options.table;
  db.open(cn, function (err) {
      if (err) {
          return console.log(err);
      }

      db.query("select * from "+table, function(err, rows, moreResults){
          var data = rows;
          callback(data);
      })
   });

}

//
//## json(path, callback)
// - **options**: specifies the file path
// - **callback**: the callback function

function json(options, callback){
      //console.log("json")
      var path = options.path;
      //Read the file using filepath
      fs.readFile(path, 'utf8', function(err, d){
        if(err){
          console.log("Error: "+ err);
          return;
        }
        data = JSON.parse(d);

        //Send data back to app.js
        callback(data);
      });
}

//
//## csv(path, callback)
// - **options**: specifies the file path
// - **callback**: the callback function
function csv(options, callback){
      var path = options.path;
      fs.readFile(path, 'utf8', function(err,data){
        csvLib.parse(data, {ltrim: true, columns: true}, function(err, data){
          callback(data);
        })

      });
}

//## restJson(options, callback)
// - **options**: HTTP header options
// - **callback**: the callback function
function restJSON(options, callback){
    //var options = options;
    //Make the HTTP GET request
    http.get(options, function(response){
        response.setEncoding("utf8");
        var data = "";
        response.on("data",function(chunk){
            if(chunk){
                data += chunk;
            }
            //console.log(chunk)
        });

        response.on("end", function(){
            var dataj = JSON.parse(data);

            callback(dataj);
        });
    });
}

//## restCsv(options, callback)
// - **options**: HTTP header options
// - **callback**: the callback function
function restCSV(options, callback){
    var data = {};
      http.get(options, function(response){
        response.on('data', function(chunk){
          chunk = chunk.toString();
          if(chunk){
            data+=chunk;
          }
        });
        response.on('end', function(){

          callback(data);
        })

      })
}

exports.json = json;
exports.csv = csv;
exports.restJSON = restJSON;
exports.restCSV = restCSV;
exports.odbc = odbc;