Optionnel) ajouter les bons joueurs à la partie #

Rejoindre un rendez-vous (créer un rendez-vous complet) #

Dans ModeleFileAttente, ajouter creerRendezVousComplet

public class ModeleFileAttente implements Model, WatchJson, WriteObjectGraph {

        // ...

        // s'assurer d'avoir 
        private int indiceRendezVousParId(String idRendezVous) {
            int indice = -1;

            for(int i = 0; i < rendezVousDansOrdre.size(); i++) {
                if(rendezVousDansOrdre.get(i).siIdEst(idRendezVous)) {
                    indice = i;
                    break;
                }
            }

            return indice;
        }

        // ajouter
        public RendezVousComplet creerRendezVousComplet(String idRendezVous, Joueur deuxiemeJoueur) {

            int indiceRendezVous = indiceRendezVousParId(idRendezVous);
            RendezVous rendezVous = rendezVousDansOrdre.get(indiceRendezVous);

            RendezVousComplet rendezVousComplet = null;

            if(rendezVous != null) {

                rendezVousComplet = rendezVous.creerRendezVousComplet(deuxiemeJoueur);

                rendezVousDansOrdre.set(indiceRendezVous, rendezVousComplet);

            }

            return rendezVousComplet;
        }

    }

Créer le MsgRejoindreRendezVous

public class MsgRejoindreRendezVous extends Message<MsgRejoindreRendezVous> {

        private String idRendezVous;
        private Joueur joueur;

        public MsgRejoindreRendezVous setIdRendezVous(String idRendezVous) {
            this.idRendezVous = idRendezVous;

            return this;
        }

        public MsgRejoindreRendezVous setJoueur(Joueur joueur) {
            this.joueur = joueur;

            return this;
        }

        public RendezVousComplet appliquerA(ModeleFileAttente fileAttente) {

            return fileAttente.creerRendezVousComplet(idRendezVous, joueur);

        }

    }

Déclarer le message dans Declarations

public class Declarations {

        public static void declarerMessages(MessageRegistrar registrar) {
            // ...

            // ajouter
            registrar.registerMessage(MsgRejoindreRendezVous.class);
        }

Sur un rendez-vous partiel, envoyer MsgRejoindreRendezVous

public class FragmentRendezVous extends ViewFx {

        // ...

        // s'assurer d'avoir
        protected Button getBoutonDebuterPartie() {
            return boutonDebuterPartie;
        }

        // s'assurer d'avoir
        public void memoriserIdRendezVous(String idRendezVous) {

            // ...

            // ajouter
            installerMsgRejoindreRendezVous(idRendezVous);
        }

        private void installerMsgRejoindreRendezVous(String idRendezVous) {

            boutonDebuterPartie.setOnAction(evtFx -> {

                Ntro.session(SessionPong.class)
                    .envoyerMsgRejoindreRendezVous(idRendezVous);

            });
        }

Sur un rendez-vous complet, afficher la partie

public class FragmentRendezVousComplet extends FragmentRendezVous {

        // ...

        @Override
        public void initialize() {
            super.initialize();

            // ...

            // ajouter
            installerEvtAfficherPartie();
        }

        private void installerEvtAfficherPartie() {

            getBoutonDebuterPartie().setOnAction(evtFx -> {

                Ntro.newEvent(EvtAfficherPartie.class)
                    .trigger();

            });
        }

Dans SessionPong, ajouter la méthode envoyerMsgRejoindreRendezVous

public class SessionPong extends Session<SessionPong> {

        // ...


        // ajouter
        public SessionPong envoyerMsgRejoindreRendezVous(String idRendezVous) {
            Ntro.newMessage(MsgRejoindreRendezVous.class)
                .setIdRendezVous(idRendezVous)
                .setJoueur(MaquetteJoueurs.joueurAleatoire(this.sessionId()))
                .send();

            return this;
        }

Ajouter les joueurs dans la partie #

Dans ModelePartie, ajouter

public class ModelePartie implements Model {

        // s'assurer d'avoir
        private String                     idRendezVous          = null;

        // s'assurer d'avoir
        private Map<Position, InfoJoueur>  infoJoueurParPosition = new HashMap<>(); 


