stress: use connectrpc http2 (#600)

Copy-pasted from the notification service Closes #543 --------- Co-authored-by: texuf <[email protected]>
river-build · Aug 5, 2024 · 761fe1c · 761fe1c
1 parent 09aa462
commit 761fe1c
Show file tree

Hide file tree

Showing 16 changed files with 446 additions and 345 deletions.
diff --git a/.vscode/launch.json b/.vscode/launch.json
@@ -82,5 +82,15 @@
       "args": ["${file}", "--config", "${workspaceFolder}/packages/sdk/jest.config.ts", "-i", "--no-cache", "--forceExit"],
       "console": "integratedTerminal",
     },
+    {
+      "name": "Jest: current file in 'packages/stress/' (single entitlements)",
+      "type": "node",
+      "request": "launch",
+      "env": { "NODE_ENV": "development", "NODE_TLS_REJECT_UNAUTHORIZED": "0", "RIVER_ENV": "local_single", "DEBUG": "csb:*,test:*", "DEBUG_DEPTH":"1" },
+      "program": "${workspaceFolder}/node_modules/.bin/jest",
+      "runtimeArgs": ["--experimental-vm-modules", "--experimental-wasm-modules"],
+      "args": ["${file}", "--config", "${workspaceFolder}/packages/stress/jest.config.ts", "-i", "--no-cache", "--forceExit"],
+      "console": "integratedTerminal",
+    },
   ]
 }
diff --git a/packages/sdk/src/client.ts b/packages/sdk/src/client.ts
@@ -52,8 +52,9 @@ import {
     UserDeviceCollection,
     makeSessionKeys,
 } from '@river-build/encryption'
+import { StreamRpcClient } from './makeStreamRpcClient'
+import { errorContains, getRpcErrorProperty } from './rpcInterceptors'
 import { assert, isDefined } from './check'
-import { errorContains, getRpcErrorProperty, StreamRpcClient } from './makeStreamRpcClient'
 import EventEmitter from 'events'
 import TypedEmitter from 'typed-emitter'
 import {

diff --git a/packages/sdk/src/index.ts b/packages/sdk/src/index.ts
@@ -16,6 +16,7 @@ export * from './observable/persistedObservable'
 export * from './persistenceStore'
 export * from './riverConfig'
 export * from './riverDbManager'
+export * from './rpcInterceptors'
 export * from './sign'
 export * from './signerContext'
 export * from './store/store'

diff --git a/packages/sdk/src/makeRiverRpcClient.ts b/packages/sdk/src/makeRiverRpcClient.ts
@@ -1,5 +1,6 @@
 import { RiverChainConfig, createRiverRegistry } from '@river-build/web3'
-import { RetryParams, StreamRpcClient, makeStreamRpcClient } from './makeStreamRpcClient'
+import { StreamRpcClient, makeStreamRpcClient } from './makeStreamRpcClient'
+import { RetryParams } from './rpcInterceptors'
 import { ethers } from 'ethers'
 
 export async function makeRiverRpcClient(

diff --git a/packages/sdk/src/makeStreamRpcClient.test.ts b/packages/sdk/src/makeStreamRpcClient.test.ts
@@ -4,7 +4,7 @@
 
 import { Err, InfoRequest, InfoResponse } from '@river-build/proto'
 import { makeTestRpcClient } from './util.test'
-import { errorContains } from './makeStreamRpcClient'
+import { errorContains } from './rpcInterceptors'
 import { makeRiverRpcClient } from './makeRiverRpcClient'
 import { LocalhostWeb3Provider } from '@river-build/web3'
 import { makeRiverChainConfig } from './riverConfig'