Compare commits
No commits in common. "95a593bdb6ca6108f39639daa81bc9b79655fe80" and "e82a0ecb5e9d1d18cf4b6ab5402407e56b323626" have entirely different histories.
95a593bdb6
...
e82a0ecb5e
1202
package-lock.json
generated
1202
package-lock.json
generated
File diff suppressed because it is too large
Load Diff
30
package.json
30
package.json
@ -10,29 +10,29 @@
|
|||||||
},
|
},
|
||||||
"private": true,
|
"private": true,
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@angular/animations": "^18.1.3",
|
"@angular/animations": "^18.1.1",
|
||||||
"@angular/cdk": "~18.1.3",
|
"@angular/cdk": "~18.1.1",
|
||||||
"@angular/cdk-experimental": "^18.1.3",
|
"@angular/cdk-experimental": "^18.1.1",
|
||||||
"@angular/common": "^18.1.3",
|
"@angular/common": "^18.1.1",
|
||||||
"@angular/compiler": "^18.1.3",
|
"@angular/compiler": "^18.1.1",
|
||||||
"@angular/core": "^18.1.3",
|
"@angular/core": "^18.1.1",
|
||||||
"@angular/forms": "^18.1.3",
|
"@angular/forms": "^18.1.1",
|
||||||
"@angular/material": "~18.1.3",
|
"@angular/material": "~18.1.1",
|
||||||
"@angular/platform-browser": "^18.1.3",
|
"@angular/platform-browser": "^18.1.1",
|
||||||
"@angular/platform-browser-dynamic": "^18.1.3",
|
"@angular/platform-browser-dynamic": "^18.1.1",
|
||||||
"@angular/router": "^18.1.3",
|
"@angular/router": "^18.1.1",
|
||||||
"@progress/kendo-date-math": "^1.5.13",
|
"@progress/kendo-date-math": "^1.5.13",
|
||||||
"rxjs": "~7.8.1",
|
"rxjs": "~7.8.1",
|
||||||
"tslib": "^2.6.3",
|
"tslib": "^2.6.3",
|
||||||
"zone.js": "~0.14.8"
|
"zone.js": "~0.14.8"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@angular-devkit/build-angular": "^18.1.3",
|
"@angular-devkit/build-angular": "^18.1.1",
|
||||||
"@angular/cli": "^18.1.3",
|
"@angular/cli": "^18.1.1",
|
||||||
"@angular/compiler-cli": "^18.1.3",
|
"@angular/compiler-cli": "^18.1.1",
|
||||||
"@types/jasmine": "~5.1.4",
|
"@types/jasmine": "~5.1.4",
|
||||||
"jasmine-core": "~5.2.0",
|
"jasmine-core": "~5.2.0",
|
||||||
"karma": "~6.4.4",
|
"karma": "~6.4.3",
|
||||||
"karma-chrome-launcher": "~3.2.0",
|
"karma-chrome-launcher": "~3.2.0",
|
||||||
"karma-coverage": "~2.2.1",
|
"karma-coverage": "~2.2.1",
|
||||||
"karma-jasmine": "~5.1.0",
|
"karma-jasmine": "~5.1.0",
|
||||||
|
@ -98,7 +98,7 @@ export class RequestBuilder {
|
|||||||
data: null,
|
data: null,
|
||||||
silenceMode: false,
|
silenceMode: false,
|
||||||
withCredentials: false
|
withCredentials: false
|
||||||
};
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public reset(): void {
|
public reset(): void {
|
||||||
|
@ -73,16 +73,17 @@ export default abstract class ApiService implements SetRequestBuilderAfterBuild
|
|||||||
}
|
}
|
||||||
|
|
||||||
protected get combinedUrl() {
|
protected get combinedUrl() {
|
||||||
return ApiService.addQuery(ApiService.combineUrls(this.apiUrl, AvailableVersion[this.version], this.basePath, this.request.endpoint), this.request.queryParams);
|
return ApiService.addQuery(ApiService.combineUrls(this.apiUrl, AvailableVersion[this.version], this.basePath, this.request.endpoint), this.request.queryParams)
|
||||||
}
|
}
|
||||||
|
|
||||||
private makeHttpRequest<Type>(method: 'get' | 'post' | 'delete' | 'put'): Observable<Type> {
|
private makeHttpRequest<Type>(method: 'get' | 'post' | 'delete' | 'put'): Observable<Type> {
|
||||||
const doneEndpoint = this.combinedUrl;
|
const doneEndpoint = this.combinedUrl;
|
||||||
|
|
||||||
return this.tokenRefreshService.getTokenRefreshing$().pipe(
|
return this.tokenRefreshService.getTokenRefreshing$().pipe(
|
||||||
filter(isRefreshing => !isRefreshing),
|
filter(refreshing => !refreshing),
|
||||||
switchMap(() =>
|
take(1),
|
||||||
this.http.request<Type>(method, doneEndpoint, {
|
switchMap(_ => {
|
||||||
|
return this.http.request<Type>(method, doneEndpoint, {
|
||||||
withCredentials: this.request.withCredentials,
|
withCredentials: this.request.withCredentials,
|
||||||
headers: this.request.httpHeaders,
|
headers: this.request.httpHeaders,
|
||||||
body: this.request.data
|
body: this.request.data
|
||||||
@ -96,8 +97,8 @@ export default abstract class ApiService implements SetRequestBuilderAfterBuild
|
|||||||
this.request = RequestBuilder.getStandardRequestData();
|
this.request = RequestBuilder.getStandardRequestData();
|
||||||
throw error;
|
throw error;
|
||||||
})
|
})
|
||||||
)
|
);
|
||||||
)
|
})
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -137,7 +138,7 @@ export default abstract class ApiService implements SetRequestBuilderAfterBuild
|
|||||||
return this;
|
return this;
|
||||||
|
|
||||||
const authToken = AuthToken.httpHeader((JSON.parse(token) as AuthToken));
|
const authToken = AuthToken.httpHeader((JSON.parse(token) as AuthToken));
|
||||||
authToken.keys().forEach(key => this.request.httpHeaders = this.request.httpHeaders.append(key, authToken.get(key) ?? ''));
|
authToken.keys().forEach(key => this.request.httpHeaders = this.request.httpHeaders.append(key, authToken.get(key) ?? ''))
|
||||||
|
|
||||||
return this;
|
return this;
|
||||||
}
|
}
|
||||||
|
@ -1,54 +0,0 @@
|
|||||||
import {Injectable} from "@angular/core";
|
|
||||||
import ApiService, {AvailableVersion} from "@api/api.service";
|
|
||||||
import {LoginRequest} from "@api/v1/loginRequest";
|
|
||||||
import {TokenResponse} from "@api/v1/tokenResponse";
|
|
||||||
import {catchError, of, tap} from "rxjs";
|
|
||||||
import {AuthRoles} from "@model/AuthRoles";
|
|
||||||
import {AuthService, AvailableAuthenticationProvider} from "@service/auth.service";
|
|
||||||
|
|
||||||
@Injectable()
|
|
||||||
export default class AuthApiService extends ApiService {
|
|
||||||
public readonly basePath = 'Auth/';
|
|
||||||
public readonly version = AvailableVersion.v1;
|
|
||||||
|
|
||||||
public login(login: LoginRequest) {
|
|
||||||
return this.createRequestBuilder()
|
|
||||||
.setEndpoint('Login')
|
|
||||||
.setData(login)
|
|
||||||
.build<ApiService>()
|
|
||||||
.post<TokenResponse>()
|
|
||||||
.pipe(
|
|
||||||
tap(response => {
|
|
||||||
AuthService.setToken(response, AvailableAuthenticationProvider.Bearer, this.createRequestBuilder().setEndpoint('ReLogin').build<AuthApiService>().combinedUrl);
|
|
||||||
this.tokenRefreshService.startTokenRefresh(response.expiresIn);
|
|
||||||
})
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
public logout() {
|
|
||||||
return this.createRequestBuilder()
|
|
||||||
.setWithCredentials()
|
|
||||||
.setEndpoint('Logout')
|
|
||||||
.build<ApiService>()
|
|
||||||
.addAuth()
|
|
||||||
.get()
|
|
||||||
.pipe(
|
|
||||||
tap(_ => {
|
|
||||||
localStorage.removeItem(ApiService.tokenKey);
|
|
||||||
})
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
public getRole(isSilence: boolean = true) {
|
|
||||||
return this.createRequestBuilder()
|
|
||||||
.setSilenceMode(isSilence)
|
|
||||||
.build<ApiService>()
|
|
||||||
.addAuth()
|
|
||||||
.get<AuthRoles>('GetRole')
|
|
||||||
.pipe(
|
|
||||||
catchError(_ => {
|
|
||||||
return of(null);
|
|
||||||
})
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
@ -8,7 +8,6 @@ import {ScheduleComponent as SetupScheduleComponent} from "@page/setup/schedule/
|
|||||||
import {SetupComponent} from "@page/setup/setup.component";
|
import {SetupComponent} from "@page/setup/setup.component";
|
||||||
import {CreateAdminComponent} from "@page/setup/create-admin/create-admin.component";
|
import {CreateAdminComponent} from "@page/setup/create-admin/create-admin.component";
|
||||||
import {SummaryComponent} from "@page/setup/summary/summary.component";
|
import {SummaryComponent} from "@page/setup/summary/summary.component";
|
||||||
import {LoginComponent} from "@page/login/login.component";
|
|
||||||
|
|
||||||
export const routes: Routes = [
|
export const routes: Routes = [
|
||||||
{path: '', title: 'Расписание', pathMatch: 'full', component: ScheduleComponent},
|
{path: '', title: 'Расписание', pathMatch: 'full', component: ScheduleComponent},
|
||||||
@ -23,8 +22,7 @@ export const routes: Routes = [
|
|||||||
{path: 'summary', component: SummaryComponent},
|
{path: 'summary', component: SummaryComponent},
|
||||||
{path: '', redirectTo: 'welcome', pathMatch: 'full'}
|
{path: '', redirectTo: 'welcome', pathMatch: 'full'}
|
||||||
]
|
]
|
||||||
},
|
}
|
||||||
{path: 'login', title: 'Вход', component: LoginComponent},
|
|
||||||
/*{path: 'not-found', title: '404 страница не найдена'},
|
/*{path: 'not-found', title: '404 страница не найдена'},
|
||||||
{path: '**', redirectTo: '/not-found'}*/
|
{path: '**', redirectTo: '/not-found'}*/
|
||||||
];
|
];
|
||||||
|
@ -1,34 +0,0 @@
|
|||||||
import {Directive, Input, TemplateRef, ViewContainerRef} from '@angular/core';
|
|
||||||
import AuthApiService from "@api/v1/authApiService";
|
|
||||||
import {AuthRoles} from "@model/AuthRoles";
|
|
||||||
import {catchError, of} from "rxjs";
|
|
||||||
|
|
||||||
@Directive({
|
|
||||||
selector: '[appHasRole]',
|
|
||||||
standalone: true,
|
|
||||||
providers: [AuthApiService]
|
|
||||||
})
|
|
||||||
export class HasRoleDirective {
|
|
||||||
constructor(
|
|
||||||
private templateRef: TemplateRef<any>,
|
|
||||||
private viewContainer: ViewContainerRef,
|
|
||||||
private authService: AuthApiService
|
|
||||||
) {}
|
|
||||||
|
|
||||||
@Input() set appHasRole(role: AuthRoles) {
|
|
||||||
this.viewContainer.clear();
|
|
||||||
|
|
||||||
this.authService
|
|
||||||
.getRole()
|
|
||||||
.pipe(catchError(error => {
|
|
||||||
this.viewContainer.clear();
|
|
||||||
return of(null);
|
|
||||||
}))
|
|
||||||
.subscribe(data => {
|
|
||||||
if (data === role)
|
|
||||||
this.viewContainer.createEmbeddedView(this.templateRef);
|
|
||||||
else
|
|
||||||
this.viewContainer.clear();
|
|
||||||
})
|
|
||||||
}
|
|
||||||
}
|
|
@ -1,26 +0,0 @@
|
|||||||
.formLogin {
|
|
||||||
display: flex;
|
|
||||||
padding: 20px;
|
|
||||||
justify-content: center;
|
|
||||||
align-items: center;
|
|
||||||
min-height: 40vh;
|
|
||||||
height: auto;
|
|
||||||
}
|
|
||||||
|
|
||||||
.formLogin mat-card {
|
|
||||||
padding: 25px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.formLogin p {
|
|
||||||
text-align: center
|
|
||||||
}
|
|
||||||
|
|
||||||
.formLogin form {
|
|
||||||
display: flex;
|
|
||||||
flex-direction:column;
|
|
||||||
}
|
|
||||||
|
|
||||||
.formLoginButton {
|
|
||||||
display: flex;
|
|
||||||
justify-content: flex-end;
|
|
||||||
}
|
|
@ -1,76 +0,0 @@
|
|||||||
<mat-sidenav-container class="formLogin">
|
|
||||||
|
|
||||||
<mat-card>
|
|
||||||
<p class="mat-h3">
|
|
||||||
Вход в систему
|
|
||||||
</p>
|
|
||||||
|
|
||||||
<form [formGroup]="loginForm">
|
|
||||||
<mat-form-field color="accent">
|
|
||||||
<mat-label>Имя пользователя/email</mat-label>
|
|
||||||
<input matInput
|
|
||||||
formControlName="user"
|
|
||||||
matTooltip='Укажите имя пользователя используя латинские буквы и цифры без пробелов или email'
|
|
||||||
required
|
|
||||||
focusNext="passwordNextFocus">
|
|
||||||
|
|
||||||
@if (loginForm.get('user')?.hasError('required')) {
|
|
||||||
<mat-error>
|
|
||||||
Имя пользователя или email является <i>обязательным</i>
|
|
||||||
</mat-error>
|
|
||||||
}
|
|
||||||
|
|
||||||
@if (loginForm.get('user')?.hasError('minlength')) {
|
|
||||||
<mat-error>
|
|
||||||
Количество символов должно быть не менее 4
|
|
||||||
</mat-error>
|
|
||||||
}
|
|
||||||
</mat-form-field>
|
|
||||||
|
|
||||||
<mat-form-field color="accent" style="margin-bottom: 20px">
|
|
||||||
<mat-label>Пароль</mat-label>
|
|
||||||
<input matInput
|
|
||||||
matTooltip="Укажите пароль"
|
|
||||||
formControlName="password"
|
|
||||||
required
|
|
||||||
[type]="hidePass ? 'password' : 'text'"
|
|
||||||
id="passwordNextFocus"
|
|
||||||
focusNext="loginNextFocus">
|
|
||||||
|
|
||||||
<button mat-icon-button matSuffix (click)="togglePassword($event)" [attr.aria-label]="'Hide password'"
|
|
||||||
[attr.aria-pressed]="hidePass">
|
|
||||||
<mat-icon>{{ hidePass ? 'visibility_off' : 'visibility' }}</mat-icon>
|
|
||||||
</button>
|
|
||||||
|
|
||||||
@if (loginForm.get('password')?.hasError('required')) {
|
|
||||||
<mat-error>
|
|
||||||
Пароль является <i>обязательным</i>
|
|
||||||
</mat-error>
|
|
||||||
}
|
|
||||||
|
|
||||||
@if (loginForm.get('password')?.hasError('minlength')) {
|
|
||||||
<mat-error>
|
|
||||||
Пароль должен быть не менее 8 символов
|
|
||||||
</mat-error>
|
|
||||||
}
|
|
||||||
</mat-form-field>
|
|
||||||
</form>
|
|
||||||
|
|
||||||
<mat-error>
|
|
||||||
{{errorText}}
|
|
||||||
</mat-error>
|
|
||||||
|
|
||||||
<div class="formLoginButton">
|
|
||||||
@if (loaderActive) {
|
|
||||||
<app-data-spinner [scale]="40"/>
|
|
||||||
} @else {
|
|
||||||
<button mat-flat-button color="accent"
|
|
||||||
[disabled]="loginButtonIsDisable"
|
|
||||||
(click)="login()"
|
|
||||||
id="loginNextFocus">
|
|
||||||
Войти
|
|
||||||
</button>
|
|
||||||
}
|
|
||||||
</div>
|
|
||||||
</mat-card>
|
|
||||||
</mat-sidenav-container>
|
|
@ -1,95 +0,0 @@
|
|||||||
import {Component} from '@angular/core';
|
|
||||||
import {MatSidenavContainer} from "@angular/material/sidenav";
|
|
||||||
import {MatFormFieldModule} from "@angular/material/form-field";
|
|
||||||
import {MatInput} from "@angular/material/input";
|
|
||||||
import {MatTooltip} from "@angular/material/tooltip";
|
|
||||||
import {MatIcon} from "@angular/material/icon";
|
|
||||||
import {MatButton, MatIconButton} from "@angular/material/button";
|
|
||||||
import {MatCard} from "@angular/material/card";
|
|
||||||
import {FormBuilder, FormGroup, ReactiveFormsModule, Validators} from "@angular/forms";
|
|
||||||
import {FocusNextDirective} from "@/directives/focus-next.directive";
|
|
||||||
import {DataSpinnerComponent} from "@component/common/data-spinner/data-spinner.component";
|
|
||||||
import AuthApiService from "@api/v1/authApiService";
|
|
||||||
import {Router} from "@angular/router";
|
|
||||||
import {catchError, of} from "rxjs";
|
|
||||||
|
|
||||||
@Component({
|
|
||||||
selector: 'app-login',
|
|
||||||
standalone: true,
|
|
||||||
imports: [
|
|
||||||
MatSidenavContainer,
|
|
||||||
MatFormFieldModule,
|
|
||||||
MatInput,
|
|
||||||
MatTooltip,
|
|
||||||
MatIcon,
|
|
||||||
MatIconButton,
|
|
||||||
MatButton,
|
|
||||||
MatCard,
|
|
||||||
ReactiveFormsModule,
|
|
||||||
FocusNextDirective,
|
|
||||||
DataSpinnerComponent
|
|
||||||
],
|
|
||||||
templateUrl: './login.component.html',
|
|
||||||
styleUrl: './login.component.css',
|
|
||||||
providers: [AuthApiService]
|
|
||||||
})
|
|
||||||
export class LoginComponent {
|
|
||||||
protected loginForm!: FormGroup;
|
|
||||||
protected hidePass: boolean = true;
|
|
||||||
protected loaderActive: boolean = false;
|
|
||||||
protected loginButtonIsDisable: boolean = true;
|
|
||||||
protected errorText: string = '';
|
|
||||||
|
|
||||||
constructor(private formBuilder: FormBuilder, private auth: AuthApiService, private route: Router) {
|
|
||||||
this.auth.getRole()
|
|
||||||
.subscribe(data => {
|
|
||||||
if (data != null)
|
|
||||||
route.navigate(['admin']).then();
|
|
||||||
});
|
|
||||||
|
|
||||||
this.loginForm = this.formBuilder.group({
|
|
||||||
user: ['',],
|
|
||||||
password: ['',]
|
|
||||||
}
|
|
||||||
);
|
|
||||||
|
|
||||||
this.loginForm.get('password')?.setValidators([
|
|
||||||
Validators.required,
|
|
||||||
Validators.minLength(8)
|
|
||||||
]);
|
|
||||||
|
|
||||||
this.loginForm.get('user')?.setValidators([
|
|
||||||
Validators.required,
|
|
||||||
Validators.minLength(4)
|
|
||||||
]);
|
|
||||||
|
|
||||||
this.loginForm.valueChanges.subscribe(() => {
|
|
||||||
this.loginButtonIsDisable = !this.loginForm.valid;
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
protected togglePassword(event: MouseEvent) {
|
|
||||||
this.hidePass = !this.hidePass;
|
|
||||||
event.stopPropagation();
|
|
||||||
}
|
|
||||||
|
|
||||||
protected login() {
|
|
||||||
this.loaderActive = true;
|
|
||||||
|
|
||||||
this.auth.login({
|
|
||||||
username: this.loginForm.get('user')?.value,
|
|
||||||
password: this.loginForm.get('password')?.value
|
|
||||||
})
|
|
||||||
.pipe(catchError(error => {
|
|
||||||
this.loaderActive = false;
|
|
||||||
this.errorText = error.error;
|
|
||||||
this.loginButtonIsDisable = true;
|
|
||||||
throw error;
|
|
||||||
}))
|
|
||||||
.subscribe(_ => {
|
|
||||||
this.loaderActive = false;
|
|
||||||
this.errorText = '';
|
|
||||||
this.route.navigate(['admin']).then();
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
@ -1,6 +1,5 @@
|
|||||||
<mat-sidenav-container class="schedule">
|
<mat-sidenav-container class="schedule">
|
||||||
<app-tabs (eventResult)="result($event)"/>
|
<app-tabs (eventResult)="result($event)"/>
|
||||||
<app-table-header [startWeek]="startWeek" [currentWeek]="currentWeek" (weekEvent)="handleWeekEvent($event)"
|
<app-table-header [startWeek]="startWeek" [currentWeek]="currentWeek" (weekEvent)="handleWeekEvent($event)" #tableHeader/>
|
||||||
#tableHeader/>
|
|
||||||
<app-table [currentWeek]="currentWeek" [startWeek]="startWeek" [data]="data" [isLoad]="isLoadTable"/>
|
<app-table [currentWeek]="currentWeek" [startWeek]="startWeek" [data]="data" [isLoad]="isLoadTable"/>
|
||||||
</mat-sidenav-container>
|
</mat-sidenav-container>
|
||||||
|
@ -61,7 +61,7 @@ export class AuthService {
|
|||||||
const token = localStorage.getItem(ApiService.tokenKey);
|
const token = localStorage.getItem(ApiService.tokenKey);
|
||||||
|
|
||||||
if (!token)
|
if (!token)
|
||||||
return of({} as TokenResponse);
|
return of();
|
||||||
|
|
||||||
const authToken = JSON.parse(token) as AuthToken;
|
const authToken = JSON.parse(token) as AuthToken;
|
||||||
|
|
||||||
|
@ -1,8 +1,7 @@
|
|||||||
import {BehaviorSubject, filter, interval, Subscription, switchMap} from "rxjs";
|
import {BehaviorSubject, interval, Subscription, switchMap} from "rxjs";
|
||||||
import {Injectable} from "@angular/core";
|
import {Injectable} from "@angular/core";
|
||||||
import {AuthService} from "@service/auth.service";
|
import {AuthService} from "@service/auth.service";
|
||||||
import {environment} from "@environment";
|
import {environment} from "@environment";
|
||||||
import ApiService from "@api/api.service";
|
|
||||||
|
|
||||||
@Injectable({
|
@Injectable({
|
||||||
providedIn: 'root',
|
providedIn: 'root',
|
||||||
@ -16,12 +15,12 @@ export class TokenRefreshService {
|
|||||||
this.setRefreshTokenExpireMs(AuthService.tokenExpiresIn.getTime() - 1000 - Date.now());
|
this.setRefreshTokenExpireMs(AuthService.tokenExpiresIn.getTime() - 1000 - Date.now());
|
||||||
|
|
||||||
authService.tokenChangeError.subscribe(_ => {
|
authService.tokenChangeError.subscribe(_ => {
|
||||||
console.debug('Token change error event received');
|
console.log('Token change error event received');
|
||||||
this.tokenRefreshing$.next(false);
|
this.tokenRefreshing$.next(false);
|
||||||
this.stopTokenRefresh();
|
this.stopTokenRefresh();
|
||||||
});
|
});
|
||||||
authService.expireTokenChange.subscribe(date => {
|
authService.expireTokenChange.subscribe(date => {
|
||||||
console.debug('Expire token change event received:', date);
|
console.log('Expire token change event received:', date);
|
||||||
this.setRefreshTokenExpireMs(date.getTime() - 1000 - Date.now());
|
this.setRefreshTokenExpireMs(date.getTime() - 1000 - Date.now());
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
@ -30,15 +29,10 @@ export class TokenRefreshService {
|
|||||||
if (date)
|
if (date)
|
||||||
this.refreshTokenExpireMs = new Date(date).getTime() - 1000 - Date.now();
|
this.refreshTokenExpireMs = new Date(date).getTime() - 1000 - Date.now();
|
||||||
|
|
||||||
console.debug(this.tokenRefreshSubscription);
|
if (!this.tokenRefreshSubscription || this.tokenRefreshSubscription.closed) {
|
||||||
if (this.tokenRefreshSubscription && !this.tokenRefreshSubscription.closed)
|
|
||||||
return;
|
|
||||||
|
|
||||||
this.tokenRefreshSubscription = interval(this.refreshTokenExpireMs).pipe(
|
this.tokenRefreshSubscription = interval(this.refreshTokenExpireMs).pipe(
|
||||||
filter(isRefreshing => !isRefreshing),
|
|
||||||
switchMap(() => {
|
switchMap(() => {
|
||||||
this.tokenRefreshing$.next(true);
|
this.tokenRefreshing$.next(true);
|
||||||
console.debug('Send query to refresh token');
|
|
||||||
return this.authService.refreshToken();
|
return this.authService.refreshToken();
|
||||||
})
|
})
|
||||||
).subscribe({
|
).subscribe({
|
||||||
@ -46,11 +40,12 @@ export class TokenRefreshService {
|
|||||||
this.tokenRefreshing$.next(false);
|
this.tokenRefreshing$.next(false);
|
||||||
},
|
},
|
||||||
error: error => {
|
error: error => {
|
||||||
|
console.error('Token refresh error:', error);
|
||||||
this.tokenRefreshing$.next(false);
|
this.tokenRefreshing$.next(false);
|
||||||
localStorage.removeItem(ApiService.tokenKey);
|
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
public getTokenRefreshing$(): BehaviorSubject<boolean> {
|
public getTokenRefreshing$(): BehaviorSubject<boolean> {
|
||||||
return this.tokenRefreshing$;
|
return this.tokenRefreshing$;
|
||||||
@ -65,12 +60,13 @@ export class TokenRefreshService {
|
|||||||
|
|
||||||
public setRefreshTokenExpireMs(expireMs: number): void {
|
public setRefreshTokenExpireMs(expireMs: number): void {
|
||||||
if (expireMs < environment.retryDelay)
|
if (expireMs < environment.retryDelay)
|
||||||
expireMs = environment.retryDelay;
|
expireMs = 3000;
|
||||||
|
|
||||||
this.refreshTokenExpireMs = expireMs;
|
|
||||||
|
|
||||||
console.log(expireMs);
|
console.log(expireMs);
|
||||||
|
this.refreshTokenExpireMs = expireMs;
|
||||||
|
|
||||||
this.stopTokenRefresh();
|
this.stopTokenRefresh();
|
||||||
this.startTokenRefresh();
|
this.startTokenRefresh();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1,3 +0,0 @@
|
|||||||
export enum AuthRoles {
|
|
||||||
Admin
|
|
||||||
}
|
|
Loading…
Reference in New Issue
Block a user