Fix compiling issue

SpringQL · Mar 21, 2023 · a43941b · a43941b
1 parent 345ce8a
commit a43941b
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 7 deletions.
diff --git a/springql-core/src/api/spring_config.rs b/springql-core/src/api/spring_config.rs
@@ -176,7 +176,7 @@ pub struct SpringWebConsoleConfig {
 
 /// Config related to source reader
 #[allow(missing_docs)]
-#[derive(Copy, Clone, Eq, PartialEq, Debug, Deserialize)]
+#[derive(Clone, Eq, PartialEq, Debug, Deserialize)]
 pub struct SpringSourceReaderConfig {
     pub net_connect_timeout_msec: u32,
     pub net_read_timeout_msec: u32,

diff --git a/springql-core/src/stream_engine/autonomous_executor/repositories.rs b/springql-core/src/stream_engine/autonomous_executor/repositories.rs
@@ -22,7 +22,7 @@ impl Repositories {
         Self {
             row_queue_repository: RowQueueRepository::default(),
             window_queue_repository: WindowQueueRepository::default(),
-            source_reader_repository: SourceReaderRepository::new(config.source_reader),
+            source_reader_repository: SourceReaderRepository::new(config.source_reader.clone()),
             sink_writer_repository: SinkWriterRepository::new(config.sink_writer),
         }
     }

diff --git a/...l-core/src/stream_engine/autonomous_executor/task/source_task/source_reader/net_server.rs b/...l-core/src/stream_engine/autonomous_executor/task/source_task/source_reader/net_server.rs
@@ -94,10 +94,13 @@ impl NetServerSourceReader {
     }
 
     fn stream_handler(stream: TcpStream, tx: mpsc::Sender<serde_json::Value>) {
-        // log::info!(
-        //     "[NetServerSourceReader] Connection from {}",
-        //     stream.peer_addr().unwrap()
-        // );
+        log::info!(
+            "[NetServerSourceReader] Connection from {}",
+            stream
+                .peer_addr()
+                .map(|peer_addr| peer_addr.to_string())
+                .unwrap_or("unknown".to_string())
+        );
 
         let mut tcp_reader = BufReader::new(stream);
 
@@ -128,7 +131,6 @@ impl NetServerSourceReader {
 
 #[cfg(test)]
 mod tests {
-    use super::*;
     use crate::{
         api::SpringSinkWriterConfig,
         pipeline::OptionsBuilder,
@@ -137,6 +139,9 @@ mod tests {
             SchemalessRow,
         },
     };
+
+    use super::*;
+
     fn ephemeral_port() -> u16 {
         let addr = TcpListener::bind("127.0.0.1:0").unwrap();
         addr.local_addr().unwrap().port()