Zenoh-C z_slice and z_bytes types compatibility

docs/api.rst

@@ -61,10 +61,14 @@ Owned Types
 
 TODO: owned type description
 
-.. c:type:: z_owned_bytes_t
+.. c:type:: z_owned_slice_t
 
   Represents an array of bytes.
 
+.. c:type:: z_owned_bytes_t
+
+  Represents an array of bytes container.
+
 .. c:type:: z_owned_string_t
 
   Represents a string without null-terminator.
@@ -130,10 +134,14 @@ Loaned Types
 
 TODO: loaned type description
 
-.. c:type:: z_loaned_bytes_t
+.. c:type:: z_loaned_slice_t
 
   Represents an array of bytes.
 
+.. c:type:: z_loaned_bytes_t
+
+  Represents an array of bytes container.
+
 .. c:type:: z_loaned_string_t
 
   Represents a string without null-terminator.
@@ -250,7 +258,7 @@ Macros
 Primitives
 ~~~~~~~~~~
 
-.. autocfunction:: primitives.h::z_view_str_wrap
+.. autocfunction:: primitives.h::z_view_string_wrap
 .. autocfunction:: primitives.h::z_view_keyexpr_from_string
 .. autocfunction:: primitives.h::z_view_keyexpr_from_string_unchecked
 .. autocfunction:: primitives.h::z_keyexpr_to_string
@@ -282,9 +290,36 @@ Primitives
 .. autocfunction:: primitives.h::z_encoding_move
 .. autocfunction:: primitives.h::z_encoding_null
 .. autocfunction:: primitives.h::z_value_payload
+.. autocfunction:: primitives.h::z_slice_data
+.. autocfunction:: primitives.h::z_slice_len
+.. autocfunction:: primitives.h::z_bytes_data
 .. autocfunction:: primitives.h::z_bytes_len
+.. autocfunction:: primitives.h::z_bytes_decode_into_int8
+.. autocfunction:: primitives.h::z_bytes_decode_into_int16
+.. autocfunction:: primitives.h::z_bytes_decode_into_int32
+.. autocfunction:: primitives.h::z_bytes_decode_into_int64
+.. autocfunction:: primitives.h::z_bytes_decode_into_uint8
+.. autocfunction:: primitives.h::z_bytes_decode_into_uint16
+.. autocfunction:: primitives.h::z_bytes_decode_into_uint32
+.. autocfunction:: primitives.h::z_bytes_decode_into_uint64
+.. autocfunction:: primitives.h::z_bytes_decode_into_float
+.. autocfunction:: primitives.h::z_bytes_decode_into_double
+.. autocfunction:: primitives.h::z_bytes_decode_into_slice
 .. autocfunction:: primitives.h::z_bytes_decode_into_string
+.. autocfunction:: primitives.h::z_bytes_encode_from_int8
+.. autocfunction:: primitives.h::z_bytes_encode_from_int16
+.. autocfunction:: primitives.h::z_bytes_encode_from_int32
+.. autocfunction:: primitives.h::z_bytes_encode_from_int64
+.. autocfunction:: primitives.h::z_bytes_encode_from_uint8
+.. autocfunction:: primitives.h::z_bytes_encode_from_uint16
+.. autocfunction:: primitives.h::z_bytes_encode_from_uint32
+.. autocfunction:: primitives.h::z_bytes_encode_from_uint64
+.. autocfunction:: primitives.h::z_bytes_encode_from_float
+.. autocfunction:: primitives.h::z_bytes_encode_from_double
+.. autocfunction:: primitives.h::z_bytes_encode_from_slice
+.. autocfunction:: primitives.h::z_bytes_encode_from_slice_copy
 .. autocfunction:: primitives.h::z_bytes_encode_from_string
+.. autocfunction:: primitives.h::z_bytes_encode_from_string_copy
 .. autocfunction:: primitives.h::z_timestamp_check
 .. autocfunction:: primitives.h::z_query_target_default
 .. autocfunction:: primitives.h::z_query_consolidation_auto

examples/arduino/z_get.ino

