//初始化聊天室
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();
  //監(jiān)聽用戶上下線提醒，實時更新onlineUsers對象
  this.subscriberPresence();
  //監(jiān)聽和接收新消息
  this.subscriberNewMessage();
};

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

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

 //隱藏登錄界面
 $(".chat-login-box").hide();
 // //顯示聊天界面
 $(".chatRoom-box").show();
 // //滑動到最后一行
 scrollBottom();
}

//監(jiān)聽用戶上下線時間，維護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在線用戶數(shù)
    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);
     //觸發(fā)界面的更新
     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);
       //觸發(fā)界面的更新
       self.onLeaveRoom(nickName, avatar);
      }
     }
    }
   });
  },
  onSuccess : function () {
   console.log("監(jiān)聽成功")
  },
  onFailed : function () {
   console.log("監(jiān)聽失敗")
  }
 });
};

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("消息發(fā)布成功。");
  },
  onFailed: function(error) {
   console.log("消息發(fā)送失敗，錯誤編碼：" + error.code + " 錯誤信息：" + error.content);
  }
 });
};

//監(jiān)聽消息或道具
this.subscriberNewMessage = function() {
 var self = this;
 this.goeasy.subscribe({
  channel: this.currentRoomId, //替換為您自己的channel
  onMessage: function(message) {
   var chatMessage = JSON.parse(message.content);
   //todo:事實上不推薦在前端收到時保存, 一個用戶開多個窗口，會導致重復保存, 建議所有消息都是都在發(fā)送時在服務器端保存，這里只是為了演示
   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("道具發(fā)布成功。");
  },
  onFailed: function(error) {
   console.log("道具發(fā)送失敗，錯誤編碼：" + error.code + " 錯誤信息：" + error.content);
  }
 });
};