void socketMessages() {
WebServices.socket.on('message', (data) {
if (data != null) {
var json = jsonDecode(data);
print(json.length.toString() + "tane mesaj listelenecek.");
MessageModel.messages.clear();
for (var index in json) {
MessageInfoModel messageInfoModel = MessageInfoModel.fromJson(index);
MessageModel.messages.add(messageInfoModel);
}
print("Son mesaj : " + MessageModel.messages.last.message);
WebServices.socket.emit('get-conversations-of', {
'ParticipantID': GlobalV.user.driver.sId,
'Limit': 30 //Kaç adet kişiyle konuşmanın döndürüleceği
});
setState(() {});
}
});
WebServices.socket.on('get-conversations-of', (data) {
if (data != null) {
List<dynamic> json = jsonDecode(data);
print(json.length.toString() + "tane konuşma mevcut.");
ConversationsModel.conversations.clear();
for (var index in json.reversed) {
ConversationInfoModel conversationInfoModel =
ConversationInfoModel.fromJson(index);
ConversationsModel.conversations.add(conversationInfoModel);
}
print(
ConversationsModel.conversations.first.participants.first.fullName);
setState(() {});
}
});
}