first working command execution

1 files changed, 57 insertions, 2 deletions

diff --git a/src/cssh.c b/src/cssh.c
index 3bb4cb9..a255618 100644
--- a/src/cssh.c
+++ b/src/cssh.c
@@ -273,9 +273,64 @@ int main( int argc, char *argv[] )
 			exit( EXIT_FAILURE );
 		}
 	}
-			
+	
+	ssh_channel channel = ssh_channel_new( session );
+	if( channel == NULL ) {
+		fprintf( stderr, "ERROR: Unable to open SSH channel: %s\n",
+			ssh_get_error( session ) );
+		ssh_disconnect( session );
+		ssh_free( session );
+		exit( EXIT_FAILURE );
+	}
+
+	rc = ssh_channel_open_session( channel );
+	if( rc != SSH_OK ) {
+		ssh_channel_free( channel );
+		ssh_disconnect( session );
+		ssh_free( session );
+		exit( EXIT_FAILURE );
+	}
+		
+	rc = ssh_channel_request_exec( channel, "ps -alef" );
+	if( rc != SSH_OK ) {
+		ssh_channel_close( channel );
+		ssh_channel_free( channel );
+		ssh_disconnect( session );
+		ssh_free( session );
+		exit( EXIT_FAILURE );
+	}
+	
+	char buffer[256];
+	unsigned int nread = ssh_channel_read( channel, buffer, sizeof( buffer ), 0 );
+	while( nread > 0 ) {
+		size_t wrc = fwrite( buffer, 1, nread, stdout );
+		if( wrc < 0 ) {
+			fprintf( stderr, "ERROR: while writting to stdout: %s\n",
+				strerror( errno ) );
+			ssh_channel_close( channel );
+			ssh_channel_free( channel );
+			ssh_disconnect( session );
+			ssh_free( session );
+			exit( EXIT_FAILURE );
+		}
+		
+		if( wrc != nread ) {
+			fprintf( stderr, "ERROR: Write mismatch on stdout (%d != %d)\n",
+				wrc, nread );
+			ssh_channel_close( channel );
+			ssh_channel_free( channel );
+			ssh_disconnect( session );
+			ssh_free( session );
+			exit( EXIT_FAILURE );
+		}
+		
+		nread = ssh_channel_read( channel, buffer, sizeof( buffer ), 0 );
+	}
+	
+	ssh_channel_send_eof( channel );
+	ssh_channel_close( channel );
+	ssh_channel_free( channel );	
 	ssh_disconnect( session );
-  
 	ssh_free( session );
 	
 	exit( EXIT_SUCCESS );