Automatic push from FunctionsAPI

Cargo.toml

@@ -0,0 +1,12 @@
+[package]
+  edition = "2024"
+  name    = "web"
+  version = "0.1.0"
+
+[dependencies]
+  chrono               = { version = "0.4" }
+  fathom-function      = { git = "ssh://git@github.com/fathom-io/pipeline-calculations.git", branch = "johnabell/ili-comparison" }
+  pipeline-application = { git = "ssh://git@github.com/fathom-io/pipeline-calculations.git", branch = "johnabell/ili-comparison" }
+  serde                = { version = "1.0.219", features = ["derive"] }
+  tokio                = { version = "1.43.0", features = ["macros", "rt-multi-thread"] }
+  uuid                 = { version = "1" }

src/main.rs

@@ -0,0 +1,76 @@
+use chrono::NaiveDate;
+use fathom_function::Context;
+use pipeline_application::application::{
+    Application, InlineInspection, InspectionType, ReportType, ToolTolerances,
+};
+use serde::{Deserialize, Deserializer};
+use uuid::Uuid;
+
+#[fathom_function::function(default(
+    org_id = "2cbfe270-d195-48ad-aed1-24145924635c",
+    project_id = "6807aed617c4295ab4a6aa78"
+))]
+async fn pipeline_route(context: Context, input: Input) -> Result<String, String> {
+    let reports_details = input.report_details;
+    for (pipeline_id, file_details) in input.pipeline_id.into_iter().zip(input.file_details) {
+        Application::new(context.env, context.org_id, &context.project_id)
+            .unwrap()
+            .process_ili_report(
+                pipeline_id,
+                file_details.file_id,
+                ToolTolerances::default(),
+                &reports_details,
+            )
+            .await
+            .unwrap();
+    }
+    Ok("Success".to_owned())
+}
+
+#[derive(Debug, Deserialize)]
+struct Input {
+    pipeline_id: Vec<Uuid>,
+    file_details: Vec<FileDetails>,
+    // TODO: parse the output of the tool tolerances.
+    #[serde(flatten)]
+    report_details: InspectionReportDetails,
+}
+
+#[derive(Debug, Deserialize)]
+struct InspectionReportDetails {
+    #[serde(deserialize_with = "deserialize_date")]
+    date: NaiveDate,
+    vendor_name: String,
+    report_type: ReportType,
+    /// The inspection type and technology used.
+    inspection_type: InspectionType,
+}
+
+impl From<&InspectionReportDetails> for InlineInspection {
+    fn from(value: &InspectionReportDetails) -> Self {
+        Self {
+            date: value.date,
+            vendor_name: value.vendor_name.to_owned(),
+            report_type: value.report_type,
+            inspection_type: value.inspection_type,
+        }
+    }
+}
+
+#[derive(Debug, Clone, PartialEq, Eq, Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct FileDetails {
+    pub file_id: Uuid,
+    pub revision_id: Uuid,
+}
+
+const FORMAT: &'static str = "%a %b %d %Y";
+
+pub fn deserialize_date<'de, D>(deserializer: D) -> Result<NaiveDate, D::Error>
+where
+    D: Deserializer<'de>,
+{
+    let s = String::deserialize(deserializer)?;
+    let dt = NaiveDate::parse_from_str(&s, FORMAT).map_err(serde::de::Error::custom)?;
+    Ok(dt)
+}