couchbase-core 1.0.1

/*
 *
 *  * Copyright (c) 2025 Couchbase, Inc.
 *  *
 *  * 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 crate::error;
use crate::error::Error;
use futures::TryStreamExt;
use serde::Deserialize;
use std::collections::HashMap;

#[derive(Debug, Clone, Deserialize)]
struct CfgErrMap {
    pub version: i64,
    pub revision: i64,
    pub errors: HashMap<String, CfgErrMapError>,
}

#[derive(Debug, Clone, Deserialize)]
struct CfgErrMapError {
    pub name: String,
    #[serde(rename = "desc")]
    pub description: String,
    #[serde(rename = "attrs")]
    pub attributes: Vec<String>,
}

#[derive(Debug, Clone)]
pub(crate) struct ErrMap {
    pub version: i64,
    pub revision: i64,
    pub errors: HashMap<u16, ErrMapError>,
}

#[derive(Debug, Clone)]
pub(crate) struct ErrMapError {
    pub name: String,
    pub description: String,
    pub attributes: Vec<String>,
}

pub(crate) fn parse_error_map(map_bytes: &[u8]) -> error::Result<ErrMap> {
    let cfg_err_map: CfgErrMap = serde_json::from_slice(map_bytes)
        .map_err(|e| Error::new_message_error(format!("failed to deserialize error map: {e}")))?;
    let mut errors = HashMap::new();

    for (code, err) in cfg_err_map.errors {
        let code: u16 = u16::from_str_radix(&code, 16)
            .map_err(|e| Error::new_message_error(format!("failed to parse error code: {e}")))?;
        errors.insert(
            code,
            ErrMapError {
                name: err.name,
                description: err.description,
                attributes: err.attributes,
            },
        );
    }

    Ok(ErrMap {
        version: cfg_err_map.version,
        revision: cfg_err_map.revision,
        errors,
    })
}