brokerapi 0.1.0

V2.16 Open Service Broker API-compliant brokers in Rust
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
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
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133

use actix_web::{web, HttpResponse, Responder};
use serde::{Deserialize, Serialize};
use serde_json::json;
use std::collections::HashMap;

use crate::catalog::MaintenanceInfo;

/// <https://github.com/openservicebrokerapi/servicebroker/blob/v2.16/spec.md#parameters-2>
#[derive(Deserialize, Debug)]
#[allow(unused)]
pub struct ProvisionParams {
    pub accepts_incomplete: Option<bool>,
}

/// <https://github.com/openservicebrokerapi/servicebroker/blob/v2.16/spec.md#body-3>
#[derive(Deserialize, Debug)]
#[allow(unused)]
pub struct ServiceInstanceRequestBody {
    pub service_id: String,
    pub plan_id: String,
    pub context: Option<HashMap<String, String>>,
    pub organization_guid: String,
    pub space_guid: String,
    pub parameters: Option<HashMap<String, String>>,
    pub maintenance_info: Option<MaintenanceInfo>,
}

/// <https://github.com/openservicebrokerapi/servicebroker/blob/v2.16/spec.md#body-4>
#[derive(Serialize, Default, Debug)]
#[allow(unused)]
pub struct CreatedServiceIstance {
    pub dashboard_url: Option<String>,
    pub operation: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub metadata: Option<ServiceInstanceMetadata>,
}

#[derive(Serialize, Default, Debug)]
#[allow(unused)]
pub struct ServiceInstanceMetadata {
    pub labels: HashMap<String, String>,
}

pub async fn put_service_instance(
    _instance_id: web::Path<String>,
    web::Query(params): web::Query<ProvisionParams>,
    web::Json(body): web::Json<ServiceInstanceRequestBody>,
) -> impl Responder {
    log::info!("params {:?}, body:\n{:#?}", params, body);

    HttpResponse::Created().json(CreatedServiceIstance::default())
}

/// <https://github.com/openservicebrokerapi/servicebroker/blob/v2.16/spec.md#parameters-3>
#[derive(Deserialize, Debug)]
#[allow(unused)]
pub struct ServiceFetchParams {
    pub service: Option<String>,
    pub plan_id: Option<String>,
}

/// <https://github.com/openservicebrokerapi/servicebroker/blob/v2.16/spec.md#body-5>
#[derive(Serialize, Default, Debug)]
#[allow(unused)]
pub struct ServiceIstance {
    #[serde(skip_serializing_if = "Option::is_none")]
    pub service_id: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub dashboard_url: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub operation: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub metadata: Option<ServiceInstanceMetadata>,
}

pub async fn get_service_instance(
    _instance_id: web::Path<String>,
    web::Query(params): web::Query<ServiceFetchParams>,
) -> impl Responder {
    log::info!("params {:?}", params);

    HttpResponse::Ok().json(ServiceIstance::default())
}

/// <https://github.com/openservicebrokerapi/servicebroker/blob/v2.16/spec.md#body-7>
#[derive(Deserialize, Debug)]
#[allow(unused)]
pub struct ServiceUpdateRequestBody {
    pub service_id: String,
    pub plan_id: Option<String>,
    pub context: Option<HashMap<String, String>>,
    pub parameters: Option<HashMap<String, String>>,
    pub previous_values: Option<PreviousValues>,
    pub maintenance_info: Option<MaintenanceInfo>,
}

#[derive(Deserialize, Debug)]
#[allow(unused)]
pub struct PreviousValues {
    pub service_id: Option<String>,
    pub plan_id: Option<String>,
    pub organization_id: Option<String>,
    pub space_id: Option<String>,
    pub maintenance_info: Option<MaintenanceInfo>,
}

pub async fn patch_service_instance(
    _instance_id: web::Path<String>,
    web::Query(params): web::Query<ProvisionParams>,
    web::Json(body): web::Json<ServiceUpdateRequestBody>,
) -> impl Responder {
    log::info!("params {:?}, body:\n{:#?}", params, body);

    HttpResponse::Ok().json(CreatedServiceIstance::default())
}

/// <https://github.com/openservicebrokerapi/servicebroker/blob/v2.16/spec.md#parameters-8>
#[derive(Deserialize, Debug)]
#[allow(unused)]
pub struct ServiceDeleteParams {
    pub service_id: String,
    pub plan_id: String,
    pub accepts_incomplete: Option<bool>,
}

pub async fn delete_service_instance(
    _instance_id: web::Path<String>,
    web::Query(params): web::Query<ServiceDeleteParams>,
) -> impl Responder {
    log::info!("params {:?}", params);

    HttpResponse::Ok().json(json!({}))
}