//初始化聊天室
this.joinRoom = function(userId,nickName, avatar, roomID) {
  //初始化当前用户
  this.currentUser = new User(userId, nickName, avatar);
  //初始化当前聊天室id
  this.currentRoomId = roomID;
  //初始化goeasy，建立长连接
  this.goeasy = new GoEasy({
   host: "hangzhou.goeasy.io",
   appkey: "您的appkey",
   userId: this.currentUser.id,
   userData: '{"nickname":"' + this.currentUser.nickname + '","avatar":"' + this.currentUser.avatar + '"}',
   onConnected: function () {
    console.log( "GoEasy connect successfully.")
   },
   onDisconnected: function () {
    console.log("GoEasy disconnected.")
   }
  });
  //查询当前在线用户列表，初始化onlineUsers对象
  this.initialOnlineUsers();
  //监听用户上下线提醒，实时更新onlineUsers对象
  this.subscriberPresence();
  //监听和接收新消息
  this.subscriberNewMessage();
};

//页面切换到聊天室界面
function showChatRoom() {
 //更新房间名
 $("#chatRoom-header").find(".current-chatRoom-name").text(loginCommand.roomName);

 //加载聊天历史
 var chatHistory = service.loadChatHistory();
 chatHistory.forEach(function (item) {
  //展示发送的消息
  var otherPerson = createCurrentChatRoomPerson(item.senderNickname + ":", item.content)
  $(".chatRoom-content-box").append($(otherPerson));
 });

 //隐藏登录界面
 $(".chat-login-box").hide();
 // //显示聊天界面
 $(".chatRoom-box").show();
 // //滑动到最后一行
 scrollBottom();
}

//监听用户上下线时间，维护onlineUsers对象
this.subscriberPresence = function() {
 var self = this;
 this.goeasy.subscribePresence({
  channel: this.currentRoomId,
  onPresence: function(presenceEvents) {
   presenceEvents.events.forEach(function(event) {
    var userId = event.userId;
    var count = presenceEvents.clientAmount;
    //更新onlineUsers在线用户数
    self.onlineUsers.count = count;
    //如果有用户进入聊天室
    if (event.action == "join" || event.action == "online") {
     var userData = JSON.parse(event.userData);
     var nickName = userData.nickname;
     var avatar = userData.avatar;
     var user = new User(userId, nickName, avatar);
     //将新用户加入onlineUsers列表
     self.onlineUsers.users.push(user);
     //触发界面的更新
     self.onJoinRoom(user.nickname, user.avatar);
    } else {
     for (var i = 0; i < self.onlineUsers.users.length; i++) {
      var leavingUser = self.onlineUsers.users[i];
      if (leavingUser.id == userId) {
       var nickName = leavingUser.nickname;
       var avatar = leavingUser.avatar;
       //将离开的用户从onlineUsers中删掉
       self.onlineUsers.users.splice(i, 1);
       //触发界面的更新
       self.onLeaveRoom(nickName, avatar);
      }
     }
    }
   });
  },
  onSuccess : function () {
   console.log("监听成功")
  },
  onFailed : function () {
   console.log("监听失败")
  }
 });
};

this.sendMessage = function(content) {
 var message = new ChatMessage(this.currentUser.id,this.currentUser.nickname, MessageType.CHAT, content);
 var self = this;
 this.goeasy.publish({
  channel: self.currentRoomId,
  message: JSON.stringify(message),
  onSuccess: function() {
   console.log("消息发布成功。");
  },
  onFailed: function(error) {
   console.log("消息发送失败，错误编码：" + error.code + " 错误信息：" + error.content);
  }
 });
};

//监听消息或道具
this.subscriberNewMessage = function() {
 var self = this;
 this.goeasy.subscribe({
  channel: this.currentRoomId, //替换为您自己的channel
  onMessage: function(message) {
   var chatMessage = JSON.parse(message.content);
   //todo:事实上不推荐在前端收到时保存, 一个用户开多个窗口，会导致重复保存, 建议所有消息都是都在发送时在服务器端保存，这里只是为了演示
   self.restapi.saveChatMessage(self.currentRoomId, chatMessage);
   //如果收到的是一个消息，就显示为消息
   if (chatMessage.type == MessageType.CHAT) {
    var selfSent = chatMessage.senderUserId == self.currentUser.id;
    var content = JSON.parse(message.content);
    self.onNewMessage(chatMessage.senderNickname, content, selfSent);
   }
   //如果收到的是一个道具，就播放道具动画
   if (chatMessage.type == MessageType.PROP) {
    if (chatMessage.content == Prop.ROCKET) {
     self.onNewRocket(chatMessage.senderNickname);
    }
    if (chatMessage.content == Prop.HEART) {
     self.onNewHeart(chatMessage.senderNickname);
    }
   }
  }
 });
};

this.sendProp = function(prop) {
 var self = this;
 var message = new ChatMessage(this.currentUser.id,this.currentUser.nickname, MessageType.PROP, prop);
 this.goeasy.publish({
  channel: self.currentRoomId,
  message: JSON.stringify(message),
  onSuccess: function() {
   console.log("道具发布成功。");
  },
  onFailed: function(error) {
   console.log("道具发送失败，错误编码：" + error.code + " 错误信息：" + error.content);
  }
 });
};