restarted with just bluesky/indigo

default.nix

···
   modules = import ./modules; # NixOS modules
   overlays = import ./overlays; # nixpkgs overlays
 
-  bluesky = pkgs.callPackage ./pkgs/bluesky { };
-}
+  bluesky = pkgs.callPackage ./pkgs/bluesky { 
+    buildGoModule = pkgs.buildGoModule;
+    fetchFromGitHub = pkgs.fetchFromGitHub;
+  };
+}

flake.lock

···
   "nodes": {
     "crane": {
       "locked": {
-        "lastModified": 1758215636,
-        "narHash": "sha256-8nkzkPbdxze8CxWhKWlcLbJEU1vfLM/nVqRlTy17V54=",
+        "lastModified": 1758758545,
+        "narHash": "sha256-NU5WaEdfwF6i8faJ2Yh+jcK9vVFrofLcwlD/mP65JrI=",
         "owner": "ipetkov",
         "repo": "crane",
-        "rev": "a669fe77a8b0cd6f11419d89ea45a16691ca5121",
+        "rev": "95d528a5f54eaba0d12102249ce42f4d01f4e364",
         "type": "github"
       },
       "original": {
···
     },
     "nixpkgs": {
       "locked": {
-        "lastModified": 1758262103,
-        "narHash": "sha256-aBGl3XEOsjWw6W3AHiKibN7FeoG73dutQQEqnd/etR8=",
+        "lastModified": 1758446476,
+        "narHash": "sha256-5rdAi7CTvM/kSs6fHe1bREIva5W3TbImsto+dxG4mBo=",
         "owner": "NixOS",
         "repo": "nixpkgs",
-        "rev": "12bd230118a1901a4a5d393f9f56b6ad7e571d01",
+        "rev": "a1f79a1770d05af18111fbbe2a3ab2c42c0f6cd0",
         "type": "github"
       },
       "original": {
···
         "nixpkgs": "nixpkgs_2"
       },
       "locked": {
-        "lastModified": 1758422215,
-        "narHash": "sha256-JvF5SXhp1wBHbfEVAWgJCDVSO8iknfDqXfqMch5YWg0=",
+        "lastModified": 1758767687,
+        "narHash": "sha256-znUulOqcL/Kkdr7CkyIi8Z1pTGXpi54Xg2FmlyJmv4A=",
         "owner": "oxalica",
         "repo": "rust-overlay",
-        "rev": "6f3988eb5885f1e2efa874a480d91de09a7f9f0b",
+        "rev": "b8bcc09d4f627f4e325408f6e7a85c3ac31f0eeb",
         "type": "github"
       },
       "original": {
···
         "nixpkgs": "nixpkgs_3"
       },
       "locked": {
-        "lastModified": 1758272005,
-        "narHash": "sha256-1u3xTH+3kaHhztPmWtLAD8LF5pTYLR2CpsPFWTFnVtQ=",
+        "lastModified": 1758662783,
+        "narHash": "sha256-igrxT+/MnmcftPOHEb+XDwAMq3Xg1Xy7kVYQaHhPlAg=",
         "owner": "NuschtOS",
         "repo": "search",
-        "rev": "aa975a3757f28ce862812466c5848787b868e116",
+        "rev": "7d4c0fc4ffe3bd64e5630417162e9e04e64b27a4",
         "type": "github"
       },
       "original": {

flake.nix

···
         nurPackages = import ./default.nix {
           inherit pkgs craneLib;
         };
+        packages = pkgs.lib.filterAttrs (n: v: pkgs.lib.isDerivation v) nurPackages;
       in
       {
-        packages = nurPackages // {
-          default = nurPackages.bluesky;
+        packages = packages // {
+          default = packages.bluesky;
           search = search.packages.${system}.default;
         };
-        legacyPackages = nurPackages;
+        legacyPackages = packages;
         nixosModules = {
           nur-atproto = import ./modules;
           search = search.nixosModules.default;
···
         };
       }
     );
-}
+}

modules/bluesky/beemo.nix

