deduplicate env timestamp on messages

Author: neuroscr

lib/recv.js

@@ -95,7 +95,7 @@ body:
 <Buffer 08 06 12 00 28 a8 cf ee db bb 2e 38 00 42 fb 03 11 0a 21 05 c1 2f 19 01 ef 8e 62 8f 8e f3 58 25 42 47 de cc 5d 43 e3 a1 70 dd 22 1e f7 c7 68 63 c9 d5 ... >,
 id: Long { low: -347036081, high: 1342692244, unsigned: true } } }
 */
- //console.log('message', message)
+ //console.log('wsMessage', wsMessage)
  if (wsMessage.type !== 1 || !wsMessage.request) {
  console.warn('unhandled websocket message', wsMessage)
  return
@@ -111,10 +111,12 @@ content:
 <Buffer 11 0a 21 05 1c 97 2a 1b d8 d7 35 38 01 4f 90 eb 66 18 9d 96 36 b6 da d5 ac a6 21 ab 8f 02 ce 46 8c 7f d0 29 12 2b 2e 71 4c a5 14 50 2a 10 1a fe 2b f3 ... > }
 */
  //console.log('env', env)
+ //console.log('env timestamp', env.timestamp.toString())
  if (decodeMessageMap[env.type]) {
  const res = await decodeMessageMap[env.type](env, ourKeypair)
  if (res) {
- return {...res, snodeExp: msg.expiration, hash: msg.hash}
+ //console.log('res', res)
+ return {...res, snodeExp: msg.expiration, hash: msg.hash, timestamp: env.timestamp.toString() }
  } else {
  return {}
  }
@@ -123,6 +125,37 @@ content:
  }
 }
 
+/*
+pubKeyAsk start https://54.39.15.185:22120/storage_rpc/v1 05aba1ad0ac5f3f5dbd14c54e81ce2a26c58e6fa2b2a901d40eb85246c3ce31b22 xJwZ9reNcRjeJZhLriFxvo3aURsokOsm0c0YN6S7a1c
+recv::checkBox - foundHash xJwZ9reNcRjeJZhLriFxvo3aURsokOsm0c0YN6S7a1c in results? false
+1669959312621 SessionClient::poll - recvLib got {
+ lastHash: 'xJwZ9reNcRjeJZhLriFxvo3aURsokOsm0c0YN6S7a1c',
+ messages: []
+}
+pubKeyAsk start https://149.56.113.46:22106/storage_rpc/v1 05aba1ad0ac5f3f5dbd14c54e81ce2a26c58e6fa2b2a901d40eb85246c3ce31b22 xJwZ9reNcRjeJZhLriFxvo3aURsokOsm0c0YN6S7a1c
+recv::checkBox - foundHash xJwZ9reNcRjeJZhLriFxvo3aURsokOsm0c0YN6S7a1c in results? false
+1669959343209 SessionClient::poll - recvLib got {
+ lastHash: 'alN/b0GFAC6FH7jWQtTwXtZ7bkNYT1xK40fvenM4uAY',
+ messages: [
+ {
+ dataMessage: [DataMessage],
+ source: '05b69cc33267ada004c60677f39bcc3db91f1cfd841c0a3226a2b2bcc062d28959',
+ snodeExp: 1671168929902,
+ hash: 'U/wmKjLCEr9ph09APgyTNefmV1b4G+pMdXf6bgVSUgw'
+ },
+ {
+ dataMessage: [DataMessage],
+ source: '05b69cc33267ada004c60677f39bcc3db91f1cfd841c0a3226a2b2bcc062d28959',
+ snodeExp: 1671168929901,
+ hash: 'alN/b0GFAC6FH7jWQtTwXtZ7bkNYT1xK40fvenM4uAY'
+ }
+ ]
+}
+setLast alN/b0GFAC6FH7jWQtTwXtZ7bkNYT1xK40fvenM4uAY
+1669959343565 DM from 05b69cc33267ada004c60677f39bcc3db91f1cfd841c0a3226a2b2bcc062d28959 Vector12ProMax: 1234567890xffa
+1669959343565 DM from 05b69cc33267ada004c60677f39bcc3db91f1cfd841c0a3226a2b2bcc062d28959 Vector12ProMax: 1234567890xffa
+*/
+
 async function checkBox(pubKey, ourKeypair, inLasthash, lib, debug) {
  if (!ourKeypair) {
  console.trace('lib::recv - no ourKeypair')
@@ -194,6 +227,7 @@ async function checkBox(pubKey, ourKeypair, inLasthash, lib, debug) {
  return handleMessage(msg, ourKeypair)
  }))
  const ts = Date.now()
+ const msgMap = {} // deduplicate duplicate envelope timestamp
  for(const m of newMsgs) {
  //console.log('m', m)
  //console.log('ts', ts, '-', m.snodeExp)
@@ -205,7 +239,9 @@ async function checkBox(pubKey, ourKeypair, inLasthash, lib, debug) {
  //console.log('UPDATING lastHash to', m.hash)
  useLastHash = m.hash
  }
+ msgMap[m.timestamp] = m
  }
+ newMsgs = Object.values(msgMap)
  }
  //console.log('returning', useLastHash)
  return {