Benchmark script + README update

README.md

@@ -186,6 +186,10 @@ Settings:
 * `DEBUG_LEDGER` - start ingest from specific ledger (debug purposes).
 * `INGEST_INTERVAL` - poll db every ms (2000 by default), useful while debugging.
 
+# Benchmark
+
+We have not done full stress test yet. Besides that, it looks like server run on MBP mid 14 with 16GB RAM survives approx 7k concurrent connections with no losses. Check [benchmark script](benchmark/index.ts) for details.
+
 # Contributing
 
 Bug reports and pull requests are welcome on GitHub at https://github.com/mobius-network/astrograph. This project is intended to be a safe, welcoming space for collaboration, and contributors are expected to adhere to the [Contributor Covenant](http://contributor-covenant.org) code of conduct.

benchmark/index.ts

@@ -1,3 +1,5 @@
+// Run with: yarn bench
+
 import ws from "ws";
 import { WebSocketLink } from "apollo-link-ws";
 import { SubscriptionClient } from "subscriptions-transport-ws";
@@ -32,7 +34,9 @@ const SUBSCRIPTION = gql`
 
 client.onError((error) => console.log("An error occured!", error.target));
 
-for (let n = 0; n < 10000; n++) {
+let eventCount = 0;
+
+for (let n = 0; n < 7000; n++) {
   apolloClient.subscribe({
     fetchPolicy: "network-only",
     query: SUBSCRIPTION,
@@ -41,9 +45,9 @@ for (let n = 0; n < 10000; n++) {
     }
   }).subscribe({
     next (data: any) {
-      console.log(data.data.account.id);
+      eventCount += 1;
     }
   });
 }
 
-setTimeout(() => { console.log("Finished."); }, 20000);
+setTimeout(() => { console.log("Finished.", eventCount, "events received."); }, 10000);