reorg

Author: vic

nix/framework/curried-st.nix

@@ -0,0 +1,27 @@
+{ config, ... }:
+let
+  inherit (config.priv) st;
+in
+{
+  # ---------------------------------------------------------------------------
+  # ST :: namespace of curried stream combinators (stream as last param)
+  #
+  # Enables point-free composition: (ST.apply "fn" arg) as a stream fn
+  # ---------------------------------------------------------------------------
+  priv.ST = {
+    __functor = _: st;
+    map = f: stream: stream.map f;
+    filter = p: stream: stream.filter p;
+    concat = otherS: stream: stream.concat otherS;
+    flatMap = f: stream: stream.flatMap f;
+    sub = {
+      __functor =
+        _: name: stream:
+        stream.sub name;
+      apply =
+        name: value: stream:
+        stream.sub.apply name value;
+      flat = name: stream: stream.sub.flat name;
+    };
+  };
+}

nix/framework/drivers/host-os-d.nix

@@ -6,4 +6,4 @@ in
   # hostOsD :: topoS -> ST comp -> ST
   # Driver factory: fans out hosts from topoS, wraps results as { host, osConfiguration }.
   priv.hostOsD = topoS: compS: hostsT topoS (osConfigD compS);
-}
+}

nix/framework/drivers/host-users-d.nix

@@ -6,4 +6,4 @@ in
   # hostUsersD :: topoS -> ST comp -> ST
   # Driver factory: fans out hosts then users from topoS, maps output per user.
   priv.hostUsersD = topoS: compS: hostsT topoS (usersT (hostUserD compS));
-}
+}

nix/framework/drivers/os-config-d.nix

@@ -20,5 +20,3 @@ in
 {
   priv = { inherit osConfigD; };
 }
-
-

nix/framework/drivers/select-host-d.nix

@@ -2,4 +2,4 @@
   # selectHostD :: name -> ST -> ST
   # Filter stream of { host, … } items to those where host.name == name.
   priv.selectHostD = name: streamS: streamS.filter (item: item.host.name == name);
-}
+}

nix/framework/forward/host-user-d.nix

@@ -17,7 +17,7 @@ let
         };
       })
     );
-in 
+in
 {
   priv = { inherit hostUserD; };
-}
+}

nix/kernel/st.nix

@@ -3,28 +3,6 @@ let
   # Empty ST — identity for concat, base for chaining: ned.st val1 val2 ...
   st = wrap (fx.stream.done null);
 
-  # ---------------------------------------------------------------------------
-  # ST :: namespace of curried stream combinators (stream as last param)
-  #
-  # Enables point-free composition: (ST.apply "fn" arg) as a stream fn
-  # ---------------------------------------------------------------------------
-  ST = {
-    __functor = _: st;
-    map = f: stream: stream.map f;
-    filter = p: stream: stream.filter p;
-    concat = otherS: stream: stream.concat otherS;
-    flatMap = f: stream: stream.flatMap f;
-    sub = {
-      __functor =
-        _: name: stream:
-        stream.sub name;
-      apply =
-        name: value: stream:
-        stream.sub.apply name value;
-      flat = name: stream: stream.sub.flat name;
-    };
-  };
-
   # ---------------------------------------------------------------------------
   # wrap :: fx.stream -> ST
   #
@@ -97,5 +75,5 @@ let
     self;
 in
 {
-  priv = { inherit wrap st ST; };
+  priv = { inherit wrap st; };
 }