Implement a basic nfs server

Cargo.toml

@@ -31,6 +31,7 @@ iroh-base = "0.12.0"
 tokio-util = { version = "0.7.10", features = ["codec"] }
 async-recursion = "1.0.5"
 quick_cache = "0.4.0"
+nfsserve = { git = "https://github.com/xetdata/nfsserve", revision = "46322e7823ccb3f0a2e549dfa91fbf7dada9c42a" }
 quinn = "0.10.2"
 
 # enable the "rug" feature (using GMP) for rs-wnfs, speeding up nameaccumulator operations

src/lib.rs

@@ -1,3 +1,4 @@
 pub mod commands;
+pub mod nfs;
 pub mod state;
 pub mod store;

src/main.rs

@@ -3,8 +3,10 @@ use std::path::{Component, Path};
 use anyhow::{Context as _, Result};
 use appa::commands::doctor::doctor;
 use appa::commands::listen_sync::{listen, sync};
+use appa::nfs::AppaNfs;
 use appa::state::Appa;
 use futures::TryStreamExt;
+use nfsserve::tcp::{NFSTcp, NFSTcpListener};
 use tokio::io::AsyncWriteExt;
 
 use clap::{Parser, Subcommand};
@@ -82,6 +84,8 @@ enum Commands {
         #[arg(value_name = "ITEM")]
         item: String,
     },
+    /// Run an NFS server for the appa filesystem locally
+    Nfsserve,
 }
 
 #[tokio::main]
@@ -170,6 +174,16 @@ async fn main() -> Result<()> {
         Commands::Sync { ticket } => {
             sync(ticket).await?;
         }
+        Commands::Nfsserve => {
+            const HOSTPORT: u32 = 11111;
+            let appa = Appa::load().await?;
+            let listener =
+                NFSTcpListener::bind(&format!("127.0.0.1:{HOSTPORT}"), AppaNfs::new(appa))
+                    .await
+                    .unwrap();
+            tracing::info!("Staring serve");
+            listener.handle_forever().await?;
+        }
     }
 
     Ok(())