snmp v3 manager - authorative engine detection fix

Author: bozokopic

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "hat-drivers"
-version = "0.8.11"
+version = "0.8.12"
 description = "Hat communication drivers"
 readme = "README.rst"
 requires-python = ">=3.10"

src_py/hat/drivers/snmp/manager/v3.py

@@ -200,18 +200,6 @@ async def _receive_loop(self):
                                             encoder.v3.MsgType.REPORT):
                         raise Exception('invalid response message type')
 
-                    req_msg, future = self._req_msg_futures[res_msg.id]
-
-                    if res_msg.auth != req_msg.auth:
-                        raise Exception('invalid auth flag')
-
-                    if res_msg.priv != req_msg.priv:
-                        raise Exception('invalid priv flag')
-
-                    if (res_msg.type == encoder.v3.MsgType.RESPONSE and
-                            res_msg.context != req_msg.context):
-                        raise Exception('invalid context')
-
                     if (self._authorative_engine and
                             self._authorative_engine.id !=
                             res_msg.authorative_engine.id):
@@ -237,6 +225,18 @@ async def _receive_loop(self):
                     self._authorative_engine = res_msg.authorative_engine
                     self._authorative_engine_set_time = time.monotonic()
 
+                    req_msg, future = self._req_msg_futures[res_msg.id]
+
+                    if res_msg.auth != req_msg.auth:
+                        raise Exception('invalid auth flag')
+
+                    if res_msg.priv != req_msg.priv:
+                        raise Exception('invalid priv flag')
+
+                    if (res_msg.type == encoder.v3.MsgType.RESPONSE and
+                            res_msg.context != req_msg.context):
+                        raise Exception('invalid context')
+
                     # TODO check user
 
                     res = (