34 lines
872 B
Fennel
34 lines
872 B
Fennel
(local watch (require :watch))
|
|
|
|
;; Events come from the devout socket as an initial summary line
|
|
;; followed by a NUL character followed by newline-separated key=value
|
|
;; pairs. For ease of editing we don't have NULs in events.txt,
|
|
;; so we need to massage it into shape here
|
|
|
|
(local events
|
|
(with-open [f (io.open "./events.txt" :r)]
|
|
(let [text (string.gsub (f:read "*a") "\n\n" "\0") ]
|
|
(icollect [n (string.gmatch text "([^\0]+)")]
|
|
(string.gsub n "\n" "\0" 1)))))
|
|
|
|
|
|
(fn next-event []
|
|
(var i 0)
|
|
(fn []
|
|
(let [i_ (+ 1 i)
|
|
e (. events i_)]
|
|
(set i i_)
|
|
e)))
|
|
|
|
;; this tests event parsing but not whether anything
|
|
;; happens as a result of processing them
|
|
(watch.run-with-fh
|
|
{
|
|
:read (next-event)
|
|
:write (fn [payload] )
|
|
}
|
|
["-s" "foo" "-n" (os.getenv "TMPDIR") "partname=backup-disk" ]
|
|
)
|
|
|
|
(print "OK")
|