jrtechs-HomePage/server.js

/** express app */
const express = require("express");

/** Manages oauth 2.0 w/ fitbit */
const passport = require('passport');

/** Used to make API calls */
const unirest = require('unirest');

/** express app */
const app = express();

/** pull config file */
const utils = require("./utils.js");
const config = utils.getFileAsJSON("config.json");




app.use(passport.initialize());
app.use(passport.session({
    resave: false,
    saveUninitialized: true
}));


var FitbitStrategy = require( 'passport-fitbit-oauth2' ).FitbitOAuth2Strategy;


var accessTokenTemp = null;
passport.use(new FitbitStrategy({
        clientID:     config.clientID,
        clientSecret: config.clientSecret,
        callbackURL: config.callbackURL
    },
    function(accessToken, refreshToken, profile, done)
    {
        console.log(accessToken);
        accessTokenTemp = accessToken;
        done(null, {
            accessToken: accessToken,
            refreshToken: refreshToken,
            profile: profile
        });
    }
));

passport.serializeUser(function(user, done) {
    done(null, user);
});

passport.deserializeUser(function(obj, done) {
    done(null, obj);
});


passport.authenticate('fitbit', { scope: ['activity','heartrate','location','profile'] });

app.get('/auth/fitbit',
    passport.authenticate('fitbit', { scope: ['activity','heartrate','location','profile'] }
));

app.get( '/auth/fitbit/callback', passport.authenticate( 'fitbit', {
    successRedirect: '/',
    failureRedirect: '/error'
}));


app.get('/error', (request, result) =>
{
    result.write("Error authenticating with Fitbit API");
    result.end();
});


app.get('/', (request, result) =>
{
    if(accessTokenTemp == null)
    {
        result.redirect('/auth/fitbit');
    }

    unirest.get('https://api.fitbit.com/1/user/-/activities/steps/date/today/1m.json')
        .headers({'Accept': 'application/json', 'Content-Type': 'application/json', Authorization: "Bearer " +  accessTokenTemp})
        .end(function (response)
        {
            // result.write(response.body);
            result.end();
            console.log(response.body);
        });
});

app.listen(PORT, () =>
    console.log(`App listening on port ${config.port}!`)
);