/***************************************************************************
* 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 "tdeiolistener.h"
#include "svnqttypes.h"
#include "dirent.h"
#include "url.h"
#include "status.h"
#include "targets.h"
#include "info_entry.h"
#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 <tdeapplication.h>
#include <kdebug.h>
#include <tdemacros.h>
#include <tdemessagebox.h>
#include <kinstance.h>
#include <tdeglobal.h>
#include <kstandarddirs.h>
#include <tdelocale.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 tdeio 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") {
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