8319fde node: Rename node `tracking` module — radicle-explorer

Radicle web interface

node: Rename node `tracking` module

cloudhead committed 2 years ago

commit 8319fde08f8fa589dfa089241173b781e1288ec5
parent 6ed02306467e0df4e2c20722de7b965b016e4320

3 files changed +10 -10

modified radicle-httpd/src/api.rs

@@ -18,8 +18,8 @@ use tower_http::cors::{self, CorsLayer};

 use radicle::cob::{issue, Uri};
 use radicle::cob::{patch, Embed};
 use radicle::identity::{DocAt, Id};
 use radicle::node::policy::Scope;
 use radicle::node::routing::Store;
 use radicle::node::tracking::Scope;
 use radicle::node::{Handle, NodeId};
 use radicle::storage::{Oid, ReadRepository, ReadStorage};
 use radicle::{Node, Profile};

modified radicle-httpd/src/api/error.rs

@@ -72,7 +72,7 @@ pub enum Error {

     /// Tracking store error.
     #[error(transparent)]
     TrackingStore(#[from] radicle::node::tracking::store::Error),
     TrackingStore(#[from] radicle::node::policy::store::Error),
     /// Node database error.
     #[error(transparent)]

modified radicle-httpd/src/api/v1/node.rs

@@ -7,7 +7,7 @@ use hyper::StatusCode;

 use serde_json::json;
 use radicle::identity::Id;
 use radicle::node::{tracking, Handle, DEFAULT_TIMEOUT};
 use radicle::node::{policy, Handle, DEFAULT_TIMEOUT};
 use radicle::Node;
 use crate::api::error::Error;

@@ -20,7 +20,7 @@ pub fn router(ctx: Context) -> Router {

         .route("/node/policies/repos", get(node_policies_repos_handler))
         .route(
             "/node/policies/repos/:rid",
             put(node_policies_track_handler).delete(node_policies_untrack_handler),
             put(node_policies_seed_handler).delete(node_policies_unseed_handler),
         )
         .with_state(ctx)
 }

@@ -57,7 +57,7 @@ async fn node_policies_repos_handler(State(ctx): State<Context>) -> impl IntoRes

     let tracking = ctx.profile.tracking()?;
     let mut repos = Vec::new();
     for tracking::Repo { id, scope, policy } in tracking.repo_policies()? {
     for policy::Repo { id, scope, policy } in tracking.repo_policies()? {
         repos.push(json!({
             "id": id,
             "scope": scope,

@@ -70,7 +70,7 @@ async fn node_policies_repos_handler(State(ctx): State<Context>) -> impl IntoRes

 /// Track a new repo.
 /// `PUT /node/policies/repos/:rid`
 async fn node_policies_track_handler(
 async fn node_policies_seed_handler(
     State(ctx): State<Context>,
     AuthBearer(token): AuthBearer,
     Path(project): Path<Id>,

@@ -78,7 +78,8 @@ async fn node_policies_track_handler(

 ) -> impl IntoResponse {
     api::auth::validate(&ctx, &token).await?;
     let mut node = Node::new(ctx.profile.socket());
     node.track_repo(project, qs.scope.unwrap_or_default())?;
     node.seed(project, qs.scope.unwrap_or_default())?;
     if let Some(from) = qs.from {
         let results = node.fetch(project, from, DEFAULT_TIMEOUT)?;
         return Ok::<_, Error>((

@@ -86,20 +87,19 @@ async fn node_policies_track_handler(

             Json(json!({ "success": true, "results": results })),
         ));
     }
     Ok::<_, Error>((StatusCode::OK, Json(json!({ "success": true }))))
 }
 /// Untrack a repo.
 /// `DELETE /node/policies/repos/:rid`
 async fn node_policies_untrack_handler(
 async fn node_policies_unseed_handler(
     State(ctx): State<Context>,
     AuthBearer(token): AuthBearer,
     Path(project): Path<Id>,
 ) -> impl IntoResponse {
     api::auth::validate(&ctx, &token).await?;
     let mut node = Node::new(ctx.profile.socket());
     node.untrack_repo(project)?;
     node.unseed(project)?;
     Ok::<_, Error>((StatusCode::OK, Json(json!({ "success": true }))))
 }