3
3
#include " utility/ECCX08Cert.h"
4
4
#include " CloudSerial.h"
5
5
6
- #include " ArduinoCloudV2 .h"
6
+ #include " ArduinoIoTCloud .h"
7
7
8
8
const static char server[] = " mqtts-sa.iot.oniudra.cc" ;
9
9
@@ -12,21 +12,21 @@ const static int compressedCertSlot = 10;
12
12
const static int serialNumberAndAuthorityKeyIdentifierSlot = 11 ;
13
13
const static int thingIdSlot = 12 ;
14
14
15
- ArduinoCloudClass::ArduinoCloudClass () :
15
+ ArduinoIoTCloudClass::ArduinoIoTCloudClass () :
16
16
_bearSslClient(NULL ),
17
17
// Size of the receive buffer
18
18
_mqttClient(MQTT_BUFFER_SIZE)
19
19
{
20
20
}
21
21
22
- ArduinoCloudClass ::~ArduinoCloudClass ()
22
+ ArduinoIoTCloudClass ::~ArduinoIoTCloudClass ()
23
23
{
24
24
if (_bearSslClient) {
25
25
delete _bearSslClient;
26
26
}
27
27
}
28
28
29
- int ArduinoCloudClass ::begin (Client& net)
29
+ int ArduinoIoTCloudClass ::begin (Client& net)
30
30
{
31
31
byte thingIdBytes[72 ];
32
32
@@ -68,7 +68,7 @@ int ArduinoCloudClass::begin(Client& net)
68
68
}
69
69
70
70
// private class method used to initialize mqttClient class member. (called in the begin class method)
71
- void ArduinoCloudClass ::mqttClientBegin (Client& net)
71
+ void ArduinoIoTCloudClass ::mqttClientBegin (Client& net)
72
72
{
73
73
// MQTT topics definition
74
74
_stdoutTopic = " /a/d/" + _id + " /s/o" ;
@@ -77,14 +77,14 @@ void ArduinoCloudClass::mqttClientBegin(Client& net)
77
77
_dataTopicOut = " /a/d/" + _id + " /e/o" ;
78
78
79
79
// use onMessage as callback for received mqtt messages
80
- _mqttClient.onMessageAdvanced (ArduinoCloudClass ::onMessage);
80
+ _mqttClient.onMessageAdvanced (ArduinoIoTCloudClass ::onMessage);
81
81
_mqttClient.begin (server, 8883 , net);
82
82
83
83
// Set MQTT connection options
84
84
_mqttClient.setOptions (mqttOpt.keepAlive , mqttOpt.cleanSession , mqttOpt.timeout );
85
85
}
86
86
87
- int ArduinoCloudClass ::connect ()
87
+ int ArduinoIoTCloudClass ::connect ()
88
88
{
89
89
// Username: device id
90
90
// Password: empty
@@ -97,18 +97,18 @@ int ArduinoCloudClass::connect()
97
97
return 1 ;
98
98
}
99
99
100
- bool ArduinoCloudClass ::disconnect ()
100
+ bool ArduinoIoTCloudClass ::disconnect ()
101
101
{
102
102
return _mqttClient.disconnect ();
103
103
}
104
104
105
- void ArduinoCloudClass ::poll ()
105
+ void ArduinoIoTCloudClass ::poll ()
106
106
{
107
107
// If user call poll() without parameters use the default ones
108
108
poll (MAX_RETRIES, RECONNECTION_TIMEOUT);
109
109
}
110
110
111
- bool ArduinoCloudClass ::mqttReconnect (int maxRetries, int timeout)
111
+ bool ArduinoIoTCloudClass ::mqttReconnect (int maxRetries, int timeout)
112
112
{
113
113
// Counter for reconnection retries
114
114
int retries = 0 ;
@@ -132,7 +132,7 @@ bool ArduinoCloudClass::mqttReconnect(int maxRetries, int timeout)
132
132
return true ;
133
133
}
134
134
135
- void ArduinoCloudClass ::poll (int reconnectionMaxRetries, int reconnectionTimeoutMs)
135
+ void ArduinoIoTCloudClass ::poll (int reconnectionMaxRetries, int reconnectionTimeoutMs)
136
136
{
137
137
// Method's argument controls
138
138
int maxRetries = (reconnectionMaxRetries > 0 ) ? reconnectionMaxRetries : MAX_RETRIES;
@@ -152,39 +152,39 @@ void ArduinoCloudClass::poll(int reconnectionMaxRetries, int reconnectionTimeout
152
152
}
153
153
}
154
154
155
- void ArduinoCloudClass ::reconnect (Client& net)
155
+ void ArduinoIoTCloudClass ::reconnect (Client& net)
156
156
{
157
157
// Initialize again the MQTTClient, otherwise it would not be able to receive messages through its callback
158
158
mqttClientBegin (net);
159
159
connect ();
160
160
}
161
161
162
- void ArduinoCloudClass ::onGetTime (unsigned long (*callback)(void ))
162
+ void ArduinoIoTCloudClass ::onGetTime (unsigned long (*callback)(void ))
163
163
{
164
164
ArduinoBearSSL.onGetTime (callback);
165
165
}
166
166
167
- int ArduinoCloudClass ::connected ()
167
+ int ArduinoIoTCloudClass ::connected ()
168
168
{
169
169
return _mqttClient.connected ();
170
170
}
171
171
172
- int ArduinoCloudClass ::writeProperties (const byte data[], int length)
172
+ int ArduinoIoTCloudClass ::writeProperties (const byte data[], int length)
173
173
{
174
174
return _mqttClient.publish (_dataTopicOut.c_str (), (const char *)data, length);
175
175
}
176
176
177
- int ArduinoCloudClass ::writeStdout (const byte data[], int length)
177
+ int ArduinoIoTCloudClass ::writeStdout (const byte data[], int length)
178
178
{
179
179
return _mqttClient.publish (_stdoutTopic.c_str (), (const char *)data, length);
180
180
}
181
181
182
- void ArduinoCloudClass ::onMessage (MQTTClient* /* client*/ , char topic[], char bytes[], int length)
182
+ void ArduinoIoTCloudClass ::onMessage (MQTTClient* /* client*/ , char topic[], char bytes[], int length)
183
183
{
184
184
ArduinoCloud.handleMessage (topic, bytes, length);
185
185
}
186
186
187
- void ArduinoCloudClass ::handleMessage (char topic[], char bytes[], int length)
187
+ void ArduinoIoTCloudClass ::handleMessage (char topic[], char bytes[], int length)
188
188
{
189
189
if (_stdinTopic == topic) {
190
190
CloudSerial.appendStdin ((uint8_t *)bytes, length);
@@ -194,4 +194,4 @@ void ArduinoCloudClass::handleMessage(char topic[], char bytes[], int length)
194
194
}
195
195
}
196
196
197
- ArduinoCloudClass ArduinoCloud;
197
+ ArduinoIoTCloudClass ArduinoCloud;
0 commit comments