'use strict'

const { tspl } = require('@matteo.collina/tspl')
const { test, after } = require('node:test')
const { once } = require('node:events')
const { Client } = require('..')
const { createServer } = require('node:http')

test('https://github.com/nodejs/undici/issues/803', { timeout: 60000 }, async (t) => {
  t = tspl(t, { plan: 2 })
  const SIZE = 5900373096

  const server = createServer({ joinDuplicateHeaders: true }, async (req, res) => {
    // Use large writes so this >32-bit Content-Length regression test does
    // not monopolize loopback I/O when the unit suite runs concurrently.
    const chunkSize = 16 * 1024 * 1024
    const parts = (SIZE / chunkSize) | 0
    const lastPartSize = SIZE % chunkSize
    const chunk = Buffer.allocUnsafe(chunkSize)

    res.shouldKeepAlive = false
    res.setHeader('content-length', SIZE)
    let i = 0

    while (i++ < parts) {
      if (res.write(chunk) === false) {
        await once(res, 'drain')
      }
    }
    if (res.write(chunk.subarray(0, lastPartSize)) === false) {
      await once(res, 'drain')
    }

    res.end()
  })
  after(() => server.close())

  server.listen(0)

  await once(server, 'listening')
  const client = new Client(`http://localhost:${server.address().port}`)
  after(() => client.close())

  client.on('disconnect', () => {
    if (!client.closed && !client.destroyed) {
      t.fail('unexpected disconnect')
    }
  })

  client.request({
    path: '/',
    method: 'GET'
  }, (err, data) => {
    t.ifError(err)

    let pos = 0
    data.body.on('data', (buf) => {
      pos += buf.length
    })
    data.body.on('end', () => {
      t.strictEqual(pos, SIZE)
    })
  })
  await t.completed
})