Allow apps to change logging level (#66)

* Allow apps to change logging level

* Make default INFO

* Fix

Author: doctorlai-msrc

sample_apps/advanced_example_py/advanced_example1.py

@@ -149,7 +149,7 @@ def jrtc_start_app(capsule):
 
     # Initialize the app
     state = AppStateVars(agg_cnt=0, app=None)
-    state.app = jrtc_app_create(capsule, app_cfg, app_handler, state)
+    state.app = jrtc_app_create(capsule, app_cfg, app_handler, state, log_level="INFO")
 
     # run the app - This is blocking until the app exits
     jrtc_app_run(state.app)

sample_apps/advanced_example_py/advanced_example2.py

@@ -140,7 +140,7 @@ def jrtc_start_app(capsule):
 
     # Initialize the app
     state = AppStateVars(agg_cnt=0, received_counter=0, app=None)
-    state.app = jrtc_app_create(capsule, app_cfg, app_handler, state)
+    state.app = jrtc_app_create(capsule, app_cfg, app_handler, state, log_level="INFO")
 
     # run the app - This is blocking until the app exists
     jrtc_app_run(state.app)

sample_apps/first_example_py/first_example.py

@@ -111,7 +111,7 @@ def jrtc_start_app(capsule):
 
     # Initialize the app
     state = AppStateVars(agg_cnt=0, received_counter=0, app=None)
-    state.app = jrtc_app_create(capsule, app_cfg, app_handler, state)
+    state.app = jrtc_app_create(capsule, app_cfg, app_handler, state, log_level="INFO")
 
     # run the app - This is blocking until the app exists
     jrtc_app_run(state.app)

src/wrapper_apis/python/jrtc_app.py

@@ -120,14 +120,13 @@ def dump_stream_id(data):
 
 
 class JrtcApp:
-    def __init__(self, env_ctx, app_cfg, app_handler, app_state):
+    def __init__(self, env_ctx, app_cfg, app_handler, app_state, log_level = "INFO"):
         super().__init__()
         self.data = JrtcAppData(
             env_ctx, app_cfg, app_handler, app_state, time.monotonic()
         )
         self.stream_items: list[StreamItem] = []
         self.logger = logging.getLogger("jrtc_app")
-        log_level = os.environ.get("JRTC_APP_LOG_LEVEL", "DEBUG").upper()
         logging.basicConfig(
             level=getattr(logging, log_level, logging.DEBUG),
             format="%(asctime)s - %(name)s - %(levelname)s - %(message)s",
@@ -311,13 +310,14 @@ def get_chan_ctx(self, stream_idx: int) -> Optional[ChannelCtx]:
         return self.stream_items[stream_idx].chan_ctx
 
 
-def jrtc_app_create(capsule, app_cfg: JrtcAppCfg_t, app_handler, app_state):
+def jrtc_app_create(capsule, app_cfg: JrtcAppCfg_t, app_handler, app_state, log_level="INFO") -> JrtcApp:
     env_ctx = get_ctx_from_capsule(capsule)
     app_instance = JrtcApp(
         env_ctx=env_ctx,
         app_cfg=app_cfg,
         app_handler=app_handler,
         app_state=app_state,
+        log_level=log_level,
     )
     return app_instance