app.js

"use strict";

var express = require('express');
var env = require('./environment.json');
var path = require('path');
var qs = require('querystring');
var request = require('request');
var bodyParser = require('body-parser');
var cookieParser = require('cookie-parser');
var session = require('express-session');
var mongoose = require('mongoose');
var _ = require('underscore');
var MongoStore = require('connect-mongo')(session);
var YahooUtils = require('./utils/yahoo');
var app;
var ApiUtil = require('./utils/apis');

//MongoDB
var userSchema = new mongoose.Schema({
  guid: String,
  email: String,
  profileImage: String,
  firstName: String,
  lastName: String,
  accessToken: String,
  refreshToken: String,
  leagues: [],
  league: {}
});
var User = mongoose.model('User', userSchema);
var clientId = process.env.CLIENT_ID || env.client_id;
var clientSecret = process.env.CLIENT_SECRET || env.client_secret;
var redirectUri = process.env.REDIRECT_URI || 'http://alexei.com/auth/yahoo/callback';
mongoose.connect(process.env.MONGODB || 'localhost');
var db = mongoose.connection;
db.once('open', function (callback) {
  console.log("# Mongo DB:  Connected to server");
});

// Setup Express app
app = express();
app.set('port', process.env.PORT || 80 );
//View Engine
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'ejs');
// middleware
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({extended: false}));
app.use(cookieParser());
app.use(session({
  secret: 'keyboard cat',
  resave: true,
  saveUninitialized: true,
  store: new MongoStore({ mongooseConnection: db })
}));
app.use(express.static(path.join(__dirname, './dist')));

//express routes
app.get(['/', '/app*'], (req, res) => {
  console.log('Serving ', req.url);
  res.sendFile(__dirname + '/dist/app.html');
});

app.get('/user', (req, res) => {
  var user = req.session.user;
  var games = false;

  // if (req.session.user && req.session.user.games){
  //   console.log('didnt request leagues')
  //   res.json({
  //     user: req.session.user
  //   })
  // } else if (user && user.guid) {
  if (user && user.guid) {
    var gamesPromise = ApiUtil.yahooPromise('https://fantasysports.yahooapis.com/fantasy/v2/users;use_login=1/games;game_keys=380/leagues?format=json', req.session.user);
    gamesPromise.then( result => {
      //this needs to be updated i think, check it out
      let leagues = result.fantasy_content ? result.fantasy_content.users['0'].user[1].games['0'].game[1].leagues : false;
      let formattedLeagues = leagues ? Object.keys(leagues).filter(key => leagues[key].league && leagues[key].league[0]).map((key) => leagues[key].league[0]) : false;

      req.session.user.games = formattedLeagues;

      res.json({
        user: user,
        league: user.league && user.leagueKey ? user.league : {},
        leagues: formattedLeagues
      })
    }, (err) => {

      res.json({
        user: user,
      })
    }).then(function(result){
    })
  } else {
    res.json({
      user: false
    })
  }
})

app.get('/logout', (req, res) => {
  delete req.session.user;
  res.json({user: {}});
});

