tests

Author: apietroni51

test/e2e/environment.test.ts

@@ -1,6 +1,15 @@
 import { afterEach, beforeEach, describe, expect, test } from "vitest"
 import { createEnvironment, Environment } from "../../src/environment.js"
-import { host, port, username, password, numberOfConnections, eventually } from "../support/util.js"
+import {
+  host,
+  port,
+  username,
+  password,
+  numberOfConnections,
+  eventually,
+  closeAllConnections,
+  wait,
+} from "../support/util.js"
 
 describe("Environment", () => {
   let environment: Environment
@@ -26,9 +35,42 @@ describe("Environment", () => {
     })
   })
 
-  test("create a connection with reconnect true", async () => {
+  test("a connection with reconnect false does not reconnect", async () => {
+    await environment.createConnection({ reconnect: false })
+
+    await closeAllConnections()
+    await wait(2000)
+
+    expect(await numberOfConnections()).to.eql(0)
+  })
+
+  test("a connection with reconnect true reconnects", async () => {
     await environment.createConnection({ reconnect: true })
 
+    await closeAllConnections()
+
+    await eventually(async () => {
+      expect(await numberOfConnections()).to.eql(1)
+    })
+  })
+
+  test("a connection reconnects by default", async () => {
+    await environment.createConnection()
+
+    await closeAllConnections()
+
+    await eventually(async () => {
+      expect(await numberOfConnections()).to.eql(1)
+    })
+  })
+
+  test("a connection with reconnect set to number retries after number ms", async () => {
+    await environment.createConnection({ reconnect: 2000, initialReconnectDelay: 2000 })
+
+    await closeAllConnections()
+    await wait(1900)
+
+    expect(await numberOfConnections()).to.eql(0)
     await eventually(async () => {
       expect(await numberOfConnections()).to.eql(1)
     })

test/unit/rhea/connection.test.ts

@@ -2,7 +2,6 @@ import { afterEach, beforeEach, describe, expect, test } from "vitest"
 import { host, port, username, password, numberOfConnections, eventually } from "../../support/util.js"
 import { Connection, Container, create_container } from "rhea"
 import { closeConnection, openConnection, openManagement } from "../../support/rhea_utils.js"
-import { isReconnectionParamsDetails } from "../../../src/connection.js"
 
 describe("Rhea connections", () => {
   let container: Container
@@ -41,17 +40,4 @@ describe("Rhea connections", () => {
       await openManagement(connection)
     }, 4000)
   })
-
-  test("is reconnection param detail", () => {
-    expect(isReconnectionParamsDetails(true)).to.eql(false)
-    expect(isReconnectionParamsDetails(false)).to.eql(false)
-    expect(isReconnectionParamsDetails(123)).to.eql(false)
-    expect(
-      isReconnectionParamsDetails({
-        initialReconnectDelay: 1,
-        maxReconnectDelay: 1,
-        reconnectLimit: 1,
-      })
-    ).to.eql(true)
-  })
 })