import { None, Some } from "@sniptt/monads"; import { Component, linkEvent } from "inferno"; import { Helmet } from "inferno-helmet"; import { GetSiteResponse, LoginResponse, Register, toUndefined, UserOperation, wsJsonToRes, wsUserOp, } from "lemmy-js-client"; import { Subscription } from "rxjs"; import { delay, retryWhen, take } from "rxjs/operators"; import { i18n } from "../../i18next"; import { UserService, WebSocketService } from "../../services"; import { setIsoData, toast, wsClient } from "../../utils"; import { Spinner } from "../common/icon"; import { SiteForm } from "./site-form"; interface State { userForm: Register; doneRegisteringUser: boolean; userLoading: boolean; siteRes: GetSiteResponse; } export class Setup extends Component { private subscription: Subscription; private isoData = setIsoData(this.context); private emptyState: State = { userForm: new Register({ username: undefined, password: undefined, password_verify: undefined, show_nsfw: true, // The first admin signup doesn't need a captcha captcha_uuid: None, captcha_answer: None, email: None, honeypot: None, answer: None, }), doneRegisteringUser: UserService.Instance.myUserInfo.isSome(), userLoading: false, siteRes: this.isoData.site_res, }; constructor(props: any, context: any) { super(props, context); this.state = this.emptyState; 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") ); } componentWillUnmount() { this.subscription.unsubscribe(); } get documentTitle(): string { return `${i18n.t("setup")} - Lemmy`; } render() { return (

{i18n.t("lemmy_instance_setup")}

{!this.state.doneRegisteringUser ? ( this.registerUser() ) : ( )}
); } registerUser() { return (
{i18n.t("setup_admin")}
); } handleRegisterSubmit(i: Setup, event: any) { event.preventDefault(); i.setState({ userLoading: true }); event.preventDefault(); WebSocketService.Instance.send(wsClient.register(i.state.userForm)); } handleRegisterUsernameChange(i: Setup, event: any) { i.state.userForm.username = event.target.value; i.setState(i.state); } handleRegisterEmailChange(i: Setup, event: any) { i.state.userForm.email = Some(event.target.value); i.setState(i.state); } handleRegisterPasswordChange(i: Setup, event: any) { i.state.userForm.password = event.target.value; i.setState(i.state); } handleRegisterPasswordVerifyChange(i: Setup, event: any) { i.state.userForm.password_verify = event.target.value; i.setState(i.state); } parseMessage(msg: any) { let op = wsUserOp(msg); if (msg.error) { toast(i18n.t(msg.error), "danger"); this.setState({ userLoading: false }); return; } else if (op == UserOperation.Register) { let data = wsJsonToRes(msg, LoginResponse); this.setState({ userLoading: false }); UserService.Instance.login(data); } else if (op == UserOperation.CreateSite) { window.location.href = "/"; } } }