Add ServiceControl V1 API

Signed-off-by: Igor Pashev <pashev.igor@gmail.com>

Author: ip1981

gcloud-protos-generator/openapi/google/servicecontrol-v1/openapi.yaml

@@ -425,11 +425,12 @@ maps-fleetengine-v1 = []
 
 # REST features
 google-rest-bigquery-v2 = ["rest"]
+google-rest-compute-v1 = ["rest"]
+google-rest-dns-v1 = ["rest"]
 google-rest-lustre-v1alpha = ["rest"]
-google-rest-storage-v1 = ["rest"]
 google-rest-sqladmin-v1 = ["rest"]
-google-rest-dns-v1 = ["rest"]
-google-rest-compute-v1 = ["rest"]
+google-rest-storage-v1 = ["rest"]
+google-rest-servicecontrol-v1 = ["rest"]
 
 [dependencies]
 tonic = { version = "0.12", features = ["tls"] }

gcloud-sdk/Cargo.toml

@@ -4,11 +4,14 @@ pub mod bigquery_v2;
 #[cfg(any(feature = "google-rest-compute-v1"))]
 pub mod compute_v1;
 
+#[cfg(any(feature = "google-rest-dns-v1"))]
+pub mod dns_v1;
+
 #[cfg(any(feature = "google-rest-lustre-v1alpha"))]
 pub mod lustre_v1alpha;
 
-#[cfg(any(feature = "google-rest-dns-v1"))]
-pub mod dns_v1;
+#[cfg(any(feature = "google-rest-servicecontrol-v1"))]
+pub mod servicecontrol_v1;
 
 #[cfg(any(feature = "google-rest-sqladmin-v1"))]
 pub mod sqladmin_v1;

gcloud-sdk/src/rest_apis/google_rest_apis/mod.rs

@@ -0,0 +1,49 @@
+use serde::{Deserialize, Serialize}; /*
+                                      * Service Control API
+                                      *
+                                      * Provides admission control and telemetry reporting for services integrated with Service Infrastructure.
+                                      *
+                                      * The version of the OpenAPI document: v1
+                                      *
+                                      * Generated by: https://openapi-generator.tech
+                                      */
+
+#[derive(Debug, Clone)]
+pub struct Configuration {
+    pub base_path: String,
+    pub user_agent: Option<String>,
+    pub client: reqwest::Client,
+    pub basic_auth: Option<BasicAuth>,
+    pub oauth_access_token: Option<String>,
+    pub bearer_access_token: Option<String>,
+    pub api_key: Option<ApiKey>,
+    // TODO: take an oauth2 token source, similar to the go one
+}
+
+pub type BasicAuth = (String, Option<String>);
+
+#[derive(Debug, Clone)]
+pub struct ApiKey {
+    pub prefix: Option<String>,
+    pub key: String,
+}
+
+impl Configuration {
+    pub fn new() -> Configuration {
+        Configuration::default()
+    }
+}
+
+impl Default for Configuration {
+    fn default() -> Self {
+        Configuration {
+            base_path: "https://servicecontrol.googleapis.com".to_owned(),
+            user_agent: Some("OpenAPI-Generator/v1/rust".to_owned()),
+            client: reqwest::Client::new(),
+            basic_auth: None,
+            oauth_access_token: None,
+            bearer_access_token: None,
+            api_key: None,
+        }
+    }
+}

gcloud-sdk/src/rest_apis/google_rest_apis/servicecontrol_v1/apis/configuration.rs

@@ -0,0 +1,98 @@
+use serde::{Deserialize, Serialize};
+use std::error;
+use std::fmt;
+
+#[derive(Debug, Clone)]
+pub struct ResponseContent<T> {
+    pub status: reqwest::StatusCode,
+    pub content: String,
+    pub entity: Option<T>,
+}
+
+#[derive(Debug)]
+pub enum Error<T> {
+    Reqwest(reqwest::Error),
+    Serde(serde_json::Error),
+    Io(std::io::Error),
+    ResponseError(ResponseContent<T>),
+}
+
+impl<T> fmt::Display for Error<T> {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        let (module, e) = match self {
+            Error::Reqwest(e) => ("reqwest", e.to_string()),
+            Error::Serde(e) => ("serde", e.to_string()),
+            Error::Io(e) => ("IO", e.to_string()),
+            Error::ResponseError(e) => ("response", format!("status code {}", e.status)),
+        };
+        write!(f, "error in {}: {}", module, e)
+    }
+}
+
+impl<T: fmt::Debug> error::Error for Error<T> {
+    fn source(&self) -> Option<&(dyn error::Error + 'static)> {
+        Some(match self {
+            Error::Reqwest(e) => e,
+            Error::Serde(e) => e,
+            Error::Io(e) => e,
+            Error::ResponseError(_) => return None,
+        })
+    }
+}
+
+impl<T> From<reqwest::Error> for Error<T> {
+    fn from(e: reqwest::Error) -> Self {
+        Error::Reqwest(e)
+    }
+}
+
+impl<T> From<serde_json::Error> for Error<T> {
+    fn from(e: serde_json::Error) -> Self {
+        Error::Serde(e)
+    }
+}
+
+impl<T> From<std::io::Error> for Error<T> {
+    fn from(e: std::io::Error) -> Self {
+        Error::Io(e)
+    }
+}
+
+pub fn urlencode<T: AsRef<str>>(s: T) -> String {
+    ::url::form_urlencoded::byte_serialize(s.as_ref().as_bytes()).collect()
+}
+
+pub fn parse_deep_object(prefix: &str, value: &serde_json::Value) -> Vec<(String, String)> {
+    if let serde_json::Value::Object(object) = value {
+        let mut params = vec![];
+
+        for (key, value) in object {
+            match value {
+                serde_json::Value::Object(_) => params.append(&mut parse_deep_object(
+                    &format!("{}[{}]", prefix, key),
+                    value,
+                )),
+                serde_json::Value::Array(array) => {
+                    for (i, value) in array.iter().enumerate() {
+                        params.append(&mut parse_deep_object(
+                            &format!("{}[{}][{}]", prefix, key, i),
+                            value,
+                        ));
+                    }
+                }
+                serde_json::Value::String(s) => {
+                    params.push((format!("{}[{}]", prefix, key), s.clone()))
+                }
+                _ => params.push((format!("{}[{}]", prefix, key), value.to_string())),
+            }
+        }
+
+        return params;
+    }
+
+    unimplemented!("Only objects are supported with style=deepObject")
+}
+
+pub mod services_api;
+
+pub mod configuration;