Merge pull request #249 from PROCOLLAB-github/fixes

Export file of projects, rates of program

Author: Awakich

package-lock.json

@@ -46,6 +46,7 @@
     "class-transformer": "^0.5.1",
     "core-js": "^3.23.4",
     "dayjs": "^1.11.3",
+    "file-saver": "^2.0.5",
     "fuse.js": "^6.6.2",
     "js-base64": "^3.7.7",
     "js-cookie": "^3.0.5",

package.json

@@ -46,9 +46,7 @@ export class BearerTokenInterceptor implements HttpInterceptor {
    */
   intercept(request: HttpRequest<unknown>, next: HttpHandler): Observable<HttpEvent<unknown>> {
     // Базовые заголовки для всех запросов
-    const headers: Record<string, string> = {
-      Accept: "application/json",
-    };
+    const headers: Record<string, string> = {};
 
     const tokens = this.tokenService.getTokens();
 
@@ -57,14 +55,24 @@ export class BearerTokenInterceptor implements HttpInterceptor {
       headers["Authorization"] = `Bearer ${tokens.access}`;
     }
 
+    // Для blob запросов (файлы) не устанавливаем Accept, чтобы не парсить blob как JSON
+    const isBlobRequest =
+      request.url.includes("/export") ||
+      request.url.includes("/download") ||
+      (request.headers.has("X-Request-Type") && request.headers.get("X-Request-Type") === "blob");
+
+    const hasAcceptHeader = request.headers.has("Accept");
+
+    if (!isBlobRequest && !hasAcceptHeader) {
+      headers["Accept"] = "application/json";
+    }
+
     const req = request.clone({ setHeaders: headers });
 
-    // Если токены есть, обрабатываем запрос с возможностью обновления токенов
     if (tokens !== null) {
       return this.handleRequestWithTokens(req, next);
     } else {
-      // Если токенов нет, просто выполняем запрос
-      return next.handle(request);
+      return next.handle(req);
     }
   }
 
@@ -107,10 +115,9 @@ export class BearerTokenInterceptor implements HttpInterceptor {
     request: HttpRequest<unknown>,
     next: HttpHandler
   ): Observable<HttpEvent<unknown>> {
-    // Если токен еще не обновляется, начинаем процесс обновления
     if (!this.isRefreshing) {
       this.isRefreshing = true;
-      this.refreshTokenSubject.next(null); // Сбрасываем subject
+      this.refreshTokenSubject.next(null);
 
       return this.tokenService.refreshTokens().pipe(
         catchError(err => {
@@ -119,22 +126,29 @@ export class BearerTokenInterceptor implements HttpInterceptor {
         }),
         switchMap(res => {
           this.isRefreshing = false;
-          this.refreshTokenSubject.next(res.access); // Уведомляем о новом токене
+          this.refreshTokenSubject.next(res.access);
 
-          // Сохраняем новые токены в хранилище
           this.tokenService.memTokens(res);
 
-          // Подготавливаем заголовки с новым токеном
-          const headers: Record<string, string> = {
-            Accept: "application/json",
-          };
+          const headers: Record<string, string> = {};
 
           const tokens = this.tokenService.getTokens();
           if (tokens) {
             headers["Authorization"] = `Bearer ${tokens.access}`;
           }
 
-          // Повторяем исходный запрос с новым токеном
+          const isBlobRequest =
+            request.url.includes("/export") ||
+            request.url.includes("/download") ||
+            (request.headers.has("X-Request-Type") &&
+              request.headers.get("X-Request-Type") === "blob");
+
+          const hasAcceptHeader = request.headers.has("Accept");
+
+          if (!isBlobRequest && !hasAcceptHeader) {
+            headers["Accept"] = "application/json";
+          }
+
           return next.handle(
             request.clone({
               setHeaders: headers,
@@ -144,17 +158,32 @@ export class BearerTokenInterceptor implements HttpInterceptor {
       );
     }
 
-    // Если токен уже обновляется, ждем завершения процесса
     return this.refreshTokenSubject.pipe(
-      filter(token => token !== null), // Ждем получения нового токена
-      take(1), // Берем только первое значение
-      switchMap(token =>
-        next.handle(
+      filter(token => token !== null),
+      take(1),
+      switchMap(token => {
+        const headers: Record<string, string> = {
+          Authorization: `Bearer ${token}`,
+        };
+
+        const isBlobRequest =
+          request.url.includes("/export") ||
+          request.url.includes("/download") ||
+          (request.headers.has("X-Request-Type") &&
+            request.headers.get("X-Request-Type") === "blob");
+
+        const hasAcceptHeader = request.headers.has("Accept");
+
+        if (!isBlobRequest && !hasAcceptHeader) {
+          headers["Accept"] = "application/json";
+        }
+
+        return next.handle(
           request.clone({
-            setHeaders: { Authorization: `Bearer ${token}` },
+            setHeaders: headers,
           })
-        )
-      )
+        );
+      })
     );
   }
 }

projects/core/src/lib/interceptors/bearer-token.interceptor.ts

@@ -54,24 +54,34 @@ export class CamelcaseInterceptor implements HttpInterceptor {
         }),
       });
     } else {
-      // Если тела нет, просто клонируем запрос
       req = request.clone();
     }
 
     // Выполняем запрос и обрабатываем ответ
     return next.handle(req).pipe(
       map((event: HttpEvent<any>) => {
-        // Обрабатываем только HTTP ответы (не события загрузки и т.д.)
         if (event instanceof HttpResponse) {
+          if (event.body instanceof Blob) {
+            return event;
+          }
+
+          if (typeof event.body !== "object" || event.body === null) {
+            return event;
+          }
+
           // Клонируем ответ с преобразованным телом (snake_case → camelCase)
-          return event.clone({
-            body: camelcaseKeys(event.body, {
-              deep: true, // Рекурсивное преобразование вложенных объектов
-            }),
-          });
+          try {
+            return event.clone({
+              body: camelcaseKeys(event.body, {
+                deep: true, // Рекурсивное преобразование вложенных объектов
+              }),
+            });
+          } catch (error) {
+            console.warn("CamelcaseInterceptor: Failed to transform response body", error);
+            return event;
+          }
         }
 
-        // Для других типов событий возвращаем как есть
         return event;
       })
     );

projects/core/src/lib/interceptors/camelcase.interceptor.ts

@@ -44,6 +44,15 @@ export class ApiService {
     return this.http.get(this.apiUrl + path, { params, ...options }).pipe(first()) as Observable<T>;
   }
 
+  getFile(path: string, params?: HttpParams): Observable<Blob> {
+    return this.http
+      .get(this.apiUrl + path, {
+        params,
+        responseType: "blob",
+      })
+      .pipe(first()) as Observable<Blob>;
+  }
+
   /**
    * Выполняет PUT запрос к API (полное обновление ресурса)
    * @param path - Относительный путь к ресурсу

projects/core/src/lib/services/api.service.ts

@@ -76,12 +76,8 @@ export class AuthService {
       .pipe(map(json => plainToInstance(RegisterResponse, json)));
   }
 
-  /**
-   * Отправить резюме по email
-   * @returns Observable завершения операции
-   */
-  sendCV(): Observable<any> {
-    return this.apiService.get(`${this.AUTH_USERS_URL}/send_mail_cv/`);
+  downloadCV() {
+    return this.apiService.getFile(`${this.AUTH_USERS_URL}/download_cv/`);
   }
 
   /** Поток данных профиля пользователя */

projects/social_platform/src/app/auth/services/auth.service.ts

@@ -545,10 +545,9 @@ <h3 class="text-body-14 cancel__title" style="flex-wrap: wrap; width: 90%">
 
           @if (+profile.id === +info().id) {
           <app-button
-            (click)="sendCVEmail()"
+            (click)="downloadCV()"
             size="medium"
-            style="opacity: 0, 5"
-            [disabled]="true"
+            [loader]="isSended"
             appearance="outline"
             customTypographyClass="text-body-12"
             >cкачать CV</app-button
@@ -645,18 +644,19 @@ <h3 class="text-body-12 lists__title">подтвердить владение н
                 <i
                   (click)="isDelayModalOpen = false"
                   appIcon
+                  appSquare="8"
                   icon="cross"
                   class="cancel__cross"
                 ></i>
                 <p class="cancel__title text-bold-body-16">Повторите загрузку позже</p>
               </div>
               <p class="text-body-14 cancel__text">
-                Скачивание будет доступно через {{ errorMessageModal() }} секунд.
+                Скачивание будет доступно через несколько секунд.
               </p>
             </div>
           </app-modal>
 
-          <app-modal [open]="isSended" (openChange)="isSended = !isSended">
+          <!-- <app-modal [open]="isSended" (openChange)="isSended = !isSended">
             <div class="cancel">
               <div class="cancel__top">
                 <i
@@ -673,7 +673,7 @@ <h3 class="text-body-12 lists__title">подтвердить владение н
                 Технические сложности? Мы всегда на связи в Telegram — {{ "@procollab_support" }}
               </p>
             </div>
-          </app-modal>
+          </app-modal> -->
         </ng-template>
 
         <router-outlet></router-outlet>

projects/social_platform/src/app/office/features/detail/detail.component.html

@@ -2,8 +2,8 @@
 
 import { CommonModule, Location } from "@angular/common";
 import { ChangeDetectorRef, Component, inject, OnDestroy, OnInit, signal } from "@angular/core";
-import { ButtonComponent, InputComponent } from "@ui/components";
-import { BackComponent, IconComponent } from "@uilib";
+import { ButtonComponent } from "@ui/components";
+import { IconComponent } from "@uilib";
 import { ModalComponent } from "@ui/components/modal/modal.component";
 import { ActivatedRoute, Router, RouterModule } from "@angular/router";
 import { AuthService } from "@auth/services";
@@ -23,15 +23,13 @@ import { ProfileDataService } from "@office/profile/detail/services/profile-date
 import { ProfileService } from "projects/skills/src/app/profile/services/profile.service";
 import { SnackbarService } from "@ui/services/snackbar.service";
 import { ApproveSkillComponent } from "../approve-skill/approve-skill.component";
-import { ProjectsService } from "@office/projects/services/projects.service";
-import { TruncatePipe } from "projects/core/src/lib/pipes/truncate.pipe";
 import { ProgramService } from "@office/program/services/program.service";
 import { ProjectFormService } from "@office/projects/edit/services/project-form.service";
 import {
   PartnerProgramFields,
   projectNewAdditionalProgramVields,
 } from "@office/models/partner-program-fields.model";
-import { HttpRequest, HttpResponse } from "@angular/common/http";
+import { saveFile } from "@utils/helpers/export-file";
 
 @Component({
   selector: "app-detail",
@@ -42,13 +40,10 @@ import { HttpRequest, HttpResponse } from "@angular/common/http";
     RouterModule,
     IconComponent,
     ButtonComponent,
-    BackComponent,
     ModalComponent,
     AvatarComponent,
     TooltipComponent,
-    InputComponent,
     ApproveSkillComponent,
-    TruncatePipe,
   ],
   standalone: true,
 })
@@ -64,7 +59,6 @@ export class DeatilComponent implements OnInit, OnDestroy {
   private readonly location = inject(Location);
   private readonly profileDataService = inject(ProfileDataService);
   public readonly skillsProfileService = inject(ProfileService);
-  private readonly projectsService = inject(ProjectsService);
   public readonly chatService = inject(ChatService);
   private readonly cdRef = inject(ChangeDetectorRef);
   private readonly programService = inject(ProgramService);
@@ -388,15 +382,17 @@ export class DeatilComponent implements OnInit, OnDestroy {
    * Отправка CV пользователя на email
    * Проверяет ограничения по времени и отправляет CV на почту пользователя
    */
-  sendCVEmail() {
-    this.authService.sendCV().subscribe({
-      next: () => {
-        this.isSended = true;
+  downloadCV() {
+    this.isSended = true;
+    this.authService.downloadCV().subscribe({
+      next: blob => {
+        saveFile(blob, "cv", this.profile?.firstName + " " + this.profile?.lastName);
+        this.isSended = false;
       },
       error: err => {
+        this.isSended = false;
         if (err.status === 400) {
           this.isDelayModalOpen = true;
-          this.errorMessageModal.set(err.error.seconds_after_retry);
         }
       },
     });