verification-client server implementation

Cargo.toml

@@ -2,6 +2,7 @@
 members = [
     "verification-server",
     "verification-common",
+    "verification-client",
     "verification-error",
     "verification-error-derive",
     "verification-http",

verification-client/Cargo.toml

@@ -0,0 +1,41 @@
+[package]
+name = "conjure-verification-client"
+version = "0.1.0"
+authors = ["Felipe Orozco <forozco@palantir.com>", "Dan Sanduleac <dsanduleac@palantir.com>"]
+license-file = "../LICENSE"
+
+[dependencies]
+conjure-verification-common = { path = "../verification-common" }
+conjure-verification-error = { path = "../verification-error" }
+conjure-verification-error-derive = { path = "../verification-error-derive" }
+conjure-verification-http-client = { path = "../verification-http-client" }
+conjure-verification-http = { path = "../verification-http" }
+conjure-verification-http-server = { path = "../verification-http-server" }
+serde-conjure = { path = "../serde-conjure" }
+serde-conjure-derive = { path = "../serde-conjure-derive" }
+
+bytes = "0.4"
+derive_more = "0.11"
+uuid = { version = "0.6", features = ["v4", "serde"] }
+either = "1.5"
+futures = "0.1.21"
+http = "0.1"
+hyper = "0.12"
+itertools = "0.7.4"
+lazy_static = "1.0"
+log = "0.4"
+mime = "0.3"
+pretty_env_logger = "0.2"
+serde = "1.0"
+serde-value = "0.5.2"
+serde_derive = "1.0"
+serde_json = "1.0"
+serde_yaml = "0.7"
+serde_plain = "0.3"
+typed-headers = "0.1"
+zipkin = "0.3"
+
+[dev-dependencies]
+tokio = "0.1"
+url = "1.0"
+pretty_assertions = "0.5.1"

verification-client/src/errors.rs

@@ -0,0 +1,101 @@
+// (c) Copyright 2018 Palantir Technologies Inc. All rights reserved.
+//
+// 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 conjure::value::ConjureValue;
+use hyper::StatusCode;
+use serde_json;
+use std::fmt::Display;
+use test_spec::EndpointName;
+
+#[derive(ErrorType)]
+#[error_type(namespace = "ConjureVerificationClient")]
+pub enum VerificationError {
+    #[error_type(code = "InvalidArgument")]
+    InvalidEndpointParameter {
+        #[error_type(safe)]
+        endpoint_name: EndpointName,
+    },
+    #[error_type(code = "FailedPrecondition")]
+    UnexpectedBody { body_size: usize },
+    #[error_type(code = "FailedPrecondition")]
+    UnexpectedContentType {
+        #[error_type(safe)]
+        content_type: String,
+    },
+    #[error_type(code = "FailedPrecondition")]
+    ConfirmationFailure {
+        #[error_type(safe)]
+        expected_body_raw: String,
+        #[error_type(safe)]
+        expected_body_conjure: String,
+        #[error_type(safe)]
+        response_body_raw: String,
+        #[error_type(safe)]
+        response_body_conjure: String,
+        #[error_type(safe)]
+        cause: String,
+    },
+    #[error_type(code = "FailedPrecondition")]
+    CouldNotParseServerResponse {
+        #[error_type(safe)]
+        response_body: String,
+        #[error_type(safe)]
+        cause: String,
+    },
+    #[error_type(code = "FailedPrecondition")]
+    ServerUnderTestConnectionError {
+        #[error_type(safe)]
+        cause: String,
+    },
+    #[error_type(code = "InvalidArgument")]
+    UnexpectedResponseCode {
+        #[error_type(safe)]
+        code: StatusCode,
+    },
+    #[error_type(code = "InvalidArgument")]
+    UrlParseFailure { url: String },
+    #[error_type(code = "InvalidArgument")]
+    IndexOutOfBounds {
+        #[error_type(safe)]
+        index: usize,
+        #[error_type(safe)]
+        max_index: usize,
+    },
+    #[error_type(code = "CustomClient")]
+    ClientIo,
+}
+
+impl VerificationError {
+    pub fn confirmation_failure<E>(
+        expected_body_str: &str,
+        expected_body: &ConjureValue,
+        response_body_str: &serde_json::Value,
+        // Option because it might be un-parseable as ConjureValue
+        response_body: Option<&ConjureValue>,
+        cause: E,
+    ) -> VerificationError
+    where
+        E: Display,
+    {
+        VerificationError::ConfirmationFailure {
+            expected_body_conjure: serde_json::ser::to_string(expected_body).unwrap(),
+            expected_body_raw: expected_body_str.to_string(),
+            response_body_conjure: response_body
+                .map(|rp| serde_json::ser::to_string(rp).unwrap())
+                .unwrap_or_else(|| "<undefined>".to_string()),
+            response_body_raw: response_body_str.to_string(),
+            cause: format!("{}", cause),
+        }
+    }
+}