fix: prevent duplicate news creation on POST retry + disable form while in-flight

ApiService.post больше не повторяет запрос (retry оставлен только на
идемпотентных GET/PUT/PATCH/DELETE): повтор неидемпотентного POST на
5xx/обрыве плодил дубликаты, напр. вторую новость по /programs/<id>/news/.

NewsFormComponent получает pending-инпут: на время создания новости форма,
кнопка отправки и input файла блокируются, onSubmit защищён guard'ом.
Программа/проект/профиль выставляют pending через finalize (успех, ошибка,
отписка), что важно для проектного фасада с filter(result.ok).

Author: Awakich

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

@@ -98,9 +98,8 @@ export class ApiService {
    * apiService.post<User>('/users', { name: 'John', email: 'john@example.com' })
    */
   post<T>(path: string, body: object): Observable<T> {
-    return this.http
-      .post<T>(this.apiUrl + path, body)
-      .pipe(retry(exponentialBackoff(this.RETRY_COUNT)), first()) as Observable<T>;
+    // Без retry: POST неидемпотентен, повтор на 5xx/обрыве плодит дубликаты ресурсов.
+    return this.http.post<T>(this.apiUrl + path, body).pipe(first()) as Observable<T>;
   }
 
   /**

projects/social_platform/src/app/ui/pages/profile/detail/main/components/profile-mid-side/profile-mid-side.component.html

@@ -54,7 +54,11 @@ <h3 class="text-body-12 about__title">обо мне</h3>
     } @else {
       <div class="profile__news news">
         @if (loggedUserId() === user()!.id) {
-          <app-news-form class="news__form" (addNews)="onAddNews($event)"></app-news-form>
+          <app-news-form
+            class="news__form"
+            [pending]="newsPending()"
+            (addNews)="onAddNews($event)"
+          ></app-news-form>
         }
         <ul>
           @for (n of news(); track n.id) {

projects/social_platform/src/app/ui/pages/profile/detail/main/components/profile-mid-side/profile-mid-side.component.ts

@@ -5,12 +5,13 @@ import {
   ChangeDetectionStrategy,
   Component,
   DestroyRef,
-  ElementRef,
   inject,
   input,
+  signal,
   viewChild,
 } from "@angular/core";
 import { takeUntilDestroyed } from "@angular/core/rxjs-interop";
+import { finalize } from "rxjs";
 import { RouterModule } from "@angular/router";
 import { ParseBreaksPipe, ParseLinksPipe } from "@corelib";
 import { IconComponent, ButtonComponent } from "@ui/primitives";
@@ -60,6 +61,8 @@ export class ProfileMidSideComponent {
   protected readonly directions = this.profileDetailUIInfoService.directions;
   protected readonly news = this.newsInfoService.news;
 
+  protected readonly newsPending = signal(false);
+
   protected readonly descriptionExpandable = this.expandService.descriptionExpandable;
   protected readonly readFullDescription = this.expandService.readFullDescription;
 
@@ -68,9 +71,13 @@ export class ProfileMidSideComponent {
   protected readonly AppRoutes = AppRoutes;
 
   onAddNews(news: { text: string; files: string[] }): void {
+    this.newsPending.set(true);
     this.profileDetailInfoService
       .onAddNews(news)
-      .pipe(takeUntilDestroyed(this.destroyRef$))
+      .pipe(
+        finalize(() => this.newsPending.set(false)),
+        takeUntilDestroyed(this.destroyRef$),
+      )
       .subscribe({
         next: () => this.newsFormComponent()?.onResetForm(),
       });

projects/social_platform/src/app/ui/pages/program/detail/main/main.component.html

@@ -50,7 +50,11 @@ <h3 class="text-body-12 about__title">о программе</h3>
             </div>
             <div class="news">
               @if (program()!.isUserManager) {
-                <app-news-form class="news__form" (addNews)="onAddNews($event)"></app-news-form>
+                <app-news-form
+                  class="news__form"
+                  [pending]="newsPending()"
+                  (addNews)="onAddNews($event)"
+                ></app-news-form>
               }
               @for (n of news(); track n.id) {
                 <app-news-card

projects/social_platform/src/app/ui/pages/program/detail/main/main.component.ts

@@ -9,8 +9,8 @@ import {
   inject,
   OnDestroy,
   OnInit,
+  signal,
   viewChild,
-  ViewChild,
 } from "@angular/core";
 import { isFailure } from "@domain/shared/async-state";
 import { RouterModule } from "@angular/router";
@@ -29,6 +29,7 @@ import { NewsInfoService } from "@api/news/news-info.service";
 import { ProjectAdditionalService } from "@api/project/facades/edit/project-additional.service";
 import { AppRoutes } from "@api/paths/app-routes";
 import { takeUntilDestroyed } from "@angular/core/rxjs-interop";
+import { finalize } from "rxjs";
 import { ProgramLinksComponent } from "@ui/widgets/program-links/program-links.component";
 
 /** Страница основной вкладки программы с описанием, ссылками и новостями. */
@@ -79,6 +80,8 @@ export class ProgramDetailMainComponent implements OnInit, OnDestroy {
   protected readonly program = this.programDetailMainUIInfoService.program;
   protected readonly news = this.newsInfoService.news;
 
+  protected readonly newsPending = signal(false);
+
   protected readonly AppRoutes = AppRoutes;
 
   protected readonly showProgramModal = this.programDetailMainUIInfoService.showProgramModal;
@@ -115,9 +118,13 @@ export class ProgramDetailMainComponent implements OnInit, OnDestroy {
   }
 
   onAddNews(news: { text: string; files: string[] }): void {
+    this.newsPending.set(true);
     this.programDetailMainService
       .onAddNews(news)
-      .pipe(takeUntilDestroyed(this.destroyRef))
+      .pipe(
+        finalize(() => this.newsPending.set(false)),
+        takeUntilDestroyed(this.destroyRef),
+      )
       .subscribe({
         next: () => this.newsFormComponent()?.onResetForm(),
       });

projects/social_platform/src/app/ui/pages/projects/detail/info/components/projects-mid-side/projects-mid-side.component.html

@@ -24,7 +24,11 @@ <h3 class="text-body-12 about__title">о проекте</h3>
   @if (profile()) {
     <div #newsEl class="project__news news">
       @if (project()!.leader === profile()!.id) {
-        <app-news-form class="news__form" (addNews)="onAddNews($event)"></app-news-form>
+        <app-news-form
+          class="news__form"
+          [pending]="newsPending()"
+          (addNews)="onAddNews($event)"
+        ></app-news-form>
       }
 
       <div class="project__directions">

projects/social_platform/src/app/ui/pages/projects/detail/info/components/projects-mid-side/projects-mid-side.component.ts

@@ -8,9 +8,8 @@ import {
   ElementRef,
   inject,
   input,
-  Input,
+  signal,
   viewChild,
-  WritableSignal,
 } from "@angular/core";
 import { NewsFormComponent } from "@ui/widgets/news-form/news-form.component";
 import { ProjectDirectionCard } from "@ui/widgets/project-direction-card/project-direction-card.component";
@@ -25,6 +24,7 @@ import { ParseBreaksPipe, ParseLinksPipe } from "@corelib";
 import { FeedNews } from "@domain/news/project-news.model";
 import { Collaborator } from "@domain/project/collaborator.model";
 import { takeUntilDestroyed } from "@angular/core/rxjs-interop";
+import { finalize } from "rxjs";
 import { ProfileInfoService } from "@api/profile/facades/profile-info.service";
 
 /** Центральная колонка детали проекта: описание, новости. */
@@ -69,6 +69,7 @@ export class ProjectsMidSideComponent {
   // Состояние компонента
   protected readonly profile = this.profileInfoService.profile;
   protected readonly news = this.newsInfoService.news; // Массив новостей
+  protected readonly newsPending = signal(false);
   protected readonly readFullDescription = this.expandService.readFullDescription; // Флаг развернутого описания
   protected readonly descriptionExpandable = this.expandService.descriptionExpandable; // Флаг необходимости кнопки "Читать полностью"
 
@@ -77,9 +78,13 @@ export class ProjectsMidSideComponent {
   }
 
   onAddNews(news: { text: string; files: string[] }): void {
+    this.newsPending.set(true);
     this.projectsDetailService
       .onAddNews(news)
-      .pipe(takeUntilDestroyed(this.destroyRef))
+      .pipe(
+        finalize(() => this.newsPending.set(false)),
+        takeUntilDestroyed(this.destroyRef),
+      )
       .subscribe({
         next: () => this.newsFormComponent()?.onResetForm(),
       });

projects/social_platform/src/app/ui/widgets/news-form/news-form.component.html

@@ -17,8 +17,8 @@
       icon="send"
       appSquare="12"
       class="form__send"
-      [style.opacity]="isTextOverflow ? '0.5' : '1'"
-      [style.pointer-events]="isTextOverflow ? 'none' : 'auto'"
+      [style.opacity]="isTextOverflow || pending() ? '0.5' : '1'"
+      [style.pointer-events]="isTextOverflow || pending() ? 'none' : 'auto'"
       (click)="onSubmit()"
     ></i>
   </div>
@@ -48,7 +48,13 @@
   <div class="footer">
     <label class="footer__attach">
       <i appIcon icon="attach" appSquare="12"></i>
-      <input type="file" accept="*/*" multiple (change)="onInputFiles($event)" />
+      <input
+        type="file"
+        accept="*/*"
+        multiple
+        [disabled]="pending()"
+        (change)="onInputFiles($event)"
+      />
     </label>
   </div>
 </form>

projects/social_platform/src/app/ui/widgets/news-form/news-form.component.ts

@@ -4,11 +4,11 @@ import {
   ChangeDetectionStrategy,
   Component,
   DestroyRef,
-  EventEmitter,
+  effect,
   inject,
+  input,
   OnInit,
   output,
-  Output,
 } from "@angular/core";
 import { FormBuilder, FormGroup, ReactiveFormsModule, Validators } from "@angular/forms";
 import { ValidationService } from "@corelib";
@@ -66,10 +66,20 @@ export class NewsFormComponent implements OnInit {
     this.messageForm = this.fb.group({
       text: ["", [Validators.required]],
     });
+
+    effect(() => {
+      if (this.pending()) {
+        this.messageForm.disable({ emitEvent: false });
+      } else {
+        this.messageForm.enable({ emitEvent: false });
+      }
+    });
   }
 
   readonly addNews = output<{ text: string; files: string[] }>();
 
+  readonly pending = input(false);
+
   ngOnInit(): void {}
 
   messageForm: FormGroup;
@@ -85,6 +95,7 @@ export class NewsFormComponent implements OnInit {
    * Валидирует форму и эмитит событие с данными новости
    */
   onSubmit() {
+    if (this.pending()) return;
     if (this.isTextOverflow) return;
     if (!this.validationService.getFormValidation(this.messageForm)) {
       return;