WebSVN – Mobile Apps.GyroMouse – Diff – /iOS-client/GyroMouse/ClientHandler.swift

 //
 import Foundation
 import CocoaAsyncSocket
-let ServerDiscoveredServicesDidChangeNotification = Notification.Name("ServerDiscoveredServicesDidChangeNotification")
-let ClientDidCompleteLocalConnectionNotification = Notification.Name("ClientDidCompleteLocalConnectionNotification")
-let ClientDidFailLocalConnectionNotification = Notification.Name("ClientDidFailLocalConnectionNotification")
-let ClientDidDisconnectNotification = Notification.Name("ClientDidDisconnectNotification")
 class ClientHandler: NSObject, NetServiceDelegate, NetServiceBrowserDelegate, GCDAsyncSocketDelegate {
     private var socket: GCDAsyncSocket?
     private var serviceBrowser: NetServiceBrowser?
         socket?.setDelegate(nil, delegateQueue: nil)
         socket = nil
         serviceBrowser?.delegate = nil
         serviceBrowser = nil
-    }
-    //MARK: - Privates
-    private func sendNotificationWithName(_ name: Notification.Name, userInfo: [String : Any]?) {
-        let center = NotificationCenter.default
-        let notif = Notification(name: name, object: self, userInfo: userInfo)
-        center.post(notif)
-    }
-    private func connectWithService(_ service: NetService) -> Bool {
-        var isConnected = false
-        // Copy Service Addresses
-        let addresses = service.addresses!
-        if socket == nil || socket?.isDisconnected ?? false {
-            // Initialize Socket
-            socket = GCDAsyncSocket(delegate: self, delegateQueue: DispatchQueue.main)
-            // Connect
-            while !isConnected && addresses.count != 0 {
-                let address = addresses.first!
-                do {
-                    try socket!.connect(toAddress: address)
-                    isConnected = true
-                } catch {
-                    isConnected = false
-                    print("Unable to connect to address. Error \(error) with user info \(error.localizedDescription).", terminator: "\n")
-                }
-            }
-        } else {
-            isConnected = socket?.isConnected ?? false
-        }
-        return isConnected
+    }
     //MARK: - Publics
     func startBrowsing() {
     func connectToLocalService(_ service: NetService) {
         // Resolve Service
         service.delegate = self
         service.resolve(withTimeout: 30)
+    }
-    func sendPacket(_ packet: GyroPacket) {
+    func sendPacket(_ type: String, keyTapped: String, isButtonDown: Bool, isRightButton: Bool, roll: Double, scrollVelocity: Double, grav: (X: Double, Y: Double, Z: Double), rotat: (X: Double, Z: Double), acc: (X: Double, Y: Double, Z: Double), moveVelocity: Double) {
-        // Encode Packet Data
-        let packetData = NSMutableData()
-        let archiver = NSKeyedArchiver(forWritingWith: packetData)
-        archiver.encode(packet, forKey: "packet")
-        archiver.finishEncoding()
-        // Initialize Buffer
         let buffer = NSMutableData()
+        var int32var: Int32
+        var uint32var: UInt32
+        var boolvar: Bool
+        var doublevar: Double
+        int32var = 1; buffer.append(&int32var, length: MemoryLayout<Int32>.size) // protocol version
+        if (type == "key") { // key tapped
+            if (keyTapped.isEmpty) { return } // consistency check: happens when we hit a backspace
+            int32var = 1; buffer.append(&int32var, length: MemoryLayout<Int32>.size) // "key" packet type
+            uint32var = keyTapped.unicodeScalars.first!.value; buffer.append(&uint32var, length: MemoryLayout<UInt32>.size)
+        }
+        else if (type == "backspace") { // backspace tapped
+            int32var = 2; buffer.append(&int32var, length: MemoryLayout<Int32>.size) // "backspace" packet type
-        // Fill Buffer
+            // nothing to add
+        }
-        var headerLength = UInt64(packetData.length)
+        else if (type == "enter") { // enter tapped
+            int32var = 3; buffer.append(&int32var, length: MemoryLayout<Int32>.size) // "enter" packet type
+            // nothing to add
+        }
+        else if (type == "click") { // click
+            int32var = 4; buffer.append(&int32var, length: MemoryLayout<Int32>.size) // "click" packet type
+            boolvar = isRightButton; buffer.append(&boolvar, length: MemoryLayout<Bool>.size)
+            boolvar = isButtonDown;  buffer.append(&boolvar, length: MemoryLayout<Bool>.size)
+        }
+        else if (type == "scroll") { // page scroll
+            int32var = 5; buffer.append(&int32var, length: MemoryLayout<Int32>.size) // "scroll" packet type
+            doublevar = roll;           buffer.append(&doublevar, length: MemoryLayout<Double>.size)
+            doublevar = scrollVelocity; buffer.append(&doublevar, length: MemoryLayout<Double>.size)
+        }
+        else if (type == "move") { // movement
+            int32var = 6; buffer.append(&int32var, length: MemoryLayout<Int32>.size) // "move" packet type
+            doublevar = grav.X;       buffer.append(&doublevar, length: MemoryLayout<Double>.size)
+            doublevar = grav.Y;       buffer.append(&doublevar, length: MemoryLayout<Double>.size)
+            doublevar = grav.Z;       buffer.append(&doublevar, length: MemoryLayout<Double>.size)
+            doublevar = rotat.X;      buffer.append(&doublevar, length: MemoryLayout<Double>.size)
+            doublevar = rotat.Z;      buffer.append(&doublevar, length: MemoryLayout<Double>.size)
+            doublevar = acc.X;        buffer.append(&doublevar, length: MemoryLayout<Double>.size)
+            doublevar = acc.Y;        buffer.append(&doublevar, length: MemoryLayout<Double>.size)
+            doublevar = acc.Z;        buffer.append(&doublevar, length: MemoryLayout<Double>.size)
-        buffer.append(&headerLength, length: MemoryLayout<UInt64>.size)
+            doublevar = moveVelocity; buffer.append(&doublevar, length: MemoryLayout<Double>.size)
+        }
-        buffer.append(packetData.bytes, length: packetData.length)
+        else if (type == "reset") { // reset pointer
+            int32var = 7; buffer.append(&int32var, length: MemoryLayout<Int32>.size) // "click" packet type
+            // nothing to add
+        }
         // Write Buffer
+        let bufferData = buffer as Data
+        print ("Sending \(bufferData.count) bytes packet:", terminator: "")
+        for i in 0...(bufferData.count - 1) {
+            let byte: UInt8 = bufferData.withUnsafeBytes { rawBuffer in rawBuffer.load(fromByteOffset: i * MemoryLayout<UInt8>.size, as: UInt8.self) }
+            print (" " + String(format: "%02X", byte), terminator: "")
+        }
+        print ("")
-        socket?.write(buffer as Data, withTimeout: -1, tag: 0)
+        socket?.write(bufferData, withTimeout: -1, tag: 0)
+    }
     func endConnection() {
         socket?.disconnect()
         socket?.setDelegate(nil, delegateQueue: nil)
     func netServiceBrowser(_ browser: NetServiceBrowser, didFind service: NetService, moreComing: Bool) {
         // Update Services
         services.append(service)
         if !moreComing {
-            sendNotificationWithName(ServerDiscoveredServicesDidChangeNotification, userInfo: nil)
+            NotificationCenter.default.post(Notification(name: GyroMouseShouldRefreshServerListNotification, object: self, userInfo: nil))
+        }
+    }
     func netServiceBrowser(_ browser: NetServiceBrowser, didRemove service: NetService, moreComing: Bool) {
         // Update Services
         services.remove(at: services.firstIndex(of: service)!)
         if !moreComing {
-            sendNotificationWithName(ServerDiscoveredServicesDidChangeNotification, userInfo: nil)
+            NotificationCenter.default.post(Notification(name: GyroMouseShouldRefreshServerListNotification, object: self, userInfo: nil))
+        }
+    }
     func netServiceBrowserDidStopSearch(_ browser: NetServiceBrowser) {
         stopBrowsing()
         sender.delegate = nil
+    }
     func netServiceDidResolveAddress(_ sender: NetService) {
         // Connect With Service
+        var isConnected = false
+        if ((socket == nil) || (socket?.isDisconnected ?? false)) {
+            // Initialize Socket
+            socket = GCDAsyncSocket(delegate: self, delegateQueue: DispatchQueue.main)
+            // Connect
+            while (!isConnected && (sender.addresses!.count != 0)) {
+                do {
+                    try socket!.connect(toAddress: sender.addresses!.first!)
+                    isConnected = true
+                } catch {
+                    isConnected = false
+                    print("Unable to connect to address. Error \(error) with user info \(error.localizedDescription).", terminator: "\n")
+                }
+            }
+        } else {
+            isConnected = socket?.isConnected ?? false
+        }
-        if connectWithService(sender) {
+        if (isConnected) {
             print("Did Connect with Service: domain(\(sender.domain)) type(\(sender.type)) name(\(sender.name)) port(\(sender.port))", terminator: "\n")
         } else {
             print("Unable to Connect with Service: domain(\(sender.domain)) type(\(sender.type)) name(\(sender.name)) port(\(sender.port))", terminator: "\n")
-            sendNotificationWithName(ClientDidFailLocalConnectionNotification, userInfo: nil)
+            NotificationCenter.default.post(Notification(name: GyroMouseConnectionFailedNotification, object: self, userInfo: nil))
+        }
+    }
     //MARK: - GCDAsyncSocketDelegate
     func socket(_ sock: GCDAsyncSocket, didConnectToHost host: String, port: UInt16) {
         print("Socket Did Connect to Host: \(host) Port: \(port)", terminator: "\n")
-        // Start Reading
-        sock.readData(toLength: UInt(MemoryLayout<UInt64>.size), withTimeout: -1, tag: 0)
         stopBrowsing()
-        sendNotificationWithName(ClientDidCompleteLocalConnectionNotification, userInfo: nil)
+        NotificationCenter.default.post(Notification(name: GyroMouseConnectionSuccessNotification, object: self, userInfo: nil))
+    }
     func socketDidDisconnect(_ sock: GCDAsyncSocket, withError err: Error?) {
         socket?.delegate = nil
         socket = nil
         startBrowsing()
-        sendNotificationWithName(ClientDidDisconnectNotification, userInfo: nil)
+        NotificationCenter.default.post(Notification(name: GyroMouseDisconnectedNotification, object: self, userInfo: nil))
         if err != nil {
             print("Socket Did Disconnect with Error \(err!) with user info \(err!.localizedDescription).", terminator: "\n")
-            sendNotificationWithName(ClientDidFailLocalConnectionNotification, userInfo: nil)
+            //NotificationCenter.default.post(Notification(name: GyroMouseConnectionFailedNotification, object: self, userInfo: nil))
         } else {
             print("Socket Did Disconnect", terminator: "\n")
+        }
+    }

Subversion Repositories Mobile Apps.GyroMouse

Mobile Apps.GyroMouse/iOS-client/GyroMouse/ClientHandler.swift – Rev 1 → 7