Add files using upload-large-folder tool

.gitattributes

@@ -211,3 +211,4 @@ tuning-competition-baseline/.venv/lib/python3.11/site-packages/torch/_inductor/_
 .venv/lib/python3.11/site-packages/watchfiles/_rust_notify.cpython-311-x86_64-linux-gnu.so filter=lfs diff=lfs merge=lfs -text
 .venv/lib/python3.11/site-packages/frozenlist/_frozenlist.cpython-311-x86_64-linux-gnu.so filter=lfs diff=lfs merge=lfs -text
 .venv/lib/python3.11/site-packages/uvloop/loop.cpython-311-x86_64-linux-gnu.so filter=lfs diff=lfs merge=lfs -text
+.venv/lib/python3.11/site-packages/functorch/_C.cpython-311-x86_64-linux-gnu.so filter=lfs diff=lfs merge=lfs -text

.venv/lib/python3.11/site-packages/fsspec/tests/abstract/__init__.py

@@ -0,0 +1,289 @@
+import os
+from hashlib import md5
+
+import pytest
+
+from fsspec.implementations.local import LocalFileSystem
+from fsspec.tests.abstract.copy import AbstractCopyTests  # noqa: F401
+from fsspec.tests.abstract.get import AbstractGetTests  # noqa: F401
+from fsspec.tests.abstract.open import AbstractOpenTests  # noqa: F401
+from fsspec.tests.abstract.pipe import AbstractPipeTests  # noqa: F401
+from fsspec.tests.abstract.put import AbstractPutTests  # noqa: F401
+
+
+class BaseAbstractFixtures:
+    """
+    Abstract base class containing fixtures that are used by but never need to
+    be overridden in derived filesystem-specific classes to run the abstract
+    tests on such filesystems.
+    """
+
+    @pytest.fixture
+    def fs_bulk_operations_scenario_0(self, fs, fs_join, fs_path):
+        """
+        Scenario on remote filesystem that is used for many cp/get/put tests.
+
+        Cleans up at the end of each test it which it is used.
+        """
+        source = self._bulk_operations_scenario_0(fs, fs_join, fs_path)
+        yield source
+        fs.rm(source, recursive=True)
+
+    @pytest.fixture
+    def fs_glob_edge_cases_files(self, fs, fs_join, fs_path):
+        """
+        Scenario on remote filesystem that is used for glob edge cases cp/get/put tests.
+
+        Cleans up at the end of each test it which it is used.
+        """
+        source = self._glob_edge_cases_files(fs, fs_join, fs_path)
+        yield source
+        fs.rm(source, recursive=True)
+
+    @pytest.fixture
+    def fs_dir_and_file_with_same_name_prefix(self, fs, fs_join, fs_path):
+        """
+        Scenario on remote filesystem that is used to check cp/get/put on directory
+        and file with the same name prefixes.
+
+        Cleans up at the end of each test it which it is used.
+        """
+        source = self._dir_and_file_with_same_name_prefix(fs, fs_join, fs_path)
+        yield source
+        fs.rm(source, recursive=True)
+
+    @pytest.fixture
+    def fs_10_files_with_hashed_names(self, fs, fs_join, fs_path):
+        """
+        Scenario on remote filesystem that is used to check cp/get/put files order
+        when source and destination are lists.
+
+        Cleans up at the end of each test it which it is used.
+        """
+        source = self._10_files_with_hashed_names(fs, fs_join, fs_path)
+        yield source
+        fs.rm(source, recursive=True)
+
+    @pytest.fixture
+    def fs_target(self, fs, fs_join, fs_path):
+        """
+        Return name of remote directory that does not yet exist to copy into.
+
+        Cleans up at the end of each test it which it is used.
+        """
+        target = fs_join(fs_path, "target")
+        yield target
+        if fs.exists(target):
+            fs.rm(target, recursive=True)
+
+    @pytest.fixture
+    def local_bulk_operations_scenario_0(self, local_fs, local_join, local_path):
+        """
+        Scenario on local filesystem that is used for many cp/get/put tests.
+
+        Cleans up at the end of each test it which it is used.
+        """
+        source = self._bulk_operations_scenario_0(local_fs, local_join, local_path)
+        yield source
+        local_fs.rm(source, recursive=True)
+
+    @pytest.fixture
+    def local_glob_edge_cases_files(self, local_fs, local_join, local_path):
+        """
+        Scenario on local filesystem that is used for glob edge cases cp/get/put tests.
+
+        Cleans up at the end of each test it which it is used.
+        """
+        source = self._glob_edge_cases_files(local_fs, local_join, local_path)
+        yield source
+        local_fs.rm(source, recursive=True)
+
+    @pytest.fixture
+    def local_dir_and_file_with_same_name_prefix(
+        self, local_fs, local_join, local_path
+    ):
+        """
+        Scenario on local filesystem that is used to check cp/get/put on directory
+        and file with the same name prefixes.
+
+        Cleans up at the end of each test it which it is used.
+        """
+        source = self._dir_and_file_with_same_name_prefix(
+            local_fs, local_join, local_path
+        )
+        yield source
+        local_fs.rm(source, recursive=True)
+
+    @pytest.fixture
+    def local_10_files_with_hashed_names(self, local_fs, local_join, local_path):
+        """
+        Scenario on local filesystem that is used to check cp/get/put files order
+        when source and destination are lists.
+
+        Cleans up at the end of each test it which it is used.
+        """
+        source = self._10_files_with_hashed_names(local_fs, local_join, local_path)
+        yield source
+        local_fs.rm(source, recursive=True)
+
+    @pytest.fixture
+    def local_target(self, local_fs, local_join, local_path):
+        """
+        Return name of local directory that does not yet exist to copy into.
+
+        Cleans up at the end of each test it which it is used.
+        """
+        target = local_join(local_path, "target")
+        yield target
+        if local_fs.exists(target):
+            local_fs.rm(target, recursive=True)
+
+    def _glob_edge_cases_files(self, some_fs, some_join, some_path):
+        """
+        Scenario that is used for glob edge cases cp/get/put tests.
+        Creates the following directory and file structure:
+
+        📁 source
+        ├── 📄 file1
+        ├── 📄 file2
+        ├── 📁 subdir0
+        │   ├── 📄 subfile1
+        │   ├── 📄 subfile2
+        │   └── 📁 nesteddir
+        │       └── 📄 nestedfile
+        └── 📁 subdir1
+            ├── 📄 subfile1
+            ├── 📄 subfile2
+            └── 📁 nesteddir
+                └── 📄 nestedfile
+        """
+        source = some_join(some_path, "source")
+        some_fs.touch(some_join(source, "file1"))
+        some_fs.touch(some_join(source, "file2"))
+
+        for subdir_idx in range(2):
+            subdir = some_join(source, f"subdir{subdir_idx}")
+            nesteddir = some_join(subdir, "nesteddir")
+            some_fs.makedirs(nesteddir)
+            some_fs.touch(some_join(subdir, "subfile1"))
+            some_fs.touch(some_join(subdir, "subfile2"))
+            some_fs.touch(some_join(nesteddir, "nestedfile"))
+
+        return source
+
+    def _bulk_operations_scenario_0(self, some_fs, some_join, some_path):
+        """
+        Scenario that is used for many cp/get/put tests. Creates the following
+        directory and file structure:
+
+        📁 source
+        ├── 📄 file1
+        ├── 📄 file2
+        └── 📁 subdir
+            ├── 📄 subfile1
+            ├── 📄 subfile2
+            └── 📁 nesteddir
+                └── 📄 nestedfile
+        """
+        source = some_join(some_path, "source")
+        subdir = some_join(source, "subdir")
+        nesteddir = some_join(subdir, "nesteddir")
+        some_fs.makedirs(nesteddir)
+        some_fs.touch(some_join(source, "file1"))
+        some_fs.touch(some_join(source, "file2"))
+        some_fs.touch(some_join(subdir, "subfile1"))
+        some_fs.touch(some_join(subdir, "subfile2"))
+        some_fs.touch(some_join(nesteddir, "nestedfile"))
+        return source
+
+    def _dir_and_file_with_same_name_prefix(self, some_fs, some_join, some_path):
+        """
+        Scenario that is used to check cp/get/put on directory and file with
+        the same name prefixes. Creates the following directory and file structure:
+
+        📁 source
+        ├── 📄 subdir.txt
+        └── 📁 subdir
+            └── 📄 subfile.txt
+        """
+        source = some_join(some_path, "source")
+        subdir = some_join(source, "subdir")
+        file = some_join(source, "subdir.txt")
+        subfile = some_join(subdir, "subfile.txt")
+        some_fs.makedirs(subdir)
+        some_fs.touch(file)
+        some_fs.touch(subfile)
+        return source
+
+    def _10_files_with_hashed_names(self, some_fs, some_join, some_path):
+        """
+        Scenario that is used to check cp/get/put files order when source and
+        destination are lists. Creates the following directory and file structure:
+
+        📁 source
+        └── 📄 {hashed([0-9])}.txt
+        """
+        source = some_join(some_path, "source")
+        for i in range(10):
+            hashed_i = md5(str(i).encode("utf-8")).hexdigest()
+            path = some_join(source, f"{hashed_i}.txt")
+            some_fs.pipe(path=path, value=f"{i}".encode())
+        return source
+
+
+class AbstractFixtures(BaseAbstractFixtures):
+    """
+    Abstract base class containing fixtures that may be overridden in derived
+    filesystem-specific classes to run the abstract tests on such filesystems.
+
+    For any particular filesystem some of these fixtures must be overridden,
+    such as ``fs`` and ``fs_path``, and others may be overridden if the
+    default functions here are not appropriate, such as ``fs_join``.
+    """
+
+    @pytest.fixture
+    def fs(self):
+        raise NotImplementedError("This function must be overridden in derived classes")
+
+    @pytest.fixture
+    def fs_join(self):
+        """
+        Return a function that joins its arguments together into a path.
+
+        Most fsspec implementations join paths in a platform-dependent way,
+        but some will override this to always use a forward slash.
+        """
+        return os.path.join
+
+    @pytest.fixture
+    def fs_path(self):
+        raise NotImplementedError("This function must be overridden in derived classes")
+
+    @pytest.fixture(scope="class")
+    def local_fs(self):
+        # Maybe need an option for auto_mkdir=False?  This is only relevant
+        # for certain implementations.
+        return LocalFileSystem(auto_mkdir=True)
+
+    @pytest.fixture
+    def local_join(self):
+        """
+        Return a function that joins its arguments together into a path, on
+        the local filesystem.
+        """
+        return os.path.join
+
+    @pytest.fixture
+    def local_path(self, tmpdir):
+        return tmpdir
+
+    @pytest.fixture
+    def supports_empty_directories(self):
+        """
+        Return whether this implementation supports empty directories.
+        """
+        return True
+
+    @pytest.fixture
+    def fs_sanitize_path(self):
+        return lambda x: x

.venv/lib/python3.11/site-packages/fsspec/tests/abstract/open.py

@@ -0,0 +1,11 @@
+import pytest
+
+
+class AbstractOpenTests:
+    def test_open_exclusive(self, fs, fs_target):
+        with fs.open(fs_target, "wb") as f:
+            f.write(b"data")
+        with fs.open(fs_target, "rb") as f:
+            assert f.read() == b"data"
+        with pytest.raises(FileExistsError):
+            fs.open(fs_target, "xb")

.venv/lib/python3.11/site-packages/functorch/_C.cpython-311-x86_64-linux-gnu.so

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:39dc1f80069251db7f97e91763cbde3e2a9b53d8db73007ad0ddf7b041fee1d5
+size 324432

.venv/lib/python3.11/site-packages/zmq/__init__.pxd

@@ -0,0 +1 @@
+from zmq.backend.cython cimport Context, Frame, Socket, libzmq

.venv/lib/python3.11/site-packages/zmq/__init__.py

@@ -0,0 +1,94 @@
+"""Python bindings for 0MQ"""
+
+# Copyright (C) PyZMQ Developers
+# Distributed under the terms of the Modified BSD License.
+
+from __future__ import annotations
+
+import os
+import sys
+from contextlib import contextmanager
+
+
+@contextmanager
+def _libs_on_path():
+    """context manager for libs directory on $PATH
+
+    Works around mysterious issue where os.add_dll_directory
+    does not resolve imports (conda-forge Python >= 3.8)
+    """
+
+    if not sys.platform.startswith("win"):
+        yield
+        return
+
+    libs_dir = os.path.abspath(
+        os.path.join(
+            os.path.dirname(__file__),
+            os.pardir,
+            "pyzmq.libs",
+        )
+    )
+    if not os.path.exists(libs_dir):
+        # no bundled libs
+        yield
+        return
+
+    path_before = os.environ.get("PATH")
+    try:
+        os.environ["PATH"] = os.pathsep.join([path_before or "", libs_dir])
+        yield
+    finally:
+        if path_before is None:
+            os.environ.pop("PATH")
+        else:
+            os.environ["PATH"] = path_before
+
+
+# zmq top-level imports
+
+# workaround for Windows
+with _libs_on_path():
+    from zmq import backend
+
+from . import constants  # noqa
+from .constants import *  # noqa
+from zmq.backend import *  # noqa
+from zmq import sugar
+from zmq.sugar import *  # noqa
+
+
+def get_includes():
+    """Return a list of directories to include for linking against pyzmq with cython."""
+    from os.path import abspath, dirname, exists, join, pardir
+
+    base = dirname(__file__)
+    parent = abspath(join(base, pardir))
+    includes = [parent] + [join(parent, base, subdir) for subdir in ('utils',)]
+    if exists(join(parent, base, 'include')):
+        includes.append(join(parent, base, 'include'))
+    return includes
+
+
+def get_library_dirs():
+    """Return a list of directories used to link against pyzmq's bundled libzmq."""
+    from os.path import abspath, dirname, join, pardir
+
+    base = dirname(__file__)
+    parent = abspath(join(base, pardir))
+    return [join(parent, base)]
+
+
+COPY_THRESHOLD = 65536
+DRAFT_API = backend.has("draft")
+
+__all__ = (
+    [
+        'get_includes',
+        'COPY_THRESHOLD',
+        'DRAFT_API',
+    ]
+    + constants.__all__
+    + sugar.__all__
+    + backend.__all__
+)

.venv/lib/python3.11/site-packages/zmq/__init__.pyi

@@ -0,0 +1,29 @@
+from typing import List
+
+from . import backend, sugar
+
+COPY_THRESHOLD: int
+DRAFT_API: bool
+__version__: str
+
+# mypy doesn't like overwriting symbols with * so be explicit
+# about what comes from backend, not from sugar
+# see tools/backend_imports.py to generate this list
+# note: `x as x` is required for re-export
+# see https://github.com/python/mypy/issues/2190
+from .backend import IPC_PATH_MAX_LEN as IPC_PATH_MAX_LEN
+from .backend import curve_keypair as curve_keypair
+from .backend import curve_public as curve_public
+from .backend import device as device
+from .backend import has as has
+from .backend import proxy as proxy
+from .backend import proxy_steerable as proxy_steerable
+from .backend import strerror as strerror
+from .backend import zmq_errno as zmq_errno
+from .backend import zmq_poll as zmq_poll
+from .constants import *
+from .error import *
+from .sugar import *
+
+def get_includes() -> list[str]: ...
+def get_library_dirs() -> list[str]: ...

.venv/lib/python3.11/site-packages/zmq/_future.pyi

