moon
/
ditto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refactor: undo repost counter in getStatsDiff

This commit is contained in:
P. Reis 2024-04-11 09:53:24 -03:00
parent cdb0d817ed
commit 3ebcf7ea25
1 changed files with 12 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/stats.ts
View File

@ -1,5 +1,5 @@
import { type AuthorStatsRow, db, type DittoDB, type EventStatsRow } from '@/db.ts'; import { type AuthorStatsRow, db, type DittoDB, type EventStatsRow } from '@/db.ts';
import { Debug, type InsertQueryBuilder, type NostrEvent, NostrFilter } from '@/deps.ts'; import { Debug, type InsertQueryBuilder, type NostrEvent } from '@/deps.ts';
import { eventsDB } from '@/storages.ts'; import { eventsDB } from '@/storages.ts';
import { findReplyTag } from '@/tags.ts'; import { findReplyTag } from '@/tags.ts';
@ -61,28 +61,22 @@ async function getStatsDiff(event: NostrEvent, prev: NostrEvent | undefined): Pr
case 5: { case 5: {
if (!firstTaggedId) break; if (!firstTaggedId) break;
let filters: NostrFilter[] = [{ kinds: [6], ids: [firstTaggedId], authors: [event.pubkey] }]; const [repostedEvent] = await eventsDB.query(
const [repostedEvent] = await eventsDB.query(filters, { limit: 1 }); [{ kinds: [6], ids: [firstTaggedId], authors: [event.pubkey] }],
{ limit: 1 },
);
// Check if the event being deleted is of kind 6, // Check if the event being deleted is of kind 6,
// if it is then proceed, else just break // if it is then proceed, else just break
if (!repostedEvent) break; if (!repostedEvent) break;
let eventBeingRepostedPubkey = ''; const eventBeingRepostedId = repostedEvent.tags.find(([name]) => name === 'e')?.[1];
let eventBeingRepostedId = ''; const eventBeingRepostedPubkey = repostedEvent.tags.find(([name]) => name === 'p')?.[1];
if (!eventBeingRepostedId || !eventBeingRepostedPubkey) break;
for (const tag of repostedEvent.tags) { const [eventBeingReposted] = await eventsDB.query(
switch (tag[0]) { [{ kinds: [1], ids: [eventBeingRepostedId], authors: [eventBeingRepostedPubkey] }],
case 'e': { limit: 1 },
eventBeingRepostedId = tag[1]; );
break;
case 'p':
eventBeingRepostedPubkey = tag[1];
break;
}
}
filters = [{ kinds: [1], ids: [eventBeingRepostedId], authors: [eventBeingRepostedPubkey] }];
const [eventBeingReposted] = await eventsDB.query(filters, { limit: 1 });
if (!eventBeingReposted) break; if (!eventBeingReposted) break;
statDiffs.push(['event_stats', eventBeingRepostedId, 'reposts_count', -1]); statDiffs.push(['event_stats', eventBeingRepostedId, 'reposts_count', -1]);