Skip to content
GitLab
Select Git revision
  • release-5.3.0
  • release-5.2.0
  • release-6.0.0
  • release-5.6.0
  • dependabot/npm_and_yarn/src/minimist-and-project-sunbird/telemetry-sdk-and-handlebars-and-mkdirp-1.2.8
  • dependabot/npm_and_yarn/src/flat-and-mocha-5.0.2
  • dependabot/npm_and_yarn/src/jsonwebtoken-9.0.0
  • dependabot/npm_and_yarn/src/decode-uri-component-0.2.2
  • dependabot/npm_and_yarn/src/async-2.6.4
  • dependabot/npm_and_yarn/src/lodash-4.17.21
  • dependabot/npm_and_yarn/src/handlebars-4.7.7
  • master default
  • release-4.8.0
  • release-4.3.0
  • release-3.6.0
  • release-5.6.0_RC1
  • release-5.2.0_RC1
  • release-4.8.5_RC1
  • release-4.8.0_RC2
  • release-4.8.0_RC1
  • release-4.3.0_RC1
  • release-3.8.0_RC3
  • release-3.8.0_RC2
  • release-3.8.0_RC1
  • release-3.7.0_RC2
  • release-3.7.0_RC1
  • release-3.2.0_RC2
  • release-3.6.0_RC1
  • release-3.1.0
  • release-3.1.0_RC2
  • release-3.2.0_RC1
  • release-3.1.0_RC1
  • release-3.0.0
  • release-3.0.1_RC1
  • release-3.0.0_RC1
Find file BlameHistoryPermalink
app.js 8.41 KiB
1 
var express = require('express')
2 
var bodyParser = require('body-parser')
3 
var methodOverride = require('method-override')
4 
var http = require('http')
5 
var path = require('path')
6 
var cp = require('child_process')
7 
var TelemetryUtil = require('sb_telemetry_util')
8 
var telemetry = new TelemetryUtil()
9 
var fs = require('fs')
10 
var configUtil = require('sb-config-util')
11 
var _ = require('lodash')
12
13 
const contentProvider = require('sb_content_provider_util')
14 
var contentMetaProvider = require('./contentMetaFilter')
15 
// TODO below configuration should to be refactored in a seperate file
16
17 
const contentProviderConfigPath = path.join(__dirname, '/config/contentProviderApiConfig.json')
18 
var contentProviderApiConfig = JSON.parse(fs.readFileSync(contentProviderConfigPath))
19 
const telemtryEventConfig = JSON.parse(fs.readFileSync(path.join(__dirname, 'config/telemetryEventConfig.json')))
20
21 
var reqDataLimitOfContentUpload = '50mb'
22
23 
const port = process.env.sunbird_content_service_port ? process.env.sunbird_content_service_port : 5000
24 
const defaultChannel = process.env.sunbird_default_channel || 'sunbird'
25 
const telemetryBaseUrl = process.env.sunbird_telemetry_service_local_url ? process.env.sunbird_telemetry_service_local_url : 'http://telemetry-service:9001/'
26 
globalEkstepProxyBaseUrl = process.env.sunbird_content_plugin_base_url ? process.env.sunbird_content_plugin_base_url : 'https://qa.ekstep.in'
27
28 
const contentRepoBaseUrl = process.env.sunbird_content_repo_api_base_url || 'https://qa.ekstep.in/api'
29 
const contentRepoApiKey = process.env.sunbird_content_repo_api_key
30
31 
const learnerServiceLocalBaseUrl = process.env.sunbird_learner_service_local_base_url
32 
  ? process.env.sunbird_learner_service_local_base_url
33 
  : 'http://learner-service:9000'
