hafas-monitor-journeys

Use any HAFAS API to monitor journeys from A to B.

Installing

npm install hafas-monitor-journeys

Usage

const createHafas = require('vbb-hafas')
const monitor = require('hafas-monitor-journeys')
 
const leinestr = '900000079201'
const schönleinstr = '900000016201'
 
const tasks = [{
    from: leinestr,
    to: schönleinstr,
    when: t => t, // query for the current point in time
}, {
    from: leinestr,
    to: schönleinstr,
    when: t => t + 10 * 60 * 1000 // query 10 minutes ahead
}]
 
const onJobDone = (err, journeys, job, iteration) => {
    if (err) return console.error(err)
 
    const ahead = Math.round((job.when - job.started) / 1000)
    console.log(
        'iteration ' + iteration,
        ahead + 's ahead',
        journeys.length + ' journeys'
    )
}
 
const onEnd = (iteration) => {
    console.log('iteration ' + iteration + ' done')
}
 
const hafas = createHafas('my-awesome-program')
const run = monitor(hafas.journeys, tasks)
run(onJobDone, onEnd)

iteration 1 0s ahead 5 journeys
iteration 1 600s ahead 5 journeys
iteration 1 done

Contributing

If you have a question or have difficulties using hafas-monitor-journeys, please double-check your code and setup first. If you think you have found a bug or want to propose a feature, refer to the issues page.