fix: look for the column in this database only

`information_schema.columns` spans every schema on PostgreSQL and every
database on MySQL, so a same-named table elsewhere could answer for this
one. The column check would then skip the `ALTER`, record migration 11,
and leave every later query referencing a column that is not there.

The lookup narrows to `current_schema()` or `DATABASE()`, as the other
metadata queries in this repository already do.

`RedriveManager.start` and the filter parameters take the types the rest
of the code uses, rather than restating `unknown`.

Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>

Author: cardmagic

src/dead-letter-scopes.ts

@@ -6,6 +6,8 @@ import type { AdministrationOptions, DeepReadonly, JsonObject } from "./types.js
 
 export type DeadLetterKind = "effect" | "broadcast"
 
+type DeadRowFilterValue = string | number
+
 export interface DeadRow {
   readonly id: string
   readonly kind: DeadLetterKind
@@ -157,9 +159,9 @@ export class DeadLetterScope {
   private conditions(
     filters: RedriveFilters,
     deadBefore?: number,
-  ): { where: string; parameters: unknown[] } {
+  ): { where: string; parameters: DeadRowFilterValue[] } {
     const clauses = ["dead.status = 'dead'"]
-    const parameters: unknown[] = []
+    const parameters: DeadRowFilterValue[] = []
     if (deadBefore !== undefined) {
       clauses.push("dead.failed_at_ms <= ?")
       parameters.push(deadBefore)

src/redrive.ts

@@ -38,7 +38,7 @@ export class RedriveManager {
   async start(input: {
     kind: DeadLetterKind
     filters: RedriveFilters
-    authorizationContext?: unknown
+    authorizationContext?: AdministrationOptions["authorizationContext"]
   }): Promise<RedriveTask> {
     await this.runtime.deadLetters.scope(input.kind).authorize({
       action: "redrive",

src/schema.ts

@@ -461,9 +461,10 @@ async function hasFailedAt(options: {
     )
     return columns.some(({ name }) => name === "failed_at_ms")
   }
+  const schema = options.family === "postgresql" ? "current_schema()" : "DATABASE()"
   const found = await options.connection.get<{ found: number | bigint }>(
     `SELECT COUNT(*) AS found FROM information_schema.columns
-     WHERE table_name = ? AND column_name = 'failed_at_ms'`,
+     WHERE table_schema = ${schema} AND table_name = ? AND column_name = 'failed_at_ms'`,
     [options.table],
   )
   return Number(found?.found ?? 0) > 0