Skip to content

fix: optimize notification_log_wallet_address insert performance #1861

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
Gr1dlock merged 3 commits into from
Apr 9, 2026
Merged

fix: optimize notification_log_wallet_address insert performance #1861

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
37853df
fix: optimize notification_log_wallet_address insert performance
Gr1dlock Apr 9, 2026
4069008
style: fix prettier formatting
Gr1dlock Apr 9, 2026
6c69623
fix: use deterministic en locale for v2 notification log message
Gr1dlock Apr 9, 2026
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
69 changes: 41 additions & 28 deletions web/api/v2/minikit/send-notification/index.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,8 @@ type SendNotificationBodyV2 = yup.InferType<
typeof sendNotificationBodySchemaV2
>;

const WALLET_ADDRESS_BATCH_SIZE = 100;

export const logNotification = async (
serviceClient: GraphQLClient,
app_id: string,
Expand Down Expand Up @@ -77,12 +79,28 @@ export const logNotification = async (
return;
}

createNotificationLogSdk(serviceClient).CreateWalletAdressNotificationLogs({
objects: wallet_addresses.map((wallet_address) => ({
wallet_address,
notification_log_id: notificationLogId,
})),
});
const sdk = createNotificationLogSdk(serviceClient);

// Batch inserts to avoid oversized Hasura CTE queries
for (let i = 0; i < wallet_addresses.length; i += WALLET_ADDRESS_BATCH_SIZE) {
const batch = wallet_addresses.slice(i, i + WALLET_ADDRESS_BATCH_SIZE);

try {
await sdk.CreateWalletAdressNotificationLogs({
objects: batch.map((wallet_address) => ({
wallet_address,
notification_log_id: notificationLogId,
})),
});
} catch (error) {
logger.error("NotificationLog - failed to insert wallet address batch", {
app_id,
notificationLogId,
batchIndex: i,
error,
});
}
}
};

const getSchemaVersion = (body: object) => {
Expand Down Expand Up @@ -430,28 +448,23 @@ export const POST = async (req: NextRequest) => {
});
}
const response: SendNotificationResponse = data.result;
if (schemaVersion === "v1") {
logNotification(
serviceClient,
app_id,
wallet_addresses,
mini_app_path,
(parsedParams as SendNotificationBodyV1).message,
);
} else if (schemaVersion === "v2") {
const localisations = (parsedParams as SendNotificationBodyV2)
.localisations;

for (const localisation of localisations) {
logNotification(
serviceClient,
app_id,
wallet_addresses,
mini_app_path,
localisation.message,
);
}
}
const logMessage =
schemaVersion === "v1"
? (parsedParams as SendNotificationBodyV1).message
: (
(parsedParams as SendNotificationBodyV2).localisations?.find(
(l) => l.language === "en",
) ?? (parsedParams as SendNotificationBodyV2).localisations?.[0]
)?.message;

// Fire-and-forget: log wallet addresses once (not per localisation)
logNotification(
serviceClient,
app_id,
wallet_addresses,
mini_app_path,
logMessage,
);

return NextResponse.json({
success: true,
Expand Down
Loading