service starts and stops

pkgs/ifwait/ifwait.fnl

@@ -1,9 +1,8 @@
 (local nl (require :anoia.nl))
+(local { : assoc : system } (require :anoia))
 
 ; (local { : view} (require :fennel))
 
-(local { : assoc : system } (require :anoia))
-
 (fn parse-args [args]
   (match args
     ["-v" & rest]  (assoc (parse-args rest) :verbose true)
@@ -31,9 +30,19 @@
 
           _
           {})]
-    (. got params.expecting)))
+    (not (not (. got params.expecting)))))
+
+(var up :unknown)
+(fn toggle-service [service wanted?]
+  (when (not (= up wanted?))
+    (set up
+         (if wanted?
+             (pcall system (.. "s6-rc -u change " service))
+             (not (pcall system (.. "s6-rc -d change " service)))))
+    ))
 
 (fn run [args event-fn]
+  (set up :unknown)
   (let [parameters
         (assert (parse-args args)
                 (.. "Usage: ifwait [-v] ifname [present|up|running]"))]
@@ -41,9 +50,13 @@
       (print (.. "ifwait: waiting for "
                  parameters.link " to be " parameters.expecting)))
 
-    (each [e (event-fn)
+    (if parameters.service
-           &until (event-matches? parameters e)]
+        (each [e (event-fn)]
-      true)))
+          (if (= e.name parameters.link)
+              (toggle-service parameters.service (event-matches? parameters e))))
+        (each [e (event-fn)
+               &until (event-matches? parameters e)]
+          true))))
 
 (when (not (= (. arg 0) "test"))
   (run arg #(nl.events {:link true})))

pkgs/ifwait/test-ifwait.fnl

@@ -4,6 +4,14 @@
 (var fake-system (fn [s] (print "executing " s)))
 (tset anoia :system #(fake-system $1))
 
+(macro expect= [actual expected]
+  `(let [ve# (view ,expected)
+         va# (view ,actual)]
+     (when (not (= ve# va#))
+       (assert false
+               (.. "\nexpected " ve# "\ngot " va#)
+               ))))
+
 (fn event-generator [events]
   (coroutine.wrap
    (fn []
@@ -19,34 +27,93 @@
 (local ifwait (require :ifwait))
 
 (let [gen (event-generator (file-events "events-fixture"))]
-  (ifwait.run ["-v" "dummy0" "up"] #gen)
+  (ifwait.run ["dummy0" "up"] #gen)
   (match (pcall gen)
     (true _) true
     (false msg) (error "didn't detect dummy0 up event")))
 
-(var succeeded? false)
+(var upsies [])
 (set fake-system
      (fn [s]
-       (print "exec" s)
+       (if (s:match "-u change addmember")
-       (if (s:match "addmember") (set succeeded? true))))
+           (table.insert upsies :u)
+           (s:match "-d change addmember")
+           (table.insert upsies :d))))
 
-(let [events
+(fn newlink [name up running]
-      [{:event "newlink"
+  {:event "newlink"
-        :hwaddr "b6:7d:5c:38:89:1d"
+   :hwaddr "b6:7d:5c:38:89:1d"
-        :index 21
+   :index (string.unpack ">i2" name)
-        :mtu 1500
+   :mtu 1500
-        :name "dummy0"
+   : name
-        :running "no"
+   : running
-        :stamp 857161382
+   :stamp 857161382
-        :up "no"}
+   : up })
-       {:event "newlink"
+
-        :hwaddr "52:f0:46:da:0c:0c"
+"when it gets events that don't match the interface, nothing happens"
-        :index 22
+
-        :mtu 1500
+(let [gen (-> [(newlink "eth1" "no" "no")] event-generator)]
-        :name "dummy0"
+  (set upsies [])
-        :running "no"
+  (ifwait.run [ "-s" "addmember" "dummy0" "up"] #gen)
-        :stamp 857161383
+  (expect= upsies []))
-        :up "yes"}]
+
-      gen (event-generator events)]
+"when it gets an event that should start the service, the service starts"
-  (ifwait.run ["-v" "-s" "addmember" "dummy0" "up"] #gen)
+
-  (assert succeeded?))
+(let [gen (->
+           [(newlink "dummy0" "no" "no")
+            (newlink "dummy0" "yes" "no")
+            (newlink "eth1" "no" "no")]
+           event-generator)]
+  (set upsies [])
+  (ifwait.run ["-s" "addmember" "dummy0" "up"] #gen)
+  (expect= upsies [:d :u]))
+
+"when it gets an event that should stop the service, the service stops"
+
+(let [gen (->
+           [(newlink "dummy0" "no" "no")
+            (newlink "dummy0" "yes" "no")
+            (newlink "dummy0" "no" "no")
+            ]
+           event-generator)]
+  (set upsies [])
+  (ifwait.run ["-s" "addmember" "dummy0" "up"] #gen)
+  (expect= upsies [:d :u :d]))
+
+"it does not call s6-rc again if the service is already in required state"
+
+(let [gen (->
+           [(newlink "dummy0" "no" "no")
+            (newlink "dummy0" "yes" "no")
+            (newlink "dummy0" "yes" "yes")
+            (newlink "dummy0" "yes" "yes")
+            (newlink "dummy0" "yes" "no")
+            (newlink "dummy0" "no" "no")
+            ]
+           event-generator)]
+  (set upsies [])
+  (ifwait.run ["-s" "addmember" "dummy0" "up"] #gen)
+  (expect= upsies [:d :u :d]))
+
+"it handles an error return from s6-rc"
+
+(set fake-system
+     (fn [s]
+       (if (s:match "-u change addmember")
+           (table.insert upsies :u)
+           (s:match "-d change addmember")
+           (table.insert upsies :d))
+       (error "false")
+       ))
+
+(let [gen (->
+           [(newlink "dummy0" "yes" "no")
+            (newlink "dummy0" "yes" "yes")
+            (newlink "dummy0" "yes" "yes")
+            (newlink "dummy0" "yes" "no")
+            (newlink "dummy0" "no" "no")
+            ]
+           event-generator)]
+  (set upsies [])
+  (ifwait.run ["-s" "addmember" "dummy0" "up"] #gen)
+  (expect= upsies [:u :u :u :u]))