ale/fediblock-instance
ale/fediblock-instance
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

stream-json
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
ale 2024-10-14 01:10:36 +02:00
parent 3c19b1c7bc
commit 6caf3d6d40
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
lib/apiswagger.js
View File

@ -481,20 +481,21 @@ module.exports = (app, client) => {
parser(), parser(),
pick({ filter: 'hits.hits' }), pick({ filter: 'hits.hits' }),
streamArray(), streamArray(),
data => { data => data.value._source
])
pipeline.on('data', data => {
block_count++ block_count++
instancescomment.push({ instancescomment.push({
instance: data.value._source.instance, comment: data.value._source.blocks.find(block => block.domain === clean(req.params.instance)).comment instance: data.instance, comment: data.blocks.find(block => block.domain === clean(req.params.instance)).comment
})
}) })
}
])
result.pipe(pipeline)
pipeline.on('end', () => { pipeline.on('end', () => {
res.json({ res.json({
block_count, block_count,
instances: instancescomment instances: instancescomment
}) })
}) })
result.pipe(pipeline)
} else { } else {
res.status(404).end() res.status(404).end()
} }