persproduct_i.h

Go to the documentation of this file.

// OSB library ********************************************* -*- C++ -*-
/*
  AUTHOR(S): Darryl Kang (dk)

  RCS information
   $Name: OSB_060808 $
   $Revision: 1.37 $

  License
   OSB rating and billing library for communication networks
   Copyright (C) 2004, 2005, 2006  OSB systems

   This file may be distributed and/or modify under the terms of the
   GNU General Public License (GPL) as published by the Free Software
   Foundation which is provided in the file LICENSE.GPL included in the
   packaging of this file.

   The file 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 General Public License
   for more details.

   Holders of a OSB Commercial License may use this file under the terms
   and conditions of this commercial license.
 */
#ifndef _PERSPRODUCT_I_H_
#define _PERSPRODUCT_I_H_

// *********************************************************************
// included header files
// + standard includes

// + libraries
#include "persproduct.h"

// + local headers
#include "persproductS.h"
#include "servantlocators.h"

// + class declarations
namespace OSB_CORBA {
    class AnCList_i;
    class ContractAdmin_i;
    class ContractWriter_i;
    class PersProdItemWriter_i;
    class PersProdNodeWriter_i;
}

namespace OSB_LIB {
    class AnCList;
}

// ************************************************************************
// namespace extensions
namespace OSB_CORBA {
    using namespace corba::cadmin::persprod;
    using namespace corba::cadmin::persprodnode;
    using namespace corba::cadmin::persproditem;

    using corba::cadmin::AssociateId;
    using corba::cadmin::PersProdId;
    using corba::cadmin::PersNodeId;
    using corba::cadmin::Status;
    using corba::cadmin::StatusHistory;
    using corba::cadmin::StatusRequest;
    using corba::cadmin::StatusValue;
    using corba::common::CfgErrorSeq_out;
    using corba::common::DateTime;
    using corba::common::Utf8String;
    using corba::pcat::pd::ProductId;
    using corba::pcat::pp::ProductPartId;

    class PersProductWriter_i :
        public virtual POA_corba::cadmin::persprod::PersProductWriter
    {
    public:
        static const std::string IFC;

        PersProductWriter_i(
            AnCList_i&            ancList,
            ContractWriter_i&     coServant,
            OSB_LIB::PersProduct* persProduct
        );

        ~PersProductWriter_i();

        const Locators::Key& key() const
        {
            return key_;
        }

        PersProdId id()
            throw (CORBA::SystemException);

        ProductId prodId()
            throw (CORBA::SystemException);

        AssociateId userId()
            throw (CORBA::SystemException);

        Utf8String* name()
            throw (CORBA::SystemException, OsbCorbaException);

        Utf8String* desc()
            throw (CORBA::SystemException, OsbCorbaException);

        Status effStatus()
            throw (CORBA::SystemException);

        Status prefStatus()
            throw (CORBA::SystemException);

        DateTime* createdDate()
            throw (CORBA::SystemException);

        DateTime* effStatusDate()
            throw (CORBA::SystemException);

        DateTime* prefStatusDate()
            throw (CORBA::SystemException);

        virtual StatusValue requestedStatus(
            const DateTime& ts
        ) throw (CORBA::SystemException, OsbCorbaException);

        StatusHistory* statusHistory(
            const DateTime& from,
            const DateTime& to,
            CORBA::Boolean  noWait
        ) throw (CORBA::SystemException, OsbCorbaException);

        AvailnSubscrPartSeq* availnSubscrParts(
            const OSB_LIB::PersParts& persParts
        );

        virtual AvailnSubscrPartSeq* getNextAvailnSubscrParts()
            throw (CORBA::SystemException);

        AvailnSubscrPartSeq* getAvailnSubscrParts(
            const ProductPartId& id
        ) throw (CORBA::SystemException, OsbCorbaException);

        AvailnSubscrPart* getAvailnSubscrPart(
            const ProductPartId& id
        ) throw (CORBA::SystemException, OsbCorbaException);

        PersProdNodeSeq* getPersProdNodes()
            throw (CORBA::SystemException, OsbCorbaException);

        PersProdNodeWriter_ptr getPersProdNode(
            const ProductPartId& id
        ) throw (CORBA::SystemException, OsbCorbaException);

        CORBA::Boolean addPersProdNode(
            const ProductPartId& id,
            CORBA::Boolean       noWait
        ) throw (CORBA::SystemException, OsbCorbaException);

        CORBA::Boolean removePersProdNode(
            const ProductPartId& id,
            CORBA::Boolean       noWait
        ) throw (CORBA::SystemException, OsbCorbaException);

        CORBA::Boolean subscribe(
            const ProductPartId& id,
            CORBA::Boolean       noWait
        ) throw (CORBA::SystemException, OsbCorbaException);

        void setUserId(
            const AssociateId& id
        ) throw (CORBA::SystemException);

        CORBA::Boolean commitChanges(
            CORBA::Boolean noWait
        ) throw (CORBA::SystemException, OsbCorbaException);



        CORBA::Boolean changeStatus(
            StatusRequest&  status,
            CORBA::Boolean  noWait,
            CfgErrorSeq_out errors
        ) throw (CORBA::SystemException, OsbCorbaException);
        CORBA::Boolean changePartStatus(
                  StatusRequest&  status,
            const ProductPartId&  id,
                  CORBA::Boolean  noWait,
                  CfgErrorSeq_out errors
        ) throw (CORBA::SystemException, OsbCorbaException);

    private:
        friend class PersProdNodeWriter_i;
        friend class PersProdItemWriter_i;

        void ppiChanged(
            const OSB_DB::Session& session
        );
        void ppnChanged(
            const OSB_DB::Session& session
        );

        ContractAdmin_i& cadmin();
        OSB_LIB::AnCList& ancList();

    private:
        typedef std::list<Locators::Key> Servants;

        AnCList_i& ancList_;
        ContractWriter_i& coServant_;
        OSB_LIB::PersProduct* persProduct_;
        Servants ppnServants_;
        Servants ansServants_;
        Locators::Key key_;
    };                                  // class PersProductWriter_i

    class AvailnSubscrPart_i :
        public virtual POA_corba::cadmin::persprod::AvailnSubscrPart
    {
    public:
        static const std::string IFC;

        AvailnSubscrPart_i(
                  ContractAdmin_i&     cadmin,
                  PersProductWriter_i& ppServant,
            const OSB_LIB::PersPart&   persPart
        );

        ~AvailnSubscrPart_i();
    public:
        PersNodeId ppnId()
            throw (CORBA::SystemException);

        ProductPartId ppId()
            throw (CORBA::SystemException);

        CORBA::Long mandatory()
            throw (CORBA::SystemException);

        CORBA::Boolean isSubscribed()
            throw (CORBA::SystemException);

        CORBA::Boolean hasDefPersPart()
            throw (CORBA::SystemException);

        PersProdItemWriter_ptr crePersPart()
            throw (CORBA::SystemException, OsbCorbaException);

    public:
        const Locators::Key& key() const
        {
            return key_;
        }

    private:
        typedef std::list<Locators::Key> Servants;

        ContractAdmin_i& cadmin_;
        PersProductWriter_i& ppServant_;

        OSB_LIB::PersPart persPart_;

        Servants ppiServants_;
        Locators::Key key_;
    };                                  // class AvailnSubscrPart_i
}                                       // namespace OSB_CORBA

// ************************************************************************
// inline definitions
namespace OSB_CORBA {
}                                       // namespace OSB_CORBA
#endif                                  // #ifndef _ASSOCIATE_I_H_

---