typescript draft

package.json

@@ -54,7 +54,8 @@
     "@bufbuild/protobuf": "^1.10.0",
     "@connectrpc/connect": "^1.6.0",
     "@connectrpc/connect-web": "^1.6.0",
-    "exponential-backoff": "^3.1.1"
+    "exponential-backoff": "^3.1.1",
+    "mongodb": "^6.10.0"
   },
   "devDependencies": {
     "@bufbuild/buf": "^1.15.0-1",

src/app/data-client.spec.ts

@@ -1,3 +1,4 @@
+import { BSON } from 'mongodb'
 import { Struct, Timestamp, type JsonValue } from '@bufbuild/protobuf';
 import { createRouterTransport, type Transport } from '@connectrpc/connect';
 import { beforeEach, describe, expect, it, vi } from 'vitest';
@@ -108,7 +109,7 @@ describe('DataClient tests', () => {
         service(DataService, {
           tabularDataBySQL: () => {
             return new TabularDataBySQLResponse({
-              data: data.map((x) => Struct.fromJson(x)),
+              rawData: data.map((x) => BSON.serialize(x)),
             });
           },
         });
@@ -134,7 +135,7 @@ describe('DataClient tests', () => {
         service(DataService, {
           tabularDataByMQL: () => {
             return new TabularDataByMQLResponse({
-              data: data.map((x) => Struct.fromJson(x)),
+              rawData: data.map((x) => BSON.serialize(x)),
             });
           },
         });

src/app/data-client.ts

@@ -1,3 +1,4 @@
+import { BSON } from 'mongodb';
 import { Struct, Timestamp, type JsonValue } from '@bufbuild/protobuf';
 import {
   createPromiseClient,
@@ -64,7 +65,7 @@ export class DataClient {
       organizationId,
       sqlQuery: query,
     });
-    return resp.data.map((value) => value.toJson());
+    return resp.rawData.map((bsonBytes) => BSON.deserialize(bsonBytes));
   }
 
   /**
@@ -79,7 +80,7 @@ export class DataClient {
       organizationId,
       mqlBinary: query,
     });
-    return resp.data.map((value) => value.toJson());
+    return resp.rawData.map((bsonBytes) => BSON.deserialize(bsonBytes));
   }
 
   /**