drizzle-effect.ts

import * as PgDrizzle from "@effect/sql-drizzle/Pg";
import { PgClient } from "@effect/sql-pg";
import { Config, Effect } from "effect";
import * as schema from "~/lib/server/schema";

const PgLive = PgClient.layerConfig({
  url: Config.redacted("DATABASE_URL"),
});

export class DrizzleClient extends Effect.Service<DrizzleClient>()("app/DrizzleClient", {
  dependencies: [PgLive],
  effect: Effect.gen(function* () {
    const db = yield* PgDrizzle.make<typeof schema>({
      schema: schema,
    });
    return db;
  }),
}) {}

thanks!

this is the abomination Im using while waiting the native Drizzle effect package 😅

the json stringify and parse is to get to some detail only available during serialization (calling toJSON methods internally) or errors that are not exposed

import { SqlError } from "@effect/sql/SqlError";

export function extractSqlErrorDetails(sqlError: SqlError) {
  const jsonStr = JSON.stringify(sqlError);
  const parsed = JSON.parse(jsonStr);

  function findPostgresErrorInJson(obj: any): any {
    if (obj && typeof obj === "object") {
      if (obj.name === "PostgresError") {
        return obj;
      }

      for (const key in obj) {
        if (Object.prototype.hasOwnProperty.call(obj, key)) {
          const result = findPostgresErrorInJson(obj[key]);
          if (result) return result;
        }
      }
    }
    return null;
  }

  const pgError = findPostgresErrorInJson(parsed);
  if (pgError) {
    return {
      code: pgError.code,
      detail: pgError.detail,
      constraint: pgError.constraint_name,
      schema: pgError.schema_name,
      table: pgError.table_name,
    };
  }
  return null;
}

result is like

{
  code: "23505",
  detail: "Key (name)=(due) already exists.",
  constraint: "test_name_key",
  schema: "public",
  table: "test",
}

thank you @kandros! I was stuck on this for a long time :)
Please update this as well when there is a better way to handle this 🙏