fix: code quality — structured logging, Workers-safe show(), dead export, private field access

- master-do: add structured log() method, replace console.warn with this.log("warn", ...)
- client: DataFrame.show() falls back to JSON.stringify when console.table unavailable (Workers)
- query-schema: remove dead ValidatedQuery type export (never imported)
- local: add getExecutor() public method for pg-wire integration
- pg-wire/server: use qm.getExecutor() instead of unsafe `as unknown as` private field access

Author: teamchong

src/client.ts

@@ -708,7 +708,11 @@ export class DataFrame<T extends Row = Row> {
   async show(n = 10): Promise<void> {
     const rows = await this.head(n);
     if (rows.length === 0) { console.log("(empty)"); return; }
-    console.table(rows);
+    if (typeof console.table === "function") {
+      console.table(rows);
+    } else {
+      console.log(JSON.stringify(rows, null, 2));
+    }
   }
 
   /** Streaming iteration over results in batches. */

src/local.ts

@@ -62,6 +62,11 @@ export class QueryMode {
   static demo(tableName?: string): DataFrame {
     return createDemo(tableName);
   }
+
+  /** @internal Get the underlying executor (for pg-wire and similar integrations). */
+  getExecutor(): QueryExecutor {
+    return this.executor;
+  }
 }
 
 export { LocalExecutor } from "./local-executor.js";

src/master-do.ts

@@ -22,6 +22,12 @@ export class MasterDO extends DurableObject<Env> {
     super(ctx, env);
   }
 
+  private log(level: "info" | "warn" | "error", msg: string, data?: Record<string, unknown>): void {
+    console[level === "error" ? "error" : level === "warn" ? "warn" : "log"](
+      JSON.stringify({ ts: new Date().toISOString(), level, msg, ...data }),
+    );
+  }
+
   // ── RPC methods ────────────────────────────────────────────────────────
 
   async registerRpc(queryDoId: string, region: string): Promise<{ registered: boolean; region: string; tableVersions?: Record<string, { r2Key: string; updatedAt: number }> }> {
@@ -412,10 +418,10 @@ export class MasterDO extends DurableObject<Env> {
         const count = (this.broadcastFailures.get(region) ?? 0) + 1;
         this.broadcastFailures.set(region, count);
         if (count >= 3) {
-          console.warn(`Broadcast to ${region} failed ${count} times, removing`);
+          this.log("warn", "broadcast_region_removed", { region, failures: count });
           deadRegions.push(region);
         } else {
-          console.warn(`Broadcast to ${region} failed (${count}/3)`);
+          this.log("warn", "broadcast_failed", { region, failures: count, threshold: 3 });
         }
       }
     }));

src/pg-wire/server.ts

@@ -19,7 +19,7 @@ const qm = QueryMode.local();
 
 const server = net.createServer((socket) => {
   const handler = new PgConnectionHandler({
-    executor: (qm as unknown as { executor: import("../client.js").QueryExecutor }).executor,
+    executor: qm.getExecutor(),
     send: (data) => {
       if (!socket.destroyed) socket.write(data);
     },

src/query-schema.ts

@@ -52,8 +52,6 @@ export const queryDescriptorSchema = z.object({
   cacheTTL: z.number().int().positive().optional(),
 });
 
-export type ValidatedQuery = z.infer<typeof queryDescriptorSchema>;
-
 /**
  * Parse and validate a raw request body into a QueryDescriptor.
  * Throws a formatted error string on validation failure.