package christie.topology.node;


import christie.annotation.Peek;
import christie.annotation.Take;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;
import christie.datagear.DataGearManager;
import christie.topology.Message;
import christie.topology.TopologyDataGear;

import java.util.List;

public class PrepareToClose extends CodeGear {

    @Take
    Message _CLOSEMESSEAGE;

    @Peek
    TopologyDataGear topoDG;

    public PrepareToClose() {

    }

    @Override
    protected void run(CodeGearManager cgm) {
        List<String> _CLIST = topoDG.getConnectionList();
        for(String dgmName: _CLIST){
            getDGM(dgmName).shutdown();
            //_CLIST.remove(dgmName);
        }

        getLocalDGM().finish();

        /*if (_CLIST.contains(_CLOSEMESSEAGE)) {
            _CLIST.remove(_CLOSEMESSEAGE);

            getDGM(_CLOSEMESSEAGE).setSendError(false);
            getDGM(_CLOSEMESSEAGE).close();

            getDGM(_CLOSEMESSEAGE).put("_CLOSEREADY", _CLOSEMESSEAGE);
            getLocalDGM().put("_CLOSEREADY", _CLOSEMESSEAGE);

            cgm.setup(new CloseRemoteDataGear());
        }
        cgm.setup(new PrepareToClose());
        getLocalDGM().put("_CLIST", _CLIST);*/

    }

}