summaryrefslogtreecommitdiffstats
path: root/ui/src/services
diff options
context:
space:
mode:
authorDessalines <tyhou13@gmx.com>2019-10-18 17:20:27 -0700
committerDessalines <tyhou13@gmx.com>2019-10-18 17:20:27 -0700
commit4e5561283392d2ab1545cabb4455a8ffc490f86b (patch)
treea4ee9cc096826dc32faf3675212c7f95f1b3ea5e /ui/src/services
parent82ea5ae9186e5a8e631c87a61077e16713eb87a4 (diff)
Running prettier on code.
- #305 , #309
Diffstat (limited to 'ui/src/services')
-rw-r--r--ui/src/services/UserService.ts24
-rw-r--r--ui/src/services/WebSocketService.ts107
2 files changed, 95 insertions, 36 deletions
diff --git a/ui/src/services/UserService.ts b/ui/src/services/UserService.ts
index ac4d4850..5ca5ff07 100644
--- a/ui/src/services/UserService.ts
+++ b/ui/src/services/UserService.ts
@@ -5,13 +5,15 @@ import * as jwt_decode from 'jwt-decode';
import { Subject } from 'rxjs';
export class UserService {
-
private static _instance: UserService;
public user: User;
- public sub: Subject<{user: User, unreadCount: number}> = new Subject<{user: User, unreadCount: number}>();
+ public sub: Subject<{ user: User; unreadCount: number }> = new Subject<{
+ user: User;
+ unreadCount: number;
+ }>();
private constructor() {
- let jwt = Cookies.get("jwt");
+ let jwt = Cookies.get('jwt');
if (jwt) {
this.setUser(jwt);
} else {
@@ -22,30 +24,30 @@ export class UserService {
public login(res: LoginResponse) {
this.setUser(res.jwt);
- Cookies.set("jwt", res.jwt, { expires: 365 });
- console.log("jwt cookie set");
+ Cookies.set('jwt', res.jwt, { expires: 365 });
+ console.log('jwt cookie set');
}
public logout() {
this.user = undefined;
- Cookies.remove("jwt");
+ Cookies.remove('jwt');
setTheme();
- this.sub.next({user: undefined, unreadCount: 0});
- console.log("Logged out.");
+ this.sub.next({ user: undefined, unreadCount: 0 });
+ console.log('Logged out.');
}
public get auth(): string {
- return Cookies.get("jwt");
+ return Cookies.get('jwt');
}
private setUser(jwt: string) {
this.user = jwt_decode(jwt);
setTheme(this.user.theme);
- this.sub.next({user: this.user, unreadCount: 0});
+ this.sub.next({ user: this.user, unreadCount: 0 });
console.log(this.user);
}
- public static get Instance(){
+ public static get Instance() {
return this._instance || (this._instance = new this());
}
}
diff --git a/ui/src/services/WebSocketService.ts b/ui/src/services/WebSocketService.ts
index 987cbfdf..f5d5b513 100644
--- a/ui/src/services/WebSocketService.ts
+++ b/ui/src/services/WebSocketService.ts
@@ -1,5 +1,34 @@
import { wsUri } from '../env';
-import { LoginForm, RegisterForm, UserOperation, CommunityForm, PostForm, SavePostForm, CommentForm, SaveCommentForm, CommentLikeForm, GetPostsForm, CreatePostLikeForm, FollowCommunityForm, GetUserDetailsForm, ListCommunitiesForm, GetModlogForm, BanFromCommunityForm, AddModToCommunityForm, TransferCommunityForm, AddAdminForm, TransferSiteForm, BanUserForm, SiteForm, Site, UserView, GetRepliesForm, SearchForm, UserSettingsForm, DeleteAccountForm } from '../interfaces';
+import {
+ LoginForm,
+ RegisterForm,
+ UserOperation,
+ CommunityForm,
+ PostForm,
+ SavePostForm,
+ CommentForm,
+ SaveCommentForm,
+ CommentLikeForm,
+ GetPostsForm,
+ CreatePostLikeForm,
+ FollowCommunityForm,
+ GetUserDetailsForm,
+ ListCommunitiesForm,
+ GetModlogForm,
+ BanFromCommunityForm,
+ AddModToCommunityForm,
+ TransferCommunityForm,
+ AddAdminForm,
+ TransferSiteForm,
+ BanUserForm,
+ SiteForm,
+ Site,
+ UserView,
+ GetRepliesForm,
+ SearchForm,
+ UserSettingsForm,
+ DeleteAccountForm,
+} from '../interfaces';
import { webSocket } from 'rxjs/webSocket';
import { Subject } from 'rxjs';
import { retryWhen, delay, take } from 'rxjs/operators';
@@ -19,16 +48,23 @@ export class WebSocketService {
// Necessary to not keep reconnecting
this.subject
- .pipe(retryWhen(errors => errors.pipe(delay(60000), take(999))))
+ .pipe(
+ retryWhen(errors =>
+ errors.pipe(
+ delay(60000),
+ take(999)
+ )
+ )
+ )
.subscribe();
- console.log(`Connected to ${wsUri}`);
+ console.log(`Connected to ${wsUri}`);
}
- public static get Instance(){
+ public static get Instance() {
return this._instance || (this._instance = new this());
}
-
+
public login(loginForm: LoginForm) {
this.subject.next(this.wsSendWrapper(UserOperation.Login, loginForm));
}
@@ -39,17 +75,23 @@ export class WebSocketService {
public createCommunity(communityForm: CommunityForm) {
this.setAuth(communityForm);
- this.subject.next(this.wsSendWrapper(UserOperation.CreateCommunity, communityForm));
+ this.subject.next(
+ this.wsSendWrapper(UserOperation.CreateCommunity, communityForm)
+ );
}
public editCommunity(communityForm: CommunityForm) {
this.setAuth(communityForm);
- this.subject.next(this.wsSendWrapper(UserOperation.EditCommunity, communityForm));
+ this.subject.next(
+ this.wsSendWrapper(UserOperation.EditCommunity, communityForm)
+ );
}
public followCommunity(followCommunityForm: FollowCommunityForm) {
this.setAuth(followCommunityForm);
- this.subject.next(this.wsSendWrapper(UserOperation.FollowCommunity, followCommunityForm));
+ this.subject.next(
+ this.wsSendWrapper(UserOperation.FollowCommunity, followCommunityForm)
+ );
}
public listCommunities(form: ListCommunitiesForm) {
@@ -58,12 +100,16 @@ export class WebSocketService {
}
public getFollowedCommunities() {
- let data = {auth: UserService.Instance.auth };
- this.subject.next(this.wsSendWrapper(UserOperation.GetFollowedCommunities, data));
+ let data = { auth: UserService.Instance.auth };
+ this.subject.next(
+ this.wsSendWrapper(UserOperation.GetFollowedCommunities, data)
+ );
}
public listCategories() {
- this.subject.next(this.wsSendWrapper(UserOperation.ListCategories, undefined));
+ this.subject.next(
+ this.wsSendWrapper(UserOperation.ListCategories, undefined)
+ );
}
public createPost(postForm: PostForm) {
@@ -72,33 +118,39 @@ export class WebSocketService {
}
public getPost(postId: number) {
- let data = {id: postId, auth: UserService.Instance.auth };
+ let data = { id: postId, auth: UserService.Instance.auth };
this.subject.next(this.wsSendWrapper(UserOperation.GetPost, data));
}
public getCommunity(communityId: number) {
- let data = {id: communityId, auth: UserService.Instance.auth };
+ let data = { id: communityId, auth: UserService.Instance.auth };
this.subject.next(this.wsSendWrapper(UserOperation.GetCommunity, data));
}
public getCommunityByName(name: string) {
- let data = {name: name, auth: UserService.Instance.auth };
+ let data = { name: name, auth: UserService.Instance.auth };
this.subject.next(this.wsSendWrapper(UserOperation.GetCommunity, data));
}
public createComment(commentForm: CommentForm) {
this.setAuth(commentForm);
- this.subject.next(this.wsSendWrapper(UserOperation.CreateComment, commentForm));
+ this.subject.next(
+ this.wsSendWrapper(UserOperation.CreateComment, commentForm)
+ );
}
public editComment(commentForm: CommentForm) {
this.setAuth(commentForm);
- this.subject.next(this.wsSendWrapper(UserOperation.EditComment, commentForm));
+ this.subject.next(
+ this.wsSendWrapper(UserOperation.EditComment, commentForm)
+ );
}
public likeComment(form: CommentLikeForm) {
this.setAuth(form);
- this.subject.next(this.wsSendWrapper(UserOperation.CreateCommentLike, form));
+ this.subject.next(
+ this.wsSendWrapper(UserOperation.CreateCommentLike, form)
+ );
}
public saveComment(form: SaveCommentForm) {
@@ -133,19 +185,23 @@ export class WebSocketService {
public addModToCommunity(form: AddModToCommunityForm) {
this.setAuth(form);
- this.subject.next(this.wsSendWrapper(UserOperation.AddModToCommunity, form));
+ this.subject.next(
+ this.wsSendWrapper(UserOperation.AddModToCommunity, form)
+ );
}
public transferCommunity(form: TransferCommunityForm) {
this.setAuth(form);
- this.subject.next(this.wsSendWrapper(UserOperation.TransferCommunity, form));
+ this.subject.next(
+ this.wsSendWrapper(UserOperation.TransferCommunity, form)
+ );
}
public transferSite(form: TransferSiteForm) {
this.setAuth(form);
this.subject.next(this.wsSendWrapper(UserOperation.TransferSite, form));
}
-
+
public banUser(form: BanUserForm) {
this.setAuth(form);
this.subject.next(this.wsSendWrapper(UserOperation.BanUser, form));
@@ -196,7 +252,9 @@ export class WebSocketService {
public saveUserSettings(userSettingsForm: UserSettingsForm) {
this.setAuth(userSettingsForm);
- this.subject.next(this.wsSendWrapper(UserOperation.SaveUserSettings, userSettingsForm));
+ this.subject.next(
+ this.wsSendWrapper(UserOperation.SaveUserSettings, userSettingsForm)
+ );
}
public deleteAccount(form: DeleteAccountForm) {
@@ -214,13 +272,12 @@ export class WebSocketService {
obj.auth = UserService.Instance.auth;
if (obj.auth == null && throwErr) {
alert(i18n.t('not_logged_in'));
- throw "Not logged in";
+ throw 'Not logged in';
}
}
}
-window.onbeforeunload = (() => {
+window.onbeforeunload = () => {
WebSocketService.Instance.subject.unsubscribe();
WebSocketService.Instance.subject = null;
-});
-
+};