feat(terminal):1.12.5, 添加stdio的终端方式

Author: hevake

examples/network/stdio_stream/01_stdin_out/main.cpp

@@ -32,6 +32,9 @@ int main()
     auto sp_stdin = new network::StdinStream(sp_loop);
     auto sp_stdout = new network::StdoutStream(sp_loop);
 
+    sp_stdin->initialize();
+    sp_stdout->initialize();
+
     sp_stdin->bind(sp_stdout);
 
     sp_stdin->enable();

examples/network/stdio_stream/02_stdio/main.cpp

@@ -31,6 +31,8 @@ int main()
     auto sp_loop = event::Loop::New();
     auto sp_stdio = new network::StdioStream(sp_loop);
 
+    sp_stdio->initialize();
+
     sp_stdio->bind(sp_stdio);
     sp_stdio->enable();
 
@@ -53,3 +55,4 @@ int main()
     delete sp_loop;
     return 0;
 }
+

examples/terminal/build_nodes.cpp

@@ -137,6 +137,7 @@ void BuildNodes(TerminalNodes &term, Loop *wp_loop)
 
     term.mountNode(dir1_1_token, term.rootNode(), "root");  //! 循环引用
 
+    //! 演示使用 AddFuncNode() 函数直接添加函数结点
     auto add_func_dir_node = term.createDirNode();
     term.mountNode(term.rootNode(), add_func_dir_node, "add_func");
 
@@ -145,4 +146,44 @@ void BuildNodes(TerminalNodes &term, Loop *wp_loop)
     AddFuncNode(term, add_func_dir_node, "int_value", int_value, 0, 100);
     AddFuncNode(term, add_func_dir_node, "double_value", double_value, 0, 1);
     AddFuncNode(term, add_func_dir_node, "str_value", str_value);
+
+    //! 演示使用 XxxxxFuncNodeProfile 来添加函数结点
+    auto profile_func_dir_node = term.createDirNode();
+    term.mountNode(term.rootNode(), profile_func_dir_node, "profile_func");
+
+    {
+        BooleanFuncNodeProfile profile;
+        profile.set_func = [&] (bool value) { bool_value = value; return true; };
+        profile.get_func = [&] () { return bool_value; };
+
+        AddFuncNode(term, profile_func_dir_node, "bool_value", profile);
+    }
+
+    {
+        StringFuncNodeProfile profile;
+        profile.set_func = [&] (const std::string &value) { str_value = value; return true; };
+        profile.get_func = [&] () { return str_value; };
+
+        AddFuncNode(term, profile_func_dir_node, "str_value", profile);
+    }
+
+    {
+        IntegerFuncNodeProfile profile;
+        profile.set_func = [&] (int value) { int_value = value; return true; };
+        profile.get_func = [&] () { return int_value; };
+        profile.min_value = 1;
+        profile.max_value = 5;
+
+        AddFuncNode(term, profile_func_dir_node, "int_value", profile);
+    }
+
+    {
+        DoubleFuncNodeProfile profile;
+        profile.set_func = [&] (double value) { double_value = value; return true; };
+        profile.get_func = [&] () { return double_value; };
+        profile.min_value = -1;
+        profile.max_value = 1;
+
+        AddFuncNode(term, profile_func_dir_node, "double_value", profile);
+    }
 }

examples/terminal/stdio/Makefile

@@ -0,0 +1,35 @@
+#
+#     .============.
+#    //  M A K E  / \
+#   //  C++ DEV  /   \
+#  //  E A S Y  /  \/ \
+# ++ ----------.  \/\  .
+#  \\     \     \ /\  /
+#   \\     \     \   /
+#    \\     \     \ /
+#     -============'
+#
+# Copyright (c) 2018 Hevake and contributors, all rights reserved.
+#
+# This file is part of cpp-tbox (https://github.com/cpp-main/cpp-tbox)
+# Use of this source code is governed by MIT license that can be found
+# in the LICENSE file in the root of the source tree. All contributing
+# project authors may be found in the CONTRIBUTORS.md file in the root
+# of the source tree.
+#
+
+PROJECT := examples/terminal/stdio
+EXE_NAME := ${PROJECT}
+
+CPP_SRC_FILES := main.cpp ../build_nodes.cpp
+
+CXXFLAGS := -DMODULE_ID='"$(EXE_NAME)"' $(CXXFLAGS)
+LDFLAGS += \
+	-ltbox_terminal \
+	-ltbox_network \
+	-ltbox_event \
+	-ltbox_util \
+	-ltbox_base \
+	-ldl
+
+include $(TOP_DIR)/mk/exe_common.mk

examples/terminal/stdio/main.cpp

