Method runCommand

packages/migrate/src/SchemaEngineCLI.ts:513–584

(request: RPCPayload)

  }

  private async runCommand(request: RPCPayload): Promise<any> {
    if (process.env.FORCE_PANIC_SCHEMA_ENGINE && request.method !== 'getDatabaseVersion') {
      request = this.getRPCPayload('debugPanic', undefined)
    }

    await this.init()

    if (this.child?.killed) {
      throw new Error(`Can't execute ${JSON.stringify(request)} because Schema engine already exited.`)
    }

    return new Promise((resolve, reject) => {
      this.registerCallback(request.id, (response, err) => {
        if (err) {
          return reject(err)
        }

        // can be null, for reset RPC for example
        if (response.result !== undefined) {
          resolve(response.result)
        } else {
          if (response.error) {
            debugRpc(response)
            if (response.error.data?.is_panic) {
              // TODO(jkomyno): I suspect no panic is ever thrown here

              const message = response.error.data?.error?.message ?? response.error.message

              // explicitly mark the error as a "response error panic" to distinguish it from the other one.
              // This will allow us to track the frequency of this particular panic in the error reporting system.
              const stackTrace = `[RESPONSE_ERROR_PANIC]\n${response.error.data?.message ?? ''}`

              reject(
                // Handle error and displays the interactive dialog to send panic error
                new RustPanic(message, stackTrace, this.lastRequest, ErrorArea.LIFT_CLI),
              )
            } else if (response.error.data?.message) {
              // Print known error code & message from engine
              // See known errors at https://github.com/prisma/specs/tree/master/errors#prisma-sdk
              let message = `${red(relativizePathInPSLError(response.error.data.message))}\n`
              if (response.error.data?.error_code) {
                message = red(`${response.error.data.error_code}\n\n`) + message
                reject(new EngineError(message, response.error.data.error_code))
              } else {
                reject(new Error(message))
              }
            } else {
              reject(
                new Error(
                  `${red('Error in RPC')}\n Request: ${JSON.stringify(request, null, 2)}\nResponse: ${JSON.stringify(
                    response,
                    null,
                    2,
                  )}\n${response.error.message}\n`,
                ),
              )
            }
          } else {