init

Author: kr1sp1n

.gitignore

@@ -0,0 +1 @@
+node_modules

Procfile

@@ -0,0 +1 @@
+api: node server.js

bvg.js

@@ -0,0 +1,105 @@
+this.title = "Welcome to bvg webservice!";
+this.name = "bvg api module";
+this.version = "0.0.1";
+this.endpoint = "http://localhost:8080";
+
+var get = require('get');
+var util = require('util'),
+    jjw = require('jjw');
+
+// you can pass an object -- will return an object with the results matching these keys
+var scrapers = {
+	stations: function($) {
+		var arr = []
+		$('select.ivu_selectbox option').each(function() {
+			arr.push($(this).attr('value'));
+		});
+		return arr;
+	}
+};
+
+exports.stations = function(options, callback){
+	//http://mobil.bvg.de/IstAbfahrtzeiten/index/mobil?input=Stromstr.+%28Berlin%29
+	
+	//console.log(escape(options.input));
+	
+	var url = 'http://mobil.bvg.de/IstAbfahrtzeiten/index/mobil?input='+escape(options.input),
+	    dl = new get(url);
+	
+	dl.asBuffer(function(err, data) {
+	    if (err) throw err;
+	
+		// convert from ISO-8859-1 to UTF-8
+		var Iconv  = require('iconv').Iconv;
+		var iconv = new Iconv('ISO-8859-1', 'UTF-8');
+		var buffer = iconv.convert(data);
+		
+		// do something useful with the buffer
+		
+		var scrapers = {
+			choices: function($) {
+				var arr = [];
+				$('select.ivu_selectbox option').each(function() {
+					arr.push($(this).attr('value'));
+				});
+				return arr;
+			},
+			departures: function($) {
+				var obj = {};
+				obj.results = [];
+				obj.status = "";
+				$('.ivu_result_box').each(function(){
+					if($(this).attr('id')=='ivuStreckeninfos') {
+						obj.status = $.trim($(this).text());
+					} else {
+						$(this).find('.ivu_table').each(function(){
+							$(this).find('tbody tr').each(function(){
+								var departure = {};
+								departure.time = $.trim($(this).find('.ivu_table_c_dep').text());
+								departure.line = $.trim($(this).find('.ivu_table_c_line').text());
+								departure.direction = $.trim($(this).find('.catlink').text());
+								obj.results.push(departure);
+							});
+						});
+					}
+				});
+				return obj;
+			}
+		};
+
+        var page = buffer.toString('utf8', 0, buffer.length);
+
+		//console.log(page);
+
+		jjw(page, scrapers, function(err, result) {
+		  if (err) throw err;
+	      callback(null, result);
+		});
+	});	
+};
+
+exports.stations.description = "Show list of found stations."
+exports.stations.schema = {
+	input: {
+		type: 'string',
+		optional: false
+	}
+}
+
+exports.departures = function(options, callback){
+	callback(null, options.input);
+};
+exports.departures.description = "this is the echo method, it echos back your msg";
+exports.departures.schema = {
+  input: { 
+    type: 'string',
+    optional: false
+  }
+};
+
+exports.ping = function(options, callback){
+  setTimeout(function(){
+    callback(null, 'pong');
+  }, 2000);
+}
+exports.ping.description = "this is the ping method, it pongs back after a 2 second delay";

crawler.js

@@ -0,0 +1,38 @@
+var get = require('get');
+
+var dl = new get('http://mobil.bvg.de/IstAbfahrtzeiten/index/mobil?input=stral').asBuffer(function(err, data) {
+    if (err) throw err;
+    console.log(data);
+});
+
+/*
+var util = require('util'),
+    jjw = require('jjw')
+
+// you can pass an object -- will return an object with the results matching these keys
+var scrapers = {
+  scripts: function($) {
+    var arr = [], src
+    $('script').each(function() {
+      src = $(this).attr('src')
+      if (src) arr.push(src)
+    })
+    return arr
+  }
+, thumbs: function($) {
+    var arr = []
+    $('.pc_img').each(function() {
+      arr.push($(this).attr('src'))
+    })
+    return arr
+  }
+, results: function($) {
+    return $('.Results').text()
+  }
+}
+
+jjw('http://www.flickr.com/search/?q=homer+simpson', scrapers, function(err, res) {
+  if (err) throw err
+  console.log(res)
+});
+*/

package.json

@@ -0,0 +1,9 @@
+{
+  "name": "bvg-api",
+  "version": "0.0.1",
+  "dependencies": {
+    "webservice": "0.5.x",
+    "get": "0.4.x",
+    "jjw": "0.0.4"
+  }
+}

server.js

@@ -0,0 +1,6 @@
+var webservice = require('webservice'),
+    bvg        = require('./bvg'),
+    port = process.env.PORT || 3000;
+
+webservice.createServer(bvg).listen(port);
+console.log('BVG json webservice started on port '+port);