Bunny-Spawner, a Node.JS and Bonita BPM example with kitties and bunnies

laurent.alepee's picture
laurent.alepee
Wednesday, September 10, 2014 - 17:59
Blog Categories: 
Tutorial

Bunny-Spawner, a Node.JS and Bonita BPM example with kitties and bunnies

This is an example of how to use the Bonita BPM web REST API with Node.js. To make it warm and fuzzy, we used some good old 8bit like sprites with cats and rabbits ;-) lol

Prerequisite

how to use

  • start the bunny process on the Bonita server, via the Portal
  • In the Bunny-Spawner-Node-JS-and-Bonita-BPM-example-with-kitties-and-bunnies folder, start the node server by typing: node server.js
  • start Internet explorer Nooo.. please don't. Start Firefox or Chrome instead.
    • Go on localhost:8042
    • have fun ! right click for kitties and left click for bunnies.

how it works

it a three parts system,

  • Browser js client
  • Node js server
  • Bonita BPM

The browser client and the Node.js server communicate throught socket with Socket.io. The Node.js server call the Bonita REST API with Unirest. And Bonita call the Node.js server via HTTP requests.

Architecture

Bonita BPM process named "bunny" is the following:

Process

Spawner process simply execute a connecteur (cf. Bonita BPM TO Node.js server)

Browser js client TO Node.js server

the following code allow the client to send notification to the server (line 107: game.js & line 19/24: handlerLoader.js)):

socket = io.connect(document.URL);
socket.emit('update', {varName: 'bunny', value: 1});
socket.emit('update', {varName: 'cat', value: 1});

this code receive the notification on server side (line 77: server.js):

socket.on('update', function(data) {
        if (data.varName == "bunny")
                bunny += data.value;
        if (data.varName == "cat")
                cat += data.value;
...

Node.js server TO Browser js client

the following code allow the server to send notification to clients (line 40: server.js):

toClient.emit('update', { type: keyval[0], val: keyval[1] });

this code receive the notification on client side and add at a random position a bunny or a kitty (line 108: game.js):

this.socket.on('update', function(data) {
        console.log("update received");
        console.log(data.type + ", " + data.val)
        switch(data.type) {
                case "bunny":
                        var x = Math.floor((Math.random() * 1200) + 40);
                        var y = Math.floor((Math.random() * 400) + 40);
                        self.addBunny(x, y);
                        break;
                case "cat":
                        var x = Math.floor((Math.random() * 1200) + 40);
                        var y = Math.floor((Math.random() * 400) + 40);
                        self.addCat(x, y);
                        break;
                default:
                        break;
        }
});

Node.js server TO Bonita BPM

This connection use the package unirest for Node.js, for more information follow the link to Unirest. To use Bonita REST API you need to be connected so there is this fonction which allows to connect then do your call and finally disconnect (line 166: server.js):

function connectThen(callback) {
        unirest.post(remoteBonitaHost + "/loginservice?redirect=false&username=admin&password=bpm")
                .headers({
                        'Accept': 'application/json'
                })
                .jar(true)
                .end(function(response) {
                        console.log(response.body);
                        callback(function() {
                                unirest.get(remoteBonitaHost + "/logoutservice")
                                        .headers({
                                                'Accept': 'application/json'
                                        })
                                        .jar(true)
                                        .end(function() {
                                                console.log("disconnect from rest API");
                                        });
                        });
                });
}

Then, three nested request are called throught the function modValue (line 103: server.js),

  • Get the process instance
  • Get value of the requested variable
  • Put the new value for the variable
function modValue(vari, newValue) {
        connectThen(function(logout) {
                >       unirest.get(remoteBonitaHost + "/API/bpm/case?p=0&c=10&s=bunny")
                                .headers({
                                        'Accept': 'application/json'
                                })
                                .jar(true)
                                .end(function(response) {
                                        console.log("Bonita Game case ID request");
                                        console.log(response.body);
                                        var processId = response.body[0].id;
                >                       unirest.get(remoteBonitaHost + "/API/bpm/caseVariable/"+processId+"/"+vari)
                                                .headers({
                                                        'Accept': 'application/json'
                                                })
                                                .jar(true)
                                                .end(function(response) {
                                                        console.log("request for " + vari);
                                                        console.log(response.body);
                                                        var value = parseInt(response.body.value) + parseInt(newValue);
                >                                       unirest.put(remoteBonitaHost + "/API/bpm/caseVariable/"+processId+"/"+vari)
                                                                .headers({
                                                                        'Accept': 'application/json'
                                                                })
                                                                .send("[{\"type\":\"java.lang.Integer\",\"value\":"+value+"}]")
                                                                .jar(true)
                                                                .end(function(response) {
                                                                        console.log("request for change " + vari + " with value " + value);
                                                                        console.log(response.body);
                                                                        logout();
                                                                });
                                                });
                                });
                });
}

NOTE: you need to send: "[{\"type\":\"java.lang.Integer\",\"value\":"+value+"}]" to change the value in order to make it work. it's a String of an array of a Json "[{ ... }]".

Bonita BPM TO Node.js server

The comunication is done by a simple HTTP request in a custom connector on a bunny process step. it's made throught the following code:

@Override
        protected void executeBusinessLogic() throws ConnectorException {
                boolean update = false;
                String request = getUrl() + "?";
                int bunny = getBunnyNb();
                int cat = getCatNb();
                int i;
                Random r = new Random();
               
                if (bunny > 5) {
                        update = true;
                        bunny++;
                        request += "bunny=1";
                }
               
                if (cat > 2) {
                        i = r.nextInt(100 - cat);
                        if (i <= 5) {
                                if (update)
                                        request += "&";
                                update = true;
                                cat++;
                                request += "cat=1";
                        }
                }
               
                if (update) {
                        try {
                >               URL url = new URL(request);
                >               InputStream is = url.openStream();
                >               is.close();
                        } catch (Exception e) {
                                e.printStackTrace();
                        }
                }
                setNewBunnyNb(bunny);
                setNewCatNb(cat);

**Enjoy and have fun ! **

praise for Konami

Notifications