34
35 
const searchServiceBaseUrl = process.env.sunbird_search_service_api_base_url || 'https://qa.ekstep.in/api/search'
36 
const dialRepoBaseUrl = process.env.sunbird_dial_repo_api_base_url || 'https://qa.ekstep.in/api'
37 
const pluginRepoBaseUrl = process.env.sunbird_plugin_repo_api_base_url || 'https://qa.ekstep.in/api'
38 
const dataServiceBaseUrl = process.env.sunbird_data_service_api_base_url || 'https://qa.ekstep.in/api'
39 
const languageServiceBaseUrl = process.env.sunbird_language_service_api_base_url || 'https://qa.ekstep.in/api/language'
40
41 
const searchServiceApiKey = process.env.sunbird_search_service_api_key
42 
const dialRepoApiKey = process.env.sunbird_dial_repo_api_key
43 
const pluginRepoApiKey = process.env.sunbird_plugin_repo_api_key
44 
const dataServiceApiKey = process.env.sunbird_data_service_api_key
45 
const enableLogging = process.env.sunbird_content_service_enable_logging
46 
const languageServiceApiKey = process.env.sunbird_language_service_api_key
47
48 
const producerId = process.env.sunbird_environment + '.' + process.env.sunbird_instance + '.content-service'
49 
const sunbirdPortalBaseUrl = process.env.sunbird_portal_base_url || 'https://staging.open-sunbird.org'
50 
const lockExpiryTime = process.env.sunbird_lock_expiry_time || 3600
51 
const contentServiceLocalBaseUrl = process.env.sunbird_content_service_local_base_url ? process.env.sunbird_content_service_local_base_url : 'http://content-service:5000'
52
53 
configUtil.setContentProviderApi(contentProviderApiConfig.API)
54 
configUtil.setConfig('CONTENT_REPO_BASE_URL', contentRepoBaseUrl)
55 
configUtil.setConfig('TELEMETRY_BASE_URL', telemetryBaseUrl)
56 
configUtil.setConfig('CONTENT_REPO_AUTHORIZATION_TOKEN', 'Bearer ' + contentRepoApiKey)
57 
configUtil.setConfig('LEARNER_SERVICE_LOCAL_BASE_URL', learnerServiceLocalBaseUrl)
58 
configUtil.setConfig('DIALCODE_GENERATE_MAX_COUNT', 20000)
59 
configUtil.setConfig('CONTENT_UPLOAD_REQ_LIMIT', reqDataLimitOfContentUpload)
60 
configUtil.setConfig('SEARCH_SERVICE_BASE_URL', searchServiceBaseUrl)
61 
configUtil.setConfig('DIAL_REPO_BASE_URL', dialRepoBaseUrl)
62 
configUtil.setConfig('PLUGIN_REPO_BASE_URL', pluginRepoBaseUrl)
63 
configUtil.setConfig('DATA_SERVICE_BASE_URL', dataServiceBaseUrl)
64 
configUtil.setConfig('SEARCH_SERVICE_AUTHORIZATION_TOKEN', 'Bearer ' + searchServiceApiKey)
65 
configUtil.setConfig('DIAL_REPO_AUTHORIZATION_TOKEN', 'Bearer ' + dialRepoApiKey)
66 
configUtil.setConfig('PLUGIN_REPO_AUTHORIZATION_TOKEN', 'Bearer ' + pluginRepoApiKey)
67 
configUtil.setConfig('DATA_SERVICE_AUTHORIZATION_TOKEN', 'Bearer ' + dataServiceApiKey)
68 
configUtil.setConfig('ENABLE_LOGGING', enableLogging)
69 
configUtil.setConfig('LANGUAGE_SERVICE_BASE_URL', languageServiceBaseUrl)
70 
configUtil.setConfig('LANGUAGE_SERVICE_AUTHORIZATION_TOKEN', 'Bearer ' + languageServiceApiKey)
7172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140
configUtil.setConfig('SUNBIRD_PORTAL_BASE_URL', sunbirdPortalBaseUrl) configUtil.setConfig('LOCK_EXPIRY_TIME', lockExpiryTime) configUtil.setConfig('CONTENT_SERVICE_LOCAL_BASE_URL', contentServiceLocalBaseUrl) process.env.sunbird_cassandra_urls = process.env.sunbird_cassandra_urls || '127.0.0.1' process.env.dial_code_image_temp_folder = 'temp' 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(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 (req.method === 'OPTIONS') { res.sendStatus(200) } else { next() }; }) app.use(function (req, res, next) { res.setHeader('Connection', 'close') next() }) require('./routes/healthCheckRoutes')(app) require('./routes/courseRoutes')(app) require('./routes/contentRoutes')(app) require('./routes/conceptRoutes')(app) require('./routes/searchRoutes')(app) require('./routes/dialCodeRoutes')(app) require('./routes/channelRoutes')(app) require('./routes/frameworkRoutes')(app) require('./routes/frameworkTermRoutes')(app) require('./routes/frameworkCategoryInstanceRoutes')(app) require('./routes/dataExhaustRoutes')(app) require('./routes/formRoutes')(app) require('./routes/externalUrlMetaRoute')(app) require('./routes/pluginsRoutes')(app) require('./routes/collaborationRoutes')(app) require('./routes/lockRoutes')(app) // this middleware route add after all the routes require('./middlewares/proxy.middleware')(app) function startServer () {
141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191
this.server = http.createServer(app).listen(port, function () { console.log('server running at PORT [%d]', port) if (!process.env.sunbird_environment || !process.env.sunbird_instance) { console.error('please set environment variable sunbird_environment, sunbird_instance' + 'start service Eg: sunbird_environment = dev, sunbird_instance = sunbird') process.exit(1) } contentMetaProvider.getMetaFilterConfig().then((configStr) => { configUtil.setConfig('META_FILTER_REQUEST_JSON', configStr) }).catch((err) => { console.log('error in getting meta filters', err) process.exit(1) }) }) } // Create server configUtil.setConfig('DEFAULT_CHANNEL', 'sunbird') if (defaultChannel) { contentProvider.getChannel(defaultChannel, (err, res) => { var defaultHashTagId = _.get(res, 'result.response.content[0].hashTagId') if (defaultHashTagId) { configUtil.setConfig('DEFAULT_CHANNEL', defaultHashTagId) } console.log('Error fetching default channel', err) console.log('DEFAULT_CHANNEL', configUtil.getConfig('DEFAULT_CHANNEL')) startServer() }) } else { startServer() } // Close server, when we start for test cases exports.close = function () { this.server.close() } // Telemetry initialization const telemetryBatchSize = parseInt(process.env.sunbird_telemetry_sync_batch_size, 10) || 20 telemtryEventConfig.pdata.id = producerId const telemetryConfig = { pdata: telemtryEventConfig.pdata, method: 'POST', batchsize: telemetryBatchSize, endpoint: configUtil.getConfig('TELEMETRY'), host: configUtil.getConfig('TELEMETRY_BASE_URL'), authtoken: configUtil.getConfig('CONTENT_REPO_AUTHORIZATION_TOKEN') } telemetry.init(telemetryConfig)