Wouter Van den Bogaert
/
PGO6_VoteController_template
PGO6
main.cpp@4:15e7cac255da, 2019-10-31 (annotated)
- Committer:
- s0130594
- Date:
- Thu Oct 31 15:19:45 2019 +0100
- Revision:
- 4:15e7cac255da
- Parent:
- 3:14b20a4f36d0
- Child:
- 6:754d3e8f9ae9
Getest tot aan connecten met broker
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
jensdehoog | 0:fd29cd85e75e | 1 | #define APP_VERSION 0.6f |
jensdehoog | 0:fd29cd85e75e | 2 | #define MQTT_VERSION 3 |
jensdehoog | 0:fd29cd85e75e | 3 | #define BROKER_NAME "broker.hivemq.com" |
jensdehoog | 0:fd29cd85e75e | 4 | #define BROKER_PORT 1883 |
jensdehoog | 0:fd29cd85e75e | 5 | |
jensdehoog | 0:fd29cd85e75e | 6 | #include "debounce_button.h" |
jensdehoog | 0:fd29cd85e75e | 7 | #include "EthernetInterface.h" |
jensdehoog | 0:fd29cd85e75e | 8 | #include "MQTTNetwork.h" |
jensdehoog | 0:fd29cd85e75e | 9 | #include "MQTTmbed.h" |
jensdehoog | 0:fd29cd85e75e | 10 | #include "MQTTClient.h" |
s0130594 | 3:14b20a4f36d0 | 11 | #include "mbed.h" |
s0130594 | 4:15e7cac255da | 12 | #include "easy-connect/easy-connect.h" |
jensdehoog | 0:fd29cd85e75e | 13 | |
jensdehoog | 0:fd29cd85e75e | 14 | char* topic; |
s0130594 | 3:14b20a4f36d0 | 15 | Serial pc(USBTX, USBRX); |
s0130594 | 4:15e7cac255da | 16 | |
s0130594 | 4:15e7cac255da | 17 | /** hier copy */ |
s0130594 | 4:15e7cac255da | 18 | volatile bool button1_pressed = false; // Used in the main loop |
s0130594 | 4:15e7cac255da | 19 | volatile bool button1_enabled = true; // Used for debouncing |
s0130594 | 4:15e7cac255da | 20 | volatile int multiclick_state =0 ; // Counts how many clicks occured in the time slot, used in main loop |
s0130594 | 4:15e7cac255da | 21 | volatile bool button1_busy = false; // Informs the mainloop that the user is clicking the button |
s0130594 | 4:15e7cac255da | 22 | volatile int button_count =0; // counter for number of clicks within 1 second |
s0130594 | 4:15e7cac255da | 23 | volatile bool disp = false; // show eindtotaal |
s0130594 | 4:15e7cac255da | 24 | |
s0130594 | 4:15e7cac255da | 25 | void button1_multiclick_reset_cb(void); // Resets the amount of clicks, but stores this value for the usage in the main loop |
s0130594 | 4:15e7cac255da | 26 | void button1_enabled_cb(void); // Enables the button again after a timeout, used for debouncing the button |
s0130594 | 4:15e7cac255da | 27 | void button1_onpressed_cb(void); // Callback which is called when the user presses the button |
s0130594 | 4:15e7cac255da | 28 | |
s0130594 | 4:15e7cac255da | 29 | DigitalOut led1(LED1); |
s0130594 | 4:15e7cac255da | 30 | DigitalOut led2(LED2); |
s0130594 | 4:15e7cac255da | 31 | DigitalOut led3(LED3); |
s0130594 | 4:15e7cac255da | 32 | Timeout someTimeout; |
s0130594 | 4:15e7cac255da | 33 | Timeout someTimeout2; |
s0130594 | 4:15e7cac255da | 34 | |
s0130594 | 4:15e7cac255da | 35 | int arrivedcount = 0; |
s0130594 | 4:15e7cac255da | 36 | |
s0130594 | 4:15e7cac255da | 37 | |
s0130594 | 4:15e7cac255da | 38 | /** end copy */ |
s0130594 | 4:15e7cac255da | 39 | |
s0130594 | 4:15e7cac255da | 40 | #include "debounce_button.h" |
s0130594 | 4:15e7cac255da | 41 | |
s0130594 | 4:15e7cac255da | 42 | /** |
s0130594 | 4:15e7cac255da | 43 | Some tips and tricks: |
s0130594 | 4:15e7cac255da | 44 | - To use the built-in LED: |
s0130594 | 4:15e7cac255da | 45 | DigitalOut led1(LED1); |
s0130594 | 4:15e7cac255da | 46 | ... |
s0130594 | 4:15e7cac255da | 47 | led1 = 1; |
s0130594 | 4:15e7cac255da | 48 | - To delay the call of a function: |
s0130594 | 4:15e7cac255da | 49 | Timeout someTimeout; |
s0130594 | 4:15e7cac255da | 50 | ... |
s0130594 | 4:15e7cac255da | 51 | someTimeout.attach(callback(&someFunction), 0.5) with 0.5 as 500 milliseconds |
s0130594 | 4:15e7cac255da | 52 | - The variables that are used in interrupt callbacks have to be volatile, |
s0130594 | 4:15e7cac255da | 53 | because these variables can change at any time. Therefore, the compiler is not |
s0130594 | 4:15e7cac255da | 54 | going to make optimisations. |
s0130594 | 4:15e7cac255da | 55 | */ |
s0130594 | 4:15e7cac255da | 56 | |
s0130594 | 4:15e7cac255da | 57 | /** |
s0130594 | 4:15e7cac255da | 58 | TODO |
s0130594 | 4:15e7cac255da | 59 | ---- |
s0130594 | 4:15e7cac255da | 60 | This function: |
s0130594 | 4:15e7cac255da | 61 | - stores the amount of clicks in a variable which is read by the main loop. |
s0130594 | 4:15e7cac255da | 62 | - resets the click counter which is used inside this file. |
s0130594 | 4:15e7cac255da | 63 | - lowers a flag which tells the main loop that the user stopped pressing the button |
s0130594 | 4:15e7cac255da | 64 | such that it can proceed its program. |
s0130594 | 4:15e7cac255da | 65 | - turns the built-in LED off. Therefore, the user gets informed that the program stopped counting the clicks. |
s0130594 | 4:15e7cac255da | 66 | */ |
s0130594 | 4:15e7cac255da | 67 | void button1_multiclick_reset_cb(void) { |
s0130594 | 4:15e7cac255da | 68 | led3=1; |
s0130594 | 4:15e7cac255da | 69 | //pc.printf("Time to reset alles"); |
s0130594 | 4:15e7cac255da | 70 | button_count = multiclick_state; |
s0130594 | 4:15e7cac255da | 71 | multiclick_state =0; |
s0130594 | 4:15e7cac255da | 72 | disp=true; |
s0130594 | 4:15e7cac255da | 73 | |
s0130594 | 4:15e7cac255da | 74 | button1_busy = false; |
s0130594 | 4:15e7cac255da | 75 | button1_pressed = false; |
s0130594 | 4:15e7cac255da | 76 | |
s0130594 | 4:15e7cac255da | 77 | DigitalOut led1(LED1); |
s0130594 | 4:15e7cac255da | 78 | led1 = 0; |
s0130594 | 4:15e7cac255da | 79 | |
s0130594 | 4:15e7cac255da | 80 | } |
s0130594 | 4:15e7cac255da | 81 | |
s0130594 | 4:15e7cac255da | 82 | /** |
s0130594 | 4:15e7cac255da | 83 | TODO |
s0130594 | 4:15e7cac255da | 84 | ---- |
s0130594 | 4:15e7cac255da | 85 | This function enables the button again, such that unwanted clicks of the bouncing button get ignored. |
s0130594 | 4:15e7cac255da | 86 | */ |
s0130594 | 4:15e7cac255da | 87 | void button1_enabled_cb(void) |
s0130594 | 4:15e7cac255da | 88 | { |
s0130594 | 4:15e7cac255da | 89 | button1_enabled = true; |
s0130594 | 4:15e7cac255da | 90 | led2=0; |
s0130594 | 4:15e7cac255da | 91 | |
s0130594 | 4:15e7cac255da | 92 | } |
s0130594 | 4:15e7cac255da | 93 | |
s0130594 | 4:15e7cac255da | 94 | /** |
s0130594 | 4:15e7cac255da | 95 | TODO |
s0130594 | 4:15e7cac255da | 96 | ---- |
s0130594 | 4:15e7cac255da | 97 | This function: |
s0130594 | 4:15e7cac255da | 98 | - turns the built-in LED on, so the user gets informed that the program has started with counting clicks |
s0130594 | 4:15e7cac255da | 99 | - disables the button such that the debouncer is active |
s0130594 | 4:15e7cac255da | 100 | - enables the button again after a certain amount of time |
s0130594 | 4:15e7cac255da | 101 | (use interrupts with "button1_enabled_cb()" as callback. |
s0130594 | 4:15e7cac255da | 102 | - counts the amount of clicks within a period of 1 second |
s0130594 | 4:15e7cac255da | 103 | - informs the main loop that the button has been pressed |
s0130594 | 4:15e7cac255da | 104 | - informs the main loop that the user is clicking the button. |
s0130594 | 4:15e7cac255da | 105 | Therefore, this main loop cannot continue its procedure until the clicks within 1 second have been counted. |
s0130594 | 4:15e7cac255da | 106 | */ |
s0130594 | 4:15e7cac255da | 107 | void button1_onpressed_cb(void) |
s0130594 | 4:15e7cac255da | 108 | { |
s0130594 | 4:15e7cac255da | 109 | // Turn led on |
s0130594 | 4:15e7cac255da | 110 | led1 = 1; |
s0130594 | 4:15e7cac255da | 111 | led2= 0; |
s0130594 | 4:15e7cac255da | 112 | // Set button disabled |
s0130594 | 4:15e7cac255da | 113 | if(button1_enabled){ |
s0130594 | 4:15e7cac255da | 114 | multiclick_state++; |
s0130594 | 4:15e7cac255da | 115 | button1_enabled = false; |
s0130594 | 4:15e7cac255da | 116 | led2=1; |
s0130594 | 4:15e7cac255da | 117 | //pc.printf("Nu is de button1_enabled false"); |
s0130594 | 4:15e7cac255da | 118 | //pc.printf("Multiclickstate is nu: %d", multiclick_state); |
s0130594 | 4:15e7cac255da | 119 | someTimeout.attach(callback(button1_enabled_cb), 0.2); |
s0130594 | 4:15e7cac255da | 120 | } |
s0130594 | 4:15e7cac255da | 121 | |
s0130594 | 4:15e7cac255da | 122 | |
s0130594 | 4:15e7cac255da | 123 | // Inform main loop that user is clicking the button |
s0130594 | 4:15e7cac255da | 124 | button1_busy = true; |
s0130594 | 4:15e7cac255da | 125 | |
s0130594 | 4:15e7cac255da | 126 | // Do a count after 1 second |
s0130594 | 4:15e7cac255da | 127 | if(!button1_pressed){ |
s0130594 | 4:15e7cac255da | 128 | // Inform main loop that button has been pressed |
s0130594 | 4:15e7cac255da | 129 | //pc.printf("Registering callback for within 1 second"); |
s0130594 | 4:15e7cac255da | 130 | button1_pressed = true; |
s0130594 | 4:15e7cac255da | 131 | led3=0; |
s0130594 | 4:15e7cac255da | 132 | someTimeout2.attach(callback(button1_multiclick_reset_cb), 1); |
s0130594 | 4:15e7cac255da | 133 | } |
s0130594 | 4:15e7cac255da | 134 | |
s0130594 | 4:15e7cac255da | 135 | } |
s0130594 | 4:15e7cac255da | 136 | |
jensdehoog | 0:fd29cd85e75e | 137 | /** |
jensdehoog | 0:fd29cd85e75e | 138 | TODO |
jensdehoog | 0:fd29cd85e75e | 139 | ---- |
jensdehoog | 0:fd29cd85e75e | 140 | - Check if the button has been pressed. If so, print the amount of clicks to a serial terminal. |
jensdehoog | 0:fd29cd85e75e | 141 | - Make an MQTT-service which: |
jensdehoog | 0:fd29cd85e75e | 142 | - starts up a network using EthernetInterface. Make sure the development board requests its address via DHCP. |
jensdehoog | 0:fd29cd85e75e | 143 | - makes a client and connects it to the broker using a client ID and credentials (username & password). |
jensdehoog | 0:fd29cd85e75e | 144 | - sends messages at the same topic as the smartphone app from PGO 2. Feel free to choose which Quality of Service |
jensdehoog | 0:fd29cd85e75e | 145 | you are going to use. Make a separate function which handles the sending procedure. Therefore, this function |
jensdehoog | 0:fd29cd85e75e | 146 | can be called each time we want to send a certain message. |
jensdehoog | 0:fd29cd85e75e | 147 | - When the button is pressed once, we send an upvote. When pressed twice, a downvote is sent. By pressing 4 times, |
jensdehoog | 0:fd29cd85e75e | 148 | the program disconnects from the broker and terminates. |
jensdehoog | 0:fd29cd85e75e | 149 | |
jensdehoog | 0:fd29cd85e75e | 150 | Extra |
jensdehoog | 0:fd29cd85e75e | 151 | ----- |
jensdehoog | 0:fd29cd85e75e | 152 | - Subscribe to the topic on which the song data is published. Display this received message on the serial terminal. |
jensdehoog | 0:fd29cd85e75e | 153 | - Test this controller in the complete system of PGO 2. Use these controllers instead of the smartphones. |
jensdehoog | 0:fd29cd85e75e | 154 | |
jensdehoog | 0:fd29cd85e75e | 155 | Tips & tricks |
jensdehoog | 0:fd29cd85e75e | 156 | ------------- |
jensdehoog | 0:fd29cd85e75e | 157 | - To generate an interrupt on the press of a button, use: |
jensdehoog | 0:fd29cd85e75e | 158 | InterruptIn button(USER_BUTTON); |
jensdehoog | 0:fd29cd85e75e | 159 | ... |
jensdehoog | 0:fd29cd85e75e | 160 | button.fall(callback(someFunction)); |
jensdehoog | 0:fd29cd85e75e | 161 | - Before implementing MQTT, test the multiclick feature first. |
jensdehoog | 0:fd29cd85e75e | 162 | - Have a look at the MQTT-library for Mbed and the HelloMQTT-example. |
jensdehoog | 0:fd29cd85e75e | 163 | - To have a uniform message sending procedure, use the following function usage: |
jensdehoog | 0:fd29cd85e75e | 164 | sendMessage(&client, topic, buf, qos, retained, duplicate) |
jensdehoog | 0:fd29cd85e75e | 165 | */ |
jensdehoog | 0:fd29cd85e75e | 166 | |
jensdehoog | 0:fd29cd85e75e | 167 | int main(int argc, char* argv[]) |
jensdehoog | 0:fd29cd85e75e | 168 | { |
s0130594 | 4:15e7cac255da | 169 | led3=1; |
s0130594 | 3:14b20a4f36d0 | 170 | InterruptIn button(USER_BUTTON); |
s0130594 | 4:15e7cac255da | 171 | button.fall(callback(&button1_onpressed_cb)); |
s0130594 | 4:15e7cac255da | 172 | //multiclick_state = 0; |
s0130594 | 3:14b20a4f36d0 | 173 | pc.printf("Print print \n"); |
s0130594 | 4:15e7cac255da | 174 | topic = "IGNISVOTESPOSTING"; |
s0130594 | 4:15e7cac255da | 175 | NetworkInterface* network = easy_connect(true); |
s0130594 | 4:15e7cac255da | 176 | if (!network) { |
s0130594 | 4:15e7cac255da | 177 | pc.printf("Je netwerk is kapot"); |
s0130594 | 4:15e7cac255da | 178 | return -1; |
s0130594 | 4:15e7cac255da | 179 | } |
s0130594 | 4:15e7cac255da | 180 | |
s0130594 | 4:15e7cac255da | 181 | MQTTNetwork mqttNetwork(network); |
s0130594 | 4:15e7cac255da | 182 | MQTT::Client<MQTTNetwork, Countdown> client(mqttNetwork); |
s0130594 | 4:15e7cac255da | 183 | |
s0130594 | 4:15e7cac255da | 184 | const char* hostname = BROKER_NAME; |
s0130594 | 4:15e7cac255da | 185 | int port = BROKER_PORT; |
s0130594 | 4:15e7cac255da | 186 | |
s0130594 | 4:15e7cac255da | 187 | pc.printf("Connecting to %s:%d\r\n", hostname, port); |
s0130594 | 4:15e7cac255da | 188 | int rc = mqttNetwork.connect(hostname, port); |
s0130594 | 4:15e7cac255da | 189 | if (rc != 0) |
s0130594 | 4:15e7cac255da | 190 | pc.printf("rc from TCP connect is %d\r\n", rc); |
s0130594 | 4:15e7cac255da | 191 | |
s0130594 | 4:15e7cac255da | 192 | // QoS 2 |
s0130594 | 4:15e7cac255da | 193 | MQTT::Message message; |
s0130594 | 4:15e7cac255da | 194 | char buf[100]; |
s0130594 | 4:15e7cac255da | 195 | sprintf(buf, "Hello World! QoS 2 message from app version %f\r\n", 1.0); |
s0130594 | 4:15e7cac255da | 196 | message.qos = MQTT::QOS2; |
s0130594 | 4:15e7cac255da | 197 | message.payload = (void*)buf; |
s0130594 | 4:15e7cac255da | 198 | message.payloadlen = strlen(buf)+1; |
s0130594 | 4:15e7cac255da | 199 | rc = client.publish(topic, message); |
s0130594 | 4:15e7cac255da | 200 | while (arrivedcount < 1) |
s0130594 | 4:15e7cac255da | 201 | client.yield(100); |
s0130594 | 4:15e7cac255da | 202 | |
s0130594 | 4:15e7cac255da | 203 | if ((rc = client.unsubscribe(topic)) != 0) |
s0130594 | 4:15e7cac255da | 204 | pc.printf("rc from unsubscribe was %d\r\n", rc); |
s0130594 | 4:15e7cac255da | 205 | |
s0130594 | 4:15e7cac255da | 206 | if ((rc = client.disconnect()) != 0) |
s0130594 | 4:15e7cac255da | 207 | pc.printf("rc from disconnect was %d\r\n", rc); |
s0130594 | 4:15e7cac255da | 208 | |
s0130594 | 4:15e7cac255da | 209 | mqttNetwork.disconnect(); |
s0130594 | 4:15e7cac255da | 210 | pc.printf("Version %.2f: finish %d msgs\r\n", 1111, arrivedcount); |
s0130594 | 4:15e7cac255da | 211 | |
s0130594 | 3:14b20a4f36d0 | 212 | while(true){ |
s0130594 | 4:15e7cac255da | 213 | if(disp){ |
s0130594 | 3:14b20a4f36d0 | 214 | // Toon eindtotaal |
s0130594 | 4:15e7cac255da | 215 | pc.printf("Er is zoveel keer geklikt: %d \n",button_count); |
s0130594 | 4:15e7cac255da | 216 | disp=false; |
s0130594 | 3:14b20a4f36d0 | 217 | |
s0130594 | 3:14b20a4f36d0 | 218 | } |
s0130594 | 3:14b20a4f36d0 | 219 | } |
jensdehoog | 0:fd29cd85e75e | 220 | return 0; |
jensdehoog | 0:fd29cd85e75e | 221 | } |