132 lines
3.8 KiB
TypeScript
132 lines
3.8 KiB
TypeScript
import bodyParser from 'body-parser';
|
|
import express from 'express';
|
|
|
|
import * as editHistoryController from './controllers/editHistoryController';
|
|
import { ApiParamError, ApiUserError } from './errors/api';
|
|
import { DatabaseError } from './errors/general';
|
|
import buildingsRouter from './routes/buildingsRouter';
|
|
import extractsRouter from './routes/extractsRouter';
|
|
import leaderboardRouter from './routes/leaderboardRouter';
|
|
import usersRouter from './routes/usersRouter';
|
|
import { queryLocation } from './services/search';
|
|
import { authUser, getNewUserAPIKey, logout } from './services/user';
|
|
|
|
const server = express.Router();
|
|
|
|
// parse POSTed json body
|
|
server.use(bodyParser.json());
|
|
|
|
server.use('/buildings', buildingsRouter);
|
|
server.use('/users', usersRouter);
|
|
server.use('/extracts', extractsRouter);
|
|
server.use('/leaderboard', leaderboardRouter);
|
|
|
|
server.get('/history', editHistoryController.getGlobalEditHistory);
|
|
|
|
// POST user auth
|
|
server.post('/login', function (req, res) {
|
|
authUser(req.body.username, req.body.password).then(function (user: any) { // TODO: remove any
|
|
if (user.user_id) {
|
|
req.session.user_id = user.user_id;
|
|
} else {
|
|
req.session.user_id = undefined;
|
|
}
|
|
res.send(user);
|
|
}).catch(function (error) {
|
|
res.send(error);
|
|
});
|
|
});
|
|
|
|
// POST user logout
|
|
server.post('/logout', function (req, res) {
|
|
logout(req.session).then(() => {
|
|
res.send({ success: true });
|
|
}).catch(err => {
|
|
console.error(err);
|
|
res.send({ error: 'Failed to end session'});
|
|
});
|
|
});
|
|
|
|
// POST generate API key
|
|
server.post('/api/key', function (req, res) {
|
|
if (!req.session.user_id) {
|
|
res.send({ error: 'Must be logged in' });
|
|
return;
|
|
}
|
|
|
|
getNewUserAPIKey(req.session.user_id).then(function (apiKey) {
|
|
res.send(apiKey);
|
|
}).catch(function (error) {
|
|
res.send(error);
|
|
});
|
|
});
|
|
|
|
// GET search
|
|
server.get('/search', function (req, res) {
|
|
const searchTerm = req.query.q;
|
|
if (!searchTerm) {
|
|
res.send({
|
|
error: 'Please provide a search term'
|
|
});
|
|
return;
|
|
}
|
|
queryLocation(searchTerm).then((results) => {
|
|
if (typeof (results) === 'undefined') {
|
|
res.send({
|
|
error: 'Database error'
|
|
});
|
|
return;
|
|
}
|
|
res.send({
|
|
results: results.map(item => {
|
|
// map from DB results to GeoJSON Feature objects
|
|
const geom = JSON.parse(item.st_asgeojson);
|
|
return {
|
|
type: 'Feature',
|
|
attributes: {
|
|
label: item.search_str,
|
|
zoom: item.zoom || 9
|
|
},
|
|
geometry: geom
|
|
};
|
|
})
|
|
});
|
|
}).catch(function (error) {
|
|
res.send(error);
|
|
});
|
|
});
|
|
|
|
server.use((err: any, req: express.Request, res: express.Response, next: express.NextFunction) => {
|
|
if (res.headersSent) {
|
|
return next(err);
|
|
}
|
|
|
|
if (err != undefined) {
|
|
console.log('Global error handler: ', err);
|
|
|
|
if (err instanceof ApiUserError) {
|
|
let errorMessage: string;
|
|
|
|
if(err instanceof ApiParamError) {
|
|
errorMessage = `Problem with parameter ${err.paramName}: ${err.message}`;
|
|
} else {
|
|
errorMessage = err.message;
|
|
}
|
|
|
|
res.status(400).send({ error: errorMessage });
|
|
} else if(err instanceof DatabaseError){
|
|
res.status(500).send({ error: 'Database error' });
|
|
} else {
|
|
res.status(500).send({ error: 'Server error' });
|
|
}
|
|
|
|
}
|
|
});
|
|
|
|
server.use((req, res) => {
|
|
res.status(404).json({ error: 'Resource not found'});
|
|
});
|
|
|
|
|
|
export default server;
|