1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90

//  BACKEND.rs
//    by Lut99
// 
//  Created:
//    18 Oct 2022, 13:50:11
//  Last edited:
//    10 Mar 2023, 15:52:47
//  Auto updated?
//    Yes
// 
//  Description:
//!   Defines the credentials and a file that describes them for the job
//!   service to connect with its backend.
// 

use std::collections::HashSet;
use std::path::PathBuf;

use serde::{Deserialize, Serialize};

use specifications::package::Capability;

pub use crate::spec::YamlError as Error;
use crate::spec::YamlConfig;


/***** AUXILLARY *****/
/// Defines the possible credentials we may encounter.
#[derive(Clone, Debug, Deserialize, Serialize)]
#[serde(rename_all = "snake_case", tag = "kind")]
pub enum Credentials {
    // Job node acting as a node
    /// Defines that this job node connects to the "backend" by simply spinning up the local Docker daemon.
    Local {
        /// If given, uses a non-default path to connect to the Docker daemon.
        path    : Option<PathBuf>,
        /// If given, uses a non-default client version to connect with the Docker daemon.
        version : Option<(usize, usize)>,
    },

    // Job node acting as a scheduler
    /// Defines that this job node connects to one node by use of SSH. This effectively allows the centralized Brane manager to orchestrate over nodes instead of clusters.
    Ssh {
        /// The address of the machine to connect to. Should include any ports if needed.
        address : String,
        /// The path to the key file to connect with.
        key     : PathBuf,
    },

    // Job node acting as a cluster connector
    /// Defines that this job node connects to a backend Slurm cluster.
    Slurm {
        /* TBD */
    },
    /// Defines that this job node connects to a backend Kubernetes cluster.
    Kubernetes {
        /// The address or URL of the machine to connect to. Should include the port if so.
        address : String,
        /// The path to the Kubernetes config file to connect with.
        config  : PathBuf,
    },
}





/***** LIBRARY *****/
/// Defines a file that describes how a job service may connect to its backend.
/// 
/// Note that this struct is designed to act as a "handle"; i.e., keep it only around when using it but otherwise refer to it only by path.
#[derive(Clone, Debug, Deserialize, Serialize)]
pub struct BackendFile {
    /// The capabilities advertised by this domain.
    pub capabilities    : Option<HashSet<Capability>>,
    /// Can be specified to disable container hash checking.
    pub hash_containers : Option<bool>,
    /// The method of connecting
    pub method          : Credentials,
}

impl BackendFile {
    /// Returns whether the user wants hash containers to be hashed, generating a default value if they didn't specify it.
    /// 
    /// # Returns
    /// Whether container hash security should be enabled (true) or not (false).
    #[inline]
    pub fn hash_containers(&self) -> bool { self.hash_containers.unwrap_or(true) }
}
impl<'de> YamlConfig<'de> for BackendFile {}