Merge branch 'master' into kanban-board

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/api.service.ts

@@ -11,7 +11,7 @@ import { SelectComponent } from "@ui/components";
 import { IconComponent } from "@uilib";
 import { FormBuilder, type FormGroup, ReactiveFormsModule } from "@angular/forms";
 import { RatingService } from "../services/rating.service";
-import { ratingFiltersList } from "projects/core/src/consts/filters/rating-filter.const";
+import { ratingFilters } from "projects/core/src/consts/filters/rating-filter.const";
 
 /**
  * Компонент общего рейтинга пользователей
@@ -66,7 +66,7 @@ export class RatingGeneralComponent implements OnInit {
   ratingForm: FormGroup;
 
   // Константы фильтров из конфигурации
-  readonly filterParams = ratingFiltersList;
+  readonly filterParams = ratingFilters;
 
   /**
    * Инициализация компонента

projects/skills/src/app/rating/general/general.component.ts

@@ -11,6 +11,8 @@ import {
   RegisterResponse,
 } from "../../domain/auth/http.model";
 import { User, UserRole } from "../../domain/auth/user.model";
+import { Project } from "../../domain/project/project.model";
+import { ApiPagination } from "../../domain/other/api-pagination.model";
 
 /**
  * Сервис аутентификации и управления пользователями
@@ -76,12 +78,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/`);
   }
 
   /** Поток данных профиля пользователя */
@@ -127,6 +125,14 @@ export class AuthService {
     );
   }
 
+  /**
+   * Получить проекты где пользователь leader
+   * @returns Observable проектов внутри профиля
+   */
+  getLeaderProjects(): Observable<ApiPagination<Project>> {
+    return this.apiService.get(`${this.AUTH_USERS_URL}/projects/leader/`);
+  }
+
   /**
    * Получить роли, которые может изменить текущий пользователь
    * @returns Observable с массивом изменяемых ролей

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

@@ -10,6 +10,7 @@ import { PartnerProgramFields } from "projects/social_platform/src/app/domain/pr
 import { Program, ProgramDataSchema } from "../../domain/program/program.model";
 import { ProgramCreate } from "../../domain/program/program-create.model";
 import { Project } from "../../domain/project/project.model";
+import { ProjectAdditionalFields } from "../../domain/project/project-additional-fields.model";
 
 /**
  * Сервис для работы с программами
@@ -67,6 +68,10 @@ export class ProgramService {
     return this.apiService.get(`${this.PROGRAMS_URL}/`, httpParams);
   }
 
+  getActualPrograms(): Observable<ApiPagination<Program>> {
+    return this.apiService.get(`${this.PROGRAMS_URL}/`);
+  }
+
   getOne(programId: number): Observable<Program> {
     return this.apiService.get(`${this.PROGRAMS_URL}/${programId}/`);
   }
@@ -103,6 +108,15 @@ export class ProgramService {
     return this.apiService.get(`${this.PROGRAMS_URL}/${programId}/filters/`);
   }
 
+  getProgramProjectAdditionalFields(programId: number): Observable<ProjectAdditionalFields> {
+    return this.apiService.get(`${this.PROGRAMS_URL}/${programId}/projects/apply/`);
+  }
+
+  // body - это форма проекта который подается + programFieldValues
+  applyProjectToProgram(programId: number, body: any): Observable<any> {
+    return this.apiService.post(`${this.PROGRAMS_URL}/${programId}/projects/apply/`, body);
+  }
+
   createProgramFilters(
     programId: number,
     filters: Record<string, string[]>,

projects/social_platform/src/app/api/program/program.service.ts

@@ -242,7 +242,7 @@ export class ProjectAdditionalService {
         control.addValidators([Validators.maxLength(500)]);
         break;
       case "textarea":
-        control.addValidators([Validators.maxLength(300)]);
+        control.addValidators([Validators.maxLength(500)]);
         break;
     }
   }