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
135
|
/*
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 <tqmap.h>
#include <tqstringlist.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 "rsyncconfigdialog.h"
// NOTE: If ANY of these functions are not utilized in the C file,
// and in a manner identical to these declarations, the plugin will
// mysteriously fail when launched with kshell but work fine under BASH
class KActionMenu;
class KonqDirPart;
class KLineEdit;
namespace KParts
{
struct URLArgs;
}
class RsyncPlugin : public KParts::Plugin
{
Q_OBJECT
public:
RsyncPlugin (TQObject* parent, const char* name, const TQStringList &);
virtual ~RsyncPlugin();
protected:
void loadSettings();
void saveSettings();
TQString findLocalFolderByName(TQString folderurl);
TQString findLoginSyncEnabledByName(TQString folderurl);
TQString findLogoutSyncEnabledByName(TQString folderurl);
TQString findTimedSyncEnabledByName(TQString folderurl);
int deleteLocalFolderByName(TQString folderurl);
int addLocalFolderByName(TQString folderurl, TQString remoteurl, TQString syncmethod, TQString excludelist, TQString sync_on_login, TQString sync_on_logout, TQString sync_timed_interval);
TQString findSyncMethodByName(TQString folderurl);
/** manages initial communication setup including password queries */
int establishConnectionRsync(char *buffer, KIO::fileoffset_t len);
/** manages initial communication setup including password queries */
int establishConnectionUnison(char *buffer, KIO::fileoffset_t len, TQString localfolder, TQString remotepath);
/** creates the unidirectional sync subprocess */
bool syncUnidirectional(TQString synccommand, TQString syncflags, int parameter_order, TQString localfolder, TQString remotepath);
/** creates the bidirectional sync subprocess */
bool syncBidirectional(TQString synccommand, TQString syncflags, int parameter_order, TQString localfolder, TQString 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 slotSetupOK();
void slotSetupCancelled();
void slotRsyncCancelled();
void slotUnisonCancelled();
private:
KURL m_pURL;
KonqDirPart* m_part;
KAction* m_pSyncNow;
KAction* m_pSyncSetup;
KProgressBoxDialog* m_progressDialog;
RsyncConfigDialog* m_configDialog;
TQStringList 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 */
TQString redirectUser, redirectPass;
/** user name of current connection */
TQString connectionUser;
/** password of current connection */
TQString connectionPassword;
/** true if this is the first login attempt (== use cached password) */
bool firstLogin;
TQString thisFn;
};
#endif
|
