Skip to content

Refactored some event handlers to match their changes #63

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
jorgecuesta merged 2 commits into from
Nov 27, 2025
Merged

Refactored some event handlers to match their changes #63

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
321254d
Refactored some event handlers of applications, gateways and supplier…
Alann27 Sep 25, 2025
ae86c68
Add logic to parse `application_address` attribute during Application…
Alann27 Oct 20, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
161 changes: 101 additions & 60 deletions src/mappings/pocket/applications.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -125,6 +125,10 @@ async function _stakeApplication<T extends StakeApplicationProps['serviceMsgIdKe
stakeStatus: StakeStatus.Staked,
transferringToId: prevApp?.transferringToId,
transferEndHeight: prevApp?.transferEndHeight,
unstakingBeginBlockId: undefined,
unstakingEndBlockId: undefined,
unstakingReason: undefined,
unstakingEndHeight: undefined,
};

// used to create the services that came in the stake message
Expand Down Expand Up @@ -204,7 +208,7 @@ async function _handleMsgClaimMorseApplication(
const msgId = messageId(msg);
const { shannonDestAddress, } = msg.msg.decodedMsg;

let stakeCoin: Coin | null = null, balanceCoin: Coin | null = null, app: ApplicationSDKType | null = null;
let stakeCoin: Coin | null = null, balanceCoin: Coin | null = null;

for (const event of msg.tx.tx.events) {
if (event.type === 'pocket.migration.EventMorseApplicationClaimed') {
Expand All @@ -226,10 +230,6 @@ async function _handleMsgClaimMorseApplication(
amount: coin.amount,
}
}

if (attribute.key === 'application') {
app = JSON.parse(attribute.value as string);
}
}
}
}
Expand All @@ -242,13 +242,7 @@ async function _handleMsgClaimMorseApplication(
throw new Error(`[handleMsgClaimMorseApplication] balance coin not found in event`);
}

if (!app) {
throw new Error(`[handleMsgClaimMorseApplication] app not found in event`);
}

if (!app.stake) {
throw new Error(`[handleMsgClaimMorseApplication] app stake not found in event`);
}
const app = await Application.get(msg.msg.decodedMsg.shannonDestAddress);

