Function uploadAssessmentInstanceScores

lib/score-upload.js:157–277

* Update assessment instance scores from a CSV file. * * @param {number} assessment_id - The assessment to update. * @param {csvFile} csvFile - An object with keys {originalname, size, buffer}. * @param {number} user_id - The current user performing the update. * @param {num

(assessment_id, csvFile, user_id, authn_user_id, callback)

     * @param {function} callback - A callback(err, job_sequence_id) function.
     */
    uploadAssessmentInstanceScores(assessment_id, csvFile, user_id, authn_user_id, callback) {
        debug('uploadAssessmentInstanceScores()');
        if (csvFile == null) {
            return callback(new Error('No CSV file uploaded'));
        }
        const params = {assessment_id};
        sqldb.queryOneRow(sql.select_assessment_info, params, function(err, result) {
            if (ERR(err, callback)) return;
            const assessment_label = result.rows[0].assessment_label;
            const course_instance_id = result.rows[0].course_instance_id;
            const course_id = result.rows[0].course_id;

            const options = {
                course_id: course_id,
                course_instance_id: course_instance_id,
                assessment_id: assessment_id,
                user_id: user_id,
                authn_user_id: authn_user_id,
                type: 'upload_assessment_instance_scores',
                description: 'Upload total scores for ' + assessment_label,
            };
            serverJobs.createJobSequence(options, function(err, job_sequence_id) {
                if (ERR(err, callback)) return;
                callback(null, job_sequence_id);

                // We've now triggered the callback to our caller, but we
                // continue executing below to launch the jobs themselves.

                const jobOptions = {
                    course_id: course_id,
                    course_instance_id: course_instance_id,
                    assessment_id: assessment_id,
                    user_id: user_id,
                    authn_user_id: authn_user_id,
                    type: 'upload_assessment_instance_scores',
                    description: 'Upload total scores for ' + assessment_label,
                    job_sequence_id: job_sequence_id,
                    last_in_sequence: true,
                };
                serverJobs.createJob(jobOptions, function(err, job) {
                    if (err) {
                        logger.error('Error in createJob()', err);
                        serverJobs.failJobSequence(job_sequence_id);
                        return;
                    }
                    job.verbose('Uploading total scores for ' + assessment_label);

                    // acculumate output lines in the "output" variable and actually
                    // output put them in blocks, to avoid spamming the updates
                    let output = null;
                    let outputCount = 0;
                    let outputThreshold = 100;

                    job.verbose(`Parsing uploaded CSV file "${csvFile.originalname}" (${csvFile.size} bytes)`);
                    job.verbose(`----------------------------------------`);
                    const csvStream = streamifier.createReadStream(csvFile.buffer, {encoding: 'utf8'});
                    const csvConverter = csvtojson({
                        colParser:{