cryogen-core/src/cryogen_core/watcher.clj

36 lines
1.1 KiB
Clojure
Raw Normal View History

2014-12-05 15:56:40 +00:00
(ns cryogen-core.watcher
(:require [clojure.java.io :refer [file]]
[cryogen-core.io :refer [ignore]]
[pandect.core :refer [md5]]
[clojure.set :as set]))
2014-12-04 16:38:48 +00:00
(defn get-assets [path ignored-files]
(->> path
file
file-seq
2015-09-14 10:06:35 +00:00
(filter #(not (.isDirectory ^java.io.File %)))
(filter (ignore ignored-files))))
2014-12-04 16:38:48 +00:00
(defn checksums [path ignored-files]
(let [files (get-assets path ignored-files)]
(zipmap (map md5 files) files)))
(defn find-changes [old-sums new-sums]
(let [old-sum-set (-> old-sums keys set)
new-sum-set (-> new-sums keys set)]
(when-some [changes (set/difference new-sum-set old-sum-set)]
(vals (select-keys new-sums changes)))))
2014-12-04 16:38:48 +00:00
(defn watch-assets [root ignored-files action]
(loop [sums (checksums root ignored-files)]
2014-12-04 16:38:48 +00:00
(Thread/sleep 300)
(let [new-sums (checksums root ignored-files)]
(when (find-changes sums new-sums)
2014-12-04 16:38:48 +00:00
(action))
(recur new-sums))))
2014-12-04 16:38:48 +00:00
(defn start-watcher! [root ignored-files action]
(doto (Thread. #(watch-assets root ignored-files action))
2014-12-04 16:38:48 +00:00
(.setDaemon true)
(.start)))