src/desadp.cpp - master - yborisov/fap5

src/desadp.cpp
303 строки6 KB
Yuri Borisov
Redesigned DAdp for BState
28 мар 2025, 11:12
28 мар 2025, 11:12c51a449

#include "desadp.h"


#if 0
const string KCont_AgentUri = "AgentUri";
const string K_DAdp_CpUri_InpMagUri = "InpMagUri";

static const vector<string> KContentIds = { KCont_AgentUri };


const string DAdp::KCpExplName = "CpExploring";

DAdp::DAdp(const string &aType, const string& aName, MEnv* aEnv): Des(aType, aName, aEnv),
    mIbMagUri(this, K_DAdp_CpUri_InpMagUri)
{
}

void DAdp::Construct()
{
    mCpExpl = new CpSystExploring(string(CpSystExploring::idStr()), KCpExplName, mEnv);
    assert(mCpExpl);
    bool res = attachOwned(mCpExpl);
    assert(res);
    mCpExpl->bind(MNode::lIft<MNode>());

}

DAdp::~DAdp()
{
    if (mCpExpl) {
	delete mCpExpl;
    }
}

MIface* DAdp::MNode_getLif(TIdHash aId)
{
    MIface* res = nullptr;
    if (res = checkLif2(aId, mMSystExploring));
    else res = Des::MNode_getLif(aId);
    return res;
}

MIface* DAdp::MSystExploring_getLif(TIdHash aId)
{
    MIface* res = checkLif2(aId, mMSystExploring);
    return res;
}

MNode* DAdp::getMag()
{
    return mMag;
}

MNode* DAdp::getMagBase()
{
    MNode* res = nullptr;
    if (mCpExpl && mCpExpl->pairsCount()) {
	auto* pairv = mCpExpl->mPairs.at(0);
	auto* explb = pairv->lIft<MSystExplorable>();
	res = explb ? explb->getMag() : nullptr;
    }
    return res;
}

void DAdp::updateMag()
{
    /*
       if (mMagBase) {
       GUri magUri(mContMagUri);
       if (magUri.isValid()) {
       mMag = mMagBase->getNode(magUri);
       }
       }
       */

    if (mMagBase && mIbMagUri.mValid) {
	MNode* magn = mMagBase->getNode(mIbMagUri.data().mData);
	if (magn && magn != mMag) {
	    mMag = magn;
	    notifyMagChanged();
	    LOGN(EInfo, "Managed agent attached [" + mMag->Uid() + "]");
	}
    }
}

void DAdp::onMagChanged()
{
    auto magBase = getMagBase();
    if (magBase != mMagBase) {
	mMagBase = magBase;
	updateMag();
	notifyMagChanged();
    }
}

void DAdp::notifyMagChanged()
{
    for (auto pair : mExplorableCp.mPairs) {
	pair->provided()->onMagChanged();
    }
}

int DAdp::contCount() const 
{
    return Des::contCount() + KContentIds.size();
}

bool DAdp::getContentId(int aIdx, string& aRes) const
{
    bool res = false;
    if (aIdx < contCount()) {
	if (aIdx < Des::contCount()) {
	    res = Des::getContentId(aIdx, aRes);
	} else {
	    aRes = KContentIds.at(aIdx - Des::contCount());
	    res = true;
	}
    }
    return res;
}


bool DAdp::getContent(const string& aId, string& aRes) const
{
    bool res = true;
    if (aId == KCont_AgentUri) {
	aRes = mContMagUri;
    } else {
	res = Des::getContent(aId, aRes);
    }
    return res;
}

bool DAdp::setContent(const string& aId, const string& aData)
{
    bool res = true;
    if (aId == KCont_AgentUri) {
	if (aData != mContMagUri) {
	    mContMagUri = aData;
	    onContentChanged(aId);
	}
	// TODO to notify update
    } else  {
	res = Des::setContent(aId, aData);
    }
    return res;
}

void DAdp::onContentChanged(const string& aId)
{
    if (aId == KCont_AgentUri) {
	//	updateMag();
	//	notifyMagChanged();
    }
}

void DAdp::update()
{
    for (auto iap : mIbs) {
	if (iap->mActivated) {
	    iap->update();
	}
    }
    Des::update();
}

