wip: add minimal changes required for a successful gda collection

Author: shihab-dls

src/fastcs_eiger/controllers/eiger_controller.py

@@ -5,7 +5,7 @@
 from fastcs.attributes import AttrR, AttrRW
 from fastcs.connections import IPConnectionSettings
 from fastcs.controllers import Controller
-from fastcs.datatypes import Bool, Int
+from fastcs.datatypes import Bool, Int, String
 from fastcs.logging import logger
 from fastcs.methods import command, scan
 
@@ -35,7 +35,13 @@ class EigerController(Controller):
 
     detector: EigerDetectorController
 
+    # Soft signals for GDA
+    image_mode = AttrRW(String(), initial_value="Multiple")
+    manual_trigger = AttrRW(String(), initial_value="No")
+    start_timeout = AttrRW(Bool())
+    datatype = AttrRW(Int())
     # Internal Attributes
+
     stale_parameters = AttrR(Bool())
     arm_timeout = AttrRW(
         Int(min=1),

src/fastcs_eiger/controllers/eiger_detector_controller.py

@@ -1,8 +1,9 @@
 from typing import Any
 
 from fastcs.attributes import AttrR, AttrRW
-from fastcs.datatypes import Float
+from fastcs.datatypes import Bool, Float
 from fastcs.methods import command
+from fastcs_odin.io import StatusSummaryAttributeIORef
 
 from fastcs_eiger.controllers.eiger_subsystem_controller import EigerSubsystemController
 from fastcs_eiger.eiger_parameter import EigerAPIVersion
@@ -23,10 +24,29 @@ class EigerDetectorController(EigerSubsystemController):
     trigger_exposure = AttrRW(Float())
 
     # Introspected attributes needed for internal logic
+    state: AttrR[str]
     bit_depth_image: AttrR[int]
     compression: AttrRW[str]
     trigger_mode: AttrR[str]
 
+    async def initialise(self) -> None:
+        await super().initialise()
+        self.armed = AttrR(
+            Bool(),
+            io_ref=StatusSummaryAttributeIORef(
+                [], "", lambda states: states[0] in ["ready", "acquire"], [self.state]
+            ),
+        )
+
+        async def acquire(value):
+            if value == 1:
+                await self.arm()
+            else:
+                await self.disarm()
+
+        self.acquire = AttrRW(Bool())
+        self.acquire.add_on_update_callback(acquire)
+
     @detector_command
     async def initialize(self):
         await self.connection.put(command_uri(self._api_version, key="initialize"))

src/fastcs_eiger/controllers/eiger_subsystem_controller.py

@@ -6,6 +6,7 @@
 from fastcs.controllers import Controller
 from fastcs.logging import logger
 from fastcs.util import ONCE
+from fastcs_odin.io import StatusSummaryAttributeIO
 
 from fastcs_eiger.eiger_parameter import (
     EIGER_PARAMETER_MODES,
@@ -61,7 +62,7 @@ def __init__(
         self.connection = connection
         self._queue_subsystem_update = queue_subsystem_update
         self._io = EigerAttributeIO(connection, self.update_now, self.queue_update)
-        super().__init__(ios=[self._io])
+        super().__init__(ios=[self._io, StatusSummaryAttributeIO()])
         self._api_version: EigerAPIVersion = api_version
 
     async def _introspect_detector_subsystem(self) -> list[EigerParameterRef]:

src/fastcs_eiger/controllers/odin/eiger_odin_controller.py

@@ -73,6 +73,8 @@ async def start_writing(self):
             self.OD.FP.data_datatype.put(f"uint{self.detector.bit_depth_image.get()}"),
         )
 
+        await self.OD.MW.acquisition_id.put("")
+
         await self.OD.FP.start_writing()
 
         try: