//
//  AbstractSocketTest.swift
//  AbstractSocketTest.socket.IO-Client-Swift
//
//  Created by Lukas Schmidt on 02.08.15.
//
//

import XCTest

class AbstractSocketTest: XCTestCase {
    static let testLocal = true
    static let serverURL = AbstractSocketTest.testLocal ? "localhost:6979" : "milkbartube.com:6979"
    static let TEST_TIMEOUT = 8.0
    static var socket:SocketIOClient!
    var testKind:TestKind?
    
    
    func openConnection() {
        guard AbstractSocketTest.socket.status == SocketIOClientStatus.NotConnected else {return}
        
        weak var expection = self.expectationWithDescription("connect")
        XCTAssertTrue(AbstractSocketTest.socket.status == SocketIOClientStatus.NotConnected)
        AbstractSocketTest.socket.on("connect") {data, ack in
            XCTAssertEqual(AbstractSocketTest.socket.status, SocketIOClientStatus.Connected)
            XCTAssertFalse(AbstractSocketTest.socket.secure)
            if let expection = expection {
                expection.fulfill()
            }
        }
        AbstractSocketTest.socket.connect()
        XCTAssertEqual(AbstractSocketTest.socket.status, SocketIOClientStatus.Connecting)
        waitForExpectationsWithTimeout(AbstractSocketTest.TEST_TIMEOUT, handler: nil)
    }
    
    func generateTestName(rawTestName:String) ->String {
        return rawTestName + testKind!.rawValue
    }
    
    func checkConnectionStatus() {
        XCTAssertEqual(AbstractSocketTest.socket.status, SocketIOClientStatus.Connected)
        XCTAssertFalse(AbstractSocketTest.socket.secure)
    }
    
    func socketMultipleEmit(testName:String, emitData:Array<AnyObject>, callback:NormalCallback){
        let finalTestname = generateTestName(testName)
        weak var expection = self.expectationWithDescription(finalTestname)
        func didGetEmit(result:NSArray?, ack:AckEmitter?) {
            callback(result, ack)
            if let expection = expection {
                expection.fulfill()
            }
        }
        
        AbstractSocketTest.socket.emit(finalTestname, withItems: emitData)
        AbstractSocketTest.socket.on(finalTestname + "Return", callback: didGetEmit)
        waitForExpectationsWithTimeout(SocketEmitTest.TEST_TIMEOUT, handler: nil)
    }
    
    
    func socketEmit(testName:String, emitData:AnyObject?, callback:NormalCallback){
        let finalTestname = generateTestName(testName)
        weak var expection = self.expectationWithDescription(finalTestname)
        func didGetEmit(result:NSArray?, ack:AckEmitter?) {
            callback(result, ack)
            if let expection = expection {
                expection.fulfill()
            }
        }
        
        AbstractSocketTest.socket.on(finalTestname + "Return", callback: didGetEmit)
        if let emitData = emitData {
            AbstractSocketTest.socket.emit(finalTestname, emitData)
        } else {
            AbstractSocketTest.socket.emit(finalTestname)
        }
        
        waitForExpectationsWithTimeout(SocketEmitTest.TEST_TIMEOUT, handler: nil)
    }
    
    func socketAcknwoledgeMultiple(testName:String, Data:Array<AnyObject>, callback:NormalCallback){
        let finalTestname = generateTestName(testName)
        weak var expection = self.expectationWithDescription(finalTestname)
        func didGetResult(result:NSArray?) {
            callback(result, nil)
            if let expection = expection {
                expection.fulfill()
            }
        }
        
        AbstractSocketTest.socket.emitWithAck(finalTestname, withItems: Data)(timeoutAfter: 5, callback: didGetResult)
        waitForExpectationsWithTimeout(SocketEmitTest.TEST_TIMEOUT, handler: nil)
    }
    
    func socketAcknwoledge(testName:String, Data:AnyObject?, callback:NormalCallback){
        let finalTestname = generateTestName(testName)
        weak var expection = self.expectationWithDescription(finalTestname)
        func didGet(result:NSArray?) {
            callback(result, nil)
            if let expection = expection {
                expection.fulfill()
            }
        }
        var ack:OnAckCallback!
        if let Data = Data {
            ack = AbstractSocketTest.socket.emitWithAck(finalTestname, Data)
        } else {
            ack = AbstractSocketTest.socket.emitWithAck(finalTestname)
        }
        ack(timeoutAfter: 20, callback: didGet)
        
        waitForExpectationsWithTimeout(SocketEmitTest.TEST_TIMEOUT, handler: nil)
    }
}