package alice.test.topology.localTestTopology;

import alice.codesegment.CodeSegment;
import alice.datasegment.CommandType;
import alice.datasegment.Receiver;

import java.util.List;

public class LTRemoteIncrement extends CodeSegment {

    private final LocalTestTopologyConfig conf;
    public Receiver num = ids.create(CommandType.TAKE);
    public Receiver clist = ids.create(CommandType.TAKE);

    public LTRemoteIncrement(LocalTestTopologyConfig conf) {
        this.conf = conf;
        num.setKey(conf.key,"num");
        clist.setKey(conf.key,"_CLIST");
    }

    @Override
    public void run() {
        int num = this.num.asInteger();
        System.out.println("node: " + conf.key + " num = " + num);
        num++;
        @SuppressWarnings("unchecked")
        List<String> list = clist.asClass(List.class);
        for( String node : list) {
            ods.put(node, "num", num ++);
        }
    }

}