persephone/Persephone/MPDClient/Extensions/MPDClient+Idle.swift

//
//  Idle.swift
//  Persephone
//
//  Created by Daniel Barber on 2019/3/15.
//  Copyright © 2019 Dan Barber. All rights reserved.
//

import Foundation
import mpdclient

extension MPDClient {
  func noIdle() {
    if isIdle {
      mpd_send_noidle(connection)
      isIdle = false
    }
  }

  func idle() {
    if !self.isIdle && self.commandQueue.operationCount == 1 {
      mpd_send_idle(self.connection)
      self.isIdle = true

      let result = mpd_recv_idle(self.connection, true)
      self.handleIdleResult(result)
    }
  }

  func handleIdleResult(_ result: mpd_idle) {
    isIdle = false
    
    let mpdIdle = MPDIdle(rawValue: result.rawValue)

    if mpdIdle.contains(.database) {
      self.fetchAllAlbums()
    }
    if mpdIdle.contains(.queue) {
      self.fetchQueue()
      self.fetchStatus()

      self.delegate?.didUpdateQueue(mpdClient: self, queue: self.queue)
      if let status = self.status {
        self.delegate?.didUpdateQueuePos(mpdClient: self, song: status.song)
      }
    }
    if mpdIdle.contains(.player) || mpdIdle.contains(.options) {
      self.fetchStatus()

      if let status = self.status {
        self.delegate?.didUpdateStatus(mpdClient: self, status: status)
        self.delegate?.didUpdateQueuePos(mpdClient: self, song: status.song)
      }
    }
    if mpdIdle.contains(.update) {
      self.fetchStatus()

      if self.status?.updating ?? false {
        self.delegate?.willStartDatabaseUpdate(mpdClient: self)
      } else {
        self.delegate?.didFinishDatabaseUpdate(mpdClient: self)
      }
    }
    if !mpdIdle.isEmpty {
      self.idle()
    }
  }
}