Define Client API

[juan-medina]

API Proposal:

class MyExample(){

  private Bridge bridge;

  private void newsTopic(final Message message){
    System.out.println(message.getSubscriber() + " has news: " + message.getText());
  }

  private void helloTopic(final Message message){
    bridge.publish("hello", "hello " + message.getSubscriber());
  }

  public void run(){
    bridge = BrigeBuilder.connect("http://localhost:8080")
       .subscribe("news", this::newsTopic)
       .subscribe("hello", this::helloTopic)
       .options(Options.discardOwnMessages, true)                   
       .options(Options.refresh, 1500)
       .options(Options.logMessages, true)
       .build();

    bridge.publish("hello", "hello world");
  }
}

[juan-medina]

@jabrena Do you like the initial one or this:

class MyExample(){

  private Bridge bridge;

  private void newsTopic(final Message message){
    System.out.println(message.getSubscriber() + " has news: " + message.getText());
  }

  private void helloTopic(final Message message){
    bridge.publish("hello", "hello " + message.getSubscriber());
  }

  public void run(){
    bridge = BrigeBuilder.connect("http://localhost:8080")
       .subscribe("news", this::newsTopic)
       .subscribe("hello", this::helloTopic)
       .discardOwnMessages(true)                   
       .refresh(1500)
       .logMessages(true)
       .build();

    bridge.publish("hello", "hello world");
  }
}

[jabrena]

I think that it is nice to begin.

[juan-medina]

which one? second or first?

[jabrena]

The second one.

[jabrena]

The usage of the client is easy with this Java client. I added this snapshot in the Gradle:

repositories {
    maven { url "https://jitpack.io" }
}

dependencies {
    compile("com.github.cloud-robots.bridge:cloud-robots.bridge.client:0.1.0-SNAPSHOT")
}

and later, I created a simple HelloWorld example:

package examples;

import cloud.robots.bridge.client.Bridge;
import cloud.robots.bridge.client.exceptions.BridgeException;
import cloud.robots.bridge.client.internal.BridgeBuilderFactory;
import cloud.robots.bridge.client.model.Message;

/**
 * Created by @jabrena on 10/7/17.
 * Using the notes from Unit tests from @juan-medina
 */
public class Demo {

    private static final String TEST_URL = "https://brick-bridge.herokuapp.com/";
    private static final int TIMEOUT = 1500;
    private static final int REFRESH = 1500;
    private static final int WAIT = 1000;

    private static Bridge bridge;

    private static boolean endTest = false;

    private static void helloMessage(Message message){
        try {
            System.out.println("got a hello: '" + message.getText() + "', from: '" + message.getSubscriber() + "'");
            bridge.send("news", "the news is that we got a hello");
        } catch (BridgeException e) {
            e.printStackTrace();
        }
    }

    private static void newsMessage(Message message) {
        System.out.println("got news: '" + message.getText() + "', from: '" + message.getSubscriber() + "'");
        endTest = true;
    }

    public static void main(String[] args) throws BridgeException, InterruptedException {

        bridge = BridgeBuilderFactory.Default()
                .connect(TEST_URL)
                .timeout(TIMEOUT)
                .subscribe("hello", Demo::helloMessage)
                .subscribe("news", Demo::newsMessage)
                .refresh(REFRESH)
                .build();

        bridge.send("hello", "hello world");

        //TODO: Review this block
        while(!endTest){
            Thread.sleep(WAIT);
        }

        bridge.stop();

    }
}

Output:

got a hello: 'hello world', from: '4709b116-277a-4b78-9161-886a83f0e3fd'
got news: 'the news is that we got a hello', from: '4709b116-277a-4b78-9161-886a83f0e3fd'

[jabrena]

In the next days, I will work in a simple example running on 2 Bricks to manage some states.

[jabrena]

Prototype running with a Simple State machine:
Original idea: https://gist.github.com/jabrena/70217b9b4f07f301457d6ba60e90a4db

package examples;

import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.function.Function;
import java.util.stream.Collectors;
import java.util.stream.Stream;

public enum CardTypes {

