package christie.topology.manager;

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

import java.util.HashMap;

public class CheckComingHost extends CodeGear {

    @Take
    HostMessage hostMessage;

    @Peek
    HashMap<String, String> absCookieTable;

    public CheckComingHost(){
    }

    @Override
    protected void run(CodeGearManager cgm) {

        String cookie = hostMessage.getCookie();
        // check cookie
        if (cookie != null) {
            if (absCookieTable.containsKey(cookie)) {
                hostMessage.setNodeName(cookie);
                System.out.println("match");
                // coming host has ever joined this App
                getLocalDGM().put("reconnectHost", hostMessage);
                cgm.setup(new SearchHostName());
            }
        }else {
            getLocalDGM().put("orderHash", "order");
            getLocalDGM().put("newHost", hostMessage);
        }
        cgm.setup(new CheckComingHost());
    }

}