test_config.py

import pytest
from streamdal import StreamdalConfig


class TestStreamdalConfig:
    def test_valid_config(self):
        # A valid config should not raise any exception
        config = StreamdalConfig(
            service_name="MyService",
            streamdal_url="localhost:8082",
            streamdal_token="fake token",
        )
        assert config.validate() is None

    def test_missing_config(self):
        # Test when a required field (service_name) is missing
        with pytest.raises(ValueError, match="service_name is required"):
            cfg = StreamdalConfig(
                service_name="",
                streamdal_url="localhost:8082",
                streamdal_token="fake token",
            )
            cfg.validate()

        # Test when streamdal_url is missing
        with pytest.raises(ValueError, match="streamdal_url is required"):
            cfg = StreamdalConfig(
                service_name="writer",
                streamdal_url="",
                streamdal_token="fake token",
            )
            cfg.validate()

        # Test when streamdal_token is missing
        with pytest.raises(ValueError, match="streamdal_token is required"):
            cfg = StreamdalConfig(
                service_name="writer",
                streamdal_url="localhost:8082",
                streamdal_token="",
            )
            cfg.validate()