feat(graphql): Add fitness activities

Added beginning of fitness activities schema. Added resolve item functionality to call 'next'
properties when needed to get correct count of items. Set default item count to 25.

res/i18n/en.json

@@ -1,3 +1,4 @@
 {
-	"SERVER_START": "Server started on port %{port}"
+	"SERVER_START": "Server started on port %{port}",
+	"RUNKEEPER_REQUEST": "Request made to Runkeeper API %{endpoint}"
 }

src/app.js

@@ -1,6 +1,6 @@
 const cookieParser = require('cookie-parser');
 const express = require('express');
-const log = require('./logging');
+const log = require('./helpers/logging');
 const path = require('path');
 
 

src/data-types/fitness-activities.js

@@ -0,0 +1,39 @@
+const graphql = require('graphql');
+const GraphQLObjectType = graphql.GraphQLObjectType;
+const GraphQLString = graphql.GraphQLString;
+const GraphQLList = graphql.GraphQLList;
+const GraphQLInt = graphql.GraphQLInt;
+const GraphQLBoolean = graphql.GraphQLBoolean;
+
+const resolveItems = require('../helpers/resolve-items');
+const resolve = resolveItems.resolve;
+const args = resolveItems.args;
+
+const FitnessItem = new GraphQLObjectType({
+	name: 'FitnessItem',
+	fields: {
+		type: {type: GraphQLString},
+		start_time: {type: GraphQLString},
+		utc_offset: {type: GraphQLInt},
+		total_distance: {type: GraphQLInt},
+		duration: {type: GraphQLInt},
+		total_calories: {type: GraphQLInt},
+		source: {type: GraphQLString},
+		entry_mode: {type: GraphQLString},
+		tracking_mode: {type: GraphQLString},
+		has_path: {type: GraphQLBoolean},
+		uri: {type: GraphQLString}
+	}
+});
+
+module.exports = new GraphQLObjectType({
+	name: 'FitnessActivities',
+	fields: {
+		size: {type: GraphQLInt},
+		items: {
+			type: new GraphQLList(FitnessItem),
+			args,
+			resolve
+		}
+	}
+});

src/data-types/strength-training-activities.js

@@ -5,6 +5,10 @@ const GraphQLList = graphql.GraphQLList;
 const GraphQLInt = graphql.GraphQLInt;
 const fetch = require('../helpers/fetch');
 
+const resolveItems = require('../helpers/resolve-items');
+const resolve = resolveItems.resolve;
+const args = resolveItems.args;
+
 const StrengthTrainingSet = new GraphQLObjectType({
 	name: 'StrengthTrainingSet',
 	fields: {
@@ -71,7 +75,9 @@ module.exports = new GraphQLObjectType({
 	fields: {
 		size: { type: GraphQLInt },
 		items: {
-			type: new GraphQLList(StrengthTrainingItem)
+			type: new GraphQLList(StrengthTrainingItem),
+			args,
+			resolve
 		}
 	}
 });

src/data-types/user.js

@@ -5,6 +5,7 @@ const GraphQLString = graphql.GraphQLString;
 const fetch = require('../helpers/fetch');
 const ProfileType = require('./profile');
 const StrengthTrainingActivitiesType = require('./strength-training-activities');
+const FitnessActivitiesType = require('./fitness-activities');
 
 module.exports = new GraphQLObjectType({
 	name: 'User',
@@ -23,6 +24,12 @@ module.exports = new GraphQLObjectType({
 			resolve (data, args, req) {
 				return fetch(data.strength_training_activities, req);
 			}
+		},
+		fitness_activities: {
+			type: FitnessActivitiesType,
+			resolve (data, args, req) {
+				return fetch(data.fitness_activities, req);
+			}
 		}
 	}
 });

src/helpers/fetch.js

@@ -1,6 +1,10 @@
 const request = require('superagent-promise')(require('superagent'), Promise);
+const log = require('./logging');
 
 module.exports = function fetch (endpoint, req) {
+
+	log.info('RUNKEEPER_REQUEST', { endpoint });
+
 	return request
 		.get(`https://api.runkeeper.com${endpoint}`)
 		.query({access_token: req.cookies.auth})

src/i18n.js → src/helpers/i18n.js

@@ -1,6 +1,6 @@
 const Polyglot = require('node-polyglot');
 const polyglot = new Polyglot();
-const strings = require('../res/i18n/en.json');
+const strings = require('../../res/i18n/en.json');
 
 polyglot.extend(strings);
 

src/helpers/resolve-items.js

@@ -0,0 +1,49 @@
+const fetch = require('./fetch');
+const graphql = require('graphql');
+const GraphQLInt = graphql.GraphQLInt;
+
+module.exports = {
+
+	args: {
+		count: {type: GraphQLInt}
+	},
+
+	resolve (parent, args, req) {
+
+		return new Promise(resolve => {
+
+			const opts = Object.assign({
+				count: 25
+			}, args);
+
+			let items = parent.items;
+
+			function getItems (count, next) {
+				return new Promise(resolve => {
+
+					fetch(next, req).then(data => {
+						items = items.concat(data.items);
+
+						if (count > items.length && data.next) {
+							return getItems(count, data.next);
+						}
+
+					}).then(resolve);
+
+				});
+			}
+
+			if (opts.count > items.length && parent.next) {
+
+				getItems(opts.count, parent.next).then(() => {
+					resolve(items.slice(0, opts.count));
+				});
+
+			} else {
+				resolve(items.slice(0, opts.count));
+			}
+
+		});
+
+	}
+};