package christie.topology.node;

import christie.annotation.Peek;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;
import christie.topology.HostMessage;
import christie.topology.manager.IncomingHosts;

import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.ArrayList;

public class TopologyNode extends CodeGear{

    @Peek
    TopologyNodeConfig topologyNodeConfig;

    public TopologyNode() {
    }

    @Override
    protected void run(CodeGearManager cgm) {

        cgm.createRemoteDGM(topologyNodeConfig.getManagerKey(),
                            topologyNodeConfig.getManagerHostName(),
                            topologyNodeConfig.getManagerPort());


        String localHostName = null;
        try {
            localHostName = InetAddress.getLocalHost().getHostAddress();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }


        if (cgm.localPort == 0) {
            // local test mode
            localHostName = topologyNodeConfig.getLocalKey();

        }
        getLocalDGM().put("config" , topologyNodeConfig);

        HostMessage host = new HostMessage(localHostName, cgm.localPort);
        host.cookie = topologyNodeConfig.cookie;

        getDGM(topologyNodeConfig.getManagerKey()).put("hostMessage", host);
        getLocalDGM().put("_CLIST", new ArrayList<String>());
        getLocalDGM().put("reverseCount", 0);

        cgm.setup(new SaveCookie());
        cgm.setup(new IncomingAbstractHostName(topologyNodeConfig));
        cgm.setup(new IncomingReverseKey());
        cgm.setup(new ConfigurationFinish());

    }
}