Function report

packages/db/tx-tripwire.ts:69–96

(poolName: string, query: string)

const recentWarnings = new Map<string, number>()

function report(poolName: string, query: string): void {
  const mode = resolveMode()
  if (mode === 'off') return

  const queryPreview = query.replace(/\s+/g, ' ').slice(0, 160)
  const message =
    `Query on the global "${poolName}" pool issued inside a transaction callback. ` +
    'The transaction already holds a pooled connection, so this checks out a second one ' +
    'and can deadlock the pool at saturation. Pass the tx handle to the query, hoist the ' +
    'work above the transaction, or wrap deliberate fire-and-forget global-pool work in ' +
    'runOutsideTransactionContext().'

  if (mode === 'throw') {
    throw new Error(`${message} Query: ${queryPreview}`)
  }

  const now = Date.now()
  const lastLogged = recentWarnings.get(queryPreview)
  if (lastLogged !== undefined && now - lastLogged < WARN_DEDUPE_WINDOW_MS) return
  if (recentWarnings.size >= WARN_DEDUPE_MAX_KEYS) {
    for (const [key, loggedAt] of recentWarnings) {
      if (now - loggedAt >= WARN_DEDUPE_WINDOW_MS) recentWarnings.delete(key)
    }
    if (recentWarnings.size >= WARN_DEDUPE_MAX_KEYS) recentWarnings.clear()
  }
  recentWarnings.set(queryPreview, now)
  logger.error(message, { poolName, queryPreview, stack: new Error().stack })
}

/**
 * Minimal structural surface of a postgres-js root client needed by the