ConversationsListInteractor.swift

class ConversationsListInteractor: ConversationsListInteractorInput {
  let chatsProvider: ChatsService = Assembler.container.resolve(ChatsProvider.self)!
  weak var output: ConversationsListInteractorOutput?
  
  // MARK: - Input
  func requestItems(request: ConversationsList.DataContext.Request) {
    DispatchQueue(label: "ConversationsListInteractor").async {
      do {
        let items = try self.chatsProvider.getChats(request: GetConversationsRequest(skip: request.skip, take: request.take))
        let models = items.map({ ConversationsListModel(currentModel: $0) })
        DispatchQueue.main.async {
          self.output?.didReceive(response: ConversationsList.DataContext.Response(originalRequest: request,
                                                                                   items: models))
        }
      } catch let error {
        DispatchQueue.main.async {
          if error.code == 401 {
            self.output?.didTokenExpire()
          } else {
            self.output?.didFail(with: error)
          }
        }
      }
    }
  }
}