use std::collections::HashMap;
use serde::{Deserialize, Serialize};
#[cfg(feature = "python")]
use pyo3::{exceptions::PyValueError, prelude::*, types::PyDict};
pub use crate::native::common::{Category, Comment, Entry, Field, Form, Reason, State, Value};
use crate::native::deserializers::{default_string_none, deserialize_empty_string_as_none};
#[cfg(not(feature = "python"))]
#[derive(Clone, Debug, Deserialize, Serialize, PartialEq)]
#[serde(rename_all = "camelCase")]
pub struct User {
#[serde(rename = "uniqueId")]
#[serde(alias = "@uniqueId")]
#[serde(alias = "uniqueId")]
pub unique_id: String,
#[serde(rename = "lastLanguage")]
#[serde(alias = "@lastLanguage")]
#[serde(alias = "lastLanguage")]
#[serde(
default = "default_string_none",
deserialize_with = "deserialize_empty_string_as_none"
)]
pub last_language: Option<String>,
#[serde(rename = "creator")]
#[serde(alias = "@creator")]
#[serde(alias = "creator")]
pub creator: String,
#[serde(rename = "numberOfForms")]
#[serde(alias = "@numberOfForms")]
#[serde(alias = "numberOfForms")]
pub number_of_forms: usize,
#[serde(alias = "form")]
pub forms: Option<Vec<Form>>,
}
#[cfg(not(feature = "python"))]
impl User {
pub fn from_attributes(attrs: HashMap<String, String>) -> Result<Self, crate::errors::Error> {
let unique_id = attrs.get("uniqueId").cloned().ok_or_else(|| {
crate::errors::Error::ParsingError(quick_xml::de::DeError::Custom(
"Missing uniqueId".to_string(),
))
})?;
let last_language = attrs.get("lastLanguage").filter(|s| !s.is_empty()).cloned();
let creator = attrs.get("creator").cloned().ok_or_else(|| {
crate::errors::Error::ParsingError(quick_xml::de::DeError::Custom(
"Missing creator".to_string(),
))
})?;
let number_of_forms = attrs
.get("numberOfForms")
.and_then(|s| s.parse().ok())
.unwrap_or(0);
Ok(User {
unique_id,
last_language,
creator,
number_of_forms,
forms: None,
})
}
pub fn set_forms(&mut self, forms: Vec<Form>) {
self.forms = if forms.is_empty() { None } else { Some(forms) };
}
}
#[cfg(feature = "python")]
#[derive(Clone, Debug, Deserialize, Serialize, PartialEq)]
#[serde(rename_all = "camelCase")]
#[pyclass(get_all, skip_from_py_object)]
pub struct User {
#[serde(rename = "uniqueId")]
#[serde(alias = "@uniqueId")]
#[serde(alias = "uniqueId")]
pub unique_id: String,
#[serde(rename = "lastLanguage")]
#[serde(alias = "@lastLanguage")]
#[serde(alias = "lastLanguage")]
#[serde(
default = "default_string_none",
deserialize_with = "deserialize_empty_string_as_none"
)]
pub last_language: Option<String>,
#[serde(rename = "creator")]
#[serde(alias = "@creator")]
#[serde(alias = "creator")]
pub creator: String,
#[serde(rename = "numberOfForms")]
#[serde(alias = "@numberOfForms")]
#[serde(alias = "numberOfForms")]
pub number_of_forms: usize,
#[serde(alias = "form")]
pub forms: Option<Vec<Form>>,
}
#[cfg(feature = "python")]
impl User {
pub fn from_attributes(attrs: HashMap<String, String>) -> Result<Self, crate::errors::Error> {
let unique_id = attrs.get("uniqueId").cloned().ok_or_else(|| {
crate::errors::Error::ParsingError(quick_xml::de::DeError::Custom(
"Missing uniqueId".to_string(),
))
})?;
let last_language = attrs.get("lastLanguage").filter(|s| !s.is_empty()).cloned();
let creator = attrs.get("creator").cloned().ok_or_else(|| {
crate::errors::Error::ParsingError(quick_xml::de::DeError::Custom(
"Missing creator".to_string(),
))
})?;
let number_of_forms = attrs
.get("numberOfForms")
.and_then(|s| s.parse().ok())
.unwrap_or(0);
Ok(User {
unique_id,
last_language,
creator,
number_of_forms,
forms: None,
})
}
pub fn set_forms(&mut self, forms: Vec<Form>) {
self.forms = if forms.is_empty() { None } else { Some(forms) };
}
}
#[cfg(feature = "python")]
#[pymethods]
impl User {
#[getter]
fn unique_id(&self) -> PyResult<String> {
Ok(self.unique_id.clone())
}
#[getter]
fn last_language(&self) -> PyResult<Option<String>> {
Ok(self.last_language.clone())
}
#[getter]
fn creator(&self) -> PyResult<String> {
Ok(self.creator.clone())
}
#[getter]
fn forms(&self) -> PyResult<Option<Vec<Form>>> {
Ok(self.forms.clone())
}
pub fn to_dict<'py>(&self, py: Python<'py>) -> PyResult<Bound<'py, PyDict>> {
let dict = PyDict::new(py);
dict.set_item("unique_id", &self.unique_id)?;
dict.set_item("last_language", &self.last_language)?;
dict.set_item("creator", &self.creator)?;
dict.set_item("number_of_forms", self.number_of_forms)?;
let mut form_dicts = Vec::new();
if let Some(forms) = &self.forms {
for form in forms {
let form_dict = form.to_dict(py)?;
form_dicts.push(form_dict);
}
dict.set_item("forms", form_dicts)?;
} else {
dict.set_item("forms", py.None())?;
}
Ok(dict)
}
}
#[cfg(not(feature = "python"))]
#[derive(Clone, Debug, Deserialize, Serialize, PartialEq)]
#[serde(rename_all = "camelCase")]
pub struct UserNative {
#[serde(alias = "user")]
pub users: Vec<User>,
}
#[cfg(not(feature = "python"))]
impl UserNative {
pub fn to_json(&self) -> serde_json::Result<String> {
let json = serde_json::to_string(&self)?;
Ok(json)
}
}
#[cfg(feature = "python")]
#[derive(Clone, Debug, Deserialize, Serialize, PartialEq)]
#[serde(rename_all = "camelCase")]
#[pyclass(get_all, skip_from_py_object)]
pub struct UserNative {
#[serde(alias = "user")]
pub users: Vec<User>,
}
#[cfg(feature = "python")]
#[pymethods]
impl UserNative {
#[getter]
fn users(&self) -> PyResult<Vec<User>> {
Ok(self.users.clone())
}
fn to_dict<'py>(&self, py: Python<'py>) -> PyResult<Bound<'py, PyDict>> {
let dict = PyDict::new(py);
let mut user_dicts = Vec::new();
for user in &self.users {
let user_dict = user.to_dict(py)?;
user_dicts.push(user_dict);
}
dict.set_item("users", user_dicts)?;
Ok(dict)
}
fn to_json(&self) -> PyResult<String> {
serde_json::to_string(&self)
.map_err(|_| PyErr::new::<PyValueError, _>("Error converting to JSON"))
}
}
#[cfg(test)]
mod tests {
use super::*;
use insta::assert_yaml_snapshot;
#[test]
fn deserialize_user_native_json() {
let json_str = r#"{
"users": [
{
"uniqueId": "1691421275437",
"lastLanguage": null,
"creator": "Paul Sanders(1681162687395)",
"numberOfForms": 1,
"forms": [
{
"name": "form.name.demographics",
"lastModified": "2023-08-07T15:15:41Z",
"whoLastModifiedName": "Paul Sanders",
"whoLastModifiedRole": "Project Manager",
"whenCreated": 1691421341578,
"hasErrors": false,
"hasWarnings": false,
"locked": false,
"user": null,
"dateTimeChanged": null,
"formTitle": "User Demographics",
"formIndex": 1,
"formGroup": null,
"formState": "In-Work",
"states": [
{
"value": "form.state.in.work",
"signer": "Paul Sanders - Project Manager",
"signerUniqueId": "1681162687395",
"dateSigned": "2023-08-07T15:15:41Z"
}
],
"categories": [
{
"name": "demographics",
"categoryType": "normal",
"highestIndex": 0,
"fields": [
{
"name": "address",
"fieldType": "text",
"dataType": "string",
"errorCode": "undefined",
"whenCreated": "2024-01-12T20:14:09Z",
"keepHistory": true,
"entries": null
},
{
"name": "email",
"fieldType": "text",
"dataType": "string",
"errorCode": "undefined",
"whenCreated": "2023-08-07T15:15:41Z",
"keepHistory": true,
"entries": [
{
"entryId": "1",
"value": {
"by": "Paul Sanders",
"byUniqueId": "1681162687395",
"role": "Project Manager",
"when": "2023-08-07T15:15:41Z",
"value": "jazz@artemis.com"
},
"reason": null
}
]
}
]
},
{
"name": "Administrative",
"categoryType": "normal",
"highestIndex": 0,
"fields": [
{
"name": "study_assignment",
"fieldType": "text",
"dataType": null,
"errorCode": "undefined",
"whenCreated": "2023-08-07T15:15:41Z",
"keepHistory": true,
"entries": [
{
"entryId": "1",
"value": {
"by": "set from calculation",
"byUniqueId": null,
"role": "System",
"when": "2023-08-07T15:15:41Z",
"value": "On 07-Aug-2023 10:15 -0500, Paul Sanders assigned user from another study"
},
"reason": {
"by": "set from calculation",
"byUniqueId": null,
"role": "System",
"when": "2023-08-07T15:15:41Z",
"value": "calculated value"
}
}
]
}
]
}
]
}
]
}
]
}
"#;
let result: UserNative = serde_json::from_str(json_str).unwrap();
assert_yaml_snapshot!(result);
}
}