Merge branch 'main' of github.com:demeter-run/ext-cardano-ogmios

Author: paulobressan

operator/yaml/crd.yaml

@@ -5,10 +5,12 @@ metadata:
 spec:
   group: demeter.run
   names:
-    categories: []
+    categories:
+    - demeter-port
     kind: OgmiosPort
     plural: ogmiosports
-    shortNames: []
+    shortNames:
+    - opt
     singular: ogmiosport
   scope: Namespaced
   versions:
@@ -28,6 +30,9 @@ spec:
     - jsonPath: .status.authToken
       name: Auth Token
       type: string
+    - jsonPath: .spec.throughputTier
+      name: Throughput Tier
+      type: string
     name: v1alpha1
     schema:
       openAPIV3Schema:
@@ -36,18 +41,16 @@ spec:
           spec:
             properties:
               network:
-                enum:
-                - mainnet
-                - preprod
-                - preview
-                - sanchonet
+                type: string
+              throughputTier:
                 type: string
               version:
                 format: uint8
                 minimum: 0.0
                 type: integer
             required:
             - network
+            - throughputTier
             - version
             type: object
           status:

operator/yaml/port.yaml

@@ -11,4 +11,4 @@ metadata:
 spec:
   network: "mainnet"
   version: 1
-
+  throughputTier: "0"

proxy/src/config.rs

@@ -8,6 +8,7 @@ pub struct Config {
     pub proxy_tiers_poll_interval: Duration,
     pub prometheus_addr: String,
     pub ogmios_port: u16,
+    pub ogmios_dns: String,
     pub ssl_crt_path: PathBuf,
     pub ssl_key_path: PathBuf,
 }
@@ -39,6 +40,7 @@ impl Config {
                 .expect("OGMIOS_PORT must be set")
                 .parse()
                 .expect("OGMIOS_PORT must a number"),
+            ogmios_dns: env::var("OGMIOS_DNS").expect("OGMIOS_DNS must be set"),
         }
     }
 }

proxy/src/proxy.rs

@@ -281,7 +281,11 @@ impl ProxyRequest {
         let network = captures.get(2)?.as_str().to_string();
         let version = captures.get(3)?.as_str().to_string();
 
-        let instance = format!("ogmios-{network}-{version}:{}", state.config.ogmios_port);
+        let instance = format!(
+            "ogmios-{network}-{version}.{}:{}",
+            state.config.ogmios_dns, state.config.ogmios_port
+        );
+
         let namespace = state.config.proxy_namespace.clone();
 
         let protocol = get_header(hyper_req, UPGRADE.as_str())