index_old.js

let express = require("express");
let app = express();
let http = require("http").Server(app);
let io = require("socket.io")(http);
let axios = require("axios");
let _ = require("lodash");
let fs = require("fs");
var path = require('path');
var bodyParser = require("body-parser");
var proxy = require('express-http-proxy');
var urlHelper = require('url')
var request1 = require("request");
var faker = require("faker");
const sleep = require('sleep-async')();

var questions;
var questionLength;
var responses = [];
var results = [];
var packetId;
var periodId;
var classContext = {};
var currentQuestion;
var topicData = {};
var quizStatus = "NOT_STARTED";

app.use(bodyParser.json());

app.use("/", express.static(__dirname + "/"));

//
// Player proxy - Start
// 

app.use('/content-plugins', proxy('dev.sunbirded.org', {
    https: true,
    proxyReqPathResolver: function(req) {
        return '/content-plugins' + urlHelper.parse(req.url).path
    }
}))

app.use('/assets/public', proxy('dev.sunbirded.org', {
    https: true,
    proxyReqPathResolver: function(req) {
        return '/assets/public' + urlHelper.parse(req.url).path
    }
}))

app.use('/content/preview', proxy('dev.sunbirded.org', {
    https: true,
    proxyReqPathResolver: function(req) {
        return '/content/preview' + urlHelper.parse(req.url).path
    }
}))

//
// Player proxy - End
//

//
//  Multiplayer Quiz - Start
//

io.on("connection", socket => {});

io.on("disconnect", function() {
    io.emit("quiz-ended", { quizId: socket.quizId, event: "end" });
});

const request = require("request-promise");
var interval = undefined;
var quizContext = {
    "stallId": "STA2",
    "stallName": "Classroom",
    "ideaId": "IDE7",
    "ideaName": "Multiplayer Quiz",
    "school": "QSBB higher secondary school",
    "district": "Bangalore"
};

const startQuiz = async function(contentId) {
    console.log('Start quiz command received with content - ' + contentId);
    responses = [];
    questions = await getContentQuestions(contentId);
    questionLength = questions.length;
    console.log('questions size', questions.length);
    io.emit("startQuiz", {});
    quizStatus = "STARTED";
    loopQuestions();

}

const endQuiz = function() {
    console.log("Quiz ended...");
    io.emit("endQuiz");
    var users = _.map(responses, "user");
    users = _.uniqWith(users, _.isEqual);
    results = [];
    _.forEach(users, function(user) {
        var userResult = user;
        userResult.time = 0;
        userResult.score = 0;
        _.forEach(responses, function(response) {
            if (user.code === response.user.code) {
                userResult.time = userResult.time + response.option.time;
                if (response.option.isCorrect) {
                    userResult.score++;
                }
            }
        });
        userResult.score = (userResult.score / questionLength) * 100;
        results.push(userResult);
    });
    results = _.orderBy(results, ["score", "time"], ["desc", "asc"]);
    var i = 1;
    results.map(r => {
        return (r.rank = i++);
    });
    io.emit("results", { results: results });
    console.log(JSON.stringify(results));
    quizStatus = "ENDED";
    return results;
}

const getContentQuestions = async contentId => {
    const options = {
        method: "GET",
        url: 'https://dev.sunbirded.org/api/content/v1/read/' + contentId + '?fields=questions,topics',
        json: true
    };
    let allQuestions;
    try {
        allQuestions = await request(options);
        const allQuestionIds = [];
        if (allQuestions.result && allQuestions.result.content) {
            quizContext.topics = [allQuestions.result.content.topics];
            allQuestions.result.content.questions.forEach(question => {
                allQuestionIds.push(question.identifier);
            });
            return await getQuestions(allQuestionIds);
        }
    } catch (error) {
        console.log(error);
    }
    return [];
};

const getQuestions = async allQuestionIds => {
    const questions = allQuestionIds.map(async questionId => {
        const options = {
            method: "GET",
            url: `https://dev.sunbirded.org/action/assessment/v3/items/read/${questionId}`,
            json: true
        };
        const response = await request(options);
        return response.result.assessment_item;
    });
    return await Promise.all(questions);
};

const loopQuestions = function() {
    console.log("Question loop activated...");
    /*interval = setInterval(function() {
        if(questions.length == 0) {
            clearInterval(interval);
            endQuiz();
        } else {
            
        }
    }, 5000);*/
    quizStatus = "IN_PROGRESS";
    questions.forEach(function(question, idx) {
        setTimeout(function() {
            io.emit("question", { data: question });
        }, 5000 * (idx + 1));
    })
    setTimeout(function() {
        endQuiz();
    }, 5000 * (questions.length + 1));

    /*
    sleep.sleepWithCondition(function() {
            if(questions.length == 0) {
                endQuiz();
            }
            return questions.length == 0;
        },
        {
            sleep: 5000,
            interval: 2500
        },
        function() {
            
            currentQuestion = questions.pop();
            io.emit("question", { data: currentQuestion });
            console.log("Questions remaining - " +  questions.length);
        }
    );*/
}

