Compare commits
12 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
fbe95c4c04 | ||
|
|
a2c2e9faf6 | ||
|
|
c8a7f22a45 | ||
|
|
4abcfc2178 | ||
|
|
70f9ad4d99 | ||
|
|
d29d2e53bd | ||
|
|
965636544e | ||
|
|
12b7224510 | ||
|
|
1d6505a2ca | ||
|
|
6cb6de28fc | ||
|
|
76e1781864 | ||
|
|
3b223dfea2 |
183
.gitignore
vendored
Normal file
183
.gitignore
vendored
Normal file
@ -0,0 +1,183 @@
|
|||||||
|
/target/
|
||||||
|
!.mvn/wrapper/maven-wrapper.jar
|
||||||
|
|
||||||
|
### STS ###
|
||||||
|
.apt_generated
|
||||||
|
.classpath
|
||||||
|
.factorypath
|
||||||
|
.project
|
||||||
|
.settings
|
||||||
|
.springBeans
|
||||||
|
.sts4-cache
|
||||||
|
|
||||||
|
|
||||||
|
# Created by https://www.gitignore.io/api/git,java,maven,eclipse,windows
|
||||||
|
|
||||||
|
### Eclipse ###
|
||||||
|
|
||||||
|
.metadata
|
||||||
|
bin/
|
||||||
|
tmp/
|
||||||
|
*.tmp
|
||||||
|
*.bak
|
||||||
|
*.swp
|
||||||
|
*~.nib
|
||||||
|
local.properties
|
||||||
|
.settings/
|
||||||
|
.loadpath
|
||||||
|
.recommenders
|
||||||
|
|
||||||
|
# External tool builders
|
||||||
|
.externalToolBuilders/
|
||||||
|
|
||||||
|
# Locally stored "Eclipse launch configurations"
|
||||||
|
*.launch
|
||||||
|
|
||||||
|
# PyDev specific (Python IDE for Eclipse)
|
||||||
|
*.pydevproject
|
||||||
|
|
||||||
|
# CDT-specific (C/C++ Development Tooling)
|
||||||
|
.cproject
|
||||||
|
|
||||||
|
# CDT- autotools
|
||||||
|
.autotools
|
||||||
|
|
||||||
|
# PDT-specific (PHP Development Tools)
|
||||||
|
.buildpath
|
||||||
|
|
||||||
|
# sbteclipse plugin
|
||||||
|
.target
|
||||||
|
|
||||||
|
# Tern plugin
|
||||||
|
.tern-project
|
||||||
|
|
||||||
|
# TeXlipse plugin
|
||||||
|
.texlipse
|
||||||
|
|
||||||
|
# Code Recommenders
|
||||||
|
.recommenders/
|
||||||
|
|
||||||
|
# Annotation Processing
|
||||||
|
.apt_generated/
|
||||||
|
|
||||||
|
# Scala IDE specific (Scala & Java development for Eclipse)
|
||||||
|
.cache-main
|
||||||
|
.scala_dependencies
|
||||||
|
.worksheet
|
||||||
|
|
||||||
|
# Annotation Processing
|
||||||
|
|
||||||
|
.sts4-cache/
|
||||||
|
|
||||||
|
### Git ###
|
||||||
|
# Created by git for backups. To disable backups in Git:
|
||||||
|
# $ git config --global mergetool.keepBackup false
|
||||||
|
*.orig
|
||||||
|
|
||||||
|
# Created by git when using merge tools for conflicts
|
||||||
|
*.BACKUP.*
|
||||||
|
*.BASE.*
|
||||||
|
*.LOCAL.*
|
||||||
|
*.REMOTE.*
|
||||||
|
*_BACKUP_*.txt
|
||||||
|
*_BASE_*.txt
|
||||||
|
*_LOCAL_*.txt
|
||||||
|
*_REMOTE_*.txt
|
||||||
|
|
||||||
|
### Java ###
|
||||||
|
# Compiled class file
|
||||||
|
*.class
|
||||||
|
|
||||||
|
# Log file
|
||||||
|
*.log
|
||||||
|
|
||||||
|
# BlueJ files
|
||||||
|
*.ctxt
|
||||||
|
|
||||||
|
# Mobile Tools for Java (J2ME)
|
||||||
|
.mtj.tmp/
|
||||||
|
|
||||||
|
# Package Files #
|
||||||
|
*.jar
|
||||||
|
*.war
|
||||||
|
*.nar
|
||||||
|
*.ear
|
||||||
|
*.zip
|
||||||
|
*.tar.gz
|
||||||
|
*.rar
|
||||||
|
|
||||||
|
# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
|
||||||
|
hs_err_pid*
|
||||||
|
|
||||||
|
### Maven ###
|
||||||
|
target/
|
||||||
|
pom.xml.tag
|
||||||
|
pom.xml.releaseBackup
|
||||||
|
pom.xml.versionsBackup
|
||||||
|
pom.xml.next
|
||||||
|
release.properties
|
||||||
|
dependency-reduced-pom.xml
|
||||||
|
buildNumber.properties
|
||||||
|
.mvn/timing.properties
|
||||||
|
.mvn/wrapper/maven-wrapper.jar
|
||||||
|
|
||||||
|
### Windows ###
|
||||||
|
# Windows thumbnail cache files
|
||||||
|
Thumbs.db
|
||||||
|
ehthumbs.db
|
||||||
|
ehthumbs_vista.db
|
||||||
|
|
||||||
|
# Dump file
|
||||||
|
*.stackdump
|
||||||
|
|
||||||
|
# Folder config file
|
||||||
|
[Dd]esktop.ini
|
||||||
|
|
||||||
|
# Recycle Bin used on file shares
|
||||||
|
$RECYCLE.BIN/
|
||||||
|
|
||||||
|
# Windows Installer files
|
||||||
|
*.cab
|
||||||
|
*.msi
|
||||||
|
*.msix
|
||||||
|
*.msm
|
||||||
|
*.msp
|
||||||
|
|
||||||
|
# Windows shortcuts
|
||||||
|
*.lnk
|
||||||
|
|
||||||
|
### IntelliJ IDEA ###
|
||||||
|
.idea
|
||||||
|
*.iws
|
||||||
|
*.iml
|
||||||
|
*.ipr
|
||||||
|
|
||||||
|
### NetBeans ###
|
||||||
|
/nbproject/private/
|
||||||
|
/nbbuild/
|
||||||
|
/dist/
|
||||||
|
/nbdist/
|
||||||
|
/.nb-gradle/
|
||||||
|
/build/
|
||||||
|
!**/src/main/**/build/
|
||||||
|
!**/src/test/**/build/
|
||||||
|
|
||||||
|
### VS Code ###
|
||||||
|
.vscode/
|
||||||
|
|
||||||
|
### Some additional ignores (sort later)
|
||||||
|
*.DS_Store
|
||||||
|
*.sw?
|
||||||
|
.#*
|
||||||
|
*#
|
||||||
|
*~
|
||||||
|
bin
|
||||||
|
build
|
||||||
|
target
|
||||||
|
*.sublime-*
|
||||||
|
/scratch
|
||||||
|
.gradle
|
||||||
|
README.html
|
||||||
|
.exercism
|
||||||
|
/target/
|
||||||
|
/.idea/
|
||||||
3
.idea/.gitignore
generated
vendored
Normal file
3
.idea/.gitignore
generated
vendored
Normal file
@ -0,0 +1,3 @@
|
|||||||
|
# Default ignored files
|
||||||
|
/shelf/
|
||||||
|
/workspace.xml
|
||||||
15
.idea/compiler.xml
generated
Normal file
15
.idea/compiler.xml
generated
Normal file
@ -0,0 +1,15 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<project version="4">
|
||||||
|
<component name="CompilerConfiguration">
|
||||||
|
<annotationProcessing>
|
||||||
|
<profile default="true" name="Default" enabled="true" />
|
||||||
|
<profile name="Maven default annotation processors profile" enabled="true">
|
||||||
|
<sourceOutputDir name="target/generated-sources/annotations" />
|
||||||
|
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
|
||||||
|
<outputRelativeToContentRoot value="true" />
|
||||||
|
<module name="social_altruism" />
|
||||||
|
</profile>
|
||||||
|
</annotationProcessing>
|
||||||
|
<bytecodeTargetLevel target="19" />
|
||||||
|
</component>
|
||||||
|
</project>
|
||||||
6
.idea/google-java-format.xml
generated
Normal file
6
.idea/google-java-format.xml
generated
Normal file
@ -0,0 +1,6 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<project version="4">
|
||||||
|
<component name="GoogleJavaFormatSettings">
|
||||||
|
<option name="enabled" value="true" />
|
||||||
|
</component>
|
||||||
|
</project>
|
||||||
17
.idea/gradle.xml
generated
Normal file
17
.idea/gradle.xml
generated
Normal file
@ -0,0 +1,17 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<project version="4">
|
||||||
|
<component name="GradleMigrationSettings" migrationVersion="1" />
|
||||||
|
<component name="GradleSettings">
|
||||||
|
<option name="linkedExternalProjectsSettings">
|
||||||
|
<GradleProjectSettings>
|
||||||
|
<option name="externalProjectPath" value="$PROJECT_DIR$" />
|
||||||
|
<option name="gradleJvm" value="corretto-19" />
|
||||||
|
<option name="modules">
|
||||||
|
<set>
|
||||||
|
<option value="$PROJECT_DIR$" />
|
||||||
|
</set>
|
||||||
|
</option>
|
||||||
|
</GradleProjectSettings>
|
||||||
|
</option>
|
||||||
|
</component>
|
||||||
|
</project>
|
||||||
35
.idea/jarRepositories.xml
generated
Normal file
35
.idea/jarRepositories.xml
generated
Normal file
@ -0,0 +1,35 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<project version="4">
|
||||||
|
<component name="RemoteRepositoriesConfiguration">
|
||||||
|
<remote-repository>
|
||||||
|
<option name="id" value="central" />
|
||||||
|
<option name="name" value="Central Repository" />
|
||||||
|
<option name="url" value="https://repo.maven.apache.org/maven2" />
|
||||||
|
</remote-repository>
|
||||||
|
<remote-repository>
|
||||||
|
<option name="id" value="MavenRepo" />
|
||||||
|
<option name="name" value="MavenRepo" />
|
||||||
|
<option name="url" value="https://repo.maven.apache.org/maven2/" />
|
||||||
|
</remote-repository>
|
||||||
|
<remote-repository>
|
||||||
|
<option name="id" value="central" />
|
||||||
|
<option name="name" value="Maven Central repository" />
|
||||||
|
<option name="url" value="https://repo1.maven.org/maven2" />
|
||||||
|
</remote-repository>
|
||||||
|
<remote-repository>
|
||||||
|
<option name="id" value="jboss.community" />
|
||||||
|
<option name="name" value="JBoss Community repository" />
|
||||||
|
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
|
||||||
|
</remote-repository>
|
||||||
|
<remote-repository>
|
||||||
|
<option name="id" value="MavenLocal" />
|
||||||
|
<option name="name" value="MavenLocal" />
|
||||||
|
<option name="url" value="file:$MAVEN_REPOSITORY$/" />
|
||||||
|
</remote-repository>
|
||||||
|
<remote-repository>
|
||||||
|
<option name="id" value="akka-repository" />
|
||||||
|
<option name="name" value="Akka library repository" />
|
||||||
|
<option name="url" value="https://repo.akka.io/maven" />
|
||||||
|
</remote-repository>
|
||||||
|
</component>
|
||||||
|
</project>
|
||||||
6
.idea/jpa-buddy.xml
generated
Normal file
6
.idea/jpa-buddy.xml
generated
Normal file
@ -0,0 +1,6 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<project version="4">
|
||||||
|
<component name="JpaBuddyIdeaProjectConfig">
|
||||||
|
<option name="renamerInitialized" value="true" />
|
||||||
|
</component>
|
||||||
|
</project>
|
||||||
16
.idea/misc.xml
generated
Normal file
16
.idea/misc.xml
generated
Normal file
@ -0,0 +1,16 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<project version="4">
|
||||||
|
<component name="ExternalStorageConfigurationManager" enabled="true" />
|
||||||
|
<component name="MavenProjectsManager">
|
||||||
|
<option name="originalFiles">
|
||||||
|
<list>
|
||||||
|
<option value="$PROJECT_DIR$/pom.xml" />
|
||||||
|
</list>
|
||||||
|
</option>
|
||||||
|
<option name="workspaceImportForciblyTurnedOn" value="true" />
|
||||||
|
</component>
|
||||||
|
<component name="ProjectRootManager" version="2" languageLevel="JDK_17" project-jdk-name="corretto-19" project-jdk-type="JavaSDK" />
|
||||||
|
<component name="ProjectType">
|
||||||
|
<option name="id" value="jpab" />
|
||||||
|
</component>
|
||||||
|
</project>
|
||||||
124
.idea/uiDesigner.xml
generated
Normal file
124
.idea/uiDesigner.xml
generated
Normal file
@ -0,0 +1,124 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<project version="4">
|
||||||
|
<component name="Palette2">
|
||||||
|
<group name="Swing">
|
||||||
|
<item class="com.intellij.uiDesigner.HSpacer" tooltip-text="Horizontal Spacer" icon="/com/intellij/uiDesigner/icons/hspacer.svg" removable="false" auto-create-binding="false" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="1" hsize-policy="6" anchor="0" fill="1" />
|
||||||
|
</item>
|
||||||
|
<item class="com.intellij.uiDesigner.VSpacer" tooltip-text="Vertical Spacer" icon="/com/intellij/uiDesigner/icons/vspacer.svg" removable="false" auto-create-binding="false" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="6" hsize-policy="1" anchor="0" fill="2" />
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JPanel" icon="/com/intellij/uiDesigner/icons/panel.svg" removable="false" auto-create-binding="false" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3" />
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JScrollPane" icon="/com/intellij/uiDesigner/icons/scrollPane.svg" removable="false" auto-create-binding="false" can-attach-label="true">
|
||||||
|
<default-constraints vsize-policy="7" hsize-policy="7" anchor="0" fill="3" />
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JButton" icon="/com/intellij/uiDesigner/icons/button.svg" removable="false" auto-create-binding="true" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="0" hsize-policy="3" anchor="0" fill="1" />
|
||||||
|
<initial-values>
|
||||||
|
<property name="text" value="Button" />
|
||||||
|
</initial-values>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JRadioButton" icon="/com/intellij/uiDesigner/icons/radioButton.svg" removable="false" auto-create-binding="true" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
|
||||||
|
<initial-values>
|
||||||
|
<property name="text" value="RadioButton" />
|
||||||
|
</initial-values>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JCheckBox" icon="/com/intellij/uiDesigner/icons/checkBox.svg" removable="false" auto-create-binding="true" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
|
||||||
|
<initial-values>
|
||||||
|
<property name="text" value="CheckBox" />
|
||||||
|
</initial-values>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JLabel" icon="/com/intellij/uiDesigner/icons/label.svg" removable="false" auto-create-binding="false" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="0" hsize-policy="0" anchor="8" fill="0" />
|
||||||
|
<initial-values>
|
||||||
|
<property name="text" value="Label" />
|
||||||
|
</initial-values>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JTextField" icon="/com/intellij/uiDesigner/icons/textField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
|
||||||
|
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
|
||||||
|
<preferred-size width="150" height="-1" />
|
||||||
|
</default-constraints>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JPasswordField" icon="/com/intellij/uiDesigner/icons/passwordField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
|
||||||
|
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
|
||||||
|
<preferred-size width="150" height="-1" />
|
||||||
|
</default-constraints>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JFormattedTextField" icon="/com/intellij/uiDesigner/icons/formattedTextField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
|
||||||
|
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
|
||||||
|
<preferred-size width="150" height="-1" />
|
||||||
|
</default-constraints>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JTextArea" icon="/com/intellij/uiDesigner/icons/textArea.svg" removable="false" auto-create-binding="true" can-attach-label="true">
|
||||||
|
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
|
||||||
|
<preferred-size width="150" height="50" />
|
||||||
|
</default-constraints>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JTextPane" icon="/com/intellij/uiDesigner/icons/textPane.svg" removable="false" auto-create-binding="true" can-attach-label="true">
|
||||||
|
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
|
||||||
|
<preferred-size width="150" height="50" />
|
||||||
|
</default-constraints>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JEditorPane" icon="/com/intellij/uiDesigner/icons/editorPane.svg" removable="false" auto-create-binding="true" can-attach-label="true">
|
||||||
|
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
|
||||||
|
<preferred-size width="150" height="50" />
|
||||||
|
</default-constraints>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JComboBox" icon="/com/intellij/uiDesigner/icons/comboBox.svg" removable="false" auto-create-binding="true" can-attach-label="true">
|
||||||
|
<default-constraints vsize-policy="0" hsize-policy="2" anchor="8" fill="1" />
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JTable" icon="/com/intellij/uiDesigner/icons/table.svg" removable="false" auto-create-binding="true" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
|
||||||
|
<preferred-size width="150" height="50" />
|
||||||
|
</default-constraints>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JList" icon="/com/intellij/uiDesigner/icons/list.svg" removable="false" auto-create-binding="true" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="6" hsize-policy="2" anchor="0" fill="3">
|
||||||
|
<preferred-size width="150" height="50" />
|
||||||
|
</default-constraints>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JTree" icon="/com/intellij/uiDesigner/icons/tree.svg" removable="false" auto-create-binding="true" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
|
||||||
|
<preferred-size width="150" height="50" />
|
||||||
|
</default-constraints>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JTabbedPane" icon="/com/intellij/uiDesigner/icons/tabbedPane.svg" removable="false" auto-create-binding="true" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
|
||||||
|
<preferred-size width="200" height="200" />
|
||||||
|
</default-constraints>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JSplitPane" icon="/com/intellij/uiDesigner/icons/splitPane.svg" removable="false" auto-create-binding="false" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
|
||||||
|
<preferred-size width="200" height="200" />
|
||||||
|
</default-constraints>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JSpinner" icon="/com/intellij/uiDesigner/icons/spinner.svg" removable="false" auto-create-binding="true" can-attach-label="true">
|
||||||
|
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JSlider" icon="/com/intellij/uiDesigner/icons/slider.svg" removable="false" auto-create-binding="true" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JSeparator" icon="/com/intellij/uiDesigner/icons/separator.svg" removable="false" auto-create-binding="false" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3" />
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JProgressBar" icon="/com/intellij/uiDesigner/icons/progressbar.svg" removable="false" auto-create-binding="true" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1" />
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JToolBar" icon="/com/intellij/uiDesigner/icons/toolbar.svg" removable="false" auto-create-binding="false" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1">
|
||||||
|
<preferred-size width="-1" height="20" />
|
||||||
|
</default-constraints>
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JToolBar$Separator" icon="/com/intellij/uiDesigner/icons/toolbarSeparator.svg" removable="false" auto-create-binding="false" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="0" hsize-policy="0" anchor="0" fill="1" />
|
||||||
|
</item>
|
||||||
|
<item class="javax.swing.JScrollBar" icon="/com/intellij/uiDesigner/icons/scrollbar.svg" removable="false" auto-create-binding="true" can-attach-label="false">
|
||||||
|
<default-constraints vsize-policy="6" hsize-policy="0" anchor="0" fill="2" />
|
||||||
|
</item>
|
||||||
|
</group>
|
||||||
|
</component>
|
||||||
|
</project>
|
||||||
7
.idea/vcs.xml
generated
Normal file
7
.idea/vcs.xml
generated
Normal file
@ -0,0 +1,7 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<project version="4">
|
||||||
|
<component name="VcsDirectoryMappings">
|
||||||
|
<mapping directory="$PROJECT_DIR$/.." vcs="Git" />
|
||||||
|
<mapping directory="$PROJECT_DIR$" vcs="Git" />
|
||||||
|
</component>
|
||||||
|
</project>
|
||||||
23
README.txt
Normal file
23
README.txt
Normal file
@ -0,0 +1,23 @@
|
|||||||
|
|
||||||
|
Juego del bien público
|
||||||
|
----------------------
|
||||||
|
- Varios jugadores.
|
||||||
|
- Reciben N monedas al comienzo.
|
||||||
|
- Hay un bote central.
|
||||||
|
|
||||||
|
- Cada turno se elige con cuántas monedas uno colabora al bote.
|
||||||
|
- Entonces, el contenido del bote se multiplica por dos y se divide entre todos los jugadores.
|
||||||
|
- Pasadas N rondas, el jugador se queda con lo que ganó + monedas iniciales.
|
||||||
|
|
||||||
|
- Tipos de jugadores:
|
||||||
|
- Pícaro: no colabora nunca.
|
||||||
|
- Santo: colabora siempre.
|
||||||
|
- Justiciero: colabora si y solo si todos los jugadores han colaborado en el turno anterior.
|
||||||
|
|
||||||
|
Comprobar distribución de ganancia según variación en tipo de jugadores; Pícaro, santo o justiciero.
|
||||||
|
|
||||||
|
10 jugadores, 100 turnos, 100 monedas iniciales.
|
||||||
|
|
||||||
|
|
||||||
|
Comprobar cómo de dispuesta está la gente a contribuir a un bien, que será compartido por todos por igual,
|
||||||
|
hayan contribuido o no.
|
||||||
122
pom.xml
Normal file
122
pom.xml
Normal file
@ -0,0 +1,122 @@
|
|||||||
|
<!-- #build-sample -->
|
||||||
|
<project>
|
||||||
|
<modelVersion>4.0.0</modelVersion>
|
||||||
|
|
||||||
|
<groupId>hello-akka-java</groupId>
|
||||||
|
<artifactId>SocialAltruism</artifactId>
|
||||||
|
<version>1.0</version>
|
||||||
|
|
||||||
|
<properties>
|
||||||
|
<akka.version>2.9.0</akka.version>
|
||||||
|
</properties>
|
||||||
|
|
||||||
|
<repositories>
|
||||||
|
<repository>
|
||||||
|
<id>akka-repository</id>
|
||||||
|
<name>Akka library repository</name>
|
||||||
|
<url>https://repo.akka.io/maven</url>
|
||||||
|
</repository>
|
||||||
|
</repositories>
|
||||||
|
|
||||||
|
<dependencies>
|
||||||
|
|
||||||
|
<!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-reload4j -->
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.slf4j</groupId>
|
||||||
|
<artifactId>slf4j-reload4j</artifactId>
|
||||||
|
<version>2.0.9</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<dependency>
|
||||||
|
<groupId>com.typesafe.akka</groupId>
|
||||||
|
<artifactId>akka-actor-typed_2.13</artifactId>
|
||||||
|
<version>${akka.version}</version>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>com.typesafe.akka</groupId>
|
||||||
|
<artifactId>akka-actor-testkit-typed_2.13</artifactId>
|
||||||
|
<version>${akka.version}</version>
|
||||||
|
<scope>test</scope>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>junit</groupId>
|
||||||
|
<artifactId>junit</artifactId>
|
||||||
|
<version>4.13.2</version>
|
||||||
|
<scope>test</scope>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.awaitility</groupId>
|
||||||
|
<artifactId>awaitility</artifactId>
|
||||||
|
<version>4.2.0</version>
|
||||||
|
<scope>test</scope>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.awaitility</groupId>
|
||||||
|
<artifactId>awaitility-proxy</artifactId>
|
||||||
|
<version>3.1.6</version>
|
||||||
|
<scope>test</scope>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<!-- https://mvnrepository.com/artifact/org.hamcrest/hamcrest -->
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.hamcrest</groupId>
|
||||||
|
<artifactId>hamcrest</artifactId>
|
||||||
|
<version>2.2</version>
|
||||||
|
<scope>test</scope>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<!-- https://mvnrepository.com/artifact/org.mockito/mockito-core -->
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.mockito</groupId>
|
||||||
|
<artifactId>mockito-core</artifactId>
|
||||||
|
<version>5.8.0</version>
|
||||||
|
<scope>test</scope>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<!-- https://mvnrepository.com/artifact/net.bytebuddy/byte-buddy -->
|
||||||
|
<dependency>
|
||||||
|
<groupId>net.bytebuddy</groupId>
|
||||||
|
<artifactId>byte-buddy</artifactId>
|
||||||
|
<version>1.14.11</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
<!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.projectlombok</groupId>
|
||||||
|
<artifactId>lombok</artifactId>
|
||||||
|
<version>1.18.30</version>
|
||||||
|
<scope>provided</scope>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
|
||||||
|
</dependencies>
|
||||||
|
<build>
|
||||||
|
<plugins>
|
||||||
|
<plugin>
|
||||||
|
<groupId>org.apache.maven.plugins</groupId>
|
||||||
|
<artifactId>maven-compiler-plugin</artifactId>
|
||||||
|
<version>3.11.0</version>
|
||||||
|
<configuration>
|
||||||
|
<source>19</source>
|
||||||
|
<target>19</target>
|
||||||
|
</configuration>
|
||||||
|
</plugin>
|
||||||
|
<plugin>
|
||||||
|
<groupId>org.codehaus.mojo</groupId>
|
||||||
|
<artifactId>exec-maven-plugin</artifactId>
|
||||||
|
<version>3.0.0</version>
|
||||||
|
<configuration>
|
||||||
|
<executable>java</executable>
|
||||||
|
<arguments>
|
||||||
|
<argument>-classpath</argument>
|
||||||
|
<classpath />
|
||||||
|
<argument>dev.freireservices.social_altruism.chat.PotQuickStart</argument>
|
||||||
|
</arguments>
|
||||||
|
</configuration>
|
||||||
|
</plugin>
|
||||||
|
</plugins>
|
||||||
|
</build>
|
||||||
|
</project>
|
||||||
@ -0,0 +1,84 @@
|
|||||||
|
package dev.freireservices.social_altruism.chat;
|
||||||
|
|
||||||
|
import akka.actor.typed.ActorRef;
|
||||||
|
import akka.actor.typed.ActorSystem;
|
||||||
|
import akka.actor.typed.Behavior;
|
||||||
|
import akka.actor.typed.Terminated;
|
||||||
|
import akka.actor.typed.javadsl.Behaviors;
|
||||||
|
import dev.freireservices.social_altruism.chat.participant.Participant;
|
||||||
|
import dev.freireservices.social_altruism.chat.participant.ParticipantProtocol;
|
||||||
|
import dev.freireservices.social_altruism.chat.potroom.PotRoom;
|
||||||
|
import dev.freireservices.social_altruism.chat.potroom.PotRoomProtocol;
|
||||||
|
|
||||||
|
import java.util.ArrayList;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
import static dev.freireservices.social_altruism.chat.participant.ParticipantType.*;
|
||||||
|
|
||||||
|
public class PotQuickStart {
|
||||||
|
|
||||||
|
public static final int MONEDAS_INIT = 100;
|
||||||
|
|
||||||
|
public static void main(String[] args) {
|
||||||
|
// #actor-system
|
||||||
|
ActorSystem.create(Main.create(), "PotRoom");
|
||||||
|
}
|
||||||
|
|
||||||
|
public static class Main {
|
||||||
|
|
||||||
|
static List<ActorRef<ParticipantProtocol.ParticipantMessage>> sessions = new ArrayList<>();
|
||||||
|
|
||||||
|
static final int numberOfParticipants = 3;
|
||||||
|
static final int numberOfTurns = 100;
|
||||||
|
|
||||||
|
public static Behavior<Void> create() {
|
||||||
|
return Behaviors.setup(
|
||||||
|
context -> {
|
||||||
|
ActorRef<PotRoomProtocol.PotRoomMessage> chatRoom =
|
||||||
|
context.spawn(
|
||||||
|
PotRoom.create(numberOfParticipants, numberOfTurns), "potRoom");
|
||||||
|
|
||||||
|
// Agregamos jugadores
|
||||||
|
final var picaroZero = Participant.create(MONEDAS_INIT, PICARO);
|
||||||
|
final var santoZero = Participant.create(MONEDAS_INIT, SANTO);
|
||||||
|
final var justiZero = Participant.create(MONEDAS_INIT, JUSTICIERO);
|
||||||
|
|
||||||
|
sessions.add(context.spawn(picaroZero, "participante-picaro-0"));
|
||||||
|
sessions.add(context.spawn(santoZero, "participante-santo-0"));
|
||||||
|
sessions.add(context.spawn(justiZero, "participante-justiciero-0"));
|
||||||
|
|
||||||
|
// Entrar en pot
|
||||||
|
for (ActorRef<ParticipantProtocol.ParticipantMessage> session : sessions) {
|
||||||
|
chatRoom.tell(new PotRoomProtocol.EnterPot(session));
|
||||||
|
}
|
||||||
|
|
||||||
|
/* for (int i = 0; i < numberOfTurns; i++) {
|
||||||
|
// Participar en cada turno cantidad diferente
|
||||||
|
for (ActorRef<ParticipantProtocol.ParticipantMessage> session : participants) {
|
||||||
|
|
||||||
|
// Pícaro
|
||||||
|
if (session.path().name().contains("participante-0")) {
|
||||||
|
chatRoom.tell(new PotRoomProtocol.PlayTurn(session, 0));
|
||||||
|
// Justiciero
|
||||||
|
} else if (session.path().name().contains("participante-1")) {
|
||||||
|
|
||||||
|
// ActorRef<Commands.RoomCommand> chatRoom, double pot,
|
||||||
|
// ActorRef<Events.SessionEvent> replyTo)
|
||||||
|
|
||||||
|
chatRoom.tell(new PotRoomProtocol.PlayTurn(session, 1));
|
||||||
|
// Santo
|
||||||
|
} else if (session.path().name().contains("participante-2")) {
|
||||||
|
chatRoom.tell(new PotRoomProtocol.PlayTurn(session, 2));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}*/
|
||||||
|
|
||||||
|
return Behaviors.receive(Void.class)
|
||||||
|
.onSignal(Terminated.class, sig -> Behaviors.stopped())
|
||||||
|
.build();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// #actor-system
|
||||||
|
}
|
||||||
@ -0,0 +1,219 @@
|
|||||||
|
package dev.freireservices.social_altruism.chat.participant;
|
||||||
|
|
||||||
|
import akka.actor.typed.ActorRef;
|
||||||
|
import akka.actor.typed.Behavior;
|
||||||
|
import akka.actor.typed.javadsl.ActorContext;
|
||||||
|
import akka.actor.typed.javadsl.Behaviors;
|
||||||
|
import dev.freireservices.social_altruism.chat.participant.ParticipantProtocol.*;
|
||||||
|
import dev.freireservices.social_altruism.chat.potroom.PotRoomProtocol.PotRoomMessage;
|
||||||
|
import dev.freireservices.social_altruism.chat.potroom.SessionProtocol;
|
||||||
|
import dev.freireservices.social_altruism.chat.potroom.SessionProtocol.SessionMessage;
|
||||||
|
import lombok.Getter;
|
||||||
|
import lombok.Setter;
|
||||||
|
|
||||||
|
import java.security.SecureRandom;
|
||||||
|
import java.time.Duration;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
import static dev.freireservices.social_altruism.chat.participant.ParticipantType.JUSTICIERO;
|
||||||
|
import static dev.freireservices.social_altruism.chat.participant.ParticipantType.SANTO;
|
||||||
|
|
||||||
|
@Setter
|
||||||
|
@Getter
|
||||||
|
public class Participant {
|
||||||
|
|
||||||
|
private final ActorContext<ParticipantMessage> context;
|
||||||
|
private ActorRef<PotRoomMessage> chatRoom;
|
||||||
|
private ActorRef<SessionMessage> session;
|
||||||
|
|
||||||
|
private boolean collaborateSwitch;
|
||||||
|
private int currentTurn;
|
||||||
|
private double participantCoins;
|
||||||
|
private final double initialCoins;
|
||||||
|
private List<ActorRef<ParticipantMessage>> participants;
|
||||||
|
private int totalTurns;
|
||||||
|
private final ParticipantType participantType;
|
||||||
|
|
||||||
|
private Participant(
|
||||||
|
ActorContext<ParticipantMessage> context,
|
||||||
|
double participantCoins,
|
||||||
|
ParticipantType participantType) {
|
||||||
|
this.context = context;
|
||||||
|
this.participantCoins = participantCoins;
|
||||||
|
this.initialCoins = participantCoins;
|
||||||
|
this.participantType = participantType;
|
||||||
|
this.collaborateSwitch = participantType == JUSTICIERO || participantType == SANTO;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static Behavior<ParticipantMessage> create(
|
||||||
|
int initialCoins, ParticipantType participantType) {
|
||||||
|
return Behaviors.setup(ctx -> new Participant(ctx, initialCoins, participantType).behavior());
|
||||||
|
}
|
||||||
|
|
||||||
|
public double decrementCoins(double coins) {
|
||||||
|
this.participantCoins -= coins;
|
||||||
|
|
||||||
|
return coins;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void incrementCoins(double coins) {
|
||||||
|
this.participantCoins += coins;
|
||||||
|
}
|
||||||
|
|
||||||
|
private Behavior<ParticipantMessage> behavior() {
|
||||||
|
return uninitialized();
|
||||||
|
}
|
||||||
|
|
||||||
|
private Behavior<ParticipantMessage> uninitialized() {
|
||||||
|
return Behaviors.receive(ParticipantMessage.class)
|
||||||
|
.onMessage(SessionDenied.class, this::onSessionDenied)
|
||||||
|
.onMessage(SessionGranted.class, x ->
|
||||||
|
{
|
||||||
|
onSessionGranted(x);
|
||||||
|
return readyToStart();
|
||||||
|
})
|
||||||
|
.build();
|
||||||
|
}
|
||||||
|
|
||||||
|
private Behavior<ParticipantMessage> readyToStart() {
|
||||||
|
return Behaviors.receive(ParticipantMessage.class)
|
||||||
|
.onMessage(SessionStarted.class,
|
||||||
|
x -> {
|
||||||
|
onSessionStarted(x);
|
||||||
|
return started();
|
||||||
|
}
|
||||||
|
)
|
||||||
|
.build();
|
||||||
|
}
|
||||||
|
|
||||||
|
private Behavior<ParticipantMessage> started() {
|
||||||
|
return Behaviors.receive(ParticipantMessage.class)
|
||||||
|
.onMessage(PotReturned.class, this::onPotReturned)
|
||||||
|
.onMessage(SessionEnded.class, this::onSessionEnded)
|
||||||
|
.build();
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private Behavior<ParticipantMessage> onSessionEnded(SessionEnded sessionEnded) {
|
||||||
|
|
||||||
|
context.getLog().info("Session ended for user: Stats: {}. Earned {} coins, profit {} %"
|
||||||
|
, context.getSelf().path().name()
|
||||||
|
, String.format("%.3f%n", getParticipantCoins() - getInitialCoins())
|
||||||
|
, calculateProfit()
|
||||||
|
);
|
||||||
|
return Behaviors.stopped();
|
||||||
|
}
|
||||||
|
|
||||||
|
private Behavior<ParticipantMessage> onSessionDenied(
|
||||||
|
SessionDenied message) {
|
||||||
|
context.getLog().info("cannot start chat room session: {}", message.reason());
|
||||||
|
return Behaviors.stopped();
|
||||||
|
}
|
||||||
|
|
||||||
|
private void onSessionGranted(
|
||||||
|
SessionGranted message) {
|
||||||
|
context.getLog().info("Session granted message received for {} ", context.getSelf().path().name());
|
||||||
|
setChatRoom(message.chatRoom());
|
||||||
|
setSession(message.session());
|
||||||
|
}
|
||||||
|
|
||||||
|
private void onSessionStarted(
|
||||||
|
SessionStarted startSession) {
|
||||||
|
context.getLog().info("Session started for {} with {} participants", context.getSelf().path().name(), startSession.participants().size());
|
||||||
|
resetCurrentTurn();
|
||||||
|
setParticipants(startSession.participants());
|
||||||
|
setTotalTurns(startSession.totalTurns());
|
||||||
|
playTurnWithSmallDelay(startSession.replyTo());
|
||||||
|
}
|
||||||
|
|
||||||
|
private void playTurnWithSmallDelay(ActorRef<SessionMessage> replyTo) {
|
||||||
|
if (getParticipantCoins() > 0 && getCurrentTurn() < getTotalTurns()) {
|
||||||
|
context.scheduleOnce(Duration.ofMillis(500),
|
||||||
|
replyTo,
|
||||||
|
new SessionProtocol.PlayTurn(
|
||||||
|
replyTo,
|
||||||
|
context.getSelf(),
|
||||||
|
participants,
|
||||||
|
getCurrentTurn(),
|
||||||
|
getParticipationForCurrentTurn())
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private double getParticipationForCurrentTurn() {
|
||||||
|
var currentTurnCoins = getRandomNumberBetween(0, Math.floor(getParticipantCoins()));
|
||||||
|
return isCollaborateSwitch() ? decrementCoins(currentTurnCoins) : 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static double getRandomNumberBetween(double min, double max) {
|
||||||
|
SecureRandom secureRandom = new SecureRandom();
|
||||||
|
return Math.round(secureRandom.nextDouble(max - min) + min);
|
||||||
|
}
|
||||||
|
|
||||||
|
private Behavior<ParticipantMessage> onPotReturned(
|
||||||
|
PotReturned potReturned) {
|
||||||
|
context.getLog().info("Pot returned: {} for participant {}", String.format("%.2f", potReturned.returnedAmount()), potReturned.participant().path().name());
|
||||||
|
incrementCoins(potReturned.returnedAmount());
|
||||||
|
incrementCurrentTurn();
|
||||||
|
context
|
||||||
|
.getLog()
|
||||||
|
.info(
|
||||||
|
"Player {} has now {} coins; started with {} for a partial profit of: {} %",
|
||||||
|
potReturned.participant().path().name(),
|
||||||
|
String.format("%.3f", getParticipantCoins()),
|
||||||
|
getInitialCoins(),
|
||||||
|
calculateProfit());
|
||||||
|
|
||||||
|
// Still game?
|
||||||
|
if (getParticipantCoins() > 1) {
|
||||||
|
playTurnWithSmallDelay(potReturned.session());
|
||||||
|
} else {
|
||||||
|
context
|
||||||
|
.getLog()
|
||||||
|
.info(
|
||||||
|
"Player {} has now {} coins; started with {} for a total profit of: {} %",
|
||||||
|
potReturned.participant().path().name(),
|
||||||
|
getParticipantCoins(),
|
||||||
|
getInitialCoins(),
|
||||||
|
calculateProfit());
|
||||||
|
|
||||||
|
context.getLog().info("END GAME");
|
||||||
|
context.getLog().info("---------");
|
||||||
|
context.getLog().info("END GAME");
|
||||||
|
|
||||||
|
context.stop(context.getSelf());
|
||||||
|
Behaviors.stopped();
|
||||||
|
|
||||||
|
}
|
||||||
|
adjustBehaviour(potReturned);
|
||||||
|
return Behaviors.same();
|
||||||
|
}
|
||||||
|
|
||||||
|
private void adjustBehaviour(PotReturned potReturned) {
|
||||||
|
|
||||||
|
switch (participantType) {
|
||||||
|
case SANTO:
|
||||||
|
setCollaborateSwitch(true);
|
||||||
|
break;
|
||||||
|
case PICARO:
|
||||||
|
setCollaborateSwitch(false);
|
||||||
|
break;
|
||||||
|
case JUSTICIERO:
|
||||||
|
// Tweak minimum amount to collaborate; average contribution must be at least the same.
|
||||||
|
setCollaborateSwitch((potReturned.returnedAmount() / participants.size() >= getParticipationForCurrentTurn()));
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public void resetCurrentTurn() {
|
||||||
|
setCurrentTurn(0);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void incrementCurrentTurn() {
|
||||||
|
setCurrentTurn(++this.currentTurn);
|
||||||
|
}
|
||||||
|
|
||||||
|
private double calculateProfit() {
|
||||||
|
return Math.round((getParticipantCoins() * 100) / getInitialCoins() - 100);
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,45 @@
|
|||||||
|
package dev.freireservices.social_altruism.chat.participant;
|
||||||
|
|
||||||
|
import akka.actor.typed.ActorRef;
|
||||||
|
import dev.freireservices.social_altruism.chat.potroom.PotRoomProtocol.PotRoomMessage;
|
||||||
|
import dev.freireservices.social_altruism.chat.potroom.SessionProtocol.SessionMessage;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
public class ParticipantProtocol {
|
||||||
|
public interface ParticipantMessage {
|
||||||
|
}
|
||||||
|
|
||||||
|
enum Timeout implements ParticipantMessage {
|
||||||
|
INSTANCE
|
||||||
|
}
|
||||||
|
|
||||||
|
public record SessionGranted(
|
||||||
|
ActorRef<PotRoomMessage> chatRoom,
|
||||||
|
ActorRef<SessionMessage> session
|
||||||
|
)
|
||||||
|
implements ParticipantMessage {
|
||||||
|
}
|
||||||
|
|
||||||
|
public record SessionStarted(
|
||||||
|
ActorRef<PotRoomMessage> chatRoom,
|
||||||
|
|
||||||
|
ActorRef<SessionMessage> replyTo,
|
||||||
|
List<ActorRef<ParticipantMessage>> participants,
|
||||||
|
int totalTurns)
|
||||||
|
implements ParticipantMessage {
|
||||||
|
}
|
||||||
|
|
||||||
|
public record SessionDenied(String reason) implements ParticipantMessage {
|
||||||
|
}
|
||||||
|
|
||||||
|
public record SessionEnded() implements ParticipantMessage {
|
||||||
|
}
|
||||||
|
|
||||||
|
public record PotReturned(
|
||||||
|
ActorRef<SessionMessage> session,
|
||||||
|
ActorRef<ParticipantMessage> participant,
|
||||||
|
double returnedAmount)
|
||||||
|
implements ParticipantMessage {
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,8 @@
|
|||||||
|
package dev.freireservices.social_altruism.chat.participant;
|
||||||
|
|
||||||
|
public enum ParticipantType {
|
||||||
|
SANTO,
|
||||||
|
JUSTICIERO,
|
||||||
|
PICARO,
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,95 @@
|
|||||||
|
package dev.freireservices.social_altruism.chat.potroom;
|
||||||
|
|
||||||
|
import akka.actor.typed.ActorRef;
|
||||||
|
import akka.actor.typed.Behavior;
|
||||||
|
import akka.actor.typed.javadsl.ActorContext;
|
||||||
|
import akka.actor.typed.javadsl.Behaviors;
|
||||||
|
import dev.freireservices.social_altruism.chat.potroom.PotRoomProtocol.EnterPot;
|
||||||
|
import dev.freireservices.social_altruism.chat.potroom.PotRoomProtocol.PotRoomMessage;
|
||||||
|
import dev.freireservices.social_altruism.chat.potroom.SessionProtocol.SessionMessage;
|
||||||
|
import lombok.Getter;
|
||||||
|
|
||||||
|
import java.net.URLEncoder;
|
||||||
|
import java.util.ArrayList;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
import static dev.freireservices.social_altruism.chat.participant.ParticipantProtocol.*;
|
||||||
|
import static java.nio.charset.StandardCharsets.UTF_8;
|
||||||
|
|
||||||
|
@Getter
|
||||||
|
public class PotRoom {
|
||||||
|
private final ActorContext<PotRoomMessage> context;
|
||||||
|
private final List<ActorRef<ParticipantMessage>> participants;
|
||||||
|
|
||||||
|
private final int totalTurns;
|
||||||
|
private final int numberOfParticipants;
|
||||||
|
|
||||||
|
private PotRoom(
|
||||||
|
ActorContext<PotRoomMessage> context,
|
||||||
|
int numberOfParticipants,
|
||||||
|
int totalTurns) {
|
||||||
|
this.context = context;
|
||||||
|
this.participants = new ArrayList<>();
|
||||||
|
this.numberOfParticipants = numberOfParticipants;
|
||||||
|
this.totalTurns = totalTurns;
|
||||||
|
}
|
||||||
|
|
||||||
|
private Behavior<PotRoomMessage> onGetPotSession(
|
||||||
|
ActorRef<PotRoomMessage> chatRoom, EnterPot enterPot) {
|
||||||
|
|
||||||
|
validate(enterPot);
|
||||||
|
|
||||||
|
context.getLog().info("Participant joined {} pot", enterPot.replyTo().path().name());
|
||||||
|
|
||||||
|
ActorRef<ParticipantMessage> participant = enterPot.replyTo();
|
||||||
|
|
||||||
|
participants.add(participant);
|
||||||
|
|
||||||
|
if (getNumberOfParticipants() == participants.size()) {
|
||||||
|
context.getLog().info("All participants joined; pot is ready to start.");
|
||||||
|
|
||||||
|
ActorRef<SessionMessage> session =
|
||||||
|
context.spawn(
|
||||||
|
Session.create(participants, totalTurns),
|
||||||
|
URLEncoder.encode(enterPot.replyTo().path().name(), UTF_8));
|
||||||
|
|
||||||
|
|
||||||
|
// Communicate session start and share pot info with all participants
|
||||||
|
//Fishy, probably could spare one..
|
||||||
|
participants.forEach(p -> p.tell(new SessionGranted(chatRoom, session.narrow())));
|
||||||
|
participants.forEach(p -> p.tell(new SessionStarted(chatRoom, session, participants, totalTurns)));
|
||||||
|
|
||||||
|
return createPotBehaviour(chatRoom);
|
||||||
|
} else {
|
||||||
|
// Waiting for more participants
|
||||||
|
context.getLog().info("Waiting for {} more participant(s).", numberOfParticipants - participants.size());
|
||||||
|
return Behaviors.same();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void validate(EnterPot enterPot) {
|
||||||
|
// Add check session started
|
||||||
|
if (participants.stream()
|
||||||
|
.anyMatch(
|
||||||
|
s ->
|
||||||
|
s.path()
|
||||||
|
.name()
|
||||||
|
.equals(URLEncoder.encode(enterPot.replyTo().path().name(), UTF_8)))) {
|
||||||
|
|
||||||
|
enterPot.replyTo().tell(new SessionDenied("Can only enter a pot once"));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private Behavior<PotRoomMessage> createPotBehaviour(ActorRef<PotRoomMessage> chatRoom) {
|
||||||
|
return Behaviors.receive(PotRoomMessage.class)
|
||||||
|
.onMessage(EnterPot.class, x -> onGetPotSession(chatRoom, x))
|
||||||
|
.build();
|
||||||
|
}
|
||||||
|
|
||||||
|
public static Behavior<PotRoomMessage> create(int numberOfParticipants, int totalTurns) {
|
||||||
|
return Behaviors.setup(
|
||||||
|
ctx -> new PotRoom(ctx, numberOfParticipants, totalTurns)
|
||||||
|
.createPotBehaviour(ctx.getSelf()));
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,12 @@
|
|||||||
|
package dev.freireservices.social_altruism.chat.potroom;
|
||||||
|
|
||||||
|
import akka.actor.typed.ActorRef;
|
||||||
|
|
||||||
|
import static dev.freireservices.social_altruism.chat.participant.ParticipantProtocol.ParticipantMessage;
|
||||||
|
|
||||||
|
public class PotRoomProtocol {
|
||||||
|
public interface PotRoomMessage {}
|
||||||
|
|
||||||
|
public record EnterPot(ActorRef<ParticipantMessage> replyTo)
|
||||||
|
implements PotRoomMessage {}
|
||||||
|
}
|
||||||
@ -0,0 +1,129 @@
|
|||||||
|
package dev.freireservices.social_altruism.chat.potroom;
|
||||||
|
|
||||||
|
import akka.actor.typed.ActorRef;
|
||||||
|
import akka.actor.typed.Behavior;
|
||||||
|
import akka.actor.typed.javadsl.ActorContext;
|
||||||
|
import akka.actor.typed.javadsl.Behaviors;
|
||||||
|
import dev.freireservices.social_altruism.chat.participant.ParticipantProtocol.ParticipantMessage;
|
||||||
|
import dev.freireservices.social_altruism.chat.participant.ParticipantProtocol.PotReturned;
|
||||||
|
import dev.freireservices.social_altruism.chat.participant.ParticipantProtocol.SessionEnded;
|
||||||
|
import dev.freireservices.social_altruism.chat.participant.ParticipantProtocol.SessionStarted;
|
||||||
|
import dev.freireservices.social_altruism.chat.potroom.PotRoomProtocol.PotRoomMessage;
|
||||||
|
import dev.freireservices.social_altruism.chat.potroom.SessionProtocol.*;
|
||||||
|
import lombok.Getter;
|
||||||
|
|
||||||
|
import java.time.Duration;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
@Getter
|
||||||
|
public class Session {
|
||||||
|
|
||||||
|
private final ActorContext<SessionMessage> context;
|
||||||
|
private int currentTurn = 0;
|
||||||
|
private final int totalTurns;
|
||||||
|
private final List<ActorRef<ParticipantMessage>> participants;
|
||||||
|
|
||||||
|
private double currentPot = 0.0;
|
||||||
|
private int numberOfParticipantsInCurrentTurn;
|
||||||
|
|
||||||
|
|
||||||
|
public Session(ActorContext<SessionMessage> context, List<ActorRef<ParticipantMessage>> participants, int totalTurns) {
|
||||||
|
this.context = context;
|
||||||
|
this.participants = participants;
|
||||||
|
this.totalTurns = totalTurns;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public void resetPot() {
|
||||||
|
this.currentPot = 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void addToPot(double pot) {
|
||||||
|
currentPot += pot;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void incrementParticipantsInTurn() {
|
||||||
|
this.numberOfParticipantsInCurrentTurn++;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void resetNumberOfParticipantsInTurn() {
|
||||||
|
this.numberOfParticipantsInCurrentTurn = 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
public int incrementCurrentTurnAndGet() {
|
||||||
|
return ++this.currentTurn;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public Behavior<SessionMessage> createSessionBehaviour() {
|
||||||
|
return Behaviors.receive(SessionMessage.class)
|
||||||
|
.onMessage(StartSession.class, startSession -> onSessionStarted(startSession.chatRoom()
|
||||||
|
, startSession.replyTo(), startSession.participants(), totalTurns))
|
||||||
|
.onMessage(PlayTurn.class, this::onPlayTurn)
|
||||||
|
.onMessage(EndSession.class, endSession -> onSessionEnded(participants))
|
||||||
|
.onMessage(ShareReturnPotWithParticipants.class,
|
||||||
|
sharePot -> onReturnPotToParticipants(sharePot.session(), sharePot.participants(), sharePot.returnedAmount()))
|
||||||
|
.build();
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public static Behavior<SessionMessage> create(List<ActorRef<ParticipantMessage>> participants, int totalTurns) {
|
||||||
|
return Behaviors.setup(context -> new Session(context, participants, totalTurns)
|
||||||
|
.createSessionBehaviour());
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private Behavior<SessionMessage> onPlayTurn(
|
||||||
|
PlayTurn playTurn) {
|
||||||
|
context.getLog()
|
||||||
|
.info("Participant {} joined for turn {} with {}",
|
||||||
|
playTurn.replyTo().path().name(),
|
||||||
|
playTurn.turn(),
|
||||||
|
playTurn.pot());
|
||||||
|
|
||||||
|
// Add to current pot
|
||||||
|
addToPot(playTurn.pot());
|
||||||
|
incrementParticipantsInTurn();
|
||||||
|
|
||||||
|
if (getNumberOfParticipantsInCurrentTurn() == participants.size()) {
|
||||||
|
|
||||||
|
double amountToShare = (getCurrentPot() * 2) / participants.size();
|
||||||
|
|
||||||
|
playTurn.session().narrow().tell(new ShareReturnPotWithParticipants(playTurn.session(), playTurn.participants(), amountToShare));
|
||||||
|
|
||||||
|
resetPot();
|
||||||
|
resetNumberOfParticipantsInTurn();
|
||||||
|
|
||||||
|
context.getLog().info("Turn {} complete", getCurrentTurn());
|
||||||
|
|
||||||
|
if (incrementCurrentTurnAndGet() == totalTurns) {
|
||||||
|
context.getLog().info("All turns completed - Waiting for other messages, then ending session.");
|
||||||
|
context.scheduleOnce(Duration.ofSeconds(3), playTurn.session().narrow(), new EndSession());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return Behaviors.same();
|
||||||
|
}
|
||||||
|
|
||||||
|
private Behavior<SessionMessage> onSessionEnded(List<ActorRef<ParticipantMessage>> participants) {
|
||||||
|
participants.forEach(participant -> participant.tell(new SessionEnded()));
|
||||||
|
return Behaviors.stopped();
|
||||||
|
}
|
||||||
|
|
||||||
|
private static Behavior<SessionMessage> onSessionStarted(
|
||||||
|
ActorRef<PotRoomMessage> chatRoom,
|
||||||
|
ActorRef<SessionMessage> session,
|
||||||
|
List<ActorRef<ParticipantMessage>> participants,
|
||||||
|
int totalTurns) {
|
||||||
|
participants.forEach(s -> s.tell(new SessionStarted(chatRoom, session, participants, totalTurns)));
|
||||||
|
return Behaviors.same();
|
||||||
|
}
|
||||||
|
|
||||||
|
private static Behavior<SessionMessage> onReturnPotToParticipants(
|
||||||
|
ActorRef<SessionMessage> session,
|
||||||
|
List<ActorRef<ParticipantMessage>> participants,
|
||||||
|
double returnedAmount) {
|
||||||
|
participants.forEach(participant -> participant.tell(new PotReturned(session, participant, returnedAmount)));
|
||||||
|
return Behaviors.same();
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,42 @@
|
|||||||
|
package dev.freireservices.social_altruism.chat.potroom;
|
||||||
|
|
||||||
|
import akka.actor.typed.ActorRef;
|
||||||
|
import dev.freireservices.social_altruism.chat.participant.ParticipantProtocol.ParticipantMessage;
|
||||||
|
import dev.freireservices.social_altruism.chat.potroom.PotRoomProtocol.PotRoomMessage;
|
||||||
|
import lombok.Getter;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
@Getter
|
||||||
|
public class SessionProtocol {
|
||||||
|
|
||||||
|
public interface SessionMessage {
|
||||||
|
}
|
||||||
|
|
||||||
|
public record StartSession(
|
||||||
|
ActorRef<PotRoomMessage> chatRoom,
|
||||||
|
ActorRef<SessionMessage> replyTo,
|
||||||
|
List<ActorRef<ParticipantMessage>> participants)
|
||||||
|
implements SessionMessage {
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public record PlayTurn(
|
||||||
|
ActorRef<SessionMessage> session,
|
||||||
|
ActorRef<ParticipantMessage> replyTo,
|
||||||
|
List<ActorRef<ParticipantMessage>> participants,
|
||||||
|
int turn,
|
||||||
|
double pot)
|
||||||
|
implements SessionMessage {
|
||||||
|
}
|
||||||
|
|
||||||
|
public record ShareReturnPotWithParticipants(
|
||||||
|
ActorRef<SessionMessage> session,
|
||||||
|
List<ActorRef<ParticipantMessage>> participants,
|
||||||
|
double returnedAmount) implements SessionMessage {
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public record EndSession() implements SessionMessage { }
|
||||||
|
|
||||||
|
}
|
||||||
18
src/main/resources/log4j.xml
Normal file
18
src/main/resources/log4j.xml
Normal file
@ -0,0 +1,18 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8" ?>
|
||||||
|
<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">
|
||||||
|
<log4j:configuration debug="true"
|
||||||
|
xmlns:log4j='http://jakarta.apache.org/log4j/'>
|
||||||
|
|
||||||
|
<appender name="console" class="org.apache.log4j.ConsoleAppender">
|
||||||
|
<layout class="org.apache.log4j.PatternLayout">
|
||||||
|
<param name="ConversionPattern"
|
||||||
|
value="%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L - %m%n" />
|
||||||
|
</layout>
|
||||||
|
</appender>
|
||||||
|
|
||||||
|
<root>
|
||||||
|
<level value="DEBUG" />
|
||||||
|
<appender-ref ref="console" />
|
||||||
|
</root>
|
||||||
|
|
||||||
|
</log4j:configuration>
|
||||||
@ -0,0 +1,57 @@
|
|||||||
|
package dev.freireservices.social_altruism.chat;
|
||||||
|
|
||||||
|
import akka.actor.testkit.typed.javadsl.ActorTestKit;
|
||||||
|
import akka.actor.typed.ActorRef;
|
||||||
|
import dev.freireservices.social_altruism.chat.participant.Participant;
|
||||||
|
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.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
|
import static dev.freireservices.social_altruism.chat.participant.ParticipantType.*;
|
||||||
|
|
||||||
|
public class CaseStudiesTests {
|
||||||
|
public static final int INITIAL_COINS = 100;
|
||||||
|
public static final int TOTAL_PARTICIPANTS = 3;
|
||||||
|
public static final int TOTAL_TURNS = 100;
|
||||||
|
|
||||||
|
final static ActorTestKit testKit = ActorTestKit.create();
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testCooperation() {
|
||||||
|
|
||||||
|
var potRoom = PotRoom.create(TOTAL_PARTICIPANTS, TOTAL_TURNS);
|
||||||
|
|
||||||
|
ActorRef<PotRoomProtocol.PotRoomMessage> chatRoomTest =
|
||||||
|
testKit.spawn(potRoom, "potRoom");
|
||||||
|
|
||||||
|
ActorRef<ParticipantMessage> p1 =
|
||||||
|
testKit.spawn(Participant.create(INITIAL_COINS, PICARO), "PICARO-1");
|
||||||
|
|
||||||
|
ActorRef<ParticipantMessage> p2 =
|
||||||
|
testKit.spawn(Participant.create(INITIAL_COINS, JUSTICIERO), "JUSTICIERO-1");
|
||||||
|
|
||||||
|
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);
|
||||||
|
} catch (InterruptedException e) {
|
||||||
|
throw new RuntimeException(e);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
@AfterClass
|
||||||
|
public static void cleanup() {
|
||||||
|
testKit.shutdownTestKit();
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,108 @@
|
|||||||
|
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.Test;
|
||||||
|
|
||||||
|
import java.time.Duration;
|
||||||
|
|
||||||
|
import static dev.freireservices.social_altruism.chat.participant.ParticipantType.*;
|
||||||
|
|
||||||
|
public class ProtocolTests {
|
||||||
|
public static final int INITIAL_COINS = 100;
|
||||||
|
public static final int TOTAL_PARTICIPANTS = 4;
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testSessionStartedOnJoinParticipants() {
|
||||||
|
|
||||||
|
final ActorTestKit testKit = ActorTestKit.create();
|
||||||
|
|
||||||
|
TestProbe<ParticipantMessage> testProbe =
|
||||||
|
testKit.createTestProbe("TestProbe", ParticipantMessage.class);
|
||||||
|
|
||||||
|
var potRoom = PotRoom.create(TOTAL_PARTICIPANTS, 1);
|
||||||
|
ActorRef<PotRoomProtocol.PotRoomMessage> chatRoomTest =
|
||||||
|
testKit.spawn(potRoom, "potRoom");
|
||||||
|
|
||||||
|
BehaviorTestKit<PotRoomProtocol.PotRoomMessage> test = BehaviorTestKit.create(potRoom);
|
||||||
|
|
||||||
|
ActorRef<ParticipantMessage> p1 =
|
||||||
|
testKit.spawn(Participant.create(INITIAL_COINS, PICARO), "PICARO-1");
|
||||||
|
|
||||||
|
ActorRef<ParticipantMessage> p2 =
|
||||||
|
testKit.spawn(Participant.create(INITIAL_COINS, JUSTICIERO), "JUSTICIERO-1");
|
||||||
|
|
||||||
|
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));
|
||||||
|
chatRoomTest.tell(new PotRoomProtocol.EnterPot(testProbe.ref()));
|
||||||
|
|
||||||
|
//Session started
|
||||||
|
|
||||||
|
testProbe.expectMessageClass(ParticipantProtocol.SessionGranted.class, Duration.ofSeconds(20));
|
||||||
|
testProbe.expectMessageClass(ParticipantProtocol.SessionStarted.class, Duration.ofSeconds(20));
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testActorGetsSessionGranted() {
|
||||||
|
final ActorTestKit testKit = ActorTestKit.create();
|
||||||
|
TestProbe<ParticipantMessage> testProbe =
|
||||||
|
testKit.createTestProbe("TestProbe");
|
||||||
|
|
||||||
|
ActorRef<PotRoomProtocol.PotRoomMessage> chatRoomTest =
|
||||||
|
testKit.spawn(PotRoom.create(1, 1), "chatRoom");
|
||||||
|
|
||||||
|
chatRoomTest.tell(new PotRoomProtocol.EnterPot(testProbe.ref()));
|
||||||
|
|
||||||
|
testProbe.expectMessageClass(ParticipantProtocol.SessionGranted.class, Duration.ofSeconds(10));
|
||||||
|
|
||||||
|
// #assert
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testActorGetsSessionDenied() {
|
||||||
|
final ActorTestKit testKit = ActorTestKit.create();
|
||||||
|
TestProbe<ParticipantMessage> testProbe =
|
||||||
|
testKit.createTestProbe("TestProbe");
|
||||||
|
|
||||||
|
ActorRef<PotRoomProtocol.PotRoomMessage> chatRoomTest =
|
||||||
|
testKit.spawn(PotRoom.create(2, 1), "chatRoom");
|
||||||
|
|
||||||
|
chatRoomTest.tell(new PotRoomProtocol.EnterPot(testProbe.ref()));
|
||||||
|
chatRoomTest.tell(new PotRoomProtocol.EnterPot(testProbe.ref()));
|
||||||
|
|
||||||
|
testProbe.expectMessageClass(ParticipantProtocol.SessionDenied.class, Duration.ofSeconds(5));
|
||||||
|
|
||||||
|
// #assert
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testMultipleSessions() {
|
||||||
|
final ActorTestKit testKit = ActorTestKit.create();
|
||||||
|
TestProbe<ParticipantMessage> testProbe =
|
||||||
|
testKit.createTestProbe("TestProbe");
|
||||||
|
|
||||||
|
ActorRef<PotRoomProtocol.PotRoomMessage> chatRoomTest =
|
||||||
|
testKit.spawn(PotRoom.create(2, 1), "chatRoom");
|
||||||
|
|
||||||
|
chatRoomTest.tell(new PotRoomProtocol.EnterPot(testProbe.ref()));
|
||||||
|
chatRoomTest.tell(new PotRoomProtocol.EnterPot(testProbe.ref()));
|
||||||
|
|
||||||
|
testProbe.expectMessageClass(ParticipantProtocol.SessionDenied.class, Duration.ofSeconds(5));
|
||||||
|
|
||||||
|
// #assert
|
||||||
|
}
|
||||||
|
}
|
||||||
Loading…
x
Reference in New Issue
Block a user