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, ModRemoveComment, ModRemoveCommunity, ModBanFromCommunity, ModBan, ModAddCommunity, ModAdd } from '../interfaces'; import { WebSocketService } from '../services'; import { msgOp, addTypeInfo, fetchLimit } from '../utils'; import { MomentTime } from './moment-time'; import * as moment from 'moment'; interface ModlogState { combined: Array<{type_: string, data: ModRemovePost | ModLockPost | 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 - Lemmy"; } setCombined(res: GetModlogResponse) { let removed_posts = addTypeInfo(res.removed_posts, "removed_posts"); let locked_posts = addTypeInfo(res.locked_posts, "locked_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(...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_ == '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 && /f/{this.state.communityName} } Modlog
{this.combined()}
Time Mod 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: any) { console.log(msg); let op: UserOperation = msgOp(msg); if (msg.error) { alert(msg.error); return; } else if (op == UserOperation.GetModlog) { let res: GetModlogResponse = msg; this.state.loading = false; this.setCombined(res); } } }