1 files changed, 75 insertions, 0 deletions
diff --git a/nixpkgs/pkgs/development/python-modules/asyncio-mqtt/default.nix b/nixpkgs/pkgs/development/python-modules/asyncio-mqtt/default.nix
new file mode 100644
index 000000000000..8274f5493967
--- /dev/null
+++ b/nixpkgs/pkgs/development/python-modules/asyncio-mqtt/default.nix
@@ -0,0 +1,75 @@
+{ lib
+, anyio
+, buildPythonPackage
+, fetchFromGitHub
+, paho-mqtt
+, pytestCheckHook
+, pythonOlder
+, setuptools
+, setuptools-scm
+, typing-extensions
+, wheel
+}:
+
+buildPythonPackage rec {
+  pname = "asyncio-mqtt";
+  version = "0.16.1";
+  format = "pyproject";
+
+  disabled = pythonOlder "3.7";
+
+  src = fetchFromGitHub {
+    owner = "sbtinstruments";
+    repo = pname;
+    rev = "refs/tags/v${version}";
+    hash = "sha256-f3JqocjOEwNjo6Uv17ij6oEdrjb6Z2wTzdhdVhx46iM=";
+  };
+
+  SETUPTOOLS_SCM_PRETEND_VERSION = version;
+
+  nativeBuildInputs = [
+    setuptools
+    setuptools-scm
+    wheel
+  ];
+
+  propagatedBuildInputs = [
+    paho-mqtt
+  ] ++ lib.optionals (pythonOlder "3.10") [
+    typing-extensions
+  ];
+
+  nativeCheckInputs = [
+    anyio
+    pytestCheckHook
+  ];
+
+  pythonImportsCheck = [
+    "asyncio_mqtt"
+  ];
+
+  disabledTests = [
+    # Tests require network access
+    "test_client_filtered_messages"
+    "test_client_logger"
+    "test_client_max_concurrent_outgoing_calls"
+    "test_client_no_pending_calls_warnings_with_max_concurrent_outgoing_calls"
+    "test_client_pending_calls_threshold"
+    "test_client_tls_context"
+    "test_client_tls_params"
+    "test_client_unfiltered_messages"
+    "test_client_unsubscribe"
+    "test_client_username_password "
+    "test_client_websockets"
+    "test_client_will"
+    "test_multiple_messages_generators"
+  ];
+
+  meta = with lib; {
+    description = "Idomatic asyncio wrapper around paho-mqtt";
+    homepage = "https://github.com/sbtinstruments/asyncio-mqtt";
+    license = licenses.bsd3;
+    changelog = "https://github.com/sbtinstruments/asyncio-mqtt/blob/v${version}/CHANGELOG.md";
+    maintainers = with maintainers; [ hexa ];
+  };
+}