diff options
Diffstat (limited to 'ui/src/components/create-community.tsx')
-rw-r--r-- | ui/src/components/create-community.tsx | 63 |
1 files changed, 55 insertions, 8 deletions
diff --git a/ui/src/components/create-community.tsx b/ui/src/components/create-community.tsx index 5c7a0a9b..3a5d943d 100644 --- a/ui/src/components/create-community.tsx +++ b/ui/src/components/create-community.tsx @@ -1,19 +1,49 @@ import { Component } from 'inferno'; +import { Subscription } from 'rxjs'; +import { retryWhen, delay, take } from 'rxjs/operators'; import { CommunityForm } from './community-form'; -import { Community } from '../interfaces'; -import { WebSocketService } from '../services'; +import { + Community, + UserOperation, + WebSocketJsonResponse, + GetSiteResponse, +} from '../interfaces'; +import { toast, wsJsonToRes } from '../utils'; +import { WebSocketService, UserService } from '../services'; import { i18n } from '../i18next'; -export class CreateCommunity extends Component<any, any> { +interface CreateCommunityState { + enableNsfw: boolean; +} + +export class CreateCommunity extends Component<any, CreateCommunityState> { + private subscription: Subscription; + private emptyState: CreateCommunityState = { + enableNsfw: null, + }; constructor(props: any, context: any) { super(props, context); this.handleCommunityCreate = this.handleCommunityCreate.bind(this); + this.state = this.emptyState; + + if (!UserService.Instance.user) { + toast(i18n.t('not_logged_in'), 'danger'); + this.context.router.history.push(`/login`); + } + + 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') + ); + + WebSocketService.Instance.getSite(); } - componentDidMount() { - document.title = `${i18n.t('create_community')} - ${ - WebSocketService.Instance.site.name - }`; + componentWillUnmount() { + this.subscription.unsubscribe(); } render() { @@ -22,7 +52,10 @@ export class CreateCommunity extends Component<any, any> { <div class="row"> <div class="col-12 col-lg-6 offset-lg-3 mb-4"> <h5>{i18n.t('create_community')}</h5> - <CommunityForm onCreate={this.handleCommunityCreate} /> + <CommunityForm + onCreate={this.handleCommunityCreate} + enableNsfw={this.state.enableNsfw} + /> </div> </div> </div> @@ -32,4 +65,18 @@ export class CreateCommunity extends Component<any, any> { handleCommunityCreate(community: Community) { this.props.history.push(`/c/${community.name}`); } + + 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.GetSite) { + let data = res.data as GetSiteResponse; + this.state.enableNsfw = data.site.enable_nsfw; + this.setState(this.state); + document.title = `${i18n.t('create_community')} - ${data.site.name}`; + } + } } |