test: Add logging when tests to something unnatural, to avoid confusion when parsing logs.

Author: timoxley

test/integration/GapFill.test.ts

@@ -121,6 +121,7 @@ describeRepeats('GapFill with resends', () => {
 
                 count += 1
                 if (count === 2) {
+                    client.debug('(%o) << Test Dropped Message %s: %o', client.connection.getState(), count, msg)
                     return null
                 }
 
@@ -130,7 +131,7 @@ describeRepeats('GapFill with resends', () => {
             expect(subscriber.count(stream.id)).toBe(1)
 
             const published = await publishTestMessages(MAX_MESSAGES, {
-                timestamp: 111111,
+                waitForLast: true,
             })
 
             const received = []
@@ -155,7 +156,8 @@ describeRepeats('GapFill with resends', () => {
                 }
 
                 count += 1
-                if (count > 1 && count < 5) {
+                if (count > 1 && count < 4) {
+                    client.debug('(%o) << Test Dropped Message %s: %o', client.connection.getState(), count, msg)
                     return null
                 }
 
@@ -164,7 +166,9 @@ describeRepeats('GapFill with resends', () => {
 
             expect(subscriber.count(stream.id)).toBe(1)
 
-            const published = await publishTestMessages(MAX_MESSAGES)
+            const published = await publishTestMessages(MAX_MESSAGES, {
+                waitForLast: true,
+            })
 
             const received = []
             for await (const m of sub) {
@@ -175,7 +179,7 @@ describeRepeats('GapFill with resends', () => {
             }
             expect(received).toEqual(published)
             expect(client.connection.getState()).toBe('connected')
-        }, 10000)
+        }, 20000)
 
         it('can fill multiple gaps', async () => {
             const sub = await client.subscribe(stream.id)
@@ -189,6 +193,7 @@ describeRepeats('GapFill with resends', () => {
 
                 count += 1
                 if (count === 3 || count === 4 || count === 7) {
+                    client.debug('(%o) << Test Dropped Message %s: %o', client.connection.getState(), count, msg)
                     return null
                 }
 
@@ -197,7 +202,9 @@ describeRepeats('GapFill with resends', () => {
 
             expect(subscriber.count(stream.id)).toBe(1)
 
-            const published = await publishTestMessages(MAX_MESSAGES)
+            const published = await publishTestMessages(MAX_MESSAGES, {
+                waitForLast: true,
+            })
 
             const received = []
             for await (const m of sub) {
@@ -221,14 +228,14 @@ describeRepeats('GapFill with resends', () => {
 
                 count += 1
                 if (count === 3 || count === 4 || count === 7) {
+                    client.debug('(%o) << Test Dropped Message %s: %o', client.connection.getState(), count, msg)
                     return null
                 }
 
                 return msg
             }
 
             const published = await publishTestMessages(MAX_MESSAGES, {
-                timestamp: 111111,
                 waitForLast: true,
             })
 
@@ -260,10 +267,12 @@ describeRepeats('GapFill with resends', () => {
                     if (!droppedMsgRef) {
                         droppedMsgRef = msg.streamMessage.getMessageRef()
                     }
+                    client.debug('(%o) << Test Dropped Message %s: %o', client.connection.getState(), count, msg)
                     return null
                 }
 
                 if (droppedMsgRef && msg.streamMessage.getMessageRef().compareTo(droppedMsgRef) === 0) {
+                    client.debug('(%o) << Test Dropped Message %s: %o', client.connection.getState(), count, msg)
                     return null
                 }
 

test/integration/StreamConnectionState.test.ts

@@ -281,6 +281,7 @@ describeRepeats('Connection State', () => {
                 received.push(msg.getParsedContent())
                 if (received.length === 2) {
                     expect(received).toEqual(published)
+                    client.debug('test closing socket')
                     client.connection.socket.close()
                     // this will cause a gap fill
                     published.push(...(await publishTestMessages(2)))
@@ -304,6 +305,7 @@ describeRepeats('Connection State', () => {
                 received.push(msg.getParsedContent())
                 if (received.length === 1) {
                     expect(received).toEqual(published.slice(0, 1))
+                    client.debug('test disconnecting')
                     client.disconnect() // should trigger break
                     // no await, should be immediate
                 }
@@ -337,6 +339,7 @@ describeRepeats('Connection State', () => {
             for await (const msg of sub2) {
                 received2.push(msg.getParsedContent())
                 if (received2.length === 1) {
+                    client.debug('test disconnecting')
                     await client.disconnect()
                 }
             }
@@ -406,7 +409,9 @@ describeRepeats('Connection State', () => {
                     if (localOtherClient !== otherClient) {
                         throw new Error('not equal')
                     }
+
                     await localOtherClient.nextConnection()
+
                     if (cancelled || msgs.length === MAX_MESSAGES) {
                         reconnected.resolve(undefined)
                         return
@@ -415,6 +420,7 @@ describeRepeats('Connection State', () => {
                     if (localOtherClient !== otherClient) {
                         throw new Error('not equal')
                     }
+                    client.debug('test closing localOtherClient socket')
                     localOtherClient.connection.socket.close()
                     // wait for reconnection before possibly disconnecting again
                     await localOtherClient.nextConnection()