Add base support for fitbit

bin/reportr.js

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

lib/config/main.js

@@ -64,6 +64,11 @@ function setup(options, imports, register) {
 					'interval': 6*60*60,
 					'clientId': process.env.RUNKEEPER_CLIENTID,
 					'clientSecret': process.env.RUNKEEPER_CLIENTSECRET
+				},
+				'fitbit': {
+					'interval': 6*60*60,
+					'clientId': process.env.FITBIT_CLIENTID,
+					'clientSecret': process.env.FITBIT_CLIENTSECRET
 				}
 			}
 		}

lib/tracker.fitbit/main.js

@@ -0,0 +1,112 @@
+var _ = require("underscore");
+var moment = require('moment');
+var FitbitStrategy = require('passport-fitbit').Strategy;
+var Fitbit = require("fitbit-js");
+
+function setup(options, imports, register) {
+	var logger = imports.logger.namespace("tracker.fitbit");
+	var trackers = imports.trackers;
+	var tasks = imports.tasks;
+
+	var tracker = trackers.register({
+		'id': "fitbit",
+		'name': "Fitbit",
+		'description': "Track your running activity from Runkeeper.",
+
+		'initConfig': function() {
+			_.defaults(this.config, {
+				'interval': 60*60
+			});
+		},
+
+		'initWeb': function() {
+			this.oauth(FitbitStrategy, {
+				'strategyOptions': {
+					'passReqToCallback': true,
+					'consumerKey': this.config.clientId,
+					'consumerSecret': this.config.clientSecret,
+					'callbackURL': "/auth/"+this.id+"/callback"
+				}
+			});
+		},
+
+		'initWorker': function() {
+			var that = this;
+
+			tasks.addTrackerTask(this, function(user) {
+				var userConfig = user.getTrackerSettings(that.id);
+				if (userConfig == null
+				|| userConfig.accessToken == null
+				|| userConfig.refreshToken == null) return;
+
+				var client = new Fitbit(that.config.clientId, that.config.clientSecret);
+				var clientMethod = function(method, url, callback) {
+					client.apiCall(method, url,  {
+						'token': {
+							'oauth_token_secret': userConfig.refreshToken,
+				            'oauth_token': userConfig.accessToken
+				        }
+				    }, callback);
+				};
+
+				that.trackActivities(clientMethod, user, userConfig);
+			}, this.config.interval);
+		},
+
+		// Track user activities
+		trackActivities: function(client, user, userConfig) {
+			var that = this;
+
+			// Define model
+			user.setModel({
+				'eventNamespace': that.id,
+				'eventName': 'distance',
+
+				'name': "Fitbit Distance",
+				'icon': '$fitbit',
+				'description': "Distance calculate on Fitbit."
+			});
+
+			client("GET", "/user/-/activities/distance/date/today/1m.json", function(err, res, json) {
+				if (err) {
+					logger.exception(err, false);
+					return;
+				}
+				if (!json 
+				|| !json["activities-distance"]) {
+					logger.error("Invalid data for fitbit activities", err, res, json);
+					return;
+				}
+
+				_.each(json["activities-distance"], function(activity) {
+					if (!activity.dateTime
+					|| !activity.value) {
+						logger.error("Invalid data for fitbit activities");
+						return;
+					}
+
+					var timestamp = moment(activity.dateTime).unix() * 1000;
+
+					// Track as an event
+					user.track({
+						'eventId': timestamp,
+						'namespace': that.id,
+						'name': 'distance',
+						'properties': {
+							'distance': activity.value
+						},
+						'timestamp': timestamp
+					});
+				});
+			});
+		}
+	});
+
+
+    register(null, {
+    	'tracker.fitbit': tracker
+    });
+};
+
+// Exports
+module.exports = setup;

lib/tracker.fitbit/package.json

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

lib/tracker.runkeeper/main.js

@@ -1,6 +1,6 @@
 var _ = require("underscore");
 var moment = require('moment');
-var RunKeeperStrategy = require('passport-runkeeper').Strategy
+var RunKeeperStrategy = require('passport-runkeeper').Strategy;
 var runkeeper = require('node-runkeeper');
 
 function setup(options, imports, register) {

lib/web.main/package.json

@@ -8,8 +8,10 @@
     "plugin": {
         "consumes": [
             "config", "logger", "database", "User", "notifications", "api", "trackers",
+
             "tracker.chrome", "tracker.facebook", "tracker.foursquare",
-            "tracker.twitter", "tracker.github", "tracker.runkeeper", "tracker.ping"
+            "tracker.twitter", "tracker.github", "tracker.runkeeper", 
+            "tracker.fitbit", "tracker.ping"
         ]
     }
 }

lib/worker.main/package.json

@@ -8,7 +8,10 @@
     "plugin": {
         "consumes": [
             "config", "logger", "database", "trackers", "tasks",
-            "tracker.ping", "tracker.foursquare"
+
+            "tracker.chrome", "tracker.facebook", "tracker.foursquare",
+            "tracker.twitter", "tracker.github", "tracker.runkeeper", 
+            "tracker.fitbit", "tracker.ping"
         ]
     }
 }

package.json

@@ -41,7 +41,10 @@
         "twit": "1.1.11",
 
         "passport-runkeeper": "0.1.2",
-        "node-runkeeper": "0.1.4"
+        "node-runkeeper": "0.1.4",
+
+        "passport-fitbit": "0.1.2",
+        "fitbit-js": "0.2.0"
     },
     "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":1382011516649,"baseUrl":"/"}; });
+define('hr/args',[],function() { return {"map":{"apiKey":"AIzaSyAAeM47baWKdmKoqWeIuK5bQCxtur6mWm0"},"revision":1382035267682,"baseUrl":"/"}; });
 //! moment.js
 //! version : 2.2.1
 //! authors : Tim Wood, Iskren Chernev, Moment.js contributors