test_errors.ts

/**
 * test_errors.ts — Error handling integration tests for perry-prisma.
 * Uses NativeCurrencyPrice model, chainId range 960001–960010.
 */
import { createPrismaClient } from "perry-prisma";
import { eq, ok, isNull, isNotNull, arrLen, finish } from "./helpers";

var url = process.env.DATABASE_URL;
if (!url || url === "undefined") {
  url = "mysql://test:k7DRayxy%23ipTebbGE@webserver.skelpo.net:3306/test";
}

var prisma = createPrismaClient({ datasourceUrl: url });

console.log("=== test_errors.ts ===");
console.log("");

try {
  prisma.$connect();

  // Ensure table exists
  prisma.$executeRaw(
    "CREATE TABLE IF NOT EXISTS NativeCurrencyPrice (" +
    "  id VARCHAR(36) NOT NULL," +
    "  chainId INT NOT NULL," +
    "  currency VARCHAR(255) NOT NULL," +
    "  usdPrice DECIMAL(36,18) NOT NULL," +
    "  createdAt DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3)," +
    "  updatedAt DATETIME(3) NOT NULL," +
    "  PRIMARY KEY (id)," +
    "  UNIQUE KEY chainId_unique (chainId)," +
    "  INDEX idx_chainId (chainId)," +
    "  INDEX idx_updatedAt (updatedAt)" +
    ")"
  );

  // Cleanup
  prisma.$executeRaw("DELETE FROM NativeCurrencyPrice WHERE chainId >= 960001 AND chainId <= 960010");

  // ── $queryRaw with non-existent table → error ──
  console.log("$queryRaw: non-existent table");
  var rawTableError = false;
  try {
    prisma.$queryRaw("SELECT * FROM NonExistentTable_XYZ_12345");
  } catch (e: any) {
    rawTableError = true;
    ok("$queryRaw bad table: error message present", e.message && e.message.length > 0);
  }
  ok("$queryRaw non-existent table throws", rawTableError);

  // ── create with empty data → error ──
  console.log("create: empty data");
  var emptyDataError = false;
  var emptyDataMsg = "";
  try {
    prisma.nativeCurrencyPrice.create({ data: {} });
  } catch (e: any) {
    emptyDataError = true;
    emptyDataMsg = e.message ? e.message : "";
  }
  ok("create empty data throws", emptyDataError);
  ok("create empty data: has error message", emptyDataMsg.length > 0);

  // ── duplicate @unique key → error ──
  console.log("duplicate @unique key");
  prisma.nativeCurrencyPrice.create({
    data: {
      id: "err-960001",
      chainId: 960001,
      currency: "ERR",
      usdPrice: 10,
      updatedAt: "2026-01-15T10:00:00.000Z"
    }
  });
  var dupError = false;
  try {
    prisma.nativeCurrencyPrice.create({
      data: {
        id: "err-960001-dup",
        chainId: 960001,
        currency: "ERR-DUP",
        usdPrice: 20,
        updatedAt: "2026-01-15T10:00:00.000Z"
      }
    });
  } catch (e: any) {
    dupError = true;
    ok("duplicate key: error message present", e.message && e.message.length > 0);
  }
  ok("duplicate @unique key throws", dupError);

  // ── $executeRaw with invalid SQL → error ──
  console.log("$executeRaw: invalid SQL");
  var invalidSqlError = false;
  try {
    prisma.$executeRaw("THIS IS NOT VALID SQL AT ALL");
  } catch (e: any) {
    invalidSqlError = true;
    ok("invalid SQL: error message present", e.message && e.message.length > 0);
  }
  ok("$executeRaw invalid SQL throws", invalidSqlError);

  // ── findUniqueOrThrow for missing record → throws ──
  console.log("findUniqueOrThrow: missing record");
  var throwError = false;
  var throwMsg = "";
  try {
    prisma.nativeCurrencyPrice.findUniqueOrThrow({ where: { chainId: 999666 } });
  } catch (e: any) {
    throwError = true;
    throwMsg = e.message ? e.message : "";
  }
  ok("findUniqueOrThrow missing record throws", throwError);
  ok("findUniqueOrThrow: message mentions model", throwMsg.indexOf("NativeCurrencyPrice") >= 0);

  // ── findFirstOrThrow for missing record → throws ──
  console.log("findFirstOrThrow: missing record");
  var throwError2 = false;
  try {
    prisma.nativeCurrencyPrice.findFirstOrThrow({ where: { chainId: 999666 } });
  } catch (e: any) {
    throwError2 = true;
  }
  ok("findFirstOrThrow missing record throws", throwError2);

  // ── update with where matching nothing → returns null ──
  console.log("update: no match returns null");
  var updateNull = prisma.nativeCurrencyPrice.update({
    where: { chainId: 999666 },
    data: { currency: "NOPE" }
  });
  isNull("update non-existent returns null", updateNull);

  // Cleanup
  prisma.$executeRaw("DELETE FROM NativeCurrencyPrice WHERE chainId >= 960001 AND chainId <= 960010");
  prisma.$disconnect();
} catch (e: any) {
  console.log("UNEXPECTED ERROR: " + e);
}

finish();