All files / src/services/game game.service.ts

80.55% Statements 29/36
100% Branches 0/0
88.88% Functions 8/9
78.78% Lines 26/33

Press n or j to go to the next uncovered block, b, p or k for the previous block.

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94                          1x     6x 6x 6x 6x   6x 6x       1x   1x       1x   1x 1x   1x       1x                 1x   1x 1x   1x       1x   1x 1x   1x       1x           1x 1x   1x                                
import { EventEmitter, Injectable } from '@angular/core';
import { Observable } from 'rxjs';
 
import { Game } from '../../models/game';
import { ApiService, RestParameters } from '../api/api.service';
import { EnvironmentService } from '../environment/environment.service';
 
export interface GameServiceUploadOptions {
  background?: Blob;
  icon?: Blob;
}
 
@Injectable({ providedIn: 'root' })
export class GameService {
  public basePath: string;
 
  public onCreate = new EventEmitter<Game>();
  public onDelete = new EventEmitter<Game>();
  public onRead = new EventEmitter<Game[]>();
  public onUpdate = new EventEmitter<Game>();
 
  constructor(private apiService: ApiService, private environmentService: EnvironmentService) {
    this.basePath = this.environmentService.gameApiBaseUrl;
  }
 
  public async count(parameters: RestParameters): Promise<number> {
    const response = await this.apiService.request('get', `${this.basePath}/count`, parameters);
 
    return response.count;
  }
 
  public async create(parameters: Partial<Game>): Promise<Game> {
    const response = await this.apiService.request('post', this.basePath, parameters);
 
    const record = new Game(response.record);
    this.onCreate.emit(record);
 
    return record;
  }
 
  public async delete(_id: string): Promise<Game> {
    const response = await this.apiService.request('delete', `${this.basePath}/${_id}`, null);
 
    const record = new Game(response.record);
    this.onDelete.emit(record);
 
    return record;
  }
 
  public async find(parameters: RestParameters): Promise<Game[]> {
    const response = await this.apiService.request('get', this.basePath, parameters);
 
    const records = response.records.map(record => new Game(record));
    this.onRead.emit(records);
 
    return records;
  }
 
  public async findOne(_id: string): Promise<Game> {
    const response = await this.apiService.request('get', `${this.basePath}/${_id}`, null);
 
    const record = new Game(response.record);
    this.onRead.emit([record]);
 
    return record;
  }
 
  public async update(parameters: Partial<Game>): Promise<Game> {
    const response = await this.apiService.request(
      'put',
      `${this.basePath}/${parameters._id}`,
      parameters,
    );
 
    const record = new Game(response.record);
    this.onUpdate.emit(record);
 
    return record;
  }
 
  public upload(_id: string, key: string, blobs: Blob[]) {
    const formData = new FormData();
 
    for (const blob of blobs) {
      formData.append(key, blob);
    }
 
    return this.apiService.request('post', `${this.basePath}/${_id}/${key}`, formData, {
      observe: 'events',
      reportProgress: true,
    }) as Observable<any>;
  }
}