        ROCK("ROCK"),
        PAPER("PAPER"),
        SCISSORS("SCISSORS"),
        LIZARD("LIZARD"),
        SPOCK("SPOCK");

        private CardTypes(String name) { }

        private static final Map<String, CardTypes> MAP =
                Stream.of(CardTypes.values())
                        .collect(Collectors
                        .toMap(Enum::name, Function.identity()));

        public static CardTypes fromName(String name){
            return MAP.get(name);
        }

        public static final List<CardTypes> cardTypesList = Arrays.asList(CardTypes.values());

        public static List<CardTypes> getList(){
            return cardTypesList;
        }

    }

package examples;

import cloud.robots.bridge.client.Bridge;
import cloud.robots.bridge.client.exceptions.BridgeException;
import cloud.robots.bridge.client.internal.BridgeBuilderFactory;
import cloud.robots.bridge.client.model.Message;

import java.util.HashSet;
import java.util.List;
import java.util.Random;
import java.util.Set;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * Created by jabrena on 10/7/17.
 */
public class RPSSL {

    //Bridge Configuration
    private static final String TEST_URL = "https://brick-bridge.herokuapp.com/";
    private static final int TIMEOUT = 15000;
    private static final int REFRESH = 150;
    private static final int WAIT = 100;

    private static Bridge bridge;

    //Business Logic

    private static String player;
    private static Set<String> playerList = new HashSet<>();

    private static final int MAX_ITERATIONS = 100;
    private static AtomicInteger counter = new AtomicInteger(0);

    private static String STATE;
    private static String CARD_VALUE;

    //TODO Interface for listener?
    private static void messageListener(Message message){

        String RAW_CMD = message.getText();
        String[] PROTOCOL = RAW_CMD.split(":");

        if(STATE.equals("WAITING")) {
            System.out.println("Adding new player");
            playerList.add(message.getSubscriber());

            playerList.stream().forEach(System.out::println);
        }

        if(STATE.equals("PLAYING")) {

            if(!player.equals(message.getSubscriber())){

                if((PROTOCOL[0].equals("CMD")) &&
                        (PROTOCOL[1].equals("PLAY"))) {

                    System.out.println(PROTOCOL[2]);

                    CardTypes adversarysMove = CardTypes.valueOf(PROTOCOL[2]);
                    CardTypes yourMove = CardTypes.valueOf(CARD_VALUE);

                    System.out.println(outcome(yourMove, adversarysMove));
                }

            }

        }

        if(playerList.size() == 2){
            STATE="PLAYING";
        }
        
        System.out.println();
        if(player.equals(message.getSubscriber())){
            System.out.println("A new message from me!");
        }else{
            System.out.println("A new message from others");
        }
        System.out.println("got a event: '" + message.getText() + "', from: '" + message.getSubscriber() + "'");

    }

    private static String outcome(CardTypes yourMove, CardTypes adversarysMove) {
        if (yourMove == adversarysMove) return "Draw!";

        if (yourMove == CardTypes.ROCK     && adversarysMove == CardTypes.SCISSORS) return "You win!";
        if (yourMove == CardTypes.ROCK     && adversarysMove == CardTypes.LIZARD  ) return "You win!";

        if (yourMove == CardTypes.SCISSORS && adversarysMove == CardTypes.PAPER   ) return "You win!";
        if (yourMove == CardTypes.SCISSORS && adversarysMove == CardTypes.LIZARD  ) return "You win!";

        if (yourMove == CardTypes.PAPER    && adversarysMove == CardTypes.ROCK    ) return "You win!";
        if (yourMove == CardTypes.PAPER    && adversarysMove == CardTypes.SPOCK   ) return "You win!";

        if (yourMove == CardTypes.LIZARD   && adversarysMove == CardTypes.SPOCK   ) return "You win!";
        if (yourMove == CardTypes.LIZARD   && adversarysMove == CardTypes.PAPER   ) return "You win!";

        if (yourMove == CardTypes.SPOCK    && adversarysMove == CardTypes.ROCK    ) return "You win!";
        if (yourMove == CardTypes.SPOCK    && adversarysMove == CardTypes.SCISSORS) return "You win!";

        return "You lose!";
    }

