diff options
Diffstat (limited to 'lanbrowsing/tdeio_lan/tdeio_lan.cpp')
| -rw-r--r-- | lanbrowsing/tdeio_lan/tdeio_lan.cpp | 794 |
1 files changed, 794 insertions, 0 deletions
diff --git a/lanbrowsing/tdeio_lan/tdeio_lan.cpp b/lanbrowsing/tdeio_lan/tdeio_lan.cpp new file mode 100644 index 00000000..e573f7ea --- /dev/null +++ b/lanbrowsing/tdeio_lan/tdeio_lan.cpp @@ -0,0 +1,794 @@ +/* This file is part of the KDE project + Copyright (C) 2000,2001 Alexander Neundorf <neundorf@kde.org> + + This library 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 library 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 library; see the file COPYING.LIB. If not, write to + the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, + Boston, MA 02110-1301, USA. +*/ + +#ifdef HAVE_CONFIG_H +#include <config.h> +#endif + +#include <kdebug.h> +#include <klocale.h> +#include <kinstance.h> +#include <tdeconfig.h> +#include <kglobal.h> +#include <kprocess.h> + +#include <tqfile.h> + +#include <iostream> +#include <string.h> +#include <sys/un.h> +#include <sys/stat.h> +#include <sys/time.h> +#include <sys/types.h> +#include <sys/socket.h> +#include <netinet/in.h> +#include <unistd.h> +#include <netdb.h> +#include <stdlib.h> +#include <fcntl.h> +#include <errno.h> +#include <time.h> +#include <pwd.h> + +#include "tdeio_lan.h" + +#ifndef AF_LOCAL +#define AF_LOCAL AF_UNIX +#endif + +#define PORTSETTINGS_CHECK 0 +#define PORTSETTINGS_PROVIDE 1 +#define PORTSETTINGS_DISABLE 2 + +using namespace TDEIO; + +#ifndef SHUT_RDWR +#define SHUT_RDWR 2 +#endif + +extern "C" { KDE_EXPORT int kdemain(int argc, char **argv); } + +int kdemain( int argc, char **argv ) +{ + TDEInstance instance( "tdeio_lan" ); + + if (argc != 4) + { + fprintf(stderr, "Usage: tdeio_lan protocol domain-socket1 domain-socket2\n"); + exit(-1); + } + int isLanIoslave=(strcmp("lan",argv[1])==0); + + // Trigger creation to make sure we pick up KIOSK settings correctly. + (void)TDEGlobal::dirs(); + (void)TDEGlobal::locale(); + (void)TDEGlobal::config(); + + kdDebug(7101) << "LAN: kdemain: starting" << endl; + + LANProtocol slave(isLanIoslave, argv[2], argv[3]); + slave.dispatchLoop(); + return 0; +} + +LANProtocol::LANProtocol(int isLanIoslave, const TQCString &pool, const TQCString &app ) +:TCPSlaveBase(7741,isLanIoslave?"lan":"rlan", pool, app) +,m_currentHost("") +,m_port(7741) +,m_maxAge(15*60) +,m_isLanIoslave(isLanIoslave?true:false) +{ + TDEConfig *config=TDEGlobal::config(); + + m_protocolInfo[KIOLAN_FTP].enabled=config->readNumEntry("Support_FTP",PORTSETTINGS_CHECK); + m_protocolInfo[KIOLAN_HTTP].enabled=config->readNumEntry("Support_HTTP",PORTSETTINGS_CHECK); + m_protocolInfo[KIOLAN_NFS].enabled=config->readNumEntry("Support_NFS",PORTSETTINGS_CHECK); + m_protocolInfo[KIOLAN_SMB].enabled=config->readNumEntry("Support_SMB",PORTSETTINGS_CHECK); + m_protocolInfo[KIOLAN_FISH].enabled=config->readNumEntry("Support_FISH",PORTSETTINGS_CHECK); + + m_defaultLisaHost=config->readEntry("DefaultLisaHost", "localhost"); + m_shortHostnames=config->readBoolEntry("ShowShortHostnames",false); + m_maxAge=config->readNumEntry("MaxAge",15)*60; + if (m_maxAge<0) m_maxAge=0; + + strcpy(m_protocolInfo[KIOLAN_NFS].name,"NFS"); + strcpy(m_protocolInfo[KIOLAN_FTP].name,"FTP"); + strcpy(m_protocolInfo[KIOLAN_SMB].name,"SMB"); + strcpy(m_protocolInfo[KIOLAN_HTTP].name,"HTTP"); + strcpy(m_protocolInfo[KIOLAN_FISH].name,"FISH"); + + // Now we check for port 445 for SMB/CIFS also. But we call both entries + // SMB. Clients will see only one SMB folder, though, whichever + // port (or both) is detected. The smb ioslave should be able + // to figure out which port to actually use. + + m_protocolInfo[KIOLAN_NFS].ports.push_back(2049); + m_protocolInfo[KIOLAN_FTP].ports.push_back(21); + m_protocolInfo[KIOLAN_SMB].ports.push_back(445); + m_protocolInfo[KIOLAN_SMB].ports.push_back(139); + m_protocolInfo[KIOLAN_HTTP].ports.push_back(80); + m_protocolInfo[KIOLAN_FISH].ports.push_back(22); + + m_hostInfoCache.setAutoDelete(true); +} + +LANProtocol::~LANProtocol() +{ + m_hostInfoCache.clear(); +} + +int LANProtocol::readDataFromServer() +{ + if (m_isLanIoslave) + return lanReadDataFromServer(); + else + return rlanReadDataFromServer(); + return 0; +} + +int LANProtocol::lanReadDataFromServer() +{ + kdDebug(7101)<<"LANProtocol::lanReadDataFromServer() host: "<<m_currentHost<<" port: "<<m_port<<endl; + if (!connectToHost(m_currentHost.latin1(), m_port, false)) + { + error(ERR_SLAVE_DEFINED, i18n("<qt>The Lisa daemon does not appear to be running.<p>" + "In order to use the LAN Browser the Lisa daemon must be " + "installed and activated by the system administrator.")); + return 0; + } + kdDebug(7101)<<"LANProtocol::lanReadDataFromServer() connected"<<endl; + + int receivedBytes(0); + char* receiveBuffer(0); + char tmpBuf[64*1024]; + int bytesRead(0); + do + { + fd_set tmpFDs; + FD_ZERO(&tmpFDs); + FD_SET(m_iSock,&tmpFDs); + timeval tv; + tv.tv_sec = 1; + tv.tv_usec = 0; + select(m_iSock+1,&tmpFDs,0,0,&tv); + if (FD_ISSET(m_iSock,&tmpFDs)) + { + bytesRead=read(tmpBuf,64*1024); + kdDebug(7101)<<"LANProtocol::lanReadDataFromServer: read "<<bytesRead<<" bytes"<<endl; + + if (bytesRead>0) + { + char *newBuf=new char[receivedBytes+bytesRead]; + if (receiveBuffer!=0) memcpy(newBuf,receiveBuffer,receivedBytes); + memcpy(newBuf+receivedBytes,tmpBuf,bytesRead); + receivedBytes+=bytesRead; + if (receiveBuffer!=0) delete [] receiveBuffer; + receiveBuffer=newBuf; + } + } + } while (bytesRead>0); + closeDescriptor(); + if ((bytesRead<0) || (receivedBytes<4)) + { + delete [] receiveBuffer; + error(ERR_INTERNAL_SERVER,i18n("Received unexpected data from %1").arg(m_currentHost)); + return 0; + } + + UDSEntry entry; + + char *currentBuf=receiveBuffer; + int bytesLeft=receivedBytes; + //this should be large enough for a name + char tmpName[4*1024]; + //this should be large enough for the hostname + char tmpHostname[4*1024]; + while (bytesLeft>0) + { + int tmpIP=2; + tmpName[0]='\0'; + if ((memchr(currentBuf,0,bytesLeft)==0) || (memchr(currentBuf,int('\n'),bytesLeft)==0)) + { + delete [] receiveBuffer; + error(ERR_INTERNAL_SERVER,i18n("Received unexpected data from %1").arg(m_currentHost)); + return 0; + } + kdDebug(7101)<<"LANProtocol::lanReadDataFromServer: processing "<<currentBuf; + //since we check for 0 and \n with memchr() we can be sure + //at this point that tmpBuf is correctly terminated + int length=strlen(currentBuf)+1; + if (length<(4*1024)) + sscanf(currentBuf,"%u %s\n",&tmpIP,tmpName); + else + { + kdDebug(7101)<<"LANProtocol::lanReadDataFromServer: buffer overflow attempt detected, aborting"<<endl; + break; + } + + bytesLeft-=length; + currentBuf+=length; + if ((bytesLeft==0) && ((tmpIP==0) ||(tmpIP==1)) && (strstr(tmpName,"succeeded")!=0)) + { + kdDebug(7101)<<"LANProtocol::lanReadDataFromServer: succeeded"<<endl; + } + else if (tmpIP!=2) + { + kdDebug(7101)<<"LANProtocol::lanReadDataFromServer: listing host: "<<tmpName<<" with ip: "<<tmpIP<<endl; + UDSAtom atom; + + atom.m_uds = TDEIO::UDS_NAME; + if (m_shortHostnames) + { + if (inet_addr(tmpName)!=-1) + atom.m_str=tmpName; + else + { + sscanf(tmpName,"%[^.]",tmpHostname); + kdDebug(7101)<<"LANProtocol::lanReadDataFromServer: Hostname of " << tmpName << " is " << tmpHostname << "\n"; + atom.m_str = tmpHostname; + } + } + else + atom.m_str = tmpName; + + entry.append( atom ); + atom.m_uds = TDEIO::UDS_SIZE; + atom.m_long = 1024; + entry.append(atom); + atom.m_uds = TDEIO::UDS_ACCESS; + atom.m_long = S_IRUSR | S_IRGRP | S_IROTH ; + //atom.m_long = S_IRUSR | S_IXUSR | S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH; + entry.append(atom); + atom.m_uds = TDEIO::UDS_FILE_TYPE; + atom.m_long = S_IFDIR; // it is always a directory + entry.append( atom ); + listEntry(entry,false); + } + } + + listEntry( entry, true ); // ready + delete [] receiveBuffer; + return 1; +} + +int LANProtocol::rlanReadDataFromServer() +{ + kdDebug(7101)<<"RLANProtocol::readDataFromServer"<<endl; + + int sockFD=socket(AF_LOCAL, SOCK_STREAM, 0); + sockaddr_un addr; + memset((char*)&addr,0,sizeof(addr)); + addr.sun_family=AF_LOCAL; + TQCString socketname="/tmp/resLisa-"; + + struct passwd *user = getpwuid( getuid() ); + if ( user ) + socketname+=user->pw_name; + else + //should never happen + socketname+="???"; + + strlcpy(addr.sun_path,socketname,sizeof(addr.sun_path)); + int result=::connect(sockFD,(sockaddr*)&addr, sizeof(addr)); + + kdDebug(7101)<<"readDataFromServer(): result: "<<result<<" name: "<<addr.sun_path<<" socket: "<<sockFD<<endl; + + if (result!=0) + { + ::close(sockFD); + TDEProcess proc; + proc<<"reslisa"; + + bool ok=proc.start(TDEProcess::DontCare); + if (!ok) + { + error( ERR_CANNOT_LAUNCH_PROCESS, "reslisa" ); + return 0; + } + //wait a moment + //reslisa starts tde-config, then does up to 64 + //name lookups and then starts to ping + //results won't be available before this is done + kdDebug(7101)<<"sleeping..."<<endl; + ::sleep(1); + kdDebug(7101)<<"sleeping again..."<<endl; + ::sleep(5); + kdDebug(7101)<<"woke up "<<endl; + sockFD=socket(AF_LOCAL, SOCK_STREAM, 0); + + memset((char*)&addr,0,sizeof(addr)); + addr.sun_family=AF_LOCAL; + strlcpy(addr.sun_path,socketname,sizeof(addr.sun_path)); + + kdDebug(7101)<<"connecting..."<<endl; + result=::connect(sockFD,(sockaddr*)&addr, sizeof(addr)); + kdDebug(7101)<<"readDataFromServer() after starting reslisa: result: "<<result<<" name: "<<addr.sun_path<<" socket: "<<sockFD<<endl; + if (result!=0) + { + error( ERR_CANNOT_OPEN_FOR_READING, socketname ); + return 0; + } + kdDebug(7101)<<"succeeded :-)"<<endl; + } + + int receivedBytes(0); + char* receiveBuffer(0); + char tmpBuf[64*1024]; + int bytesRead(0); + do + { + fd_set tmpFDs; + FD_ZERO(&tmpFDs); + FD_SET(sockFD,&tmpFDs); + timeval tv; + tv.tv_sec = 1; + tv.tv_usec = 0; + select(sockFD+1,&tmpFDs,0,0,&tv); + if (FD_ISSET(sockFD,&tmpFDs)) + { + bytesRead=::read(sockFD,tmpBuf,64*1024); + kdDebug(7101)<<"RLANProtocol::readDataFromServer: read "<<bytesRead<<" bytes"<<endl; + + if (bytesRead>0) + { + char *newBuf=new char[receivedBytes+bytesRead]; + if (receiveBuffer!=0) memcpy(newBuf,receiveBuffer,receivedBytes); + memcpy(newBuf+receivedBytes,tmpBuf,bytesRead); + receivedBytes+=bytesRead; + if (receiveBuffer!=0) delete [] receiveBuffer; + receiveBuffer=newBuf; + } + } + } while (bytesRead>0); + ::close(sockFD); + + + if ((bytesRead<0) || (receivedBytes<4)) + { + delete [] receiveBuffer; + error(ERR_CANNOT_OPEN_FOR_READING,socketname); + return 0; + } + + UDSEntry entry; + + char *currentBuf=receiveBuffer; + int bytesLeft=receivedBytes; + //this should be large enough for a name + char tmpName[4*1024]; + //this should be large enough for the hostname + char tmpHostname[4*1024]; + while (bytesLeft>0) + { + int tmpIP=2; + tmpName[0]='\0'; + if ((memchr(currentBuf,0,bytesLeft)==0) || (memchr(currentBuf,int('\n'),bytesLeft)==0)) + { + delete [] receiveBuffer; + error(ERR_INTERNAL_SERVER,i18n("Received unexpected data from %1").arg(socketname.data())); + return 0; + } + kdDebug(7101)<<"RLANProtocol::readDataFromServer: processing "<<currentBuf; + //since we check for 0 and \n with memchr() we can be sure + //at this point that tmpBuf is correctly terminated + int length=strlen(currentBuf)+1; + if (length<(4*1024)) + sscanf(currentBuf,"%u %s\n",&tmpIP,tmpName); + else + { + kdDebug(7101)<<"RLANProtocol::readDataFromServer: buffer overflow attempt detected, aborting"<<endl; + break; + } + + bytesLeft-=length; + currentBuf+=length; + if ((bytesLeft==0) && ((tmpIP==0) ||(tmpIP==1)) && (strstr(tmpName,"succeeded")!=0)) + { + kdDebug(7101)<<"RLANProtocol::readDataFromServer: succeeded"<<endl; + } + else if (tmpIP!=2) + { + kdDebug(7101)<<"RLANProtocol::readDataFromServer: listing host: "<<tmpName<<" with ip: "<<tmpIP<<endl; + UDSAtom atom; + + atom.m_uds = TDEIO::UDS_NAME; + if (m_shortHostnames) + { + if (inet_addr(tmpName)!=-1) + atom.m_str=tmpName; + else + { + sscanf(tmpName,"%[^.]",tmpHostname); + kdDebug(7101)<<"LANProtocol::lanReadDataFromServer: Hostname of " << tmpName << " is " << tmpHostname << "\n"; + atom.m_str = tmpHostname; + } + } + else + atom.m_str = tmpName; + entry.append( atom ); + atom.m_uds = TDEIO::UDS_SIZE; + atom.m_long = 1024; + entry.append(atom); + atom.m_uds = TDEIO::UDS_ACCESS; + atom.m_long = S_IRUSR | S_IRGRP | S_IROTH ; + //atom.m_long = S_IRUSR | S_IXUSR | S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH; + entry.append(atom); + atom.m_uds = TDEIO::UDS_FILE_TYPE; + atom.m_long = S_IFDIR; // it is always a directory + entry.append( atom ); + listEntry(entry,false); + } + } + + listEntry( entry, true ); // ready + delete [] receiveBuffer; + return 1; +} + +int LANProtocol::checkHost(const TQString& host) +{ + kdDebug(7101)<<"LAN::checkHost() "<<host<<endl; + + TQString hostUpper=host.upper(); + HostInfo* hostInfo=m_hostInfoCache[hostUpper]; + if (hostInfo!=0) + { + kdDebug(7101)<<"LAN::checkHost() getting from cache"<<endl; + //this entry is too old, we delete it ! + if ((time(0)-hostInfo->created)>m_maxAge) + { + kdDebug(7101)<<"LAN::checkHost() cache content too old, deleting it"<<endl; + m_hostInfoCache.remove(hostUpper); + hostInfo=0; + } + } + if (hostInfo==0) + { + hostInfo=new HostInfo; + in_addr ip; + + struct hostent *hp=gethostbyname(host.latin1()); + if (hp==0) + { + error( ERR_UNKNOWN_HOST, host.latin1() ); + delete hostInfo; + return 0; + } + memcpy(&ip, hp->h_addr, sizeof(ip)); + + for (int i=0; i<KIOLAN_MAX; i++) + { + int result(0); + if (m_protocolInfo[i].enabled==PORTSETTINGS_DISABLE) + result=0; + else if (m_protocolInfo[i].enabled==PORTSETTINGS_PROVIDE) + result=1; + else if (m_protocolInfo[i].enabled==PORTSETTINGS_CHECK) + result=checkPort(m_protocolInfo[i].ports,ip); + + //host not reachable + if (result==-1) + { + delete hostInfo; + hostInfo=0; + error( ERR_UNKNOWN_HOST, host.latin1() ); + return 0; + } + hostInfo->services[i]=result; + } + hostInfo->created=time(0); + m_hostInfoCache.insert(hostUpper,hostInfo); + } + //here hostInfo is always != 0 + if (hostInfo==0) + { + error( ERR_INTERNAL, "hostInfo==0" ); + return 0; + } + + UDSEntry entry; + for (int i=0; i<KIOLAN_MAX; i++) + { + if (hostInfo->services[i]==1) + { + kdDebug(7101)<<"LAN::checkHost(): Host ["<<hostUpper<<"] Service ["<<m_protocolInfo[i].name<<"]"<<endl; + UDSAtom atom; + // name + atom.m_uds = TDEIO::UDS_NAME; + atom.m_str = m_protocolInfo[i].name; + entry.append( atom ); + // size + atom.m_uds = TDEIO::UDS_SIZE; + atom.m_long = 1024; + entry.append(atom); + // access permissions + atom.m_uds = TDEIO::UDS_ACCESS; + atom.m_long = S_IRUSR | S_IRGRP | S_IROTH ; + //atom.m_long = S_IRUSR | S_IXUSR | S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH; + entry.append(atom); + // file type + atom.m_uds = TDEIO::UDS_FILE_TYPE; + if (strcmp(m_protocolInfo[i].name,"HTTP")==0) + { + // normal file -- if we called stat(2) on this, + // this flag would be set in the st_mode field of struct stat + atom.m_long=S_IFREG; + entry.append(atom); + + // also define the mime-type for this file + atom.m_uds = TDEIO::UDS_MIME_TYPE; + atom.m_str="text/html"; + entry.append( atom ); + } + else + { + // directory -- if we called stat(2) on this, then this + // flag would be set in the st_mode field of the struct stat + atom.m_long = S_IFDIR; // it is always a directory + entry.append(atom); + + // also set the mime-type + atom.m_uds = TDEIO::UDS_MIME_TYPE; + atom.m_str="inode/directory"; + entry.append( atom ); + } + listEntry(entry,false); + } + } + listEntry( entry, true ); // ready + return 1; +} + +// Check if a service is running on a host with IP address 'ip' +// by checking all the ports in '_ports', using a non-blocking connect. +// Right now -- assume if *any* of these ports are active, +// the service is active. +int LANProtocol::checkPort( TQValueVector<int>& _ports, in_addr ip ) +{ + int _port=0; + struct sockaddr_in to_scan; + + to_scan.sin_family = AF_INET; + to_scan.sin_addr = ip; + + for (TQValueVector<int>::iterator i= _ports.begin(); i != _ports.end(); i++) + { + _port=(*i); + kdDebug(7101)<<"LANProtocol::checkPort: "<<_port<<endl; + to_scan.sin_port = htons(_port); + // open a TCP socket + int mysocket = ::socket (AF_INET, SOCK_STREAM, IPPROTO_TCP); + if (mysocket< 0 ) + { + std::cerr << "LanProt::checkPort: Error while opening Socket" << std::endl; + ::close( mysocket ); + return 0; + } + //make the socket non blocking + long int options = O_NONBLOCK | ::fcntl(mysocket, F_GETFL); + if (::fcntl( mysocket, F_SETFL, options )!=0) + { + std::cerr << "LanProt::checkPort: Error making it nonblocking"<< std::endl; + ::close( mysocket ); + return 0; + } + int result=connect( mysocket, (struct sockaddr *) &to_scan, sizeof( to_scan )); + //it succeeded immediately + if (result==0) + { + std::cerr<<"LANProtocol::checkPort("<<_port<<") connect succeeded immediately"<<std::endl; + ::shutdown( mysocket, SHUT_RDWR ); + return 1; + } + //it failed + if ((result<0) && (errno!=EINPROGRESS)) + { + // errno was not EINPROGRESS, so there is some serious problem + ::shutdown( mysocket, SHUT_RDWR ); + // maybe some other port will work + continue; + } + // last errno was EINPROGRESS, so we should select() on socket + // and wait for the final verdict + timeval tv; + tv.tv_sec=5; + tv.tv_usec=0; + fd_set rSet, wSet; + FD_ZERO(&rSet); + FD_SET(mysocket,&rSet); + wSet=rSet; + //timeout or error + result=select(mysocket+1,&rSet,&wSet,0,&tv); + ::shutdown( mysocket, SHUT_RDWR ); + if (result==1) + return 1; + } + // gosh, no port worked + return 0; + +} + +void LANProtocol::setHost( const TQString& host, int port, const TQString& , const TQString& ) +{ + if (m_isLanIoslave) + { + m_currentHost=host; + if (port==0) + m_port=7741; + else + m_port=port; + kdDebug(7101)<<"LANProtocol::setHost: "<<m_currentHost<<endl; + } + else + { + if (!host.isEmpty()) + error(ERR_MALFORMED_URL,i18n("No hosts allowed in rlan:/ URL")); + } +} + +void LANProtocol::mimetype( const KURL& url) +{ + kdDebug(7101)<<"LANProtocol::mimetype -"<<url.prettyURL()<<"-"<<endl; + TQString path( TQFile::encodeName(url.path())); + TQStringList pathList=TQStringList::split( "/",path); + if ((pathList.count()==2) && (pathList[1].upper()=="HTTP")) + { + //kdDebug(7101)<<"LANProtocol::mimeType text/html"<<endl; + mimeType("text/html"); + } + else + { + mimeType("inode/directory"); + //kdDebug(7101)<<"LANProtocol::mimeType inode/directory"<<endl; + } + finished(); +} + +void LANProtocol::listDir( const KURL& _url) +{ + KURL url(_url); + TQString path( TQFile::encodeName(url.path())); + if (path.isEmpty()) + { + url.setPath("/"); + redirection(url); + finished(); + return; + } + if ((m_currentHost.isEmpty()) && (m_isLanIoslave)) + { + url.setHost(m_defaultLisaHost); + redirection(url); + finished(); + return; + } + kdDebug(7101)<<"LANProtocol::listDir: host: "<<m_currentHost<<" port: "<<m_port<<" path: "<<path<<endl; + TQStringList pathList=TQStringList::split("/", path); + kdDebug(7101)<<"parts are: "<<endl; + for (TQStringList::Iterator it=pathList.begin(); it !=pathList.end(); it++) + kdDebug(7101)<<"-"<<(*it)<<"-"<<endl; + if (pathList.count()>2) + { + kdDebug(7101)<<"LANProtocol::listDir: too deep path: "<<pathList.count()<<endl; + error(ERR_DOES_NOT_EXIST,_url.prettyURL()); + return; + } + int succeeded(0); + if (path=="/") + { + //get the stuff from the netland server + succeeded=readDataFromServer(); + } + else if (pathList.count()==1) + { + //check the ports and stuff + succeeded=checkHost(pathList[0]); + } + else + { + kdDebug(7101)<<"LANProtocol::listDir: trying to redirect"<<endl; + int isSupportedProtocol(0); + for (int i=0; i<KIOLAN_MAX; i++) + { + if (pathList[1].upper()==m_protocolInfo[i].name) + { + isSupportedProtocol=m_protocolInfo[i].enabled; + break; + } + } + if (isSupportedProtocol==PORTSETTINGS_DISABLE) + { + kdDebug(7101)<<"LANProtocol::listDir: protocol not enabled "<<endl; + error(ERR_DOES_NOT_EXIST,_url.prettyURL()); + return; + } + //redirect it + KURL newUrl(pathList[1]+"://"+pathList[0]); + redirection(newUrl); + succeeded=1; + } + if (succeeded) finished(); +} + +void LANProtocol::stat( const KURL & url) +{ + kdDebug(7101)<<"LANProtocol::stat: "<<endl; + UDSEntry entry; + UDSAtom atom; + + atom.m_uds = TDEIO::UDS_NAME; + atom.m_str = url.path(); + entry.append( atom ); + atom.m_uds = TDEIO::UDS_SIZE; + atom.m_long = 1024; + entry.append(atom); + + atom.m_uds = TDEIO::UDS_ACCESS; + atom.m_long = S_IRUSR | S_IRGRP | S_IROTH ; + //atom.m_long = S_IRUSR | S_IXUSR | S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH; + entry.append(atom); + + + TQString path( TQFile::encodeName(url.path())); + TQStringList pathList=TQStringList::split( "/",path); + if ((pathList.count()==2) && (pathList[1].upper()=="HTTP")) + { + atom.m_uds = TDEIO::UDS_FILE_TYPE; + atom.m_long=S_IFREG; + entry.append(atom); + atom.m_uds = TDEIO::UDS_MIME_TYPE; + atom.m_str="text/html"; + //kdDebug(7101)<<"LANProtocol::stat: http is reg file"<<endl; + entry.append( atom ); + } + else + { + atom.m_uds = TDEIO::UDS_FILE_TYPE; + atom.m_long = S_IFDIR; // it is always a directory + entry.append(atom); + atom.m_uds = TDEIO::UDS_MIME_TYPE; + atom.m_str="inode/directory"; + //kdDebug(7101)<<"LANProtocol::stat: is dir"<<endl; + entry.append( atom ); + } + + statEntry( entry ); + finished(); +} + +void LANProtocol::get(const KURL& url ) +{ + TQString path(TQFile::encodeName(url.path())); + + kdDebug(7101)<<"LANProtocol::get: "<<path<<endl; + TQStringList pathList=TQStringList::split("/", path); + kdDebug(7101)<<"parts are: "<<endl; + for (TQStringList::Iterator it=pathList.begin(); it !=pathList.end(); it++) + kdDebug(7101)<<"-"<<(*it)<<"-"<<endl; + if ((pathList.count()!=2) || (pathList[1].upper()!="HTTP")) + { + kdDebug(7101)<<"LANProtocol::get: invalid url: "<<pathList.count()<<endl; + error(ERR_DOES_NOT_EXIST,url.prettyURL()); + return; + } + KURL newUrl("http://"+pathList[0]); + redirection(newUrl); + finished(); + return; +} |