diff options
Diffstat (limited to 'src/kiosvn/kiosvn.cpp')
| -rw-r--r-- | src/kiosvn/kiosvn.cpp | 954 |
1 files changed, 0 insertions, 954 deletions
diff --git a/src/kiosvn/kiosvn.cpp b/src/kiosvn/kiosvn.cpp deleted file mode 100644 index 2d8365c..0000000 --- a/src/kiosvn/kiosvn.cpp +++ /dev/null @@ -1,954 +0,0 @@ -/*************************************************************************** - * Copyright (C) 2005-2007 by Rajko Albrecht * - * ral@alwins-world.de * - * * - * 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. * - * * - * This program 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 General Public License for more details. * - * * - * You should have received a copy of the GNU General Public License * - * along with this program; if not, write to the * - * Free Software Foundation, Inc., * - * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. * - ***************************************************************************/ -#include "tdesvn-config.h" -#include "kiosvn.h" -#include "kiolistener.h" - -#include "svnqttypes.hpp" -#include "dirent.hpp" -#include "url.hpp" -#include "status.hpp" -#include "targets.hpp" -#include "info_entry.hpp" -#include "tdesvnsettings.h" -#include "sub2qt.h" -#include "sshagent.h" - -#include <stdlib.h> -#include <math.h> -#include <unistd.h> -#include <sys/socket.h> -#include <netinet/in.h> -#include <netdb.h> - -#include <kapplication.h> -#include <kdebug.h> -#include <kdemacros.h> -#include <kmessagebox.h> -#include <kinstance.h> -#include <kglobal.h> -#include <kstandarddirs.h> -#include <klocale.h> -#include <kurl.h> -#include <ktempdir.h> -#include <ksock.h> -#include <dcopclient.h> -#include <tqcstring.h> -#include <kmimetype.h> -#include <krun.h> -#include <tqtextstream.h> - -#include <stdlib.h> -#include <math.h> -#include <unistd.h> -#include <sys/socket.h> -#include <netinet/in.h> -#include <netdb.h> - -namespace TDEIO -{ - -class KioSvnData -{ -public: - KioSvnData(tdeio_svnProtocol*); - virtual ~KioSvnData(); - - void reInitClient(); - - KioListener m_Listener; - bool first_done; - bool dispProgress; - svn::ContextP m_CurrentContext; - svn::Client* m_Svnclient; - - svn::Revision urlToRev(const KURL&); - -}; - -KioSvnData::KioSvnData(tdeio_svnProtocol*par) - : m_Listener(par),first_done(false) -{ - m_Svnclient=svn::Client::getobject(0,0); - m_CurrentContext = 0; - dispProgress = false; - reInitClient(); -} - -void KioSvnData::reInitClient() -{ - if (first_done) { - return; - } - SshAgent ag; - ag.querySshAgent(); - - first_done = true; - m_CurrentContext = new svn::Context(); - m_CurrentContext->setListener(&m_Listener); - m_Svnclient->setContext(m_CurrentContext); -} - -KioSvnData::~KioSvnData() -{ - m_Listener.setCancel(true); - /* wait a little bit */ - sleep(1); - delete m_Svnclient; - m_CurrentContext->setListener(0L); - m_CurrentContext = 0; -} - -svn::Revision KioSvnData::urlToRev(const KURL&url) -{ - TQMap<TQString,TQString> q = url.queryItems(); - - /* we try to check if it is ssh and try to get a password for it */ - TQString proto = url.protocol(); - - if (proto.find("ssh")!=-1) { - SshAgent ag; - ag.addSshIdentities(); - } - - svn::Revision rev,tmp; - rev = svn::Revision::UNDEFINED; - if (q.find("rev")!=q.end()) { - TQString v = q["rev"]; - m_Svnclient->url2Revision(v,rev,tmp); - } - return rev; -} - - -tdeio_svnProtocol::tdeio_svnProtocol(const TQCString &pool_socket, const TQCString &app_socket) - : SlaveBase("tdeio_ksvn", pool_socket, app_socket),StreamWrittenCb() -{ - m_pData=new KioSvnData(this); - TDEGlobal::locale()->insertCatalogue("tdesvn"); -} - -tdeio_svnProtocol::~tdeio_svnProtocol() -{ - kdDebug()<<"Delete kio protocol"<<endl; - delete m_pData; -} - -} - -extern "C" -{ - KDESVN_EXPORT int kdemain(int argc, char **argv); -} - -int kdemain(int argc, char **argv) -{ - kdDebug()<<"kdemain" << endl; - TDEInstance instance( "tdeio_ksvn" ); - // start the tdesvnd DCOP service - TQString error; - TQCString appId; - - kdDebug(7101) << "*** Starting tdeio_ksvn " << endl; - - if (argc != 4) { - kdDebug(7101) << "Usage: tdeio_ksvn protocol domain-socket1 domain-socket2" << endl; - exit(-1); - } - - TDEIO::tdeio_svnProtocol slave(argv[2], argv[3]); - slave.dispatchLoop(); - - kdDebug(7101) << "*** tdeio_ksvn Done" << endl; - return 0; -} - -namespace TDEIO -{ -/*! - \fn tdeio_svnProtocol::listDir (const KURL&url) - */ -void tdeio_svnProtocol::listDir(const KURL&url) -{ - kdDebug() << "tdeio_svn::listDir(const KURL& url) : " << url.url() << endl ; - svn::DirEntries dlist; - svn::Revision rev = m_pData->urlToRev(url); - if (rev == svn::Revision::UNDEFINED) { - rev = svn::Revision::HEAD; - } - - try { - dlist = m_pData->m_Svnclient->list(makeSvnUrl(url),rev,rev,svn::DepthImmediates,false); - } catch (const svn::ClientException&e) { - TQString ex = e.msg(); - kdDebug()<<ex<<endl; - error(TDEIO::ERR_CANNOT_ENTER_DIRECTORY,ex); - return; - } - TDEIO::UDSEntry entry; - totalSize(dlist.size()); - for (unsigned int i=0; i < dlist.size();++i) { - if (!dlist[i] || dlist[i]->name().isEmpty()) { - continue; - } - TQDateTime dt = svn::DateTime(dlist[i]->time()); - if (createUDSEntry(dlist[i]->name(), - dlist[i]->lastAuthor(), - dlist[i]->size(), - dlist[i]->kind()==svn_node_dir?true:false, - dt.toTime_t(), - entry) ) { - listEntry(entry,false); - } - entry.clear(); - } - listEntry(entry, true ); - finished(); -} - -void tdeio_svnProtocol::stat(const KURL& url) -{ - kdDebug()<<"tdeio_svn::stat "<< url << endl; - svn::Revision rev = m_pData->urlToRev(url); - if (rev == svn::Revision::UNDEFINED) { - rev = svn::Revision::HEAD; - } - svn::Revision peg = rev; - bool dummy = false; - svn::InfoEntries e; - try { - e = m_pData->m_Svnclient->info(makeSvnUrl(url),svn::DepthEmpty,rev,peg); - } catch (const svn::ClientException&e) { - TQString ex = e.msg(); - kdDebug()<<ex<<endl; - error( TDEIO::ERR_SLAVE_DEFINED,ex); - return; - } - - if (e.count()==0) { - dummy = true; -/* finished(); - return;*/ - } - - TDEIO::UDSEntry entry; - TQDateTime dt; - if (dummy) { - createUDSEntry(url.filename(),"",0,true,dt.toTime_t(),entry); - } else { - dt = svn::DateTime(e[0].cmtDate()); - if (e[0].kind()==svn_node_file) { - createUDSEntry(url.filename(),"",0,false,dt.toTime_t(),entry); - } else { - createUDSEntry(url.filename(),"",0,true,dt.toTime_t(),entry); - } - } - statEntry(entry); - finished(); -} - -void tdeio_svnProtocol::get(const KURL& url) -{ - kdDebug()<<"tdeio_svn::get "<< url << endl; - if (m_pData->m_Listener.contextCancel()) { - finished(); - return; - } - svn::Revision rev = m_pData->urlToRev(url); - if (rev == svn::Revision::UNDEFINED) { - rev = svn::Revision::HEAD; - } - KioByteStream dstream(this,url.filename()); - try { - m_pData->m_Svnclient->cat(dstream,makeSvnUrl(url),rev,rev); - } catch (const svn::ClientException&e) { - TQString ex = e.msg(); - kdDebug()<<ex<<endl; - error( TDEIO::ERR_SLAVE_DEFINED,"Subversion error "+ex); - finished(); - return; - } - totalSize(dstream.written()); - data(TQByteArray()); // empty array means we're done sending the data - finished(); -} - -void tdeio_svnProtocol::mkdir(const KURL &url, int) -{ - kdDebug()<<"tdeio_svn::mkdir "<< url << endl; - svn::Revision rev = m_pData->urlToRev(url); - if (rev == svn::Revision::UNDEFINED) { - rev = svn::Revision::HEAD; - } - try { - svn::Path p(makeSvnUrl(url)); - m_pData->m_Svnclient->mkdir(p,getDefaultLog()); - }catch (const svn::ClientException&e) { - error( TDEIO::ERR_SLAVE_DEFINED,e.msg()); - } - kdDebug()<<"tdeio_svn::mkdir finished " << url << endl; - finished(); -} - -void tdeio_svnProtocol::mkdir(const KURL::List &urls, int) -{ - svn::Pathes p; - for ( TQValueListConstIterator<KURL> it = urls.begin(); it != urls.end() ; ++it ) { - p.append((*it).path()); - } - try { - m_pData->m_Svnclient->mkdir(svn::Targets(p),getDefaultLog()); - } catch (const svn::ClientException&e) { - error(TDEIO::ERR_SLAVE_DEFINED,e.msg()); - return; - } - finished(); -} - -void tdeio_svnProtocol::rename(const KURL&src,const KURL&target,bool force) -{ - kdDebug()<<"tdeio_svn::rename "<< src << " to " << target << endl; - TQString msg; - m_pData->m_CurrentContext->setLogMessage(getDefaultLog()); - try { - m_pData->m_Svnclient->move(makeSvnUrl(src),makeSvnUrl(target),force); - }catch (const svn::ClientException&e) { - error( TDEIO::ERR_SLAVE_DEFINED,e.msg()); - } - kdDebug()<<"tdeio_svn::rename finished" << endl; - finished(); -} - -void tdeio_svnProtocol::copy(const KURL&src,const KURL&dest,int permissions,bool overwrite) -{ - Q_UNUSED(permissions); - Q_UNUSED(overwrite); - kdDebug()<<"tdeio_svn::copy "<< src << " to " << dest << endl; - svn::Revision rev = m_pData->urlToRev(src); - if (rev == svn::Revision::UNDEFINED) { - rev = svn::Revision::HEAD; - } - m_pData->dispProgress=true; - m_pData->m_CurrentContext->setLogMessage(getDefaultLog()); - try { - m_pData->m_Svnclient->copy(makeSvnUrl(src),rev,makeSvnUrl(dest)); - }catch (const svn::ClientException&e) { - error( TDEIO::ERR_SLAVE_DEFINED,e.msg()); - } - m_pData->dispProgress=false; - kdDebug()<<"tdeio_svn::copy finished" << endl; - finished(); -} - -void tdeio_svnProtocol::del(const KURL&src,bool isfile) -{ - Q_UNUSED(isfile); - kdDebug()<<"tdeio_svn::del "<< src << endl; - //m_pData->reInitClient(); - svn::Revision rev = m_pData->urlToRev(src); - if (rev == svn::Revision::UNDEFINED) { - rev = svn::Revision::HEAD; - } - m_pData->m_CurrentContext->setLogMessage(getDefaultLog()); - try { - svn::Targets target(makeSvnUrl(src)); - m_pData->m_Svnclient->remove(target,false); - } catch (const svn::ClientException&e) { - TQString ex = e.msg(); - kdDebug()<<ex<<endl; - error( TDEIO::ERR_SLAVE_DEFINED,ex); - } - kdDebug()<<"tdeio_svn::del finished" << endl; - finished(); -} - -bool tdeio_svnProtocol::getLogMsg(TQString&t) -{ - svn::CommitItemList _items; - return m_pData->m_Listener.contextGetLogMessage(t,_items); -} - -bool tdeio_svnProtocol::checkWc(const KURL&url) -{ - if (url.isEmpty()||!url.isLocalFile()) return false; - svn::Revision peg(svn_opt_revision_unspecified); - svn::Revision rev(svn_opt_revision_unspecified); - svn::InfoEntries e; - try { - e = m_pData->m_Svnclient->info(url.prettyURL(),svn::DepthEmpty,rev,peg); - } catch (const svn::ClientException&e) { - if (SVN_ERR_WC_NOT_DIRECTORY==e.apr_err()) - { - return false; - } - return true; - } - return false; -} - -TQString tdeio_svnProtocol::makeSvnUrl(const KURL&url,bool check_Wc) -{ - TQString res; - TQString proto = svn::Url::transformProtokoll(url.protocol()); - if (proto=="file" && check_Wc) - { - if (checkWc(url)) - { - return url.path(); - } - } - - TQStringList s = TQStringList::split("://",res); - TQString base = url.path(); - TQString host = url.host(); - TQString user = (url.hasUser()?url.user()+(url.hasPass()?":"+url.pass():""):""); - if (host.isEmpty()) { - res=proto+"://"+base; - } else { - res = proto+"://"+(user.isEmpty()?"":user+"@")+host+base; - } - if (base.isEmpty()) { - throw svn::ClientException(TQString("'")+res+TQString("' is not a valid subversion url")); - } - return res; -} - -bool tdeio_svnProtocol::createUDSEntry( const TQString& filename, const TQString& user, long long int size, bool isdir, time_t mtime, TDEIO::UDSEntry& entry) -{ -#if 0 - kdDebug() << "MTime : " << ( long )mtime << endl; - kdDebug() << "UDS filename : " << filename << endl; - kdDebug()<< "UDS Size: " << size << endl; - kdDebug()<< "UDS Dir: " << isdir << endl; -#endif - TDEIO::UDSAtom atom; - atom.m_uds = TDEIO::UDS_NAME; - atom.m_str = filename; - entry.append( atom ); - - atom.m_uds = TDEIO::UDS_FILE_TYPE; - atom.m_long = isdir ? S_IFDIR : S_IFREG; - entry.append( atom ); - - atom.m_uds = TDEIO::UDS_ACCESS; - atom.m_long = isdir?0777:0666; - entry.append(atom); - - - atom.m_uds = TDEIO::UDS_SIZE; - atom.m_long = size; - entry.append( atom ); - - atom.m_uds = TDEIO::UDS_MODIFICATION_TIME; - atom.m_long = mtime; - entry.append( atom ); - - atom.m_uds = TDEIO::UDS_USER; - atom.m_str = user; - entry.append( atom ); - - return true; -} - -void tdeio_svnProtocol::special(const TQByteArray& data) -{ - kdDebug()<<"tdeio_svnProtocol::special"<<endl; - TQDataStream stream(data,IO_ReadOnly); - int tmp; - stream >> tmp; - kdDebug() << "tdeio_svnProtocol::special " << tmp << endl; - switch (tmp) { - case SVN_CHECKOUT: - { - KURL repository, wc; - int revnumber; - TQString revkind; - stream >> repository; - stream >> wc; - stream >> revnumber; - stream >> revkind; - kdDebug(0) << "tdeio_svnProtocol CHECKOUT from " << repository.url() << " to " << wc.url() << " at " << revnumber << " or " << revkind << endl; - checkout( repository, wc, revnumber, revkind ); - break; - } - case SVN_UPDATE: - { - KURL wc; - int revnumber; - TQString revkind; - stream >> wc; - stream >> revnumber; - stream >> revkind; - kdDebug(0) << "tdeio_svnProtocol UPDATE " << wc.url() << " at " << revnumber << " or " << revkind << endl; - update(wc, revnumber, revkind ); - break; - } - case SVN_COMMIT: - { - KURL::List wclist; - while ( !stream.atEnd() ) { - KURL tmp; - stream >> tmp; - wclist << tmp; - } - kdDebug(0) << "tdeio_svnProtocol COMMIT" << endl; - commit( wclist ); - break; - } - case SVN_LOG: - { - kdDebug(0) << "tdeio_svnProtocol LOG" << endl; - int revstart, revend; - TQString revkindstart, revkindend; - KURL::List targets; - stream >> revstart; - stream >> revkindstart; - stream >> revend; - stream >> revkindend; - while ( !stream.atEnd() ) { - KURL tmp; - stream >> tmp; - targets << tmp; - } - svnlog( revstart, revkindstart, revend, revkindend, targets ); - break; - } - case SVN_IMPORT: - { - KURL wc,repos; - stream >> repos; - stream >> wc; - kdDebug(0) << "tdeio_ksvnProtocol IMPORT" << endl; - import(repos,wc); - break; - } - case SVN_ADD: - { - KURL wc; - kdDebug(0) << "tdeio_ksvnProtocol ADD" << endl; - stream >> wc; - add(wc); - break; - } - case SVN_DEL: - { - KURL::List wclist; - while ( !stream.atEnd() ) { - KURL tmp; - stream >> tmp; - wclist << tmp; - } - wc_delete(wclist); - break; - } - case SVN_REVERT: - { - KURL::List wclist; - while ( !stream.atEnd() ) { - KURL tmp; - stream >> tmp; - wclist << tmp; - } - kdDebug(7128) << "tdeio_svnProtocol REVERT" << endl; - revert(wclist); - break; - } - case SVN_STATUS: - { - KURL wc; - bool checkRepos=false; - bool fullRecurse=false; - stream >> wc; - stream >> checkRepos; - stream >> fullRecurse; - kdDebug(0) << "tdeio_svnProtocol STATUS" << endl; - status(wc,checkRepos,fullRecurse); - break; - } - case SVN_MKDIR: - { - KURL::List list; - stream >> list; - kdDebug(0) << "tdeio_svnProtocol MKDIR" << endl; - mkdir(list,0); - break; - } - case SVN_RESOLVE: - { - KURL url; - bool recurse; - stream >> url; - stream >> recurse; - kdDebug(7128) << "tdeio_svnProtocol RESOLVE" << endl; - wc_resolve(url,recurse); - break; - } - case SVN_SWITCH: - { - KURL wc,url; - bool recurse; - int revnumber; - TQString revkind; - stream >> wc; - stream >> url; - stream >> recurse; - stream >> revnumber; - stream >> revkind; - kdDebug(7128) << "tdeio_svnProtocol SWITCH" << endl; - wc_switch(wc,url,recurse,revnumber,revkind); - break; - } - case SVN_DIFF: - { - KURL url1,url2; - int rev1, rev2; - bool recurse; - TQString revkind1, revkind2; - stream >> url1; - stream >> url2; - stream >> rev1; - stream >> revkind1; - stream >> rev2; - stream >> revkind2; - stream >> recurse; - diff(url1,url2,rev1,revkind1,rev2,revkind2,recurse); - break; - } - default: - {kdDebug()<<"Unknown special" << endl;} - } - finished(); -} - -void tdeio_svnProtocol::update(const KURL&url,int revnumber,const TQString&revkind) -{ - svn::Revision where(revnumber,revkind); - /* update is always local - so make a path instead URI */ - svn::Path p(url.path()); - try { - svn::Targets pathes(p.path()); - // always update externals, too. (third last parameter) - // no unversioned items allowed (second last parameter) - // sticky depth (last parameter) - m_pData->m_Svnclient->update(pathes, where,svn::DepthInfinity,false,false,true); - } catch (const svn::ClientException&e) { - error(TDEIO::ERR_SLAVE_DEFINED,e.msg()); - } -} - -void tdeio_svnProtocol::status(const KURL&wc,bool cR,bool rec) -{ - svn::Revision where = svn::Revision::UNDEFINED; - svn::StatusEntries dlist; - try { - // rec all up noign - dlist = m_pData->m_Svnclient->status(wc.path(),rec?svn::DepthInfinity:svn::DepthEmpty,false,cR,false,where); - } catch (const svn::ClientException&e) { - error(TDEIO::ERR_SLAVE_DEFINED,e.msg()); - return; - } - kdDebug()<<"Status got " << dlist.count() << " entries." << endl; - for (unsigned j=0;j<dlist.count();++j) { - if (!dlist[j]) { - continue; - } - //TQDataStream stream(params, IO_WriteOnly); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+"path",dlist[j]->path()); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+"text",TQString::number(dlist[j]->textStatus())); - setMetaData(TQString::number(m_pData->m_Listener.counter() ).rightJustify( 10,'0' )+ "prop", - TQString::number(dlist[j]->propStatus())); - setMetaData(TQString::number(m_pData->m_Listener.counter() ).rightJustify( 10,'0' )+ "reptxt", - TQString::number(dlist[j]->reposTextStatus())); - setMetaData(TQString::number(m_pData->m_Listener.counter() ).rightJustify( 10,'0' )+ "repprop", - TQString::number(dlist[j]->reposPropStatus())); - setMetaData(TQString::number(m_pData->m_Listener.counter() ).rightJustify( 10,'0' )+ "rev", - TQString::number(dlist[j]->entry().cmtRev())); - m_pData->m_Listener.incCounter(); - } -} - -void tdeio_svnProtocol::commit(const KURL::List&url) -{ - /// @todo replace with direct call to tdesvn? - TQByteArray reply; - TQByteArray params; - TQCString replyType; - TQString msg; - - if (!dcopClient()->call("kded","tdesvnd","get_logmsg()",params,replyType,reply)) { - msg = "Communication with dcop failed"; - kdWarning()<<msg<<endl; - return; - } - if (replyType!=TQSTRINGLIST_OBJECT_NAME_STRING) { - msg = "Wrong reply type"; - kdWarning()<<msg<<endl; - return; - } - TQDataStream stream2(reply,IO_ReadOnly); - TQStringList lt; - stream2>>lt; - if (lt.count()!=1) { - msg = "Wrong or missing log (may cancel pressed)."; - kdDebug()<< msg << endl; - return; - } - msg = lt[0]; - TQValueList<svn::Path> targets; - for (unsigned j=0; j<url.count();++j) { - targets.push_back(svn::Path(url[j].path())); - } - svn::Revision nnum=svn::Revision::UNDEFINED; - try { - nnum = m_pData->m_Svnclient->commit(svn::Targets(targets),msg,svn::DepthInfinity,false); - } catch (const svn::ClientException&e) { - error(TDEIO::ERR_SLAVE_DEFINED,e.msg()); - } - for (unsigned j=0;j<url.count();++j) { - TQString userstring; - if (nnum!=svn::Revision::UNDEFINED) { - userstring = i18n( "Committed revision %1." ).arg(nnum.toString()); - } else { - userstring = i18n ( "Nothing to commit." ); - } - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "path", url[j].path() ); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "action", "0" ); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "kind", "0" ); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "mime_t", "" ); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "content", "0" ); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "prop", "0" ); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "rev" , TQString::number(nnum) ); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "string", userstring ); - m_pData->m_Listener.incCounter(); - } -} - -void tdeio_svnProtocol::checkout(const KURL&src,const KURL&target,const int rev, const TQString&revstring) -{ - svn::Revision where(rev,revstring); - svn::Revision peg = svn::Revision::UNDEFINED; - svn::Path _target(target.path()); - try { - KURL _src = makeSvnUrl(src); - m_pData->m_Svnclient->checkout(_src.url(),_target,where,peg,svn::DepthInfinity,false,false); - } catch (const svn::ClientException&e) { - error(TDEIO::ERR_SLAVE_DEFINED,e.msg()); - } -} - -void tdeio_svnProtocol::svnlog(int revstart,const TQString&revstringstart,int revend, const TQString&revstringend, const KURL::List&urls) -{ - svn::Revision start(revstart,revstringstart); - svn::Revision end(revend,revstringend); - svn::LogEntriesPtr logs; - - for (unsigned j = 0; j<urls.count();++j) { - logs = 0; - try { - logs = m_pData->m_Svnclient->log(makeSvnUrl(urls[j]),start,end,svn::Revision::UNDEFINED,true,true,0); - } catch (const svn::ClientException&e) { - error(TDEIO::ERR_SLAVE_DEFINED,e.msg()); - break; - } - if (!logs) { - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify(10,'0')+"path",urls[j].path()); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify(10,'0')+"string", - i18n("Empty logs")); - m_pData->m_Listener.incCounter(); - continue; - } - for (unsigned int i = 0; i < logs->count();++i) { - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "path",urls[j].path()); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "rev", - TQString::number( (*logs)[i].revision)); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+"author", - (*logs)[i].author); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+"logmessage", - (*logs)[i].message); - m_pData->m_Listener.incCounter(); - for (unsigned z = 0; z<(*logs)[i].changedPaths.count();++z) { - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "rev", - TQString::number( (*logs)[i].revision)); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "path",urls[j].path()); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "loggedpath", - (*logs)[i].changedPaths[z].path); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "loggedaction", - TQChar((*logs)[i].changedPaths[z].action)); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "loggedcopyfrompath", - (*logs)[i].changedPaths[z].copyFromPath); - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "loggedcopyfromrevision", - TQString::number((*logs)[i].changedPaths[z].copyFromRevision)); - m_pData->m_Listener.incCounter(); - } - } - } -} - -void tdeio_svnProtocol::revert(const KURL::List&l) -{ - TQValueList<svn::Path> list; - for (unsigned j=0; j<l.count();++j) { - list.append(svn::Path(l[j].path())); - } - svn::Targets target(list); - try { - m_pData->m_Svnclient->revert(target,svn::DepthEmpty); - } catch (const svn::ClientException&e) { - error(TDEIO::ERR_SLAVE_DEFINED,e.msg()); - } -} - -void tdeio_svnProtocol::wc_switch(const KURL&wc,const KURL&target,bool rec,int rev,const TQString&revstring) -{ - svn::Revision where(rev,revstring); - svn::Path wc_path(wc.path()); - try { - m_pData->m_Svnclient->doSwitch(wc_path,makeSvnUrl(target.url()),where,rec?svn::DepthInfinity:svn::DepthFiles); - } catch (const svn::ClientException&e) { - error(TDEIO::ERR_SLAVE_DEFINED,e.msg()); - } -} - -void tdeio_svnProtocol::diff(const KURL&uri1,const KURL&uri2,int rnum1,const TQString&rstring1,int rnum2, const TQString&rstring2,bool rec) -{ - TQByteArray ex; - /// @todo read settings for diff (ignore contentype) - try { - svn::Revision r1(rnum1,rstring1); - svn::Revision r2(rnum2,rstring2); - TQString u1 = makeSvnUrl(uri1,true); - TQString u2 = makeSvnUrl(uri2,true); - KTempDir tdir; - kdDebug() << "tdeio_ksvn::diff : " << u1 << " at revision " << r1.toString() << " with " - << u2 << " at revision " << r2.toString() - << endl ; - - tdir.setAutoDelete(true); - ex = m_pData->m_Svnclient->diff(svn::Path(tdir.name()), - u1,u2,svn::Path(),r1, r2,rec?svn::DepthInfinity:svn::DepthEmpty,false,false,false); - } catch (const svn::ClientException&e) { - error(TDEIO::ERR_SLAVE_DEFINED,e.msg()); - return; - } - TQString out = TQString::FROMUTF8(ex); - TQTextIStream stream(&out); - while (!stream.atEnd()) { - setMetaData(TQString::number(m_pData->m_Listener.counter()).rightJustify( 10,'0' )+ "diffresult",stream.readLine()); - m_pData->m_Listener.incCounter(); - } -} - -void tdeio_svnProtocol::import(const KURL& repos, const KURL& wc) -{ - try { - TQString target = makeSvnUrl(repos); - TQString path = wc.path(); - m_pData->m_Svnclient->import(svn::Path(path),target,TQString(),svn::DepthInfinity,false,false); - } catch (const svn::ClientException&e) { - error(TDEIO::ERR_SLAVE_DEFINED,e.msg()); - return; - } - finished(); -} - -void tdeio_svnProtocol::add(const KURL& wc) -{ - TQString path = wc.path(); - try { - /* rec */ - m_pData->m_Svnclient->add(svn::Path(path),svn::DepthInfinity); - } catch (const svn::ClientException&e) { - error(TDEIO::ERR_SLAVE_DEFINED,e.msg()); - return; - } - finished(); -} - -void tdeio_svnProtocol::wc_delete(const KURL::List&l) -{ - svn::Pathes p; - for ( TQValueListConstIterator<KURL> it = l.begin(); it != l.end() ; ++it ) { - p.append((*it).path()); - } - try { - m_pData->m_Svnclient->remove(svn::Targets(p),false); - } catch (const svn::ClientException&e) { - error(TDEIO::ERR_SLAVE_DEFINED,e.msg()); - return; - } - finished(); -} - -void tdeio_svnProtocol::wc_resolve(const KURL&url,bool recurse) -{ - try { - svn::Depth depth=recurse?svn::DepthInfinity:svn::DepthEmpty; - m_pData->m_Svnclient->resolve(url.path(),depth); - } catch (const svn::ClientException&e) { - error(TDEIO::ERR_SLAVE_DEFINED,e.msg()); - return; - } - finished(); -} - -void tdeio_svnProtocol::streamWritten(const TDEIO::filesize_t current) -{ - processedSize(current); -} - -void tdeio_svnProtocol::streamSendMime(KMimeMagicResult* mt) -{ - if (mt) { - mimeType(mt->mimeType()); - } -} - -void tdeio_svnProtocol::streamPushData(TQByteArray array) -{ - data(array); -} - -void tdeio_svnProtocol::contextProgress(long long int current, long long int) -{ - if (m_pData->dispProgress) { - processedSize(current); - } -} - -void tdeio_svnProtocol::streamTotalSizeNull() -{ - totalSize(0); -} - - -/*! - \fn tdeio_svnProtocol::getDefaultLog() - */ -TQString tdeio_svnProtocol::getDefaultLog() -{ - TQString res = TQString(); - Kdesvnsettings::self()->readConfig(); - if (Kdesvnsettings::tdeio_use_standard_logmsg()) { - res = Kdesvnsettings::tdeio_standard_logmsg(); - } - return res; -} - -} // namespace TDEIO |