feat: introduce ofborg builder

Signed-off-by: Raito Bezarius <masterancpp@gmail.com>

flake.lock

@@ -684,6 +684,26 @@
         "type": "github"
       }
     },
+    "ofborg": {
+      "inputs": {
+        "nixpkgs": [
+          "nixpkgs"
+        ]
+      },
+      "locked": {
+        "lastModified": 1720307338,
+        "narHash": "sha256-cOnbqAiTHejdR/N1m/ClwQ0mou0Ctir66nhJL+aB85M=",
+        "ref": "refs/heads/main",
+        "rev": "8cdae352b0b4fd148288e35c4348e6d236ea2271",
+        "revCount": 1449,
+        "type": "git",
+        "url": "https://git.lix.systems/the-distro/ofborg.git"
+      },
+      "original": {
+        "type": "git",
+        "url": "https://git.lix.systems/the-distro/ofborg.git"
+      }
+    },
     "pre-commit-hooks": {
       "flake": false,
       "locked": {
@@ -715,6 +735,7 @@
         ],
         "nix-gerrit": "nix-gerrit",
         "nixpkgs": "nixpkgs_2",
+        "ofborg": "ofborg",
         "stateless-uptime-kuma": "stateless-uptime-kuma",
         "terranix": "terranix"
       }

flake.nix

@@ -19,6 +19,9 @@
     nix-gerrit.url = "git+https://git.lix.systems/the-distro/nix-gerrit.git";
     nix-gerrit.inputs.nixpkgs.follows = "nixpkgs";
 
+    ofborg.url = "git+https://git.lix.systems/the-distro/ofborg.git";
+    ofborg.inputs.nixpkgs.follows = "nixpkgs";
+
     gerrit-dashboard.url = "git+https://git.lix.systems/the-distro/gerrit-monitoring.git";
     gerrit-dashboard.flake = false;
 
@@ -58,6 +61,9 @@
           inputs.lix.overlays.default
           inputs.nix-gerrit.overlays.default
           inputs.channel-scripts.overlays.default
+          (super: self: {
+            inherit (inputs.ofborg.packages.${system}) ofborg;
+          })
           (import "${inputs.stateless-uptime-kuma}/overlay.nix")
         ];
       };

hosts/bagel-box/default.nix

@@ -37,7 +37,10 @@
 
   bagel.services = {
     postgres.enable = true;
-    ofborg.enable = true;
+    ofborg = {
+      rabbitmq.enable = true;
+      builder.enable = true;
+    };
   };
 
   bagel.sysadmin.enable = true;

secrets.nix

@@ -46,6 +46,7 @@ let
 
       postgres-ca-priv = [ machines.bagel-box ];
       postgres-tls-priv = [ machines.bagel-box ];
+      rabbitmq-password = [ machines.bagel-box ];
 
       newsletter-secrets = [ machines.public01 ];
       s3-revproxy-api-keys = [ machines.public01 ];

secrets/floral/rabbitmq-password.age

@@ -0,0 +1,20 @@
+age-encryption.org/v1
+-> ssh-ed25519 +HUDfA N/08Rh4cN52OOLk3Mp7n71mqU0zRvXeFr+HNXPVudSw
+txBFV3BJLmUng4cq5AEuSHQ4wUozc82hbMH9eA4AcqU
+-> ssh-ed25519 +qVung ryhY0CsF0pyJoCFGHdVaBS3S1rbEwPx6K/xEmKeI8js
+2dvCxR1w1uEf1Qq7lRqZJfGRUw2gsKH5DgrPe5HWUk0
+-> ssh-rsa krWCLQ
+adfK11ogZxXsenyFYgyIgOSsekwDTcMmOdTD4GXPjGGSOfXhxOTq9CsWfMksSDXq
+HIPTZLK7oYSvlNxvnqITGv4ESJGQMBat3TjZ4TTb2+hczWpzg3CqMeNluPDX4A2h
+dr+0TZH3XuHOuCrmukQ/EirBxnODBtSPqheZLqp562nrrpxDqqKdJkzwYWamu9H3
+S2pZFYtWe1YX0+1dooH/KqCTCR6yI7u0g9J/uxP2uPN2pgvD95mSpzd7nvfsKv7b
+kejB/5Gg5w0WNYwqi7uTnrL8l7WVtYLdIziK83RGviau5Grtuv+18Mj/a8YeupiQ
+B2tCRddiS/1DvlfobRtqtw
+-> ssh-ed25519 /vwQcQ sHef1IQRAJXykiG82Madjb+FTaNZKg2PpJONHmEKsEU
+NuBmo4GlVYc7Asy4gGiAE6Be2xS8t9ZYDgI8cF0rHms
+-> ssh-ed25519 0R97PA wQLniyviNyifUhEIlFqk+kDKNo5AUy4Vrh/gGweGygM
+7v/82hVu8d+RuZGxq9xmAiacv0ddUW7HDVGKVFgYrAw
+-> ssh-ed25519 K3b7BA SUF2L0mvu+7Pn8NZArC3tT7sr4FivAUjFexWXnLfckc
+QDnle9e13/Ch9DjXdYDzC1jsCH81HB2m+97CaRrZLAI
+--- PMNk1z2Vk3cRHqaB3G1/giBnOVduxex6tfwR3ihc4pE
+M踝ヽ齘暞堗)5m<35>"H唢罡<E594A2>7fs+R郑o/J1N槇e<E6A787>F<>罐<EFBFBD>鲈衅Oじ７&蟒至

