2052480191

Build # 2052480191

Build Type

github

Committed by GitHub

Commit Message

<a href="https://github.com/tremor-rs/tremor-runtime/commit/<a class=hub.com/tremor-rs/tremor-runtime/commit/<a class="double-link" href="https://git"><a class=hub.com/tremor-rs/tremor-runtime/commit/<a class="double-link" href="https://git"><a class=hub.com/tremor-rs/tremor-runtime/commit/2030b8e29c88cdcc2c52faa9e6a0be5e69bc1c3c">2030b8e29<a href="https://github.com/tremor-rs/tremor-runtime/commit/2030b8e29c88cdcc2c52faa9e6a0be5e69bc1c3c">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/tremor-rs/tremor-runtime/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/tremor-rs/tremor-runtime/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/tremor-rs/tremor-runtime/commit/2030b8e29c88cdcc2c52faa9e6a0be5e69bc1c3c&quot;&gt;2030b8e29&lt;/a&gt;&lt;a href=&quot;https://github.com/tremor-rs/tremor-runtime/commit/2030b8e29c88cdcc2c52faa9e6a0be5e69bc1c3c&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/tremor-rs/tremor-runtime/commit/2030b8e29c88cdcc2c52faa9e6a0be5e&lt;/a&gt;69bc1c3c&quot;>&quot;&gt;Merge &lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/tremor-rs/tremor-runtime/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/tremor-rs/tremor-runtime/commit/<a class="double-link" href="https://github.com/tremor-rs/tremor-runtime/commit/1955e5211dd37901c64deea913b85ddf963d6d1f">1955e5211</a><a href="https://github.com/tremor-rs/tremor-runtime/commit/2030b8e29c88cdcc2c52faa9e6a0be5e69bc1c3c">&amp;quot;&amp;gt;1955e5211&amp;lt;/a&amp;gt;&amp;quot;&amp;gt;1955e5211&amp;lt;/a&amp;gt;&amp;lt;a href=&amp;quot;https://github.com/tremor-rs/tremor-runtime/commit/2030b8e29c88cdcc2c52faa9e6a0be5e69bc1&lt;/a&gt;c3c&quot;&gt; into &lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/tremor-rs/tremor-runtime/commit/<a class="double-link" href="https://github.com/tremor-rs/tremor-runtime/commit/85f4dfb1e">85f4dfb1e">85f4dfb1e</a>

Pull Request Pull Request #1077: Connectors Implementation

Run Details

13266 of 13266 new or added lines in 167 files covered. (100.0%)

23673 of 28749 relevant lines covered (82.34%)

4.15 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

45.45

/src/connectors/impls/http/utils.rs

// Copyright 2022, The Tremor Team
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

use http_types::Method;
use serde::de::Visitor;
use serde::{Deserialize, Deserializer};
use std::fmt;
use std::str::FromStr;

// We use surf for http clients
pub use surf::{
    Request as SurfRequest, RequestBuilder as SurfRequestBuilder, Response as SurfResponse,
};

// We use tide for http servers
pub use tide::{Request as TideRequest, Response as TideResponse, Result as TideResult};

struct MethodStrVisitor;

impl<'de> Visitor<'de> for MethodStrVisitor {
    type Value = SerdeMethod;
    fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
        formatter.write_str("an HTTP method string.")
    }

    fn visit_str<E>(self, v: &str) -> core::result::Result<Self::Value, E>
    where
        E: serde::de::Error,
    {
        Method::from_str(v)
            .map(SerdeMethod)
            .map_err(|e| serde::de::Error::custom(e.to_string()))
    }
}

#[derive(Debug, Clone, Copy, Eq, PartialEq, Hash)]
pub struct SerdeMethod(pub(crate) Method);

impl<'de> Deserialize<'de> for SerdeMethod {
    fn deserialize<D>(deserializer: D) -> core::result::Result<Self, D::Error>
    where
        D: Deserializer<'de>,
    {
        deserializer.deserialize_str(MethodStrVisitor)
    }
}

#[cfg(test)]
mod test {
    use super::*;
    use crate::connectors::prelude::ConfigImpl;
    use crate::errors::Result;
    use tremor_value::literal;

    #[test]
    fn deserialize_method() -> Result<()> {
        let v = literal!({
          "url": "http://localhost:8080/",
          "method": "PATCH"
        });
        let config = super::super::meta::Config::new(&v)?;
        assert_eq!(Method::Patch, Method::from_str(&config.method)?);
        Ok(())
    }
}

1	// Copyright 2022, The Tremor Team
2	//
3	// Licensed under the Apache License, Version 2.0 (the "License");
4	// you may not use this file except in compliance with the License.
5	// You may obtain a copy of the License at
6	//
7	// http://www.apache.org/licenses/LICENSE-2.0
8	//
9	// Unless required by applicable law or agreed to in writing, software
10	// distributed under the License is distributed on an "AS IS" BASIS,
11	// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12	// See the License for the specific language governing permissions and
13	// limitations under the License.
14
15	use http_types::Method;
16	use serde::de::Visitor;
17	use serde::{Deserialize, Deserializer};
18	use std::fmt;
19	use std::str::FromStr;
20
21	// We use surf for http clients
22	pub use surf::{
23	Request as SurfRequest, RequestBuilder as SurfRequestBuilder, Response as SurfResponse,
24	};
25
26	// We use tide for http servers
27	pub use tide::{Request as TideRequest, Response as TideResponse, Result as TideResult};
28
29	struct MethodStrVisitor;
30
31	impl<'de> Visitor<'de> for MethodStrVisitor {
32	type Value = SerdeMethod;
33	fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {	×
34	formatter.write_str("an HTTP method string.")	×
35	}
36
37	fn visit_str<E>(self, v: &str) -> core::result::Result<Self::Value, E>
38	where
39	E: serde::de::Error,
40	{
41	Method::from_str(v)	×
42	.map(SerdeMethod)	×
43	.map_err(\|e\| serde::de::Error::custom(e.to_string()))	×
44	}
45	}
46
47	#[derive(Debug, Clone, Copy, Eq, PartialEq, Hash)]
48	pub struct SerdeMethod(pub(crate) Method);
49
50	impl<'de> Deserialize<'de> for SerdeMethod {
51	fn deserialize<D>(deserializer: D) -> core::result::Result<Self, D::Error>
52	where
53	D: Deserializer<'de>,
54	{
55	deserializer.deserialize_str(MethodStrVisitor)	×
56	}
57	}
58
59	#[cfg(test)]
60	mod test {
61	use super::*;
62	use crate::connectors::prelude::ConfigImpl;
63	use crate::errors::Result;
64	use tremor_value::literal;
65
66	#[test]
67	fn deserialize_method() -> Result<()> {	3✔
68	let v = literal!({	1✔
69	"url": "http://localhost:8080/",
70	"method": "PATCH"
71	});
72	let config = super::super::meta::Config::new(&v)?;	2✔
73	assert_eq!(Method::Patch, Method::from_str(&config.method)?);	4✔
74	Ok(())	1✔
75	}
76	}

tremor-rs / tremor-runtime / 2052480191

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous