Skip to content
This repository was archived by the owner on Dec 21, 2021. It is now read-only.

Fix resend gapfills, improve pipeline error handling #200

Merged
merged 30 commits into from
Feb 22, 2021
Merged

Fix resend gapfills, improve pipeline error handling #200

merged 30 commits into from
Feb 22, 2021

Conversation

@timoxley
Copy link
Contributor

@timoxley timoxley commented Feb 16, 2021

  • Fixes and adds tests around gaps in resends.
  • Standardised and added error handling where missing in pipeline.
  • Explicitly ignore specific messages. Does not use orderingutil for ignored messages.
  • Fixes handling for failed gapfills.
  • Uses/requires typescripted streamr-client-protocol 8.0.0 beta-x.

Also:

  • Improves AggregatedError messages to include original message + custom message.
  • Excluded gapfilling tests from "no resend" tests.
  • Improve test log readability by making test messages like: { value: "11 of 20" }

@timoxley timoxley requested review from harbu and teogeb February 16, 2021 21:21
@linear
Copy link

linear bot commented Feb 16, 2021

NET-181 Client doesn't try to recover from a gap during resend 

DEBUG=* ./bin/streamr.js resend range "2021-01-29" "2021-01-30" szZk2t2JTZylrRwN6CYJNg --ws-url wss://corea1.streamr.network:7001/api/v1/ws

This range happens to include an (unfillable) gap, which leads to the following behavior:

  • 3 first messages are reported to the message handler and printed on console
  • In the data, there's a gap after the 3 first messages
  • The rest of the messages are received from websocket but never reported
  • The client doesn't appear to make any attempt to fill the gap
