transform wrapped result later before returning the response

Author: KSDaemon

packages/cubejs-api-gateway/src/gateway.ts

@@ -1834,11 +1834,10 @@ class ApiGateway {
       if (props.queryType === 'multi') {
         // We prepare the final json result on native side
         const resultMulti = new ResultMultiWrapper(results, { queryType, slowQuery });
-        res(await resultMulti.getFinalResult());
+        res(resultMulti);
       } else {
         // We prepare the full final json result on native side
-        const r = results[0];
-        res(await r.getFinalResult());
+        res(results[0]);
       }
     } catch (e: any) {
       this.handleError({
@@ -1973,7 +1972,7 @@ class ApiGateway {
         } else {
           // We prepare the final json result on native side
           const resultArray = new ResultArrayWrapper(results);
-          res(await resultArray.getFinalResult());
+          res(resultArray);
         }
       }
     } catch (e: any) {
@@ -2021,7 +2020,7 @@ class ApiGateway {
         query,
         context,
         res: (message, opts) => {
-          if (!Array.isArray(message) && message.error) {
+          if (!Array.isArray(message) && 'error' in message && message.error) {
             error = { message, opts };
           } else {
             result = { message, opts };
@@ -2045,14 +2044,14 @@ class ApiGateway {
   }
 
   protected resToResultFn(res: ExpressResponse) {
-    return (message, { status }: { status?: number } = {}) => {
+    return async (message, { status }: { status?: number } = {}) => {
       if (status) {
         res.status(status);
       }
 
-      if (message instanceof ArrayBuffer) {
+      if (message.isWrapper) {
         res.set('Content-Type', 'application/json');
-        res.send(Buffer.from(message));
+        res.send(Buffer.from(await message.getFinalResult()));
       } else {
         res.json(message);
       }

packages/cubejs-api-gateway/src/sql-server.ts

@@ -193,12 +193,7 @@ export class SQLServer {
                   return;
                 }
 
-                if (response instanceof ArrayBuffer) {
-                  const json = JSON.parse(new TextDecoder().decode(response));
-                  resolve(json);
-                } else {
-                  resolve(response);
-                }
+                resolve(response);
               },
               apiType: 'sql',
             });

packages/cubejs-api-gateway/src/types/request.ts

@@ -6,6 +6,7 @@
  */
 
 import type { Request as ExpressRequest } from 'express';
+import type { DataResult } from '@cubejs-backend/native';
 import { RequestType, ApiType, ResultType } from './strings';
 import { Query } from './query';
 
@@ -105,7 +106,7 @@ type MetaResponseResultFn = (message: MetaResponse | ErrorResponse) => void;
  */
 type ResponseResultFn =
   (
-    message: (Record<string, any> | Record<string, any>[]) | ErrorResponse,
+    message: (Record<string, any> | Record<string, any>[]) | DataResult | ErrorResponse,
     extra?: { status: number }
   ) => void;
 

packages/cubejs-backend-native/js/ResultWrapper.ts

@@ -7,6 +7,7 @@ import {
 } from './index';
 
 export interface DataResult {
+  isWrapper: boolean;
   getFinalResult(): Promise<any>;
 }
 

packages/cubejs-backend-native/js/index.ts

@@ -266,8 +266,11 @@ function wrapNativeFunctionWithStream(
         });
       } else if (response.error) {
         writerOrChannel.reject(errorString(response));
+      } else if (response.isWrapper) { // Native wrapped result
+        const resArBuf = await response.getFinalResult();
+        const resStr = new TextDecoder().decode(resArBuf);
+        writerOrChannel.resolve(resStr);
       } else {
-        // TODO remove JSON.stringify()
         writerOrChannel.resolve(JSON.stringify(response));
       }
     } catch (e: any) {