update kwil to support results precision

trufnetwork · Oct 24, 2024 · b098f7c · b098f7c
1 parent 60cd07b
commit b098f7c
Show file tree

Hide file tree

Showing 5 changed files with 23 additions and 23 deletions.
diff --git a/package.json b/package.json
@@ -12,7 +12,7 @@
     "lodash": "4.17.21"
   },
   "peerDependencies": {
-    "@kwilteam/kwil-js": "0.7.1"
+    "@kwilteam/kwil-js": "0.7.2"
   },
   "devDependencies": {
     "@typescript-eslint/eslint-plugin": "8.11.0",

diff --git a/src/contracts-api/stream.ts b/src/contracts-api/stream.ts
@@ -171,7 +171,7 @@ export class Stream {
    */
   public async getRecord(input: GetRecordInput): Promise<StreamRecord[]> {
     // TODO: change value to string when kwil-js is updated
-    const result = await this.call<{ date_value: string; value: number }[]>(
+    const result = await this.call<{ date_value: string; value: string }[]>(
       "get_record",
       [
         ActionInput.fromObject({
@@ -186,7 +186,7 @@ export class Stream {
       .mapRight((result) =>
         result.map((row) => ({
           dateValue: row.date_value,
-          value: row.value.toString(),
+          value: row.value,
         })),
       )
       .throw();
@@ -196,7 +196,7 @@ export class Stream {
    * Returns the index of the stream within the given date range
    */
   public async getIndex(input: GetRecordInput): Promise<StreamRecord[]> {
-    const result = await this.call<{ date_value: string; value: number }[]>(
+    const result = await this.call<{ date_value: string; value: string }[]>(
       "get_index",
       [
         ActionInput.fromObject({
@@ -211,7 +211,7 @@ export class Stream {
       .mapRight((result) =>
         result.map((row) => ({
           dateValue: row.date_value,
-          value: row.value.toString(),
+          value: row.value,
         })),
       )
       .throw();
@@ -248,7 +248,7 @@ export class Stream {
   public async getFirstRecord(
     input: GetFirstRecordInput,
   ): Promise<StreamRecord | null> {
-    const result = await this.call<{ date_value: string; value: number }[]>(
+    const result = await this.call<{ date_value: string; value: string }[]>(
       "get_first_record",
       [
         ActionInput.fromObject({
@@ -264,7 +264,7 @@ export class Stream {
         result
           .map((result) => ({
             dateValue: result.date_value,
-            value: result.value.toString(),
+            value: result.value,
           }))
           .unwrapOr(null),
       )

diff --git a/tests/integration/composedStream.test.ts b/tests/integration/composedStream.test.ts
@@ -30,20 +30,20 @@ describe.sequential(
           // Deploy child streams with initial data
           // Child A: [2020-01-01: 1, 2020-01-02: 2, 2020-01-30: 3, 2020-02-01: 4, 2020-02-02: 5]
           await deployPrimitiveStreamWithData(defaultClient, childAStreamId, [
-            { dateValue: "2020-01-01", value: "1" },
-            { dateValue: "2020-01-02", value: "2" },
-            { dateValue: "2020-01-30", value: "3" },
-            { dateValue: "2020-02-01", value: "4" },
-            { dateValue: "2020-02-02", value: "5" },
+            { dateValue: "2020-01-01", value: "1.000000000000000000" },
+            { dateValue: "2020-01-02", value: "2.000000000000000000" },
+            { dateValue: "2020-01-30", value: "3.000000000000000000" },
+            { dateValue: "2020-02-01", value: "4.000000000000000000" },
+            { dateValue: "2020-02-02", value: "5.000000000000000000" },
           ]);
 
           // Child B: [2020-01-01: 3, 2020-01-02: 4, 2020-01-30: 5, 2020-02-01: 6, 2020-02-02: 7]
           await deployPrimitiveStreamWithData(defaultClient, childBStreamId, [
-            { dateValue: "2020-01-01", value: "3" },
-            { dateValue: "2020-01-02", value: "4" },
-            { dateValue: "2020-01-30", value: "5" },
-            { dateValue: "2020-02-01", value: "6" },
-            { dateValue: "2020-02-02", value: "7" },
+            { dateValue: "2020-01-01", value: "3.000000000000000000" },
+            { dateValue: "2020-01-02", value: "4.000000000000000000" },
+            { dateValue: "2020-01-30", value: "5.000000000000000000" },
+            { dateValue: "2020-02-01", value: "6.000000000000000000" },
+            { dateValue: "2020-02-02", value: "7.000000000000000000" },
           ]);
 
           // Deploy composed stream

diff --git a/tests/integration/permissions.test.ts b/tests/integration/permissions.test.ts
@@ -40,7 +40,7 @@ describe.sequential("Permissions", { timeout: 90000 }, () => {
 
         // Insert test data
         tx = await primitiveStream.insertRecords([
-          { dateValue: "2024-01-01", value: "100" },
+          { dateValue: "2024-01-01", value: "100.000000000000000000" },
         ]);
         await waitForTxSuccess(tx, ownerClient);
 
@@ -54,7 +54,7 @@ describe.sequential("Permissions", { timeout: 90000 }, () => {
           dateTo: "2024-01-01",
         });
         expect(publicRecords.length).toBe(1);
-        expect(publicRecords[0].value).toBe("100");
+        expect(publicRecords[0].value).toBe("100.000000000000000000");
 
         // Set stream to private
         tx = await primitiveStream.setReadVisibility(visibility.private);
@@ -128,7 +128,7 @@ describe.sequential("Permissions", { timeout: 90000 }, () => {
         tx = await primitiveStream.initializeStream();
         await waitForTxSuccess(tx, ownerClient);
         tx = await primitiveStream.insertRecords([
-          { dateValue: "2024-01-01", value: "100" },
+          { dateValue: "2024-01-01", value: "100.000000000000000000" },
         ]);
         await waitForTxSuccess(tx, ownerClient);
         // Deploy and initialize composed stream

diff --git a/tests/integration/primitiveStream.test.ts b/tests/integration/primitiveStream.test.ts
@@ -54,7 +54,7 @@ describe.sequential(
 
           // Verify record content
           expect(records.length).toBe(1);
-          expect(records[0].value).toBe("1");
+          expect(records[0].value).toBe("1.000000000000000000");
           expect(records[0].dateValue).toBe("2020-01-01");
 
           // Query index
@@ -65,13 +65,13 @@ describe.sequential(
 
           // Verify index content
           expect(index.length).toBe(1);
-          expect(index[0].value).toBe("100");
+          expect(index[0].value).toBe("100.000000000000000000");
           expect(index[0].dateValue).toBe("2020-01-01");
 
           // Query first record
           const firstRecord = await primitiveStream.getFirstRecord({});
           expect(firstRecord).not.toBeNull();
-          expect(firstRecord?.value).toBe("1");
+          expect(firstRecord?.value).toBe("1.000000000000000000");
           expect(firstRecord?.dateValue).toBe("2020-01-01");
         } finally {
           // Cleanup: destroy the stream after test