import http from 'node:http';
import events from 'node:events';
import timers from 'node:timers/promises';

// Create a ReadableStream
const stream = new ReadableStream({
  async start(controller) {
		const chunks = ['Hello', ' ', 'World', '!'];
		for (const chunk of chunks) {
			controller.enqueue(chunk);
			await timers.setTimeout(500);
		}
		controller.close();
  }
});

const server = http.createServer((req, res) => {
	// Gather important information about the request
	const requestInfo = {
		method: req.method,
		url: req.url,
		headers: req.headers,
	};

	// Print the request information
	console.log('Incoming Request:');
	console.log(JSON.stringify(requestInfo, null, 2));

	if (req.method === 'POST') {
		res.writeHead(200, {
			// 'Content-Type': 'text/plain',
			'transfer-encoding': 'chunked'
		})

		req.on('data', (chunk) => {
			console.log('Server Received Chunk:', chunk);
			res.write(chunk);
		})

		req.on('end', ()=> {
			console.log('Server Request Ended');
			res.end();
		})
	} else {
			res.writeHead(200, { 'Content-Type': 'text/plain' });
			res.end('200 OK');
	}
});

server.listen(3000);

await events.once(server, 'listening');

const data = {
  async *[Symbol.asyncIterator]() {
    yield 'hello'
    yield 'world'
  },
}

const response = await fetch('http://localhost:3000', {
  method: 'POST',
  body: stream,
  duplex: 'half'
});

const reader = response.body.getReader();

while (true) {
	const { done, value } = await reader.read();
	if (done) break;
	console.log('Client Received Chunk:', value);
}

server.close();