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

stream-json
Some checks reported errors
continuous-integration/drone/push Build was killed
Details

Browse Source
This commit is contained in:
ale 2024-10-14 00:15:11 +02:00
parent 35f3097b8e
commit 1eb0efe2a2
1 changed files with 16 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
lib/apiswagger.js
View File

@ -477,21 +477,23 @@ module.exports = (app, client) => {
}, { asStream: true, meta: false }), }, { asStream: true, meta: false }),
instancescomment = [], instancescomment = [],
block_count = 0, block_count = 0,
pipeline = chain([ pipeline = chain([
parser(), parser(),
pick({ filter: 'hits.hits' }), pick({ filter: 'hits.hits' }),
streamArray(), streamArray(),
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.value._source.instance, comment: data.value._source.blocks.find(block => block.domain === clean(req.params.instance)).comment
}) })
} }
]) ])
result.pipe(pipeline) result.pipe(pipeline)
res.json({ pipeline.on('end', () => {
block_count, res.json({
instances: instancescomment block_count,
instances: instancescomment
})
}) })
} else { } else {
res.status(404).end() res.status(404).end()