TransferSettings.cc

Go to the documentation of this file.

#include <iostream>
#include <sstream>
 
#include <zypp/base/String.h>
#include <zypp/base/Logger.h>
#include <zypp/base/WatchFile.h>
#include <zypp/base/ReferenceCounted.h>
#include <zypp/base/NonCopyable.h>
#include <zypp/ExternalProgram.h>
#include <zypp/media/TransferSettings.h>
#include <zypp/ZConfig.h>
 
using std::endl;
 
#define CURL_BINARY "/usr/bin/curl"
 
namespace zypp
{
  namespace media
  {
    class TransferSettings::Impl
    {
    public:
      Impl()
      : _useproxy(false)
      , _timeout( ZConfig::instance().download_transfer_timeout() )
      , _connect_timeout( 60 )
      , _maxConcurrentConnections(ZConfig::instance().download_max_concurrent_connections())
      , _minDownloadSpeed(ZConfig::instance().download_min_download_speed())
      , _maxDownloadSpeed(ZConfig::instance().download_max_download_speed())
      , _maxSilentTries(ZConfig::instance().download_max_silent_tries())
      , _verify_host(false)
      , _verify_peer(false)
      , _ca_path("/etc/ssl/certs")
      , _head_requests_allowed(true)
      {}
 
      virtual ~Impl()
      {}
 
      static shared_ptr<Impl> nullimpl()
      {
        static shared_ptr<Impl> _nullimpl( new Impl );
        return _nullimpl;
      }
 
    private:
      friend Impl * rwcowClone<Impl>( const Impl * rhs );
      Impl * clone() const
      { return new Impl( *this ); }
 
    public:
      std::vector<std::string> _headers;
      std::string _useragent;
      std::string _username;
      std::string _password;
      bool _useproxy;
      std::string _proxy;
      std::string _proxy_username;
      std::string _proxy_password;
      std::string _authtype;
      long _timeout;
      long _connect_timeout;
      Url _url;
      Pathname _targetdir;
 
      long _maxConcurrentConnections;
      long _minDownloadSpeed;
      long _maxDownloadSpeed;
      long _maxSilentTries;
 
      bool _verify_host;
      bool _verify_peer;
      Pathname _ca_path;
      Pathname _client_cert_path;
      Pathname _client_key_path;
 
      // workarounds
      bool _head_requests_allowed;
    };
 
    TransferSettings::TransferSettings()
    : _impl(new TransferSettings::Impl())
    {}
 
    void TransferSettings::reset()
    { _impl.reset(new TransferSettings::Impl()); }
 
 
    void TransferSettings::addHeader( std::string && val_r )
    { if ( ! val_r.empty() ) _impl->_headers.push_back( std::move(val_r) ); }
 
    TransferSettings::Headers::const_iterator TransferSettings::headersBegin() const
    { return _impl->_headers.begin(); }
 
    TransferSettings::Headers::const_iterator TransferSettings::headersEnd() const
    { return _impl->_headers.end(); }
 
 
    void TransferSettings::setUserAgentString( std::string && val_r )
    { _impl->_useragent = std::move(val_r); }
 
    std::string TransferSettings::userAgentString() const
    { return _impl->_useragent; }
 
 
    void TransferSettings::setUsername( std::string && val_r )
    { _impl->_username = std::move(val_r); }
 
    std::string TransferSettings::username() const
    { return _impl->_username; }
 
    void TransferSettings::setPassword( std::string && val_r )
    { _impl->_password = std::move(val_r); }
 
    std::string TransferSettings::password() const
    { return _impl->_password; }
 
    std::string TransferSettings::userPassword() const
    {
      std::string userpwd = username();
      if ( password().size() ) {
        userpwd += ":" + password();
      }
      return userpwd;
    }
 
    void TransferSettings::setAnonymousAuth()
    {
      setUsername("anonymous");
      setPassword("yast@" LIBZYPP_VERSION_STRING);
    }
 
 
    void TransferSettings::setProxyEnabled( bool enabled )
    { _impl->_useproxy = enabled; }
 
