             "msg": "method",
             "method": "stream-notify-room",
             "params": ["\(subscription.rid)/typing", username, isTyping]
-        ] as [String : Any]
+            ] as [String : Any]
 
         SocketManager.send(request) { response in
             guard !response.isError() else { return Log.debug(response.result.string) }

            })
        }
    }

    // MARK: Rooms, Groups & DMs

    static func createDirectMessage(_ username: String, completion: @escaping MessageCompletion) {
        let request = [
            "msg": "method",
            "method": "createDirectMessage",
            "params": [username]
        ] as [String : Any]

        SocketManager.send(request) { response in
            guard !response.isError() else { return Log.debug(response.result.string) }

            })
        }
    }
}

// MARK: Typing
extension SubscriptionManager {
    static func subscribeTypingEvent(_ subscription: Subscription, completion: @escaping (String?, Bool) -> Void) {
        let eventName = "\(subscription.rid)/typing"
        let request = [