void DAdp::confirm()
{
    for (auto iap : mIbs) {
	iap->mChanged = false;
	if (iap->mUpdated) {
	    iap->confirm();
	}
    }
    if (mIbMagUri.mChanged) {
	updateMag();
    }
    Des::confirm();
}

void DAdp::registerIb(DesEIbb* aIb)
{
    MNode* cp = Provider()->createNode(aIb->mCpType, aIb->getUri(), mEnv);
    assert(cp);
    bool res = attachOwned(cp->MNode::lIft<MOwned>());
    assert(res);
    mIbs.push_back(aIb);
    MVert* cpv = cp->lIf(cpv);
    assert(cpv);
    cpv->bind(aIb->MDesInpObserver::lIft<MDesInpObserver>());
}

#endif



void DAdp::MagUriHandler::onInpUpdated()
{
    LOGN(EInfo, "MAG Uri changed");
    mHost->updateMag();
}

const string DAdp::KCpExplName = "CpExploring";
const string K_DAdp_InpMagUri = "InpMagUri";
const string K_DAdp_StMagUri = "StMagUri";

DAdp::DAdp(const string &aType, const string& aName, MEnv* aEnv): Des(aType, aName, aEnv)
{
}

void DAdp::Construct()
{
    // Add exploring cp
    auto ecp = addComp(CpSystExploring::idStr(), KCpExplName);
    assert(ecp);
    mCpExpl = ecp->lIft<MVert>();
    assert(mCpExpl);
    bool res = mCpExpl->bind(MNode::lIft<MNode>());
    assert(res);
    // Add MAG uri input
    auto inpMagUrin = addComp(CpStateInp::idStr(), K_DAdp_InpMagUri);
    auto inpMagUri = inpMagUrin ? inpMagUrin->lIft<MVert>() : nullptr;
    assert(inpMagUri);
    // Add MagUri state
    mStMagUri = addComp(BState::idStr(), K_DAdp_StMagUri);
    assert(mStMagUri);
    mStMagUri->lIft<MContentOwner>()->setContent("", "URI");
    res = inpMagUri->bind(mStMagUri->MNode::lIft<MNode>());
    assert(res);
    auto stMagUriv = mStMagUri->lIft<MVert>();
    res = stMagUriv->bind(inpMagUri);
    assert(res);
    mHdlr = new MagUriHandler("MagUriHandler", mEnv, this);
    MVert::connect(stMagUriv, mHdlr->lIft<MVert>());
}

DAdp::~DAdp()
{
    if (mHdlr) {
	delete mHdlr;
    }
}

MIface* DAdp::MNode_getLif(TIdHash aId)
{
    MIface* res = nullptr;
    if (res = checkLif2(aId, mMSystExploring));
    else res = Des::MNode_getLif(aId);
    return res;
}

MIface* DAdp::MSystExploring_getLif(TIdHash aId)
{
    MIface* res = checkLif2(aId, mMSystExploring);
    return res;
}

MNode* DAdp::getMag()
{
    return mMag;
}

MNode* DAdp::getMagBase()
{
    MNode* res = nullptr;
    if (mCpExpl && mCpExpl->pairsCount()) {
	auto* pairv = mCpExpl->getPair(0);
	auto* explb = pairv->lIft<MSystExplorable>();
	res = explb ? explb->getMag() : nullptr;
    }
    return res;
}

void DAdp::updateMag()
{
    DGuri magUri;
    GetGData(mStMagUri, magUri);
    if (mMagBase && magUri.IsValid()) {
	MNode* magn = mMagBase->getNode(magUri.mData);
	if (magn && magn != mMag) {
	    mMag = magn;
	    notifyMagChanged();
	    LOGN(EInfo, "Managed agent attached [" + mMag->Uid() + "]");
	}
    }
}

void DAdp::onMagChanged()
{
    auto magBase = getMagBase();
    if (magBase != mMagBase) {
	mMagBase = magBase;
	updateMag();
	notifyMagChanged();
    }
}

void DAdp::notifyMagChanged()
{
    for (auto pair : mExplorableCp.mPairs) {
	pair->provided()->onMagChanged();
    }
}