Skip to content

Commit

Permalink
plugins/grpc: default value for grpc port
Browse files Browse the repository at this point in the history
  • Loading branch information
jackstar12 committed Jul 21, 2024
1 parent 097491f commit 11899b2
Showing 1 changed file with 6 additions and 15 deletions.
21 changes: 6 additions & 15 deletions plugins/grpc-plugin/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -17,8 +17,9 @@ struct PluginState {
events : broadcast::Sender<cln_rpc::notifications::Notification>,
}

const OPTION_GRPC_PORT : options::IntegerConfigOption = options::ConfigOption::new_i64_no_default(
"grpc-port",
const OPTION_GRPC_PORT : options::DefaultIntegerConfigOption = options::ConfigOption::new_i64_with_default(
"grpc-port",
9736,
"Which port should the grpc plugin listen for incoming connections?");

const OPTION_GRPC_MSG_BUFFER_SIZE : options::DefaultIntegerConfigOption = options::ConfigOption::new_i64_with_default(
Expand Down Expand Up @@ -53,17 +54,7 @@ async fn main() -> Result<()> {
None => return Ok(()),
};

let bind_port = match plugin.option(&OPTION_GRPC_PORT).unwrap() {
Some(port) => port,
None => {
log::info!("'grpc-port' options i not configured. exiting.");
plugin
.disable("Missing 'grpc-port' option")
.await?;
return Ok(())
}
};

let bind_port : i64 = plugin.option(&OPTION_GRPC_PORT).unwrap();
let buffer_size : i64 = plugin.option(&OPTION_GRPC_MSG_BUFFER_SIZE).unwrap();
let buffer_size = match usize::try_from(buffer_size) {
Ok(b) => b,
Expand Down Expand Up @@ -137,7 +128,7 @@ async fn run_interface(bind_addr: SocketAddr, state: PluginState) -> Result<()>
async fn handle_notification(plugin : Plugin<PluginState>, value : serde_json::Value) -> Result<()> {
let notification : Result<Notification, _> = serde_json::from_value(value);
match notification {
Err(err) => {
Err(err) => {
log::debug!("Failed to parse notification from lightningd {:?}", err);
},
Ok(notification) => {
Expand All @@ -148,4 +139,4 @@ async fn handle_notification(plugin : Plugin<PluginState>, value : serde_json::V
}
};
Ok(())
}
}

0 comments on commit 11899b2

Please sign in to comment.