ServiceRepos.cc

Go to the documentation of this file.

#include <iostream>
#include <sstream>
#include "zypp/base/Logger.h"
#include "zypp/repo/ServiceRepos.h"
#include "zypp/repo/RepoException.h"
#include "zypp/media/MediaException.h"
#include "zypp/parser/RepoFileReader.h"
#include "zypp/media/MediaManager.h"
#include "zypp/parser/RepoindexFileReader.h"
#include "zypp/ExternalProgram.h"

using std::stringstream;
using std::endl;

namespace zypp
{
namespace repo
{

class ServiceRepos::Impl
{
public:
    Impl()
    {
    }

    virtual ~Impl()
    {
    }
};

class RIMServiceRepos : public ServiceRepos::Impl
{
public:
    ServiceRepos::ProcessRepo _callback;

    RIMServiceRepos(const ServiceInfo &service,
                    const ServiceRepos::ProcessRepo & callback,
                    const ProgressData::ReceiverFnc &progress = ProgressData::ReceiverFnc() )
        : _callback(callback)
    {
      // repoindex.xml must be fetched always without using cookies (bnc #573897)
      Url serviceUrl( service.url() );
      serviceUrl.setQueryParam( "cookies", "0" );

      // download the repo index file
      media::MediaManager mediamanager;
      media::MediaAccessId mid = mediamanager.open( serviceUrl );
      mediamanager.attach( mid );
      mediamanager.provideFile( mid, "repo/repoindex.xml" );
      Pathname path = mediamanager.localPath(mid, "repo/repoindex.xml" );
      parser::RepoindexFileReader reader(path, _callback);
      mediamanager.release( mid );
      mediamanager.close( mid );
    }

    ~RIMServiceRepos()
    {

    }
};

class PluginServiceRepos : public ServiceRepos::Impl
{
public:
    ServiceRepos::ProcessRepo _callback;

    PluginServiceRepos(const ServiceInfo &service,
                      const ServiceRepos::ProcessRepo & callback,
                      const ProgressData::ReceiverFnc &progress = ProgressData::ReceiverFnc() )
        : _callback(callback)
    {
      Url serviceUrl( service.url() );
      stringstream buffer;

      ExternalProgram::Arguments args;
      args.reserve( 3 );
      args.push_back( "/bin/sh" );
      args.push_back( "-c" );
      args.push_back( serviceUrl.getPathName() );
      ExternalProgramWithStderr prog( args );
      prog >> buffer;

      if ( prog.close() != 0 )
      {
        // ServicePluginInformalException:
        // Ignore this error but we'd like to report it somehow...
        std::string errbuffer;
        prog.stderrGetUpTo( errbuffer, '\0' );
        ERR << "Capture plugin error:[" << endl << errbuffer << endl << ']' << endl;
        ZYPP_THROW( repo::ServicePluginInformalException(errbuffer));
      }

      parser::RepoFileReader parser(buffer, _callback);
    }

    ~PluginServiceRepos()
    {}
};


ServiceRepos::ServiceRepos(const ServiceInfo &service,
                           const ServiceRepos::ProcessRepo & callback,
                           const ProgressData::ReceiverFnc &progress)
    : _impl( (service.type() == ServiceType::PLUGIN) ? (ServiceRepos::Impl *)(new PluginServiceRepos(service, callback, progress)) : (ServiceRepos::Impl *)(new RIMServiceRepos(service, callback, progress)))
{
}

ServiceRepos::~ServiceRepos()
{
}


}
}