Added support for EventSupplierServiceConfigActivated to schema, mappings, and handlers to track supplier service activation events.

Author: Alann27

project.ts

@@ -332,6 +332,7 @@ const project: CosmosProject = {
             "EventSupplierStaked",
             "EventSupplierUnbondingBegin",
             "EventSupplierUnbondingEnd",
+            "EventSupplierServiceConfigActivated",
           ],
         },
       ],

schema.graphql

@@ -744,6 +744,16 @@ type SupplierServiceConfig @entity {
   service: Service!
   revShare: [SupplierRevShare]!
   endpoints: [SupplierEndpoint]!
+  # activation block per EventSupplierServiceConfigActivated event
+  activatedAt: Block
+  activatedEvent: EventSupplierServiceConfigActivated
+}
+
+type EventSupplierServiceConfigActivated @entity {
+  id: ID!
+  event: Event!
+  block: Block!
+  activatedServicesConfig: [SupplierServiceConfig] @derivedFrom(field: "activatedEvent")
 }
 
 type EventSupplierUnbondingBegin @entity {

src/mappings/handlers.ts

@@ -37,6 +37,7 @@ import {
 } from "./pocket/relays";
 import { handleEventRelayMiningDifficultyUpdated, handleMsgAddService } from "./pocket/services";
 import {
+  handleEventSupplierServiceConfigActivated,
   handleMsgClaimMorseSupplier,
   handleSupplierStakeMsg,
   handleSupplierUnbondingBeginEvent,
@@ -116,6 +117,7 @@ export const EventHandlers: Record<string, (events: Array<CosmosEvent>) => Promi
   "pocket.application.EventApplicationUnbondingBegin": handleApplicationUnbondingBeginEvent,
   "pocket.application.EventApplicationUnbondingEnd": handleApplicationUnbondingEndEvent,
   // supplier
+  "pocket.supplier.EventSupplierServiceConfigActivated": handleEventSupplierServiceConfigActivated,
   "pocket.supplier.EventSupplierUnbondingBegin": handleSupplierUnbondingBeginEvent,
   "pocket.supplier.EventSupplierUnbondingEnd": handleSupplierUnbondingEndEvent,
   // service

src/mappings/indexer.manager.ts

@@ -516,6 +516,7 @@ async function indexSupplier(msgByType: MessageByType, eventByType: EventByType)
   const eventTypes = [
     "pocket.supplier.EventSupplierUnbondingBegin",
     "pocket.supplier.EventSupplierUnbondingEnd",
+    "pocket.supplier.EventSupplierServiceConfigActivated",
     // this is here because it modifies the staked tokens of the supplier
     "pocket.tokenomics.EventSupplierSlashed"
   ];
@@ -541,6 +542,7 @@ async function indexSupplier(msgByType: MessageByType, eventByType: EventByType)
     "/pocket.migration.MsgClaimMorseSupplier": "shannonOperatorAddress",
     "pocket.supplier.EventSupplierUnbondingBegin": eventGetId,
     "pocket.supplier.EventSupplierUnbondingEnd": eventGetId,
+    "pocket.supplier.EventSupplierServiceConfigActivated": eventGetId,
     "pocket.tokenomics.EventSupplierSlashed": (attributes) => {
       for (const attribute of attributes) {
         // in the previous version of this event this is the key to get the supplierId
@@ -618,6 +620,11 @@ async function _indexingHandler(block: CosmosBlock): Promise<void> {
     if (isMessageType) {
       return false;
     }
+
+    if (evt.event.type === "tx") {
+      return false
+    }
+
     const hasValidAmount = hasValidAmountAttribute(evt);
 
     if (!hasValidAmount) {

src/mappings/pocket/suppliers.ts

@@ -17,6 +17,7 @@ import {
   SupplierServiceConfig,
   SupplierUnbondingReason,
   MorseSupplierClaimSignerType,
+  EventSupplierServiceConfigActivated,
 } from "../../types";
 import { MsgClaimMorseSupplierProps } from "../../types/models/MsgClaimMorseSupplier";
 import { MsgStakeSupplierServiceProps } from "../../types/models/MsgStakeSupplierService";
@@ -342,6 +343,52 @@ async function _handleUnstakeSupplierMsg(
   ]);
 }
 
+async function _handleEventSupplierServiceConfigActivated(
+  event: CosmosEvent,
+) {
+  let activationHeight: bigint | null = null, supplierSdk: SupplierSDKType | null = null;
+
+  for (const {key, value} of event.event.attributes) {
+    if (key === "activation_height") {
+      activationHeight = BigInt((value as string).replaceAll('"', ''));
+    }
+
+    if (key === "supplier") {
+      supplierSdk = JSON.parse(value as unknown as string);
+    }
+  }
+
+  if (!activationHeight) {
+    throw new Error(`[handleEventSupplierServiceConfigActivated] activation_height not found in event`);
+  }
+
+  if (!supplierSdk) {
+    throw new Error(`[handleEventSupplierServiceConfigActivated] supplier not found in event`);
+  }
+
+  const services = await fetchAllSupplierServiceConfigBySupplier(supplierSdk.operator_address);
+
+  const eventId = getEventId(event);
+
+  await Promise.all([
+    EventSupplierServiceConfigActivated.create({
+      id: eventId,
+      eventId: eventId,
+      blockId: getBlockId(event.block),
+    }).save(),
+    store.bulkUpdate(
+      "SupplierServiceConfig",
+      services
+        .filter((service) => !service.activatedAtId)
+        .map((service) => {
+          service.activatedAtId = activationHeight;
+          service.activatedEventId = eventId;
+          return service;
+      })
+    )
+  ])
+}
+
 async function _handleSupplierUnbondingBeginEvent(
   event: CosmosEvent,
 ) {
@@ -544,6 +591,12 @@ export async function handleUnstakeSupplierMsg(
   await Promise.all(messages.map(_handleUnstakeSupplierMsg));
 }
 
+export async function handleEventSupplierServiceConfigActivated(
+  events: Array<CosmosEvent>,
+): Promise<void> {
+  await Promise.all(events.map(_handleEventSupplierServiceConfigActivated));
+}
+
 export async function handleSupplierUnbondingBeginEvent(
   events: Array<CosmosEvent>,
 ): Promise<void> {