Function execaCommand

packages/internals/src/schemaEngineCommands.ts:168–207

({
  connectionString,
  cwd,
  schemaEnginePath,
  engineCommandName,
}: {
  connectionString: string
  cwd: string
  schemaEnginePath?: string
  engineCommandName: 'create-database' | 'drop-database' | 'can-connect-to-database'
})

}

export async function execaCommand({
  connectionString,
  cwd,
  schemaEnginePath,
  engineCommandName,
}: {
  connectionString: string
  cwd: string
  schemaEnginePath?: string
  engineCommandName: 'create-database' | 'drop-database' | 'can-connect-to-database'
}) {
  schemaEnginePath = schemaEnginePath || (await resolveBinary(BinaryType.SchemaEngineBinary))

  try {
    return await execa(
      schemaEnginePath,
      ['--datasource', JSON.stringify({ url: connectionString }), 'cli', engineCommandName],
      {
        cwd,
        env: {
          RUST_BACKTRACE: process.env.RUST_BACKTRACE ?? '1',
          RUST_LOG: process.env.RUST_LOG ?? 'info',
        },
      },
    )
  } catch (_e) {
    const e = _e as ExecaError

    if (e.message) {
      e.message = e.message.replace(connectionString, '<REDACTED>')
    }
    if (e.stdout) {
      e.stdout = e.stdout.replace(connectionString, '<REDACTED>')
    }
    if (e.stderr) {
      e.stderr = e.stderr.replace(connectionString, '<REDACTED>')
    }
    throw e
  }
}