ambee/giterated

Added `IntoGiteratedHandler`, which is the new trait for handler functions. This allows us to finally get rid of the Object and ObjectOperation bounds that resulted in hacks around the newer features of the unified stack. Squashed commit of the following: commit 62e1ecf76ee31cda0bab4602d9d00fa0dc2f9158 Author: Amber <[email protected]> Date: Wed Oct 11 09:31:11 2023 -0500 Update commit dfd2d1b0b5d81ee3bc48f0321c6aceaa677e3b8b Author: Amber <[email protected]> Date: Wed Oct 11 09:31:07 2023 -0500 Major refactor to handler traits Added `IntoGiteratedHandler`, which is the new trait for handler functions. This allows us to finally get rid of the Object and ObjectOperation bounds that resulted in hacks around the newer features of the unified stack. Removed dead and legacy code. I think... commit 57b4b398eff32e69f2f4b9700e42a1277a4d1055 Author: Amber <[email protected]> Date: Sun Oct 1 23:05:10 2023 -0500 New handler trait for giterated stack Refactor the old handler trait so it is more generic and can be used for specific kinds of handlers

1	use serde::Serialize;
2
3	use crate::{
4	object::{GiteratedObject, NetworkAnyObject},
5	operation::{GiteratedOperation, NetworkAnyOperation},
6	};
7	use std::fmt::Debug;
8
9	#[derive(Serialize)]
10	#[serde(bound(deserialize = "O: GiteratedObject, V: GiteratedOperation<O>"))]
11	pub struct GiteratedMessage<O: GiteratedObject, V: GiteratedOperation<O>> {
12	#[serde(with = "string")]
13	pub object: O,
14	pub operation: String,
15	pub payload: V,
16	}
17
18	#[allow(unused)]
19	mod string {
20	use std::fmt::Display;
21	use std::str::FromStr;
22
23	use serde::{de, Deserialize, Deserializer, Serializer};
24
25	pub fn serialize<T, S>(value: &T, serializer: S) -> Result<S::Ok, S::Error>
26	where
27	T: Display,
28	S: Serializer,
29	{
30	serializer.collect_str(value)
31	}
32
33	pub fn deserialize<'de, T, D>(deserializer: D) -> Result<T, D::Error>
34	where
35	T: FromStr,
36	T::Err: Display,
37	D: Deserializer<'de>,
38	{
39	String::deserialize(deserializer)?
40	.parse()
41	.map_err(de::Error::custom)
42	}
43	}
44
45	impl GiteratedMessage<NetworkAnyObject, NetworkAnyOperation> {
46	pub fn try_into<O: GiteratedObject, V: GiteratedOperation<O>>(
47	&self,
48	) -> Result<GiteratedMessage<O, V>, ()> {
49	let object = O::from_object_str(&self.object.0).map_err(\|_\| ())?;
50	let payload = serde_json::from_slice::<V>(&self.payload.0).map_err(\|_\| ())?;
51
52	Ok(GiteratedMessage {
53	object,
54	operation: self.operation.clone(),
55	payload,
56	})
57	}
58	}
59
60	impl<V: GiteratedOperation<O> + Debug, O: GiteratedObject + Debug> Debug
61	for GiteratedMessage<O, V>
62	{
63	fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
64	f.debug_struct("GiteratedMessage")
65	.field("object", &self.object)
66	.field("operation", &self.operation)
67	.field("payload", &self.payload)
68	.finish()
69	}
70	}
71