query node - working group leader set event removal

query-node/generated/types/gateway-working-group.ts

@@ -207,45 +207,6 @@ export namespace GatewayWorkingGroup {
       );
     }
   }
-  /**
-   *  Emits on setting the leader.
-   *  Params:
-   *  - Worker id.
-   *
-   *  Event parameters: [WorkerId, ]
-   */
-  export class LeaderSetEvent {
-    public readonly expectedParamTypes = ["WorkerId"];
-
-    constructor(public readonly ctx: SubstrateEvent) {}
-
-    get data(): LeaderSet_Params {
-      return new LeaderSet_Params(this.ctx);
-    }
-
-    validateParams(): boolean {
-      if (this.expectedParamTypes.length !== this.ctx.params.length) {
-        return false;
-      }
-      let valid = true;
-      this.expectedParamTypes.forEach((type, i) => {
-        if (type !== this.ctx.params[i].type) {
-          valid = false;
-        }
-      });
-      return valid;
-    }
-  }
-
-  class LeaderSet_Params {
-    constructor(public readonly ctx: SubstrateEvent) {}
-
-    get workerId(): WorkerId {
-      return createTypeUnsafe<WorkerId & Codec>(typeRegistry, "WorkerId", [
-        this.ctx.params[0].value,
-      ]);
-    }
-  }
   /**
    *  Emits on terminating the leader.
    *  Params:

query-node/generated/types/storage-working-group.ts

@@ -207,45 +207,6 @@ export namespace StorageWorkingGroup {
       );
     }
   }
-  /**
-   *  Emits on setting the leader.
-   *  Params:
-   *  - Worker id.
-   *
-   *  Event parameters: [WorkerId, ]
-   */
-  export class LeaderSetEvent {
-    public readonly expectedParamTypes = ["WorkerId"];
-
-    constructor(public readonly ctx: SubstrateEvent) {}
-
-    get data(): LeaderSet_Params {
-      return new LeaderSet_Params(this.ctx);
-    }
-
-    validateParams(): boolean {
-      if (this.expectedParamTypes.length !== this.ctx.params.length) {
-        return false;
-      }
-      let valid = true;
-      this.expectedParamTypes.forEach((type, i) => {
-        if (type !== this.ctx.params[i].type) {
-          valid = false;
-        }
-      });
-      return valid;
-    }
-  }
-
-  class LeaderSet_Params {
-    constructor(public readonly ctx: SubstrateEvent) {}
-
-    get workerId(): WorkerId {
-      return createTypeUnsafe<WorkerId & Codec>(typeRegistry, "WorkerId", [
-        this.ctx.params[0].value,
-      ]);
-    }
-  }
   /**
    *  Emits on terminating the leader.
    *  Params:

query-node/manifest.yml

@@ -58,16 +58,12 @@ typegen:
     - storage_working_group.OpeningFilled
     - storage_working_group.TerminatedWorker
     - storage_working_group.WorkerExited
-    - storage_working_group.LeaderSet
-    # - storage_working_group.LeaderUnset # not needed as long as Leader vs Worker distinction is not needed
     - storage_working_group.TerminatedLeader
 
     - gateway_working_group.WorkerStorageUpdated
     - gateway_working_group.OpeningFilled
     - gateway_working_group.TerminatedWorker
     - gateway_working_group.WorkerExited
-    - gateway_working_group.LeaderSet
-    # - gateway_working_group.LeaderUnset # not needed as long as Leader vs Worker distinction is not needed
     - gateway_working_group.TerminatedLeader
   calls:
     # members
@@ -219,8 +215,6 @@ mappings:
       handler: storageWorkingGroup_WorkerExited(DatabaseManager, SubstrateEvent)
 
     ## storage - leader
-    - event: storageWorkingGroup.LeaderSet
-      handler: storageWorkingGroup_LeaderSet(DatabaseManager, SubstrateEvent)
     - event: storageWorkingGroup.TerminatedLeader
       handler: storageWorkingGroup_TerminatedLeader(DatabaseManager, SubstrateEvent)
 
@@ -235,8 +229,6 @@ mappings:
       handler: gatewayWorkingGroup_WorkerExited(DatabaseManager, SubstrateEvent)
 
     ## gateway - leader
-    - event: gatewayWorkingGroup.LeaderSet
-      handler: gatewayWorkingGroup_LeaderSet(DatabaseManager, SubstrateEvent)
     - event: gatewayWorkingGroup.TerminatedLeader
       handler: gatewayWorkingGroup_TerminatedLeader(DatabaseManager, SubstrateEvent)
 

query-node/mappings/src/workingGroup.ts

@@ -57,14 +57,6 @@ export async function storageWorkingGroup_WorkerExited(db: DatabaseManager, even
   await workingGroup_WorkerExited(db, WorkerType.STORAGE, workerId)
 }
 
-export async function storageWorkingGroup_LeaderSet(db: DatabaseManager, event: SubstrateEvent): Promise<void> {
-  // read event data
-  const {workerId} = new StorageWorkingGroup.LeaderSetEvent(event).data
-
-  // call generic processing
-  await workingGroup_LeaderSet(db, WorkerType.STORAGE, workerId)
-}
-
 export async function storageWorkingGroup_TerminatedLeader(db: DatabaseManager, event: SubstrateEvent): Promise<void> {
   // read event data
   const {workerId} = new StorageWorkingGroup.TerminatedLeaderEvent(event).data
@@ -107,14 +99,6 @@ export async function gatewayWorkingGroup_WorkerExited(db: DatabaseManager, even
   await workingGroup_WorkerExited(db, WorkerType.GATEWAY, workerId)
 }
 
-export async function gatewayWorkingGroup_LeaderSet(db: DatabaseManager, event: SubstrateEvent): Promise<void> {
-  // read event data
-  const {workerId} = new GatewayWorkingGroup.LeaderSetEvent(event).data
-
-  // call generic processing
-  await workingGroup_LeaderSet(db, WorkerType.GATEWAY, workerId)
-}
-
 export async function gatewayWorkingGroup_TerminatedLeader(db: DatabaseManager, event: SubstrateEvent): Promise<void> {
   // read event data
   const {workerId} = new GatewayWorkingGroup.TerminatedLeaderEvent(event).data
@@ -178,14 +162,6 @@ export async function workingGroup_WorkerExited(db: DatabaseManager, workerType:
   logger.info("Worker has been removed (worker exited)", {workerId, workerType})
 }
 
-export async function workingGroup_LeaderSet(db: DatabaseManager, workerType: WorkerType, workerId: WorkerId): Promise<void> {
-  // create leader (worker)
-  await createWorker(db, workerId, workerType)
-
-  // emit log event
-  logger.info("Working group leader has been removed (worker exited)", {workerId, workerType})
-}
-
 export async function workingGroup_TerminatedLeader(db: DatabaseManager, workerType: WorkerType, workerId: WorkerId): Promise<void> {
   // do removal logic
   await deactivateWorker(db, workerType, workerId)