import { Component } from 'inferno'; import { Link } from 'inferno-router'; import { Subscription } from "rxjs"; import { retryWhen, delay, take } from 'rxjs/operators'; import { UserOperation, CommunityUser, GetFollowedCommunitiesResponse, ListCommunitiesForm, ListCommunitiesResponse, Community, SortType, GetSiteResponse, GetRepliesResponse, GetRepliesForm } from '../interfaces'; import { WebSocketService, UserService } from '../services'; import { PostListings } from './post-listings'; import { msgOp, repoUrl, mdToHtml } from '../utils'; interface State { subscribedCommunities: Array; trendingCommunities: Array; site: GetSiteResponse; loading: boolean; } export class Main extends Component { private subscription: Subscription; private emptyState: State = { subscribedCommunities: [], trendingCommunities: [], site: { op: null, site: { id: null, name: null, creator_id: null, creator_name: null, published: null, number_of_users: null, number_of_posts: null, number_of_comments: null, }, admins: [], banned: [], }, loading: true } 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') ); WebSocketService.Instance.getSite(); if (UserService.Instance.user) { WebSocketService.Instance.getFollowedCommunities(); // Get replies for the count let repliesForm: GetRepliesForm = { sort: SortType[SortType.New], unread_only: true, page: 1, limit: 9999, }; WebSocketService.Instance.getReplies(repliesForm); } let listCommunitiesForm: ListCommunitiesForm = { sort: SortType[SortType.New], limit: 6 } WebSocketService.Instance.listCommunities(listCommunitiesForm); } componentWillUnmount() { this.subscription.unsubscribe(); } render() { return (
{this.state.loading ?
:
{this.trendingCommunities()} {UserService.Instance.user && this.state.subscribedCommunities.length > 0 &&
Subscribed forums
    {this.state.subscribedCommunities.map(community =>
  • {community.community_name}
  • )}
} {this.landing()}
}
) } trendingCommunities() { return (
Trending forums
    {this.state.trendingCommunities.map(community =>
  • {community.name}
  • )}
) } landing() { return (
{`${this.state.site.site.name}`}
  • {this.state.site.site.number_of_users} Users
  • {this.state.site.site.number_of_posts} Posts
  • {this.state.site.site.number_of_comments} Comments
  • Modlog
  • admins:
  • {this.state.site.admins.map(admin =>
  • {admin.name}
  • )}
{this.state.site.site.description &&


}
Welcome to LemmyBeta

Lemmy is a link aggregator / reddit alternative, intended to work in the fediverse.

Its self-hostable, has live-updating comment threads, and is tiny (~80kB). Federation into the ActivityPub network is on the roadmap.

This is a very early beta version, and a lot of features are currently broken or missing.

Suggest new features or report bugs here.

Made with Rust, Actix, Inferno, Typescript.

) } parseMessage(msg: any) { console.log(msg); let op: UserOperation = msgOp(msg); if (msg.error) { alert(msg.error); return; } else if (op == UserOperation.GetFollowedCommunities) { let res: GetFollowedCommunitiesResponse = msg; this.state.subscribedCommunities = res.communities; this.state.loading = false; this.setState(this.state); } else if (op == UserOperation.ListCommunities) { let res: ListCommunitiesResponse = msg; this.state.trendingCommunities = res.communities; this.state.loading = false; this.setState(this.state); } else if (op == UserOperation.GetSite) { let res: GetSiteResponse = msg; // This means it hasn't been set up yet if (!res.site) { this.context.router.history.push("/setup"); } this.state.site.admins = res.admins; this.state.site.site = res.site; this.state.site.banned = res.banned; this.setState(this.state); } else if (op == UserOperation.GetReplies) { let res: GetRepliesResponse = msg; this.sendRepliesCount(res); } } sendRepliesCount(res: GetRepliesResponse) { UserService.Instance.sub.next({user: UserService.Instance.user, unreadCount: res.replies.filter(r => !r.read).length}); } }