app.get('/league/:leagueKey', (req, res) => {
  console.log('FETCHING LEAGUE INFO...')
  // if (req.session.user && req.session.user.guid && req.session.user.league) {
  //   User.findOne({ guid: req.session.user.guid }, (err, existingUser) =>  {
  //     if (existingUser && existingUser.league) {
  //       console.log("we didn't make the request")
  //       res.json(existingUser.league)
  //     }
  //   })
  // } else {
    var leagueRosterResult, formattedSettings;
    ApiUtil.yahooPromise(`https://fantasysports.yahooapis.com/fantasy/v2/league/${req.params.leagueKey}/settings/?format=json`, req.session.user)
    .then((settings) => Promise.resolve( YahooUtils.formatLeagueSettings(settings) ))
    .then((fSettings) => {
      formattedSettings = fSettings
      return ApiUtil.yahooPromise('https://fantasysports.yahooapis.com/fantasy/v2/league/'+req.params.leagueKey+'/teams/roster/players/?format=json', req.session.user)
    })
    .then(function(result){
      leagueRosterResult = result;
      return new Promise((resolve, reject) => {
        request('https://s3-us-west-1.amazonaws.com/fantasy-football-trade-values/ranks', (err, res, body) =>{
          if (err || (body && body.error)) {
            reject(err)
          } else {
            resolve(YahooUtils.addPlayerWeights(JSON.parse(body), YahooUtils.formatTeamRosters(result)))
          }
        })
      })      
    })
    .then(normalized => {
      
      var leagueDataResponse = {
        settings: formattedSettings,
        league: YahooUtils.formatLeague(leagueRosterResult),
        rankings: YahooUtils.rankByPosition(normalized, formattedSettings, req.session.user.guid),
        // normalized: normalized,
        leagueKey: req.params.leagueKey
      }

      User.findOne({ guid: req.session.user.guid }, function(err, existingUser) {
        if (existingUser) {
          existingUser.league = leagueDataResponse
          existingUser.save(function(err){
            req.session.user = existingUser;
          })
        }
      })

      return leagueDataResponse

    })
    // .then(leagueData => leagueData)
    .then(leagueData => res.json(leagueData))
    .catch( (error) => {
      console.log(error)
      res.json({
        user: user,
        games: false
      })
    })
  // }
})

//Oauth
app.get('/auth/yahoo', function(req, res) {
  console.log('auth/yahoo route hit....')
  var authorizationUrl = 'https://api.login.yahoo.com/oauth2/request_auth';

  var queryParams = qs.stringify({
    client_id: clientId,
    redirect_uri: redirectUri,
    response_type: 'code' //'token'?
  });

  res.redirect(authorizationUrl + '?' + queryParams);
});

app.get('/auth/yahoo/callback', function(req, res) {
  console.log('auth/yahoo/callback route hit....')

  var accessTokenUrl = 'https://api.login.yahoo.com/oauth2/get_token';

  var options = {
    url: accessTokenUrl,
    headers: { Authorization: 'Basic ' + new Buffer(clientId + ':' + clientSecret).toString('base64') },
    rejectUnauthorized: false,
    json: true,
    form: {
      code: req.query.code,
      redirect_uri: redirectUri,
      grant_type: 'authorization_code'
    }
  };

  // 1. Exchange authorization code for access token.
  request.post(options, function(err, response, body) {
    var guid = body.xoauth_yahoo_guid;
    var accessToken = body.access_token;
    var refreshToken = body.refresh_token;
    var socialApiUrl = 'https://social.yahooapis.com/v1/user/' + guid + '/profile?format=json';
    var options = {
      url: socialApiUrl,
      headers: { Authorization: 'Bearer ' + accessToken },
      rejectUnauthorized: false,
      json: true
    };

    // 2. Retrieve profile information about the current user.
    request.get(options, (err, response, body) => {
    console.log('requesting user profile from yahoo...')
      // 3. Create a new user account or return an existing one.
      User.findOne({ guid: guid }, (err, existingUser) => {
        if (existingUser) {
          existingUser.accessToken = accessToken
          existingUser.refreshToken = refreshToken
          existingUser.save(err => {
            // req.session.user = existingUser;
          })
          req.session.user = existingUser;
          req.session.save();
          console.log('found user...')
          return res.redirect('/');
        }

        var user = new User({
          guid: guid,
          email: body.profile.emails[0].handle,
          profileImage: body.profile.image.imageUrl,
          firstName: body.profile.givenName,
          lastName: body.profile.familyName,
          accessToken: accessToken,
          refreshToken: refreshToken
        });

        user.save(err => {
          req.session.user = user;
          req.session.save();
          console.log('created/saved user...')

          res.redirect('/');
        });
      });
    });
  });
});


app.listen(app.get('port'), function() {
  console.log('app listening on port ' + app.get('port'))
});