Function mergeSchemas

packages/internals/src/engine-commands/mergeSchemas.ts:46–106

(options: MergeSchemasOptions)

 * Wasm'd version of `merge_schemas`.
 */
export function mergeSchemas(options: MergeSchemasOptions): string {
  const debugErrorType = createDebugErrorType(debug, 'mergeSchemasWasm')
  debug(`Using mergeSchemas Wasm`)

  const mergeSchemasEither = pipe(
    E.tryCatch(
      () => {
        const params = JSON.stringify({
          schema: options.schemas,
        })
        return prismaSchemaWasm.merge_schemas(params)
      },
      (e) =>
        ({
          type: 'wasm-error' as const,
          reason: '(mergeSchemas wasm)',
          error: e as Error | WasmPanic,
        }) as const,
    ),
  )

  if (E.isRight(mergeSchemasEither)) {
    return mergeSchemasEither.right
  }

  /**
   * Check which error to throw.
   */
  const error = match(mergeSchemasEither.left)
    .with({ type: 'wasm-error' }, (e) => {
      debugErrorType(e)

      console.error('') // empty line for better readability

      /**
       * Capture and propagate possible Wasm panics.
       */
      if (isWasmPanic(e.error)) {
        const { message, stack } = getWasmError(e.error)
        debug(`Error merging schemas: ${message}`)
        debug(stack)

        const panic = new RustPanic(
          /* message */ message,
          /* rustStack */ stack,
          /* request */ '@prisma/prisma-schema-wasm merge_schemas',
          ErrorArea.FMT_CLI,
        )
        return panic
      }

      /*
       * Extract the actual error by attempting to JSON-parse the error message.
       */
      const errorOutput = e.error.message
      return new MergeSchemasError(parseQueryEngineError({ errorOutput, reason: e.reason }))
    })
    .exhaustive()