Enable SSE logs only on GUI flag and misc reviewers comments

Author: AgeManning

beacon_node/http_api/src/lib.rs

@@ -3750,7 +3750,7 @@ pub fn serve<T: BeaconChainTypes>(
                                     }
                                 }
                                 Err(e) => Err(warp_utils::reject::server_sent_event_error(
-                                    format!("Unable to serialize to JSON {}", e),
+                                    format!("Unable to receive event {}", e),
                                 )),
                             }
                         });
@@ -3929,4 +3929,4 @@ fn publish_network_message<T: EthSpec>(
             e
         ))
     })
-}
+}

beacon_node/src/cli.rs

@@ -1081,7 +1081,7 @@ pub fn cli_app<'a, 'b>() -> App<'a, 'b> {
                 .long("gui")
                 .hidden(true)
                 .help("Enable the graphical user interface and all its requirements. \
-                      This is equivalent to --http and --validator-monitor-auto.")
+                      This enables --http and --validator-monitor-auto and enables SSE logging.")
                 .takes_value(false)
         )
         .arg(
@@ -1093,4 +1093,4 @@ pub fn cli_app<'a, 'b>() -> App<'a, 'b> {
             // always using the builder.
             .conflicts_with("builder-profit-threshold")
         )
-}
+}

book/src/api-lighthouse.md

@@ -684,7 +684,7 @@ Caveats:
 
 This is a Server Side Event subscription endpoint. This allows a user to read
 the Lighthouse logs directly from the HTTP API endpoint. This currently
-exposes INFO and higher level logs.
+exposes INFO and higher level logs. It is only enabled when the `--gui` flag is set in the CLI.
 
 Example:
 
@@ -694,7 +694,7 @@ curl -N "http://localhost:5052/lighthouse/logs"
 
 Should provide an output that emits log events as they occur:
 ```json
-{ 
+{
 "data": {
 	  "time": "Mar 13 15:28:41",
 	  "level": "INFO",
@@ -707,4 +707,3 @@ Should provide an output that emits log events as they occur:
 	}
 }
 ```
-

book/src/api-vc-endpoints.md

@@ -588,9 +588,9 @@ logs emitted are INFO level or higher.
 
 | Property          | Specification                              |
 |-------------------|--------------------------------------------|
-| Path              | `/lighthouse/logs`                    |
+| Path              | `/lighthouse/logs`                         |
 | Method            | GET                                        |
-| Required Headers  | [`Authorization`](./api-vc-auth-header.md) |
+| Required Headers  | None                                       |
 | Typical Responses | 200                                        |
 
 ### Example Response Body
@@ -607,4 +607,4 @@ logs emitted are INFO level or higher.
 	  "total": 1
   }
 }
-```
+```

common/logging/src/sse_logging_components.rs

@@ -35,12 +35,12 @@ impl Drain for SSELoggingComponents {
 
     fn log(&self, record: &Record, logger_values: &OwnedKVList) -> Result<Self::Ok, Self::Err> {
         if record.level().is_at_least(LOG_LEVEL) {
-            // There are subscribers, attempt to send the logs
+            // Attempt to send the logs
             match self.sender.send(AsyncRecord::from(record, logger_values)) {
                 Ok(_num_sent) => {} // Everything got sent
                 Err(_err) => {}     // There are no subscribers, do nothing
             }
         }
         Ok(())
     }
-}
+}

lighthouse/src/main.rs

@@ -485,7 +485,7 @@ fn run<E: EthSpec>(
 
     let sse_logging = {
         if let Some(bn_matches) = matches.subcommand_matches("beacon_node") {
-            bn_matches.is_present("http") || bn_matches.is_present("gui")
+            bn_matches.is_present("gui")
         } else if let Some(vc_matches) = matches.subcommand_matches("validator_client") {
             vc_matches.is_present("http")
         } else {

validator_client/src/http_api/mod.rs

@@ -1058,7 +1058,7 @@ pub fn serve<T: 'static + SlotClock + Clone, E: EthSpec>(
                                     }
                                 }
                                 Err(e) => Err(warp_utils::reject::server_sent_event_error(
-                                    format!("Unable to serialize to JSON {}", e),
+                                    format!("Unable to receive event {}", e),
                                 )),
                             }
                         });
@@ -1174,4 +1174,4 @@ where
 
             response
         })
-}
+}