nixpkgs/nixos/tests/ustreamer.nix

import ./make-test-python.nix ({ pkgs, ... }: {
  name = "ustreamer-vmtest";
  nodes = {
    client = {...}: {
      environment.systemPackages = [ pkgs.curl ];
    };
    camera = {config, ...}: let
      configFile = pkgs.writeText "akvcam-configFile" ''
        [Cameras]
        cameras/size = 2

        cameras/1/type = output
        cameras/1/mode = mmap, userptr, rw
        cameras/1/description = Virtual Camera (output device)
        cameras/1/formats = 2
        cameras/1/videonr = 7

        cameras/2/type = capture
        cameras/2/mode = mmap, rw
        cameras/2/description = Virtual Camera
        cameras/2/formats = 1, 2
        cameras/2/videonr = 9

        [Connections]
        connections/size = 1
        connections/1/connection = 1:2

        [Formats]
        formats/size = 2

        formats/1/format = YUY2
        formats/1/width = 640
        formats/1/height = 480
        formats/1/fps = 30

        formats/2/format = RGB24, YUY2
        formats/2/width = 640
        formats/2/height = 480
        formats/2/fps = 20/1, 15/2
      '';
    in {
      environment.systemPackages = [ pkgs.ustreamer ];
      networking.firewall.enable = false;
      systemd.services.ustreamer = {
        description = "ustreamer service";
        wantedBy = ["multi-user.target"];
        serviceConfig = {
          DynamicUser = true;
          ExecStart = "${pkgs.ustreamer}/bin/ustreamer --host=0.0.0.0 --port 8000 --device /dev/video9 --device-timeout=8";
          PrivateTmp = true;
          BindReadOnlyPaths = "/dev/video9";
          SupplementaryGroups = [
            "video"
          ];
          Restart = "always";
        };
      };
      boot.extraModulePackages = [config.boot.kernelPackages.akvcam];
      boot.kernelModules = ["akvcam"];
      boot.extraModprobeConfig = ''
        options akvcam config_file=${configFile}
      '';
    };
  };

  testScript = ''
    start_all()

    camera.wait_for_unit("ustreamer.service")
    camera.wait_for_open_port(8000)

    client.wait_for_unit("multi-user.target")
    client.succeed("curl http://camera:8000")
  '';
})