update for latest beta
This commit is contained in:
parent
4fdb49ea2f
commit
ccd6dcbf0a
@ -368,7 +368,7 @@ public final class SocketEngine: NSObject, WebSocketDelegate, SocketLogClient {
|
|||||||
if message.hasPrefix("b4") {
|
if message.hasPrefix("b4") {
|
||||||
// binary in base64 string
|
// binary in base64 string
|
||||||
message.removeRange(Range<String.Index>(start: message.startIndex,
|
message.removeRange(Range<String.Index>(start: message.startIndex,
|
||||||
end: advance(message.startIndex, 2)))
|
end: message.startIndex.advancedBy(2)))
|
||||||
|
|
||||||
if let data = NSData(base64EncodedString: message,
|
if let data = NSData(base64EncodedString: message,
|
||||||
options: NSDataBase64DecodingOptions.IgnoreUnknownCharacters) {
|
options: NSDataBase64DecodingOptions.IgnoreUnknownCharacters) {
|
||||||
|
|||||||
@ -138,7 +138,7 @@ class SocketParser {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if ++i < arr.count {
|
if ++i < arr.count {
|
||||||
let d = str[advance(str.startIndex, i)...advance(str.startIndex, str.characters.count-1)]
|
let d = str[str.startIndex.advancedBy(i)...str.startIndex.advancedBy(str.characters.count-1)]
|
||||||
let noPlaceholders = d["(\\{\"_placeholder\":true,\"num\":(\\d*)\\})"] ~= "\"~~$2\""
|
let noPlaceholders = d["(\\{\"_placeholder\":true,\"num\":(\\d*)\\})"] ~= "\"~~$2\""
|
||||||
let data = SocketParser.parseData(noPlaceholders) as? [AnyObject] ?? [noPlaceholders]
|
let data = SocketParser.parseData(noPlaceholders) as? [AnyObject] ?? [noPlaceholders]
|
||||||
|
|
||||||
|
|||||||
@ -190,7 +190,7 @@ public class WebSocket : NSObject, NSStreamDelegate {
|
|||||||
self.addHeader(urlRequest, key: headerWSUpgradeName, val: headerWSUpgradeValue)
|
self.addHeader(urlRequest, key: headerWSUpgradeName, val: headerWSUpgradeValue)
|
||||||
self.addHeader(urlRequest, key: headerWSConnectionName, val: headerWSConnectionValue)
|
self.addHeader(urlRequest, key: headerWSConnectionName, val: headerWSConnectionValue)
|
||||||
if let protocols = optionalProtocols {
|
if let protocols = optionalProtocols {
|
||||||
self.addHeader(urlRequest, key: headerWSProtocolName, val: ",".join(protocols))
|
self.addHeader(urlRequest, key: headerWSProtocolName, val: protocols.joinWithSeparator(","))
|
||||||
}
|
}
|
||||||
self.addHeader(urlRequest, key: headerWSVersionName, val: headerWSVersionValue)
|
self.addHeader(urlRequest, key: headerWSVersionName, val: headerWSVersionValue)
|
||||||
self.addHeader(urlRequest, key: headerWSKeyName, val: self.generateWebSocketKey())
|
self.addHeader(urlRequest, key: headerWSKeyName, val: self.generateWebSocketKey())
|
||||||
@ -459,7 +459,7 @@ public class WebSocket : NSObject, NSStreamDelegate {
|
|||||||
if payloadLen == 1 {
|
if payloadLen == 1 {
|
||||||
code = CloseCode.ProtocolError.rawValue
|
code = CloseCode.ProtocolError.rawValue
|
||||||
} else if payloadLen > 1 {
|
} else if payloadLen > 1 {
|
||||||
var codeBuffer = UnsafePointer<UInt16>((buffer+offset))
|
let codeBuffer = UnsafePointer<UInt16>((buffer+offset))
|
||||||
code = codeBuffer[0].bigEndian
|
code = codeBuffer[0].bigEndian
|
||||||
if code < 1000 || (code > 1003 && code < 1007) || (code > 1011 && code < 3000) {
|
if code < 1000 || (code > 1003 && code < 1007) || (code > 1011 && code < 3000) {
|
||||||
code = CloseCode.ProtocolError.rawValue
|
code = CloseCode.ProtocolError.rawValue
|
||||||
@ -680,7 +680,7 @@ public class WebSocket : NSObject, NSStreamDelegate {
|
|||||||
offset += sizeof(UInt64)
|
offset += sizeof(UInt64)
|
||||||
}
|
}
|
||||||
buffer[1] |= self.MaskMask
|
buffer[1] |= self.MaskMask
|
||||||
var maskKey = UnsafeMutablePointer<UInt8>(buffer + offset)
|
let maskKey = UnsafeMutablePointer<UInt8>(buffer + offset)
|
||||||
SecRandomCopyBytes(kSecRandomDefault, Int(sizeof(UInt32)), maskKey)
|
SecRandomCopyBytes(kSecRandomDefault, Int(sizeof(UInt32)), maskKey)
|
||||||
offset += sizeof(UInt32)
|
offset += sizeof(UInt32)
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user