* Removed commented code un schema.graphql

* Created stake.ts file in types directory
* Throwing error when the transaction fails in `optimizedBulkCreate`

Author: Alann27

schema.graphql

@@ -758,14 +758,6 @@ type EventRelayMiningDifficultyUpdated @entity {
   event: Event!
 }
 
-#message EventRelayMiningDifficultyUpdated {
-#    string service_id = 1;
-#    string prev_target_hash_hex_encoded = 2;
-#    string new_target_hash_hex_encoded = 3;
-#    uint64 prev_num_relays_ema = 4;
-#    uint64 new_num_relays_ema = 5;
-#}
-
 type Gateway @entity {
   # id is the address of the gateway
   id: ID!

src/mappings/indexer.manager.ts

@@ -35,6 +35,7 @@ import {
   EventByType,
   MessageByType,
 } from "./types/common";
+import { GetIdFromEventAttribute, RecordGetId } from "./types/stake";
 import { optimizedBulkCreate } from "./utils/db";
 import { getBlockId } from "./utils/ids";
 import { stringify } from "./utils/json";
@@ -366,7 +367,6 @@ function groupConnectedComponents(arrays: string[][]): string[][] {
   return result;
 }
 
-type GetIdFromEventAttribute = (attributes: CosmosEvent["event"]["attributes"]) => string | Array<string>;
 
 /*
 This function is used to call handlers in order to avoid updating the same entity twice or more at the same time
@@ -375,7 +375,7 @@ This function is used to call handlers in order to avoid updating the same entit
     for messages it is the path of the decodedMsg to get the entity id
     for events it is a function that receives the attributes and returns the entity id
 */
-async function indexStakeEntity(data: Array<CosmosEvent | CosmosMessage>, getEntityIdArg: Record<string, string | GetIdFromEventAttribute>) {
+async function indexStakeEntity(data: Array<CosmosEvent | CosmosMessage>, getEntityIdArg: RecordGetId) {
   // this is to handle events where more than one stake entity is updated
   // like in _handleTransferApplicationEndEvent handler
   const entitiesUpdatedAtSameDatum: Array<Array<string>> = [];

src/mappings/types/stake.ts

@@ -0,0 +1,5 @@
+import { CosmosEvent } from "@subql/types-cosmos";
+
+export type GetIdFromEventAttribute = (attributes: CosmosEvent["event"]["attributes"]) => string | Array<string>;
+
+export type RecordGetId = Record<string, string | GetIdFromEventAttribute>

src/mappings/utils/db.ts

@@ -156,8 +156,9 @@ export async function optimizedBulkCreate(modelName: string, docs: Array<any>, t
       });
 
       await transaction.commit()
-    } catch {
+    } catch (e) {
       await transaction.rollback()
+      throw e
     }
 
     // Update and log progress after successful batch creation