sachaw•6mo ago

Way too iterate over Deno.serve connections?

Hi, as a lot of the old http api's are now deprecated, I would like to know if there is a nice way to achieve the following: Create a Deno.serve instance, iterate over each request, my goal is to put this in an async generator that yields upgraded websockets. This is doable with the Deno.listen api, but now that the Deno.serveHttp is deprecated, I'm not sure how to proceed. Thanks.

3 Replies

Deno AI Helper•6mo ago

Hello! 🦕 To iterate over connections using Deno.serve, you can use the new stable API that simplifies the process of setting up a web server. Here's an example from the documentation that demonstrates how to create a server and handle requests:

import { serve } from "https://deno.land/std@0.140.0/http/server.ts";

serve((req) => new Response("Hello, world"));

import { serve } from "https://deno.land/std@0.140.0/http/server.ts";

serve((req) => new Response("Hello, world"));

In this example, serve is a function that takes a handler function as an argument. The handler function is called for each incoming request, and you can respond to each request with a Response object. If you want to upgrade connections to WebSockets within this setup, you can use Deno.upgradeWebSocket inside the handler function. Here's an example based on the documentation:

import { serve } from "https://deno.land/std@0.140.0/http/server.ts";

serve((req) => {
  const upgrade = req.headers.get("upgrade") || "";
  if (upgrade.toLowerCase() != "websocket") {
    return new Response("request isn't trying to upgrade to websocket.");
  }
  const { socket, response } = Deno.upgradeWebSocket(req);
  socket.onopen = () => console.log("socket opened");
  socket.onmessage = (e) => {
    console.log("socket message:", e.data);
    socket.send(new Date().toString());
  };
  socket.onerror = (e) => console.log("socket errored:", e.message);
  socket.onclose = () => console.log("socket closed");
  return response;
});

import { serve } from "https://deno.land/std@0.140.0/http/server.ts";

serve((req) => {
  const upgrade = req.headers.get("upgrade") || "";
  if (upgrade.toLowerCase() != "websocket") {
    return new Response("request isn't trying to upgrade to websocket.");
  }
  const { socket, response } = Deno.upgradeWebSocket(req);
  socket.onopen = () => console.log("socket opened");
  socket.onmessage = (e) => {
    console.log("socket message:", e.data);
    socket.send(new Date().toString());
  };
  socket.onerror = (e) => console.log("socket errored:", e.message);
  socket.onclose = () => console.log("socket closed");
  return response;
});

In this code, we check if the request is trying to upgrade to a WebSocket. If it is, we use Deno.upgradeWebSocket to upgrade the connection and then handle the WebSocket events like onopen, onmessage, onerror, and onclose. You can adapt this example to fit into an async generator by yielding the upgraded WebSocket connections. Remember to handle each request

Deno AI Helper•6mo ago

asynchronously to ensure that your server can process multiple requests concurrently. I hope this helps you set up your server with upgraded WebSocket connections! If you have any more questions or need further assistance, feel free to ask. 🦕

Helpful Links: Web Streams at the Edge Deno 1.33: Deno 2 is coming Deno 1.19 Release Notes Deno 1.35: A fast and convenient way to build web servers Deno 1.9 Release Notes Deno 1.17 Release Notes HTTP Server: WebSockets - Deno by Example Deno 1.13 Release Notes Deno 1.18 Release Notes

Leokuma•5mo ago

You can yield a WebSocket like this:

Deno.serve(req => {
  const {socket, response} = Deno.upgradeWebSocket(req)
  return response
})

Deno.serve(req => {
  const {socket, response} = Deno.upgradeWebSocket(req)
  return response
})

I hope it helps