remove unused imports

Author: VigneshVSV

hololinked/core/thing.py

@@ -1,9 +1,7 @@
 import logging
 import inspect
-import threading
 import ssl
 import typing
-import warnings
 
 from ..constants import ZMQ_TRANSPORTS
 from ..utils import *  # noqa: F403

hololinked/server/server.py

@@ -1,8 +1,7 @@
-import asyncio
 import logging
 from pydantic import BaseModel, model_validator
 
-from ..utils import get_current_async_loop, forkable, complete_pending_tasks_in_current_loop
+from ..utils import forkable
 from ..param import Parameterized
 from ..core.properties import ClassSelector, Integer, TypedList, Selector
 from ..core import Thing, Property, Action, Event

tests/helper-scripts/run_test_thing.py

@@ -1,6 +1,6 @@
 import os
 import sys
-
+import ssl
 
 sys.path.insert(0, os.path.abspath(os.path.join(os.path.dirname(__file__), "../")))
 
@@ -9,14 +9,13 @@
 from hololinked.server.mqtt import MQTTPublisher
 from hololinked.serializers import Serializers
 from hololinked.config import global_config
+from hololinked.server import run
 from things import TestThing, OceanOpticsSpectrometer
 
-import ssl
-
 global_config.DEBUG = True
 
-thing = TestThing(id="example-test")
-# thing = OceanOpticsSpectrometer(id="example-test", serial_number="simulation")
+thing1 = TestThing(id="test-thing")
+thing2 = OceanOpticsSpectrometer(id="test-spectrometer", serial_number="simulation")
 
 
 Serializers.register_for_object(TestThing.db_init_int_prop, Serializers.pickle)
@@ -32,9 +31,6 @@
 #     ]
 # )
 
-http_server = HTTPServer(port=9000)
-zmq_server = ZMQServer(id="example-test-server", things=[thing], access_points="IPC")
-
 mqtt_ssl = ssl.create_default_context(ssl.Purpose.SERVER_AUTH)
 if not os.path.exists("ca.crt"):
     raise FileNotFoundError("CA certificate 'ca.crt' not found in current directory for MQTT TLS connection")
@@ -43,6 +39,8 @@
 mqtt_ssl.verify_mode = ssl.CERT_REQUIRED
 mqtt_ssl.minimum_version = ssl.TLSVersion.TLSv1_2
 
+http_server = HTTPServer(port=9000)
+zmq_server = ZMQServer(id="example-test-server", access_points="IPC")
 mqtt_publisher = MQTTPublisher(
     hostname="localhost",
     port=8883,
@@ -51,4 +49,8 @@
     qos=1,
     ssl_context=mqtt_ssl,
 )
-thing.run(servers=[http_server, zmq_server, mqtt_publisher])
+zmq_server.add_things(thing1, thing2)
+mqtt_publisher.add_things(thing2)
+http_server.add_things(thing1)
+
+run(zmq_server, mqtt_publisher, http_server)