API for system info (status) streaming from RE Manager

[dmgav]

Description

Added REManager.system_info_monitor class to support System Info streaming by RE Manager (see bluesky/bluesky-queueserver#339). The class supports streaming over 0MQ (directly by RE Manager) or a WebSocket (via HTTP Server). For example, the following code may be used to receive messages by subscribing to the WebSocket:

from bluesky_queueserver_api.http import REManagerAPI

RM = REManagerAPI()
RM.system_info_monitor.enable()
while True:
    try:
        msg = RM.system_info_monitor.next_msg()
        print(f"msg={msg}")
    except RM.RequestTimeoutError:
        pass

The asyncio version:

import asyncio
from bluesky_queueserver_api.http.aio import REManagerAPI

async def func():
    RM = REManagerAPI()
    RM.system_info_monitor.enable()
    while True:
        try:
            msg = await RM.system_info_monitor.next_msg(timeout=0.1)
            print(f"msg={msg}")
        except RM.RequestTimeoutError:
            pass

asyncio.run(func())

Summary of Changes for Release Notes

Added

• Support for streaming of RE Manager System Info (including RE Manager status) using REManager.system_info_monitor.

How Has This Been Tested?