Changeset 21 for exampleparties/randomparty/src/main

Timestamp:

09/22/20 08:52:04 (4 years ago)

Author:

bart

Message:

Version 1.5.

File:

• exampleparties/randomparty/src/main/java/geniusweb/exampleparties/randomparty/RandomParty.java (modified) (9 diffs)

exampleparties/randomparty/src/main/java/geniusweb/exampleparties/randomparty/RandomParty.java

@@ -5 +5 @@
 import java.util.Arrays;
 import java.util.HashSet;
+import java.util.List;
 import java.util.Random;
 import java.util.logging.Level;
+import java.util.stream.Collectors;
 
 import geniusweb.actions.Accept;
@@ -12 +14 @@
 import geniusweb.actions.Offer;
 import geniusweb.actions.PartyId;
+import geniusweb.actions.Vote;
+import geniusweb.actions.Votes;
 import geniusweb.bidspace.AllPartialBidsList;
+import geniusweb.inform.ActionDone;
+import geniusweb.inform.Finished;
+import geniusweb.inform.Inform;
+import geniusweb.inform.OptIn;
+import geniusweb.inform.Settings;
+import geniusweb.inform.Voting;
+import geniusweb.inform.YourTurn;
 import geniusweb.issuevalue.Bid;
 import geniusweb.party.Capabilities;
 import geniusweb.party.DefaultParty;
-import geniusweb.party.inform.ActionDone;
-import geniusweb.party.inform.Finished;
-import geniusweb.party.inform.Inform;
-import geniusweb.party.inform.Settings;
-import geniusweb.party.inform.YourTurn;
 import geniusweb.profile.PartialOrdering;
 import geniusweb.profile.Profile;
@@ -33 +39 @@
  * A simple party that places random bids and accepts when it receives an offer
  * with sufficient utility.
+ * <h2>voting</h2> If the party receives a parameter "minPower", it will
+ * {@link Vote} using that minPower instead of the default value 2 if it
+ * receives a {@link Voting} request.
  */
 public class RandomParty extends DefaultParty {
@@ -41 +50 @@
         protected ProfileInterface profileint;
         private Progress progress;
+        private Settings settings;
+        private Votes lastvotes;
 
         public RandomParty() {
@@ -58 +69 @@
                                 this.me = settings.getID();
                                 this.progress = settings.getProgress();
+                                this.settings = settings;
                         } else if (info instanceof ActionDone) {
                                 Action otheract = ((ActionDone) info).getAction();
@@ -64 +76 @@
                                 }
                         } else if (info instanceof YourTurn) {
-                                myTurn();
-                                if (progress instanceof ProgressRounds) {
-                                        progress = ((ProgressRounds) progress).advance();
-                                }
+                                makeOffer();
+                                nextRound();
                         } else if (info instanceof Finished) {
                                 getReporter().log(Level.INFO, "Final ourcome:" + info);
+                        } else if (info instanceof Voting) {
+                                lastvotes = vote((Voting) info);
+                                getConnection().send(lastvotes);
+                                nextRound();
+                        } else if (info instanceof OptIn) {
+                                // just repeat our last vote.
+                                getConnection().send(lastvotes);
+                                nextRound();
                         }
                 } catch (Exception e) {
@@ -76 +94 @@
         }
 
+        private void nextRound() {
+                if (progress instanceof ProgressRounds) {
+                        progress = ((ProgressRounds) progress).advance();
+                }
+
+        }
+
         @Override
         public Capabilities getCapabilities() {
-                return new Capabilities(new HashSet<>(Arrays.asList("SAOP")));
+                return new Capabilities(
+                                new HashSet<>(Arrays.asList("SAOP", "AMOP", "MOPAC")));
         }
 
@@ -86 +112 @@
         }
 
-        private void myTurn() throws IOException {
+        /**
+         * send our next offer
+         */
+        private void makeOffer() throws IOException {
                 Action action;
-                if (isGood(lastReceivedBid)) {
+                String protocol = settings.getProtocol().getURI().getPath();
+                if ((protocol.equals("SAOP") || protocol.equals("SHAOP"))
+                                && isGood(lastReceivedBid)) {
                         action = new Accept(me, lastReceivedBid);
                 } else {
@@ -105 +136 @@
         }
 
-        private boolean isGood(Bid bid) throws IOException {
+        /**
+         * @param bid the bid to check
+         * @return true iff bid is good for us.
+         */
+        private boolean isGood(Bid bid) {
                 if (bid == null)
                         return false;
-                Profile profile = profileint.getProfile();
-                if (profile instanceof UtilitySpace) {
+                Profile profile;
+                try {
+                        profile = profileint.getProfile();
+                } catch (IOException e) {
+                        throw new IllegalStateException(e);
+                }
+                if (profile instanceof UtilitySpace)
                         return ((UtilitySpace) profile).getUtility(bid).doubleValue() > 0.6;
-                }
                 if (profile instanceof PartialOrdering) {
                         return ((PartialOrdering) profile).isPreferredOrEqual(bid,
                                         profile.getReservationBid());
                 }
-                throw new IllegalArgumentException(
-                                "Can not handle profile type " + profile.getClass());
+                return false;
+        }
+
+        /**
+         * @param voting the {@link Voting} object containing the options
+         * 
+         * @return our next Votes.
+         */
+        private Votes vote(Voting voting) throws IOException {
+                Object val = settings.getParameters().get("minPowwer");
+                Integer n = (val instanceof Integer) ? (Integer) val : 2;
+                for (Bid bid : voting.getBids()) {
+                        System.out.println("Bid " + bid + "="
+                                        + ((UtilitySpace) profileint.getProfile()).getUtility(bid));
+                }
+                List<Vote> votes = voting.getBids().stream().distinct()
+                                .filter(bid -> isGood(bid)).map(bid -> new Vote(me, bid, n))
+                                .collect(Collectors.toList());
+                return new Votes(me, votes);
         }