Code refactoring and cleanup

Author: Karol-G

README.md

@@ -44,7 +44,6 @@ pip install "napari-stream[all]"
 ```
 
 
-
 ## Contributing
 
 Contributions are very welcome. Tests can be run with [tox], please ensure

pyproject.toml

@@ -30,9 +30,7 @@ requires-python = ">=3.10"
 # See best practices: https://napari.org/stable/plugins/building_a_plugin/best_practices.html
 dependencies = [
     "numpy",
-    "magicgui",
-    "qtpy",
-    "scikit-image",
+    "pyzmq",
 ]
 
 [project.optional-dependencies]
@@ -52,8 +50,6 @@ dev = [
 [project.entry-points."napari.manifest"]
 napari-stream = "napari_stream:napari.yaml"
 
-
-
 [build-system]
 requires = ["setuptools>=42.0.0", "setuptools_scm"]
 build-backend = "setuptools.build_meta"

src/napari_stream/_listener.py

@@ -1,16 +1,10 @@
 from __future__ import annotations
 import json
-import os
-import sys
-import socket
 from typing import Optional
-
 import numpy as np
 import zmq
-from qtpy.QtCore import QObject, QThread, Signal
-
-
-DEFAULT_TCP_PORT = 5556
+from qtpy.QtCore import QObject, Signal
+from ._utils import default_endpoint
 
 
 class ZMQImageListener(QObject):
@@ -77,15 +71,6 @@ def _teardown(self):
             self.status.emit("Listener stopped.")
 
 
-def default_endpoint(public: bool = False) -> str:
-    if public:
-        return f"tcp://{_preferred_ip()}:{DEFAULT_TCP_PORT}"
-    if os.name == "nt":  # Windows: prefer TCP
-        return f"tcp://127.0.0.1:{DEFAULT_TCP_PORT}"
-    # Unix: fast local IPC
-    return "ipc:///tmp/napari_stream.sock"
-
-
 def bind_endpoint_for_public(endpoint: str) -> str:
     """Convert a TCP endpoint to bind on all interfaces."""
     if not endpoint.startswith("tcp://"):
@@ -101,18 +86,6 @@ def bind_endpoint_for_public(endpoint: str) -> str:
     return f"tcp://*:{port_int}"
 
 
-def _preferred_ip() -> str:
-    """Best-effort guess of a non-loopback IPv4 address for sharing endpoints."""
-    try:
-        infos = socket.getaddrinfo(socket.gethostname(), None, family=socket.AF_INET)
-        for _, _, _, _, (addr, *_rest) in infos:
-            if not addr.startswith("127."):
-                return addr
-    except Exception:
-        pass
-    return "127.0.0.1"
-
-
 def _from_bytes(buf: bytes, meta: dict) -> np.ndarray:
     """Reconstruct ndarray from raw bytes and metadata.
 

src/napari_stream/_receiver_widget.py

@@ -1,7 +1,6 @@
 from __future__ import annotations
 import traceback
 from typing import Optional
-
 import numpy as np
 from qtpy.QtCore import QThread
 from qtpy.QtGui import QGuiApplication

src/napari_stream/_utils.py

@@ -0,0 +1,26 @@
+from __future__ import annotations
+import os
+import socket
+
+DEFAULT_TCP_PORT = 5556
+
+
+def default_endpoint(public: bool = False) -> str:
+    if public:
+        return f"tcp://{_preferred_ip()}:{DEFAULT_TCP_PORT}"
+    if os.name == "nt":  # Windows: prefer TCP
+        return f"tcp://127.0.0.1:{DEFAULT_TCP_PORT}"
+    # Unix: fast local IPC
+    return "ipc:///tmp/napari_stream.sock"
+
+
+def _preferred_ip() -> str:
+    """Best-effort guess of a non-loopback IPv4 address for sharing endpoints."""
+    try:
+        infos = socket.getaddrinfo(socket.gethostname(), None, family=socket.AF_INET)
+        for _, _, _, _, (addr, *_rest) in infos:
+            if not addr.startswith("127."):
+                return addr
+    except Exception:
+        pass
+    return "127.0.0.1"

src/napari_stream/_widget.py

@@ -4,36 +4,6 @@ display_name: Napari Stream
 visibility: public
 # see https://napari.org/stable/plugins/technical_references/manifest.html#fields for valid categories
 # categories: []
-# contributions:
-#   commands:
-#     - id: napari-stream.make_container_widget
-#       python_name: napari_stream:ImageThreshold
-#       title: Make threshold Container widget
-#     - id: napari-stream.make_magic_widget
-#       python_name: napari_stream:threshold_magic_widget
-#       title: Make threshold magic widget
-#     - id: napari-stream.make_function_widget
-#       python_name: napari_stream:threshold_autogenerate_widget
-#       title: Make threshold function widget
-#     - id: napari-stream.make_qwidget
-#       python_name: napari_stream:ExampleQWidget
-#       title: Make example QWidget
-#   widgets:
-#     - command: napari-stream.make_container_widget
-#       display_name: Container Threshold
-#     - command: napari-stream.make_magic_widget
-#       display_name: Magic Threshold
-#     - command: napari-stream.make_function_widget
-#       autogenerate: true
-#       display_name: Autogenerate Threshold
-#     - command: napari-stream.make_qwidget
-#       display_name: Example QWidget
-#   menus:
-#     napari/layers/segment:
-#       - command: napari-stream.make_container_widget
-#       - command: napari-stream.make_magic_widget
-#       - command: napari-stream.make_function_widget
-#       - command: napari-stream.make_qwidget
 contributions:
   widgets:
     - command: napari-stream.start_receiver

src/napari_stream/napari.yaml

@@ -2,13 +2,11 @@
 import json
 import os
 import time
-from typing import Optional, Sequence, Any, Iterable
+from typing import Optional, Sequence, Any
 from collections.abc import Mapping
-
 import numpy as np
 import zmq
-from ._listener import default_endpoint
-from numpy.typing import ArrayLike
+from ._utils import default_endpoint
 
 
 class StreamSender: