mirror of
https://github.com/permissionlesstech/bitchat.git
synced 2026-07-25 18:45:20 +00:00
fix relay
This commit is contained in:
@@ -62,6 +62,7 @@ struct NotificationStreamAssembler {
|
|||||||
let hasRecipient = (flags & BinaryProtocol.Flags.hasRecipient) != 0
|
let hasRecipient = (flags & BinaryProtocol.Flags.hasRecipient) != 0
|
||||||
let hasSignature = (flags & BinaryProtocol.Flags.hasSignature) != 0
|
let hasSignature = (flags & BinaryProtocol.Flags.hasSignature) != 0
|
||||||
let isCompressed = (flags & BinaryProtocol.Flags.isCompressed) != 0
|
let isCompressed = (flags & BinaryProtocol.Flags.isCompressed) != 0
|
||||||
|
let hasRoute = (version >= 2) && (flags & BinaryProtocol.Flags.hasRoute) != 0
|
||||||
|
|
||||||
let lengthOffset = 12
|
let lengthOffset = 12
|
||||||
let payloadLength: Int
|
let payloadLength: Int
|
||||||
@@ -80,6 +81,15 @@ struct NotificationStreamAssembler {
|
|||||||
var frameLength = framePrefix + payloadLength
|
var frameLength = framePrefix + payloadLength
|
||||||
if hasRecipient { frameLength += BinaryProtocol.recipientIDSize }
|
if hasRecipient { frameLength += BinaryProtocol.recipientIDSize }
|
||||||
if hasSignature { frameLength += BinaryProtocol.signatureSize }
|
if hasSignature { frameLength += BinaryProtocol.signatureSize }
|
||||||
|
|
||||||
|
if hasRoute {
|
||||||
|
let routeCountOffset = framePrefix + (hasRecipient ? BinaryProtocol.recipientIDSize : 0)
|
||||||
|
let routeCountIndex = buffer.startIndex + routeCountOffset
|
||||||
|
guard buffer.count > routeCountOffset else { break }
|
||||||
|
let routeCount = Int(buffer[routeCountIndex])
|
||||||
|
frameLength += 1 + (routeCount * BinaryProtocol.senderIDSize)
|
||||||
|
}
|
||||||
|
|
||||||
if isCompressed {
|
if isCompressed {
|
||||||
let rawLengthFieldBytes = (version == 2) ? 4 : 2
|
let rawLengthFieldBytes = (version == 2) ? 4 : 2
|
||||||
if payloadLength < rawLengthFieldBytes {
|
if payloadLength < rawLengthFieldBytes {
|
||||||
|
|||||||
Reference in New Issue
Block a user