feat: timer from 32 -> 64 s

Author: shenjinti

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "rsipstack"
-version = "0.2.27"
+version = "0.2.28"
 edition = "2021"
 description = "SIP Stack Rust library for building SIP applications"
 license = "MIT"
@@ -31,19 +31,19 @@ wasm-bindgen = "0.2.84"
 # code size when deploying.
 console_error_panic_hook = { version = "0.1.7", optional = true }
 wasm-bindgen-futures = "0.4.45"
-tokio-util = { version = "0.7.15", features = ["full"] }
+tokio-util = { version = "0.7.16", features = ["full"] }
 tracing-subscriber = { version = "0.3.19", features = ["local-time"] }
-rand = { version = "0.9.1" }
+rand = { version = "0.9.2" }
 get_if_addrs = "0.5.3"
 rsip-dns = { version = "0.1.4", features = ["trust-dns"] }
 bytes = "1.10.1"
 futures-util = "0.3.30"
 tokio-tungstenite = { version = "0.27.0", optional = true }
 tokio-rustls = { version = "0.26.2", optional = true }
 rustls-pemfile = { version = "2.2.0", optional = true }
-webpki-roots = { version = "1.0.0", optional = true }
-rustls = "0.23.28"
-clap = { version = "4.5.37", features = ["derive"] }
+webpki-roots = { version = "1.0.2", optional = true }
+rustls = "0.23.31"
+clap = { version = "4.5.43", features = ["derive"] }
 http = "1.3.1"
 
 [features]
@@ -53,8 +53,8 @@ websocket = ["tokio-tungstenite"]
 all-transports = ["rustls", "websocket"]
 
 [target.'cfg(target_arch = "wasm32")'.dependencies]
-tokio = { version = "1.44.2", features = ["time", "sync", "macros", "io-util"] }
-getrandom = { version = "0.3.2" }
+tokio = { version = "1.47.1", features = ["time", "sync", "macros", "io-util"] }
+getrandom = { version = "0.3.3" }
 
 [target.'cfg(not(target_arch = "wasm32"))'.dependencies]
 tokio = { version = "1.44.2", features = ["full"] }
@@ -65,10 +65,10 @@ dotenv = "0.15"
 sdp-rs = "0.2.1"
 rtp-rs = "0.6.0"
 stun-rs = "0.1.11"
-openai-api-rs = "6.0.3"
+openai-api-rs = "6.0.8"
 base64 = "0.22.1"
 serde = "1.0.219"
-serde_json = "1.0.140"
+serde_json = "1.0.142"
 dasp = { version = "0.11", features = ["all"] }
 axum = { version = "0.8.4", features = ["ws"] }
 tower = "0.5.2"

examples/client/main.rs

@@ -71,6 +71,9 @@ struct Args {
 
     #[arg(long)]
     call: Option<String>,
+
+    #[arg(long)]
+    reject: bool,
 }
 
 async fn handle_user_input(cancel_token: CancellationToken) -> Result<()> {
@@ -229,7 +232,7 @@ async fn main() -> rsipstack::Result<()> {
         r = process_registration(endpoint.inner.clone(), sip_server, credential.clone(), token.clone()) => {
             info!("register loop finished {:?}", r);
         }
-        r = process_incoming_request(dialog_layer.clone(), incoming, state_sender.clone(), contact.clone()) => {
+        r = process_incoming_request(dialog_layer.clone(), incoming, state_sender.clone(), contact.clone(), args.reject) => {
             info!("serve loop finished {:?}", r);
         }
         r = process_dialog(dialog_layer.clone(), state_receiver, opt.clone()) => {
@@ -295,6 +298,7 @@ async fn process_incoming_request(
     mut incoming: TransactionReceiver,
     state_sender: DialogStateSender,
     contact: rsip::Uri,
+    reject: bool,
 ) -> Result<()> {
     while let Some(mut tx) = incoming.recv().await {
         info!("Received transaction: {:?}", tx.key);
@@ -320,6 +324,11 @@ async fn process_incoming_request(
         // out dialog, new server dialog
         match tx.original.method {
             rsip::Method::Invite | rsip::Method::Ack => {
+                if reject && tx.original.method == rsip::Method::Invite {
+                    info!("Rejecting incoming call: {}", tx.original);
+                    tx.reply(rsip::StatusCode::BusyHere).await?;
+                    continue;
+                }
                 let mut dialog = match dialog_layer.get_or_create_server_invite(
                     &tx,
                     state_sender.clone(),

examples/proxy.rs

@@ -596,15 +596,11 @@ impl fmt::Display for ClientAddr {
 async fn serve_index() -> impl IntoResponse {
     Html(include_str!("../assets/index.html"))
 }
-async fn serve_sip_js() -> impl IntoResponse {
-    Html(include_str!("../assets/sip-0.17.1.js"))
-}
 
 fn create_http_app(state: AppState) -> Router {
     Router::new()
         .route("/", get(serve_index))
         .route("/ws", get(websocket_handler))
-        .route("/sip-0.17.1.js", get(serve_sip_js))
         .with_state(state)
         .layer(ServiceBuilder::new().layer(CorsLayer::permissive()))
 }

src/transaction/endpoint.rs

@@ -28,6 +28,7 @@ pub struct EndpointOption {
     pub t1: Duration,
     pub t4: Duration,
     pub t1x64: Duration,
+    pub timerb: Duration,
     pub ignore_out_of_dialog_option: bool,
     pub callid_suffix: Option<String>,
 }
@@ -38,6 +39,7 @@ impl Default for EndpointOption {
             t1: Duration::from_millis(500),
             t4: Duration::from_secs(4),
             t1x64: Duration::from_millis(64 * 500),
+            timerb: Duration::from_secs(64),
             ignore_out_of_dialog_option: true,
             callid_suffix: None,
         }

src/transaction/transaction.rs

@@ -673,7 +673,7 @@ impl Transaction {
                     .take()
                     .map(|id| self.endpoint_inner.timers.cancel(id));
                 self.timer_b.replace(self.endpoint_inner.timers.timeout(
-                    self.endpoint_inner.option.t1x64,
+                    self.endpoint_inner.option.timerb,
                     TransactionTimer::TimerB(self.key.clone()),
                 ));
             }
@@ -683,7 +683,7 @@ impl Transaction {
                     .map(|id| self.endpoint_inner.timers.cancel(id));
                 // start Timer B
                 let timer_b = self.endpoint_inner.timers.timeout(
-                    self.endpoint_inner.option.t1x64,
+                    self.endpoint_inner.option.timerb,
                     TransactionTimer::TimerB(self.key.clone()),
                 );
                 self.timer_b.replace(timer_b);