Skip to content

Commit 1f27676

Browse files
fixup! implementing cbor message decoder following cloud utils definition
1 parent 0a1ed79 commit 1f27676

File tree

2 files changed

+25
-25
lines changed

2 files changed

+25
-25
lines changed

src/cbor/MessageDecoder.cpp renamed to src/cbor/IoTCloudMessageDecoder.cpp

+19-19
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414

1515
#include <Arduino.h>
1616

17-
#include "MessageDecoder.h"
17+
#include "IoTCloudMessageDecoder.h"
1818
#include <AIoTC_Config.h>
1919

2020
/******************************************************************************
@@ -53,29 +53,29 @@ static bool copyCBORByteToArray(CborValue * param, uint8_t * dest, size_t dest_s
5353
MESSAGE DECODE FUNCTIONS
5454
******************************************************************************/
5555

56-
Decoder::Status ThingUpdateCommandDecoder::decode(CborValue* iter, Message *msg) {
56+
MessageDecoder::Status ThingUpdateCommandDecoder::decode(CborValue* iter, Message *msg) {
5757
ThingUpdateCmd * thingCommand = (ThingUpdateCmd *) msg;
5858

5959
// Message is composed of a single parameter, a string (thing_id)
6060
if (!copyCBORStringToArray(iter, thingCommand->params.thing_id, sizeof(thingCommand->params.thing_id))) {
61-
return Decoder::Status::Error;
61+
return MessageDecoder::Status::Error;
6262
}
6363

64-
return Decoder::Status::Complete;
64+
return MessageDecoder::Status::Complete;
6565
}
6666

67-
Decoder::Status ThingDetachCommandDecoder::decode(CborValue* iter, Message *msg) {
67+
MessageDecoder::Status ThingDetachCommandDecoder::decode(CborValue* iter, Message *msg) {
6868
ThingDetachCmd * thingCommand = (ThingDetachCmd *) msg;
6969

7070
// Message is composed of a single parameter, a string (thing_id)
7171
if (!copyCBORStringToArray(iter, thingCommand->params.thing_id, sizeof(thingCommand->params.thing_id))) {
72-
return Decoder::Status::Error;
72+
return MessageDecoder::Status::Error;
7373
}
7474

75-
return Decoder::Status::Complete;
75+
return MessageDecoder::Status::Complete;
7676
}
7777

78-
Decoder::Status TimezoneCommandDownDecoder::decode(CborValue* iter, Message *msg) {
78+
MessageDecoder::Status TimezoneCommandDownDecoder::decode(CborValue* iter, Message *msg) {
7979
TimezoneCommandDown * setTz = (TimezoneCommandDown *) msg;
8080

8181
// Message is composed of 2 parameters, offset 32-bit signed integer and until 32-bit unsigned integer
@@ -89,7 +89,7 @@ Decoder::Status TimezoneCommandDownDecoder::decode(CborValue* iter, Message *msg
8989

9090
// Next
9191
if (cbor_value_advance(iter) != CborNoError) {
92-
return Decoder::Status::Error;
92+
return MessageDecoder::Status::Error;
9393
}
9494

9595
// Get until
@@ -100,10 +100,10 @@ Decoder::Status TimezoneCommandDownDecoder::decode(CborValue* iter, Message *msg
100100
}
101101
}
102102

103-
return Decoder::Status::Complete;
103+
return MessageDecoder::Status::Complete;
104104
}
105105

106-
Decoder::Status LastValuesUpdateCommandDecoder::decode(CborValue* iter, Message *msg) {
106+
MessageDecoder::Status LastValuesUpdateCommandDecoder::decode(CborValue* iter, Message *msg) {
107107
LastValuesUpdateCmd * setLv = (LastValuesUpdateCmd *) msg;
108108

109109
// Message is composed by a single parameter, a variable length byte array.
@@ -112,43 +112,43 @@ Decoder::Status LastValuesUpdateCommandDecoder::decode(CborValue* iter, Message
112112
// we use a support variable to cope with that
113113
size_t s;
114114
if (cbor_value_dup_byte_string(iter, &setLv->params.last_values, &s, NULL) != CborNoError) {
115-
return Decoder::Status::Error;
115+
return MessageDecoder::Status::Error;
116116
}
117117

118118
setLv->params.length = s;
119119
}
120120

121-
return Decoder::Status::Complete;
121+
return MessageDecoder::Status::Complete;
122122
}
123123

124-
Decoder::Status OtaUpdateCommandDecoder::decode(CborValue* iter, Message *msg) {
124+
MessageDecoder::Status OtaUpdateCommandDecoder::decode(CborValue* iter, Message *msg) {
125125
CborError error = CborNoError;
126126
OtaUpdateCmdDown * ota = (OtaUpdateCmdDown *) msg;
127127

128128
// Message is composed 4 parameters: id, url, initialSha, finalSha
129129
if (!copyCBORByteToArray(iter, ota->params.id, sizeof(ota->params.id))) {
130-
return Decoder::Status::Error;
130+
return MessageDecoder::Status::Error;
131131
}
132132

133133
error = cbor_value_advance(iter);
134134

135135
if ((error != CborNoError) || !copyCBORStringToArray(iter, ota->params.url, sizeof(ota->params.url))) {
136-
return Decoder::Status::Error;
136+
return MessageDecoder::Status::Error;
137137
}
138138

139139
error = cbor_value_advance(iter);
140140

141141
if ((error != CborNoError) || !copyCBORByteToArray(iter, ota->params.initialSha256, sizeof(ota->params.initialSha256))) {
142-
return Decoder::Status::Error;
142+
return MessageDecoder::Status::Error;
143143
}
144144

145145
error = cbor_value_advance(iter);
146146

147147
if ((error != CborNoError) || !copyCBORByteToArray(iter, ota->params.finalSha256, sizeof(ota->params.finalSha256))) {
148-
return Decoder::Status::Error;
148+
return MessageDecoder::Status::Error;
149149
}
150150

151-
return Decoder::Status::Complete;
151+
return MessageDecoder::Status::Complete;
152152
}
153153

154154
static OtaUpdateCommandDecoder otaUpdateCommandDecoder;

src/cbor/MessageDecoder.h renamed to src/cbor/IoTCloudMessageDecoder.h

+6-6
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
******************************************************************************/
1717

1818
#include "./CBOR.h"
19-
#include <cbor/CborDecoder.h>
19+
#include <cbor/MessageDecoder.h>
2020
#include "message/Commands.h"
2121

2222
/******************************************************************************
@@ -28,39 +28,39 @@ class OtaUpdateCommandDecoder: public CBORMessageDecoderInterface {
2828
OtaUpdateCommandDecoder()
2929
: CBORMessageDecoderInterface(CBOROtaUpdateCmdDown, OtaUpdateCmdDownId) {}
3030
protected:
31-
Decoder::Status decode(CborValue* iter, Message *msg) override;
31+
MessageDecoder::Status decode(CborValue* iter, Message *msg) override;
3232
};
3333

3434
class ThingUpdateCommandDecoder: public CBORMessageDecoderInterface {
3535
public:
3636
ThingUpdateCommandDecoder()
3737
: CBORMessageDecoderInterface(CBORThingUpdateCmd, ThingUpdateCmdId) {}
3838
protected:
39-
Decoder::Status decode(CborValue* iter, Message *msg) override;
39+
MessageDecoder::Status decode(CborValue* iter, Message *msg) override;
4040
};
4141

4242
class ThingDetachCommandDecoder: public CBORMessageDecoderInterface {
4343
public:
4444
ThingDetachCommandDecoder()
4545
: CBORMessageDecoderInterface(CBORThingDetachCmd, ThingDetachCmdId) {}
4646
protected:
47-
Decoder::Status decode(CborValue* iter, Message *msg) override;
47+
MessageDecoder::Status decode(CborValue* iter, Message *msg) override;
4848
};
4949

5050
class LastValuesUpdateCommandDecoder: public CBORMessageDecoderInterface {
5151
public:
5252
LastValuesUpdateCommandDecoder()
5353
: CBORMessageDecoderInterface(CBORLastValuesUpdate, LastValuesUpdateCmdId) {}
5454
protected:
55-
Decoder::Status decode(CborValue* iter, Message *msg) override;
55+
MessageDecoder::Status decode(CborValue* iter, Message *msg) override;
5656
};
5757

5858
class TimezoneCommandDownDecoder: public CBORMessageDecoderInterface {
5959
public:
6060
TimezoneCommandDownDecoder()
6161
: CBORMessageDecoderInterface(CBORTimezoneCommandDown, TimezoneCommandDownId) {}
6262
protected:
63-
Decoder::Status decode(CborValue* iter, Message *msg) override;
63+
MessageDecoder::Status decode(CborValue* iter, Message *msg) override;
6464
};
6565

6666
#endif /* ARDUINO_CBOR_MESSAGE_DECODER_H_ */

0 commit comments

Comments
 (0)