teocli.clients.ts

/*
 * The MIT License
 *
 * Copyright 2017 Kirill Scherba <kirill@scherba.ru>.
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */

import {Component, OnDestroy} from '@angular/core';

import {TeonetCli, Teonet, onotherData, onechoData} from './teocli.module';
import {IntervalObservable} from 'rxjs/observable/IntervalObservable';

export type onclientDisplArEl = {name: string, translate: string, email: string, type: string, time: number};
export type onclientDisplAr = Array<onclientDisplArEl>;
type onclientsDataAr = Array<{name: string}>;
type onclientsData = {
  cmd: number,
  from: string,
  data: {
    length: number,
    client_data_ar: onclientsDataAr
  }
};

export class TeonetClientsRequest {

  constructor(private t: TeonetCli) {}

  /**
   * Send user info request
   *
   * @param {string} name Clients accessToken
   * @returns {undefined}
   */
  sendUserInfo (name: string) {

    //console.debug("TeonetCli.send_user_info_request", name);

    //if(teocli !== undefined)
    this.t.send('{ "cmd": 132, "to": "' + Teonet.peer.auth + '", "data": ["' + name + '"] }');
  }

  /**
   * Send clients info request
   *
   * @param {type} client
   * @returns {undefined}
   */
  sendClientInfo(client: string) {

    //console.debug("ClientsController.send_client_info_request", client);

    //if(teocli !== undefined)
    this.t.send('{ "cmd": 134, "to": "' + Teonet.peer.auth + '", "data": ["' + client + '"] }');
  }

}

@Component({
  selector: 'teonet-clients',
  styles: ['\n\
  .border-right {\n\
    border-right: solid 1px #eee;\n\
  }\n\
  .header {\n\
    border: solid 1px #eee;\n\
  }\n\
  '],
  template: '\n\
    <div class="row item-divider item header toolbar-background-md">\n\
      <div class="col border-right" col-1>№</div>\n\
      <div class="col border-right">User name</div>\n\
      <div class="col border-right">Client type</div>\n\
      <div class="col" col-2 text-right>Ping</div>\n\
    </div>\n\
    \n\
    <div class="content">\n\
      <div class="teonet-clients-body row item {{ (i%2 ? \'toolbar-background-md\' : \'\') }}" \n\
        *ngFor="let client of clients; index as i; first as isFirst">\n\
        <div class="col border-right" col-1>{{i+1}}</div>\n\
        <div class="col border-right"><a href="#">{{(client.translate ? client.translate : client.name) | slice:0:15}}</a></div>\n\
        <div class="col border-right">{{(client.type ? client.type : "") | slice:0:15}}</div>\n\
        <div class="col" col-2 text-right>{{(client.time ? client.time : "")}}</div>\n\
      </div>\n\
    </div>\n\
    \n'
//    <div class="row text-center padding" [hidden]="clients.length">\n\
//      <ion-col col-1><ion-spinner icon="lines"></ion-spinner></ion-col>\n\
//      <ion-col class="padding">Clients loading...</ion-col>\n\
//    </div>\n\
})

/**
 * Clients class
 */
export class TeonetClients implements OnDestroy {

  n: number = 0;
  tabIndex: number;
  clients: onclientDisplAr = [];

  private f: Array<any> = [];
  private onclients: any;
  private cli = new TeonetClientsTranslate(this.t);

  private interval = IntervalObservable.create(1000).subscribe(() => { //.subscribe(n => this.n = n);
    this.n++;
    if (this.isComponentActive()) this.t.clients(Teonet.peer.l0);
  });

