   [fs directory entries]
   (map (partial get-permissions-for-entry fs directory)
        entries))
+
 
 (defn entry-is-type?
   [type entry]

            [langohr.queue :as lq]
            [langohr.channel :as lch]
            [langohr.consumers :as lcons])
  ;; (:require [me.raynes.fs :as fs])
  (:require [clojure.tools.cli :as cli])
  (:require [clojure.string :as string])
  (:require [brainbot.nozzle.stat :as stat]
            [brainbot.nozzle.vfs :as vfs])
  (:require [clojure.stacktrace :as trace])
  (:require [com.brainbot.iniconfig :as ini])
  (:require [tika])
  (:import java.io.File)
  (:import [com.rabbitmq.client Address ConnectionFactory Connection Channel ShutdownListener])
  (:import [java.util.concurrent Executors]))


(defn get-permissions-for-entry

  [fs {path :path :as body} {publish :publish}]
  (publish "get_permissions" {:directory path
                              :entries (vfs/cmd-listdir fs path)}))


(def command->msg-handler
