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
136
137
138
139
140
141
142
|
/***************************************************************************
krarc.h
-------------------
begin : Sat Jun 14 14:42:49 IDT 2003
copyright : (C) 2003 by Rafi Yanai & Shie Erlich
email : [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. *
* *
***************************************************************************/
#ifndef __krarc_h__
#define __krarc_h__
#include <qstring.h>
#include <qcstring.h>
#include <qdict.h>
#include <qfile.h>
#include <sys/types.h>
#include <kurl.h>
#include <kio/global.h>
#include <kio/slavebase.h>
#include <kprocess.h>
class KProcess;
class KFileItem;
class QCString;
class kio_krarcProtocol : public QObject, public KIO::SlaveBase {
Q_OBJECT
public:
kio_krarcProtocol(const QCString &pool_socket, const QCString &app_socket);
virtual ~kio_krarcProtocol();
virtual void stat( const KURL & url );
virtual void get(const KURL& url);
virtual void put(const KURL& url,int permissions,bool overwrite,bool resume);
virtual void mkdir(const KURL& url,int permissions);
virtual void listDir(const KURL& url);
virtual void del(KURL const & url, bool isFile);
virtual void copy (const KURL &src, const KURL &dest, int permissions, bool overwrite);
public slots:
void receivedData(KProcess* proc,char* buf,int len);
void checkOutputForPassword( KProcess*,char*,int );
protected:
virtual bool initDirDict(const KURL& url,bool forced = false);
virtual bool initArcParameters();
QString detectArchive( bool &encrypted, QString fileName );
virtual void parseLine(int lineNo, QString line, QFile* temp);
virtual bool setArcFile(const KURL& url);
virtual QString getPassword();
virtual void invalidatePassword();
// archive specific commands
QString cmd; ///< the archiver name.
QString listCmd; ///< list files.
QString getCmd; ///< unpack files command.
QString delCmd; ///< delete files command.
QString putCmd; ///< add file command.
QString copyCmd; ///< copy to file command.
private:
void get(const KURL& url, int tries);
/** checks if the exit code is OK. */
bool checkStatus( int exitCode );
/** service function for parseLine. */
QString nextWord(QString &s,char d=' ');
/** translate permittion string to mode_t. */
mode_t parsePermString(QString perm);
/** return the name of the directory inside the archive. */
QString findArcDirectory(const KURL& url);
/** find the UDSEntry of a file in a directory. */
KIO::UDSEntry* findFileEntry(const KURL& url);
/** add a new directory (file list container). */
KIO::UDSEntryList* addNewDir(QString path);
QString fullPathName( QString name );
QString convertFileName( QString name );
static QString convertName( QString name );
static QString escape( QString name );
QDict<KIO::UDSEntryList> dirDict; //< the directoris data structure.
bool encrypted; //< tells whether the archive is encrypted
bool archiveChanged; //< true if the archive was changed.
bool archiveChanging; //< true if the archive is currently changing.
bool newArchiveURL; //< true if new archive was entered for the protocol
KIO::filesize_t decompressedLen; //< the number of the decompressed bytes
KFileItem* arcFile; //< the archive file item.
QString arcPath; //< the archive location
QString arcTempDir; //< the currently used temp directory.
QString arcType; //< the archive type.
bool extArcReady; //< Used for RPM & DEB files.
QString password; //< Password for the archives
KConfig *krConfig; //< The configuration file for krusader
QString lastData;
QString encryptedArchPath;
};
class KrShellProcess : public KShellProcess {
Q_OBJECT
public:
KrShellProcess() : KShellProcess(), errorMsg( QString::null ), outputMsg( QString::null ) {
connect(this,SIGNAL(receivedStderr(KProcess*,char*,int)),
this,SLOT(receivedErrorMsg(KProcess*,char*,int)) );
connect(this,SIGNAL(receivedStdout(KProcess*,char*,int)),
this,SLOT(receivedOutputMsg(KProcess*,char*,int)) );
}
QString getErrorMsg() {
if( errorMsg.stripWhiteSpace().isEmpty() )
return outputMsg.right( 500 );
else
return errorMsg.right( 500 );
}
public slots:
void receivedErrorMsg(KProcess*, char *buf, int len) {
errorMsg += QString::fromLocal8Bit( buf, len );
if( errorMsg.length() > 500 )
errorMsg = errorMsg.right( 500 );
receivedOutputMsg( 0, buf, len );
}
void receivedOutputMsg(KProcess*, char *buf, int len) {
outputMsg += QString::fromLocal8Bit( buf, len );
if( outputMsg.length() > 500 )
outputMsg = outputMsg.right( 500 );
}
private:
QString errorMsg;
QString outputMsg;
};
#endif
|
