1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
/*
Copyright (C) 2000, 2001, 2002 Dawit Alemayehu <adawit@kde.org>
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, QString syncmethod, QString excludelist);
QString findSyncMethodByName(QString folderurl);
/** manages initial communication setup including password queries */
int establishConnection(char *buffer, KIO::fileoffset_t len);
/** creates the unidirectional sync subprocess */
bool syncUnidirectional(QString synccommand, QString syncflags, int parameter_order, QString localfolder, QString remotepath);
/** creates the bidirectional sync subprocess */
bool syncBidirectional(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
|
