diff options
Diffstat (limited to 'kio/kio/slavebase.h')
| -rw-r--r-- | kio/kio/slavebase.h | 847 |
1 files changed, 0 insertions, 847 deletions
diff --git a/kio/kio/slavebase.h b/kio/kio/slavebase.h deleted file mode 100644 index a65a1f94f..000000000 --- a/kio/kio/slavebase.h +++ /dev/null @@ -1,847 +0,0 @@ -/* - Copyright (C) 2000 David Faure <faure@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 as published by the Free Software Foundation; either - version 2 of the License, or (at your option) any later version. - - 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 __slavebase_h -#define __slavebase_h - -#include <kurl.h> -#include <kconfigbase.h> -#include <kio/global.h> -#include <kio/authinfo.h> - -class DCOPClient; -class KRemoteEncoding; - -namespace TDEIO { - -class Connection; -class SlaveBasePrivate; - -/** - * There are two classes that specifies the protocol between application (job) - * and kioslave. SlaveInterface is the class to use on the application end, - * SlaveBase is the one to use on the slave end. - * - * Slave implementations should simply inherit SlaveBase - * - * A call to foo() results in a call to slotFoo() on the other end. - */ -class TDEIO_EXPORT SlaveBase -{ -public: - SlaveBase( const TQCString &protocol, const TQCString &pool_socket, const TQCString &app_socket); - virtual ~SlaveBase(); - - /** - * @internal - * Terminate the slave by calling the destructor and then ::exit() - */ - void exit(); - - /** - * @internal - */ - void dispatchLoop(); - - /** - * @internal - */ - void setConnection( Connection* connection ) { m_pConnection = connection; } - /** - * @internal - */ - Connection *connection() const { return m_pConnection; } - - - /////////// - // Message Signals to send to the job - /////////// - - /** - * Sends data in the slave to the job (i.e. in get). - * - * To signal end of data, simply send an empty - * TQByteArray(). - * - * @param data the data read by the slave - */ - void data( const TQByteArray &data ); - - /** - * Asks for data from the job. - * @see readData - */ - void dataReq( ); - - /** - * Call to signal an error. - * This also finishes the job, no need to call finished. - * - * If the Error code is TDEIO::ERR_SLAVE_DEFINED then the - * _text should contain the complete translated text of - * of the error message. This message will be displayed - * in an KTextBrowser which allows rich text complete - * with hyper links. Email links will call the default - * mailer, "exec:/command arg1 arg2" will be forked and - * all other links will call the default browser. - * - * @see TDEIO::Error - * @see KTextBrowser - * @param _errid the error code from TDEIO::Error - * @param _text the rich text error message - */ - void error( int _errid, const TQString &_text ); - - /** - * Call in openConnection, if you reimplement it, when you're done. - */ - void connected(); - - /** - * Call to signal successful completion of any command - * (besides openConnection and closeConnection) - */ - void finished(); - - /** - * Call to signal that data from the sub-URL is needed - */ - void needSubURLData(); - - /** - * Used to report the status of the slave. - * @param host the slave is currently connected to. (Should be - * empty if not connected) - * @param connected Whether an actual network connection exists. - **/ - void slaveStatus(const TQString &host, bool connected); - - /** - * Call this from stat() to express details about an object, the - * UDSEntry customarily contains the atoms describing file name, size, - * mimetype, etc. - * @param _entry The UDSEntry containing all of the object attributes. - */ - void statEntry( const UDSEntry& _entry ); - - /** - * Call this in listDir, each time you have a bunch of entries - * to report. - * @param _entry The UDSEntry containing all of the object attributes. - */ - void listEntries( const UDSEntryList& _entry ); - - /** - * Call this at the beginning of put(), to give the size of the existing - * partial file, if there is one. The @p offset argument notifies the - * other job (the one that gets the data) about the offset to use. - * In this case, the boolean returns whether we can indeed resume or not - * (we can't if the protocol doing the get() doesn't support setting an offset) - */ - bool canResume( TDEIO::filesize_t offset ); - - /* - * Call this at the beginning of get(), if the "resume" metadata was set - * and resuming is implemented by this protocol. - */ - void canResume(); - - /////////// - // Info Signals to send to the job - /////////// - - /** - * Call this in get and copy, to give the total size - * of the file - * Call in listDir too, when you know the total number of items. - */ - void totalSize( TDEIO::filesize_t _bytes ); - /** - * Call this during get and copy, once in a while, - * to give some info about the current state. - * Don't emit it in listDir, listEntries speaks for itself. - */ - void processedSize( TDEIO::filesize_t _bytes ); - - /** - * Only use this if you can't know in advance the size of the - * copied data. For example, if you're doing variable bitrate - * compression of the source. - * - * STUB ! Currently unimplemented. Here now for binary compatibility. - * - * Call this during get and copy, once in a while, - * to give some info about the current state. - * Don't emit it in listDir, listEntries speaks for itself. - */ - void processedPercent( float percent ); - - /** - * Call this in get and copy, to give the current transfer - * speed, but only if it can't be calculated out of the size you - * passed to processedSize (in most cases you don't want to call it) - */ - void speed( unsigned long _bytes_per_second ); - - /** - * Call this to signal a redirection - * The job will take care of going to that url. - */ - void redirection( const KURL &_url ); - - /** - * Tell that we will only get an error page here. - * This means: the data you'll get isn't the data you requested, - * but an error page (usually HTML) that describes an error. - */ - void errorPage(); - - /** - * Call this in mimetype() and in get(), when you know the mimetype. - * See mimetype about other ways to implement it. - */ - void mimeType( const TQString &_type ); - - /** - * Call to signal a warning, to be displayed in a dialog box. - */ - void warning( const TQString &msg ); - - /** - * Call to signal a message, to be displayed if the application wants to, - * for instance in a status bar. Usual examples are "connecting to host xyz", etc. - */ - void infoMessage( const TQString &msg ); - - enum MessageBoxType { QuestionYesNo = 1, WarningYesNo = 2, WarningContinueCancel = 3, WarningYesNoCancel = 4, Information = 5, SSLMessageBox = 6 }; - - /** - * Call this to show a message box from the slave - * @param type type of message box: QuestionYesNo, WarningYesNo, WarningContinueCancel... - * @param text Message string. May contain newlines. - * @param caption Message box title. - * @param buttonYes The text for the first button. - * The default is i18n("&Yes"). - * @param buttonNo The text for the second button. - * The default is i18n("&No"). - * Note: for ContinueCancel, buttonYes is the continue button and buttonNo is unused. - * and for Information, none is used. - * @return a button code, as defined in KMessageBox, or 0 on communication error. - */ - int messageBox( MessageBoxType type, const TQString &text, - const TQString &caption = TQString::null, - const TQString &buttonYes = TQString::null, - const TQString &buttonNo = TQString::null ); - - /** - * Call this to show a message box from the slave - * @param text Message string. May contain newlines. - * @param type type of message box: QuestionYesNo, WarningYesNo, WarningContinueCancel... - * @param caption Message box title. - * @param buttonYes The text for the first button. - * The default is i18n("&Yes"). - * @param buttonNo The text for the second button. - * The default is i18n("&No"). - * Note: for ContinueCancel, buttonYes is the continue button and buttonNo is unused. - * and for Information, none is used. - * @param dontAskAgainName A checkbox is added with which further confirmation can be turned off. - * The string is used to lookup and store the setting in kioslaverc. - * @return a button code, as defined in KMessageBox, or 0 on communication error. - * @since 3.3 - */ - int messageBox( const TQString &text, MessageBoxType type, - const TQString &caption = TQString::null, - const TQString &buttonYes = TQString::null, - const TQString &buttonNo = TQString::null, - const TQString &dontAskAgainName = TQString::null ); - - /** - * Sets meta-data to be send to the application before the first - * data() or finished() signal. - */ - void setMetaData(const TQString &key, const TQString &value); - - /** - * Queries for the existence of a certain config/meta-data entry - * send by the application to the slave. - * @since 3.2 - */ - bool hasMetaData(const TQString &key) const; - - /** - * Queries for config/meta-data send by the application to the slave. - * @since 3.2 - */ - TQString metaData(const TQString &key) const; - - /** - * @obsolete kept for binary compatibility - * Queries for the existence of a certain config/meta-data entry - * send by the application to the slave. - */ - bool hasMetaData(const TQString &key); - - /** - * @obsolete kept for binary compatibility - * Queries for config/meta-data sent by the application to the slave. - */ - TQString metaData(const TQString &key); - - /** - * @internal for ForwardingSlaveBase - * Contains all metadata (but no config) sent by the application to the slave. - * @since 3.5.2 - */ - MetaData allMetaData() const { return mIncomingMetaData; } - - /** - * Returns a configuration object to query config/meta-data information - * from. - * - * The application provides the slave with all configuration information - * relevant for the current protocol and host. - */ - TDEConfigBase* config(); - - /** - * Returns an object that can translate remote filenames into proper - * Unicode forms. This encoding can be set by the user. - * - * @since 3.3 - */ - KRemoteEncoding* remoteEncoding(); - - - /////////// - // Commands sent by the job, the slave has to - // override what it wants to implement - /////////// - - /** - * Set the host - * @param host - * @param port - * @param user - * @param pass - * Called directly by createSlave, this is why there is no equivalent in - * SlaveInterface, unlike the other methods. - * - * This method is called whenever a change in host, port or user occurs. - */ - virtual void setHost(const TQString& host, int port, const TQString& user, const TQString& pass); - - /** - * Prepare slave for streaming operation - */ - virtual void setSubURL(const KURL&url); - - /** - * Opens the connection (forced) - * When this function gets called the slave is operating in - * connection-oriented mode. - * When a connection gets lost while the slave operates in - * connection oriented mode, the slave should report - * ERR_CONNECTION_BROKEN instead of reconnecting. The user is - * expected to disconnect the slave in the error handler. - */ - virtual void openConnection(); - - /** - * Closes the connection (forced) - * Called when the application disconnects the slave to close - * any open network connections. - * - * When the slave was operating in connection-oriented mode, - * it should reset itself to connectionless (default) mode. - */ - virtual void closeConnection(); - - /** - * get, aka read. - * @param url the full url for this request. Host, port and user of the URL - * can be assumed to be the same as in the last setHost() call. - * The slave emits the data through data - */ - virtual void get( const KURL& url ); - - /** - * put, i.e. write data into a file. - * - * @param url where to write the file - * @param permissions may be -1. In this case no special permission mode is set. - * @param overwrite if true, any existing file will be overwritten. - * If the file indeed already exists, the slave should NOT apply the - * permissions change to it. - * @param resume currently unused, please ignore. - * The support for resuming using .part files is done by calling canResume(). - * - * IMPORTANT: Use the "modified" metadata in order to set the modification time of the file. - * - * @see canResume() - */ - virtual void put( const KURL& url, int permissions, bool overwrite, bool resume ); - - /** - * Finds all details for one file or directory. - * The information returned is the same as what listDir returns, - * but only for one file or directory. - */ - virtual void stat( const KURL& url ); - - /** - * Finds mimetype for one file or directory. - * - * This method should either emit 'mimeType' or it - * should send a block of data big enough to be able - * to determine the mimetype. - * - * If the slave doesn't reimplement it, a get will - * be issued, i.e. the whole file will be downloaded before - * determining the mimetype on it - this is obviously not a - * good thing in most cases. - */ - virtual void mimetype( const KURL& url ); - - /** - * Lists the contents of @p url. - * The slave should emit ERR_CANNOT_ENTER_DIRECTORY if it doesn't exist, - * if we don't have enough permissions, or if it is a file - * It should also emit totalFiles as soon as it knows how many - * files it will list. - */ - virtual void listDir( const KURL& url ); - - /** - * Create a directory - * @param url path to the directory to create - * @param permissions the permissions to set after creating the directory - * (-1 if no permissions to be set) - * The slave emits ERR_COULD_NOT_MKDIR if failure. - */ - virtual void mkdir( const KURL&url, int permissions ); - - /** - * Rename @p oldname into @p newname. - * If the slave returns an error ERR_UNSUPPORTED_ACTION, the job will - * ask for copy + del instead. - * @param src where to move the file from - * @param dest where to move the file to - * @param overwrite if true, any existing file will be overwritten - */ - virtual void rename( const KURL& src, const KURL& dest, bool overwrite ); - - /** - * Creates a symbolic link named @p dest, pointing to @p target, which - * may be a relative or an absolute path. - * @param target The string that will become the "target" of the link (can be relative) - * @param dest The symlink to create. - * @param overwrite whether to automatically overwrite if the dest exists - */ - virtual void symlink( const TQString& target, const KURL& dest, bool overwrite ); - - /** - * Change permissions on @p path - * The slave emits ERR_DOES_NOT_EXIST or ERR_CANNOT_CHMOD - */ - virtual void chmod( const KURL& url, int permissions ); - - /** - * Copy @p src into @p dest. - * If the slave returns an error ERR_UNSUPPORTED_ACTION, the job will - * ask for get + put instead. - * @param src where to copy the file from (decoded) - * @param dest where to copy the file to (decoded) - * @param permissions may be -1. In this case no special permission mode is set. - * @param overwrite if true, any existing file will be overwritten - * - */ - virtual void copy( const KURL &src, const KURL &dest, int permissions, bool overwrite ); - - /** - * Delete a file or directory. - * @param url file/directory to delete - * @param isfile if true, a file should be deleted. - * if false, a directory should be deleted. - */ - virtual void del( const KURL &url, bool isfile); - - // TODO KDE4: add setLinkDest() or something, to modify symlink targets. - // Will be used for kio_file but also kio_remote (#97129) - - /** - * Used for any command that is specific to this slave (protocol) - * Examples are : HTTP POST, mount and unmount (kio_file) - * - * @param data packed data; the meaning is completely dependent on the - * slave, but usually starts with an int for the command number. - * Document your slave's commands, at least in its header file. - */ - virtual void special( const TQByteArray & data ); - - /** - * Used for multiple get. Currently only used foir HTTP pielining - * support. - * - * @param data packed data; Contains number of URLs to fetch, and for - * each URL the URL itself and its associated MetaData. - */ - virtual void multiGet( const TQByteArray & data ); - - /** - * Called to get the status of the slave. Slave should respond - * by calling slaveStatus(...) - */ - virtual void slave_status(); - - /** - * Called by the scheduler to tell the slave that the configuration - * changed (i.e. proxy settings) . - */ - virtual void reparseConfiguration(); - - /** - * For use with for ForwardingSlaveBase - * Returns the local URL of the given remote URL if possible - * @since R14.0.0 - */ - virtual void localURL( const KURL& remoteURL ); - - /** - * @return timeout value for connecting to remote host. - */ - int connectTimeout(); - - /** - * @return timeout value for connecting to proxy in secs. - */ - int proxyConnectTimeout(); - - /** - * @return timeout value for read from first data from - * remote host in seconds. - */ - int responseTimeout(); - - /** - * @return timeout value for read from subsequent data from - * remote host in secs. - */ - int readTimeout(); - - /** - * This function sets a timeout of @p timeout seconds and calls - * special(data) when the timeout occurs as if it was called by the - * application. - * - * A timeout can only occur when the slave is waiting for a command - * from the application. - * - * Specifying a negative timeout cancels a pending timeout. - * - * Only one timeout at a time is supported, setting a timeout - * cancels any pending timeout. - * @since 3.1 - */ - void setTimeoutSpecialCommand(int timeout, const TQByteArray &data=TQByteArray()); - - /** - * @internal - */ - static void sigsegv_handler(int); - /** - * @internal - */ - static void sigpipe_handler(int); - - ///////////////// - // Dispatching (internal) - //////////////// - - /** - * @internal - */ - virtual bool dispatch(); - /** - * @internal - */ - virtual void dispatch( int command, const TQByteArray &data ); - - /** - * Read data send by the job, after a dataReq - * - * @param buffer buffer where data is stored - * @return 0 on end of data, - * > 0 bytes read - * < 0 error - **/ - int readData( TQByteArray &buffer ); - - /** - * internal function to be called by the slave. - * It collects entries and emits them via listEntries - * when enough of them are there or a certain time - * frame exceeded (to make sure the app gets some - * items in time but not too many items one by one - * as this will cause a drastic performance penalty) - * @param _entry The UDSEntry containing all of the object attributes. - * @param ready set to true after emitting all items. @p _entry is not - * used in this case - */ - void listEntry( const UDSEntry& _entry, bool ready); - - /** - * internal function to connect a slave to/ disconnect from - * either the slave pool or the application - */ - void connectSlave(const TQString& path); - void disconnectSlave(); - - /** - * Prompt the user for Authorization info (login & password). - * - * Use this function to request authorization information from - * the end user. You can also pass an error message which explains - * why a previous authorization attempt failed. Here is a very - * simple example: - * - * \code - * TDEIO::AuthInfo authInfo; - * if ( openPassDlg( authInfo ) ) - * { - * kdDebug() << TQString::fromLatin1("User: ") - * << authInfo.username << endl; - * kdDebug() << TQString::fromLatin1("Password: ") - * << TQString::fromLatin1("Not displayed here!") << endl; - * } - * \endcode - * - * You can also preset some values like the username, caption or - * comment as follows: - * - * \code - * TDEIO::AuthInfo authInfo; - * authInfo.caption= "Acme Password Dialog"; - * authInfo.username= "Wile E. Coyote"; - * TQString errorMsg = "You entered an incorrect password."; - * if ( openPassDlg( authInfo, errorMsg ) ) - * { - * kdDebug() << TQString::fromLatin1("User: ") - * << authInfo.username << endl; - * kdDebug() << TQString::fromLatin1("Password: ") - * << TQString::fromLatin1("Not displayed here!") << endl; - * } - * \endcode - * - * \note You should consider using checkCachedAuthentication() to - * see if the password is available in kpasswdserver before calling - * this function. - * - * \note A call to this function can fail and return @p false, - * if the UIServer could not be started for whatever reason. - * - * @see checkCachedAuthentication - * @param info See AuthInfo. - * @param errorMsg Error message to show - * @return @p true if user clicks on "OK", @p false otherwsie. - * @since 3.1 - */ - bool openPassDlg( TDEIO::AuthInfo& info, const TQString &errorMsg ); - - /** - * Same as above function except it does not need error message. - * BIC: Combine this function with the above for KDE4. - */ - bool openPassDlg( TDEIO::AuthInfo& info ); - - /** - * Checks for cached authentication based on parameters - * given by @p info. - * - * Use this function to check if any cached password exists - * for the URL given by @p info. If @p AuthInfo::realmValue - * and/or @p AuthInfo::verifyPath flag is specified, then - * they will also be factored in determining the presence - * of a cached password. Note that @p Auth::url is a required - * parameter when attempting to check for cached authorization - * info. Here is a simple example: - * - * \code - * AuthInfo info; - * info.url = KURL("http://www.foobar.org/foo/bar"); - * info.username = "somename"; - * info.verifyPath = true; - * if ( !checkCachedAuthentication( info ) ) - * { - * if ( !openPassDlg(info) ) - * .... - * } - * \endcode - * - * @param info See AuthInfo. - * @return @p true if cached Authorization is found, false otherwise. - */ - bool checkCachedAuthentication( AuthInfo& info ); - - /** - * Explicitly store authentication information. openPassDlg already - * stores password information automatically, you only need to call - * this function if you want to store authentication information that - * is different from the information returned by openPassDlg. - */ - bool cacheAuthentication( const AuthInfo& info ); - - /** - * @obsolete as of 3.1. - * TODO: Remove before KDE 4.0 - */ - bool pingCacheDaemon() const; - - /** - * @obsolete as of 3.1. Use openPassDlg instead. - * TODO: Remove before KDE 4.0 - * Creates a basic key to be used to cache the password. - * @param url the url from which the key is supposed to be generated - */ - TQString createAuthCacheKey( const KURL& url ); - - /** - * @obsolete as of 3.1. Use openPassDlg instead. - * TODO: Remove before KDE 4.0 - * - * Cache authentication information is now stored automatically - * by openPassDlg. - */ - void sendAuthenticationKey( const TQCString& gKey, const TQCString& key, bool keep ); - - /** - * @obsolete as of 3.1. Use openPassDlg instead. - * TODO: Remove before KDE 4.0 - * - * Cached authentication information is now session based and - * removed automatically when a given session ends, i.e. the - * application is closed. - */ - void delCachedAuthentication( const TQString& key ); - - /** - * @obsolete as of 3.1. Use openPassDlg instead. - * TODO: Remove before KDE 4.0 - */ - void setMultipleAuthCaching( bool ) {}; - - /** - * @obsolete as of 3.1. Use openPassDlg instead. - * TODO: Remove before KDE 4.0 - */ - bool multipleAuthCaching() const { return false; } - - /** - * Used by the slave to check if it can connect - * to a given host. This should be called where the slave is ready - * to do a ::connect() on a socket. For each call to - * requestNetwork must exist a matching call to - * dropNetwork, or the system will stay online until - * KNetMgr gets closed (or the SlaveBase gets destructed)! - * - * If KNetMgr is not running, then this is a no-op and returns true - * - * @param host tells the netmgr the host the slave wants to connect - * to. As this could also be a proxy, we can't just take - * the host currenctly connected to (but that's the default - * value) - * - * @return true in theorie, the host is reachable - * false the system is offline and the host is in a remote network. - */ - bool requestNetwork(const TQString& host = TQString::null); - - /** - * Used by the slave to withdraw a connection requested by - * requestNetwork. This function cancels the last call to - * requestNetwork. If a client uses more than one internet - * connection, it must use dropNetwork(host) to - * stop each request. - * - * If KNetMgr is not running, then this is a no-op. - * - * @param host the host passed to requestNetwork - * - * A slave should call this function every time it disconnect from a host. - * */ - void dropNetwork(const TQString& host = TQString::null); - - /** - * Return the dcop client used by this slave. - * @since 3.1 - */ - DCOPClient *dcopClient(); - - /** - * Wait for an answer to our request, until we get @p expected1 or @p expected2 - * @return the result from readData, as well as the cmd in *pCmd if set, and the data in @p data - */ - int waitForAnswer( int expected1, int expected2, TQByteArray & data, int * pCmd = 0 ); - - /** - * Internal function to transmit meta data to the application. - */ - void sendMetaData(); - - /** - * Name of the protocol supported by this slave - */ - TQCString mProtocol; - - Connection * m_pConnection; - - MetaData mOutgoingMetaData; - MetaData mIncomingMetaData; - - /** If your ioslave was killed by a signal, wasKilled() returns true. - Check it regularly in lengthy functions (e.g. in get();) and return - as fast as possible from this function if wasKilled() returns true. - This will ensure that your slave destructor will be called correctly. - @since 3.1 - */ - bool wasKilled() const; - - /** Internally used. - * @internal - * @since 3.1 - */ - void setKillFlag(); - -protected: - UDSEntryList pendingListEntries; - uint listEntryCurrentSize; - long listEntry_sec, listEntry_usec; - Connection *appconn; - TQString mPoolSocket; - TQString mAppSocket; - bool mConnectedToApp; - static long s_seqNr; - virtual void virtual_hook( int id, void* data ); - -private: - SlaveBasePrivate *d; -}; - -} - -#endif |