something

Author: simensrostad

app/src/main.c

@@ -454,9 +454,11 @@ static void triggering_run(void *o)
 		}
 
 		if (msg.type == CLOUD_SHADOW_RESPONSE) {
-			/* Missing: Parse the interval received in the shadow response,
-			 * write to state object and schedule new interval
-			 */
+
+			/* Search through the msg.response.buffer and find the value of the interval */
+			/* If the interval is different from the current interval, update the interval */
+			/* and reschedule the trigger_work, Use the nrf cloud codec? */
+
 
 			int err = k_work_reschedule(&trigger_work,
 						    K_SECONDS(state_object->interval_sec));

app/src/modules/cloud/cloud_module.c

@@ -491,7 +491,22 @@ static void shadow_get(bool delta_only)
 		return;
 	}
 
-	/* No further processing of shadow is implemented */
+	/* Send event CLOUD_SHADOW_RESPONSE with the buffer */
+	struct cloud_msg msg = {
+		.type = CLOUD_SHADOW_RESPONSE,
+	};
+
+	__BUILD_ASSERT(sizeof(msg.response.buffer) >= sizeof(recv_buf),
+		       "Buffer size must be large enough to hold the received data");
+
+	memcpy(msg.response.buffer, recv_buf, recv_buf_len);
+	msg.response.buffer_len = recv_buf_len;
+
+	err = zbus_chan_pub(&CLOUD_CHAN, &msg, K_SECONDS(1));
+	if (err) {
+		LOG_ERR("zbus_chan_pub, error: %d", err);
+		SEND_FATAL_ERROR();
+	}
 }
 
 static void state_connected_ready_entry(void *o)

app/src/modules/cloud/cloud_module.h

@@ -43,6 +43,7 @@ enum cloud_msg_type {
 struct cloud_msg {
 	enum cloud_msg_type type;
 	struct cloud_payload payload;
+	struct cloud_shadow_response response;
 };
 
 #define MSG_TO_CLOUD_MSG(_msg)	(*(const struct cloud_msg *)_msg)