1 import { Component } from 'inferno';
2 import { Helmet } from 'inferno-helmet';
3 import { Subscription } from 'rxjs';
4 import { retryWhen, delay, take } from 'rxjs/operators';
9 } from 'lemmy-js-client';
10 import { WebSocketService } from '../services';
11 import { wsJsonToRes, toast, isBrowser } from '../utils';
12 import { i18n } from '../i18next';
14 interface InstancesState {
16 siteRes: GetSiteResponse;
19 export class Instances extends Component<any, InstancesState> {
20 private subscription: Subscription;
21 private emptyState: InstancesState = {
26 constructor(props: any, context: any) {
27 super(props, context);
28 this.state = this.emptyState;
31 this.subscription = WebSocketService.Instance.subject
32 .pipe(retryWhen(errors => errors.pipe(delay(3000), take(10))))
34 msg => this.parseMessage(msg),
35 err => console.error(err),
36 () => console.log('complete')
39 WebSocketService.Instance.getSite();
43 componentWillUnmount() {
44 this.subscription.unsubscribe();
47 get documentTitle(): string {
48 if (this.state.siteRes) {
49 return `${i18n.t('instances')} - ${this.state.siteRes.site.name}`;
57 <div class="container">
58 <Helmet title={this.documentTitle} />
59 {this.state.loading ? (
61 <svg class="icon icon-spinner spin">
62 <use xlinkHref="#icon-spinner"></use>
67 <h5>{i18n.t('linked_instances')}</h5>
68 {this.state.siteRes &&
69 this.state.siteRes.federated_instances.length ? (
71 {this.state.siteRes.federated_instances.map(i => (
73 <a href={`https://${i}`} target="_blank" rel="noopener">
80 <div>{i18n.t('none_found')}</div>
88 parseMessage(msg: WebSocketJsonResponse) {
90 let res = wsJsonToRes(msg);
92 toast(i18n.t(msg.error), 'danger');
94 } else if (res.op == UserOperation.GetSite) {
95 let data = res.data as GetSiteResponse;
96 this.state.siteRes = data;
97 this.state.loading = false;
98 this.setState(this.state);