mmp.hy

(import argparse mpd threading signal
  [beets.library [Library]]
  [mpd.server [Server]]
  [protocol [control connection commands playback queue status]]
  [playback.playback [Playback]])
(require [hy.contrib.walk [let]])

;; The socketserver needs to be closed from a different thread. This
;; thread blocks until a signal is received then closes the server.
(defclass CleanupThread [threading.Thread]
  (defn __init__ [self socket-server]
    (setv self.server socket-server)
    (setv self.lock (threading.Semaphore 0))
    (signal.signal signal.SIGINT
      (fn [signal frame] (self.lock.release)))
    (.__init__ threading.Thread self))

  (defn run [self]
    (self.lock.acquire)
    (self.server.shutdown)))

(defclass ConnHandler []
  (defn __init__ [self playback beets]
    (setv self.disabled-tags [])
    (setv self.playback playback)
    (setv self.beets beets))

  (defn __call__ [self cmd]
    (.handle commands self cmd)))

(defn start-server [addr port playback beets]
  (let [handler (ConnHandler playback beets)]
    (with [server (Server (, addr port) handler)]
      (.start (CleanupThread server))
      (server.serve-forever))))

(defmain [&rest args]
  (let [parser (argparse.ArgumentParser)]
    (parser.add-argument "LIBRARY" :type str
      :help "Path to the beets database")
    (parser.add-argument "-p" :type int :metavar "PORT"
      :default 6600 :help "TCP port used by the MPD server")
    (parser.add-argument "-a" :type str :metavar "ADDR"
      :default "localhost" :help "Address the MPD server binds to")
    (let [args (parser.parse-args)]
      (start-server args.a args.p (Playback) (Library args.LIBRARY))))
  0)