PrimaryFileReader.cc

Go to the documentation of this file.

/*---------------------------------------------------------------------\
|                          ____ _   __ __ ___                          |
|                         |__  / \ / / . \ . \                         |
|                           / / \ V /|  _/  _/                         |
|                          / /__ | | | | | |                           |
|                         /_____||_| |_| |_|                           |
|                                                                      |
\---------------------------------------------------------------------*/
#include "zypp/base/Logger.h"
#include "zypp/ZConfig.h"

#include "zypp/parser/xml/Reader.h"
#include "zypp/data/ResolvableData.h"
#include "zypp/base/UserRequestException.h"

#include "zypp/parser/yum/FileReaderBaseImpl.h"
#include "zypp/parser/yum/PrimaryFileReader.h"

#undef ZYPP_BASE_LOGGER_LOGGROUP
#define ZYPP_BASE_LOGGER_LOGGROUP "parser::yum"

using namespace std;
using namespace zypp::xml;

namespace zypp
{
  namespace parser
  {
    namespace yum
    {


  //
  //  CLASS NAME : PrimaryFileReader::Impl
  //
  class PrimaryFileReader::Impl : public BaseImpl
  {
  public:
    Impl(const Pathname & primary_file,
         const ProcessPackage & callback,
         const ProgressData::ReceiverFnc & progress);

    bool consumeNode(xml::Reader & reader_r);

  private:
    data::Packagebase_Ptr handoutPackage();

  private:
    ProcessPackage _callback;

    data::Packagebase_Ptr _package;

    ProgressData _ticks;

    Arch _sysarch;
  };


  PrimaryFileReader::Impl::Impl(
      const Pathname & primary_file,
      const ProcessPackage & callback,
      const ProgressData::ReceiverFnc & progress)
    :
      _callback(callback)
    , _sysarch( ZConfig::instance().systemArchitecture() )
  {
    _ticks.sendTo(progress);

    Reader reader(primary_file);
    MIL << "Reading " << primary_file << endl;
    reader.foreachNode(bind( &PrimaryFileReader::Impl::consumeNode, this, _1 ));
  }

  // --------------------------------------------------------------------------

  bool PrimaryFileReader::Impl::consumeNode(Reader & reader_r)
  {
//    DBG << "**node: " << reader_r->name() << " (" << reader_r->nodeType() << ")" << endl;
    if (isBeingProcessed(tag_package) && consumePackageNode(reader_r, _package))
      return true;


    if (reader_r->nodeType() == XML_READER_TYPE_ELEMENT)
    {
      // xpath: /metadata
      if (reader_r->name() == "metadata")
      {
        unsigned total_packages;
        zypp::str::strtonum(reader_r->getAttribute("packages").asString(), total_packages);
        _ticks.range(total_packages);
        _ticks.toMin();
        return true;
      }

      // xpath: /metadata/package (+)
      if (reader_r->name() == "package")
      {
        tag(tag_package);
  //      DBG << "got " << reader_r->getAttribute("type") << " package" << endl;
        _package = new data::Package;

        return consumePackageNode(reader_r, _package);
      }
    }

    else if ( reader_r->nodeType() == XML_READER_TYPE_END_ELEMENT )
    {
      // xpath: /metadata/package (+)
      if (reader_r->name() == "package")
      {
        if (_package && _callback
            && _package->arch.compatibleWith( _sysarch ))
        {
          _callback(handoutPackage());
        }
        if (!_ticks.incr())
          ZYPP_THROW(AbortRequestException());

        toParentTag();
        return true;
      }

      // xpath: /metdata
      if (reader_r->name() == "metadata")
      {
        _ticks.toMax();
        return true;
      }
    }

    return true;
  }

  // --------------------------------------------------------------------------

  data::Packagebase_Ptr PrimaryFileReader::Impl::handoutPackage()
  {
    data::Packagebase_Ptr ret;
    ret.swap(_package);
    return ret;
  }

  //
  //  CLASS NAME : PrimaryFileReader
  //

  PrimaryFileReader::PrimaryFileReader(
      const Pathname & primary_file,
      const ProcessPackage & callback,
      const ProgressData::ReceiverFnc & progress)
    : _pimpl(new PrimaryFileReader::Impl(primary_file, callback, progress))
  {}


  PrimaryFileReader::~PrimaryFileReader()
  {}


    } // ns yum
  } // ns parser
} //ns zypp

// vim: set ts=2 sts=2 sw=2 et ai:

---