From 569271c2c5683880119a02a150a7afe1bf8d8d87 Mon Sep 17 00:00:00 2001
From: Alex Leong <alex@buoyant.io>
Date: Tue, 14 Jun 2022 14:24:55 -0700
Subject: [PATCH] Add HttpRoute round-trip test (#11)

Signed-off-by: Alex Leong <alex@buoyant.io>
---
 integration/tests/httproute.rs | 83 ++++++++++++++++++++++++++++++++++
 src/v1alpha2/httproute.rs      | 14 ++++--
 src/v1alpha2/shared.rs         |  8 +++-
 3 files changed, 101 insertions(+), 4 deletions(-)
 create mode 100644 integration/tests/httproute.rs

diff --git a/integration/tests/httproute.rs b/integration/tests/httproute.rs
new file mode 100644
index 0000000..9d0487e
--- /dev/null
+++ b/integration/tests/httproute.rs
@@ -0,0 +1,83 @@
+use k8s_gateway_api::v1alpha2::{
+    BackendRef, HttpBackendRef, HttpHeaderMatch, HttpRoute, HttpRouteMatch, HttpRouteRule,
+    HttpRouteSpec,
+};
+use kube::{api::PostParams, core::ObjectMeta};
+
+#[tokio::test(flavor = "current_thread")]
+async fn round_trip() {
+    tracing::trace!("Initializing client");
+    let client = kube::Client::try_default()
+        .await
+        .expect("failed to initialize k8s client");
+    let api = kube::Api::<HttpRoute>::default_namespaced(client);
+
+    let route = HttpRoute {
+        metadata: ObjectMeta {
+            name: Some("bar-route".to_string()),
+            namespace: None,
+            labels: Some([("gateway".to_string(), "external-https-prod".to_string())].into()),
+            ..Default::default()
+        },
+        spec: HttpRouteSpec {
+            hostnames: Some(vec!["bar.example.com".to_string()]),
+            rules: Some(vec![
+                HttpRouteRule {
+                    backend_refs: Some(vec![
+                        HttpBackendRef {
+                            backend_ref: Some(BackendRef {
+                                name: "bar-v1".to_string(),
+                                port: 8080,
+                                weight: Some(90),
+                            }),
+                            filters: None,
+                        },
+                        HttpBackendRef {
+                            backend_ref: Some(BackendRef {
+                                name: "bar-v2".to_string(),
+                                port: 8080,
+                                weight: Some(10),
+                            }),
+                            filters: None,
+                        },
+                    ]),
+                    filters: None,
+                    matches: None,
+                },
+                HttpRouteRule {
+                    matches: Some(vec![HttpRouteMatch {
+                        headers: Some(vec![HttpHeaderMatch::Exact {
+                            name: "env".to_string(),
+                            value: "canary".to_string(),
+                        }]),
+                        ..HttpRouteMatch::default()
+                    }]),
+                    backend_refs: Some(vec![HttpBackendRef {
+                        backend_ref: Some(BackendRef {
+                            name: "bar-v2".to_string(),
+                            port: 8080,
+                            weight: None,
+                        }),
+                        filters: None,
+                    }]),
+                    filters: None,
+                },
+            ]),
+            ..HttpRouteSpec::default()
+        },
+        status: None,
+    };
+    let post_params = PostParams {
+        field_manager: Some("gateway-api-test".to_string()),
+        ..Default::default()
+    };
+    api.create(&post_params, &route)
+        .await
+        .expect("failed to create resource");
+
+    api.get("bar-route").await.expect("failed to get resource");
+
+    api.delete("bar-route", &Default::default())
+        .await
+        .expect("failed to delete resource");
+}
diff --git a/src/v1alpha2/httproute.rs b/src/v1alpha2/httproute.rs
index ede14b6..4a526b4 100644
--- a/src/v1alpha2/httproute.rs
+++ b/src/v1alpha2/httproute.rs
@@ -5,7 +5,13 @@ use super::*;
 /// Filters can be used to specify additional processing steps. Backends specify
 /// where matching requests should be routed.
 #[derive(
-    Clone, Debug, kube::CustomResource, serde::Deserialize, serde::Serialize, schemars::JsonSchema,
+    Clone,
+    Debug,
+    Default,
+    kube::CustomResource,
+    serde::Deserialize,
+    serde::Serialize,
+    schemars::JsonSchema,
 )]
 #[kube(
     group = "gateway.networking.k8s.io",
@@ -119,7 +125,7 @@ pub struct HttpRouteRule {
     ///
     /// When no rules matching a request have been successfully attached to the
     /// parent a request is coming from, a HTTP 404 status code MUST be returned.
-    pub matches: Option<HttpRouteMatch>,
+    pub matches: Option<Vec<HttpRouteMatch>>,
 
     /// Filters define the filters that are applied to requests that match this
     /// rule.
@@ -185,7 +191,9 @@ pub struct HttpRouteRule {
 ///   - name: "version"
 ///     value "v1"
 /// ```
-#[derive(Clone, Debug, PartialEq, serde::Deserialize, serde::Serialize, schemars::JsonSchema)]
+#[derive(
+    Clone, Debug, Default, PartialEq, serde::Deserialize, serde::Serialize, schemars::JsonSchema,
+)]
 #[serde(rename_all = "camelCase")]
 pub struct HttpRouteMatch {
     /// Path specifies a HTTP request path matcher. If this field is not
diff --git a/src/v1alpha2/shared.rs b/src/v1alpha2/shared.rs
index 13a1c99..5495721 100644
--- a/src/v1alpha2/shared.rs
+++ b/src/v1alpha2/shared.rs
@@ -84,7 +84,9 @@ pub struct ParentReference {
 
 /// CommonRouteSpec defines the common attributes that all Routes MUST include
 /// within their spec.
-#[derive(Clone, Debug, PartialEq, serde::Deserialize, serde::Serialize, schemars::JsonSchema)]
+#[derive(
+    Clone, Debug, Default, PartialEq, serde::Deserialize, serde::Serialize, schemars::JsonSchema,
+)]
 #[serde(rename_all = "camelCase")]
 pub struct CommonRouteSpec {
     /// ParentRefs references the resources (usually Gateways) that a Route
@@ -134,6 +136,10 @@ pub struct BackendRef {
     ///
     /// Support for this field varies based on the context where used.
     pub weight: Option<u16>,
+
+    pub name: String,
+
+    pub port: PortNumber,
 }
 
 /// RouteConditionType is a type of condition for a route.