services/ofborg/default.nix

@@ -1,35 +1,101 @@
-{ config, lib, ... }:
+{ pkgs, config, lib, ... }:
 
 let
+  inherit (lib) mkIf mkMerge;
   cfg = config.bagel.services.ofborg;
 
   amqpHost = "amqp.forkos.org";
   amqpPort = 5671;
+  generators = pkgs.formats.json { };
+  configFile = generators.generate "ofborg-config.json" pkgs.config.bagel.services.ofborg.settings;
+  mkOfborgWorker = binaryName: extra: extra // {
+    wantedBy = [ "multi-user.target" ];
+    description = "ofborg CI service - ${binaryName} worker";
+    after = [ "rabbitmq.service" ];
+    serviceConfig = {
+      DynamicUser = true;
+      ExecStart = "${cfg.package}/bin/${binaryName} ${configFile}";
+      # TODO: more hardening.
+      StateDirectory = "ofborg";
+      LogsDirectory = "ofborg";
+      WorkingDirectory = "/var/lib/ofborg";
+    };
+  };
 in {
   options.bagel.services.ofborg = with lib; {
-    enable = mkEnableOption "ofborg coordinator";
+    rabbitmq.enable = mkEnableOption "ofborg AMQP queue";
+    builder.enable = mkEnableOption "ofborg builder worker";
+
+    package = mkPackageOption pkgs "ofborg" { };
+
+    settings = mkOption {
+      type = generators.type;
+    };
   };
 
-  config = lib.mkIf cfg.enable {
-    services.rabbitmq = {
-      enable = true;
-      configItems = {
-        "listeners.tcp" = "none";
-        "listeners.ssl.default" = builtins.toString amqpPort;
+  config = mkMerge [
+    {
+      age.secrets.rabbitmq-password.file = ../../secrets/rabbitmq-password.age;
+    }
+    (mkIf cfg.rabbitmq.enable {
+      services.rabbitmq = {
+        enable = true;
+        configItems = {
+          "listeners.tcp" = "none";
+          "listeners.ssl.default" = builtins.toString amqpPort;
 
-        "ssl_options.certfile" = "${config.security.acme.certs.${amqpHost}.directory}/cert.pem";
-        "ssl_options.keyfile" = "${config.security.acme.certs.${amqpHost}.directory}/key.pem";
+          "ssl_options.certfile" = "${config.security.acme.certs.${amqpHost}.directory}/cert.pem";
+          "ssl_options.keyfile" = "${config.security.acme.certs.${amqpHost}.directory}/key.pem";
+        };
       };
-    };
 
-    security.acme.certs.${amqpHost} = {
-      webroot = "/var/lib/acme/.challenges";
-      group = "rabbitmq";
-    };
-    services.nginx.virtualHosts.${amqpHost}.locations."/.well-known/acme-challenge".root =
-      "/var/lib/acme/.challenges";
-    systemd.services.rabbitmq.requires = ["acme-finished-${amqpHost}.target"];
+      security.acme.certs.${amqpHost} = {
+        webroot = "/var/lib/acme/.challenges";
+        group = "rabbitmq";
+      };
+      services.nginx.virtualHosts.${amqpHost}.locations."/.well-known/acme-challenge".root =
+        "/var/lib/acme/.challenges";
+      systemd.services.rabbitmq.requires = ["acme-finished-${amqpHost}.target"];
 
-    networking.firewall.allowedTCPPorts = [ amqpPort ];
-  };
+      networking.firewall.allowedTCPPorts = [ amqpPort ];
+    })
+    (mkIf cfg.builder.enable {
+      # TODO: move this to global.
+      bagel.services.ofborg.settings = {
+        rabbitmq = {
+          ssl = true;
+          host = "amqp.forkos.org";
+          virtualhost = "amqp.forkos.org";
+          username = "worker";
+          password_file = config.age.secrets.rabbitmq-password.path;
+        };
+        feedback.full_logs = lib.mkDefault true;
+        log_storage = lib.mkDefault "/var/logs/ofborg";
+        runner = {
+          repos = lib.mkDefault [
+            "nixpkgs"
+            "ofborg"
+          ];
+
+          disable_trusted_users = true;
+        };
+        checkout.root = lib.mkDefault "/var/lib/ofborg/checkouts";
+        nix = {
+          system = "x86_64-linux";
+          remote = "daemon";
+          build_timeout_seconds = 3600;
+          initial_heap_size = "4g";
+        };
+      };
+
+      systemd.services.ofborg-builder = mkIf cfg.builder.enable (mkOfborgWorker "builder" {
+      });
+    })
+  ];
+    # systemd.services.ofborg-stats = {};
+    # systemd.services.ofborg-log-message-collector = {};
+    # systemd.services.ofborg-evaluation-filter = {};
+    # systemd.services.ofborg-vcs-comment-filter = {};
+    # systemd.services.ofborg-vcs-comment-poster = {};
+    # systemd.services.ofborg-mass-rebuilder = {};
 }