[{'Text': '    mock_response = json.dumps({"ok": True, "insertedId": op_id, "operator": "TestOp", "country": "UK", "tech": "FTTP"})\n\n    with patch("point_topic_mcp.core.mongodb_utils.insert_statistic_safe", return_value=mock_response):\n        result = gbs.add_statistic(type="broadband", operator_id=op_id, period="2025Q3", tech="FTTP", channel="Infrastructure", domain="Residential", subscribers=50000, created_by="test-agent")\n        assert "Created statistic" in result\n        assert op_id in result\n        assert "TestOp" in result\n        assert "50,000" in result\n        assert "Admin:" in result\n\n\ndef test_add_statistic_duplicate_rejected(gbs_env):\n    """add_statistic rejects duplicate (operator, period, type, tech, channel, domain)."""\n    gbs = gbs_env\n    existing_id = str(ObjectId())\n    mock_response = json.dumps({"ok": False, "error": f"Duplicate exists (id={existing_id})"})\n\n    with patch("point_topic_mcp.core.mongodb_utils.insert_statistic_safe", return_value=mock_response):\n        result = gbs.add_statistic(type="broadband", operator_id=str(ObjectId()), period="2025Q3", tech="FTTP", channel="Infrastructure", domain="Residential", subscribers=50000)\n        assert "Duplicate" in result\n        assert existing_id in result\n\n\n# --- create_source tests ---\n\ndef test_create_source_validation(gbs_env):\n    """create_source returns errors for invalid inputs."""\n    gbs = gbs_env\n    oid = "000000000000000000000001"\n    assert "Invalid operator_id" in gbs.create_source(operator_id="bad", year=2025, quarter=1, type="report")\n    assert "Invalid quarter" in gbs.create_source(operator_id=oid, year=2025, quarter=5, type="report")\n    assert "At least one" in gbs.create_source(operator_id=oid, year=2025, quarter=1, type="report", url="")\n\n\ndef test_create_source_success(gbs_env):\n    """create_source inserts a source record."""\n'}]