Bug: Stream groups does not get callback when streaming all messages

[alexrisch]

Describe the bug

When having both a streamAllMessages (or similar variant) and streamGroups (or similar variant) the streamGroups does not get a callback

Expected behavior

Expect the test case to pass successfully

Steps to reproduce the bug

Simplified Test case:

  let groupCallbacks = 0
  let messageCallbacks = 0
  const [alix, bo] = await createClients(2)
  await Promise.all([
    bo.conversations.streamGroups(async () => {
      groupCallbacks++
    }),
    bo.conversations.streamAllGroupMessages(async () => {
      messageCallbacks++
    }),
  ])

  const group = await alix.conversations.newGroup([bo.address])
  await group.send('Hello')
  await delayToPropogate(10000)

  assert(
    groupCallbacks === 1,
    `group stream should have received 1 group but received ${groupCallbacks}`
  )
  assert(
    messageCallbacks === 1,
    `message stream should have received 1 message but received ${messageCallbacks}`
  )

Test case uses streamGroups & streamAllGroupMessages, but see the same when mixing streamAll and streamAllMessages

[cameronvoell]

Looks like we got a partial fix with PR here, but still seeing db locking errors when the libxmtp repro still sometimes fails xmtp/libxmtp#855