D-Net

/*

* Created by myrto on 12/05/2017

*/

import {HttpClient, HttpHeaders, HttpParams} from '@angular/common/http';

import { Injectable } from '@angular/core';

import { environment } from '../../environments/environment';

import {

  AggregationDetails,

  Country, MetricsInfo,

  Repository,

  RepositoryInterface,

  RepositorySnippet, RepositorySummaryInfo, TermsOfUse,

  Timezone,

  Typology, User

} from '../domain/typeScriptClasses';

import { Observable, of } from 'rxjs';

import { timezones } from '../domain/timezones';

import { typologies } from '../domain/typologies';

import {URLParameter} from '../domain/url-parameter';

const headerOptions = {

  headers : new HttpHeaders().set('Content-Type', 'application/json')

                             .set('Accept', 'application/json'),

  withCredentials: true

};

@Injectable ()

export class RepositoryService {

  private apiUrl = environment.API_ENDPOINT + '/repositories/';

  private dashboardAPIUrl = environment.API_ENDPOINT + '/dashboard/';

  constructor(private httpClient: HttpClient) { }

  addInterface(datatype: string, repoId: string, registeredBy: string, comment: string, newInterface: RepositoryInterface): Observable<RepositoryInterface> {

    let url;

    comment = newInterface.comments; // temporary fix. TODO: test with backend

    if (comment == null || comment === '') {

      url = `${this.apiUrl}addInterface?datatype=${datatype}&repoId=${repoId}&registeredBy=${registeredBy}`;

    } else {

      url = `${this.apiUrl}addInterface?datatype=${datatype}&repoId=${repoId}&registeredBy=${registeredBy}&comment=${comment}`;

    }

    console.log(`knocking on: ${url}`);

    console.log(`sending ${JSON.stringify(newInterface)}`);

    return this.httpClient.post<RepositoryInterface>(url, newInterface, headerOptions);

  }

  updateInterface(repoId: string, registeredBy: string, comment: string, interfaceInfo: RepositoryInterface): Observable<RepositoryInterface> {

    let url;

    comment = interfaceInfo.comments; // temporary fix. TODO: test with backend

    if (comment == null || comment === '') {

      url = `${this.apiUrl}updateRepositoryInterface?repoId=${repoId}&registeredBy=${registeredBy}`;

    } else {

      url  = `${this.apiUrl}updateRepositoryInterface?repoId=${repoId}&registeredBy=${registeredBy}&comment=${comment}`;

    }

    console.log(`knocking on: ${url}`);

    console.log(`sending ${JSON.stringify(interfaceInfo)}`);

    return this.httpClient.post<RepositoryInterface>(url, interfaceInfo, headerOptions);

  }

  deleteInterface(id: string, registeredBy: string) {

    const url = `${this.apiUrl}deleteInterface/?id=${id}&registeredBy=${registeredBy}`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.delete(url, {withCredentials: true, responseType: 'text'});

  }

  addRepository(datatype: string, newRepository: Repository): Observable<Repository> {

    const url = `${this.apiUrl}addRepository?datatype=${datatype}`;

    console.log(`knocking on: ${url}`);

    console.log(`sending ${JSON.stringify(newRepository)}`);

    return this.httpClient.post<Repository>(url, newRepository, headerOptions);

  }

  // updateRepository(repoInfo: Repository): Observable<Repository> {

  //   const url = `${this.apiUrl}updateRepository`;

  //   console.log(`knocking on: ${url}`);

  //   console.log(`sending ${JSON.stringify(repoInfo)}`);

  //   return this.httpClient.post<Repository>(url, repoInfo, headerOptions);

  // }

  updateRepository(repoInfo: Repository): Observable<Repository> {

    const url = `${this.apiUrl}updateRepository`;

    console.log(`knocking on: ${url}`);

    console.log(`sending ${JSON.stringify(repoInfo)}`);

    return this.httpClient.post<Repository>(url, repoInfo, headerOptions);

  }

  updateRepositoriesTerms(termsList: any): Observable<TermsOfUse> {

    const url = `${this.apiUrl}terms`;

    console.log(`knocking on: ${url}`);

    console.log(`sending ${JSON.stringify(termsList)}`);

    return this.httpClient.post<TermsOfUse>(url, termsList, headerOptions);

  }