@@ -0,0 +1,69 @@
+/*
+ *     .============.
+ *    //  M A K E  / \
+ *   //  C++ DEV  /   \
+ *  //  E A S Y  /  \/ \
+ * ++ ----------.  \/\  .
+ *  \\     \     \ /\  /
+ *   \\     \     \   /
+ *    \\     \     \ /
+ *     -============'
+ *
+ * Copyright (c) 2025 Hevake and contributors, all rights reserved.
+ *
+ * This file is part of cpp-tbox (https://github.com/cpp-main/cpp-tbox)
+ * Use of this source code is governed by MIT license that can be found
+ * in the LICENSE file in the root of the source tree. All contributing
+ * project authors may be found in the CONTRIBUTORS.md file in the root
+ * of the source tree.
+ */
+#include <string>
+#include <signal.h>
+
+#include <tbox/base/scope_exit.hpp>
+#include <tbox/base/log_output.h>
+
+#include <tbox/event/loop.h>
+#include <tbox/event/signal_event.h>
+
+#include <tbox/terminal/terminal.h>
+#include <tbox/terminal/service/stdio.h>
+
+using namespace tbox;
+
+void BuildNodes(terminal::TerminalNodes &term, event::Loop *wp_loop);
+
+int main()
+{
+    //LogOutput_Enable();
+    auto sp_loop = event::Loop::New();
+    SetScopeExitAction([sp_loop] { delete sp_loop; });
+
+    terminal::Terminal term(sp_loop);
+    terminal::Stdio stdio(sp_loop, &term);
+    stdio.initialize();
+
+    term.setWelcomeText("Welcome to Terminal STDIO demo! \r\n");
+
+    //! 注册ctrl+C停止信号
+    auto *sp_stop_ev = sp_loop->newSignalEvent();
+    SetScopeExitAction([sp_stop_ev] { delete sp_stop_ev; });
+    sp_stop_ev->initialize({SIGINT,SIGTERM}, event::Event::Mode::kOneshot);
+    //! 指定ctrl+C时要做的事务
+    sp_stop_ev->setCallback(
+        [&] (int) {
+            stdio.stop();
+            sp_loop->exitLoop();    //! (3) 退出事件循环
+        }
+    );
+    sp_stop_ev->enable();
+
+    BuildNodes(term, sp_loop);
+
+    stdio.start();
+
+    sp_loop->runLoop();
+
+    stdio.cleanup();
+    return 0;
+}

modules/network/stdio_stream.cpp

@@ -26,8 +26,12 @@ namespace network {
 
 StdinStream::StdinStream(event::Loop *wp_loop) :
     buff_fd_(wp_loop)
+{ }
+
+bool StdinStream::initialize()
 {
     buff_fd_.initialize(STDIN_FILENO, BufferedFd::kReadOnly);
+    return true;
 }
 
 bool StdinStream::enable()
@@ -47,8 +51,12 @@ bool StdinStream::disable()
 
 StdoutStream::StdoutStream(event::Loop *wp_loop) :
     buff_fd_(wp_loop)
+{ }
+
+bool StdoutStream::initialize()
 {
     buff_fd_.initialize(STDOUT_FILENO, BufferedFd::kWriteOnly);
+    return true;
 }
 
 void StdoutStream::setSendCompleteCallback(const SendCompleteCallback &cb)
@@ -74,19 +82,23 @@ bool StdoutStream::disable()
 StdioStream::StdioStream(event::Loop *wp_loop) :
     in_buff_fd_(wp_loop),
     out_buff_fd_(wp_loop)
+{ }
+
+bool StdioStream::initialize()
 {
     in_buff_fd_.initialize(STDIN_FILENO, BufferedFd::kReadOnly);
     out_buff_fd_.initialize(STDOUT_FILENO, BufferedFd::kWriteOnly);
+    return true;
 }
 
 void StdioStream::setReceiveCallback(const ReceiveCallback &cb, size_t threshold)
 {
-    out_buff_fd_.setReceiveCallback(cb, threshold);
+    in_buff_fd_.setReceiveCallback(cb, threshold);
 }
 
 void StdioStream::setSendCompleteCallback(const SendCompleteCallback &cb)
 {
-    in_buff_fd_.setSendCompleteCallback(cb);
+    out_buff_fd_.setSendCompleteCallback(cb);
 }
 
 bool StdioStream::send(const void *data_ptr, size_t data_size)

modules/network/stdio_stream.h

@@ -47,6 +47,8 @@ class StdinStream : public ByteStream {
     virtual void unbind() override { buff_fd_.unbind(); }
     virtual Buffer* getReceiveBuffer() override { return buff_fd_.getReceiveBuffer(); }
 
+    bool initialize();
+
     bool enable();
     bool disable();
 
@@ -69,6 +71,8 @@ class StdoutStream : public ByteStream {
     virtual void unbind() override { }
     virtual Buffer* getReceiveBuffer() override { return nullptr; }
 
+    bool initialize();
+
     bool enable();
     bool disable();
 
@@ -91,6 +95,8 @@ class StdioStream : public ByteStream {
     virtual void unbind() override { in_buff_fd_.unbind(); }
     virtual Buffer* getReceiveBuffer() override { return in_buff_fd_.getReceiveBuffer(); }
 
+    bool initialize();
+
     bool enable();
     bool disable();
 

modules/terminal/Makefile

@@ -34,13 +34,15 @@ HEAD_FILES = \
 	terminal.h \
 	service/telnetd.h \
 	service/tcp_rpc.h \
+	service/stdio.h \
 
 CPP_SRC_FILES = \
 	terminal.cpp \
 	session.cpp \
 	service/telnetd.cpp \
-	helper.cpp \
 	service/tcp_rpc.cpp \
+	service/stdio.cpp \
+	helper.cpp \
 	impl/terminal.cpp \
 	impl/terminal_key_events.cpp \
 	impl/terminal_commands.cpp \
@@ -50,6 +52,7 @@ CPP_SRC_FILES = \
 	impl/func_node.cpp \
 	impl/service/telnetd.cpp \
 	impl/service/tcp_rpc.cpp \
+	impl/service/stdio.cpp \
 
 CXXFLAGS := -DMODULE_ID='"tbox.terminal"' $(CXXFLAGS)