@@ -0,0 +1,92 @@
+"""type annotations for async sockets"""
+
+from __future__ import annotations
+
+from asyncio import Future
+from pickle import DEFAULT_PROTOCOL
+from typing import Any, Awaitable, Literal, Sequence, TypeVar, overload
+
+import zmq as _zmq
+
+class _AsyncPoller(_zmq.Poller):
+    _socket_class: type[_AsyncSocket]
+
+    def poll(self, timeout=-1) -> Awaitable[list[tuple[Any, int]]]: ...  # type: ignore
+
+T = TypeVar("T", bound="_AsyncSocket")
+
+class _AsyncSocket(_zmq.Socket[Future]):
+    @classmethod
+    def from_socket(cls: type[T], socket: _zmq.Socket, io_loop: Any = None) -> T: ...
+    def send(  # type: ignore
+        self,
+        data: Any,
+        flags: int = 0,
+        copy: bool = True,
+        track: bool = False,
+        routing_id: int | None = None,
+        group: str | None = None,
+    ) -> Awaitable[_zmq.MessageTracker | None]: ...
+    @overload  # type: ignore
+    def recv(self, flags: int = 0, *, track: bool = False) -> Awaitable[bytes]: ...
+    @overload
+    def recv(
+        self, flags: int = 0, *, copy: Literal[True], track: bool = False
+    ) -> Awaitable[bytes]: ...
+    @overload
+    def recv(
+        self, flags: int = 0, *, copy: Literal[False], track: bool = False
+    ) -> Awaitable[_zmq.Frame]: ...
+    @overload
+    def recv(
+        self, flags: int = 0, copy: bool = True, track: bool = False
+    ) -> Awaitable[bytes | _zmq.Frame]: ...
+    def send_multipart(  # type: ignore
+        self,
+        msg_parts: Sequence,
+        flags: int = 0,
+        copy: bool = True,
+        track: bool = False,
+        routing_id: int | None = None,
+        group: str | None = None,
+    ) -> Awaitable[_zmq.MessageTracker | None]: ...
+    @overload  # type: ignore
+    def recv_multipart(
+        self, flags: int = 0, *, track: bool = False
+    ) -> Awaitable[list[bytes]]: ...
+    @overload
+    def recv_multipart(
+        self, flags: int = 0, *, copy: Literal[True], track: bool = False
+    ) -> Awaitable[list[bytes]]: ...
+    @overload
+    def recv_multipart(
+        self, flags: int = 0, *, copy: Literal[False], track: bool = False
+    ) -> Awaitable[list[_zmq.Frame]]: ...
+    @overload
+    def recv_multipart(
+        self, flags: int = 0, copy: bool = True, track: bool = False
+    ) -> Awaitable[list[bytes] | list[_zmq.Frame]]: ...
+
+    # serialization wrappers
+
+    def send_string(  # type: ignore
+        self,
+        u: str,
+        flags: int = 0,
+        copy: bool = True,
+        *,
+        encoding: str = 'utf-8',
+        **kwargs,
+    ) -> Awaitable[_zmq.Frame | None]: ...
+    def recv_string(  # type: ignore
+        self, flags: int = 0, encoding: str = 'utf-8'
+    ) -> Awaitable[str]: ...
+    def send_pyobj(  # type: ignore
+        self, obj: Any, flags: int = 0, protocol: int = DEFAULT_PROTOCOL, **kwargs
+    ) -> Awaitable[_zmq.Frame | None]: ...
+    def recv_pyobj(self, flags: int = 0) -> Awaitable[Any]: ...  # type: ignore
+    def send_json(  # type: ignore
+        self, obj: Any, flags: int = 0, **kwargs
+    ) -> Awaitable[_zmq.Frame | None]: ...
+    def recv_json(self, flags: int = 0, **kwargs) -> Awaitable[Any]: ...  # type: ignore
+    def poll(self, timeout=-1) -> Awaitable[list[tuple[Any, int]]]: ...  # type: ignore

.venv/lib/python3.11/site-packages/zmq/_typing.py

@@ -0,0 +1,30 @@
+from __future__ import annotations
+
+import sys
+from typing import Any, Dict
+
+if sys.version_info >= (3, 8):
+    from typing import Literal, TypedDict
+else:
+    # avoid runtime dependency on typing_extensions on py37
+    try:
+        from typing_extensions import Literal, TypedDict  # type: ignore
+    except ImportError:
+
+        class _Literal:
+            def __getitem__(self, key):
+                return Any
+
+        Literal = _Literal()  # type: ignore
+
+        class TypedDict(Dict):  # type: ignore
+            pass
+
+
+if sys.version_info >= (3, 10):
+    from typing import TypeAlias
+else:
+    try:
+        from typing_extensions import TypeAlias
+    except ImportError:
+        TypeAlias = type  # type: ignore

.venv/lib/python3.11/site-packages/zmq/auth/__init__.py

@@ -0,0 +1,13 @@
+"""Utilities for ZAP authentication.
+
+To run authentication in a background thread, see :mod:`zmq.auth.thread`.
+For integration with the asyncio event loop, see :mod:`zmq.auth.asyncio`.
+
+Authentication examples are provided in the pyzmq codebase, under
+`/examples/security/`.
+
+.. versionadded:: 14.1
+"""
+
+from .base import *
+from .certs import *

.venv/lib/python3.11/site-packages/zmq/auth/asyncio.py

@@ -0,0 +1,66 @@
+"""ZAP Authenticator integrated with the asyncio IO loop.
+
+.. versionadded:: 15.2
+"""
+
+# Copyright (C) PyZMQ Developers
+# Distributed under the terms of the Modified BSD License.
+
+import asyncio
+import warnings
+from typing import Any, Optional
+
+import zmq
+from zmq.asyncio import Poller
+
+from .base import Authenticator
+
+
+class AsyncioAuthenticator(Authenticator):
+    """ZAP authentication for use in the asyncio IO loop"""
+
+    __poller: Optional[Poller]
+    __task: Any
+
+    def __init__(
+        self,
+        context: Optional["zmq.Context"] = None,
+        loop: Any = None,
+        encoding: str = 'utf-8',
+        log: Any = None,
+    ):
+        super().__init__(context, encoding, log)
+        if loop is not None:
+            warnings.warn(
+                f"{self.__class__.__name__}(loop) is deprecated and ignored",
+                DeprecationWarning,
+                stacklevel=2,
+            )
+        self.__poller = None
+        self.__task = None
+
+    async def __handle_zap(self) -> None:
+        while self.__poller is not None:
+            events = await self.__poller.poll()
+            if self.zap_socket in dict(events):
+                msg = self.zap_socket.recv_multipart()
+                await self.handle_zap_message(msg)
+
+    def start(self) -> None:
+        """Start ZAP authentication"""
+        super().start()
+        self.__poller = Poller()
+        self.__poller.register(self.zap_socket, zmq.POLLIN)
+        self.__task = asyncio.ensure_future(self.__handle_zap())
+
+    def stop(self) -> None:
+        """Stop ZAP authentication"""
+        if self.__task:
+            self.__task.cancel()
+        if self.__poller:
+            self.__poller.unregister(self.zap_socket)
+            self.__poller = None
+        super().stop()
+
+
+__all__ = ["AsyncioAuthenticator"]

.venv/lib/python3.11/site-packages/zmq/auth/base.py

@@ -0,0 +1,445 @@
+"""Base implementation of 0MQ authentication."""
+
+# Copyright (C) PyZMQ Developers
+# Distributed under the terms of the Modified BSD License.
+
+import logging
+import os
+from typing import Any, Awaitable, Dict, List, Optional, Set, Tuple, Union
+
+import zmq
+from zmq.error import _check_version
+from zmq.utils import z85
+
+from .certs import load_certificates
+
+CURVE_ALLOW_ANY = '*'
+VERSION = b'1.0'
+
+
+class Authenticator:
+    """Implementation of ZAP authentication for zmq connections.
+
+    This authenticator class does not register with an event loop. As a result,
+    you will need to manually call `handle_zap_message`::
+
+        auth = zmq.Authenticator()
+        auth.allow("127.0.0.1")
+        auth.start()
+        while True:
+            await auth.handle_zap_msg(auth.zap_socket.recv_multipart())
+
+    Alternatively, you can register `auth.zap_socket` with a poller.
+
+    Since many users will want to run ZAP in a way that does not block the
+    main thread, other authentication classes (such as :mod:`zmq.auth.thread`)
+    are provided.
+
+    Note:
+
+    - libzmq provides four levels of security: default NULL (which the Authenticator does
+      not see), and authenticated NULL, PLAIN, CURVE, and GSSAPI, which the Authenticator can see.
+    - until you add policies, all incoming NULL connections are allowed.
+      (classic ZeroMQ behavior), and all PLAIN and CURVE connections are denied.
+    - GSSAPI requires no configuration.
+    """
+
+    context: "zmq.Context"
+    encoding: str
+    allow_any: bool
+    credentials_providers: Dict[str, Any]
+    zap_socket: "zmq.Socket"
+    _allowed: Set[str]
+    _denied: Set[str]
+    passwords: Dict[str, Dict[str, str]]
+    certs: Dict[str, Dict[bytes, Any]]
+    log: Any
+
+    def __init__(
+        self,
+        context: Optional["zmq.Context"] = None,
+        encoding: str = 'utf-8',
+        log: Any = None,
+    ):
+        _check_version((4, 0), "security")
+        self.context = context or zmq.Context.instance()
+        self.encoding = encoding
+        self.allow_any = False
+        self.credentials_providers = {}
+        self.zap_socket = None  # type: ignore
+        self._allowed = set()
+        self._denied = set()
+        # passwords is a dict keyed by domain and contains values
+        # of dicts with username:password pairs.
+        self.passwords = {}
+        # certs is dict keyed by domain and contains values
+        # of dicts keyed by the public keys from the specified location.
+        self.certs = {}
+        self.log = log or logging.getLogger('zmq.auth')
+
+    def start(self) -> None:
+        """Create and bind the ZAP socket"""
+        self.zap_socket = self.context.socket(zmq.REP, socket_class=zmq.Socket)
+        self.zap_socket.linger = 1
+        self.zap_socket.bind("inproc://zeromq.zap.01")
+        self.log.debug("Starting")
+
+    def stop(self) -> None:
+        """Close the ZAP socket"""
+        if self.zap_socket:
+            self.zap_socket.close()
+        self.zap_socket = None  # type: ignore
+
+    def allow(self, *addresses: str) -> None:
+        """Allow IP address(es).
+
+        Connections from addresses not explicitly allowed will be rejected.
+
+        - For NULL, all clients from this address will be accepted.
+        - For real auth setups, they will be allowed to continue with authentication.
+
+        allow is mutually exclusive with deny.
+        """
+        if self._denied:
+            raise ValueError("Only use allow or deny, not both")
+        self.log.debug("Allowing %s", ','.join(addresses))
+        self._allowed.update(addresses)
+
+    def deny(self, *addresses: str) -> None:
+        """Deny IP address(es).
+
+        Addresses not explicitly denied will be allowed to continue with authentication.
+
+        deny is mutually exclusive with allow.
+        """
+        if self._allowed:
+            raise ValueError("Only use a allow or deny, not both")
+        self.log.debug("Denying %s", ','.join(addresses))
+        self._denied.update(addresses)
+
+    def configure_plain(
+        self, domain: str = '*', passwords: Optional[Dict[str, str]] = None
+    ) -> None:
+        """Configure PLAIN authentication for a given domain.
+
+        PLAIN authentication uses a plain-text password file.
+        To cover all domains, use "*".
+        You can modify the password file at any time; it is reloaded automatically.
+        """
+        if passwords:
+            self.passwords[domain] = passwords
+        self.log.debug("Configure plain: %s", domain)
+
+    def configure_curve(
+        self, domain: str = '*', location: Union[str, os.PathLike] = "."
+    ) -> None:
+        """Configure CURVE authentication for a given domain.
+
+        CURVE authentication uses a directory that holds all public client certificates,
+        i.e. their public keys.
+
+        To cover all domains, use "*".
+
+        You can add and remove certificates in that directory at any time. configure_curve must be called
+        every time certificates are added or removed, in order to update the Authenticator's state
+
+        To allow all client keys without checking, specify CURVE_ALLOW_ANY for the location.
+        """
+        # If location is CURVE_ALLOW_ANY then allow all clients. Otherwise
+        # treat location as a directory that holds the certificates.
+        self.log.debug("Configure curve: %s[%s]", domain, location)
+        if location == CURVE_ALLOW_ANY:
+            self.allow_any = True
+        else:
+            self.allow_any = False
+            try:
+                self.certs[domain] = load_certificates(location)
+            except Exception as e:
+                self.log.error("Failed to load CURVE certs from %s: %s", location, e)
+
+    def configure_curve_callback(
+        self, domain: str = '*', credentials_provider: Any = None
+    ) -> None:
+        """Configure CURVE authentication for a given domain.
+
+        CURVE authentication using a callback function validating
+        the client public key according to a custom mechanism, e.g. checking the
+        key against records in a db. credentials_provider is an object of a class which
+        implements a callback method accepting two parameters (domain and key), e.g.::
+
+            class CredentialsProvider(object):
+
+                def __init__(self):
+                    ...e.g. db connection
+
+                def callback(self, domain, key):
+                    valid = ...lookup key and/or domain in db
+                    if valid:
+                        logging.info('Authorizing: {0}, {1}'.format(domain, key))
+                        return True
+                    else:
+                        logging.warning('NOT Authorizing: {0}, {1}'.format(domain, key))
+                        return False
+
+        To cover all domains, use "*".
+        """
+
+        self.allow_any = False
+
+        if credentials_provider is not None:
+            self.credentials_providers[domain] = credentials_provider
+        else:
+            self.log.error("None credentials_provider provided for domain:%s", domain)
+
+    def curve_user_id(self, client_public_key: bytes) -> str:
+        """Return the User-Id corresponding to a CURVE client's public key
+
+        Default implementation uses the z85-encoding of the public key.
+
+        Override to define a custom mapping of public key : user-id
+
+        This is only called on successful authentication.
+
+        Parameters
+        ----------
+        client_public_key: bytes
+            The client public key used for the given message
+
+        Returns
+        -------
+        user_id: unicode
+            The user ID as text
+        """
+        return z85.encode(client_public_key).decode('ascii')
+
+    def configure_gssapi(
+        self, domain: str = '*', location: Optional[str] = None
+    ) -> None:
+        """Configure GSSAPI authentication
+
+        Currently this is a no-op because there is nothing to configure with GSSAPI.
+        """
+
+    async def handle_zap_message(self, msg: List[bytes]):
+        """Perform ZAP authentication"""
+        if len(msg) < 6:
+            self.log.error("Invalid ZAP message, not enough frames: %r", msg)
+            if len(msg) < 2:
+                self.log.error("Not enough information to reply")
+            else:
+                self._send_zap_reply(msg[1], b"400", b"Not enough frames")
+            return
+
+        version, request_id, domain, address, identity, mechanism = msg[:6]
+        credentials = msg[6:]
+
+        domain = domain.decode(self.encoding, 'replace')
+        address = address.decode(self.encoding, 'replace')
+
+        if version != VERSION:
+            self.log.error("Invalid ZAP version: %r", msg)
+            self._send_zap_reply(request_id, b"400", b"Invalid version")
+            return
+
+        self.log.debug(
+            "version: %r, request_id: %r, domain: %r,"
+            " address: %r, identity: %r, mechanism: %r",
+            version,
+            request_id,
+            domain,
+            address,
+            identity,
+            mechanism,
+        )
+
+        # Is address is explicitly allowed or _denied?
+        allowed = False
+        denied = False
+        reason = b"NO ACCESS"
+
+        if self._allowed:
+            if address in self._allowed:
+                allowed = True
+                self.log.debug("PASSED (allowed) address=%s", address)
+            else:
+                denied = True
+                reason = b"Address not allowed"
+                self.log.debug("DENIED (not allowed) address=%s", address)
+
+        elif self._denied:
+            if address in self._denied:
+                denied = True
+                reason = b"Address denied"
+                self.log.debug("DENIED (denied) address=%s", address)
+            else:
+                allowed = True
+                self.log.debug("PASSED (not denied) address=%s", address)
+
+        # Perform authentication mechanism-specific checks if necessary
+        username = "anonymous"
+        if not denied:
+            if mechanism == b'NULL' and not allowed:
+                # For NULL, we allow if the address wasn't denied
+                self.log.debug("ALLOWED (NULL)")
+                allowed = True
+
+            elif mechanism == b'PLAIN':
+                # For PLAIN, even a _alloweded address must authenticate
+                if len(credentials) != 2:
+                    self.log.error("Invalid PLAIN credentials: %r", credentials)
+                    self._send_zap_reply(request_id, b"400", b"Invalid credentials")
+                    return
+                username, password = (
+                    c.decode(self.encoding, 'replace') for c in credentials
+                )
+                allowed, reason = self._authenticate_plain(domain, username, password)
+
+            elif mechanism == b'CURVE':
+                # For CURVE, even a _alloweded address must authenticate
+                if len(credentials) != 1:
+                    self.log.error("Invalid CURVE credentials: %r", credentials)
+                    self._send_zap_reply(request_id, b"400", b"Invalid credentials")
+                    return
+                key = credentials[0]
+                allowed, reason = await self._authenticate_curve(domain, key)
+                if allowed:
+                    username = self.curve_user_id(key)
+
+            elif mechanism == b'GSSAPI':
+                if len(credentials) != 1:
+                    self.log.error("Invalid GSSAPI credentials: %r", credentials)
+                    self._send_zap_reply(request_id, b"400", b"Invalid credentials")
+                    return
+                # use principal as user-id for now
+                principal = credentials[0]
+                username = principal.decode("utf8")
+                allowed, reason = self._authenticate_gssapi(domain, principal)
+
+        if allowed:
+            self._send_zap_reply(request_id, b"200", b"OK", username)
+        else:
+            self._send_zap_reply(request_id, b"400", reason)
+
+    def _authenticate_plain(
+        self, domain: str, username: str, password: str
+    ) -> Tuple[bool, bytes]:
+        """PLAIN ZAP authentication"""
+        allowed = False
+        reason = b""
+        if self.passwords:
+            # If no domain is not specified then use the default domain
+            if not domain:
+                domain = '*'
+
+            if domain in self.passwords:
+                if username in self.passwords[domain]:
+                    if password == self.passwords[domain][username]:
+                        allowed = True
+                    else:
+                        reason = b"Invalid password"
+                else:
+                    reason = b"Invalid username"
+            else:
+                reason = b"Invalid domain"
+
+            if allowed:
+                self.log.debug(
+                    "ALLOWED (PLAIN) domain=%s username=%s password=%s",
+                    domain,
+                    username,
+                    password,
+                )
+            else:
+                self.log.debug("DENIED %s", reason)
+
+        else:
+            reason = b"No passwords defined"
+            self.log.debug("DENIED (PLAIN) %s", reason)
+
+        return allowed, reason
+
+    async def _authenticate_curve(
+        self, domain: str, client_key: bytes
+    ) -> Tuple[bool, bytes]:
+        """CURVE ZAP authentication"""
+        allowed = False
+        reason = b""
+        if self.allow_any:
+            allowed = True
+            reason = b"OK"
+            self.log.debug("ALLOWED (CURVE allow any client)")
+        elif self.credentials_providers != {}:
+            # If no explicit domain is specified then use the default domain
+            if not domain:
+                domain = '*'
+
+            if domain in self.credentials_providers:
+                z85_client_key = z85.encode(client_key)
+                # Callback to check if key is Allowed
+                r = self.credentials_providers[domain].callback(domain, z85_client_key)
+                if isinstance(r, Awaitable):
+                    r = await r
+                if r:
+                    allowed = True
+                    reason = b"OK"
+                else:
+                    reason = b"Unknown key"
+
+                status = "ALLOWED" if allowed else "DENIED"
+                self.log.debug(
+                    "%s (CURVE auth_callback) domain=%s client_key=%s",
+                    status,
+                    domain,
+                    z85_client_key,
+                )
+            else:
+                reason = b"Unknown domain"
+        else:
+            # If no explicit domain is specified then use the default domain
+            if not domain:
+                domain = '*'
+
+            if domain in self.certs:
+                # The certs dict stores keys in z85 format, convert binary key to z85 bytes
+                z85_client_key = z85.encode(client_key)
+                if self.certs[domain].get(z85_client_key):
+                    allowed = True
+                    reason = b"OK"
+                else:
+                    reason = b"Unknown key"
+
+                status = "ALLOWED" if allowed else "DENIED"
+                self.log.debug(
+                    "%s (CURVE) domain=%s client_key=%s",
+                    status,
+                    domain,
+                    z85_client_key,
+                )
+            else:
+                reason = b"Unknown domain"
+
+        return allowed, reason
+
+    def _authenticate_gssapi(self, domain: str, principal: bytes) -> Tuple[bool, bytes]:
+        """Nothing to do for GSSAPI, which has already been handled by an external service."""
+        self.log.debug("ALLOWED (GSSAPI) domain=%s principal=%s", domain, principal)
+        return True, b'OK'
+
+    def _send_zap_reply(
+        self,
+        request_id: bytes,
+        status_code: bytes,
+        status_text: bytes,
+        user_id: str = 'anonymous',
+    ) -> None:
+        """Send a ZAP reply to finish the authentication."""
+        user_id = user_id if status_code == b'200' else b''
+        if isinstance(user_id, str):
+            user_id = user_id.encode(self.encoding, 'replace')
+        metadata = b''  # not currently used
+        self.log.debug("ZAP reply code=%s text=%s", status_code, status_text)
+        reply = [VERSION, request_id, status_code, status_text, user_id, metadata]
+        self.zap_socket.send_multipart(reply)
+
+
+__all__ = ['Authenticator', 'CURVE_ALLOW_ANY']

