summaryrefslogtreecommitdiffstats
path: root/KMFSysTray/kmfiptwatcher.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'KMFSysTray/kmfiptwatcher.cpp')
-rw-r--r--KMFSysTray/kmfiptwatcher.cpp306
1 files changed, 306 insertions, 0 deletions
diff --git a/KMFSysTray/kmfiptwatcher.cpp b/KMFSysTray/kmfiptwatcher.cpp
new file mode 100644
index 0000000..c2f8c1a
--- /dev/null
+++ b/KMFSysTray/kmfiptwatcher.cpp
@@ -0,0 +1,306 @@
+/***************************************************************************
+* Copyright (C) 2005 by Christian Hubinger *
+* [email protected] *
+* *
+* This program is free software; you can redistribute it and/or modify *
+* it under the terms of the GNU General Public License as published by *
+* the Free Software Foundation; either version 2 of the License, or *
+* (at your option) any later version. *
+* *
+* This program is distributed in the hope that it will be useful, *
+* but WITHOUT ANY WARRANTY; without even the implied warranty of *
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
+* GNU General Public License for more details. *
+* *
+* You should have received a copy of the GNU General Public License *
+* along with this program; if not, write to the *
+* Free Software Foundation, Inc., *
+* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. *
+***************************************************************************/
+#include "kmfiptwatcher.h"
+
+
+// QT includes
+#include <qtimer.h>
+
+// KDE includes
+#include <kdebug.h>
+#include <klocale.h>
+#include <kapp.h>
+#include <kapplication.h>
+#include <kmessagebox.h>
+#include <kapplication.h>
+#include <kmessagebox.h>
+#include <dcopclient.h>
+
+// Project includes
+#include "../core/kmfiptdoc.h"
+#include "../core/kmferror.h"
+#include "../core/iptable.h"
+#include "../core/iptchain.h"
+#include "../core/iptrule.h"
+#include "../core/iptruleoption.h"
+
+KMFIPTWatcher::KMFIPTWatcher( QObject *parent, const char *name )
+ : QObject( parent, name ) {
+ m_queryExtendedInfo = true;
+ m_doc = new KMFIPTDoc( 0, "iptdoc" );
+ go();
+}
+
+
+KMFIPTWatcher::~KMFIPTWatcher() {}
+
+
+void KMFIPTWatcher::go() {
+ // KMessageBox::information( 0, i18n( "go()" ) );
+ m_timer = new QTimer();
+ QObject::connect( m_timer, SIGNAL( timeout() ), this, SLOT( timeout() ) );
+ m_timer->start( 3000, false );
+}
+
+void KMFIPTWatcher::timeout() {
+// kdDebug() << "timeout()" << endl;
+
+
+ DCOPClient *client = kapp->dcopClient();
+ QCString reply_type;
+ QByteArray params;
+ QDataStream stream( params, IO_WriteOnly );
+ QString arg = "filter";
+ stream << arg;
+ QByteArray reply_data;
+
+ if ( ! client->call( *( new QCString( "kmfiptinterface" ) ),
+ *( new QCString( "KMFIPTInterface" ) ),
+ *( new QCString( "numChainsInTable(QString)" ) ), params,
+ reply_type, reply_data, false, 10000 ) ) {
+
+ // KMessageBox::information( 0, i18n( "Error with DCOP: %1" ).arg( kapp->dcopClient() ->appId() ) );
+ emit sigUpdateActive( false );
+ } else {
+ QDataStream answer( reply_data, IO_ReadOnly );
+ if ( reply_type == "int" ) {
+ int result;
+ answer >> result;
+ // KMessageBox::information( 0, i18n( "Got answer %1" ).arg(result) );
+ emit sigUpdateActive( result > 0 );
+ } else
+ KMessageBox::information( 0, i18n( "Calling over DCOP succeeded, but the answer had wrong type!" ) );
+ }
+
+ if ( m_queryExtendedInfo ) {
+ queryExtendedInfo();
+ }
+}
+
+void KMFIPTWatcher::queryExtendedInfo() {
+ queryChainsInTable( "filter", m_doc );
+ queryChainsInTable( "nat", m_doc );
+ queryChainsInTable( "mangle", m_doc );
+ kdDebug() << "emit sigUpdateIPTDoc( m_doc )" << endl;
+ emit sigUpdateIPTDoc( m_doc );
+}
+
+void KMFIPTWatcher::queryChainsInTable( const QString& table, KMFIPTDoc* iptdoc ) {
+ kdDebug() << "queryNumRulesInChain( const QString& table, const QString& chain )" << endl;
+ DCOPClient *client = kapp->dcopClient();
+ QCString reply_type;
+ QByteArray params;
+ QDataStream stream( params, IO_WriteOnly );
+ stream << table;
+ QByteArray reply_data;
+
+ if ( ! client->call( *( new QCString( "kmfiptinterface" ) ),
+ *( new QCString( "KMFIPTInterface" ) ),
+ *( new QCString( "getChainsInTable(QString)" ) ), params,
+ reply_type, reply_data, false, 10000 ) ) {
+ emit sigUpdateActive( false );
+ } else {
+ QDataStream answer( reply_data, IO_ReadOnly );
+ if ( reply_type == "QStringList" ) {
+ QStringList result;
+ answer >> result;
+ IPTable *tableObj = iptdoc->table( table );
+ kdDebug() << "Filling Table: " << tableObj->name() << endl;
+ QPtrList<IPTChain> *used = new QPtrList<IPTChain>;
+ for ( QStringList::Iterator it = result.begin(); it != result.end(); ++it ) {
+ kdDebug() << "Found Chain" << *it << endl;
+ IPTChain *chain = tableObj->chainForName( *it );
+ if ( ! chain ) {
+ QString tg = "ACCEPT";
+ tableObj->addChain( *it, tg, false, new KMFError() );
+ }
+ fetchChainPolicy( tableObj->chainForName( *it ) );
+ fetchRulesInChain( tableObj->chainForName( *it ) );
+ used->append( tableObj->chainForName( *it ) );
+ }
+
+ QPtrListIterator<IPTChain> it_chains( tableObj->chains() );
+ IPTChain* found_chain = 0;
+ while ( it_chains.current() ) {
+ found_chain = it_chains.current();
+ bool found = false;
+ for ( QStringList::Iterator it_all = result.begin(); it_all != result.end(); ++it_all ) {
+ if ( *it_all == found_chain->name() ) {
+ found = true;
+ }
+ }
+ kdDebug() << "Found chain: " << found_chain->name() << " " << found << endl;
+ if ( ! found ) {
+ tableObj->delChain( found_chain );
+ }
+ ++it_chains;
+ }
+
+
+ } else {
+ KMessageBox::information( 0, i18n( "Calling over DCOP succeeded, but the answer had wrong type!" ) );
+ }
+ }
+}
+
+void KMFIPTWatcher::fetchChainPolicy( IPTChain* chain ) {
+ DCOPClient *client = kapp->dcopClient();
+ QCString reply_type;
+ QByteArray params;
+ QDataStream stream( params, IO_WriteOnly );
+ stream << chain->table()->name() << chain->name();
+ QByteArray reply_data;
+
+ if ( ! client->call( *( new QCString( "kmfiptinterface" ) ),
+ *( new QCString( "KMFIPTInterface" ) ),
+ *( new QCString( "getChainPolicy(QString,QString)" ) ), params,
+ reply_type, reply_data, false, 10000 ) ) {
+ emit sigUpdateActive( false );
+ } else {
+ QDataStream answer( reply_data, IO_ReadOnly );
+ if ( reply_type == "QString" ) {
+ QString result;
+ answer >> result;
+ kdDebug() << "Found Chain Policy: " << chain->table()->name() << " " << chain->name() << " " << result << endl;
+ chain->setDefaultTarget( result );
+ }
+ }
+}
+
+void KMFIPTWatcher::fetchRulesInChain( IPTChain* chain ) {
+ kdDebug() << "fetchRulesInChain( const QString& table, const QString& chain )" << endl;
+ DCOPClient *client = kapp->dcopClient();
+ QCString reply_type;
+ QByteArray params;
+ QDataStream stream( params, IO_WriteOnly );
+ stream << chain->table()->name() << chain->name();
+ QByteArray reply_data;
+
+ if ( ! client->call( *( new QCString( "kmfiptinterface" ) ),
+ *( new QCString( "KMFIPTInterface" ) ),
+ *( new QCString( "numRulesInChain(QString,QString)" ) ), params,
+ reply_type, reply_data, false, 10000 ) ) {
+ emit sigUpdateActive( false );
+ } else {
+ QDataStream answer( reply_data, IO_ReadOnly );
+ if ( reply_type == "int" ) {
+ int result;
+ answer >> result;
+ QPtrList<IPTRule> *used = new QPtrList<IPTRule>;
+ for ( int i = 0; i < result; i++ ) {
+ QString rn = QString("rule_%1").arg( i );
+ IPTRule *rule = 0;
+ rule = chain->ruleForName( rn );
+ if ( ! rule ) {
+ rule = chain->addRule( rn , new KMFError() );
+ }
+ fetchRulesProperties( rule, i );
+ used->append( rule );
+ }
+
+ QPtrListIterator<IPTRule> it_rules( chain->chainRuleset() );
+ IPTRule* found_rule = 0;
+ while ( it_rules.current() ) {
+ found_rule = it_rules.current();
+ bool found = false;
+ for ( int i = 0; i < result; i++ ) {
+ QString rn = QString("rule_%1").arg( i );
+ if ( rn == found_rule->name() ) {
+ found = true;
+ }
+ }
+ if ( ! found ) {
+ chain->delRule( found_rule );
+ }
+ ++it_rules;
+ }
+ } else {
+ KMessageBox::information( 0, i18n( "Calling over DCOP succeeded, but the answer had wrong type!" ) );
+ }
+ }
+}
+
+void KMFIPTWatcher::fetchRulesProperties( IPTRule* rule, int index ) {
+ kdDebug() << "queryNumRulesInChain( const QString& table, const QString& chain )" << endl;
+ DCOPClient *client = kapp->dcopClient();
+ QCString reply_type;
+ QByteArray params;
+ QDataStream stream( params, IO_WriteOnly );
+ stream << rule->chain()->table()->name() << rule->chain()->name() << index;
+ QByteArray reply_data;
+
+ if ( ! client->call( *( new QCString( "kmfiptinterface" ) ),
+ *( new QCString( "KMFIPTInterface" ) ),
+ *( new QCString( "getRuleProperties(QString,QString,int)" ) ), params,
+ reply_type, reply_data, false, 10000 ) ) {
+ emit sigUpdateActive( false );
+ } else {
+ QDataStream answer( reply_data, IO_ReadOnly );
+ if ( reply_type == "QStringList" ) {
+ QStringList result;
+ answer >> result;
+ if ( *result.at( 0 ) == "ERROR" ) {
+ return;
+ }
+ rule->setTarget( *result.at( 0 ) );
+
+
+ } else {
+ KMessageBox::information( 0, i18n( "Calling over DCOP succeeded, but the answer had wrong type!" ) );
+ }
+ }
+
+}
+
+
+void KMFIPTWatcher::queryNumRulesInChain( const QString& table, const QString& chain, KMFIPTDoc* doc ) {
+ kdDebug() << "queryNumRulesInChain( const QString& table, const QString& chain )" << endl;
+ DCOPClient *client = kapp->dcopClient();
+ QCString reply_type;
+ QByteArray params;
+ QDataStream stream( params, IO_WriteOnly );
+ stream << table << chain;
+ QByteArray reply_data;
+
+ if ( ! client->call( *( new QCString( "kmfiptinterface" ) ),
+ *( new QCString( "KMFIPTInterface" ) ),
+ *( new QCString( "numRulesInChain(QString,QString)" ) ), params,
+ reply_type, reply_data, false, 10000 ) ) {
+ emit sigUpdateActive( false );
+ } else {
+ QDataStream answer( reply_data, IO_ReadOnly );
+ if ( reply_type == "int" ) {
+ int result;
+ answer >> result;
+
+ } else
+ KMessageBox::information( 0, i18n( "Calling over DCOP succeeded, but the answer had wrong type!" ) );
+ }
+}
+
+void KMFIPTWatcher::worked() {
+ KMessageBox::information( 0, i18n( "Callback Worked" ) );
+}
+
+void KMFIPTWatcher::slotQueryDetails( bool on ) {
+ kdDebug() << "slotQueryDetails( bool " << on << " )" << endl;
+ m_queryExtendedInfo = on;
+}
+#include "kmfiptwatcher.moc"
generated by cgit v1.2.1 (git 2.18.0) at 2025-03-11 04:57:49 +0000