# Necessary plugins
[use]
plugin = basics
plugin = analytics
plugin = storage

# Flow configuration
[JSONParse]
[JSONParse]
legacy = false
separator = $

[bufferize]

[combine]
path = env('path', 'value')
primer = get('bufferID')
prepend = buffers
append = transit
persistent = true

[combine/exchange]
value = get('value')

[combine/group]
size = 100

[combine/replace]
path = rows
value = fix(self.length)
path = filter
value = self().map(x => 'doi:'.concat(x)).join(',')

# see https://github.com/CrossRef/rest-api-doc#api-overview
[combine/URLStream]
url  = https://api.crossref.org/works
path = .items.*
timeout = 30000

[combine/replace]
path = id
value = get('DOI')
path = value
value = self()

[dump]
indent = env('indent', false)