package jp.ac.u_ryukyu.ie.cr.jungleNetwork.logupdate;

import alice.codesegment.CodeSegment;
import alice.datasegment.CommandType;
import alice.datasegment.ReceiveData;
import alice.datasegment.Receiver;
import org.msgpack.type.ValueFactory;

import java.util.List;

public class LogupdateFinish extends CodeSegment {
    private final String host;
    Receiver finish = ids.create(CommandType.TAKE);
    private Receiver clist = ids.create(CommandType.PEEK);

    LogupdateFinish(String host) {
        finish.setKey("finish");
        clist.setKey("_CLIST");
        this.host = host;
    }

    @Override
    public void run() {
        int command = finish.asInteger();

        @SuppressWarnings("unchecked")
        List<String> list = clist.asClass(List.class);
        for (String node : list) {// close connection
            if (!node.equals(finish.from)) {
                ods.finish(node);
            }
        }
        if (host.equals("node0")) {
            ods.put("manager","finish",0);
            ods.finish("manager");
        }
    }
}