ThePain/Swiftgram
1
0
Fork 0
mirror of https://github.com/Swiftgram/Telegram-iOS.git synced 2026-01-06 13:12:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

[WIP] Autoremove timer

Browse Source
This commit is contained in:
Ali
2021-02-06 00:09:51 +04:00
parent e80c198605
commit 4cd27e7864
26 changed files with 1251 additions and 218 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
submodules/SyncCore/Sources/CachedChannelData.swift
View File

@@ -429,15 +429,7 @@ public final class CachedChannelData: CachedPeerData {
self.slowModeTimeout = decoder.decodeOptionalInt32ForKey("smt")
self.slowModeValidUntilTimestamp = decoder.decodeOptionalInt32ForKey("smv")
self.hasScheduledMessages = decoder.decodeBoolForKey("hsm", orElse: false)
if let value = decoder.decodeOptionalInt32ForKey("art") {
if value == -1 {
self.autoremoveTimeout = .known(nil)
} else {
self.autoremoveTimeout = .known(value)
}
} else {
self.autoremoveTimeout = .unknown
}
self.autoremoveTimeout = decoder.decodeObjectForKey("artv", decoder: CachedPeerAutoremoveTimeout.init(decoder:)) as? CachedPeerAutoremoveTimeout ?? .unknown
self.statsDatacenterId = decoder.decodeInt32ForKey("sdi", orElse: 0)
self.invitedBy = decoder.decodeOptionalInt64ForKey("invBy").flatMap(PeerId.init)
@@ -545,16 +537,7 @@ public final class CachedChannelData: CachedPeerData {
encoder.encodeNil(forKey: "smv")
}
encoder.encodeBool(self.hasScheduledMessages, forKey: "hsm")
switch self.autoremoveTimeout {
case let .known(value):
if let value = value {
encoder.encodeInt32(value, forKey: "art")
} else {
encoder.encodeInt32(-1, forKey: "art")
}
case .unknown:
encoder.encodeNil(forKey: "art")
}
encoder.encodeObject(self.autoremoveTimeout, forKey: "artv")
encoder.encodeInt32(self.statsDatacenterId, forKey: "sdi")
if let invitedBy = self.invitedBy {

21
submodules/SyncCore/Sources/CachedGroupData.swift
View File

@@ -131,15 +131,7 @@ public final class CachedGroupData: CachedPeerData {
self.about = decoder.decodeOptionalStringForKey("ab")
self.flags = CachedGroupFlags(rawValue: decoder.decodeInt32ForKey("fl", orElse: 0))
self.hasScheduledMessages = decoder.decodeBoolForKey("hsm", orElse: false)
if let value = decoder.decodeOptionalInt32ForKey("art") {
if value == -1 {
self.autoremoveTimeout = .known(nil)
} else {
self.autoremoveTimeout = .known(value)
}
} else {
self.autoremoveTimeout = .unknown
}
self.autoremoveTimeout = decoder.decodeObjectForKey("artv", decoder: CachedPeerAutoremoveTimeout.init(decoder:)) as? CachedPeerAutoremoveTimeout ?? .unknown
self.invitedBy = decoder.decodeOptionalInt64ForKey("invBy").flatMap(PeerId.init)
@@ -207,16 +199,7 @@ public final class CachedGroupData: CachedPeerData {
}
encoder.encodeInt32(self.flags.rawValue, forKey: "fl")
encoder.encodeBool(self.hasScheduledMessages, forKey: "hsm")
switch self.autoremoveTimeout {
case let .known(value):
if let value = value {
encoder.encodeInt32(value, forKey: "art")
} else {
encoder.encodeInt32(-1, forKey: "art")
}
case .unknown:
encoder.encodeNil(forKey: "art")
}
encoder.encodeObject(self.autoremoveTimeout, forKey: "artv")
if let invitedBy = self.invitedBy {
encoder.encodeInt64(invitedBy.toInt64(), forKey: "invBy")

72
submodules/SyncCore/Sources/CachedUserData.swift
View File

@@ -1,9 +1,56 @@
import Foundation
import Postbox
public enum CachedPeerAutoremoveTimeout: Equatable {
public enum CachedPeerAutoremoveTimeout: Equatable, PostboxCoding {
public struct Value: Equatable, PostboxCoding {
public var myValue: Int32
public var peerValue: Int32
public var isGlobal: Bool
public init(myValue: Int32, peerValue: Int32, isGlobal: Bool) {
self.myValue = myValue
self.peerValue = peerValue
self.isGlobal = isGlobal
}
public init(decoder: PostboxDecoder) {
self.myValue = decoder.decodeInt32ForKey("myValue", orElse: 7 * 60 * 60)
self.peerValue = decoder.decodeInt32ForKey("peerValue", orElse: 7 * 60 * 60)
self.isGlobal = decoder.decodeInt32ForKey("isGlobal", orElse: 1) != 0
}
public func encode(_ encoder: PostboxEncoder) {
encoder.encodeInt32(self.myValue, forKey: "myValue")
encoder.encodeInt32(self.peerValue, forKey: "peerValue")
encoder.encodeInt32(self.isGlobal ? 1 : 0, forKey: "isGlobal")
}
}
case unknown
case known(Int32?)
case known(Value?)
public init(decoder: PostboxDecoder) {
switch decoder.decodeInt32ForKey("_v", orElse: 0) {
case 1:
self = .known(decoder.decodeObjectForKey("v", decoder: Value.init(decoder:)) as? Value)
default:
self = .unknown
}
}
public func encode(_ encoder: PostboxEncoder) {
switch self {
case .unknown:
encoder.encodeInt32(0, forKey: "_v")
case let .known(value):
encoder.encodeInt32(1, forKey: "_v")
if let value = value {
encoder.encodeObject(value, forKey: "v")
} else {
encoder.encodeNil(forKey: "v")
}
}
}
}
public final class CachedUserData: CachedPeerData {
@@ -82,15 +129,7 @@ public final class CachedUserData: CachedPeerData {
self.callsPrivate = decoder.decodeInt32ForKey("cp", orElse: 0) != 0
self.canPinMessages = decoder.decodeInt32ForKey("cpm", orElse: 0) != 0
self.hasScheduledMessages = decoder.decodeBoolForKey("hsm", orElse: false)
if let value = decoder.decodeOptionalInt32ForKey("art") {
if value == -1 {
self.autoremoveTimeout = .known(nil)
} else {
self.autoremoveTimeout = .known(value)
}
} else {
self.autoremoveTimeout = .unknown
}
self.autoremoveTimeout = decoder.decodeObjectForKey("artv", decoder: CachedPeerAutoremoveTimeout.init(decoder:)) as? CachedPeerAutoremoveTimeout ?? .unknown
var messageIds = Set<MessageId>()
if let pinnedMessageId = self.pinnedMessageId {
@@ -131,16 +170,7 @@ public final class CachedUserData: CachedPeerData {
encoder.encodeInt32(self.callsPrivate ? 1 : 0, forKey: "cp")
encoder.encodeInt32(self.canPinMessages ? 1 : 0, forKey: "cpm")
encoder.encodeBool(self.hasScheduledMessages, forKey: "hsm")
switch self.autoremoveTimeout {
case let .known(value):
if let value = value {
encoder.encodeInt32(value, forKey: "art")
} else {
encoder.encodeInt32(-1, forKey: "art")
}
case .unknown:
encoder.encodeNil(forKey: "art")
}
encoder.encodeObject(self.autoremoveTimeout, forKey: "artv")
}
public func isEqual(to: CachedPeerData) -> Bool {