From 280b458e381039b7e95684fbd8ccb51ed9545965 Mon Sep 17 00:00:00 2001
From: zakharenkodmytro <amidum@gmail.com>
Date: Mon, 27 Jan 2025 10:11:17 -0500
Subject: [PATCH] Fix helm (#5)

 - fix chart files
---
 charts/templates/secret.yaml | 14 ++++++++++++++
 cmd/stream/main.go           |  5 +++--
 2 files changed, 17 insertions(+), 2 deletions(-)
 create mode 100644 charts/templates/secret.yaml

diff --git a/charts/templates/secret.yaml b/charts/templates/secret.yaml
new file mode 100644
index 0000000..90c3752
--- /dev/null
+++ b/charts/templates/secret.yaml
@@ -0,0 +1,14 @@
+apiVersion: external-secrets.io/v1beta1
+kind: ExternalSecret
+metadata:
+  name: {{ include "compass-poc.fullname" . }}-secret
+  namespace: {{ .Release.Namespace }}
+spec:
+  data:
+  secretStoreRef:
+    kind: ClusterSecretStore
+    name: aws-secretsmanager-secret-store
+  target:
+    name: {{ include "compass-poc.fullname" . }}-secret
+    template:
+      metadata: {}
diff --git a/cmd/stream/main.go b/cmd/stream/main.go
index 8e354cd..71c4f6d 100644
--- a/cmd/stream/main.go
+++ b/cmd/stream/main.go
@@ -94,7 +94,7 @@ func (cw *compassWrapper) startStream(vins []string) {
 		// Use the provided context
 		realtimeData, err := cw.client.RealtimeRawPointByVins(timeoutCtx, &v1.RealtimeRawPointByVinsRequest{
 			Vins:                vins,
-			MaxStalenessMinutes: 7,
+			MaxStalenessMinutes: 5,
 		})
 		if err != nil {
 			cw.logger.Error().Err(err).Msg("failed to get realtime data, retrying...")
@@ -111,7 +111,8 @@ func (cw *compassWrapper) startStream(vins []string) {
 					cw.logger.Info().Msg("Stream ended.")
 					break
 				}
-				cw.logger.Fatal().Err(err).Msg("Error receiving from stream, retrying...")
+
+				cw.logger.Err(err).Msg("Error receiving from stream, retrying...")
 				break
 			}