chore: do not wait for open event

Author: achingbrain

packages/transport-webrtc/src/muxer.ts

@@ -1,5 +1,4 @@
 import { AbstractStreamMuxer } from '@libp2p/utils'
-import { pEvent } from 'p-event'
 import { MUXER_PROTOCOL } from './constants.js'
 import { createStream, WebRTCStream } from './stream.js'
 import type { DataChannelOptions } from './index.js'
@@ -157,16 +156,6 @@ export class DataChannelMuxer extends AbstractStreamMuxer<WebRTCStream> implemen
 
     this.log('open channel %d for protocol %s', channel.id, options?.protocol)
 
-    if (channel.readyState !== 'open') {
-      this.log('channel ready state is "%s" and not "open", waiting for "open" event before creating stream', channel.readyState)
-      await pEvent(channel, 'open', {
-        rejectionEvents: [
-          'close',
-          'error'
-        ]
-      })
-    }
-
     const stream = createStream({
       ...options,
       ...this.dataChannelOptions,

packages/transport-webrtc/src/stream.ts

@@ -107,6 +107,26 @@ export class WebRTCStream extends AbstractStream {
       }
     }
     this.addEventListener('close', cleanUpDatachannelOnClose)
+
+    // chrome can receive message events before the open even is fired - calling
+    // code needs to attach message event listeners before these events occur
+    // but we need to wait before sending any data so this has to be done async
+    if (this.channel.readyState !== 'open') {
+      this.log('channel ready state is "%s" and not "open", waiting for "open" event before sending data', this.channel.readyState)
+      pEvent(this.channel, 'open', {
+        rejectionEvents: [
+          'close',
+          'error'
+        ]
+      })
+        .then(() => {
+          this.log('channel ready state is now "%s", dispatching drain', this.channel.readyState)
+          this.safeDispatchEvent('drain')
+        })
+        .catch(err => {
+          this.abort(err.error ?? err)
+        })
+    }
   }
 
   sendNewStream (): void {