// Copyright Rivtower Technologies LLC.
//
// 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 cita_cloud_proto::client::{InterceptedSvc, StorageClientTrait};
use cita_cloud_proto::retry::RetryClient;
use cita_cloud_proto::status_code::StatusCodeEnum;
use cita_cloud_proto::storage::storage_service_client::StorageServiceClient;
use cita_cloud_proto::storage::{Content, ExtKey};

pub async fn store_data(
    client: RetryClient<StorageServiceClient<InterceptedSvc>>,
    region: u32,
    key: Vec<u8>,
    value: Vec<u8>,
) -> StatusCodeEnum {
    let content = Content { region, key, value };
    match client.store(content.clone()).await {
        Ok(code) => StatusCodeEnum::from(code),
        Err(e) => {
            warn!("store_data({:?}) failed: {}", content, e.to_string());
            StatusCodeEnum::StorageServerNotReady
        }
    }
}

pub async fn load_data(
    client: RetryClient<StorageServiceClient<InterceptedSvc>>,
    region: u32,
    key: Vec<u8>,
) -> Result<Vec<u8>, StatusCodeEnum> {
    let ext_key = ExtKey { region, key };
    let value = client.load(ext_key.clone()).await.map_err(|e| {
        warn!("load_data({:?}) failed: {}", ext_key, e.to_string());
        StatusCodeEnum::StorageServerNotReady
    })?;

    StatusCodeEnum::from(value.status.ok_or(StatusCodeEnum::NoneStatusCode)?).is_success()?;
    Ok(value.value)
}