feat: Development

bin/main.rs

@@ -2,10 +2,9 @@ use axum::body::Body;
 use axum::extract::{Query, Request};
 use axum::http::StatusCode;
 use axum::response::{IntoResponse, Response};
-use axum::routing::{delete, head, post, put};
+use axum::routing::{delete, get, post, put};
 use axum::{
     extract::{Path, State},
-    routing::get,
     Json, Router,
 };
 use clap::{Parser, Subcommand};
@@ -97,12 +96,6 @@ struct AppState {
     config: Arc<RwLock<Config>>,
     config_path: PathBuf,
 }
-
-#[derive(Serialize)]
-struct TableExistsResponse {
-    pub exists: bool,
-}
-
 #[derive(Serialize)]
 struct TablesExistsResponse {
     pub exists: bool,
@@ -160,7 +153,6 @@ async fn app() -> Result<(), Error> {
                 .route("/tables/:table/", get(table_ls))
                 .route("/tables/:table/share/", get(table_share))
                 .route("/tables/:table/*key", get(table_get))
-                .route("/tables/:table/*key", head(table_exists))
                 .route("/tables/:table/*key", put(table_insert))
                 .route("/tables/:table/*key", delete(table_delete))
                 .route("/tables/foreign_insert/", post(table_foreign_insert))
@@ -466,22 +458,6 @@ async fn table_delete(
     }
 }
 
-async fn table_exists(
-    State(state): State<AppState>,
-    Path((table, key)): Path<(String, String)>,
-) -> Response {
-    match state
-        .iroh_node
-        .read()
-        .await
-        .table_exists(&table, &key)
-        .await
-    {
-        Ok(exists) => Json(TableExistsResponse { exists }).into_response(),
-        Err(e) => e.into_response(),
-    }
-}
-
 async fn table_ls(State(state): State<AppState>, Path(table): Path<String>) -> Response {
     match state.iroh_node.read().await.table_keys(&table) {
         Some(stream) => Response::builder().body(Body::from_stream(stream)).unwrap(),

src/iroh_node.rs

@@ -408,13 +408,6 @@ impl IrohNode {
         }
     }
 
-    pub async fn table_exists(&self, table_name: &str, key: &str) -> Result<bool> {
-        match self.table_storages.get(table_name) {
-            Some(table_storage) => Ok(table_storage.exists(key).await?.is_some()),
-            None => Err(Error::missing_table(table_name)),
-        }
-    }
-
     pub fn table_keys(&self, table_name: &str) -> Option<impl Stream<Item = Result<String>>> {
         self.table_storages.get(table_name).cloned().map_or_else(
             || None,

src/storage.rs

@@ -351,21 +351,6 @@ impl Storage {
         })
     }
 
-    pub async fn exists(&self, key: &str) -> Result<Option<PathBuf>> {
-        for file_shard_config in self.hash_ring.range(key, 1) {
-            let file_shard = &self.shards[&file_shard_config.name];
-            if file_shard
-                .exists(key)
-                .await
-                .map_err(Error::io_error)?
-                .is_some()
-            {
-                return Ok(Some(file_shard.get_path_for(key)));
-            }
-        }
-        Ok(None)
-    }
-
     pub fn iroh_doc(&self) -> &IrohDoc {
         &self.iroh_doc
     }

trident-py/pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "izihawa-trident-client"
-version = "1.1.0"
+version = "1.1.1"
 description = ""
 authors = ["Pasha Podolsky <[email protected]>"]
 readme = "README.md"

trident-py/trident/client.py

@@ -114,7 +114,4 @@ async def table_ls(self, table) -> typing.AsyncGenerator[str, None]:
     async def table_exists(self, table: str, key: str) -> bool:
         url = f"/tables/{table}/{key}"
         response = await self.head(url)
-        if response is None:
-            return False
-        response = await response.json()
-        return response["exists"]
+        return response is not None