Add runkeeper tracker

README.md

@@ -58,6 +58,11 @@ FACEBOOK_CLIENTSECRET
 # Callback url is {HOST}/auth/twitter/callback
 TWITTER_CLIENTID
 TWITTER_CLIENTSECRET
+
+# Runkeeper oAuth
+# Callback url is {HOST}/auth/runkeeper/callback
+RUNKEEPER_CLIENTID
+RUNKEEPER_CLIENTSECRET
 ```
 
 #### Create your application and deploy it
@@ -121,10 +126,11 @@ Here is a list of trackers, I already built:
 * GitHub: track coding activity on GitHub
 * Facebook: track relations on Facebook (using Realtime API)
 * Twitter: track twitter activity (tweets, mentions, ...)
+* Runkeeper: track running activity
 
 And more to come:
 
-* Runkeeper: track running activity
+* Fitbit
 * Hardware:
 	* Track the temperature in a room (using tessel.io)
 

bin/reportr.js

@@ -22,6 +22,7 @@ var modulesSection = {
         "./tracker.foursquare",
         "./tracker.twitter",
         "./tracker.github",
+        "./tracker.runkeeper",
         "./tracker.ping",
 
         "./model.user",

lib/config/main.js

@@ -56,9 +56,14 @@ function setup(options, imports, register) {
 					'clientSecret': process.env.FOURSQUARE_CLIENTSECRET
 				},
 				'github': {
-						'interval': 6*60*60,
-						'clientId': process.env.GITHUB_CLIENTID,
-						'clientSecret': process.env.GITHUB_CLIENTSECRET
+					'interval': 6*60*60,
+					'clientId': process.env.GITHUB_CLIENTID,
+					'clientSecret': process.env.GITHUB_CLIENTSECRET
+				},
+				'runkeeper': {
+					'interval': 6*60*60,
+					'clientId': process.env.RUNKEEPER_CLIENTID,
+					'clientSecret': process.env.RUNKEEPER_CLIENTSECRET
 				}
 			}
 		}

lib/logger/main.js

@@ -16,12 +16,12 @@ function setup(options, imports, register) {
 
 	var error = _.partial(print, 'error');
 	var log = _.partial(print, 'log');
-	var exception = _.wrap(error, function(func, logSection, err) {
+	var exception = _.wrap(error, function(func, logSection, err, kill) {
 		func(logSection, "Error ", err.message);
 		console.error(err.stack);
 
         // Kill process
-        process.exit(1);
+        if (kill != false) process.exit(1);
 	});
 
     register(null, {

lib/tracker.runkeeper/main.js

@@ -0,0 +1,113 @@
+var _ = require("underscore");
+var moment = require('moment');
+var RunKeeperStrategy = require('passport-runkeeper').Strategy
+var runkeeper = require('node-runkeeper');
+
+function setup(options, imports, register) {
+	var logger = imports.logger.namespace("tracker.runkeeper");
+	var trackers = imports.trackers;
+	var tasks = imports.tasks;
+
+	var tracker = trackers.register({
+		'id': "runkeeper",
+		'name': "Runkeeper",
+		'description': "Track your running activity from Runkeeper.",
+
+		'initConfig': function() {
+			_.defaults(this.config, {
+				'interval': 60*60
+			});
+		},
+
+		'initWeb': function() {
+			this.oauth(RunKeeperStrategy);
+		},
+
+		'initWorker': function() {
+			var that = this;
+
+			tasks.addTrackerTask(this, function(user) {
+				var userConfig = user.getTrackerSettings(that.id);
+				if (userConfig == null || userConfig.accessToken == null) return;
+
+				var client = new runkeeper.HealthGraph({
+					'client_id': that.config.clientId,  
+    				'client_secret': that.config.clientSecret
+				});
+				client.accessToken = userConfig.accessToken;
+				that.trackFitnessActivities(client, user, userConfig);
+			}, this.config.interval);
+		},
+
+		// Track user tweets
+		trackFitnessActivities: function(client, user, userConfig) {
+			var that = this;
+			var modelsDefined = [];
+
+			client.fitnessActivityFeed(client.accessToken, function(output) {
+				var data = {};
+
+				try {
+					data = JSON.parse(output);
+				} catch (err) {
+					logger.exception(err, false);
+			    	return;
+				}
+
+
+			    if (!data.items) {
+			    	logger.error("Invalid runkeeper fitness data", data);
+			    	return;
+			    }
+			    _.each(data.items, function(activity) {
+			    	if (!activity.type
+			    	|| !activity.start_time
+			    	|| !activity.duration
+			    	|| !activity.total_distance
+			    	|| !activity.total_calories) {
+			    		logger.error("Invalid runkeeper activity", activity);
+			    		return;
+			    	}
+
+			    	var eventName = "activity"+activity.type;
+			    	var timestamp = moment(activity.start_time).unix() * 1000;
+
+			    	// Define model
+			    	if (!_.contains(modelsDefined, eventName)) {
+			    		modelsDefined.push(eventName);
+			    		user.setModel({
+							'eventNamespace': that.id,
+							'eventName': eventName,
+
+							'name': activity.type,
+							'icon': '$runkeeper',
+							'description': "Fitness activity "+activity.type+"."
+						});
+			    	}
+
+			    	// Add event
+			    	user.track({
+						'eventId': timestamp,
+						'namespace': that.id,
+						'name': eventName,
+						'properties': {
+							'duration': activity.duration,
+							'distance': activity.total_distance,
+							'calories': activity.total_calories,
+							'startTime': activity.start_time
+						},
+						'timestamp': timestamp
+					});
+			    });
+			});
+		}
+	});
+
+
+    register(null, {
+    	'tracker.runkeeper': tracker
+    });
+};
+
+// Exports
+module.exports = setup;

lib/tracker.runkeeper/package.json

@@ -0,0 +1,16 @@
+{
+    "name": "tracker.runkeeper",
+    "version": "0.0.1",
+
+    "main": "./main.js",
+    "private": true,
+
+    "plugin": {
+        "consumes": [
+            "logger", "trackers", "tasks"
+        ],
+        "provides": [
+            "tracker.runkeeper"
+        ]
+    }
+}

lib/web.main/package.json

@@ -9,7 +9,7 @@
         "consumes": [
             "config", "logger", "database", "User", "notifications", "api", "trackers",
             "tracker.chrome", "tracker.facebook", "tracker.foursquare",
-            "tracker.twitter", "tracker.github", "tracker.ping"
+            "tracker.twitter", "tracker.github", "tracker.runkeeper", "tracker.ping"
         ]
     }
 }

package.json

@@ -38,7 +38,10 @@
         "facebook-client": "1.6.1",
 
         "passport-twitter": "1.0.2",
-        "twit": "1.1.11"
+        "twit": "1.1.11",
+
+        "passport-runkeeper": "0.1.2",
+        "node-runkeeper": "0.1.4"
     },
     "bin": {
         "reportr": "./bin/reportr.js"

public/static/application.js

@@ -25527,7 +25527,7 @@ Logger, Requests, Urls, Storage, Cache, Template, Resources, Deferred, Queue, I1
         }
     }
 });
-define('hr/args',[],function() { return {"map":{"apiKey":"AIzaSyAAeM47baWKdmKoqWeIuK5bQCxtur6mWm0"},"revision":1381999800489,"baseUrl":"/"}; });
+define('hr/args',[],function() { return {"map":{"apiKey":"AIzaSyAAeM47baWKdmKoqWeIuK5bQCxtur6mWm0"},"revision":1382011516649,"baseUrl":"/"}; });
 //! moment.js
 //! version : 2.2.1
 //! authors : Tim Wood, Iskren Chernev, Moment.js contributors