DEBUG=* ./bin/streamr.js resend range "2021-01-29" "2021-01-30" szZk2t2JTZylrRwN6CYJNg --ws-url wss://corea1.streamr.network:7001/api/v1/ws
  StreamrClient:8185.0 new StreamrClient StreamrClient:8185.0: { version: '5.0.0-beta.5', GIT_VERSION: 'v5.0.0-beta.5', GIT_COMMITHASH: 'b589499bc230622aa8e3bb2951875ad3b849bb6a', GIT_BRANCH: '5.x' } +0ms
  StreamrClient:8185.0:StreamrConnection.0 emit connecting +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 emit connected undefined +0ms
  StreamrClient:8185.0 Connected! +94ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 (connected) send() +2ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 (connected) >> ResendRangeRequest { version: 2, type: 13, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, fromMsgRef: MessageRef { timestamp: 1611878400000, sequenceNumber: 0 }, toMsgRef: MessageRef { timestamp: 1611964800000, sequenceNumber: 0 }, publisherId: undefined, msgChainId: undefined, sessionToken: undefined } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << ResendResponseResending { version: 2, type: 4, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0 } +42ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611893042125, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611891266005, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xf155db6ae9a455f86031618da471b035508092390422fd1463f475864cff152e221005114f1b053fc87f872724dcfc6971a4e9690f3496059b1a854e9b84b5901b', serializedContent: '{"type":"join","addresses":["0x08aa22670F3f5e08DCB56e876A0cD1CCcc8E0989"]}' } } +2ms
  StreamrClient:8185.0 getStream { streamId: 'szZk2t2JTZylrRwN6CYJNg' } +48ms
  StreamrClient:utils:authfetch 1 https://streamr.network/api/v1/streams/szZk2t2JTZylrRwN6CYJNg >> undefined +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611894849149, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611893042125, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x1e0c9eb08af9a1b1caa5d70b9e69dfcaa50ca6fe9f25040191149a4c176d56500ce7ea90d67173718462e2c00674e7eeec2f7b75d2f58b4aede4d59b5b51bdcc1c', serializedContent: '{"type":"join","addresses":["0xAB298D9B70bdC207C60597a02aD7FFf4bfca4E0c"]}' } } +7ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611895755063, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611894849149, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x14792fc8716e18d3ee893ad2b804cadc1a641f3d36c0a3f2f3c99fe132e5daa4736a34b95c6cd118ce54af3b59061d6e9f338bfc48f436450c4648773cef85a41b', serializedContent: '{"type":"join","addresses":["0xbA27d7dc9b3Fb0371CEFf31A18B7743C833f9937"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611899022112, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611898513305, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xb0e852fd55473d4c7db3f21e27fef469c31e515b7af84480a54287e45a272c280aaf9f95798153525c38ff923ba313ac9ec55219fbb6f46052dd239f458eeee01b', serializedContent: '{"type":"join","addresses":["0x911c683C96E971ff801328D55F0faEA9d304A3DE"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611900456254, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611899022112, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x79cbd61b377f656de12d462cdeddb7b53f50bfe154b44e70fb593fdbe6a07061500a6cab04d68f2ae63b90aea700aab14fc66c7ab62941fb755fc87ee7c5f95a1b', serializedContent: '{"type":"join","addresses":["0x17af2F8Ad3E3fAdD24966a60f831590E723Ff10a"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611900599980, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611900456254, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x768c70aab1e2782d1abbd06d117d17ef4820fe8c52db6db62e409ecebcd205c8544fb92a7c1e9abab7fbb2a6e309156d886c1b35e471e917bc4e571b9ef025771c', serializedContent: '{"type":"join","addresses":["0xeB21A50F7E7EB826a48a63536660361CA3CB48Cb"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611900621961, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611900599980, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xe23c47c15cd7aad97684e3aa75dba7898374a346b565c127ba63796331810bf6570dd465633360dced87ee42f1077763455093dafea58a33cbb066a2809c2fe81b', serializedContent: '{"type":"join","addresses":["0xeB21A50F7E7EB826a48a63536660361CA3CB48Cb"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611900713909, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611900621961, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xe83a1b82753151f8442df5e4daefd856e64cff13c38f14d168bed92f0c167fde192c4167b298f4a2354a4dbec4ebc20b784708c5f9a5065a16e55efd394872a81c', serializedContent: '{"type":"join","addresses":["0x3CB085e16A156294a511A53070c99616eE9297C7"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611901249443, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611900713909, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xdf736b535a948d1a5bc764865d3f1e0d99cc4d5dfd6698a34f85ebd04f0fc68439438e48d6240fc7a78e367224fcd540cef1c919860ddfaa6c8e59a852a91b201c', serializedContent: '{"type":"join","addresses":["0x6147514bc7845e4F3c36c9bC629079698df9280A"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611911647679, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611910543538, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xc241d987a7c40e80947cd6bf54a6ae7316e2e7d01a155fcef5dec8ddbfa7d44a673aa6763a27abcbcfa562e6741d79832933545bee7acf19bcfabd1d5c970cb01b', serializedContent: '{"type":"join","addresses":["0x1199540f355c6772abF35706bbA88F0bE8136Fed"]}' } } +2ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611912668754, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611911775341, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xf08b10f8404ad6476001d04025782b8d3ee10a759875f68b8100c9e59a0871f4231853d01e5787279e0ce2932ce2610cb26677537019a8c545971b6853d263a71c', serializedContent: '{"type":"join","addresses":["0xCdaa0e38d3cBa51200D1659d380cfaac77001373"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611913515573, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611913276658, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x514b80acfbe18b58020480e70530b8355b904fb79b8e4ed1e9e32373dfd36d325be2f9b8091ebb1b2b22b3005421c2e854d01b06e0878a6fc91dbb517ddb8a751b', serializedContent: '{"type":"join","addresses":["0xE4E6f3038c7d7b12BF5E285e7534Bc6D64aD1AB4"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611913565497, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611913515573, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x9de5080a0b6be6d142906f100f14eed6fa1c5b57d519bc12f5e972e0bc009fc87d5a292ef19f182e4b93ccb173e94858c619aa7fbf83759cb648a537b2a59b711b', serializedContent: '{"type":"join","addresses":["0xCdaa0e38d3cBa51200D1659d380cfaac77001373"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611917706771, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611915602615, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xfa41a5a81b772e7e7906e48f4101124cca91db61c438c61aadc3986b2507c5c2199355424c42487d2aa0801d3021a3ff1716a61a3d1da3a41552d783a82466de1c', serializedContent: '{"type":"join","addresses":["0x629952a80A3542CDe382777762441b9E9f26F0AB"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611918168036, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611917803947, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x5359b29ced1fe3f7845a96332a84ac75dfee8daa25deb7ec6bdd00ad4822df55669787f836f68cf0926b727ed2444631867e17237eba9af8094529953e5d76361c', serializedContent: '{"type":"join","addresses":["0x3F4c14282F981E3D74568b9Abe959f27E2f60e31"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611918505727, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611918168036, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x0b3324ed48e3b1fb78d2b34c8d164fd0abdbb2b7111ac30c7a89d50d9fd680cf7e9243cf4ea03e722a7b613a5894b0af7528540b489fbf458fc503bec9c4110d1b', serializedContent: '{"type":"join","addresses":["0xff36635B8334f7488551C71D936673EbfBFE0Dee"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611918787255, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611918778446, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xa125110502d45c5abc97a54e3ee02de0eb31b23d69664194b25900fd352f98865576618a71c10bb11abfc329ed971ed97a21ce36943a8e6e41fec6dc518a23df1c', serializedContent: '{"type":"join","addresses":["0x0536eF4a5073BDf4980DaC607c35FAC2e1ebBC15"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611918966562, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611918835756, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x79d2e0201f91ceb6ef5d8d2b10e8e9d5d652fa76105ec9cdb815835b82ca1a59291324594573869c8df6596c196bc0cfb7b8ad5686db38fc7b70d05d4a61bb761c', serializedContent: '{"type":"join","addresses":["0xaC05491Eb556beB174bAB9344de7949bB817F238"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611919283980, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611918966562, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x953d7b9aedf3fb111be7b5ad71c8c33892a50acc198c62fb29058be8adb4bcff25e3c2806ddffae9bbc8684542f3aac675574e567c076d4c2352c22a3eb372041c', serializedContent: '{"type":"join","addresses":["0x017b9Abab15EFdafbf89858EC1A3B8fA8Be2Ec29"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611919430674, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611919283980, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x4c5327d33e5c78af50bfe37578aadef7c908dd912115daadf1529c5390ce26db3f4e6da78197b9ebdeda27cce3d2c3ee09142e1c71a0b76a549aac0ba366daac1b', serializedContent: '{"type":"join","addresses":["0x96B9B2929F8Febd2413CF9c9416F758a44FF4707"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611919781286, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611919601723, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xb5172d24e18b7b2c62d651e6fa45713f2a9aacfe1cbc2794d452bd9fc0967d31030fc92dbdc0b7051b902bb6ca31b369ede26ad5da67fbc1378f3a3882df58041c', serializedContent: '{"type":"join","addresses":["0x2467955C787295C31d7f7ce1455fa749Ee601b1F"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611919993996, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611919781286, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xe3092f50ec02f22d999d812abc067609c20893ffb9b0211ae0e20e6e6fe8a3114b3bc7d7eccfbca186a6741ed720157b41068da32b373802e72b2642d5cbf1211c', serializedContent: '{"type":"join","addresses":["0x58221944E5b824beb531717AC0a3e5525AE171Bd"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611920173531, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611920001416, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xbea49f38fd14842ee9cc1ad1cd47cf4a11ffcacb3f12137ea96e6bab58089d54157e811447be08cbd112971083bb63e2feabc19b4f11684b4a9bc6e9dbeaecab1c', serializedContent: '{"type":"join","addresses":["0x6E9d07528A6790B422A25597E0E9D0af9A2Df8f1"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611920176340, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611920173531, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xd3823ebe06826cd9a925571e252e2ff4b9cd7a2e3ecee63429fe67e27a38c2f772dec893bc137ba9c8c9c22ef583515d9622a6fc3eb0ba8d6a8040323a393d9c1b', serializedContent: '{"type":"join","addresses":["0x7DEE74a646BCa2C1BD252eb9f2eF0443f6F0B99d"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611920183408, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611920176340, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x4750e6de3e7694d2e8c4eebbfc750e344152bc28f636e640aced3de37c20d00410f496f76654beb8553299692f7a39d3eb0c9712c34c1e0e764b8e6c309c329f1b', serializedContent: '{"type":"join","addresses":["0x95e307F94C48262529037A1CDee5bFaD9bc292A3"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611920243628, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611920183408, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x44eceab8bbb65f2a7d83a75ed872a7b19f198fc1d2ec87a643f2ade2a612a35e27e57446e5cb93a6365994c28582e09245f89ea59c859edce3e740be03d4f53a1b', serializedContent: '{"type":"join","addresses":["0xE5391022f2Cf599237948999fdb4D00244A93b8A"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611920360953, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611920310874, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x71ae29537d38b4779ba31688d9d655c99d880bf0de7261a8f6d09da1a66958df179af5bdb1992d1551f47eba6c9cf2fa74274d38ea2919064ed47f05e18583231c', serializedContent: '{"type":"join","addresses":["0x01e0277CDcbca988a78813f0c9eF184EA2eCFf0F"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611920476548, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611920360953, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xbe776f61a75ee8b82bd39f827a6c8cf4f841bb9f719e1efd7ff41d359e2fa9f93ab9947c38dd1ed0e7fd492e1767bcc126f59149c1223514272cca9143f372371b', serializedContent: '{"type":"join","addresses":["0x15dc3924C513FF692b60C239CDe270211741A3Bf"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611920643107, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611920476548, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x0e7f020d27f8dbbf70e5d1181394ca2b7cc6052f613c6154421aee928708104d79fe61f1373c28eada33ee3ab2cdf5088c87d8a4be09c55b9eb46af495daacee1b', serializedContent: '{"type":"join","addresses":["0xa51213595c7De763a7F99077340E138FF7a7B7db"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611921068739, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611920982421, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x5a5e54a5677f68c7dfa49f30962142148e82cfe9aa94b05c8e4868a01c760be84f2a49a5ea1ba42cb047d0df6e15e1260aa1379726d506a19355b81e03f006241c', serializedContent: '{"type":"join","addresses":["0xA9d5b4bf4231b14F71Cbd9a07fAf40e08c2e30a7"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611921343083, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611921147748, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x865418aa404631e4227fe80f65756e55305a89777d90d87bde4267829721761b0ae05e380daea5e17cfca62d9792c1351fe89e29ab3ef3de421d9415d0099c981c', serializedContent: '{"type":"join","addresses":["0x6749DcFF53470F0E8FFd23ad65C458C8254aEB30"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611921506667, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611921343083, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xff49d2e6aa2db63cb24186049a8c76091135f86854fb68334a630459d7dc980b1a310612a894104975d2cafd127225a93f027f437369d71e4341b591054c6ab91b', serializedContent: '{"type":"join","addresses":["0xadB504477d0fFC570bB795429cd4685906376baA"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611921782471, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611921662623, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x1557bd01709afa221649e80f515edd081ba640e8057b1135a1d41061b878edd05c3ff2cbca192d7be34d8bd95815fb41e2eb4d0b48f10de873fb7c0251f21b281c', serializedContent: '{"type":"join","addresses":["0x81b434C37593F7f66D73BFd06D01267e85A96A20"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611921799777, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611921782471, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x1a35c883084d2855bdb60c1e8bdd3846b379b89c9fe371b5c61e49034d3972cb31efeeca89748152be49695f769e1a963af670d16b7c7e6a7d9d4bcc92e63c2a1c', serializedContent: '{"type":"join","addresses":["0xE2848eF32554b9aD34Eabb09bC95F862caF14853"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611921907596, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611921799777, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xf2464b785d50751a55b48f02d485fab596f92b61c6b13c5eda2e1b3aa0fe66362b29ecd001dfe0f953cabf139a11e3448b34a34bdcb73af41dcc5ac9386001761b', serializedContent: '{"type":"join","addresses":["0xD7632e6a26ce6dd88135D392bBE1d4ef49904D2e"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611922023985, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611921907596, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x7fa2072575b00df50b2877efd93f960cb9df313537c2b19579517ec4dffbf8cc72a16ee879fd9fe87d1f5f590ab1c561468b1aa5adcf4d1c89dd9ea298ca5a101b', serializedContent: '{"type":"join","addresses":["0x21a6B93A16574552de2fc929575Cb2F1b5343791"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611922166825, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611922023985, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xbf4f2d4ab61e517c1177178fadd57511400c4821494eaf6588444e580b20e75863d104f17c7cd16168940148c27c0fdb1e0d7943dd948f9d42c652c1815677421c', serializedContent: '{"type":"join","addresses":["0x8C90cBd3C79F8bc4D794C55A9011a1A149547bAA"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611923636920, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611922166825, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xcebbbfda3919d0429c7378b2c055eda3e7992eccf856b40b0dbf4ff890be227a0cf92d4a07a3d06945388d2af80483932755482dd945152cd9d98f2a0a2e12421c', serializedContent: '{"type":"join","addresses":["0x4E387753fa8d8129D17D65e932307E2860a96131"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611923962460, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611923636920, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xfa6450a90ff0814540c96c601b0e07127996815babfd383d087fa46b147834af6c86eaea60333a6dd9d019f541a7581f55f4e44b4428bcf0f6a7bc2d218e26fb1c', serializedContent: '{"type":"join","addresses":["0xa81388635E1478aacf89943483a80975053Fa76c"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611923979499, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611923962460, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x3e32f37d20b63380bd81c39ef6b7632e04e112c7da6cc470c0e9c80c38bcfff3443c9370ad49020b56c648d1755d2265ea4f2b499a230d7c22dc6827d5b883ec1b', serializedContent: '{"type":"join","addresses":["0x2b4285F7e83F5302cF024195C337Dfb7e4f38A74"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611923999261, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611923979499, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x4e115a2e042739da61733dd648c50f9096c021f9c047bbb0fea799fd8be48d8d0f364c3485b0736650a057ac629f4124cb67d0cdd2378886d6f5b730a554775d1c', serializedContent: '{"type":"join","addresses":["0x2b4285F7e83F5302cF024195C337Dfb7e4f38A74"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611924176113, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611924079786, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x036d53b90fd30aa406fdcf2f3ac7b73d00dac7c57a2dfe7de9309fcc3e4d53ad4a37de53512cfbe5eba6280be7e1e4918f0b4ee4dd4ef3c045d2bc5d23aff2291c', serializedContent: '{"type":"join","addresses":["0xc884595eB5c3616D0BEa56bB93E49643FBCE8742"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611924347947, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611924176113, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xbe6d1dee5e60b971a2b83390df907c5bf98a41090b1befbecda2898f8e8f639179b8ca3871bdf7c52f996baa285eb1c2c59d69e559afde843e8474f15d21c8fa1b', serializedContent: '{"type":"join","addresses":["0x75cc7a8A00a264c25AB999dEb7dA9755EF69D253"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611926506065, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611925945477, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x95a4989706f7a26a075bce7a498cebfae1ca34a9efed2d37ecb91485cbc8614d16e0d6418d738e84ec6494bc84288a465f944039419e526a05651e319647c9171c', serializedContent: '{"type":"join","addresses":["0x2b4285F7e83F5302cF024195C337Dfb7e4f38A74"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611926525721, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611926506065, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x50f6b91b99366553f1cac5667f7cdb509974f8b582a6f1896d5617829baa468921a73604c47f110a9b906c6d32b368706be3c02fe1d06a0235886d8dfc54c9991c', serializedContent: '{"type":"join","addresses":["0x2b4285F7e83F5302cF024195C337Dfb7e4f38A74"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611926615682, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611926525721, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x9249847d0dc26ce40203d4a262679f97e3b108b3816a210e1ddda13c93fe37cd0d0f67d39620de203cd804f02b6c92c0309f831fff5d9b086416e3569f7bc5ea1b', serializedContent: '{"type":"join","addresses":["0x4F3620c2F85390389D2662D49cfE5b9ceca20a4f"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611927093547, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611926615682, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x4ca98722872be7d3bdf1e0a117e23a3f9b5c367e7a59b867d78e76c1f9ac159a3c118f3e64345ac934751912070d4eab02fbcf47d5bb3961289faf1fe7e64ab41b', serializedContent: '{"type":"join","addresses":["0xE02a5c85E4356E10dB3916F6fBb9323F66811CF5"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611927800078, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611927093547, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x862ee6406e2a904fc522e7a037d2065cebab3e9e2103cfeb3cce3d8c17f994d15dc74ddd78ecd61f53686d41e042eebe5e8468da9e2caf9f2365bff46b20f0c31c', serializedContent: '{"type":"join","addresses":["0xe9b61730D654Da13B0C8Fe853f861A262B310817"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611928331347, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611927800078, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xb7944ed51f5afe88b6faa408ca5a52f575d85c1e2b0df994499e1d17057f9c7325dbe051292abee9122eeb794e13e248582eba06b1fb818fd912fbc103fcee391c', serializedContent: '{"type":"join","addresses":["0x0f765694eD52200Bb525Ee2beEA94A568e5D7f6a"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611929738089, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611928331347, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x8212b98225b7e27ad3946bf084476fb63070e9e42cab18028648cff951d1cd2a2b13f4629fd0b7ae0251606fce60aa2103257bef63223d29772f1339ec86a4f81c', serializedContent: '{"type":"join","addresses":["0x2ee62aD051D2fE9f0DaDcD4c9EFD54EB7c305EeF"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611929907737, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611929738089, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x52c6023a18112b2a4ba7004e3df576db341e3ccdf73b1d12e3294af312e21abb31afb57a0dff9e535b848674e61a56414b90b181005cebd5e62cb4ce6d7635331c', serializedContent: '{"type":"join","addresses":["0x73b5eb0808600CCfaeb9415752588656a6F59F19"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611930138754, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611929907737, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x933a3f1994b2e3cdf318918d13396408a6c46bfabc762d02661c293725b6bad725af87f1fd7cf28088599f41788f23e9bcc867d8a35d4cc4836423caebd0515a1b', serializedContent: '{"type":"join","addresses":["0x96B4f852e00beeE65144dE77DCA4D01313EB7ef0"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611930849166, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611930138754, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xbf9fc1933fec23da766b1c6b5eaabd1475a168c01f44f34291b0e83156cbc9a27787d0767c090d22a428d4731b73e94a8d8264c7b973a5cb4feb3020724b283c1c', serializedContent: '{"type":"join","addresses":["0xC91985eb8DA6c51F9AB072E9a28B25Db983D3Fc2"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611932459123, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611930849166, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x9d2d558ebcbf9315b18c0440ba2b66d0f33817069c7d7c9c19648a709c7dea895a5389e4e734555834af8da9904a9f2e140b88309d7c644532157ce512be847c1c', serializedContent: '{"type":"join","addresses":["0xfC4522fB1747d3fC576bdf2864AdBEc0BddF44BC"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611933584126, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611932459123, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xb4c1c87a55be659f293c95017f4db8913e61e2e5283f6f463c994bff9f0eac316a45732a74f34cea42e2bdb6ccc648b43169128eca0ab95481eda6f7e094c1d21b', serializedContent: '{"type":"join","addresses":["0x064e3df935528A2A340373c587ca1404fA6bD45C"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611939128560, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611935111906, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x6af4aee16e6ea2233a4addd168e85b65eeb12045a62217a648fdbf1715ffe1d962849edef8fe858c3bd99165c08abdc874961556fb8858cccb0b5b70418c66d51c', serializedContent: '{"type":"join","addresses":["0xC2dBE9411db00Fd0C2611161B3ff0B464cF9e9e1"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611939653347, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611939376590, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xa146d4fc3e0e6a8c28345b537b7d4cd559b7ff2c5eecd0fbc7c0bfb5ccd4e4ac5e529e4815f81e0ae8a3dba1fdfb83dd80e7ae719714b9f4ba7754e0c2fdbff51b', serializedContent: '{"type":"join","addresses":["0x356d08453fA42b7cb77DA430c42Bdebb60afA49f"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611940362550, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611939670380, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xc6d14ad784d0a248f94fbec61f2cab0a64f89f2d6c00a6ac698115f8d41fad144d6e01fef8d25fcfd482458a721bf231dfdaedaf80b67bed74006ae93f3b1db21b', serializedContent: '{"type":"join","addresses":["0x787765c80c65E54B73e65768D1aE98cf2b99f0Ba"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611941018781, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611940362550, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xcdbb1eb95223235a1ef21526ae720b6ce6a891f4d6e5967c8a2281d598bfca7c3d7ed0a70036ff303514b7a9b3e92786deafb73814826cea81a344a7ba0ee0c51b', serializedContent: '{"type":"join","addresses":["0x09c6A1123DA96dE0CFaEd7a651a7f06a9744C376"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611941113037, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611941018781, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0xa9f5612a2243ba688aeeabe1dbe7d5402895482e0beac48d678c36da0d17d6fb2d6e8665235258613d900acc92d28630d5d3d856429bb6d62574e14a034ecdc41b', serializedContent: '{"type":"join","addresses":["0x9dF46f8F4ce8f7Ff778b6c4e55Fe50797D751f79"]}' } } +83ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611941278299, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611941113037, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x7830db76217ae532d05edff6d17bdd5560f95db7d7a0e60ba54e44af6530da567e8a91273f3ccc21984668ab4cde35c1adcef7e3a7c669365c04f21b8220c3c41c', serializedContent: '{"type":"join","addresses":["0x9dbC7aAB008D9C1bD4822088d361D908B3cc5950"]}' } } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611941475796, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611941278299, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x7b1b472e94874fe6b1dec449bf65eda0db66fd2071679099932e1aa596dba8a779d25b3b24028bbb047c8b250047452130612f2c543874a3c84f31fb6adabf171b', serializedContent: '{"type":"join","addresses":["0x89D42DB8720A9F53C47F392535bd19774C610380"]}' } } +2ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << UnicastMessage { version: 2, type: 1, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamMessage: StreamMessage { messageId: MessageIDStrict { streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0, timestamp: 1611942610059, sequenceNumber: 0, publisherId: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266', msgChainId: 'SglTq9k0buDhp2CaDkiz' }, prevMsgRef: MessageRef { timestamp: 1611941475796, sequenceNumber: 0 }, messageType: 27, contentType: 0, encryptionType: 0, groupKeyId: null, newGroupKey: null, signatureType: 2, signature: '0x266045f13e3429e62c60da6d16203442e0c8fd40e28034d1b6c8332b0d969a9564731ced041aa25c45acf5b514c3acdf1ab9761a23995a50c6ff82eacf31a5ad1c', serializedContent: '{"type":"join","addresses":["0xdeD1cefa90f3651a8A198468f614afA3958651f5"]}' } } +1ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 ('connected') << ResendResponseResent { version: 2, type: 5, requestId: 'szZk2t2JTZylrRwN6CYJNg::0-resend.0', streamId: 'szZk2t2JTZylrRwN6CYJNg', streamPartition: 0 } +0ms
  StreamrClient:8185.0:StreamrConnection.0:ws.0 emit disconnecting +1ms
  StreamrClient:utils:authfetch 1 https://streamr.network/api/v1/streams/szZk2t2JTZylrRwN6CYJNg << 200 OK 182ms +182ms
  StreamrClient:8185.0 isStreamPublisher { streamId: 'szZk2t2JTZylrRwN6CYJNg', ethAddress: '0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266' } +190ms
  StreamrClient:utils:authfetch 2 https://streamr.network/api/v1/streams/szZk2t2JTZylrRwN6CYJNg/publisher/0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266 >> undefined +8ms
  StreamrClient:8185.0:StreamrConnection.0 emit disconnected +522ms
  StreamrClient:8185.0 Disconnected. +203ms
  StreamrClient:8185.0:StreamrConnection.0 emit done undefined +0ms
  StreamrClient:utils:authfetch 2 https://streamr.network/api/v1/streams/szZk2t2JTZylrRwN6CYJNg/publisher/0x8d4597fB06aDc1AaA2285777B0b2A7f279Cfc266 << 200 OK 205ms +205ms
{"type":"join","addresses":["0x08aa22670F3f5e08DCB56e876A0cD1CCcc8E0989"]}
{"type":"join","addresses":["0xAB298D9B70bdC207C60597a02aD7FFf4bfca4E0c"]}
{"type":"join","addresses":["0xbA27d7dc9b3Fb0371CEFf31A18B7743C833f9937"]}

