up

Dockerfile

@@ -4,7 +4,7 @@ WORKDIR /app
 
 COPY go.mod go.sum ./
 
-COPY clublog.go config.go config.yml database.go flexradio.go HTTPServer.go spot.go main.go TCPClient.go TCPServer.go utils.go log.go ./
+COPY config.go config.yml database.go flexradio.go spot.go main.go TCPClient.go TCPServer.go utils.go log.go xml.go ./
 COPY templates/* .
 
 RUN go build -o bin main.go

TCPClient.go

@@ -18,10 +18,12 @@ type TCPClient struct {
 	Password             string
 	Address              string
 	Port                 string
+	LoggedIn             bool
 	Timeout              time.Duration
 	LogWriter            *bufio.Writer
 	Reader               *bufio.Reader
 	Writer               *bufio.Writer
+	Scanner              *bufio.Scanner
 	Conn                 *net.TCPConn
 	TCPServer            TCPServer
 	MsgChan              chan string
@@ -38,6 +40,7 @@ func NewTCPClient(TCPServer *TCPServer, Countries Countries) *TCPClient {
 		Address:              Cfg.Cluster.Server,
 		Port:                 Cfg.Cluster.Port,
 		Login:                Cfg.Cluster.Login,
+		Password:             Cfg.Cluster.Password,
 		MsgChan:              TCPServer.MsgChan,
 		CmdChan:              TCPServer.CmdChan,
 		SpotChanToFlex:       make(chan TelnetSpot, 100),
@@ -54,6 +57,7 @@ func (c *TCPClient) setDefaultParams() {
 	if c.LogWriter == nil {
 		c.LogWriter = bufio.NewWriter(os.Stdout)
 	}
+	c.LoggedIn = false
 }
 
 func (c *TCPClient) StartClient() {
@@ -69,19 +73,18 @@ func (c *TCPClient) StartClient() {
 	if err != nil {
 		Log.Error("Cannot connect to Telnet Client:", err)
 	}
-	Log.Infof("Connected to DX cluster %s:%s", c.Address, c.Port)
 
-	err = c.Conn.SetKeepAlive(true)
-	if err != nil {
-		Log.Error("Error while setting keep alive:", err)
-	}
+	// err = c.Conn.SetKeepAlive(true)
+	// if err != nil {
+	// 	Log.Error("Error while setting keep alive:", err)
+	// }
 
 	c.Reader = bufio.NewReader(c.Conn)
 	c.Writer = bufio.NewWriter(c.Conn)
 
 	go func() {
 		for message := range c.TCPServer.CmdChan {
-			Log.Infof("Received DX Command: %s", message)
+			Log.Infof("Received Command: %s", message)
 			message := message + "\n"
 			c.WriteString(message)
 		}
@@ -130,32 +133,63 @@ func (c *TCPClient) SetFilters() {
 func (c *TCPClient) ReadLine() {
 
 	for {
-		message, err := c.Reader.ReadString('\n')
-		message, _ = strings.CutSuffix(message, "\n")
-		message, _ = strings.CutSuffix(message, "\r")
-		if err != nil {
-			Log.Errorf("Error reading message: %s", err)
-			continue
-		}
 
-		if strings.Contains(message, Cfg.Cluster.LoginPrompt) {
-			Log.Debug("Found login prompt...sending callsign")
-			c.Write([]byte(c.Login + "\r\n"))
-			c.SetFilters()
-			if Cfg.Cluster.Command != "" {
-				c.WriteString(Cfg.Cluster.Command)
+		// Need to check data with space first to find login and then use \n
+		if !c.LoggedIn {
+			message, err := c.Reader.ReadString(' ')
+			message, _ = strings.CutSuffix(message, "\n")
+			message, _ = strings.CutSuffix(message, "\r")
+
+			if err != nil {
+				Log.Errorf("Error reading message: %s", err)
+				c.Conn.Close()
+				c.StartClient()
+			}
+
+			if strings.Contains(message, Cfg.Cluster.LoginPrompt) {
+				Log.Debug("Found login prompt...sending callsign")
+				c.Write([]byte(c.Login + "\r\n"))
+				c.LoggedIn = true
+				// c.SetFilters()
+				// if Cfg.Cluster.Command != "" {
+				// 	c.WriteString(Cfg.Cluster.Command + "\n\r")
+				// }
+				Log.Infof("Connected to DX cluster %s:%s", Cfg.Cluster.Server, Cfg.Cluster.Port)
+				Log.Info("Start receiving spots")
+				continue
 			}
-			Log.Info("Start receiving spots")
-		} else if strings.Contains(message, "Error reading from server: read tcp") {
-			Log.Error("Disconnected from Telnet Server, reconnecting")
-			c.Close()
-			c.StartClient()
-		} else {
-			ProcessTelnetSpot(spotRe, message, c.SpotChanToFlex, c.SpotChanToHTTPServer, c.Countries)
 		}
 
-		// Send the spot message to TCP server
-		c.MsgChan <- message
+		if c.LoggedIn {
+			message, err := c.Reader.ReadString('\n')
+			message, _ = strings.CutSuffix(message, "\n")
+			message, _ = strings.CutSuffix(message, "\r")
+
+			if strings.Contains(message, "password") {
+				Log.Debug("Found password prompt...sending password")
+				c.Write([]byte(c.Password + "\r\n"))
+			}
+
+			if err != nil {
+				Log.Errorf("Error reading message: %s", err)
+				c.Conn.Close()
+				c.StartClient()
+			}
+
+			if strings.Contains(message, "Error reading from server: read tcp") {
+				Log.Error("Disconnected from Telnet Server, reconnecting")
+				c.Close()
+				c.StartClient()
+			} else {
+				if c.LoggedIn && strings.Contains(message, "DX") {
+					ProcessTelnetSpot(spotRe, message, c.SpotChanToFlex, c.SpotChanToHTTPServer, c.Countries)
+				}
+			}
+
+			// Send the spot message to TCP server
+			c.MsgChan <- message
+
+		}
 
 	}
 }

config.go

@@ -27,6 +27,7 @@ type Config struct {
 		Server      string `yaml:"server"`
 		Port        string `yaml:"port"`
 		Login       string `yaml:"login"`
+		Password    string `yaml:"password"`
 		Skimmer     bool   `yaml:"skimmer"`
 		FT8         bool   `yaml:"ft8"`
 		FT4         bool   `yaml:"ft4"`
@@ -44,6 +45,16 @@ type Config struct {
 		Host string `yaml:"host"`
 		Port string `yaml:"port"`
 	} `yaml:"telnetserver"`
+
+	Gotify struct {
+		Enable         bool   `yaml:"enable"`
+		URL            string `yaml:"url"`
+		Token          string `yaml:"token"`
+		NewDXCC        bool   `yaml:"NewDXCC"`
+		NewBand        bool   `yaml:"NewBand"`
+		NewMode        bool   `yaml:"NewMode"`
+		NewBandAndMode bool   `yaml:"NewBandAndMode"`
+	} `yaml:"gotify"`
 }
 
 func NewConfig(configPath string) *Config {

config.yml

@@ -1,25 +1,34 @@
 general:
   delete_log_file_at_start: true
   log_to_file: true
-  log_level: DEBUG # INFO or DEBUG or WARN
+  log_level: INFO # INFO or DEBUG or WARN
   telnetserver: true # not in use for now
   flexradiospot: true # not in use for now
 sqlite:
-  sqlite_path: 'C:\Perso\Seafile\Radio\Logs\Log4OM\Vietnam.SQLite' # SQLite Db oath of Log4OM
-  callsign: XV9Q # Log4OM Callsign used to check if you get spotted by someone
+  sqlite_path: 'C:\Perso\Seafile\Radio\Logs\Log4OM\F4BPO.SQLite' # SQLite Db oath of Log4OM
+  callsign: F4BPO # Log4OM Callsign used to check if you get spotted by someone
 cluster:
-  server: dxc.k0xm.net
+  server: cluster.f4bpo.com # dxc.k0xm.net dxc.sm7iun.se
   port: 7300
-  login: xv9q
+  login: f4bpo
+  password: 89DGgg
   skimmer: true
-  ft8: true
+  ft8: false
   ft4: false
-  command: #SET/NOFILTER
-  login_prompt: "Please enter your call:"
+  command: 
+  login_prompt: "login:"
 flex:
   discovery: true # Radio must be on same LAN than the program
   ip: 10.10.10.120 # if discovery is true no need to put an IP
   spot_life: 600 #seconds
 telnetserver: # Log4OM must be connected to this server ie: localhost:7301 if on same machine as this program else ip:7301
   host: 0.0.0.0
-  port: 7301
+  port: 7301
+gotify:
+  enable: false
+  url: https://gotify.rouggy.com/message
+  token: ALaGS4MVMWTEMcP
+  NewDXCC: true
+  NewBand: false
+  NewMode: false
+  NewBandAndMode: false

country.xml

@@ -6713,7 +6713,7 @@
 	  <CountryTag />
 	  <CountryPrefixList>
 		<CountryPrefix>
-		  <PrefixList>^FO.*</PrefixList>
+		  <PrefixList>^FO.*|TX5U</PrefixList>
 		  <StartDate xsi:nil="true" />
 		  <EndDate>1979-07-18T00:00:00Z</EndDate>
 		</CountryPrefix>
@@ -6723,7 +6723,7 @@
 		  <EndDate>1979-07-22T23:59:59Z</EndDate>
 		</CountryPrefix>
 		<CountryPrefix>
-		  <PrefixList>^FO.*</PrefixList>
+		  <PrefixList>^FO.*|TX5U</PrefixList>
 		  <StartDate>1979-07-22T23:59:59Z</StartDate>
 		  <EndDate xsi:nil="true" />
 		</CountryPrefix>
@@ -12832,7 +12832,7 @@
 		  <EndDate>1979-12-31T23:59:59Z</EndDate>
 		</CountryPrefix>
 		<CountryPrefix>
-		  <PrefixList>^FR.*</PrefixList>
+		  <PrefixList>^FR.*|^TO974REF</PrefixList>
 		  <StartDate>1979-12-31T23:59:59Z</StartDate>
 		  <EndDate xsi:nil="true" />
 		</CountryPrefix>

database.go

@@ -161,6 +161,52 @@ func (r *Log4OMContactsRepository) ListByCountryMode(countryID string, mode stri
 	}
 }
 
+func (r *Log4OMContactsRepository) ListByCountryModeBand(countryID string, band string, mode string, contactsModeBandChan chan []Contact, wg *sync.WaitGroup) {
+	defer wg.Done()
+
+	if mode == "USB" || mode == "LSB" {
+
+		rows, err := r.db.Query("SELECT callsign, band, mode, dxcc, stationcallsign, country FROM log WHERE dxcc = ? AND (mode = ? OR mode = ?) AND band = ?", countryID, "USB", "LSB", band)
+		if err != nil {
+			log.Error("could not query database", err)
+		}
+
+		defer rows.Close()
+
+		contacts := []Contact{}
+		for rows.Next() {
+			c := Contact{}
+			if err := rows.Scan(&c.Callsign, &c.Band, &c.Mode, &c.DXCC, &c.StationCallsign, &c.Country); err != nil {
+				log.Error("could not query database", err)
+
+			}
+			contacts = append(contacts, c)
+		}
+		contactsModeBandChan <- contacts
+
+	} else {
+
+		rows, err := r.db.Query("SELECT callsign, band, mode, dxcc, stationcallsign, country FROM log WHERE dxcc = ? AND mode = ? AND band = ?", countryID, mode, band)
+		if err != nil {
+			log.Error("could not query the database", err)
+		}
+
+		defer rows.Close()
+
+		contacts := []Contact{}
+		for rows.Next() {
+			c := Contact{}
+			if err := rows.Scan(&c.Callsign, &c.Band, &c.Mode, &c.DXCC, &c.StationCallsign, &c.Country); err != nil {
+				fmt.Println(err)
+
+			}
+			contacts = append(contacts, c)
+		}
+		contactsModeBandChan <- contacts
+
+	}
+}
+
 func (r *Log4OMContactsRepository) ListByCountryBand(countryID string, band string, contactsBandChan chan []Contact, wg *sync.WaitGroup) {
 	defer wg.Done()
 	rows, err := r.db.Query("SELECT callsign, band, mode, dxcc, stationcallsign, country FROM log WHERE dxcc = ? AND band = ?", countryID, band)

flexradio.go

@@ -34,6 +34,7 @@ type FlexSpot struct {
 	NewDXCC         bool
 	NewBand         bool
 	NewMode         bool
+	NewSlot         bool
 	Worked          bool
 }
 
@@ -164,6 +165,7 @@ func (fc *FlexClient) SendSpottoFlex(spot TelnetSpot) {
 		NewDXCC:         spot.NewDXCC,
 		NewBand:         spot.NewBand,
 		NewMode:         spot.NewMode,
+		NewSlot:         spot.NewSlot,
 		Worked:          spot.CallsignWorked,
 	}
 
@@ -180,7 +182,7 @@ func (fc *FlexClient) SendSpottoFlex(spot TelnetSpot) {
 		flexSpot.Priority = "1"
 		flexSpot.BackgroundColor = "#ff000000"
 	} else if spot.CallsignWorked {
-		flexSpot.Color = "#ff000000"
+		flexSpot.Color = "#ffeaeaea"
 		flexSpot.BackgroundColor = "#ff00c0c0"
 		flexSpot.Priority = "5"
 		flexSpot.Comment = flexSpot.Comment + " [Worked]"
@@ -199,12 +201,24 @@ func (fc *FlexClient) SendSpottoFlex(spot TelnetSpot) {
 		flexSpot.Priority = "3"
 		flexSpot.BackgroundColor = "#ff000000"
 		flexSpot.Comment = flexSpot.Comment + " [New Band]"
+	} else if !spot.NewBand && !spot.NewMode && !spot.NewDXCC && !spot.CallsignWorked && spot.NewSlot {
+		flexSpot.Color = "#ff91d2ff"
+		flexSpot.Priority = "5"
+		flexSpot.BackgroundColor = "#ff000000"
+		flexSpot.Comment = flexSpot.Comment + " [New Slot]"
 	} else if !spot.NewBand && !spot.NewMode && !spot.NewDXCC && !spot.CallsignWorked {
 		flexSpot.Color = "#ffeaeaea"
 		flexSpot.Priority = "5"
 		flexSpot.BackgroundColor = "#ff000000"
+	} else {
+		flexSpot.Color = "#ffeaeaea"
+		flexSpot.Priority = "5"
+		flexSpot.BackgroundColor = "#ff000000"
 	}
 
+	// Send notification to Gotify
+	Gotify(flexSpot)
+
 	flexSpot.Comment = strings.ReplaceAll(flexSpot.Comment, " ", "\u00A0")
 
 	srcFlexSpot, err := fc.Repo.FindDXSameBand(flexSpot)

gotify.go

@@ -0,0 +1,86 @@
+package main
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"net/http"
+)
+
+type GotifyMessage struct {
+	Title    string `json:"title"`
+	Message  string `json:"message"`
+	Priority int    `json:"priority"`
+}
+
+func Gotify(spot FlexSpot) {
+
+	if Cfg.Gotify.Enable {
+
+		message := fmt.Sprintf("DX: %s\nFrom: %s\nFreq: %s\nMode: %s\n", spot.DX, spot.Source, spot.FrequencyMhz, spot.Mode)
+
+		gotifyMsg := GotifyMessage{
+			Title:    "",
+			Message:  message,
+			Priority: 10,
+		}
+
+		if spot.NewDXCC && Cfg.Gotify.NewDXCC {
+			title := "FlexDXCluster New DXCC"
+			gotifyMsg.Title = title
+			gotifyMsg.Message = message
+			sendToGotify(gotifyMsg)
+		}
+
+		if spot.NewBand && spot.NewMode && Cfg.Gotify.NewBandAndMode {
+			title := "FlexDXCluster New Mode & Band"
+			gotifyMsg.Title = title
+			gotifyMsg.Message = message
+			sendToGotify(gotifyMsg)
+		}
+
+		if spot.NewMode && Cfg.Gotify.NewMode && !spot.NewBand {
+			title := "FlexDXCluster New Mode"
+			gotifyMsg.Title = title
+			gotifyMsg.Message = message
+			sendToGotify(gotifyMsg)
+		}
+
+		if spot.NewBand && Cfg.Gotify.NewBand && !spot.NewMode {
+			title := "FlexDXCluster New Band"
+			gotifyMsg.Title = title
+			gotifyMsg.Message = message
+			sendToGotify(gotifyMsg)
+		}
+	}
+}
+
+func sendToGotify(mess GotifyMessage) {
+	jsonData, err := json.Marshal(mess)
+	if err != nil {
+		Log.Errorln("Error marshaling JSON:", err)
+		return
+	}
+
+	req, err := http.NewRequest("POST", Cfg.Gotify.URL, bytes.NewBuffer(jsonData))
+	if err != nil {
+		Log.Errorln("Error creating request:", err)
+		return
+	}
+	req.Header.Set("Content-Type", "application/json")
+	req.Header.Add("Authorization", "Bearer "+Cfg.Gotify.Token)
+
+	client := &http.Client{}
+	resp, err := client.Do(req)
+	if err != nil {
+		Log.Errorln("Error sending request:", err)
+		return
+	}
+	defer resp.Body.Close()
+
+	if resp.StatusCode != http.StatusOK {
+		Log.Errorln("Gotify server returned non-OK status:", resp.Status)
+	} else {
+		Log.Debugln("Push successfully sent to Gotify")
+	}
+}

main.go

@@ -4,9 +4,7 @@ import (
 	"flag"
 	"log"
 	"os"
-	"os/signal"
 	"path/filepath"
-	"syscall"
 )
 
 func ParseFlags() (string, error) {
@@ -44,11 +42,16 @@ func main() {
 	cfg := NewConfig(cfgPath)
 
 	log := NewLog()
-	log.Info("Running FlexDXCluster version 0.1")
+	log.Info("Running FlexDXCluster version 0.5")
 	log.Infof("Callsign: %s", cfg.SQLite.Callsign)
 
 	DeleteDatabase("./flex.sqlite", log)
 
+	log.Infof("Gotify Push Enabled: %v", cfg.Gotify.Enable)
+	if cfg.Gotify.Enable {
+		log.Infof("Gotify Push NewDXCC: %v - NewBand: %v - NewMode: %v - NewBandAndMode: %v", cfg.Gotify.NewDXCC, cfg.Gotify.NewBand, cfg.Gotify.NewMode, cfg.Gotify.NewBandAndMode)
+	}
+
 	// Load country.xml to get all the DXCC number
 	Countries := LoadCountryFile()
 
@@ -65,32 +68,10 @@ func main() {
 	FlexClient := NewFlexClient(*fRepo, TCPServer, TCPClient.SpotChanToFlex)
 	// HTTPServer := NewHTTPServer(*cRepo, *fRepo, TCPServer, TCPClient.SpotChanToHTTPServer)
 
-	sigCh := make(chan os.Signal, 1)
-	signal.Notify(sigCh, syscall.SIGHUP, syscall.SIGINT, syscall.SIGQUIT, syscall.SIGTERM)
-
 	go FlexClient.StartFlexClient()
 	go TCPClient.StartClient()
 	go TCPServer.StartServer()
 
-	// Gracely closing all connextions if signal is received
-	for sig := range sigCh {
-		log.Infof("received signal: %v, shutting down all connections.", sig)
-
-		TCPClient.Close()
-		TCPServer.Conn.Close()
-		FlexClient.Conn.Close()
-
-		if err := fRepo.db.Close(); err != nil {
-			log.Error("failed to close the database connection properly")
-			os.Exit(1)
-		}
-
-		if err := cRepo.db.Close(); err != nil {
-			log.Error("failed to close Log4OM database connection properly")
-			os.Exit(1)
-		}
-
-		os.Exit(0)
-	}
+	CheckSignal(TCPClient, TCPServer, FlexClient, fRepo, cRepo)
 
 }

spot.go

@@ -23,6 +23,7 @@ type TelnetSpot struct {
 	NewDXCC        bool
 	NewBand        bool
 	NewMode        bool
+	NewSlot        bool
 	CallsignWorked bool
 }
 
@@ -52,17 +53,19 @@ func ProcessTelnetSpot(re *regexp.Regexp, spotRaw string, SpotChanToFlex chan Te
 		spot.NewBand = false
 		spot.NewMode = false
 		spot.NewDXCC = false
+		spot.NewSlot = false
 
 		contactRepo := NewLog4OMContactsRepository(Cfg.SQLite.SQLitePath)
 		defer contactRepo.db.Close()
 
 		contactsChan := make(chan []Contact)
 		contactsModeChan := make(chan []Contact)
+		contactsModeBandChan := make(chan []Contact)
 		contactsBandChan := make(chan []Contact)
 		contactsCallChan := make(chan []Contact)
 
 		wg := new(sync.WaitGroup)
-		wg.Add(4)
+		wg.Add(5)
 
 		go contactRepo.ListByCountry(spot.DXCC, contactsChan, wg)
 		contacts := <-contactsChan
@@ -76,6 +79,9 @@ func ProcessTelnetSpot(re *regexp.Regexp, spotRaw string, SpotChanToFlex chan Te
 		go contactRepo.ListByCallSign(spot.DX, spot.Band, spot.Mode, contactsCallChan, wg)
 		contactsCall := <-contactsCallChan
 
+		go contactRepo.ListByCountryModeBand(spot.DXCC, spot.Band, spot.Mode, contactsModeBandChan, wg)
+		contactsModeBand := <-contactsModeBandChan
+
 		wg.Wait()
 
 		if len(contacts) == 0 {
@@ -88,6 +94,11 @@ func ProcessTelnetSpot(re *regexp.Regexp, spotRaw string, SpotChanToFlex chan Te
 		if len(contactsBand) == 0 {
 			spot.NewBand = true
 		}
+
+		if len(contactsModeBand) == 0 {
+			spot.NewSlot = true
+		}
+
 		if len(contactsCall) > 0 {
 			spot.CallsignWorked = true
 		}
@@ -96,8 +107,8 @@ func ProcessTelnetSpot(re *regexp.Regexp, spotRaw string, SpotChanToFlex chan Te
 		SpotChanToFlex <- spot
 
 		if spot.NewDXCC {
-			Log.Debugf("(** New DXCC **) DX: %s - Spotter: %s - Freq: %s - Band: %s - Mode: %s - Comment: %s - Time: %s - Command: %v, FlexSpot: %v",
-				spot.DX, spot.Spotter, spot.Frequency, spot.Band, spot.Mode, spot.Comment, spot.Time, spot.CommandNumber, spot.FlexSpotNumber)
+			Log.Debugf("(** New DXCC **) DX: %s - Spotter: %s - Freq: %s - Band: %s - Mode: %s - Comment: %s - Time: %s - DXCC: %s",
+				spot.DX, spot.Spotter, spot.Frequency, spot.Band, spot.Mode, spot.Comment, spot.Time, spot.DXCC)
 		}
 
 		if !spot.NewDXCC && spot.NewBand && spot.NewMode {
@@ -115,6 +126,11 @@ func ProcessTelnetSpot(re *regexp.Regexp, spotRaw string, SpotChanToFlex chan Te
 				spot.DX, spot.Spotter, spot.Frequency, spot.Band, spot.Mode, spot.Comment, spot.Time, spot.DXCC)
 		}
 
+		if !spot.NewDXCC && !spot.NewBand && !spot.NewMode && spot.NewSlot && spot.Mode != "" {
+			Log.Debugf("(** New Slot **) DX: %s - Spotter: %s - Freq: %s - Band: %s - Mode: %s - Comment: %s - Time: %s - DXCC: %s",
+				spot.DX, spot.Spotter, spot.Frequency, spot.Band, spot.Mode, spot.Comment, spot.Time, spot.DXCC)
+		}
+
 		if !spot.NewDXCC && !spot.NewBand && !spot.NewMode && spot.CallsignWorked {
 			Log.Debugf("(** Worked **) DX: %s - Spotter: %s - Freq: %s - Band: %s - Mode: %s - Comment: %s - Time: %s - DXCC: %s",
 				spot.DX, spot.Spotter, spot.Frequency, spot.Band, spot.Mode, spot.Comment, spot.Time, spot.DXCC)

utils.go

@@ -2,7 +2,10 @@ package main
 
 import (
 	"log"
+	"os"
+	"os/signal"
 	"strconv"
+	"syscall"
 )
 
 func FreqMhztoHz(freq string) string {
@@ -26,3 +29,30 @@ func FreqHztoMhz(freq string) string {
 
 	return strconv.FormatFloat(frequency, 'f', 6, 64)
 }
+
+func CheckSignal(TCPClient *TCPClient, TCPServer *TCPServer, FlexClient *FlexClient, fRepo *FlexDXClusterRepository, cRepo *Log4OMContactsRepository) {
+
+	sigCh := make(chan os.Signal, 1)
+	signal.Notify(sigCh, syscall.SIGHUP, syscall.SIGINT, syscall.SIGQUIT, syscall.SIGTERM)
+
+	// Gracely closing all connextions if signal is received
+	for sig := range sigCh {
+		Log.Infof("received signal: %v, shutting down all connections.", sig)
+
+		TCPClient.Close()
+		TCPServer.Conn.Close()
+		FlexClient.Conn.Close()
+
+		if err := fRepo.db.Close(); err != nil {
+			Log.Error("failed to close the database connection properly")
+			os.Exit(1)
+		}
+
+		if err := cRepo.db.Close(); err != nil {
+			Log.Error("failed to close Log4OM database connection properly")
+			os.Exit(1)
+		}
+
+		os.Exit(0)
+	}
+}