sensors: Update bme280 sample to async APIs

DNM, this change is only an example and should not yet be merged.

Signed-off-by: Yuval Peress <peress@google.com>

samples/sensor/bme280/Kconfig

@@ -7,9 +7,6 @@ config LOG
 config LOG_PRINTK
 	default y
 
-config SENSOR_LOG_LEVEL
-	default 4
-
 # Enable SPI and I2C support by default so that the sample works with
 # the device connected either way. These defaults can be overridden if
 # needed.

samples/sensor/bme280/prj.conf

@@ -1 +1,2 @@
 CONFIG_SENSOR=y
+CONFIG_SENSOR_LOG_LEVEL_OFF=y

samples/sensor/bme280/src/main.c

@@ -5,11 +5,21 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
+#include "zephyr/rtio/rtio.h"
 #include <zephyr/kernel.h>
 #include <zephyr/device.h>
 #include <zephyr/devicetree.h>
 #include <zephyr/drivers/sensor.h>
 
+
+#define BME280_DT_NODE DT_COMPAT_GET_ANY_STATUS_OKAY(bosch_bme280)
+
+RTIO_DEFINE_WITH_MEMPOOL(r, 1, 1, 1, 32, 4);
+SENSOR_DT_READ_IODEV(bme280_io, BME280_DT_NODE,
+		     SENSOR_CHAN_AMBIENT_TEMP, SENSOR_CHAN_PRESS, SENSOR_CHAN_HUMIDITY);
+
+static const struct sensor_decoder_api *decoder;
+
 /*
  * Get a device structure from a devicetree node with compatible
  * "bosch,bme280". (If there are multiple, just pick one.)
@@ -35,25 +45,50 @@ static const struct device *get_bme280_device(void)
 	return dev;
 }
 
+#define B(x) (int32_t)FIELD_GET(GENMASK64(63, 31), x)
+#define L(x) (int32_t)FIELD_GET(GENMASK(30, 0), x)
+
+void process(int result, uint8_t *buf, uint32_t buf_len, void *userdata)
+{
+	sensor_frame_iterator_t fit = {0};
+	sensor_channel_iterator_t cit = {0};
+	enum sensor_channel channels[3];
+	q31_t values[3];
+	int8_t shift[3];
+
+	decoder->decode(buf, &fit, &cit, channels, values, 3);
+
+	decoder->get_shift(buf, channels[0], &shift[0]);
+	decoder->get_shift(buf, channels[0], &shift[1]);
+	decoder->get_shift(buf, channels[0], &shift[2]);
+
+	int64_t scaled[] = {
+		values[0] << shift[0],
+		values[1] << shift[1],
+		values[2] << shift[2]
+	};
+
+	printk("temp: %d.%06d; press: %d.%06d; humidity: %d.%06d\n",
+	       B(scaled[0]), L(scaled[0]),
+	       B(scaled[1]), L(scaled[1]),
+	       B(scaled[2]), L(scaled[2]));
+
+}
+
 int main(void)
 {
 	const struct device *dev = get_bme280_device();
 
+	sensor_get_decoder(dev, &decoder);
+
 	if (dev == NULL) {
 		return 0;
 	}
 
 	while (1) {
-		struct sensor_value temp, press, humidity;
-
-		sensor_sample_fetch(dev);
-		sensor_channel_get(dev, SENSOR_CHAN_AMBIENT_TEMP, &temp);
-		sensor_channel_get(dev, SENSOR_CHAN_PRESS, &press);
-		sensor_channel_get(dev, SENSOR_CHAN_HUMIDITY, &humidity);
+		sensor_read(&bme280_io, &r, NULL);
 
-		printk("temp: %d.%06d; press: %d.%06d; humidity: %d.%06d\n",
-		      temp.val1, temp.val2, press.val1, press.val2,
-		      humidity.val1, humidity.val2);
+		sensor_processing_with_callback(&r, process);
 
 		k_sleep(K_MSEC(1000));
 	}