fix: Handle legacy networks without chain prefix

Author: gonzalezzfelipe

bootstrap/feature/operator.tf

@@ -72,7 +72,7 @@ resource "kubernetes_deployment_v1" "operator" {
 
           env {
             name  = "DB_NAMES"
-            value = "mainnet=dbsync-mainnet,preprod=dbsync-preprod,preview=dbsync-preview,vector-testnet=dbsync-vector-testnet,prime-testnet=dbsync-prime-testnet"
+            value = "vector-testnet=dbsync-vector-testnet,prime-testnet=dbsync-prime-testnet,cardano-mainnet=dbsync-mainnet,cardano-preprod=dbsync-preprod,cardano-preview=dbsync-preview"
           }
 
           env {

operator/src/controller.rs

@@ -18,7 +18,7 @@ use sha3::{Digest, Sha3_256};
 use std::{sync::Arc, time::Duration};
 use tracing::{error, info, instrument};
 
-use crate::{postgres::Postgres, Error, State};
+use crate::{postgres::Postgres, utils::handle_legacy_networks, Error, State};
 
 pub static DB_SYNC_PORT_FINALIZER: &str = "dbsyncports.demeter.run";
 
@@ -138,7 +138,7 @@ async fn reconcile(crd: Arc<DbSyncPort>, state: Arc<State>) -> Result<Action, Er
     let ns = crd.namespace().unwrap();
     let crds: Api<DbSyncPort> = Api::namespaced(state.kube_client.clone(), &ns);
 
-    let pg_connections = state.get_pg_by_network(&crd.spec.network)?;
+    let pg_connections = state.get_pg_by_network(&handle_legacy_networks(&crd.spec.network))?;
 
     finalizer(&crds, DB_SYNC_PORT_FINALIZER, crd, |event| async {
         match event {

operator/src/lib.rs

@@ -139,6 +139,7 @@ impl State {
 pub mod controller;
 pub mod metrics;
 pub mod postgres;
+pub mod utils;
 
 pub use controller::*;
 pub use metrics::*;

operator/src/utils.rs

@@ -0,0 +1,17 @@
+use lazy_static::lazy_static;
+use std::collections::HashMap;
+
+lazy_static! {
+    static ref LEGACY_NETWORKS: HashMap<&'static str, String> = {
+        let mut m = HashMap::new();
+        m.insert("mainnet", "cardano-mainnet".into());
+        m.insert("preprod", "cardano-preprod".into());
+        m.insert("preview", "cardano-preview".into());
+        m
+    };
+}
+
+pub fn handle_legacy_networks(network: &str) -> String {
+    let default = network.to_string();
+    LEGACY_NETWORKS.get(network).unwrap_or(&default).to_string()
+}