import { Component } from 'inferno'; import { Subscription } from 'rxjs'; import { PrivateMessageForm } from './private-message-form'; import { HtmlTags } from './html-tags'; import { UserService, WebSocketService } from '../services'; import { Site, WebSocketJsonResponse, UserOperation, UserDetailsResponse, UserView, SortType, GetUserDetailsForm, } from 'lemmy-js-client'; import { getRecipientIdFromProps, isBrowser, lemmyHttp, setAuth, setIsoData, toast, wsJsonToRes, wsSubscribe, } from '../utils'; import { i18n } from '../i18next'; interface CreatePrivateMessageProps {} interface CreatePrivateMessageState { site: Site; recipient: UserView; recipient_id: number; loading: boolean; } export class CreatePrivateMessage extends Component< CreatePrivateMessageProps, CreatePrivateMessageState > { private isoData = setIsoData(this.context); private subscription: Subscription; private emptyState: CreatePrivateMessageState = { site: this.isoData.site.site, recipient: undefined, recipient_id: getRecipientIdFromProps(this.props), loading: true, }; constructor(props: any, context: any) { super(props, context); this.state = this.emptyState; this.handlePrivateMessageCreate = this.handlePrivateMessageCreate.bind( this ); this.parseMessage = this.parseMessage.bind(this); this.subscription = wsSubscribe(this.parseMessage); if (!UserService.Instance.user) { toast(i18n.t('not_logged_in'), 'danger'); this.context.router.history.push(`/login`); } // Only fetch the data if coming from another route if (this.isoData.path == this.context.router.route.match.url) { this.state.recipient = this.isoData.routeData[0].user; this.state.loading = false; } else { this.fetchUserDetails(); } } fetchUserDetails() { let form: GetUserDetailsForm = { user_id: this.state.recipient_id, sort: SortType.New, saved_only: false, }; WebSocketService.Instance.getUserDetails(form); } static fetchInitialData(auth: string, path: string): Promise[] { let user_id = Number(path.split('/').pop()); let form: GetUserDetailsForm = { user_id, sort: SortType.New, saved_only: false, }; setAuth(form, auth); return [lemmyHttp.getUserDetails(form)]; } get documentTitle(): string { return `${i18n.t('create_private_message')} - ${this.state.site.name}`; } componentWillUnmount() { if (isBrowser()) { this.subscription.unsubscribe(); } } render() { return (
{this.state.loading ? (
) : (
{i18n.t('create_private_message')}
)}
); } handlePrivateMessageCreate() { toast(i18n.t('message_sent')); // Navigate to the front this.context.router.history.push(`/`); } parseMessage(msg: WebSocketJsonResponse) { let res = wsJsonToRes(msg); if (msg.error) { toast(i18n.t(msg.error), 'danger'); this.state.loading = false; this.setState(this.state); return; } else if (res.op == UserOperation.GetUserDetails) { let data = res.data as UserDetailsResponse; this.state.recipient = data.user; this.state.loading = false; this.setState(this.state); } } }