.venv/lib/python3.11/site-packages/zmq/auth/certs.py

@@ -0,0 +1,140 @@
+"""0MQ authentication related functions and classes."""
+
+# Copyright (C) PyZMQ Developers
+# Distributed under the terms of the Modified BSD License.
+
+import datetime
+import glob
+import os
+from typing import Dict, Optional, Tuple, Union
+
+import zmq
+
+_cert_secret_banner = """#   ****  Generated on {0} by pyzmq  ****
+#   ZeroMQ CURVE **Secret** Certificate
+#   DO NOT PROVIDE THIS FILE TO OTHER USERS nor change its permissions.
+
+"""
+
+
+_cert_public_banner = """#   ****  Generated on {0} by pyzmq  ****
+#   ZeroMQ CURVE Public Certificate
+#   Exchange securely, or use a secure mechanism to verify the contents
+#   of this file after exchange. Store public certificates in your home
+#   directory, in the .curve subdirectory.
+
+"""
+
+
+def _write_key_file(
+    key_filename: Union[str, os.PathLike],
+    banner: str,
+    public_key: Union[str, bytes],
+    secret_key: Optional[Union[str, bytes]] = None,
+    metadata: Optional[Dict[str, str]] = None,
+    encoding: str = 'utf-8',
+) -> None:
+    """Create a certificate file"""
+    if isinstance(public_key, bytes):
+        public_key = public_key.decode(encoding)
+    if isinstance(secret_key, bytes):
+        secret_key = secret_key.decode(encoding)
+    with open(key_filename, 'w', encoding='utf8') as f:
+        f.write(banner.format(datetime.datetime.now()))
+
+        f.write('metadata\n')
+        if metadata:
+            for k, v in metadata.items():
+                if isinstance(k, bytes):
+                    k = k.decode(encoding)
+                if isinstance(v, bytes):
+                    v = v.decode(encoding)
+                f.write(f"    {k} = {v}\n")
+
+        f.write('curve\n')
+        f.write(f"    public-key = \"{public_key}\"\n")
+
+        if secret_key:
+            f.write(f"    secret-key = \"{secret_key}\"\n")
+
+
+def create_certificates(
+    key_dir: Union[str, os.PathLike],
+    name: str,
+    metadata: Optional[Dict[str, str]] = None,
+) -> Tuple[str, str]:
+    """Create zmq certificates.
+
+    Returns the file paths to the public and secret certificate files.
+    """
+    public_key, secret_key = zmq.curve_keypair()
+    base_filename = os.path.join(key_dir, name)
+    secret_key_file = f"{base_filename}.key_secret"
+    public_key_file = f"{base_filename}.key"
+    now = datetime.datetime.now()
+
+    _write_key_file(public_key_file, _cert_public_banner.format(now), public_key)
+
+    _write_key_file(
+        secret_key_file,
+        _cert_secret_banner.format(now),
+        public_key,
+        secret_key=secret_key,
+        metadata=metadata,
+    )
+
+    return public_key_file, secret_key_file
+
+
+def load_certificate(
+    filename: Union[str, os.PathLike],
+) -> Tuple[bytes, Optional[bytes]]:
+    """Load public and secret key from a zmq certificate.
+
+    Returns (public_key, secret_key)
+
+    If the certificate file only contains the public key,
+    secret_key will be None.
+
+    If there is no public key found in the file, ValueError will be raised.
+    """
+    public_key = None
+    secret_key = None
+    if not os.path.exists(filename):
+        raise OSError(f"Invalid certificate file: {filename}")
+
+    with open(filename, 'rb') as f:
+        for line in f:
+            line = line.strip()
+            if line.startswith(b'#'):
+                continue
+            if line.startswith(b'public-key'):
+                public_key = line.split(b"=", 1)[1].strip(b' \t\'"')
+            if line.startswith(b'secret-key'):
+                secret_key = line.split(b"=", 1)[1].strip(b' \t\'"')
+            if public_key and secret_key:
+                break
+
+    if public_key is None:
+        raise ValueError(f"No public key found in {filename}")
+
+    return public_key, secret_key
+
+
+def load_certificates(directory: Union[str, os.PathLike] = '.') -> Dict[bytes, bool]:
+    """Load public keys from all certificates in a directory"""
+    certs = {}
+    if not os.path.isdir(directory):
+        raise OSError(f"Invalid certificate directory: {directory}")
+    # Follow czmq pattern of public keys stored in *.key files.
+    glob_string = os.path.join(directory, "*.key")
+
+    cert_files = glob.glob(glob_string)
+    for cert_file in cert_files:
+        public_key, _ = load_certificate(cert_file)
+        if public_key:
+            certs[public_key] = True
+    return certs
+
+
+__all__ = ['create_certificates', 'load_certificate', 'load_certificates']

.venv/lib/python3.11/site-packages/zmq/auth/ioloop.py

@@ -0,0 +1,48 @@
+"""ZAP Authenticator integrated with the tornado IOLoop.
+
+.. versionadded:: 14.1
+.. deprecated:: 25
+    Use asyncio.AsyncioAuthenticator instead.
+    Since tornado runs on asyncio, the asyncio authenticator
+    offers the same functionality in tornado.
+"""
+
+import warnings
+
+# Copyright (C) PyZMQ Developers
+# Distributed under the terms of the Modified BSD License.
+from typing import Any, Optional
+
+import zmq
+
+from .asyncio import AsyncioAuthenticator
+
+warnings.warn(
+    "zmq.auth.ioloop.IOLoopAuthenticator is deprecated. Use zmq.auth.asyncio.AsyncioAuthenticator",
+    DeprecationWarning,
+    stacklevel=2,
+)
+
+
+class IOLoopAuthenticator(AsyncioAuthenticator):
+    """ZAP authentication for use in the tornado IOLoop"""
+
+    def __init__(
+        self,
+        context: Optional["zmq.Context"] = None,
+        encoding: str = 'utf-8',
+        log: Any = None,
+        io_loop: Any = None,
+    ):
+        loop = None
+        if io_loop is not None:
+            warnings.warn(
+                f"{self.__class__.__name__}(io_loop) is deprecated and ignored",
+                DeprecationWarning,
+                stacklevel=2,
+            )
+            loop = io_loop.asyncio_loop
+        super().__init__(context=context, encoding=encoding, log=log, loop=loop)
+
+
+__all__ = ['IOLoopAuthenticator']

.venv/lib/python3.11/site-packages/zmq/auth/thread.py

@@ -0,0 +1,139 @@
+"""ZAP Authenticator in a Python Thread.
+
+.. versionadded:: 14.1
+"""
+
+# Copyright (C) PyZMQ Developers
+# Distributed under the terms of the Modified BSD License.
+
+import asyncio
+from threading import Event, Thread
+from typing import Any, List, Optional
+
+import zmq
+import zmq.asyncio
+
+from .base import Authenticator
+
+
+class AuthenticationThread(Thread):
+    """A Thread for running a zmq Authenticator
+
+    This is run in the background by ThreadAuthenticator
+    """
+
+    pipe: zmq.Socket
+    loop: asyncio.AbstractEventLoop
+    authenticator: Authenticator
+    poller: Optional[zmq.asyncio.Poller] = None
+
+    def __init__(
+        self,
+        authenticator: Authenticator,
+        pipe: zmq.Socket,
+    ) -> None:
+        super().__init__(daemon=True)
+        self.authenticator = authenticator
+        self.log = authenticator.log
+        self.pipe = pipe
+
+        self.started = Event()
+
+    def run(self) -> None:
+        """Start the Authentication Agent thread task"""
+
+        loop = asyncio.new_event_loop()
+        try:
+            loop.run_until_complete(self._run())
+        finally:
+            if self.pipe:
+                self.pipe.close()
+                self.pipe = None  # type: ignore
+
+            loop.close()
+
+    async def _run(self):
+        self.poller = zmq.asyncio.Poller()
+        self.poller.register(self.pipe, zmq.POLLIN)
+        self.poller.register(self.authenticator.zap_socket, zmq.POLLIN)
+        self.started.set()
+
+        while True:
+            events = dict(await self.poller.poll())
+            if self.pipe in events:
+                msg = self.pipe.recv_multipart()
+                if self._handle_pipe_message(msg):
+                    return
+            if self.authenticator.zap_socket in events:
+                msg = self.authenticator.zap_socket.recv_multipart()
+                await self.authenticator.handle_zap_message(msg)
+
+    def _handle_pipe_message(self, msg: List[bytes]) -> bool:
+        command = msg[0]
+        self.log.debug("auth received API command %r", command)
+
+        if command == b'TERMINATE':
+            return True
+
+        else:
+            self.log.error("Invalid auth command from API: %r", command)
+            self.pipe.send(b'ERROR')
+
+        return False
+
+
+class ThreadAuthenticator(Authenticator):
+    """Run ZAP authentication in a background thread"""
+
+    pipe: "zmq.Socket"
+    pipe_endpoint: str = ''
+    thread: AuthenticationThread
+
+    def __init__(
+        self,
+        context: Optional["zmq.Context"] = None,
+        encoding: str = 'utf-8',
+        log: Any = None,
+    ):
+        super().__init__(context=context, encoding=encoding, log=log)
+        self.pipe = None  # type: ignore
+        self.pipe_endpoint = f"inproc://{id(self)}.inproc"
+        self.thread = None  # type: ignore
+
+    def start(self) -> None:
+        """Start the authentication thread"""
+        # start the Authenticator
+        super().start()
+
+        # create a socket pair to communicate with auth thread.
+        self.pipe = self.context.socket(zmq.PAIR, socket_class=zmq.Socket)
+        self.pipe.linger = 1
+        self.pipe.bind(self.pipe_endpoint)
+        thread_pipe = self.context.socket(zmq.PAIR, socket_class=zmq.Socket)
+        thread_pipe.linger = 1
+        thread_pipe.connect(self.pipe_endpoint)
+        self.thread = AuthenticationThread(authenticator=self, pipe=thread_pipe)
+        self.thread.start()
+        if not self.thread.started.wait(timeout=10):
+            raise RuntimeError("Authenticator thread failed to start")
+
+    def stop(self) -> None:
+        """Stop the authentication thread"""
+        if self.pipe:
+            self.pipe.send(b'TERMINATE')
+            if self.is_alive():
+                self.thread.join()
+            self.thread = None  # type: ignore
+            self.pipe.close()
+            self.pipe = None  # type: ignore
+        super().stop()
+
+    def is_alive(self) -> bool:
+        """Is the ZAP thread currently running?"""
+        return bool(self.thread and self.thread.is_alive())
+
+    def __del__(self) -> None:
+        self.stop()
+
+
+__all__ = ['ThreadAuthenticator']

