This commit is contained in:
Eudes Inácio
2022-02-08 15:46:12 +01:00
10 changed files with 36 additions and 30 deletions
+4 -1
View File
@@ -1,6 +1,7 @@
import { Injectable } from '@angular/core'; import { Injectable } from '@angular/core';
import { CanActivate, ActivatedRouteSnapshot, RouterStateSnapshot, UrlTree, Router } from '@angular/router'; import { CanActivate, ActivatedRouteSnapshot, RouterStateSnapshot, UrlTree, Router } from '@angular/router';
import { Observable } from 'rxjs'; import { Observable } from 'rxjs';
import { AuthService } from '../services/auth.service';
import { LocalstoreService } from '../store/localstore.service'; import { LocalstoreService } from '../store/localstore.service';
import { SessionStore } from '../store/session.service'; import { SessionStore } from '../store/session.service';
@@ -10,7 +11,8 @@ import { SessionStore } from '../store/session.service';
export class AuthGuard implements CanActivate { export class AuthGuard implements CanActivate {
constructor( constructor(
private router:Router, private router:Router,
private localstoreService: LocalstoreService private localstoreService: LocalstoreService,
private authService: AuthService,
){} ){}
canActivate( canActivate(
@@ -27,6 +29,7 @@ export class AuthGuard implements CanActivate {
this.router.navigate(['/']); this.router.navigate(['/']);
return false return false
} else { } else {
this.authService.loginChat(SessionStore.user)
return true return true
} }
} }
@@ -84,7 +84,6 @@ export class SetRoomOwnerPage implements OnInit {
} }
this.chatService.addGroupOwner(body).subscribe((res)=>{ this.chatService.addGroupOwner(body).subscribe((res)=>{
alert('here');
console.log(res); console.log(res);
this.close(); this.close();
this.toastService._successMessage('Operação realizada com sucesso'); this.toastService._successMessage('Operação realizada com sucesso');
@@ -261,7 +261,6 @@ export class BookMeetingModalPage implements OnInit {
} }
if(this.task.FsId == '8') { if(this.task.FsId == '8') {
alert('Chegou')
const loader = this.toastService.loading() const loader = this.toastService.loading()
try { try {
switch (this.loggeduser.Profile) { switch (this.loggeduser.Profile) {
-1
View File
@@ -100,7 +100,6 @@ export class LoginPage implements OnInit {
// login to API successfully // login to API successfully
if (attempt) { if (attempt) {
if (attempt.UserId == SessionStore.user.UserId) { if (attempt.UserId == SessionStore.user.UserId) {
await this.authService.SetSession(attempt, this.userattempt); await this.authService.SetSession(attempt, this.userattempt);
await this.authService.loginChat(this.userattempt); await this.authService.loginChat(this.userattempt);
+18 -11
View File
@@ -107,12 +107,17 @@ export class AuthService {
} }
} }
//Login to rocketChat server //Login to rocketChat server2
async loginChat(user: UserForm) { //user: UserForm
const expireDate = new Date(new Date().getTime() + 60*1000); async loginChat(user: any) {
const expirationMinutes = 60;
let date = new Date().getTime();
let expirationDate = new Date(new Date().getTime() + expirationMinutes*60*1000);
let postData = { let postData = {
"user": user.username, "user": user.RochetChatUser,
"password": user.password, "password": user.Password,
} }
let responseChat = await this.httpService.post('login', postData).toPromise(); let responseChat = await this.httpService.post('login', postData).toPromise();
@@ -125,17 +130,19 @@ export class AuthService {
this.ValidatedUserChat = responseChat; this.ValidatedUserChat = responseChat;
localStorage.setItem('userChat', JSON.stringify(responseChat)); localStorage.setItem('userChat', JSON.stringify(responseChat));
this.storageService.store(AuthConnstants.AUTH, responseChat); this.storageService.store(AuthConnstants.AUTH, responseChat);
/* this.autologout(10000); */
return true;
} }
else{ else{
console.log('Network error'); console.log('Network error');
this.presentAlert('Network error'); this.presentAlert('Network error');
return false;
} }
this.autoLoginChat(expirationDate.getTime() - date, user);
}
async autoLoginChat(expirationDate:number, user:any){
setTimeout(()=>{
this.loginChat(user);
}, expirationDate)
} }
private loginToChatWs() { private loginToChatWs() {
@@ -187,12 +187,12 @@ export class WsChatMethodsService {
*/ */
private defaultSubtribe(id: any) { private defaultSubtribe(id: any) {
this.WsChatService.streamRoomMessages(id).then((subscription)=>{ this.WsChatService.streamRoomMessages(id).then((subscription)=>{
console.log('streamRoomMessages', subscription) //console.log('streamRoomMessages', subscription)
}) })
this.WsChatService.subStreamNotifyRoom(id, 'typing', false) this.WsChatService.subStreamNotifyRoom(id, 'typing', false)
this.WsChatService.streamNotifyRoomDeleteMessage(id).then((subscription)=>{ this.WsChatService.streamNotifyRoomDeleteMessage(id).then((subscription)=>{
console.log('streamNotifyRoomDeleteMessage', subscription); //console.log('streamNotifyRoomDeleteMessage', subscription);
}) })
} }
+2 -2
View File
@@ -657,11 +657,11 @@ updateRoomEventss(roomId, collection:string, funx: Function, ) {
for (const [key, item] of Object.entries(this.wsMsgQueue)) { for (const [key, item] of Object.entries(this.wsMsgQueue)) {
if(item.loginRequired == true && this.isLogin == true) { if(item.loginRequired == true && this.isLogin == true) {
console.log('run msgQueue ', key) //console.log('run msgQueue ', key)
this.ws.send(item); this.ws.send(item);
delete this.wsMsgQueue[key] delete this.wsMsgQueue[key]
} else if(item.loginRequired == false) { } else if(item.loginRequired == false) {
console.log('run msgQueue ', key) //console.log('run msgQueue ', key)
this.ws.send(item); this.ws.send(item);
delete this.wsMsgQueue[key] delete this.wsMsgQueue[key]
} }
@@ -67,7 +67,6 @@ export class NewGroupPage implements OnInit{
} }
/* ngOnDestroy(){ /* ngOnDestroy(){
alert('Destroy')
this.dataService.set("newGroup", false); this.dataService.set("newGroup", false);
this.dataService.set("task", null); this.dataService.set("task", null);
this.dataService.set("newGroupName", ''); this.dataService.set("newGroupName", '');