Gecko [ c.stage.kornherr.net ]

Linux v69820.1blu.de 4.15.0 #1 SMP Mon Sep 30 15:36:27 MSK 2024 x86_64
Apache/2.4.58
Server IP : 195.90.215.149 & Your IP : 216.73.216.250
Domains : Cant Read [ /etc/named.conf ]
User : www-data

Name	Size	Permission	Date
abort-signal.js	968 B	-rw-r--r--	2023-10-14 10:49
api-connect.js	2.47 KB	-rw-r--r--	2023-10-14 10:49
api-pipeline.js	5.29 KB	-rw-r--r--	2023-10-14 10:49
api-request.js	4.44 KB	-rw-r--r--	2023-10-14 10:49
api-stream.js	5.08 KB	-rw-r--r--	2023-10-14 10:49
api-upgrade.js	2.52 KB	-rw-r--r--	2023-10-14 10:49
index.js	264 B	-rw-r--r--	2023-10-14 10:49
readable.js	6.82 KB	-rw-r--r--	2023-10-14 10:49
util.js	1.56 KB	-rw-r--r--	2023-10-14 10:49

Rename

const assert = require('assert')
const {
  ResponseStatusCodeError
} = require('../core/errors')
const { toUSVString } = require('../core/util')

async function getResolveErrorBodyCallback ({ callback, body, contentType, statusCode, statusMessage, headers }) {
  assert(body)

let chunks = []
  let limit = 0

for await (const chunk of body) {
    chunks.push(chunk)
    limit += chunk.length
    if (limit > 128 * 1024) {
      chunks = null
      break
    }
  }

if (statusCode === 204 || !contentType || !chunks) {
    process.nextTick(callback, new ResponseStatusCodeError(`Response status code ${statusCode}${statusMessage ? `: ${statusMessage}` : ''}`, statusCode, headers))
    return
  }

try {
    if (contentType.startsWith('application/json')) {
      const payload = JSON.parse(toUSVString(Buffer.concat(chunks)))
      process.nextTick(callback, new ResponseStatusCodeError(`Response status code ${statusCode}${statusMessage ? `: ${statusMessage}` : ''}`, statusCode, headers, payload))
      return
    }

if (contentType.startsWith('text/')) {
      const payload = toUSVString(Buffer.concat(chunks))
      process.nextTick(callback, new ResponseStatusCodeError(`Response status code ${statusCode}${statusMessage ? `: ${statusMessage}` : ''}`, statusCode, headers, payload))
      return
    }
  } catch (err) {
    // Process in a fallback if error
  }

process.nextTick(callback, new ResponseStatusCodeError(`Response status code ${statusCode}${statusMessage ? `: ${statusMessage}` : ''}`, statusCode, headers))
}

module.exports = { getResolveErrorBodyCallback }