Merge pull request #1 from axelfaure/rabbitmq

Add rabbitmq generate credentials request

Author: tricquebourg-netwo

src/api.rs

@@ -6,6 +6,7 @@ pub mod identity;
 pub mod kv1;
 pub mod kv2;
 pub mod pki;
+pub mod rabbitmq;
 pub mod ssh;
 pub mod sys;
 pub mod token;

src/api/database/requests.rs

@@ -242,7 +242,7 @@ pub struct DeleteRoleRequest {
 /// * Path: {self.mount}/creds/{self.name}
 /// * Method: GET
 /// * Response: [GenerateCredentialsResponse]
-/// * Reference: <https://developer.hashicorp.com/vault/api-docs/secret/databases#read-role>
+/// * Reference: <https://developer.hashicorp.com/vault/api-docs/secret/database#generate-credentials>
 #[derive(Builder, Debug, Default, Endpoint)]
 #[endpoint(
     path = "{self.mount}/creds/{self.name}",

src/api/database/responses.rs

@@ -53,14 +53,14 @@ pub struct GenerateCredentialsResponseData {
 /// [GetSecretRequest][crate::api::database::requests::GenerateCredentialsRequest]
 #[derive(Deserialize, Debug, Serialize)]
 pub struct GenerateCredentialsResponse {
-  pub data: GenerateCredentialsResponseData,
+    pub data: GenerateCredentialsResponseData,
 
-  /// Auth is always null, official doc does not document this field
-  pub auth: Option<String>,
-  pub lease_duration: i32,
-  pub lease_id: String,
-  pub renewable: bool,
-  pub request_id: String,
+    /// Auth is always null, official doc does not document this field
+    pub auth: Option<String>,
+    pub lease_duration: i32,
+    pub lease_id: String,
+    pub renewable: bool,
+    pub request_id: String,
 }
 
 /// Response from executing

src/api/rabbitmq.rs

@@ -0,0 +1,2 @@
+pub mod requests;
+pub mod responses;

src/api/rabbitmq/requests.rs

@@ -0,0 +1,25 @@
+use super::responses::GenerateCredentialsResponse;
+use rustify_derive::Endpoint;
+use std::fmt::Debug;
+
+/// ## Generate Credentials
+/// This endpoint generates a new set of dynamic credentials based on the named
+/// role.
+///
+/// * Path: {self.mount}/creds/{self.name}
+/// * Method: GET
+/// * Response: [GenerateCredentialsResponse]
+/// * Reference: <https://developer.hashicorp.com/vault/api-docs/secret/rabbitmq#generate-credentials>
+#[derive(Builder, Debug, Default, Endpoint)]
+#[endpoint(
+    path = "{self.mount}/creds/{self.name}",
+    response = "GenerateCredentialsResponse",
+    builder = "true"
+)]
+#[builder(setter(into, strip_option), default)]
+pub struct GenerateCredentialsRequest {
+    #[endpoint(skip)]
+    pub mount: String,
+    #[endpoint(skip)]
+    pub name: String,
+}

src/api/rabbitmq/responses.rs

@@ -0,0 +1,21 @@
+use serde::{Deserialize, Serialize};
+/// Response from executing
+#[derive(Deserialize, Debug, Serialize)]
+pub struct GenerateCredentialsResponseData {
+    pub username: String,
+    pub password: String,
+}
+
+/// Response from executing
+/// [GetSecretRequest][crate::api::rabbitmq::requests::GenerateCredentialsRequest]
+#[derive(Deserialize, Debug, Serialize)]
+pub struct GenerateCredentialsResponse {
+    pub data: GenerateCredentialsResponseData,
+
+    /// Auth is always null, official doc does not document this field
+    pub auth: Option<String>,
+    pub lease_duration: i32,
+    pub lease_id: String,
+    pub renewable: bool,
+    pub request_id: String,
+}

src/api/sys/requests.rs

@@ -463,5 +463,5 @@ pub struct RandomRequest {
 #[builder(setter(into, strip_option), default)]
 pub struct RenewLeaseRequest {
     pub lease_id: String,
-    pub increment: Option<String>
+    pub increment: Option<String>,
 }

src/api/sys/responses.rs

@@ -173,7 +173,6 @@ pub struct RandomResponse {
     pub random_bytes: String,
 }
 
-
 /// Response from executing
 /// [RenewLeaseRequest][crate::api::sys::requests::RenewLeaseRequest]
 #[derive(Deserialize, Debug, Serialize)]

src/lib.rs

@@ -267,6 +267,7 @@ pub mod identity;
 pub mod kv1;
 pub mod kv2;
 pub mod pki;
+pub mod rabbitmq;
 pub mod ssh;
 pub mod sys;
 pub mod token;

src/rabbitmq.rs

@@ -0,0 +1,24 @@
+pub mod role {
+    use crate::api;
+    use crate::api::rabbitmq::{
+        requests::GenerateCredentialsRequest, responses::GenerateCredentialsResponse,
+    };
+    use crate::client::Client;
+    use crate::error::ClientError;
+
+    /// Generates credentials from a role
+    ///
+    /// See [GenerateCredentialsRequest]
+    pub async fn creds(
+        client: &impl Client,
+        mount: &str,
+        name: &str,
+    ) -> Result<GenerateCredentialsResponse, ClientError> {
+        let endpoint = GenerateCredentialsRequest::builder()
+            .mount(mount)
+            .name(name)
+            .build()
+            .unwrap();
+        api::exec_with_no_result(client, endpoint).await
+    }
+}