Add traffic watcher services for the on_start/on_stop callbacks (#27)

CHANGELOG.md

@@ -46,6 +46,9 @@ All user visible changes to this project will be documented in this file. This p
     - `[turn.cli]` and `[turn.cli.pool]` sections to configure access to [Coturn] admin interface ([#84]);
     - `server.client.http.public_url` option to configure public URL of Client API HTTP server ([#33]);
     - `rpc.ping_interval` option to configure `Ping`s sending interval ([#75]).
+    - `[media]` section to configure timeouts involved for determining media flow liveness ([#98]):
+        - `max_lag`;
+        - `init_timeout`.
 - Testing:
     - E2E tests for signalling ([#28]).
 
@@ -66,6 +69,7 @@ All user visible changes to this project will be documented in this file. This p
 [#86]: /../../pull/86
 [#94]: /../../pull/94
 [#95]: /../../pull/95
+[#98]: /../../pull/98
 
 
 

config.toml

@@ -208,3 +208,19 @@
 # Env var: MEDEA_SHUTDOWN__TIMEOUT
 # Default:
 #   timeout = "5s"
+
+
+
+
+[media]
+# Max duration of media-flow lag, after which `on_stop` callback is fired.
+#
+# Env var: MEDEA_MEDIA__MAX_LAG
+# Default:
+#   max_lag = "15s"
+
+# Timeout for peer to become active after it has been created.
+#
+# Env var: MEDEA_MEDIA__INIT_TIMEOUT
+# Default:
+#   init_timeout = "15s"

crates/medea-macro/CHANGELOG.md

@@ -12,11 +12,19 @@ All user visible changes to this project will be documented in this file. This p
 ### BC Breaks
 
 - `#[dispatchable]` macro:
-    - Handler traits now require specifying `Output` associative type, which is the return type of all handler trait methods ([#66](/../../pull/66)).
+    - Handler traits now require specifying `Output` associative type, which is the return type of all handler trait methods ([#66]).
 
 ### Added
 
-- `#[derive(JsCaused)]` macro for deriving `JsCaused` trait from `medea-jason` crate ([#68](/../../pull/68)).
+- `#[derive(JsCaused)]` macro for deriving `JsCaused` trait from `medea-jason` crate ([#68]).
+
+### Fixed
+
+- `#[enum_delegate]` macro now works fine on functions with multiple arguments ([#91]).
+
+[#66]: /../../pull/66
+[#68]: /../../pull/68
+[#91]: /../../pull/91
 
 
 
@@ -26,8 +34,11 @@ All user visible changes to this project will be documented in this file. This p
 
 ### Added
 
-- `#[enum_delegate]` macro for delegating function calls to `enum` variants fields ([#23](/../../pull/23));
-- `#[dispatchable]` macro for dispatching `enum`-based events ([#26](/../../pull/26)).
+- `#[enum_delegate]` macro for delegating function calls to `enum` variants fields ([#23]);
+- `#[dispatchable]` macro for dispatching `enum`-based events ([#26]).
+
+[#23]: /../../pull/23
+[#26]: /../../pull/26
 
 
 

crates/medea-macro/src/enum_delegate.rs

@@ -84,7 +84,7 @@ pub fn derive(args: &TokenStream, input: TokenStream) -> Result<TokenStream> {
 
     let enum_output = quote! {
         #(#enum_name_iter::#variants(inner) => {
-            inner.#function_ident(#(#function_args)*)
+            inner.#function_ident(#(#function_args,)*)
         },)*
     };