Compare commits

..

No commits in common. "v1" and "main" have entirely different histories.
v1 ... main

4 changed files with 1 additions and 3612 deletions

3535
Cargo.lock generated

File diff suppressed because it is too large Load Diff

View File

@ -1,11 +0,0 @@
[package]
edition = "2024"
name = "web"
version = "0.1.0"
[dependencies]
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" }

View File

@ -1,45 +1,2 @@
# Updates the pipeline facility geolocations
# a8102f7063ed4e3797dd1013f48740bf
A function that updates the pipeline facilities with their geolocation based on
the pipeline route. Fails if there is no pipeline route.
## Input
### Arguments
- `pipeline_id`: a `string` which should be a valid uuid for a pipeline.
### Environment
- `ORG_ID`: the organization id
- `PROJECT_ID`: the id of the data project where the pipeline data is found
- `ENV`: the environment of the platform e.g. `dev` or `stg` etc.
## Creating the function on the platform
To create this function on the platform using the `cli` set up the port forwarding as shown in README.
Then run the following command to create the function.
```bash
cargo run functions create \
-f functions/facility_locations \
-n facilitylocations \
-d "Update the facility locations based on the pipeline route and log distance" \
-i pipeline_id=string
```
## Testing the function locally
You can run and test the function locally by running
```bash
cargo run
```
Then you can check it work with `curl` as follows
```bash
curl -X POST localhost:8080 -v \
-d "\"{\\\"pipeline_id\\\": \\\"0195a527-f16b-7d83-b936-35bc2dd92f9d\\\"}\""
```

View File

@ -1,22 +0,0 @@
use fathom_function::Context;
use pipeline_application::application::Application;
use serde::Deserialize;
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> {
Application::new(context.env, context.org_id, &context.project_id)
.unwrap()
.update_assets_with_geo_locations(input.pipeline_id)
.await
.unwrap();
Ok("Success".to_owned())
}
#[derive(Debug, Deserialize)]
struct Input {
pipeline_id: Uuid,
}