From c148906f935b54972a49e6568027699e13823641 Mon Sep 17 00:00:00 2001
From: Jonas Michel <jonasrmichel@gmail.com>
Date: Wed, 3 Jan 2024 14:30:23 -0600
Subject: [PATCH] Enable numpin and pinqueue informers in ipfs-cluster-follow
 (as in ipfs-cluster-service)

---
 cmd/ipfs-cluster-follow/commands.go | 30 +++++++++++++++++++++++++----
 1 file changed, 26 insertions(+), 4 deletions(-)

diff --git a/cmd/ipfs-cluster-follow/commands.go b/cmd/ipfs-cluster-follow/commands.go
index ee07ee7d..8a885cc6 100644
--- a/cmd/ipfs-cluster-follow/commands.go
+++ b/cmd/ipfs-cluster-follow/commands.go
@@ -19,6 +19,8 @@ import (
 	"github.com/ipfs-cluster/ipfs-cluster/datastore/badger"
 	"github.com/ipfs-cluster/ipfs-cluster/datastore/leveldb"
 	"github.com/ipfs-cluster/ipfs-cluster/informer/disk"
+	"github.com/ipfs-cluster/ipfs-cluster/informer/pinqueue"
+	"github.com/ipfs-cluster/ipfs-cluster/informer/tags"
 	"github.com/ipfs-cluster/ipfs-cluster/ipfsconn/ipfshttp"
 	"github.com/ipfs-cluster/ipfs-cluster/monitor/pubsubmon"
 	"github.com/ipfs-cluster/ipfs-cluster/observations"
@@ -337,10 +339,30 @@ func runCmd(c *cli.Context) error {
 		return cli.Exit(errors.Wrap(err, "creating IPFS Connector component"), 1)
 	}
 
-	informer, err := disk.NewInformer(cfgs.DiskInf)
-	if err != nil {
-		return cli.Exit(errors.Wrap(err, "creating disk informer"), 1)
+	var informers []ipfscluster.Informer
+	if cfgHelper.Manager().IsLoadedFromJSON(config.Informer, cfgs.DiskInf.ConfigKey()) {
+		diskInf, err := disk.NewInformer(cfgs.DiskInf)
+		if err != nil {
+			return cli.Exit(errors.Wrap(err, "creating disk informer"), 1)
+		}
+		informers = append(informers, diskInf)
 	}
+	if cfgHelper.Manager().IsLoadedFromJSON(config.Informer, cfgs.TagsInf.ConfigKey()) {
+		tagsInf, err := tags.New(cfgs.TagsInf)
+		if err != nil {
+			return cli.Exit(errors.Wrap(err, "creating numpin informer"), 1)
+		}
+		informers = append(informers, tagsInf)
+	}
+
+	if cfgHelper.Manager().IsLoadedFromJSON(config.Informer, cfgs.PinQueueInf.ConfigKey()) {
+		pinQueueInf, err := pinqueue.New(cfgs.PinQueueInf)
+		if err != nil {
+			return cli.Exit(errors.Wrap(err, "creating pinqueue informer"), 1)
+		}
+		informers = append(informers, pinQueueInf)
+	}
+
 	alloc, err := balanced.New(cfgs.BalancedAlloc)
 	if err != nil {
 		return cli.Exit(errors.Wrap(err, "creating metrics allocator"), 1)
@@ -402,7 +424,7 @@ func runCmd(c *cli.Context) error {
 		tracker,
 		mon,
 		alloc,
-		[]ipfscluster.Informer{informer},
+		informers,
 		tracer,
 	)
 	if err != nil {