@@ -18,7 +18,7 @@ class SingleClientResponseHandler(ResponseHandler):
1818 # ~~~~~~~~~~~~~~~~~~~~~~~~~ Incoming OmegaMessages ~~~~~~~~~~~~~~~~~~~~~~ #
1919 # #
2020 ###########################################################################
21- def __init__ (self ):
21+ def __init__ (self , refresh_buffer_time : float = 30. ):
2222 self ._command_dispatcher = {
2323 'heartbeat' : self .on_heartbeat ,
2424 'test' : self .on_test_message ,
@@ -37,6 +37,7 @@ def __init__(self):
3737 }
3838 self ._request_sender = None
3939 self ._refresh_token = None
40+ self ._REFRESH_BUFFER_TIME = refresh_buffer_time
4041
4142 def set_request_sender (self , request_sender ):
4243 self ._request_sender = request_sender
@@ -92,8 +93,9 @@ def _on_authorization_grant(self,
9293 authorization_grant .access_token )
9394 self ._refresh_token = authorization_grant .refresh_token
9495 self ._token_expire_time = authorization_grant .expire_at
95- time_until_session_refresh = (self ._token_expire_time -
96- dt .utcnow ().timestamp () - 30. )
96+ time_until_session_refresh = (
97+ self ._token_expire_time - dt .utcnow ().timestamp () -
98+ self ._REFRESH_BUFFER_TIME )
9799 Timer (time_until_session_refresh ,
98100 self ._send_authorization_refresh ).start ()
99101 else :
0 commit comments