Method startChildProcess

src/childBridgeService.ts:392–505

* Start the child bridge process

()

   * Start the child bridge process
   */
  private startChildProcess(): void {
    this.bridgeStatus = ChildBridgeStatus.PENDING

    this.child = fork(resolve(__dirname, 'childBridgeFork.js'), this.args, this.processEnv)

    this.child.stdout?.on('data', (data) => {
      process.stdout.write(data)
    })

    this.child.stderr?.on('data', (data) => {
      process.stderr.write(data)
    })

    this.child.on('error', (e) => {
      this.bridgeStatus = ChildBridgeStatus.DOWN
      this.log.error('Child bridge process error', e)
    })

    this.child.once('close', (code, signal) => {
      this.handleProcessClose(code, signal)
    })

    // handle incoming ipc messages from the child process
    this.child.on('message', (message: ChildProcessMessageEvent<unknown>) => {
      if (typeof message !== 'object' || !message.id) {
        return
      }

      switch (message.id) {
        case ChildProcessMessageEventType.READY: {
          this.log(`Child bridge starting${this.child?.pid ? ` (pid ${this.child.pid})` : ''}...`)
          this.loadPlugin()
          break
        }
        case ChildProcessMessageEventType.LOADED: {
          const version = (message.data as ChildProcessPluginLoadedEventData).version
          if (this.pluginConfig.length > 1) {
            this.log.success(`Child bridge started successfully with ${this.pluginConfig.length} accessories (plugin v${version}).`)
          } else {
            this.log.success(`Child bridge started successfully (plugin v${version}).`)
          }
          this.startBridge()
          break
        }
        case ChildProcessMessageEventType.ONLINE: {
          this.bridgeStatus = ChildBridgeStatus.OK
          break
        }
        case ChildProcessMessageEventType.PORT_REQUEST: {
          void this.handlePortRequest(message.data as ChildProcessPortRequestEventData)
          break
        }
        case ChildProcessMessageEventType.RELEASE_MATTER_PORT: {
          const data = message.data as { uniqueId?: string } | undefined
          if (data?.uniqueId) {
            this.externalPortService.releaseMatterPort(data.uniqueId)
          }
          break