fix: fromJSON uses all row keys, pg-wire unknown messages no longer fake terminate

convenience.ts: createFromJSON() used Object.keys(data[0]) for column
detection — rows with extra keys had those columns silently dropped.
Now unions keys across all rows.

pg-wire: unknown frontend messages (extended query protocol Parse/Bind/
Execute/Sync) were returned as { type: "terminate" }, conflating them
with real client disconnect. Now returns { type: "skip" } which the
handler explicitly ignores without affecting connection lifecycle.

Author: teamchong

src/convenience.ts

@@ -19,7 +19,11 @@ export function createFromJSON<T extends Record<string, unknown>>(
     return new DataFrame(tableName, new MaterializedExecutor(result));
   }
 
-  const columns = Object.keys(data[0]);
+  const columnSet = new Set<string>();
+  for (const item of data) {
+    for (const key of Object.keys(item)) columnSet.add(key);
+  }
+  const columns = [...columnSet];
   const rows: Row[] = data.map(item => {
     const row: Row = {};
     for (const col of columns) {

src/pg-wire/handler.ts

@@ -96,7 +96,7 @@ export class PgConnectionHandler {
   }
 
   private async handleMessage(msg: FrontendMessage): Promise<void> {
-    if (msg.type === "terminate") return;
+    if (msg.type === "terminate" || msg.type === "skip") return;
 
     if (msg.type === "query") {
       await this.handleQuery(msg.sql);

src/pg-wire/protocol.ts

@@ -30,7 +30,11 @@ export interface SSLRequest {
   type: "ssl_request";
 }
 
-export type FrontendMessage = StartupMessage | QueryMessage | TerminateMessage | SSLRequest;
+export interface SkipMessage {
+  type: "skip";
+}
+
+export type FrontendMessage = StartupMessage | QueryMessage | TerminateMessage | SSLRequest | SkipMessage;
 
 // ── Parsing ─────────────────────────────────────────────────────────────
 
@@ -95,8 +99,8 @@ export function parseFrontendMessage(buf: Uint8Array): [FrontendMessage, number]
     case 0x58: // 'X' — Terminate
       return [{ type: "terminate" }, totalLen];
     default:
-      // Skip unknown messages
-      return [{ type: "terminate" }, totalLen];
+      // Skip unknown/unsupported messages (extended query protocol, etc.)
+      return [{ type: "skip" }, totalLen];
   }
 }