Direct Access to parse-server (#2316)
* Adds ParseServerRESTController experimental support * Adds basic tests * Do not create sessionToken when requests come from cloudCode #1495
This commit is contained in:
99
src/ParseServerRESTController.js
Normal file
99
src/ParseServerRESTController.js
Normal file
@@ -0,0 +1,99 @@
|
||||
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) {
|
||||
if (options.useMasterKey) {
|
||||
return Parse.Promise.as(new Auth.Auth({config, isMaster: true, installationId: 'cloud' }));
|
||||
}
|
||||
return getSessionToken(options).then((sessionToken) => {
|
||||
if (sessionToken) {
|
||||
options.sessionToken = sessionToken;
|
||||
return Auth.getAuthForSessionToken({
|
||||
config,
|
||||
sessionToken: sessionToken,
|
||||
installationId: 'cloud'
|
||||
});
|
||||
} else {
|
||||
return Parse.Promise.as(new Auth.Auth({ config, installationId: 'cloud' }));
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
function ParseServerRESTController(applicationId, router) {
|
||||
function handleRequest(method, path, data = {}, options = {}) {
|
||||
// Store the arguments, for later use if internal fails
|
||||
let args = arguments;
|
||||
|
||||
let config = new Config(applicationId);
|
||||
let 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') {
|
||||
let 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) => {
|
||||
let 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 };
|
||||
Reference in New Issue
Block a user