I changed the listeners to webSocketMessage() and webSocketClose(), theoretically that's all I need

E

Ephemeros•1/7/25, 6:24 PM

what's the recommended way to keep a durable object staying up forever? e.g. to listen to the bsky firehose

and restart if it crashes somehow

or, should I use something other than a DO for that?

E

Ephemeros•1/7/25, 6:26 PM

hmm, maybe with repeated alarms to keep it awake?

Original message was deleted

E

Ephemeros•1/7/25, 7:26 PM

thanks for confirming!

VVitor S I changed the listeners to webSocketMessage() and webSocketClose(), theoreticall...

1

1984 Ford Laser•1/7/25, 9:11 PM

how are you accepting the connection? You need to use

this.state.acceptWebSocket(socket)

this.state.acceptWebSocket(socket)

this.state.acceptWebSocket(socket)

this.state.acceptWebSocket(socket)

11984 Ford Laser how are you accepting the connection? You need to use `this.state.acceptWebSocke...

V

Vitor SOP•1/8/25, 1:04 PM

Im using the acceptWebsocket()

11984 Ford Laser how are you accepting the connection? You need to use `this.state.acceptWebSocke...

V

Vitor SOP•1/8/25, 1:05 PM

async fetch(request) {
    const upgradeHeader = request.headers.get("Upgrade");

    if (upgradeHeader === "websocket") {
      const [client, server] = Object.values(new WebSocketPair());

      this.state.acceptWebSocket(server);

      const isFirst = this.sessions.size === 0;

      server.serializeAttachment({ isFirst });

      this.sessions.set(server, { isFirst });

      if (!isFirst) {
        console.log("sessions.size: ", this.sessions.size);

        // Debug
        for (let [ws, data] of this.sessions.entries()) {
          console.log("WS:", ws, "DATA:", data);
        }

        // find the connection with session.isFirst === true
        const [firstWs, firstSession] = [...this.sessions.entries()].find(([_, session]) => session.isFirst) || [];

        console.log("Found firstWs:", firstWs, "firstSession:", firstSession);

        if (firstWs) {
          console.log("Sending sync.")
          firstWs.send(JSON.stringify({ Evento: "sincronizar_fila", Comando: "" }));
        }
      }

      // When connect, send the stored musics 
      const storedMusics = await this.state.storage.get("musicas");
      if (storedMusics) {
        server.send(JSON.stringify({ Evento: "musicas", Comando: storedMusics }));
      }

      return new Response(null, { status: 101, webSocket: client });
    }

    return new Response("The request is not a websocket.", { status: 400 });
  }

async fetch(request) {
    const upgradeHeader = request.headers.get("Upgrade");

    if (upgradeHeader === "websocket") {
      const [client, server] = Object.values(new WebSocketPair());

      this.state.acceptWebSocket(server);

      const isFirst = this.sessions.size === 0;

      server.serializeAttachment({ isFirst });

      this.sessions.set(server, { isFirst });

      if (!isFirst) {
        console.log("sessions.size: ", this.sessions.size);

        // Debug
        for (let [ws, data] of this.sessions.entries()) {
          console.log("WS:", ws, "DATA:", data);
        }

        // find the connection with session.isFirst === true
        const [firstWs, firstSession] = [...this.sessions.entries()].find(([_, session]) => session.isFirst) || [];

        console.log("Found firstWs:", firstWs, "firstSession:", firstSession);

        if (firstWs) {
          console.log("Sending sync.")
          firstWs.send(JSON.stringify({ Evento: "sincronizar_fila", Comando: "" }));
        }
      }

      // When connect, send the stored musics 
      const storedMusics = await this.state.storage.get("musicas");
      if (storedMusics) {
        server.send(JSON.stringify({ Evento: "musicas", Comando: storedMusics }));
      }

      return new Response(null, { status: 101, webSocket: client });
    }

    return new Response("The request is not a websocket.", { status: 400 });
  }

