add anoia.nl, a convenience wrapper on netlink

pkgs/anoia/nl.fnl

@@ -0,0 +1,15 @@
+(local netlink (require :netlink))
+
+(local { : view } (require :fennel))
+
+(fn events [groups]
+  (let [sock (netlink.socket)]
+    (coroutine.wrap
+     (fn []
+       (each [_ e (ipairs (sock:query groups))]
+         (coroutine.yield e))
+       (while (sock:poll)
+         (each [_ e (ipairs (sock:event))]
+           (coroutine.yield e)))))))
+
+{ : events }

pkgs/anoia/test-nl.fnl

@@ -0,0 +1,7 @@
+(local nl (require :anoia.nl))
+(local { : view } (require :fennel))
+
+(let [events (nl.events {:link true})]
+  (each [ev events]
+    (print "got one ")
+    (print (view ev))))

pkgs/ifwait/ifwait.fnl

@@ -1,5 +1,4 @@
-(local netlink (require :netlink))
+(local nl (require :anoia.nl))
-(local sock (netlink.socket))
 
 ; (local { : view} (require :fennel))
 
@@ -22,8 +21,7 @@
         (parse-args arg)
         (assert false (.. "Usage: " (. arg 0) " [-v] ifname [present|up|running]"))))
 
-(fn run-events [evs]
+(fn run-event [v]
-  (each [_ v (ipairs evs)]
   (let [got
         (match v
           ;; - up: Reflects the administrative state of the interface (IFF_UP)
@@ -40,13 +38,11 @@
           _
           {})]
     (when (. got parameters.expecting)
-        (os.exit 0)))))
+      (os.exit 0))))
-
 
 (when parameters.verbose
   (print (.. (. arg 0) ": waiting for "
              parameters.link " to be " parameters.expecting)))
 
-(run-events (sock:query {:link true}))
+(each [event (nl.events {:link true})]
-
+  (run-event event))
-(while (sock:poll) (run-events (sock:event)))