You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
tdesdk/cervisia/cvsservice/cvsjob.cpp

237 lines
5.0 KiB

/*
* Copyright (c) 2002-2003 Christian Loose <christian.loose@hamburg.de>
*
* This program 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 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
* Library General Public License for more details.
*
* You should have received a copy of the GNU Library General Public License
* along with this program; see the file COPYING. If not, write to
* the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
* Boston, MA 02110-1301, USA.
*
*/
#include "cvsjob.h"
#include <tqfile.h>
#include <kdebug.h>
#include <kprocess.h>
#include "sshagent.h"
struct CvsJob::Private
{
Private() : isRunning(false)
{
childproc = new TDEProcess;
childproc->setUseShell(true, "/bin/sh");
}
~Private() { delete childproc; }
TDEProcess* childproc;
TQString server;
TQString rsh;
TQString directory;
bool isRunning;
TQStringList outputLines;
};
CvsJob::CvsJob(unsigned jobNum)
: TQObject()
, DCOPObject()
, d(new Private)
{
TQString objId("CvsJob" + TQString::number(jobNum));
setObjId(objId.local8Bit());
}
CvsJob::CvsJob(const TQString& objId)
: TQObject()
, DCOPObject()
, d(new Private)
{
setObjId(objId.local8Bit());
}
CvsJob::~CvsJob()
{
delete d;
}
void CvsJob::clearCvsCommand()
{
d->childproc->clearArguments();
}
void CvsJob::setRSH(const TQString& rsh)
{
d->rsh = rsh;
}
void CvsJob::setServer(const TQString& server)
{
d->server = server;
}
void CvsJob::setDirectory(const TQString& directory)
{
d->directory = directory;
}
bool CvsJob::isRunning() const
{
return d->isRunning;
}
CvsJob& CvsJob::operator<<(const TQString& arg)
{
*d->childproc << arg;
return *this;
}
CvsJob& CvsJob::operator<<(const char* arg)
{
*d->childproc << arg;
return *this;
}
CvsJob& CvsJob::operator<<(const TQCString& arg)
{
*d->childproc << arg;
return *this;
}
CvsJob& CvsJob::operator<<(const TQStringList& args)
{
*d->childproc << args;
return *this;
}
TQString CvsJob::cvsCommand() const
{
TQString command;
const TQValueList<TQCString>& args(d->childproc->args());
for (TQValueList<TQCString>::const_iterator it = args.begin(), itEnd = args.end();
it != itEnd; ++it)
{
if (!command.isEmpty())
command += ' ';
command += TQFile::decodeName(*it);
}
return command;
}
TQStringList CvsJob::output() const
{
return d->outputLines;
}
bool CvsJob::execute()
{
// setup job environment to use the ssh-agent (if it is running)
SshAgent ssh;
if( !ssh.pid().isEmpty() )
{
// kdDebug(8051) << "PID = " << ssh.pid() << endl;
// kdDebug(8051) << "SOCK = " << ssh.authSock() << endl;
d->childproc->setEnvironment("SSH_AGENT_PID", ssh.pid());
d->childproc->setEnvironment("SSH_AUTH_SOCK", ssh.authSock());
}
d->childproc->setEnvironment("SSH_ASKPASS", "cvsaskpass");
if( !d->rsh.isEmpty() )
d->childproc->setEnvironment("CVS_RSH", d->rsh);
if( !d->server.isEmpty() )
d->childproc->setEnvironment("CVS_SERVER", d->server);
if( !d->directory.isEmpty() )
d->childproc->setWorkingDirectory(d->directory);
connect(d->childproc, TQT_SIGNAL(processExited(TDEProcess*)),
TQT_SLOT(slotProcessExited()));
connect(d->childproc, TQT_SIGNAL(receivedStdout(TDEProcess*, char*, int)),
TQT_SLOT(slotReceivedStdout(TDEProcess*, char*, int)));
connect(d->childproc, TQT_SIGNAL(receivedStderr(TDEProcess*, char*, int)),
TQT_SLOT(slotReceivedStderr(TDEProcess*, char*, int)) );
kdDebug(8051) << "Execute cvs command: " << cvsCommand() << endl;
d->isRunning = true;
return d->childproc->start(TDEProcess::NotifyOnExit, TDEProcess::AllOutput);
}
void CvsJob::cancel()
{
d->childproc->kill();
}
void CvsJob::slotProcessExited()
{
// disconnect all connections to childproc's signals
d->childproc->disconnect();
d->childproc->clearArguments();
d->isRunning = false;
emit jobExited(d->childproc->normalExit(), d->childproc->exitStatus());
}
void CvsJob::slotReceivedStdout(TDEProcess* proc, char* buffer, int buflen)
{
Q_UNUSED(proc);
TQString output = TQString::fromLocal8Bit(buffer, buflen);
// accumulate output
d->outputLines += TQStringList::split("\n", output);
emit receivedStdout(output);
}
void CvsJob::slotReceivedStderr(TDEProcess* proc, char* buffer, int buflen)
{
Q_UNUSED(proc);
TQString output = TQString::fromLocal8Bit(buffer, buflen);
// accumulate output
d->outputLines += TQStringList::split("\n", output);
emit receivedStderr(output);
}
#include "cvsjob.moc"