From 9ae5a14c38f2213f7801cfdcd3b577910ded8913 Mon Sep 17 00:00:00 2001
From: Hector <hector@hjs.dev>
Date: Thu, 22 Jun 2023 16:04:57 +0100
Subject: [PATCH] move code into new function

---
 collector/f2b/collector.go | 26 +++++++++++++++-----------
 1 file changed, 15 insertions(+), 11 deletions(-)

diff --git a/collector/f2b/collector.go b/collector/f2b/collector.go
index aeccfa1..4ec1936 100644
--- a/collector/f2b/collector.go
+++ b/collector/f2b/collector.go
@@ -20,17 +20,7 @@ type Collector struct {
 
 func NewExporter(appSettings *cfg.AppSettings, exporterVersion string) *Collector {
 	log.Printf("reading fail2ban metrics socket file: %s", appSettings.Fail2BanSocketPath)
-	s, err := socket.ConnectToSocket(appSettings.Fail2BanSocketPath)
-	if err != nil {
-		log.Printf("error connecting to socket: %v", err)
-	} else {
-		version, err := s.GetServerVersion()
-		if err != nil {
-			log.Printf("error interacting with socket: %v", err)
-		} else {
-			log.Printf("successfully connected to fail2ban socket! fail2ban version: %s", version)
-		}
-	}
+	printFail2BanServerVersion(appSettings.Fail2BanSocketPath)
 	return &Collector{
 		socketPath:                 appSettings.Fail2BanSocketPath,
 		exporterVersion:            exporterVersion,
@@ -70,3 +60,17 @@ func (c *Collector) Collect(ch chan<- prometheus.Metric) {
 	}
 	c.collectErrorCountMetric(ch)
 }
+
+func printFail2BanServerVersion(socketPath string) {
+	s, err := socket.ConnectToSocket(socketPath)
+	if err != nil {
+		log.Printf("error connecting to socket: %v", err)
+	} else {
+		version, err := s.GetServerVersion()
+		if err != nil {
+			log.Printf("error interacting with socket: %v", err)
+		} else {
+			log.Printf("successfully connected to fail2ban socket! fail2ban version: %s", version)
+		}
+	}
+}