Make source tcp listener address configurable

To allow listening on different interfaces for incoming connections, the
tcp listener address is made configurable.
Additionally, it is set to "0.0.0.0" such that the source server reader
listens on all interfaces per default.

CHANGELOG.md

@@ -14,6 +14,9 @@ All other sections are for end-users.
 
 - (Breaking Change) Remove `TimedStream` from foreign-service ([#250](https://github.com/SpringQL/SpringQL/pull/250)
 
+### Fixed
+- Make TCP server source address configurable, set it to "0.0.0.0" per default ([#260](https://github.com/SpringQL/SpringQL/pull/260))
+
 ## [v0.18.1] - 2022-10-07
 
 ### For developers

springql-core/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "springql-core"
-version = "0.18.1"
+version = "0.18.2"
 
 authors = ["Sho Nakatani <lay.sakura@gmail.com>"]
 license = "MIT OR Apache-2.0"

springql-core/src/api/spring_config.rs

@@ -57,6 +57,7 @@ timeout_msec = 3_000
 [source_reader]
 net_connect_timeout_msec = 1_000
 net_read_timeout_msec = 100
+net_address = "0.0.0.0"
 
 can_read_timeout_msec = 100
 
@@ -179,6 +180,7 @@ pub struct SpringWebConsoleConfig {
 pub struct SpringSourceReaderConfig {
     pub net_connect_timeout_msec: u32,
     pub net_read_timeout_msec: u32,
+    pub net_address: String,
 
     pub can_read_timeout_msec: u32,
 }

springql-core/src/stream_engine/autonomous_executor/task/source_task/source_reader/net_server.rs

@@ -40,7 +40,7 @@ impl SourceReader for NetServerSourceReader {
             "unsupported protocol"
         );
 
-        let listener = TcpListener::bind(("127.0.0.1", options.port)).unwrap();
+        let listener = TcpListener::bind((config.net_address.clone(), options.port)).unwrap();
         let my_addr = listener.local_addr().unwrap();
 
         let (tx, rx) = mpsc::channel();
@@ -94,10 +94,10 @@ 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().unwrap()
+        // );
 
         let mut tcp_reader = BufReader::new(stream);