import { Component, linkEvent } from 'inferno'; import { Link } from 'inferno-router'; import { Subscription } from 'rxjs'; import { retryWhen, delay, take } from 'rxjs/operators'; import { UserOperation, Post, Comment, Community, UserView, SortType, SearchForm, SearchResponse, SearchType, PostResponse, CommentResponse, WebSocketJsonResponse, } from '../interfaces'; import { WebSocketService } from '../services'; import { wsJsonToRes, fetchLimit, routeSearchTypeToEnum, routeSortTypeToEnum, toast, createCommentLikeRes, createPostLikeFindRes, commentsToFlatNodes, } from '../utils'; import { PostListing } from './post-listing'; import { UserListing } from './user-listing'; import { CommunityLink } from './community-link'; import { SortSelect } from './sort-select'; import { CommentNodes } from './comment-nodes'; import { i18n } from '../i18next'; interface SearchState { q: string; type_: SearchType; sort: SortType; page: number; searchResponse: SearchResponse; loading: boolean; } export class Search extends Component { private subscription: Subscription; private emptyState: SearchState = { q: this.getSearchQueryFromProps(this.props), type_: this.getSearchTypeFromProps(this.props), sort: this.getSortTypeFromProps(this.props), page: this.getPageFromProps(this.props), searchResponse: { type_: null, posts: [], comments: [], communities: [], users: [], }, loading: false, }; getSearchQueryFromProps(props: any): string { return props.match.params.q ? props.match.params.q : ''; } getSearchTypeFromProps(props: any): SearchType { return props.match.params.type ? routeSearchTypeToEnum(props.match.params.type) : SearchType.All; } getSortTypeFromProps(props: any): SortType { return props.match.params.sort ? routeSortTypeToEnum(props.match.params.sort) : SortType.TopAll; } getPageFromProps(props: any): number { return props.match.params.page ? Number(props.match.params.page) : 1; } constructor(props: any, context: any) { super(props, context); this.state = this.emptyState; this.handleSortChange = this.handleSortChange.bind(this); 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') ); if (this.state.q) { this.search(); } } componentWillUnmount() { this.subscription.unsubscribe(); } // Necessary for back button for some reason componentWillReceiveProps(nextProps: any) { if ( nextProps.history.action == 'POP' || nextProps.history.action == 'PUSH' ) { this.state.q = this.getSearchQueryFromProps(nextProps); this.state.type_ = this.getSearchTypeFromProps(nextProps); this.state.sort = this.getSortTypeFromProps(nextProps); this.state.page = this.getPageFromProps(nextProps); this.setState(this.state); this.search(); } } componentDidMount() { document.title = `${i18n.t('search')} - ${ WebSocketService.Instance.site.name }`; } render() { return (
{i18n.t('search')}
{this.selects()} {this.searchForm()} {this.state.type_ == SearchType.All && this.all()} {this.state.type_ == SearchType.Comments && this.comments()} {this.state.type_ == SearchType.Posts && this.posts()} {this.state.type_ == SearchType.Communities && this.communities()} {this.state.type_ == SearchType.Users && this.users()} {this.noResults()} {this.paginator()}
); } searchForm() { return (
); } selects() { return (
); } all() { let combined: Array<{ type_: string; data: Comment | Post | Community | UserView; }> = []; let comments = this.state.searchResponse.comments.map(e => { return { type_: 'comments', data: e }; }); let posts = this.state.searchResponse.posts.map(e => { return { type_: 'posts', data: e }; }); let communities = this.state.searchResponse.communities.map(e => { return { type_: 'communities', data: e }; }); let users = this.state.searchResponse.users.map(e => { return { type_: 'users', data: e }; }); combined.push(...comments); combined.push(...posts); combined.push(...communities); combined.push(...users); // Sort it if (this.state.sort == SortType.New) { combined.sort((a, b) => b.data.published.localeCompare(a.data.published)); } else { combined.sort( (a, b) => ((b.data as Comment | Post).score | (b.data as Community).number_of_subscribers | (b.data as UserView).comment_score) - ((a.data as Comment | Post).score | (a.data as Community).number_of_subscribers | (a.data as UserView).comment_score) ); } return (
{combined.map(i => (
{i.type_ == 'posts' && ( )} {i.type_ == 'comments' && ( )} {i.type_ == 'communities' && (
{this.communityListing(i.data as Community)}
)} {i.type_ == 'users' && (
{` - ${ (i.data as UserView).comment_score } comment karma`}
)}
))}
); } comments() { return ( ); } posts() { return ( <> {this.state.searchResponse.posts.map(post => (
))} ); } // Todo possibly create UserListing and CommunityListing communities() { return ( <> {this.state.searchResponse.communities.map(community => (
{this.communityListing(community)}
))} ); } communityListing(community: Community) { return ( <> {` - ${community.title} - ${i18n.t('number_of_subscribers', { count: community.number_of_subscribers, })} `} ); } users() { return ( <> {this.state.searchResponse.users.map(user => (
{`/u/${user.name}`} {` - ${user.comment_score} comment karma`}
))} ); } paginator() { return (
{this.state.page > 1 && ( )}
); } noResults() { let res = this.state.searchResponse; return (
{res && res.posts.length == 0 && res.comments.length == 0 && res.communities.length == 0 && res.users.length == 0 && {i18n.t('no_results')}}
); } nextPage(i: Search) { i.state.page++; i.setState(i.state); i.updateUrl(); i.search(); } prevPage(i: Search) { i.state.page--; i.setState(i.state); i.updateUrl(); i.search(); } search() { let form: SearchForm = { q: this.state.q, type_: SearchType[this.state.type_], sort: SortType[this.state.sort], page: this.state.page, limit: fetchLimit, }; if (this.state.q != '') { WebSocketService.Instance.search(form); } } handleSortChange(val: SortType) { this.state.sort = val; this.state.page = 1; this.setState(this.state); this.updateUrl(); } handleTypeChange(i: Search, event: any) { i.state.type_ = Number(event.target.value); i.state.page = 1; i.setState(i.state); i.updateUrl(); } handleSearchSubmit(i: Search, event: any) { event.preventDefault(); i.state.loading = true; i.search(); i.setState(i.state); i.updateUrl(); } handleQChange(i: Search, event: any) { i.state.q = event.target.value; i.setState(i.state); } updateUrl() { let typeStr = SearchType[this.state.type_].toLowerCase(); let sortStr = SortType[this.state.sort].toLowerCase(); this.props.history.push( `/search/q/${this.state.q}/type/${typeStr}/sort/${sortStr}/page/${this.state.page}` ); } parseMessage(msg: WebSocketJsonResponse) { console.log(msg); let res = wsJsonToRes(msg); if (msg.error) { toast(i18n.t(msg.error), 'danger'); return; } else if (res.op == UserOperation.Search) { let data = res.data as SearchResponse; this.state.searchResponse = data; this.state.loading = false; document.title = `${i18n.t('search')} - ${this.state.q} - ${ WebSocketService.Instance.site.name }`; window.scrollTo(0, 0); this.setState(this.state); } else if (res.op == UserOperation.CreateCommentLike) { let data = res.data as CommentResponse; createCommentLikeRes(data, this.state.searchResponse.comments); this.setState(this.state); } else if (res.op == UserOperation.CreatePostLike) { let data = res.data as PostResponse; createPostLikeFindRes(data, this.state.searchResponse.posts); this.setState(this.state); } } }