ThePain/Swiftgram
1
0
Fork 0
mirror of https://github.com/Swiftgram/Telegram-iOS.git synced 2025-12-24 07:05:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

no message

Browse Source
This commit is contained in:
Peter Iakovlev
2018-01-28 20:02:12 +04:00
parent 707558f331
commit 0d3e30c7c9
29 changed files with 456 additions and 1065 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
TelegramCore/SynchronizePeerReadState.swift
View File

@@ -66,7 +66,9 @@ private func dialogTopMessage(network: Network, postbox: Postbox, peerId: PeerId
}
func fetchPeerCloudReadState(network: Network, postbox: Postbox, peerId: PeerId, inputPeer: Api.InputPeer) -> Signal<PeerReadState?, NoError> {
return network.request(Api.functions.messages.getPeerDialogs(peers: [.inputDialogPeer(peer: inputPeer)]))
/*%layer76*/
//return network.request(Api.functions.messages.getPeerDialogs(peers: [.inputDialogPeer(peer: inputPeer)]))
return network.request(Api.functions.messages.getPeerDialogs(peers: [inputPeer]))
|> map { result -> PeerReadState? in
switch result {
case let .peerDialogs(dialogs, _, _, _, _):
@@ -81,9 +83,10 @@ func fetchPeerCloudReadState(network: Network, postbox: Postbox, peerId: PeerId,
apiReadInboxMaxId = readInboxMaxId
apiReadOutboxMaxId = readOutboxMaxId
apiUnreadCount = unreadCount
case .dialogFeed:
/*%layer76*/
/*case .dialogFeed:
assertionFailure()
return nil
return nil*/
}
return .idBased(maxIncomingReadId: apiReadInboxMaxId, maxOutgoingReadId: apiReadOutboxMaxId, maxKnownId: apiTopMessage, count: apiUnreadCount)
@@ -102,7 +105,9 @@ private func dialogReadState(network: Network, postbox: Postbox, peerId: PeerId)
|> mapToSignal { topMessage -> Signal<(PeerReadState, PeerReadStateMarker), VerifyReadStateError> in
return inputPeer(postbox: postbox, peerId: peerId)
|> mapToSignal { inputPeer -> Signal<(PeerReadState, PeerReadStateMarker), VerifyReadStateError> in
return network.request(Api.functions.messages.getPeerDialogs(peers: [.inputDialogPeer(peer: inputPeer)]))
/*%layer76*/
//return network.request(Api.functions.messages.getPeerDialogs(peers: [.inputDialogPeer(peer: inputPeer)]))
return network.request(Api.functions.messages.getPeerDialogs(peers: [inputPeer]))
|> retryRequest
|> mapToSignalPromotingError { result -> Signal<(PeerReadState, PeerReadStateMarker), VerifyReadStateError> in
switch result {
@@ -122,9 +127,10 @@ private func dialogReadState(network: Network, postbox: Postbox, peerId: PeerId)
if let pts = pts {
apiChannelPts = pts
}
case .dialogFeed:
/*%layer76*/
/*case .dialogFeed:
assertionFailure()
return .fail(.Abort)
return .fail(.Abort)*/
}
let marker: PeerReadStateMarker