| 2206 | } |
| 2207 | |
| 2208 | FullMsgId ResolveTopPinnedId( |
| 2209 | not_null<PeerData*> peer, |
| 2210 | MsgId topicRootId, |
| 2211 | PeerId monoforumPeerId, |
| 2212 | PeerData *migrated) { |
| 2213 | const auto slice = peer->session().storage().snapshot( |
| 2214 | Storage::SharedMediaQuery( |
| 2215 | Storage::SharedMediaKey( |
| 2216 | peer->id, |
| 2217 | topicRootId, |
| 2218 | monoforumPeerId, |
| 2219 | Storage::SharedMediaType::Pinned, |
| 2220 | ServerMaxMsgId - 1), |
| 2221 | 1, |
| 2222 | 1)); |
| 2223 | const auto old = (!topicRootId && !monoforumPeerId && migrated) |
| 2224 | ? migrated->session().storage().snapshot( |
| 2225 | Storage::SharedMediaQuery( |
| 2226 | Storage::SharedMediaKey( |
| 2227 | migrated->id, |
| 2228 | MsgId(0), // topicRootId |
| 2229 | PeerId(0), // monoforumPeerId |
| 2230 | Storage::SharedMediaType::Pinned, |
| 2231 | ServerMaxMsgId - 1), |
| 2232 | 1, |
| 2233 | 1)) |
| 2234 | : Storage::SharedMediaResult{ |
| 2235 | .count = 0, |
| 2236 | .skippedBefore = 0, |
| 2237 | .skippedAfter = 0, |
| 2238 | }; |
| 2239 | if (!slice.messageIds.empty()) { |
| 2240 | return FullMsgId(peer->id, slice.messageIds.back()); |
| 2241 | } else if (!migrated || slice.count != 0 || old.messageIds.empty()) { |
| 2242 | return FullMsgId(); |
| 2243 | } else { |
| 2244 | return FullMsgId(migrated->id, old.messageIds.back()); |
| 2245 | } |
| 2246 | } |
| 2247 | |
| 2248 | FullMsgId ResolveMinPinnedId( |
| 2249 | not_null<PeerData*> peer, |
no test coverage detected