    bool TransferSettings::proxyEnabled() const
    { return _impl->_useproxy; }
 
 
    void TransferSettings::setProxy( std::string && val_r )
    { _impl->_proxy = std::move(val_r); }
 
    std::string TransferSettings::proxy() const
    { return _impl->_proxy; }
 
 
    void TransferSettings::setProxyUsername( std::string && val_r )
    { _impl->_proxy_username = std::move(val_r); }
 
    std::string TransferSettings::proxyUsername() const
    { return _impl->_proxy_username; }
 
    void TransferSettings::setProxyPassword( std::string && val_r )
    { _impl->_proxy_password = std::move(val_r); }
 
    std::string TransferSettings::proxyPassword() const
    { return _impl->_proxy_password; }
 
    std::string TransferSettings::proxyUserPassword() const
    {
      std::string userpwd = proxyUsername();
      if ( proxyPassword().size() ) {
        userpwd += ":" + proxyPassword();
      }
      return userpwd;
    }
 
 
    void TransferSettings::setTimeout( long t )
    { _impl->_timeout = t; }
 
    long TransferSettings::timeout() const
    { return _impl->_timeout; }
 
 
    void TransferSettings::setConnectTimeout( long t )
    { _impl->_connect_timeout = t; }
 
    long TransferSettings::connectTimeout() const
    { return _impl->_connect_timeout; }
 
 
    void TransferSettings::setMaxConcurrentConnections( long v )
    { _impl->_maxConcurrentConnections = v; }
 
    long TransferSettings::maxConcurrentConnections() const
    { return _impl->_maxConcurrentConnections; }
 
 
    void TransferSettings::setMinDownloadSpeed( long v )
    { _impl->_minDownloadSpeed = v; }
 
    long TransferSettings::minDownloadSpeed() const
    { return _impl->_minDownloadSpeed; }
 
 
    void TransferSettings::setMaxDownloadSpeed( long v )
    { _impl->_maxDownloadSpeed = v; }
 
    long TransferSettings::maxDownloadSpeed() const
    { return _impl->_maxDownloadSpeed; }
 
 
    void TransferSettings::setMaxSilentTries( long v )
    { _impl->_maxSilentTries = v; }
 
    long TransferSettings::maxSilentTries() const
    { return _impl->_maxSilentTries; }
 
 
    void TransferSettings::setVerifyHostEnabled( bool enabled )
    { _impl->_verify_host = enabled; }
 
    bool TransferSettings::verifyHostEnabled() const
    { return _impl->_verify_host; }
 
 
    void TransferSettings::setVerifyPeerEnabled( bool enabled )
    { _impl->_verify_peer = enabled; }
 
    bool TransferSettings::verifyPeerEnabled() const
    { return _impl->_verify_peer; }
 
 
    void TransferSettings::setClientCertificatePath( Pathname && val_r )
    { _impl->_client_cert_path = std::move(val_r); }
 
    Pathname TransferSettings::clientCertificatePath() const
    { return _impl->_client_cert_path; }
 
 
    void TransferSettings::setClientKeyPath( Pathname && val_r )
    { _impl->_client_key_path = std::move(val_r); }
 
    Pathname TransferSettings::clientKeyPath() const
    { return _impl->_client_key_path; }
 
 
    void TransferSettings::setCertificateAuthoritiesPath( Pathname && val_r )
    { _impl->_ca_path = std::move(val_r); }
 
    Pathname TransferSettings::certificateAuthoritiesPath() const
    { return _impl->_ca_path; }
 
 
    void TransferSettings::setAuthType( std::string && val_r )
    { _impl->_authtype = std::move(val_r); }
 
    std::string TransferSettings::authType() const
    { return _impl->_authtype; }
 
 
    void TransferSettings::setHeadRequestsAllowed( bool allowed )
    { _impl->_head_requests_allowed = allowed; }
 
    bool TransferSettings::headRequestsAllowed() const
    { return _impl->_head_requests_allowed; }
 
  } // namespace media
} // namespace zypp