Expand configuration query

Expand configuration query to be able to return multiple configurations.
Change name to configurations. Make beamline parameter optional (and
rename to beamlineFilter). When a filter is provided, only details for
that beamline are returned, otherwise all beamline configurations are
returned.

Also add a test for the multi-configuration DB query and update the
example query in the README.

Author: callumforrester

README.md

@@ -109,13 +109,13 @@ Get the visit directory for a beamline and visit
 }
 ```
 
-#### configuration
+#### configurations
 Get the current configuration values for the given beamline
 
 ##### Query
 ```graphql
 {
-  configuration(beamline: "i22") {
+  configurations(beamlineFilter: "i22") {
     visitTemplate
     scanTemplate
     detectorTemplate
@@ -127,12 +127,14 @@ Get the current configuration values for the given beamline
 ##### Response
 ```json
 {
-  "configuration": {
-    "visitTemplate": "/data/{instrument}/data/{year}/{visit}",
-    "scanTemplate": "{subdirectory}/{instrument}-{scan_number}",
-    "detectorTemplate": "{subdirectory}/{instrument}-{scan_number}-{detector}",
-    "latestScanNumber": 20839
-  }
+  "configurations": [
+    {
+      "visitTemplate": "/tmp/{instrument}/data/{year}/{visit}",
+      "scanTemplate": "{subdirectory}/{instrument}-{scan_number}",
+      "detectorTemplate": "{subdirectory}/{instrument}-{scan_number}-{detector}",
+      "latestScanNumber": 12345
+    }
+  ]
 }
 ```
 

src/db_service.rs

@@ -303,6 +303,15 @@ impl SqliteScanPathService {
         .ok_or(ConfigurationError::MissingBeamline(beamline.into()))
     }
 
+    pub async fn configurations(&self) -> Result<Vec<BeamlineConfiguration>, ConfigurationError> {
+        Ok(query_as!(DbBeamlineConfig, "SELECT * FROM beamline")
+            .fetch_all(&self.pool)
+            .await?
+            .into_iter()
+            .map(BeamlineConfiguration::from)
+            .collect())
+    }
+
     pub async fn next_scan_configuration(
         &self,
         beamline: &str,
@@ -604,6 +613,33 @@ mod db_tests {
         assert_eq!(fb.extension, "ext");
     }
 
+    #[rstest]
+    #[test]
+    async fn configurations(#[future(awt)] db: SqliteScanPathService) {
+        let confs = ok!(db.configurations());
+        assert_eq!(confs.len(), 1);
+        let conf = confs.first().unwrap();
+        assert_eq!(conf.name(), "i22");
+        assert_eq!(conf.scan_number(), 122);
+        assert_eq!(
+            conf.visit().unwrap().to_string(),
+            "/tmp/{instrument}/data/{year}/{visit}"
+        );
+        assert_eq!(
+            conf.scan().unwrap().to_string(),
+            "{subdirectory}/{instrument}-{scan_number}"
+        );
+        assert_eq!(
+            conf.detector().unwrap().to_string(),
+            "{subdirectory}/{instrument}-{scan_number}-{detector}"
+        );
+        let Some(fb) = conf.fallback() else {
+            panic!("Missing fallback configuration");
+        };
+        assert_eq!(fb.directory, "/tmp/trackers");
+        assert_eq!(fb.extension, "ext");
+    }
+
     type Update = BeamlineConfigurationUpdate;
 
     #[rstest]

src/graphql.rs

@@ -255,14 +255,23 @@ impl Query {
     }
 
     #[instrument(skip(self, ctx))]
-    async fn configuration(
+    async fn configurations(
         &self,
         ctx: &Context<'_>,
-        beamline: String,
-    ) -> async_graphql::Result<BeamlineConfiguration> {
+        beamline_filter: Option<String>,
+    ) -> async_graphql::Result<Vec<BeamlineConfiguration>> {
         let db = ctx.data::<SqliteScanPathService>()?;
-        trace!("Getting config for {beamline:?}");
-        Ok(db.current_configuration(&beamline).await?)
+        match beamline_filter {
+            Some(filter) => {
+                trace!("Getting configs matching {filter:?}");
+                let singleton = db.current_configuration(&filter).await?;
+                Ok(vec![singleton])
+            }
+            None => {
+                trace!("Getting all configs");
+                Ok(db.configurations().await?)
+            }
+        }
     }
 }