Added new rsync plugin for Konqueror

git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/kdeaddons@1105435 283d02a7-25f6-0310-bc7c-ecb5cbfe19da

12 files changed, 1329 insertions, 0 deletions

diff --git a/konq-plugins/rsync/Makefile.am b/konq-plugins/rsync/Makefile.am
new file mode 100644
index 0000000..4f68035
--- /dev/null
+++ b/konq-plugins/rsync/Makefile.am
@@ -0,0 +1,21 @@
+INCLUDES    = $(all_includes)
+METASOURCES = AUTO
+
+kde_module_LTLIBRARIES = librsyncplugin.la
+librsyncplugin_la_SOURCES = rsyncplugin.cpp rsyncconfigdialog.cpp
+librsyncplugin_la_LIBADD = -lkonq
+librsyncplugin_la_LDFLAGS = -module $(KDE_PLUGIN) $(all_libraries)
+
+iconviewdir = $(kde_datadir)/konqiconview/kpartplugins
+iconview_DATA = rsyncplugin.rc rsync_plugin.desktop
+
+listviewdir = $(kde_datadir)/konqlistview/kpartplugins
+listview_DATA = rsyncplugin.rc rsync_plugin.desktop
+
+appsdir = $(kde_appsdir)/.hidden
+apps_DATA = rsyncplugin.desktop
+
+KDE_ICON = AUTO
+
+messages: rc.cpp
+	$(XGETTEXT) *.cpp *.h -o $(podir)/rsyncplugin.pot
diff --git a/konq-plugins/rsync/cr16-action-remotesync.png b/konq-plugins/rsync/cr16-action-remotesync.png
new file mode 100644
index 0000000..5ef60f9
--- /dev/null
+++ b/konq-plugins/rsync/cr16-action-remotesync.png
diff --git a/konq-plugins/rsync/cr16-action-remotesyncconfig.png b/konq-plugins/rsync/cr16-action-remotesyncconfig.png
new file mode 100644
index 0000000..a8d720b
--- /dev/null
+++ b/konq-plugins/rsync/cr16-action-remotesyncconfig.png
diff --git a/konq-plugins/rsync/cr22-action-remotesync.png b/konq-plugins/rsync/cr22-action-remotesync.png
new file mode 100644
index 0000000..3158b67
--- /dev/null
+++ b/konq-plugins/rsync/cr22-action-remotesync.png
diff --git a/konq-plugins/rsync/cr22-action-remotesyncconfig.png b/konq-plugins/rsync/cr22-action-remotesyncconfig.png
new file mode 100644
index 0000000..ddf73f5
--- /dev/null
+++ b/konq-plugins/rsync/cr22-action-remotesyncconfig.png
diff --git a/konq-plugins/rsync/rsync_plugin.desktop b/konq-plugins/rsync/rsync_plugin.desktop
new file mode 100644
index 0000000..14f84e2
--- /dev/null
+++ b/konq-plugins/rsync/rsync_plugin.desktop
@@ -0,0 +1,17 @@
+[Desktop Entry]
+Encoding=UTF-8
+Type=Service
+X-KDE-PluginInfo-Author=Timothy Pearson
[email protected]
+X-KDE-PluginInfo-Name=Rsync
+X-KDE-PluginInfo-Version=3.4
+X-KDE-PluginInfo-Website=
+X-KDE-PluginInfo-Category=Tools
+X-KDE-PluginInfo-Depends=
+X-KDE-PluginInfo-License=GPL
+X-KDE-PluginInfo-EnabledByDefault=true
+Name=Remote Folder Synchronization Plugin
+Comment=Remote folder synchronization plugin
+Icon=remotesync
+X-KDE-ParentApp=konqueror
+DocPath=konq-plugins/rsync/index.html
diff --git a/konq-plugins/rsync/rsyncconfigdialog.cpp b/konq-plugins/rsync/rsyncconfigdialog.cpp
new file mode 100644
index 0000000..f990fc8
--- /dev/null
+++ b/konq-plugins/rsync/rsyncconfigdialog.cpp
@@ -0,0 +1,162 @@
+/*
+   Copyright (C) 2000, 2001, 2002 Dawit Alemayehu <[email protected]>
+
+   This library is free software; you can redistribute it and/or
+   modify it under the terms of the GNU Library General Public
+   License version 2 as published by the Free Software Foundation.
+
+   This library 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
+   Library General Public License for more details.
+
+   You should have received a copy of the GNU Library General Public License
+   along with this library; see the file COPYING.LIB.  If not, write to
+   the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
+   Boston, MA 02110-1301, USA.
+*/
+#include <unistd.h>
+#include <sys/types.h>
+#include <signal.h>
+#include <sys/socket.h>
+#include <sys/un.h>
+#include <errno.h>
+#include <sys/time.h>
+#include <sys/resource.h>
+#include <sys/ioctl.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+
+#define HAVE_TERMIOS_H 1
+#define HAVE_GRANTPT 1
+
+#include <stdlib.h>
+#ifdef HAVE_PTY_H
+#include <pty.h>
+#endif
+#ifdef HAVE_TERMIOS_H
+#include <termios.h>
+#endif
+#ifdef HAVE_STROPTS
+#include <stropts.h>
+#endif
+#ifdef HAVE_SYS_IOCTL_H
+#include <sys/ioctl.h>
+#endif
+#ifdef HAVE_LIBUTIL_H
+#include <libutil.h>
+#endif
+#ifdef HAVE_UTIL_H
+#include <util.h>
+#endif
+
+#include <qfile.h>
+#include <qtimer.h>
+#include <qapplication.h>
+#include <qpushbutton.h>
+#include <qhbox.h>
+#include <qwhatsthis.h>
+#include <qiconview.h>
+#include <qpainter.h>
+#include <qpixmap.h>
+#include <qlabel.h>
+#include <qlayout.h>
+#include <qpushbutton.h>
+#include <qstring.h>
+#include <qregexp.h>
+#include <qstyle.h>
+#include <qtimer.h>
+#include <qgroupbox.h>
+#include <qradiobutton.h>
+#include <qbuttongroup.h>
+
+#include <kdebug.h>
+#include <klocale.h>
+#include <kinstance.h>
+
+#include <kwin.h>
+#include <kaction.h>
+#include <kpopupmenu.h>
+#include <kmessagebox.h>
+#include <kiconloader.h>
+#include <kprogressbox.h>
+#include <kpassdlg.h>
+#include <klistview.h>
+#include <kapplication.h>
+#include <kconfigdialog.h>
+
+#include <kdirlister.h>
+#include <kstandarddirs.h>
+#include <klistviewsearchline.h>
+#include <kiconviewsearchline.h>
+#include <konq_dirpart.h>
+#include <konq_propsview.h>
+#include <kstaticdeleter.h>
+#include <kgenericfactory.h>
+#include <kparts/browserextension.h>
+
+#include "rsyncconfigdialog.h"
+
+/*
+ * RsyncConfigDialog implementation
+ */
+RsyncConfigDialog::RsyncConfigDialog(QWidget* parent, const char* name,
+                                 const QString& caption, const QString& text,
+                                 const QString& localfolder, const QString& remotefolder,
+                                 bool modal)
+    : KDialogBase(KDialogBase::Plain, caption, KDialogBase::Cancel | KDialogBase::Ok,
+                  KDialogBase::Ok, parent, name, modal),
+      mAutoClose(true),
+      mAutoReset(false),
+      mCancelled(false),
+      mAllowCancel(true),
+      mAllowTextEdit(false),
+      mShown(false)
+{
+#ifdef Q_WS_X11
+    KWin::setIcons(winId(), kapp->icon(), kapp->miniIcon());
+#endif
+    mShowTimer = new QTimer(this);
+
+    showButton(KDialogBase::Close, false);
+    mCancelText = actionButton(KDialogBase::Cancel)->text();
+
+    QFrame* mainWidget = plainPage();
+    QVBoxLayout* layout = new QVBoxLayout(mainWidget, 10);
+    mLabel = new QLabel(QString("<b>") + text + QString("</b><br>Setting up synchronization for local folder<br><i>") + localfolder, mainWidget);
+    layout->addWidget(mLabel);
+
+    // Create an exclusive button group
+    QButtonGroup *layoutg = new QButtonGroup( 1, QGroupBox::Horizontal, "Synchronization Method:", mainWidget);
+    layout->addWidget( layoutg );
+    layoutg->setExclusive( TRUE );
+
+    // Insert radiobuttons
+    QRadioButton *rsync_rb = new QRadioButton("&Utilize rsync + ssh\nExample: servername:/path/to/remote/folder", layoutg);
+    rsync_rb->setChecked( TRUE );
+    //(void)new QRadioButton( "R&adiobutton 2", layoutg );
+    //(void)new QRadioButton( "Ra&diobutton 3", layoutg );
+
+    // Create an exclusive button group
+    QButtonGroup *layoutm = new QButtonGroup( 1, QGroupBox::Horizontal, "Remote Folder:", mainWidget);
+    layout->addWidget( layoutm );
+    layoutg->setExclusive( TRUE );
+
+    m_rsync_txt = new QLineEdit(layoutm);
+    if (remotefolder.isEmpty() == false) {
+        m_rsync_txt->setText(remotefolder);
+    }
+    m_rsync_txt->setFocus();
+}
+
+QLineEdit* RsyncConfigDialog::lineEdit()
+{
+    return m_rsync_txt;
+}
+
+const QLineEdit* RsyncConfigDialog::lineEdit() const
+{
+    return m_rsync_txt;
+}
+
+#include "rsyncconfigdialog.moc"
diff --git a/konq-plugins/rsync/rsyncconfigdialog.h b/konq-plugins/rsync/rsyncconfigdialog.h
new file mode 100644
index 0000000..83314e8
--- /dev/null
+++ b/konq-plugins/rsync/rsyncconfigdialog.h
@@ -0,0 +1,255 @@
+/*
+   Copyright (C) 2000, 2001, 2002 Dawit Alemayehu <[email protected]>
+
+   This library is free software; you can redistribute it and/or
+   modify it under the terms of the GNU Library General Public
+   License version 2 as published by the Free Software Foundation.
+
+   This library 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
+   Library General Public License for more details.
+
+   You should have received a copy of the GNU Library General Public License
+   along with this library; see the file COPYING.LIB.  If not, write to
+   the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
+   Boston, MA 02110-1301, USA.
+*/
+
+#ifndef __RSYNC_CONFIG_DIALOG_H
+#define __RSYNC_CONFIG_DIALOG_H
+
+#include <qmap.h>
+#include <qstringlist.h>
+#include <qlineedit.h>
+
+#include <kurl.h>
+#include <kprocess.h>
+#include <kfileitem.h>
+#include <klibloader.h>
+#include <kdialogbase.h>
+
+class RsyncConfigDialog : public KDialogBase
+{
+    Q_OBJECT
+
+    public:
+        RsyncConfigDialog(QWidget* parent = 0, const char* name = 0,
+                        const QString& caption = QString::null,
+                        const QString& text = QString::null,
+                        const QString& localfolder = QString::null,
+                        const QString& remotefolder = QString::null,
+                        bool modal = false);
+
+        ~RsyncConfigDialog() {}
+//
+//         /**
+//          * Returns the KProgressBox used in this dialog.
+//          * To set the number of steps or other progress bar related
+//          * settings, access the KProgressBox object directly via this method.
+//          */
+//         KProgress* progressBar();
+//
+         /**
+         * Returns the QLineEdit used in this dialog.
+         * To set the number of lines or other text box related
+         * settings, access the KTextEdit object directly via this method.
+         */
+        QLineEdit* lineEdit();
+//
+//         /**
+//          * Returns the KProgressBox used in this dialog.
+//          * To set the number of steps or other progress bar related
+//          * settings, access the KProgressBox object directly via this method.
+//          */
+//         const KProgress* progressBar() const;
+//
+        /**
+         * Returns the QLineEdit used in this dialog.
+         * To set the number of lines or other text box related
+         * settings, access the KTextEdit object directly via this method.
+         */
+        const QLineEdit* lineEdit() const;
+
+        /**
+         * Sets the text in the dialog
+         *
+         * @param text the text to display
+         */
+        void    setLabel(const QString & text);
+
+        /**
+         * Returns the current dialog text
+         * @deprecated
+         */
+        // ### Remove this KDE 4.0
+        QString labelText() KDE_DEPRECATED;
+
+        /**
+         * Returns the current dialog text
+         */
+        QString labelText() const;
+
+        /**
+         * Sets whether or not the user can cancel the process.
+         * If the dialog is cancellable, the Cancel button will be shown
+         * and the user can close the window using the window decorations.
+         * If the process is not (or should not be) interuptable,
+         * set the dialog to be modal and not cancellable.
+         *
+         * @param allowCancel Set to true to make the dialog non-closable
+         */
+        void setAllowCancel(bool allowCancel);
+
+        /**
+         * Sets whether or not the user can edit the text shown in the textbox.
+         *
+         * @param allowTextEdit Set to true to make the text editable
+         */
+        void setAllowTextEdit(bool allowTextEdit);
+
+        /**
+         * Returns true if the dialog can be canceled, false otherwise
+         * @deprecated
+         */
+        // ### Remove this KDE 4.0
+        bool allowCancel() KDE_DEPRECATED;
+
+        /**
+         * Returns true if the dialog can be canceled, false otherwise
+         */
+        bool allowCancel() const;
+
+        /**
+         * Sets whether the cancel button is visible. setAllowCancel(false)
+         * implies showCancelButton(false)
+         *
+         * @param show Whether or not the cancel button should be shown
+         */
+        void showCancelButton(bool show);
+//
+//         /**
+//          * Sets whether the dialog should close automagically when
+//          * all the steps in the KProgressBox have been completed.
+//          */
+//         void setAutoClose(bool close);
+//
+//         /**
+//          * Returns true if the dialog will close upon completion,
+//          * or false otherwise
+//          */
+//         // ### Remove this KDE 4.0
+//         bool autoClose();
+//
+//         /**
+//          * Returns true if the dialog will close upon completion,
+//          * or false otherwise
+//          */
+//         bool autoClose() const;
+//
+//         /**
+//          * Sets whether the dialog should reset the KProgressBox dialog
+//          * back to 0 steps compelete when all steps have been completed.
+//          * This is useful for RsyncConfigDialogs that will be reused.
+//          */
+//         void setAutoReset(bool autoReset);
+//
+//         /**
+//          * Returns true if the KProgressBox widget will be reset
+//          * upon completion, or false otherwise
+//          */
+//         // ### Remove this KDE 4.0
+//         bool autoReset();
+//
+//         /**
+//          * Returns true if the KProgressBox widget will be reset
+//          * upon completion, or false otherwise
+//          */
+//         bool autoReset() const;
+//
+        /**
+         * Returns true if the dialog was closed or canceled
+         * before completion. If the dialog is not cancellable
+         * it will always return false.
+         */
+        // ### Remove this KDE 4.0
+        bool wasCancelled();
+
+        /**
+         * Returns true if the dialog was closed or canceled
+         * before completion. If the dialog is not cancellable
+         * it will always return false.
+         */
+        bool wasCancelled() const;
+
+        /**
+         * Ignores the last cancel action if the cancel button was
+         * pressed. Useful for kdialog when combined with a KMessageBox
+         * to display a message like "Are you sure you want to cancel?"
+	 * @since 3.5.5
+         */
+        void ignoreCancel();
+
+        /**
+         * Sets the text to appear on the cancel button.
+         */
+        void setButtonText(const QString&);
+
+        /**
+         * Returns the text on the cancel button
+         * @deprecated
+         */
+        // ### Remove this KDE 4.0
+        QString buttonText() KDE_DEPRECATED;
+
+        /**
+         * Returns the text on the cancel button
+         */
+        QString buttonText() const;
+//
+//         /**
+//          * Set the minimum number of milliseconds to wait before
+//          * actually showing the dialog
+//          */
+//         void setMinimumDuration(int ms);
+//
+//         /**
+//          * Returns the wait duration in milliseconds
+//          * @deprecated
+//          */
+//         // ### Remove this KDE 4.0
+//         int  minimumDuration() KDE_DEPRECATED;
+//
+//         /**
+//          * Returns the wait duration in milliseconds
+//          */
+//         int  minimumDuration() const;
+//
+//  	/**
+// 	 * Reimplemented for internal reasons, the API is not affected.
+// 	 */
+//         virtual void show();
+//
+//     protected slots:
+//         void slotAutoShow();
+//         void slotAutoActions(int percentage);
+//         void slotCancel();
+//
+    private:
+        // ### Move these member variables to d in KDE 4.0
+        bool       mAutoClose;
+        bool       mAutoReset;
+        bool       mCancelled;
+        bool       mAllowCancel;
+        bool       mAllowTextEdit;
+        bool       mShown;
+        QString    mCancelText;
+        QLabel*    mLabel;
+        KProgress* mProgressBar;
+        KTextEdit* mTextBox;
+        QTimer*    mShowTimer;
+        QLineEdit* m_rsync_txt;
+//     protected:
+// 	virtual void virtual_hook( int id, void* data );
+};
+#endif
diff --git a/konq-plugins/rsync/rsyncplugin.cpp b/konq-plugins/rsync/rsyncplugin.cpp
new file mode 100644
index 0000000..11785ac
--- /dev/null
+++ b/konq-plugins/rsync/rsyncplugin.cpp
@@ -0,0 +1,721 @@
+/*
+   Copyright (C) 2000, 2001, 2002 Dawit Alemayehu <[email protected]>
+
+   This library is free software; you can redistribute it and/or
+   modify it under the terms of the GNU Library General Public
+   License version 2 as published by the Free Software Foundation.
+
+   This library 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
+   Library General Public License for more details.
+
+   You should have received a copy of the GNU Library General Public License
+   along with this library; see the file COPYING.LIB.  If not, write to
+   the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
+   Boston, MA 02110-1301, USA.
+*/
+#include <unistd.h>
+#include <sys/types.h>
+#include <signal.h>
+#include <sys/socket.h>
+#include <sys/un.h>
+#include <errno.h>
+#include <sys/time.h>
+#include <sys/resource.h>
+#include <sys/ioctl.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+
+#define HAVE_TERMIOS_H 1
+#define HAVE_GRANTPT 1
+
+#include <stdlib.h>
+#ifdef HAVE_PTY_H
+#include <pty.h>
+#endif
+#ifdef HAVE_TERMIOS_H
+#include <termios.h>
+#endif
+#ifdef HAVE_STROPTS
+#include <stropts.h>
+#endif
+#ifdef HAVE_SYS_IOCTL_H
+#include <sys/ioctl.h>
+#endif
+#ifdef HAVE_LIBUTIL_H
+#include <libutil.h>
+#endif
+#ifdef HAVE_UTIL_H
+#include <util.h>
+#endif
+
+#include <qfile.h>
+#include <qtimer.h>
+#include <qapplication.h>
+#include <qlabel.h>
+#include <qpushbutton.h>
+#include <qhbox.h>
+#include <qwhatsthis.h>
+#include <qiconview.h>
+#include <qpainter.h>
+#include <qpixmap.h>
+#include <qlabel.h>
+#include <qlayout.h>
+#include <qpushbutton.h>
+#include <qstring.h>
+#include <qregexp.h>
+#include <qstyle.h>
+#include <qtimer.h>
+
+#include <kdebug.h>
+#include <klocale.h>
+#include <kinstance.h>
+
+#include <kwin.h>
+#include <kaction.h>
+#include <kpopupmenu.h>
+#include <kmessagebox.h>
+#include <kiconloader.h>
+#include <kprogressbox.h>
+#include <kpassdlg.h>
+#include <klistview.h>
+#include <kapplication.h>
+#include <kconfigdialog.h>
+
+#include <kdirlister.h>
+#include <kstandarddirs.h>
+#include <klistviewsearchline.h>
+#include <kiconviewsearchline.h>
+#include <konq_dirpart.h>
+#include <konq_propsview.h>
+#include <kstaticdeleter.h>
+#include <kgenericfactory.h>
+#include <kparts/browserextension.h>
+
+#include <kio/global.h>
+#include <kio/slavebase.h>
+#include <kio/authinfo.h>
+
+#include "rsyncplugin.h"
+#include "rsyncconfigdialog.h"
+
+#define myDebug(x) kdDebug(7127) << __LINE__ << ": " x
+// #define myDebug(x) cout << __LINE__ << ": " x
+#define infoMessage(x) printf("INFO: %s\n\r", x);
+
+static char *rsyncPath = NULL;
+static char *suPath = NULL;
+
+static int open_pty_pair(int fd[2])
+{
+#if defined(HAVE_TERMIOS_H) && defined(HAVE_GRANTPT) && !defined(HAVE_OPENPTY)
+/** with kind regards to The GNU C Library
+Reference Manual for Version 2.2.x of the GNU C Library */
+    int master, slave;
+    char *name;
+    struct ::termios ti;
+    memset(&ti,0,sizeof(ti));
+
+    ti.c_cflag = CLOCAL|CREAD|CS8;
+    ti.c_cc[VMIN] = 1;
+
+#ifdef HAVE_GETPT
+    master = getpt();
+#else
+    master = open("/dev/ptmx", O_RDWR);
+#endif
+    if (master < 0) return 0;
+
+    if (grantpt(master) < 0 || unlockpt(master) < 0) goto close_master;
+
+    name = ptsname(master);
+    if (name == NULL) goto close_master;
+
+    slave = open(name, O_RDWR);
+    if (slave == -1) goto close_master;
+
+#if (defined(HAVE_ISASTREAM) || defined(isastream)) && defined(I_PUSH)
+    if (isastream(slave) &&
+        (ioctl(slave, I_PUSH, "ptem") < 0 ||
+         ioctl(slave, I_PUSH, "ldterm") < 0))
+            goto close_slave;
+#endif
+
+    tcsetattr(slave, TCSANOW, &ti);
+    fd[0] = master;
+    fd[1] = slave;
+    return 0;
+
+#if (defined(HAVE_ISASTREAM) || defined(isastream)) && defined(I_PUSH)
+close_slave:
+#endif
+    close(slave);
+
+close_master:
+    close(master);
+    return -1;
+#else
+#ifdef HAVE_OPENPTY
+    struct ::termios ti;
+    memset(&ti,0,sizeof(ti));
+
+    ti.c_cflag = CLOCAL|CREAD|CS8;
+    ti.c_cc[VMIN] = 1;
+
+    return openpty(fd,fd+1,NULL,&ti,NULL);
+#else
+#ifdef __GNUC__
+#warning "No tty support available. Password dialog won't work."
+#endif
+    return socketpair(PF_UNIX,SOCK_STREAM,0,fd);
+#endif
+#endif
+}
+/**
+creates the subprocess
+*/
+bool RsyncPlugin::connectionStart(QString localfolder, QString remotepath) {
+    int fd[2];
+    int rc, flags;
+    thisFn = QString::null;
+
+    rc = open_pty_pair(fd);
+    if (rc == -1) {
+        myDebug( << "socketpair failed, error: " << strerror(errno) << endl);
+        return true;
+    }
+
+    //myDebug( << "Exec: " << (local ? suPath : rsyncPath) << " Port: " << connectionPort << " User: " << connectionUser << endl);
+    //infoMessage(rsyncPath);
+    childPid = fork();
+    if (childPid == -1) {
+        myDebug( << "fork failed, error: " << strerror(errno) << endl);
+        close(fd[0]);
+        close(fd[1]);
+        childPid = 0;
+        return true;
+    }
+    if (childPid == 0) {
+        // Create the rsync command to run
+        QString execstring;
+        execstring = QString(rsyncPath) + QString(" -avtzAXE --delete --progress ") + localfolder + QString("/ ") + remotepath;
+
+        // taken from konsole, see TEPty.C for details
+        // note: if we're running on socket pairs,
+        // this will fail, but thats what we expect
+
+        for (int sig = 1; sig < NSIG; sig++) signal(sig,SIG_DFL);
+
+        struct rlimit rlp;
+        getrlimit(RLIMIT_NOFILE, &rlp);
+        for (int i = 0; i < (int)rlp.rlim_cur; i++)
+            if (i != fd[1]) close(i);
+
+        dup2(fd[1],0);
+        dup2(fd[1],1);
+        dup2(fd[1],2);
+        if (fd[1] > 2) close(fd[1]);
+
+        setsid();
+
+#if defined(TIOCSCTTY)
+        ioctl(0, TIOCSCTTY, 0);
+#endif
+
+        int pgrp = getpid();
+#if defined( _AIX) || defined( __hpux)
+        tcsetpgrp(0, pgrp);
+#else
+        ioctl(0, TIOCSPGRP, (char *)&pgrp);
+#endif
+
+        const char *dev = ttyname(0);
+        setpgid(0,0);
+        if (dev) close(open(dev, O_WRONLY, 0));
+        setpgid(0,0);
+
+        system(execstring.ascii());
+        #undef common_args
+        myDebug( << "could not exec! " << strerror(errno) << endl);
+        ::exit(-1);
+    }
+    close(fd[1]);
+    rc = fcntl(fd[0],F_GETFL,&flags);
+    rc = fcntl(fd[0],F_SETFL,flags|O_NONBLOCK);
+    childFd = fd[0];
+
+    fd_set rfds, wfds;
+    FD_ZERO(&rfds);
+    FD_ZERO(&wfds);
+    char buf[32768];
+    int offset = 0;
+    while (!isLoggedIn) {
+        FD_SET(childFd,&rfds);
+        FD_ZERO(&wfds);
+        if (outBufPos >= 0) FD_SET(childFd,&wfds);
+        struct timeval timeout;
+        timeout.tv_sec = 0;
+        timeout.tv_usec = 1000;
+        rc = select(childFd+1, &rfds, &wfds, NULL, &timeout);
+        if (rc < 0) {
+            if (errno == EINTR)
+                continue;
+            myDebug( << "select failed, rc: " << rc << ", error: " << strerror(errno) << endl);
+            return true;
+        }
+        if (FD_ISSET(childFd,&wfds) && outBufPos >= 0) {
+            if (outBuf) {
+                rc = write(childFd,outBuf+outBufPos,outBufLen-outBufPos);
+                fflush(stdout);
+            }
+            else {
+                rc = 0;
+            }
+            if (rc >= 0) outBufPos += rc;
+            else {
+                if (errno == EINTR)
+                    continue;
+                myDebug( << "write failed, rc: " << rc << ", error: " << strerror(errno) << endl);
+                outBufPos = -1;
+                //return true;
+            }
+            if (outBufPos >= outBufLen) {
+                outBufPos = -1;
+                outBuf = NULL;
+                outBufLen = 0;
+            }
+        }
+        if (FD_ISSET(childFd,&rfds)) {
+            rc = read(childFd,buf+offset,32768-offset);
+            if (rc > 0) {
+                int noff = establishConnection(buf,rc+offset);
+                if (noff < 0) return false;
+                if (noff > 0) memmove(buf,buf+offset+rc-noff,noff);
+                offset = noff;
+            } else {
+                if (errno == EINTR)
+                    continue;
+                //if (errno == EAGAIN)
+                //    continue;
+                myDebug( << "read failed, rc: " << rc << ", error: " << strerror(errno) << endl);
+                return true;
+            }
+        }
+    }
+    return false;
+}
+
+/**
+writes one chunk of data to stdin of child process
+*/
+void RsyncPlugin::writeChild(const char *buf, KIO::fileoffset_t len) {
+    if (outBufPos >= 0 && outBuf) {
+#if 0
+        QString debug;
+        debug.setLatin1(outBuf,outBufLen);
+        if (len > 0) myDebug( << "write request while old one is pending, throwing away input (" << outBufLen << "," << outBufPos << "," << debug.left(10) << "...)" << endl);
+#endif
+        return;
+    }
+    outBuf = buf;
+    outBufPos = 0;
+    outBufLen = len;
+}
+
+/**
+manages initial communication setup including password queries
+*/
+int RsyncPlugin::establishConnection(char *buffer, KIO::fileoffset_t len) {
+    QString buf;
+    buf.setLatin1(buffer,len);
+    int pos;
+    // Strip trailing whitespace
+    while (buf.length() && (buf[buf.length()-1] == ' '))
+       buf.truncate(buf.length()-1);
+
+    myDebug( << "establishing: got " << buf << endl);
+    while (childPid && ((pos = buf.find('\n')) >= 0 || buf.endsWith(":") || buf.endsWith("?"))) {
+        if (m_progressDialogExists == true) {
+            qApp->processEvents();
+        }
+        pos++;
+        QString str = buf.left(pos);
+        buf = buf.mid(pos);
+        if (str == "\n")
+            continue;
+        //if (str.contains("rsync error:")) {
+        if (str.contains("rsync:") || str.contains("failed.") || (str.contains("Could not") && str.endsWith("."))) {
+            KMessageBox::error(NULL, str);
+        }
+        else if (!str.isEmpty()) {
+            thisFn += str;
+            if ((buf.endsWith(":") == false) && (buf.endsWith("?") == false)) {
+                // Display a nice little progress bar with text box
+                if (m_progressDialogExists == false) {
+                    m_progressDialog = new KProgressBoxDialog(0, "rsyncProgress", i18n("Synchronizing Folder..."), i18n("Synchronizing Folder..."), true);
+                    m_progressDialog->progressBar()->setFormat("%v / %m");
+                    m_progressDialog->setAutoClose(true);
+                    m_progressDialog->progressBar()->setTotalSteps(2);
+                    m_progressDialog->progressBar()->setValue(1);
+                    connect (m_progressDialog, SIGNAL(cancelClicked()), SLOT(slotRsyncCancelled()));
+                    m_progressDialog->show();
+                    m_progressDialogExists = true;
+                }
+            }
+        }
+        else if (buf.endsWith(":")) {
+            if (!redirectUser.isEmpty() && connectionUser != redirectUser) {
+               // FIXME: Possibly do something here; is this the success response?
+                return -1;
+            } else if (!connectionPassword.isEmpty()) {
+                myDebug( << "sending cpass" << endl);
+                connectionAuth.password = connectionPassword+"\n";
+                connectionPassword = QString::null;
+                writeChild(connectionAuth.password.latin1(),connectionAuth.password.length());
+            } else {
+                myDebug( << "sending mpass" << endl);
+                connectionAuth.prompt = thisFn+buf;
+                connectionAuth.password = QString::null; // don't prefill
+                QCString thispass;
+                if (KPasswordDialog::getPassword (thispass, i18n("Remote authorization required") + QString("\n") + i18n("Please input") + QString(" ") + QString(buf), NULL) != 1) {
+                    shutdownConnection(true, false);
+                    return -1;
+                }
+                else {
+                    connectionAuth.password = QString(thispass);
+                }
+                connectionAuth.password += "\n";
+                myDebug( << "sending pass" << endl);
+                writeChild(connectionAuth.password.latin1(),connectionAuth.password.length());
+            }
+            thisFn = QString::null;
+            return 0;
+        }
+        else if (buf.endsWith("?")) {
+            int rc = KMessageBox::questionYesNo(NULL, thisFn+buf);
+            if (rc == KMessageBox::Yes) {
+                writeChild("yes\n",4);
+            } else {
+                writeChild("no\n",3);
+            }
+            thisFn = QString::null;
+            return 0;
+        }
+
+        if (m_progressDialogExists == true) {
+            if (str.contains("exit()") && str.contains("ICE default IO")) {
+                if (m_progressDialogExists == true) {
+                    m_progressDialog->progressBar()->setValue(m_progressDialog->progressBar()->totalSteps());
+                }
+            }
+            else {
+                if (str.contains(", to-check=")) {
+                    // Parse the to-check output
+                    QString tocheck_out_cur;
+                    QString tocheck_out_tot;
+                    tocheck_out_cur = str.mid(str.find(", to-check=") + 11, str.length());
+                    tocheck_out_tot = tocheck_out_cur.mid(tocheck_out_cur.find("/") + 1, tocheck_out_cur.length());
+                    tocheck_out_cur = tocheck_out_cur.left(tocheck_out_cur.find("/"));
+                    tocheck_out_tot = tocheck_out_tot.left(tocheck_out_tot.find(")"));
+                    m_progressDialog->progressBar()->setTotalSteps(tocheck_out_tot.toInt()-1);
+                    m_progressDialog->progressBar()->setValue(tocheck_out_tot.toInt()-tocheck_out_cur.toInt()-2);
+                }
+                else {
+                    m_progressDialog->textEdit()->append(str);
+                    m_progressDialog->textEdit()->scrollToBottom();
+                }
+            }
+        }
+    }
+    return buf.length();
+}
+
+/**
+Forced close of the connection
+
+This function gets called from the application side of the universe,
+it shouldn't send any response.
+ */
+void RsyncPlugin::closeConnection(){
+    myDebug( << "closeConnection()" << endl);
+    shutdownConnection(true, false);
+}
+
+/**
+Closes the connection
+ */
+void RsyncPlugin::shutdownConnection(bool forced, bool wait){
+    if (childPid) {
+        kill(childPid,SIGTERM); // We may not have permission...
+        childPid = 0;
+        if (wait == false) {
+            close(childFd); // ...in which case this should do the trick
+            childFd = -1;
+        }
+    }
+    outBufPos = -1;
+    outBuf = NULL;
+    outBufLen = 0;
+    isLoggedIn = false;
+}
+
+// --------------------------------------------------------------------------------------------
+//
+// Here begins the standard load/save/search/Konqy stuff
+//
+// --------------------------------------------------------------------------------------------
+
+void RsyncPlugin::saveSettings()
+{
+  KConfig cfg ("rsyncrc", false, false);
+  cfg.setGroup ("General");
+
+  bool min_entry = false;
+  QString longstring = QString("");
+  for (QStringList::Iterator i(cfgfolderlist.begin()); i != cfgfolderlist.end(); ++i) {
+	if (min_entry)
+		longstring = longstring + QString(";");
+	longstring = longstring + (*i);
+	i++;
+	longstring = longstring + QString(";") + (*i);
+	min_entry = true;
+  }
+
+  cfg.writeEntry("LocalFolders", longstring);
+  cfg.sync();
+}
+
+void RsyncPlugin::loadSettings()
+{
+  if (m_bSettingsLoaded)
+    return;
+
+  KConfig cfg ("rsyncrc", false, false);
+  cfg.setGroup ("General");
+
+  cfgfolderlist = cfg.readListEntry("LocalFolders", ';');
+
+  m_bSettingsLoaded = true;
+}
+
+QString RsyncPlugin::findLocalFolderByName(QString folderurl)
+{
+  QString folderurl_stripped;
+  folderurl_stripped = folderurl;
+  folderurl_stripped.replace(QString("file://"), QString(""));
+  for (QStringList::Iterator i(cfgfolderlist.begin()); i != cfgfolderlist.end(); ++i) {
+	if (QString::compare((*i), folderurl_stripped) == 0) {
+		i++;
+		return (*i);
+	}
+  }
+  return NULL;
+}
+
+int RsyncPlugin::deleteLocalFolderByName(QString folderurl)
+{
+  QString folderurl_stripped;
+  folderurl_stripped = folderurl;
+  folderurl_stripped.replace(QString("file://"), QString(""));
+  for (QStringList::Iterator i(cfgfolderlist.begin()); i != cfgfolderlist.end(); ++i) {
+	if (QString::compare((*i), folderurl_stripped) == 0) {
+		i=cfgfolderlist.remove(i);
+		cfgfolderlist.remove(i);
+		return 0;
+	}
+  }
+  return 1;
+}
+
+int RsyncPlugin::addLocalFolderByName(QString folderurl, QString remoteurl)
+{
+  QString folderurl_stripped;
+  folderurl_stripped = folderurl;
+  folderurl_stripped.replace(QString("file://"), QString(""));
+  cfgfolderlist.append(folderurl);
+  cfgfolderlist.append(remoteurl);
+  return 1;
+}
+
+RsyncPlugin::RsyncPlugin (QObject* parent, const char* name,
+                                  const QStringList&)
+                :KParts::Plugin (parent, name),
+                 m_pSyncMenu(0)
+{
+  m_part = ::qt_cast<KonqDirPart*>(parent);
+
+  if ( !m_part || !m_part->scrollWidget() )
+    return;
+
+  m_pSyncNow = new KAction(i18n("Synchronize F&older"), "syncnow",
+                               actionCollection(), "syncnow");
+  m_pSyncSetup = new KAction (i18n("Setup Syn&chronization"), "setupsync",
+                               actionCollection(), "setupsync");
+  //m_pSyncMenu = new KActionMenu (i18n("Remote Folder S&ynchronization"), "syncmenu",
+  //                                 actionCollection(), "rsync");
+  m_pSyncNow->setIcon("remotesync");
+  m_pSyncSetup->setIcon("remotesyncconfig");
+  m_pSyncNow->setEnabled (false);
+  //m_pSyncMenu->setDelayed (false);
+  //m_pSyncMenu->setWhatsThis(i18n("Synchronizes this folder with a remote server."));
+
+  //connect (m_pSyncMenu->popupMenu(), SIGNAL (aboutToShow()),
+  //         SLOT (slotShowPopup()));
+
+  connect (m_part, SIGNAL(aboutToOpenURL()), SLOT(slotOpenURL()));
+
+//  // add a menu option for konqis icons/list views
+//  KAction *syncnow = new KAction(i18n("Synchronize folder contents with server"),
+//                                QApplication::reverseLayout() ? "remotesync" : "remotesync",
+//                                0, 0, 0, actionCollection(), "syncnow");
+//
+//  syncnow->setWhatsThis(i18n("Synchronize Folder<p>Synchronizes folder contents with remote server."));
+//
+  connect(m_pSyncNow, SIGNAL(activated()), this, SLOT(slotSync()));
+  connect(m_pSyncSetup, SIGNAL(activated()), this, SLOT(slotSetup()));
+
+  loadSettings();
+
+    // Initialize the rsync backend variables
+    if (rsyncPath == NULL) {
+        rsyncPath = strdup(QFile::encodeName(KStandardDirs::findExe("rsync")));
+    }
+    if (suPath == NULL) {
+        suPath = strdup(QFile::encodeName(KStandardDirs::findExe("su")));
+    }
+    childPid = 0;
+    isLoggedIn = false;
+    firstLogin = true;
+    connectionAuth.keepPassword = true;
+    //connectionAuth.url.setProtocol("fish");
+    outBufPos = -1;
+    outBuf = NULL;
+    outBufLen = 0;
+    isStat = false; // FIXME: just a workaround for konq deficiencies
+    redirectUser = ""; // FIXME: just a workaround for konq deficiencies
+    redirectPass = ""; // FIXME: just a workaround for konq deficiencies
+}
+
+RsyncPlugin::~RsyncPlugin()
+{
+  delete m_pSyncMenu;
+}
+
+void RsyncPlugin::slotOpenURL ()
+{
+  KURL url = m_part->url();
+
+  if (m_pURL != url)
+  {
+	// See if this URL is in the list of rsync-able directories
+	if (findLocalFolderByName(url.directory(true, true) + QString("/") + url.fileName(true)) != NULL) {
+		m_pSyncNow->setEnabled (true);
+	}
+	else {
+		m_pSyncNow->setEnabled (false);
+	}
+  }
+  m_pURL = url;
+}
+
+// void RsyncPlugin::slotShowPopup()
+// {
+//   if (!m_part)
+//   {
+//     m_pSyncMenu->setEnabled (false);
+//     return;
+//   }
+//
+//   int id = 0;
+//   uint enableReset = 0;
+//
+//   QString label;
+//   QStringList inodes;
+//
+//   m_pSyncMenu->popupMenu()->clear();
+//   m_pSyncMenu->popupMenu()->insertTitle (i18n("Remote Folder Synchronization"));
+//   id = m_pSyncMenu->popupMenu()->insertItem (i18n("Synchronize Now"), this, SLOT(slotSync()));
+// }
+
+void RsyncPlugin::slotSetup()
+{
+	KURL url = m_part->url();
+
+	m_pSyncSetup->setEnabled (false);
+
+	// Look up settings
+	QString localfolder = url.directory(true, true) + QString("/") + url.fileName(true);
+	QString remotefolder = findLocalFolderByName(url.directory(true, true) + QString("/") + url.fileName(true));
+
+	m_configDialog = new RsyncConfigDialog(0, "rsyncConfig", i18n("Remote Folder Synchronization"), i18n("Configuring Remote Folder Synchronization"), localfolder, remotefolder, true);
+	m_configDialog->show();
+
+	connect (m_configDialog, SIGNAL(okClicked()), SLOT(slotSetupOK()));
+	connect (m_configDialog, SIGNAL(cancelClicked()), SLOT(slotSetupCancelled()));
+}
+
+void RsyncPlugin::slotSetupOK()
+{
+	if (!m_part)
+		return;
+
+	KURL url = m_part->url();
+
+	// Look up settings
+	QString localfolder = url.directory(true, true) + QString("/") + url.fileName(true);
+	QString remotefolder = findLocalFolderByName(localfolder);
+	QString remotefolder_new = m_configDialog->lineEdit()->text().ascii();
+
+	// See if an old entry has to be deleted
+	if (remotefolder.isEmpty() == false) {
+		deleteLocalFolderByName(localfolder);
+	}
+	if (remotefolder_new.isEmpty() == false) {
+		addLocalFolderByName(localfolder, remotefolder_new);
+	}
+	saveSettings();
+
+	if (remotefolder_new.isEmpty() == false) {
+		m_pSyncNow->setEnabled (true);
+	}
+	else {
+		m_pSyncNow->setEnabled (false);
+	}
+	m_pSyncSetup->setEnabled (true);
+}
+
+void RsyncPlugin::slotSetupCancelled()
+{
+	m_pSyncSetup->setEnabled (true);
+}
+
+void RsyncPlugin::slotRsyncCancelled()
+{
+        shutdownConnection(true, true);
+        if (m_progressDialogExists == true) {
+            m_progressDialog->progressBar()->setValue(m_progressDialog->progressBar()->totalSteps());
+        }
+	m_pSyncNow->setEnabled (true);
+}
+
+void RsyncPlugin::slotSync()
+{
+  if (!m_part)
+    return;
+
+  KURL url = m_part->url();
+
+  m_pSyncNow->setEnabled (false);
+
+  // Initiate rsync
+  connectionStart(url.directory(true, true) + QString("/") + url.fileName(true), findLocalFolderByName(url.directory(true, true) + QString("/") + url.fileName(true)));
+
+  m_progressDialogExists = false;
+  m_pSyncNow->setEnabled (true);
+}
+
+typedef KGenericFactory<RsyncPlugin> RsyncFactory;
+K_EXPORT_COMPONENT_FACTORY (librsyncplugin, RsyncFactory("rsyncplugin"))
+
+#include "rsyncplugin.moc"
diff --git a/konq-plugins/rsync/rsyncplugin.desktop b/konq-plugins/rsync/rsyncplugin.desktop
new file mode 100644
index 0000000..a06f228
--- /dev/null
+++ b/konq-plugins/rsync/rsyncplugin.desktop
@@ -0,0 +1,15 @@
+[Desktop Entry]
+X-KDE-PluginInfo-Author=Timothy Pearson
[email protected]
+X-KDE-PluginInfo-Name=Rsync
+X-KDE-PluginInfo-Version=3.4
+X-KDE-PluginInfo-Website=
+X-KDE-PluginInfo-Category=Tools
+X-KDE-PluginInfo-Depends=
+X-KDE-PluginInfo-License=GPL
+X-KDE-PluginInfo-EnabledByDefault=true
+Name=Remote Folder Synchronization Plugin
+Comment=Remote folder synchronization plugin
+Icon=remotesync
+X-KDE-ParentApp=konqueror
+DocPath=konq-plugins/rsync/index.html
diff --git a/konq-plugins/rsync/rsyncplugin.h b/konq-plugins/rsync/rsyncplugin.h
new file mode 100644
index 0000000..0e8c22d
--- /dev/null
+++ b/konq-plugins/rsync/rsyncplugin.h
@@ -0,0 +1,131 @@
+/*
+   Copyright (C) 2000, 2001, 2002 Dawit Alemayehu <[email protected]>
+
+   This library is free software; you can redistribute it and/or
+   modify it under the terms of the GNU Library General Public
+   License version 2 as published by the Free Software Foundation.
+
+   This library 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
+   Library General Public License for more details.
+
+   You should have received a copy of the GNU Library General Public License
+   along with this library; see the file COPYING.LIB.  If not, write to
+   the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
+   Boston, MA 02110-1301, USA.
+*/
+
+#ifndef __RSYNC_PLUGIN_H
+#define __RSYNC_PLUGIN_H
+
+#include <qmap.h>
+#include <qstringlist.h>
+
+#include <kurl.h>
+#include <kprocess.h>
+#include <kfileitem.h>
+#include <klibloader.h>
+#include <kparts/plugin.h>
+#include <kio/global.h>
+#include <kio/slavebase.h>
+#include <kio/authinfo.h>
+
+#include "rsyncconfigdialog.h"
+
+class KActionMenu;
+class KonqDirPart;
+class KLineEdit;
+
+
+namespace KParts
+{
+  struct URLArgs;
+}
+
+namespace KIO
+{
+  class Job;
+}
+
+class RsyncPlugin : public KParts::Plugin
+{
+  Q_OBJECT
+
+public:
+
+  RsyncPlugin (QObject* parent, const char* name, const QStringList &);
+  ~RsyncPlugin ();
+
+protected:
+  void loadSettings();
+  void saveSettings();
+  QString findLocalFolderByName(QString folderurl);
+  int deleteLocalFolderByName(QString folderurl);
+  int addLocalFolderByName(QString folderurl, QString remoteurl);
+  /** manages initial communication setup including password queries */
+  int establishConnection(char *buffer, KIO::fileoffset_t len);
+  /** creates the subprocess */
+  bool connectionStart(QString localfolder, QString remotepath);
+  /** writes one chunk of data to stdin of child process */
+  void writeChild(const char *buf, KIO::fileoffset_t len);
+  /** AuthInfo object used for logging in */
+  KIO::AuthInfo connectionAuth;
+  /**
+   Clean up connection
+  */
+  void shutdownConnection(bool forced=false, bool wait=false);
+  /** Forced close of the connection */
+  void closeConnection();
+
+private slots:
+  void slotSync();
+  void slotSetup();
+  void slotOpenURL();
+  void slotShowPopup();
+  void slotSetupOK();
+  void slotSetupCancelled();
+  void slotRsyncCancelled();
+
+private:
+  KURL m_pURL;
+  KonqDirPart* m_part;
+  KAction* m_pSyncNow;
+  KAction* m_pSyncSetup;
+  KActionMenu* m_pSyncMenu;
+  KProgressBoxDialog* m_progressDialog;
+  RsyncConfigDialog* m_configDialog;
+
+  QStringList cfgfolderlist;
+  bool m_progressDialogExists;
+
+  bool m_bSettingsLoaded;
+
+  /** true if connection is logged in successfully */
+  bool isLoggedIn;
+  /** the rsync process used to communicate with the remote end */
+  pid_t childPid;
+  /** fd for reading and writing to the process */
+  int childFd;
+  /** buffer for data to be written */
+  const char *outBuf;
+  /** current write position in buffer */
+  KIO::fileoffset_t outBufPos;
+  /** length of buffer */
+  KIO::fileoffset_t outBufLen;
+  /** use su if true else use ssh */
+  //bool local;
+  /**  // FIXME: just a workaround for konq deficiencies */
+  bool isStat;
+  /**  // FIXME: just a workaround for konq deficiencies */
+  QString redirectUser, redirectPass;
+  /** user name of current connection */
+  QString connectionUser;
+  /** password of current connection */
+  QString connectionPassword;
+  /** true if this is the first login attempt (== use cached password) */
+  bool firstLogin;
+
+  QString thisFn;
+};
+#endif
diff --git a/konq-plugins/rsync/rsyncplugin.rc b/konq-plugins/rsync/rsyncplugin.rc
new file mode 100644
index 0000000..40ec020
--- /dev/null
+++ b/konq-plugins/rsync/rsyncplugin.rc
@@ -0,0 +1,7 @@
+<!DOCTYPE kpartplugin>
+<kpartplugin name="RsyncPlugin" library="librsyncplugin" version = "4">
+<ToolBar fullWidth="true" name="locationToolBar" newline="true">
+	<Action name="syncnow"/>
+	<Action name="setupsync"/>
+</ToolBar>
+</kpartplugin>