@timoxley timoxley force-pushed the NET-181-resend-gapfill branch from cfec0af to 405b6a2 Compare February 17, 2021 15:07
teogeb
teogeb reviewed Feb 18, 2021
View reviewed changes
teogeb
teogeb reviewed Feb 18, 2021
View reviewed changes
teogeb
teogeb reviewed Feb 18, 2021
View reviewed changes
@timoxley
Add end parameter to PushQueue.from & pipeline. Prevents premature cl…
537062d 
…osing of pipeline.
@timoxley
Add tests for PushQueue.from end parameter. PushQueue.from should buf…
1d95da2 
…fer sync iterable immediately.
@timoxley
Add autoEnd option to PushQueue.
e5857ff
@timoxley
Use streamr-client-protocol@8.0.0-beta.1
468eb55
@timoxley
Fix decryption transform.
08f9280
@timoxley
Add resend gapfill test. WIP.
9f13e02
@timoxley
Add runtime-corejs3 to dependencies, update babel runtime deps.
d334d58
@timoxley
Fix jest module resolution with npm linked deps.
942f7c4
@timoxley
Default onFinally is async for type hinting.
5be869d
@timoxley
Fix broken OrderMessages output.
2898004
@timoxley
Convert jest.setup to ESM.
7d1a91f
@timoxley
Refresh package-lock.
1147ee5
@timoxley
Fix issues with gaps in resends. Test gap failure mode.
3ac9c57 
Only ~Close OrderMessages stream once messages sent & all gaps filled or failed.
@timoxley
Ignore failed messages explicitly rather than treat them as unfillabl…
2ec2963 
…e gaps in ordering util.
@timoxley
Fix handling for failed gapfills.
02c4d03
@timoxley
Add onError option to Scaffold.
45d6174
@timoxley
Give each test message a count out of total so it's clear what it is.
3e04753
@timoxley
Exclude gap related tests from 'npm run test-integration-no-resend'
d177205
@timoxley
Concatenate error messages with passed-in message in AggregatedError.
a6f1055
@timoxley
Tune collecting of subscription errors.
9b2cf39
@timoxley
Ignore connection errors if should be disconnected during subscriptio…
f523e57 
…n scaffold.
@timoxley
Add another variant of flakey disconnect/reconnect subscribe test.
5354b9e
@timoxley
Make test/utils getPublishTestMessages timestamp option into optional…
46c3a35 
… function.
@timoxley timoxley force-pushed the NET-181-resend-gapfill branch from 6e83a42 to f3f986a Compare February 18, 2021 16:33
@teogeb teogeb self-requested a review February 19, 2021 10:29
@timoxley timoxley merged commit b94bdcd into 5.x Feb 22, 2021
@timoxley timoxley deleted the NET-181-resend-gapfill branch February 22, 2021 13:22
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Reviewers

@harbu harbu Awaiting requested review from harbu

1 more reviewer

@teogeb teogeb teogeb approved these changes

Reviewers whose approvals may not affect merge requirements

Assignees

No one assigned

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

3 participants

@timoxley @teogeb