Rename source to sensor

CHANGELOG.md

@@ -12,6 +12,10 @@ Versioning](https://semver.org/spec/v2.0.0.html).
 - Updated the encoding and decoding method for GraphQL cursors by removing
   `graphql::encode_cursor` and `graphql::decode_cursor` methods and replacing
   them with the encoding and decoding methods of `OpaqueCursor`.
+- Replaced the term source with sensor, where it refers to a device or software
+  that captures or detects raw events. This update broadly affects GraphQL APIs
+  that previously used source field as a parameter, and GraphQL APIs that return
+  event, outlier, or triage related structs.
 
 ### Fixed
 

Cargo.toml

@@ -26,7 +26,7 @@ num-traits = "0.2"
 reqwest = { version = "0.12", default-features = false, features = [
   "rustls-tls-native-roots",
 ] }
-review-database = { git = "https://github.com/petabi/review-database.git", tag = "0.32.0" }
+review-database = { git = "https://github.com/petabi/review-database.git", rev = "a1905ce" }
 roxy = { git = "https://github.com/aicers/roxy.git", tag = "0.3.0" }
 rustls = { version = "0.23", default-features = false, features = [
   "ring",

README.md

@@ -1,7 +1,7 @@
 # review-web
 
 This project aims to provide an easy-to-use interface for the REview system,
-allowing users to manage and analyze events from various sources. The web
+allowing users to manage and analyze events from various sensors. The web
 interface is built using modern web technologies, and it exposes a GraphQL API
 for flexible data querying and manipulation.
 

src/graphql/event.rs

@@ -1190,11 +1190,11 @@ mod tests {
 
     use crate::graphql::TestSchema;
 
-    /// Creates an event message at `timestamp` with the given source and
+    /// Creates an event message at `timestamp` with the given sensor and
     /// destination `IPv4` addresses.
     fn event_message_at(timestamp: DateTime<Utc>, src: u32, dst: u32) -> EventMessage {
         let fields = DnsEventFields {
-            source: "sensor1".to_string(),
+            sensor: "sensor1".to_string(),
             session_end_time: timestamp,
             src_addr: Ipv4Addr::from(src).into(),
             src_port: 10000,
@@ -1367,7 +1367,7 @@ mod tests {
                         sensors: [0], \
                     }}, \
                 ) {{ \
-                    edges {{ node {{... on DnsCovertChannel {{ time, source }} }} }} \
+                    edges {{ node {{... on DnsCovertChannel {{ time, sensor }} }} }} \
                     totalCount \
                 }} \
             }}",
@@ -1376,7 +1376,7 @@ mod tests {
         let res = schema.execute(&query).await;
         assert_eq!(
             res.data.to_string(),
-            r#"{eventList: {edges: [{node: {time: "2018-01-27T18:30:09.453829+00:00", source: "sensor1"}}], totalCount: 1}}"#
+            r#"{eventList: {edges: [{node: {time: "2018-01-27T18:30:09.453829+00:00", sensor: "sensor1"}}], totalCount: 1}}"#
         );
     }
 
@@ -1708,7 +1708,7 @@ mod tests {
             .and_local_timezone(Utc)
             .unwrap();
         let fields = BlockListDhcpFields {
-            source: "sensor1".to_string(),
+            sensor: "sensor1".to_string(),
             src_addr: Ipv4Addr::new(127, 0, 0, 1).into(),
             src_port: 68,
             dst_addr: Ipv4Addr::new(127, 0, 0, 2).into(),
@@ -1797,7 +1797,7 @@ mod tests {
             .and_local_timezone(Utc)
             .unwrap();
         let fields = BlockListBootpFields {
-            source: "sensor1".to_string(),
+            sensor: "sensor1".to_string(),
             src_addr: Ipv4Addr::new(127, 0, 0, 1).into(),
             src_port: 68,
             dst_addr: Ipv4Addr::new(127, 0, 0, 2).into(),
@@ -1879,7 +1879,7 @@ mod tests {
             .and_local_timezone(Utc)
             .unwrap();
         let fields = DnsEventFields {
-            source: "sensor1".to_string(),
+            sensor: "sensor1".to_string(),
             session_end_time: timestamp,
             src_addr: Ipv4Addr::from(1).into(),
             src_port: 10000,
@@ -1936,7 +1936,7 @@ mod tests {
             .and_local_timezone(Utc)
             .unwrap();
         let fields = BlockListTlsFields {
-            source: "sensor1".to_string(),
+            sensor: "sensor1".to_string(),
             src_addr: Ipv4Addr::from(1).into(),
             src_port: 10000,
             dst_addr: Ipv4Addr::from(2).into(),

src/graphql/event/bootp.rs

@@ -15,8 +15,8 @@ impl BlockListBootp {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {

src/graphql/event/conn.rs

@@ -320,8 +320,8 @@ impl BlockListConn {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {

src/graphql/event/dcerpc.rs

@@ -15,8 +15,8 @@ impl BlockListDceRpc {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {

src/graphql/event/dhcp.rs

@@ -15,8 +15,8 @@ impl BlockListDhcp {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {

src/graphql/event/dns.rs

@@ -16,8 +16,8 @@ impl DnsCovertChannel {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn session_end_time(&self) -> DateTime<Utc> {
@@ -163,8 +163,8 @@ impl LockyRansomware {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn session_end_time(&self) -> DateTime<Utc> {
@@ -309,8 +309,8 @@ impl CryptocurrencyMiningPool {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {
@@ -451,8 +451,8 @@ impl BlockListDns {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {

src/graphql/event/ftp.rs

@@ -115,8 +115,8 @@ impl FtpPlainText {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {
@@ -254,8 +254,8 @@ impl BlockListFtp {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {

src/graphql/event/group.rs

@@ -445,7 +445,7 @@ mod tests {
     /// destination `IPv4` addresses.
     fn event_message_at(timestamp: DateTime<Utc>, src: u32, dst: u32) -> EventMessage {
         let fields = DnsEventFields {
-            source: "sensor1".to_string(),
+            sensor: "sensor1".to_string(),
             session_end_time: timestamp,
             src_addr: Ipv4Addr::from(src).into(),
             src_port: 10000,

src/graphql/event/http.rs

@@ -16,8 +16,8 @@ impl HttpThreat {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {
@@ -238,8 +238,8 @@ impl RepeatedHttpSessions {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {
@@ -328,8 +328,8 @@ impl TorConnection {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn session_end_time(&self) -> DateTime<Utc> {
@@ -514,8 +514,8 @@ impl DomainGenerationAlgorithm {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {
@@ -700,8 +700,8 @@ impl NonBrowser {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {
@@ -882,8 +882,8 @@ impl BlockListHttp {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {

src/graphql/event/kerberos.rs

@@ -15,8 +15,8 @@ impl BlockListKerberos {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {

src/graphql/event/ldap.rs

@@ -115,8 +115,8 @@ impl LdapPlainText {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {
@@ -235,8 +235,8 @@ impl BlockListLdap {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {

src/graphql/event/log.rs

@@ -16,8 +16,8 @@ impl ExtraThreat {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn service(&self) -> &str {

src/graphql/event/mqtt.rs

@@ -15,8 +15,8 @@ impl BlockListMqtt {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {

src/graphql/event/network.rs

@@ -16,8 +16,8 @@ impl NetworkThreat {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {

src/graphql/event/nfs.rs

@@ -15,8 +15,8 @@ impl BlockListNfs {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {

src/graphql/event/ntlm.rs

@@ -15,8 +15,8 @@ impl BlockListNtlm {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {

src/graphql/event/rdp.rs

@@ -108,8 +108,8 @@ impl BlockListRdp {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {

src/graphql/event/smb.rs

@@ -15,8 +15,8 @@ impl BlockListSmb {
         self.inner.time
     }
 
-    async fn source(&self) -> &str {
-        &self.inner.source
+    async fn sensor(&self) -> &str {
+        &self.inner.sensor
     }
 
     async fn src_addr(&self) -> String {