@@ -955,14 +955,17 @@ async def node_info_update(
955955 await self ._relay_update_state (
956956 node_info .relay_state , timestamp = node_info .timestamp
957957 )
958- if self ._current_log_address is None :
959- if node_info .current_logaddress_pointer :
960- self ._set_cache (
961- CACHE_CURRENT_LOG_ADDRESS ,
962- node_info .current_logaddress_pointer ,
963- )
964- await self .save_cache ()
965- elif (
958+ if (
959+ self ._get_cache (CACHE_CURRENT_LOG_ADDRESS ) is None
960+ and node_info .current_logaddress_pointer
961+ ):
962+ self ._set_cache (
963+ CACHE_CURRENT_LOG_ADDRESS ,
964+ node_info .current_logaddress_pointer ,
965+ )
966+ await self .save_cache ()
967+
968+ if self ._current_log_address is not None and (
966969 self ._current_log_address > node_info .current_logaddress_pointer
967970 or self ._current_log_address == 0
968971 ):
@@ -973,13 +976,12 @@ async def node_info_update(
973976 node_info .current_logaddress_pointer ,
974977 self ._mac_in_str ,
975978 )
976-
977- if self ._current_log_address != node_info .current_logaddress_pointer :
978- self ._current_log_address = node_info .current_logaddress_pointer
979- self ._set_cache (
980- CACHE_CURRENT_LOG_ADDRESS , node_info .current_logaddress_pointer
981- )
982- await self .save_cache ()
979+ if self ._current_log_address != node_info .current_logaddress_pointer :
980+ self ._current_log_address = node_info .current_logaddress_pointer
981+ self ._set_cache (
982+ CACHE_CURRENT_LOG_ADDRESS , node_info .current_logaddress_pointer
983+ )
984+ await self .save_cache ()
983985
984986 return self ._node_info
985987
0 commit comments