import {Injectable} from '@angular/core';
import {User} from "../../models/common/User";
import {AuthService} from "./auth/AuthService";
import {ApiService} from './ApiService';
import * as Rx from 'rxjs';
let _uniq = require('lodash/uniq');

@Injectable()
export class UserService {
  currentUserId:string;
  currentUser:User;
  currentUserObservable:Rx.Subject<User>;

  constructor(private api:ApiService, authService:AuthService) {
    //noinspection TypeScriptUnresolvedFunction
    authService.currentUserObservable.subscribe((user) => {
      this.currentUser = user;
      this.currentUserId = user ? user.id : null;
      if (user) {
        let o = new Rx.ReplaySubject<User>(1);
        o.next(user);
        this._usersCache.set(user.id, o);
      }
    });
    this.currentUserObservable = authService.currentUserObservable;
  }

  private _usersCache:Map<string, Rx.ReplaySubject<User>> = new Map<string, Rx.ReplaySubject<User>>();

  isCurrentUser(user:User) {
    return this.currentUser && user && this.currentUser.id === user.id;
  }

  getById(id):Rx.Subject<User> {
    if (!this._usersCache.has(id)) {
      this._usersCache.set(id, new Rx.ReplaySubject<User>(1));
      this.api.request('get', `users/${id}`)
        .subscribe(user => this._usersCache.get(user.id).next(user));
    }
    return this._usersCache.get(id);
  }

  requestById(id, filter = null) {
    let data = filter ? {filter: JSON.stringify(filter)} : null;
    return this.api.request('get', `users/${id}`, data)
  }

  requestIds(allIds) {
    allIds = _uniq(allIds);
    let ids = allIds.filter(id => !this._usersCache.has(id));
    if (ids.length > 0) {
      ids.forEach((id) => {
        this._usersCache.set(id, new Rx.ReplaySubject<User>(1));
      });

      //let's request for allIds to update cache if we need at least one
      let where = {id: {inq: allIds}};
      let filter = {where: where};
      this.api.request('get', 'users', {filter: JSON.stringify(filter)})
        .subscribe(users => {
          users.forEach(user => this._usersCache.get(user.id).next(user));
        })
    }
  }

  getUserIdentitiesById(id) {
    return this.api.request('get', `users/${id}/identities`)
  }

  get({where, order = "", offset = 0}) {
    let filter = JSON.stringify({where: where, order: order, offset: offset});
    return this.api.request('get', 'users', {filter: filter})
      .map(rows => rows.map(row => new User({init: row})))
  }

  count(where = null) {
    let data = {};
    if (where) {
      data['where'] = JSON.stringify(where);
    }
    return this.api.request('get', 'users/count', data).map(data => data.count);
  }
}