home: check network before daily services

3 files changed, 80 insertions, 24 deletions

diff --git a/pkgs/lib/default.nix b/pkgs/lib/default.nix
index 22c9e07..7b11956 100644
--- a/pkgs/lib/default.nix
+++ b/pkgs/lib/default.nix
@@ -1,8 +1,8 @@
-{ lib }:
+{ lib, pkgs }:
 
 let
   self = {
-    homeManager = import ./home-manager { };
+    services = import ./services { inherit lib pkgs; };
     toUserJS = prefs: ''
       ${lib.concatStrings (
         lib.mapAttrsToList (name: value: ''
diff --git a/pkgs/lib/home-manager/default.nix b/pkgs/lib/home-manager/default.nix
deleted file mode 100644
index 91149d6..0000000
--- a/pkgs/lib/home-manager/default.nix
+++ /dev/null
@@ -1,22 +0,0 @@
-{ }:
-
-{
-  serviceWithTimer =
-    name:
-    {
-      Unit,
-      Service,
-      Timer,
-      Install,
-      ...
-    }@config:
-    {
-      services.${name} = { inherit (config) Unit Service; };
-      timers.${name} = {
-        inherit (config) Unit Install;
-        Timer = config.Timer // {
-          Unit = "${name}.service";
-        };
-      };
-    };
-}
diff --git a/pkgs/lib/services/default.nix b/pkgs/lib/services/default.nix
new file mode 100644
index 0000000..148126c
--- /dev/null
+++ b/pkgs/lib/services/default.nix
@@ -0,0 +1,78 @@
+{ lib, pkgs }:
+
+let
+  checkNetwork =
+    hosts:
+    let
+      pkg = pkgs.writeShellApplication {
+        name = "check-network";
+        runtimeInputs = [ pkgs.unixtools.ping ];
+        text = ''
+          (${lib.concatMapStringsSep " && " (host: "ping -c 1 ${host}") hosts}) || kill -s SIGUSR1 $$
+        '';
+      };
+    in
+    "${pkg}/bin/check-network";
+in
+{
+  home.serviceWithTimer =
+    name:
+    {
+      Unit,
+      Service,
+      # Timer,
+      Install,
+      ...
+    }@config:
+    {
+      services.${name} = { inherit (config) Unit Service; };
+      timers.${name} = {
+        inherit (config) Unit Install;
+        Timer = config.Timer // {
+          Unit = "${name}.service";
+        };
+      };
+    };
+
+  home.checkNetwork =
+    {
+      hosts,
+      restart ? true,
+    }:
+    {
+      # Check network connectivity
+      Unit = {
+        StartLimitIntervalSec = 300;
+        StartLimitBurst = 5;
+      };
+      Service = lib.mkMerge [
+        {
+          ExecStartPre = checkNetwork hosts;
+        }
+        (lib.mkIf restart {
+          Restart = "on-abort";
+          RestartSec = 30;
+          RestartMode = "direct"; # dependent units will not fail
+        })
+      ];
+    };
+
+  checkNetwork =
+    {
+      hosts,
+      restart ? true,
+    }:
+    {
+      # Check network connectivity
+      preStart = checkNetwork hosts;
+      unitConfig = {
+        StartLimitIntervalSec = 300;
+        StartLimitBurst = 5;
+      };
+      serviceConfig = lib.mkIf restart {
+        Restart = "on-abort";
+        RestartSec = 30;
+        RestartMode = "direct"; # dependent units will not fail
+      };
+    };
+}