stream-json out

lib/apiswagger.js

@@ -3,9 +3,6 @@ const nodeinfo = require('activitypub-express/pub/nodeinfo')
 module.exports = (app, client) => {
     const constant = require('./constant'),
         zlib = require('zlib'),
-        Pick = require('stream-json/filters/Pick'),
-        { streamArray } = require('stream-json/streamers/StreamArray'),
-        { chain } = require('stream-chain'),
         clean = str => {
             return str.replace(/[/\\^$+?()`'¡¿¨!"·%&=;,\|\[\]{}]+/gmi, '')
         }
@@ -511,14 +508,8 @@ module.exports = (app, client) => {
                 query: {
                     match_all: {}
                 }
-            }, { asStream: true, meta: false }),
+            }, { asStream: true, meta: false })
-                pipeline = chain([
+            result.pipe(zlib.createGzip()).pipe(res)
-                    Pick.withParser({ filter: 'hits.hits' }),
-                    streamArray(),
-                    data => data.value._source,
-                    zlib.createGzip()
-                ])
-            result.pipe(pipeline).pipe(res)
         } catch (e) {
             console.error(e)
             res.status(404).end()

lib/fediblock.js

@@ -19,7 +19,7 @@ module.exports = async (client, apex, app) => {
 		requestPart = async uri => {
 			const ac = new AbortController(),
 				timeout = setTimeout(() => {
-					ac.abort()
+					setImmediate(ac.abort())
 				}, constant.abort_timeout),
 				response = await fetch(uri, {
 					headers: { 'User-Agent': constant.agent },
@@ -27,7 +27,7 @@ module.exports = async (client, apex, app) => {
 					keepalive: false,
 					timeout: constant.timeout,
 				})
-			clearTimeout(timeout)
+			setImmediate(clearTimeout(timeout))
 			return await response.json()
 		},
 		scanInstance = async instance => {

package.json

@@ -25,7 +25,6 @@
     "node-schedule": "^2.1.1",
     "parcel": "^2.12.0",
     "rotating-file-stream": "^3.2.5",
-    "stream-json": "^1.8.0",
     "swagger-jsdoc": "^6.2.8",
     "swagger-ui-express": "^5.0.1"
   }