import { Component, linkEvent } from 'inferno'; import { Subscription } from "rxjs"; import { retryWhen, delay, take } from 'rxjs/operators'; import { LoginForm, RegisterForm, LoginResponse, UserOperation } from '../interfaces'; import { WebSocketService, UserService } from '../services'; import { msgOp } from '../utils'; interface State { loginForm: LoginForm; registerForm: RegisterForm; loginLoading: boolean; registerLoading: boolean; spamNada: string; } export class Login extends Component { private subscription: Subscription; emptyState: State = { loginForm: { username_or_email: undefined, password: undefined }, registerForm: { username: undefined, password: undefined, password_verify: undefined, admin: false, spam_timeri: undefined, }, loginLoading: false, registerLoading: false, spamNada: undefined } 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(); } componentDidMount() { document.title = "Login - Lemmy"; } render() { return (
{this.loginForm()}
{this.registerForm()}
) } loginForm() { return (
Login
Forgot your password or deleted your account? Reset your password. TODO
); } registerForm() { return (
Sign Up
); } handleLoginSubmit(i: Login, event: any) { event.preventDefault(); i.state.loginLoading = true; i.setState(i.state); WebSocketService.Instance.login(i.state.loginForm); } handleLoginUsernameChange(i: Login, event: any) { i.state.loginForm.username_or_email = event.target.value; i.setState(i.state); } handleLoginPasswordChange(i: Login, event: any) { i.state.loginForm.password = event.target.value; i.setState(i.state); } handleRegisterSubmit(i: Login, event: any) { event.preventDefault(); i.state.registerLoading = true; i.setState(i.state); event.preventDefault(); let endTimer = new Date().getTime(); let elapsed = endTimer - i.state.registerForm.spam_timeri; i.state.registerForm.spam_timeri = elapsed; if (elapsed > 1423 && i.state.spamNada == undefined) { WebSocketService.Instance.register(i.state.registerForm); } else { window.location.href = "https://github.com/dessalines/lemmy"; } } handleRegisterUsernameChange(i: Login, event: any) { i.state.registerForm.username = event.target.value; i.state.registerForm.spam_timeri = new Date().getTime(); i.setState(i.state); } handleSpamNada(i: Login, event: any) { i.state.spamNada = event.target.value; i.setState(i.state); } handleRegisterEmailChange(i: Login, event: any) { i.state.registerForm.email = event.target.value; i.setState(i.state); } handleRegisterPasswordChange(i: Login, event: any) { i.state.registerForm.password = event.target.value; i.setState(i.state); } handleRegisterPasswordVerifyChange(i: Login, event: any) { i.state.registerForm.password_verify = event.target.value; i.setState(i.state); } parseMessage(msg: any) { let op: UserOperation = msgOp(msg); if (msg.error) { alert(msg.error); this.state = this.emptyState; this.setState(this.state); return; } else { if (op == UserOperation.Login) { this.state.loginLoading = false; this.state.registerLoading = false; let res: LoginResponse = msg; UserService.Instance.login(res); this.props.history.push('/'); } else if (op == UserOperation.Register) { this.state.loginLoading = false; this.state.registerLoading = false; let res: LoginResponse = msg; UserService.Instance.login(res); this.props.history.push('/communities'); } } } }