421.7 Abp microserices and Keycloak - chempkovsky/CS82ANGULAR GitHub Wiki

import { Environment } from '@abp/ng.core';

const baseUrl = 'http://localhost:4200';

export const environment = {
  production: false,
  application: {
    baseUrl: 'http://localhost:4200/',
    name: 'tstapp_angular',
    logoUrl: '',
  },
  oAuthConfig: {
    issuer: 'https://kc.rupbes.by:8445/realms/rupbes.tstrealm',
    redirectUri: baseUrl,
    clientId: 'tstapp_angular',
    responseType: 'code',
    scope: 'offline_access tstapihost_scope tstauth_scope tenantid roles email phone',
    requireHttps: true
  },
  apis: {
    default: {
      url: 'https://localhost:54635/',
      rootNamespace: 'rupbes.tstapp',
    },
    tstapp: {
      url: 'https://localhost:44323',
      rootNamespace: 'rupbes.tstapp',
    },
  },
} as Environment;

    // providers: [
    // ...
    // {
    //     provide: HTTP_INTERCEPTORS,
    //     useExisting:  CustomOAuthApiInterceptor,
    //     multi: true
    // },
    // { provide: OAuthApiInterceptor, useClass: CustomOAuthApiInterceptor } 
    // ...
    // ]
    //

import { HttpEvent, HttpHandler, HttpHeaders, HttpRequest } from '@angular/common/http';
import { Injectable, inject } from '@angular/core';
import { OAuthService } from 'angular-oauth2-oidc';
import { finalize } from 'rxjs/operators';
import { Observable } from 'rxjs';
import {
  HttpWaitService,
  IApiInterceptor,
  IS_EXTERNAL_REQUEST,
  SessionStateService,
  TENANT_KEY,
} from '@abp/ng.core';
import { OAuthApiInterceptor } from '@abp/ng.oauth';

@Injectable({
  providedIn: 'root',
})
export class CustomOAuthApiInterceptor implements IApiInterceptor {

  protected oAuthService = inject(OAuthService);
  protected sessionState = inject(SessionStateService);
  protected httpWaitService = inject(HttpWaitService);
  protected tenantKey = inject(TENANT_KEY);

  intercept(request: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
    this.httpWaitService.addRequest(request);
    const isExternalRequest = request.context?.get(IS_EXTERNAL_REQUEST);
    // const newRequest = isExternalRequest
    //   ? request
    //   : request.clone({
    //       setHeaders: this.getAdditionalHeaders(request.headers),
    //     });
    const newRequest = request.clone({
           setHeaders: this.getAdditionalHeaders(request.headers),
         });

    return next
      .handle(newRequest)
      .pipe(finalize(() => this.httpWaitService.deleteRequest(request)));
  }


  getAdditionalHeaders(existingHeaders?: HttpHeaders) {
    const headers = {} as any;

    const token = this.oAuthService.getAccessToken();
    if (!existingHeaders?.has('Authorization') && token) {
      headers['Authorization'] = `Bearer ${token}`;
    }

    const lang = this.sessionState.getLanguage();
    if (!existingHeaders?.has('Accept-Language') && lang) {
      headers['Accept-Language'] = lang;
    }

    this.sessionState.setTenant(null);
    // console.log('this.sessionState.getTenant()=', this.sessionState.getTenant());
    
    //const tenant = this.sessionState.getTenant();
    //if (!existingHeaders?.has(this.tenantKey) && tenant?.id) {
    //  headers[this.tenantKey] = tenant.id;
    //}
    

    headers['X-Requested-With'] = 'XMLHttpRequest';

    console.log('headers=', headers);
    return headers;
  }
}