model.js

model.js

/**
 * Module dependencies.
 */

var mongoose = require('mongoose');
var Schema = mongoose.Schema;

/**
 * Schema definitions.
 */

mongoose.model('OAuthTokens', new Schema({
  accessToken: { type: String },
  accessTokenExpiresOn: { type: Date },
  clientId: { type: String },
  refreshToken: { type: String },
  refreshTokenExpiresOn: { type: Date },
  userId: { type: String }
}));

mongoose.model('OAuthClients', new Schema({
  clientId: { type: String },
  clientSecret: { type: String },
  redirectUris: { type: Array }
}));

mongoose.model('OAuthUsers', new Schema({
  email: { type: String, default: '' },
  firstname: { type: String },
  lastname: { type: String },
  password: { type: String },
  username: { type: String }
}));

var OAuthTokensModel = mongoose.model('OAuthTokens');
var OAuthClientsModel = mongoose.model('OAuthClients');
var OAuthUsersModel = mongoose.model('OAuthUsers');

/**
 * Get access token.
 */

module.exports.getAccessToken = function(bearerToken) {
  console.log('in getAccessToken (bearerToken: ' + bearerToken + ')');

  return OAuthTokensModel.findOne({ accessToken: bearerToken });
};

/**
 * Get client.
 */

module.exports.getClient = function(clientId, clientSecret) {
  console.log('in getClient (clientId: ' + clientId + ', clientSecret: ' + clientSecret + ')');

  return OAuthClientsModel.findOne({ clientId: clientId, clientSecret: clientSecret });
};

/**
 * Get refresh token.
 */

module.exports.getRefreshToken = function(refreshToken) {
  console.log('in getRefreshToken (refreshToken: ' + refreshToken + ')');

  return OAuthTokensModel.findOne({ refreshToken: refreshToken });
};

/*
 * Get user.
 */

module.exports.getUser = function(username, password) {
  console.log('in getUser (username: ' + username + ', password: ' + password + ')');

  return OAuthUsersModel.findOne({ username: username, password: password });
};

/**
 * Save token.
 */

module.exports.saveToken = function(token, client, user) {
  console.log('in saveToken (token: ' + token + ')');

  var accessToken = new OAuthTokensModel({
    accessToken: token.accessToken,
    accessTokenExpiresOn: token.accessTokenExpiresOn,
    clientId: client.id,
    refreshToken: token.refreshToken,
    refreshTokenExpiresOn: token.refreshTokenExpiresOn,
    userId: user.id
  });

  return accessToken.save();
};