mirror of
https://github.com/irislib/iris-messenger.git
synced 2024-09-20 01:56:33 +00:00
rm old indexes
This commit is contained in:
parent
3b2a29d119
commit
651b62adf7
@ -52,8 +52,6 @@ const Events = {
|
|||||||
deletedEvents: new Set<string>(),
|
deletedEvents: new Set<string>(),
|
||||||
directMessagesByUser: new Map<string, SortedLimitedEventSet>(),
|
directMessagesByUser: new Map<string, SortedLimitedEventSet>(),
|
||||||
likesByUser: new Map<string, SortedLimitedEventSet>(),
|
likesByUser: new Map<string, SortedLimitedEventSet>(),
|
||||||
postsByUser: new Map<string, SortedLimitedEventSet>(),
|
|
||||||
postsAndRepliesByUser: new Map<string, SortedLimitedEventSet>(),
|
|
||||||
latestNotificationByTargetAndKind: new Map<string, string>(),
|
latestNotificationByTargetAndKind: new Map<string, string>(),
|
||||||
notifications: new SortedLimitedEventSet(MAX_LATEST_MSGS),
|
notifications: new SortedLimitedEventSet(MAX_LATEST_MSGS),
|
||||||
zapsByNote: new Map<string, SortedLimitedEventSet>(),
|
zapsByNote: new Map<string, SortedLimitedEventSet>(),
|
||||||
@ -82,10 +80,6 @@ const Events = {
|
|||||||
console.log('error inserting event', e);
|
console.log('error inserting event', e);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (!this.postsAndRepliesByUser.has(event.pubkey)) {
|
|
||||||
this.postsAndRepliesByUser.set(event.pubkey, new SortedLimitedEventSet(MAX_MSGS_BY_USER));
|
|
||||||
}
|
|
||||||
this.postsAndRepliesByUser.get(event.pubkey)?.add(event);
|
|
||||||
|
|
||||||
this.latestNotesAndRepliesByEveryone.add(event);
|
this.latestNotesAndRepliesByEveryone.add(event);
|
||||||
|
|
||||||
@ -144,11 +138,6 @@ const Events = {
|
|||||||
}
|
}
|
||||||
this.threadRepliesByMessageId.get(id)?.add(event.id);
|
this.threadRepliesByMessageId.get(id)?.add(event.id);
|
||||||
}
|
}
|
||||||
} else {
|
|
||||||
if (!this.postsByUser.has(event.pubkey)) {
|
|
||||||
this.postsByUser.set(event.pubkey, new SortedLimitedEventSet(MAX_MSGS_BY_USER));
|
|
||||||
}
|
|
||||||
this.postsByUser.get(event.pubkey)?.add(event);
|
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
deleteRepostedMsgsFromFeeds(event: Event, feeds: SortedLimitedEventSet[]) {
|
deleteRepostedMsgsFromFeeds(event: Event, feeds: SortedLimitedEventSet[]) {
|
||||||
@ -365,7 +354,6 @@ const Events = {
|
|||||||
// only we or the author can delete
|
// only we or the author can delete
|
||||||
if (deletedEvent && [event.pubkey, myPub].includes(deletedEvent.pubkey)) {
|
if (deletedEvent && [event.pubkey, myPub].includes(deletedEvent.pubkey)) {
|
||||||
this.cache.delete(id);
|
this.cache.delete(id);
|
||||||
this.postsAndRepliesByUser.get(event.pubkey)?.delete(id);
|
|
||||||
this.latestNotesByFollows.delete(id);
|
this.latestNotesByFollows.delete(id);
|
||||||
this.latestNotesByEveryone.delete(id);
|
this.latestNotesByEveryone.delete(id);
|
||||||
}
|
}
|
||||||
@ -852,21 +840,6 @@ const Events = {
|
|||||||
cb(this.latestNotesByKeywords.get(keyword)?.eventIds);
|
cb(this.latestNotesByKeywords.get(keyword)?.eventIds);
|
||||||
return PubSub.subscribe([filter], callback);
|
return PubSub.subscribe([filter], callback);
|
||||||
},
|
},
|
||||||
getPostsAndRepliesByUser(address: string, cb?: (messageIds: string[]) => void): Unsubscribe {
|
|
||||||
// TODO subscribe on view profile and unsub on leave profile
|
|
||||||
const callback = () => {
|
|
||||||
cb?.(this.postsAndRepliesByUser.get(address)?.eventIds);
|
|
||||||
};
|
|
||||||
this.postsAndRepliesByUser.has(address) && callback();
|
|
||||||
return PubSub.subscribe([{ kinds: [1, 5, 7], authors: [address] }], callback);
|
|
||||||
},
|
|
||||||
getPostsByUser(address: string, cb?: (messageIds: string[]) => void): Unsubscribe {
|
|
||||||
const callback = () => {
|
|
||||||
cb?.(this.postsByUser.get(address)?.eventIds);
|
|
||||||
};
|
|
||||||
this.postsByUser.has(address) && callback();
|
|
||||||
return PubSub.subscribe([{ kinds: [1, 5, 7], authors: [address] }], callback);
|
|
||||||
},
|
|
||||||
getLikesByUser(address: string, cb?: (messageIds: string[]) => void): Unsubscribe {
|
getLikesByUser(address: string, cb?: (messageIds: string[]) => void): Unsubscribe {
|
||||||
const callback = () => {
|
const callback = () => {
|
||||||
cb?.(this.likesByUser.get(address)?.eventIds);
|
cb?.(this.likesByUser.get(address)?.eventIds);
|
||||||
|
@ -121,25 +121,9 @@ export default {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// if new follow, move all their posts to followedByUser
|
|
||||||
if (follower === myPub && !this.followedByUser.get(myPub).has(followedUser)) {
|
|
||||||
const posts = Events.postsByUser.get(followedUser);
|
|
||||||
if (posts) {
|
|
||||||
posts.eventIds.forEach((eventId) => {
|
|
||||||
const event = Events.cache.get(eventId);
|
|
||||||
if (event) {
|
|
||||||
const replyingTo = Events.getNoteReplyingTo(event);
|
|
||||||
if (!replyingTo) {
|
|
||||||
Events.latestNotesByFollows.add(event);
|
|
||||||
}
|
|
||||||
Events.latestNotesAndRepliesByFollows.add(event);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
this.followedByUser.get(follower)?.add(followedUser);
|
this.followedByUser.get(follower)?.add(followedUser);
|
||||||
if (follower === myPub) {
|
if (follower === myPub) {
|
||||||
Events.getPostsAndRepliesByUser(followedUser);
|
PubSub.subscribe([{ kinds: [1, 5, 7], authors: [followedUser] }]);
|
||||||
}
|
}
|
||||||
if (followedUser === myPub) {
|
if (followedUser === myPub) {
|
||||||
if (this.followersByUser.get(followedUser)?.size === 1) {
|
if (this.followersByUser.get(followedUser)?.size === 1) {
|
||||||
|
Loading…
Reference in New Issue
Block a user