// fetch.ts error path
const responseText = await response.text();  // <-- Consumes body
// ...
for (const onError of hooks.onError) {
  await onError({
    ...errorContext,
    response: cloneResponse ? response.clone() : response  // <-- Fails: body already consumed
  });
}

const http = require('http');
const { createFetch } = require('@better-fetch/fetch');

const server = http.createServer((req, res) => {
  res.writeHead(500, { 'Content-Type': 'application/json' });
  res.end(JSON.stringify({ error: 'Internal Server Error' }));
});

server.listen(3456, async () => {
  const client = createFetch({
    baseURL: 'http://localhost:3456',
    throw: true,
  });

  console.log('=== Test 1: Without cloneResponse (works) ===\n');
  await client('/', {
    onError: (ctx) => console.log('onError fired! status:', ctx.response?.status),
  }).catch(e => console.log('Caught:', e.constructor.name, '-', e.message, '- status:', e.status));

  console.log('\n=== Test 2: With cloneResponse: true (broken) ===\n');
  await client('/', {
    hookOptions: { cloneResponse: true },
    onError: (ctx) => console.log('onError fired! status:', ctx.response?.status),
  }).catch(e => console.log('Caught:', e.constructor.name, '-', e.message, '- status:', e.status));

  server.close();
});