.venv/lib/python3.11/site-packages/zmq/constants.py

@@ -0,0 +1,974 @@
+"""zmq constants as enums"""
+
+from __future__ import annotations
+
+import errno
+import sys
+from enum import Enum, IntEnum, IntFlag
+
+_HAUSNUMERO = 156384712
+
+
+class Errno(IntEnum):
+    """libzmq error codes
+
+    .. versionadded:: 23
+    """
+
+    EAGAIN = errno.EAGAIN
+    EFAULT = errno.EFAULT
+    EINVAL = errno.EINVAL
+
+    if sys.platform.startswith("win"):
+        # Windows: libzmq uses errno.h
+        # while Python errno prefers WSA* variants
+        # many of these were introduced to errno.h in vs2010
+        # ref: https://github.com/python/cpython/blob/3.9/Modules/errnomodule.c#L10-L37
+        # source: https://docs.microsoft.com/en-us/cpp/c-runtime-library/errno-constants
+        ENOTSUP = 129
+        EPROTONOSUPPORT = 135
+        ENOBUFS = 119
+        ENETDOWN = 116
+        EADDRINUSE = 100
+        EADDRNOTAVAIL = 101
+        ECONNREFUSED = 107
+        EINPROGRESS = 112
+        ENOTSOCK = 128
+        EMSGSIZE = 115
+        EAFNOSUPPORT = 102
+        ENETUNREACH = 118
+        ECONNABORTED = 106
+        ECONNRESET = 108
+        ENOTCONN = 126
+        ETIMEDOUT = 138
+        EHOSTUNREACH = 110
+        ENETRESET = 117
+
+    else:
+        ENOTSUP = getattr(errno, "ENOTSUP", _HAUSNUMERO + 1)
+        EPROTONOSUPPORT = getattr(errno, "EPROTONOSUPPORT", _HAUSNUMERO + 2)
+        ENOBUFS = getattr(errno, "ENOBUFS", _HAUSNUMERO + 3)
+        ENETDOWN = getattr(errno, "ENETDOWN", _HAUSNUMERO + 4)
+        EADDRINUSE = getattr(errno, "EADDRINUSE", _HAUSNUMERO + 5)
+        EADDRNOTAVAIL = getattr(errno, "EADDRNOTAVAIL", _HAUSNUMERO + 6)
+        ECONNREFUSED = getattr(errno, "ECONNREFUSED", _HAUSNUMERO + 7)
+        EINPROGRESS = getattr(errno, "EINPROGRESS", _HAUSNUMERO + 8)
+        ENOTSOCK = getattr(errno, "ENOTSOCK", _HAUSNUMERO + 9)
+        EMSGSIZE = getattr(errno, "EMSGSIZE", _HAUSNUMERO + 10)
+        EAFNOSUPPORT = getattr(errno, "EAFNOSUPPORT", _HAUSNUMERO + 11)
+        ENETUNREACH = getattr(errno, "ENETUNREACH", _HAUSNUMERO + 12)
+        ECONNABORTED = getattr(errno, "ECONNABORTED", _HAUSNUMERO + 13)
+        ECONNRESET = getattr(errno, "ECONNRESET", _HAUSNUMERO + 14)
+        ENOTCONN = getattr(errno, "ENOTCONN", _HAUSNUMERO + 15)
+        ETIMEDOUT = getattr(errno, "ETIMEDOUT", _HAUSNUMERO + 16)
+        EHOSTUNREACH = getattr(errno, "EHOSTUNREACH", _HAUSNUMERO + 17)
+        ENETRESET = getattr(errno, "ENETRESET", _HAUSNUMERO + 18)
+
+    # Native 0MQ error codes
+    EFSM = _HAUSNUMERO + 51
+    ENOCOMPATPROTO = _HAUSNUMERO + 52
+    ETERM = _HAUSNUMERO + 53
+    EMTHREAD = _HAUSNUMERO + 54
+
+
+class ContextOption(IntEnum):
+    """Options for Context.get/set
+
+    .. versionadded:: 23
+    """
+
+    IO_THREADS = 1
+    MAX_SOCKETS = 2
+    SOCKET_LIMIT = 3
+    THREAD_PRIORITY = 3
+    THREAD_SCHED_POLICY = 4
+    MAX_MSGSZ = 5
+    MSG_T_SIZE = 6
+    THREAD_AFFINITY_CPU_ADD = 7
+    THREAD_AFFINITY_CPU_REMOVE = 8
+    THREAD_NAME_PREFIX = 9
+
+
+class SocketType(IntEnum):
+    """zmq socket types
+
+    .. versionadded:: 23
+    """
+
+    PAIR = 0
+    PUB = 1
+    SUB = 2
+    REQ = 3
+    REP = 4
+    DEALER = 5
+    ROUTER = 6
+    PULL = 7
+    PUSH = 8
+    XPUB = 9
+    XSUB = 10
+    STREAM = 11
+
+    # deprecated aliases
+    XREQ = DEALER
+    XREP = ROUTER
+
+    # DRAFT socket types
+    SERVER = 12
+    CLIENT = 13
+    RADIO = 14
+    DISH = 15
+    GATHER = 16
+    SCATTER = 17
+    DGRAM = 18
+    PEER = 19
+    CHANNEL = 20
+
+
+class _OptType(Enum):
+    int = 'int'
+    int64 = 'int64'
+    bytes = 'bytes'
+    fd = 'fd'
+
+
+class SocketOption(IntEnum):
+    """Options for Socket.get/set
+
+    .. versionadded:: 23
+    """
+
+    _opt_type: _OptType
+
+    def __new__(cls, value: int, opt_type: _OptType = _OptType.int):
+        """Attach option type as `._opt_type`"""
+        obj = int.__new__(cls, value)
+        obj._value_ = value
+        obj._opt_type = opt_type
+        return obj
+
+    HWM = 1
+    AFFINITY = 4, _OptType.int64
+    ROUTING_ID = 5, _OptType.bytes
+    SUBSCRIBE = 6, _OptType.bytes
+    UNSUBSCRIBE = 7, _OptType.bytes
+    RATE = 8
+    RECOVERY_IVL = 9
+    SNDBUF = 11
+    RCVBUF = 12
+    RCVMORE = 13
+    FD = 14, _OptType.fd
+    EVENTS = 15
+    TYPE = 16
+    LINGER = 17
+    RECONNECT_IVL = 18
+    BACKLOG = 19
+    RECONNECT_IVL_MAX = 21
+    MAXMSGSIZE = 22, _OptType.int64
+    SNDHWM = 23
+    RCVHWM = 24
+    MULTICAST_HOPS = 25
+    RCVTIMEO = 27
+    SNDTIMEO = 28
+    LAST_ENDPOINT = 32, _OptType.bytes
+    ROUTER_MANDATORY = 33
+    TCP_KEEPALIVE = 34
+    TCP_KEEPALIVE_CNT = 35
+    TCP_KEEPALIVE_IDLE = 36
+    TCP_KEEPALIVE_INTVL = 37
+    IMMEDIATE = 39
+    XPUB_VERBOSE = 40
+    ROUTER_RAW = 41
+    IPV6 = 42
+    MECHANISM = 43
+    PLAIN_SERVER = 44
+    PLAIN_USERNAME = 45, _OptType.bytes
+    PLAIN_PASSWORD = 46, _OptType.bytes
+    CURVE_SERVER = 47
+    CURVE_PUBLICKEY = 48, _OptType.bytes
+    CURVE_SECRETKEY = 49, _OptType.bytes
+    CURVE_SERVERKEY = 50, _OptType.bytes
+    PROBE_ROUTER = 51
+    REQ_CORRELATE = 52
+    REQ_RELAXED = 53
+    CONFLATE = 54
+    ZAP_DOMAIN = 55, _OptType.bytes
+    ROUTER_HANDOVER = 56
+    TOS = 57
+    CONNECT_ROUTING_ID = 61, _OptType.bytes
+    GSSAPI_SERVER = 62
+    GSSAPI_PRINCIPAL = 63, _OptType.bytes
+    GSSAPI_SERVICE_PRINCIPAL = 64, _OptType.bytes
+    GSSAPI_PLAINTEXT = 65
+    HANDSHAKE_IVL = 66
+    SOCKS_PROXY = 68, _OptType.bytes
+    XPUB_NODROP = 69
+    BLOCKY = 70
+    XPUB_MANUAL = 71
+    XPUB_WELCOME_MSG = 72, _OptType.bytes
+    STREAM_NOTIFY = 73
+    INVERT_MATCHING = 74
+    HEARTBEAT_IVL = 75
+    HEARTBEAT_TTL = 76
+    HEARTBEAT_TIMEOUT = 77
+    XPUB_VERBOSER = 78
+    CONNECT_TIMEOUT = 79
+    TCP_MAXRT = 80
+    THREAD_SAFE = 81
+    MULTICAST_MAXTPDU = 84
+    VMCI_BUFFER_SIZE = 85, _OptType.int64
+    VMCI_BUFFER_MIN_SIZE = 86, _OptType.int64
+    VMCI_BUFFER_MAX_SIZE = 87, _OptType.int64
+    VMCI_CONNECT_TIMEOUT = 88
+    USE_FD = 89
+    GSSAPI_PRINCIPAL_NAMETYPE = 90
+    GSSAPI_SERVICE_PRINCIPAL_NAMETYPE = 91
+    BINDTODEVICE = 92, _OptType.bytes
+
+    # Deprecated options and aliases
+    # must not use name-assignment, must have the same value
+    IDENTITY = ROUTING_ID
+    CONNECT_RID = CONNECT_ROUTING_ID
+    TCP_ACCEPT_FILTER = 38, _OptType.bytes
+    IPC_FILTER_PID = 58
+    IPC_FILTER_UID = 59
+    IPC_FILTER_GID = 60
+    IPV4ONLY = 31
+    DELAY_ATTACH_ON_CONNECT = IMMEDIATE
+    FAIL_UNROUTABLE = ROUTER_MANDATORY
+    ROUTER_BEHAVIOR = ROUTER_MANDATORY
+
+    # Draft socket options
+    ZAP_ENFORCE_DOMAIN = 93
+    LOOPBACK_FASTPATH = 94
+    METADATA = 95, _OptType.bytes
+    MULTICAST_LOOP = 96
+    ROUTER_NOTIFY = 97
+    XPUB_MANUAL_LAST_VALUE = 98
+    SOCKS_USERNAME = 99, _OptType.bytes
+    SOCKS_PASSWORD = 100, _OptType.bytes
+    IN_BATCH_SIZE = 101
+    OUT_BATCH_SIZE = 102
+    WSS_KEY_PEM = 103, _OptType.bytes
+    WSS_CERT_PEM = 104, _OptType.bytes
+    WSS_TRUST_PEM = 105, _OptType.bytes
+    WSS_HOSTNAME = 106, _OptType.bytes
+    WSS_TRUST_SYSTEM = 107
+    ONLY_FIRST_SUBSCRIBE = 108
+    RECONNECT_STOP = 109
+    HELLO_MSG = 110, _OptType.bytes
+    DISCONNECT_MSG = 111, _OptType.bytes
+    PRIORITY = 112
+    # 4.3.5
+    BUSY_POLL = 113
+    HICCUP_MSG = 114, _OptType.bytes
+    XSUB_VERBOSE_UNSUBSCRIBE = 115
+    TOPICS_COUNT = 116
+    NORM_MODE = 117
+    NORM_UNICAST_NACK = 118
+    NORM_BUFFER_SIZE = 119
+    NORM_SEGMENT_SIZE = 120
+    NORM_BLOCK_SIZE = 121
+    NORM_NUM_PARITY = 122
+    NORM_NUM_AUTOPARITY = 123
+    NORM_PUSH = 124
+
+
+class MessageOption(IntEnum):
+    """Options on zmq.Frame objects
+
+    .. versionadded:: 23
+    """
+
+    MORE = 1
+    SHARED = 3
+    # Deprecated message options
+    SRCFD = 2
+
+
+class Flag(IntFlag):
+    """Send/recv flags
+
+    .. versionadded:: 23
+    """
+
+    DONTWAIT = 1
+    SNDMORE = 2
+    NOBLOCK = DONTWAIT
+
+
+class RouterNotify(IntEnum):
+    """Values for zmq.ROUTER_NOTIFY socket option
+
+    .. versionadded:: 26
+    .. versionadded:: libzmq-4.3.0 (draft)
+    """
+
+    @staticmethod
+    def _global_name(name):
+        return f"NOTIFY_{name}"
+
+    CONNECT = 1
+    DISCONNECT = 2
+
+
+class NormMode(IntEnum):
+    """Values for zmq.NORM_MODE socket option
+
+    .. versionadded:: 26
+    .. versionadded:: libzmq-4.3.5 (draft)
+    """
+
+    @staticmethod
+    def _global_name(name):
+        return f"NORM_{name}"
+
+    FIXED = 0
+    CC = 1
+    CCL = 2
+    CCE = 3
+    CCE_ECNONLY = 4
+
+
+class SecurityMechanism(IntEnum):
+    """Security mechanisms (as returned by ``socket.get(zmq.MECHANISM)``)
+
+    .. versionadded:: 23
+    """
+
+    NULL = 0
+    PLAIN = 1
+    CURVE = 2
+    GSSAPI = 3
+
+
+class ReconnectStop(IntEnum):
+    """Select behavior for socket.reconnect_stop
+
+    .. versionadded:: 25
+    """
+
+    @staticmethod
+    def _global_name(name):
+        return f"RECONNECT_STOP_{name}"
+
+    CONN_REFUSED = 0x1
+    HANDSHAKE_FAILED = 0x2
+    AFTER_DISCONNECT = 0x4
+
+
+class Event(IntFlag):
+    """Socket monitoring events
+
+    .. versionadded:: 23
+    """
+
+    @staticmethod
+    def _global_name(name):
+        if name.startswith("PROTOCOL_ERROR_"):
+            return name
+        else:
+            # add EVENT_ prefix
+            return "EVENT_" + name
+
+    PROTOCOL_ERROR_WS_UNSPECIFIED = 0x30000000
+    PROTOCOL_ERROR_ZMTP_UNSPECIFIED = 0x10000000
+    PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND = 0x10000001
+    PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE = 0x10000002
+    PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE = 0x10000003
+    PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED = 0x10000011
+    PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE = 0x10000012
+    PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO = 0x10000013
+    PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE = 0x10000014
+    PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR = 0x10000015
+    PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY = 0x10000016
+    PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME = 0x10000017
+    PROTOCOL_ERROR_ZMTP_INVALID_METADATA = 0x10000018
+
+    PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC = 0x11000001
+    PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH = 0x11000002
+    PROTOCOL_ERROR_ZAP_UNSPECIFIED = 0x20000000
+    PROTOCOL_ERROR_ZAP_MALFORMED_REPLY = 0x20000001
+    PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID = 0x20000002
+    PROTOCOL_ERROR_ZAP_BAD_VERSION = 0x20000003
+    PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE = 0x20000004
+    PROTOCOL_ERROR_ZAP_INVALID_METADATA = 0x20000005
+
+    # define event types _after_ overlapping protocol error masks
+    CONNECTED = 0x0001
+    CONNECT_DELAYED = 0x0002
+    CONNECT_RETRIED = 0x0004
+    LISTENING = 0x0008
+    BIND_FAILED = 0x0010
+    ACCEPTED = 0x0020
+    ACCEPT_FAILED = 0x0040
+    CLOSED = 0x0080
+    CLOSE_FAILED = 0x0100
+    DISCONNECTED = 0x0200
+    MONITOR_STOPPED = 0x0400
+
+    HANDSHAKE_FAILED_NO_DETAIL = 0x0800
+    HANDSHAKE_SUCCEEDED = 0x1000
+    HANDSHAKE_FAILED_PROTOCOL = 0x2000
+    HANDSHAKE_FAILED_AUTH = 0x4000
+
+    ALL_V1 = 0xFFFF
+    ALL = ALL_V1
+
+    # DRAFT Socket monitoring events
+    PIPES_STATS = 0x10000
+    ALL_V2 = ALL_V1 | PIPES_STATS
+
+
+class PollEvent(IntFlag):
+    """Which events to poll for in poll methods
+
+    .. versionadded: 23
+    """
+
+    POLLIN = 1
+    POLLOUT = 2
+    POLLERR = 4
+    POLLPRI = 8
+
+
+class DeviceType(IntEnum):
+    """Device type constants for zmq.device
+
+    .. versionadded: 23
+    """
+
+    STREAMER = 1
+    FORWARDER = 2
+    QUEUE = 3
+
+
+# AUTOGENERATED_BELOW_HERE
+
+
+IO_THREADS: int = ContextOption.IO_THREADS
+MAX_SOCKETS: int = ContextOption.MAX_SOCKETS
+SOCKET_LIMIT: int = ContextOption.SOCKET_LIMIT
+THREAD_PRIORITY: int = ContextOption.THREAD_PRIORITY
+THREAD_SCHED_POLICY: int = ContextOption.THREAD_SCHED_POLICY
+MAX_MSGSZ: int = ContextOption.MAX_MSGSZ
+MSG_T_SIZE: int = ContextOption.MSG_T_SIZE
+THREAD_AFFINITY_CPU_ADD: int = ContextOption.THREAD_AFFINITY_CPU_ADD
+THREAD_AFFINITY_CPU_REMOVE: int = ContextOption.THREAD_AFFINITY_CPU_REMOVE
+THREAD_NAME_PREFIX: int = ContextOption.THREAD_NAME_PREFIX
+STREAMER: int = DeviceType.STREAMER
+FORWARDER: int = DeviceType.FORWARDER
+QUEUE: int = DeviceType.QUEUE
+EAGAIN: int = Errno.EAGAIN
+EFAULT: int = Errno.EFAULT
+EINVAL: int = Errno.EINVAL
+ENOTSUP: int = Errno.ENOTSUP
+EPROTONOSUPPORT: int = Errno.EPROTONOSUPPORT
+ENOBUFS: int = Errno.ENOBUFS
+ENETDOWN: int = Errno.ENETDOWN
+EADDRINUSE: int = Errno.EADDRINUSE
+EADDRNOTAVAIL: int = Errno.EADDRNOTAVAIL
+ECONNREFUSED: int = Errno.ECONNREFUSED
+EINPROGRESS: int = Errno.EINPROGRESS
+ENOTSOCK: int = Errno.ENOTSOCK
+EMSGSIZE: int = Errno.EMSGSIZE
+EAFNOSUPPORT: int = Errno.EAFNOSUPPORT
+ENETUNREACH: int = Errno.ENETUNREACH
+ECONNABORTED: int = Errno.ECONNABORTED
+ECONNRESET: int = Errno.ECONNRESET
+ENOTCONN: int = Errno.ENOTCONN
+ETIMEDOUT: int = Errno.ETIMEDOUT
+EHOSTUNREACH: int = Errno.EHOSTUNREACH
+ENETRESET: int = Errno.ENETRESET
+EFSM: int = Errno.EFSM
+ENOCOMPATPROTO: int = Errno.ENOCOMPATPROTO
+ETERM: int = Errno.ETERM
+EMTHREAD: int = Errno.EMTHREAD
+PROTOCOL_ERROR_WS_UNSPECIFIED: int = Event.PROTOCOL_ERROR_WS_UNSPECIFIED
+PROTOCOL_ERROR_ZMTP_UNSPECIFIED: int = Event.PROTOCOL_ERROR_ZMTP_UNSPECIFIED
+PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND: int = (
+    Event.PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND
+)
+PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE: int = Event.PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE
+PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE: int = Event.PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE
+PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED: int = (
+    Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED
+)
+PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE: int = (
+    Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE
+)
+PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO: int = (
+    Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO
+)
+PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE: int = (
+    Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE
+)
+PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR: int = (
+    Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR
+)
+PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY: int = (
+    Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY
+)
+PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME: int = (
+    Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME
+)
+PROTOCOL_ERROR_ZMTP_INVALID_METADATA: int = Event.PROTOCOL_ERROR_ZMTP_INVALID_METADATA
+PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC: int = Event.PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC
+PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH: int = (
+    Event.PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH
+)
+PROTOCOL_ERROR_ZAP_UNSPECIFIED: int = Event.PROTOCOL_ERROR_ZAP_UNSPECIFIED
+PROTOCOL_ERROR_ZAP_MALFORMED_REPLY: int = Event.PROTOCOL_ERROR_ZAP_MALFORMED_REPLY
+PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID: int = Event.PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID
+PROTOCOL_ERROR_ZAP_BAD_VERSION: int = Event.PROTOCOL_ERROR_ZAP_BAD_VERSION
+PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE: int = (
+    Event.PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE
+)
+PROTOCOL_ERROR_ZAP_INVALID_METADATA: int = Event.PROTOCOL_ERROR_ZAP_INVALID_METADATA
+EVENT_CONNECTED: int = Event.CONNECTED
+EVENT_CONNECT_DELAYED: int = Event.CONNECT_DELAYED
+EVENT_CONNECT_RETRIED: int = Event.CONNECT_RETRIED
+EVENT_LISTENING: int = Event.LISTENING
+EVENT_BIND_FAILED: int = Event.BIND_FAILED
+EVENT_ACCEPTED: int = Event.ACCEPTED
+EVENT_ACCEPT_FAILED: int = Event.ACCEPT_FAILED
+EVENT_CLOSED: int = Event.CLOSED
+EVENT_CLOSE_FAILED: int = Event.CLOSE_FAILED
+EVENT_DISCONNECTED: int = Event.DISCONNECTED
+EVENT_MONITOR_STOPPED: int = Event.MONITOR_STOPPED
+EVENT_HANDSHAKE_FAILED_NO_DETAIL: int = Event.HANDSHAKE_FAILED_NO_DETAIL
+EVENT_HANDSHAKE_SUCCEEDED: int = Event.HANDSHAKE_SUCCEEDED
+EVENT_HANDSHAKE_FAILED_PROTOCOL: int = Event.HANDSHAKE_FAILED_PROTOCOL
+EVENT_HANDSHAKE_FAILED_AUTH: int = Event.HANDSHAKE_FAILED_AUTH
+EVENT_ALL_V1: int = Event.ALL_V1
+EVENT_ALL: int = Event.ALL
+EVENT_PIPES_STATS: int = Event.PIPES_STATS
+EVENT_ALL_V2: int = Event.ALL_V2
+DONTWAIT: int = Flag.DONTWAIT
+SNDMORE: int = Flag.SNDMORE
+NOBLOCK: int = Flag.NOBLOCK
+MORE: int = MessageOption.MORE
+SHARED: int = MessageOption.SHARED
+SRCFD: int = MessageOption.SRCFD
+NORM_FIXED: int = NormMode.FIXED
+NORM_CC: int = NormMode.CC
+NORM_CCL: int = NormMode.CCL
+NORM_CCE: int = NormMode.CCE
+NORM_CCE_ECNONLY: int = NormMode.CCE_ECNONLY
+POLLIN: int = PollEvent.POLLIN
+POLLOUT: int = PollEvent.POLLOUT
+POLLERR: int = PollEvent.POLLERR
+POLLPRI: int = PollEvent.POLLPRI
+RECONNECT_STOP_CONN_REFUSED: int = ReconnectStop.CONN_REFUSED
+RECONNECT_STOP_HANDSHAKE_FAILED: int = ReconnectStop.HANDSHAKE_FAILED
+RECONNECT_STOP_AFTER_DISCONNECT: int = ReconnectStop.AFTER_DISCONNECT
+NOTIFY_CONNECT: int = RouterNotify.CONNECT
+NOTIFY_DISCONNECT: int = RouterNotify.DISCONNECT
+NULL: int = SecurityMechanism.NULL
+PLAIN: int = SecurityMechanism.PLAIN
+CURVE: int = SecurityMechanism.CURVE
+GSSAPI: int = SecurityMechanism.GSSAPI
+HWM: int = SocketOption.HWM
+AFFINITY: int = SocketOption.AFFINITY
+ROUTING_ID: int = SocketOption.ROUTING_ID
+SUBSCRIBE: int = SocketOption.SUBSCRIBE
+UNSUBSCRIBE: int = SocketOption.UNSUBSCRIBE
+RATE: int = SocketOption.RATE
+RECOVERY_IVL: int = SocketOption.RECOVERY_IVL
+SNDBUF: int = SocketOption.SNDBUF
+RCVBUF: int = SocketOption.RCVBUF
+RCVMORE: int = SocketOption.RCVMORE
+FD: int = SocketOption.FD
+EVENTS: int = SocketOption.EVENTS
+TYPE: int = SocketOption.TYPE
+LINGER: int = SocketOption.LINGER
+RECONNECT_IVL: int = SocketOption.RECONNECT_IVL
+BACKLOG: int = SocketOption.BACKLOG
+RECONNECT_IVL_MAX: int = SocketOption.RECONNECT_IVL_MAX
+MAXMSGSIZE: int = SocketOption.MAXMSGSIZE
+SNDHWM: int = SocketOption.SNDHWM
+RCVHWM: int = SocketOption.RCVHWM
+MULTICAST_HOPS: int = SocketOption.MULTICAST_HOPS
+RCVTIMEO: int = SocketOption.RCVTIMEO
+SNDTIMEO: int = SocketOption.SNDTIMEO
+LAST_ENDPOINT: int = SocketOption.LAST_ENDPOINT
+ROUTER_MANDATORY: int = SocketOption.ROUTER_MANDATORY
+TCP_KEEPALIVE: int = SocketOption.TCP_KEEPALIVE
+TCP_KEEPALIVE_CNT: int = SocketOption.TCP_KEEPALIVE_CNT
+TCP_KEEPALIVE_IDLE: int = SocketOption.TCP_KEEPALIVE_IDLE
+TCP_KEEPALIVE_INTVL: int = SocketOption.TCP_KEEPALIVE_INTVL
+IMMEDIATE: int = SocketOption.IMMEDIATE
+XPUB_VERBOSE: int = SocketOption.XPUB_VERBOSE
+ROUTER_RAW: int = SocketOption.ROUTER_RAW
+IPV6: int = SocketOption.IPV6
+MECHANISM: int = SocketOption.MECHANISM
+PLAIN_SERVER: int = SocketOption.PLAIN_SERVER
+PLAIN_USERNAME: int = SocketOption.PLAIN_USERNAME
+PLAIN_PASSWORD: int = SocketOption.PLAIN_PASSWORD
+CURVE_SERVER: int = SocketOption.CURVE_SERVER
+CURVE_PUBLICKEY: int = SocketOption.CURVE_PUBLICKEY
+CURVE_SECRETKEY: int = SocketOption.CURVE_SECRETKEY
+CURVE_SERVERKEY: int = SocketOption.CURVE_SERVERKEY
+PROBE_ROUTER: int = SocketOption.PROBE_ROUTER
+REQ_CORRELATE: int = SocketOption.REQ_CORRELATE
+REQ_RELAXED: int = SocketOption.REQ_RELAXED
+CONFLATE: int = SocketOption.CONFLATE
+ZAP_DOMAIN: int = SocketOption.ZAP_DOMAIN
+ROUTER_HANDOVER: int = SocketOption.ROUTER_HANDOVER
+TOS: int = SocketOption.TOS
+CONNECT_ROUTING_ID: int = SocketOption.CONNECT_ROUTING_ID
+GSSAPI_SERVER: int = SocketOption.GSSAPI_SERVER
+GSSAPI_PRINCIPAL: int = SocketOption.GSSAPI_PRINCIPAL
+GSSAPI_SERVICE_PRINCIPAL: int = SocketOption.GSSAPI_SERVICE_PRINCIPAL
+GSSAPI_PLAINTEXT: int = SocketOption.GSSAPI_PLAINTEXT
+HANDSHAKE_IVL: int = SocketOption.HANDSHAKE_IVL
+SOCKS_PROXY: int = SocketOption.SOCKS_PROXY
+XPUB_NODROP: int = SocketOption.XPUB_NODROP
+BLOCKY: int = SocketOption.BLOCKY
+XPUB_MANUAL: int = SocketOption.XPUB_MANUAL
+XPUB_WELCOME_MSG: int = SocketOption.XPUB_WELCOME_MSG
+STREAM_NOTIFY: int = SocketOption.STREAM_NOTIFY
+INVERT_MATCHING: int = SocketOption.INVERT_MATCHING
+HEARTBEAT_IVL: int = SocketOption.HEARTBEAT_IVL
+HEARTBEAT_TTL: int = SocketOption.HEARTBEAT_TTL
+HEARTBEAT_TIMEOUT: int = SocketOption.HEARTBEAT_TIMEOUT
+XPUB_VERBOSER: int = SocketOption.XPUB_VERBOSER
+CONNECT_TIMEOUT: int = SocketOption.CONNECT_TIMEOUT
+TCP_MAXRT: int = SocketOption.TCP_MAXRT
+THREAD_SAFE: int = SocketOption.THREAD_SAFE
+MULTICAST_MAXTPDU: int = SocketOption.MULTICAST_MAXTPDU
+VMCI_BUFFER_SIZE: int = SocketOption.VMCI_BUFFER_SIZE
+VMCI_BUFFER_MIN_SIZE: int = SocketOption.VMCI_BUFFER_MIN_SIZE
+VMCI_BUFFER_MAX_SIZE: int = SocketOption.VMCI_BUFFER_MAX_SIZE
+VMCI_CONNECT_TIMEOUT: int = SocketOption.VMCI_CONNECT_TIMEOUT
+USE_FD: int = SocketOption.USE_FD
+GSSAPI_PRINCIPAL_NAMETYPE: int = SocketOption.GSSAPI_PRINCIPAL_NAMETYPE
+GSSAPI_SERVICE_PRINCIPAL_NAMETYPE: int = SocketOption.GSSAPI_SERVICE_PRINCIPAL_NAMETYPE
+BINDTODEVICE: int = SocketOption.BINDTODEVICE
+IDENTITY: int = SocketOption.IDENTITY
+CONNECT_RID: int = SocketOption.CONNECT_RID
+TCP_ACCEPT_FILTER: int = SocketOption.TCP_ACCEPT_FILTER
+IPC_FILTER_PID: int = SocketOption.IPC_FILTER_PID
+IPC_FILTER_UID: int = SocketOption.IPC_FILTER_UID
+IPC_FILTER_GID: int = SocketOption.IPC_FILTER_GID
+IPV4ONLY: int = SocketOption.IPV4ONLY
+DELAY_ATTACH_ON_CONNECT: int = SocketOption.DELAY_ATTACH_ON_CONNECT
+FAIL_UNROUTABLE: int = SocketOption.FAIL_UNROUTABLE
+ROUTER_BEHAVIOR: int = SocketOption.ROUTER_BEHAVIOR
+ZAP_ENFORCE_DOMAIN: int = SocketOption.ZAP_ENFORCE_DOMAIN
+LOOPBACK_FASTPATH: int = SocketOption.LOOPBACK_FASTPATH
+METADATA: int = SocketOption.METADATA
+MULTICAST_LOOP: int = SocketOption.MULTICAST_LOOP
+ROUTER_NOTIFY: int = SocketOption.ROUTER_NOTIFY
+XPUB_MANUAL_LAST_VALUE: int = SocketOption.XPUB_MANUAL_LAST_VALUE
+SOCKS_USERNAME: int = SocketOption.SOCKS_USERNAME
+SOCKS_PASSWORD: int = SocketOption.SOCKS_PASSWORD
+IN_BATCH_SIZE: int = SocketOption.IN_BATCH_SIZE
+OUT_BATCH_SIZE: int = SocketOption.OUT_BATCH_SIZE
+WSS_KEY_PEM: int = SocketOption.WSS_KEY_PEM
+WSS_CERT_PEM: int = SocketOption.WSS_CERT_PEM
+WSS_TRUST_PEM: int = SocketOption.WSS_TRUST_PEM
+WSS_HOSTNAME: int = SocketOption.WSS_HOSTNAME
+WSS_TRUST_SYSTEM: int = SocketOption.WSS_TRUST_SYSTEM
+ONLY_FIRST_SUBSCRIBE: int = SocketOption.ONLY_FIRST_SUBSCRIBE
+RECONNECT_STOP: int = SocketOption.RECONNECT_STOP
+HELLO_MSG: int = SocketOption.HELLO_MSG
+DISCONNECT_MSG: int = SocketOption.DISCONNECT_MSG
+PRIORITY: int = SocketOption.PRIORITY
+BUSY_POLL: int = SocketOption.BUSY_POLL
+HICCUP_MSG: int = SocketOption.HICCUP_MSG
+XSUB_VERBOSE_UNSUBSCRIBE: int = SocketOption.XSUB_VERBOSE_UNSUBSCRIBE
+TOPICS_COUNT: int = SocketOption.TOPICS_COUNT
+NORM_MODE: int = SocketOption.NORM_MODE
+NORM_UNICAST_NACK: int = SocketOption.NORM_UNICAST_NACK
+NORM_BUFFER_SIZE: int = SocketOption.NORM_BUFFER_SIZE
+NORM_SEGMENT_SIZE: int = SocketOption.NORM_SEGMENT_SIZE
+NORM_BLOCK_SIZE: int = SocketOption.NORM_BLOCK_SIZE
+NORM_NUM_PARITY: int = SocketOption.NORM_NUM_PARITY
+NORM_NUM_AUTOPARITY: int = SocketOption.NORM_NUM_AUTOPARITY
+NORM_PUSH: int = SocketOption.NORM_PUSH
+PAIR: int = SocketType.PAIR
+PUB: int = SocketType.PUB
+SUB: int = SocketType.SUB
+REQ: int = SocketType.REQ
+REP: int = SocketType.REP
+DEALER: int = SocketType.DEALER
+ROUTER: int = SocketType.ROUTER
+PULL: int = SocketType.PULL
+PUSH: int = SocketType.PUSH
+XPUB: int = SocketType.XPUB
+XSUB: int = SocketType.XSUB
+STREAM: int = SocketType.STREAM
+XREQ: int = SocketType.XREQ
+XREP: int = SocketType.XREP
+SERVER: int = SocketType.SERVER
+CLIENT: int = SocketType.CLIENT
+RADIO: int = SocketType.RADIO
+DISH: int = SocketType.DISH
+GATHER: int = SocketType.GATHER
+SCATTER: int = SocketType.SCATTER
+DGRAM: int = SocketType.DGRAM
+PEER: int = SocketType.PEER
+CHANNEL: int = SocketType.CHANNEL
+
+__all__: list[str] = [
+    "ContextOption",
+    "IO_THREADS",
+    "MAX_SOCKETS",
+    "SOCKET_LIMIT",
+    "THREAD_PRIORITY",
+    "THREAD_SCHED_POLICY",
+    "MAX_MSGSZ",
+    "MSG_T_SIZE",
+    "THREAD_AFFINITY_CPU_ADD",
+    "THREAD_AFFINITY_CPU_REMOVE",
+    "THREAD_NAME_PREFIX",
+    "DeviceType",
+    "STREAMER",
+    "FORWARDER",
+    "QUEUE",
+    "Enum",
+    "Errno",
+    "EAGAIN",
+    "EFAULT",
+    "EINVAL",
+    "ENOTSUP",
+    "EPROTONOSUPPORT",
+    "ENOBUFS",
+    "ENETDOWN",
+    "EADDRINUSE",
+    "EADDRNOTAVAIL",
+    "ECONNREFUSED",
+    "EINPROGRESS",
+    "ENOTSOCK",
+    "EMSGSIZE",
+    "EAFNOSUPPORT",
+    "ENETUNREACH",
+    "ECONNABORTED",
+    "ECONNRESET",
+    "ENOTCONN",
+    "ETIMEDOUT",
+    "EHOSTUNREACH",
+    "ENETRESET",
+    "EFSM",
+    "ENOCOMPATPROTO",
+    "ETERM",
+    "EMTHREAD",
+    "Event",
+    "PROTOCOL_ERROR_WS_UNSPECIFIED",
+    "PROTOCOL_ERROR_ZMTP_UNSPECIFIED",
+    "PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND",
+    "PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE",
+    "PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE",
+    "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED",
+    "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE",
+    "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO",
+    "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE",
+    "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR",
+    "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY",
+    "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME",
+    "PROTOCOL_ERROR_ZMTP_INVALID_METADATA",
+    "PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC",
+    "PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH",
+    "PROTOCOL_ERROR_ZAP_UNSPECIFIED",
+    "PROTOCOL_ERROR_ZAP_MALFORMED_REPLY",
+    "PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID",
+    "PROTOCOL_ERROR_ZAP_BAD_VERSION",
+    "PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE",
+    "PROTOCOL_ERROR_ZAP_INVALID_METADATA",
+    "EVENT_CONNECTED",
+    "EVENT_CONNECT_DELAYED",
+    "EVENT_CONNECT_RETRIED",
+    "EVENT_LISTENING",
+    "EVENT_BIND_FAILED",
+    "EVENT_ACCEPTED",
+    "EVENT_ACCEPT_FAILED",
+    "EVENT_CLOSED",
+    "EVENT_CLOSE_FAILED",
+    "EVENT_DISCONNECTED",
+    "EVENT_MONITOR_STOPPED",
+    "EVENT_HANDSHAKE_FAILED_NO_DETAIL",
+    "EVENT_HANDSHAKE_SUCCEEDED",
+    "EVENT_HANDSHAKE_FAILED_PROTOCOL",
+    "EVENT_HANDSHAKE_FAILED_AUTH",
+    "EVENT_ALL_V1",
+    "EVENT_ALL",
+    "EVENT_PIPES_STATS",
+    "EVENT_ALL_V2",
+    "Flag",
+    "DONTWAIT",
+    "SNDMORE",
+    "NOBLOCK",
+    "IntEnum",
+    "IntFlag",
+    "MessageOption",
+    "MORE",
+    "SHARED",
+    "SRCFD",
+    "NormMode",
+    "NORM_FIXED",
+    "NORM_CC",
+    "NORM_CCL",
+    "NORM_CCE",
+    "NORM_CCE_ECNONLY",
+    "PollEvent",
+    "POLLIN",
+    "POLLOUT",
+    "POLLERR",
+    "POLLPRI",
+    "ReconnectStop",
+    "RECONNECT_STOP_CONN_REFUSED",
+    "RECONNECT_STOP_HANDSHAKE_FAILED",
+    "RECONNECT_STOP_AFTER_DISCONNECT",
+    "RouterNotify",
+    "NOTIFY_CONNECT",
+    "NOTIFY_DISCONNECT",
+    "SecurityMechanism",
+    "NULL",
+    "PLAIN",
+    "CURVE",
+    "GSSAPI",
+    "SocketOption",
+    "HWM",
+    "AFFINITY",
+    "ROUTING_ID",
+    "SUBSCRIBE",
+    "UNSUBSCRIBE",
+    "RATE",
+    "RECOVERY_IVL",
+    "SNDBUF",
+    "RCVBUF",
+    "RCVMORE",
+    "FD",
+    "EVENTS",
+    "TYPE",
+    "LINGER",
+    "RECONNECT_IVL",
+    "BACKLOG",
+    "RECONNECT_IVL_MAX",
+    "MAXMSGSIZE",
+    "SNDHWM",
+    "RCVHWM",
+    "MULTICAST_HOPS",
+    "RCVTIMEO",
+    "SNDTIMEO",
+    "LAST_ENDPOINT",
+    "ROUTER_MANDATORY",
+    "TCP_KEEPALIVE",
+    "TCP_KEEPALIVE_CNT",
+    "TCP_KEEPALIVE_IDLE",
+    "TCP_KEEPALIVE_INTVL",
+    "IMMEDIATE",
+    "XPUB_VERBOSE",
+    "ROUTER_RAW",
+    "IPV6",
+    "MECHANISM",
+    "PLAIN_SERVER",
+    "PLAIN_USERNAME",
+    "PLAIN_PASSWORD",
+    "CURVE_SERVER",
+    "CURVE_PUBLICKEY",
+    "CURVE_SECRETKEY",
+    "CURVE_SERVERKEY",
+    "PROBE_ROUTER",
+    "REQ_CORRELATE",
+    "REQ_RELAXED",
+    "CONFLATE",
+    "ZAP_DOMAIN",
+    "ROUTER_HANDOVER",
+    "TOS",
+    "CONNECT_ROUTING_ID",
+    "GSSAPI_SERVER",
+    "GSSAPI_PRINCIPAL",
+    "GSSAPI_SERVICE_PRINCIPAL",
+    "GSSAPI_PLAINTEXT",
+    "HANDSHAKE_IVL",
+    "SOCKS_PROXY",
+    "XPUB_NODROP",
+    "BLOCKY",
+    "XPUB_MANUAL",
+    "XPUB_WELCOME_MSG",
+    "STREAM_NOTIFY",
+    "INVERT_MATCHING",
+    "HEARTBEAT_IVL",
+    "HEARTBEAT_TTL",
+    "HEARTBEAT_TIMEOUT",
+    "XPUB_VERBOSER",
+    "CONNECT_TIMEOUT",
+    "TCP_MAXRT",
+    "THREAD_SAFE",
+    "MULTICAST_MAXTPDU",
+    "VMCI_BUFFER_SIZE",
+    "VMCI_BUFFER_MIN_SIZE",
+    "VMCI_BUFFER_MAX_SIZE",
+    "VMCI_CONNECT_TIMEOUT",
+    "USE_FD",
+    "GSSAPI_PRINCIPAL_NAMETYPE",
+    "GSSAPI_SERVICE_PRINCIPAL_NAMETYPE",
+    "BINDTODEVICE",
+    "IDENTITY",
+    "CONNECT_RID",
+    "TCP_ACCEPT_FILTER",
+    "IPC_FILTER_PID",
+    "IPC_FILTER_UID",
+    "IPC_FILTER_GID",
+    "IPV4ONLY",
+    "DELAY_ATTACH_ON_CONNECT",
+    "FAIL_UNROUTABLE",
+    "ROUTER_BEHAVIOR",
+    "ZAP_ENFORCE_DOMAIN",
+    "LOOPBACK_FASTPATH",
+    "METADATA",
+    "MULTICAST_LOOP",
+    "ROUTER_NOTIFY",
+    "XPUB_MANUAL_LAST_VALUE",
+    "SOCKS_USERNAME",
+    "SOCKS_PASSWORD",
+    "IN_BATCH_SIZE",
+    "OUT_BATCH_SIZE",
+    "WSS_KEY_PEM",
+    "WSS_CERT_PEM",
+    "WSS_TRUST_PEM",
+    "WSS_HOSTNAME",
+    "WSS_TRUST_SYSTEM",
+    "ONLY_FIRST_SUBSCRIBE",
+    "RECONNECT_STOP",
+    "HELLO_MSG",
+    "DISCONNECT_MSG",
+    "PRIORITY",
+    "BUSY_POLL",
+    "HICCUP_MSG",
+    "XSUB_VERBOSE_UNSUBSCRIBE",
+    "TOPICS_COUNT",
+    "NORM_MODE",
+    "NORM_UNICAST_NACK",
+    "NORM_BUFFER_SIZE",
+    "NORM_SEGMENT_SIZE",
+    "NORM_BLOCK_SIZE",
+    "NORM_NUM_PARITY",
+    "NORM_NUM_AUTOPARITY",
+    "NORM_PUSH",
+    "SocketType",
+    "PAIR",
+    "PUB",
+    "SUB",
+    "REQ",
+    "REP",
+    "DEALER",
+    "ROUTER",
+    "PULL",
+    "PUSH",
+    "XPUB",
+    "XSUB",
+    "STREAM",
+    "XREQ",
+    "XREP",
+    "SERVER",
+    "CLIENT",
+    "RADIO",
+    "DISH",
+    "GATHER",
+    "SCATTER",
+    "DGRAM",
+    "PEER",
+    "CHANNEL",
+]

