tango control libs

Author: SafiullahOmar

.gitignore

@@ -45,4 +45,7 @@ wheels/
 *.pyo
 __pycache__/
 
+.DS_Store
+
+
 venv*/

src/dt4acc/__init__.py

@@ -2,4 +2,4 @@
 
 mongodb_ = _mongodb_(__name__)
 
-__all__ = ["mongodb_"]
+__all__ = ["mongodb_"]

src/dt4acc/core/accelerators/element_proxies.py

@@ -104,9 +104,6 @@ async def update(self, property_id: str, value, element_data):
 
         Raises:
             ValueError: If an unknown property is specified.
-
-        Todo: is that Liasion management?
-              the inverse way
         """
         if value is not None:
             assert np.isfinite(value), "Value must be finite"
@@ -167,7 +164,7 @@ class KickAngleCorrectorProxy(AddOnElementProxy):
 
     def __init__(self, obj, *, correction_plane, **kwargs):
         assert correction_plane in ["horizontal", "vertical"], "Invalid correction plane"
-        self.correction_plane = correction_plane
+        self.correction_planes = correction_plane
         super().__init__(*obj, **kwargs)
 
     async def update_kick(self, *, kick_x=None, kick_y=None, element_data):
@@ -179,7 +176,7 @@ async def update_kick(self, *, kick_x=None, kick_y=None, element_data):
             kick_y: Vertical kick angle.
             element_data: Element-specific conversion data.
         """
-        element = self._obj
+        element, = self._obj
         kick_angles = self._obj.KickAngle.copy()
         if kick_x is not None:
             kick_angles[0] = kick_x * element_data.hw2phys

src/dt4acc/custom_epics/data/querries.py

@@ -1,5 +1,7 @@
+import sys
 import os
 
+# sys.path.append('/Volumes/MyDrive/Bessy/dt4acc/dt4acc/src')
 import pymongo
 
 from dt4acc import mongodb_

src/dt4acc/custom_epics/ioc/handlers.py

@@ -92,4 +92,4 @@ def get_property_id(pv_name):
     elif ':rdbk' in pv_name:
         return 'rdbk'
     else:
-        return None
+        return None

src/dt4acc/custom_epics/utils/bpm_mimicry.py

@@ -1,14 +1,17 @@
 import functools
 import os
+import sys
+# sys.path.append('/Volumes/MyDrive/Bessy/dt4acc/dt4acc/src')
 
 import numpy as np
 import pandas as pd
 import pymongo
 from bact_device_models.devices.bpm_elem_libera import BPMElement, BPMElementPosition, BPMElementList
 from bact_device_models.filters.bpm_calibration import BPMCalibrationPlane
 
-from ...core.model.orbit import Orbit
-from ...core.utils.logger import get_logger
+
+from dt4acc.core.model.orbit import Orbit
+from dt4acc.core.utils.logger import get_logger
 
 MONGO_URI = os.environ.get("MONGODB_URL", "mongodb://localhost:27017")
 DB_NAME = os.environ.get("MONGODB_DB", "bessyii")

src/dt4acc/custom_tango/README.md

@@ -0,0 +1,186 @@
+# Tango Device Server Setup
+
+This repository contains a Tango Device Server implementation for controlling various accelerator devices such as magnets, power converters, BPMs, and orbit devices.
+
+## Prerequisites
+
+Ensure you have the following dependencies installed before running the Tango server:
+
+- **Python** (>=3.7)
+- **PyTango** (Tango Controls Python API)
+- **MariaDB** (for the Tango Database)
+- **NumPy** (for numerical computations)
+
+Install the required Python dependencies:
+```bash
+pip install pytango numpy
+```
+
+Alternatively, you can install `PyTango` using Conda:
+```bash
+conda create --channel conda-forge --name pytango-env python=3.11 pytango
+conda activate pytango-env
+```
+
+### Cloning and Running the Tango Database Repository
+To use the official Tango Database, clone the repository with submodules:
+```bash
+git clone --recursive https://gitlab.com/tango-controls/TangoDatabase.git
+```
+Then navigate into the cloned repository:
+```bash
+cd TangoDatabase
+```
+Follow the repository instructions to set up and run the Tango Database.
+
+### Testing the PyTango Installation
+To verify that `PyTango` is installed correctly, run the following command:
+```bash
+python -c "import tango; print(tango.Release.version)"
+```
+If the installation is successful, this will print the installed Tango version.
+
+### Starting the Tango Database Server
+Before running the Tango device server, you need to start the Tango Database:
+
+```bash
+sudo DataBaseds 2 -ORBendPoint giop:tcp::10000
+```
+This command starts the Tango Database Service on port `10000`. Ensure it is running before proceeding.
+
+To install additional Tango tools such as `tango-test`, `jive`, and `tango-database` from Conda:
+```bash
+conda install -c conda-forge tango-test jive tango-database
+```
+
+## Setting Up the Tango Database
+
+Before running the server, initialize the Tango Database:
+
+```python
+from dt4acc.custom_tango.utils.tango_util import initialize_tango_database
+
+# Initialize Tango Database
+initialize_tango_database()
+```
+
+## Running the Tango Server
+
+To start the Tango device server, navigate to the project directory and run the following command:
+
+```bash
+python tango_server.py test
+```
+
+### What Happens When You Start the Server?
+1. The server initializes the Tango database.
+2. Registers the device classes: `MagnetDevice`, `PowerConverterDevice`, `BPMDevice`, `OrbitDevice`, `TwissDevice`, `OtherDevice`.
+3. Starts the Tango device server to manage and interact with these devices.
+
+## Available Tango Devices
+
+### Magnet Device
+Handles magnet attributes like:
+- `Cm_set` (magnetic field strength)
+- `im_I` (read-only measured current)
+- `x_set` & `y_set` (position setpoints)
+
+### Power Converter Device
+Manages power converters with attributes:
+- `set` (setpoint value)
+- `rdbk` (readback value)
+
+### Orbit Device
+Monitors beam orbits with attributes:
+- `orbit_x`, `orbit_y` (orbit coordinates)
+- `beam_data` (2048-sample beam data array)
+
+### Twiss Device
+Handles Twiss parameters like:
+- `x_alpha`, `x_beta`, `x_nu`
+- `y_alpha`, `y_beta`, `y_nu`
+
+### Other Device
+Handles miscellaneous parameters including:
+- `master_clock_freq` (clock frequency)
+- `current` (current measurement)
+
+### BPM Device
+Handles Beam Position Monitor (BPM) data with attributes:
+- `bpm_bdata` (beam data array)
+- `bpm_count` (BPM count)
+
+## Pushing Data to Tango Devices
+
+### Pushing Orbit Data
+To push beam orbit data to the Tango Device:
+
+```bash
+python push_orbit.py
+```
+This script:
+- Generates random orbit data.
+- Pushes it to the Tango server.
+- Reads the updated orbit data back from the Tango server.
+
+### Pushing BPM Data
+To push BPM (Beam Position Monitor) data:
+
+```bash
+python push_bpm.py
+```
+This script:
+- Mimics BPM behavior.
+- Pushes BPM readings to Tango.
+- Reads back BPM data from the server.
+
+### Pushing Twiss Parameters
+To update Twiss parameters:
+
+```bash
+python push_twiss.py
+```
+This script:
+- Simulates Twiss parameter values.
+- Pushes them to the Tango server.
+- Reads the updated values from the server.
+
+## Monitoring the Heartbeat
+To ensure the server is running correctly, start the heartbeat monitor:
+
+```bash
+python heartbeat.py
+```
+This script:
+- Calls `heart_beat()` every second to check server status.
+- Logs any errors encountered.
+- Can be stopped with `CTRL + C`.
+
+## Interacting with Devices
+Once the server is running, you can interact with devices using `Jive` (Tango graphical interface) or `TangoTest` CLI:
+
+To read attributes:
+```bash
+tango_read tango://localhost:10000/test/MagnetDevice_1/Cm_set
+```
+
+To write attributes:
+```bash
+tango_write tango://localhost:10000/test/MagnetDevice_1/Cm_set 5.0
+```
+
+## Stopping the Server
+To stop the running Tango server, use:
+```bash
+CTRL + C
+```
+
+## Troubleshooting
+- Ensure that the Tango database is running (`TangoDB` service must be active).
+- Use `Jive` to check registered devices and their statuses.
+- Verify that `sys.path.append()` correctly points to the required modules.
+
+---
+
+This setup allows you to run and interact with the Tango device server seamlessly. Let me know if you need any modifications!
+

src/dt4acc/custom_tango/__init__.py

@@ -0,0 +1,11 @@
+from tango import DeviceProxy, DevFailed
+
+device_name = "tango_server/test/MagnetDevice_VS3M2T8R"
+
+try:
+    magnet = DeviceProxy(device_name)
+    print(f"{device_name} exists and is reachable!")
+    print("Ping response:", magnet.ping(), "ms")
+except DevFailed as e:
+    print(f"Device {device_name} is NOT found or not running.")
+    print(e)