Parse entity ids

examples/iot-service/src/registration_projection.rs

@@ -27,8 +27,11 @@ pub async fn task(
     state_storage_path: PathBuf,
     temperature_command: mpsc::Sender<Message<temperature::Command>>,
 ) {
-    // Establish our source of events either as a commit log or a gRPC
-    // connection, depending on our feature configuration.
+    // Establish our source of as a gRPC connection, and also setup
+    // an offset store to track the ordering of remote events. In so doing,
+    // we must also describe how an entity can be represented reliably as
+    // distinct keys to this store. In the case here, because our entity
+    // ids are numeric, we attempt a numeric conversion.
 
     let stream_id = StreamId::from("registration-events");
 
@@ -40,7 +43,7 @@ pub async fn task(
             EXPECTED_DISTINCT_REGISTRATIONS,
             offset_store_id,
             offset_store_receiver,
-            |_, _| None, // FIXME
+            |entity_id, _| entity_id.parse().ok(),
         )
         .await
     });