index.js

var config = require('./config');
var express = require('express');
var bodyParser = require('body-parser');
var cookieParser = require('cookie-parser');
var session = require('express-session');
var ejs = require('ejs');
var util = require('util');
var passport = require('passport');
var GitHubStrategy = require('passport-github2').Strategy;
var ecc = require('eccjs');
var pubnub = require('pubnub');

var storage = require('node-persist');
storage.initSync();

var app = express();

// configure Express
app.set('views', __dirname + '/views');
app.set('view engine', 'html');
app.engine('html', ejs.renderFile);
app.use(express.static(__dirname + '/public'));
app.use(cookieParser());
app.use(bodyParser.urlencoded({ extended: true }));
app.use(session({
  secret: 'keyboard cat',
  resave: false,
  saveUninitialized: false
}));
app.use(passport.initialize());
app.use(passport.session());


passport.serializeUser(function(user, done) {
  // Reading or generating a publicKey for the user

  var cachedUser = storage.getItem('user_' + user.id);

  if (cachedUser && 'secretKey' in cachedUser && 'publicKey' in cachedUser) {
    user.eccKey = cachedUser.eccKey;
    user.publicKey = cachedUser.publicKey;

    console.log('========');
    console.log('cachedUser.eccKey');

    done(null, user.id);

  } else { // if not in local storage, get from PubNub "DB"
    console.log('========');
    console.log('Getting from history...');

    // Using a PubNub channel (separated from the chat channel) as a DB

    var dbChannel = 'user_' + user.id;

    var db = pubnub.init({
      subscribe_key: 'sub-c-981faf3a-2421-11e5-8326-0619f8945a4f',
      publish_key: 'pub-c-351c975f-ab81-4294-b630-0aa7ec290c58',
      secret_key: config.pubnub.secret_key,
      auth_key: config.pubnub.auth_key,
    });

    db.grant({ 
      channel: dbChannel, 
      auth_key: config.pubnub.auth_key, 
      read: true, 
      write: true, 
      callback: function(m){console.log(m);} ,
      error: function(err){console.log(err);}
    });

    db.subscribe({
      channel: dbChannel,
      callback: function(m) {console.log(m)},
      connect: function() {
        db.history({
          channel: dbChannel,
          callback: function(m) {
       
            if(m[0].length > 0) {
              console.log('========');
              console.log('User data found in history. No new key is generated.');

              user.eccKey = m[0][0].eccKey;
              user.publicKey = m[0][0].publicKey;
              storage.setItem('user_' + user.id, user);
              done(null, user.id);

            } else { // the user info is never stored in "DB" (history) before

              console.log('========');
              console.log('Nothing in history. Publishing new keys');

              var keys = ecc.generate(ecc.SIG_VER);
              user.eccKey = keys.sig;
              user.publicKey = keys.ver;
              storage.setItem('user_' + user.id, user);

              db.publish({
                channel: dbChannel,
                message: user,
                callback: function() {
                  done(null, user.id);
                }
              });
            }


          }
        });
      }
    });
  }

  
});

passport.deserializeUser(function(id, done) {
  done(null, storage.getItem('user_' + id));
});

passport.use(new GitHubStrategy({
    clientID: config.auth.github.client_id,
    clientSecret: config.auth.github.client_secret,
    callbackURL: 'https://pubnub-auth-chat.herokuapp.com/callback'
    //callbackURL: 'http://localhost:3000/callback'
  },
  function(accessToken, refreshToken, profile, done) {
    var user = profile;
    user.accessToken = accessToken;
    return done(null, user); 
  }
));

var channel = 'am-ecc-chat';
var channelPres = channel + '-pnpres';

pubnub = pubnub.init({
  subscribe_key: 'sub-c-981faf3a-2421-11e5-8326-0619f8945a4f',
  publish_key: 'pub-c-351c975f-ab81-4294-b630-0aa7ec290c58',
  secret_key: config.pubnub.secret_key,
  auth_key: config.pubnub.auth_key,
  ssl: true
});

pubnub.grant({ 
  channel: channel + ',' + channelPres, 
  auth_key: config.pubnub.auth_key, 
  read: true, 
  write: true, 
  callback: function(m){console.log(m);} ,
  error: function(err){console.log(err);}
});

//Routes 

app.get('/', function (req, res) {
  res.render('index', { user: req.user });

  if(req.user) {
    pubnub.grant({ 
      channel: channel + ',' + channelPres, 
      auth_key: req.user.accessToken, 
      read: true, 
      write: true, 
      callback: function(m){console.log(m);} ,
      error: function(err){console.log(err);}
    });
  }
  pubnub.audit({
    callback: function(m){
      console.log(util.inspect(m, false, null));
    }
  });
});

app.get('/user/:id', function (req, res) {
  if(req.user) {
    try {
      var id = req.params.id;
      var cachedUser = storage.getItem('user_' + id);

      res.send({
        'publicKey': cachedUser.publicKey,
        'displayName': cachedUser.displayName,
        'username': cachedUser.username,
        'avatar_url': cachedUser._json.avatar_url,
        'id':  cachedUser.id
      });

    } catch (e) {
      res.send({'status': 404});
    }
  } else {
    res.send({'status': 403});
  }
  
});

app.get('/login', 
  passport.authenticate('github', { scope: ['user']}),
  function(req, res) {
});

app.get('/logout', function(req, res) {
  req.logout();
  res.redirect('/');
});

app.get('/callback', passport.authenticate('github', { failureRedirect: '/login' }),
  function(req, res) {
    res.redirect('/');
});

var server = app.listen(process.env.PORT || 3000, function(){
  console.log('Express server listening on port %d in %s mode', this.address().port, app.settings.env);
});