bytelyst/learning_ai_clock
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(backend): replace $contains with post-filter for webhook events array query

Browse Source 
$contains generates CONTAINS() SQL in Cosmos (string match), not
ARRAY_CONTAINS() needed for string[] fields. Use findMany + in-memory
post-filter for correct behavior across both providers.
This commit is contained in:
saravanakumardb1 2026-03-02 01:49:18 -08:00
parent 8731cf38fd
commit 4cb5d3e627
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
backend/src/modules/webhooks/repository.ts
View File

@ -96,10 +96,12 @@ export async function findSubscriptionsForEvent(
productId: string, productId: string,
eventType: WebhookEventType eventType: WebhookEventType
): Promise<WebhookSubscriptionDoc[]> { ): Promise<WebhookSubscriptionDoc[]> {
// events is a string[] — $contains works for primitive arrays in memory provider // $contains generates CONTAINS() SQL (string match) in Cosmos, not ARRAY_CONTAINS().
return subsCollection().findMany({ // Use findMany + post-filter for correct behavior across both providers.
filter: { userId, productId, active: true, events: { $contains: eventType } }, const subs = await subsCollection().findMany({
filter: { userId, productId, active: true },
}); });
return subs.filter(s => s.events.includes(eventType));
} }
// ── Increment Failure Count ─────────────────────────────────── // ── Increment Failure Count ───────────────────────────────────