--- lbbs/src/bbs_net.c	2025/05/15 08:53:23	1.43
+++ lbbs/src/bbs_net.c	2025/06/05 08:36:02	1.48
@@ -36,6 +36,9 @@
 #include <netinet/in.h>
 #include <netinet/ip.h>
 #include <arpa/inet.h>
+#include <libssh/libssh.h>
+#include <libssh/server.h>
+#include <libssh/callbacks.h>
 
 #define MENU_CONF_DELIM " \t\r\n"
 
@@ -239,7 +242,7 @@ int bbsnet_connect(int n)
 	}
 
 	sin.sin_family = AF_INET;
-	sin.sin_addr.s_addr = (hostaddr_server[0] != '\0' ? inet_addr(hostaddr_server) : INADDR_ANY);
+	sin.sin_addr.s_addr = (BBS_address[0] != '\0' ? inet_addr(BBS_address) : INADDR_ANY);
 	sin.sin_port = 0;
 
 	if (bind(sock, (struct sockaddr *)&sin, sizeof(sin)) < 0)
@@ -357,7 +360,7 @@ int bbsnet_connect(int n)
 				else if (events[i].data.fd == STDIN_FILENO)
 				{
 					ch = igetch(0);
-					if (ch == Ctrl('C'))
+					if (ch == Ctrl('C') || ch == KEY_ESC)
 					{
 						goto cleanup;
 					}
@@ -385,7 +388,7 @@ int bbsnet_connect(int n)
 
 	prints("\033[1;31mÁ¬½Ó³É¹¦£¡\033[m\r\n");
 	iflush();
-	log_std("BBSNET connect to %s:%d\n", remote_addr, remote_port);
+	log_common("BBSNET connect to %s:%d\n", remote_addr, remote_port);
 
 	ev.events = EPOLLIN | EPOLLOUT | EPOLLET;
 	ev.data.fd = sock;
@@ -408,6 +411,13 @@ int bbsnet_connect(int n)
 
 	while (loop && !SYS_server_exit)
 	{
+		if (SSH_v2 && ssh_channel_is_closed(SSH_channel))
+		{
+			log_error("SSH channel is closed\n");
+			loop = 0;
+			break;
+		}
+
 		nfds = epoll_wait(epollfd, events, MAX_EVENTS, 100); // 0.1 second
 
 		if (nfds < 0)
@@ -435,7 +445,31 @@ int bbsnet_connect(int n)
 				stdin_read_wait = 1;
 				while (input_buf_len < sizeof(input_buf) && !SYS_server_exit)
 				{
-					ret = (int)read(STDIN_FILENO, input_buf + input_buf_len, sizeof(input_buf) - (size_t)input_buf_len);
+					if (SSH_v2)
+					{
+						ret = ssh_channel_read_nonblocking(SSH_channel, input_buf + input_buf_len, sizeof(input_buf) - (uint32_t)input_buf_len, 0);
+						if (ret == SSH_ERROR)
+						{
+							log_error("ssh_channel_read_nonblocking() error: %s\n", ssh_get_error(SSH_session));
+							loop = 0;
+							break;
+						}
+						else if (ret == SSH_EOF)
+						{
+							stdin_read_wait = 0;
+							loop = 0;
+							break;
+						}
+						else if (ret == 0)
+						{
+							stdin_read_wait = 0;
+							break; // Check whether channel is still open
+						}
+					}
+					else
+					{
+						ret = (int)read(STDIN_FILENO, input_buf + input_buf_len, sizeof(input_buf) - (size_t)input_buf_len);
+					}
 					if (ret < 0)
 					{
 						if (errno == EAGAIN || errno == EWOULDBLOCK)
@@ -456,7 +490,7 @@ int bbsnet_connect(int n)
 					}
 					else if (ret == 0) // broken pipe
 					{
-						log_std("read(STDIN) EOF\n");
+						log_common("read(STDIN) EOF\n");
 						stdin_read_wait = 0;
 						loop = 0;
 						break;
@@ -496,7 +530,7 @@ int bbsnet_connect(int n)
 					}
 					else if (ret == 0) // broken pipe
 					{
-						log_std("write(socket) EOF\n");
+						log_common("write(socket) EOF\n");
 						sock_write_wait = 0;
 						loop = 0;
 						break;
@@ -541,7 +575,7 @@ int bbsnet_connect(int n)
 					}
 					else if (ret == 0) // broken pipe
 					{
-						log_std("read(socket) EOF\n");
+						log_common("read(socket) EOF\n");
 						sock_read_wait = 0;
 						loop = 0;
 						break;
@@ -559,7 +593,20 @@ int bbsnet_connect(int n)
 				stdout_write_wait = 1;
 				while (output_buf_offset < output_buf_len && !SYS_server_exit)
 				{
-					ret = (int)write(STDOUT_FILENO, output_buf + output_buf_offset, (size_t)(output_buf_len - output_buf_offset));
+					if (SSH_v2)
+					{
+						ret = ssh_channel_write(SSH_channel, output_buf + output_buf_offset, (uint32_t)(output_buf_len - output_buf_offset));
+						if (ret == SSH_ERROR)
+						{
+							log_error("ssh_channel_write() error: %s\n", ssh_get_error(SSH_session));
+							loop = 0;
+							break;
+						}
+					}
+					else
+					{
+						ret = (int)write(STDOUT_FILENO, output_buf + output_buf_offset, (size_t)(output_buf_len - output_buf_offset));
+					}
 					if (ret < 0)
 					{
 						if (errno == EAGAIN || errno == EWOULDBLOCK)
@@ -580,7 +627,7 @@ int bbsnet_connect(int n)
 					}
 					else if (ret == 0) // broken pipe
 					{
-						log_std("write(STDOUT) EOF\n");
+						log_common("write(STDOUT) EOF\n");
 						stdout_write_wait = 0;
 						loop = 0;
 						break;
@@ -622,9 +669,9 @@ cleanup:
 	t_used = time(0) - t_used;
 	tm_used = gmtime(&t_used);
 
-	log_std("BBSNET disconnect, %d days %d hours %d minutes %d seconds used\n",
-			tm_used->tm_mday - 1, tm_used->tm_hour, tm_used->tm_min,
-			tm_used->tm_sec);
+	log_common("BBSNET disconnect, %d days %d hours %d minutes %d seconds used\n",
+			   tm_used->tm_mday - 1, tm_used->tm_hour, tm_used->tm_min,
+			   tm_used->tm_sec);
 
 	return 0;
 }
@@ -697,7 +744,8 @@ int bbs_net()
 		ch = igetch(100);
 		switch (ch)
 		{
-		case KEY_NULL:	// broken pipe
+		case KEY_NULL: // broken pipe
+		case KEY_ESC:
 		case Ctrl('C'): // user cancel
 			goto cleanup;
 		case KEY_TIMEOUT:
@@ -735,10 +783,16 @@ int bbs_net()
 			menu_control(&bbsnet_menu, KEY_DOWN);
 			bbsnet_selchange();
 			break;
+		case KEY_HOME:
 		case KEY_PGUP:
 			menu_control(&bbsnet_menu, KEY_PGUP);
 			bbsnet_selchange();
 			break;
+		case KEY_END:
+		case KEY_PGDN:
+			menu_control(&bbsnet_menu, KEY_PGDN);
+			bbsnet_selchange();
+			break;
 		default:
 			menu_control(&bbsnet_menu, ch);
 			bbsnet_selchange();