job_parse.js

/* encoding: utf-8 */

import { DiffMessageBuilder } from "./builders/build_message";
import { JDDiffParser } from "./parsers/parser_diff";
import { JSONParser } from "./parsers/parser_json";

export function parseDataDiffs(dataFile, diffFile) {
    /**
     * Main function to parse data diffs from a given file
     * @param dataFile: path to the data objects file
     * @param diffFile: path to the data diffs file
     * @return array of DiffMessages
     */

    let dataParser = new JSONParser();
    let diffParser = new JDDiffParser();

    let postEntries = diffParser.getCreationEntries(diffFile);
    let prevEntries = diffParser.getDeletionEntries(diffFile);
    let editEntries = diffParser.getEditionEntries(diffFile);

    // Deletion entries are not allowed, as they destroy IDs history
    if (prevEntries.length > 0) {
        console.error(`Invalid data diff file. Object deletion is not allowed.`);
        process.exit(1);
    }

    let dataStruct = dataParser.parseFile(dataFile);
    let msgBuilder = new DiffMessageBuilder(dataParser);

    // Creation and edition entries are allowed
    let entries = [...postEntries, ...editEntries];
    let msgList = [];

    for (const entry of entries) {
        const message = msgBuilder.build(dataFile, dataStruct, entry);
        msgList.push(message);
    }

    return msgList;
}