in aepsych/server.py [0:0]
def versioned_handler(self, request):
handled_types = ["setup", "resume", "ask"]
if request["type"] == "setup":
if request["version"] == "0.01":
ret_val = self.handle_setup_v01(request)
else:
raise RuntimeError(
f"Unknown message version {request['version']} for message 'setup'!"
)
elif request["type"] == "resume":
if request["version"] == "0.01":
ret_val = self.handle_resume_v01(request)
else:
raise RuntimeError(
f"Unknown message version {request['version']} for message 'resume'!"
)
elif request["type"] == "ask":
if request["version"] == "0.01":
ret_val = self.handle_ask_v01(request)
else:
raise RuntimeError(
f"Unknown message version {request['version']} for message 'ask'!"
)
if request["type"] in handled_types:
logger.info(f"Received msg [{request['type']}]")
else:
warnings.warn(
"Got versioned handler but no version, falling back to unversioned!"
)
self.unversioned_handler(request)
return ret_val