fix: store

waku-org · Jun 10, 2022 · 10319c3 · 10319c3
1 parent 92540ae
commit 10319c3
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/waku/node.go b/waku/node.go
@@ -192,11 +192,15 @@ func Execute(options Options) {
 		nodeOpts = append(nodeOpts, node.WithWakuFilter(!options.Filter.DisableFullNode, filter.WithTimeout(time.Duration(options.Filter.Timeout)*time.Second)))
 	}
 
-	if options.Store.Enable && options.Store.PersistMessages {
-		nodeOpts = append(nodeOpts, node.WithWakuStoreAndRetentionPolicy(options.Store.ShouldResume, options.Store.RetentionMaxDaysDuration(), options.Store.RetentionMaxMessages))
-		dbStore, err := persistence.NewDBStore(logger, persistence.WithDB(db), persistence.WithRetentionPolicy(options.Store.RetentionMaxMessages, options.Store.RetentionMaxDaysDuration()))
-		failOnErr(err, "DBStore")
-		nodeOpts = append(nodeOpts, node.WithMessageProvider(dbStore))
+	if options.Store.Enable {
+		if options.Store.PersistMessages {
+			nodeOpts = append(nodeOpts, node.WithWakuStoreAndRetentionPolicy(options.Store.ShouldResume, options.Store.RetentionMaxDaysDuration(), options.Store.RetentionMaxMessages))
+			dbStore, err := persistence.NewDBStore(logger, persistence.WithDB(db), persistence.WithRetentionPolicy(options.Store.RetentionMaxMessages, options.Store.RetentionMaxDaysDuration()))
+			failOnErr(err, "DBStore")
+			nodeOpts = append(nodeOpts, node.WithMessageProvider(dbStore))
+		} else {
+			nodeOpts = append(nodeOpts, node.WithWakuStore(false, false))
+		}
 	}
 
 	if options.LightPush.Enable {