Javascript MQTT Web Application

Olá pessoal, eu espero que estejam bem!

Primeiramente eu gostaria de me desculpar pela minha "noobice". Eu não venho da área de web, por isso a minha falta de conhecimento e a minha necessidade urgente de obter ajuda :/

Como não conheço muito a linguagem, vou tentar detalhar bem meu problema colocando várias imagens em anexo, perdoem-me se eu estiver sendo exagerada rsrs

Vamos lá:

Eu criei uma aplicação bem simples (imagem APP - 1. Tela.png). Essa aplicação tem 4 campos em tela que quando publicados, salva a mensagem (payload) em tempo real em uma tabela (imagem SAP HANA database - Tabela para salvar dados.png) no SAP HANA database (banco de dados do SAP HANA Trial (imagem SAP HANA database.png)).

Para isso, usarei o protocolo MQTT. Sendo assim, criei uma conta no Cloud MQTT (imagem Cloud MQTT criado.png).

Obs: Ou seja, a grosso modo, a minha app vai mandar a mensagem para o cloud mqtt e o cloud mqqt vai direcionar para a minha tabela do SAP HANA database. Para isso usei o tutorial http://www.hivemq.com/blog/build-javascript-mqtt-web-application. 

Porém, nem tudo são flores :/

1) Testando pela web (http://www.hivemq.com/demos/websocket-client/) e passando todos os parâmetros correspondentes, eu consigo que o payload seja salvo em minha tabela.

{mode":"sync","messageType":"57cd765743f3f9c473d5","messages":[{"Humidity":25.7, "Temperature": 21.5, "Brightness": 13.0, "timestamp":1413100000}]}

-
WEB - sucesso - 1. Connect - Estabelecendo conexão com o Cloud MQTT.png

-
WEB - sucesso - 2. Subscribed – Subscrevendo o Topic.png

-
WEB - sucesso - 3. Publish – Publicando a mensagem no Topic.png

-
WEB - sucesso - 4. Salvando na tabela do SAP HANA database.png

2) Ainda testando via  web (http://www.hivemq.com/demos/websocket-client/) e passando todos os parâmetros correspondentes, e não consigo que o payload que eu estou gerando no código da minha aplicação salve os dados na minha tabela do banco sap hana.

{"mode":"sync","messageType":"57cd765743f3f9c473d5","messages":[{"Humidity":"99.1","Temperature":"99.2","Brightness":"99.3","Timestamp":"1999999999"}]}

-
WEB - erro - 3. Publish – Publicando a mensagem no Topic.png

-
WEB - erro - 4. NÃO Salvando na tabela do SAP HANA database.png

3) Testando direto pela minha aplicação, o payload gerado não está salvando os dados na minha tabela do SAP HANA database.

{"mode":"sync","messageType":"57cd765743f3f9c473d5","messages":[{"Humidity":"99.1","Temperature":"99.2","Brightness":"99.3","Timestamp":"1999999999"}]}

-
APP - erro - 2. Publish - Publicação realizada.png

-
APP - erro - 3. NÃO salvando na tabela do SAP HANA database.png

4) Meu código javascript

<script>
 //Using the HiveMQ public Broker, with a random client Id
 var client = new Messaging.Client("m12.cloudmqtt.com", 39388, "bnuser" + parseInt(Math.random() * 100, 10));

 //Gets called if the websocket/mqtt connection gets disconnected for any reason
 client.onConnectionLost = function(responseObject) {
 //Depending on your scenario you could implement a reconnect logic here
 alert("connection lost: " + responseObject.errorMessage);
 };

 //Gets called whenever you receive a message for your subscriptions
 client.onMessageArrived = function(message) {
 //Do something with the push message you received
 // $('#messages').append('<span>Topic: ' + message.destinationName + ' | ' + message.payloadString + '</span><br/>');
console.log("Message Arrived: " + message.payloadString);
 console.log("Topic: " + message.destinationName);
 console.log("QoS: " + message.qos);
 console.log("Retained: " + message.retained);
 // Read Only, set if message might be a duplicate sent from broker
 console.log("Duplicate: " + message.duplicate);
};

 //Connect Options
 var options = {
 userName: "tyanxvet",
 password: "fmZYiSylGtjD",
 useSSL: true,
 timeout: 3,

 //Gets Called if the connection has sucessfully been established
 onSuccess: function() {
 alert("Connected");
 },
 //Gets Called if the connection could not be established
 onFailure: function(message) {
 alert("Connection failed: " + message.errorMessage);
 }
 };

 var pl = new Object();
 pl.mode = "sync";
 pl.messageType = "57cd765743f3f9c473d5";

 var topic = "iot/data/iotmmss0016095593trial/v1/dc71fe1f-f710-4c06-a9f3-579d28a05e64";
 var mensagem = new Object();

 //Creates a new Messaging.Message Object and sends it to the HiveMQ MQTT Broker
 var publish = function(payload, topic, qos) {

 mensagem.Humidity = document.getElementById("humidity").value;
 mensagem.Temperature = document.getElementById("temperature").value;
 mensagem.Brightness = document.getElementById("brightness").value;
 mensagem.Timestamp = document.getElementById("timestamp").value;

 pl.messages = new Array();
 pl.messages[0] = mensagem;
 console.log(JSON.stringify(pl));

 //Send your message (also possible to serialize it as JSON or protobuf or just use a string, no limitations)
 var message = new Messaging.Message(payload);
 message.destinationName = topic;
 message.qos = 0;
 //message.retained = true;
 client.send(message);
 }

 function refreshPage() {
 window.location.reload();
 }
 </script>

	 

	5) Meu código HTML

<body>
 <fieldset>
 <legend>Send Data</legend>
 <p>Humidity:
 <input type="text" id="humidity">
 </p>
 <p>Temperature:
 <input type="text" id="temperature">
 </p>
 <p>Brightness:
 <input type="text" id="brightness">
 </p>
 <p>Timestamp:
 <input type="text" id="timestamp">
 </p>
 <button onclick="client.connect(options);">1. Connect</button>
 <button onclick="client.subscribe(topic, {qos: 2}); alert('Subscribed');">2. Subscribe</button>
 <button onclick="publish(JSON.stringify(pl),topic, 2);">3. Publish</button>
 <button onclick="client.disconnect();">4. Disconect</button>
 <div id="messages"></div>
 </fieldset>
</body>

	 

	Para mim parece que o problema é na montagem do payload da minha aplicação, mas pode ser que o problema seja outro e eu não fui capaz de identificar. Caso o problema seja realmente o payload, como eu devo ajustá-lo? Tentei algumas formas mas todas fotam sem sucesso ://

	 

	Alguém pode me ajudar??? 

Att,

Tata Cardeal