Automatic push from FunctionsAPI

Cargo.toml

@@ -0,0 +1,10 @@
+[package]
+  edition = "2021"
+  name    = "web"
+  version = "0.1.0"
+
+[dependencies]
+  axum                   = { version = "0.8" }
+  pipeline-configuration = { git = "ssh://git@github.com/fathom-io/pipeline-calculations.git" }
+  serde_json             = { version = "1.0.138" }
+  tokio                  = { version = "1.43.0", features = ["macros", "rt-multi-thread"] }

README.md

@@ -1,2 +1 @@
-# 1127db45c0da43c9af99d49085e6105f
-
+# rust hello-world

src/main.rs

@@ -0,0 +1,36 @@
+use axum::http::HeaderMap;
+use axum::{routing::post, Router};
+use pipeline_configuration::pipeline_route::{PipelineRoute, Waypoint};
+use std::net::SocketAddr;
+use tokio::net::TcpListener;
+
+async fn hello_world(headers: HeaderMap, body: String) -> String {
+    let env = std::env::vars().collect::<Vec<_>>();
+    let waypoints = vec![
+        Waypoint {
+            latitude: 52.16975830941925,
+            longitude: -104.1288528141576,
+            measure: 0.0,
+            elevation: 540.0,
+        },
+        Waypoint {
+            latitude: 52.20097892887157,
+            longitude: -104.0144102732867,
+            measure: 8563.471,
+            elevation: 540.0,
+        },
+    ];
+    let route = PipelineRoute::new(waypoints);
+    let start = route.location_of_measure(100.0).unwrap();
+    format!("Request headers: {headers:?}, request body: {body}, env: {env:?}, start: {start:?}")
+}
+
+#[tokio::main]
+async fn main() {
+    let router = Router::new().route("/", post(hello_world));
+
+    let addr = SocketAddr::from(([0, 0, 0, 0], 8080));
+    let tcp = TcpListener::bind(&addr).await.unwrap();
+    println!("Ready and listening on {}", addr);
+    axum::serve(tcp, router).await.unwrap();
+}