Compare commits

..

No commits in common. "275590709acb44705be95cb91fb59816bed3ba7c" and "394b0b5b7774d03aef7dc4b93670d4bcb2cd3b2d" have entirely different histories.

6 changed files with 7 additions and 103 deletions

1
Cargo.lock generated
View File

@ -304,7 +304,6 @@ version = "0.1.0"
dependencies = [
"axum",
"serde",
"tokio",
]
[[package]]

View File

@ -3,14 +3,6 @@ name = "offline-web"
version = "0.1.0"
edition = "2021"
[lib]
path = "src/lib.rs"
[[bin]]
name = "example"
path = "src/main.rs"
[dependencies]
axum = "0.8.3"
serde = { version = "1.0.219", features = ["derive", "rc"] }
tokio = "1.44.1"

View File

@ -90,7 +90,7 @@ operations.
### Bootstrapping
* Load `/api/v1/ref/all/<username>` and then follow the sub resources to
* Load `/api/v1/resource/all/<username>` and then follow the sub resources to
load the entire dataset locally making sure to keep the content-addresses
around for comparison.

View File

@ -5,17 +5,15 @@ use serde::{Serialize, Deserialize};
#[derive(Serialize, Deserialize)]
pub struct Reference {
object_id: String,
content_address: String,
path: String,
#[serde(skip_serializing_if = "Vec::is_empty")]
dependents: Vec<Rc<Reference>>,
}
impl Reference {
pub fn new(object_id: String, content_address: String, path: String) -> Self {
pub fn new(object_id: String, path: String) -> Self {
Self {
object_id,
content_address,
path,
dependents: Vec::new(),
}

View File

@ -1,90 +1,10 @@
use std::rc::Rc;
use axum::{extract::Path, routing::get, Json, Router};
use datamodel::Reference;
use axum::{
routing::get,
Router
};
mod datamodel;
async fn all_references() -> Json<Rc<Reference>> {
let path_root = String::from("ref/0");
let mut root_ref = Reference::new(
"username:0".to_string(),
String::from("0"),
path_root.clone(),
);
for i in 1..=10 {
let mut item_ref = Reference::new(
format!("item:{}", i),
format!("0:{}", i),
format!("{}/item/{}", path_root, i),
);
for j in 1..=10 {
item_ref = item_ref.add_dep(Rc::new(Reference::new(
format!("item:{}:subitem:{}", i, j),
format!("0:{}:{}", i, j),
format!("{}/item/{}/subitem/{}", path_root, i, j),
)));
}
root_ref = root_ref.add_dep(Rc::new(item_ref));
}
Json(root_ref.to_rc())
}
async fn dummy_item_ref(Path(i): Path<usize>) -> Json<Rc<Reference>> {
let path_root = String::from("ref/0");
let mut item_ref = Reference::new(
format!("item:{}", i),
format!("0:{}", i),
format!("{}/item/{}", path_root, i),
);
for j in 1..=10 {
item_ref = item_ref.add_dep(Rc::new(Reference::new(
format!("item:{}:subitem:{}", i, j),
format!("0:{}:{}", i, j),
format!("{}/item/{}/subitem/{}", path_root, i, j),
)));
}
Json(item_ref.to_rc())
}
async fn dummy_subitem_ref(Path(i): Path<usize>, Path(j): Path<usize>) -> Json<Rc<Reference>> {
let path_root = String::from("ref/0");
Json(
Reference::new(
format!("item:{}:subitem:{}", i, j),
format!("0:{}:{}", i, j),
format!("{}/item/{}/subitem/{}", path_root, i, j),
)
.to_rc(),
)
}
async fn dummy_object(Path(addr): Path<String>) -> String {
format!("I am object {}", addr)
}
pub fn endpoints() -> Router {
Router::new().nest(
"/api/v1",
Router::new().nest(
"/ref",
Router::new()
.route("/all/username", get(all_references))
.route("/item/{i}", get(dummy_item_ref))
.route("/item/{i}/subitem/{j}", get(dummy_subitem_ref))
).nest(
"/object",
Router::new()
.route("/{addr}", get(dummy_object))
),
)
}
// TODO(jwall): Javascript test script
pub async fn serve() {
// run our app with hyper, listening globally on port 3000
let listener = tokio::net::TcpListener::bind("127.0.0.1:3000")
.await
.unwrap();
axum::serve(listener, endpoints()).await.unwrap();
Router::new().route("/api/v1/ref/all/username", get(|| async { "hello world" }))
}

View File

@ -1,5 +0,0 @@
#[tokio::main(flavor = "current_thread")]
async fn main() {
offline_web::serve().await;
}