Add support for broadcasting data in sessions #36

Signed-off-by: xiaoming <2014500726@smail.xtu.edu.cn>
QQxiaoming · May 26, 2024 · a289244 · a289244
1 parent ced4472
commit a289244
Show file tree

Hide file tree

Showing 4 changed files with 54 additions and 2 deletions.
diff --git a/src/mainwindow.cpp b/src/mainwindow.cpp
@@ -85,8 +85,6 @@ CentralWidget::CentralWidget(QString dir, StartupUIMode mode, QLocale lang, bool
 
     setWindowTitle(QApplication::applicationName()+" - "+VERSION);
 
-
-
     splitter = new QSplitter(Qt::Horizontal,this);
     splitter->setHandleWidth(1);
     ui->centralwidget->layout()->addWidget(splitter);
@@ -398,6 +396,24 @@ CentralWidget::CentralWidget(QString dir, StartupUIMode mode, QLocale lang, bool
                         });
                     }
                     #endif
+                    QAction *addToBroadCastSessionListAction = new QAction(tr("Add to BroadCast List"),this);
+                    addToBroadCastSessionListAction->setStatusTip(tr("Add current session to broadcast list"));
+                    addToBroadCastSessionListAction->setCheckable(true);
+                    addToBroadCastSessionListAction->setChecked(sessionsWindow->isInBroadCastList());
+                    if(sessionsWindow->isInBroadCastList()) {
+                        addToBroadCastSessionListAction->setText(tr("Remove from BroadCast List"));
+                    }
+                    menu->addAction(addToBroadCastSessionListAction);
+                    connect(addToBroadCastSessionListAction,&QAction::triggered,this,[=](){
+                        QWidget *widget = mainWidgetGroup->sessionTab->currentWidget();
+                        SessionsWindow *sessionsWindow = widget->property("session").value<SessionsWindow *>();
+                        sessionsWindow->setInBroadCastList(!sessionsWindow->isInBroadCastList());
+                        if(sessionsWindow->isInBroadCastList()) {
+                            broadCastSessionList.append(sessionsWindow);
+                        } else {
+                            broadCastSessionList.removeAll(sessionsWindow);
+                        }
+                    });
                     QAction *saveSessionAction = new QAction(tr("Save Session"),this);
                     saveSessionAction->setStatusTip(tr("Save current session to session manager"));
                     menu->addAction(saveSessionAction);
@@ -2017,6 +2033,10 @@ void CentralWidget::onPluginReadSettings(QString group, QString key, QVariant &v
     value = settings.value("Plugin/"+iface->name()+"/"+group+"/"+key);
 }
 
