Merge pull request #2098 from openmsupply/1955-omSupply-Cold-Chain-Te…

…mperature-Sensors

1955 om supply cold chain temperature sensors

server/graphql/Cargo.toml

@@ -17,6 +17,7 @@ graphql_programs = { path = "programs" }
 graphql_types = { path = "types" }
 graphql_general = { path = "general" }
 graphql_location = { path = "location" }
+graphql_sensor = { path = "sensor" }
 graphql_reports = { path = "reports" }
 graphql_invoice = { path = "invoice" }
 graphql_invoice_line = { path = "invoice_line" }

server/graphql/core/src/loader/mod.rs

@@ -18,6 +18,7 @@ mod program_enrolment;
 mod requisition;
 mod requisition_line;
 mod requisition_supply_status;
+mod sensor;
 mod stock_line;
 mod stocktake_lines;
 mod store;
@@ -45,6 +46,7 @@ pub use program_enrolment::*;
 pub use requisition::*;
 pub use requisition_line::*;
 pub use requisition_supply_status::*;
+pub use sensor::*;
 pub use stock_line::*;
 pub use stocktake_lines::*;
 pub use store::*;

server/graphql/core/src/loader/sensor.rs

@@ -0,0 +1,32 @@
+use repository::EqualFilter;
+use repository::{
+    sensor::{Sensor, SensorFilter, SensorRepository},
+    RepositoryError, StorageConnectionManager,
+};
+
+use async_graphql::dataloader::*;
+use async_graphql::*;
+use std::collections::HashMap;
+
+pub struct SensorByIdLoader {
+    pub connection_manager: StorageConnectionManager,
+}
+
+#[async_trait::async_trait]
+impl Loader<String> for SensorByIdLoader {
+    type Value = Sensor;
+    type Error = RepositoryError;
+
+    async fn load(&self, ids: &[String]) -> Result<HashMap<String, Self::Value>, Self::Error> {
+        let connection = self.connection_manager.connection()?;
+        let repo = SensorRepository::new(&connection);
+
+        let result =
+            repo.query_by_filter(SensorFilter::new().id(EqualFilter::equal_any(ids.to_owned())))?;
+
+        Ok(result
+            .into_iter()
+            .map(|sensor| (sensor.sensor_row.id.clone(), sensor))
+            .collect())
+    }
+}

server/graphql/core/src/simple_generic_errors.rs

@@ -267,6 +267,7 @@ impl InvoiceLineBelongsToAnotherInvoice {
 #[graphql(rename_items = "camelCase")]
 pub enum UniqueValueKey {
     Code,
+    Serial,
 }
 
 pub struct UniqueValueViolation(pub UniqueValueKey);

server/graphql/lib.rs

@@ -21,11 +21,12 @@ use graphql_general::{
 use graphql_invoice::{InvoiceMutations, InvoiceQueries};
 use graphql_invoice_line::InvoiceLineMutations;
 use graphql_location::{LocationMutations, LocationQueries};
-use graphql_repack::{RepackMutations, RepackQueries};
 use graphql_programs::{ProgramsMutations, ProgramsQueries};
+use graphql_repack::{RepackMutations, RepackQueries};
 use graphql_reports::ReportQueries;
 use graphql_requisition::{RequisitionMutations, RequisitionQueries};
 use graphql_requisition_line::RequisitionLineMutations;
+use graphql_sensor::{SensorMutations, SensorQueries};
 use graphql_stock_line::{StockLineMutations, StockLineQueries};
 use graphql_stocktake::{StocktakeMutations, StocktakeQueries};
 use graphql_stocktake_line::StocktakeLineMutations;
@@ -48,6 +49,7 @@ pub type InitialisationSchema = async_graphql::Schema<
 pub struct Queries(
     pub InvoiceQueries,
     pub LocationQueries,
+    pub SensorQueries,
     pub StocktakeQueries,
     pub GeneralQueries,
     pub RequisitionQueries,
@@ -64,6 +66,7 @@ impl Queries {
         Queries(
             InvoiceQueries,
             LocationQueries,
+            SensorQueries,
             StocktakeQueries,
             GeneralQueries,
             RequisitionQueries,
@@ -82,6 +85,7 @@ pub struct Mutations(
     pub InvoiceMutations,
     pub InvoiceLineMutations,
     pub LocationMutations,
+    pub SensorMutations,
     pub StocktakeMutations,
     pub StocktakeLineMutations,
     pub BatchMutations,
@@ -100,6 +104,7 @@ impl Mutations {
             InvoiceMutations,
             InvoiceLineMutations,
             LocationMutations,
+            SensorMutations,
             StocktakeMutations,
             StocktakeLineMutations,
             BatchMutations,

server/graphql/sensor/Cargo.toml

@@ -0,0 +1,36 @@
+[package]
+name = "graphql_sensor"
+version = "0.1.0"
+edition = "2018"
+
+[lib]
+path = "src/lib.rs"
+doctest = false
+
+[dependencies]
+
+repository = { path = "../../repository" }
+service = { path = "../../service" }
+util = { path = "../../util" }
+graphql_core = { path = "../core" }
+graphql_types = { path = "../types" }
+
+actix-web = { workspace = true }
+anymap= { workspace = true }
+async-graphql = { workspace = true }
+async-graphql-actix-web = { workspace = true }
+async-trait = { workspace = true }
+chrono = { workspace = true }
+reqwest = { workspace = true }
+serde = { workspace = true }
+serde_json = { workspace = true }
+thiserror = { workspace = true }
+
+[dev-dependencies]
+actix-rt = { workspace = true }
+assert-json-diff = { workspace = true }
+
+[features]
+default = ["sqlite"]
+sqlite = ["repository/sqlite"]
+postgres = ["repository/postgres"]