Fix C compilation errors and remove proto.js dependency

- Fix PgQueryScanResult access to use result.pbuf.data
- Fix PgQuerySplitResult serialization with proper JSON and buffer management
- Disable deparse functions that depend on proto.js (temporarily)
- Remove proto.js from package.json files array
- Eliminate 5.4MB proto.js dependency completely

Addresses CI build failure: 'no member named pbuf in PgQuerySplitResult'

Co-Authored-By: Dan Lynch <[email protected]>

Author: devin-ai-integration[bot]

src/wasm_wrapper.c

@@ -141,9 +141,30 @@ char* wasm_split_statements(const char* input) {
         return error_msg;
     }
 
-    char* split_result = strdup(result.pbuf.data);
+    size_t buffer_size = 1024 + (result.n_stmts * 64);
+    char* json_result = malloc(buffer_size);
+    strcpy(json_result, "{\"stmts\":[");
+    
+    for (int i = 0; i < result.n_stmts; i++) {
+        char stmt_json[256];
+        snprintf(stmt_json, sizeof(stmt_json), 
+                "%s{\"stmt_location\":%d,\"stmt_len\":%d}",
+                (i > 0) ? "," : "",
+                result.stmts[i]->stmt_location,
+                result.stmts[i]->stmt_len);
+        
+        if (strlen(json_result) + strlen(stmt_json) + 10 >= buffer_size) {
+            buffer_size *= 2;
+            json_result = realloc(json_result, buffer_size);
+        }
+        strcat(json_result, stmt_json);
+    }
+    strcat(json_result, "]}");
+    
+    char* final_result = strdup(json_result);
+    free(json_result);
     pg_query_free_split_result(result);
-    return split_result;
+    return final_result;
 }
 
 typedef struct {

wasm/index.cjs

@@ -1,4 +1,3 @@
-const { pg_query } = require('../proto.js');
 const PgQueryModule = require('./libpg-query.js');
 
 let wasmModule;
@@ -52,28 +51,7 @@ const parseQuery = awaitInit(async (query) => {
 });
 
 const deparse = awaitInit(async (parseTree) => {
-  const msg = pg_query.ParseResult.fromObject(parseTree);
-  const data = pg_query.ParseResult.encode(msg).finish();
-  
-  const dataPtr = wasmModule._malloc(data.length);
-  let resultPtr;
-  
-  try {
-    wasmModule.HEAPU8.set(data, dataPtr);
-    resultPtr = wasmModule._wasm_deparse_protobuf(dataPtr, data.length);
-    const resultStr = ptrToString(resultPtr);
-    
-    if (resultStr.startsWith('syntax error') || resultStr.startsWith('deparse error') || resultStr.includes('ERROR')) {
-      throw new Error(resultStr);
-    }
-    
-    return resultStr;
-  } finally {
-    wasmModule._free(dataPtr);
-    if (resultPtr) {
-      wasmModule._wasm_free_string(resultPtr);
-    }
-  }
+  throw new Error('deparse function temporarily disabled - proto.js dependency removed');
 });
 
 const parsePlPgSQL = awaitInit(async (query) => {
@@ -147,28 +125,7 @@ function deparseSync(parseTree) {
   if (!wasmModule) {
     throw new Error('WASM module not initialized. Call an async method first to initialize.');
   }
-  const msg = pg_query.ParseResult.fromObject(parseTree);
-  const data = pg_query.ParseResult.encode(msg).finish();
-  
-  const dataPtr = wasmModule._malloc(data.length);
-  let resultPtr;
-  
-  try {
-    wasmModule.HEAPU8.set(data, dataPtr);
-    resultPtr = wasmModule._wasm_deparse_protobuf(dataPtr, data.length);
-    const resultStr = ptrToString(resultPtr);
-    
-    if (resultStr.startsWith('syntax error') || resultStr.startsWith('deparse error') || resultStr.includes('ERROR')) {
-      throw new Error(resultStr);
-    }
-    
-    return resultStr;
-  } finally {
-    wasmModule._free(dataPtr);
-    if (resultPtr) {
-      wasmModule._wasm_free_string(resultPtr);
-    }
-  }
+  throw new Error('deparse function temporarily disabled - proto.js dependency removed');
 }
 
 function parsePlPgSQLSync(query) {

wasm/index.js

@@ -1,4 +1,3 @@
-import { pg_query } from '../proto.js';
 import PgQueryModule from './libpg-query.js';
 
 let wasmModule;
@@ -52,28 +51,7 @@ export const parseQuery = awaitInit(async (query) => {
 });
 
 export const deparse = awaitInit(async (parseTree) => {
-  const msg = pg_query.ParseResult.fromObject(parseTree);
-  const data = pg_query.ParseResult.encode(msg).finish();
-  
-  const dataPtr = wasmModule._malloc(data.length);
-  let resultPtr;
-  
-  try {
-    wasmModule.HEAPU8.set(data, dataPtr);
-    resultPtr = wasmModule._wasm_deparse_protobuf(dataPtr, data.length);
-    const resultStr = ptrToString(resultPtr);
-    
-    if (resultStr.startsWith('syntax error') || resultStr.startsWith('deparse error') || resultStr.includes('ERROR')) {
-      throw new Error(resultStr);
-    }
-    
-    return resultStr;
-  } finally {
-    wasmModule._free(dataPtr);
-    if (resultPtr) {
-      wasmModule._wasm_free_string(resultPtr);
-    }
-  }
+  throw new Error('deparse function temporarily disabled - proto.js dependency removed');
 });
 
 export const parsePlPgSQL = awaitInit(async (query) => {