mirror of
https://github.com/TelegramMessenger/Telegram-iOS.git
synced 2026-06-20 18:24:43 +00:00
isaacandClaude Opus 4.7
d1aa0db537
Squash of 63 commits spanning waves 46-93 (plus interspersed docs commits) of the gradual Postbox->TelegramEngine consumer-side migration. Scope: 139 files changed, 2123 insertions(+), 452 deletions(-). ## Themes by wave-block **Waves 46-58 — Peer field migrations + facade additions** Foundational EnginePeer convenience init additions (PeerReference, RenderedPeer, SelectivePrivacyPeer). Multiple `peer: Peer` field migrations across PeerInfo, ChatList, and SettingsUI components. **Waves 59-73 — peer field cascade + EnginePeer wrap drops** Series of single- to two-file peer-field migrations; consumer-side wrap removal (`EnginePeer(peer)` -> direct EnginePeer use); `as? TelegramUser` cast conversion to `case let .user(...)` enum match. Wave 64: RenderedPeer convenience init. Wave 68: SelectivePrivacyPeer convenience init. **Waves 74-83 — controller-Node bridge cleanup + small migrations** Wave-71 shadow-pattern cleanup at controller->Node bridges. Migrations of ChatRecentActionsController.peer (74), PeerInfoMember (75), MentionChatInputPanelItem (76), PassportUI SecureIdAuthController (77), AccountWithInfo + ShareController (78), peerInputActivitiesPromise (79), InactiveChannel (80), BlockedPeers (81), openHashtag resolveSignal (82), NotificationExceptionsList (83). **Waves 84-90 — TelegramEngine.Resources facade migrations** Per-method Shape-A/B sweeps converting `<ctx>.account.postbox.mediaBox.X(...)` to `<ctx>.engine.resources.X(...)`. Wave 90 was a single-commit big sweep: 40 fetchedMediaResource sites in 25 files migrated to engine.resources.fetch facade in one atomic pass with first-pass-clean build. Methods covered: storeResourceData, completedResourcePath, cancelInteractiveResourceFetch, resourceRangesStatus, resourceStatus, fetch (fetchedMediaResource). **Waves 91-92 — additional type migrations** Wave 91: ItemListWebsiteItem.peer + RecentSessionsController enum-case payload + openWebSession callback Peer? -> EnginePeer?. Wave 92: ChatListController StateHolder.EntryContext status type MediaResourceStatus -> EngineMediaResource.FetchStatus. **Wave 93 — speculative `import Postbox` drop sweep** Drop import from 7 wave-touched files where it became unused; restore in 5 files where bare PeerId/Message/MediaId/StoryId references escaped the pre-flight regex. Includes one MediaId(...) -> EngineMedia.Id(...) swap in InAppPurchaseManager to unlock its import drop. ## Build state Final state at squash: clean Telegram/Telegram build at debug_sim_arm64. ## Persistent-state notes - Pre-existing WIP unchanged across the squashed range: - build-system/bazel-rules/sourcekit-bazel-bsp submodule marker - Untracked: build-system/tulsi/, submodules/TgVoip/, third-party/libx264/ Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
365 lines
18 KiB
Swift
365 lines
18 KiB
Swift
import Foundation
|
|
import Postbox
|
|
import SwiftSignalKit
|
|
import TelegramApi
|
|
|
|
func _internal_togglePeerMuted(account: Account, peerId: PeerId, threadId: Int64?) -> Signal<Void, NoError> {
|
|
return account.postbox.transaction { transaction -> Void in
|
|
guard let peer = transaction.getPeer(peerId) else {
|
|
return
|
|
}
|
|
|
|
var notificationPeerId = peerId
|
|
if peer is TelegramSecretChat, let associatedPeerId = peer.associatedPeerId {
|
|
notificationPeerId = associatedPeerId
|
|
}
|
|
|
|
if let threadId = threadId {
|
|
if var data = transaction.getMessageHistoryThreadInfo(peerId: peerId, threadId: threadId)?.data.get(MessageHistoryThreadData.self) {
|
|
var updatedSettings: TelegramPeerNotificationSettings
|
|
switch data.notificationSettings.muteState {
|
|
case .default:
|
|
updatedSettings = data.notificationSettings.withUpdatedMuteState(.muted(until: Int32.max))
|
|
case .unmuted:
|
|
updatedSettings = data.notificationSettings.withUpdatedMuteState(.muted(until: Int32.max))
|
|
case .muted:
|
|
updatedSettings = data.notificationSettings.withUpdatedMuteState(.unmuted)
|
|
}
|
|
data.notificationSettings = updatedSettings
|
|
|
|
if let entry = StoredMessageHistoryThreadInfo(data) {
|
|
transaction.setMessageHistoryThreadInfo(peerId: peerId, threadId: threadId, info: entry)
|
|
|
|
//TODO:loc
|
|
let _ = pushPeerNotificationSettings(postbox: account.postbox, network: account.network, peerId: peerId, threadId: threadId, settings: TelegramPeerNotificationSettings.defaultSettings).start()
|
|
}
|
|
}
|
|
} else {
|
|
let currentSettings = transaction.getPeerNotificationSettings(id: notificationPeerId) as? TelegramPeerNotificationSettings
|
|
let previousSettings: TelegramPeerNotificationSettings
|
|
if let currentSettings = currentSettings {
|
|
previousSettings = currentSettings
|
|
} else {
|
|
previousSettings = TelegramPeerNotificationSettings.defaultSettings
|
|
}
|
|
|
|
let updatedSettings: TelegramPeerNotificationSettings
|
|
switch previousSettings.muteState {
|
|
case .default:
|
|
let globalNotificationSettings = transaction.getGlobalNotificationSettings()
|
|
if resolvedIsRemovedFromTotalUnreadCount(globalSettings: globalNotificationSettings, peer: peer, peerSettings: previousSettings) {
|
|
updatedSettings = previousSettings.withUpdatedMuteState(.unmuted)
|
|
} else {
|
|
updatedSettings = previousSettings.withUpdatedMuteState(.muted(until: Int32.max))
|
|
}
|
|
case .unmuted:
|
|
updatedSettings = previousSettings.withUpdatedMuteState(.muted(until: Int32.max))
|
|
case .muted:
|
|
updatedSettings = previousSettings.withUpdatedMuteState(.unmuted)
|
|
}
|
|
transaction.updatePendingPeerNotificationSettings(peerId: notificationPeerId, settings: updatedSettings)
|
|
}
|
|
}
|
|
}
|
|
|
|
public func resolvedAreStoriesMuted(globalSettings: GlobalNotificationSettingsSet, peer: EnginePeer, peerSettings: TelegramPeerNotificationSettings?, topSearchPeers: [PeerId]) -> Bool {
|
|
let defaultIsMuted: Bool
|
|
switch globalSettings.privateChats.storySettings.mute {
|
|
case .muted:
|
|
defaultIsMuted = true
|
|
case .unmuted:
|
|
defaultIsMuted = false
|
|
case .default:
|
|
defaultIsMuted = !topSearchPeers.prefix(5).contains(peer.id)
|
|
}
|
|
switch peerSettings?.storySettings.mute {
|
|
case .none:
|
|
return defaultIsMuted
|
|
case .muted:
|
|
return true
|
|
case .unmuted:
|
|
return false
|
|
default:
|
|
return defaultIsMuted
|
|
}
|
|
}
|
|
|
|
func _internal_togglePeerStoriesMuted(account: Account, peerId: PeerId) -> Signal<Void, NoError> {
|
|
return account.postbox.transaction { transaction -> Void in
|
|
guard let peer = transaction.getPeer(peerId) else {
|
|
return
|
|
}
|
|
|
|
var notificationPeerId = peerId
|
|
if peer is TelegramSecretChat, let associatedPeerId = peer.associatedPeerId {
|
|
notificationPeerId = associatedPeerId
|
|
}
|
|
|
|
let currentSettings = transaction.getPeerNotificationSettings(id: notificationPeerId) as? TelegramPeerNotificationSettings
|
|
let previousSettings: TelegramPeerNotificationSettings
|
|
if let currentSettings = currentSettings {
|
|
previousSettings = currentSettings
|
|
} else {
|
|
previousSettings = TelegramPeerNotificationSettings.defaultSettings
|
|
}
|
|
|
|
var topSearchPeers: [PeerId] = []
|
|
if let value = transaction.retrieveItemCacheEntry(id: cachedRecentPeersEntryId())?.get(CachedRecentPeers.self), value.enabled {
|
|
topSearchPeers = value.ids
|
|
}
|
|
|
|
let updatedSettings: TelegramPeerNotificationSettings
|
|
var storySettings = previousSettings.storySettings
|
|
switch previousSettings.storySettings.mute {
|
|
case .default:
|
|
let globalNotificationSettings = transaction.getPreferencesEntry(key: PreferencesKeys.globalNotifications)?.get(GlobalNotificationSettings.self) ?? GlobalNotificationSettings.defaultSettings
|
|
|
|
if resolvedAreStoriesMuted(globalSettings: globalNotificationSettings.effective, peer: EnginePeer(peer), peerSettings: previousSettings, topSearchPeers: topSearchPeers) {
|
|
storySettings.mute = .unmuted
|
|
} else {
|
|
storySettings.mute = .muted
|
|
}
|
|
case .unmuted:
|
|
storySettings.mute = .muted
|
|
case .muted:
|
|
storySettings.mute = .unmuted
|
|
}
|
|
updatedSettings = previousSettings.withUpdatedStorySettings(storySettings)
|
|
transaction.updatePendingPeerNotificationSettings(peerId: notificationPeerId, settings: updatedSettings)
|
|
}
|
|
}
|
|
|
|
func _internal_updatePeerMuteSetting(account: Account, peerId: PeerId, threadId: Int64?, muteInterval: Int32?) -> Signal<Void, NoError> {
|
|
return account.postbox.transaction { transaction -> Void in
|
|
_internal_updatePeerMuteSetting(account: account, transaction: transaction, peerId: peerId, threadId: threadId, muteInterval: muteInterval)
|
|
}
|
|
}
|
|
|
|
func _internal_updatePeerMuteSetting(account: Account, transaction: Transaction, peerId: PeerId, threadId: Int64?, muteInterval: Int32?) {
|
|
if let peer = transaction.getPeer(peerId) {
|
|
if let threadId = threadId {
|
|
let peerSettings: TelegramPeerNotificationSettings = (transaction.getPeerNotificationSettings(id: peerId) as? TelegramPeerNotificationSettings) ?? .defaultSettings
|
|
|
|
if var data = transaction.getMessageHistoryThreadInfo(peerId: peerId, threadId: threadId)?.data.get(MessageHistoryThreadData.self) {
|
|
let previousSettings: TelegramPeerNotificationSettings = data.notificationSettings
|
|
|
|
var muteState: PeerMuteState
|
|
if let muteInterval = muteInterval {
|
|
if muteInterval == 0 {
|
|
muteState = .unmuted
|
|
} else {
|
|
let absoluteUntil: Int32
|
|
if muteInterval == Int32.max {
|
|
absoluteUntil = Int32.max
|
|
} else {
|
|
absoluteUntil = Int32(Date().timeIntervalSince1970) + muteInterval
|
|
}
|
|
muteState = .muted(until: absoluteUntil)
|
|
}
|
|
} else {
|
|
muteState = .unmuted
|
|
}
|
|
if peerSettings.muteState == muteState {
|
|
muteState = .default
|
|
}
|
|
|
|
data.notificationSettings = previousSettings.withUpdatedMuteState(muteState)
|
|
|
|
if let entry = StoredMessageHistoryThreadInfo(data) {
|
|
transaction.setMessageHistoryThreadInfo(peerId: peerId, threadId: threadId, info: entry)
|
|
}
|
|
|
|
//TODO:loc
|
|
let _ = pushPeerNotificationSettings(postbox: account.postbox, network: account.network, peerId: peerId, threadId: threadId, settings: TelegramPeerNotificationSettings.defaultSettings).start()
|
|
}
|
|
} else {
|
|
var notificationPeerId = peerId
|
|
if peer is TelegramSecretChat, let associatedPeerId = peer.associatedPeerId {
|
|
notificationPeerId = associatedPeerId
|
|
}
|
|
|
|
let currentSettings = transaction.getPeerNotificationSettings(id: notificationPeerId) as? TelegramPeerNotificationSettings
|
|
let previousSettings: TelegramPeerNotificationSettings
|
|
if let currentSettings = currentSettings {
|
|
previousSettings = currentSettings
|
|
} else {
|
|
previousSettings = TelegramPeerNotificationSettings.defaultSettings
|
|
}
|
|
|
|
let muteState: PeerMuteState
|
|
if let muteInterval = muteInterval {
|
|
if muteInterval == 0 {
|
|
muteState = .unmuted
|
|
} else {
|
|
let absoluteUntil: Int32
|
|
if muteInterval == Int32.max {
|
|
absoluteUntil = Int32.max
|
|
} else {
|
|
absoluteUntil = Int32(Date().timeIntervalSince1970) + muteInterval
|
|
}
|
|
muteState = .muted(until: absoluteUntil)
|
|
}
|
|
} else {
|
|
muteState = .default
|
|
}
|
|
|
|
let updatedSettings = previousSettings.withUpdatedMuteState(muteState)
|
|
transaction.updatePendingPeerNotificationSettings(peerId: peerId, settings: updatedSettings)
|
|
}
|
|
}
|
|
}
|
|
|
|
func _internal_updatePeerDisplayPreviewsSetting(account: Account, peerId: PeerId, threadId: Int64?, displayPreviews: PeerNotificationDisplayPreviews) -> Signal<Void, NoError> {
|
|
return account.postbox.transaction { transaction -> Void in
|
|
_internal_updatePeerDisplayPreviewsSetting(account: account, transaction: transaction, peerId: peerId, threadId: threadId, displayPreviews: displayPreviews)
|
|
}
|
|
}
|
|
|
|
func _internal_updatePeerDisplayPreviewsSetting(account: Account, transaction: Transaction, peerId: PeerId, threadId: Int64?, displayPreviews: PeerNotificationDisplayPreviews) {
|
|
if let peer = transaction.getPeer(peerId) {
|
|
if let threadId = threadId {
|
|
if var data = transaction.getMessageHistoryThreadInfo(peerId: peerId, threadId: threadId)?.data.get(MessageHistoryThreadData.self) {
|
|
let previousSettings: TelegramPeerNotificationSettings = data.notificationSettings
|
|
|
|
data.notificationSettings = previousSettings.withUpdatedDisplayPreviews(displayPreviews)
|
|
|
|
if let entry = StoredMessageHistoryThreadInfo(data) {
|
|
transaction.setMessageHistoryThreadInfo(peerId: peerId, threadId: threadId, info: entry)
|
|
}
|
|
|
|
//TODO:loc
|
|
let _ = pushPeerNotificationSettings(postbox: account.postbox, network: account.network, peerId: peerId, threadId: threadId, settings: TelegramPeerNotificationSettings.defaultSettings).start()
|
|
}
|
|
} else {
|
|
var notificationPeerId = peerId
|
|
if peer is TelegramSecretChat, let associatedPeerId = peer.associatedPeerId {
|
|
notificationPeerId = associatedPeerId
|
|
}
|
|
|
|
let currentSettings = transaction.getPeerNotificationSettings(id: notificationPeerId) as? TelegramPeerNotificationSettings
|
|
let previousSettings: TelegramPeerNotificationSettings
|
|
if let currentSettings = currentSettings {
|
|
previousSettings = currentSettings
|
|
} else {
|
|
previousSettings = TelegramPeerNotificationSettings.defaultSettings
|
|
}
|
|
|
|
let updatedSettings = previousSettings.withUpdatedDisplayPreviews(displayPreviews)
|
|
transaction.updatePendingPeerNotificationSettings(peerId: peerId, settings: updatedSettings)
|
|
}
|
|
}
|
|
}
|
|
|
|
func _internal_updatePeerStoriesMutedSetting(account: Account, peerId: PeerId, mute: PeerStoryNotificationSettings.Mute) -> Signal<Void, NoError> {
|
|
return account.postbox.transaction { transaction -> Void in
|
|
_internal_updatePeerStoriesMutedSetting(account: account, transaction: transaction, peerId: peerId, mute: mute)
|
|
}
|
|
}
|
|
|
|
func _internal_updatePeerStoriesMutedSetting(account: Account, transaction: Transaction, peerId: PeerId, mute: PeerStoryNotificationSettings.Mute) {
|
|
if let peer = transaction.getPeer(peerId) {
|
|
var notificationPeerId = peerId
|
|
if peer is TelegramSecretChat, let associatedPeerId = peer.associatedPeerId {
|
|
notificationPeerId = associatedPeerId
|
|
}
|
|
|
|
let currentSettings = transaction.getPeerNotificationSettings(id: notificationPeerId) as? TelegramPeerNotificationSettings
|
|
let previousSettings: TelegramPeerNotificationSettings
|
|
if let currentSettings = currentSettings {
|
|
previousSettings = currentSettings
|
|
} else {
|
|
previousSettings = TelegramPeerNotificationSettings.defaultSettings
|
|
}
|
|
|
|
var storySettings = previousSettings.storySettings
|
|
storySettings.mute = mute
|
|
let updatedSettings = previousSettings.withUpdatedStorySettings(storySettings)
|
|
transaction.updatePendingPeerNotificationSettings(peerId: peerId, settings: updatedSettings)
|
|
}
|
|
}
|
|
|
|
func _internal_updatePeerStoriesHideSenderSetting(account: Account, transaction: Transaction, peerId: PeerId, hideSender: PeerStoryNotificationSettings.HideSender) {
|
|
if let peer = transaction.getPeer(peerId) {
|
|
var notificationPeerId = peerId
|
|
if peer is TelegramSecretChat, let associatedPeerId = peer.associatedPeerId {
|
|
notificationPeerId = associatedPeerId
|
|
}
|
|
|
|
let currentSettings = transaction.getPeerNotificationSettings(id: notificationPeerId) as? TelegramPeerNotificationSettings
|
|
let previousSettings: TelegramPeerNotificationSettings
|
|
if let currentSettings = currentSettings {
|
|
previousSettings = currentSettings
|
|
} else {
|
|
previousSettings = TelegramPeerNotificationSettings.defaultSettings
|
|
}
|
|
|
|
var storySettings = previousSettings.storySettings
|
|
storySettings.hideSender = hideSender
|
|
let updatedSettings = previousSettings.withUpdatedStorySettings(storySettings)
|
|
transaction.updatePendingPeerNotificationSettings(peerId: peerId, settings: updatedSettings)
|
|
}
|
|
}
|
|
|
|
func _internal_updatePeerNotificationSoundInteractive(account: Account, peerId: PeerId, threadId: Int64?, sound: PeerMessageSound) -> Signal<Void, NoError> {
|
|
return account.postbox.transaction { transaction -> Void in
|
|
_internal_updatePeerNotificationSoundInteractive(account: account, transaction: transaction, peerId: peerId, threadId: threadId, sound: sound)
|
|
}
|
|
}
|
|
|
|
func _internal_updatePeerNotificationSoundInteractive(account: Account, transaction: Transaction, peerId: PeerId, threadId: Int64?, sound: PeerMessageSound) {
|
|
if let peer = transaction.getPeer(peerId) {
|
|
if let threadId = threadId {
|
|
if var data = transaction.getMessageHistoryThreadInfo(peerId: peerId, threadId: threadId)?.data.get(MessageHistoryThreadData.self) {
|
|
let previousSettings: TelegramPeerNotificationSettings = data.notificationSettings
|
|
|
|
data.notificationSettings = previousSettings.withUpdatedMessageSound(sound)
|
|
|
|
if let entry = StoredMessageHistoryThreadInfo(data) {
|
|
transaction.setMessageHistoryThreadInfo(peerId: peerId, threadId: threadId, info: entry)
|
|
}
|
|
|
|
//TODO:loc
|
|
let _ = pushPeerNotificationSettings(postbox: account.postbox, network: account.network, peerId: peerId, threadId: threadId, settings: TelegramPeerNotificationSettings.defaultSettings).start()
|
|
}
|
|
} else {
|
|
var notificationPeerId = peerId
|
|
if peer is TelegramSecretChat, let associatedPeerId = peer.associatedPeerId {
|
|
notificationPeerId = associatedPeerId
|
|
}
|
|
|
|
let currentSettings = transaction.getPeerNotificationSettings(id: notificationPeerId) as? TelegramPeerNotificationSettings
|
|
let previousSettings: TelegramPeerNotificationSettings
|
|
if let currentSettings = currentSettings {
|
|
previousSettings = currentSettings
|
|
} else {
|
|
previousSettings = TelegramPeerNotificationSettings.defaultSettings
|
|
}
|
|
|
|
let updatedSettings = previousSettings.withUpdatedMessageSound(sound)
|
|
transaction.updatePendingPeerNotificationSettings(peerId: peerId, settings: updatedSettings)
|
|
}
|
|
}
|
|
}
|
|
|
|
func _internal_updatePeerStoryNotificationSoundInteractive(account: Account, transaction: Transaction, peerId: PeerId, sound: PeerMessageSound) {
|
|
if let peer = transaction.getPeer(peerId) {
|
|
var notificationPeerId = peerId
|
|
if peer is TelegramSecretChat, let associatedPeerId = peer.associatedPeerId {
|
|
notificationPeerId = associatedPeerId
|
|
}
|
|
|
|
let currentSettings = transaction.getPeerNotificationSettings(id: notificationPeerId) as? TelegramPeerNotificationSettings
|
|
let previousSettings: TelegramPeerNotificationSettings
|
|
if let currentSettings = currentSettings {
|
|
previousSettings = currentSettings
|
|
} else {
|
|
previousSettings = TelegramPeerNotificationSettings.defaultSettings
|
|
}
|
|
|
|
var storySettings = previousSettings.storySettings
|
|
storySettings.sound = sound
|
|
let updatedSettings = previousSettings.withUpdatedStorySettings(storySettings)
|
|
transaction.updatePendingPeerNotificationSettings(peerId: peerId, settings: updatedSettings)
|
|
}
|
|
}
|