source: protocol/src/main/java/geniusweb/protocol/session/mopac2/phase/VotingPhase.java@ 52

package geniusweb.protocol.session.mopac2.phase;

import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;

import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;

import geniusweb.actions.Action;
import geniusweb.actions.EndNegotiation;
import geniusweb.actions.Offer;
import geniusweb.actions.PartyId;
import geniusweb.actions.VotesWithValue;
import geniusweb.inform.Inform;
import geniusweb.inform.Voting;
import geniusweb.protocol.ProtocolException;
import geniusweb.protocol.session.mopac2.PartyStates;
import geniusweb.voting.VotingEvaluatorWithValue;

public class VotingPhase extends DefaultPhase {

        /**
         * the offers received in the {@link OfferPhase}
         */
        private final List<Offer> offers;

        @JsonCreator
        protected VotingPhase(@JsonProperty("offers") List<Offer> offers,
                        @JsonProperty("partyStates") PartyStates partyStates,
                        @JsonProperty("deadlinems") Long deadlinems,
                        @JsonProperty("evaluator") VotingEvaluatorWithValue evaluator) {
                super(partyStates, deadlinems, evaluator);
                this.offers = offers;
        }

        @Override
        public VotingPhase with(PartyId actor, Action action, long now) {
                try {
                        checkAction(actor, action, now);
                } catch (ProtocolException ex) {
                        return this.with(ex);
                }
                return new VotingPhase(offers, partyStates.with(action), deadline,
                                evaluator);
        }

        @Override
        public Inform getInform() {
                return new Voting(offers, partyStates.getPowers());
        }

        @Override
        public VotingPhase with(ProtocolException e) {
                return new VotingPhase(offers, partyStates.with(e), deadline,
                                evaluator);
        }

        @Override
        public VotingPhase finish() {
                return new VotingPhase(offers, partyStates.finish(), deadline,
                                evaluator);
        }

        @Override
        protected Phase checkedNext(long deadln) {
                return new OptInPhase(getVotes(), partyStates.flush(), deadln,
                                evaluator);
        }

        @Override
        public List<Class<? extends Action>> getAllowedActions() {
                return Arrays.asList(VotesWithValue.class, EndNegotiation.class);
        }

        /**
         * @return all votes done in this phase.
         */
        public List<VotesWithValue> getVotes() {
                return partyStates.getActions().stream()
                                .filter(act -> act instanceof VotesWithValue)
                                .map(act -> (VotesWithValue) act).collect(Collectors.toList());
        }

}