async fetch(request) {
    const upgradeHeader = request.headers.get("Upgrade");

    if (upgradeHeader === "websocket") {
      const [client, server] = Object.values(new WebSocketPair());

      this.state.acceptWebSocket(server);

      const isFirst = this.sessions.size === 0;

      server.serializeAttachment({ isFirst });

      this.sessions.set(server, { isFirst });

      if (!isFirst) {
        console.log("sessions.size: ", this.sessions.size);

        // Debug
        for (let [ws, data] of this.sessions.entries()) {
          console.log("WS:", ws, "DATA:", data);
        }

        // find the connection with session.isFirst === true
        const [firstWs, firstSession] = [...this.sessions.entries()].find(([_, session]) => session.isFirst) || [];

        console.log("Found firstWs:", firstWs, "firstSession:", firstSession);

        if (firstWs) {
          console.log("Sending sync.")
          firstWs.send(JSON.stringify({ Evento: "sincronizar_fila", Comando: "" }));
        }
      }

      // When connect, send the stored musics 
      const storedMusics = await this.state.storage.get("musicas");
      if (storedMusics) {
        server.send(JSON.stringify({ Evento: "musicas", Comando: storedMusics }));
      }

      return new Response(null, { status: 101, webSocket: client });
    }

    return new Response("The request is not a websocket.", { status: 400 });
  }

async fetch(request) {
    const upgradeHeader = request.headers.get("Upgrade");

    if (upgradeHeader === "websocket") {
      const [client, server] = Object.values(new WebSocketPair());

      this.state.acceptWebSocket(server);

      const isFirst = this.sessions.size === 0;

      server.serializeAttachment({ isFirst });

      this.sessions.set(server, { isFirst });

      if (!isFirst) {
        console.log("sessions.size: ", this.sessions.size);

        // Debug
        for (let [ws, data] of this.sessions.entries()) {
          console.log("WS:", ws, "DATA:", data);
        }

        // find the connection with session.isFirst === true
        const [firstWs, firstSession] = [...this.sessions.entries()].find(([_, session]) => session.isFirst) || [];

        console.log("Found firstWs:", firstWs, "firstSession:", firstSession);

        if (firstWs) {
          console.log("Sending sync.")
          firstWs.send(JSON.stringify({ Evento: "sincronizar_fila", Comando: "" }));
        }
      }

      // When connect, send the stored musics 
      const storedMusics = await this.state.storage.get("musicas");
      if (storedMusics) {
        server.send(JSON.stringify({ Evento: "musicas", Comando: storedMusics }));
      }

      return new Response(null, { status: 101, webSocket: client });
    }

    return new Response("The request is not a websocket.", { status: 400 });
  }

V

Vitor SOP•1/8/25, 1:06 PM

I managed to migrate. But now I have problems with webSocketClose().

I need the connection that has isFirst = true to close all the others when it is closed.

V

Vitor SOP•1/8/25, 1:07 PM

what i tried:


async webSocketClose(ws) {
    let session = this.sessions.get(ws);

    this.sessions.delete(ws);

    if (session?.isFirst) {
      console.log("The first. Closing all");
      await this.state.storage.delete("musicas");
      for (let [otherWs] of this.sessions.entries()) {
        otherWs.close();
        this.sessions.delete(otherWs);
      }
    }

    ws.close();
  }


async webSocketClose(ws) {
    let session = this.sessions.get(ws);

    this.sessions.delete(ws);

    if (session?.isFirst) {
      console.log("The first. Closing all");
      await this.state.storage.delete("musicas");
      for (let [otherWs] of this.sessions.entries()) {
        otherWs.close();
        this.sessions.delete(otherWs);
      }
    }

    ws.close();
  }


async webSocketClose(ws) {
    let session = this.sessions.get(ws);

    this.sessions.delete(ws);

    if (session?.isFirst) {
      console.log("The first. Closing all");
      await this.state.storage.delete("musicas");
      for (let [otherWs] of this.sessions.entries()) {
        otherWs.close();
        this.sessions.delete(otherWs);
      }
    }

    ws.close();
  }


