loops?

[static-moonlight]

I'm trying to build a stream processor which reads messages from a NATS subject, extract a file list from those messages, executes a processor for each file, and eventually creating a new message and send it back to another NATS subject.

Currently I'm struggling with the "for each file" part. Is there some kind of loop, I can use to go over this?

{
  "files": [
    {"path":"a","size":1},
    {"path":"b","size":2},
    {"path":"c","size":3}
  ]
}

This json was extracted from the message using the mapper processor, meaning I can adjust this if necessary.

This is my current configuration:

input:
  nats_jetstream:
    urls: [nats://${NATS_USERNAME}:${NATS_PASSWORD}@${NATS_ENDPOINT}]
    subject: ${NATS_INPUT_SUBJECT}
    stream: ${NATS_INPUT_STREAM}
    deliver: ${NATS_INPUT_DELIVER}
    durable: ${NATS_INPUT_CONSUMER_NAME}

pipeline:
  processors:
    - mapping: |
        root.files = this.package.files
    # for each file???

output:
  nats_jetstream:
    urls: [nats://${NATS_USERNAME}:${NATS_PASSWORD}@${NATS_ENDPOINT}]
    subject: ${NATS_OUTPUT_SUBJECT}

I could need a little push into the right direction :)

[static-moonlight]

sorry, wrong project