        // ajouter
        public ModelePartie setIdRendezVous(String idRendezVous) {
            this.idRendezVous = idRendezVous;

            return this;
        }


        // ajouter
        public ModelePartie ajouterJoueur(Position position, Joueur joueur) {
            infoJoueurParPosition.put(position, new InfoJoueur(joueur));

            return this;
        }

Créer la partie (en réaction à la création d’un rendez-vous complet) #

Créer le MsgCreerPartie

public class MsgCreerPartie extends Message<MsgCreerPartie> {

        private String idRendezVous;
        private Joueur premierJoueur;
        private Joueur deuxiemeJoueur;

        public MsgCreerPartie setIdRendezVous(String idRendezVous) {

            this.idRendezVous = idRendezVous;

            return this;
        }

        public MsgCreerPartie setPremierJoueur(Joueur premierJoueur) {
            this.premierJoueur = premierJoueur;

            return this;
        }

        public MsgCreerPartie setDeuxiemeJoueur(Joueur deuxiemeJoueur) {
            this.deuxiemeJoueur = deuxiemeJoueur;

            return this;
        }

        public void appliquerA(ModelePartie partie) {

            partie.setIdRendezVous(idRendezVous)
                  .ajouterJoueur(Position.GAUCHE, premierJoueur)
                  .ajouterJoueur(Position.DROITE, deuxiemeJoueur);

        }
    }

Déclarer le message dans Declarations

public class Declarations {

        public static void declarerMessages(MessageRegistrar registrar) {
            // ...

            // ajouter
            registrar.registerMessage(MsgCreerPartie.class);
        }

Dans ModifierFileAttente, ajouter

public class ModifierFileAttente {

        public static void creerTaches(BackendTasks tasks) {

            tasks.taskGroup("ModifierFileAttente")

                 .waitsFor(model(ModeleFileAttente.class))

                 .contains(subTasks -> {

                     // ...

                     // s'assurer d'avoir
                     rejoindreRendezVous(subTasks);

                     // ajouter
                     envoyerMsgCreerPartie(subTasks);

                 });
        }

        private static void rejoindreRendezVous(BackendTasks subTasks) {
            subTasks.task("rejoindreRendezVous")

                 .waitsFor(model(ModeleFileAttente.class))

                 .waitsFor(message(MsgRejoindreRendezVous.class))

                 // modifier
                 .executesAndReturnsValue(inputs -> {

                     MsgRejoindreRendezVous msgRejoindreRendezVous = inputs.get(message(MsgRejoindreRendezVous.class));
                     ModeleFileAttente      fileAttente            = inputs.get(model(ModeleFileAttente.class));

                     RendezVousComplet rendezVousComplet = msgRejoindreRendezVous.appliquerA(fileAttente);

                     // modifier
                     return rendezVousComplet;

                 });
        }

        // ajouter
        private static void envoyerMsgCreerPartie(BackendTasks subTasks) {
            subTasks.task("envoyerMsgCreerPartie")

                 .waitsFor("rejoindreRendezVous")

                 .executes(inputs -> {

                     RendezVousComplet rendezVousComplet = inputs.get("rejoindreRendezVous");

                     if(rendezVousComplet != null) {

                         rendezVousComplet.envoyerMsgCreerPartie();

                     }
                 });
        }

Dans ModifierPartie, ajouter

public class ModifierPartie {

        public static void creerTaches(BackendTasks tasks) {

            tasks.taskGroup("ModifierPartie")

                 .waitsFor(model(ModelePartie.class))

                  .contains(subTasks -> {

                        // ajouter
                        creerPartie(subTasks);

                        // ...

                  });
        }

        // ajouter
        private static void creerPartie(BackendTasks subTasks) {

            subTasks.task("creerPartie")

                    .waitsFor(model(ModelePartie.class))

                    .waitsFor(message(MsgCreerPartie.class))

                    .executes(inputs -> {

                        MsgCreerPartie msgCreerPartie = inputs.get(message(MsgCreerPartie.class));
                        ModelePartie   partie         = inputs.get(model(ModelePartie.class));

                        msgCreerPartie.appliquerA(partie);

                 });
        }

Le graphe de tâche du Dorsal devrait contenir