Refactor and deduplicate logic in SessionsRouter.
This commit is contained in:
63
src/Routers/SessionsRouter.js
Normal file
63
src/Routers/SessionsRouter.js
Normal file
@@ -0,0 +1,63 @@
|
||||
|
||||
import ClassesRouter from './ClassesRouter';
|
||||
import PromiseRouter from '../PromiseRouter';
|
||||
import rest from '../rest';
|
||||
import Auth from '../Auth';
|
||||
|
||||
export class SessionsRouter extends ClassesRouter {
|
||||
handleFind(req) {
|
||||
req.params.className = '_Session';
|
||||
return super.handleFind(req);
|
||||
}
|
||||
|
||||
handleGet(req) {
|
||||
req.params.className = '_Session';
|
||||
return super.handleGet(req);
|
||||
}
|
||||
|
||||
handleCreate(req) {
|
||||
req.params.className = '_Session';
|
||||
return super.handleCreate(req);
|
||||
}
|
||||
|
||||
handleUpdate(req) {
|
||||
req.params.className = '_Session';
|
||||
return super.handleUpdate(req);
|
||||
}
|
||||
|
||||
handleDelete(req) {
|
||||
req.params.className = '_Session';
|
||||
return super.handleDelete(req);
|
||||
}
|
||||
|
||||
handleMe(req) {
|
||||
// TODO: Verify correct behavior
|
||||
if (!req.info || !req.info.sessionToken) {
|
||||
throw new Parse.Error(Parse.Error.INVALID_SESSION_TOKEN,
|
||||
'Session token required.');
|
||||
}
|
||||
return rest.find(req.config, Auth.master(req.config), '_Session', { _session_token: req.info.sessionToken })
|
||||
.then((response) => {
|
||||
if (!response.results || response.results.length == 0) {
|
||||
throw new Parse.Error(Parse.Error.INVALID_SESSION_TOKEN,
|
||||
'Session token not found.');
|
||||
}
|
||||
return {
|
||||
response: response.results[0]
|
||||
};
|
||||
});
|
||||
}
|
||||
|
||||
getExpressRouter() {
|
||||
let router = new PromiseRouter();
|
||||
router.route('GET','/sessions/me', req => { return this.handleMe(req); });
|
||||
router.route('GET', '/sessions', req => { return this.handleFind(req); });
|
||||
router.route('GET', '/sessions/:objectId', req => { return this.handleGet(req); });
|
||||
router.route('POST', '/sessions', req => { return this.handleCreate(req); });
|
||||
router.route('PUT', '/sessions/:objectId', req => { return this.handleUpdate(req); });
|
||||
router.route('DELETE', '/sessions/:objectId', req => { return this.handleDelete(req); });
|
||||
return router;
|
||||
}
|
||||
}
|
||||
|
||||
export default SessionsRouter;
|
||||
@@ -21,6 +21,7 @@ import { PushController } from './Controllers/PushController';
|
||||
import { ClassesRouter } from './Routers/ClassesRouter';
|
||||
import { InstallationsRouter } from './Routers/InstallationsRouter';
|
||||
import { UsersRouter } from './Routers/UsersRouter';
|
||||
import { SessionsRouter } from './Routers/SessionsRouter';
|
||||
|
||||
// Mutate the Parse object to add the Cloud Code handlers
|
||||
addParseCloud();
|
||||
@@ -131,7 +132,7 @@ function ParseServer(args) {
|
||||
let routers = [
|
||||
new ClassesRouter().getExpressRouter(),
|
||||
new UsersRouter().getExpressRouter(),
|
||||
require('./sessions'),
|
||||
new SessionsRouter().getExpressRouter(),
|
||||
require('./roles'),
|
||||
require('./analytics'),
|
||||
new InstallationsRouter().getExpressRouter(),
|
||||
|
||||
@@ -1,98 +0,0 @@
|
||||
// sessions.js
|
||||
|
||||
var Auth = require('./Auth'),
|
||||
Parse = require('parse/node').Parse,
|
||||
PromiseRouter = require('./PromiseRouter'),
|
||||
rest = require('./rest');
|
||||
|
||||
var router = new PromiseRouter();
|
||||
|
||||
function handleCreate(req) {
|
||||
return rest.create(req.config, req.auth,
|
||||
'_Session', req.body);
|
||||
}
|
||||
|
||||
function handleUpdate(req) {
|
||||
return rest.update(req.config, req.auth, '_Session',
|
||||
req.params.objectId, req.body)
|
||||
.then((response) => {
|
||||
return {response: response};
|
||||
});
|
||||
}
|
||||
|
||||
function handleDelete(req) {
|
||||
return rest.del(req.config, req.auth,
|
||||
'_Session', req.params.objectId)
|
||||
.then(() => {
|
||||
return {response: {}};
|
||||
});
|
||||
}
|
||||
|
||||
function handleGet(req) {
|
||||
return rest.find(req.config, req.auth, '_Session',
|
||||
{objectId: req.params.objectId})
|
||||
.then((response) => {
|
||||
if (!response.results || response.results.length == 0) {
|
||||
throw new Parse.Error(Parse.Error.OBJECT_NOT_FOUND,
|
||||
'Object not found.');
|
||||
} else {
|
||||
return {response: response.results[0]};
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
function handleFind(req) {
|
||||
var options = {};
|
||||
if (req.body.skip) {
|
||||
options.skip = Number(req.body.skip);
|
||||
}
|
||||
if (req.body.limit) {
|
||||
options.limit = Number(req.body.limit);
|
||||
}
|
||||
if (req.body.order) {
|
||||
options.order = String(req.body.order);
|
||||
}
|
||||
if (req.body.count) {
|
||||
options.count = true;
|
||||
}
|
||||
if (typeof req.body.keys == 'string') {
|
||||
options.keys = req.body.keys;
|
||||
}
|
||||
if (req.body.include) {
|
||||
options.include = String(req.body.include);
|
||||
}
|
||||
|
||||
return rest.find(req.config, req.auth,
|
||||
'_Session', req.body.where, options)
|
||||
.then((response) => {
|
||||
return {response: response};
|
||||
});
|
||||
}
|
||||
|
||||
function handleMe(req) {
|
||||
// TODO: Verify correct behavior
|
||||
if (!req.info || !req.info.sessionToken) {
|
||||
throw new Parse.Error(Parse.Error.INVALID_SESSION_TOKEN,
|
||||
'Session token required.');
|
||||
}
|
||||
return rest.find(req.config, Auth.master(req.config), '_Session',
|
||||
{ _session_token: req.info.sessionToken})
|
||||
.then((response) => {
|
||||
if (!response.results || response.results.length == 0) {
|
||||
throw new Parse.Error(Parse.Error.INVALID_SESSION_TOKEN,
|
||||
'Session token not found.');
|
||||
}
|
||||
return {
|
||||
response: response.results[0]
|
||||
};
|
||||
});
|
||||
}
|
||||
|
||||
router.route('POST','/sessions', handleCreate);
|
||||
router.route('GET','/sessions/me', handleMe);
|
||||
router.route('GET','/sessions/:objectId', handleGet);
|
||||
router.route('PUT','/sessions/:objectId', handleUpdate);
|
||||
router.route('GET','/sessions', handleFind);
|
||||
router.route('DELETE','/sessions/:objectId', handleDelete);
|
||||
|
||||
module.exports = router;
|
||||
Reference in New Issue
Block a user