Kieran/snort
5
14
Fork 14
Code Issues 37 Pull Requests 1 Packages Projects Releases 24 Wiki Activity

common like counts in scoring
Some checks are pending
continuous-integration/drone/push Build is running
Details

Browse Source
This commit is contained in:
Martti Malmi 2024-02-03 14:55:18 +02:00
parent 4dff677809
commit 2ab7e63e55
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
packages/app/src/Db/getForYouFeed.ts
View File

@ -49,7 +49,7 @@ async function getMyReactedEventIds(pubkey: string) {
} }
async function getOthersWhoReacted(myReactedEventIds: Set<string>, myPubkey: string) { async function getOthersWhoReacted(myReactedEventIds: Set<string>, myPubkey: string) {
const othersWhoReacted = new Set<string>(); const othersWhoReacted = new Map<string, number>();
const otherReactions = await Relay.query([ const otherReactions = await Relay.query([
"REQ", "REQ",
@ -61,21 +61,21 @@ async function getOthersWhoReacted(myReactedEventIds: Set<string>, myPubkey: str
otherReactions.forEach(reaction => { otherReactions.forEach(reaction => {
if (reaction.pubkey !== myPubkey) { if (reaction.pubkey !== myPubkey) {
othersWhoReacted.add(reaction.pubkey); othersWhoReacted.set(reaction.pubkey, (othersWhoReacted.get(reaction.pubkey) || 0) + 1);
} }
}); });
return [...othersWhoReacted]; return othersWhoReacted;
} }
async function getEventIdsReactedByOthers(othersWhoReacted: string[], myReactedEvents: Set<string>, myPub: string) { async function getEventIdsReactedByOthers(othersWhoReacted: Map<string, number>, myReactedEvents: Set<string>, myPub: string) {
const eventIdsReactedByOthers = new Map<string, number>(); const eventIdsReactedByOthers = new Map<string, number>();
const events = await Relay.query([ const events = await Relay.query([
"REQ", "REQ",
"getEventIdsReactedByOthers", "getEventIdsReactedByOthers",
{ {
authors: othersWhoReacted, authors: [...othersWhoReacted.keys()],
kinds: [1, 6, 7, 9735], kinds: [1, 6, 7, 9735],
}, },
]); ]);
@ -87,7 +87,8 @@ async function getEventIdsReactedByOthers(othersWhoReacted: string[], myReactedE
} }
event.tags.forEach(tag => { event.tags.forEach(tag => {
if (tag[0] === "e") { if (tag[0] === "e") {
eventIdsReactedByOthers.set(tag[1], (eventIdsReactedByOthers.get(tag[1]) || 0) + 1); const score = Math.ceil(Math.sqrt(othersWhoReacted.get(event.pubkey) || 0));
eventIdsReactedByOthers.set(tag[1], (eventIdsReactedByOthers.get(tag[1]) || 0) + score);
} }
}); });
}); });