Issue #SB-3313 feat: added framework publish

src/app.js

@@ -19,7 +19,7 @@ const port = process.env.sunbird_content_service_port ? process.env.sunbird_cont
 
 globalEkstepProxyBaseUrl = process.env.sunbird_content_plugin_base_url ? process.env.sunbird_content_plugin_base_url : 'https://qa.ekstep.in'
 
-const contentProviderBaseUrl = process.env.sunbird_content_provider_api_base_url ? process.env.sunbird_content_provider_api_base_url : 'https://dev.ekstep.in/api'
+const contentProviderBaseUrl = process.env.sunbird_content_provider_api_base_url ? process.env.sunbird_content_provider_api_base_url : 'https://qa.ekstep.in/api'
 const contentProviderApiKey = process.env.sunbird_content_provider_api_key
 
 const learnerServiceApiKey = process.env.sunbird_learner_service_api_key

src/config/contentProviderApiConfig.json

@@ -47,6 +47,7 @@
         "FRAMEWORK_CREATE_URI": "/framework/v3/create",
         "FRAMEWORK_UPDATE_URI": "/framework/v3/update",
         "FRAMEWORK_COPY_URI": "/framework/v3/copy",
+        "FRAMEWORK_PUBLISH_URI":"/framework/v3/publish",
       
         "FRAMEWORK_TERM_URI": "/framework/v3/term/read",
         "FRAMEWORK_TERM_SEARCH_URI": "/framework/v3/term/search",

libs @ 14c58ffb

-Subproject commit 203cecd3d5ded0b79bb536427e24295944950355
+Subproject commit 14c58ffb7e009d51a155a5f3ff46dc0e7a925777

src/routes/frameworkRoutes.js

@@ -7,21 +7,23 @@
 var frameworkService = require('../service/frameworkService')
 var requestMiddleware = require('../middlewares/request.middleware')
 
-var BASE_URL_V1_Framework = '/v1/framework'
+var baseUrl = '/v1/framework'
 
 module.exports = function (app) {
-  app.route(BASE_URL_V1_Framework + '/read/:frameworkId')
+  app.route(baseUrl + '/read/:frameworkId')
     .get(requestMiddleware.createAndValidateRequestBody, frameworkService.getFrameworkById)
 
-  app.route(BASE_URL_V1_Framework + '/list')
+  app.route(baseUrl + '/list')
     .post(requestMiddleware.createAndValidateRequestBody, frameworkService.frameworklList)
 
-  app.route(BASE_URL_V1_Framework + '/create')
+  app.route(baseUrl + '/create')
     .post(requestMiddleware.createAndValidateRequestBody, frameworkService.frameworkCreate)
 
-  app.route(BASE_URL_V1_Framework + '/update/:frameworkId')
+  app.route(baseUrl + '/update/:frameworkId')
     .patch(requestMiddleware.createAndValidateRequestBody, frameworkService.frameworkUpdate)
-    
-  app.route(BASE_URL_V1_Framework + '/copy/:frameworkId')
+
+  app.route(baseUrl + '/copy/:frameworkId')
     .post(requestMiddleware.createAndValidateRequestBody, frameworkService.frameworkCopy)
+  app.route(baseUrl + '/publish/:frameworkId')
+    .post(requestMiddleware.createAndValidateRequestBody, frameworkService.frameworkPublish)
 }

src/service/frameworkService.js

@@ -264,8 +264,60 @@ function frameworkCopy (req, response) {
   ])
 }
 
+function frameworkPublish (req, response) {
+  var rspObj = req.rspObj
+  var data = req.body
+  data.frameworkId = req.params.frameworkId
+  // Adding telemetry object data
+  if (rspObj.telemetryData) {
+    rspObj.telemetryData.object = utilsService.getObjectData(data.frameworkId, 'framework', '', {})
+  }
+  if (!data) {
+    LOG.error(utilsService.getLoggerData(rspObj, 'ERROR', filename, 'frameworkServiceAPI',
+      'Error due to required params are missing', data))
+    rspObj.responseCode = responseCode.CLIENT_ERROR
+    return response.status(400).send(respUtil.errorResponse(rspObj))
+  }
+
+  var ekStepReqData = {
+    request: data.request
+  }
+
+  async.waterfall([
+
+    function (CBW) {
+      LOG.info(utilsService.getLoggerData(rspObj, 'INFO', filename, 'frameworkServiceAPI',
+        'Request to ekstep for search object type', {
+          body: data,
+          headers: req.headers,
+          frameworkId: data.frameworkId
+        }))
+      ekStepUtil.frameworkPublish(ekStepReqData, data.frameworkId, req.headers, function (err, res) {
+        if (err || res.responseCode !== responseCode.SUCCESS) {
+          LOG.error(utilsService.getLoggerData(rspObj, 'ERROR', filename, 'frameworkServiceAPI',
+            'Getting error from ekstep', res))
+          rspObj.responseCode = res && res.responseCode ? res.responseCode : responseCode.SERVER_ERROR
+          var httpStatus = res && res.statusCode >= 100 && res.statusCode < 600 ? res.statusCode : 500
+          rspObj = utilsService.getErrorResponse(rspObj, res)
+          return response.status(httpStatus).send(respUtil.errorResponse(rspObj))
+        } else {
+          CBW(null, res)
+        }
+      })
+    },
+
+    function (res) {
+      LOG.info(utilsService.getLoggerData(rspObj, 'INFO', filename, 'frameworkServiceAPI',
+        'Sending response back to user'))
+      rspObj.result = res.result
+      return response.status(200).send(respUtil.successResponse(rspObj))
+    }
+  ])
+}
+
 module.exports.getFrameworkById = getFrameworkById
 module.exports.frameworklList = frameworklList
 module.exports.frameworkCreate = frameworkCreate
 module.exports.frameworkUpdate = frameworkUpdate
 module.exports.frameworkCopy = frameworkCopy
+module.exports.frameworkPublish = frameworkPublish