Function parseRow

packages/infra/src/Store/SQL/Pg.ts:18–25

(
  row: { id: string; _etag: string | null; data: unknown },
  idKey: PropertyKey,
  defaultValues: Partial<Encoded>
)

import { buildWhereSQLQuery, logQuery, pgDialect } from "./query.ts"

const sqlErrorMessage = (e: unknown) => (e as any)?.message ? String((e as any).message) : String(e)
const sqlIsTransient = (e: unknown) =>
  /timeout|ETIMEDOUT|ECONNRESET|ECONNREFUSED|connection|deadlock|too many connections/i.test(sqlErrorMessage(e))
// Map a SqlError into a typed, serializable DatabaseError (instead of `.orDie`,
// which would turn it into an opaque, non-serializable defect).
const toDatabaseError = (e: unknown) =>
  new DatabaseError({ message: `SQL request failed: ${sqlErrorMessage(e)}`, transient: sqlIsTransient(e), cause: e })
// withTransaction may re-raise setInternal's typed errors or add SqlError on begin/commit.
// Preserve DatabaseError / OCC by `_tag` (not instanceof — dual package instances break it);
// map residual SQL failures to DatabaseError.
const preserveStoreError = (e: unknown): DatabaseError | OptimisticConcurrencyException => {