package christie.test.topology.paxos.acceptor;

import christie.annotation.Take;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;
import christie.test.topology.paxos.Proposal;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

public class PromiseCodeGear extends CodeGear {

    @Take
    Proposal promisedProposal;

    @Take
    Proposal prepareProposal;

    Logger logger = LogManager.getLogger(PromiseCodeGear.class);


    public PromiseCodeGear(){ }

    @Override
    protected void run(CodeGearManager cgm) {
        if(promisedProposal.getNumber() < prepareProposal.getNumber()) {
            if(promisedProposal.isAccepted()){
                promisedProposal.setNumber(prepareProposal.getNumber());
            }else{
                promisedProposal = prepareProposal;
            }
        }
        put("promisedProposal", promisedProposal);
        logger.debug("promise " + promisedProposal);
        put(prepareProposal.getProposerName(),"receivePromise", promisedProposal);
        cgm.setup(new PromiseCodeGear());
    }

}