ecency/ecency-mobile
1
1
Fork 0
mirror of https://github.com/ecency/ecency-mobile.git synced 2024-12-02 11:15:35 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

comments votes cache injection

Browse Source
This commit is contained in:
Nouman Tahir 2023-02-28 20:13:13 +05:00
parent acc7a032c5
commit 266b950812
1 changed files with 37 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

64
src/providers/queries/postQueries/postQueries.ts
View File

@ -92,6 +92,9 @@ export const useDiscussionQuery = (_author?: string, _permlink?: string) => {
const cachedComments: { [key: string]: Comment } = useAppSelector( const cachedComments: { [key: string]: Comment } = useAppSelector(
(state) => state.cache.commentsCollection, (state) => state.cache.commentsCollection,
); );
const cachedVotes: { [key: string]: Comment } = useAppSelector(
(state) => state.cache.votesCollection
);
const lastCacheUpdate: LastUpdateMeta = useAppSelector((state) => state.cache.lastUpdate); const lastCacheUpdate: LastUpdateMeta = useAppSelector((state) => state.cache.lastUpdate);
const [author, setAuthor] = useState(_author); const [author, setAuthor] = useState(_author);
@ -107,21 +110,32 @@ export const useDiscussionQuery = (_author?: string, _permlink?: string) => {
); );
useEffect(() => { useEffect(() => {
_injectCachedComments(); _injectCache();
}, [query.data, cachedComments]); }, [query.data, cachedComments, cachedVotes]);
useEffect(() => { useEffect(() => {
restructureData(); restructureData();
}, [data]); }, [data]);
// inject cached comments here // inject cached comments here
const _injectCachedComments = async () => { const _injectCache = async () => {
const _comments = query.data || {}; const _comments = query.data || {};
console.log('updating with cache', _comments, cachedComments); console.log('updating with cache', _comments, cachedComments);
if (!cachedComments || !_comments) { if (!cachedComments || !_comments) {
console.log("Skipping cache injection")
return _comments; return _comments;
} }
//process votes cache
for (const path in cachedVotes){
const cachedVote = cachedVotes[path];
if(_comments[path]){
console.log("injection vote cache")
_comments[path] = _injectVoteFunc(_comments[path], cachedVote)
}
}
//process comments cache
for (const path in cachedComments) { for (const path in cachedComments) {
const currentTime = new Date().getTime(); const currentTime = new Date().getTime();
const cachedComment = cachedComments[path]; const cachedComment = cachedComments[path];
@ -272,7 +286,7 @@ export const useInjectVotesCache = (_data: any | any[]) => {
//if post available, inject cache and update state //if post available, inject cache and update state
if (_postData) { if (_postData) {
_postData = _injectionFunc(_postData, _voteCache); _postData = _injectVoteFunc(_postData, _voteCache);
if (_postIndex < 0) { if (_postIndex < 0) {
console.log("updating data", _postData) console.log("updating data", _postData)
@ -300,7 +314,7 @@ export const useInjectVotesCache = (_data: any | any[]) => {
const _path = `${item.author}/${item.permlink}`; const _path = `${item.author}/${item.permlink}`;
const voteCache = votesCollection[_path] const voteCache = votesCollection[_path]
item = _injectionFunc(item, voteCache); item = _injectVoteFunc(item, voteCache);
} }
return item; return item;
} }
@ -313,30 +327,26 @@ export const useInjectVotesCache = (_data: any | any[]) => {
}, [_data]) }, [_data])
const _injectionFunc = (post, voteCache) => {
if (voteCache && (voteCache.status !== CacheStatus.FAILED || voteCache.status !== CacheStatus.DELETED)) {
const _voteIndex = post.active_votes.findIndex(i => i.voter === voteCache.voter);
if (_voteIndex < 0) {
post.total_payout += voteCache.amount * (voteCache.isDownvote ? -1 : 1);
post.active_votes = [...post.active_votes, {
voter: voteCache.voter,
rshares: voteCache.isDownvote ? -1000 : 1000
}]
} else {
post.active_votes[_voteIndex].rshares = voteCache.isDownvote ? -1000 : 1000;
post.active_votes = [...post.active_votes];
}
}
return post
}
return retData || _data; return retData || _data;
} }
const _injectVoteFunc = (post, voteCache) => {
if (voteCache && (voteCache.status !== CacheStatus.FAILED || voteCache.status !== CacheStatus.DELETED)) {
const _voteIndex = post.active_votes.findIndex(i => i.voter === voteCache.voter);
if (_voteIndex < 0) {
post.total_payout += voteCache.amount * (voteCache.isDownvote ? -1 : 1);
post.active_votes = [...post.active_votes, {
voter: voteCache.voter,
rshares: voteCache.isDownvote ? -1000 : 1000
}]
} else {
post.active_votes[_voteIndex].rshares = voteCache.isDownvote ? -1000 : 1000;
post.active_votes = [...post.active_votes];
}
}
return post
}