alex/snort3
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

use queueMicrotask instead of setTimeout 0

Browse Source
This commit is contained in:
Martti Malmi 2024-01-09 14:56:20 +02:00
parent 8216cb8741
commit 3eeeee4b06
2 changed files with 3 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
packages/app/src/Db/FuzzySearch.ts
View File

@ -20,7 +20,7 @@ export const addEventToFuzzySearch = ev => {
if (ev.kind !== 0) { if (ev.kind !== 0) {
return; return;
} }
setTimeout(() => { queueMicrotask(() => {
const existing = profileTimestamps.get(ev.pubkey); const existing = profileTimestamps.get(ev.pubkey);
if (existing) { if (existing) {
if (existing > ev.created_at) { if (existing > ev.created_at) {
@ -42,7 +42,7 @@ export const addEventToFuzzySearch = ev => {
}; };
export const addCachedMetadataToFuzzySearch = (profile: CachedMetadata) => { export const addCachedMetadataToFuzzySearch = (profile: CachedMetadata) => {
setTimeout(() => { queueMicrotask(() => {
const existing = profileTimestamps.get(profile.pubkey); const existing = profileTimestamps.get(profile.pubkey);
if (existing) { if (existing) {
if (existing > profile.created) { if (existing > profile.created) {

20
packages/system/src/SocialGraph/SocialGraph.ts
View File

@ -51,7 +51,7 @@ export default class SocialGraph {
if (event.kind !== 3) { if (event.kind !== 3) {
return; return;
} }
setTimeout(() => { queueMicrotask(() => {
try { try {
const author = ID(event.pubkey); const author = ID(event.pubkey);
const timestamp = event.created_at; const timestamp = event.created_at;
@ -116,15 +116,6 @@ export default class SocialGraph {
if (!this.usersByFollowDistance.has(distance)) { if (!this.usersByFollowDistance.has(distance)) {
this.usersByFollowDistance.set(distance, new Set()); this.usersByFollowDistance.set(distance, new Set());
} }
if (distance <= 2) {
/*
let unsub;
// get also profile events for profile search indexing
// eslint-disable-next-line prefer-const
unsub = PubSub.subscribe({ authors: [STR(user)], kinds: [0] }, () => unsub?.(), true);
// TODO subscribe once param?
*/
}
this.usersByFollowDistance.get(distance)?.add(user); this.usersByFollowDistance.get(distance)?.add(user);
// remove from higher distances // remove from higher distances
for (const d of this.usersByFollowDistance.keys()) { for (const d of this.usersByFollowDistance.keys()) {
@ -166,13 +157,6 @@ export default class SocialGraph {
} }
this.followedByUser.get(follower)?.add(followedUser); this.followedByUser.get(follower)?.add(followedUser);
if (this.followedByUser.get(this.root)?.has(follower)) {
/*
setTimeout(() => {
PubSub.subscribe({ authors: [STR(followedUser)], kinds: [0, 3] }, undefined, true);
}, 0);
*/
}
} }
removeFollower(unfollowedUser: UID, follower: UID) { removeFollower(unfollowedUser: UID, follower: UID) {
@ -236,7 +220,6 @@ export default class SocialGraph {
if (includeSelf) { if (includeSelf) {
set.add(user); set.add(user);
} }
//return PubSub.subscribe({ kinds: [3], authors: [user] }, callback);
return set; return set;
} }
@ -246,7 +229,6 @@ export default class SocialGraph {
for (const id of this.followersByUser.get(userId) || []) { for (const id of this.followersByUser.get(userId) || []) {
set.add(STR(id)); set.add(STR(id));
} }
//return PubSub.subscribe({ kinds: [3], '#p': [address] }, callback); // TODO this doesn't fire when a user is unfollowed
return set; return set;
} }
} }