Moved uncommitted changes from backup-before-filterrepand added new changes for repeated view

Author: SafiullahOmar

src/dt4acc/core/views/shared_view.py

@@ -22,8 +22,15 @@ def get_view_instance():
 
     if server_type == "tango":
         from ...custom_tango.views.result_view import ResultView
+        # For Tango, prefix must be in format: server_name/instance_name
+        # Check for TANGO_SERVER_NAME and TANGO_INSTANCE_NAME env vars first
+        server_name = os.environ.get("TANGO_SERVER_NAME", "SimpleTangoServer")
+        instance_name = os.environ.get("TANGO_INSTANCE_NAME", "test")
+        prefix = f"{server_name}/{instance_name}"
     elif server_type == "epics":
         from ...custom_epics.views.result_view import ResultView
+        # For EPICS, use DT4ACC_PREFIX or username
+        prefix = os.environ.get("DT4ACC_PREFIX", getpass.getuser())
     else:
         raise ValueError(f"Unsupported server type: {server_type}")
 

src/dt4acc/custom_tango/enhanced_tango_server_complete.py

@@ -266,6 +266,14 @@ def main():
         # Ensure server type is set for shared view system
         os.environ["server"] = "tango"
 
+        # Set Tango server/instance names for view prefix (required for device names)
+        server_name = "SimpleTangoServer"
+        instance_name = "test"
+        os.environ["TANGO_SERVER_NAME"] = server_name
+        os.environ["TANGO_INSTANCE_NAME"] = instance_name
+        print(f"Setting Tango server name: {server_name}/{instance_name}")
+        logger.info(f"Setting Tango server name: {server_name}/{instance_name}")
+        
         # Set DT4ACC_PREFIX for PV naming - use a sensible default if not set
         if "DT4ACC_PREFIX" not in os.environ:
             default_prefix = "BESSY"  # Default prefix for BESSY

src/dt4acc/custom_tango/heartbeat_monitor.py

@@ -122,6 +122,14 @@ def main():
         # Ensure server type is set for shared view system
         os.environ["server"] = "tango"
 
+        # Set Tango server/instance names for view prefix (required for device names)
+        server_name = os.environ.get("TANGO_SERVER_NAME", "SimpleTangoServer")
+        instance_name = os.environ.get("TANGO_INSTANCE_NAME", "test")
+        os.environ["TANGO_SERVER_NAME"] = server_name
+        os.environ["TANGO_INSTANCE_NAME"] = instance_name
+        print(f"🔧 Setting Tango server name: {server_name}/{instance_name}")
+        logger.info(f"Setting Tango server name: {server_name}/{instance_name}")
+        
         # Set DT4ACC_PREFIX for PV naming - use a sensible default if not set
         if "DT4ACC_PREFIX" not in os.environ:
             default_prefix = "BESSY"  # Default prefix for BESSY

src/dt4acc/custom_tango/ioc/devices/power_converter_device.py

@@ -7,6 +7,7 @@
 from dt4acc.custom_epics.data.constants import special_pvs, cavity_names
 from dt4acc.core.command import UpdateManager
 from bact_twin_architecture.data_model.identifiers import DevicePropertyID
+from dt4acc.custom_tango.ioc.devices.async_wrapper import run_async_in_background
 
 logger = get_logger()
 
@@ -195,8 +196,8 @@ def current_setpoint(self, value):
         """Set current setpoint (:set in EPICS)."""
         try:
             self._current_setpoint = float(value)
-            # Use EPICS update handler
-            handle_device_update(self.name, "set_current", value)
+            # Use EPICS update handler with async wrapper to avoid coroutine warning
+            run_async_in_background(handle_device_update)(self.name, "set_current", value)
             # Update readback to match EPICS behavior
             self._current_readback = value
             logger.info(f"Updated current setpoint to {value}")
@@ -230,8 +231,8 @@ def frequency(self, value):
         try:
             if self.name in cavity_names:
                 self._frequency = float(value)
-                # Use EPICS update handler for master clock
-                handle_device_update("master_clock", "reference_frequency", value)
+                # Use EPICS update handler for master clock with async wrapper to avoid coroutine warning
+                run_async_in_background(handle_device_update)("master_clock", "reference_frequency", value)
                 logger.info(f"Updated frequency to {value}")
             else:
                 logger.warning(f"Frequency control not available for non-cavity power converter {self.name}")