ThePain/Swiftgram
1
0
Fork 0
mirror of https://github.com/Swiftgram/Telegram-iOS.git synced 2025-12-23 14:45:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

Bot updates

Browse Source
This commit is contained in:
Isaac
2025-08-15 13:35:06 +02:00
parent 92156ffec0
commit 826c48a4dc
17 changed files with 403 additions and 64 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
submodules/TelegramUI/Sources/Chat/ChatControllerLoadDisplayNode.swift
View File

@@ -130,6 +130,9 @@ extension ChatControllerImpl {
self.contentDataDisposable?.dispose()
self.newTopicEventsDisposable?.dispose()
self.newTopicEventsDisposable = nil
let configuration: Signal<ChatControllerImpl.ContentData.Configuration, NoError> = self.presentationInterfaceStatePromise.get()
|> map { presentationInterfaceState -> ChatControllerImpl.ContentData.Configuration in
return ChatControllerImpl.ContentData.Configuration(
@@ -166,9 +169,9 @@ extension ChatControllerImpl {
if let historyNodeData = contentData.state.historyNodeData {
self.updateChatLocationToOther(chatLocation: historyNodeData.chatLocation)
return
} else if case let .botForumThread(_, threadId) = self.subject {
} else if case let .botForumThread(linkedForumId, threadId) = self.subject {
self.subject = nil
self.updateChatLocationThread(threadId: threadId)
self.updateInitialChatBotForumLocationThread(linkedForumId: linkedForumId, threadId: threadId)
return
}
@@ -206,6 +209,25 @@ extension ChatControllerImpl {
self.contentDataUpdated(synchronous: false, forceAnimation: false, previousState: previousState)
}
})
if self.newTopicEventsDisposable == nil, let peerId = chatLocation.peerId, chatLocation.threadId == EngineMessage.newTopicThreadId {
self.newTopicEventsDisposable = (self.context.account.pendingMessageManager.newTopicEvents(peerId: peerId)
|> mapToSignal { event -> Signal<Int64, NoError> in
if case let .didMove(fromThreadId, toThreadId) = event {
if fromThreadId == EngineMessage.newTopicThreadId {
return .single(toThreadId)
}
}
return .never()
}
|> take(1)
|> deliverOnMainQueue).startStrict(next: { [weak self] threadId in
guard let self else {
return
}
self.updateInitialChatBotForumLocationThread(linkedForumId: peerId, threadId: threadId)
})
}
})
}