feat(wtx): Add optional support for uuid format in postgres.

wtx/Cargo.toml

@@ -41,6 +41,7 @@ tokio-rustls = { default-features = false, features = ["ring"], optional = true,
 tracing = { default-features = false, features = ["attributes"], optional = true, version = "0.1" }
 tracing-subscriber = { default-features = false, features = ["env-filter", "fmt"], optional = true, version = "0.3" }
 tracing-tree = { default-features = false, optional = true, version = "0.4" }
+uuid = { default-features = false, optional = true, version = "1.11.0" }
 webpki-roots = { default-features = false, optional = true, version = "0.26" }
 x509-certificate = { default-features = false, optional = true, version = "0.24" }
 
@@ -114,6 +115,7 @@ std = [
 tls = []
 tokio = ["std", "dep:tokio"]
 tokio-rustls = ["ring", "rustls", "dep:rustls-pemfile", "rustls-pki-types", "tokio", "dep:tokio-rustls"]
+uuid = ["dep:uuid"]
 web-socket = ["http"]
 web-socket-handshake = ["base64", "httparse", "sha1", "web-socket"]
 

wtx/src/database/client/postgres/tys.rs

@@ -836,3 +836,50 @@ mod serde_json {
     const TY: Ty = Ty::Jsonb;
   }
 }
+
+#[cfg(feature = "uuid")]
+mod uuid {
+  use std::prelude::v1::Box;
+
+  use uuid::{Error as UuidError, Uuid};
+
+  use crate::database::{
+    client::postgres::{DecodeValue, EncodeValue, Postgres, Ty},
+    Decode, Encode, Typed,
+  };
+
+  impl<'de, E> Decode<'de, Postgres<E>> for Uuid
+  where
+    E: From<crate::Error>,
+  {
+    #[inline]
+    fn decode(input: &DecodeValue<'de>) -> Result<Self, E> {
+      let elem = Uuid::from_slice(input.bytes()).map_err(Into::into)?;
+      Ok(elem)
+    }
+  }
+
+  impl<E> Encode<Postgres<E>> for Uuid
+  where
+    E: From<crate::Error>,
+  {
+    #[inline]
+    fn encode(&self, ev: &mut EncodeValue<'_, '_>) -> Result<(), E> {
+      ev.fbw()._extend_from_slice(self.as_bytes()).map_err(Into::into)?;
+      Ok(())
+    }
+  }
+
+  impl<E> Typed<Postgres<E>> for Uuid
+  where
+    E: From<crate::Error>,
+  {
+    const TY: Ty = Ty::Uuid;
+  }
+
+  impl From<UuidError> for crate::Error {
+    fn from(value: UuidError) -> Self {
+      Self::UuidError(Box::new(value))
+    }
+  }
+}

wtx/src/error.rs

@@ -72,6 +72,8 @@ pub enum Error {
   TryInitError(tracing_subscriber::util::TryInitError),
   #[cfg(feature = "std")]
   TryLockError(std::sync::TryLockError<()>),
+  #[cfg(feature = "uuid")]
+  UuidError(Box<uuid::Error>),
   #[cfg(feature = "x509-certificate")]
   X509CertificateError(Box<x509_certificate::X509CertificateError>),