From 27bb38c9259b24d4ee9c06fa74b72128e0dedfc0 Mon Sep 17 00:00:00 2001
From: Zdravko Iliev <zdravko.iliev@vereign.com>
Date: Wed, 16 Aug 2023 15:23:17 +0300
Subject: [PATCH] fix: try to update the stream
---
apps/agent/README.md | 2 +-
libs/nats/src/base.nats.service.ts | 7 ++-----
2 files changed, 3 insertions(+), 6 deletions(-)
diff --git a/apps/agent/README.md b/apps/agent/README.md
index 63a0c611..4ac3348f 100644
--- a/apps/agent/README.md
+++ b/apps/agent/README.md
@@ -1,4 +1,4 @@
-# OCM ENGINE - AGENT
+# OCM ENGINE - AGENT
Agent service is a wrapper around @ocm-engine/askar library.
diff --git a/libs/nats/src/base.nats.service.ts b/libs/nats/src/base.nats.service.ts
index 20a6bde0..2b6e8bd0 100644
--- a/libs/nats/src/base.nats.service.ts
+++ b/libs/nats/src/base.nats.service.ts
@@ -76,10 +76,6 @@ export class NatsBaseService {
this.logger.error(
`Failed to connect to NATS, retrying...${error.message}`,
);
-
- throw new Error(
- `Failed to connect to NATS, retrying...${error.message}`,
- );
},
},
);
@@ -98,7 +94,8 @@ export class NatsBaseService {
this.logger.log(JSON.stringify(e, null, 2));
if (e instanceof NatsError && e.api_error?.err_code === 10065) {
- return await this.jsm.streams.get(sconfig.name);
+ this.logger.log("here ?");
+ return await this.jsm.streams.update(sconfig.name, sconfig);
}
throw new Error(`RegisterStream failed.`);
--
GitLab