mirror/ditto
mirror/ditto
1
0
Fork 0
mirror of https://gitlab.com/soapbox-pub/ditto.git synced 2025-12-06 11:29:46 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

checkpoint: handleEvent7 function uses raw SQL directly (temporarily) to update reactions

Browse source
This commit is contained in:
P. Reis 2024-12-28 19:56:07 -03:00
parent 51fc0c9cc9
commit aae00cdc10
1 changed files with 14 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

35
src/utils/stats.ts
View file

@ -1,5 +1,5 @@
import { NostrEvent, NSchema as n, NStore } from '@nostrify/nostrify';
import { Kysely, UpdateObject } from 'kysely';
import { Kysely, sql, UpdateObject } from 'kysely';
import { SetRequired } from 'type-fest';
import { z } from 'zod';
@ -107,30 +107,23 @@ async function handleEvent6(kysely: Kysely<DittoTables>, event: NostrEvent, x: n
/** Update stats for kind 7 event. */
async function handleEvent7(kysely: Kysely<DittoTables>, event: NostrEvent, x: number): Promise<void> {
const id = event.tags.findLast(([name]) => name === 'e')?.[1];
// the '+' and '-' signs are considered emojis
const emoji = event.content;
if (id && emoji && (['+', '-'].includes(emoji) || /^\p{RGI_Emoji}$/v.test(emoji))) {
await updateEventStats(kysely, id, ({ reactions }) => {
const data: Record<string, number> = JSON.parse(reactions);
const baka = await sql`
UPDATE event_stats
SET reactions = jsonb_set(
reactions::jsonb,
ARRAY[${emoji}],
CASE WHEN reactions::jsonb->${emoji} IS NULL THEN ${x}
ELSE to_jsonb((reactions::jsonb->${emoji})::int + ${x}::int)
END
)
WHERE event_id = ${id}`
.execute(kysely);
// Increment or decrement the emoji count.
data[emoji] = (data[emoji] ?? 0) + x;
// Remove reactions with a count of 0 or less.
for (const key of Object.keys(data)) {
if (data[key] < 1) {
delete data[key];
}
}
// Total reactions count.
const count = Object.values(data).reduce((result, value) => result + value, 0);
return {
reactions: JSON.stringify(data),
reactions_count: count,
};
});
console.log(baka);
}
}