ZTerton/src/handlers/h_home.rs

use std::collections::{HashMap,BTreeMap};
use warp::{
  // http::{StatusCode},
  http::{method::Method, HeaderMap, HeaderValue},
  Reply, Rejection,
};
use reqenv::ReqEnv;
// use app_env::profile::Profile;
use app_auth::{UserCtx};

// use kloud::{
//   defs::{
// 		KloudQueryConfigFilters,
// 	},
// };
use clds::defs::{KloudCheckHome};
use clds::clouds::defs::{Cloud,SrvcsHostInfo,App,AppsrvcInfo,TskSrvc,TsksrvcInfo};
use crate::defs::{DataDBs}; // ,CollsData};
use clds::clouds::on_clouds::{get_cloud_check,get_apps_check};

pub async fn get_tsks_apps_check(reqenv: &ReqEnv, cld_indx: usize, _auth: UserCtx, role: &str) -> String {
	let result_apps = get_apps_check(&reqenv).await;
	// println!("Result apps: {}",&result_apps);
  let res_apps: Vec<KloudCheckHome> = serde_json::from_str(&result_apps).unwrap_or_else(|e| {
		println!("Error serde apps json: {}",e);
	 	Vec::new()
	});
	// let mut list_groups = String::from("");
  let mut grp_apps_hash: HashMap<String, BTreeMap<String,Vec<SrvcsHostInfo>>> = HashMap::new();
	if let Some(kld) = res_apps.get(cld_indx) {
		for grp in &kld.groups {
			// if !list_groups.is_empty() {
      //   list_groups.push(',');
      // }
      // list_groups.push_str(&grp.name);
			let mut m_items = BTreeMap::new();
      for itm in &grp.items {
				let liveness: Vec<SrvcsHostInfo>;
				if role.is_empty() {
					liveness = itm.liveness.to_owned().into_iter().map(|it| { 
					  SrvcsHostInfo {
							hostname: format!("{}",&it.hostname),
							tsksrvcs: it.tsksrvcs.to_owned(),
							appsrvcs: it.appsrvcs.into_iter().map(|ap| {
								AppsrvcInfo {
									name: ap.name.to_owned(),
									info: ap.info.to_owned(),
									srvc: App {
									  name: ap.srvc.name.to_owned(),
										path: String::from(""),
										req: String::from(""),
										target: ap.srvc.target.to_owned(),
										liveness: String::from(""),
										critical: ap.srvc.critical.to_owned(),
									}
								}
							}).collect()
						}
					}).collect();
				} else {
					liveness = itm.liveness.to_owned();
				}
        m_items.insert(format!("{}",&itm.name),liveness);
			}
      grp_apps_hash.insert(format!("{}",grp.name),m_items);
		}
  }
	let result_cloud = get_cloud_check(&reqenv).await;
	// println!("Result cloud: {}",&result_cloud);
  let res_cloud: Vec<KloudCheckHome> = serde_json::from_str(&result_cloud).unwrap_or_else(|e| {
		println!("Error serde apps json: {}",e);
	 	Vec::new()
	});
	let mut grp_cloud_hash: HashMap<String, BTreeMap<String,Vec<SrvcsHostInfo>>> = HashMap::new();
	if let Some(kld) = res_cloud.get(cld_indx) {
		for grp in &kld.groups {
			let mut m_items = BTreeMap::new();
      for itm in &grp.items {
				let liveness: Vec<SrvcsHostInfo>;
				if role.is_empty() {
					liveness = itm.liveness.to_owned().into_iter().map(|it| { 
					  SrvcsHostInfo {
							hostname: format!("{}",&it.hostname),
							appsrvcs: it.appsrvcs.to_owned(),
							tsksrvcs: it.tsksrvcs.into_iter().map(|tsk| {
								TsksrvcInfo {
									name: tsk.name.to_owned(),
									info: tsk.info.to_owned(),
									srvc: TskSrvc {
									  name: tsk.srvc.name.to_owned(),
										path: String::from(""),
										req: String::from(""),
										target: tsk.srvc.target.to_owned(),
										liveness: String::from(""),
										critical: tsk.srvc.critical.to_owned(),
									}
								}
							}).collect()
						}
					}).collect();
				} else {
					liveness = itm.liveness.to_owned();
				}
        m_items.insert(format!("{}",&itm.name),liveness.to_owned());
			}
      grp_cloud_hash.insert(format!("{}",grp.name),m_items);
		}
  }
 	// ctx.insert("groups_cloud".to_string(),&grp_cloud_hash);
	let res_apps_json=serde_json::to_string(&grp_apps_hash).unwrap_or_else(|e|{
		println!("Error serde from value: {}",e);
		String::from("")
	});
	let res_cloud_json=serde_json::to_string(&grp_cloud_hash).unwrap_or_else(|e|{
		println!("Error serde from value: {}",e);
		String::from("")
	});
	let result = format!("{}:{}{}:{}{}",r#"{"group_apps""#,&res_apps_json,r#","group_cloud""#,&res_cloud_json,r#"}"#);
  result.to_owned()
}
pub async fn home(
	header: HeaderMap<HeaderValue>,
	method: Method,
//  user: UserCtx, 
	db: DataDBs, 
	_cloud: Cloud,
	prfx: String,
// headers: warp::http::HeaderMap
//  path: warp::path::FullPath, headers: warp::http::HeaderMap
) -> Result<impl Reply, Rejection> {
	let reqenv = ReqEnv::new(db.app, db.auth, header, method, "/home", "home", &prfx);
	// let allow_origin = reqenv.websrvr().allow_origin;
	// let opts = KloudQueryConfigFilters::default();
	// let source = format!("{}/{}","ma","");
	match reqenv.user_authentication().await {
		Ok(auth) => {
			// dbg!("auth: {}",&auth); 
			// println!("User: {} | {}",&user.user_id,&user.token);
			// if let Some(lang) = reqtasks.params().get("lang") {
			//   res.render_json_text(&get_lang_items_str("langs",req_lang,"yaml"))
			// } else {
			//   res.render_json_text(&get_lang_items_str("langs",&reqtasks.lang(),"yaml"))
			// }
			// log::debug!("LANG: {} - {}",language, lang);
			//  dbg!("LANG: {} - {}",language, lang);
      let role = reqenv.req.user_role().await;
			// reqenv.is_admin()
			let result = get_tsks_apps_check(&reqenv,1,auth,&role).await;
			// let mut path = format!("{}/profiles/{}/{}/defs.yaml",reqenv.websrvr().resources_path,&prfx,&auth.user_id);
			// if ! std::path::Path::new(&path).exists() {
			// 	path = format!("{}/profiles/{}/defs.yaml",reqenv.websrvr().resources_path,&prfx);
			// }
			// let content = Profile::load_fs_content(path.into());

			// let lang = opts.lang.unwrap_or_else(|| String::from("es"));
			// let section = opts.section.unwrap_or_else(|| String::from(""));
			// let lang_items = LangItems::new("langs/ta",&lang,"yaml");
			// let result = lang_items.get_items_str(&section);

			// let res = Profile::to_yaml(content); // String::from("");
			// let result = serde_json::to_string(&res).unwrap_or_else(|_| String::from(""));


			Ok(warp::http::Response::builder()
			.body(result.to_string())
			.into_response())
			/*
			Ok(warp::reply::with_header(
					warp::http::Response::new(result),
						"Access-Control-Allow-Origin",
						&allow_origin))
			*/
			//  warp::reply::json(&res),
			// Ok(warp::reply::with_header(
			//  warp::http::Response::new(result),
			//    "Access-Control-Allow-Origin",
			//    &allow_origin))
			// Ok(warp::reply::json(&result))
		},
		Err(_e) => {
			// let result = format!("Error: no credentials found");
			// println!("{}",e);
			let result = get_tsks_apps_check(&reqenv,1,UserCtx::default(),"").await;
			Ok(warp::http::Response::builder()
			.body(result.to_string())
			.into_response())
			/*
			Ok(warp::reply::with_header(
			warp::http::Response::new(result),
			"Access-Control-Allow-Origin",
			&allow_origin))
			*/
		}
	}
}