feat: store timestamps in DAQJobN1081B

src/daq/caen/n1081b.py

@@ -1,5 +1,6 @@
 import time
 from dataclasses import dataclass
+from datetime import datetime
 
 from N1081B import N1081B
 from websocket import WebSocket
@@ -79,12 +80,14 @@ def _poll_sections(self):
             self._send_store_message(data, section.name)
 
     def _send_store_message(self, data: dict, section):
+        keys = ["timestamp", *[f"lemo_{x['lemo']}" for x in data["counters"]]]
+        values = [datetime.now().timestamp(), *[x["value"] for x in data["counters"]]]
         self.message_out.put(
             DAQJobMessageStore(
                 store_config=self.config.store_config,
                 daq_job=self,
                 prefix=section,
-                keys=[f"lemo_{x['lemo']}" for x in data["counters"]],
-                data=[[x["value"] for x in data["counters"]]],
+                keys=keys,
+                data=values,
             )
         )