// //////////////////////////////////////////////////////////////////////////////
//
//  Copyright (C) 2016-present  All Rights Reserved.
//  Licensed under the Apache License, Version 2.0 (the "License");
//  http://www.apache.org/licenses/LICENSE-2.0
//
//  Github Home: https://github.com/AlexWang1987
//  Author: AlexWang
//  Date: 2016-08-26 17:36:20
//  QQ Email: 1669499355@qq.com
//  Last Modified time: 2017-06-27 18:13:39
//  Description: LiveClass-CursorApe
//
// //////////////////////////////////////////////////////////////////////////////

import Ape from './Ape';
import ApeConsts from './ApeConsts';
import pdu from 'pdus';
import Loger from 'Loger';
import MessageTypes from 'MessageTypes';
import GlobalConfig from 'GlobalConfig';
import EngineUtils from 'EngineUtils';

let loger = Loger.getLoger('CursorApe');

const DEFAULT_TYPE = 0; //鼠标

class CursorApe extends Ape {
  constructor() {
    super(
      ApeConsts.CURSOR_SESSION_ID,
      ApeConsts.CURSOR_SESSION_NAME,
      ApeConsts.CURSOR_SESSION_TAG
    );

    //Ape Models
    this.registerKey(this._session_id, this._session_name, this._session_tag, new ArrayBuffer);
    this.registerObj(pdu.RCPDU_REG_REGISTER_TABLE, ApeConsts.CURSOR_OBJ_TABLE_ID,
      ApeConsts.CURSOR_OBJ_TABLE_NAME, ApeConsts.CURSOR_OBJ_TABLE_TAG, 0, new ArrayBuffer);

    // ape listeners
    this.on(pdu.RCPDU_SESSION_JOIN_RESPONSE, this._joinSessionHandler.bind(this));
  }

  _joinSessionHandler(_data) {
    loger.log("RCPDU_SESSION_JOIN_RESPONSE");
  }

  // 添加鼠标
  sendInsertCursor(_param) {
    if (_param == null || EngineUtils.isEmptyObject(_param)) {
      loger.warn('添加标注失败->参数错误->', _param);
      this._emit(MessageTypes.MCU_ERROR, MessageTypes.ERR_APE_INTERFACE_PARAM_WRONG);
      return;
    }

    let itemIdx = EngineUtils.creatSoleNumberFromTimestamp(); //创建时间戳，保证每条数据的唯一
    let cursorModelPdu = this.packPdu(_param, itemIdx);
    if (cursorModelPdu == null) {
      loger.warn('添加标注失败-->参数错误->', _param);
      this._emit(MessageTypes.MCU_ERROR, MessageTypes.ERR_APE_INTERFACE_PARAM_WRONG);
      return;
    }

    let tableItemPdu = new pdu['RCRegistryTableItemPdu'];
    tableItemPdu.itemIdx = itemIdx; //直接用时间戳作为id
    tableItemPdu.registerObjId = ApeConsts.CURSOR_OBJ_TABLE_ID;
    tableItemPdu.owner = 0; //收到flash的是这个值，不清楚先写固定
    tableItemPdu.itemData = cursorModelPdu.toArrayBuffer();

    //insert
    let tableInsertItemPdu = new pdu['RCRegistryTableInsertItemPdu'];
    tableInsertItemPdu.type = pdu.RCPDU_REG_TABLE_INSERT_PDU; //
    tableInsertItemPdu.items.push(tableItemPdu);

    let updateObjPdu = new pdu['RCRegistryUpdateObjPdu'];
    updateObjPdu.objId = ApeConsts.CURSOR_OBJ_TABLE_ID;
    updateObjPdu.subType = tableInsertItemPdu.type;
    updateObjPdu.userData = tableInsertItemPdu.toArrayBuffer();

    //同步
    let adapterItemPdu = new pdu['RCAdapterItemPdu'];
    adapterItemPdu.type = pdu.RCPDU_REG_UPDATE_OBJ;
    adapterItemPdu.itemData = updateObjPdu.toArrayBuffer();

    let adapterPdu = new pdu['RCAdapterPdu'];
    adapterPdu.type = pdu.RCPDU_REG_ADAPTER;
    adapterPdu.item.push(adapterItemPdu);

    loger.log("添加标注->itemIdx=" + tableItemPdu.itemIdx);
    this.sendUniform(adapterPdu, true);
  }

  /////鼠标数据接受/////////////////////////////////////////////////////////////////////////////////
  tableInsertHandler(owner, itemIdx, itemData) {
    let cursorModel = this.unPackPdu(owner, itemIdx, itemData);
    loger.log('tableInsertHandler', "activeDocId->", GlobalConfig.activeDocId, "parentId->", cursorModel.parentId);
    loger.log(cursorModel);
    if (cursorModel) {
      this._emit(MessageTypes.CURSOR_UPDATE, cursorModel);
    }
  }

  ///////鼠标数据发送/////////////////////////////////////////
  packPdu(_param, _itemIdx) {
    //验证坐标点集合数组是否合法
    if (_param.pointGroup == null || _param.pointGroup.length < 1) {
      this._emit(MessageTypes.MCU_ERROR, MessageTypes.ERR_APE_INTERFACE_PARAM_WRONG);
      return null;
    }

    //判断type类型，根据type设置不同的参数
    let cursorModelPdu = new pdu['RCCursorDataModelPdu'];

    //下面4个是必须的参数
    cursorModelPdu.type = DEFAULT_TYPE;
    cursorModelPdu.itemIdx = _itemIdx;
    cursorModelPdu.initiator = GlobalConfig.nodeId;

    cursorModelPdu.parentId = GlobalConfig.activeDocId; //当前激活的文档id
    cursorModelPdu.curPageNo = GlobalConfig.activeDocCurPage; //当前激活的文档页码

    cursorModelPdu.pointGroup = EngineUtils.arrayToJsonString(_param.pointGroup);
    cursorModelPdu.color = _param.color || "#000000";
    cursorModelPdu.thickness = _param.thickness || 1;
    cursorModelPdu.duration = _param.duration || 0;

    return cursorModelPdu;
  }

  unPackPdu(owner, itemIdx, itemData) {
    try {
      loger.log("鼠标标注数据->unPackPdu");
      let cursorModelPdu = pdu['RCCursorDataModelPdu'].decode(itemData);
      let _pointGroup = EngineUtils.arrayFromJsonString(cursorModelPdu.pointGroup);
      cursorModelPdu.pointGroup = _pointGroup;
      return cursorModelPdu;
    } catch (err) {
      loger.log("鼠标标注数据->unPackPdu->Pdu解析错误，itemIdx=" + itemIdx + "  err:" + err.message);
    }
    return null;
  }
}

export default CursorApe;