9de4b8b2a7
* Adds flow types / Configuration interfaces * Lets call it options * Use a single interface to generate the configurations * Translates options to definitions only if comments are set * improves logic * Moves objects around * Fixes issue affecting logging of circular objects * fixes undefined env * Moves all defaults to defaults * Adds back CLI defaults * Restored defaults in commander.js * Merge provided defaults and platform defaults * Addresses visual nits * Improves Config.js code * Adds ability to pass the default value in trailing comments * Load platform defaults from the definitions file * proper default values on various options * Adds ParseServer.start and server.start(options) as quick startup methods * Moves creating liveQueryServer http into ParseServer.js * removes dead code * Adds tests to guarantee we can start a LQ Server from main module * Fixes incorrect code regading liveQuery init port * Start a http server for LQ if port is specified * ensure we dont fail if config.port is not set * Specify port * ignore other path skipped in tests * Adds test for custom middleware setting * Refactors new Config into Config.get - Hides AppCache from ParseServer.js, use Config.put which validates * Extracts controller creation into Controllers/index.js - This makes the ParseServer init way simpler * Move serverURL inference into ParseServer * review nits
101 lines
2.9 KiB
JavaScript
101 lines
2.9 KiB
JavaScript
const Config = require('./Config');
|
|
const Auth = require('./Auth');
|
|
const RESTController = require('parse/lib/node/RESTController');
|
|
const URL = require('url');
|
|
const Parse = require('parse/node');
|
|
|
|
function getSessionToken(options) {
|
|
if (options && typeof options.sessionToken === 'string') {
|
|
return Parse.Promise.as(options.sessionToken);
|
|
}
|
|
return Parse.Promise.as(null);
|
|
}
|
|
|
|
function getAuth(options = {}, config) {
|
|
const installationId = options.installationId || 'cloud';
|
|
if (options.useMasterKey) {
|
|
return Parse.Promise.as(new Auth.Auth({config, isMaster: true, installationId }));
|
|
}
|
|
return getSessionToken(options).then((sessionToken) => {
|
|
if (sessionToken) {
|
|
options.sessionToken = sessionToken;
|
|
return Auth.getAuthForSessionToken({
|
|
config,
|
|
sessionToken: sessionToken,
|
|
installationId
|
|
});
|
|
} else {
|
|
return Parse.Promise.as(new Auth.Auth({ config, installationId }));
|
|
}
|
|
})
|
|
}
|
|
|
|
function ParseServerRESTController(applicationId, router) {
|
|
function handleRequest(method, path, data = {}, options = {}) {
|
|
// Store the arguments, for later use if internal fails
|
|
const args = arguments;
|
|
|
|
const config = Config.get(applicationId);
|
|
const serverURL = URL.parse(config.serverURL);
|
|
if (path.indexOf(serverURL.path) === 0) {
|
|
path = path.slice(serverURL.path.length, path.length);
|
|
}
|
|
|
|
if (path[0] !== "/") {
|
|
path = "/" + path;
|
|
}
|
|
|
|
if (path === '/batch') {
|
|
const promises = data.requests.map((request) => {
|
|
return handleRequest(request.method, request.path, request.body, options).then((response) => {
|
|
return Parse.Promise.as({success: response});
|
|
}, (error) => {
|
|
return Parse.Promise.as({error: {code: error.code, error: error.message}});
|
|
});
|
|
});
|
|
return Parse.Promise.all(promises);
|
|
}
|
|
|
|
let query;
|
|
if (method === 'GET') {
|
|
query = data;
|
|
}
|
|
|
|
return new Parse.Promise((resolve, reject) => {
|
|
getAuth(options, config).then((auth) => {
|
|
const request = {
|
|
body: data,
|
|
config,
|
|
auth,
|
|
info: {
|
|
applicationId: applicationId,
|
|
sessionToken: options.sessionToken
|
|
},
|
|
query
|
|
};
|
|
return Promise.resolve().then(() => {
|
|
return router.tryRouteRequest(method, path, request);
|
|
}).then((response) => {
|
|
resolve(response.response, response.status, response);
|
|
}, (err) => {
|
|
if (err instanceof Parse.Error &&
|
|
err.code == Parse.Error.INVALID_JSON &&
|
|
err.message == `cannot route ${method} ${path}`) {
|
|
RESTController.request.apply(null, args).then(resolve, reject);
|
|
} else {
|
|
reject(err);
|
|
}
|
|
});
|
|
}, reject);
|
|
});
|
|
}
|
|
|
|
return {
|
|
request: handleRequest,
|
|
ajax: RESTController.ajax
|
|
};
|
|
}
|
|
|
|
export default ParseServerRESTController;
|
|
export { ParseServerRESTController };
|