chore: 🤖 update demo server scripts/tests

Author: streamich

package.json

@@ -56,7 +56,7 @@
     "demo:e2e:json-crdt-server:http1": "ts-node src/__demos__/json-crdt-server/main-http1.ts",
     "demo:e2e:json-crdt-server:uws": "ts-node src/__demos__/json-crdt-server/main-uws.ts",
     "start:json-crdt-server:http1": "NODE_ENV=production PORT=80 JSON_CRDT_STORE=level pm2 start lib/__demos__/json-crdt-server/main-http1.js",
-    "start": "NODE_ENV=production PORT=80 JSON_CRDT_STORE=level pm2 start lib/__demos__/json-crdt-server/main-http1.js",
+    "start": "NODE_ENV=production PORT=80 JSON_CRDT_STORE=level pm2 start lib/__demos__/json-crdt-server/main-http1.js --exp-backoff-restart-delay=100",
     "coverage": "yarn test --collectCoverage",
     "typedoc": "typedoc",
     "build:pages": "rimraf gh-pages && mkdir -p gh-pages && cp -r typedocs/* gh-pages && cp -r coverage gh-pages/coverage",

src/__tests__/e2e/demo-client.ts

@@ -3,10 +3,10 @@ import {RpcCodec} from '../../common/codec/RpcCodec';
 import {RpcPersistentClient, StreamingRpcClient, WebSocketChannel} from '../../common';
 import {FetchRpcClient} from '../../common/rpc/client/FetchRpcClient';
 
-const address = '3.92.169.31';
+const host = '54.204.106.133';
 
 export const setupDemoServerPersistentClient = (codec: RpcCodec) => {
-  const url = `ws://${address}/rpc`;
+  const url = `ws://${host}/rpc`;
   const client = new RpcPersistentClient({
     codec,
     channel: {
@@ -24,7 +24,7 @@ export const setupDemoServerPersistentClient = (codec: RpcCodec) => {
 };
 
 export const setupDemoServerFetchClient = (codec: RpcCodec) => {
-  const url = `http://${address}/rpc`;
+  const url = `http://${host}/rpc`;
   const client = new FetchRpcClient({
     url,
     msgCodec: codec.msg,
@@ -43,7 +43,7 @@ export const setupDemoServerStreamingClient = (codec: RpcCodec) => {
   const client = new StreamingRpcClient({
     send: async (messages) => {
       const port = +(process.env.PORT || 9999);
-      const url = `http://${address}/rpc`;
+      const url = `http://${host}/rpc`;
       codec.req.encoder.writer.reset();
       codec.msg.encodeBatch(codec.req, messages);
       const body = codec.req.encoder.writer.flush();