pub async fn run_listen_socket(
    listen: &Listen,
    state: GlobalStateR,
    channels: Channels,
    watch_service: Server<WatchClient>
) -> Result<(), ListenError>