mirror of
https://gitlab.com/soapbox-pub/ditto.git
synced 2025-12-06 11:29:46 +00:00
webpush: fix query error in pipeline
This commit is contained in:
parent
94d8d43d78
commit
30a5d9a20f
1 changed files with 6 additions and 1 deletions
|
|
@ -239,11 +239,16 @@ async function webPush(event: NostrEvent): Promise<void> {
|
||||||
}
|
}
|
||||||
|
|
||||||
const kysely = await Storages.kysely();
|
const kysely = await Storages.kysely();
|
||||||
|
const pubkeys = getTagSet(event.tags, 'p');
|
||||||
|
|
||||||
|
if (!pubkeys.size) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
const rows = await kysely
|
const rows = await kysely
|
||||||
.selectFrom('push_subscriptions')
|
.selectFrom('push_subscriptions')
|
||||||
.selectAll()
|
.selectAll()
|
||||||
.where('pubkey', 'in', [...getTagSet(event.tags, 'p')])
|
.where('pubkey', 'in', [...pubkeys])
|
||||||
.execute();
|
.execute();
|
||||||
|
|
||||||
for (const row of rows) {
|
for (const row of rows) {
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue