Function wireRuntimeBridgeChannels

packages/devtools-vite/src/runtime-bridge.ts:76–113

(
  server: BridgeServerLike,
  getTarget: () => EventTarget | null | undefined,
)

}

export function wireRuntimeBridgeChannels(
  server: BridgeServerLike,
  getTarget: () => EventTarget | null | undefined,
): () => void {
  const teardowns: Array<() => void> = []

  for (const [name, env] of Object.entries(server.environments)) {
    if (name === 'client') continue
    const hot = env?.hot
    if (
      !hot ||
      typeof hot.on !== 'function' ||
      typeof hot.send !== 'function'
    ) {
      continue
    }

    // Worker -> ServerEventBus (broadcasts to browser + in-process listeners).
    const onToServer = (event: any) => {
      getTarget()?.dispatchEvent(
        new CustomEvent('tanstack-dispatch-event', { detail: event }),
      )
    }
    hot.on('tsd:to-server', onToServer)
    teardowns.push(() => hot.off?.('tsd:to-server', onToServer))

    // ServerEventBus output -> worker listeners.
    const target = getTarget()
    const forward = (e: Event) =>
      hot.send!('tsd:to-client', (e as CustomEvent).detail)
    target?.addEventListener('tanstack-devtools-global', forward)
    teardowns.push(() =>
      target?.removeEventListener('tanstack-devtools-global', forward),
    )
  }

  return () => teardowns.forEach((off) => off())
}