.venv/lib/python3.11/site-packages/zmq/devices/__init__.py

@@ -0,0 +1,28 @@
+"""0MQ Device classes for running in background threads or processes."""
+
+# Copyright (C) PyZMQ Developers
+# Distributed under the terms of the Modified BSD License.
+
+from zmq import device
+from zmq.devices import (
+    basedevice,
+    monitoredqueue,
+    monitoredqueuedevice,
+    proxydevice,
+    proxysteerabledevice,
+)
+from zmq.devices.basedevice import *
+from zmq.devices.monitoredqueue import *
+from zmq.devices.monitoredqueuedevice import *
+from zmq.devices.proxydevice import *
+from zmq.devices.proxysteerabledevice import *
+
+__all__ = ['device']
+for submod in (
+    basedevice,
+    proxydevice,
+    proxysteerabledevice,
+    monitoredqueue,
+    monitoredqueuedevice,
+):
+    __all__.extend(submod.__all__)  # type: ignore

.venv/lib/python3.11/site-packages/zmq/devices/basedevice.py

@@ -0,0 +1,310 @@
+"""Classes for running 0MQ Devices in the background."""
+
+# Copyright (C) PyZMQ Developers
+# Distributed under the terms of the Modified BSD License.
+
+import time
+from multiprocessing import Process
+from threading import Thread
+from typing import Any, Callable, List, Optional, Tuple
+
+import zmq
+from zmq import ENOTSOCK, ETERM, PUSH, QUEUE, Context, ZMQBindError, ZMQError, device
+
+
+class Device:
+    """A 0MQ Device to be run in the background.
+
+    You do not pass Socket instances to this, but rather Socket types::
+
+        Device(device_type, in_socket_type, out_socket_type)
+
+    For instance::
+
+        dev = Device(zmq.QUEUE, zmq.DEALER, zmq.ROUTER)
+
+    Similar to zmq.device, but socket types instead of sockets themselves are
+    passed, and the sockets are created in the work thread, to avoid issues
+    with thread safety. As a result, additional bind_{in|out} and
+    connect_{in|out} methods and setsockopt_{in|out} allow users to specify
+    connections for the sockets.
+
+    Parameters
+    ----------
+    device_type : int
+        The 0MQ Device type
+    {in|out}_type : int
+        zmq socket types, to be passed later to context.socket(). e.g.
+        zmq.PUB, zmq.SUB, zmq.REQ. If out_type is < 0, then in_socket is used
+        for both in_socket and out_socket.
+
+    Methods
+    -------
+    bind_{in_out}(iface)
+        passthrough for ``{in|out}_socket.bind(iface)``, to be called in the thread
+    connect_{in_out}(iface)
+        passthrough for ``{in|out}_socket.connect(iface)``, to be called in the
+        thread
+    setsockopt_{in_out}(opt,value)
+        passthrough for ``{in|out}_socket.setsockopt(opt, value)``, to be called in
+        the thread
+
+    Attributes
+    ----------
+    daemon : bool
+        sets whether the thread should be run as a daemon
+        Default is true, because if it is false, the thread will not
+        exit unless it is killed
+    context_factory : callable
+        This is a class attribute.
+        Function for creating the Context. This will be Context.instance
+        in ThreadDevices, and Context in ProcessDevices.  The only reason
+        it is not instance() in ProcessDevices is that there may be a stale
+        Context instance already initialized, and the forked environment
+        should *never* try to use it.
+    """
+
+    context_factory: Callable[[], zmq.Context] = Context.instance
+    """Callable that returns a context. Typically either Context.instance or Context,
+    depending on whether the device should share the global instance or not.
+    """
+
+    daemon: bool
+    device_type: int
+    in_type: int
+    out_type: int
+
+    _in_binds: List[str]
+    _in_connects: List[str]
+    _in_sockopts: List[Tuple[int, Any]]
+    _out_binds: List[str]
+    _out_connects: List[str]
+    _out_sockopts: List[Tuple[int, Any]]
+    _random_addrs: List[str]
+    _sockets: List[zmq.Socket]
+
+    def __init__(
+        self,
+        device_type: int = QUEUE,
+        in_type: Optional[int] = None,
+        out_type: Optional[int] = None,
+    ) -> None:
+        self.device_type = device_type
+        if in_type is None:
+            raise TypeError("in_type must be specified")
+        if out_type is None:
+            raise TypeError("out_type must be specified")
+        self.in_type = in_type
+        self.out_type = out_type
+        self._in_binds = []
+        self._in_connects = []
+        self._in_sockopts = []
+        self._out_binds = []
+        self._out_connects = []
+        self._out_sockopts = []
+        self._random_addrs = []
+        self.daemon = True
+        self.done = False
+        self._sockets = []
+
+    def bind_in(self, addr: str) -> None:
+        """Enqueue ZMQ address for binding on in_socket.
+
+        See zmq.Socket.bind for details.
+        """
+        self._in_binds.append(addr)
+
+    def bind_in_to_random_port(self, addr: str, *args, **kwargs) -> int:
+        """Enqueue a random port on the given interface for binding on
+        in_socket.
+
+        See zmq.Socket.bind_to_random_port for details.
+
+        .. versionadded:: 18.0
+        """
+        port = self._reserve_random_port(addr, *args, **kwargs)
+
+        self.bind_in(f'{addr}:{port}')
+
+        return port
+
+    def connect_in(self, addr: str) -> None:
+        """Enqueue ZMQ address for connecting on in_socket.
+
+        See zmq.Socket.connect for details.
+        """
+        self._in_connects.append(addr)
+
+    def setsockopt_in(self, opt: int, value: Any) -> None:
+        """Enqueue setsockopt(opt, value) for in_socket
+
+        See zmq.Socket.setsockopt for details.
+        """
+        self._in_sockopts.append((opt, value))
+
+    def bind_out(self, addr: str) -> None:
+        """Enqueue ZMQ address for binding on out_socket.
+
+        See zmq.Socket.bind for details.
+        """
+        self._out_binds.append(addr)
+
+    def bind_out_to_random_port(self, addr: str, *args, **kwargs) -> int:
+        """Enqueue a random port on the given interface for binding on
+        out_socket.
+
+        See zmq.Socket.bind_to_random_port for details.
+
+        .. versionadded:: 18.0
+        """
+        port = self._reserve_random_port(addr, *args, **kwargs)
+
+        self.bind_out(f'{addr}:{port}')
+
+        return port
+
+    def connect_out(self, addr: str):
+        """Enqueue ZMQ address for connecting on out_socket.
+
+        See zmq.Socket.connect for details.
+        """
+        self._out_connects.append(addr)
+
+    def setsockopt_out(self, opt: int, value: Any):
+        """Enqueue setsockopt(opt, value) for out_socket
+
+        See zmq.Socket.setsockopt for details.
+        """
+        self._out_sockopts.append((opt, value))
+
+    def _reserve_random_port(self, addr: str, *args, **kwargs) -> int:
+        with Context() as ctx:
+            with ctx.socket(PUSH) as binder:
+                for i in range(5):
+                    port = binder.bind_to_random_port(addr, *args, **kwargs)
+
+                    new_addr = f'{addr}:{port}'
+
+                    if new_addr in self._random_addrs:
+                        continue
+                    else:
+                        break
+                else:
+                    raise ZMQBindError("Could not reserve random port.")
+
+                self._random_addrs.append(new_addr)
+
+        return port
+
+    def _setup_sockets(self) -> Tuple[zmq.Socket, zmq.Socket]:
+        ctx: zmq.Context[zmq.Socket] = self.context_factory()  # type: ignore
+        self._context = ctx
+
+        # create the sockets
+        ins = ctx.socket(self.in_type)
+        self._sockets.append(ins)
+        if self.out_type < 0:
+            outs = ins
+        else:
+            outs = ctx.socket(self.out_type)
+            self._sockets.append(outs)
+
+        # set sockopts (must be done first, in case of zmq.IDENTITY)
+        for opt, value in self._in_sockopts:
+            ins.setsockopt(opt, value)
+        for opt, value in self._out_sockopts:
+            outs.setsockopt(opt, value)
+
+        for iface in self._in_binds:
+            ins.bind(iface)
+        for iface in self._out_binds:
+            outs.bind(iface)
+
+        for iface in self._in_connects:
+            ins.connect(iface)
+        for iface in self._out_connects:
+            outs.connect(iface)
+
+        return ins, outs
+
+    def run_device(self) -> None:
+        """The runner method.
+
+        Do not call me directly, instead call ``self.start()``, just like a Thread.
+        """
+        ins, outs = self._setup_sockets()
+        device(self.device_type, ins, outs)
+
+    def _close_sockets(self):
+        """Cleanup sockets we created"""
+        for s in self._sockets:
+            if s and not s.closed:
+                s.close()
+
+    def run(self) -> None:
+        """wrap run_device in try/catch ETERM"""
+        try:
+            self.run_device()
+        except ZMQError as e:
+            if e.errno in {ETERM, ENOTSOCK}:
+                # silence TERM, ENOTSOCK errors, because this should be a clean shutdown
+                pass
+            else:
+                raise
+        finally:
+            self.done = True
+            self._close_sockets()
+
+    def start(self) -> None:
+        """Start the device. Override me in subclass for other launchers."""
+        return self.run()
+
+    def join(self, timeout: Optional[float] = None) -> None:
+        """wait for me to finish, like Thread.join.
+
+        Reimplemented appropriately by subclasses."""
+        tic = time.monotonic()
+        toc = tic
+        while not self.done and not (timeout is not None and toc - tic > timeout):
+            time.sleep(0.001)
+            toc = time.monotonic()
+
+
+class BackgroundDevice(Device):
+    """Base class for launching Devices in background processes and threads."""
+
+    launcher: Any = None
+    _launch_class: Any = None
+
+    def start(self) -> None:
+        self.launcher = self._launch_class(target=self.run)
+        self.launcher.daemon = self.daemon
+        return self.launcher.start()
+
+    def join(self, timeout: Optional[float] = None) -> None:
+        return self.launcher.join(timeout=timeout)
+
+
+class ThreadDevice(BackgroundDevice):
+    """A Device that will be run in a background Thread.
+
+    See Device for details.
+    """
+
+    _launch_class = Thread
+
+
+class ProcessDevice(BackgroundDevice):
+    """A Device that will be run in a background Process.
+
+    See Device for details.
+    """
+
+    _launch_class = Process
+    context_factory = Context
+    """Callable that returns a context. Typically either Context.instance or Context,
+    depending on whether the device should share the global instance or not.
+    """
+
+
+__all__ = ['Device', 'ThreadDevice', 'ProcessDevice']

