From 2b1d0f7f05de237733ad6f6c5aeb1ba787313dd7 Mon Sep 17 00:00:00 2001
From: Akim <59872966+akim-bow@users.noreply.github.com>
Date: Fri, 9 Feb 2024 07:49:33 +0700
Subject: [PATCH] fix(js-client): Improve logging of conversion API (#429)

* Improve logging of conversion API

* Fix arg name
---
 packages/core/js-client/src/api.ts            | 14 +++++++---
 .../__test__/conversion.spec.ts               |  4 +--
 .../src/compilerSupport/conversions.ts        | 26 +++++++++++--------
 3 files changed, 27 insertions(+), 17 deletions(-)

diff --git a/packages/core/js-client/src/api.ts b/packages/core/js-client/src/api.ts
index e61ce1fab..2dbd95e5a 100644
--- a/packages/core/js-client/src/api.ts
+++ b/packages/core/js-client/src/api.ts
@@ -102,7 +102,7 @@ export const v5_callFunction = async (
             );
           }
 
-          return [argName, wrapJsFunction(arg, argType)];
+          return [argName, wrapJsFunction(arg, argType, argName)];
         }
 
         if (typeof arg === "function") {
@@ -114,7 +114,7 @@ export const v5_callFunction = async (
           );
         }
 
-        return [argName, js2aqua(arg, argType, { path: [def.functionName] })];
+        return [argName, js2aqua(arg, argType, { path: [argName] })];
       },
     ),
   );
@@ -141,7 +141,9 @@ export const v5_callFunction = async (
     result = null;
   }
 
-  return aqua2js(result, returnSchema);
+  return aqua2js(result, returnSchema, {
+    path: [`${def.functionName}ReturnValue`],
+  });
 };
 
 const getDefaultPeer = (): FluencePeer => {
@@ -215,7 +217,11 @@ export const v5_registerService = (
 
       return [
         schemaKey,
-        wrapJsFunction(serviceImplValue.bind(serviceImpl), schemaValue),
+        wrapJsFunction(
+          serviceImplValue.bind(serviceImpl),
+          schemaValue,
+          schemaKey,
+        ),
       ] as const;
     }),
   );
diff --git a/packages/core/js-client/src/compilerSupport/__test__/conversion.spec.ts b/packages/core/js-client/src/compilerSupport/__test__/conversion.spec.ts
index d7735df4b..fef9ed245 100644
--- a/packages/core/js-client/src/compilerSupport/__test__/conversion.spec.ts
+++ b/packages/core/js-client/src/compilerSupport/__test__/conversion.spec.ts
@@ -200,7 +200,7 @@ describe("Conversion from aqua to typescript", () => {
       // arrange
 
       // act
-      const tsFromAqua = aqua2js(aqua, type);
+      const tsFromAqua = aqua2js(aqua, type, { path: [] });
       const aquaFromTs = js2aqua(ts, type, { path: [] });
 
       // assert
@@ -232,7 +232,7 @@ describe("Conversion corner cases", () => {
 
     // act
     const aqua = js2aqua(valueInTs, type, { path: [] });
-    const ts = aqua2js(valueInAqua, type);
+    const ts = aqua2js(valueInAqua, type, { path: [] });
 
     // assert
     expect(aqua).toStrictEqual({
diff --git a/packages/core/js-client/src/compilerSupport/conversions.ts b/packages/core/js-client/src/compilerSupport/conversions.ts
index b593ba655..db30dffaf 100644
--- a/packages/core/js-client/src/compilerSupport/conversions.ts
+++ b/packages/core/js-client/src/compilerSupport/conversions.ts
@@ -97,16 +97,17 @@ function isScalar(
 export function aqua2js(
   value: JSONValue,
   schema: NonArrowSimpleType,
+  { path }: ValidationContext,
 ): JSONValue {
   if (schema.tag === "nil") {
     return null;
   } else if (schema.tag === "option") {
     if (!Array.isArray(value)) {
-      throw new SchemaValidationError([], schema, "array", value);
+      throw new SchemaValidationError(path, schema, "array", value);
     }
 
     if ("0" in value) {
-      return aqua2js(value[0], schema.type);
+      return aqua2js(value[0], schema.type, { path: [...path, "?"] });
     } else {
       return null;
     }
@@ -121,16 +122,16 @@ export function aqua2js(
       throw new SchemaValidationError([], schema, "array", value);
     }
 
-    return value.map((y) => {
-      return aqua2js(y, schema.type);
+    return value.map((y, i) => {
+      return aqua2js(y, schema.type, { path: [...path, `[${i}]`] });
     });
   } else if (schema.tag === "unlabeledProduct") {
     if (!Array.isArray(value)) {
       throw new SchemaValidationError([], schema, "array", value);
     }
 
-    return zip(value, schema.items).map(([v, s]) => {
-      return aqua2js(v, s);
+    return zip(value, schema.items).map(([v, s], i) => {
+      return aqua2js(v, s, { path: [...path, `[${i}]`] });
     });
   } else if (["labeledProduct", "struct"].includes(schema.tag)) {
     if (typeof value !== "object" || value === null || Array.isArray(value)) {
@@ -145,7 +146,7 @@ export function aqua2js(
           v = null;
         }
 
-        const val = aqua2js(v, type);
+        const val = aqua2js(v, type, { path: [...path, key] });
         return [key, val];
       }),
     );
@@ -167,7 +168,9 @@ export function js2aqua(
     return value;
   } else if (schema.tag === "option") {
     // option means 'type | null'
-    return value === null ? [] : [js2aqua(value, schema.type, { path })];
+    return value === null
+      ? []
+      : [js2aqua(value, schema.type, { path: [...path, "?"] })];
   } else if (schema.tag === "topType") {
     // topType equals to 'any'
     return value;
@@ -221,6 +224,7 @@ export const wrapJsFunction = (
   schema:
     | ArrowWithoutCallbacks
     | ArrowType<LabeledProductType<SimpleTypes> | UnlabeledProductType>,
+  funcName: string,
 ): ServiceImpl[string] => {
   return async ({ args, context }) => {
     const schemaArgs =
@@ -236,8 +240,8 @@ export const wrapJsFunction = (
       );
     }
 
-    const jsArgs = zip(args, schemaArgs).map(([arg, schemaArg]) => {
-      return aqua2js(arg, schemaArg);
+    const jsArgs = zip(args, schemaArgs).map(([arg, schemaArg], i) => {
+      return aqua2js(arg, schemaArg, { path: [`${funcName}Args`, `[${i}]`] });
     });
 
     const returnTypeVoid =
@@ -256,6 +260,6 @@ export const wrapJsFunction = (
       result = null;
     }
 
-    return js2aqua(result, resultSchema, { path: [] });
+    return js2aqua(result, resultSchema, { path: [`${funcName}ReturnValue`] });
   };
 };