let meteor: MeteorClient = {
MeteorClient(url: url, webSocket: .starscream)
}()

// Global meteor subscriptions manager (optional to manage through this way)
let meteorCollection: MeteorCollections = {
MeteorCollections(client: meteor)
}()

public static var loggingLevel: Level = .normal

meteor.connect {
// do something after the client connects
}

meteor.loginWithPassword("[email protected]", password: "********") { (result, error) in 
if error != nil {
//Login Failed
}
else {
// do something after login
}
}

meteor.loginWithUsername("Ali", password: "********") { (result, error) in 
if error != nil {
//Login Failed
}
else {
// do something after login
}
}

meteor.login("Ali", password: "********") { (result, error) in 
if error != nil {
//Login Failed
}
else {
// do something after login
}
}

meteor.logout { (result, error) in
if error != nil {
//Logout Failed
}
else {
// do something after logout
}
}

meteor.disconnect()

meteor.subscribe("todos", [1,2,3,4]) {
// Do something when the todos subscription is ready
}

meteor.unsubscribe("SubID") {
// Unsubscribed of SubID
}

meteor.unsubscribe(withName: "todos") {
// Unsubscribed from todos
}

meteor.unsubscribeAll {
// Unsubscribed to all 
}

// First subscribe with name
meteorCollection.subscribe("todos", params: nil) { events, document in
// Do something when the todos subscription is ready
}

// Listen to collection changes
meteorCollection.collectionDidChange = { collection in
// collection.documents new or changed dataset
}

// Add observer to some event, like dataAdded, dataChange or dataRemove
meteor.addEventObserver("todos", event: .dataAdded) {
guard let value = $0 as? MeteorDocument else {
return
}
// value.id is the unique ID of MeteorDocument
self.documents[value.id] = value.fields
}

// Optionally remove events registered against subscription
meteor.removeEventObservers("todos", event: [.dataAdded, .dataChange, .dataRemove]) 

// Unsubscribe 
meteorCollection.unsubscribe("todos")

// operation could be insert, remove or update against given meteor document
// keyValue is the update request to meteor server against that collection
meteor.updateColection("todos", type: .update, documents: [["_id": "MeteorDocumentID"],["$set": keyValue]]) { (res, error) in
if error == nil {
// Successfully updated
}
}

meteor.call("tasks.insert", params: [textField.text!]) { (res, error) in
if error == nil && res != nil {
// do something with the response
}
}

meteor.delegate = self

func didReceive(name: MeteorEvents, event: Any) {

switch name {
case .method:
// event -> MeteorMethod object
case .websocket:
// event -> WebSocketEvent, could be connected, disconnected, text, error
case .dataAdded:
// event -> MeteorDocument object
case .dataChange:
// event -> MeteorDocument object
case .dataRemove:
// event -> MeteorDocument object
}
}

// Event could be any as mentioned in MeteorDelegate
meteor.addEventObserver("todos", event: .dataAdded) { 
// $0 is the data against that event
}

MeteorEncodable.encode
MeteorEncodable.decode

// MeteorLoginService are twitter, github, google, facebook
// MeteorOAuthViewController is to present MeteorOAuth