Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
53 changes: 33 additions & 20 deletions examples/mongodb/model.js
Original file line number Diff line number Diff line change
Expand Up @@ -13,10 +13,12 @@ var Schema = mongoose.Schema;
mongoose.model('OAuthTokens', new Schema({
accessToken: { type: String },
accessTokenExpiresOn: { type: Date },
client : { type: Object }, // `client` and `user` are required in multiple places, for example `getAccessToken()`
clientId: { type: String },
refreshToken: { type: String },
refreshTokenExpiresOn: { type: Date },
userId: { type: String }
user : { type: Object },
userId: { type: String },
}));

mongoose.model('OAuthClients', new Schema({
Expand All @@ -42,56 +44,67 @@ var OAuthUsersModel = mongoose.model('OAuthUsers');
*/

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Dropped these in favour of the developer adding mongoose.set('debug', true); to the top of the file to get console output.

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

return OAuthTokensModel.findOne({ accessToken: bearerToken });
// Adding `.lean()`, as we get a mongoose wrapper object back from `findOne(...)`, and oauth2-server complains.
return OAuthTokensModel.findOne({ accessToken: bearerToken }).lean();
};

/**
* Get client.
*/

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

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

/**
* Get refresh token.
*/

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

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

/*
/**
* Get user.
*/

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

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

/**
* 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,
client : client,
clientId: client.clientId,
refreshToken: token.refreshToken,
refreshTokenExpiresOn: token.refreshTokenExpiresOn,
userId: user.id
user : user,
userId: user._id,
});
// Can't just chain `lean()` to `save()` as we did with `findOne()` elsewhere. Instead we use `Promise` to resolve the data.
return new Promise( function(resolve,reject){
accessToken.save(function(err,data){
if( err ) reject( err );
else resolve( data );
}) ;
}).then(function(saveResult){
// `saveResult` is mongoose wrapper object, not doc itself. Calling `toJSON()` returns the doc.
saveResult = saveResult && typeof saveResult == 'object' ? saveResult.toJSON() : saveResult;

// Unsure what else points to `saveResult` in oauth2-server, making copy to be safe
var data = new Object();
for( var prop in saveResult ) data[prop] = saveResult[prop];

// /oauth-server/lib/models/token-model.js complains if missing `client` and `user`. Creating missing properties.
data.client = data.clientId;
data.user = data.userId;

return data;
});

return accessToken.save();
};