test: allow running integration tests against a single endpoint (#558)

Author: rflechtner

packages/core/src/__integrationtests__/utils.ts

@@ -33,17 +33,17 @@ import { connect, init } from '../kilt'
 export const EXISTENTIAL_DEPOSIT = new BN(10 ** 13)
 const ENDOWMENT = EXISTENTIAL_DEPOSIT.muln(10000)
 
-const containerPromise = new GenericContainer(
-  process.env.TESTCONTAINERS_NODE_IMG || 'kiltprotocol/mashnet-node:latest'
-)
-  .withCmd(['--dev', '--ws-port', '9944', '--ws-external'])
-  .withExposedPorts(9944)
-  .withWaitStrategy(Wait.forLogMessage('Idle'))
-  .start()
-
 async function getStartedTestContainer(): Promise<StartedTestContainer> {
   try {
-    return await containerPromise
+    const image =
+      process.env.TESTCONTAINERS_NODE_IMG || 'kiltprotocol/mashnet-node'
+    console.log(`using testcontainer with image ${image}`)
+    const testcontainer = new GenericContainer(image)
+      .withCmd(['--dev', '--ws-port', '9944', '--ws-external'])
+      .withExposedPorts(9944)
+      .withWaitStrategy(Wait.forLogMessage(/idle/i))
+    const started = await testcontainer.start()
+    return started
   } catch (error) {
     console.error(
       'Could not start the docker container via testcontainers, run with DEBUG=testcontainers* to debug'
@@ -53,20 +53,21 @@ async function getStartedTestContainer(): Promise<StartedTestContainer> {
 }
 
 export async function initializeApi(): Promise<void> {
-  const started = await getStartedTestContainer()
-  const port = started.getMappedPort(9944)
-  const host = started.getHost()
-  const WS_ADDRESS = `ws://${host}:${port}`
-  await init({ address: WS_ADDRESS })
-  const api = await connect()
-
-  api.once('disconnected', async () => {
-    try {
-      await started.stop()
-    } catch (error) {
-      console.error(error)
-    }
-  })
+  if (process.env.TEST_WS_ADDRESS) {
+    console.log(`connecting to node ${process.env.TEST_WS_ADDRESS}`)
+    await init({ address: process.env.TEST_WS_ADDRESS })
+    connect()
+  } else {
+    const started = await getStartedTestContainer()
+    const port = started.getMappedPort(9944)
+    const host = started.getHost()
+    const WS_ADDRESS = `ws://${host}:${port}`
+    console.log(`connecting to node ${WS_ADDRESS}`)
+    await init({ address: WS_ADDRESS })
+    connect().then((api) =>
+      api.once('disconnected', () => started.stop().catch())
+    )
+  }
 }
 
 const keyring = new Keyring({ ss58Format, type: 'ed25519' })