app.js 3.48 KiB
var express = require('express');
var bodyParser = require('body-parser');
var methodOverride = require('method-override');
var http = require('http');
var messageUtil = require('./service/messageUtil');
var respUtil = require('response_util');
var configUtil = require('sb-config-util');
var fs = require('fs');
var apiConfig = JSON.parse(fs.readFileSync(__dirname + '/config/apiConfig.json', 'utf8'));
var reqMsg = messageUtil.REQUEST;
var responseCode = messageUtil.RESPONSE_CODE;
var apiVersions = messageUtil.API_VERSION;
var reqDataLimitOfContentUpload = '30mb';
const port = process.env.sunbird_content_service_port ? process.env.sunbird_content_service_port : 5000;
global_content_provider_base_url = process.env.sunbird_content_provider_api_base_url ? process.env.sunbird_content_provider_api_base_url : "https://qa.ekstep.in/api";
global_ekstep_proxy_base_url = process.env.sunbird_content_plugin_base_url ? process.env.sunbird_content_plugin_base_url : "https://qa.ekstep.in";
global_content_provider_api_key = process.env.sunbird_content_provider_api_key;
global_learner_service_api_key = process.env.sunbird_learner_service_api_key;
global_learner_service_base_url = process.env.sunbird_learner_service_base_url ? process.env.sunbird_learner_service_base_url : "https://dev.open-sunbird.org/api";
configUtil.setApiConfig(apiConfig.API)
configUtil.setConfig('BASE_URL', global_content_provider_base_url);
configUtil.setConfig('Authorization_TOKEN', 'Bearer ' + global_content_provider_api_key);
configUtil.setConfig('LEARNER_SERVICE_BASE_URL', global_learner_service_base_url);
configUtil.setConfig('LEARNER_SERVICE_AUTHORIZATION_TOKEN', 'Bearer ' + global_learner_service_api_key);
var app = express();
const isEkStepProxyRequest = function (req) {
  let url = req.url;
  const uploadAPI = configUtil.getConfig('UPLOAD_CONTENT_URI');
  const uploadUrlAPI = configUtil.getConfig('CONTENT_UPLOAD_URL_URI')
  return url && ((url.indexOf(uploadAPI) > -1 && !(url.indexOf(uploadUrlAPI) > -1)) || url.indexOf('/telemetry') > -1);
const bodyParserJsonMiddleware = function () {
  return function (req, res, next) {
    if (isEkStepProxyRequest(req)) {
      return next();
    } else {
        return bodyParser.json({limit: reqDataLimitOfContentUpload})(req, res, next);
app.use(bodyParserJsonMiddleware());
// app.use(bodyParser.urlencoded({
//     extended: true
// }));
app.use(methodOverride());
//Cache-Control, X-Requested-With these two headers required for upload file through fine-upload library
app.use(function(req, res, next) {
    res.header('Access-Control-Allow-Origin', '*');
    res.header('Access-Control-Allow-Methods', 'GET,PUT,POST,PATCH,DELETE,OPTIONS');
    res.header('Access-Control-Allow-Headers', 'Content-Type, Authorization, cid, user-id, x-auth, Cache-Control, X-Requested-With, *');
    if ('OPTIONS' === req.method) {
        res.sendStatus(200);
    } else {
        next();
});
app.use(function (req, res, next) {
717273747576777879808182838485868788899091
res.setHeader('Connection', 'close'); next(); }); require('./routes/courseRoutes')(app); require('./routes/contentRoutes')(app); require('./routes/conceptRoutes')(app); require('./routes/searchRoutes')(app); require('./routes/dialCodeRoutes')(app); //last this middle in last require('./middlewares/proxy.middleware')(app); //Create server this.server = http.createServer(app).listen(port, function() { console.log('server running at PORT [%d]', port); }); //Close server, when we start for test cases exports.close = function() { this.server.close(); };