···
+{ lib, config, pkgs, ... }:
+
+with lib;
+
+let
+  cfg = config.services.beemo;
+in
+{
+  options.services.beemo = {
+    enable = mkEnableOption "beemo";
+
+    package = mkOption {
+      type = types.package;
+      default = pkgs.bluesky;
+      description = "The beemo package to use.";
+    };
+
+    slackWebhookUrl = mkOption {
+      type = types.str;
+      description = "Slack webhook URL.";
+    };
+  };
+
+  config = mkIf cfg.enable {
+    systemd.services.beemo-notify-reports = {
+      description = "beemo notify-reports service";
+      after = [ "network.target" ];
+      wantedBy = [ "multi-user.target" ];
+      serviceConfig = {
+        ExecStart = "${cfg.package}/bin/beemo notify-reports --slack-webhook-url ${cfg.slackWebhookUrl}";
+        Restart = "on-failure";
+      };
+    };
+
+    systemd.services.beemo-notify-mentions = {
+      description = "beemo notify-mentions service";
+      after = [ "network.target" ];
+      wantedBy = [ "multi-user.target" ];
+      serviceConfig = {
+        ExecStart = "${cfg.package}/bin/beemo notify-mentions --slack-webhook-url ${cfg.slackWebhookUrl}";
+        Restart = "on-failure";
+      };
+    };
+  };
+}

modules/bluesky/bigsky.nix

···
+{ lib, config, pkgs, ... }:
+
+with lib;
+
+let
+  cfg = config.services.bigsky;
+in
+{
+  options.services.bigsky = {
+    enable = mkEnableOption "bigsky";
+
+    package = mkOption {
+      type = types.package;
+      default = pkgs.bluesky;
+      description = "The bigsky package to use.";
+    };
+  };
+
+  config = mkIf cfg.enable {
+    systemd.services.bigsky = {
+      description = "bigsky service";
+      after = [ "network.target" ];
+      wantedBy = [ "multi-user.target" ];
+      serviceConfig = {
+        ExecStart = "${cfg.package}/bin/bigsky";
+        Restart = "on-failure";
+      };
+    };
+  };
+}

modules/bluesky/default.nix

···
+{ lib, config, pkgs, ... }:
+
+{
+  imports = [
+    ./bigsky.nix
+    ./relay.nix
+    ./hepa.nix
+    ./palomar.nix
+    ./beemo.nix
+    ./sonar.nix
+  ];
+}

modules/bluesky/hepa.nix

···
+{ lib, config, pkgs, ... }:
+
+with lib;
+
+let
+  cfg = config.services.hepa;
+in
+{
+  options.services.hepa = {
+    enable = mkEnableOption "hepa";
+
+    package = mkOption {
+      type = types.package;
+      default = pkgs.bluesky;
+      description = "The hepa package to use.";
+    };
+
+    atpRelayHost = mkOption {
+      type = types.str;
+      default = "wss://bsky.network";
+      description = "ATP relay host.";
+    };
+
+    atpPlcHost = mkOption {
+      type = types.str;
+      default = "https://plc.directory";
+      description = "ATP PLC host.";
+    };
+
+    atpBskyHost = mkOption {
+      type = types.str;
+      default = "https://public.api.bsky.app";
+      description = "ATP bsky host.";
+    };
+
+    atpOzoneHost = mkOption {
+      type = types.str;
+      default = "https://mod.bsky.app";
+      description = "ATP ozone host.";
+    };
+
+    ozoneDid = mkOption {
+      type = types.str;
+      description = "Ozone DID.";
+    };
+
+    ozoneAdminToken = mkOption {
+      type = types.str;
+      description = "Ozone admin token.";
+    };
+
+    atpPdsHost = mkOption {
+      type = types.str;
+      default = "https://bsky.social";
+      description = "ATP PDS host.";
+    };
+
+    pdsAdminToken = mkOption {
+      type = types.str;
+      description = "PDS admin token.";
+    };
+
+    redisUrl = mkOption {
+      type = types.str;
+      description = "Redis URL.";
+    };
+
+    hiveaiApiToken = mkOption {
+      type = types.str;
+      description = "Hive AI API token.";
+    };
+
+    abyssHost = mkOption {
+      type = types.str;
+      description = "Abyss host.";
+    };
+
+    abyssPassword = mkOption {
+      type = types.str;
+      description = "Abyss password.";
+    };
+  };
+
+  config = mkIf cfg.enable {
+    systemd.services.hepa = {
+      description = "hepa service";
+      after = [ "network.target" ];
+      wantedBy = [ "multi-user.target" ];
+      serviceConfig = {
+        ExecStart = "${cfg.package}/bin/hepa run --atp-relay-host ${cfg.atpRelayHost} --atp-plc-host ${cfg.atpPlcHost} --atp-bsky-host ${cfg.atpBskyHost} --atp-ozone-host ${cfg.atpOzoneHost} --ozone-did ${cfg.ozoneDid} --ozone-admin-token ${cfg.ozoneAdminToken} --atp-pds-host ${cfg.atpPdsHost} --pds-admin-token ${cfg.pdsAdminToken} --redis-url ${cfg.redisUrl} --hiveai-api-token ${cfg.hiveaiApiToken} --abyss-host ${cfg.abyssHost} --abyss-password ${cfg.abyssPassword}";
+        Restart = "on-failure";
+      };
+    };
+  };
+}