async webSocketClose(ws) {
    let session = this.sessions.get(ws);

    this.sessions.delete(ws);

    if (session?.isFirst) {
      console.log("The first. Closing all");
      await this.state.storage.delete("musicas");
      for (let [otherWs] of this.sessions.entries()) {
        otherWs.close();
        this.sessions.delete(otherWs);
      }
    }

    ws.close();
  }

V

Vitor SOP•1/8/25, 1:07 PM

but it is not closing the other connections

P

peachneo•1/9/25, 1:45 AM

is rpc just sugar over the fetch handler? Or does it have material performance differences (eg uses websockets or some different underlying transpoort)

Ppeachneo is rpc just sugar over the fetch handler? Or does it have material performance d...

M

Max (@rozenmd)•1/9/25, 11:27 AM

rpc is faster, less overhead

Ppeachneo is rpc just sugar over the fetch handler? Or does it have material performance d...

S

sathoro•1/9/25, 1:26 PM

websockets are HTTP with more overhead

Ssathoro websockets are HTTP with more overhead 👀

M

Milan•1/9/25, 3:37 PM

WebSockets start as an HTTP upgrade but once the connection is established it's just TCP.

M

Milan•1/9/25, 3:38 PM

https://datatracker.ietf.org/doc/html/rfc6455#section-1.7

IETF Datatracker

RFC 6455: The WebSocket Protocol

The WebSocket Protocol enables two-way communication between a client running untrusted code in a controlled environment to a remote host that has opted-in to communications from that code. The security model used for this is the origin-based security model commonly used by web browsers. The protocol consists of an opening handshake followed by ...

Ppeachneo is rpc just sugar over the fetch handler? Or does it have material performance d...

B

Beefp•1/9/25, 6:12 PM

rpc has limit of i think 1mb arguments/response over the wire

BBeefp rpc has limit of i think 1mb arguments/response over the wire

L

lambrospetrou•1/9/25, 7:15 PM

You can pass and return streams to overcome the 1mb limit. These streams can even be inside an object.

R

rob•1/9/25, 7:37 PM

if im looking to do a real time chat with rooms is partyserver the bst bet to get going? Is there any starter examples for that

M

marko.333•1/9/25, 9:11 PM

I'm a little uncertain of the concurrency rules for Durable Objects RPC calls?
If i have a DO("id1").doStuff() and many concurrent clients are connected to same DO instance ("id1"), then (roughly) all callers to doStuff() are serialized when a storage call is in-progress.
But i wanted to confirm that serialized execution is only triggered for storage calls - correct?
For example, what if the doStuff() implementation included some external calls (to another Worker, or external API fetch, ...)?
While await'ing for the external call to complete, will the other concurrent callers of doStuff() be able to continue execution (ie. an external API call will not cause all other concurrent callers to block)?
Thx.

Mmarko.333 I'm a little uncertain of the concurrency rules for Durable Objects RPC calls? ...

L

lambrospetrou•1/10/25, 9:49 AM

Yes, if you do an async IO call then other requests will run. If you want to fully block concurrency you can use https://developers.cloudflare.com/durable-objects/api/state/#blockconcurrencywhile

M

mihaaai•1/10/25, 1:58 PM

When using a sqlite-based Durable Objects, is Libsql for DO storage increasing the cursor memory with each read operation? Asking because we're trying to figure out final costs based also on the Duration GB-s constraint.

Rrob if im looking to do a real time chat with rooms is partyserver the bst bet to ge...

H

harshil1712•1/10/25, 2:28 PM

Hey, I have used PartyServer and love it because it makes it takes away a lot of boilerplate code. Also, I found this example in the repo: https://github.com/threepointone/partyserver/blob/main/fixtures/chat/README.md
Also, FYI, the repo says it is a Work in Progress

GitHub

partyserver/fixtures/chat/README.md at main · threepointone/partyse...

PartyKit, for Workers. Contribute to threepointone/partyserver development by creating an account on GitHub.

Mmihaaai When using a sqlite-based Durable Objects, is Libsql for DO storage increasing t...

L

lambrospetrou•1/10/25, 3:17 PM

GB/s is not checking how much memory your code uses, since you are charged for the 128MB allocated to your DO. See details in https://developers.cloudflare.com/durable-objects/platform/pricing/
So, regardless if you use 100MB or 10MB while iterating your results, the billing won't change.

5 Duration billing charges for the 128 MB of memory your Durable Object is allocated, regardless of actual usage. If your account creates many instances of a single Durable Object class, Durable Objects may run in the same isolate on the same physical machine and share the 128 MB of memory. These Durable Objects are still billed as if they are allocated a full 128 MB of memory.

Hharshil1712 Hey, I have used PartyServer and love it because it makes it takes away a lot of...

R

rob•1/10/25, 3:19 PM

yes thsi! i was looking if someone/s set it up before and could asisst a bit

Rraoulduke Hey I have a problem with my connections map for my web socket not maintaining s...

1

1984 Ford Laser•1/10/25, 8:42 PM

what happens when you do

this.state.getWebSockets()

this.state.getWebSockets()

?

Hharshil1712 Hey, I have used PartyServer and love it because it makes it takes away a lot of...

R

ray•1/10/25, 11:45 PM

I've been trying to set up partyserver for my use case and was wondering if you could share a bit of your experience; i have multiple durable objects that handle different logic and I'm not sure how best to run local dev and deploy

R

ray•1/10/25, 11:48 PM

Should each DO be defined with it's own wrangler.toml and have a root package.json that runs

wrangler dev

wrangler dev

in each folder? Or should i have all the DO bindings defined on a root wrangler.toml? In my case I have a sveltekit app that I'm also deploying on a worker, and was wondering if I should be defining all my DO bindings on my sveltekit wrangler.toml

P

peachneo•1/11/25, 2:48 AM

How do alarm() retries interact with setAlarm() ?

if alarm() throws thereby queueing a retry - will a subsequent call to setAlarm() "reset" the retry?

Rray Should each DO be defined with it's own wrangler.toml and have a root package.js...

E

Ephemeros•1/11/25, 11:11 AM

i dunno about partyserver but I have that setup, each DO and worker has its own wrangler and they share dbs etc like this

e.g.

durable-objects/authdo

"dev": "wrangler dev -e local --show-interactive-dev-session false --ip 0.0.0.0 --persist-to ../../.wrangler/state",

durable-objects/chatdo
"dev": "wrangler dev -e local --show-interactive-dev-session false --ip 0.0.0.0 --persist-to ../../.wrangler/state",

apps/worker-app
"dev": "wrangler dev -e local --show-interactive-dev-session false --ip 0.0.0.0 --persist-to ../../.wrangler/state",

EEphemeros i dunno about partyserver but I have that setup, each DO and worker has its own ...

R

ray•1/12/25, 2:28 AM

Appreciate you sharing this! Really helps me wrap my head around how I should structure things, are you also binding your authDO on your worker-app wrangler file?

Rray Appreciate you sharing this! Really helps me wrap my head around how I should st...

E

Ephemeros•1/12/25, 7:47 AM

Yep, I have some as service binding some as durable object bindings

E

Ephemeros•1/12/25, 3:19 PM

Totally, also when you separate them and can deploy only what changes it's a superpower, like zero downtime

E

Ephemeros•1/12/25, 3:19 PM

Especially if you can have multiple deployments for your workers and DOs and you can swap from one to another with a switch, really zero downtime

E

Ephemeros•1/12/25, 3:20 PM

And then we are back to.. microservices

E

Ephemeros•1/12/25, 3:21 PM

I made it kinda overkill with local/dev/staging/prod environments but it just was too easy to set that up lol

Rray I've been trying to set up partyserver for my use case and was wondering if you ...

B

Beefp•1/12/25, 6:25 PM

