Merge pull request #74 from gregnr/feat/deparse-wasm

Deparse in WASM builds

Author: pyramation

src/async.cc

@@ -137,7 +137,7 @@ Napi::Value ParseQueryAsync(const Napi::CallbackInfo& info) {
 }
 
 Napi::Value DeparseAsync(const Napi::CallbackInfo& info) {
-  if (info.Length() < 2 || !info[0].IsBuffer() || !info[1].IsFunction()) {
+  if (info.Length() < 2 || !(info[0].IsBuffer() || info[0].IsTypedArray()) || !info[1].IsFunction()) {
     Napi::TypeError::New(info.Env(), "Invalid arguments").ThrowAsJavaScriptException();
     return info.Env().Undefined();
   }

test/webpack/src/index.js

@@ -1,7 +1,9 @@
-import { parseQuery } from '../../../wasm';
+import { deparse, parseQuery } from '../../../wasm';
 
 const sql = 'select * from customers;';
 const result = await parseQuery(sql);
+const newSql = await deparse(result);
 
 console.log(sql);
 console.log(result);
+console.log(newSql);

wasm/index.js

@@ -1,4 +1,5 @@
 import { getDefaultContext } from '@emnapi/runtime';
+import { pg_query } from '../proto.js';
 import PgQueryModule from './libpg-query.js';
 
 let PgQuery;
@@ -30,6 +31,16 @@ export const parseQuery = awaitInit((query) => {
   });
 });
 
+export const deparse = awaitInit((parseTree) => {
+  const msg = pg_query.ParseResult.fromObject(parseTree);
+  const data = pg_query.ParseResult.encode(msg).finish();
+  return new Promise((resolve, reject) => {
+    PgQuery.deparseAsync(data, (err, result) => {
+      err ? reject(err) : resolve(result);
+    });
+  });
+});
+
 export const parsePlPgSQL = awaitInit((query) => {
   return new Promise(async (resolve, reject) => {
     PgQuery.parsePlPgSQLAsync(query, (err, result) => {