code: def test_parse_conn_protocol_valid(maddr_str, expected_proto):
      assert parse_conn_protocol(Multiaddr(maddr_str)) == expected_proto
  
imports: import asyncio
  import io
  from contextlib import AsyncExitStack
  import pytest
  from google.protobuf.message import EncodeError
  from multiaddr import Multiaddr, protocols
  from hivemind.p2p.p2p_daemon_bindings.control import ControlClient, DaemonConnector, parse_conn_protocol
  from hivemind.p2p.p2p_daemon_bindings.datastructures import PeerID, PeerInfo, StreamInfo
  from hivemind.p2p.p2p_daemon_bindings.utils import ControlFailure, raise_if_failed, read_pbmsg_safe, read_unsigned_varint, write_pbmsg, write_unsigned_varint
  from hivemind.proto import p2pd_pb2
  from test_utils.p2p_daemon import connect_safe, make_p2pd_pair_unix
label_desc: Use image node_id 6 for calling a global function with example usage: test_parse_conn_protocol_valid(maddr_str, expected_proto) without return types