We started out with 6 DO classes in a monolith worker. In the beginning it was a lot easier to work with (single deploy, no bindings) but we hit perf issues because our monolith bundle was so large and Cf loads it on every Worker request or every individual DO request. We are currently splitting into multiple Workers which means transfer migrations as we DO storage heavily

Personally I'd love if Cloudflare improved support for smarter loading/importing based on whether the code is executing as a Worker or as a DO, and which DO class specifically. Doesn't seem necessary to load everything at once if the Worker scripts are set up the right way

BBeefp We started out with 6 DO classes in a monolith worker. In the beginning it was a...

R

ray•1/13/25, 4:16 AM

Thanks for the heads-up, definitely will be deploying separately based on your experiences, although local dev experience is going to suck until they release the v5 terraform sdk

I

Isak•1/13/25, 9:44 PM

Interesting thanks for this. How big was your worker and what performance gains did you observe? @Beefp

IIsak Interesting thanks for this. How big was your worker and what performance gains ...

B

Beefp•1/13/25, 10:13 PM

I started writing but it turned into a wall of text. I'll summarize here but I want to write a more detailed thing later on our blog. We measured two things:

Bundle startup time which you get as output from Wrangler when you deploy. We went from 200ms -> 40ms just by simplifying dependencies, lazy-loading where possible, splitting out heavier packages.
Response time hitting a simple Hello World endpoint. We had endpoints just for the Worker and one for each DO class. Response times on the Worker went from about 500ms to sub 200. Going through the Worker to the DO is a bit more.

We started off with a lot of low hanging fruit like bundles that were doing all their processing when you imported them, and some packages like limax and OpenAI which have a heavy overhead (they went into different Workers).

B

Beefp•1/13/25, 10:16 PM

if you are dealing with a monolith my recommendation is: build your worker locally and load it into Chrome with

---inspect-brk

---inspect-brk

you'll see exactly where time is being spent. I think once you've optimized on your side the only thing you can do is architect your DOs and Workers in a way that they're closer to your users which is another topic + what we're dealing with now (moveable DOs when pls)

TTyveris I’m considering using Durable Objects with WebSockets and hibernation for a game...

1

1984 Ford Laser•1/14/25, 2:42 AM

It makes sense to me
According to this page: https://developers.cloudflare.com/durable-objects/best-practices/websockets/#extended-methods the serialized attachment will survive hibernation, I think there is always a chance of losing the data such as in the event of CF maintenance/outages, or a reboot on the overall runtime, or you deploy a new version (I think)
Memory is reliable for 5sec, after that there's zero guarantee, if you know you won't need it after 5 seconds then you'd be fine

All of this is in theory, I'd be interested in how your solution works as I'm also interested in the websocket attachment methods

1

1984 Ford Laser•1/14/25, 4:05 AM

I'd love if

namespaceId

namespaceId

and

objectId

objectId

were added as dimensions to the

durableObjectsStorageGroups

durableObjectsStorageGroups

in the graphql API, so we could calculate used storage per DO instance

M

mihaaai•1/14/25, 4:54 PM

I noticed that in a SQLite based Durable Object, any

INSERT

INSERT

operation against the storage returns 2

rowsWritten

rowsWritten

, although I only inserted one row, is this normal behavior or am I missing something?
It's also unlikely that I exceeded any 4k limit for write units, although I'm not sure if it applies to SQLite based DOs, and I don't have any index on the table I'm writing to.

Mmihaaai I noticed that in a SQLite based Durable Object, any `INSERT` operation against ...

J

James•1/14/25, 4:59 PM

could be the default index for rowid, or a trigger for updated ts updates

JJames could be the default index for rowid, or a trigger for updated ts updates

M

mihaaai•1/14/25, 5:02 PM

Interesting, is there any way to disable that index on

rowid

rowid

?
I'm trying to optimize pricing since my use case is a write heavy one.

J

James•1/14/25, 5:03 PM

https://www.sqlite.org/withoutrowid.html

I changed the listeners to webSocketMessage() and webSocketClose(), theoretically that's all I need

Similar Threads

Similar Threads

Similar Threads