Skip to content

Create devcontainer.json#4

Closed
CASABECI wants to merge 1 commit into
apfitzge:masterfrom
CASABECI:patch-1
Closed

Create devcontainer.json#4
CASABECI wants to merge 1 commit into
apfitzge:masterfrom
CASABECI:patch-1

Conversation

@CASABECI
Copy link
Copy Markdown

@CASABECI CASABECI commented Oct 2, 2024

Problem

Summary of Changes

Fixes #

@github-actions github-actions Bot added the stale label Oct 17, 2024
@github-actions github-actions Bot closed this Oct 25, 2024
apfitzge pushed a commit that referenced this pull request Oct 21, 2025
* Apply the retry code to the async pubsub client

Create a test server

```ts
import http from "http";

import { WebSocketServer } from "ws";

let attemptCount = 0;

const server = http.createServer();
const wss = new WebSocketServer({ noServer: true });

wss.on("connection", (ws) => {
  ws.send("Connection accepted.");
  ws.on("message", (msg) => console.log(`Received: ${msg}`));
});

server.on("upgrade", (req, socket, head) => {
  attemptCount += 1;

  if (attemptCount <= 4) {
    socket.write("HTTP/1.1 429 Too Many Requests\r\n\r\n");
    socket.destroy();
    console.log(`Rejected connection #${attemptCount} (429)`);
    return;
  }

  wss.handleUpgrade(req, socket, head, (ws) => {
    wss.emit("connection", ws, req);
    console.log("Connection accepted on attempt", attemptCount);
  });
});

server.listen(8080, () => {
  console.log("Server listening on port 8080");
});
```

Run `test_slot_subscription_async`:

```
Rejected connection #1 (429)
Rejected connection #2 (429)
Rejected connection #3 (429)
Rejected connection #4 (429)
Connection accepted on attempt 5
Received: {"id":1,"jsonrpc":"2.0","method":"slotSubscribe","params":[]}
```

* `s/async_with_retry/with_retry/`
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant