THe function wasn't unused but should be renamed

Author: d-j-hatton

src/murfey/client/analyser.py

@@ -22,7 +22,7 @@
 from murfey.client.instance_environment import MurfeyInstanceEnvironment
 from murfey.client.rsync import RSyncerUpdate, TransferResult
 from murfey.client.tui.forms import FormDependency
-from murfey.util import Observer, get_machine_config
+from murfey.util import Observer, get_machine_config_client
 from murfey.util.models import PreprocessingParametersTomo, ProcessingParametersSPA
 
 logger = logging.getLogger("murfey.client.analyser")
@@ -73,7 +73,7 @@ def __init__(
         self._stopping = False
         self._halt_thread = False
         self._murfey_config = (
-            get_machine_config(
+            get_machine_config_client(
                 str(environment.url.geturl()),
                 instrument_name=environment.instrument_name,
                 demo=environment.demo,
@@ -145,7 +145,7 @@ def _find_context(self, file_path: Path) -> bool:
             and self._environment
         ):
             created_directories = set(
-                get_machine_config(
+                get_machine_config_client(
                     str(self._environment.url.geturl()),
                     instrument_name=self._environment.instrument_name,
                     demo=self._environment.demo,
@@ -165,7 +165,7 @@ def _find_context(self, file_path: Path) -> bool:
                     logger.info("Acquisition software: EPU")
                     if self._environment:
                         try:
-                            cfg = get_machine_config(
+                            cfg = get_machine_config_client(
                                 str(self._environment.url.geturl()),
                                 instrument_name=self._environment.instrument_name,
                                 demo=self._environment.demo,

src/murfey/client/contexts/clem.py

@@ -14,7 +14,7 @@
 
 from murfey.client.context import Context
 from murfey.client.instance_environment import MurfeyInstanceEnvironment
-from murfey.util import capture_post, get_machine_config
+from murfey.util import capture_post, get_machine_config_client
 
 # Create logger object
 logger = logging.getLogger("murfey.client.contexts.clem")
@@ -26,7 +26,7 @@ def _file_transferred_to(
     """
     Returns the Path of the transferred file on the DLS file system.
     """
-    machine_config = get_machine_config(
+    machine_config = get_machine_config_client(
         str(environment.url.geturl()),
         instrument_name=environment.instrument_name,
         demo=environment.demo,

src/murfey/client/contexts/spa.py

@@ -19,7 +19,7 @@
     authorised_requests,
     capture_get,
     capture_post,
-    get_machine_config,
+    get_machine_config_client,
 )
 
 logger = logging.getLogger("murfey.client.contexts.spa")
@@ -105,7 +105,7 @@ def _get_grid_square_atlas_positions(
 def _file_transferred_to(
     environment: MurfeyInstanceEnvironment, source: Path, file_path: Path
 ):
-    machine_config = get_machine_config(
+    machine_config = get_machine_config_client(
         str(environment.url.geturl()),
         instrument_name=environment.instrument_name,
         demo=environment.demo,
@@ -684,7 +684,7 @@ def post_transfer(
             if transferred_file.suffix in data_suffixes:
                 if self._acquisition_software == "epu":
                     if environment:
-                        machine_config = get_machine_config(
+                        machine_config = get_machine_config_client(
                             str(environment.url.geturl()),
                             instrument_name=environment.instrument_name,
                             demo=environment.demo,
@@ -872,7 +872,7 @@ def _register_processing_job(
         parameters = parameters or {}
         environment.id_tag_registry["processing_job"].append(tag)
         proc_url = f"{str(environment.url.geturl())}/visits/{environment.visit}/{environment.murfey_session}/register_processing_job"
-        machine_config = get_machine_config(
+        machine_config = get_machine_config_client(
             str(environment.url.geturl()),
             instrument_name=environment.instrument_name,
             demo=environment.demo,

src/murfey/client/contexts/spa_metadata.py

@@ -8,7 +8,7 @@
 from murfey.client.context import Context
 from murfey.client.contexts.spa import _get_grid_square_atlas_positions, _get_source
 from murfey.client.instance_environment import MurfeyInstanceEnvironment, SampleInfo
-from murfey.util import authorised_requests, capture_post, get_machine_config
+from murfey.util import authorised_requests, capture_post, get_machine_config_client
 
 logger = logging.getLogger("murfey.client.contexts.spa_metadata")
 
@@ -18,7 +18,7 @@
 def _atlas_destination(
     environment: MurfeyInstanceEnvironment, source: Path, file_path: Path
 ) -> Path:
-    machine_config = get_machine_config(
+    machine_config = get_machine_config_client(
         str(environment.url.geturl()),
         instrument_name=environment.instrument_name,
         demo=environment.demo,

src/murfey/client/contexts/tomo.py

@@ -19,7 +19,7 @@
     MurfeyInstanceEnvironment,
     global_env_lock,
 )
-from murfey.util import authorised_requests, capture_post, get_machine_config
+from murfey.util import authorised_requests, capture_post, get_machine_config_client
 from murfey.util.mdoc import get_block, get_global_data, get_num_blocks
 
 logger = logging.getLogger("murfey.client.contexts.tomo")
@@ -341,7 +341,7 @@ def _complete_process_file(
     def _file_transferred_to(
         self, environment: MurfeyInstanceEnvironment, source: Path, file_path: Path
     ):
-        machine_config = get_machine_config(
+        machine_config = get_machine_config_client(
             str(environment.url.geturl()),
             instrument_name=environment.instrument_name,
             demo=environment.demo,
@@ -794,7 +794,7 @@ def post_transfer(
             if transferred_file.suffix in data_suffixes:
                 if self._acquisition_software == "tomo":
                     if environment:
-                        machine_config = get_machine_config(
+                        machine_config = get_machine_config_client(
                             str(environment.url.geturl()),
                             instrument_name=environment.instrument_name,
                             demo=environment.demo,

src/murfey/client/tui/app.py

@@ -34,7 +34,7 @@
 from murfey.client.watchdir_multigrid import MultigridDirWatcher
 from murfey.util import (
     capture_post,
-    get_machine_config,
+    get_machine_config_client,
     read_config,
     set_default_acquisition_output,
 )
@@ -104,7 +104,7 @@ def __init__(
         self._force_mdoc_metadata = force_mdoc_metadata
         self._strict = strict
         self._skip_existing_processing = skip_existing_processing
-        self._machine_config = get_machine_config(
+        self._machine_config = get_machine_config_client(
             str(self._environment.url.geturl()),
             instrument_name=self._environment.instrument_name,
             demo=self._environment.demo,
@@ -128,7 +128,7 @@ def _launch_multigrid_watcher(
         self, source: Path, destination_overrides: Dict[Path, str] | None = None
     ):
         log.info(f"Launching multigrid watcher for source {source}")
-        machine_config = get_machine_config(
+        machine_config = get_machine_config_client(
             str(self._environment.url.geturl()),
             instrument_name=self._environment.instrument_name,
             demo=self._environment.demo,
@@ -688,7 +688,7 @@ def on_log_book_log(self, message):
         self.log_book.write(message.renderable)
 
     async def reset(self):
-        machine_config = get_machine_config(
+        machine_config = get_machine_config_client(
             str(self._environment.url.geturl()),
             instrument_name=self._environment.instrument_name,
             demo=self._environment.demo,
@@ -743,7 +743,7 @@ def clean_up_quit(self) -> None:
         exit()
 
     async def action_clear(self) -> None:
-        machine_config = get_machine_config(
+        machine_config = get_machine_config_client(
             str(self._environment.url.geturl()),
             instrument_name=self._environment.instrument_name,
             demo=self._environment.demo,

src/murfey/client/tui/screens.py

@@ -56,7 +56,7 @@
 )
 from murfey.client.rsync import RSyncer
 from murfey.client.tui.forms import FormDependency
-from murfey.util import capture_post, get_machine_config, read_config
+from murfey.util import capture_post, get_machine_config_client, read_config
 from murfey.util.models import PreprocessingParametersTomo, ProcessingParametersSPA
 
 log = logging.getLogger("murfey.tui.screens")
@@ -262,7 +262,7 @@ def __init__(
         super().__init__(*args, **kwargs)
         self._selected_dir = basepath
         self._add_basepath = add_basepath
-        cfg = get_machine_config(
+        cfg = get_machine_config_client(
             str(self.app._environment.url.geturl()),
             instrument_name=self.app._environment.instrument_name,
             demo=self.app._environment.demo,
@@ -898,7 +898,7 @@ def on_button_pressed(self, event: Button.Pressed):
         visit_dir = Path(str(event.button.label)) / self.app._visit
         visit_dir.mkdir(exist_ok=True)
         self.app._set_default_acquisition_directories(visit_dir)
-        machine_config = get_machine_config(
+        machine_config = get_machine_config_client(
             str(self.app._environment.url.geturl()),
             instrument_name=self.app._environment.instrument_name,
             demo=self.app._environment.demo,
@@ -940,7 +940,7 @@ def compose(self):
             )
             yield RadioButton("Tomography", value=self._context is TomographyContext)
         if self.app._multigrid:
-            machine_config = get_machine_config(
+            machine_config = get_machine_config_client(
                 str(self.app._environment.url.geturl()),
                 instrument_name=self.app._environment.instrument_name,
             )
@@ -1000,7 +1000,7 @@ def compose(self):
                                 )
                             )
         else:
-            machine_config = get_machine_config(
+            machine_config = get_machine_config_client(
                 str(self.app._environment.url.geturl()),
                 instrument_name=self.app._environment.instrument_name,
             )
@@ -1031,7 +1031,7 @@ def compose(self):
                     i = Input(value=val, id=k.name, classes="input-destination")
                 params_bulk.append(i)
                 self._inputs[i] = k.name
-            machine_config = get_machine_config(
+            machine_config = get_machine_config_client(
                 str(self.app._environment.url.geturl()),
                 instrument_name=self.app._environment.instrument_name,
                 demo=self.app._environment.demo,
@@ -1083,7 +1083,7 @@ def on_switch_changed(self, event):
 
     def on_radio_set_changed(self, event: RadioSet.Changed) -> None:
         if event.index == 0:
-            cfg = get_machine_config(
+            cfg = get_machine_config_client(
                 str(self.app._environment.url.geturl()),
                 instrument_name=self.app._environment.instrument_name,
                 demo=self.app._environment.demo,

src/murfey/util/__init__.py

@@ -8,7 +8,7 @@
 import logging
 import os
 import shutil
-from functools import partial
+from functools import lru_cache, partial
 from pathlib import Path
 from queue import Queue
 from threading import Thread
@@ -40,6 +40,16 @@ def read_config() -> configparser.ConfigParser:
     return config
 
 
+@lru_cache(maxsize=1)
+def get_machine_config_client(
+    url: str, instrument_name: str = "", demo: bool = False
+) -> dict:
+    _instrument_name: str | None = instrument_name or os.getenv("BEAMLINE")
+    if not _instrument_name:
+        return {}
+    return requests.get(f"{url}/instruments/{_instrument_name}/machine").json()
+
+
 def authorised_requests() -> Tuple[Callable, Callable, Callable, Callable]:
     token = read_config()["Murfey"].get("token", "")
     _get = partial(requests.get, headers={"Authorization": f"Bearer {token}"})