[task] enable getTimeSinceLastMessage

:100644 100644 29ae60b d2b44d6 M src/connection/socket-factory.ts
deepstreamIO · May 8, 2020 · 388506e · 388506e
1 parent 772810d
commit 388506e
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/src/connection/connection.spec.ts b/src/connection/connection.spec.ts
@@ -67,10 +67,10 @@ describe('connection', () => {
     await recieveConnectionClose()
   })
 
-  it('send pong when ping received across all states', async () => {
+  it('send ping and recieve pong across all states', async () => {
     await openConnection()
-    sendPong()
-    receivePing()
+    sendPing()
+    receivePong()
   })
 
   it('miss heartbeat once', async () => {
@@ -504,20 +504,20 @@ describe('connection', () => {
     await PromiseDelay(0)
   }
 
-  function receivePing () {
+  function receivePong () {
     socket.simulateMessages([{
       topic: TOPIC.CONNECTION,
-      action: CONNECTION_ACTION.PING
+      action: CONNECTION_ACTION.PONG
     }])
   }
 
-  function sendPong () {
+  function sendPing () {
     socketMock
       .expects('sendParsedMessage')
       .once()
       .withExactArgs({
         topic: TOPIC.CONNECTION,
-        action: CONNECTION_ACTION.PONG
+        action: CONNECTION_ACTION.PING
       })
   }
 

diff --git a/src/connection/socket-factory.ts b/src/connection/socket-factory.ts
@@ -35,8 +35,8 @@ export const socketFactory: SocketFactory = (url, options = { jsonTransportMode:
         socket.onparsedmessages(parseResults)
     }
     socket.getTimeSinceLastMessage = () => {
-        return 0
-        // return Date.now() - lastRecievedMessageTimestamp
+      if (lastRecievedMessageTimestamp < 0) return 0
+      return Date.now() - lastRecievedMessageTimestamp
     }
     socket.sendParsedMessage = (message: Message): void => {
         if (message.topic === TOPIC.CONNECTION && message.action === CONNECTION_ACTION.CLOSING) {