Implement dsn~usubscription-change-notification-update (eclipse-uprotocol#21)

* Implement dsn~usubscription-change-notification-update
* minor improvements to devcontainer config
* deal with new clippy rules

Author: AnotherDaniel

.devcontainer/Dockerfile

@@ -17,6 +17,7 @@ ARG TARGETARCH
 
 RUN apt-get update && export DEBIAN_FRONTEND=noninteractive \
     && apt-get -y install \
+    cmake \
     curl \
     gcc \
     git \

.env.oft-current

@@ -17,7 +17,7 @@ UP_SPEC_FILE_PATTERNS="up-spec/up-l3/usubscription/v3/README.adoc"
 
 # The file patterns that specify this component's resources which contain specification items
 # that cover the requirements
-COMPONENT_FILE_PATTERNS="*.adoc *.md *.rs .github up-subscription/src"
+COMPONENT_FILE_PATTERNS="*.md .github up-subscription/src"
 
 OFT_FILE_PATTERNS="$UP_SPEC_FILE_PATTERNS $COMPONENT_FILE_PATTERNS"
 OFT_TAGS=""

.env.oft-latest

@@ -17,7 +17,7 @@ UP_SPEC_FILE_PATTERNS="up-spec/up-l3/usubscription/v3/README.adoc"
 
 # The file patterns that specify this component's resources which contain specification items
 # that cover the requirements
-COMPONENT_FILE_PATTERNS="*.adoc *.md *.rs .github up-subscription/src"
+COMPONENT_FILE_PATTERNS="*.md .github up-subscription/src"
 
 OFT_FILE_PATTERNS="$UP_SPEC_FILE_PATTERNS $COMPONENT_FILE_PATTERNS"
 OFT_TAGS="_,uSubscription"

tools/coverage.sh

@@ -58,7 +58,7 @@ impl StartupError {
 impl std::fmt::Display for StartupError {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         match self {
-            Self::ConfigurationError(e) => f.write_fmt(format_args!("Configuration error: {}", e)),
+            Self::ConfigurationError(e) => f.write_fmt(format_args!("Configuration error: {e}")),
         }
     }
 }
@@ -193,7 +193,7 @@ async fn main() {
             Ok(_) => {
                 debug!("Success, running daemonized");
             }
-            Err(e) => error!("Error, {}", e),
+            Err(e) => error!("Error, {e}"),
         }
     }
 

tools/generate_test_coverage_report.sh

@@ -36,7 +36,7 @@ where
 {
     task::spawn(async move {
         if let Err(e) = fut.await {
-            error!("{}", e)
+            error!("{e}")
         }
     })
 }
@@ -53,8 +53,7 @@ where
 {
     if resource_id != expected_resource_id {
         return Err(ServiceInvocationError::InvalidArgument(format!(
-            "Wrong resource ID (expected {}, got {})",
-            expected_resource_id, resource_id
+            "Wrong resource ID (expected {expected_resource_id}, got {resource_id})"
         )));
     }
     let Some(payload) = payload else {

tools/startup.sh

@@ -86,13 +86,10 @@ impl USubscriptionConfiguration {
         let persistency_path = if let Some(path_string) = persistency_path {
             let p = Path::new(&path_string);
             p.try_exists().unwrap_or_else(|_| {
-                panic!("Persistency storage path does not exist {}", path_string)
+                panic!("Persistency storage path does not exist {path_string}")
             });
             if !p.is_dir() {
-                panic!(
-                    "Persistency storage path is not a directory {}",
-                    path_string
-                );
+                panic!("Persistency storage path is not a directory {path_string}");
             }
             p.to_path_buf()
         } else {

up-subscription-cli/src/main.rs

@@ -64,6 +64,43 @@ pub(crate) enum NotificationEvent {
     },
 }
 
+impl PartialEq for NotificationEvent {
+    fn eq(&self, other: &Self) -> bool {
+        match (self, other) {
+            (
+                NotificationEvent::StateChange {
+                    subscriber: s1,
+                    topic: t1,
+                    status: st1,
+                    ..
+                },
+                NotificationEvent::StateChange {
+                    subscriber: s2,
+                    topic: t2,
+                    status: st2,
+                    ..
+                },
+            ) => s1 == s2 && t1 == t2 && st1 == st2,
+            (
+                NotificationEvent::AddNotifyee {
+                    subscriber: s1,
+                    topic: t1,
+                },
+                NotificationEvent::AddNotifyee {
+                    subscriber: s2,
+                    topic: t2,
+                },
+            ) => s1 == s2 && t1 == t2,
+            (
+                NotificationEvent::RemoveNotifyee { subscriber: s1 },
+                NotificationEvent::RemoveNotifyee { subscriber: s2 },
+            ) => s1 == s2,
+            // Don't care about the test-only variants
+            _ => false,
+        }
+    }
+}
+
 // Keeps track of and sends subscription update notification to all registered update-notification channels.
 // Interfacing with this purely works via channels.
 pub(crate) async fn notification_engine(
@@ -186,7 +223,7 @@ pub(crate) async fn notification_engine(
                     }
                 }
 
-                let _r = respond_to.send(());
+                let _ = respond_to.send(());
             }
             #[cfg(test)]
             NotificationEvent::GetNotificationTopics { respond_to } => {