feat(wip): forward life-cycle events over http

src/node/SetupServerApi.ts

@@ -123,7 +123,7 @@ export class SetupServerApi
       const remoteConnectionPromise = remoteClient.connect().then(
         () => {
           // Forward the life-cycle events from this process to the remote.
-          // this.forwardLifeCycleEventsToRemote()
+          this.forwardLifeCycleEventsToRemote()
 
           this.handlersController.currentHandlers = new Proxy(
             this.handlersController.currentHandlers,
@@ -184,10 +184,10 @@ export class SetupServerApi
     for (const event of events) {
       this.emitter.on(event, (args) => {
         if (!shouldBypassRequest(args.request)) {
-          // remoteClient.handleLifeCycleEvent({
-          //   type: event,
-          //   args,
-          // })
+          remoteClient.handleLifeCycleEvent({
+            type: event,
+            args,
+          })
         }
       })
     }

src/node/setupRemoteServer.ts

@@ -474,56 +474,66 @@ export class RemoteClient {
     return responsePromise
   }
 
-  // public async handleLifeCycleEvent<
-  //   EventType extends keyof LifeCycleEventsMap,
-  // >(event: {
-  //   type: EventType
-  //   args: LifeCycleEventsMap[EventType][0]
-  // }): Promise<void> {
-  //   const url = new URL('/life-cycle-events', this.url)
-  //   const payload: Record<string, unknown> = {
-  //     event: event.type,
-  //     requestId: event.args.requestId,
-  //     request: {
-  //       url: event.args.request.url,
-  //       method: event.args.request.method,
-  //       headers: Array.from(event.args.request.headers),
-  //       body: await event.args.request.arrayBuffer(),
-  //     },
-  //   }
-
-  //   switch (event.type) {
-  //     case 'unhandledException': {
-  //       payload.error = event.args.error
-  //       break
-  //     }
-
-  //     case 'response:bypass':
-  //     case 'response:mocked': {
-  //       payload.response = {
-  //         status: event.args.response.status,
-  //         statustext: event.args.response.statusText,
-  //         headers: Array.from(event.args.response.headers),
-  //         body: await event.args.response.arrayBuffer(),
-  //       }
-  //       break
-  //     }
-  //   }
-
-  //   const response = await fetch(url, {
-  //     method: 'POST',
-  //     headers: {
-  //       'content-type': 'application/json',
-  //     },
-  //     body: JSON.stringify(payload),
-  //   })
-
-  //   invariant(
-  //     response && response.ok,
-  //     'Failed to forward a life-cycle event "%s" (%s %s) to the remote',
-  //     event.type,
-  //     event.args.request.method,
-  //     event.args.request.url,
-  //   )
-  // }
+  public async handleLifeCycleEvent<
+    EventType extends keyof LifeCycleEventsMap,
+  >(event: {
+    type: EventType
+    args: LifeCycleEventsMap[EventType][0]
+  }): Promise<void> {
+    invariant(
+      this.connected,
+      'Failed to forward life-cycle events for "%s %s": remote client not connected',
+      event.args.request.method,
+      event.args.request.url,
+    )
+
+    const url = new URL('/life-cycle-events', this.url)
+    const payload: Record<string, unknown> = {
+      event: event.type,
+      requestId: event.args.requestId,
+      request: {
+        url: event.args.request.url,
+        method: event.args.request.method,
+        headers: Array.from(event.args.request.headers),
+        body: await event.args.request.arrayBuffer(),
+      },
+    }
+
+    switch (event.type) {
+      case 'unhandledException': {
+        payload.error = event.args.error
+        break
+      }
+
+      case 'response:bypass':
+      case 'response:mocked': {
+        payload.response = {
+          status: event.args.response.status,
+          statustext: event.args.response.statusText,
+          headers: Array.from(event.args.response.headers),
+          body: await event.args.response.arrayBuffer(),
+        }
+        break
+      }
+    }
+
+    /**
+     * @todo @fixme Design the protocol for forwarding life-cycle events.
+     */
+    const response = await fetch(url, {
+      method: 'POST',
+      headers: {
+        'content-type': 'application/json',
+      },
+      body: JSON.stringify(payload),
+    })
+
+    invariant(
+      response && response.ok,
+      'Failed to forward a life-cycle event "%s" (%s %s) to the remote',
+      event.type,
+      event.args.request.method,
+      event.args.request.url,
+    )
+  }
 }