var htcondor = require('htcondor');
 
//create condor submit object
var submit_options = {
    universe: "vanilla",
    executable: "test.sh",
    arguments: "hello",
    notification: "never",
 
    //transfer_output_files: 'bogus',
 
    requirements: '(Arch == "INTEL") || (Arch == "X86_64") && (machine == "some_ce")',
 
    shouldtransferfiles: "yes",
    when_to_transfer_output: "ON_EXIT",
    output: "stdout.txt",
    error: "stderr.txt",
    queue: 1
};
 
//submit to start the job
htcondor.submit(submit_options).then(function(job) {
    console.log("Submitted");
 
    //you can dump the condor submit property for your new job
    //console.dir(job.props);
 
    //job.id contains cluster/proc ids
    //console.dir(job.id);
 
    //you can *watch* job log
    job.onevent(function(event) {
        switch(event.MyType) {
 
        //normal status type events (just display content)
        case "SubmitEvent":
        case "ExecuteEvent":
        case "JobImageSizeEvent":
            console.log(event.MyType);
            break;
 
        //critical events
        case "ShadowExceptionEvent":
            console.log(event.MyType);
            console.dir(event);
 
            //I now stop the watcher (ends this submission)
            job.unwatch();
            break;
 
        //job ended normally
        case "JobTerminatedEvent":
            console.log(event.MyType);
            console.dir(event);
 
            //Do something based on the ReturnValue (resubmit, submit different job, etc..)
            console.log("return value:"+event.ReturnValue);
 
            //If you submitted queue != 1, then you can look for Event.Proc to get the Process ID (0, 1, etc..)
 
            //If you are happy, just unwatch
            job.unwatch();
            break;
 
        default:
            console.log(event.MyType);
            console.log("unknown event type.. ignoring for now");
        }
    });
});
 

job.remove(function(err) {
    if(err) throw err;
    console.log("successfully removed job");
});

job.hold(function(err) {
    if(err) throw err;
    console.log("successfully held job");
});

job.release(function(err) {
    if(err) throw err;
    console.log("successfully released job");
});

htcondor.remove(job, function(err) {
    if(err) throw err;
    console.log("successfully removed job");
});

htcondor.remove(job).then(function() {
    console.log("successfully removed job");
}).fail(function(err) {
    //handle err
});;

htcondor = require("htcondor");
htcondor.q({id: "59794891.0"},function(err, job) {
    console.log(JSON.stringify(job, null, 4));
});

htcondor = require("htcondor");
htcondor.q({
    constraint: "JobStatus==5",
    attributes: ["Iwd", "Owner", "JobStatus"]
},
function(err, jobs) {
    console.log(JSON.stringify(jobs, null, 4));
}
);

htcondor = require("htcondor");
htcondor.q({constraint: "JobStatus==5"}).then(function(jobs) {
    console.log(JSON.stringify(jobs, null, 4));
});

var eventlog = require('htcondor').eventlog
 
//you can start watching on your htcondor eventlog
eventlog.watch("/var/log/condor/EventLog");
 
//and receive events
eventlog.on(function(ads) {
    console.dir(ads);
});

{ _jobid: '49563264.000.000',
  _timestamp: '12/15 19:12:25',
  _updatetime: Sun Dec 15 2013 19:12:25 GMT+0000 (UTC),
  Proc: 0,
  EventTime: '2013-12-15T19:12:25',
  TriggerEventTypeName: 'ULOG_SUBMIT',
  SubmitHost: '<129.79.53.21:9615?sock=8287_a430_1068600>',
  QDate: 1387134745,
  TriggerEventTypeNumber: 0,
  MyType: 'SubmitEvent',
  Owner: 'donkri',
  CurrentHosts: 0,
  GlobalJobId: 'osg-xsede.grid.iu.edu#49563264.0#1387134745',
  Cluster: 49563264,
  AccountingGroup: 'group_xsedelow.donkri',
  Subproc: 0,
  EventTypeNumber: 28,
  CurrentTime: 'time()' }

eventlog.unwatch()

htcondor.dumpconfig().then(function(configs) {
    console.dir(configs);
}).catch(function(err) {
    console.log("error occured");
    console.dir(err);
});