Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
function runTaskForAllJobFiles(taskName, callback) {
var dataPacksJobsData = {};
var properties = grunt.config.get('properties');
if (properties['vlocity.dataPacksJobFolder']) {
dataPacksJobFolder = properties['vlocity.dataPacksJobFolder'];
}
try {
fs.readdirSync(dataPacksJobFolder).filter(function(file) {
try {
var fileName = file.substr(0,file.indexOf('.'));
if (!/QueryDefinitions/.test(fileName)) {
dataPacksJobsData[fileName] = yaml.safeLoad(fs.readFileSync(dataPacksJobFolder + '/' + file, 'utf8'));;
}
} catch (e) {
//console.log(e);
}
});
var properties = grunt.config.get('properties');
var jobStartTime = Date.now();
var vlocity = new node_vlocity({
username: properties['sf.username'],
password: properties['sf.password'],
vlocityNamespace: properties['vlocity.namespace'],
verbose: grunt.option('verbose'),
loginUrl: properties['sf.loginUrl']
});
grunt.log.writeln('DataPacks Job Started - ' + jobName + ' Org: ' + properties['sf.username']);
if (properties['vlocity.dataPacksJobFolder']) {
dataPacksJobFolder = properties['vlocity.dataPacksJobFolder'];
}
var dataPacksJobsData = {};
var queryDefinitions;
try {
queryDefinitions = yaml.safeLoad(fs.readFileSync(dataPacksJobFolder + '/QueryDefinitions.yaml', 'utf8'));
} catch (e) {
//console.log(e);
}
var dataPackFolderExists;
try {
fs.readdirSync(dataPacksJobFolder).filter(function(file) {
try {
function dataPacksJob(action, jobName, callback) {
var properties = grunt.config.get('properties');
var jobStartTime = Date.now();
var vlocity = new node_vlocity({
username: properties['sf.username'],
password: properties['sf.password'],
vlocityNamespace: properties['vlocity.namespace'],
verbose: grunt.option('verbose'),
loginUrl: properties['sf.loginUrl']
});
grunt.log.writeln('DataPacks Job Started - ' + jobName + ' Org: ' + properties['sf.username']);
if (properties['vlocity.dataPacksJobFolder']) {
dataPacksJobFolder = properties['vlocity.dataPacksJobFolder'];
}
var dataPacksJobsData = {};
var queryDefinitions;
try {
queryDefinitions = yaml.safeLoad(fs.readFileSync(dataPacksJobFolder + '/QueryDefinitions.yaml', 'utf8'));
} catch (e) {
//console.log(e);
}
var dataPackFolderExists;
try {
fs.readdirSync(dataPacksJobFolder).filter(function(file) {