Initial Commit

.gitignore

@@ -62,4 +62,7 @@ typings/
 /db
 
 # Code Editor Configuration file
-.vscode
+.vscode
+
+# CSV test file
+assessmentItem.csv

app.js

@@ -6,6 +6,7 @@ const bunyanMiddleware = require('bunyan-middleware');
 const ping = require('./ping');
 const question = require('./question');
 const history = require('./history');
+const bulkUpload = require('./bulk_upload');
 
 const app = express();
 const logger = bunyan.createLogger({ name: 'Question-Authoring-API' });
@@ -31,5 +32,6 @@ app.use(bunyanMiddleware({
 app.use('/ping', ping);
 app.use('/history', history);
 app.use('/question', question);
+app.use('/bulkupload', bulkUpload);
 
 module.exports = app;

bulk_upload/csv.controller.js

@@ -0,0 +1,42 @@
+const questionController = require('../question/question.controller');
+const config = require('../config');
+const fs = require('fs');
+const csv = require('fast-csv');
+const _ = require('lodash');
+
+const readAndPublish = async () => {
+  const stream = fs.createReadStream(config.fileUploadPath);
+  let publishedQuestion = '';
+  await csv
+    .fromStream(stream, { objectMode: true, headers: true })
+    .validate(data =>
+      data.concept && data.content && data.expectedOutcome && data.player && data.evaluator)
+    .on('data-invalid', () => {
+      console.log('Error: Primary fields  are missing!!!');
+    })
+    .on('data', async (data) => {
+      let assessmentItem = data;
+      let primaryObject = {};
+      primaryObject = _.pick(assessmentItem, ['concept', 'content', 'expectedOutcome', 'player', 'evaluator']);
+      _.forOwnRight(assessmentItem, (value, key) => {
+        if (key === 'concept' || key === 'content' || key === 'expectedOutcome' || key === 'player' || key === 'evaluator') {
+          _.unset(assessmentItem, key);
+        }
+      });
+      const secondaryObject = assessmentItem;
+      primaryObject.question = secondaryObject;
+      assessmentItem = primaryObject;
+      const initialisedQuestion = await questionController.initQuestion();
+      assessmentItem.id = initialisedQuestion.id;
+      publishedQuestion = await questionController.publishQuestion(assessmentItem);
+      return publishedQuestion;
+    })
+    .on('error', (err) => {
+      console.log(`Error is ${err}`);
+    });
+};
+
+module.exports = {
+  readAndPublish,
+};
+

bulk_upload/csv.router.js

@@ -0,0 +1,11 @@
+const express = require('express');
+const csvController = require('./csv.controller');
+
+const router = express.Router();
+
+router.get('/csvUpload', (req, res) => {
+  const publishedQuestion = csvController.readAndPublish();
+  res.json(publishedQuestion);
+});
+
+module.exports = router;

bulk_upload/index.js

@@ -0,0 +1 @@
+module.exports = require('./csv.router');

config/config.js

@@ -1,6 +1,7 @@
 const config = {
   PORT: process.env.PORT || 4000,
   MONGODB_URL: process.env.MONGODB_URL || 'localhost:29017/assessment_item',
+  fileUploadPath: process.env.FILE_UPLOAD_PATH || 'assessmentItem.csv',
 };
 
 module.exports = config;

package.json

@@ -6,7 +6,9 @@
     "bunyan-middleware": "^0.8.0",
     "eslint": "^4.9.0",
     "express": "^4.16.2",
+    "fast-csv": "^2.4.1",
     "json-diff-rfc6902": "^1.3.3",
+    "lodash": "^4.17.4",
     "mongoose": "^4.12.4",
     "simple-neo4j-wrapper": "^1.0.5",
     "sinon": "^4.0.1"