import { Component, linkEvent } from "inferno"; import { AddModToCommunityResponse, BanFromCommunityResponse, BlockPersonResponse, CommentReportResponse, CommentResponse, CommentView, CommunityResponse, GetComments, GetCommentsResponse, GetCommunity, GetCommunityResponse, GetPosts, GetPostsResponse, GetSiteResponse, ListingType, PostReportResponse, PostResponse, PostView, SortType, UserOperation, } from "lemmy-js-client"; import { Subscription } from "rxjs"; import { i18n } from "../../i18next"; import { DataType, InitialFetchRequest } from "../../interfaces"; import { UserService, WebSocketService } from "../../services"; import { authField, commentsToFlatNodes, communityRSSUrl, createCommentLikeRes, createPostLikeFindRes, editCommentRes, editPostFindRes, fetchLimit, getDataTypeFromProps, getPageFromProps, getSortTypeFromProps, notifyPost, relTags, restoreScrollPosition, saveCommentRes, saveScrollPosition, setIsoData, setOptionalAuth, setupTippy, toast, updatePersonBlock, wsClient, wsJsonToRes, wsSubscribe, wsUserOp, } from "../../utils"; import { CommentNodes } from "../comment/comment-nodes"; import { BannerIconHeader } from "../common/banner-icon-header"; import { DataTypeSelect } from "../common/data-type-select"; import { HtmlTags } from "../common/html-tags"; import { Icon, Spinner } from "../common/icon"; import { Paginator } from "../common/paginator"; import { SortSelect } from "../common/sort-select"; import { Sidebar } from "../community/sidebar"; import { PostListings } from "../post/post-listings"; import { CommunityLink } from "./community-link"; interface State { communityRes: GetCommunityResponse; siteRes: GetSiteResponse; communityName: string; communityLoading: boolean; postsLoading: boolean; commentsLoading: boolean; posts: PostView[]; comments: CommentView[]; dataType: DataType; sort: SortType; page: number; showSidebarMobile: boolean; } interface CommunityProps { dataType: DataType; sort: SortType; page: number; } interface UrlParams { dataType?: string; sort?: SortType; page?: number; } export class Community extends Component { private isoData = setIsoData(this.context); private subscription: Subscription; private emptyState: State = { communityRes: undefined, communityName: this.props.match.params.name, communityLoading: true, postsLoading: true, commentsLoading: true, posts: [], comments: [], dataType: getDataTypeFromProps(this.props), sort: getSortTypeFromProps(this.props), page: getPageFromProps(this.props), siteRes: this.isoData.site_res, showSidebarMobile: false, }; constructor(props: any, context: any) { super(props, context); this.state = this.emptyState; this.handleSortChange = this.handleSortChange.bind(this); this.handleDataTypeChange = this.handleDataTypeChange.bind(this); this.handlePageChange = this.handlePageChange.bind(this); this.parseMessage = this.parseMessage.bind(this); this.subscription = wsSubscribe(this.parseMessage); // Only fetch the data if coming from another route if (this.isoData.path == this.context.router.route.match.url) { this.state.communityRes = this.isoData.routeData[0]; if (this.state.dataType == DataType.Post) { this.state.posts = this.isoData.routeData[1].posts; } else { this.state.comments = this.isoData.routeData[1].comments; } this.state.communityLoading = false; this.state.postsLoading = false; this.state.commentsLoading = false; } else { this.fetchCommunity(); this.fetchData(); } } fetchCommunity() { let form: GetCommunity = { name: this.state.communityName ? this.state.communityName : null, auth: authField(false), }; WebSocketService.Instance.send(wsClient.getCommunity(form)); } componentDidMount() { setupTippy(); } componentWillUnmount() { saveScrollPosition(this.context); this.subscription.unsubscribe(); window.isoData.path = undefined; } static getDerivedStateFromProps(props: any): CommunityProps { return { dataType: getDataTypeFromProps(props), sort: getSortTypeFromProps(props), page: getPageFromProps(props), }; } static fetchInitialData(req: InitialFetchRequest): Promise[] { let pathSplit = req.path.split("/"); let promises: Promise[] = []; let communityName = pathSplit[2]; let communityForm: GetCommunity = { name: communityName }; setOptionalAuth(communityForm, req.auth); promises.push(req.client.getCommunity(communityForm)); let dataType: DataType = pathSplit[4] ? DataType[pathSplit[4]] : DataType.Post; let sort: SortType = pathSplit[6] ? SortType[pathSplit[6]] : UserService.Instance.myUserInfo ? Object.values(SortType)[ UserService.Instance.myUserInfo.local_user_view.local_user .default_sort_type ] : SortType.Active; let page = pathSplit[8] ? Number(pathSplit[8]) : 1; if (dataType == DataType.Post) { let getPostsForm: GetPosts = { page, limit: fetchLimit, sort, type_: ListingType.Community, saved_only: false, }; setOptionalAuth(getPostsForm, req.auth); this.setName(getPostsForm, communityName); promises.push(req.client.getPosts(getPostsForm)); } else { let getCommentsForm: GetComments = { page, limit: fetchLimit, sort, type_: ListingType.Community, saved_only: false, }; this.setName(getCommentsForm, communityName); setOptionalAuth(getCommentsForm, req.auth); promises.push(req.client.getComments(getCommentsForm)); } return promises; } static setName(obj: any, name_: string) { obj.community_name = name_; } componentDidUpdate(_: any, lastState: State) { if ( lastState.dataType !== this.state.dataType || lastState.sort !== this.state.sort || lastState.page !== this.state.page ) { this.setState({ postsLoading: true, commentsLoading: true }); this.fetchData(); } } get documentTitle(): string { return `${this.state.communityRes.community_view.community.title} - ${this.state.siteRes.site_view.site.name}`; } render() { let cv = this.state.communityRes?.community_view; return (
{this.state.communityLoading ? (
) : ( <>
{this.communityInfo()}
{this.state.showSidebarMobile && ( )}
{this.selects()} {this.listings()}
)}
); } listings() { let site = this.state.siteRes.site_view.site; return this.state.dataType == DataType.Post ? ( this.state.postsLoading ? (
) : ( ) ) : this.state.commentsLoading ? (
) : ( ); } communityInfo() { let community = this.state.communityRes.community_view.community; return (
{community.title}
); } selects() { let communityRss = communityRSSUrl( this.state.communityRes.community_view.community.actor_id, this.state.sort ); return ( ); } handlePageChange(page: number) { this.updateUrl({ page }); window.scrollTo(0, 0); } handleSortChange(val: SortType) { this.updateUrl({ sort: val, page: 1 }); window.scrollTo(0, 0); } handleDataTypeChange(val: DataType) { this.updateUrl({ dataType: DataType[val], page: 1 }); window.scrollTo(0, 0); } handleShowSidebarMobile(i: Community) { i.state.showSidebarMobile = !i.state.showSidebarMobile; i.setState(i.state); } updateUrl(paramUpdates: UrlParams) { const dataTypeStr = paramUpdates.dataType || DataType[this.state.dataType]; const sortStr = paramUpdates.sort || this.state.sort; const page = paramUpdates.page || this.state.page; let typeView = `/c/${this.state.communityName}`; this.props.history.push( `${typeView}/data_type/${dataTypeStr}/sort/${sortStr}/page/${page}` ); } fetchData() { if (this.state.dataType == DataType.Post) { let form: GetPosts = { page: this.state.page, limit: fetchLimit, sort: this.state.sort, type_: ListingType.Community, community_name: this.state.communityName, saved_only: false, auth: authField(false), }; WebSocketService.Instance.send(wsClient.getPosts(form)); } else { let form: GetComments = { page: this.state.page, limit: fetchLimit, sort: this.state.sort, type_: ListingType.Community, community_name: this.state.communityName, saved_only: false, auth: authField(false), }; WebSocketService.Instance.send(wsClient.getComments(form)); } } parseMessage(msg: any) { let op = wsUserOp(msg); console.log(msg); if (msg.error) { toast(i18n.t(msg.error), "danger"); this.context.router.history.push("/"); return; } else if (msg.reconnect) { WebSocketService.Instance.send( wsClient.communityJoin({ community_id: this.state.communityRes.community_view.community.id, }) ); this.fetchData(); } else if (op == UserOperation.GetCommunity) { let data = wsJsonToRes(msg).data; this.state.communityRes = data; this.state.communityLoading = false; this.setState(this.state); // TODO why is there no auth in this form? WebSocketService.Instance.send( wsClient.communityJoin({ community_id: data.community_view.community.id, }) ); } else if ( op == UserOperation.EditCommunity || op == UserOperation.DeleteCommunity || op == UserOperation.RemoveCommunity ) { let data = wsJsonToRes(msg).data; this.state.communityRes.community_view = data.community_view; this.setState(this.state); } else if (op == UserOperation.FollowCommunity) { let data = wsJsonToRes(msg).data; this.state.communityRes.community_view.subscribed = data.community_view.subscribed; this.state.communityRes.community_view.counts.subscribers = data.community_view.counts.subscribers; this.setState(this.state); } else if (op == UserOperation.GetPosts) { let data = wsJsonToRes(msg).data; this.state.posts = data.posts; this.state.postsLoading = false; this.setState(this.state); restoreScrollPosition(this.context); setupTippy(); } else if ( op == UserOperation.EditPost || op == UserOperation.DeletePost || op == UserOperation.RemovePost || op == UserOperation.LockPost || op == UserOperation.StickyPost || op == UserOperation.SavePost ) { let data = wsJsonToRes(msg).data; editPostFindRes(data.post_view, this.state.posts); this.setState(this.state); } else if (op == UserOperation.CreatePost) { let data = wsJsonToRes(msg).data; this.state.posts.unshift(data.post_view); if ( UserService.Instance.myUserInfo?.local_user_view.local_user .show_new_post_notifs ) { notifyPost(data.post_view, this.context.router); } this.setState(this.state); } else if (op == UserOperation.CreatePostLike) { let data = wsJsonToRes(msg).data; createPostLikeFindRes(data.post_view, this.state.posts); this.setState(this.state); } else if (op == UserOperation.AddModToCommunity) { let data = wsJsonToRes(msg).data; this.state.communityRes.moderators = data.moderators; this.setState(this.state); } else if (op == UserOperation.BanFromCommunity) { let data = wsJsonToRes(msg).data; // TODO this might be incorrect this.state.posts .filter(p => p.creator.id == data.person_view.person.id) .forEach(p => (p.creator_banned_from_community = data.banned)); this.setState(this.state); } else if (op == UserOperation.GetComments) { let data = wsJsonToRes(msg).data; this.state.comments = data.comments; this.state.commentsLoading = false; this.setState(this.state); } else if ( op == UserOperation.EditComment || op == UserOperation.DeleteComment || op == UserOperation.RemoveComment ) { let data = wsJsonToRes(msg).data; editCommentRes(data.comment_view, this.state.comments); this.setState(this.state); } else if (op == UserOperation.CreateComment) { let data = wsJsonToRes(msg).data; // Necessary since it might be a user reply if (data.form_id) { this.state.comments.unshift(data.comment_view); this.setState(this.state); } } else if (op == UserOperation.SaveComment) { let data = wsJsonToRes(msg).data; saveCommentRes(data.comment_view, this.state.comments); this.setState(this.state); } else if (op == UserOperation.CreateCommentLike) { let data = wsJsonToRes(msg).data; createCommentLikeRes(data.comment_view, this.state.comments); this.setState(this.state); } else if (op == UserOperation.BlockPerson) { let data = wsJsonToRes(msg).data; updatePersonBlock(data); } else if (op == UserOperation.CreatePostReport) { let data = wsJsonToRes(msg).data; if (data) { toast(i18n.t("report_created")); } } else if (op == UserOperation.CreateCommentReport) { let data = wsJsonToRes(msg).data; if (data) { toast(i18n.t("report_created")); } } } }