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 man! can you give me an example of how you are mapping SqlError.

i am getting this error cause and not able to get the PostgresError :(

(FiberFailure) SqlError: Failed to execute statement
    at cause (/home/akshat/Documents/git/commander/node_modules/.pnpm/@[email protected]_@[email protected]_@[email protected][email protected]_42ab70da82d8a05f56a95887e3aec16b/node_modules/@effect/sql-pg/src/PgClient.ts:220:31)
    at process.processTicksAndRejections (node:internal/process/task_queues:105:5) {
  [cause]: PostgresError: duplicate key value violates unique constraint "course_code_unique"
      at ErrorResponse (file:///home/akshat/Documents/git/commander/node_modules/.pnpm/[email protected]/node_modules/postgres/src/connection.js:794:26)
      at handle (file:///home/akshat/Documents/git/commander/node_modules/.pnpm/[email protected]/node_modules/postgres/src/connection.js:480:6)
      at Socket.data (file:///home/akshat/Documents/git/commander/node_modules/.pnpm/[email protected]/node_modules/postgres/src/connection.js:315:9)
      at Socket.emit (node:events:518:28)
      at addChunk (node:internal/streams/readable:561:12)
      at readableAddChunkPushByteMode (node:internal/streams/readable:512:3)
      at Readable.push (node:internal/streams/readable:392:5)
      at TCP.onStreamRead (node:internal/stream_base_commons:189:23)
      at TCP.callbackTrampoline (node:internal/async_hooks:130:17)
}```

yeah unfortunately I cannot use PostgresError from the postgres library either. I have to utils to map the SqlError to original error data. I'm not at the computer now, will add this later

thanks!

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 🙏