declared disconnect socket function

Author: StanislavDevIOS

Adamant/ServiceProtocols/SocketService.swift

@@ -18,6 +18,8 @@ protocol SocketService: AnyObject {
 
     func connect(address: String)
 
+    func disconnect()
+    
     // MARK: - Receive New Transaction
 
     func receiveNewTransaction(completion: ((ApiServiceResult<Transaction>) -> Void)?)

Adamant/Services/DataProviders/AdamantChatsProvider.swift

@@ -90,6 +90,8 @@ class AdamantChatsProvider: ChatsProvider {
 
             self?.blackList = []
             self?.removedMessages = []
+            
+            self?.disconnectFromSocket()
         }
 
         NotificationCenter.default.addObserver(forName: Notification.Name.AdamantAccountService.stayInChanged, object: nil, queue: nil) { [weak self] notification in
@@ -195,11 +197,11 @@ extension AdamantChatsProvider {
         let privateContext = NSManagedObjectContext(concurrencyType: .privateQueueConcurrencyType)
         privateContext.parent = self.stack.container.viewContext
         self.socketService.connect(address: address)
-        self.socketService.receiveNewTransaction { result in
+        self.socketService.receiveNewTransaction { [weak self] result in
             switch result {
             case .success(let trans):
-                self.processingQueue.async {
-                    self.process(messageTransactions: [trans],
+                self?.processingQueue.async {
+                    self?.process(messageTransactions: [trans],
                                  senderId: address,
                                  privateKey: privateKey,
                                  context: privateContext,
@@ -211,6 +213,10 @@ extension AdamantChatsProvider {
         }
     }
 
+    func disconnectFromSocket() {
+        self.socketService.disconnect()
+    }
+    
     func update(completion: ((ChatsProviderResult?) -> Void)?) {
         if state == .updating {
             completion?(nil)

Adamant/Services/SocketService/AdamantSocketService.swift

@@ -51,6 +51,10 @@ class AdamantSocketService: SocketService {
         socket?.connect()
     }
 
+    func disconnect() {
+        socket?.disconnect()
+    }
+    
     func receiveNewTransaction(completion: ((ApiServiceResult<Transaction>) -> Void)?) {
         socket?.on("newTrans", callback: { [weak self] data, ack in
             guard let data = data.first else { return }