modules/bluesky/palomar.nix

···
+{ lib, config, pkgs, ... }:
+
+with lib;
+
+let
+  cfg = config.services.palomar;
+in
+{
+  options.services.palomar = {
+    enable = mkEnableOption "palomar";
+
+    package = mkOption {
+      type = types.package;
+      default = pkgs.bluesky;
+      description = "The palomar package to use.";
+    };
+
+    elasticCertFile = mkOption {
+      type = types.str;
+      description = "Elasticsearch cert file.";
+    };
+
+    elasticInsecureSsl = mkOption {
+      type = types.bool;
+      default = false;
+      description = "Elasticsearch insecure SSL.";
+    };
+
+    elasticUsername = mkOption {
+      type = types.str;
+      default = "admin";
+      description = "Elasticsearch username.";
+    };
+
+    elasticPassword = mkOption {
+      type = types.str;
+      default = "0penSearch-Pal0mar";
+      description = "Elasticsearch password.";
+    };
+
+    elasticHosts = mkOption {
+      type = types.str;
+      default = "http://localhost:9200";
+      description = "Elasticsearch hosts.";
+    };
+
+    esPostIndex = mkOption {
+      type = types.str;
+      default = "palomar_post";
+      description = "Elasticsearch post index.";
+    };
+
+    esProfileIndex = mkOption {
+      type = types.str;
+      default = "palomar_profile";
+      description = "Elasticsearch profile index.";
+    };
+
+    atpRelayHost = mkOption {
+      type = types.str;
+      default = "wss://bsky.network";
+      description = "ATP relay host.";
+    };
+
+    atpPlcHost = mkOption {
+      type = types.str;
+      default = "https://plc.directory";
+      description = "ATP PLC host.";
+    };
+  };
+
+  config = mkIf cfg.enable {
+    systemd.services.palomar = {
+      description = "palomar service";
+      after = [ "network.target" ];
+      wantedBy = [ "multi-user.target" ];
+      serviceConfig = {
+        ExecStart = "${cfg.package}/bin/palomar run --elastic-cert-file ${cfg.elasticCertFile} --elastic-insecure-ssl ${toString cfg.elasticInsecureSsl} --elastic-username ${cfg.elasticUsername} --elastic-password ${cfg.elasticPassword} --elastic-hosts ${cfg.elasticHosts} --es-post-index ${cfg.esPostIndex} --es-profile-index ${cfg.esProfileIndex} --atp-relay-host ${cfg.atpRelayHost} --atp-plc-host ${cfg.atpPlcHost}";
+        Restart = "on-failure";
+      };
+    };
+  };
+}

modules/bluesky/relay.nix

