"use strict";
const restify = require('restify');
const getTopStories = require("./topStories");
const getPool = require("./pools");
const getSections = require("./sections");
const getTags = require("./tags");
const config = require("config");
const hl = require("highland");
const utils = require("./utils");
const ebHealth = require('eb-healthd-middleware');
const restifyEtagCache = require('restify-etag-cache');
const BeneLogger = require('bene-logger');
const logger = new BeneLogger({logging: config.logging.enabled});
const redis = require('redis');
const apicache = require('apicache');
let AWS = require("aws-sdk");
AWS.config.update({
region: config.dynamodb.region
});
Eif (config.dynamodb.endpoint) {
AWS.config.update({
"endpoint": config.dynamodb.endpoint
});
}
let dc = hl.streamifyAll(new AWS.DynamoDB.DocumentClient());
const pg = require('tm-apps-db')(config.db);
function redisCache(config, redis, apicache) {
return apicache.options({
redisClient: redis.createClient(config.cache.redis),
statusCodes: {
exclude: [],
include: [200]
}
}).middleware(config.cache.duration);
}
let app = (config, dc, pg) => {
let server = restify.createServer({
name: 'appsListAPI'
});
server.use(restify.queryParser());
server.pre(restify.pre.sanitizePath());
server.use(restify.bodyParser());
Iif(config.logging.enhanced === true) server.use(ebHealth({}));
Iif(config.cache.enabled === true) server.use(redisCache(config, redis, apicache));
server.use(restifyEtagCache());
config.cacheEndpoint = utils.setCacheEndpoint(config.articleEndpoint);
server.get("/:source/:publicationId/top-stories", getTopStories(config, dc));
server.get("/:source/:publicationId/pool/:escenicId/:area", getPool(config, dc));
server.get("/:source/:publicationId/sections/:escenicId", getSections(config, pg));
server.get("/:source/:publicationId/tags/:escenicId", getTags(config, pg));
server.get('/healthcheck', (req, res) => {
res.json({
version: process.env.npm_package_version,
server: {
name: server.name,
url: server.url
}
});
});
server.on('uncaughtException', function (req, res) {
res.send(new restify.InternalServerError());
res.end();
});
return server;
};
let server;
Iif (require.main === module) {
server = app(config, dc, pg);
server.listen(config.server.port, function () {
logger.info('server listening', {
server_name: server.name,
server_url: server.url
});
});
}
module.exports = server || app; |