package christie.topology.node;

import christie.annotation.Peek;
import christie.annotation.Take;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;

public class ConfigurationFinish extends CodeGear {

    @Take
    String reverseNodeName;

    @Take
    int reverseCount;

    @Peek
    int connectNodeNum;

    @Peek
    TopologyNodeConfig topologyNodeConfig;

    public ConfigurationFinish() {
    }

    @Override
    protected void run(CodeGearManager cgm) {
        reverseCount++;
        if (reverseCount >= connectNodeNum) {
            getDGM(topologyNodeConfig.getManagerKey()).put("nodePrepareDone", "done");
            cgm.setup(new Start());


            /*if (topologyNodeConfig.useKeepAlive)
                cgm.setup(new KeepAlive());*/
            cgm.setup(new PrepareToClose());

            /*ClosedEventManager closedEventManager = new ClosedEventManager();
            closedEventManager.register(cgm, DeleteConnection.class);
            cgm.setup(closedEventManager);
            return;*/

        }else {
            getLocalDGM().put("reverseCount", reverseCount);
            cgm.setup(new ConfigurationFinish());
        }
    }
}