···
+{ lib, config, pkgs, ... }:
+
+with lib;
+
+let
+  cfg = config.services.relay;
+in
+{
+  options.services.relay = {
+    enable = mkEnableOption "relay";
+
+    package = mkOption {
+      type = types.package;
+      default = pkgs.bluesky;
+      description = "The relay package to use.";
+    };
+
+    adminPassword = mkOption {
+      type = types.str;
+      description = "Admin password for the relay.";
+    };
+
+    plcHost = mkOption {
+      type = types.str;
+      default = "https://plc.directory";
+      description = "PLC host for the relay.";
+    };
+  };
+
+  config = mkIf cfg.enable {
+    systemd.services.relay = {
+      description = "relay service";
+      after = [ "network.target" ];
+      wantedBy = [ "multi-user.target" ];
+      serviceConfig = {
+        ExecStart = "${cfg.package}/bin/relay serve --admin-password ${cfg.adminPassword} --plc-host ${cfg.plcHost}";
+        Restart = "on-failure";
+      };
+    };
+  };
+}

modules/bluesky/sonar.nix

···
+{ lib, config, pkgs, ... }:
+
+with lib;
+
+let
+  cfg = config.services.sonar;
+in
+{
+  options.services.sonar = {
+    enable = mkEnableOption "sonar";
+
+    package = mkOption {
+      type = types.package;
+      default = pkgs.bluesky;
+      description = "The sonar package to use.";
+    };
+
+    wsUrl = mkOption {
+      type = types.str;
+      default = "wss://bsky.network/xrpc/com.atproto.sync.subscribeRepos";
+      description = "Websocket URL.";
+    };
+
+    logLevel = mkOption {
+      type = types.str;
+      default = "info";
+      description = "Log level.";
+    };
+
+    port = mkOption {
+      type = types.port;
+      default = 8345;
+      description = "Metrics server port.";
+    };
+
+    maxQueueSize = mkOption {
+      type = types.int;
+      default = 10;
+      description = "Max queue size.";
+    };
+
+    cursorFile = mkOption {
+      type = types.str;
+      default = "/var/lib/sonar/cursor.json";
+      description = "Cursor file.";
+    };
+  };
+
+  config = mkIf cfg.enable {
+    systemd.services.sonar = {
+      description = "sonar service";
+      after = [ "network.target" ];
+      wantedBy = [ "multi-user.target" ];
+      serviceConfig = {
+        ExecStart = "${cfg.package}/bin/sonar --ws-url ${cfg.wsUrl} --log-level ${cfg.logLevel} --port ${toString cfg.port} --max-queue-size ${toString cfg.maxQueueSize} --cursor-file ${cfg.cursorFile}";
+        Restart = "on-failure";
+        StateDirectory = "sonar";
+      };
+    };
+  };
+}

modules/default.nix

···
 {
   imports = [
+    ./bluesky
   ];
-}
+}

pkgs/bluesky/default.nix

···
-{ stdenv }:
+{ lib, buildGoModule, fetchFromGitHub }:
 
-stdenv.mkDerivation rec {
-  name = "example-package-${version}";
-  version = "1.0";
-  src = ./.;
-  buildPhase = "echo echo Hello World > example";
-  installPhase = "install -Dm755 example $out";
-}
+buildGoModule rec {
+  pname = "indigo";
+  version = "unstable-2023-09-24";
+
+  src = fetchFromGitHub {
+    owner = "bluesky-social";
+    repo = "indigo";
+    rev = "b4dd6383c76ffe205afe5407a027bb90a7461b12";
+    sha256 = "sha256-e0Y/k1RBnFg8Z9VT7rxuZeyvJo2MZIOHQJbo9prTaoQ=";
+  };
+
+  vendorHash = "sha256-7mYvgvR0tZdEnUgUYzKv6d2QyeXXnrFgVwY8/4UM3oU=";
+
+  subPackages = [
+    "cmd/goat"
+    "cmd/gosky"
+    "cmd/bigsky"
+    "cmd/relay"
+    "cmd/beemo"
+    "cmd/lexgen"
+    "cmd/stress"
+    "cmd/fakermaker"
+    "cmd/hepa"
+    "cmd/supercollider"
+    "cmd/sonar"
+    "cmd/palomar"
+  ];
+
+  meta = with lib; {
+    description = "Go source code for Bluesky's atproto services";
+    homepage = "https://github.com/bluesky-social/indigo";
+    license = licenses.mit;
+    maintainers = with maintainers; [ ];
+  };
+}