Get ruptela source from env

DIMO-Network · Oct 23, 2024 · b949599 · b949599
1 parent 8fefa6b
commit b949599
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 1 deletion.
diff --git a/charts/telemetry-api/values-prod.yaml b/charts/telemetry-api/values-prod.yaml
@@ -18,6 +18,7 @@ env:
   IDENTITY_API_REQUEST_TIMEOUT_SECONDS: 5
   DEVICE_LAST_SEEN_BIN_HOURS: 3
   POMVC_BUCKET: dimo-network-pomvc-prod
+  RUPTELA_CONNECTION_ID: "0x3A6603E1065C9b3142403b1b7e349a6Ae936E819"
 ingress:
   enabled: true
   className: nginx

diff --git a/charts/telemetry-api/values.yaml b/charts/telemetry-api/values.yaml
@@ -42,6 +42,7 @@ env:
   IDENTITY_API_URL: https://identity-api.dev.dimo.zone/query
   IDENTITY_API_REQUEST_TIMEOUT_SECONDS: 5
   DEVICE_LAST_SEEN_BIN_HOURS: 3
+  RUPTELA_CONNECTION_ID: "0x4Dc84a226102c08e911A5159e165e616e3A877A8"
 service:
   type: ClusterIP
   ports:

diff --git a/internal/config/settings.go b/internal/config/settings.go
@@ -23,4 +23,7 @@ type Settings struct {
 	IdentityAPIURL               string          `yaml:"IDENTITY_API_URL"`
 	IdentityAPIReqTimeoutSeconds int             `yaml:"IDENTITY_API_REQUEST_TIMEOUT_SECONDS"`
 	DeviceLastSeenBinHrs         int64           `yaml:"DEVICE_LAST_SEEN_BIN_HOURS"`
+
+	// TODO (kevin): We should pull this from the chain when we have the ability to do so.
+	RuptelaConnectionId string `yaml:"RUPTELA_CONNECTION_ID"`
 }
diff --git a/internal/service/ch/ch.go b/internal/service/ch/ch.go
@@ -58,6 +58,7 @@ func NewService(settings config.Settings) (*Service, error) {
 	if err != nil {
 		return nil, fmt.Errorf("failed to ping clickhouse: %w", err)
 	}
+	SourceTranslations["ruptela"] = settings.RuptelaConnectionId
 	return &Service{conn: conn, lastSeenBucketHrs: settings.DeviceLastSeenBinHrs}, nil
 }
 

diff --git a/internal/service/ch/queries.go b/internal/service/ch/queries.go
@@ -68,7 +68,6 @@ var SourceTranslations = map[string]string{
 	"tesla":    "dimo/integration/26A5Dk3vvvQutjSyF0Jka2DP5lg",
 	"autopi":   "dimo/integration/27qftVRWQYpVDcO5DltO5Ojbjxk",
 	"smartcar": "dimo/integration/22N2xaPOq2WW2gAHBHd0Ikn4Zob",
-	"ruptela":  "dimo/integration/2lcaMFuCO0HJIUfdq8o780Kx5n3",
 }
 
 var dialect = drivers.Dialect{