libstratis 2.4.2

// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at http://mozilla.org/MPL/2.0/.

use crate::{
    engine::{Engine, Pool, PoolUuid},
    jsonrpc::consts::{OP_ERR, OP_OK, OP_OK_STR},
    stratis::StratisResult,
};

macro_rules! expects_fd {
    ($fd_opt:expr, $ret:ident, $default:expr, true) => {
        match $fd_opt {
            Some(fd) => fd,
            None => {
                let res = Err($crate::stratis::StratisError::Error(
                    "Method expected a file descriptor and did not receive one".to_string(),
                ));
                return $crate::jsonrpc::interface::StratisRet::$ret(
                    $crate::jsonrpc::server::utils::stratis_result_to_return(res, $default),
                );
            }
        }
    };
    ($fd_opt:expr, $ret:ident, $default:expr, false) => {
        match $fd_opt {
            Some(fd) => {
                if let Err(e) = nix::unistd::close(fd) {
                    warn!(
                        "Failed to close file descriptor {}: {}; a file descriptor \
                        may have been leaked",
                        fd, e,
                    );
                }
                let res = Err($crate::stratis::StratisError::Error(
                    "Method did not expect a file descriptor and received one \
                    anyway; file descriptor has been closed"
                        .to_string(),
                ));
                return $crate::jsonrpc::interface::StratisRet::$ret(
                    $crate::jsonrpc::server::utils::stratis_result_to_return(res, $default),
                );
            }
            None => (),
        }
    };
}

pub fn stratis_result_to_return<T>(result: StratisResult<T>, default_value: T) -> (T, u16, String) {
    match result {
        Ok(r) => (r, OP_OK, OP_OK_STR.to_string()),
        Err(e) => (default_value, OP_ERR, e.to_string()),
    }
}

/// Convert a string representing the name of a pool to the UUID and stratisd
/// data structure representing the pool state.
pub fn name_to_uuid_and_pool<'a>(
    engine: &'a mut dyn Engine,
    name: &str,
) -> Option<(PoolUuid, &'a mut dyn Pool)> {
    let mut uuids_pools_for_name = engine
        .pools_mut()
        .into_iter()
        .filter_map(|(n, u, p)| if &*n == name { Some((u, p)) } else { None })
        .collect::<Vec<_>>();
    assert!(uuids_pools_for_name.len() <= 1);
    uuids_pools_for_name.pop()
}