expose entities global id

Author: wyfo

Cargo.lock

@@ -467,6 +467,11 @@ impl AdvancedPublisher {
         Ok(py.None())
     }
 
+    #[getter]
+    fn id(&self) -> PyResult<EntityGlobalId> {
+        Ok(self.get_ref()?.id().into())
+    }
+
     #[getter]
     fn key_expr(&self) -> PyResult<KeyExpr> {
         Ok(self.get_ref()?.key_expr().clone().into())
@@ -545,6 +550,11 @@ impl AdvancedSubscriber {
         Ok(py.None())
     }
 
+    #[getter]
+    fn id(&self) -> PyResult<EntityGlobalId> {
+        Ok(self.get_ref()?.id().into())
+    }
+
     #[getter]
     fn key_expr(&self) -> PyResult<KeyExpr> {
         Ok(self.get_ref()?.key_expr().clone().into())

src/ext.rs

@@ -25,6 +25,7 @@ use crate::{
     matching::{MatchingListener, MatchingStatus},
     qos::{CongestionControl, Priority, Reliability},
     sample::Sample,
+    session::EntityGlobalId,
     time::Timestamp,
     utils::{generic, wait},
 };
@@ -48,6 +49,11 @@ impl Publisher {
         Ok(py.None())
     }
 
+    #[getter]
+    fn id(&self) -> PyResult<EntityGlobalId> {
+        Ok(self.get_ref()?.id().into())
+    }
+
     #[getter]
     fn key_expr(&self) -> PyResult<KeyExpr> {
         Ok(self.get_ref()?.key_expr().clone().into())
@@ -154,6 +160,11 @@ impl Subscriber {
         Ok(py.None())
     }
 
+    #[getter]
+    fn id(&self) -> PyResult<EntityGlobalId> {
+        Ok(self.get_ref()?.id().into())
+    }
+
     #[getter]
     fn key_expr(&self) -> PyResult<KeyExpr> {
         Ok(self.get_ref()?.key_expr().clone().into())

src/pubsub.rs

@@ -285,6 +285,11 @@ impl Queryable {
         Ok(py.None())
     }
 
+    #[getter]
+    fn id(&self) -> PyResult<EntityGlobalId> {
+        Ok(self.get_ref()?.id().into())
+    }
+
     #[getter]
     fn key_expr(&self) -> PyResult<KeyExpr> {
         Ok(self.get_ref()?.key_expr().clone().into())
@@ -340,6 +345,11 @@ impl Querier {
         Ok(py.None())
     }
 
+    #[getter]
+    fn id(&self) -> PyResult<EntityGlobalId> {
+        Ok(self.get_ref()?.id().into())
+    }
+
     #[getter]
     fn key_expr(&self) -> PyResult<KeyExpr> {
         Ok(self.get_ref()?.key_expr().clone().into())

src/query.rs

@@ -54,6 +54,11 @@ impl Session {
         Ok(py.None())
     }
 
+    #[getter]
+    fn id(&self) -> EntityGlobalId {
+        self.0.id().into()
+    }
+
     fn zid(&self) -> PyResult<ZenohId> {
         Ok(self.0.zid().into())
     }

src/session.rs

@@ -492,6 +492,9 @@ class Publisher:
 
     def __enter__(self) -> Self: ...
     def __exit__(self, *_args, **_kwargs): ...
+    @_unstable
+    @property
+    def id(self) -> EntityGlobalId: ...
     @property
     def key_expr(self) -> KeyExpr: ...
     @property
@@ -618,6 +621,9 @@ class Queryable(Generic[_H]):
 
     def __enter__(self) -> Self: ...
     def __exit__(self, *_args, **_kwargs): ...
+    @_unstable
+    @property
+    def id(self) -> EntityGlobalId: ...
     @property
     def key_expr(self) -> KeyExpr: ...
     @property
@@ -643,6 +649,9 @@ class Querier:
 
     def __enter__(self) -> Self: ...
     def __exit__(self, *_args, **_kwargs): ...
+    @_unstable
+    @property
+    def id(self) -> EntityGlobalId: ...
     @property
     def key_expr(self) -> KeyExpr: ...
     @property
@@ -872,6 +881,9 @@ class Session:
     def __exit__(self, *_args, **_kwargs): ...
     @property
     def info(self) -> SessionInfo: ...
+    @_unstable
+    @property
+    def id(self) -> EntityGlobalId: ...
     def zid(self) -> ZenohId:
         """Returns the identifier of the current session. zid() is a convenient shortcut."""
 
@@ -1145,6 +1157,9 @@ class Subscriber(Generic[_H]):
 
     def __enter__(self) -> Self: ...
     def __exit__(self, *_args, **_kwargs): ...
+    @_unstable
+    @property
+    def id(self) -> EntityGlobalId: ...
     @property
     def key_expr(self) -> KeyExpr: ...
     @property