  constructor(private t: TeonetCli) {

    //console.debug('TeonetClients::constructor');

    this.f.push(t.whenInit(() => {
      //console.debug('TeonetClients::whenInit');
      t.clients(Teonet.peer.l0);
    }));

    this.f.push(t.whenClose(() => {
      //console.debug('TeonetClients::whenClose');
      this.clients = [];
    }));

    this.f.push(t.whenEvent('onclients', (data: any): number => {

      let need_sort = false;
      let d = <onclientsData>(data[0][0]);
      if (d.from == Teonet.peer.l0) {
        //console.debug('TeonetClients::onclients', data, d, this.clients);

        // Remove not existing (disconnected) clients
        let clients = this.clients.filter(
          function (x) {
            return d.data.client_data_ar.inArray(
              function (e) {
                return x.name === e.name;
              },
              function () {}
            );
          }
        );
        if (clients.length != this.clients.length) {
          this.clients = clients;
          //need_sort = true;
        }

        // Add new clients to clients array
        for (let client of d.data.client_data_ar) {

          let el: onclientDisplArEl = {
            name: client.name,
            translate: '',
            email: '',
            type: '',
            time: 0
          };
          this.clients.pushIfNotExist(
            // Client to add
            el,
            // Comparer
            function (currentElement: onclientDisplArEl) {
              return currentElement.name === el.name;
            },
            // Done
            (currentElement: onclientDisplArEl) => {
              //console.debug('TeonetClients::pushIfNotExist Add element:',
              //  currentElement);

              // Send user_info & client_info requests
              let name_split = currentElement.name.split(':');
              if (name_split[0]) {
                //this.cli.sendUserInfo(name_split[0]);
                this.cli.getUserInfo(name_split[0],
                  (err: any, user: TeonetUserInfo) => {
                    if (!err) {
                      this.clients.inArray(
                        // Comparer
                        function (currentElement: onclientDisplArEl) {
                          let name_split = currentElement.name.split(':');
                          return name_split[0] === user.userId;
                        },
                        // Exists
                        function (currentElement: onclientDisplArEl) {
                          currentElement.translate = user.username;
                          currentElement.email = user.email;
                        }
                      );
                    }
                  }
                );
              }
              if (name_split[1]) {
                this.cli.getClientInfo(name_split[1],
                  (err: any, client: TeonetClientInfo) => {
                    if (!err) {
                      //this.cli.sendClientInfo(name_split[1]);
                      this.clients.inArray(
                        // Comparer
                        function (currentElement: onclientDisplArEl) {
                          let name_split = currentElement.name.split(':');
                          return name_split[1] === client.clientId;
                        },
                        // Exists
                        function (currentElement: onclientDisplArEl) {
                          currentElement.type = client.data.type;
                        }
                      );
                    }
                  }
                );
              }

              need_sort = true;
            },
            // Exists
            function (currentElement: onclientDisplArEl) {
              //console.debug('TeonetClients::pushIfNotExist Element exists:',
              //  currentElement);
            }
          );

          // Send ping to client
          if (client.name != t.getClientName())
            t.echo(client.name, 'Hello from contact page n = ' + this.n);

        }

        // Sort clients array
        if (need_sort) {
          this.clients.sort(function (a, b) {
            return a.name == b.name ? (a.type == b.type ? 0 :
              (a.type < b.type ? -1 : 1)) : (a.name < b.name ? -1 : 1);
          });
        }
      }
      
      if (this.onclients) this.onclients();

      return 0;
    }));

    this.f.push(t.whenEvent('onecho', (data: any): number => {

      if (!this.isComponentActive()) return 0;

      var d: onechoData = data[0][0];
      //console.debug('TeonetClients::onecho', data, d);

      this.clients.inArray(
        // Comparer
        function (currentElement: onclientDisplArEl) {
          return currentElement.name === d.from;
        },
        // Exists
        function (currentElement: onclientDisplArEl) {
          currentElement.time = d.data.time;
        }
      );

      return 0;
    }));

    // Send clients list request to L0 server
    t.clients(Teonet.peer.l0);
  }

  ngOnDestroy() {
    //console.debug('TeonetClients::ngOnDestroy');
    for (let f of this.f) this.t.unsubscribe(f);
    this.interval.unsubscribe();
  }
  
  setOnclients(onclients: any) {
    this.onclients = onclients;
  }

  private isComponentActive(): boolean {
    return this.t.isTeonetClientsActive();
  }
}

/**
 * Number of loggedin clients
 */
export class TeonetClientsNum implements OnDestroy {

  num_clients = 0;
  private f: Array<any> = [];

  constructor(public t: TeonetCli) {

    //console.debug('TeonetClientsNum::constructor');

    this.f.push(t.whenInit(() => {
      //console.debug('TeonetClientsNum::whenInit');
      // Send clients number request command to "teo-web" peer
      this.sendClientsNum();
    }));

    this.f.push(t.whenEvent('onother', (data: any): number => {
      let d: onotherData = data[0][0];
      if(d.from == Teonet.peer.l0) {
        //console.debug('TeonetClientsNum::onother', data, d);
        // Process clients number responces
        this.processClientsNum(d);
      }
      return 0;
    }));
  }

  ngOnDestroy() {
    //console.debug('TeonetClientsNum::destructor');
    for (let f of this.f) this.t.unsubscribe(f);
    this.sendClientsMumUnsubscribe();
    this.num_clients = 0;
  }

  /**
   * Get clients number answer callback function
   *
   * @param {onotherData} data
   * @returns {number}
   */
  private processClientsNum(data: onotherData) {

    let processed = 0;
    let client = "";
    let client_code = "";
    let clientsNumber = this.num_clients;

    // Process command #85 CMD_L0_CLIENTS_N_ANSWER
    if (data.cmd === 85) {

      type CMD_L0_CLIENTS_N_ANSWER = {numClients: number};

      //console.debug("TeonetClientsNum::processClientsNum, data:", data);

      clientsNumber = (<CMD_L0_CLIENTS_N_ANSWER> data.data).numClients;
      this.sendClientsNumSubscribe();
      processed = 1;
    }

    // Process command #83 CMD_SUBSCRIBE_ANSWER
    else if (data.cmd === 83) {

      type CMD_SUBSCRIBE_ANSWER = {ev: number, cmd: number, data: string}

      let byteCharacters = atob((<CMD_SUBSCRIBE_ANSWER> data.data).data);
      for (let i = 0; i < (byteCharacters.length); i++) {
        client_code += byteCharacters.charCodeAt(i) + '.';
      }

      client = atob((<CMD_SUBSCRIBE_ANSWER> data.data).data);

      // L0 client Connected
      if ((<CMD_SUBSCRIBE_ANSWER> data.data).ev === 21) {
        if (byteCharacters.charCodeAt(0)) clientsNumber += 1;
        processed = 1;
      }

      // L0 client Disconnected
      else if ((<CMD_SUBSCRIBE_ANSWER> data.data).ev === 22) {
        clientsNumber -= 1;
        processed = 1;
      }
    }

    if (processed) {
      //console.debug("TeonetClientsNum::processClientsNum, data:",
      //  data, "client:", client, "client_code:", client_code);
      this.num_clients = clientsNumber;
    }

    return processed;
  }

  /**
   * Send clients number request
   *
   * @returns {undefined}
   */
  private sendClientsNum() {

    // Send clients number request
    this.t.send('{ "cmd": 84, "to": "' + Teonet.peer.l0 + '", "data": "JSON" }');
  }

  /**
   * Send subscribe to connect / disconnect client events request
   *
   * @returns {undefined}
   */
  private sendClientsNumSubscribe() {

    // Send CMD_SUBSCRIBE Subscribe to L0 client Connected / Disconnected
    this.t.send('{ "cmd": 81, "to": "' + Teonet.peer.l0 + '", "data": "TEXT:21" }');
    this.t.send('{ "cmd": 81, "to": "' + Teonet.peer.l0 + '", "data": "TEXT:22" }');
  }

  /**
   * Request unsubscribe from Connected / Disconnected events
   *
   * @returns {undefined}
   */
  private sendClientsMumUnsubscribe() {

    // Send CMD_SUBSCRIBE UnSubscribe to L0 client Connected / Disconnected
    if (this.t && this.t.isInit()) {
      this.t.send('{ "cmd": 82, "to": "' + Teonet.peer.l0 + '", "data": "TEXT:21" }');
      this.t.send('{ "cmd": 82, "to": "' + Teonet.peer.l0 + '", "data": "TEXT:22" }');
    }
  }
}

export type TeonetUserInfo = {
  userId: string,
  username: string,
  email: string
};
export type TeonetClientInfo = {
  clientId: string,
  registerDate: Date,
  data: {
    type: string;
  }
};

/**
 * Class to translate user and clien from code to human name (from teonet)
 */
export class TeonetClientsTranslate implements OnDestroy {

  //private f: Array<any> = [];
  private cli = new TeonetClientsRequest(this.t);
  private TIMEOUT = 3000;

  // Register to TeonetCli onother event
  constructor(private t: TeonetCli) {
    //
  }

  ngOnDestroy() {
    //
  }

  private setTimeout(f: any, done: any) {
    return setTimeout(()=>{
      done('Timeout');
      this.t.unsubscribe(f);
    }, this.TIMEOUT);
  }

  splitName(name: string): { user: string, client: string } {
    let name_split = name.split(':');
    return { user: name_split[0], client: name_split[1] };
  }
  
  private getInfo(id: string, type: boolean, 
    done: (err: any, info?: TeonetUserInfo | TeonetClientInfo) => void) {

    let f = this.t.whenEvent('onother', (data: any): number => {
      var d: onotherData = data[0][0];
      // Process ansewers from teo-auth
      if (d.from == Teonet.peer.auth) {
        // Process user_info # 133 
        if (!type && d.cmd == 133) {
          let user: TeonetUserInfo = d.data;
          if (id == user.userId) _done(user);
        }
        // Process client_info # 135
        else if (type && d.cmd == 135) {
          let client: TeonetClientInfo = d.data;
          if (id == client.clientId) _done(client);
        }
      }
      return 0;
    }), 
    timer = this.setTimeout(f, done),
    _done = (arg: any) => {
      this.t.unsubscribe(f);
      clearTimeout(timer);
      done(null, arg);
    }
    
    if(!type) this.cli.sendUserInfo(id);
    else this.cli.sendClientInfo(id);
  }
  
  getUserInfo(user_id: string, done: (err: any, user?: TeonetUserInfo) => void) {
    this.getInfo(user_id, false, done);    
  }

  getClientInfo(client_id: string, done: (err: any, client?: TeonetClientInfo) => void) {
    this.getInfo(client_id, true, done);    
  }
}