Improve log for entity history error

Author: DZakh

codegenerator/cli/npm/envio/src/PgStorage.res

@@ -418,8 +418,7 @@ let setEntityHistoryOrThrow = (
   ~shouldCopyCurrentEntity=?,
   ~shouldRemoveInvalidUtf8=false,
 ) => {
-  rows
-  ->Belt.Array.map(historyRow => {
+  rows->Belt.Array.map(historyRow => {
     let row = historyRow->S.reverseConvertToJsonOrThrow(entityHistory.schema)
     if shouldRemoveInvalidUtf8 {
       [row]->removeInvalidUtf8InPlace
@@ -435,10 +434,19 @@ let setEntityHistoryOrThrow = (
           !containsRollbackDiffChange
         }
       },
-    )
+    )->Promise.catch(exn => {
+      let reason = exn->Utils.prettifyExn
+      let detail = %raw(`reason?.detail || ""`)
+      raise(
+        Persistence.StorageError({
+          message: `Failed to insert history item into table "${entityHistory.table.tableName}".${detail !== ""
+              ? ` Details: ${detail}`
+              : ""}`,
+          reason,
+        }),
+      )
+    })
   })
-  ->Promise.all
-  ->(Utils.magic: promise<array<unit>> => promise<unit>)
 }
 
 type schemaTableName = {

codegenerator/cli/npm/envio/src/db/InternalTable.gen.ts

@@ -3,41 +3,41 @@
 /* eslint-disable */
 /* tslint:disable */
 
-import type { Json_t as Js_Json_t } from "../../src/Js.shim";
+import type {Json_t as Js_Json_t} from '../../src/Js.shim';
 
-import type { t as Address_t } from "../../src/Address.gen";
+import type {t as Address_t} from '../../src/Address.gen';
 
 export type EventSyncState_t = {
-  readonly chain_id: number;
-  readonly block_number: number;
-  readonly log_index: number;
-  readonly block_timestamp: number;
+  readonly chain_id: number; 
+  readonly block_number: number; 
+  readonly log_index: number; 
+  readonly block_timestamp: number
 };
 
 export type RawEvents_t = {
-  readonly chain_id: number;
-  readonly event_id: bigint;
-  readonly event_name: string;
-  readonly contract_name: string;
-  readonly block_number: number;
-  readonly log_index: number;
-  readonly src_address: Address_t;
-  readonly block_hash: string;
-  readonly block_timestamp: number;
-  readonly block_fields: Js_Json_t;
-  readonly transaction_fields: Js_Json_t;
-  readonly params: Js_Json_t;
+  readonly chain_id: number; 
+  readonly event_id: bigint; 
+  readonly event_name: string; 
+  readonly contract_name: string; 
+  readonly block_number: number; 
+  readonly log_index: number; 
+  readonly src_address: Address_t; 
+  readonly block_hash: string; 
+  readonly block_timestamp: number; 
+  readonly block_fields: Js_Json_t; 
+  readonly transaction_fields: Js_Json_t; 
+  readonly params: Js_Json_t
 };
 
 export type DynamicContractRegistry_t = {
-  readonly id: string;
-  readonly chain_id: number;
-  readonly registering_event_block_number: number;
-  readonly registering_event_log_index: number;
-  readonly registering_event_block_timestamp: number;
-  readonly registering_event_contract_name: string;
-  readonly registering_event_name: string;
-  readonly registering_event_src_address: Address_t;
-  readonly contract_address: Address_t;
-  readonly contract_name: string;
+  readonly id: string; 
+  readonly chain_id: number; 
+  readonly registering_event_block_number: number; 
+  readonly registering_event_log_index: number; 
+  readonly registering_event_block_timestamp: number; 
+  readonly registering_event_contract_name: string; 
+  readonly registering_event_name: string; 
+  readonly registering_event_src_address: Address_t; 
+  readonly contract_address: Address_t; 
+  readonly contract_name: string
 };

codegenerator/cli/templates/static/codegen/src/IO.res

@@ -136,13 +136,17 @@ let executeBatch = async (
     sql => {
       let promises = []
       if entityHistoryItemsToSet->Utils.Array.notEmpty {
-        promises->Array.push(
+        promises
+        ->Js.Array2.pushMany(
           sql->PgStorage.setEntityHistoryOrThrow(
             ~entityHistory=entityConfig.entityHistory,
-            ~rows=entityHistoryItemsToSet,
+            ~rows=entityHistoryItemsToSet->Array.concat([
+              entityHistoryItemsToSet->Js.Array2.unsafe_get(0),
+            ]),
             ~shouldRemoveInvalidUtf8,
           ),
         )
+        ->ignore
       }
       if entitiesToSet->Utils.Array.notEmpty {
         if shouldRemoveInvalidUtf8 {