expanded: boolean;
expandUserDropdown: boolean;
replies: Array<Comment>,
+ fetchCount: number,
unreadCount: number;
siteName: string;
}
emptyState: NavbarState = {
isLoggedIn: (UserService.Instance.user !== undefined),
unreadCount: 0,
+ fetchCount: 0,
replies: [],
expanded: false,
expandUserDropdown: false,
return;
} else if (op == UserOperation.GetReplies) {
let res: GetRepliesResponse = msg;
- if (res.replies.length > 0 && this.state.replies.length > 0 &&
- (JSON.stringify(this.state.replies) !== JSON.stringify(res.replies))) {
- this.notify(res.replies);
+ let unreadReplies = res.replies.filter(r => !r.read);
+ if (unreadReplies.length > 0 && this.state.fetchCount > 1 &&
+ (JSON.stringify(this.state.replies) !== JSON.stringify(unreadReplies))) {
+ this.notify(unreadReplies);
}
- this.state.replies = res.replies;
+ this.state.replies = unreadReplies;
this.sendRepliesCount(res);
} else if (op == UserOperation.GetSite) {
let res: GetSiteResponse = msg;
limit: 9999,
};
WebSocketService.Instance.getReplies(repliesForm);
+ this.state.fetchCount++;
}
}
else {
var notification = new Notification(`${replies.length} Unread Messages`, {
icon: `${window.location.protocol}//${window.location.host}/static/assets/apple-touch-icon.png`,
- body: recentReply.content
+ body: `${recentReply.creator_name}: ${recentReply.content}`
});
notification.onclick = () => {
import { Component, linkEvent } from 'inferno';
import { Subscription } from "rxjs";
import { retryWhen, delay, take } from 'rxjs/operators';
-import { UserOperation, Community, Post as PostI, GetPostResponse, PostResponse, Comment, CommentResponse, CommentSortType, CreatePostLikeResponse, CommunityUser, CommunityResponse, CommentNode as CommentNodeI, BanFromCommunityResponse, BanUserResponse, AddModToCommunityResponse, AddAdminResponse, UserView } from '../interfaces';
-import { WebSocketService } from '../services';
+import { UserOperation, Community, Post as PostI, GetPostResponse, PostResponse, Comment, CommentForm as CommentFormI, CommentResponse, CommentSortType, CreatePostLikeResponse, CommunityUser, CommunityResponse, CommentNode as CommentNodeI, BanFromCommunityResponse, BanUserResponse, AddModToCommunityResponse, AddAdminResponse, UserView } from '../interfaces';
+import { WebSocketService, UserService } from '../services';
import { msgOp, hotRank } from '../utils';
import { PostListing } from './post-listing';
import { Sidebar } from './sidebar';
elmnt.scrollIntoView();
elmnt.classList.add("mark-two");
this.state.scrolled = true;
+ this.markScrolledAsRead(this.state.scrolled_comment_id);
+ }
+ }
+
+ markScrolledAsRead(commentId: number) {
+ let found = this.state.comments.find(c => c.id == commentId);
+ let parent = this.state.comments.find(c => found.parent_id == c.id);
+ let parent_user_id = parent ? parent.creator_id : this.state.post.creator_id;
+
+ if (UserService.Instance.user && UserService.Instance.user.id == parent_user_id) {
+
+ let form: CommentFormI = {
+ content: found.content,
+ edit_id: found.id,
+ creator_id: found.creator_id,
+ post_id: found.post_id,
+ parent_id: found.parent_id,
+ read: true,
+ auth: null
+ };
+ WebSocketService.Instance.editComment(form);
}
}
found.upvotes = res.comment.upvotes;
found.downvotes = res.comment.downvotes;
found.score = res.comment.score;
+ found.read = res.comment.read;
this.setState(this.state);
} else if (op == UserOperation.SaveComment) {