  getRepositoriesOfCountry(country: string, mode: string): Observable<RepositorySnippet[]> {

    const url = `${this.apiUrl}getRepositoriesByCountry/${country}/${mode}`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<RepositorySnippet[]>(url, headerOptions);

  }

  getRepositoriesSnippetsOfUser(): Observable<RepositorySnippet[]> {

    const url = `${this.apiUrl}snippets/user`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<RepositorySnippet[]>(url, headerOptions);

  }

  getRepositoryById(id: string): Observable<Repository> {

    const   url = `${this.apiUrl}getRepositoryById/${id}`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<Repository>(url, headerOptions);

  }

  getRepositoryInterface(id: string): Observable<RepositoryInterface[]> {

    const url = `${this.apiUrl}getRepositoryInterface/${id}`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<RepositoryInterface[]>(url, headerOptions);

  }

  getUrlsOfUserRepos(): Observable<string[]> {

    const url = `${this.apiUrl}getUrlsOfUserRepos/0/100/`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<string[]>(url, headerOptions);

  }

  getRepositoryAggregations(id: string): Observable<AggregationDetails[]> {

    const url = `${this.apiUrl}getRepositoryAggregations/${id}`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<AggregationDetails[]>(url, headerOptions);

  }

  getRepositoryAggregationsByYear(id: string): Observable<Map<string, AggregationDetails[]>> {

    const url = `${this.apiUrl}getRepositoryAggregationsByYear/${id}`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<Map<string, AggregationDetails[]>>(url, headerOptions);

  }

  getTimezones(): Observable<Timezone[]> {

/*    const url = `${this.apiUrl}getTimezones`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<Timezone[]>(url, headerOptions);*/

    return of(<Timezone[]>timezones);

  }

  getTypologies(): Observable<Typology[]> {

/*    const url = `${this.apiUrl}getTypologies`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<Typology[]>(url, headerOptions);*/

    return of(<Typology[]>typologies);

  }

  getCountries(): Observable<Country[]> {

    const url = `${this.apiUrl}countries`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<Country[]>(url, headerOptions);

  }

  getCompatibilityClasses (mode: string): Observable<Map<string, string>> {

    const url = `${this.apiUrl}getCompatibilityClasses/${mode}`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<Map<string, string>>(url, headerOptions);

  }

  getDatasourceClasses(mode: string): Observable<Object> {

    const url = `${this.apiUrl}getDatasourceClasses/${mode}`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<Map<string, string>>(url, headerOptions);

  }

  getMetricsInfoForRepository (repoId: string): Observable<MetricsInfo> {

    const url = `${this.apiUrl}getMetricsInfoForRepository/${repoId}`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<MetricsInfo>(url, headerOptions);

  }

  getListLatestUpdate(mode: string): Observable<any> {

    const url = `${this.apiUrl}getListLatestUpdate/${mode}`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<any>(url, headerOptions);

  }

  searchRegisteredRepositories(page, size, urlParams: URLParameter[]) {

    const url = `${this.apiUrl}searchRegisteredRepositories/${page}/${size}`;

    console.log(`knocking on: ${url}`);

    let params = new HttpParams();

    for (const urlParameter of urlParams) {

      for (const value of urlParameter.value) {

        params = params.append(urlParameter.key, value);

      }

    }

    return this.httpClient.get<RepositorySnippet[]>(url, {params, withCredentials: true});

  }

  getRepositoriesSummaryInfo(): Observable<RepositorySummaryInfo[]> {

    const url = `${this.dashboardAPIUrl}getRepositoriesSummary/0/100`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<RepositorySummaryInfo[]>(url, headerOptions);

  }

  getRepositoryAdmins(repoId: string): Observable<User[]> {

    const url = `${this.apiUrl}${repoId}/admins`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.get<User[]>(url, headerOptions);

  }

  deleteRepositoryAdmin(repoId: string, repoAdminEmail: string) {

    const url = `${this.apiUrl}${repoId}/admins/${repoAdminEmail}`;

    console.log(`knocking on: ${url}`);

    return this.httpClient.delete(url, headerOptions);

  }

  addRepositoryAdmin(repoId: string, repoAdminEmail: string) {

    const url = `${this.apiUrl}${repoId}/admins`;

    return this.httpClient.post<string>(url, repoAdminEmail, headerOptions);

  }

}