libctf 0.3.1

SDK intended for use with CTF-rs, but is designed to be repurposed by others to easily extend functionality for other CTF related projects
Documentation 
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

use crate::spec::challenge::{Challenge, ChallengeSpec};
// use crate::spec::util::{ResourceRequestSpec, ResourceSpec};
use context::Context;
use hyper_util::rt::TokioExecutor;
use kube::Error;
use kube::api::{DeleteParams, GetParams, Patch, PatchParams, PostParams};
use kube::{Client, Config, client::ConfigExt};
use serde::Serialize;
use std::future::Future;
use tower::{BoxError, ServiceBuilder};
use tracing::{Level, span};

pub const MAX_RETRIES: u32 = 3;

/// Defines an interface for creating, reading, updating, and deleting (CRUD) resources.
pub trait Crud {
    // Challenge, Plugin, Flag, Verifier
    /// Expects same output as `kube::api::Request::create()`
    fn create(
        ctx: &Context,
        client: Client,
        pp: &PostParams,
        data: ChallengeSpec,
    ) -> impl Future<Output = Result<Challenge, Error>> + Send;
    /// Expects same output as `kube::api::Request::get()`
    fn read(
        ctx: &Context,
        client: Client,
        name: String,
        gp: &GetParams,
    ) -> impl Future<Output = Result<Challenge, Error>> + Send;
    /// Expects same output as `kube::api::Request::patch()`
    fn update<P: Serialize + std::fmt::Debug + Send + Sync + Clone + 'static>(
        ctx: &Context,
        client: Client,
        name: String,
        pp: &PatchParams,
        patch: &Patch<P>,
    ) -> impl Future<Output = Result<Challenge, Error>> + Send;
    /// Expects same output as `kube::api::Request::delete()`
    fn delete(
        ctx: &Context,
        client: Client,
        name: String,
        dp: &DeleteParams,
    ) -> impl Future<Output = Result<Challenge, Error>> + Send;
}

/// Wrapper around `kube::api::Request`, creates a 'client' for working on Kubernetes resources.
pub async fn client() -> Result<Client, BoxError> {
    let span = span!(Level::TRACE, "create_client");
    let _enter = span.enter();
    let config = Config::infer().await?;
    let service = ServiceBuilder::new()
        .layer(config.base_uri_layer())
        .option_layer(config.auth_layer()?)
        .map_err(BoxError::from)
        .service(hyper_util::client::legacy::Client::builder(TokioExecutor::new()).build_http());
    Ok(Client::new(service, config.default_namespace))
}