socket.io-client-swift/SwiftIO/SocketParser.swift

//
//  SocketParser.swift
//  Socket.IO-Swift
//
//  Permission is hereby granted, free of charge, to any person obtaining a copy
//  of this software and associated documentation files (the "Software"), to deal
//  in the Software without restriction, including without limitation the rights
//  to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
//  copies of the Software, and to permit persons to whom the Software is
//  furnished to do so, subject to the following conditions:
//
//  The above copyright notice and this permission notice shall be included in
//  all copies or substantial portions of the Software.
//
//  THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
//  IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
//  FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
//  AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
//  LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
//  OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
//  THE SOFTWARE.

import Foundation

private let shredder = SocketParser.PacketShredder()

class SocketParser {
    // Translation of socket.io-parser#deconstructPacket
    private class PacketShredder {
        var buf = ContiguousArray<NSData>()
        
        func shred(data:AnyObject) -> AnyObject {
            if let bin = data as? NSData {
                let placeholder = ["_placeholder" :true, "num": buf.count]
                
                buf.append(bin)
                
                return placeholder
            } else if let arr = data as? NSArray {
                var newArr = NSMutableArray(array: arr)
                
                for i in 0..<arr.count {
                    newArr[i] = shred(arr[i])
                }
                
                return newArr
            } else if let dict = data as? NSDictionary {
                var newDict = NSMutableDictionary(dictionary: dict)
                
                for (key, value) in newDict {
                    newDict[key as NSCopying] = shred(value)
                }
                
                return newDict
            } else {
                return data
            }
        }
        
        func deconstructPacket(packet:SocketPacket) {
            if packet.data == nil {
                return
            }
            
            var data = packet.data!
            
            for i in 0..<data.count {
                if data[i] is NSArray || data[i] is NSDictionary {
                    data[i] = shred(data[i])
                } else if let bin = data[i] as? NSData {
                    data[i] = ["_placeholder" :true, "num": buf.count]
                    buf.append(bin)
                }
            }
            
            packet.data = data
            packet.binary = buf
            buf.removeAll(keepCapacity: true)
        }
    }
    
    // Translation of socket.io-client#decodeString
    class func parseString(str:String) -> SocketPacket? {
        let arr = Array(str)
        let type = String(arr[0])
        
        if arr.count == 1 {
            return SocketPacket(type: SocketPacketType(str: type))
        }
        
        var id = nil as Int?
        var nsp = ""
        var i = 0
        var placeholders = -1
        
        if type == "5" || type == "6" {
            var buf = ""
            
            while arr[++i] != "-" {
                buf += String(arr[i])
                if i == arr.count {
                    break
                }
            }
            
            if buf.toInt() == nil || arr[i] != "-" {
                NSLog("Error parsing \(str)")
                return nil
            } else {
                placeholders = buf.toInt()!
            }
        }
        
        if arr[i + 1] == "/" {
            while ++i < arr.count {
                let c = arr[i]
                
                if c == "," {
                    break
                }
                
                nsp += String(c)
            }
        }
        
        if i + 1 >= arr.count {
            return SocketPacket(type: SocketPacketType(str: type),
                nsp: nsp, placeholders: placeholders, id: id)
        }
        
        let next = String(arr[i + 1])
        
        if next.toInt() != nil {
            var c = ""
            while ++i < arr.count {
                if let int = String(arr[i]).toInt() {
                    c += String(arr[i])
                } else {
                    --i
                    break
                }
            }
            
            id = c.toInt()
        }
        
        if i + 1 < arr.count {
            let d = String(arr[++i...arr.count-1])
            let noPlaceholders = d["(\\{\"_placeholder\":true,\"num\":(\\d*)\\})"] ~= "\"~~$2\""
            
            let data = SocketParser.parseData(noPlaceholders) as [AnyObject]
            
            return SocketPacket(type: SocketPacketType(str: type), data: data,
                nsp: nsp, placeholders: placeholders, id: id)
        }
        
        return nil
    }
    
    // Parses data for events
    class func parseData(data:String) -> AnyObject? {
        var err:NSError?
        let stringData = data.dataUsingEncoding(NSUTF8StringEncoding, allowLossyConversion: false)
        let parsed:AnyObject? = NSJSONSerialization.JSONObjectWithData(stringData!,
            options: NSJSONReadingOptions.AllowFragments, error: &err)
        
        if err != nil {
            // println(err)
            return nil
        }
        
        return parsed
    }
    
    class func parseForEmit(packet:SocketPacket) {
        shredder.deconstructPacket(packet)
    }
    
    // Parses messages recieved
    class func parseSocketMessage(stringMessage:String, socket:SocketIOClient) {
        if stringMessage == "" {
            return
        }
        
        func checkNSP(nsp:String) -> Bool {
            if nsp == "" && socket.nsp != "/" {
                return true
            } else {
                return false
            }
        }
        
        let p = parseString(stringMessage) as SocketPacket!
        
        if p.type == SocketPacketType.EVENT {
            if checkNSP(p.nsp) {
                return
            }
            
            socket.handleEvent(p.getEvent(), data: p.data, isInternalMessage: false, wantsAck: p.id, withAckType: 3)
        } else if p.type == SocketPacketType.ACK {
            if checkNSP(p.nsp) {
                return
            }
            
            socket.handleAck(p.id!, data: p.data)
        } else if p.type == SocketPacketType.BINARY_EVENT {
            if checkNSP(p.nsp) {
                return
            }
            
            socket.waitingData.append(p)
        } else if p.type == SocketPacketType.BINARY_ACK {
            if checkNSP(p.nsp) {
                return
            }
            
            p.justAck = true
            socket.waitingData.append(p)
        } else if p.type == SocketPacketType.CONNECT {
            if p.nsp == "" && socket.nsp != "/" {
                socket.joinNamespace()
            } else if p.nsp != "" && socket.nsp == "/" {
                socket.didConnect()
            } else {
                socket.didConnect()
            }
        } else if p.type == SocketPacketType.DISCONNECT {
            socket.didForceClose(message: "Got Disconnect")
        }
    }
    
    // Handles binary data
    class func parseBinaryData(data:NSData, socket:SocketIOClient) {
        // NSLog(data.base64EncodedStringWithOptions(NSDataBase64EncodingOptions.allZeros))
        
        if socket.waitingData.count == 0 {
            NSLog("Got data when not remaking packet")
            return
        }
        
        let shouldExecute = socket.waitingData[0].addData(data)
        
        if !shouldExecute {
            return
        }
        
        let packet = socket.waitingData.removeAtIndex(0)
        packet.fillInPlaceholders()
        
        if !packet.justAck {
            socket.handleEvent(packet.getEvent(), data: packet.data,
                wantsAck: packet.id, withAckType: 6)
        } else {
            socket.handleAck(packet.id!, data: packet.data)
        }
    }
}