github-mirror/Telegram-iOS
1
0
Fork 0
mirror of https://github.com/TelegramMessenger/Telegram-iOS.git synced 2026-07-06 03:33:41 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update API

Browse source
This commit is contained in:
isaac 2026-05-24 00:24:21 +04:00
parent 8b9f498d53
commit 38464954b0
9 changed files with 94 additions and 38 deletions
Download patch file Download diff file Expand all files Collapse all files

1
submodules/TelegramApi/Sources/Api0.swift
View file

@ -790,6 +790,7 @@ fileprivate let parsers: [Int32 : (BufferReader) -> Any?] = {
dict[-248793375] = { return Api.PageBlock.parse_pageBlockSubheader($0) }
dict[-1879401953] = { return Api.PageBlock.parse_pageBlockSubtitle($0) }
dict[-1085412734] = { return Api.PageBlock.parse_pageBlockTable($0) }
dict[1009361890] = { return Api.PageBlock.parse_pageBlockThinking($0) }
dict[1890305021] = { return Api.PageBlock.parse_pageBlockTitle($0) }
dict[324435594] = { return Api.PageBlock.parse_pageBlockUnsupported($0) }
dict[2089805750] = { return Api.PageBlock.parse_pageBlockVideo($0) }

31
submodules/TelegramApi/Sources/Api19.swift
View file

@ -797,6 +797,15 @@ public extension Api {
return ("pageBlockTable", [("flags", ConstructorParameterDescription(self.flags)), ("title", ConstructorParameterDescription(self.title)), ("rows", ConstructorParameterDescription(self.rows))])
}
}
public class Cons_pageBlockThinking: TypeConstructorDescription {
public var text: Api.RichText
public init(text: Api.RichText) {
self.text = text
}
public func descriptionFields() -> (String, [(String, ConstructorParameterDescription)]) {
return ("pageBlockThinking", [("text", ConstructorParameterDescription(self.text))])
}
}
public class Cons_pageBlockTitle: TypeConstructorDescription {
public var text: Api.RichText
public init(text: Api.RichText) {
@ -854,6 +863,7 @@ public extension Api {
case pageBlockSubheader(Cons_pageBlockSubheader)
case pageBlockSubtitle(Cons_pageBlockSubtitle)
case pageBlockTable(Cons_pageBlockTable)
case pageBlockThinking(Cons_pageBlockThinking)
case pageBlockTitle(Cons_pageBlockTitle)
case pageBlockUnsupported
case pageBlockVideo(Cons_pageBlockVideo)
@ -1162,6 +1172,12 @@ public extension Api {
item.serialize(buffer, true)
}
break
case .pageBlockThinking(let _data):
if boxed {
buffer.appendInt32(1009361890)
}
_data.text.serialize(buffer, true)
break
case .pageBlockTitle(let _data):
if boxed {
buffer.appendInt32(1890305021)
@ -1256,6 +1272,8 @@ public extension Api {
return ("pageBlockSubtitle", [("text", ConstructorParameterDescription(_data.text))])
case .pageBlockTable(let _data):
return ("pageBlockTable", [("flags", ConstructorParameterDescription(_data.flags)), ("title", ConstructorParameterDescription(_data.title)), ("rows", ConstructorParameterDescription(_data.rows))])
case .pageBlockThinking(let _data):
return ("pageBlockThinking", [("text", ConstructorParameterDescription(_data.text))])
case .pageBlockTitle(let _data):
return ("pageBlockTitle", [("text", ConstructorParameterDescription(_data.text))])
case .pageBlockUnsupported:
@ -1861,6 +1879,19 @@ public extension Api {
return nil
}
}
public static func parse_pageBlockThinking(_ reader: BufferReader) -> PageBlock? {
var _1: Api.RichText?
if let signature = reader.readInt32() {
_1 = Api.parse(reader, signature: signature) as? Api.RichText
}
let _c1 = _1 != nil
if _c1 {
return Api.PageBlock.pageBlockThinking(Cons_pageBlockThinking(text: _1!))
}
else {
return nil
}
}
public static func parse_pageBlockTitle(_ reader: BufferReader) -> PageBlock? {
var _1: Api.RichText?
if let signature = reader.readInt32() {

7
submodules/TelegramApi/Sources/Api42.swift
View file

@ -4922,12 +4922,13 @@ public extension Api.functions.contacts {
}
}
public extension Api.functions.contacts {
static func search(q: String, limit: Int32) -> (FunctionDescription, Buffer, DeserializeFunctionResponse<Api.contacts.Found>) {
static func search(flags: Int32, q: String, limit: Int32) -> (FunctionDescription, Buffer, DeserializeFunctionResponse<Api.contacts.Found>) {
let buffer = Buffer()
buffer.appendInt32(301470424)
buffer.appendInt32(99978511)
serializeInt32(flags, buffer: buffer, boxed: false)
serializeString(q, buffer: buffer, boxed: false)
serializeInt32(limit, buffer: buffer, boxed: false)
return (FunctionDescription(name: "contacts.search", parameters: [("q", ConstructorParameterDescription(q)), ("limit", ConstructorParameterDescription(limit))]), buffer, DeserializeFunctionResponse { (buffer: Buffer) -> Api.contacts.Found? in
return (FunctionDescription(name: "contacts.search", parameters: [("flags", ConstructorParameterDescription(flags)), ("q", ConstructorParameterDescription(q)), ("limit", ConstructorParameterDescription(limit))]), buffer, DeserializeFunctionResponse { (buffer: Buffer) -> Api.contacts.Found? in
let reader = BufferReader(buffer)
var result: Api.contacts.Found?
if let signature = reader.readInt32() {

33
submodules/TelegramCore/Sources/Account/AccountIntermediateState.swift
View file

@ -64,6 +64,16 @@ enum AccountStateGlobalNotificationSettingsSubject {
case channels
}
struct UpdatedApiPresence {
var status: Api.UserStatus
var isMin: Bool
init(status: Api.UserStatus, isMin: Bool) {
self.status = status
self.isMin = isMin
}
}
enum AccountStateMutationOperation {
case AddMessages([StoreMessage], AddMessagesLocation)
case AddScheduledMessages([StoreMessage])
@ -93,7 +103,7 @@ enum AccountStateMutationOperation {
case UpdateCachedPeerData(PeerId, (CachedPeerData?) -> CachedPeerData?)
case UpdateMessagesPinned([MessageId], Bool)
case MergeApiUsers([Api.User])
case MergePeerPresences([PeerId: Api.UserStatus], Bool)
case MergePeerPresences([PeerId: UpdatedApiPresence], Bool)
case UpdateSecretChat(chat: Api.EncryptedChat, timestamp: Int32)
case AddSecretMessages([Api.EncryptedMessage])
case ReadSecretOutbox(peerId: PeerId, maxTimestamp: Int32, actionTimestamp: Int32)
@ -575,17 +585,18 @@ struct AccountMutableState {
mutating func mergeUsers(_ users: [Api.User]) {
self.addOperation(.MergeApiUsers(users))
var presences: [PeerId: Api.UserStatus] = [:]
var presences: [PeerId: UpdatedApiPresence] = [:]
for user in users {
switch user {
case let .user(userData):
let (id, status) = (userData.id, userData.status)
if let status = status {
presences[PeerId(namespace: Namespaces.Peer.CloudUser, id: PeerId.Id._internalFromInt64Value(id))] = status
}
break
case .userEmpty:
break
case let .user(userData):
let (id, status) = (userData.id, userData.status)
let isMin = (userData.flags & (1 << 20)) != 0
if let status = status {
presences[PeerId(namespace: Namespaces.Peer.CloudUser, id: PeerId.Id._internalFromInt64Value(id))] = UpdatedApiPresence(status: status, isMin: isMin)
}
break
case .userEmpty:
break
}
}
if !presences.isEmpty {
@ -594,7 +605,7 @@ struct AccountMutableState {
}
mutating func mergePeerPresences(_ presences: [PeerId: Api.UserStatus], explicit: Bool) {
self.addOperation(.MergePeerPresences(presences, explicit))
self.addOperation(.MergePeerPresences(presences.mapValues({ UpdatedApiPresence(status: $0, isMin: false) }), explicit))
}
mutating func updateSecretChat(chat: Api.EncryptedChat, timestamp: Int32) {

2
submodules/TelegramCore/Sources/ApiUtils/InstantPage.swift
View file

@ -302,7 +302,7 @@ extension InstantPageBlock {
self = .heading(text: RichText(apiText: pageBlockHeading6.text), level: 6)
case let .pageBlockMath(pageBlockMath):
self = .formula(latex: pageBlockMath.source)
case .inputPageBlockMap, .inputPageBlockOrderedList:
case .inputPageBlockMap, .inputPageBlockOrderedList, .pageBlockThinking:
self = .unsupported
}
}

24
submodules/TelegramCore/Sources/State/AccountStateManagementUtils.swift
View file

@ -4923,26 +4923,24 @@ func replayFinalState(
})
}
case let .MergePeerPresences(statuses, explicit):
var presences: [PeerId: PeerPresence] = [:]
var presences: [PeerId: UpdatedApiPresence] = [:]
for (peerId, status) in statuses {
if peerId == accountPeerId {
if explicit {
switch status {
case let .userStatusOnline(userStatusOnlineData):
let timestamp = userStatusOnlineData.expires
delayNotificatonsUntil = timestamp + 30
case let .userStatusOffline(userStatusOfflineData):
let timestamp = userStatusOfflineData.wasOnline
delayNotificatonsUntil = timestamp
default:
break
switch status.status {
case let .userStatusOnline(userStatusOnlineData):
let timestamp = userStatusOnlineData.expires
delayNotificatonsUntil = timestamp + 30
case let .userStatusOffline(userStatusOfflineData):
let timestamp = userStatusOfflineData.wasOnline
delayNotificatonsUntil = timestamp
default:
break
}
}
} else {
let presence = TelegramUserPresence(apiStatus: status)
presences[peerId] = presence
presences[peerId] = status
}
}
updatePeerPresencesClean(transaction: transaction, accountPeerId: accountPeerId, peerPresences: presences)
case let .UpdateSecretChat(chat, _):

8
submodules/TelegramCore/Sources/State/ContactSyncManager.swift
View file

@ -405,12 +405,12 @@ private func updateContactPresences(postbox: Postbox, network: Network, accountP
}
|> mapToSignal { statuses -> Signal<Never, NoError> in
return postbox.transaction { transaction -> Void in
var peerPresences: [PeerId: PeerPresence] = [:]
var peerPresences: [PeerId: UpdatedApiPresence] = [:]
for status in statuses {
switch status {
case let .contactStatus(contactStatusData):
let (userId, status) = (contactStatusData.userId, contactStatusData.status)
peerPresences[PeerId(namespace: Namespaces.Peer.CloudUser, id: PeerId.Id._internalFromInt64Value(userId))] = TelegramUserPresence(apiStatus: status)
case let .contactStatus(contactStatusData):
let (userId, status) = (contactStatusData.userId, contactStatusData.status)
peerPresences[PeerId(namespace: Namespaces.Peer.CloudUser, id: PeerId.Id._internalFromInt64Value(userId))] = UpdatedApiPresence(status: status, isMin: false)
}
}
updatePeerPresencesClean(transaction: transaction, accountPeerId: accountPeerId, peerPresences: peerPresences)

2
submodules/TelegramCore/Sources/TelegramEngine/Peers/SearchPeers.swift
View file

@ -27,7 +27,7 @@ public enum TelegramSearchPeersScope: Equatable {
}
public func _internal_searchPeers(accountPeerId: PeerId, postbox: Postbox, network: Network, query: String, scope: TelegramSearchPeersScope) -> Signal<([FoundPeer], [FoundPeer]), NoError> {
let searchResult = network.request(Api.functions.contacts.search(q: query, limit: 20), automaticFloodWait: false)
let searchResult = network.request(Api.functions.contacts.search(flags: 0, q: query, limit: 20), automaticFloodWait: false)
|> map(Optional.init)
|> `catch` { _ in
return Signal<Api.contacts.Found?, NoError>.single(nil)

24
submodules/TelegramCore/Sources/UpdatePeers.swift
View file

@ -360,12 +360,26 @@ func updatePeerPresences(transaction: Transaction, accountPeerId: PeerId, peerPr
})
}
func updatePeerPresencesClean(transaction: Transaction, accountPeerId: PeerId, peerPresences: [PeerId: PeerPresence]) {
var peerPresences = peerPresences
if peerPresences[accountPeerId] != nil {
peerPresences.removeValue(forKey: accountPeerId)
func updatePeerPresencesClean(transaction: Transaction, accountPeerId: PeerId, peerPresences: [PeerId: UpdatedApiPresence]) {
var parsedPresences: [PeerId: PeerPresence] = [:]
for (peerId, status) in peerPresences {
let presence = TelegramUserPresence(apiStatus: status.status)
switch presence.status {
case .present:
parsedPresences[peerId] = presence
default:
if status.isMin, let _ = transaction.getPeerPresence(peerId: peerId) {
} else {
parsedPresences[peerId] = presence
}
}
}
transaction.updatePeerPresencesInternal(presences: peerPresences, merge: { previous, updated in
if parsedPresences[accountPeerId] != nil {
parsedPresences.removeValue(forKey: accountPeerId)
}
transaction.updatePeerPresencesInternal(presences: parsedPresences, merge: { previous, updated in
if let previous = previous as? TelegramUserPresence, let updated = updated as? TelegramUserPresence, previous.lastActivity != updated.lastActivity {
return TelegramUserPresence(status: updated.status, lastActivity: max(previous.lastActivity, updated.lastActivity))
}