109 lines
4.1 KiB
Swift
109 lines
4.1 KiB
Swift
//
|
|
// Copyright 2026 Signal Messenger, LLC
|
|
// SPDX-License-Identifier: AGPL-3.0-only
|
|
//
|
|
|
|
import Foundation
|
|
import LibSignalClient
|
|
|
|
@objc(OWSViewOnceMessageReadSyncMessage)
|
|
final class OutgoingViewOnceOpenSyncMessage: OutgoingSyncMessage {
|
|
|
|
let senderAddress: SignalServiceAddress
|
|
let messageIdTimestamp: UInt64
|
|
let readTimestamp: UInt64
|
|
let messageUniqueId: String? // Only nil if decoding old values
|
|
|
|
init(
|
|
localThread: TSContactThread,
|
|
senderAci: Aci,
|
|
message: TSMessage,
|
|
readTimestamp: UInt64,
|
|
tx: DBReadTransaction,
|
|
) {
|
|
owsAssertDebug(message.timestamp > 0)
|
|
self.senderAddress = SignalServiceAddress(senderAci)
|
|
self.messageUniqueId = message.uniqueId
|
|
self.messageIdTimestamp = message.timestamp
|
|
self.readTimestamp = readTimestamp
|
|
super.init(localThread: localThread, tx: tx)
|
|
}
|
|
|
|
override class var supportsSecureCoding: Bool { true }
|
|
|
|
override func encode(with coder: NSCoder) {
|
|
super.encode(with: coder)
|
|
coder.encode(NSNumber(value: self.messageIdTimestamp), forKey: "messageIdTimestamp")
|
|
if let messageUniqueId {
|
|
coder.encode(messageUniqueId, forKey: "messageUniqueId")
|
|
}
|
|
coder.encode(NSNumber(value: self.readTimestamp), forKey: "readTimestamp")
|
|
coder.encode(self.senderAddress, forKey: "senderAddress")
|
|
}
|
|
|
|
required init?(coder: NSCoder) {
|
|
guard let messageIdTimestamp = coder.decodeObject(of: NSNumber.self, forKey: "messageIdTimestamp") else {
|
|
return nil
|
|
}
|
|
self.messageIdTimestamp = messageIdTimestamp.uint64Value
|
|
self.messageUniqueId = coder.decodeObject(of: NSString.self, forKey: "messageUniqueId") as String?
|
|
guard let readTimestamp = coder.decodeObject(of: NSNumber.self, forKey: "readTimestamp") else {
|
|
return nil
|
|
}
|
|
self.readTimestamp = readTimestamp.uint64Value
|
|
let modernAddress = coder.decodeObject(of: SignalServiceAddress.self, forKey: "senderAddress")
|
|
self.senderAddress = modernAddress ?? SignalServiceAddress.legacyAddress(
|
|
serviceIdString: nil,
|
|
phoneNumber: coder.decodeObject(of: NSString.self, forKey: "senderId") as String?,
|
|
)
|
|
owsAssertDebug(self.senderAddress.isValid)
|
|
super.init(coder: coder)
|
|
}
|
|
|
|
override var hash: Int {
|
|
var hasher = Hasher()
|
|
hasher.combine(super.hash)
|
|
hasher.combine(self.messageIdTimestamp)
|
|
hasher.combine(self.messageUniqueId)
|
|
hasher.combine(self.readTimestamp)
|
|
hasher.combine(self.senderAddress)
|
|
return hasher.finalize()
|
|
}
|
|
|
|
override func isEqual(_ object: Any?) -> Bool {
|
|
guard let object = object as? Self else { return false }
|
|
guard super.isEqual(object) else { return false }
|
|
guard self.messageIdTimestamp == object.messageIdTimestamp else { return false }
|
|
guard self.messageUniqueId == object.messageUniqueId else { return false }
|
|
guard self.readTimestamp == object.readTimestamp else { return false }
|
|
guard self.senderAddress == object.senderAddress else { return false }
|
|
return true
|
|
}
|
|
|
|
override var isUrgent: Bool { false }
|
|
|
|
override func syncMessageBuilder(tx: DBReadTransaction) -> SSKProtoSyncMessageBuilder? {
|
|
let syncMessageBuilder = SSKProtoSyncMessage.builder()
|
|
|
|
let readProtoBuilder = SSKProtoSyncMessageViewOnceOpen.builder(timestamp: self.messageIdTimestamp)
|
|
if let senderAci = self.senderAddress.serviceId as? Aci {
|
|
readProtoBuilder.setSenderAciBinary(senderAci.serviceIdBinary)
|
|
} else {
|
|
owsFailDebug("can't send view once open sync for message without an ACI")
|
|
}
|
|
|
|
do {
|
|
let readProto = try readProtoBuilder.build()
|
|
syncMessageBuilder.setViewOnceOpen(readProto)
|
|
return syncMessageBuilder
|
|
} catch {
|
|
owsFailDebug("could not build protobuf: \(error)")
|
|
return nil
|
|
}
|
|
}
|
|
|
|
override var relatedUniqueIds: Set<String> {
|
|
return super.relatedUniqueIds.union([self.messageUniqueId].compacted())
|
|
}
|
|
}
|