import { connect } from "@arrowood.dev/socket";

const decoder = new TextDecoder();

async function fetch(request) {
  const gopherAddr = { hostname: "gopher.floodgap.com", port: 70 };
  const url = new URL(request.url);

  try {
    const socket = connect(gopherAddr);

    const writer = socket.writable.getWriter();
    const encoder = new TextEncoder();
    const encoded = encoder.encode(url.pathname + "\r\n");
    await writer.write(encoded);

    return new Response(socket.readable, {
      headers: { "Content-Type": "text/plain" },
    });
  } catch (error) {
    console.log("error", error);
    return new Response("Socket connection failed: " + error, { status: 500 });
  }
}

const response = await fetch(new Request("gopher://gopher.floodgap.com/"));

for await (const chunk of response.body) {
  // console.log(decoder.decode(chunk));
}