const stakeAmount = BigInt(stakeCoin.amount);
const stakeDenom = stakeCoin.denom;
Expand Down Expand Up @@ -283,8 +277,8 @@ async function _handleMsgClaimMorseApplication(
address: shannonDestAddress,
msgId,
services: [msg.msg.decodedMsg.serviceConfig!],
stakeAmount: BigInt(app.stake.amount),
stakeDenom: app.stake.denom,
stakeAmount: stakeAmount + BigInt(app?.stakeAmount?.toString() || "0"),
stakeDenom: stakeDenom,
serviceMsgIdKey: 'claimMsgId'
}),
];
Expand Down Expand Up @@ -430,7 +424,22 @@ async function _handleTransferApplicationBeginEvent(
async function _handleTransferApplicationEndEvent(
event: CosmosEvent,
) {
let sourceAddress = event.event.attributes.find(attribute => attribute.key === "source_address")?.value as unknown as string;
let sourceAddress: string | undefined, destinationAppAddress: string | undefined

for (const attribute of event.event.attributes) {
if (attribute.key === "source_address") {
sourceAddress = (attribute.value as string).replaceAll("\"", "");
}

if (attribute.key === "destination_address") {
destinationAppAddress = (attribute.value as string).replaceAll("\"", "");
}

// Older versions of this event included the whole destination application
if (attribute.key === "destination_application") {
destinationAppAddress = (JSON.parse(attribute.value as string) as ApplicationSDKType).address;
}
}

if (!sourceAddress) {
throw new Error(`[handleTransferApplicationEndEvent] event.event.attributes not found`);
Expand All @@ -439,7 +448,27 @@ async function _handleTransferApplicationEndEvent(
// the source address is surrounded by quotes
sourceAddress = sourceAddress.replaceAll("\"", "");

const sourceApplication = await Application.get(sourceAddress);
if (!destinationAppAddress) {
throw new Error(`[handleTransferApplicationMsg] destination application not in event`);
}

destinationAppAddress = destinationAppAddress.replaceAll("\"", "");

const results = await Promise.all([
Application.get(sourceAddress),
Application.get(destinationAppAddress),
fetchAllApplicationServiceByApplicationId(sourceAddress),
fetchAllApplicationGatewayByApplicationId(sourceAddress),
])

const [
sourceApplication,
,
sourceApplicationServices,
sourceApplicationGateways,
] = results;

let destinationApplication = results[1]

if (!sourceApplication) {
throw new Error(`[handleTransferApplicationMsg] source application not found for address ${sourceAddress}`);
Expand All @@ -452,44 +481,42 @@ async function _handleTransferApplicationEndEvent(
sourceApplication.stakeStatus = StakeStatus.Unstaked;
sourceApplication.unstakingReason = ApplicationUnbondingReason.TRANSFER;
sourceApplication.unstakingEndBlockId = getBlockId(event.block);

const destinationAppStringified = event.event.attributes.find(attribute => attribute.key === "destination_application")?.value as string;

if (!destinationAppStringified) {
throw new Error(`[handleTransferApplicationMsg] destination application not in event`);
}

const destinationApp: Required<ApplicationSDKType> = JSON.parse(destinationAppStringified);

sourceApplication.destinationApplicationId = destinationApp.address;

const { delegatee_gateway_addresses, service_configs } = destinationApp;
const stake = destinationApp.stake as Required<typeof destinationApp.stake>;

const destinationApplication = Application.create({
id: destinationApp.address,
accountId: destinationApp.address,
stakeAmount: BigInt(stake.amount),
stakeDenom: stake.denom,
stakeStatus: StakeStatus.Staked,
sourceApplicationId: sourceAddress,
transferredFromAtId: getBlockId(event.block),
unstakingEndBlockId: prevUnstakingEndBlockId,
unstakingBeginBlockId: sourceApplication.unstakingBeginBlockId,
});

const appDelegatedToGateways: Array<ApplicationGatewayProps> = delegatee_gateway_addresses.map(gateway => ({
id: getAppDelegatedToGatewayId(destinationApplication.id, gateway),
sourceApplication.destinationApplicationId = destinationAppAddress;

if (destinationApplication && destinationApplication.stakeStatus === StakeStatus.Staked) {
destinationApplication.stakeAmount = sourceApplication.stakeAmount.valueOf() + destinationApplication.stakeAmount.valueOf();
} else {
destinationApplication = Application.create({
id: destinationAppAddress,
accountId: destinationAppAddress,
stakeAmount: sourceApplication.stakeAmount.valueOf(),
stakeDenom: sourceApplication.stakeDenom,
stakeStatus: StakeStatus.Staked,
unstakingEndHeight: undefined,
unstakingReason: undefined,
unstakingEndBlockId: undefined,
unstakingBeginBlockId: undefined,
})
}

destinationApplication.sourceApplicationId = sourceAddress
destinationApplication.transferredFromAtId = getBlockId(event.block)
destinationApplication.unstakingBeginBlockId = sourceApplication.unstakingBeginBlockId
destinationApplication.unstakingEndBlockId = destinationApplication.unstakingEndBlockId ?
destinationApplication.unstakingEndBlockId :
prevUnstakingEndBlockId

const appDelegatedToGateways: Array<ApplicationGatewayProps> = sourceApplicationGateways.map(gateway => ({
id: getAppDelegatedToGatewayId(destinationApplication.id, gateway.gatewayId),
applicationId: destinationApplication.id,
gatewayId: gateway,
gatewayId: gateway.gatewayId,
}));

const sourceApplicationServices = await fetchAllApplicationServiceByApplicationId(sourceAddress);
const sourceApplicationGateways = await fetchAllApplicationGatewayByApplicationId(sourceAddress);
const newApplicationServices: Array<ApplicationServiceProps> = service_configs?.map(service => ({
id: getStakeServiceId(destinationApp.address, service.service_id),
serviceId: service.service_id,
applicationId: destinationApp.address,

const newApplicationServices: Array<ApplicationServiceProps> = sourceApplicationServices.map(service => ({
id: getStakeServiceId(destinationApplication.id, service.serviceId),
serviceId: service.serviceId,
applicationId: destinationApplication.id,
})) || [];

const eventId = getEventId(event);
Expand All @@ -500,7 +527,7 @@ async function _handleTransferApplicationEndEvent(
EventTransferEndEntity.create({
id: eventId,
sourceId: sourceAddress,
destinationId: destinationApp.address,
destinationId: destinationApplication.id,
blockId: getBlockId(event.block),
eventId,
}).save(),
Expand All @@ -525,6 +552,11 @@ async function _handleTransferApplicationErrorEvent(
destinationAddress = (attribute.value as unknown as string).replaceAll("\"", "");
}

// Older versions of this event included the whole destination application
if (attribute.key === "destination_application") {
destinationAddress = (JSON.parse(attribute.value as string) as ApplicationSDKType).address;
}

if (attribute.key === "error") {
error = (attribute.value as unknown as string).replaceAll("\"", "");
}
Expand Down Expand Up @@ -620,6 +652,10 @@ async function _handleApplicationUnbondingBeginEvent(
reason = applicationUnbondingReasonFromJSON((attribute.value as unknown as string).replaceAll("\"", ""));
}

if (!msg && attribute.key === "application_address") {
address = (attribute.value as string).replaceAll("\"", "")
}

if (!msg && attribute.key === "application") {
// now this is a block event?
const application: ApplicationSDKType = parseJson(attribute.value as unknown as string);
Expand Down Expand Up @@ -673,7 +709,7 @@ async function _handleApplicationUnbondingEndEvent(
event: CosmosEvent,
) {
let unstakingEndHeight = BigInt(0), sessionEndHeight = BigInt(0), reason: number | null = null,
applicationSdk: ApplicationSDKType | undefined;
applicationAddress: string | undefined;

for (const attribute of event.event.attributes) {
if (attribute.key === "unbonding_end_height") {
Expand All @@ -688,8 +724,13 @@ async function _handleApplicationUnbondingEndEvent(
reason = applicationUnbondingReasonFromJSON((attribute.value as unknown as string).replaceAll("\"", ""));
}

if (attribute.key === "application_address") {
applicationAddress = (attribute.value as string).replaceAll("\"", "")
}

// Older versions of this event included the whole application
if (attribute.key === "application") {
applicationSdk = JSON.parse(attribute.value as unknown as string);
applicationAddress = (JSON.parse(attribute.value as unknown as string) as ApplicationSDKType).address;
}
}

Expand All @@ -705,21 +746,21 @@ async function _handleApplicationUnbondingEndEvent(
throw new Error(`[handleApplicationUnbondingEndEvent] reason not found in event`);
}

if (!applicationSdk) {
throw new Error(`[handleApplicationUnbondingEndEvent] application not found in event`);
if (!applicationAddress) {
throw new Error(`[handleApplicationUnbondingEndEvent] applicationAddress not found in event`);
}

const application = await Application.get(applicationSdk.address);
const application = await Application.get(applicationAddress);

if (!application) {
throw new Error(`[handleApplicationUnbondingEndEvent] application not found for address ${applicationSdk.address}`);
throw new Error(`[handleApplicationUnbondingEndEvent] application not found for address ${applicationAddress}`);
}

application.unstakingEndBlockId = getBlockId(event.block);
application.stakeStatus = StakeStatus.Unstaked;
application.unstakingReason = getAppUnbondingReasonFromSDK(reason);

const applicationServices = (await fetchAllApplicationServiceByApplicationId(applicationSdk.address)).map(item => item.id);
const applicationServices = (await fetchAllApplicationServiceByApplicationId(applicationAddress)).map(item => item.id);

const eventId = getEventId(event);

Expand All @@ -730,7 +771,7 @@ async function _handleApplicationUnbondingEndEvent(
sessionEndHeight,
unstakingEndHeight,
reason,
applicationId: applicationSdk.address,
applicationId: applicationAddress,
eventId,
}).save(),
application.save(),
Expand Down
39 changes: 26 additions & 13 deletions src/mappings/pocket/gateways.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,9 @@ async function _handleGatewayMsgStake(
stakeDenom: stake.denom,
accountId: msg.msg.decodedMsg.address,
stakeStatus: StakeStatus.Staked,
unstakingEndHeight: undefined,
unstakingEndBlockId: undefined,
unstakingBeginBlockId: undefined,
});

const msgId = messageId(msg);
Expand Down Expand Up @@ -143,7 +146,7 @@ async function _handleGatewayUnstakeEvent(
}

async function _handleEventGatewayUnbondingBegin(event: CosmosEvent) {
let unstakingEndHeight: bigint | null = null, sessionEndHeight: bigint | null = null, gatewaySdk: GatewaySDKType | null = null;
let unstakingEndHeight: bigint | null = null, sessionEndHeight: bigint | null = null, gatewayAddress: string | null = null;

for (const attribute of event.event.attributes) {
if (attribute.key === "unbonding_end_height") {
Expand All @@ -154,8 +157,13 @@ async function _handleEventGatewayUnbondingBegin(event: CosmosEvent) {
sessionEndHeight = BigInt((attribute.value as unknown as string).replaceAll("\"", ""));
}

if (attribute.key === "gateway_address") {
gatewayAddress = (attribute.value as string).replaceAll("\"", "");
}

// older versions of this event included this attribute
if (attribute.key === "gateway") {
gatewaySdk = JSON.parse(attribute.value as unknown as string);
gatewayAddress = (JSON.parse(attribute.value as string) as GatewaySDKType).address;
}
}

Expand All @@ -167,14 +175,14 @@ async function _handleEventGatewayUnbondingBegin(event: CosmosEvent) {
throw new Error(`[handleEventGatewayUnbondingBegin] sessionEndHeight not found in event`);
}

if (!gatewaySdk) {
throw new Error(`[handleEventGatewayUnbondingBegin] gateway not found in event`);
if (!gatewayAddress) {
throw new Error(`[handleEventGatewayUnbondingBegin] gatewayAddress not found in event`);
}

const gateway = await Gateway.get(gatewaySdk.address);
const gateway = await Gateway.get(gatewayAddress);

if (!gateway) {
throw new Error(`[handleEventGatewayUnbondingBegin] gateway not found for address ${gatewaySdk.address}`);
throw new Error(`[handleEventGatewayUnbondingBegin] gateway not found for address ${gatewayAddress}`);
}

gateway.unstakingEndHeight = unstakingEndHeight;
Expand All @@ -196,7 +204,7 @@ async function _handleEventGatewayUnbondingBegin(event: CosmosEvent) {
}

async function _handleEventGatewayUnbondingEnd(event: CosmosEvent) {
let unstakingEndHeight: bigint | null = null, sessionEndHeight: bigint | null = null, gatewaySdk: GatewaySDKType | null = null;
let unstakingEndHeight: bigint | null = null, sessionEndHeight: bigint | null = null, gatewayAddress: string | null = null;

for (const attribute of event.event.attributes) {
if (attribute.key === "unbonding_end_height") {
Expand All @@ -207,8 +215,13 @@ async function _handleEventGatewayUnbondingEnd(event: CosmosEvent) {
sessionEndHeight = BigInt((attribute.value as unknown as string).replaceAll("\"", ""));
}

if (attribute.key === "gateway_address") {
gatewayAddress = (attribute.value as string).replaceAll("\"", "");
}

// older versions of this event included this attribute
if (attribute.key === "gateway") {
gatewaySdk = JSON.parse(attribute.value as unknown as string);
gatewayAddress = (JSON.parse(attribute.value as string) as GatewaySDKType).address;
}
}

Expand All @@ -220,17 +233,17 @@ async function _handleEventGatewayUnbondingEnd(event: CosmosEvent) {
throw new Error(`[handleEventGatewayUnbondingEnd] sessionEndHeight not found in event`);
}

if (!gatewaySdk) {
throw new Error(`[handleEventGatewayUnbondingEnd] gateway not found in event`);
if (!gatewayAddress) {
throw new Error(`[handleEventGatewayUnbondingEnd] gatewayAddress not found in event`);
}

const [gateway, undelegates] = await Promise.all([
Gateway.get(gatewaySdk.address),
getUndelegatesForUnstakedGateway(gatewaySdk.address)
Gateway.get(gatewayAddress),
getUndelegatesForUnstakedGateway(gatewayAddress)
]);

if (!gateway) {
throw new Error(`[handleEventGatewayUnbondingEnd] gateway not found for address ${gatewaySdk.address}`);
throw new Error(`[handleEventGatewayUnbondingEnd] gateway not found for address ${gatewayAddress}`);
}

gateway.unstakingEndBlockId = unstakingEndHeight;
Expand Down
Loading