Time nodes

• Ticks - emit new message with t key as Date.now() by every interval prop
• Timeout - timeout by timeout prop
• Daterange - generate array of dates between start and stop by step from daterange key from message and push to out port one by one as date key

Usage

Ticks

const def = `
# get new token every day
ticks(@nsfx/time/Ticks, {"interval": 86400000}) -> GET token(Tokens)
`

build(def, {}, { logger, nodesdir: __dirname }, (err, flow) => {

    flow.ticks.start.write({})
})

Timeout

const def = `
timeout(@nsfx/time/Timeout, {"timeout": 1000}) -> execute(./Dummy)
`

build(def, {}, { logger, nodesdir: __dirname }, (err, flow) => {

    flow.timeout.in.write({})
})

Daterange

const def = `
# generate array of dates between start, stop by step from daterange key from message
dates(@nsfx/time/Daterange) -> GET_BY_DATE request(./Dummy) -> NEXT dates

request EMPTY -> NEXT dates
`

const data = {
    dates: {
        start: '2021-01-01',
        stop: _ => Date.now(),
        step: 5
    }
}

build(def, data, { logger, nodesdir: __dirname }, (err, flow) => {

    flow.dates.in.write({})
})