Send the Connected message when the public worker is loaded

[bacongobbler]

yew/src/agent.rs

Line 540 in 1ede167

// TODO Send `Connected` message

[TheNeikos]

What exactly needs to be done here? I'd gladly help!

[jstarry]

Thanks for offering!

So, whenever someone connects to an agent, Yew should send a Connected message to the agent so that it can track who's connected. Each connection has a unique HandlerId.

I think we can take advantage of the existing msg queue that was setup not too long ago. Yew allows sending messages to a public worker that hasn't loaded yet, as soon as the worker loads, the queue will be emptied message by message:

yew/src/agent.rs

Lines 601 to 620 in c991c7c

	FromWorker::WorkerLoaded => {
	// TODO(#944): Send `Connected` message
	REMOTE_AGENTS_LOADED.with(|loaded| {
	let _ = loaded.borrow_mut().insert(TypeId::of::<AGN>());
	});
	REMOTE_AGENTS_EARLY_MSGS_QUEUE.with(|queue| {
	let mut queue = queue.borrow_mut();
	if let Some(msgs) = queue.get_mut(&TypeId::of::<AGN>()) {
	for msg in msgs.drain(..) {
	cfg_match! {
	feature = "std_web" => ({
	let worker = &worker;
	js! {@{worker}.postMessage(@{msg});};
	}),
	feature = "web_sys" => worker.post_message_vec(msg),
	}
	}
	}
	});

I think we could pull out the code here:

yew/src/agent.rs

Lines 714 to 720 in c991c7c

	fn send(&mut self, msg: AGN::Input) {
	let msg = ToWorker::ProcessInput(self.id, msg);
	if self.worker_is_loaded() {
	send_to_remote::<AGN>(&self.worker, msg);
	} else {
	self.msg_to_queue(msg.pack());
	}

and reuse it for non-input messages (Connected, Disconnected, Destroy) so that Connected is sent first from the queue and so that Disconnected and Destroy get sent if the bridge gets dropped before the worker loads.