import UIKit
import CocoaMQTT


class MQTTViewController: BaseViewController, CocoaMQTTDelegate, MQTTPassBackDelegate {

    // MARK: Internal classes
    class MQTTState {
        var connected = false
        var loggedIn = false
    }


    // MARK: Properties
    var mqtt: CocoaMQTT? {
        didSet {
            if mqtt == nil {
                state.connected = false
                state.loggedIn = false
                if oldValue?.connState == .CONNECTED {
                    oldValue?.disconnect()
                }
            }
        }
    }

    var state = MQTTState()
    var username: String?
    var password: String?

    weak var delegate: MQTTPassBackDelegate? = nil


    // MARK: Lifecycle
    override func viewWillAppear(animated: Bool) {
        super.viewWillAppear(animated)

        guard mqtt != nil else {
            mqttInit()
            return
        }
    }

    override func viewWillDisappear(animated: Bool) {
        super.viewWillDisappear(animated)

        if self.isMovingFromParentViewController() == true {
            delegate?.passBackMQTTData(mqtt, state: state, username: username, password: password)
        }
    }


    // MARK: CocoaMQTTDelegate functions
    func mqtt(mqtt: CocoaMQTT, didConnect host: String, port: Int) {
        dprint("didConnect (host):(port)")
    }

    func mqtt(mqtt: CocoaMQTT, didConnectAck ack: CocoaMQTTConnAck) {
        dprint("didConnectAck (ack.rawValue)")
    }

    func mqtt(mqtt: CocoaMQTT, didPublishMessage message: CocoaMQTTMessage, id: UInt16) {
        dprint("didPublishMessage with message: (message.string)")
    }

    func mqtt(mqtt: CocoaMQTT, didPublishAck id: UInt16) {
        dprint("didPublishAck with id: (id)")
    }

    func mqtt(mqtt: CocoaMQTT, didReceiveMessage message: CocoaMQTTMessage, id: UInt16 ) {
        guard message.string != nil else {
            dprint("didReceivedMessage: NOT STRING with id (id)")
            return
        }
        dprint("didReceivedMessage: (message.string) with id (id)")
    }

    func mqtt(mqtt: CocoaMQTT, didSubscribeTopic topic: String) {
        dprint("didSubscribeTopic to (topic)")
    }

    func mqtt(mqtt: CocoaMQTT, didUnsubscribeTopic topic: String) {
        dprint("didUnsubscribeTopic to (topic)")
    }

    func mqttDidPing(mqtt: CocoaMQTT) {
        dprint("didPing")
    }

    func mqttDidReceivePong(mqtt: CocoaMQTT) {
        dprint("didReceivePong")
    }

    func mqttDidDisconnect(mqtt: CocoaMQTT, withError err: NSError?) {
        dprint("mqttDidDisconnect")
    }


    // MARK: MQTTPassBackDelegate functions
    func passBackMQTTData(mqtt: CocoaMQTT?, state: AnyObject, username: String?, password: String?) {
        dprint("passBackMQTTData")
        self.mqtt = mqtt
        self.state = state as! MQTTState
        self.username = username
        self.password = password
    }


    // MARK: Helpers
    final func pushMQTTViewControllerWithIdentifier(identifier: String) {
        let vc = storyboard?.instantiateViewControllerWithIdentifier(identifier) as! MQTTViewController
        vc.mqtt = mqtt
        vc.state = state
        vc.username = username
        vc.password = password
        vc.delegate = self
        navigationController!.pushViewController(vc, animated: true)
    }

    final func mqttInit(clientIdPid: String = "ACC_MQTT-" + String(NSProcessInfo().processIdentifier)) {
        guard mqtt == nil else {
            return      // Prevent reinit
        }
        mqtt = CocoaMQTT(clientId: clientIdPid, host: ACC_MQTT_SERVER, port: UInt16(ACC_MQTT_PORT))
    }

    final func mqttSetup(username: String, password: String) {
        print("Attempting to connect using (username):(password)")
        if let mqtt = mqtt {
            mqtt.username = username
            mqtt.password = password
            mqtt.cleanSess = false
            mqtt.keepAlive = 90
            mqtt.delegate = self
        }
    }

}


protocol MQTTPassBackDelegate: class {

    func passBackMQTTData(mqtt: CocoaMQTT?, state: AnyObject, username: String?, password: String?)

}