import { Component, linkEvent } from 'inferno'; import { Link } from 'inferno-router'; import { Subscription } from "rxjs"; import { retryWhen, delay, take } from 'rxjs/operators'; import { UserOperation, Community as CommunityI, GetCommunityResponse, CommunityResponse, Post, GetPostsForm, ListingSortType, ListingType, GetPostsResponse, CreatePostLikeForm, CreatePostLikeResponse, CommunityUser} from '../interfaces'; import { WebSocketService, UserService } from '../services'; import { MomentTime } from './moment-time'; import { PostListing } from './post-listing'; import { Sidebar } from './sidebar'; import { msgOp, mdToHtml } from '../utils'; interface PostListingsProps { communityId?: number; } interface PostListingsState { community: CommunityI; moderators: Array; posts: Array; sortType: ListingSortType; type_: ListingType; } export class PostListings extends Component { private subscription: Subscription; private emptyState: PostListingsState = { community: { id: null, name: null, title: null, category_id: null, category_name: null, creator_id: null, creator_name: null, number_of_subscribers: null, number_of_posts: null, number_of_comments: null, published: null }, moderators: [], posts: [], sortType: ListingSortType.Hot, type_: this.props.communityId ? ListingType.Community : UserService.Instance.loggedIn ? ListingType.Subscribed : ListingType.All } constructor(props, context) { super(props, context); this.state = this.emptyState; this.subscription = WebSocketService.Instance.subject .pipe(retryWhen(errors => errors.pipe(delay(3000), take(10)))) .subscribe( (msg) => this.parseMessage(msg), (err) => console.error(err), () => console.log('complete') ); let getPostsForm: GetPostsForm = { type_: ListingType[this.state.type_], community_id: this.props.communityId, limit: 10, sort: ListingSortType[ListingSortType.Hot], } WebSocketService.Instance.getPosts(getPostsForm); } componentWillUnmount() { this.subscription.unsubscribe(); } render() { return (
{this.selects()}
{this.state.posts.length > 0 ? this.state.posts.map(post => ) :
No Listings. Subscribe to some forums.
}
) } selects() { return (
{!this.props.communityId && UserService.Instance.loggedIn && }
) } handleSortChange(i: PostListings, event) { i.state.sortType = Number(event.target.value); i.setState(i.state); let getPostsForm: GetPostsForm = { community_id: i.state.community.id, limit: 10, sort: ListingSortType[i.state.sortType], type_: ListingType[ListingType.Community] } WebSocketService.Instance.getPosts(getPostsForm); } handleTypeChange(i: PostListings, event) { i.state.type_ = Number(event.target.value); i.setState(i.state); let getPostsForm: GetPostsForm = { limit: 10, sort: ListingSortType[i.state.sortType], type_: ListingType[i.state.type_] } WebSocketService.Instance.getPosts(getPostsForm); } parseMessage(msg: any) { console.log(msg); let op: UserOperation = msgOp(msg); if (msg.error) { alert(msg.error); return; } else if (op == UserOperation.GetPosts) { let res: GetPostsResponse = msg; this.state.posts = res.posts; this.setState(this.state); } else if (op == UserOperation.CreatePostLike) { let res: CreatePostLikeResponse = msg; let found = this.state.posts.find(c => c.id == res.post.id); found.my_vote = res.post.my_vote; found.score = res.post.score; found.upvotes = res.post.upvotes; found.downvotes = res.post.downvotes; this.setState(this.state); } } }