ADFWQEF

main.cpp

Committer:
rishat
Date:
23 months ago
Revision:
100:7c75f1700889
Parent:
91:dab9882e2b49

File content as of revision 100:7c75f1700889:

#include "MQTTmbed.h"
#include <MQTTClientMbedOs.h>
#include <cstdio> 
#include "mbed.h"



AnalogIn my_adc(PA_7); //D11 on board
AnalogIn my_abc(PA_6);
//DigitalOut led(LED1);
DigitalOut dat(D15); 
 int main(int argc, char *argv[]) {
 //long distance = sensor.distance(); 
 //long distanza =  distance;
 //printf("distanza  %d  \n",distanza);
  

 
 printf("Starting IBM MQTT demo:\n");
 TCPSocket socket;
 NetworkInterface *net = NetworkInterface::get_default_instance();
 if (!net) {
   printf("Error! No 11network inteface11 found.\n");
   return 0; }
 printf("Connecting to the network...\r\n");
 nsapi_size_or_error_t rc = net->connect();
 if (rc != 0) {
   printf("Error! _net->connect() returned: %d\r\n", rc);
   return -1; }
 rc = socket.open(net);
 if (rc != 0) {
   printf("Error! _socket.open() returned: %d\r\n", rc);
   return -1; }
 SocketAddress address;
 net->gethostbyname("dev.rightech.io",
                    &address);
 address.set_port(1883);
 printf("Opening connection to remote %s port %d\r\n",
        address.get_ip_address(), address.get_port());
 rc = socket.connect(address);
 if (rc != 0) {
   printf("Error! _socket.connect() returned: %d\r\n", rc);
   return -1; }
 printf("Connected socket\n");
 MQTTClient client(&socket);
 MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
 data.MQTTVersion = 3;
 data.clientID.cstring = "XXXXX";
 data.username.cstring = "ZZZ";
 data.password.cstring = "ZZZ";
 if ((rc = client.connect(data)) != 0)
   printf("rc from MQTT connect is %d\r\n", rc);  
 MQTT::Message message;
 
 while(1)
{
     
 char *topic = "post";
 char buf[100];
 int distanza = round(my_adc*100);
 //sprintf(buf,
 //        "{\"d\":{\"ST\":\"Nucleo-IoT-mbed\",\"Temp\":%d,\"Pressure\":"
 //        "%d,\"Humidity\":%d}}", temp, press, hum);
 
 sprintf(buf,
             "{\"distanse\": %d}", distanza);
            wait_ns(1000000);   
          
printf("Sending message: \n%s\n", buf);
message.qos = MQTT::QOS0;
message.retained = false;
message.dup = false;
message.payload = (void *)buf;
message.payloadlen = strlen(buf);
rc = client.publish(topic, message);
printf("Message sent\n");
printf("Demo concluded successfully \r\n");
 wait_ns(9000000000);



 
char buf2[10];        
int ogon = round(my_abc*100);           
sprintf(buf2,
             "{\"ogon\": %d}", ogon);
             
             
            wait_ns(9000000000);
                       
 printf("Sending message: \n%s\n", buf2);
 message.qos = MQTT::QOS0;
 message.retained = false;
 message.dup = false;
 message.payload = (void *)buf2;
 message.payloadlen = strlen(buf2);
 rc = client.publish(topic, message);
 printf("Message sent\n");
 printf("Demo concluded successfully \r\n");
 wait_ns(10000000000);
 }
 return 0; }