from src.integrations.connector_contract import IntegrationConnectorRegistry, IntegrationResourceRef


def test_resources_are_generic_not_agent_specific() -> None:
    ref = IntegrationResourceRef("provider-a", "agent", "agent-1")
    assert ref.resource_type == "agent"
    assert IntegrationResourceRef("provider-a", "phone_number", "phone-1").resource_type == "phone_number"


def test_connector_registry_is_provider_keyed() -> None:
    class Connector:
        provider_key = "provider-a"
        capabilities = frozenset({"agent.configure", "webhook.events"})

    registry = IntegrationConnectorRegistry([Connector()])
    assert registry.get("provider-a").capabilities == {"agent.configure", "webhook.events"}
    assert registry.get("provider-b") is None