+void CentralWidget::onBroadCastSendData(const QByteArray &data) {
+
+}
+
 void CentralWidget::setSessionClassActionEnable(bool enable)
 {
     reconnectAction->setEnabled(enable);
@@ -3000,6 +3020,13 @@ void CentralWidget::setGlobalOptions(SessionsWindow *window) {
     window->setZmodemOnlie(!globalOptionsWindow->getDisableZmodemOnline());
     window->setZmodemUploadPath(globalOptionsWindow->getModemUploadPath());
     window->setZmodemDownloadPath(globalOptionsWindow->getModemDownloadPath());
+    connect(window,&SessionsWindow::broadCastSendData,this,[=](const QByteArray &data){
+        foreach(SessionsWindow *sessionsWindow, broadCastSessionList) {
+            if(sessionsWindow != window) {
+                sessionsWindow->reverseProxySendData(data);
+            }
+        }
+    });
 }
 
 void CentralWidget::restoreSessionToSessionManager(void)

diff --git a/src/mainwindow.h b/src/mainwindow.h
@@ -153,6 +153,7 @@ private slots:
     void onPluginSendCommand(QString cmd);
     void onPluginWriteSettings(QString group, QString key, QVariant value);
     void onPluginReadSettings(QString group, QString key, QVariant &value);
+    void onBroadCastSendData(const QByteArray &data);
 
 protected:
     void closeEvent(QCloseEvent *event) override {
@@ -325,6 +326,7 @@ private slots:
 
     KeyChainClass keyChainClass;
     QList<SessionsWindow *> sessionList;
+    QList<SessionsWindow *> broadCastSessionList;
     struct pluginState_t {
         PluginInterface *iface;
         bool state;

diff --git a/src/sessionswindow/sessionswindow.cpp b/src/sessionswindow/sessionswindow.cpp
@@ -145,6 +145,9 @@ SessionsWindow::SessionsWindow(SessionType tp, QWidget *parent)
                 if(modemProxyChannel) {
                     return;
                 }
+                if(enableBroadCast) {
+                    emit broadCastSendData(QByteArray(data, size));
+                }
                 if(telnet->isConnected()) {
                     telnet->sendData(data, size);
                     tx_total += size;
@@ -195,6 +198,9 @@ SessionsWindow::SessionsWindow(SessionType tp, QWidget *parent)
                 if(modemProxyChannel) {
                     return;
                 }
+                if(enableBroadCast) {
+                    emit broadCastSendData(QByteArray(data, size));
+                }
                 if(serialPort->isOpen()) {
                     serialPort->write(data, size);
                     tx_total += size;
@@ -239,6 +245,9 @@ SessionsWindow::SessionsWindow(SessionType tp, QWidget *parent)
                 if(modemProxyChannel) {
                     return;
                 }
+                if(enableBroadCast) {
+                    emit broadCastSendData(QByteArray(data, size));
+                }
                 if(rawSocket->state() == QAbstractSocket::ConnectedState) {
                     rawSocket->write(data, size);
                     tx_total += size;
@@ -287,6 +296,9 @@ SessionsWindow::SessionsWindow(SessionType tp, QWidget *parent)
                 if(modemProxyChannel) {
                     return;
                 }
+                if(enableBroadCast) {
+                    emit broadCastSendData(QByteArray(data, size));
+                }
                 if(namePipe->state() == QLocalSocket::ConnectedState) {
                     namePipe->write(data, size);
                 }
@@ -346,6 +358,9 @@ SessionsWindow::SessionsWindow(SessionType tp, QWidget *parent)
                     if(modemProxyChannel) {
                         return;
                     }
+                    if(enableBroadCast) {
+                        emit broadCastSendData(QByteArray(data, size));
+                    }
                     shell->sendData(data, size);
                     tx_total += size;
                 });
@@ -710,6 +725,9 @@ int SessionsWindow::startLocalShellSession(const QString &command, ShellType sTp
         if(modemProxyChannel) {
             return;
         }
+        if(enableBroadCast) {
+            emit broadCastSendData(QByteArray(data, size));
+        }
         localShell->write(QByteArray(data, size));
     });
     m_command = command;

diff --git a/src/sessionswindow/sessionswindow.h b/src/sessionswindow/sessionswindow.h
@@ -127,6 +127,8 @@ class SessionsWindow : public QObject
     bool isLog(void) { return enableLog; }
     int setRawLog(bool enable);
     bool isRawLog(void) { return enableRawLog; }
+    void setInBroadCastList(bool enable) { enableBroadCast = enable; }
+    bool isInBroadCastList() { return enableBroadCast; }
 
     int writeReceiveASCIIFile(const char *data, int size);
     int startReceiveASCIIFile(const QString &fileName);
@@ -352,13 +354,15 @@ class SessionsWindow : public QObject
         zmodemOnlie = enable;
     }
 
+
 signals:
     void hexDataDup(const char *data, int size);
     void stateChanged(SessionsState state);
     void titleChanged(int title,const QString& newTitle);
     void modemProxySendData(QByteArray data);
     void modemProxyRecvData(const QByteArray &data);
     void waitForStringFinished(const QString &str, int matchIndex);
+    void broadCastSendData(const QByteArray &data);
 
 private:
     int saveLog(const char *data, int size);
@@ -386,6 +390,7 @@ class SessionsWindow : public QObject
     QVNCClientWidget *vncClient;
     bool enableLog;
     bool enableRawLog;
+    bool enableBroadCast;
     QMutex log_file_mutex;
     QMutex raw_log_file_mutex;
     QFile *log_file = nullptr;