Function processGradingResult

lib/assessment.js:285–331

* Process the result of an external grading job. * * @param {Obect} content - The grading job data to process.

(content)

     * @param {Obect} content - The grading job data to process.
     */
    processGradingResult(content) {
        async.series([
            (callback) => {
                if (!_(content.grading).isObject()) {
                    return callback(error.makeWithData('invalid grading', {content: content}));
                }
                if (!_(content.grading.score).isNumber()) {
                    return callback(error.makeWithData('invalid grading.score', {content: content}));
                }
                if (content.grading.score < 0 || content.grading.score > 1) {
                    return callback(error.makeWithData('grading.score out of range', {content: content}));
                }
                if (_(content.grading).has('feedback') && !_(content.grading.feedback).isObject()) {
                    return callback(error.makeWithData('invalid grading.feedback', {content: content}));
                }
                const params = [
                    content.gradingId,
                    content.grading.score,
                    content.grading.feedback,
                    content.grading.receivedTime,
                    content.grading.startTime,
                    content.grading.endTime,
                ];
                sqldb.call('grading_jobs_process_external', params, (err) => {
                    if (ERR(err, callback)) return;
                    callback(null);
                });
            },
            (callback) => {
                sqldb.queryOneRow(sql.select_assessment_for_grading_job, {grading_job_id: content.gradingId}, (err, result) => {
                    if (ERR(err, callback)) return;
                    let assessment_instance_id = result.rows[0].assessment_instance_id;
                    ltiOutcomes.updateScore(assessment_instance_id, null, (err) => {
                        if (ERR(err, callback)) return;
                        callback(null);
                    });
                });
            },
        ], (err) => {
            if (ERR(err, () => {})) {
                // FIXME: call sprocs/errors_insert here
                logger.error('processGradingResult: error',
                             {message: err.message, stack: err.stack, data: JSON.stringify(err.data)});
            }
            externalGradingSocket.gradingJobStatusUpdated(content.gradingId);
        });
    },
};