Merge pull request #11333 from msupply-foundation/11288-ancillary-item-graphql

#11288 Ancillary item service + GraphQL layers

Author: ria8651

server/Cargo.lock

@@ -22,6 +22,7 @@ graphql_asset_catalogue = { path = "asset_catalogue" }
 graphql_inventory_adjustment = { path = "inventory_adjustment" }
 graphql_item_variant = { path = "item_variant" }
 graphql_item_bundle = { path = "item_bundle" }
+graphql_ancillary_item = { path = "ancillary_item" }
 graphql_invoice = { path = "invoice" }
 graphql_invoice_line = { path = "invoice_line" }
 graphql_vaccine_course = { path = "vaccine_course" }

server/graphql/Cargo.toml

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

server/graphql/ancillary_item/Cargo.toml

@@ -0,0 +1,28 @@
+use async_graphql::*;
+
+mod mutations;
+use self::mutations::*;
+
+#[derive(Default, Clone)]
+pub struct AncillaryItemMutations;
+
+#[Object]
+impl AncillaryItemMutations {
+    async fn upsert_ancillary_item(
+        &self,
+        ctx: &Context<'_>,
+        store_id: String,
+        input: UpsertAncillaryItemInput,
+    ) -> Result<UpsertAncillaryItemResponse> {
+        upsert_ancillary_item(ctx, store_id, input)
+    }
+
+    async fn delete_ancillary_item(
+        &self,
+        ctx: &Context<'_>,
+        store_id: String,
+        input: DeleteAncillaryItemInput,
+    ) -> Result<DeleteAncillaryItemResponse> {
+        delete_ancillary_item(ctx, store_id, input)
+    }
+}

server/graphql/ancillary_item/src/lib.rs

@@ -0,0 +1,72 @@
+use async_graphql::*;
+use graphql_core::{
+    standard_graphql_error::{validate_auth, StandardGraphqlError},
+    ContextExt,
+};
+use graphql_types::types::DeleteResponse;
+use service::{
+    auth::{Resource, ResourceAccessRequest},
+    item::ancillary_item::{DeleteAncillaryItem, DeleteAncillaryItemError},
+};
+
+#[derive(InputObject)]
+pub struct DeleteAncillaryItemInput {
+    pub id: String,
+}
+
+#[derive(Union)]
+pub enum DeleteAncillaryItemResponse {
+    Response(DeleteResponse),
+}
+
+pub fn delete_ancillary_item(
+    ctx: &Context<'_>,
+    store_id: String,
+    input: DeleteAncillaryItemInput,
+) -> Result<DeleteAncillaryItemResponse> {
+    validate_auth(
+        ctx,
+        &ResourceAccessRequest {
+            resource: Resource::MutateItemNamesCodesAndUnits,
+            store_id: Some(store_id.to_string()),
+        },
+    )?;
+
+    let service_provider = ctx.service_provider();
+    let service_context = service_provider.basic_context()?;
+
+    let result = service_provider
+        .item_service
+        .delete_ancillary_item(&service_context, input.to_domain());
+
+    map_response(result)
+}
+
+impl DeleteAncillaryItemInput {
+    pub fn to_domain(self) -> DeleteAncillaryItem {
+        let DeleteAncillaryItemInput { id } = self;
+        DeleteAncillaryItem { id }
+    }
+}
+
+fn map_response(
+    from: Result<String, DeleteAncillaryItemError>,
+) -> Result<DeleteAncillaryItemResponse> {
+    match from {
+        Ok(result) => Ok(DeleteAncillaryItemResponse::Response(DeleteResponse(result))),
+        Err(error) => {
+            let formatted_error = format!("{error:#?}");
+
+            let graphql_error = match error {
+                DeleteAncillaryItemError::NotCentralServer => {
+                    StandardGraphqlError::Forbidden(formatted_error)
+                }
+                DeleteAncillaryItemError::DatabaseError(_) => {
+                    StandardGraphqlError::InternalError(formatted_error)
+                }
+            };
+
+            Err(graphql_error.extend())
+        }
+    }
+}

server/graphql/ancillary_item/src/mutations/delete.rs

@@ -0,0 +1,8 @@
+mod upsert;
+pub use upsert::*;
+
+mod delete;
+pub use delete::*;
+
+#[cfg(test)]
+mod test;