import { Component, linkEvent } from 'inferno'; import { Link } from 'inferno-router'; import { Subscription } from 'rxjs'; import { retryWhen, delay, take } from 'rxjs/operators'; import { UserOperation, GetModlogForm, GetModlogResponse, ModRemovePost, ModLockPost, ModStickyPost, ModRemoveComment, ModRemoveCommunity, ModBanFromCommunity, ModBan, ModAddCommunity, ModAdd, WebSocketJsonResponse, } from '../interfaces'; import { WebSocketService } from '../services'; import { wsJsonToRes, addTypeInfo, fetchLimit, toast } from '../utils'; import { MomentTime } from './moment-time'; import moment from 'moment'; import { i18n } from '../i18next'; interface ModlogState { combined: Array<{ type_: string; data: | ModRemovePost | ModLockPost | ModStickyPost | ModRemoveCommunity | ModAdd | ModBan; }>; communityId?: number; communityName?: string; page: number; loading: boolean; } export class Modlog extends Component { private subscription: Subscription; private emptyState: ModlogState = { combined: [], page: 1, loading: true, }; constructor(props: any, context: any) { super(props, context); this.state = this.emptyState; this.state.communityId = this.props.match.params.community_id ? Number(this.props.match.params.community_id) : undefined; 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') ); this.refetch(); } componentWillUnmount() { this.subscription.unsubscribe(); } componentDidMount() { document.title = `Modlog - ${WebSocketService.Instance.site.name}`; } setCombined(res: GetModlogResponse) { let removed_posts = addTypeInfo(res.removed_posts, 'removed_posts'); let locked_posts = addTypeInfo(res.locked_posts, 'locked_posts'); let stickied_posts = addTypeInfo(res.stickied_posts, 'stickied_posts'); let removed_comments = addTypeInfo( res.removed_comments, 'removed_comments' ); let removed_communities = addTypeInfo( res.removed_communities, 'removed_communities' ); let banned_from_community = addTypeInfo( res.banned_from_community, 'banned_from_community' ); let added_to_community = addTypeInfo( res.added_to_community, 'added_to_community' ); let added = addTypeInfo(res.added, 'added'); let banned = addTypeInfo(res.banned, 'banned'); this.state.combined = []; this.state.combined.push(...removed_posts); this.state.combined.push(...locked_posts); this.state.combined.push(...stickied_posts); this.state.combined.push(...removed_comments); this.state.combined.push(...removed_communities); this.state.combined.push(...banned_from_community); this.state.combined.push(...added_to_community); this.state.combined.push(...added); this.state.combined.push(...banned); if (this.state.communityId && this.state.combined.length > 0) { this.state.communityName = (this.state.combined[0] .data as ModRemovePost).community_name; } // Sort them by time this.state.combined.sort((a, b) => b.data.when_.localeCompare(a.data.when_) ); this.setState(this.state); } combined() { return ( {this.state.combined.map(i => ( {i.data.mod_user_name} {i.type_ == 'removed_posts' && ( <> {(i.data as ModRemovePost).removed ? 'Removed' : 'Restored'} {' '} Post{' '} {(i.data as ModRemovePost).post_name}
{(i.data as ModRemovePost).reason && ` reason: ${(i.data as ModRemovePost).reason}`}
)} {i.type_ == 'locked_posts' && ( <> {(i.data as ModLockPost).locked ? 'Locked' : 'Unlocked'} {' '} Post{' '} {(i.data as ModLockPost).post_name} )} {i.type_ == 'stickied_posts' && ( <> {(i.data as ModStickyPost).stickied ? 'Stickied' : 'Unstickied'} {' '} Post{' '} {(i.data as ModStickyPost).post_name} )} {i.type_ == 'removed_comments' && ( <> {(i.data as ModRemoveComment).removed ? 'Removed' : 'Restored'} {' '} Comment{' '} {(i.data as ModRemoveComment).comment_content} {' '} by{' '} {(i.data as ModRemoveComment).comment_user_name}
{(i.data as ModRemoveComment).reason && ` reason: ${(i.data as ModRemoveComment).reason}`}
)} {i.type_ == 'removed_communities' && ( <> {(i.data as ModRemoveCommunity).removed ? 'Removed' : 'Restored'} {' '} Community{' '} {(i.data as ModRemoveCommunity).community_name}
{(i.data as ModRemoveCommunity).reason && ` reason: ${(i.data as ModRemoveCommunity).reason}`}
{(i.data as ModRemoveCommunity).expires && ` expires: ${moment .utc((i.data as ModRemoveCommunity).expires) .fromNow()}`}
)} {i.type_ == 'banned_from_community' && ( <> {(i.data as ModBanFromCommunity).banned ? 'Banned ' : 'Unbanned '}{' '} {(i.data as ModBanFromCommunity).other_user_name} from the community {(i.data as ModBanFromCommunity).community_name}
{(i.data as ModBanFromCommunity).reason && ` reason: ${(i.data as ModBanFromCommunity).reason}`}
{(i.data as ModBanFromCommunity).expires && ` expires: ${moment .utc((i.data as ModBanFromCommunity).expires) .fromNow()}`}
)} {i.type_ == 'added_to_community' && ( <> {(i.data as ModAddCommunity).removed ? 'Removed ' : 'Appointed '}{' '} {(i.data as ModAddCommunity).other_user_name} as a mod to the community {(i.data as ModAddCommunity).community_name} )} {i.type_ == 'banned' && ( <> {(i.data as ModBan).banned ? 'Banned ' : 'Unbanned '}{' '} {(i.data as ModBan).other_user_name}
{(i.data as ModBan).reason && ` reason: ${(i.data as ModBan).reason}`}
{(i.data as ModBan).expires && ` expires: ${moment .utc((i.data as ModBan).expires) .fromNow()}`}
)} {i.type_ == 'added' && ( <> {(i.data as ModAdd).removed ? 'Removed ' : 'Appointed '}{' '} {(i.data as ModAdd).other_user_name} as an admin )} ))} ); } render() { return (
{this.state.loading ? (
) : (
{this.state.communityName && ( /c/{this.state.communityName}{' '} )} {i18n.t('modlog')}
{this.combined()}
{i18n.t('time')} {i18n.t('mod')} {i18n.t('action')}
{this.paginator()}
)}
); } paginator() { return (
{this.state.page > 1 && ( )}
); } nextPage(i: Modlog) { i.state.page++; i.setState(i.state); i.refetch(); } prevPage(i: Modlog) { i.state.page--; i.setState(i.state); i.refetch(); } refetch() { let modlogForm: GetModlogForm = { community_id: this.state.communityId, page: this.state.page, limit: fetchLimit, }; WebSocketService.Instance.getModlog(modlogForm); } 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.GetModlog) { let data = res.data as GetModlogResponse; this.state.loading = false; window.scrollTo(0, 0); this.setCombined(data); } } }