diff --git a/include/libssh/callbacks.h b/include/libssh/callbacks.h index a838bdce..5fd7dd1e 100644 --- a/include/libssh/callbacks.h +++ b/include/libssh/callbacks.h @@ -569,6 +569,18 @@ typedef int (*ssh_channel_env_request_callback) (ssh_session session, const char *env_name, const char *env_value, void *userdata); +/** + * @brief SSH channel subsystem request from a client. + * @param channel the channel + * @param subsystem the subsystem required + * @param userdata Userdata to be passed to the callback function. + * @returns 0 if the subsystem request is accepted + * @returns 1 if the request is denied + */ +typedef int (*ssh_channel_subsystem_request_callback) (ssh_session session, + ssh_channel channel, + const char *subsystem, + void *userdata); struct ssh_channel_callbacks_struct { @@ -630,6 +642,10 @@ struct ssh_channel_callbacks_struct { * variable to be set. */ ssh_channel_env_request_callback channel_env_request_function; + /** This function will be called when a client requests a subsystem + * (like sftp). + */ + ssh_channel_subsystem_request_callback channel_subsystem_request_function; }; typedef struct ssh_channel_callbacks_struct *ssh_channel_callbacks; diff --git a/src/messages.c b/src/messages.c index 450b3236..d1e88765 100644 --- a/src/messages.c +++ b/src/messages.c @@ -198,6 +198,17 @@ static int ssh_execute_server_callbacks(ssh_session session, ssh_message msg){ ssh_message_reply_default(msg); return SSH_OK; } + } else if(msg->channel_request.type == SSH_CHANNEL_REQUEST_SUBSYSTEM){ + if(ssh_callbacks_exists(channel->callbacks, channel_subsystem_request_function)){ + rc = channel->callbacks->channel_subsystem_request_function(session, channel, + msg->channel_request.subsystem, + channel->callbacks->userdata); + if(rc == 0) + ssh_message_channel_request_reply_success(msg); + else + ssh_message_reply_default(msg); + return SSH_OK; + } } break; case SSH_REQUEST_SERVICE: