87 lines
3.3 KiB
Swift
87 lines
3.3 KiB
Swift
//
|
|
// Copyright 2026 Signal Messenger, LLC
|
|
// SPDX-License-Identifier: AGPL-3.0-only
|
|
//
|
|
|
|
import Foundation
|
|
import LibSignalClient
|
|
|
|
final class OutgoingSenderKeyDistributionMessage: TransientOutgoingMessage {
|
|
|
|
/// True if this message is being sent as a precondition to sending an
|
|
/// online-only message. Typing indicators are only delivered to online
|
|
/// devices. Since they're ephemeral we just don't bother sending a typing
|
|
/// indicator to a recipient if we need the user to verify a safety number
|
|
/// change. Outgoing SKDMs being sent on behalf of an outgoing typing
|
|
/// indicator should inherit this behavior.
|
|
let isSentOnBehalfOfOnlineMessage: Bool
|
|
|
|
/// True if this message is being sent as a precondition to sending a story
|
|
/// message.
|
|
let isSentOnBehalfOfStoryMessage: Bool
|
|
|
|
let senderKeyDistributionMessage: SenderKeyDistributionMessage
|
|
|
|
init(
|
|
recipientThread: TSContactThread,
|
|
senderKeyDistributionMessage: SenderKeyDistributionMessage,
|
|
onBehalfOfMessage originalMessage: any SendableMessage,
|
|
inThread originalThread: TSThread,
|
|
tx: DBReadTransaction,
|
|
) {
|
|
self.senderKeyDistributionMessage = senderKeyDistributionMessage
|
|
self.isSentOnBehalfOfOnlineMessage = originalMessage.isOnline
|
|
self.isSentOnBehalfOfStoryMessage = originalMessage.isStorySend && !originalThread.isGroupThread
|
|
super.init(
|
|
outgoingMessageWith: TSOutgoingMessageBuilder.outgoingMessageBuilder(thread: recipientThread),
|
|
additionalRecipients: [],
|
|
explicitRecipients: [],
|
|
skippedRecipients: [],
|
|
transaction: tx,
|
|
)
|
|
}
|
|
|
|
override class var supportsSecureCoding: Bool { true }
|
|
|
|
override func encode(with coder: NSCoder) {
|
|
owsFail("Doesn't support serialization.")
|
|
}
|
|
|
|
required init?(coder: NSCoder) {
|
|
// Doesn't support serialization.
|
|
return nil
|
|
}
|
|
|
|
override var hash: Int {
|
|
var hasher = Hasher()
|
|
hasher.combine(super.hash)
|
|
hasher.combine(self.isSentOnBehalfOfOnlineMessage)
|
|
hasher.combine(self.isSentOnBehalfOfStoryMessage)
|
|
hasher.combine(self.senderKeyDistributionMessage.serialize())
|
|
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.isSentOnBehalfOfOnlineMessage == object.isSentOnBehalfOfOnlineMessage else { return false }
|
|
guard self.isSentOnBehalfOfStoryMessage == object.isSentOnBehalfOfStoryMessage else { return false }
|
|
guard self.senderKeyDistributionMessage.serialize() == object.senderKeyDistributionMessage.serialize() else { return false }
|
|
return true
|
|
}
|
|
|
|
override var shouldRecordSendLog: Bool { false }
|
|
|
|
override var isUrgent: Bool { false }
|
|
|
|
override var isStorySend: Bool { self.isSentOnBehalfOfStoryMessage }
|
|
|
|
override var contentHint: SealedSenderContentHint { .implicit }
|
|
|
|
override func contentBuilder(thread: TSThread, transaction: DBReadTransaction) -> SSKProtoContentBuilder? {
|
|
let builder = SSKProtoContent.builder()
|
|
builder.setSenderKeyDistributionMessage(self.senderKeyDistributionMessage.serialize())
|
|
return builder
|
|
}
|
|
}
|