mirror of
https://github.com/danbee/persephone
synced 2025-03-04 08:39:11 +00:00
50 lines
1.1 KiB
Swift
50 lines
1.1 KiB
Swift
//
|
|
// Connection.swift
|
|
// Persephone
|
|
//
|
|
// Created by Daniel Barber on 2019/3/15.
|
|
// Copyright © 2019 Dan Barber. All rights reserved.
|
|
//
|
|
|
|
import Foundation
|
|
import mpdclient
|
|
|
|
extension MPDClient {
|
|
func makeConnectionOperation(host: String, port: Int) -> BlockOperation {
|
|
BlockOperation { [unowned self] in
|
|
guard let connection = mpd_connection_new(host, UInt32(port), 10000),
|
|
mpd_connection_get_error(connection) == MPD_ERROR_SUCCESS
|
|
else { return }
|
|
|
|
self.isConnected = true
|
|
|
|
guard let status = mpd_run_status(connection)
|
|
else { return }
|
|
|
|
self.connection = connection
|
|
self.status = MPDStatus(status)
|
|
|
|
self.delegate?.didConnect(mpdClient: self)
|
|
self.delegate?.didUpdateStatus(mpdClient: self, status: self.status!)
|
|
|
|
self.idle()
|
|
}
|
|
}
|
|
|
|
func connect() {
|
|
commandQueue.addOperation(connectionOperation)
|
|
}
|
|
|
|
func disconnect() {
|
|
guard isConnected else { return }
|
|
|
|
noIdle()
|
|
commandQueue.addOperation { [unowned self] in
|
|
self.delegate?.willDisconnect(mpdClient: self)
|
|
|
|
mpd_connection_free(self.connection)
|
|
self.isConnected = false
|
|
}
|
|
}
|
|
}
|