|
|
/***************************************************************************
|
|
|
fish.cpp - a FISH tdeioslave
|
|
|
-------------------
|
|
|
begin : Thu Oct 4 17:09:14 CEST 2001
|
|
|
copyright : (C) 2001-2003 by J<>rg Walter
|
|
|
email : jwalt-kde@garni.ch
|
|
|
***************************************************************************/
|
|
|
|
|
|
/***************************************************************************
|
|
|
* *
|
|
|
* 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, version 2 of the License *
|
|
|
* *
|
|
|
***************************************************************************/
|
|
|
|
|
|
/*
|
|
|
This code contains fragments and ideas from the ftp tdeioslave
|
|
|
done by David Faure <faure@kde.org>.
|
|
|
|
|
|
Structure is a bit complicated, since I made the mistake to use
|
|
|
TDEProcess... now there is a lightweight homebrew async IO system
|
|
|
inside, but if signals/slots become available for ioslaves, switching
|
|
|
back to TDEProcess should be easy.
|
|
|
*/
|
|
|
|
|
|
#include "config.h"
|
|
|
|
|
|
#include <tqcstring.h>
|
|
|
#include <tqfile.h>
|
|
|
#include <tqsocket.h>
|
|
|
#include <tqdatetime.h>
|
|
|
#include <tqbitarray.h>
|
|
|
#include <tqregexp.h>
|
|
|
|
|
|
#include <stdlib.h>
|
|
|
#ifdef HAVE_PTY_H
|
|
|
#include <pty.h>
|
|
|
#endif
|
|
|
#ifdef HAVE_TERMIOS_H
|
|
|
#include <termios.h>
|
|
|
#endif
|
|
|
#include <math.h>
|
|
|
#include <unistd.h>
|
|
|
#include <signal.h>
|
|
|
#include <sys/wait.h>
|
|
|
#include <sys/socket.h>
|
|
|
#include <netinet/in.h>
|
|
|
#include <netdb.h>
|
|
|
#include <sys/types.h>
|
|
|
#ifdef HAVE_STROPTS
|
|
|
#include <stropts.h>
|
|
|
#endif
|
|
|
#ifdef HAVE_SYS_IOCTL_H
|
|
|
#include <sys/ioctl.h>
|
|
|
#endif
|
|
|
#ifdef HAVE_LIBUTIL_H
|
|
|
#include <libutil.h>
|
|
|
#endif
|
|
|
#ifdef HAVE_UTIL_H
|
|
|
#include <util.h>
|
|
|
#endif
|
|
|
|
|
|
#include <kdebug.h>
|
|
|
#include <tdemessagebox.h>
|
|
|
#include <kinstance.h>
|
|
|
#include <tdeglobal.h>
|
|
|
#include <kstandarddirs.h>
|
|
|
#include <tdelocale.h>
|
|
|
#include <kremoteencoding.h>
|
|
|
#include <kurl.h>
|
|
|
#include <ksock.h>
|
|
|
#include <stdarg.h>
|
|
|
#include <time.h>
|
|
|
#include <sys/stat.h>
|
|
|
#include <kmimetype.h>
|
|
|
#include <kmimemagic.h>
|
|
|
#include <fcntl.h>
|
|
|
#include <sys/socket.h>
|
|
|
#include <errno.h>
|
|
|
#include <sys/resource.h>
|
|
|
|
|
|
#include "fish.h"
|
|
|
#include "fishcode.h"
|
|
|
|
|
|
#ifndef NDEBUG
|
|
|
#define myDebug(x) kdDebug(7127) << __LINE__ << ": " x
|
|
|
#define connected() do{myDebug( << "_______ emitting connected()" << endl); connected();}while(0)
|
|
|
#define dataReq() do{myDebug( << "_______ emitting dataReq()" << endl); dataReq();}while(0)
|
|
|
#define needSubURLData() do{myDebug( << "_______ emitting needSubURLData()" << endl); needSubURLData();}while(0)
|
|
|
#define slaveStatus(x,y) do{myDebug( << "_______ emitting slaveStatus(" << x << ", " << y << ")" << endl); slaveStatus(x,y);}while(0)
|
|
|
#define statEntry(x) do{myDebug( << "_______ emitting statEntry("<<x.size()<<")" << endl); statEntry(x);}while(0)
|
|
|
#define listEntries(x) do{myDebug( << "_______ emitting listEntries(...)" << endl); listEntries(x);}while(0)
|
|
|
#define canResume(x) do{myDebug( << "_______ emitting canResume("<<(int)x<<")" << endl); canResume(x);}while(0)
|
|
|
#define totalSize(x) do{myDebug( << "_______ emitting totalSize("<<(int)x<<")" << endl); totalSize(x);}while(0)
|
|
|
#define processedSize(x) do{myDebug( << "_______ emitting processedSize("<<x<<")" << endl); processedSize(x);}while(0)
|
|
|
#define speed(x) do{myDebug( << "_______ emitting speed("<<(int)x<<")" << endl); speed(x);}while(0)
|
|
|
#define redirection(x) do{myDebug( << "_______ emitting redirection("<<x<<")" << endl); redirection(x);}while(0)
|
|
|
#define errorPage() do{myDebug( << "_______ emitting errorPage()" << endl); errorPage();}while(0)
|
|
|
#define sendmimeType(x) do{myDebug( << "_______ emitting mimeType("<<x<<")" << endl); mimeType(x);}while(0)
|
|
|
#define warning(x) do{myDebug( << "_______ emitting warning("<<x<<")" << endl); warning(x);}while(0)
|
|
|
#define infoMessage(x) do{myDebug( << "_______ emitting infoMessage("<<x<<")" << endl); infoMessage(x);}while(0)
|
|
|
#else
|
|
|
#define myDebug(x)
|
|
|
#define sendmimeType(x) mimeType(x)
|
|
|
#endif
|
|
|
|
|
|
static char *sshPath = NULL;
|
|
|
static char *suPath = NULL;
|
|
|
// disabled: currently not needed. Didn't work reliably.
|
|
|
// static int isOpenSSH = 0;
|
|
|
|
|
|
static int isNXFish = 0;
|
|
|
|
|
|
#define E(x) ((const char*)remoteEncoding()->encode(x).data())
|
|
|
|
|
|
using namespace TDEIO;
|
|
|
extern "C" {
|
|
|
|
|
|
static void ripper(int)
|
|
|
{
|
|
|
while (waitpid(-1,0,WNOHANG) > 0) {
|
|
|
// do nothing, go on
|
|
|
}
|
|
|
}
|
|
|
|
|
|
int KDE_EXPORT kdemain( int argc, char **argv )
|
|
|
{
|
|
|
TDELocale::setMainCatalogue("tdeio_fish");
|
|
|
TDEInstance instance("fish");
|
|
|
|
|
|
myDebug( << "*** Starting fish " << endl);
|
|
|
if (argc != 4) {
|
|
|
myDebug( << "Usage: fish protocol domain-socket1 domain-socket2" << endl);
|
|
|
exit(-1);
|
|
|
}
|
|
|
|
|
|
setenv("TZ", "UTC", true);
|
|
|
|
|
|
struct sigaction act;
|
|
|
memset(&act,0,sizeof(act));
|
|
|
act.sa_handler = ripper;
|
|
|
act.sa_flags = 0
|
|
|
#ifdef SA_NOCLDSTOP
|
|
|
| SA_NOCLDSTOP
|
|
|
#endif
|
|
|
#ifdef SA_RESTART
|
|
|
| SA_RESTART
|
|
|
#endif
|
|
|
;
|
|
|
sigaction(SIGCHLD,&act,NULL);
|
|
|
|
|
|
if (qstrcmp(argv[1],"nxfish")==0) {
|
|
|
// Set NXFish - Mode
|
|
|
isNXFish=1;
|
|
|
}
|
|
|
|
|
|
fishProtocol slave(argv[2], argv[3]);
|
|
|
slave.dispatchLoop();
|
|
|
|
|
|
myDebug( << "*** fish Done" << endl);
|
|
|
return 0;
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
const struct fishProtocol::fish_info fishProtocol::fishInfo[] = {
|
|
|
{ ("FISH"), 0,
|
|
|
("echo; /bin/sh -c start_fish_server > /dev/null 2>/dev/null; perl .fishsrv.pl " CHECKSUM " 2>/dev/null; perl -e '$|=1; print \"### 100 transfer fish server\\n\"; while(<STDIN>) { last if /^__END__/; $code.=$_; } exit(eval($code));' 2>/dev/null;"),
|
|
|
1 },
|
|
|
{ ("VER 0.0.3 copy append lscount lslinks lsmime exec stat"), 0,
|
|
|
("echo 'VER 0.0.3 copy append lscount lslinks lsmime exec stat'"),
|
|
|
1 },
|
|
|
{ ("PWD"), 0,
|
|
|
("pwd"),
|
|
|
1 },
|
|
|
{ ("LIST"), 1,
|
|
|
("echo `ls -Lla %1 2> /dev/null | grep '^[-dsplcb]' | wc -l`; ls -Lla %1 2>/dev/null | grep '^[-dspl]' | ( while read -r p x u g s m d y n; do file -b -i $n 2>/dev/null | sed -e '\\,^[^/]*$,d;s/^/M/;s,/.*[ \t],/,'; FILE=%1; if [ -e %1\"/$n\" ]; then FILE=%1\"/$n\"; fi; if [ -L \"$FILE\" ]; then echo \":$n\"; ls -lad \"$FILE\" | sed -e 's/.* -> /L/'; else echo \":$n\" | sed -e 's/ -> /\\\nL/'; fi; echo \"P$p $u.$g\nS$s\nd$m $d $y\n\"; done; );"
|
|
|
"ls -Lla %1 2>/dev/null | grep '^[cb]' | ( while read -r p x u g a i m d y n; do echo \"P$p $u.$g\nE$a$i\nd$m $d $y\n:$n\n\"; done; )"),
|
|
|
0 },
|
|
|
{ ("STAT"), 1,
|
|
|
("echo `ls -dLla %1 2> /dev/null | grep '^[-dsplcb]' | wc -l`; ls -dLla %1 2>/dev/null | grep '^[-dspl]' | ( while read -r p x u g s m d y n; do file -b -i $n 2>/dev/null | sed -e '\\,^[^/]*$,d;s/^/M/;s,/.*[ \t],/,'; FILE=%1; if [ -e %1\"/$n\" ]; then FILE=%1\"/$n\"; fi; if [ -L \"$FILE\" ]; then echo \":$n\"; ls -lad \"$FILE\" | sed -e 's/.* -> /L/'; else echo \":$n\" | sed -e 's/ -> /\\\nL/'; fi; echo \"P$p $u.$g\nS$s\nd$m $d $y\n\"; done; );"
|
|
|
"ls -dLla %1 2>/dev/null | grep '^[cb]' | ( while read -r p x u g a i m d y n; do echo \"P$p $u.$g\nE$a$i\nd$m $d $y\n:$n\n\"; done; )"),
|
|
|
0 },
|
|
|
{ ("RETR"), 1,
|
|
|
("ls -l %1 2>&1 | ( read -r a b c d x e; echo $x ) 2>&1; echo '### 001'; cat %1"),
|
|
|
1 },
|
|
|
{ ("STOR"), 2,
|
|
|
("> %2; echo '### 001'; ( [ \"`expr %1 / 4096`\" -gt 0 ] && dd bs=4096 count=`expr %1 / 4096` 2>/dev/null;"
|
|
|
"[ \"`expr %1 % 4096`\" -gt 0 ] && dd bs=`expr %1 % 4096` count=1 2>/dev/null; ) | ( cat > %2 || echo Error $?; cat > /dev/null )"),
|
|
|
0 },
|
|
|
{ ("CWD"), 1,
|
|
|
("cd %1"),
|
|
|
0 },
|
|
|
{ ("CHMOD"), 2,
|
|
|
("chmod %1 %2"),
|
|
|
0 },
|
|
|
{ ("DELE"), 1,
|
|
|
("rm -f %1"),
|
|
|
0 },
|
|
|
{ ("MKD"), 1,
|
|
|
("mkdir %1"),
|
|
|
0 },
|
|
|
{ ("RMD"), 1,
|
|
|
("rmdir %1"),
|
|
|
0 },
|
|
|
{ ("RENAME"), 2,
|
|
|
("mv -f %1 %2"),
|
|
|
0 },
|
|
|
{ ("LINK"), 2,
|
|
|
("ln -f %1 %2"),
|
|
|
0 },
|
|
|
{ ("SYMLINK"), 2,
|
|
|
("ln -sf %1 %2"),
|
|
|
0 },
|
|
|
{ ("CHOWN"), 2,
|
|
|
("chown %1 %2"),
|
|
|
0 },
|
|
|
{ ("CHGRP"), 2,
|
|
|
("chgrp %1 %2"),
|
|
|
0 },
|
|
|
{ ("READ"), 3,
|
|
|
("echo '### 100';cat %3 /dev/zero | ( [ \"`expr %1 / 4096`\" -gt 0 ] && dd bs=4096 count=`expr %1 / 4096` >/dev/null;"
|
|
|
"[ \"`expr %1 % 4096`\" -gt 0 ] && dd bs=`expr %1 % 4096` count=1 >/dev/null;"
|
|
|
"dd bs=%2 count=1; ) 2>/dev/null;"),
|
|
|
0 },
|
|
|
// Yes, this is "ibs=1", since dd "count" is input blocks.
|
|
|
// On network connections, read() may not fill the buffer
|
|
|
// completely (no more data immediately available), but dd
|
|
|
// does ignore that fact by design. Sorry, writes are slow.
|
|
|
// OTOH, WRITE is not used by the current ioslave methods,
|
|
|
// we use APPEND.
|
|
|
{ ("WRITE"), 3,
|
|
|
(">> %3; echo '### 001'; ( [ %2 -gt 0 ] && dd ibs=1 obs=%2 count=%2 2>/dev/null ) | "
|
|
|
"( dd ibs=32768 obs=%1 seek=1 of=%3 2>/dev/null || echo Error $?; cat >/dev/null; )"),
|
|
|
0 },
|
|
|
{ ("COPY"), 2,
|
|
|
("if [ -L %1 ]; then if cp -pdf %1 %2 2>/dev/null; then :; else LINK=\"`readlink %1`\"; ln -sf $LINK %2; fi; else cp -pf %1 %2; fi"),
|
|
|
0 },
|
|
|
{ ("APPEND"), 2,
|
|
|
(">> %2; echo '### 001'; ( [ %1 -gt 0 ] && dd ibs=1 obs=%1 count=%1 2> /dev/null; ) | ( cat >> %2 || echo Error $?; cat >/dev/null; )"),
|
|
|
0 },
|
|
|
{ ("EXEC"), 2,
|
|
|
("UMASK=`umask`; umask 077; touch %2; umask $UMASK; eval %1 < /dev/null > %2 2>&1; echo \"###RESULT: $?\" >> %2"),
|
|
|
0 }
|
|
|
};
|
|
|
|
|
|
fishProtocol::fishProtocol(const TQCString &pool_socket, const TQCString &app_socket)
|
|
|
: SlaveBase("fish", pool_socket, app_socket), mimeBuffer(1024),
|
|
|
mimeTypeSent(false)
|
|
|
{
|
|
|
myDebug( << "fishProtocol::fishProtocol()" << endl);
|
|
|
if (sshPath == NULL) {
|
|
|
// disabled: currently not needed. Didn't work reliably.
|
|
|
// isOpenSSH = !system("ssh -V 2>&1 | grep OpenSSH > /dev/null");
|
|
|
if (isNXFish)
|
|
|
sshPath = strdup(TQFile::encodeName(TDEStandardDirs::findExe("nxfish")));
|
|
|
else
|
|
|
sshPath = strdup(TQFile::encodeName(TDEStandardDirs::findExe("ssh")));
|
|
|
}
|
|
|
if (suPath == NULL) {
|
|
|
suPath = strdup(TQFile::encodeName(TDEStandardDirs::findExe("su")));
|
|
|
}
|
|
|
childPid = 0;
|
|
|
connectionPort = 0;
|
|
|
isLoggedIn = false;
|
|
|
writeReady = true;
|
|
|
isRunning = false;
|
|
|
firstLogin = true;
|
|
|
errorCount = 0;
|
|
|
rawRead = 0;
|
|
|
rawWrite = -1;
|
|
|
recvLen = -1;
|
|
|
sendLen = -1;
|
|
|
setMultipleAuthCaching( true );
|
|
|
connectionAuth.keepPassword = true;
|
|
|
connectionAuth.url.setProtocol("fish");
|
|
|
outBufPos = -1;
|
|
|
outBuf = NULL;
|
|
|
outBufLen = 0;
|
|
|
typeAtom.m_uds = UDS_FILE_TYPE;
|
|
|
typeAtom.m_long = 0;
|
|
|
mimeAtom.m_uds = UDS_MIME_TYPE;
|
|
|
mimeAtom.m_long = 0;
|
|
|
mimeAtom.m_str = TQString::null;
|
|
|
|
|
|
hasAppend = false;
|
|
|
|
|
|
isStat = false; // FIXME: just a workaround for konq deficiencies
|
|
|
redirectUser = ""; // FIXME: just a workaround for konq deficiencies
|
|
|
redirectPass = ""; // FIXME: just a workaround for konq deficiencies
|
|
|
fishCodeLen = strlen(fishCode);
|
|
|
}
|
|
|
/* ---------------------------------------------------------------------------------- */
|
|
|
|
|
|
|
|
|
fishProtocol::~fishProtocol()
|
|
|
{
|
|
|
myDebug( << "fishProtocol::~fishProtocol()" << endl);
|
|
|
shutdownConnection(true);
|
|
|
}
|
|
|
|
|
|
/* --------------------------------------------------------------------------- */
|
|
|
|
|
|
/**
|
|
|
Connects to a server and logs us in via SSH. Then starts FISH protocol.
|
|
|
*/
|
|
|
void fishProtocol::openConnection() {
|
|
|
if (childPid) return;
|
|
|
|
|
|
if (connectionHost.isEmpty() && !isNXFish)
|
|
|
{
|
|
|
error( TDEIO::ERR_UNKNOWN_HOST, TQString::null );
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
infoMessage(i18n("Connecting..."));
|
|
|
|
|
|
myDebug( << "connecting to: " << connectionUser << "@" << connectionHost << ":" << connectionPort << endl);
|
|
|
sendCommand(FISH_FISH);
|
|
|
sendCommand(FISH_VER);
|
|
|
if (connectionStart()) {
|
|
|
error(ERR_COULD_NOT_CONNECT,connectionHost);
|
|
|
shutdownConnection();
|
|
|
return;
|
|
|
};
|
|
|
myDebug( << "subprocess is running" << endl);
|
|
|
}
|
|
|
|
|
|
static int open_pty_pair(int fd[2])
|
|
|
{
|
|
|
#if defined(HAVE_TERMIOS_H) && defined(HAVE_GRANTPT) && !defined(HAVE_OPENPTY)
|
|
|
/** with kind regards to The GNU C Library
|
|
|
Reference Manual for Version 2.2.x of the GNU C Library */
|
|
|
int master, slave;
|
|
|
char *name;
|
|
|
struct ::termios ti;
|
|
|
memset(&ti,0,sizeof(ti));
|
|
|
|
|
|
ti.c_cflag = CLOCAL|CREAD|CS8;
|
|
|
ti.c_cc[VMIN] = 1;
|
|
|
|
|
|
#ifdef HAVE_GETPT
|
|
|
master = getpt();
|
|
|
#else
|
|
|
master = open("/dev/ptmx", O_RDWR);
|
|
|
#endif
|
|
|
if (master < 0) return 0;
|
|
|
|
|
|
if (grantpt(master) < 0 || unlockpt(master) < 0) goto close_master;
|
|
|
|
|
|
name = ptsname(master);
|
|
|
if (name == NULL) goto close_master;
|
|
|
|
|
|
slave = open(name, O_RDWR);
|
|
|
if (slave == -1) goto close_master;
|
|
|
|
|
|
#if (defined(HAVE_ISASTREAM) || defined(isastream)) && defined(I_PUSH)
|
|
|
if (isastream(slave) &&
|
|
|
(ioctl(slave, I_PUSH, "ptem") < 0 ||
|
|
|
ioctl(slave, I_PUSH, "ldterm") < 0))
|
|
|
goto close_slave;
|
|
|
#endif
|
|
|
|
|
|
tcsetattr(slave, TCSANOW, &ti);
|
|
|
fd[0] = master;
|
|
|
fd[1] = slave;
|
|
|
return 0;
|
|
|
|
|
|
#if (defined(HAVE_ISASTREAM) || defined(isastream)) && defined(I_PUSH)
|
|
|
close_slave:
|
|
|
#endif
|
|
|
close(slave);
|
|
|
|
|
|
close_master:
|
|
|
close(master);
|
|
|
return -1;
|
|
|
#else
|
|
|
#ifdef HAVE_OPENPTY
|
|
|
struct ::termios ti;
|
|
|
memset(&ti,0,sizeof(ti));
|
|
|
|
|
|
ti.c_cflag = CLOCAL|CREAD|CS8;
|
|
|
ti.c_cc[VMIN] = 1;
|
|
|
|
|
|
return openpty(fd,fd+1,NULL,&ti,NULL);
|
|
|
#else
|
|
|
#ifdef __GNUC__
|
|
|
#warning "No tty support available. Password dialog won't work."
|
|
|
#endif
|
|
|
return socketpair(PF_UNIX,SOCK_STREAM,0,fd);
|
|
|
#endif
|
|
|
#endif
|
|
|
}
|
|
|
/**
|
|
|
creates the subprocess
|
|
|
*/
|
|
|
bool fishProtocol::connectionStart() {
|
|
|
int fd[2];
|
|
|
int rc, flags;
|
|
|
thisFn = TQString::null;
|
|
|
|
|
|
rc = open_pty_pair(fd);
|
|
|
if (rc == -1) {
|
|
|
myDebug( << "socketpair failed, error: " << strerror(errno) << endl);
|
|
|
return true;
|
|
|
}
|
|
|
|
|
|
if (!requestNetwork()) return true;
|
|
|
myDebug( << "Exec: " << (local ? suPath : sshPath) << " Port: " << connectionPort << " User: " << connectionUser << endl);
|
|
|
childPid = fork();
|
|
|
if (childPid == -1) {
|
|
|
myDebug( << "fork failed, error: " << strerror(errno) << endl);
|
|
|
close(fd[0]);
|
|
|
close(fd[1]);
|
|
|
childPid = 0;
|
|
|
dropNetwork();
|
|
|
return true;
|
|
|
}
|
|
|
if (childPid == 0) {
|
|
|
// taken from konsole, see TEPty.C for details
|
|
|
// note: if we're running on socket pairs,
|
|
|
// this will fail, but thats what we expect
|
|
|
|
|
|
for (int sig = 1; sig < NSIG; sig++) signal(sig,SIG_DFL);
|
|
|
|
|
|
struct rlimit rlp;
|
|
|
getrlimit(RLIMIT_NOFILE, &rlp);
|
|
|
for (int i = 0; i < (int)rlp.rlim_cur; i++)
|
|
|
if (i != fd[1]) close(i);
|
|
|
|
|
|
dup2(fd[1],0);
|
|
|
dup2(fd[1],1);
|
|
|
dup2(fd[1],2);
|
|
|
if (fd[1] > 2) close(fd[1]);
|
|
|
|
|
|
setsid();
|
|
|
|
|
|
#if defined(TIOCSCTTY)
|
|
|
ioctl(0, TIOCSCTTY, 0);
|
|
|
#endif
|
|
|
|
|
|
int pgrp = getpid();
|
|
|
#if defined( _AIX) || defined( __hpux)
|
|
|
tcsetpgrp(0, pgrp);
|
|
|
#else
|
|
|
ioctl(0, TIOCSPGRP, (char *)&pgrp);
|
|
|
#endif
|
|
|
|
|
|
const char *dev = ttyname(0);
|
|
|
setpgid(0,0);
|
|
|
if (dev) close(open(dev, O_WRONLY, 0));
|
|
|
setpgid(0,0);
|
|
|
|
|
|
if (local) {
|
|
|
execl(suPath, "su", "-", connectionUser.latin1(), "-c", "cd ~;echo FISH:;exec /bin/sh -c \"if env true 2>/dev/null; then env PS1= PS2= TZ=UTC LANG=C LC_ALL=C LOCALE=C /bin/sh; else PS1= PS2= TZ=UTC LANG=C LC_ALL=C LOCALE=C /bin/sh; fi\"", (void *)0);
|
|
|
} else {
|
|
|
#define common_args "-l", connectionUser.latin1(), "-x", "-e", "none", \
|
|
|
"-q", connectionHost.latin1(), \
|
|
|
"echo FISH:;exec /bin/sh -c \"if env true 2>/dev/null; then env PS1= PS2= TZ=UTC LANG=C LC_ALL=C LOCALE=C /bin/sh; else PS1= PS2= TZ=UTC LANG=C LC_ALL=C LOCALE=C /bin/sh; fi\"", (void *)0
|
|
|
// disabled: leave compression up to the client.
|
|
|
// (isOpenSSH?"-C":"+C"),
|
|
|
|
|
|
if (connectionPort)
|
|
|
execl(sshPath, "ssh", "-p", TQString::number(connectionPort).latin1(), common_args);
|
|
|
else
|
|
|
execl(sshPath, "ssh", common_args);
|
|
|
#undef common_args
|
|
|
}
|
|
|
myDebug( << "could not exec! " << strerror(errno) << endl);
|
|
|
::exit(-1);
|
|
|
}
|
|
|
close(fd[1]);
|
|
|
rc = fcntl(fd[0],F_GETFL,&flags);
|
|
|
rc = fcntl(fd[0],F_SETFL,flags|O_NONBLOCK);
|
|
|
childFd = fd[0];
|
|
|
|
|
|
fd_set rfds, wfds;
|
|
|
FD_ZERO(&rfds);
|
|
|
FD_ZERO(&wfds);
|
|
|
char buf[32768];
|
|
|
int offset = 0;
|
|
|
while (!isLoggedIn) {
|
|
|
FD_SET(childFd,&rfds);
|
|
|
FD_ZERO(&wfds);
|
|
|
if (outBufPos >= 0) FD_SET(childFd,&wfds);
|
|
|
struct timeval timeout;
|
|
|
timeout.tv_sec = 0;
|
|
|
timeout.tv_usec = 1000;
|
|
|
rc = select(childFd+1, &rfds, &wfds, NULL, &timeout);
|
|
|
if (rc < 0) {
|
|
|
if (errno == EINTR)
|
|
|
continue;
|
|
|
myDebug( << "select failed, rc: " << rc << ", error: " << strerror(errno) << endl);
|
|
|
return true;
|
|
|
}
|
|
|
if (FD_ISSET(childFd,&wfds) && outBufPos >= 0) {
|
|
|
if (outBuf) rc = write(childFd,outBuf+outBufPos,outBufLen-outBufPos);
|
|
|
else rc = 0;
|
|
|
if (rc >= 0) outBufPos += rc;
|
|
|
else {
|
|
|
if (errno == EINTR)
|
|
|
continue;
|
|
|
myDebug( << "write failed, rc: " << rc << ", error: " << strerror(errno) << endl);
|
|
|
outBufPos = -1;
|
|
|
//return true;
|
|
|
}
|
|
|
if (outBufPos >= outBufLen) {
|
|
|
outBufPos = -1;
|
|
|
outBuf = NULL;
|
|
|
outBufLen = 0;
|
|
|
}
|
|
|
}
|
|
|
if (FD_ISSET(childFd,&rfds)) {
|
|
|
rc = read(childFd,buf+offset,32768-offset);
|
|
|
if (rc > 0) {
|
|
|
int noff = establishConnection(buf,rc+offset);
|
|
|
if (noff < 0) return false;
|
|
|
if (noff > 0) memmove(buf,buf+offset+rc-noff,noff);
|
|
|
offset = noff;
|
|
|
} else {
|
|
|
if (errno == EINTR)
|
|
|
continue;
|
|
|
myDebug( << "read failed, rc: " << rc << ", error: " << strerror(errno) << endl);
|
|
|
return true;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
return false;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
writes one chunk of data to stdin of child process
|
|
|
*/
|
|
|
void fishProtocol::writeChild(const char *buf, TDEIO::fileoffset_t len) {
|
|
|
if (outBufPos >= 0 && outBuf) {
|
|
|
#if 0
|
|
|
TQString debug;
|
|
|
debug.setLatin1(outBuf,outBufLen);
|
|
|
if (len > 0) myDebug( << "write request while old one is pending, throwing away input (" << outBufLen << "," << outBufPos << "," << debug.left(10) << "...)" << endl);
|
|
|
#endif
|
|
|
return;
|
|
|
}
|
|
|
outBuf = buf;
|
|
|
outBufPos = 0;
|
|
|
outBufLen = len;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
manages initial communication setup including password queries
|
|
|
*/
|
|
|
int fishProtocol::establishConnection(char *buffer, TDEIO::fileoffset_t len) {
|
|
|
TQString buf;
|
|
|
buf.setLatin1(buffer,len);
|
|
|
int pos;
|
|
|
// Strip trailing whitespace
|
|
|
while (buf.length() && (buf[buf.length()-1] == ' '))
|
|
|
buf.truncate(buf.length()-1);
|
|
|
|
|
|
myDebug( << "establishing: got " << buf << endl);
|
|
|
while (childPid && ((pos = buf.find('\n')) >= 0 ||
|
|
|
buf.endsWith(":") || buf.endsWith("?"))) {
|
|
|
pos++;
|
|
|
TQString str = buf.left(pos);
|
|
|
buf = buf.mid(pos);
|
|
|
if (str == "\n")
|
|
|
continue;
|
|
|
if (str == "FISH:\n") {
|
|
|
thisFn = TQString::null;
|
|
|
infoMessage(i18n("Initiating protocol..."));
|
|
|
if (!connectionAuth.password.isEmpty()) {
|
|
|
connectionAuth.password = connectionAuth.password.left(connectionAuth.password.length()-1);
|
|
|
if (connectionAuth.keepPassword) {
|
|
|
cacheAuthentication(connectionAuth);
|
|
|
}
|
|
|
}
|
|
|
isLoggedIn = true;
|
|
|
return 0;
|
|
|
} else if (!str.isEmpty()) {
|
|
|
thisFn += str;
|
|
|
} else if (buf.endsWith(":")) {
|
|
|
if (!redirectUser.isEmpty() && connectionUser != redirectUser) {
|
|
|
KURL dest = url;
|
|
|
dest.setUser(redirectUser);
|
|
|
dest.setPass(redirectPass);
|
|
|
redirection(dest);
|
|
|
commandList.clear();
|
|
|
commandCodes.clear();
|
|
|
finished();
|
|
|
redirectUser = "";
|
|
|
redirectPass = "";
|
|
|
return -1;
|
|
|
} else if (!connectionPassword.isEmpty()) {
|
|
|
myDebug( << "sending cpass" << endl);
|
|
|
connectionAuth.password = connectionPassword+"\n";
|
|
|
connectionPassword = TQString::null;
|
|
|
// su does not like receiving a password directly after sending
|
|
|
// the password prompt so we wait a while.
|
|
|
if (local)
|
|
|
sleep(1);
|
|
|
writeChild(connectionAuth.password.latin1(),connectionAuth.password.length());
|
|
|
} else {
|
|
|
myDebug( << "sending mpass" << endl);
|
|
|
connectionAuth.prompt = thisFn+buf;
|
|
|
if (local)
|
|
|
connectionAuth.caption = i18n("Local Login") + " - " + url.user() + "@" + url.host();
|
|
|
else
|
|
|
connectionAuth.caption = i18n("SSH Authorization") + " - " + url.user() + "@" + url.host();
|
|
|
if ((!firstLogin || !checkCachedAuthentication(connectionAuth))) {
|
|
|
connectionAuth.password = TQString::null; // don't prefill
|
|
|
if ( !openPassDlg(connectionAuth)) {
|
|
|
error(ERR_USER_CANCELED,connectionHost);
|
|
|
shutdownConnection();
|
|
|
return -1;
|
|
|
}
|
|
|
}
|
|
|
firstLogin = false;
|
|
|
connectionAuth.password += "\n";
|
|
|
if (connectionAuth.username != connectionUser) {
|
|
|
KURL dest = url;
|
|
|
dest.setUser(connectionAuth.username);
|
|
|
dest.setPass(connectionAuth.password);
|
|
|
redirection(dest);
|
|
|
if (isStat) { // FIXME: just a workaround for konq deficiencies
|
|
|
redirectUser = connectionAuth.username;
|
|
|
redirectPass = connectionAuth.password;
|
|
|
}
|
|
|
commandList.clear();
|
|
|
commandCodes.clear();
|
|
|
finished();
|
|
|
return -1;
|
|
|
}
|
|
|
myDebug( << "sending pass" << endl);
|
|
|
if (local)
|
|
|
sleep(1);
|
|
|
writeChild(connectionAuth.password.latin1(),connectionAuth.password.length());
|
|
|
}
|
|
|
thisFn = TQString::null;
|
|
|
return 0;
|
|
|
} else if (buf.endsWith("?")) {
|
|
|
int rc = messageBox(QuestionYesNo,thisFn+buf);
|
|
|
if (rc == KMessageBox::Yes) {
|
|
|
writeChild("yes\n",4);
|
|
|
} else {
|
|
|
writeChild("no\n",3);
|
|
|
}
|
|
|
thisFn = TQString::null;
|
|
|
return 0;
|
|
|
} else {
|
|
|
myDebug( << "unmatched case in initial handling! shouldn't happen!" << endl);
|
|
|
}
|
|
|
}
|
|
|
return buf.length();
|
|
|
}
|
|
|
/**
|
|
|
sets connection information for subsequent commands
|
|
|
*/
|
|
|
void fishProtocol::setHost(const TQString & host, int port, const TQString & u, const TQString & pass){
|
|
|
TQString user(u);
|
|
|
|
|
|
if (isNXFish)
|
|
|
local = 0;
|
|
|
else
|
|
|
local = (host == "localhost" && port == 0);
|
|
|
|
|
|
if (port <= 0) port = 0;
|
|
|
if (user.isEmpty()) user = getenv("LOGNAME");
|
|
|
|
|
|
if (host == connectionHost && port == connectionPort && user == connectionUser)
|
|
|
return;
|
|
|
myDebug( << "setHost " << u << "@" << host << endl);
|
|
|
|
|
|
if (childPid) shutdownConnection();
|
|
|
|
|
|
connectionHost = host;
|
|
|
connectionAuth.url.setHost(host);
|
|
|
|
|
|
connectionUser = user;
|
|
|
connectionAuth.username = user;
|
|
|
connectionAuth.url.setUser(user);
|
|
|
|
|
|
connectionPort = port;
|
|
|
connectionPassword = pass;
|
|
|
firstLogin = true;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
Forced close of the connection
|
|
|
|
|
|
This function gets called from the application side of the universe,
|
|
|
it shouldn't send any response.
|
|
|
*/
|
|
|
void fishProtocol::closeConnection(){
|
|
|
myDebug( << "closeConnection()" << endl);
|
|
|
shutdownConnection(true);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
Closes the connection
|
|
|
*/
|
|
|
void fishProtocol::shutdownConnection(bool forced){
|
|
|
if (childPid) {
|
|
|
kill(childPid,SIGTERM); // We may not have permission...
|
|
|
childPid = 0;
|
|
|
close(childFd); // ...in which case this should do the trick
|
|
|
childFd = -1;
|
|
|
if (!forced)
|
|
|
{
|
|
|
dropNetwork();
|
|
|
infoMessage(i18n("Disconnected."));
|
|
|
}
|
|
|
}
|
|
|
outBufPos = -1;
|
|
|
outBuf = NULL;
|
|
|
outBufLen = 0;
|
|
|
qlist.clear();
|
|
|
commandList.clear();
|
|
|
commandCodes.clear();
|
|
|
isLoggedIn = false;
|
|
|
writeReady = true;
|
|
|
isRunning = false;
|
|
|
rawRead = 0;
|
|
|
rawWrite = -1;
|
|
|
recvLen = -1;
|
|
|
sendLen = -1;
|
|
|
}
|
|
|
/**
|
|
|
builds each FISH request and sets the error counter
|
|
|
*/
|
|
|
bool fishProtocol::sendCommand(fish_command_type cmd, ...) {
|
|
|
const fish_info &info = fishInfo[cmd];
|
|
|
myDebug( << "queueing: cmd="<< cmd << "['" << info.command << "'](" << info.params <<"), alt=['" << info.alt << "'], lines=" << info.lines << endl);
|
|
|
|
|
|
va_list list;
|
|
|
va_start(list, cmd);
|
|
|
TQString realCmd = info.command;
|
|
|
TQString realAlt = info.alt;
|
|
|
static TQRegExp rx("[][\\\\\n $`#!()*?{}~&<>;'\"%^@|\t]");
|
|
|
for (int i = 0; i < info.params; i++) {
|
|
|
TQString arg(va_arg(list, const char *));
|
|
|
int pos = -2;
|
|
|
while ((pos = rx.search(arg,pos+2)) >= 0) {
|
|
|
arg.replace(pos,0,TQString("\\"));
|
|
|
}
|
|
|
//myDebug( << "arg " << i << ": " << arg << endl);
|
|
|
realCmd.append(" ").append(arg);
|
|
|
realAlt.replace(TQRegExp("%"+TQString::number(i+1)),arg);
|
|
|
}
|
|
|
TQString s("#");
|
|
|
s.append(realCmd).append("\n ").append(realAlt).append(" 2>&1;echo '### 000'\n");
|
|
|
if (realCmd == "FISH")
|
|
|
s.prepend(" ");
|
|
|
commandList.append(s);
|
|
|
commandCodes.append(cmd);
|
|
|
return true;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
checks response string for result code, converting 000 and 001 appropriately
|
|
|
*/
|
|
|
int fishProtocol::handleResponse(const TQString &str){
|
|
|
myDebug( << "handling: " << str << endl);
|
|
|
if (str.startsWith("### ")) {
|
|
|
bool isOk = false;
|
|
|
int result = str.mid(4,3).toInt(&isOk);
|
|
|
if (!isOk) result = 500;
|
|
|
if (result == 0) result = (errorCount != 0?500:200);
|
|
|
if (result == 1) result = (errorCount != 0?500:100);
|
|
|
myDebug( << "result: " << result << ", errorCount: " << errorCount << endl);
|
|
|
return result;
|
|
|
} else {
|
|
|
errorCount++;
|
|
|
return 0;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
int fishProtocol::makeTimeFromLs(const TQString &monthStr, const TQString &dayStr, const TQString &timeyearStr)
|
|
|
{
|
|
|
TQDateTime dt(TQDate::currentDate(Qt::UTC));
|
|
|
int year = dt.date().year();
|
|
|
int month = dt.date().month();
|
|
|
int currentMonth = month;
|
|
|
int day = dayStr.toInt();
|
|
|
|
|
|
static const char * const monthNames[12] = {
|
|
|
"Jan", "Feb", "Mar", "Apr", "May", "Jun",
|
|
|
"Jul", "Aug", "Sep", "Oct", "Nov", "Dec"
|
|
|
};
|
|
|
|
|
|
for (int i=0; i < 12; i++) if (monthStr.startsWith(monthNames[i])) {
|
|
|
month = i+1;
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
int pos = timeyearStr.find(':');
|
|
|
if (timeyearStr.length() == 4 && pos == -1) {
|
|
|
year = timeyearStr.toInt();
|
|
|
} else if (pos == -1) {
|
|
|
return 0;
|
|
|
} else {
|
|
|
if (month > currentMonth + 1) year--;
|
|
|
dt.time().setHMS(timeyearStr.left(pos).toInt(),timeyearStr.mid(pos+1).toInt(),0);
|
|
|
}
|
|
|
dt.date().setYMD(year,month,day);
|
|
|
|
|
|
return dt.toTime_t();
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
parses response from server and acts accordingly
|
|
|
*/
|
|
|
void fishProtocol::manageConnection(const TQString &l) {
|
|
|
TQString line(l);
|
|
|
int rc = handleResponse(line);
|
|
|
UDSAtom atom;
|
|
|
TQDateTime dt;
|
|
|
TDEIO::filesize_t fsize;
|
|
|
int pos, pos2, pos3;
|
|
|
bool isOk = false;
|
|
|
if (!rc) {
|
|
|
switch (fishCommand) {
|
|
|
case FISH_VER:
|
|
|
if (line.startsWith("VER 0.0.3")) {
|
|
|
line.append(" ");
|
|
|
hasAppend = line.contains(" append ");
|
|
|
} else {
|
|
|
error(ERR_UNSUPPORTED_PROTOCOL,line);
|
|
|
shutdownConnection();
|
|
|
}
|
|
|
break;
|
|
|
case FISH_PWD:
|
|
|
url.setPath(line);
|
|
|
redirection(url);
|
|
|
break;
|
|
|
case FISH_LIST:
|
|
|
myDebug( << "listReason: " << listReason << endl);
|
|
|
/* Fall through */
|
|
|
case FISH_STAT:
|
|
|
if (line.length() > 0) {
|
|
|
switch (line[0].cell()) {
|
|
|
case '0':
|
|
|
case '1':
|
|
|
case '2':
|
|
|
case '3':
|
|
|
case '4':
|
|
|
case '5':
|
|
|
case '6':
|
|
|
case '7':
|
|
|
case '8':
|
|
|
case '9':
|
|
|
fsize = line.toULongLong(&isOk);
|
|
|
if (fsize > 0 && isOk) errorCount--;
|
|
|
if ((fishCommand == FISH_LIST) && (listReason == LIST))
|
|
|
totalSize(fsize);
|
|
|
break;
|
|
|
|
|
|
case 'P':
|
|
|
errorCount--;
|
|
|
if (line[1] == 'd') {
|
|
|
mimeAtom.m_str = "inode/directory";
|
|
|
typeAtom.m_long = S_IFDIR;
|
|
|
} else {
|
|
|
if (line[1] == '-') {
|
|
|
typeAtom.m_long = S_IFREG;
|
|
|
} else if (line[1] == 'l') {
|
|
|
typeAtom.m_long = S_IFLNK;
|
|
|
} else if (line[1] == 'c') {
|
|
|
typeAtom.m_long = S_IFCHR;
|
|
|
} else if (line[1] == 'b') {
|
|
|
typeAtom.m_long = S_IFBLK;
|
|
|
} else if (line[1] == 's') {
|
|
|
typeAtom.m_long = S_IFSOCK;
|
|
|
} else if (line[1] == 'p') {
|
|
|
typeAtom.m_long = S_IFIFO;
|
|
|
} else {
|
|
|
myDebug( << "unknown file type: " << line[1].cell() << endl);
|
|
|
errorCount++;
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
//myDebug( << "file type: " << atom.m_long << endl);
|
|
|
//udsEntry.append(atom);
|
|
|
|
|
|
atom.m_uds = UDS_ACCESS;
|
|
|
atom.m_long = 0;
|
|
|
if (line[2] == 'r') atom.m_long |= S_IRUSR;
|
|
|
if (line[3] == 'w') atom.m_long |= S_IWUSR;
|
|
|
if (line[4] == 'x' || line[4] == 's') atom.m_long |= S_IXUSR;
|
|
|
if (line[4] == 'S' || line[4] == 's') atom.m_long |= S_ISUID;
|
|
|
if (line[5] == 'r') atom.m_long |= S_IRGRP;
|
|
|
if (line[6] == 'w') atom.m_long |= S_IWGRP;
|
|
|
if (line[7] == 'x' || line[7] == 's') atom.m_long |= S_IXGRP;
|
|
|
if (line[7] == 'S' || line[7] == 's') atom.m_long |= S_ISGID;
|
|
|
if (line[8] == 'r') atom.m_long |= S_IROTH;
|
|
|
if (line[9] == 'w') atom.m_long |= S_IWOTH;
|
|
|
if (line[10] == 'x' || line[10] == 't') atom.m_long |= S_IXOTH;
|
|
|
if (line[10] == 'T' || line[10] == 't') atom.m_long |= S_ISVTX;
|
|
|
udsEntry.append(atom);
|
|
|
|
|
|
atom.m_uds = UDS_USER;
|
|
|
atom.m_long = 0;
|
|
|
pos = line.find('.',12);
|
|
|
if (pos < 0) {
|
|
|
errorCount++;
|
|
|
break;
|
|
|
}
|
|
|
atom.m_str = line.mid(12,pos-12);
|
|
|
udsEntry.append(atom);
|
|
|
|
|
|
atom.m_uds = UDS_GROUP;
|
|
|
atom.m_long = 0;
|
|
|
atom.m_str = line.mid(pos+1);
|
|
|
udsEntry.append(atom);
|
|
|
break;
|
|
|
|
|
|
case 'd':
|
|
|
atom.m_uds = UDS_MODIFICATION_TIME;
|
|
|
pos = line.find(' ');
|
|
|
pos2 = line.find(' ',pos+1);
|
|
|
if (pos < 0 || pos2 < 0) break;
|
|
|
errorCount--;
|
|
|
atom.m_long = makeTimeFromLs(line.mid(1,pos-1), line.mid(pos+1,pos2-pos), line.mid(pos2+1));
|
|
|
udsEntry.append(atom);
|
|
|
break;
|
|
|
|
|
|
case 'D':
|
|
|
atom.m_uds = UDS_MODIFICATION_TIME;
|
|
|
pos = line.find(' ');
|
|
|
pos2 = line.find(' ',pos+1);
|
|
|
pos3 = line.find(' ',pos2+1);
|
|
|
if (pos < 0 || pos2 < 0 || pos3 < 0) break;
|
|
|
dt.setDate(TQDate(line.mid(1,pos-1).toInt(),line.mid(pos+1,pos2-pos-1).toInt(),line.mid(pos2+1,pos3-pos2-1).toInt()));
|
|
|
pos = pos3;
|
|
|
pos2 = line.find(' ',pos+1);
|
|
|
pos3 = line.find(' ',pos2+1);
|
|
|
if (pos < 0 || pos2 < 0 || pos3 < 0) break;
|
|
|
dt.setTime(TQTime(line.mid(pos+1,pos2-pos-1).toInt(),line.mid(pos2+1,pos3-pos2-1).toInt(),line.mid(pos3+1).toInt()));
|
|
|
errorCount--;
|
|
|
atom.m_long = dt.toTime_t();
|
|
|
udsEntry.append(atom);
|
|
|
break;
|
|
|
|
|
|
case 'S':
|
|
|
atom.m_uds = UDS_SIZE;
|
|
|
atom.m_long = line.mid(1).toULongLong(&isOk);
|
|
|
if (!isOk) break;
|
|
|
errorCount--;
|
|
|
udsEntry.append(atom);
|
|
|
break;
|
|
|
|
|
|
case 'E':
|
|
|
errorCount--;
|
|
|
break;
|
|
|
|
|
|
case ':':
|
|
|
atom.m_uds = UDS_NAME;
|
|
|
atom.m_long = 0;
|
|
|
pos = line.findRev('/');
|
|
|
atom.m_str = thisFn = line.mid(pos < 0?1:pos+1);
|
|
|
if (fishCommand == FISH_LIST)
|
|
|
udsEntry.append(atom);
|
|
|
// By default, the mimetype comes from the extension
|
|
|
// We'll use the file(1) result only as fallback [like the rest of KDE does]
|
|
|
{
|
|
|
KURL kurl("fish://host/");
|
|
|
kurl.setFileName(thisFn); // properly encode special chars
|
|
|
KMimeType::Ptr mime = KMimeType::findByURL(kurl);
|
|
|
if ( mime->name() != KMimeType::defaultMimeType() )
|
|
|
mimeAtom.m_str = mime->name();
|
|
|
}
|
|
|
errorCount--;
|
|
|
break;
|
|
|
|
|
|
case 'M': {
|
|
|
TQString type = line.mid(1);
|
|
|
|
|
|
// First thing's first. If remote says this is a directory, throw out any
|
|
|
// name-based file type guesses.
|
|
|
if (type == "inode/directory" && mimeAtom.m_str != type) {
|
|
|
mimeAtom.m_str = type;
|
|
|
typeAtom.m_long = S_IFDIR;
|
|
|
}
|
|
|
// This is getting ugly. file(1) makes some uneducated
|
|
|
// guesses, so we must try to ignore them (#51274)
|
|
|
else if (mimeAtom.m_str.isEmpty() && line.right(8) != "/unknown" &&
|
|
|
(thisFn.find('.') < 0 || (line.left(8) != "Mtext/x-"
|
|
|
&& line != "Mtext/plain"))) {
|
|
|
mimeAtom.m_str = type;
|
|
|
}
|
|
|
errorCount--;
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
case 'L':
|
|
|
atom.m_uds = UDS_LINK_DEST;
|
|
|
atom.m_long = 0;
|
|
|
atom.m_str = line.mid(1);
|
|
|
udsEntry.append(atom);
|
|
|
if (!typeAtom.m_long) typeAtom.m_long = S_IFLNK;
|
|
|
errorCount--;
|
|
|
break;
|
|
|
}
|
|
|
} else {
|
|
|
if (!mimeAtom.m_str.isNull())
|
|
|
udsEntry.append(mimeAtom);
|
|
|
mimeAtom.m_str = TQString::null;
|
|
|
|
|
|
udsEntry.append(typeAtom);
|
|
|
typeAtom.m_long = 0;
|
|
|
|
|
|
if (fishCommand == FISH_STAT)
|
|
|
udsStatEntry = udsEntry;
|
|
|
else if (listReason == LIST) {
|
|
|
listEntry(udsEntry, false); //1
|
|
|
} else if (listReason == CHECK) checkExist = true; //0
|
|
|
errorCount--;
|
|
|
udsEntry.clear();
|
|
|
}
|
|
|
break;
|
|
|
|
|
|
case FISH_RETR:
|
|
|
if (line.length() == 0) {
|
|
|
error(ERR_IS_DIRECTORY,url.prettyURL());
|
|
|
recvLen = 0;
|
|
|
break;
|
|
|
}
|
|
|
recvLen = line.toLongLong(&isOk);
|
|
|
if (!isOk) {
|
|
|
error(ERR_COULD_NOT_READ,url.prettyURL());
|
|
|
shutdownConnection();
|
|
|
break;
|
|
|
}
|
|
|
break;
|
|
|
default : break;
|
|
|
}
|
|
|
|
|
|
} else if (rc == 100) {
|
|
|
switch (fishCommand) {
|
|
|
case FISH_FISH:
|
|
|
writeChild(fishCode, fishCodeLen);
|
|
|
break;
|
|
|
case FISH_READ:
|
|
|
recvLen = 1024;
|
|
|
/* fall through */
|
|
|
case FISH_RETR:
|
|
|
myDebug( << "reading " << recvLen << endl);
|
|
|
if (recvLen == -1) {
|
|
|
error(ERR_COULD_NOT_READ,url.prettyURL());
|
|
|
shutdownConnection();
|
|
|
} else {
|
|
|
rawRead = recvLen;
|
|
|
dataRead = 0;
|
|
|
mimeTypeSent = false;
|
|
|
if (recvLen == 0)
|
|
|
{
|
|
|
mimeType("application/x-zerosize");
|
|
|
mimeTypeSent = true;
|
|
|
}
|
|
|
}
|
|
|
break;
|
|
|
case FISH_STOR:
|
|
|
case FISH_WRITE:
|
|
|
case FISH_APPEND:
|
|
|
rawWrite = sendLen;
|
|
|
//myDebug( << "sending " << sendLen << endl);
|
|
|
writeChild(NULL,0);
|
|
|
break;
|
|
|
default : break;
|
|
|
}
|
|
|
} else if (rc/100 != 2) {
|
|
|
switch (fishCommand) {
|
|
|
case FISH_STOR:
|
|
|
case FISH_WRITE:
|
|
|
case FISH_APPEND:
|
|
|
error(ERR_COULD_NOT_WRITE,url.prettyURL());
|
|
|
shutdownConnection();
|
|
|
break;
|
|
|
case FISH_RETR:
|
|
|
error(ERR_COULD_NOT_READ,url.prettyURL());
|
|
|
shutdownConnection();
|
|
|
break;
|
|
|
case FISH_READ:
|
|
|
if ( rc == 501 )
|
|
|
{
|
|
|
mimeType("inode/directory");
|
|
|
mimeTypeSent = true;
|
|
|
recvLen = 0;
|
|
|
finished();
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
error(ERR_COULD_NOT_READ,url.prettyURL());
|
|
|
shutdownConnection();
|
|
|
}
|
|
|
break;
|
|
|
case FISH_FISH:
|
|
|
case FISH_VER:
|
|
|
error(ERR_SLAVE_DEFINED,line);
|
|
|
shutdownConnection();
|
|
|
break;
|
|
|
case FISH_PWD:
|
|
|
case FISH_CWD:
|
|
|
error(ERR_CANNOT_ENTER_DIRECTORY,url.prettyURL());
|
|
|
break;
|
|
|
case FISH_LIST:
|
|
|
myDebug( << "list error. reason: " << listReason << endl);
|
|
|
if (listReason == LIST) error(ERR_CANNOT_ENTER_DIRECTORY,url.prettyURL());
|
|
|
else if (listReason == CHECK) {
|
|
|
checkExist = false;
|
|
|
finished();
|
|
|
}
|
|
|
break;
|
|
|
case FISH_STAT:
|
|
|
error(ERR_DOES_NOT_EXIST,url.prettyURL());
|
|
|
udsStatEntry.clear();
|
|
|
break;
|
|
|
case FISH_CHMOD:
|
|
|
error(ERR_CANNOT_CHMOD,url.prettyURL());
|
|
|
break;
|
|
|
case FISH_CHOWN:
|
|
|
case FISH_CHGRP:
|
|
|
error(ERR_ACCESS_DENIED,url.prettyURL());
|
|
|
break;
|
|
|
case FISH_MKD:
|
|
|
if ( rc == 501 )
|
|
|
error(ERR_DIR_ALREADY_EXIST,url.prettyURL());
|
|
|
else
|
|
|
error(ERR_COULD_NOT_MKDIR,url.prettyURL());
|
|
|
break;
|
|
|
case FISH_RMD:
|
|
|
error(ERR_COULD_NOT_RMDIR,url.prettyURL());
|
|
|
break;
|
|
|
case FISH_DELE:
|
|
|
error(ERR_CANNOT_DELETE,url.prettyURL());
|
|
|
break;
|
|
|
case FISH_RENAME:
|
|
|
error(ERR_CANNOT_RENAME,url.prettyURL());
|
|
|
break;
|
|
|
case FISH_COPY:
|
|
|
case FISH_LINK:
|
|
|
case FISH_SYMLINK:
|
|
|
error(ERR_COULD_NOT_WRITE,url.prettyURL());
|
|
|
break;
|
|
|
default : break;
|
|
|
}
|
|
|
} else {
|
|
|
if (fishCommand == FISH_STOR) fishCommand = (hasAppend?FISH_APPEND:FISH_WRITE);
|
|
|
if (fishCommand == FISH_FISH) {
|
|
|
connected();
|
|
|
} else if (fishCommand == FISH_LIST) {
|
|
|
if (listReason == LIST) {
|
|
|
listEntry(UDSEntry(),true);
|
|
|
} else if (listReason == CHECK) {
|
|
|
if (!checkOverwrite && checkExist)
|
|
|
{
|
|
|
error(ERR_FILE_ALREADY_EXIST,url.prettyURL());
|
|
|
return; // Don't call finished!
|
|
|
}
|
|
|
}
|
|
|
} else if (fishCommand == FISH_STAT) {
|
|
|
UDSAtom atom;
|
|
|
|
|
|
atom.m_uds = TDEIO::UDS_NAME;
|
|
|
atom.m_str = url.fileName();
|
|
|
udsStatEntry.append( atom );
|
|
|
statEntry(udsStatEntry);
|
|
|
} else if (fishCommand == FISH_APPEND) {
|
|
|
dataReq();
|
|
|
if (readData(rawData) > 0) sendCommand(FISH_APPEND,E(TQString::number(rawData.size())),E(url.path()));
|
|
|
else if (!checkExist && putPerm > -1) sendCommand(FISH_CHMOD,E(TQString::number(putPerm,8)),E(url.path()));
|
|
|
sendLen = rawData.size();
|
|
|
} else if (fishCommand == FISH_WRITE) {
|
|
|
dataReq();
|
|
|
if (readData(rawData) > 0) sendCommand(FISH_WRITE,E(TQString::number(putPos)),E(TQString::number(rawData.size())),E(url.path()));
|
|
|
else if (!checkExist && putPerm > -1) sendCommand(FISH_CHMOD,E(TQString::number(putPerm,8)),E(url.path()));
|
|
|
putPos += rawData.size();
|
|
|
sendLen = rawData.size();
|
|
|
} else if (fishCommand == FISH_RETR) {
|
|
|
data(TQByteArray());
|
|
|
}
|
|
|
finished();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
void fishProtocol::writeStdin(const TQString &line)
|
|
|
{
|
|
|
qlist.append(line);
|
|
|
|
|
|
if (writeReady) {
|
|
|
writeReady = false;
|
|
|
//myDebug( << "Writing: " << qlist.first().mid(0,qlist.first().find('\n')) << endl);
|
|
|
myDebug( << "Writing: " << qlist.first() << endl);
|
|
|
myDebug( << "---------" << endl);
|
|
|
writeChild((const char *)qlist.first().latin1(), qlist.first().length());
|
|
|
}
|
|
|
}
|
|
|
|
|
|
void fishProtocol::sent()
|
|
|
{
|
|
|
if (rawWrite > 0) {
|
|
|
myDebug( << "writing raw: " << rawData.size() << "/" << rawWrite << endl);
|
|
|
writeChild(rawData.data(),(rawWrite > rawData.size()?rawData.size():rawWrite));
|
|
|
rawWrite -= rawData.size();
|
|
|
if (rawWrite > 0) {
|
|
|
dataReq();
|
|
|
if (readData(rawData) <= 0) {
|
|
|
shutdownConnection();
|
|
|
}
|
|
|
}
|
|
|
return;
|
|
|
} else if (rawWrite == 0) {
|
|
|
// workaround: some dd's insist in reading multiples of
|
|
|
// 8 bytes, swallowing up to seven bytes. Sending
|
|
|
// newlines is safe even when a sane dd is used
|
|
|
writeChild("\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n",15);
|
|
|
rawWrite = -1;
|
|
|
return;
|
|
|
}
|
|
|
if (qlist.count() > 0) qlist.remove(qlist.begin());
|
|
|
if (qlist.count() == 0) {
|
|
|
writeReady = true;
|
|
|
} else {
|
|
|
//myDebug( << "Writing: " << qlist.first().mid(0,qlist.first().find('\n')) << endl);
|
|
|
myDebug( << "Writing: " << qlist.first() << endl);
|
|
|
myDebug( << "---------" << endl);
|
|
|
writeChild((const char *)qlist.first().latin1(),qlist.first().length());
|
|
|
}
|
|
|
}
|
|
|
|
|
|
int fishProtocol::received(const char *buffer, TDEIO::fileoffset_t buflen)
|
|
|
{
|
|
|
int pos = 0;
|
|
|
do {
|
|
|
if (buflen <= 0) break;
|
|
|
|
|
|
if (rawRead > 0) {
|
|
|
//myDebug( << "processedSize " << dataRead << ", len " << buflen << "/" << rawRead << endl);
|
|
|
int dataSize = (rawRead > buflen?buflen:rawRead);
|
|
|
if (!mimeTypeSent)
|
|
|
{
|
|
|
int mimeSize = TQMIN(dataSize, (int)mimeBuffer.size()-dataRead);
|
|
|
memcpy(mimeBuffer.data()+dataRead,buffer,mimeSize);
|
|
|
dataRead += mimeSize;
|
|
|
rawRead -= mimeSize;
|
|
|
buffer += mimeSize;
|
|
|
buflen -= mimeSize;
|
|
|
if (rawRead == 0) // End of data
|
|
|
mimeBuffer.resize(dataRead);
|
|
|
if (dataRead < (int)mimeBuffer.size())
|
|
|
{
|
|
|
myDebug( << "wait for more" << endl);
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
// We need a KMimeType::findByNameAndContent(filename,data)
|
|
|
// For now we do: find by extension, and if not found (or extension not reliable)
|
|
|
// then find by content.
|
|
|
bool accurate = false;
|
|
|
KMimeType::Ptr mime = KMimeType::findByURL( url, 0, false, true, &accurate );
|
|
|
if ( !mime || mime->name() == KMimeType::defaultMimeType()
|
|
|
|| !accurate )
|
|
|
{
|
|
|
KMimeType::Ptr p_mimeType = KMimeType::findByContent(mimeBuffer);
|
|
|
if ( p_mimeType && p_mimeType->name() != KMimeType::defaultMimeType() )
|
|
|
mime = p_mimeType;
|
|
|
}
|
|
|
|
|
|
sendmimeType(mime->name());
|
|
|
|
|
|
|
|
|
mimeTypeSent = true;
|
|
|
if (fishCommand != FISH_READ) {
|
|
|
totalSize(dataRead + rawRead);
|
|
|
data(mimeBuffer);
|
|
|
processedSize(dataRead);
|
|
|
}
|
|
|
mimeBuffer.resize(1024);
|
|
|
pos = 0;
|
|
|
continue; // Process rest of buffer/buflen
|
|
|
}
|
|
|
|
|
|
TQByteArray bdata;
|
|
|
bdata.duplicate(buffer,dataSize);
|
|
|
data(bdata);
|
|
|
|
|
|
dataRead += dataSize;
|
|
|
rawRead -= dataSize;
|
|
|
processedSize(dataRead);
|
|
|
if (rawRead <= 0) {
|
|
|
buffer += dataSize;
|
|
|
buflen -= dataSize;
|
|
|
} else {
|
|
|
return 0;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if (buflen <= 0) break;
|
|
|
|
|
|
pos = 0;
|
|
|
// Find newline
|
|
|
while((pos < buflen) && (buffer[pos] != '\n'))
|
|
|
++pos;
|
|
|
|
|
|
if (pos < buflen)
|
|
|
{
|
|
|
TQString s = remoteEncoding()->decode(TQCString(buffer,pos+1));
|
|
|
|
|
|
buffer += pos+1;
|
|
|
buflen -= pos+1;
|
|
|
|
|
|
manageConnection(s);
|
|
|
|
|
|
pos = 0;
|
|
|
// Find next newline
|
|
|
while((pos < buflen) && (buffer[pos] != '\n'))
|
|
|
++pos;
|
|
|
}
|
|
|
} while (childPid && buflen && (rawRead > 0 || pos < buflen));
|
|
|
return buflen;
|
|
|
}
|
|
|
/** get a file */
|
|
|
void fishProtocol::get(const KURL& u){
|
|
|
myDebug( << "@@@@@@@@@ get " << u << endl);
|
|
|
setHost(u.host(),u.port(),u.user(),u.pass());
|
|
|
url = u;
|
|
|
openConnection();
|
|
|
if (!isLoggedIn) return;
|
|
|
url.cleanPath();
|
|
|
if (!url.hasPath()) {
|
|
|
sendCommand(FISH_PWD);
|
|
|
} else {
|
|
|
recvLen = -1;
|
|
|
sendCommand(FISH_RETR,E(url.path()));
|
|
|
}
|
|
|
run();
|
|
|
}
|
|
|
|
|
|
/** put a file */
|
|
|
void fishProtocol::put(const KURL& u, int permissions, bool overwrite, bool /*resume*/){
|
|
|
myDebug( << "@@@@@@@@@ put " << u << " " << permissions << " " << overwrite << " " /* << resume */ << endl);
|
|
|
setHost(u.host(),u.port(),u.user(),u.pass());
|
|
|
url = u;
|
|
|
openConnection();
|
|
|
if (!isLoggedIn) return;
|
|
|
url.cleanPath();
|
|
|
if (!url.hasPath()) {
|
|
|
sendCommand(FISH_PWD);
|
|
|
} else {
|
|
|
putPerm = permissions;
|
|
|
checkOverwrite = overwrite;
|
|
|
checkExist = false;
|
|
|
putPos = 0;
|
|
|
listReason = CHECK;
|
|
|
sendCommand(FISH_LIST,E(url.path()));
|
|
|
sendCommand(FISH_STOR,"0",E(url.path()));
|
|
|
}
|
|
|
run();
|
|
|
}
|
|
|
/** executes next command in sequence or calls finished() if all is done */
|
|
|
void fishProtocol::finished() {
|
|
|
if (commandList.count() > 0) {
|
|
|
fishCommand = (fish_command_type)commandCodes.first();
|
|
|
errorCount = -fishInfo[fishCommand].lines;
|
|
|
rawRead = 0;
|
|
|
rawWrite = -1;
|
|
|
udsEntry.clear();
|
|
|
udsStatEntry.clear();
|
|
|
writeStdin(commandList.first());
|
|
|
//if (fishCommand != FISH_APPEND && fishCommand != FISH_WRITE) infoMessage("Sending "+(commandList.first().mid(1,commandList.first().find("\n")-1))+"...");
|
|
|
commandList.remove(commandList.begin());
|
|
|
commandCodes.remove(commandCodes.begin());
|
|
|
} else {
|
|
|
myDebug( << "_______ emitting finished()" << endl);
|
|
|
SlaveBase::finished();
|
|
|
isRunning = false;
|
|
|
}
|
|
|
}
|
|
|
/** aborts command sequence and calls error() */
|
|
|
void fishProtocol::error(int type, const TQString &detail) {
|
|
|
commandList.clear();
|
|
|
commandCodes.clear();
|
|
|
myDebug( << "ERROR: " << type << " - " << detail << endl);
|
|
|
SlaveBase::error(type,detail);
|
|
|
isRunning = false;
|
|
|
}
|
|
|
/** executes a chain of commands */
|
|
|
void fishProtocol::run() {
|
|
|
if (!isRunning) {
|
|
|
int rc;
|
|
|
isRunning = true;
|
|
|
finished();
|
|
|
fd_set rfds, wfds;
|
|
|
FD_ZERO(&rfds);
|
|
|
char buf[32768];
|
|
|
int offset = 0;
|
|
|
while (isRunning) {
|
|
|
FD_SET(childFd,&rfds);
|
|
|
FD_ZERO(&wfds);
|
|
|
if (outBufPos >= 0) FD_SET(childFd,&wfds);
|
|
|
struct timeval timeout;
|
|
|
timeout.tv_sec = 0;
|
|
|
timeout.tv_usec = 1000;
|
|
|
rc = select(childFd+1, &rfds, &wfds, NULL, &timeout);
|
|
|
if (rc < 0) {
|
|
|
if (errno == EINTR)
|
|
|
continue;
|
|
|
myDebug( << "select failed, rc: " << rc << ", error: " << strerror(errno) << endl);
|
|
|
error(ERR_CONNECTION_BROKEN,connectionHost);
|
|
|
shutdownConnection();
|
|
|
return;
|
|
|
}
|
|
|
if (FD_ISSET(childFd,&wfds) && outBufPos >= 0) {
|
|
|
#if 0
|
|
|
TQString debug;
|
|
|
debug.setLatin1(outBuf+outBufPos,outBufLen-outBufPos);
|
|
|
myDebug( << "now writing " << (outBufLen-outBufPos) << " " << debug.left(40) << "..." << endl);
|
|
|
#endif
|
|
|
if (outBufLen-outBufPos > 0) rc = write(childFd,outBuf+outBufPos,outBufLen-outBufPos);
|
|
|
else rc = 0;
|
|
|
if (rc >= 0) outBufPos += rc;
|
|
|
else {
|
|
|
if (errno == EINTR)
|
|
|
continue;
|
|
|
myDebug( << "write failed, rc: " << rc << ", error: " << strerror(errno) << endl);
|
|
|
error(ERR_CONNECTION_BROKEN,connectionHost);
|
|
|
shutdownConnection();
|
|
|
return;
|
|
|
}
|
|
|
if (outBufPos >= outBufLen) {
|
|
|
outBufPos = -1;
|
|
|
outBuf = NULL;
|
|
|
sent();
|
|
|
}
|
|
|
}
|
|
|
else if (FD_ISSET(childFd,&rfds)) {
|
|
|
rc = read(childFd,buf+offset,32768-offset);
|
|
|
//myDebug( << "read " << rc << " bytes" << endl);
|
|
|
if (rc > 0) {
|
|
|
int noff = received(buf,rc+offset);
|
|
|
if (noff > 0) memmove(buf,buf+offset+rc-noff,noff);
|
|
|
//myDebug( << "left " << noff << " bytes: " << TQString::fromLatin1(buf,offset) << endl);
|
|
|
offset = noff;
|
|
|
} else {
|
|
|
if (errno == EINTR)
|
|
|
continue;
|
|
|
myDebug( << "read failed, rc: " << rc << ", error: " << strerror(errno) << endl);
|
|
|
error(ERR_CONNECTION_BROKEN,connectionHost);
|
|
|
shutdownConnection();
|
|
|
return;
|
|
|
}
|
|
|
}
|
|
|
if (wasKilled())
|
|
|
return;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
/** stat a file */
|
|
|
void fishProtocol::stat(const KURL& u){
|
|
|
myDebug( << "@@@@@@@@@ stat " << u << endl);
|
|
|
setHost(u.host(),u.port(),u.user(),u.pass());
|
|
|
url = u;
|
|
|
isStat = true; // FIXME: just a workaround for konq deficiencies
|
|
|
openConnection();
|
|
|
isStat = false; // FIXME: just a workaround for konq deficiencies
|
|
|
if (!isLoggedIn) return;
|
|
|
url.cleanPath();
|
|
|
if (!url.hasPath()) {
|
|
|
sendCommand(FISH_PWD);
|
|
|
} else {
|
|
|
sendCommand(FISH_STAT,E(url.path(-1)));
|
|
|
}
|
|
|
run();
|
|
|
}
|
|
|
/** find mimetype for a file */
|
|
|
void fishProtocol::mimetype(const KURL& u){
|
|
|
myDebug( << "@@@@@@@@@ mimetype " << u << endl);
|
|
|
setHost(u.host(),u.port(),u.user(),u.pass());
|
|
|
url = u;
|
|
|
openConnection();
|
|
|
if (!isLoggedIn) return;
|
|
|
url.cleanPath();
|
|
|
if (!url.hasPath()) {
|
|
|
sendCommand(FISH_PWD);
|
|
|
} else {
|
|
|
recvLen = 1024;
|
|
|
sendCommand(FISH_READ,"0","1024",E(url.path()));
|
|
|
}
|
|
|
run();
|
|
|
}
|
|
|
/** list a directory */
|
|
|
void fishProtocol::listDir(const KURL& u){
|
|
|
myDebug( << "@@@@@@@@@ listDir " << u << endl);
|
|
|
setHost(u.host(),u.port(),u.user(),u.pass());
|
|
|
url = u;
|
|
|
openConnection();
|
|
|
if (!isLoggedIn) return;
|
|
|
url.cleanPath();
|
|
|
if (!url.hasPath()) {
|
|
|
sendCommand(FISH_PWD);
|
|
|
} else {
|
|
|
listReason = LIST;
|
|
|
sendCommand(FISH_LIST,E(url.path()));
|
|
|
}
|
|
|
run();
|
|
|
}
|
|
|
/** create a directory */
|
|
|
void fishProtocol::mkdir(const KURL& u, int permissions) {
|
|
|
myDebug( << "@@@@@@@@@ mkdir " << u << " " << permissions << endl);
|
|
|
setHost(u.host(),u.port(),u.user(),u.pass());
|
|
|
url = u;
|
|
|
openConnection();
|
|
|
if (!isLoggedIn) return;
|
|
|
url.cleanPath();
|
|
|
if (!url.hasPath()) {
|
|
|
sendCommand(FISH_PWD);
|
|
|
} else {
|
|
|
sendCommand(FISH_MKD,E(url.path()));
|
|
|
if (permissions > -1) sendCommand(FISH_CHMOD,E(TQString::number(permissions,8)),E(url.path()));
|
|
|
}
|
|
|
run();
|
|
|
}
|
|
|
/** rename a file */
|
|
|
void fishProtocol::rename(const KURL& s, const KURL& d, bool overwrite) {
|
|
|
myDebug( << "@@@@@@@@@ rename " << s << " " << d << " " << overwrite << endl);
|
|
|
if (s.host() != d.host() || s.port() != d.port() || s.user() != d.user()) {
|
|
|
error(ERR_UNSUPPORTED_ACTION,s.prettyURL());
|
|
|
return;
|
|
|
}
|
|
|
setHost(s.host(),s.port(),s.user(),s.pass());
|
|
|
url = d;
|
|
|
openConnection();
|
|
|
if (!isLoggedIn) return;
|
|
|
KURL src = s;
|
|
|
url.cleanPath();
|
|
|
src.cleanPath();
|
|
|
if (!url.hasPath()) {
|
|
|
sendCommand(FISH_PWD);
|
|
|
} else {
|
|
|
if (!overwrite) {
|
|
|
listReason = CHECK;
|
|
|
checkOverwrite = false;
|
|
|
sendCommand(FISH_LIST,E(url.path()));
|
|
|
}
|
|
|
sendCommand(FISH_RENAME,E(src.path()),E(url.path()));
|
|
|
}
|
|
|
run();
|
|
|
}
|
|
|
/** create a symlink */
|
|
|
void fishProtocol::symlink(const TQString& target, const KURL& u, bool overwrite) {
|
|
|
myDebug( << "@@@@@@@@@ symlink " << target << " " << u << " " << overwrite << endl);
|
|
|
setHost(u.host(),u.port(),u.user(),u.pass());
|
|
|
url = u;
|
|
|
openConnection();
|
|
|
if (!isLoggedIn) return;
|
|
|
url.cleanPath();
|
|
|
if (!url.hasPath()) {
|
|
|
sendCommand(FISH_PWD);
|
|
|
} else {
|
|
|
if (!overwrite) {
|
|
|
listReason = CHECK;
|
|
|
checkOverwrite = false;
|
|
|
sendCommand(FISH_LIST,E(url.path()));
|
|
|
}
|
|
|
sendCommand(FISH_SYMLINK,E(target),E(url.path()));
|
|
|
}
|
|
|
run();
|
|
|
}
|
|
|
/** change file permissions */
|
|
|
void fishProtocol::chmod(const KURL& u, int permissions){
|
|
|
myDebug( << "@@@@@@@@@ chmod " << u << " " << permissions << endl);
|
|
|
setHost(u.host(),u.port(),u.user(),u.pass());
|
|
|
url = u;
|
|
|
openConnection();
|
|
|
if (!isLoggedIn) return;
|
|
|
url.cleanPath();
|
|
|
if (!url.hasPath()) {
|
|
|
sendCommand(FISH_PWD);
|
|
|
} else {
|
|
|
if (permissions > -1) sendCommand(FISH_CHMOD,E(TQString::number(permissions,8)),E(url.path()));
|
|
|
}
|
|
|
run();
|
|
|
}
|
|
|
/** copies a file */
|
|
|
void fishProtocol::copy(const KURL &s, const KURL &d, int permissions, bool overwrite) {
|
|
|
myDebug( << "@@@@@@@@@ copy " << s << " " << d << " " << permissions << " " << overwrite << endl);
|
|
|
if (s.host() != d.host() || s.port() != d.port() || s.user() != d.user()) {
|
|
|
error(ERR_UNSUPPORTED_ACTION,s.prettyURL());
|
|
|
return;
|
|
|
}
|
|
|
//myDebug( << s << endl << d << endl);
|
|
|
setHost(s.host(),s.port(),s.user(),s.pass());
|
|
|
url = d;
|
|
|
openConnection();
|
|
|
if (!isLoggedIn) return;
|
|
|
KURL src = s;
|
|
|
url.cleanPath();
|
|
|
src.cleanPath();
|
|
|
if (!src.hasPath()) {
|
|
|
sendCommand(FISH_PWD);
|
|
|
} else {
|
|
|
if (!overwrite) {
|
|
|
listReason = CHECK;
|
|
|
checkOverwrite = false;
|
|
|
sendCommand(FISH_LIST,E(url.path()));
|
|
|
}
|
|
|
sendCommand(FISH_COPY,E(src.path()),E(url.path()));
|
|
|
if (permissions > -1) sendCommand(FISH_CHMOD,E(TQString::number(permissions,8)),E(url.path()));
|
|
|
}
|
|
|
run();
|
|
|
}
|
|
|
/** removes a file or directory */
|
|
|
void fishProtocol::del(const KURL &u, bool isFile){
|
|
|
myDebug( << "@@@@@@@@@ del " << u << " " << isFile << endl);
|
|
|
setHost(u.host(),u.port(),u.user(),u.pass());
|
|
|
url = u;
|
|
|
openConnection();
|
|
|
if (!isLoggedIn) return;
|
|
|
url.cleanPath();
|
|
|
if (!url.hasPath()) {
|
|
|
sendCommand(FISH_PWD);
|
|
|
} else {
|
|
|
sendCommand((isFile?FISH_DELE:FISH_RMD),E(url.path()));
|
|
|
}
|
|
|
run();
|
|
|
}
|
|
|
/** special like background execute */
|
|
|
void fishProtocol::special( const TQByteArray &data ){
|
|
|
int tmp;
|
|
|
|
|
|
TQDataStream stream(data, IO_ReadOnly);
|
|
|
|
|
|
stream >> tmp;
|
|
|
switch (tmp) {
|
|
|
case FISH_EXEC_CMD: // SSH EXEC
|
|
|
{
|
|
|
KURL u;
|
|
|
TQString command;
|
|
|
TQString tempfile;
|
|
|
stream >> u;
|
|
|
stream >> command;
|
|
|
myDebug( << "@@@@@@@@@ exec " << u << " " << command << endl);
|
|
|
setHost(u.host(),u.port(),u.user(),u.pass());
|
|
|
url = u;
|
|
|
openConnection();
|
|
|
if (!isLoggedIn) return;
|
|
|
sendCommand(FISH_EXEC,E(command),E(url.path()));
|
|
|
run();
|
|
|
break;
|
|
|
}
|
|
|
default:
|
|
|
// Some command we don't understand.
|
|
|
error(ERR_UNSUPPORTED_ACTION,TQString().setNum(tmp));
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
/** report status */
|
|
|
void fishProtocol::slave_status() {
|
|
|
myDebug( << "@@@@@@@@@ slave_status" << endl);
|
|
|
if (childPid > 0)
|
|
|
slaveStatus(connectionHost,isLoggedIn);
|
|
|
else
|
|
|
slaveStatus(TQString::null,false);
|
|
|
}
|