    public static void main(String[] args) throws BridgeException, InterruptedException {

        bridge = BridgeBuilderFactory.Default()
                .connect(TEST_URL)
                .timeout(TIMEOUT)
                .refresh(REFRESH)
                .subscribe("pong", RPSSL::messageListener)
                .build();
        player = bridge.getSubscriber();

        //Init State machine
        STATE = "WAITING";

        while(counter.get() < MAX_ITERATIONS){

            System.out.println("STATE:" + STATE);
            if(STATE.equals("WAITING")){
                bridge.send("pong", "CMD:" + "HELLO");
            }

            if(STATE.equals("PLAYING")){

                List<CardTypes> list = CardTypes.getList();
                Random randomGenerator = new Random();
                int index = randomGenerator.nextInt(list.size());
                CARD_VALUE = list.get(index).toString();

                bridge.send("pong", "CMD:" + "PLAY:" + CARD_VALUE);
            }

            Thread.sleep(WAIT);
        }

        bridge.stop();

        System.exit(0);
    }
}

Output:

STATE:WAITING
Adding new player
e55f0a23-5f08-4365-8515-27f6ca434efe

A new message from me!
got a event: 'CMD:HELLO', from: 'e55f0a23-5f08-4365-8515-27f6ca434efe'
STATE:WAITING
Adding new player
e55f0a23-5f08-4365-8515-27f6ca434efe

A new message from me!
got a event: 'CMD:HELLO', from: 'e55f0a23-5f08-4365-8515-27f6ca434efe'
STATE:WAITING
Adding new player
e55f0a23-5f08-4365-8515-27f6ca434efe

A new message from me!
got a event: 'CMD:HELLO', from: 'e55f0a23-5f08-4365-8515-27f6ca434efe'
STATE:WAITING
Adding new player
e55f0a23-5f08-4365-8515-27f6ca434efe

A new message from me!
got a event: 'CMD:HELLO', from: 'e55f0a23-5f08-4365-8515-27f6ca434efe'
STATE:WAITING
Adding new player
e55f0a23-5f08-4365-8515-27f6ca434efe

A new message from me!
got a event: 'CMD:HELLO', from: 'e55f0a23-5f08-4365-8515-27f6ca434efe'
STATE:WAITING
Adding new player
11c4d21d-1818-4303-9992-13cde71f73aa
e55f0a23-5f08-4365-8515-27f6ca434efe

A new message from others
got a event: 'CMD:HELLO', from: '11c4d21d-1818-4303-9992-13cde71f73aa'

A new message from me!
got a event: 'CMD:HELLO', from: 'e55f0a23-5f08-4365-8515-27f6ca434efe'
PAPER
You lose!

A new message from others
got a event: 'CMD:PLAY:PAPER', from: '11c4d21d-1818-4303-9992-13cde71f73aa'

A new message from me!
got a event: 'CMD:PLAY:ROCK', from: 'e55f0a23-5f08-4365-8515-27f6ca434efe'
STATE:PLAYING
LIZARD
You lose!

A new message from others
got a event: 'CMD:PLAY:LIZARD', from: '11c4d21d-1818-4303-9992-13cde71f73aa'

A new message from me!
got a event: 'CMD:PLAY:SPOCK', from: 'e55f0a23-5f08-4365-8515-27f6ca434efe'
STATE:PLAYING

[jabrena]

The example could evolve to use a HFSM.
http://aigamedev.com/open/article/hfsm-gist/

[juan-medina]

if you dont want to do an static lister you could do:

public class RPSSL {
  
  // the current code

  public void doStuff(){
    // your code here

    bridge = BridgeBuilderFactory.Default()
                .connect(TEST_URL)
                .timeout(TIMEOUT)
                .refresh(REFRESH)
                .subscribe("pong", this::messageListener)
                .build();
 } 
  public static void main(String[] args) throws BridgeException, InterruptedException {

    RPSSL rpssl = new RPSSL();
    rpssl.doStuff();
  }
}