🚧 WIP, dsx - added message

Author: brentru

src/components/ds18x20/controller.cpp

@@ -24,9 +24,18 @@ bool DS18X20Controller::Handle_Ds18x20Add(pb_istream_t *stream) {
     WS_DEBUG_PRINTLN("ERROR: Unable to decode Ds18x20Add message");
     return false;
   }
-  // Pass the decoded message to the hardware
-  // TODO: Brent you were here and looking at this:
-  // https://github.com/pstolarz/OneWireNg/blob/master/examples/arduino/DallasTemperature/DallasTemperature.ino#L125
+  // Extract the OneWire pin from the message
+  uint8_t pin_name = atoi(_DS18X20_model->GetDS18x20AddMsg()->onewire_pin + 1);
+
+  // Initialize the DS18X20Hardware object
+  DS18X20Hardware new_dsx_driver(pin_name);
+  new_dsx_driver.setResolution(
+      _DS18X20_model->GetDS18x20AddMsg()->sensor_resolution);
+
+  // Add the DS18X20Hardware object to the vector of hardware objects
+  _DS18X20_pins.push_back(new_dsx_driver);
+
+  // TODO: We should publish back an Added message to the broker
 
   return true;
 }

src/components/ds18x20/model.cpp

@@ -26,4 +26,27 @@ bool DS18X20Model::DecodeDS18x20Add(pb_istream_t *stream) {
   // Attempt to decode the stream into a Ds18x20Add message
   return pb_decode(stream, wippersnapper_ds18x20_Ds18x20Add_fields,
                    &_msg_DS18x20Add);
+}
+
+wippersnapper_ds18x20_Ds18x20Add *DS18X20Model::GetDS18x20AddMsg() {
+  return &_msg_DS18x20Add;
+}
+
+bool DS18X20Model::EncodeDS18x20Added(char *onewire_pin, bool is_init) {
+  // Fill the Ds18x20Added message
+  _msg_DS18x20Added = wippersnapper_ds18x20_Ds18x20Added_init_zero;
+  _msg_DS18x20Added.is_initialized = is_init;
+  strcpy(_msg_DS18x20Added.onewire_pin, onewire_pin);
+
+  // Encode the Ds18x20Added message
+  size_t sz_aio_event_msg;
+  if (!pb_get_encoded_size(&sz_aio_event_msg,
+                           wippersnapper_ds18x20_Ds18x20Added_fields,
+                           &_msg_DS18x20Added))
+    return false;
+
+  uint8_t buf[sz_aio_event_msg];
+  pb_ostream_t msg_stream = pb_ostream_from_buffer(buf, sizeof(buf));
+  return pb_encode(&msg_stream, wippersnapper_ds18x20_Ds18x20Added_fields,
+                   &_msg_DS18x20Added);
 }

src/components/ds18x20/model.h

@@ -29,9 +29,13 @@ class DS18X20Model {
   // Ds18x20Add Message
   bool DecodeDS18x20Add(pb_istream_t *stream);
   wippersnapper_ds18x20_Ds18x20Add *GetDS18x20AddMsg();
+  // Ds18x20Remove Message
+  bool EncodeDS18x20Added(char *onewire_pin, bool is_init);
 
 private:
   wippersnapper_ds18x20_Ds18x20Add
       _msg_DS18x20Add; ///< wippersnapper_ds18x20_Ds18x20Add message
+  wippersnapper_ds18x20_Ds18x20Added
+      _msg_DS18x20Added; ///< wippersnapper_ds18x20_Ds18x20Added message
 };
 #endif // WS_DIGITALIO_MODEL_H