refactor: handling godwoken error

packages/api-server/src/cache/data.ts

@@ -1,3 +1,5 @@
+import { handleGwError } from "../methods/gw-error";
+
 require("newrelic");
 import { createClient } from "redis";
 import { envConfig } from "../base/env-config";
@@ -178,7 +180,7 @@ export class RedisDataCache {
             );
           }
           await releaseLock(lockValue);
-          throw new Error(error.message);
+          throw error;
         }
       }
 
@@ -199,7 +201,7 @@ export class RedisDataCache {
             `[${this.constructor.name}]: subscribe err:`,
             error.message
           );
-          throw new Error(error.message);
+          throw error;
         }
       }
 
@@ -281,12 +283,15 @@ export function errorResult(reason: string) {
 }
 
 export function parseExecuteResult(res: string) {
-  const jsonRes: PublishExecuteResult = JSON.parse(res);
-  if (jsonRes.status === PublishExecuteResultStatus.Success) {
-    return jsonRes.data!;
+  const executionResult = JSON.parse(res);
+  if (executionResult?.status === PublishExecuteResultStatus.Success) {
+    return (executionResult as PublishExecuteResult).data;
+  }
+  if (executionResult?.err != null) {
+    handleGwError(executionResult.err);
   }
 
-  throw new Error("[RedisSubscribeResult]" + jsonRes.err);
+  throw new Error("[RedisSubscribeResult] unrecognizable result: " + res);
 }
 
 const asyncSleep = async (ms = 0) => {

packages/api-server/src/methods/error-code.ts

@@ -16,6 +16,7 @@ export const RESOURCE_UNAVAILABLE = -32002;
 export const TRANSACTION_REJECTED = -32003;
 export const METHOD_NOT_SUPPORT = -32004;
 export const LIMIT_EXCEEDED = -32005;
+export const TRANSACTION_EXECUTION_ERROR = -32000;
 
 // Polyjuice Chain custom error
 // TODO - WEB3_ERROR is pretty generalize error

packages/api-server/src/methods/error.ts

@@ -2,19 +2,21 @@ import { JSONRPCError } from "jayson";
 import { logger } from "../base/logger";
 import { HEADER_NOT_FOUND_ERR_MESSAGE } from "./constant";
 import {
+  TRANSACTION_EXECUTION_ERROR,
   HEADER_NOT_FOUND_ERROR,
   INTERNAL_ERROR,
   INVALID_PARAMS,
   LIMIT_EXCEEDED,
   METHOD_NOT_SUPPORT,
   WEB3_ERROR,
 } from "./error-code";
+import { HexString } from "@ckb-lumos/base";
 
 export class RpcError extends Error implements JSONRPCError {
   code: number;
-  data?: object;
+  data?: any;
 
-  constructor(code: number, message: string, data?: object) {
+  constructor(code: number, message: string, data?: any) {
     super(message);
     this.name = "RpcError";
 
@@ -23,6 +25,16 @@ export class RpcError extends Error implements JSONRPCError {
   }
 }
 
+export function isRpcError(err: any): err is RpcError {
+  return err.name === "RpcError";
+}
+
+export class TransactionExecutionError extends RpcError {
+  constructor(message: string, data?: HexString) {
+    super(TRANSACTION_EXECUTION_ERROR, message, data);
+  }
+}
+
 export class Web3Error extends RpcError {
   constructor(message: string, data?: object) {
     super(WEB3_ERROR, message, data);