301 lines
11 KiB
JavaScript
301 lines
11 KiB
JavaScript
////////////////////////////////////////////////////////////////////////////
|
|
//
|
|
// Copyright 2016 Realm Inc.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
//
|
|
////////////////////////////////////////////////////////////////////////////
|
|
|
|
'use strict';
|
|
|
|
const AuthError = require('./errors').AuthError;
|
|
const permissionApis = require('./permission-api');
|
|
|
|
function node_require(module) {
|
|
return require(module);
|
|
}
|
|
|
|
function checkTypes(args, types) {
|
|
args = Array.prototype.slice.call(args);
|
|
for (var i = 0; i < types.length; ++i) {
|
|
if (args.length > i && typeof args[i] !== types[i]) {
|
|
throw new TypeError('param ' + i + ' must be of type ' + types[i]);
|
|
}
|
|
}
|
|
}
|
|
|
|
/* global fetch */
|
|
const performFetch = typeof fetch === 'undefined' ? node_require('node-fetch') : fetch;
|
|
|
|
const url_parse = require('url-parse');
|
|
|
|
const postHeaders = {
|
|
'content-type': 'application/json;charset=utf-8',
|
|
'accept': 'application/json'
|
|
};
|
|
|
|
function auth_url(server) {
|
|
if (server.charAt(server.length - 1) != '/') {
|
|
return server + '/auth';
|
|
}
|
|
return server + 'auth';
|
|
}
|
|
|
|
function scheduleAccessTokenRefresh(user, localRealmPath, realmUrl, expirationDate) {
|
|
const refreshBuffer = 10 * 1000;
|
|
const timeout = expirationDate - Date.now() - refreshBuffer;
|
|
setTimeout(() => refreshAccessToken(user, localRealmPath, realmUrl), timeout);
|
|
}
|
|
|
|
function print_error() {
|
|
(console.error || console.log).apply(console, arguments);
|
|
}
|
|
|
|
function refreshAccessToken(user, localRealmPath, realmUrl) {
|
|
let parsedRealmUrl = url_parse(realmUrl);
|
|
const url = auth_url(user.server);
|
|
const options = {
|
|
method: 'POST',
|
|
body: JSON.stringify({
|
|
data: user.token,
|
|
path: parsedRealmUrl.pathname,
|
|
provider: 'realm',
|
|
app_id: ''
|
|
}),
|
|
headers: postHeaders
|
|
};
|
|
performFetch(url, options)
|
|
// in case something lower in the HTTP stack breaks, try again in 10 seconds
|
|
.catch(() => setTimeout(() => refreshAccessToken(user, localRealmPath, realmUrl), 10 * 1000))
|
|
.then((response) => response.json().then((json) => { return { response, json }; }))
|
|
.then((responseAndJson) => {
|
|
const response = responseAndJson.response;
|
|
const json = responseAndJson.json;
|
|
// Look up a fresh instance of the user.
|
|
// We do this because in React Native Remote Debugging
|
|
// `Realm.clearTestState()` will have invalidated the user object
|
|
let newUser = user.constructor.all[user.identity];
|
|
if (newUser) {
|
|
let session = newUser._sessionForOnDiskPath(localRealmPath);
|
|
if (session) {
|
|
const errorHandler = session.config.error;
|
|
if (response.status != 200) {
|
|
let error = new AuthError(json);
|
|
if (errorHandler) {
|
|
errorHandler(session, error);
|
|
} else {
|
|
print_error('Unhandled session token refresh error', error);
|
|
}
|
|
} else if (session.state !== 'invalid') {
|
|
parsedRealmUrl.set('pathname', json.access_token.token_data.path);
|
|
session._refreshAccessToken(json.access_token.token, parsedRealmUrl.href);
|
|
|
|
if (errorHandler && errorHandler._notifyOnAccessTokenRefreshed) {
|
|
errorHandler(session, errorHandler._notifyOnAccessTokenRefreshed)
|
|
}
|
|
|
|
const tokenExpirationDate = new Date(json.access_token.token_data.expires * 1000);
|
|
scheduleAccessTokenRefresh(newUser, localRealmPath, realmUrl, tokenExpirationDate);
|
|
}
|
|
} else {
|
|
print_error(`Unhandled session token refresh error: could not look up session at path ${localRealmPath}`);
|
|
}
|
|
}
|
|
});
|
|
}
|
|
|
|
/**
|
|
* The base authentication method. It fires a JSON POST to the server parameter plus the auth url
|
|
* For example, if the server parameter is `http://myapp.com`, this url will post to `http://myapp.com/auth`
|
|
* @param {object} userConstructor
|
|
* @param {string} server the http or https server url
|
|
* @param {object} json the json to post to the auth endpoint
|
|
* @param {Function} callback an optional callback with an error and user parameter
|
|
* @returns {Promise} only returns a promise if the callback parameter was omitted
|
|
*/
|
|
function _authenticate(userConstructor, server, json, callback) {
|
|
json.app_id = '';
|
|
const url = auth_url(server);
|
|
const options = {
|
|
method: 'POST',
|
|
body: JSON.stringify(json),
|
|
headers: postHeaders,
|
|
open_timeout: 5000
|
|
};
|
|
const promise = performFetch(url, options)
|
|
.then((response) => {
|
|
if (response.status !== 200) {
|
|
return response.json().then((body) => callback(new AuthError(body)));
|
|
} else {
|
|
return response.json().then(function (body) {
|
|
// TODO: validate JSON
|
|
const token = body.refresh_token.token;
|
|
const identity = body.refresh_token.token_data.identity;
|
|
const isAdmin = body.refresh_token.token_data.is_admin;
|
|
callback(undefined, userConstructor.createUser(server, identity, token, false, isAdmin));
|
|
})
|
|
}
|
|
});
|
|
|
|
if (callback) {
|
|
promise.then(user => {
|
|
callback(null, user);
|
|
})
|
|
.catch(err => {
|
|
callback(err)
|
|
});
|
|
} else {
|
|
return promise;
|
|
}
|
|
}
|
|
|
|
const staticMethods = {
|
|
get current() {
|
|
const allUsers = this.all;
|
|
const keys = Object.keys(allUsers);
|
|
if (keys.length === 0) {
|
|
return undefined;
|
|
} else if (keys.length > 1) {
|
|
throw new Error("Multiple users are logged in");
|
|
}
|
|
|
|
return allUsers[keys[0]];
|
|
},
|
|
|
|
adminUser(token, server) {
|
|
checkTypes(arguments, ['string', 'string']);
|
|
const uuid = 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function (c) {
|
|
var r = Math.random() * 16 | 0, v = c == 'x' ? r : (r & 0x3 | 0x8);
|
|
return v.toString(16);
|
|
});
|
|
return this.createUser(server || '', uuid, token, true);
|
|
},
|
|
|
|
register(server, username, password, callback) {
|
|
checkTypes(arguments, ['string', 'string', 'string', 'function']);
|
|
const json = {
|
|
provider: 'password',
|
|
user_info: { password: password, register: true },
|
|
data: username
|
|
};
|
|
if (callback) {
|
|
_authenticate(this, server, json, callback);
|
|
} else {
|
|
return _authenticate(this, server)
|
|
}
|
|
},
|
|
|
|
login(server, username, password, callback) {
|
|
checkTypes(arguments, ['string', 'string', 'string', 'function']);
|
|
const json = {
|
|
provider: 'password',
|
|
user_info: { password: password },
|
|
data: username
|
|
};
|
|
if (callback) {
|
|
_authenticate(this, server, json, callback);
|
|
} else {
|
|
return _authenticate(this, server)
|
|
}
|
|
},
|
|
|
|
registerWithProvider(server, options, callback) {
|
|
|
|
// Compatibility with previous signature:
|
|
// registerWithProvider(server, provider, providerToken, callback)
|
|
if (arguments.length === 4) {
|
|
checkTypes(arguments, ['string', 'string', 'string', 'function']);
|
|
options = {
|
|
provider: arguments[1],
|
|
providerToken: arguments[2]
|
|
};
|
|
callback = arguments[3];
|
|
} else {
|
|
checkTypes(arguments, ['string', 'object', 'function']);
|
|
}
|
|
|
|
let json = {
|
|
provider: options.provider,
|
|
data: options.providerToken,
|
|
};
|
|
|
|
if (options.userInfo) {
|
|
json.user_info = options.userInfo;
|
|
}
|
|
|
|
if (callback) {
|
|
_authenticate(this, server, json, callback);
|
|
} else {
|
|
return _authenticate(this, server)
|
|
}
|
|
},
|
|
|
|
_refreshAccessToken: refreshAccessToken
|
|
};
|
|
|
|
const instanceMethods = {
|
|
openManagementRealm() {
|
|
let url = url_parse(this.server);
|
|
if (url.protocol === 'http:') {
|
|
url.set('protocol', 'realm:');
|
|
} else if (url.protocol === 'https:') {
|
|
url.set('protocol', 'realms:');
|
|
} else {
|
|
throw new Error(`Unexpected user auth url: ${this.server}`);
|
|
}
|
|
|
|
url.set('pathname', '/~/__management');
|
|
|
|
return new this.constructor._realmConstructor({
|
|
schema: require('./management-schema'),
|
|
sync: {
|
|
user: this,
|
|
url: url.href
|
|
}
|
|
});
|
|
},
|
|
retrieveAccount(provider, provider_id) {
|
|
checkTypes(arguments, ['string', 'string']);
|
|
const url = url_parse(this.server);
|
|
url.set('pathname', `/api/providers/${provider}/accounts/${provider_id}`);
|
|
const headers = {
|
|
Authorization: this.token
|
|
};
|
|
const options = {
|
|
method: 'GET',
|
|
headers,
|
|
open_timeout: 5000
|
|
};
|
|
return performFetch(url.href, options)
|
|
.then((response) => {
|
|
if (response.status !== 200) {
|
|
return response.json()
|
|
.then(body => {
|
|
throw new AuthError(body);
|
|
});
|
|
} else {
|
|
|
|
return response.json();
|
|
}
|
|
});
|
|
},
|
|
};
|
|
|
|
// Append the permission apis
|
|
Object.assign(instanceMethods, permissionApis);
|
|
|
|
module.exports = {
|
|
static: staticMethods,
|
|
instance: instanceMethods
|
|
};
|