home/Yep
2
0
Fork 0
mirror of https://github.com/wahyd4/Yep.git synced 2026-08-16 16:28:45 +10:00
Code Issues Packages Projects Releases Wiki Activity

better sync history logic for when into Conversation

Browse Source
This commit is contained in:
nixzhu
2015-10-13 13:15:09 +08:00
committed by nixzhu
parent 9f847edaa9
commit cf1fcd163a
1 changed files with 39 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Yep/ViewControllers/Conversation/ConversationViewController.swift
+39 -26
View File
@@ -404,37 +404,50 @@ class ConversationViewController: BaseViewController {
}
}
// sync unread messages
// sync messages
if let groupID = conversation.withGroup?.groupID {
joinGroup(groupID: groupID, failureHandler: { (reason, error) -> Void in
print("Join Group Failed \(reason)")
}, completion: {(result) -> Void in
dispatch_async(dispatch_get_main_queue()) {
FayeService.sharedManager.subscribeGroup(groupID: groupID)
let syncMessages: () -> Void = {
dispatch_async(dispatch_get_main_queue()) { [weak self] in
if let recipient = self?.conversation.recipient {
let timeDirection: TimeDirection
if let minMessageID = self?.messages.last?.messageID {
timeDirection = .Future(minMessageID: minMessageID)
} else {
timeDirection = .None
}
messagesFromRecipient(recipient, withTimeDirection: timeDirection, failureHandler: nil, completion: { success in
println("messagesFromRecipient: \(success)")
})
}
})
}
dispatch_async(dispatch_get_main_queue()) { [weak self] in
if let recipient = self?.conversation.recipient {
let timeDirection: TimeDirection
if let minMessageID = self?.messages.last?.messageID {
timeDirection = .Future(minMessageID: minMessageID)
} else {
timeDirection = .None
}
messagesFromRecipient(recipient, withTimeDirection: timeDirection, failureHandler: nil, completion: { success in
println("messagesFromRecipient: \(success)")
})
}
}
}
switch conversation.type {
case ConversationType.OneToOne.rawValue:
syncMessages()
case ConversationType.Group.rawValue:
if let groupID = conversation.withGroup?.groupID {
joinGroup(groupID: groupID, failureHandler: nil, completion: { result in
syncMessages()
dispatch_async(dispatch_get_main_queue()) {
FayeService.sharedManager.subscribeGroup(groupID: groupID)
}
})
}
default:
break
}
}
override func viewWillAppear(animated: Bool) {
super.viewWillAppear(animated)