@@ -116,11 +116,9 @@ void loop() {
     z_get_options_t opts;
     z_get_options_default(&opts);
     // Value encoding
+    z_owned_bytes_t payload;
     if (strcmp(VALUE, "") != 0) {
-        z_view_string_t value_str;
-        z_view_string_wrap(&value_str, VALUE);
-        z_owned_bytes_t payload;
-        z_bytes_encode_from_string(&payload, z_view_string_loan(&value_str));
+        z_bytes_encode_from_string(&payload, VALUE);
         opts.payload = &payload;
     }
     z_owned_closure_reply_t callback;

examples/arduino/z_queryable.ino

@@ -57,10 +57,8 @@ void query_handler(const z_loaned_query_t *query, void *arg) {
     z_view_keyexpr_from_string_unchecked(&ke, KEYEXPR);
 
     // Reply value encoding
-    z_view_string_t reply_str;
-    z_view_string_wrap(&reply_str, VALUE);
     z_owned_bytes_t reply_payload;
-    z_bytes_encode_from_string(&reply_payload, z_view_string_loan(&reply_str));
+    z_bytes_encode_from_string(&reply_payload, VALUE);
 
     z_query_reply(query, z_view_keyexpr_loan(&ke), z_bytes_move(&reply_payload), NULL);
 

examples/arduino/z_sub.ino

@@ -37,7 +37,8 @@
 void data_handler(const z_loaned_sample_t *sample, void *arg) {
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
-    std::string val((const char *)z_sample_payload(sample)->start, z_sample_payload(sample)->len);
+    const z_loaned_bytes_t *payload = z_sample_payload(sample);
+    std::string val((const char *)z_bytes_data(payload), z_bytes_len(payload));
 
     Serial.print(" >> [Subscription listener] Received (");
     Serial.print(z_string_data(z_string_loan(&keystr)));

examples/espidf/z_get.c

@@ -163,11 +163,9 @@ void app_main() {
         z_get_options_t opts;
         z_get_options_default(&opts);
         // Value encoding
+        z_owned_bytes_t payload;
         if (strcmp(VALUE, "") != 0) {
-            z_view_string_t value_str;
-            z_view_string_wrap(&value_str, VALUE);
-            z_owned_bytes_t payload;
-            z_bytes_encode_from_string(&payload, z_loan(value_str));
+            z_bytes_encode_from_string(&payload, VALUE);
             opts.payload = &payload;
         }
         z_owned_closure_reply_t callback;

examples/espidf/z_queryable.c

@@ -120,10 +120,8 @@ void query_handler(const z_loaned_query_t *query, void *ctx) {
     z_view_keyexpr_t ke;
     z_view_keyexpr_from_string_unchecked(&ke, KEYEXPR);
     // Reply value encoding
-    z_view_string_t reply_str;
-    z_view_string_wrap(&reply_str, VALUE);
     z_owned_bytes_t reply_payload;
-    z_bytes_encode_from_string(&reply_payload, z_loan(reply_str));
+    z_bytes_encode_from_string(&reply_payload, VALUE);
 
     z_query_reply(query, z_loan(ke), z_move(reply_payload), NULL);
     z_drop(z_move(keystr));

examples/espidf/z_sub.c

@@ -105,7 +105,7 @@ void data_handler(const z_loaned_sample_t* sample, void* arg) {
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
     const z_loaned_bytes_t* payload = z_sample_payload(sample);
     printf(" >> [Subscriber handler] Received ('%s': '%.*s')\n", z_string_data(z_string_loan(&keystr)),
-           (int)payload->len, payload->start);
+           (int)z_bytes_len(payload), z_bytes_data(payload));
     z_string_drop(z_string_move(&keystr));
 }
 

examples/freertos_plus_tcp/z_get.c

@@ -87,11 +87,9 @@ void app_main(void) {
         z_get_options_t opts;
         z_get_options_default(&opts);
         // Value encoding
+        z_owned_bytes_t payload;
         if (strcmp(VALUE, "") != 0) {
-            z_view_string_t value_str;
-            z_view_string_wrap(&value_str, VALUE);
-            z_owned_bytes_t payload;
-            z_bytes_encode_from_string(&payload, z_loan(value_str));
+            z_bytes_encode_from_string(&payload, VALUE);
             opts.payload = &payload;
         }
         z_owned_closure_reply_t callback;

examples/freertos_plus_tcp/z_queryable.c

@@ -48,10 +48,8 @@ void query_handler(const z_loaned_query_t *query, void *ctx) {
     z_query_reply_options_t options;
     z_query_reply_options_default(&options);
     // Reply value encoding
-    z_view_string_t reply_str;
-    z_view_string_wrap(&reply_str, VALUE);
     z_owned_bytes_t reply_payload;
-    z_bytes_encode_from_string(&reply_payload, z_loan(reply_str));
+    z_bytes_encode_from_string(&reply_payload, VALUE);
 
     z_query_reply(query, z_query_keyexpr(query), z_move(reply_payload), &options);
     z_drop(z_move(keystr));

examples/freertos_plus_tcp/z_sub.c

@@ -33,8 +33,8 @@ void data_handler(const z_loaned_sample_t *sample, void *ctx) {
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
     const z_loaned_bytes_t *payload = z_sample_payload(sample);
-    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)payload->len,
-           payload->start);
+    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_bytes_len(payload),
+           z_bytes_data(payload));
     z_drop(z_move(keystr));
 }
 

examples/freertos_plus_tcp/z_sub_st.c

@@ -36,8 +36,8 @@ void data_handler(const z_loaned_sample_t *sample, void *ctx) {
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
     const z_loaned_bytes_t *payload = z_sample_payload(sample);
-    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)payload->len,
-           payload->start);
+    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_bytes_len(payload),
+           z_bytes_data(payload));
     z_drop(z_move(keystr));
     z_drop(z_move(keystr));
     msg_nb++;

examples/mbed/z_get.cpp

@@ -84,11 +84,9 @@ int main(int argc, char **argv) {
         z_get_options_t opts;
         z_get_options_default(&opts);
         // Value encoding
+        z_owned_bytes_t payload;
         if (strcmp(VALUE, "") != 0) {
-            z_view_string_t value_str;
-            z_view_string_wrap(&value_str, VALUE);
-            z_owned_bytes_t payload;
-            z_bytes_encode_from_string(&payload, z_view_string_loan(&value_str));
+            z_bytes_encode_from_string(&payload, VALUE);
             opts.payload = &payload;
         }
         z_owned_closure_reply_t callback;

examples/mbed/z_queryable.cpp

@@ -48,10 +48,8 @@ void query_handler(const z_loaned_query_t *query, void *ctx) {
         z_string_drop(z_string_move(&payload_string));
     }
     // Reply value encoding
-    z_view_string_t reply_str;
-    z_view_string_wrap(&reply_str, VALUE);
     z_owned_bytes_t reply_payload;
-    z_bytes_encode_from_string(&reply_payload, z_view_string_loan(&reply_str));
+    z_bytes_encode_from_string(&reply_payload, VALUE);
 
     z_query_reply(query, z_query_keyexpr(query), z_bytes_move(&reply_payload), NULL);
     z_string_drop(z_string_move(&keystr));

examples/mbed/z_sub.cpp

@@ -35,7 +35,7 @@ void data_handler(const z_loaned_sample_t *sample, void *arg) {
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
     const z_loaned_bytes_t *payload = z_sample_payload(sample);
     printf(" >> [Subscriber handler] Received ('%s': '%.*s')\n", z_string_data(z_string_loan(&keystr)),
-           (int)payload->len, payload->start);
+           (int)z_bytes_len(payload), z_bytes_data(payload));
     z_string_drop(z_string_move(&keystr));
 }
 

examples/unix/c11/z_get.c

@@ -134,12 +134,10 @@ int main(int argc, char **argv) {
     printf("Sending Query '%s'...\n", keyexpr);
     z_get_options_t opts;
     z_get_options_default(&opts);
-
+    // Value encoding
+    z_owned_bytes_t payload;
     if (value != NULL) {
-        z_view_string_t value_str;
-        z_view_string_wrap(&value_str, value);
-        z_owned_bytes_t payload;
-        z_bytes_encode_from_string(&payload, z_loan(value_str));
+        z_bytes_encode_from_string(&payload, value);
         opts.payload = &payload;
     }
 #if Z_FEATURE_ATTACHMENT == 1

examples/unix/c11/z_get_channel.c

@@ -91,11 +91,9 @@ int main(int argc, char **argv) {
     z_get_options_t opts;
     z_get_options_default(&opts);
     // Value encoding
+    z_owned_bytes_t payload;
     if (value != NULL) {
-        z_view_string_t value_str;
-        z_view_string_wrap(&value_str, value);
-        z_owned_bytes_t payload;
-        z_bytes_encode_from_string(&payload, z_loan(value_str));
+        z_bytes_encode_from_string(&payload, value);
         opts.payload = &payload;
     }
     z_owned_reply_ring_channel_t channel;

examples/unix/c11/z_pong.c

@@ -19,7 +19,7 @@
 void callback(const z_loaned_sample_t* sample, void* context) {
     const z_loaned_publisher_t* pub = z_loan(*(z_owned_publisher_t*)context);
     const z_loaned_bytes_t* payload = z_sample_payload(sample);
-    z_publisher_put(pub, payload->start, payload->len, NULL);
+    z_publisher_put(pub, z_bytes_data(payload), z_bytes_len(payload), NULL);
 }
 void drop(void* context) {
     z_owned_publisher_t* pub = (z_owned_publisher_t*)context;

examples/unix/c11/z_pull.c

@@ -90,8 +90,9 @@ int main(int argc, char **argv) {
         for (z_call(channel.try_recv, &sample); z_check(sample); z_call(channel.try_recv, &sample)) {
             z_owned_string_t keystr;
             z_keyexpr_to_string(z_sample_keyexpr(z_loan(sample)), &keystr);
-            printf(">> [Subscriber] Pulled ('%s': '%.*s')\n", z_string_data(z_loan(keystr)),
-                   (int)z_sample_payload(z_loan(sample))->len, z_sample_payload(z_loan(sample))->start);
+            const z_loaned_bytes_t *payload = z_sample_payload(z_loan(sample));
+            printf(">> [Subscriber] Pulled ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_bytes_len(payload),
+                   z_bytes_data(payload));
             z_drop(z_move(keystr));
             z_drop(z_move(sample));
         }

examples/unix/c11/z_queryable.c

@@ -71,10 +71,8 @@ void query_handler(const z_loaned_query_t *query, void *ctx) {
 #endif
 
     // Reply value encoding
-    z_view_string_t reply_str;
-    z_view_string_wrap(&reply_str, value);
     z_owned_bytes_t reply_payload;
-    z_bytes_encode_from_string(&reply_payload, z_loan(reply_str));
+    z_bytes_encode_from_string(&reply_payload, value);
 
     z_query_reply(query, z_query_keyexpr(query), z_move(reply_payload), &options);
     z_drop(z_move(keystr));

examples/unix/c11/z_queryable_channel.c

@@ -116,10 +116,8 @@ int main(int argc, char **argv) {
         z_query_reply_options_t options;
         z_query_reply_options_default(&options);
         // Reply value encoding
-        z_view_string_t reply_str;
-        z_view_string_wrap(&reply_str, value);
         z_owned_bytes_t reply_payload;
-        z_bytes_encode_from_string(&reply_payload, z_loan(reply_str));
+        z_bytes_encode_from_string(&reply_payload, value);
 
         z_query_reply(q, z_query_keyexpr(q), z_move(reply_payload), &options);
         z_drop(z_move(keystr));

examples/unix/c11/z_sub.c

@@ -37,8 +37,8 @@ void data_handler(const z_loaned_sample_t *sample, void *ctx) {
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
     const z_loaned_bytes_t *payload = z_sample_payload(sample);
-    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)payload->len,
-           payload->start);
+    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_bytes_len(payload),
+           z_bytes_data(payload));
 #if Z_FEATURE_ATTACHMENT == 1
     z_attachment_t attachment = z_sample_attachment(sample);
     if (z_attachment_check(&attachment)) {

examples/unix/c11/z_sub_channel.c

@@ -80,8 +80,9 @@ int main(int argc, char **argv) {
     for (z_call(channel.recv, &sample); z_check(sample); z_call(channel.recv, &sample)) {
         z_owned_string_t keystr;
         z_keyexpr_to_string(z_sample_keyexpr(z_loan(sample)), &keystr);
-        printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)),
-               (int)z_sample_payload(z_loan(sample))->len, z_sample_payload(z_loan(sample))->start);
+        const z_loaned_bytes_t *payload = z_sample_payload(z_loan(sample));
+        printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_bytes_len(payload),
+               z_bytes_data(payload));
         z_drop(z_move(keystr));
         z_drop(z_move(sample));
         z_null(&sample);

examples/unix/c11/z_sub_st.c

@@ -28,8 +28,8 @@ void data_handler(const z_loaned_sample_t *sample, void *ctx) {
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
     const z_loaned_bytes_t *payload = z_sample_payload(sample);
-    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)payload->len,
-           payload->start);
+    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_bytes_len(payload),
+           z_bytes_data(payload));
     z_drop(z_move(keystr));
     msg_nb++;
 }

examples/unix/c99/z_get.c

@@ -122,11 +122,9 @@ int main(int argc, char **argv) {
     z_get_options_t opts;
     z_get_options_default(&opts);
     // Value encoding
+    z_owned_bytes_t payload;
     if (value != NULL) {
-        z_view_string_t value_str;
-        z_view_string_wrap(&value_str, value);
-        z_owned_bytes_t payload;
-        z_bytes_encode_from_string(&payload, z_view_string_loan(&value_str));
+        z_bytes_encode_from_string(&payload, value);
         opts.payload = &payload;
     }
     z_owned_closure_reply_t callback;

examples/unix/c99/z_pong.c

@@ -20,7 +20,7 @@
 void callback(const z_loaned_sample_t* sample, void* context) {
     const z_loaned_publisher_t* pub = z_publisher_loan((z_owned_publisher_t*)context);
     const z_loaned_bytes_t* payload = z_sample_payload(sample);
-    z_publisher_put(pub, payload->start, payload->len, NULL);
+    z_publisher_put(pub, z_bytes_data(payload), z_bytes_len(payload), NULL);
 }
 void drop(void* context) {
     z_owned_publisher_t* pub = (z_owned_publisher_t*)context;

examples/unix/c99/z_queryable.c

@@ -46,10 +46,8 @@ void query_handler(const z_loaned_query_t *query, void *ctx) {
     z_query_reply_options_default(&options);
     options.encoding = z_encoding_move(&encoding);
     // Reply value encoding
-    z_view_string_t reply_str;
-    z_view_string_wrap(&reply_str, value);
     z_owned_bytes_t reply_payload;
-    z_bytes_encode_from_string(&reply_payload, z_view_string_loan(&reply_str));
+    z_bytes_encode_from_string(&reply_payload, value);
 
     z_query_reply(query, z_query_keyexpr(query), z_bytes_move(&reply_payload), &options);
     z_string_drop(z_string_move(&keystr));

examples/unix/c99/z_sub.c

@@ -25,8 +25,8 @@ void data_handler(const z_loaned_sample_t *sample, void *arg) {
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
     const z_loaned_bytes_t *payload = z_sample_payload(sample);
-    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_string_loan(&keystr)), (int)payload->len,
-           payload->start);
+    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_string_loan(&keystr)),
+           (int)z_bytes_len(payload), z_bytes_data(payload));
     z_string_drop(z_string_move(&keystr));
 }
 

examples/unix/c99/z_sub_st.c

@@ -28,8 +28,8 @@ void data_handler(const z_loaned_sample_t *sample, void *arg) {
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
     const z_loaned_bytes_t *payload = z_sample_payload(sample);
-    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_string_loan(&keystr)), (int)payload->len,
-           payload->start);
+    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_string_loan(&keystr)),
+           (int)z_bytes_len(payload), z_bytes_data(payload));
     z_string_drop(z_string_move(&keystr));
     msg_nb++;
 }