diff options
Diffstat (limited to 'src/tdeiosvn/tdeiosvn.cpp')
| -rw-r--r-- | src/tdeiosvn/tdeiosvn.cpp | 954 |
1 files changed, 954 insertions, 0 deletions
diff --git a/src/tdeiosvn/tdeiosvn.cpp b/src/tdeiosvn/tdeiosvn.cpp new file mode 100644 index 0000000..fe17ab1 --- /dev/null +++ b/src/tdeiosvn/tdeiosvn.cpp @@ -0,0 +1,954 @@ +/*************************************************************************** + * 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 "tdeiosvn.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 |