.venv/lib/python3.11/site-packages/zmq/devices/monitoredqueue.py

@@ -0,0 +1,51 @@
+"""pure Python monitored_queue function
+
+For use when Cython extension is unavailable (PyPy).
+
+Authors
+-------
+* MinRK
+"""
+
+# Copyright (C) PyZMQ Developers
+# Distributed under the terms of the Modified BSD License.
+
+from typing import Callable
+
+import zmq
+from zmq.backend import monitored_queue as _backend_mq
+
+
+def _relay(ins, outs, sides, prefix, swap_ids):
+    msg = ins.recv_multipart()
+    if swap_ids:
+        msg[:2] = msg[:2][::-1]
+    outs.send_multipart(msg)
+    sides.send_multipart([prefix] + msg)
+
+
+def _monitored_queue(
+    in_socket, out_socket, mon_socket, in_prefix=b'in', out_prefix=b'out'
+):
+    swap_ids = in_socket.type == zmq.ROUTER and out_socket.type == zmq.ROUTER
+
+    poller = zmq.Poller()
+    poller.register(in_socket, zmq.POLLIN)
+    poller.register(out_socket, zmq.POLLIN)
+    while True:
+        events = dict(poller.poll())
+        if in_socket in events:
+            _relay(in_socket, out_socket, mon_socket, in_prefix, swap_ids)
+        if out_socket in events:
+            _relay(out_socket, in_socket, mon_socket, out_prefix, swap_ids)
+
+
+monitored_queue: Callable
+if _backend_mq is not None:
+    monitored_queue = _backend_mq  # type: ignore
+else:
+    # backend has no monitored_queue
+    monitored_queue = _monitored_queue
+
+
+__all__ = ['monitored_queue']

