fix port conflicts in kinto e2e tests

pimlicolabs · May 30, 2024 · 2155f7e · 2155f7e
1 parent 27aef2f
commit 2155f7e
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 7 deletions.
diff --git a/test/kinto-e2e/src/index.ts b/test/kinto-e2e/src/index.ts
@@ -120,8 +120,8 @@ const main = async () => {
 
  const failedOps: OpInfoType[] = []
 
- const chunkSize = 50
- const totalOps = 200
+ const chunkSize = 25
+ const totalOps = 800
  let processed = 0
 
  while (userOperationEvents.length > 0) {
@@ -194,12 +194,19 @@ const main = async () => {
  let anvilIdCounter = 0
  let altoPortCounter = 4337
 
- const inputStream = filteredOpInfo.map(async (opInfo) => {
+ const portNumbers = Array.from({ length: filteredOpInfo.length }, () => ({
+ anvilId: anvilIdCounter++,
+ altoPort: altoPortCounter++
+ }))
+
+ const inputStream = filteredOpInfo.map(async (opInfo, index) => {
  try {
+ const { anvilId, altoPort } = portNumbers[index]
+
  const canReplay = await canReplayUserOperation({
  anvilPool,
- anvilId: anvilIdCounter++,
- altoPort: altoPortCounter++,
+ anvilId,
+ altoPort,
  opInfo
  })
 

diff --git a/test/kinto-e2e/src/setupAlto.ts b/test/kinto-e2e/src/setupAlto.ts
@@ -47,8 +47,8 @@ export const startAlto = async (rpc: string, altoPort: string) => {
  const alto = spawn(command, args, options)
 
  // [USE FOR DEBUGGING]
- //alto.stdout.on("data", (data) => console.log(data.toString()))
- //alto.stderr.on("data", (data) => console.log(data.toString()))
+ // alto.stdout.on("data", (data) => console.log(data.toString()))
+ // alto.stderr.on("data", (data) => console.log(data.toString()))
 
  await waitPort({
  host: "127.0.0.1",