From 8fe302346aeee1cc2683b9a9e1b3cd7a6a3502bd Mon Sep 17 00:00:00 2001
From: Hartigan <hartigans@live.com>
Date: Fri, 5 Apr 2024 16:06:28 +0200
Subject: [PATCH] Pass origin to endpoint from service definition

---
 ginepro/src/service_probe.rs | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/ginepro/src/service_probe.rs b/ginepro/src/service_probe.rs
index 79efcbf..42ca2fd 100644
--- a/ginepro/src/service_probe.rs
+++ b/ginepro/src/service_probe.rs
@@ -217,6 +217,20 @@ impl<Lookup: LookupService> GrpcServiceProbe<Lookup> {
                 .ok()?;
         }
 
+        let origin_uri = format!(
+            "{}://{}:{}",
+            self.scheme,
+            self.service_definition.hostname(),
+            self.service_definition.port(),
+        );
+
+        endpoint = endpoint.origin(
+            origin_uri
+                .try_into()
+                .map_err(|err| tracing::warn!("origin uri creation error: {err:?}"))
+                .ok()?,
+        );
+
         if let Some(ref timeout) = self.endpoint_timeout {
             endpoint = endpoint.timeout(*timeout);
         }