.venv/lib/python3.11/site-packages/zmq/devices/monitoredqueuedevice.py

@@ -0,0 +1,60 @@
+"""MonitoredQueue classes and functions."""
+
+# Copyright (C) PyZMQ Developers
+# Distributed under the terms of the Modified BSD License.
+
+from zmq import PUB
+from zmq.devices.monitoredqueue import monitored_queue
+from zmq.devices.proxydevice import ProcessProxy, Proxy, ProxyBase, ThreadProxy
+
+
+class MonitoredQueueBase(ProxyBase):
+    """Base class for overriding methods."""
+
+    _in_prefix = b''
+    _out_prefix = b''
+
+    def __init__(
+        self, in_type, out_type, mon_type=PUB, in_prefix=b'in', out_prefix=b'out'
+    ):
+        ProxyBase.__init__(self, in_type=in_type, out_type=out_type, mon_type=mon_type)
+
+        self._in_prefix = in_prefix
+        self._out_prefix = out_prefix
+
+    def run_device(self):
+        ins, outs, mons = self._setup_sockets()
+        monitored_queue(ins, outs, mons, self._in_prefix, self._out_prefix)
+
+
+class MonitoredQueue(MonitoredQueueBase, Proxy):
+    """Class for running monitored_queue in the background.
+
+    See zmq.devices.Device for most of the spec. MonitoredQueue differs from Proxy,
+    only in that it adds a ``prefix`` to messages sent on the monitor socket,
+    with a different prefix for each direction.
+
+    MQ also supports ROUTER on both sides, which zmq.proxy does not.
+
+    If a message arrives on `in_sock`, it will be prefixed with `in_prefix` on the monitor socket.
+    If it arrives on out_sock, it will be prefixed with `out_prefix`.
+
+    A PUB socket is the most logical choice for the mon_socket, but it is not required.
+    """
+
+
+class ThreadMonitoredQueue(MonitoredQueueBase, ThreadProxy):
+    """Run zmq.monitored_queue in a background thread.
+
+    See MonitoredQueue and Proxy for details.
+    """
+
+
+class ProcessMonitoredQueue(MonitoredQueueBase, ProcessProxy):
+    """Run zmq.monitored_queue in a separate process.
+
+    See MonitoredQueue and Proxy for details.
+    """
+
+
+__all__ = ['MonitoredQueue', 'ThreadMonitoredQueue', 'ProcessMonitoredQueue']

.venv/lib/python3.11/site-packages/zmq/devices/proxydevice.py

@@ -0,0 +1,104 @@
+"""Proxy classes and functions."""
+
+# Copyright (C) PyZMQ Developers
+# Distributed under the terms of the Modified BSD License.
+
+import zmq
+from zmq.devices.basedevice import Device, ProcessDevice, ThreadDevice
+
+
+class ProxyBase:
+    """Base class for overriding methods."""
+
+    def __init__(self, in_type, out_type, mon_type=zmq.PUB):
+        Device.__init__(self, in_type=in_type, out_type=out_type)
+        self.mon_type = mon_type
+        self._mon_binds = []
+        self._mon_connects = []
+        self._mon_sockopts = []
+
+    def bind_mon(self, addr):
+        """Enqueue ZMQ address for binding on mon_socket.
+
+        See zmq.Socket.bind for details.
+        """
+        self._mon_binds.append(addr)
+
+    def bind_mon_to_random_port(self, addr, *args, **kwargs):
+        """Enqueue a random port on the given interface for binding on
+        mon_socket.
+
+        See zmq.Socket.bind_to_random_port for details.
+
+        .. versionadded:: 18.0
+        """
+        port = self._reserve_random_port(addr, *args, **kwargs)
+
+        self.bind_mon(f'{addr}:{port}')
+
+        return port
+
+    def connect_mon(self, addr):
+        """Enqueue ZMQ address for connecting on mon_socket.
+
+        See zmq.Socket.connect for details.
+        """
+        self._mon_connects.append(addr)
+
+    def setsockopt_mon(self, opt, value):
+        """Enqueue setsockopt(opt, value) for mon_socket
+
+        See zmq.Socket.setsockopt for details.
+        """
+        self._mon_sockopts.append((opt, value))
+
+    def _setup_sockets(self):
+        ins, outs = Device._setup_sockets(self)
+        ctx = self._context
+        mons = ctx.socket(self.mon_type)
+        self._sockets.append(mons)
+
+        # set sockopts (must be done first, in case of zmq.IDENTITY)
+        for opt, value in self._mon_sockopts:
+            mons.setsockopt(opt, value)
+
+        for iface in self._mon_binds:
+            mons.bind(iface)
+
+        for iface in self._mon_connects:
+            mons.connect(iface)
+
+        return ins, outs, mons
+
+    def run_device(self):
+        ins, outs, mons = self._setup_sockets()
+        zmq.proxy(ins, outs, mons)
+
+
+class Proxy(ProxyBase, Device):
+    """Threadsafe Proxy object.
+
+    See zmq.devices.Device for most of the spec. This subclass adds a
+    <method>_mon version of each <method>_{in|out} method, for configuring the
+    monitor socket.
+
+    A Proxy is a 3-socket ZMQ Device that functions just like a
+    QUEUE, except each message is also sent out on the monitor socket.
+
+    A PUB socket is the most logical choice for the mon_socket, but it is not required.
+    """
+
+
+class ThreadProxy(ProxyBase, ThreadDevice):
+    """Proxy in a Thread. See Proxy for more."""
+
+
+class ProcessProxy(ProxyBase, ProcessDevice):
+    """Proxy in a Process. See Proxy for more."""
+
+
+__all__ = [
+    'Proxy',
+    'ThreadProxy',
+    'ProcessProxy',
+]

