Add failing IPC test

This commit adds a test for a failing IPC.

Signed-off-by: Ionut Mihalcea <[email protected]>

Author: ionut-arm

src/core/testing/core_tests.rs

@@ -1,8 +1,8 @@
 // Copyright 2020 Contributors to the Parsec project.
 // SPDX-License-Identifier: Apache-2.0
-use super::{TestCoreClient, DEFAULT_APP_NAME};
+use super::{FailingMockIpc, TestCoreClient, DEFAULT_APP_NAME};
 use crate::error::{ClientErrorKind, Error};
-use mockstream::MockStream;
+use mockstream::{FailingMockStream, MockStream};
 use parsec_interface::operations;
 use parsec_interface::operations::list_providers::ProviderInfo;
 use parsec_interface::operations::psa_algorithm::*;
@@ -15,6 +15,7 @@ use parsec_interface::requests::ResponseStatus;
 use parsec_interface::requests::{request::RequestHeader, Request};
 use parsec_interface::requests::{AuthType, BodyType, Opcode, ProviderID};
 use std::collections::HashSet;
+use std::io::ErrorKind;
 
 const PROTOBUF_CONVERTER: ProtobufConverter = ProtobufConverter {};
 const REQ_HEADER: RequestHeader = RequestHeader {
@@ -411,3 +412,19 @@ fn auth_value_test() {
         String::from(DEFAULT_APP_NAME)
     );
 }
+
+#[test]
+fn failing_ipc_test() {
+    let mut client: TestCoreClient = Default::default();
+    client.set_ipc_client(Box::from(FailingMockIpc(FailingMockStream::new(
+        ErrorKind::ConnectionRefused,
+        "connection was refused, so rude",
+        1,
+    ))));
+
+    let err = client.ping().expect_err("Expected to fail");
+    assert_eq!(
+        err,
+        Error::Client(ClientErrorKind::Interface(ResponseStatus::ConnectionError))
+    );
+}

src/core/testing/mod.rs

@@ -5,7 +5,7 @@ use super::ipc_client::{Connect, ReadWrite};
 use super::CoreClient;
 use crate::auth::AuthenticationData;
 use crate::error::Result;
-use mockstream::SyncMockStream;
+use mockstream::{FailingMockStream, SyncMockStream};
 use std::ops::{Deref, DerefMut};
 
 mod core_tests;
@@ -20,6 +20,14 @@ impl Connect for MockIpc {
     }
 }
 
+struct FailingMockIpc(FailingMockStream);
+
+impl Connect for FailingMockIpc {
+    fn connect(&self) -> Result<Box<dyn ReadWrite>> {
+        Ok(Box::from(self.0.clone()))
+    }
+}
+
 struct TestCoreClient {
     core_client: CoreClient,
     mock_stream: SyncMockStream,