const quizResponse = function(response) {

    var context = JSON.parse(JSON.stringify(quizContext));
    context.visitorId = response.user.code;
    context.visitorName = response.user.name;
    context.studentId = response.user.code;
    context.studentName = response.user.name;
    responses.push(response);
    console.log('response', JSON.stringify(response));
    postTelemetryEvent({
        "eid": "DC_PERFORMANCE",
        "ets": new Date().getTime(),
        "did": "device_001",
        "dimensions": context,
        "edata": {
            duration: (response.option.time / 1000),
            value: (response.option.isCorrect ? 100 : 0)
        }
    }, function(error, response, body) {
        if (error) console.log(error);
    });
}

app.get("/quiz/start/:contentId", async (req, res) => {
    await startQuiz(req.params.contentId);
    res.json({ "quizStatus": quizStatus });
});

app.get("/quiz/status", (req, res) => {
    res.json({ "quizStatus": quizStatus });
});

app.get("/endQuiz", (req, res) => {
    results = endQuiz();
    res.status(200).send({ results: results });
});

app.post("/userResponse", (req, res) => {
    quizResponse(req.body);
    res.end();
});

//
//  Multiplayer Quiz - End
//

//
//  Classroom APIs - Start
//

app.post("/packet/:id/:periodId", function(req, res) {
    packetId = req.params.id;
    classContext.period = req.params.periodId;
    var periodData = periodMap[classContext.period];
    classContext.classroomId = periodData.grade;
    classContext.subject = periodData.subject;
    classStudents = _.shuffle(JSON.parse(JSON.stringify(periodData.students)));
    console.log('students', classStudents);
    console.log('context', classContext);
    res.status(200).send({ status: true });
});


var periodMap = {
    "PTCH1_2": {
        "grade": "Class 3",
        "subject": "EVS",
        "students": [
            { "studentId": "STU1", "studentName": "Nandu" },
            { "studentId": "STU2", "studentName": "Vedanth" },
            { "studentId": "STU3", "studentName": "Aashna" },
            { "studentId": "STU4", "studentName": "Akira" },
            { "studentId": "STU5", "studentName": "Vandhana" }
        ]
    },
    "PTCH2_2": {
        "grade": "Class 4",
        "subject": "Geography",
        "students": [
            { "studentId": "STU6", "studentName": "Anu" },
            { "studentId": "STU7", "studentName": "Deepa" },
            { "studentId": "STU8", "studentName": "Deepak" },
            { "studentId": "STU9", "studentName": "Manoj" },
            { "studentId": "STU10", "studentName": "Hari" }
        ]
    },
    "PTCH3_2": {
        "grade": "Class 4",
        "subject": "EVS",
        "students": [
            { "studentId": "STU6", "studentName": "Anu" },
            { "studentId": "STU7", "studentName": "Deepa" },
            { "studentId": "STU8", "studentName": "Deepak" },
            { "studentId": "STU9", "studentName": "Manoj" },
            { "studentId": "STU10", "studentName": "Hari" }
        ]
    },
    "PTCH4_2": {
        "grade": "Class 5",
        "subject": "Geography",
        "students": [
            { "studentId": "STU11", "studentName": "Pritha" },
            { "studentId": "STU12", "studentName": "Bindu" },
            { "studentId": "STU13", "studentName": "Neel" },
            { "studentId": "STU14", "studentName": "Harsha" },
            { "studentId": "STU15", "studentName": "Harshita" }
        ]
    },
    "PTCH5_2": {
        "grade": "Class 8",
        "subject": "Science",
        "students": [
            { "studentId": "STU16", "studentName": "Rajesh" },
            { "studentId": "STU17", "studentName": "Mohana" },
            { "studentId": "STU18", "studentName": "Ramya" },
            { "studentId": "STU19", "studentName": "Banu" },
            { "studentId": "STU20", "studentName": "Boominathan" }
        ]
    }
}

var classContext = {
    "stallId": "STA2",
    "stallName": "Classroom",
    "ideaId": "IDE6",
    "ideaName": "APPU Classroom",
    "school": "QSBB higher secondary school",
    "district": "Bangalore"
};
var classContexts = {};

var classStudents = [];

app.post("/classroom/start/:id", function(req, res) {

    var context = JSON.parse(JSON.stringify(classContext));
    context.visitorId = req.body.visitorId;
    context.visitorName = req.body.visitorName;
    var student = classStudents.pop();
    context.studentId = student.studentId;
    context.studentName = student.studentName;

    classContexts[req.params.id] = context;
    console.log('class start context', context);
    postTelemetryEvent({
        "eid": "DC_ATTENDANCE",
        "ets": new Date().getTime(),
        "did": "device_001",
        "dimensions": context,
        "edata": {
            "value": 100
        }
    }, function(error, response, body) {
        if (error) console.log(error);
        console.log(body);
        res.status(200).send({ id: packetId });
    })
});

app.delete("/packet", function(req, res) {
    packetId = undefined;
    res.status(200).send({ deleted: true });
});

app.post("/classroom/telemetry/:id", function(req, res) {

    var context = classContexts[req.params.id];
    console.log('class telemetry context', context);
    var events = req.body.events;
    var interactions = []
    events.forEach(function(event) {
        var topic = _.find(event.context.cdata, { 'type': 'topic' });
        if (topic) {
            var topicId = topic.id;
            if (!topicData[topicId]) topicData[topicId] = { eventsCount: 0, score: 0, maxscore: 0 };
            topicData[topicId].eventsCount = topicData[topicId].eventsCount + 1;
            if (event.eid === 'ASSESS') {
                topicData[topicId].score = topicData[topicId].score + event.edata.score;
                topicData[topicId].maxscore = topicData[topicId].maxscore + event.edata.item.maxscore;
            }
        }

        interactions.push({
            "eid": "DC_INTERACT",
            "ets": event.ets,
            "did": event.context.did,
            "dimensions": _.assign(context, { topics: [topicId] }),
            "edata": {}
        })
    });
    console.log('topicData', topicData);
    postTelemetryEvents(interactions, function(error, response, body) {
        if (error) console.log(error);
        console.log(body);
        res.status(200).send({});
    });
});

app.get("/classroom/end/:id", function(req, res) {

    var context = classContexts[req.params.id];
    console.log('class end context', context, 'topicData', topicData);
    var events = [];
    _.keysIn(topicData).forEach(function(key) {
        var data = topicData[key];
        events.push({
            "eid": "DC_ENGAGEMENT",
            "ets": new Date().getTime(),
            "did": "device_001",
            "dimensions": _.assign(context, { topics: [key] }),
            "edata": {
                "value": data.eventsCount > 100 ? 100 : data.eventsCount
            }
        });
        events.push({
            "eid": "DC_PERFORMANCE",
            "ets": new Date().getTime(),
            "did": "device_001",
            "dimensions": _.assign(context, { topics: [key] }),
            "edata": {
                "value": _.ceil((data.score * 100) / data.maxscore)
            }
        });
    });
    postTelemetryEvents(events, function(error, response, body) {
        if (error) console.log(error);
        console.log(body);
        res.status(200).send({});
    })
});

app.use("/get/:id", async (req, res) => {
    const options = {
        method: "GET",
        url: `https://dev.sunbirded.org/api/content/v1/read/${req.params.id}?fields=questions`,
        json: true
    };
    let allQuestions;
    try {
        allQuestions = await request(options);
        const allQuestionIds = [];
        allQuestions.result.content.questions.forEach(question => {
            allQuestionIds.push(question.identifier);
        });
        questionMeta = await getQuestions(allQuestionIds);
        res.json(questionMeta);
    } catch (error) {
        console.log(error);
        if (error.error) {
            res.status(404).json(error.error);
        } else {
            res.status(404).json("unhandled erro");
        }
    }
});

//
//  Classroom APIs - End
//

function postTelemetryEvent(event, cb) {
    console.log('event', JSON.stringify(event));
    postTelemetryEvents([event], cb);
}

function postTelemetryEvents(events, cb) {
    var options = {
        method: "POST",
        url: "http://52.172.188.118:3000/v1/telemetry",
        headers: {
            "Postman-Token": "8201b334-e622-4920-b760-6c4ab83ad26d",
            "cache-control": "no-cache",
            "Content-Type": "application/json"
        },
        body: { events: events },
        json: true
    };

    request1(options, cb);
}

app.post("/telemetry", function(req, res) {
    console.log('telemetry event', req.body);
    postTelemetryEvents(req.body, function(error, response, body) {
        if (error) console.log(error);
        console.log(body);
        res.status(200).send(body);
    });
});

var port = process.env.PORT || 3000;

http.listen(port, function() {
    console.log("listening in http://localhost:" + port);
});