.venv/lib/python3.11/site-packages/zmq/devices/proxysteerabledevice.py

@@ -0,0 +1,106 @@
+"""Classes for running a steerable ZMQ proxy"""
+
+# Copyright (C) PyZMQ Developers
+# Distributed under the terms of the Modified BSD License.
+
+import zmq
+from zmq.devices.proxydevice import ProcessProxy, Proxy, ThreadProxy
+
+
+class ProxySteerableBase:
+    """Base class for overriding methods."""
+
+    def __init__(self, in_type, out_type, mon_type=zmq.PUB, ctrl_type=None):
+        super().__init__(in_type=in_type, out_type=out_type, mon_type=mon_type)
+        self.ctrl_type = ctrl_type
+        self._ctrl_binds = []
+        self._ctrl_connects = []
+        self._ctrl_sockopts = []
+
+    def bind_ctrl(self, addr):
+        """Enqueue ZMQ address for binding on ctrl_socket.
+
+        See zmq.Socket.bind for details.
+        """
+        self._ctrl_binds.append(addr)
+
+    def bind_ctrl_to_random_port(self, addr, *args, **kwargs):
+        """Enqueue a random port on the given interface for binding on
+        ctrl_socket.
+
+        See zmq.Socket.bind_to_random_port for details.
+        """
+        port = self._reserve_random_port(addr, *args, **kwargs)
+
+        self.bind_ctrl(f'{addr}:{port}')
+
+        return port
+
+    def connect_ctrl(self, addr):
+        """Enqueue ZMQ address for connecting on ctrl_socket.
+
+        See zmq.Socket.connect for details.
+        """
+        self._ctrl_connects.append(addr)
+
+    def setsockopt_ctrl(self, opt, value):
+        """Enqueue setsockopt(opt, value) for ctrl_socket
+
+        See zmq.Socket.setsockopt for details.
+        """
+        self._ctrl_sockopts.append((opt, value))
+
+    def _setup_sockets(self):
+        ins, outs, mons = super()._setup_sockets()
+        ctx = self._context
+        ctrls = ctx.socket(self.ctrl_type)
+        self._sockets.append(ctrls)
+
+        for opt, value in self._ctrl_sockopts:
+            ctrls.setsockopt(opt, value)
+
+        for iface in self._ctrl_binds:
+            ctrls.bind(iface)
+
+        for iface in self._ctrl_connects:
+            ctrls.connect(iface)
+
+        return ins, outs, mons, ctrls
+
+    def run_device(self):
+        ins, outs, mons, ctrls = self._setup_sockets()
+        zmq.proxy_steerable(ins, outs, mons, ctrls)
+
+
+class ProxySteerable(ProxySteerableBase, Proxy):
+    """Class for running a steerable proxy in the background.
+
+    See zmq.devices.Proxy for most of the spec.  If the control socket is not
+    NULL, the proxy supports control flow, provided by the socket.
+
+    If PAUSE is received on this socket, the proxy suspends its activities. If
+    RESUME is received, it goes on. If TERMINATE is received, it terminates
+    smoothly.  If the control socket is NULL, the proxy behave exactly as if
+    zmq.devices.Proxy had been used.
+
+    This subclass adds a <method>_ctrl version of each <method>_{in|out}
+    method, for configuring the control socket.
+
+    .. versionadded:: libzmq-4.1
+    .. versionadded:: 18.0
+    """
+
+
+class ThreadProxySteerable(ProxySteerableBase, ThreadProxy):
+    """ProxySteerable in a Thread. See ProxySteerable for details."""
+
+
+class ProcessProxySteerable(ProxySteerableBase, ProcessProxy):
+    """ProxySteerable in a Process. See ProxySteerable for details."""
+
+
+__all__ = [
+    'ProxySteerable',
+    'ThreadProxySteerable',
+    'ProcessProxySteerable',
+]

.venv/lib/python3.11/site-packages/zmq/log/__main__.py

@@ -0,0 +1,135 @@
+"""pyzmq log watcher.
+
+Easily view log messages published by the PUBHandler in zmq.log.handlers
+
+Designed to be run as an executable module - try this to see options:
+    python -m zmq.log -h
+
+Subscribes to the '' (empty string) topic by default which means it will work
+out-of-the-box with a PUBHandler object instantiated with default settings.
+If you change the root topic with PUBHandler.setRootTopic() you must pass
+the value to this script with the --topic argument.
+
+Note that the default formats for the PUBHandler object selectively include
+the log level in the message. This creates redundancy in this script as it
+always prints the topic of the message, which includes the log level.
+Consider overriding the default formats with PUBHandler.setFormat() to
+avoid this issue.
+
+"""
+
+# encoding: utf-8
+
+# Copyright (C) PyZMQ Developers
+# Distributed under the terms of the Modified BSD License.
+
+import argparse
+from datetime import datetime
+from typing import Dict
+
+import zmq
+
+parser = argparse.ArgumentParser('ZMQ Log Watcher')
+parser.add_argument('zmq_pub_url', type=str, help='URL to a ZMQ publisher socket.')
+parser.add_argument(
+    '-t',
+    '--topic',
+    type=str,
+    default='',
+    help='Only receive messages that start with this topic.',
+)
+parser.add_argument(
+    '--timestamp', action='store_true', help='Append local time to the log messages.'
+)
+parser.add_argument(
+    '--separator',
+    type=str,
+    default=' | ',
+    help='String to print between topic and message.',
+)
+parser.add_argument(
+    '--dateformat',
+    type=str,
+    default='%Y-%d-%m %H:%M',
+    help='Set alternative date format for use with --timestamp.',
+)
+parser.add_argument(
+    '--align',
+    action='store_true',
+    default=False,
+    help='Try to align messages by the width of their topics.',
+)
+parser.add_argument(
+    '--color',
+    action='store_true',
+    default=False,
+    help='Color the output based on the error level. Requires the colorama module.',
+)
+args = parser.parse_args()
+
+
+if args.color:
+    import colorama
+
+    colorama.init()
+    colors = {
+        'DEBUG': colorama.Fore.LIGHTCYAN_EX,
+        'INFO': colorama.Fore.LIGHTWHITE_EX,
+        'WARNING': colorama.Fore.YELLOW,
+        'ERROR': colorama.Fore.LIGHTRED_EX,
+        'CRITICAL': colorama.Fore.LIGHTRED_EX,
+        '__RESET__': colorama.Fore.RESET,
+    }
+else:
+    colors = {}
+
+
+ctx = zmq.Context()
+sub = ctx.socket(zmq.SUB)
+sub.subscribe(args.topic.encode("utf8"))
+sub.connect(args.zmq_pub_url)
+
+topic_widths: Dict[int, int] = {}
+
+while True:
+    try:
+        if sub.poll(10, zmq.POLLIN):
+            topic, msg = sub.recv_multipart()
+            topics = topic.decode('utf8').strip().split('.')
+
+            if args.align:
+                topics.extend(' ' for extra in range(len(topics), len(topic_widths)))
+                aligned_parts = []
+                for key, part in enumerate(topics):
+                    topic_widths[key] = max(len(part), topic_widths.get(key, 0))
+                    fmt = ''.join(('{:<', str(topic_widths[key]), '}'))
+                    aligned_parts.append(fmt.format(part))
+
+            if len(topics) == 1:
+                level = topics[0]
+            else:
+                level = topics[1]
+
+            fields = {
+                'msg': msg.decode('utf8').strip(),
+                'ts': (
+                    datetime.now().strftime(args.dateformat) + ' '
+                    if args.timestamp
+                    else ''
+                ),
+                'aligned': (
+                    '.'.join(aligned_parts)
+                    if args.align
+                    else topic.decode('utf8').strip()
+                ),
+                'color': colors.get(level, ''),
+                'color_rst': colors.get('__RESET__', ''),
+                'sep': args.separator,
+            }
+            print('{ts}{color}{aligned}{sep}{msg}{color_rst}'.format(**fields))
+    except KeyboardInterrupt:
+        break
+
+sub.disconnect(args.zmq_pub_url)
+if args.color:
+    print(colorama.Fore.RESET)

.venv/lib/python3.11/site-packages/zmq/log/handlers.py

@@ -0,0 +1,232 @@
+"""pyzmq logging handlers.
+
+This mainly defines the PUBHandler object for publishing logging messages over
+a zmq.PUB socket.
+
+The PUBHandler can be used with the regular logging module, as in::
+
+    >>> import logging
+    >>> handler = PUBHandler('tcp://127.0.0.1:12345')
+    >>> handler.root_topic = 'foo'
+    >>> logger = logging.getLogger('foobar')
+    >>> logger.setLevel(logging.DEBUG)
+    >>> logger.addHandler(handler)
+
+Or using ``dictConfig``, as in::
+
+    >>> from logging.config import dictConfig
+    >>> socket = Context.instance().socket(PUB)
+    >>> socket.connect('tcp://127.0.0.1:12345')
+    >>> dictConfig({
+    >>>     'version': 1,
+    >>>     'handlers': {
+    >>>         'zmq': {
+    >>>             'class': 'zmq.log.handlers.PUBHandler',
+    >>>             'level': logging.DEBUG,
+    >>>             'root_topic': 'foo',
+    >>>             'interface_or_socket': socket
+    >>>         }
+    >>>     },
+    >>>     'root': {
+    >>>         'level': 'DEBUG',
+    >>>         'handlers': ['zmq'],
+    >>>     }
+    >>> })
+
+
+After this point, all messages logged by ``logger`` will be published on the
+PUB socket.
+
+Code adapted from StarCluster:
+
+    https://github.com/jtriley/StarCluster/blob/StarCluster-0.91/starcluster/logger.py
+"""
+
+from __future__ import annotations
+
+import logging
+from copy import copy
+
+import zmq
+
+# Copyright (C) PyZMQ Developers
+# Distributed under the terms of the Modified BSD License.
+
+
+TOPIC_DELIM = "::"  # delimiter for splitting topics on the receiving end.
+
+
+class PUBHandler(logging.Handler):
+    """A basic logging handler that emits log messages through a PUB socket.
+
+    Takes a PUB socket already bound to interfaces or an interface to bind to.
+
+    Example::
+
+        sock = context.socket(zmq.PUB)
+        sock.bind('inproc://log')
+        handler = PUBHandler(sock)
+
+    Or::
+
+        handler = PUBHandler('inproc://loc')
+
+    These are equivalent.
+
+    Log messages handled by this handler are broadcast with ZMQ topics
+    ``this.root_topic`` comes first, followed by the log level
+    (DEBUG,INFO,etc.), followed by any additional subtopics specified in the
+    message by: log.debug("subtopic.subsub::the real message")
+    """
+
+    ctx: zmq.Context
+    socket: zmq.Socket
+
+    def __init__(
+        self,
+        interface_or_socket: str | zmq.Socket,
+        context: zmq.Context | None = None,
+        root_topic: str = '',
+    ) -> None:
+        logging.Handler.__init__(self)
+        self.root_topic = root_topic
+        self.formatters = {
+            logging.DEBUG: logging.Formatter(
+                "%(levelname)s %(filename)s:%(lineno)d - %(message)s\n"
+            ),
+            logging.INFO: logging.Formatter("%(message)s\n"),
+            logging.WARN: logging.Formatter(
+                "%(levelname)s %(filename)s:%(lineno)d - %(message)s\n"
+            ),
+            logging.ERROR: logging.Formatter(
+                "%(levelname)s %(filename)s:%(lineno)d - %(message)s - %(exc_info)s\n"
+            ),
+            logging.CRITICAL: logging.Formatter(
+                "%(levelname)s %(filename)s:%(lineno)d - %(message)s\n"
+            ),
+        }
+        if isinstance(interface_or_socket, zmq.Socket):
+            self.socket = interface_or_socket
+            self.ctx = self.socket.context
+        else:
+            self.ctx = context or zmq.Context()
+            self.socket = self.ctx.socket(zmq.PUB)
+            self.socket.bind(interface_or_socket)
+
+    @property
+    def root_topic(self) -> str:
+        return self._root_topic
+
+    @root_topic.setter
+    def root_topic(self, value: str):
+        self.setRootTopic(value)
+
+    def setRootTopic(self, root_topic: str):
+        """Set the root topic for this handler.
+
+        This value is prepended to all messages published by this handler, and it
+        defaults to the empty string ''. When you subscribe to this socket, you must
+        set your subscription to an empty string, or to at least the first letter of
+        the binary representation of this string to ensure you receive any messages
+        from this handler.
+
+        If you use the default empty string root topic, messages will begin with
+        the binary representation of the log level string (INFO, WARN, etc.).
+        Note that ZMQ SUB sockets can have multiple subscriptions.
+        """
+        if isinstance(root_topic, bytes):
+            root_topic = root_topic.decode("utf8")
+        self._root_topic = root_topic
+
+    def setFormatter(self, fmt, level=logging.NOTSET):
+        """Set the Formatter for this handler.
+
+        If no level is provided, the same format is used for all levels. This
+        will overwrite all selective formatters set in the object constructor.
+        """
+        if level == logging.NOTSET:
+            for fmt_level in self.formatters.keys():
+                self.formatters[fmt_level] = fmt
+        else:
+            self.formatters[level] = fmt
+
+    def format(self, record):
+        """Format a record."""
+        return self.formatters[record.levelno].format(record)
+
+    def emit(self, record):
+        """Emit a log message on my socket."""
+
+        # LogRecord.getMessage explicitly allows msg to be anything _castable_ to a str
+        try:
+            topic, msg = str(record.msg).split(TOPIC_DELIM, 1)
+        except ValueError:
+            topic = ""
+        else:
+            # copy to avoid mutating LogRecord in-place
+            record = copy(record)
+            record.msg = msg
+
+        try:
+            bmsg = self.format(record).encode("utf8")
+        except Exception:
+            self.handleError(record)
+            return
+
+        topic_list = []
+
+        if self.root_topic:
+            topic_list.append(self.root_topic)
+
+        topic_list.append(record.levelname)
+
+        if topic:
+            topic_list.append(topic)
+
+        btopic = '.'.join(topic_list).encode("utf8", "replace")
+
+        self.socket.send_multipart([btopic, bmsg])
+
+
+class TopicLogger(logging.Logger):
+    """A simple wrapper that takes an additional argument to log methods.
+
+    All the regular methods exist, but instead of one msg argument, two
+    arguments: topic, msg are passed.
+
+    That is::
+
+        logger.debug('msg')
+
+    Would become::
+
+        logger.debug('topic.sub', 'msg')
+    """
+
+    def log(self, level, topic, msg, *args, **kwargs):
+        """Log 'msg % args' with level and topic.
+
+        To pass exception information, use the keyword argument exc_info
+        with a True value::
+
+            logger.log(level, "zmq.fun", "We have a %s",
+                    "mysterious problem", exc_info=1)
+        """
+        logging.Logger.log(self, level, f'{topic}{TOPIC_DELIM}{msg}', *args, **kwargs)
+
+
+# Generate the methods of TopicLogger, since they are just adding a
+# topic prefix to a message.
+for name in "debug warn warning error critical fatal".split():
+    try:
+        meth = getattr(logging.Logger, name)
+    except AttributeError:
+        # some methods are missing, e.g. Logger.warn was removed from Python 3.13
+        continue
+    setattr(
+        TopicLogger,
+        name,
+        lambda self, level, topic, msg, *args, **kwargs: meth(
+            self, level, topic + TOPIC_DELIM + msg, *args, **kwargs
+        ),
+    )