From 764d9561bd3ef45520b9bd6ec50614d244e00e78 Mon Sep 17 00:00:00 2001
From: Nick Todd <nick.todd@t-s.qinetiq.com>
Date: Mon, 13 Nov 2023 17:40:25 +0000
Subject: [PATCH] #2042: NTP client initial commit

---
 .../system/services/ntp/ntp_client.py         | 50 +++++++++++++++++++
 1 file changed, 50 insertions(+)
 create mode 100644 src/primaite/simulator/system/services/ntp/ntp_client.py

diff --git a/src/primaite/simulator/system/services/ntp/ntp_client.py b/src/primaite/simulator/system/services/ntp/ntp_client.py
new file mode 100644
index 00000000..edae9af6
--- /dev/null
+++ b/src/primaite/simulator/system/services/ntp/ntp_client.py
@@ -0,0 +1,50 @@
+from ipaddress import IPv4Address
+from typing import Dict, Optional
+from primaite.simulator.network.transmission.network_layer import IPProtocol
+from primaite.simulator.network.transmission.transport_layer import Port
+from primaite.simulator.system.services.service import Service
+
+
+from primaite import getLogger
+
+_LOGGER = getLogger(__name__)
+
+
+class NTPClient(Service):
+    """Represents a NTP client as a service"""
+
+    ntp_server: Optional[IPv4Address] = None
+    "The NTP server the client sends requests to."
+
+    def __init__(self, **kwargs):
+        kwargs["name"] = "NTPClient"
+        kwargs["port"] = Port.NTP
+        kwargs["protocol"] = IPProtocol.UDP
+        super().__init__(**kwargs)
+        self.start()
+
+    def describe_state(self) -> Dict:
+        """
+        Describes the current state of the software.
+
+        The specifics of the software's state, including its health, criticality,
+        and any other pertinent information, should be implemented in subclasses.
+
+        :return: A dictionary containing key-value pairs representing the current state of the software.
+        :rtype: Dict
+        """
+        state = super().describe_state()
+        return state
+
+    def reset_component_for_episode(self, episode: int):
+        """
+        Resets the Service component for a new episode.
+
+        This method ensures the Service is ready for a new episode, including resetting any
+        stateful properties or statistics, and clearing any message queues.
+        """
+        pass
+
+    def receive(self):
+        """Receives time data from server"""
+        pass