httpmock 0.8.3

HTTP mocking library for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106

use bytes::{BufMut, Bytes, BytesMut};
use std::{
    convert::{TryFrom, TryInto},
    fs::{read_dir, read_to_string},
    path::PathBuf,
    str::FromStr,
};

use serde::Deserialize;

use crate::common::data;
use serde_yaml::{Deserializer, Value as YamlValue};
use thiserror::Error;

use crate::{
    common::data::{MockDefinition, StaticMockDefinition},
    server::{
        persistence::Error::{DeserializationError, FileReadError},
        state,
        state::{Error::DataConversionError, StateManager},
    },
};

#[derive(Error, Debug)]
pub enum Error {
    #[error("cannot read from mock file: {0}")]
    FileReadError(String),
    #[error("cannot modify state: {0}")]
    StateError(#[from] state::Error),
    #[error("cannot deserialize YAML: {0}")]
    DeserializationError(String),
    #[error("cannot convert data structures: {0}")]
    DataConversionError(#[from] data::Error),
}

pub fn read_static_mock_definitions<S>(path_opt: PathBuf, state: &S) -> Result<(), Error>
where
    S: StateManager + Send + Sync + 'static,
{
    for def in read_static_mocks(path_opt)? {
        state.add_mock(def.try_into()?, true)?;
    }

    Ok(())
}

fn read_static_mocks(path: PathBuf) -> Result<Vec<StaticMockDefinition>, Error> {
    let mut definitions: Vec<StaticMockDefinition> = Vec::new();

    let paths = read_dir(path).expect("cannot list files in directory");
    for file_path in paths {
        let file_path = file_path.unwrap().path();
        if let Some(ext) = file_path.extension() {
            if !"yaml".eq(ext) && !"yml".eq(ext) {
                continue;
            }
        }

        tracing::info!(
            "Loading static mock file from '{}'",
            file_path.to_string_lossy()
        );

        let content = read_to_string(file_path).map_err(|err| FileReadError(err.to_string()))?;

        definitions.extend(deserialize_mock_defs_from_yaml(&content)?);
    }

    return Ok(definitions);
}

pub fn deserialize_mock_defs_from_yaml(
    yaml_content: &str,
) -> Result<Vec<StaticMockDefinition>, Error> {
    let mut definitions = Vec::new();

    for document in Deserializer::from_str(&yaml_content) {
        let value = YamlValue::deserialize(document)
            .map_err(|err| DeserializationError(err.to_string()))?;

        let definition: StaticMockDefinition =
            serde_yaml::from_value(value).map_err(|err| DeserializationError(err.to_string()))?;

        definitions.push(definition);
    }

    Ok(definitions)
}

pub fn serialize_mock_defs_to_yaml(mocks: &Vec<MockDefinition>) -> Result<Bytes, Error> {
    let mut buffer = BytesMut::new();

    for (idx, mock) in mocks.iter().enumerate() {
        if idx > 0 {
            buffer.put_slice(b"---\n");
        }

        let static_mock: StaticMockDefinition = StaticMockDefinition::try_from(mock)
            .map_err(|err| DataConversionError(err.to_string()))?;
        let yaml = serde_yaml::to_string(&static_mock)
            .map_err(|err| DataConversionError(err.to_string()))?;
        buffer.put_slice(yaml.as_bytes());
    }

    Ok(buffer.freeze())
}