From 7f0e68e65111982c88c40c2056fad6837c8822ae Mon Sep 17 00:00:00 2001
From: Joakim Recht <joakim@beyondwork.ai>
Date: Tue, 21 Nov 2023 12:52:07 +0100
Subject: [PATCH] Configure nats replicas for stateful streams

---
 setup/jetstream/streams.go | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/setup/jetstream/streams.go b/setup/jetstream/streams.go
index 741407926..5d898fabf 100644
--- a/setup/jetstream/streams.go
+++ b/setup/jetstream/streams.go
@@ -49,31 +49,37 @@ var streams = []*nats.StreamConfig{
 		Retention: nats.InterestPolicy,
 		Storage:   nats.FileStorage,
 		MaxAge:    time.Hour * 24,
+		Replicas:  2,
 	},
 	{
 		Name:      InputDeviceListUpdate,
 		Retention: nats.InterestPolicy,
 		Storage:   nats.FileStorage,
+		Replicas:  2,
 	},
 	{
 		Name:      InputSigningKeyUpdate,
 		Retention: nats.InterestPolicy,
 		Storage:   nats.FileStorage,
+		Replicas:  2,
 	},
 	{
 		Name:      OutputRoomEvent,
 		Retention: nats.InterestPolicy,
 		Storage:   nats.FileStorage,
+		Replicas:  2,
 	},
 	{
 		Name:      OutputSendToDeviceEvent,
 		Retention: nats.InterestPolicy,
 		Storage:   nats.FileStorage,
+		Replicas:  2,
 	},
 	{
 		Name:      OutputKeyChangeEvent,
 		Retention: nats.InterestPolicy,
 		Storage:   nats.FileStorage,
+		Replicas:  2,
 	},
 	{
 		Name:      OutputTypingEvent,
@@ -85,16 +91,19 @@ var streams = []*nats.StreamConfig{
 		Name:      OutputClientData,
 		Retention: nats.InterestPolicy,
 		Storage:   nats.FileStorage,
+		Replicas:  2,
 	},
 	{
 		Name:      OutputReceiptEvent,
 		Retention: nats.InterestPolicy,
 		Storage:   nats.FileStorage,
+		Replicas:  2,
 	},
 	{
 		Name:      OutputNotificationData,
 		Retention: nats.InterestPolicy,
 		Storage:   nats.FileStorage,
+		Replicas:  2,
 	},
 	{
 		Name:      OutputPresenceEvent,