rdt-client/client/src/app/torrent.service.ts

import { HttpClient } from '@angular/common/http';
import { Injectable } from '@angular/core';
import * as signalR from '@microsoft/signalr';
import { Observable, Subject } from 'rxjs';
import { Torrent } from './models/torrent.model';

@Injectable({
  providedIn: 'root',
})
export class TorrentService {
  constructor(private http: HttpClient) {}

  public update$: Subject<Torrent[]> = new Subject();

  private connection: signalR.HubConnection;

  public connect(): void {
    this.connection = new signalR.HubConnectionBuilder().withUrl('/hub').withAutomaticReconnect().build();
    this.connection.start().catch((err) => console.error(err));

    this.connection.on('update', (torrents: Torrent[]) => {
      this.update$.next(torrents);
    });
  }

  public disconnect(): void {
    this.connection?.stop();
  }

  public getList(): Observable<Torrent[]> {
    return this.http.get<Torrent[]>(`/Api/Torrents`);
  }

  public uploadMagnet(magnetLink: string, autoDelete: boolean): Observable<void> {
    return this.http.post<void>(`/Api/Torrents/UploadMagnet`, {
      magnetLink,
      autoDelete,
    });
  }

  public uploadFile(file: File, autoDelete: boolean): Observable<void> {
    const formData: FormData = new FormData();
    formData.append('file', file);
    formData.append('formData', JSON.stringify({ autoDelete }));
    return this.http.post<void>(`/Api/Torrents/UploadFile`, formData);
  }

  public checkFilesMagnet(magnetLink: string): Observable<string[]> {
    return this.http.post<string[]>(`/Api/Torrents/CheckFilesMagnet`, {
      magnetLink,
    });
  }

  public checkFiles(file: File): Observable<string[]> {
    const formData: FormData = new FormData();
    formData.append('file', file);
    return this.http.post<string[]>(`/Api/Torrents/CheckFiles`, formData);
  }

  public delete(
    torrentId: string,
    deleteData: boolean,
    deleteRdTorrent: boolean,
    deleteLocalFiles: boolean
  ): Observable<void> {
    return this.http.post<void>(`/Api/Torrents/Delete/${torrentId}`, {
      deleteData,
      deleteRdTorrent,
      deleteLocalFiles,
    });
  }

  public retry(torrentId: string, retry: number): Observable<void> {
    return this.http.post<void>(`/Api/Torrents/Retry/${torrentId}`, {
      retry,
    });
  }
}