Method runCommand

packages/migrate/src/SchemaEngineWasm.ts:82–124

(
    command: M,
    input: SchemaEngineInput<M>,
  )

  }

  private async runCommand<M extends keyof SchemaEngineMethods>(
    command: M,
    input: SchemaEngineInput<M>,
  ): Promise<Awaited<SchemaEngineOutput<M>>> {
    if (process.env.FORCE_PANIC_SCHEMA_ENGINE && command !== 'debugPanic') return this.debugPanic()

    this.isRunning = true

    debugStdout('[%s] input: %o', command, input)

    try {
      // Don't modify this by extracting the method call into a variable,
      // as it breaks the binding to the WebAssembly instance, and triggers the
      // `TypeError: Cannot read properties of undefined (reading '__wbg_ptr')`
      // error.
      const result = await (this.engine[command] as (_: SchemaEngineInput<M>) => SchemaEngineOutput<M>)(input)
      debugStdout('[%s] result: %o', command, result)
      return result
    } catch (error) {
      const e = error as Error
      debugStdout('[%s] error: %o', command, e)

      if (isWasmPanic(e)) {
        debugStdout('[schema-engine] it is a Wasm panic')
        const { message, stack } = getWasmError(e)
        // Handle error and displays the interactive dialog to send panic error
        throw new RustPanic(serializePanic(message), stack, command, ErrorArea.LIFT_CLI)
      } else if ('code' in error) {
        throw new EngineError(red(`${error.code}\n\n${relativizePathInPSLError(error.message)}\n`), error.code)
      } else {
        assertAlways(
          e.name === 'SchemaConnectorError',
          'Malformed error received from the engine, expected SchemaConnectorError',
        )

        debugStderr('e.message', e.message)
        debugStderr('e.cause', e.cause)
        debugStderr('e.stack', e.stack)

        throw e
      }
    }
  }

  /**
   * Apply the migrations from the migrations directory to the database.