File indexing completed on 2024-11-10 04:30:38

 /*
     SPDX-License-Identifier: GPL-2.0-or-later
     SPDX-FileCopyrightText: 2000 Caldera Systems Inc.
     SPDX-FileCopyrightText: 2018-2022 Harald Sitter <sitter@kde.org>
     SPDX-FileContributor: Matthew Peterson <mpeterson@caldera.com>
 */
 
 #include "kio_smb.h"
 #include "smburl.h"
 
 #include <utility>
 
 #include <KDNSSD/RemoteService>
 #include <KDNSSD/ServiceBrowser>
 #include <KIO/Job>
 #include <KLocalizedString>
 
 #include <QEventLoop>
 #include <QTimer>
 
 #include <grp.h>
 #include <pwd.h>
 
 #include "dnssddiscoverer.h"
 #include "smbcdiscoverer.h"
 #include "wsdiscoverer.h"
 #include <config-runtime.h>
 
 using namespace KIO;
 
 int SMBWorker::cache_stat(const SMBUrl &url, struct stat *st)
 {
     int cacheStatErr = 0;
     int result = smbc_stat(url.toSmbcUrl(), st);
     if (result == 0) {
         cacheStatErr = 0;
     } else {
         cacheStatErr = errno;
     }
     qCDebug(KIO_SMB_LOG) << "size " << static_cast<KIO::filesize_t>(st->st_size);
     return cacheStatErr;
 }
 
 int SMBWorker::browse_stat_path(const SMBUrl &url, UDSEntry &udsentry)
 {
     int cacheStatErr = cache_stat(url, &st);
     if (cacheStatErr == 0) {
         return statToUDSEntry(url, st, udsentry);
     }
 
     return cacheStatErr;
 }
 
 int SMBWorker::statToUDSEntry(const QUrl &url, const struct stat &st, KIO::UDSEntry &udsentry)
 {
     if (!S_ISDIR(st.st_mode) && !S_ISREG(st.st_mode)) {
         qCDebug(KIO_SMB_LOG) << "mode: " << st.st_mode;
         warning(
             i18n("%1:\n"
                  "Unknown file type, neither directory or file.",
                  url.toDisplayString()));
         return EINVAL;
     }
 
     if (!S_ISDIR(st.st_mode)) {
         // Awkwardly documented at
         //    https://www.samba.org/samba/docs/using_samba/ch08.html
         // libsmb_stat.c assigns special meaning to +x permissions
         // (obviously only on files, all dirs are +x so this hacky representation
         //  wouldn't work!):
         // - S_IXUSR = DOS archive: This file has been touched since the last DOS backup was performed on it.
         // - S_IXGRP = DOS system: This file has a specific purpose required by the operating system.
         // - S_IXOTH = DOS hidden: This file has been marked to be invisible to the user, unless the operating system is explicitly set to show it.
         // Only hiding has backing through KIO right now.
         if (st.st_mode & S_IXOTH) { // DOS hidden
             udsentry.fastInsert(KIO::UDSEntry::UDS_HIDDEN, true);
         }
     }
 
     // UID and GID **must** not be mapped. The values returned by libsmbclient are
     // simply the getuid/getgid of the process. They mean absolutely nothing.
     // Also see libsmb_stat.c.
     // Related: https://bugs.kde.org/show_bug.cgi?id=212801
 
     // POSIX Access mode must not be mapped either!
     // It's meaningless for smb shares and downright disadvantageous.
     // The mode attributes outside the ones used and document above are
     // useless. The only one actively set is readonlyness.
     //
     // BUT the READONLY attribute does nothing on NT systems:
     // https://support.microsoft.com/en-us/help/326549/you-cannot-view-or-change-the-read-only-or-the-system-attributes-of-fo
     // The Read-only and System attributes is only used by Windows Explorer to determine
     // whether the folder is a special folder, such as a system folder that has its view
     // customized by Windows (for example, My Documents, Favorites, Fonts, Downloaded Program Files),
     // or a folder that you customized by using the Customize tab of the folder's Properties dialog box.
     //
     // As such respecting it on a KIO level is actually wrong as it doesn't indicate actual
     // readonlyness since the 90s and causes us to show readonly UI states when in fact
     // the directory is perfectly writable.
     // https://bugs.kde.org/show_bug.cgi?id=414482
     //
     // Should we ever want to parse desktop.ini like we do .directory we'd only want to when a
     // dir is readonly as per the above microsoft support article.
     // Also see:
     // https://docs.microsoft.com/en-us/windows/win32/shell/how-to-customize-folders-with-desktop-ini
 
     udsentry.fastInsert(KIO::UDSEntry::UDS_FILE_TYPE, st.st_mode & S_IFMT);
     udsentry.fastInsert(KIO::UDSEntry::UDS_SIZE, st.st_size);
     udsentry.fastInsert(KIO::UDSEntry::UDS_MODIFICATION_TIME, st.st_mtime);
     udsentry.fastInsert(KIO::UDSEntry::UDS_ACCESS_TIME, st.st_atime);
     // No, st_ctime is not UDS_CREATION_TIME...
 
     return 0;
 }
 
 WorkerResult SMBWorker::stat(const QUrl &kurl)
 {
     qCDebug(KIO_SMB_LOG) << kurl;
     // make a valid URL
     QUrl url = checkURL(kurl);
 
     // if URL is not valid we have to redirect to correct URL
     if (url != kurl) {
         qCDebug(KIO_SMB_LOG) << "redirection " << url;
         redirection(url);
         return WorkerResult::pass();
     }
 
     m_current_url = url;
 
     UDSEntry udsentry;
     // Set name
     udsentry.fastInsert(KIO::UDSEntry::UDS_NAME, kurl.fileName());
 
     switch (m_current_url.getType()) {
     case SMBURLTYPE_UNKNOWN:
         return WorkerResult::fail(ERR_MALFORMED_URL, url.toDisplayString());
     case SMBURLTYPE_PRINTER:
         return WorkerResult::fail(ERR_UNSUPPORTED_ACTION, url.toDisplayString());
     case SMBURLTYPE_ENTIRE_NETWORK:
     case SMBURLTYPE_WORKGROUP_OR_SERVER:
         udsentry.fastInsert(KIO::UDSEntry::UDS_FILE_TYPE, S_IFDIR);
         statEntry(udsentry);
         return WorkerResult::pass();
     case SMBURLTYPE_SHARE_OR_PATH: {
         int ret = browse_stat_path(m_current_url, udsentry);
 
         if (ret == EPERM || ret == EACCES || workaroundEEXIST(ret)) {
             SMBUrl smbUrl(url);
 
             const int passwordError = checkPassword(smbUrl);
             if (passwordError == KJob::NoError) {
                 redirection(smbUrl);
                 return WorkerResult::pass();
             }
             if (passwordError == KIO::ERR_USER_CANCELED) {
                 return reportError(url, ret);
             }
             return WorkerResult::fail(passwordError, url.toString());
         }
         if (ret != 0) {
             qCDebug(KIO_SMB_LOG) << "stat() error" << ret << url;
             return reportError(url, ret);
         }
 
         statEntry(udsentry);
         return WorkerResult::pass();
     }
     }
 
     qCDebug(KIO_SMB_LOG) << "UNKNOWN " << url;
     return WorkerResult::pass();
 }
 
 // TODO: complete checking <-- what does that even mean?
 // TODO: why is this not part of SMBUrl or at the very least URL validation should
 //    be 100% shared between this and SMBUrl. Notably SMBUrl has code that looks
 //    to do a similar thing but is much less complete.
 QUrl SMBWorker::checkURL(const QUrl &kurl_) const
 {
     qCDebug(KIO_SMB_LOG) << "checkURL " << kurl_;
 
     QUrl kurl(kurl_);
     // We treat cifs as an alias but need to translate it to smb.
     // https://bugs.kde.org/show_bug.cgi?id=327295
     // It's not IANA registered and also libsmbc internally expects
     // smb URIs so we do very broadly coerce cifs to smb.
     // Also see SMBUrl.
     if (kurl.scheme() == "cifs") {
         kurl.setScheme("smb");
     }
 
     // For WS-Discovered hosts we assume they'll respond to DNSSD names on .local but
     // they may only respond to llmnr/netbios names. Transparently fall back.
     //
     // Desktop linuxes tend to have llmnr disabled, by contrast win10 has dnssd enabled,
     // so chances are we'll be able to find a host.local more reliably.
     // Attempt to resolve foo.local natively, if that works use it, otherwise default to
     // the presumed LLMNR/netbios name found during discovery.
     // This should then yield reasonable results with any combination of WSD/DNSSD/LLMNR support.
     // - WSD+Avahi (on linux)
     // - WSD+Win10 (i.e. dnssd + llmnr)
     // - WSD+CrappyNAS (e.g. llmnr or netbios only)
     //
     // NB: smbc has no way to resolve a name without also triggering auth etc.: we must
     //   rely on the system's ability to resolve DNSSD for this check.
     const QLatin1String wsdSuffix(".kio-discovery-wsd");
     if (kurl.host().endsWith(wsdSuffix)) {
         QString host = kurl.host();
         host.chop(wsdSuffix.size());
         const QString dnssd(host + ".local");
         auto dnssdHost = KDNSSD::ServiceBrowser::resolveHostName(dnssd);
         if (!dnssdHost.isNull()) {
             qCDebug(KIO_SMB_LOG) << "Resolved DNSSD name:" << dnssd;
             host = dnssd;
         } else {
             qCDebug(KIO_SMB_LOG) << "Failed to resolve DNSSD name:" << dnssd;
             qCDebug(KIO_SMB_LOG) << "Falling back to LLMNR name:" << host;
         }
         kurl.setHost(host);
     }
 
     QString surl = kurl.url();
     // transform any links in the form smb:/ into smb://
     if (surl.startsWith(QLatin1String("smb:/"))) {
         if (surl.length() == 5) {
             return QUrl("smb://");
         }
         if (surl.at(5) != '/') {
             surl = "smb://" + surl.mid(5);
             qCDebug(KIO_SMB_LOG) << "checkURL return1 " << surl << " " << QUrl(surl);
             return QUrl(surl);
         }
     }
     if (surl == QLatin1String("smb://")) {
         return kurl; // unchanged
     }
 
     // smb:// normally have no userinfo
     // we must redirect ourself to remove the username and password
     if (surl.contains('@') && !surl.contains("smb://")) {
         QUrl url(kurl);
         url.setPath('/' + kurl.url().right(kurl.url().length() - kurl.url().indexOf('@') - 1));
         QString userinfo = kurl.url().mid(5, kurl.url().indexOf('@') - 5);
         if (userinfo.contains(':')) {
             url.setUserName(userinfo.left(userinfo.indexOf(':')));
             url.setPassword(userinfo.right(userinfo.length() - userinfo.indexOf(':') - 1));
         } else {
             url.setUserName(userinfo);
         }
         qCDebug(KIO_SMB_LOG) << "checkURL return2 " << url;
         return url;
     }
 
     // if there's a valid host, don't have an empty path
     QUrl url(kurl);
 
     if (url.path().isEmpty()) {
         url.setPath("/");
     }
 
     qCDebug(KIO_SMB_LOG) << "checkURL return3 " << url;
     return url;
 }
 
 SMBWorker::SMBError SMBWorker::errnumToKioError(const SMBUrl &url, const int errNum)
 {
     qCDebug(KIO_SMB_LOG) << "errNum" << errNum;
 
     switch (errNum) {
     case ENOENT:
         if (url.getType() == SMBURLTYPE_ENTIRE_NETWORK) {
             return SMBError{ERR_WORKER_DEFINED, i18n("Unable to find any workgroups in your local network. This might be caused by an enabled firewall.")};
         }
         return SMBError{ERR_DOES_NOT_EXIST, url.toDisplayString()};
 #ifdef ENOMEDIUM
     case ENOMEDIUM:
         return SMBError{ERR_WORKER_DEFINED, i18n("No media in device for %1", url.toDisplayString())};
 #endif
 #ifdef EHOSTDOWN
     case EHOSTDOWN:
 #endif
     case ECONNREFUSED:
         return SMBError{ERR_WORKER_DEFINED, i18n("Could not connect to host for %1", url.toDisplayString())};
     case ENOTDIR:
         return SMBError{ERR_CANNOT_ENTER_DIRECTORY, url.toDisplayString()};
     case EFAULT:
     case EINVAL:
         return SMBError{ERR_DOES_NOT_EXIST, url.toDisplayString()};
     case EPERM:
     case EACCES:
         return SMBError{ERR_ACCESS_DENIED, url.toDisplayString()};
     case EIO:
     case ENETUNREACH:
         if (url.getType() == SMBURLTYPE_ENTIRE_NETWORK || url.getType() == SMBURLTYPE_WORKGROUP_OR_SERVER) {
             return SMBError{ERR_WORKER_DEFINED, i18n("Error while connecting to server responsible for %1", url.toDisplayString())};
         }
         return SMBError{ERR_CONNECTION_BROKEN, url.toDisplayString()};
     case ENOMEM:
         return SMBError{ERR_OUT_OF_MEMORY, url.toDisplayString()};
     case ENODEV:
         return SMBError{ERR_WORKER_DEFINED, i18n("Share could not be found on given server")};
     case EBADF:
         return SMBError{ERR_INTERNAL, i18n("Bad file descriptor")};
     case ETIMEDOUT:
         return SMBError{ERR_SERVER_TIMEOUT, url.host()};
     case ENOTEMPTY:
         return SMBError{ERR_CANNOT_RMDIR, url.toDisplayString()};
 #ifdef ENOTUNIQ
     case ENOTUNIQ:
         return SMBError{ERR_WORKER_DEFINED,
                         i18n("The given name could not be resolved to a unique server. "
                              "Make sure your network is setup without any name conflicts "
                              "between names used by Windows and by UNIX name resolution.")};
 #endif
     case ECONNABORTED:
         return SMBError{ERR_CONNECTION_BROKEN, url.host()};
     case EHOSTUNREACH:
         return SMBError{ERR_CANNOT_CONNECT,
                         i18nc("@info:status smb failed to reach the server (e.g. server offline or network failure). %1 is an ip address or hostname",
                               "%1: Host unreachable",
                               url.host())};
     case 0: // success
         return SMBError{ERR_INTERNAL,
                         i18n("libsmbclient reported an error, but did not specify "
                              "what the problem is. This might indicate a severe problem "
                              "with your network - but also might indicate a problem with "
                              "libsmbclient.\n"
                              "If you want to help us, please provide a tcpdump of the "
                              "network interface while you try to browse (be aware that "
                              "it might contain private data, so do not post it if you are "
                              "unsure about that - you can send it privately to the developers "
                              "if they ask for it)")};
     default:
         return SMBError{ERR_INTERNAL,
                         i18nc("%1 is an error number, %2 either a pretty string or the number",
                               "Unknown error condition: [%1] %2",
                               QString::number(errNum),
                               QString::fromLocal8Bit(strerror(errNum)))};
     }
 }
 
 WorkerResult SMBWorker::reportError(const SMBUrl &url, const int errNum)
 {
     const SMBError smbErr = errnumToKioError(url, errNum);
     return WorkerResult::fail(smbErr.kioErrorId, smbErr.errorString);
 }
 
 void SMBWorker::reportWarning(const SMBUrl &url, const int errNum)
 {
     const SMBError smbErr = errnumToKioError(url, errNum);
     const QString errorString = buildErrorString(smbErr.kioErrorId, smbErr.errorString);
 
     warning(xi18n("Error occurred while trying to access %1<nl/>%2", url.url(), errorString));
 }
 
 WorkerResult SMBWorker::listDir(const QUrl &kurl)
 {
     qCDebug(KIO_SMB_LOG) << kurl;
 
     // check (correct) URL
     QUrl url = checkURL(kurl);
     // if URL is not valid we have to redirect to correct URL
     if (url != kurl) {
         redirection(url);
         return WorkerResult::pass();
     }
 
     m_current_url = kurl;
 
     QEventLoop e;
 
     UDSEntryList list;
     QStringList discoveredNames;
 
     const auto flushEntries = [this, &list]() {
         if (list.isEmpty()) {
             return;
         }
         listEntries(list);
         list.clear();
     };
 
     // Since WorkerBase has no eventloop it wont publish results
     // on a timer, since we do not know how long our discovery
     // will take this is super meh because we may appear
     // stuck for a while. Implement our own listing system
     // based on QTimer to mitigate.
     QTimer sendTimer;
     sendTimer.setInterval(300);
     connect(&sendTimer, &QTimer::timeout, this, flushEntries);
     sendTimer.start();
 
     QSharedPointer<SMBCDiscoverer> smbc(new SMBCDiscoverer(m_current_url, &e, this));
 
     QVector<QSharedPointer<Discoverer>> discoverers;
     discoverers << smbc;
 
     auto appendDiscovery = [&](const Discovery::Ptr &discovery) {
         if (discoveredNames.contains(discovery->udsName(), Qt::CaseInsensitive)) {
             return;
         }
         // Not tracking hosts. Tracking hosts means **guessing** if foo.local
         // and foo and foo.kio-discovery-wsd will actually resolve to the same
         // IP address, which is tricky to do at best. In the interest of efficiency
         // I'd rather have the de-duplication requirement be that the name of
         // two competing service discovery systems needs to be the same.
         discoveredNames << discovery->udsName();
         list.append(discovery->toEntry());
     };
 
     auto maybeFinished = [&] { // finishes if all discoveries finished
         bool allFinished = true;
         for (const auto &discoverer : std::as_const(discoverers)) {
             allFinished = allFinished && discoverer->isFinished();
         }
         if (allFinished) {
             flushEntries();
             e.quit();
         }
     };
 
     connect(smbc.data(), &SMBCDiscoverer::newDiscovery, this, appendDiscovery);
     connect(smbc.data(), &SMBCDiscoverer::finished, this, maybeFinished);
 
     // Run service discovery if the path is root. This augments
     // "native" results from libsmbclient.
     // Also, should native resolution have encountered an error it will not matter.
     if (m_current_url.getType() == SMBURLTYPE_ENTIRE_NETWORK) {
         QSharedPointer<DNSSDDiscoverer> dnssd(new DNSSDDiscoverer);
         QSharedPointer<WSDiscoverer> wsd(new WSDiscoverer);
         discoverers << dnssd << wsd;
 
         qCDebug(KIO_SMB_LOG) << "Adding modern discovery (dnssd/wsdiscovery)";
 
         connect(dnssd.data(), &DNSSDDiscoverer::newDiscovery, this, appendDiscovery);
         connect(wsd.data(), &WSDiscoverer::newDiscovery, this, appendDiscovery);
 
         connect(dnssd.data(), &DNSSDDiscoverer::finished, this, maybeFinished);
         connect(wsd.data(), &WSDiscoverer::finished, this, maybeFinished);
 
         dnssd->start();
         wsd->start();
 
         qCDebug(KIO_SMB_LOG) << "Modern discovery set up.";
     }
 
     qCDebug(KIO_SMB_LOG) << "Starting discovery.";
     smbc->start();
     e.exec();
 
     qCDebug(KIO_SMB_LOG) << "Discovery finished.";
 
     if (m_current_url.getType() != SMBURLTYPE_ENTIRE_NETWORK && smbc->error() != 0) {
         // not smb:// and had an error -> handle it
         const int err = smbc->error();
         if (err == EPERM || err == EACCES || err == EINVAL || workaroundEEXIST(err)) {
             qCDebug(KIO_SMB_LOG) << "trying checkPassword";
             const int passwordError = checkPassword(m_current_url);
             if (passwordError == KJob::NoError) {
                 redirection(m_current_url);
                 return WorkerResult::pass();
             }
             if (passwordError == KIO::ERR_USER_CANCELED) {
                 qCDebug(KIO_SMB_LOG) << "user cancelled password request";
                 return reportError(m_current_url, err);
             }
             qCDebug(KIO_SMB_LOG) << "generic password error:" << passwordError;
             return WorkerResult::fail(passwordError, m_current_url.toString());
         }
 
         qCDebug(KIO_SMB_LOG) << "reporting generic error:" << err;
         return reportError(m_current_url, err);
     }
 
     UDSEntry udsentry;
     if (smbc->dirWasRoot()) {
         udsentry.fastInsert(KIO::UDSEntry::UDS_FILE_TYPE, S_IFDIR);
         udsentry.fastInsert(KIO::UDSEntry::UDS_NAME, ".");
         udsentry.fastInsert(KIO::UDSEntry::UDS_ACCESS, (S_IRUSR | S_IRGRP | S_IROTH | S_IXUSR | S_IXGRP | S_IXOTH));
     } else {
         udsentry.fastInsert(KIO::UDSEntry::UDS_NAME, ".");
         const int statErr = browse_stat_path(m_current_url, udsentry);
         if (statErr != 0) {
             if (statErr == ENOENT || statErr == ENOTDIR) {
                 reportWarning(m_current_url, statErr);
             }
             // Create a default UDSEntry if we could not stat the actual directory
             udsentry.fastInsert(KIO::UDSEntry::UDS_FILE_TYPE, S_IFDIR);
             udsentry.fastInsert(KIO::UDSEntry::UDS_ACCESS, (S_IRWXU | S_IRWXG | S_IROTH | S_IXOTH));
         }
     }
     listEntry(udsentry);
 
     return WorkerResult::pass();
 }
 
 WorkerResult SMBWorker::fileSystemFreeSpace(const QUrl &url)
 {
     if (url.host().endsWith("kio-discovery-wsd")) {
         return WorkerResult::fail(KIO::ERR_UNKNOWN_HOST, url.url());
     }
     qCDebug(KIO_SMB_LOG) << url;
 
     // Avoid crashing in smbc_fstatvfs below when
     // requesting free space for smb:// which doesn't
     // make sense to do to begin with
     if (url.host().isEmpty()) {
         return WorkerResult::fail(KIO::ERR_CANNOT_STAT, url.url());
     }
 
     SMBUrl smbUrl = url;
 
     struct statvfs dirStat {
     };
     memset(&dirStat, 0, sizeof(struct statvfs));
     auto smbcUrl = smbUrl.toSmbcUrl(); // do not use temporary in function call, makes clazy happy
     const int err = smbc_statvfs(smbcUrl.data(), &dirStat);
     if (err < 0) {
         return WorkerResult::fail(KIO::ERR_CANNOT_STAT, url.url());
     }
 
     // libsmb_stat.c has very awkward conditional branching that results
     // in data meaning different things based on context:
     // A samba host with unix extensions has f_frsize==0 and the f_bsize is
     // the actual block size. Any other server (such as windows) has a non-zero
     // f_frsize denoting the amount of sectors in a block and the f_bsize is
     // the amount of bytes in a sector. As such frsize*bsize is the actual
     // block size.
     // This was also broken in different ways throughout history, so depending
     // on the specific libsmbc versions the milage will vary. 4.7 to 4.11 are
     // at least behaving as described though.
     // https://bugs.kde.org/show_bug.cgi?id=298801
     const auto frames = (dirStat.f_frsize == 0) ? 1 : dirStat.f_frsize;
     const auto blockSize = dirStat.f_bsize * frames;
     // Further more on older versions of samba f_bavail may not be set...
     const auto total = blockSize * dirStat.f_blocks;
     const auto available = blockSize * ((dirStat.f_bavail != 0) ? dirStat.f_bavail : dirStat.f_bfree);
 
     // If total is 0 don't bother reporting it, it just makes dolphin misbehave. And is indicative of
     // us not having any viable data.
     // https://bugs.kde.org/show_bug.cgi?id=431050
     if (total <= 0) {
         return WorkerResult::fail(KIO::ERR_UNSUPPORTED_ACTION, url.url());
     }
 
     setMetaData("total", QString::number(total));
     setMetaData("available", QString::number(available));
 
     return WorkerResult::pass();
 }
 
 bool SMBWorker::workaroundEEXIST(const int errNum) const
 {
     return (errNum == EEXIST) && m_enableEEXISTWorkaround;
 }