src/main/java/dev/freireservices/social_altruism/chat/participant/Participant.java

@@ -50,10 +50,8 @@ public class Participant {
         return Behaviors.setup(ctx -> new Participant(ctx, initialCoins, participantType).behavior());
     }
 
-    public double decrementCoins(double coins) {
+    public void decrementCoins(double coins) {
         this.participantCoins -= coins;
-
-        return coins;
     }
 
     public void incrementCoins(double coins) {
@@ -96,10 +94,12 @@ public class Participant {
 
     private Behavior<ParticipantMessage> onSessionEnded(SessionEnded sessionEnded) {
 
+        context.getLog().info("Session ended for user {}", context.getSelf().path().name());
+
         context.getLog().info("Session ended for user: Stats: {}. Earned {} coins, profit {} %"
                 , context.getSelf().path().name()
-                , String.format("%.3f%n", getParticipantCoins() - getInitialCoins())
+                , getParticipantCoins() - getInitialCoins()
-                , calculateProfit()
+                , (getParticipantCoins() - getInitialCoins())
         );
         return Behaviors.stopped();
     }
@@ -128,7 +128,7 @@ public class Participant {
 
     private void playTurnWithSmallDelay(ActorRef<SessionMessage> replyTo) {
         if (getParticipantCoins() > 0 && getCurrentTurn() < getTotalTurns()) {
-            context.scheduleOnce(Duration.ofMillis(500),
+            context.scheduleOnce(Duration.ofSeconds(5),
                     replyTo,
                     new SessionProtocol.PlayTurn(
                             replyTo,
@@ -142,7 +142,8 @@ public class Participant {
 
     private double getParticipationForCurrentTurn() {
         var currentTurnCoins = getRandomNumberBetween(0, Math.floor(getParticipantCoins()));
-        return isCollaborateSwitch() ? decrementCoins(currentTurnCoins) : 0;
+        decrementCoins(currentTurnCoins);
+        return currentTurnCoins;
     }
 
     public static double getRandomNumberBetween(double min, double max) {
@@ -152,7 +153,7 @@ public class Participant {
 
     private Behavior<ParticipantMessage> onPotReturned(
             PotReturned potReturned) {
-        context.getLog().info("Pot returned: {} for participant {}", String.format("%.2f", potReturned.returnedAmount()), potReturned.participant().path().name());
+        context.getLog().info("Pot returned: {} for participant {}", potReturned.returnedAmount(), potReturned.participant().path().name());
         incrementCoins(potReturned.returnedAmount());
         incrementCurrentTurn();
         context
@@ -160,7 +161,7 @@ public class Participant {
                 .info(
                         "Player {} has now {} coins; started with {} for a partial profit of: {} %",
                         potReturned.participant().path().name(),
-                        String.format("%.3f", getParticipantCoins()),
+                        getParticipantCoins(),
                         getInitialCoins(),
                         calculateProfit());
 
@@ -199,8 +200,8 @@ public class Participant {
                 setCollaborateSwitch(false);
                 break;
             case JUSTICIERO:
-                // Tweak minimum amount to collaborate; average contribution must be at least the same.
+                // Tweak minimum amount to collaborate
-                setCollaborateSwitch((potReturned.returnedAmount() / participants.size() >= getParticipationForCurrentTurn()));
+                setCollaborateSwitch(potReturned.returnedAmount() > participants.size());
                 break;
         }
     }

src/main/java/dev/freireservices/social_altruism/chat/potroom/Session.java

@@ -12,8 +12,8 @@ import dev.freireservices.social_altruism.chat.potroom.PotRoomProtocol.PotRoomMe
 import dev.freireservices.social_altruism.chat.potroom.SessionProtocol.*;
 import lombok.Getter;
 
-import java.time.Duration;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 
 @Getter
 public class Session {
@@ -97,8 +97,15 @@ public class Session {
             context.getLog().info("Turn {} complete", getCurrentTurn());
 
             if (incrementCurrentTurnAndGet() == totalTurns) {
-                context.getLog().info("All turns completed - Waiting for other messages, then ending session.");
+                context.getLog().info("All turns completed");
-                context.scheduleOnce(Duration.ofSeconds(3), playTurn.session().narrow(), new EndSession());
+                context.getLog().info("Waiting for other messages, then ending session.");
+                try {
+                    TimeUnit.SECONDS.sleep(5);
+                } catch (InterruptedException e) {
+                    throw new RuntimeException(e);
+                }
+                playTurn.session().narrow().tell(new EndSession());
+
             }
         }
         return Behaviors.same();

src/test/java/dev/freireservices/social_altruism/chat/CaseStudiesTests.java

@@ -1,14 +1,17 @@
 package dev.freireservices.social_altruism.chat;
 
 import akka.actor.testkit.typed.javadsl.ActorTestKit;
+import akka.actor.testkit.typed.javadsl.BehaviorTestKit;
+import akka.actor.testkit.typed.javadsl.TestProbe;
 import akka.actor.typed.ActorRef;
 import dev.freireservices.social_altruism.chat.participant.Participant;
+import dev.freireservices.social_altruism.chat.participant.ParticipantProtocol;
 import dev.freireservices.social_altruism.chat.participant.ParticipantProtocol.ParticipantMessage;
 import dev.freireservices.social_altruism.chat.potroom.PotRoom;
 import dev.freireservices.social_altruism.chat.potroom.PotRoomProtocol;
-import org.junit.AfterClass;
 import org.junit.Test;
 
+import java.time.Duration;
 import java.util.concurrent.TimeUnit;
 
 import static dev.freireservices.social_altruism.chat.participant.ParticipantType.*;
@@ -16,13 +19,12 @@ import static dev.freireservices.social_altruism.chat.participant.ParticipantTyp
 public class CaseStudiesTests {
     public static final int INITIAL_COINS = 100;
     public static final int TOTAL_PARTICIPANTS = 3;
-    public static final int TOTAL_TURNS = 100;
+    public static final int TOTAL_TURNS = 10;
-
-    final static ActorTestKit testKit = ActorTestKit.create();
 
     @Test
     public void testCooperation() {
 
+        final ActorTestKit testKit = ActorTestKit.create();
         var potRoom = PotRoom.create(TOTAL_PARTICIPANTS, TOTAL_TURNS);
 
         ActorRef<PotRoomProtocol.PotRoomMessage> chatRoomTest =
@@ -37,21 +39,20 @@ public class CaseStudiesTests {
         ActorRef<ParticipantMessage> p3 =
                 testKit.spawn(Participant.create(INITIAL_COINS, SANTO), "SANTO-1");
 
+
+
+
+
         // Enter POT
         chatRoomTest.tell(new PotRoomProtocol.EnterPot(p1));
         chatRoomTest.tell(new PotRoomProtocol.EnterPot(p2));
         chatRoomTest.tell(new PotRoomProtocol.EnterPot(p3));
 
         try {
-            TimeUnit.MINUTES.sleep(1);
+            TimeUnit.MINUTES.sleep(3);
         } catch (InterruptedException e) {
             throw new RuntimeException(e);
         }
 
     }
-
-    @AfterClass
-    public static void cleanup() {
-        testKit.shutdownTestKit();
-    }
 }