import {Injectable} from "@angular/core";
import {User} from "../../models/model-interfaces";
import {URLSearchParams} from "@angular/http";
import {Observable} from "rxjs/Observable";
import {ADD, EDIT, LOAD, REMOVE, UserStore} from "../stores/user.store";
import {AppConfig} from "../../app.config";
import {HttpClient} from "../http-client";

@Injectable()
export class UserService {

  users$: Observable<User[]>;

  totalCount = 0;

  constructor(private http: HttpClient,
              private userStore: UserStore,
              private config: AppConfig) {
    this.users$ = userStore.items$;
  }

  findUsers(query = '', fractionFilter?, squadFilter?, limit?, offset?, action = LOAD) {
    const searchParams = new URLSearchParams();
    searchParams.append('q', query);
    if (fractionFilter) {
      searchParams.append('fractFilter', fractionFilter);
    }
    if (squadFilter) {
      searchParams.append('squadId', squadFilter);
    }
    searchParams.append('limit', limit);
    searchParams.append('offset', offset);
    this.http.get(this.config.apiUserPath, searchParams)
        .do((res) => {
          let headerCount = parseInt(res.headers.get('x-total-count'));
          if (headerCount) {
            this.totalCount = headerCount;
          }
        }).map(res => res.json()).do((users) => {
      this.userStore.dispatch({type: action, data: users});
    }).subscribe(_ => {
    });

    return this.users$;
  }

  getUser(_id: number | string): Observable<User> {
    return this.http.get(this.config.apiUserPath + _id)
               .map(res => res.json());
  }

  submitUser(user) {
    return this.http.post(this.config.apiUserPath, user)
               .map(res => res.json())
               .do(savedUser => {
                 const action = {type: ADD, data: savedUser};
                 this.userStore.dispatch(action);
               });
  }

  updateUser(user) {
    return this.http.put(this.config.apiUserPath + user._id, user)
               .map(res => res.json())
               .do(savedUser => {
                 const action = {type: EDIT, data: savedUser};
                 this.userStore.dispatch(action);
               });
  }

  deleteUser(user) {
    return this.http.delete(this.config.apiUserPath + user._id)
               .do(res => {
                 this.userStore.dispatch({type: REMOVE, data: user});
               });
  }

}