nostr/iris-messenger
1
0
Fork 0
mirror of https://github.com/irislib/iris-messenger.git synced 2024-09-20 01:56:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

getExtendedFollows fix

Browse Source
This commit is contained in:
Martti Malmi 2022-06-29 00:42:26 +03:00
parent 3d7b3619a4
commit 5b020d6747
1 changed files with 10 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/js/Session.js
View File

@ -76,22 +76,19 @@ function removeFollow(k, followDistance, follower) {
const getExtendedFollows = _.throttle((callback, k, maxDepth = 3, currentDepth = 1) => {
k = k || key.pub;
const shouldQuery = !follows[k];
addFollow(callback, k, currentDepth - 1);
if (shouldQuery) {
State.public.user(k).get('follow').map().on((isFollowing, followedKey) => { // TODO: unfollow
if (follows[followedKey] === isFollowing) { return; }
if (isFollowing) {
addFollow(callback, followedKey, currentDepth, k);
if (currentDepth < maxDepth) {
_.defer(() => getExtendedFollows(callback, followedKey, maxDepth, currentDepth + 1));
}
} else {
removeFollow(followedKey, currentDepth, k);
State.public.user(k).get('follow').map().on((isFollowing, followedKey) => { // TODO: unfollow
if (follows[followedKey] === isFollowing) { return; }
if (isFollowing) {
addFollow(callback, followedKey, currentDepth, k);
if (currentDepth < maxDepth) {
_.defer(() => getExtendedFollows(callback, followedKey, maxDepth, currentDepth + 1));
}
});
}
} else {
removeFollow(followedKey, currentDepth, k);
}
});
return follows;
}, 2000);