Needs an example using flatbuffer in foxglove-websocket

[lhuang-ae]

Does any one have a simple example using flatbuffer in foxglove-websocket?

[jtbandes]

Just created an example using C++ and flatbuffers: foxglove/ws-protocol#469

[lhuang-ae]

Thanks!

[xeonqq]

@jtbandes could you also provide an example in python?

[xeonqq]

I figured out myself by looking at the protobuf example, so quite similar

async def websocket_server_task(queue, websocket_port, topics):
    """Start the WebSocket server. When a client connects, it starts the handler."""
    topic_channel_dict = {}
    async with FoxgloveServer(
        "0.0.0.0", websocket_port, "my server"
    ) as server:
        for topic in topics:
            with open("foxglove/{}.bfbs".format(snake_to_camel(topic)), "rb") as file:
                schema_data = b64encode(file.read()).decode(
                    "ascii"
                ) 

                channel_id = await server.add_channel(
                    {
                        "topic": topic,
                        "encoding": "flatbuffer",
                        "schemaName": "foxglove.{}".format(snake_to_camel(topic)),
                        "schemaEncoding": "flatbuffer",
                        "schema": schema_data,
                    }
                )
                topic_channel_dict[topic] = channel_id

        while True:
            topic, message = await queue.get()
            await server.send_message(topic_channel_dict[topic], time_ns(), message)