Struct LlmSftpHandler 

pub struct LlmSftpHandler { /* private fields */ }

LLM-controlled SFTP handler

This handler implements the russh_sftp::server::Handler trait but delegates all filesystem decisions to the LLM instead of using a real filesystem.

Implementations

impl LlmSftpHandler

pub fn new( connection_id: ConnectionId, server_id: ServerId, llm_client: OllamaClient, app_state: Arc<AppState>, protocol: Arc<SshProtocol>, status_tx: UnboundedSender<String>, owner: CancellationToken, ) -> Self

Create a new LLM-controlled SFTP handler

Trait Implementations

impl Handler for LlmSftpHandler

async fn stat(&mut self, id: u32, path: String) -> Result<Attrs, Self::Error>

SSH_FXP_STAT — the follow-symlinks form of lstat.

This used to fall through to unimplemented() and answer SSH_FX_OP_UNSUPPORTED, so sftp.stat(path) — what every client calls to size a file before downloading it, and what sftp -P … ls -l uses — failed against a server whose lstat worked fine. There is no filesystem behind this handler and therefore no symlink for the two calls to disagree about, so stat is lstat, exactly as fstat already is once its handle is resolved. The handler still sees a single lstat operation and needs no new vocabulary.

type Error = StatusCode

The type must have an Into<StatusCode> implementation because a response must be sent to any request, even if completed by error.

async fn init( &mut self, version: u32, extensions: HashMap<String, String>, ) -> Result<Version, Self::Error>

The default is to send an SSH_FXP_VERSION response with the protocol version and ignore any extensions.

async fn opendir( &mut self, id: u32, path: String, ) -> Result<Handle, Self::Error>

Called on SSH_FXP_OPENDIR

async fn readdir( &mut self, id: u32, handle: String, ) -> Result<Name, Self::Error>

Called on SSH_FXP_READDIR. EOF error should be returned at the end of reading the directory

async fn open( &mut self, id: u32, path: String, pflags: OpenFlags, _attrs: FileAttributes, ) -> Result<Handle, Self::Error>

Called on SSH_FXP_OPEN

async fn read( &mut self, id: u32, handle: String, offset: u64, len: u32, ) -> Result<Data, Self::Error>

Called on SSH_FXP_READ

async fn close( &mut self, id: u32, handle: String, ) -> Result<Status, Self::Error>

Called on SSH_FXP_CLOSE. The status can be returned as Ok or as Err

async fn lstat(&mut self, id: u32, path: String) -> Result<Attrs, Self::Error>

Called on SSH_FXP_LSTAT

async fn fstat(&mut self, id: u32, handle: String) -> Result<Attrs, Self::Error>

Called on SSH_FXP_FSTAT

async fn realpath(&mut self, id: u32, path: String) -> Result<Name, Self::Error>

Called on SSH_FXP_REALPATH. Must contain only one name and a dummy attributes

fn unimplemented(&self) -> Self::Error

Called by the handler when the packet is not implemented

fn write( &mut self, id: u32, handle: String, offset: u64, data: Vec<u8>, ) -> impl Future<Output = Result<Status, Self::Error>> + Send

Called on SSH_FXP_WRITE

fn setstat( &mut self, id: u32, path: String, attrs: FileAttributes, ) -> impl Future<Output = Result<Status, Self::Error>> + Send

Called on SSH_FXP_SETSTAT

fn fsetstat( &mut self, id: u32, handle: String, attrs: FileAttributes, ) -> impl Future<Output = Result<Status, Self::Error>> + Send

Called on SSH_FXP_FSETSTAT

fn remove( &mut self, id: u32, filename: String, ) -> impl Future<Output = Result<Status, Self::Error>> + Send

Called on SSH_FXP_REMOVE. The status can be returned as Ok or as Err

fn mkdir( &mut self, id: u32, path: String, attrs: FileAttributes, ) -> impl Future<Output = Result<Status, Self::Error>> + Send

Called on SSH_FXP_MKDIR

fn rmdir( &mut self, id: u32, path: String, ) -> impl Future<Output = Result<Status, Self::Error>> + Send

Called on SSH_FXP_RMDIR. The status can be returned as Ok or as Err

fn rename( &mut self, id: u32, oldpath: String, newpath: String, ) -> impl Future<Output = Result<Status, Self::Error>> + Send

Called on SSH_FXP_RENAME. The status can be returned as Ok or as Err

fn readlink( &mut self, id: u32, path: String, ) -> impl Future<Output = Result<Name, Self::Error>> + Send

Called on SSH_FXP_READLINK

fn symlink( &mut self, id: u32, linkpath: String, targetpath: String, ) -> impl Future<Output = Result<Status, Self::Error>> + Send

Called on SSH_FXP_SYMLINK. The status can be returned as Ok or as Err

fn extended( &mut self, id: u32, request: String, data: Vec<u8>, ) -> impl Future<Output = Result<Packet, Self::Error>> + Send

Called on SSH_FXP_EXTENDED. The extension can return any packet, so it’s not specific. If the server does not recognize the `request’ name the server must respond with an SSH_FX_OP_UNSUPPORTED error