447 lines
14 KiB
JavaScript
447 lines
14 KiB
JavaScript
const NamedMapsCacheEntry = require('../cache/model/named_maps_entry');
|
|
const cors = require('../middleware/cors');
|
|
const userMiddleware = require('../middleware/user');
|
|
const allowQueryParams = require('../middleware/allow-query-params');
|
|
const vectorError = require('../middleware/vector-error');
|
|
|
|
const DEFAULT_ZOOM_CENTER = {
|
|
zoom: 1,
|
|
center: {
|
|
lng: 0,
|
|
lat: 0
|
|
}
|
|
};
|
|
|
|
function numMapper(n) {
|
|
return +n;
|
|
}
|
|
|
|
function NamedMapsController(prepareContext, namedMapProviderCache, tileBackend, previewBackend,
|
|
surrogateKeysCache, tablesExtentApi, metadataBackend) {
|
|
this.namedMapProviderCache = namedMapProviderCache;
|
|
this.tileBackend = tileBackend;
|
|
this.previewBackend = previewBackend;
|
|
this.surrogateKeysCache = surrogateKeysCache;
|
|
this.tablesExtentApi = tablesExtentApi;
|
|
this.metadataBackend = metadataBackend;
|
|
this.prepareContext = prepareContext;
|
|
}
|
|
|
|
module.exports = NamedMapsController;
|
|
|
|
NamedMapsController.prototype.register = function(app) {
|
|
app.get(
|
|
app.base_url_templated + '/:template_id/:layer/:z/:x/:y.(:format)',
|
|
cors(),
|
|
userMiddleware,
|
|
this.prepareContext,
|
|
this.getNamedMapProvider(),
|
|
this.getAffectedTables(),
|
|
this.getTile(),
|
|
this.setSurrogateKey(),
|
|
this.setCacheChannelHeader(),
|
|
this.setLastModifiedHeader(),
|
|
this.setCacheControlHeader(),
|
|
this.setContentTypeHeader(),
|
|
this.respond(),
|
|
vectorError()
|
|
);
|
|
|
|
app.get(
|
|
app.base_url_mapconfig + '/static/named/:template_id/:width/:height.:format',
|
|
cors(),
|
|
userMiddleware,
|
|
allowQueryParams(['layer', 'zoom', 'lon', 'lat', 'bbox']),
|
|
this.prepareContext,
|
|
this.getNamedMapProvider('STATIC_VIZ_MAP'),
|
|
this.getAffectedTables(),
|
|
this.getTemplate('STATIC_VIZ_MAP'),
|
|
this.prepareLayerFilterFromPreviewLayers('STATIC_VIZ_MAP'),
|
|
this.getStaticImageOptions(),
|
|
this.getImage('STATIC_VIZ_MAP'),
|
|
this.incrementMapViews(),
|
|
this.setSurrogateKey(),
|
|
this.setCacheChannelHeader(),
|
|
this.setLastModifiedHeader(),
|
|
this.setCacheControlHeader(),
|
|
this.setContentTypeHeader(),
|
|
this.respond()
|
|
);
|
|
};
|
|
|
|
NamedMapsController.prototype.getNamedMapProvider = function (label) {
|
|
return function getNamedMapProviderMiddleware (req, res, next) {
|
|
const { user } = res.locals;
|
|
const { config, auth_token } = req.query;
|
|
const { template_id } = req.params;
|
|
|
|
this.namedMapProviderCache.get(user, template_id, config, auth_token, res.locals, (err, namedMapProvider) => {
|
|
if (err) {
|
|
err.label = label;
|
|
return next(err);
|
|
}
|
|
|
|
res.locals.namedMapProvider = namedMapProvider;
|
|
|
|
next();
|
|
});
|
|
}.bind(this);
|
|
};
|
|
|
|
NamedMapsController.prototype.getAffectedTables = function () {
|
|
return function getAffectedTables (req, res, next) {
|
|
const { namedMapProvider } = res.locals;
|
|
|
|
namedMapProvider.getAffectedTablesAndLastUpdatedTime((err, affectedTablesAndLastUpdate) => {
|
|
req.profiler.done('affectedTables');
|
|
|
|
if (err) {
|
|
return next(err);
|
|
}
|
|
|
|
res.locals.affectedTablesAndLastUpdate = affectedTablesAndLastUpdate;
|
|
|
|
next();
|
|
});
|
|
}.bind(this);
|
|
};
|
|
|
|
NamedMapsController.prototype.getTemplate = function (label) {
|
|
return function getTemplateMiddleware (req, res, next) {
|
|
const { namedMapProvider } = res.locals;
|
|
|
|
namedMapProvider.getTemplate((err, template) => {
|
|
if (err) {
|
|
err.label = label;
|
|
return next(err);
|
|
}
|
|
|
|
res.locals.template = template;
|
|
|
|
next();
|
|
});
|
|
};
|
|
};
|
|
|
|
NamedMapsController.prototype.prepareLayerFilterFromPreviewLayers = function (label) {
|
|
return function prepareLayerFilterFromPreviewLayersMiddleware (req, res, next) {
|
|
const { user, template } = res.locals;
|
|
const { template_id } = req.params;
|
|
const { config, auth_token } = req.query;
|
|
|
|
if (!template || !template.view || !template.view.preview_layers) {
|
|
return next();
|
|
}
|
|
|
|
var previewLayers = template.view.preview_layers;
|
|
var layerVisibilityFilter = [];
|
|
|
|
template.layergroup.layers.forEach(function (layer, index) {
|
|
if (previewLayers[''+index] !== false && previewLayers[layer.id] !== false) {
|
|
layerVisibilityFilter.push(''+index);
|
|
}
|
|
});
|
|
|
|
if (!layerVisibilityFilter.length) {
|
|
return next();
|
|
}
|
|
|
|
// overwrites 'all' default filter
|
|
res.locals.layer = layerVisibilityFilter.join(',');
|
|
|
|
// recreates the provider
|
|
this.namedMapProviderCache.get(user, template_id, config, auth_token, res.locals, (err, provider) => {
|
|
if (err) {
|
|
err.label = label;
|
|
return next(err);
|
|
}
|
|
|
|
res.locals.namedMapProvider = provider;
|
|
|
|
next();
|
|
});
|
|
}.bind(this);
|
|
};
|
|
|
|
NamedMapsController.prototype.getTile = function () {
|
|
return function getTileMiddleware (req, res, next) {
|
|
const { namedMapProvider } = res.locals;
|
|
|
|
this.tileBackend.getTile(namedMapProvider, req.params, (err, tile, headers, stats) => {
|
|
req.profiler.add(stats);
|
|
|
|
if (err) {
|
|
err.label = 'NAMED_MAP_TILE';
|
|
return next(err);
|
|
}
|
|
|
|
res.locals.body = tile;
|
|
res.locals.headers = headers;
|
|
res.locals.stats = stats;
|
|
|
|
next();
|
|
});
|
|
}.bind(this);
|
|
};
|
|
|
|
NamedMapsController.prototype.getStaticImageOptions = function () {
|
|
return function getStaticImageOptionsMiddleware(req, res, next) {
|
|
const { user, namedMapProvider, template, zoom, lon, lat, bbox } = res.locals;
|
|
|
|
if ([zoom, lon, lat].map(numMapper).every(Number.isFinite)) {
|
|
res.locals.imageOpts = {
|
|
zoom: zoom,
|
|
center: {
|
|
lng: lon,
|
|
lat: lat
|
|
}
|
|
};
|
|
|
|
return next();
|
|
}
|
|
|
|
if (bbox) {
|
|
var _bbox = bbox.split(',').map(numMapper);
|
|
if (_bbox.length === 4 && _bbox.every(Number.isFinite)) {
|
|
res.locals.imageOpts = {
|
|
bounds: {
|
|
west: _bbox[0],
|
|
south: _bbox[1],
|
|
east: _bbox[2],
|
|
north: _bbox[3]
|
|
}
|
|
};
|
|
|
|
return next();
|
|
}
|
|
}
|
|
|
|
if (template.view) {
|
|
var zoomCenter = templateZoomCenter(template.view);
|
|
if (zoomCenter) {
|
|
if (Number.isFinite(+zoom)) {
|
|
zoomCenter.zoom = +zoom;
|
|
}
|
|
res.locals.imageOpts = zoomCenter;
|
|
return next();
|
|
}
|
|
|
|
var bounds = templateBounds(template.view);
|
|
if (bounds) {
|
|
res.locals.imageOpts = bounds;
|
|
return next();
|
|
}
|
|
}
|
|
|
|
res.locals.imageOpts = DEFAULT_ZOOM_CENTER;
|
|
|
|
namedMapProvider.getAffectedTablesAndLastUpdatedTime((err, affectedTablesAndLastUpdate) => {
|
|
if (err) {
|
|
return next();
|
|
}
|
|
|
|
var affectedTables = affectedTablesAndLastUpdate.tables || [];
|
|
|
|
if (affectedTables.length === 0) {
|
|
return next();
|
|
}
|
|
|
|
this.tablesExtentApi.getBounds(user, affectedTables, (err, bounds) => {
|
|
if (err) {
|
|
return next();
|
|
}
|
|
|
|
res.locals.imageOpts = bounds;
|
|
return next();
|
|
});
|
|
});
|
|
}.bind(this);
|
|
};
|
|
|
|
NamedMapsController.prototype.getImage = function (label) {
|
|
return function getImageMiddleware (req, res, next) {
|
|
const { imageOpts, namedMapProvider } = res.locals;
|
|
const { zoom, center, bounds } = imageOpts;
|
|
|
|
let { width, height } = req.params;
|
|
|
|
width = +width;
|
|
height = +height;
|
|
|
|
const format = req.params.format === 'jpg' ? 'jpeg' : 'png';
|
|
// We force always the tile to be generated using PNG because
|
|
// is the only format we support by now
|
|
res.locals.format = 'png';
|
|
res.locals.layer = res.locals.layer || 'all';
|
|
|
|
if (zoom !== undefined && center) {
|
|
return this.previewBackend.getImage(namedMapProvider, format, width, height, zoom, center,
|
|
(err, image, headers, stats) => {
|
|
if (err) {
|
|
err.label = label;
|
|
return next(err);
|
|
}
|
|
|
|
res.locals.body = image;
|
|
res.locals.headers = headers;
|
|
res.locals.stats = stats;
|
|
|
|
next();
|
|
});
|
|
}
|
|
|
|
this.previewBackend.getImage(namedMapProvider, format, width, height, bounds, (err, image, headers, stats) => {
|
|
if (err) {
|
|
err.label = label;
|
|
return next(err);
|
|
}
|
|
|
|
res.locals.body = image;
|
|
res.locals.headers = headers;
|
|
res.locals.stats = stats;
|
|
|
|
next();
|
|
});
|
|
}.bind(this);
|
|
};
|
|
|
|
const incrementMapViewsError = ctx => `ERROR: failed to increment mapview count for user '${ctx.user}': ${ctx.err}`;
|
|
|
|
NamedMapsController.prototype.incrementMapViews = function () {
|
|
return function incrementMapViewsMiddleware(req, res, next) {
|
|
const { user, namedMapProvider } = res.locals;
|
|
|
|
namedMapProvider.getMapConfig((err, mapConfig) => {
|
|
if (err) {
|
|
global.logger.log(incrementMapViewsError({ user, err }));
|
|
return next();
|
|
}
|
|
|
|
const statTag = mapConfig.obj().stat_tag;
|
|
|
|
this.metadataBackend.incMapviewCount(user, statTag, (err) => {
|
|
if (err) {
|
|
global.logger.log(incrementMapViewsError({ user, err }));
|
|
}
|
|
|
|
next();
|
|
});
|
|
});
|
|
}.bind(this);
|
|
};
|
|
|
|
function templateZoomCenter(view) {
|
|
if (view.zoom !== undefined && view.center) {
|
|
return {
|
|
zoom: view.zoom,
|
|
center: view.center
|
|
};
|
|
}
|
|
return false;
|
|
}
|
|
|
|
function templateBounds(view) {
|
|
if (view.bounds) {
|
|
var hasAllBounds = ['west', 'south', 'east', 'north'].every(function(prop) {
|
|
return Number.isFinite(view.bounds[prop]);
|
|
});
|
|
|
|
if (hasAllBounds) {
|
|
return {
|
|
bounds: {
|
|
west: view.bounds.west,
|
|
south: view.bounds.south,
|
|
east: view.bounds.east,
|
|
north: view.bounds.north
|
|
}
|
|
};
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
NamedMapsController.prototype.setCacheChannelHeader = function () {
|
|
return function setCacheChannelHeaderMiddleware (req, res, next) {
|
|
const { affectedTablesAndLastUpdate } = res.locals;
|
|
|
|
if (!affectedTablesAndLastUpdate || !!affectedTablesAndLastUpdate.tables) {
|
|
res.set('X-Cache-Channel', affectedTablesAndLastUpdate.getCacheChannel());
|
|
}
|
|
|
|
next();
|
|
};
|
|
};
|
|
|
|
NamedMapsController.prototype.setSurrogateKey = function () {
|
|
return function setSurrogateKeyMiddleware(req, res, next) {
|
|
const { user, namedMapProvider, affectedTablesAndLastUpdate } = res.locals;
|
|
|
|
this.surrogateKeysCache.tag(res, new NamedMapsCacheEntry(user, namedMapProvider.getTemplateName()));
|
|
if (!affectedTablesAndLastUpdate || !!affectedTablesAndLastUpdate.tables) {
|
|
if (affectedTablesAndLastUpdate.tables.length > 0) {
|
|
this.surrogateKeysCache.tag(res, affectedTablesAndLastUpdate);
|
|
}
|
|
}
|
|
|
|
next();
|
|
}.bind(this);
|
|
};
|
|
|
|
NamedMapsController.prototype.setLastModifiedHeader = function () {
|
|
return function setLastModifiedHeaderMiddleware(req, res, next) {
|
|
const { affectedTablesAndLastUpdate } = res.locals;
|
|
|
|
if (!affectedTablesAndLastUpdate || !!affectedTablesAndLastUpdate.tables) {
|
|
var lastModifiedDate;
|
|
if (Number.isFinite(affectedTablesAndLastUpdate.lastUpdatedTime)) {
|
|
lastModifiedDate = new Date(affectedTablesAndLastUpdate.getLastUpdatedAt());
|
|
} else {
|
|
lastModifiedDate = new Date();
|
|
}
|
|
|
|
res.set('Last-Modified', lastModifiedDate.toUTCString());
|
|
}
|
|
|
|
next();
|
|
};
|
|
};
|
|
|
|
NamedMapsController.prototype.setCacheControlHeader = function () {
|
|
return function setCacheControlHeaderMiddleware(req, res, next) {
|
|
const { affectedTablesAndLastUpdate } = res.locals;
|
|
|
|
res.set('Cache-Control', 'public,max-age=7200,must-revalidate');
|
|
|
|
if (!affectedTablesAndLastUpdate || !!affectedTablesAndLastUpdate.tables) {
|
|
// we increase cache control as we can invalidate it
|
|
res.set('Cache-Control', 'public,max-age=31536000');
|
|
}
|
|
|
|
next();
|
|
};
|
|
};
|
|
|
|
NamedMapsController.prototype.setContentTypeHeader = function () {
|
|
return function setContentTypeHeaderMiddleware(req, res, next) {
|
|
const { headers = {} } = res.locals;
|
|
|
|
res.set('Content-Type', headers['content-type'] || headers['Content-Type'] || 'image/png');
|
|
|
|
next();
|
|
};
|
|
};
|
|
|
|
NamedMapsController.prototype.respond = function () {
|
|
return function respondMiddleware (req, res) {
|
|
const { body, stats = {}, format } = res.locals;
|
|
|
|
req.profiler.done('render-' + format);
|
|
req.profiler.add(stats);
|
|
|
|
res.status(200);
|
|
res.send(body);
|
|
};
|
|
};
|