Enfocus Community

Code: Select all

const xsd = require('libxmljs2-xsd');
const fs = require('fs');

async function jobArrived(s, flowElement, job) {
    let xsdPath = await flowElement.getPropertyStringValue("xsdPath");
    await job.log(LogLevel.Info,'%1',[xsdPath]);
    //const jobName = await getName();
    const jobTempPath = await job.get(AccessLevel.Read);
    const schema = await xsd.parseFile(xsdPath);
    let documentString = await fs.readdirSync(jobTempPath)
    let validationErrors = await schema.validate(documentString);
    if (validationErrors === null){
        job.sendToData(Connection.Level.Success);
    } else{
        job.log(LogLevel.Info,'%1',[validationErrors]);
        job.sendToData(Connection.Level.Warning);
    }    
}