import { Observable } from 'rxjs';
import { AuthHttp } from 'angular2-jwt';
import { Response } from '@angular/http';
import { Organization } from './organization.model';
import { OrganizationCollectionConverter } from './organization.collection.converter';
import { OrganizationCollection } from './organization.collection';
import { OrganizationConverter } from './organization.converter';
import { OrganizationSerializer } from './organization.serializer';
import { UrlParamBuilderService } from '../service/url-param-builder.service';
import { IErrorHandler } from '../error/error-handler.interface';
import { ApiPathComponent } from '../api-path-component';

export class OrganizationService {

  public constructor(
    private authHttp: AuthHttp,
    private converter: OrganizationConverter,
    private collectionConverter: OrganizationCollectionConverter,
    private serializer: OrganizationSerializer,
    private baseUrl: string,
    private urlParamBuilderService: UrlParamBuilderService,
    private errorHandler: IErrorHandler
  ) {}

  public getMany(filters?: {[key: string]: any}, sort?: string[], page?: number,
                 limit?: number): Observable<OrganizationCollection> {
    const url: string = this.baseUrl
      + '/' + ApiPathComponent.organizations
      + '?' + this.urlParamBuilderService.build(filters, sort, page, limit)
    ;
    return this.authHttp.get(url)
      .catch((error?: any) => this.errorHandler.handle(error))
      .map((res: Response) => this.collectionConverter.toCollection(res.json()));
  }

  public getOne(id: string): Observable<Organization> {
    const url: string = this.baseUrl + '/' + ApiPathComponent.organizations + '/' + id;
    return this.authHttp.get(url)
      .catch((error?: any) => this.errorHandler.handle(error))
      .map((res: Response) => this.converter.toOne(res.json()));
  }

  public create(organization: Organization): Observable<Organization> {
    const url: string = this.baseUrl + '/' + ApiPathComponent.organizations;
    return this.authHttp.post(url, this.serializer.serialize(organization))
      .catch((error?: any) => this.errorHandler.handle(error))
      .map((res: Response) => this.converter.toOne(res.json()));
  }

  public update(organization: Organization): Observable<Organization> {
    const url: string = this.baseUrl + '/' + ApiPathComponent.organizations + '/' + organization.id;
    return this.authHttp.put(url, this.serializer.serialize(organization))
      .catch((error?: any) => this.errorHandler.handle(error))
      .map((res: Response) => this.converter.toOne(res.json()));
  }
}