From 333553f45681df1b370480d3bc6a13b6898d2f6d Mon Sep 17 00:00:00 2001
From: SammyOina <sammyoina@gmail.com>
Date: Wed, 29 Mar 2023 00:36:28 +0300
Subject: [PATCH] remove homing client

Signed-off-by: SammyOina <sammyoina@gmail.com>
---
 internal/homing/homing.go      | 116 ---------------------------------
 internal/homing/homing_test.go |  15 -----
 2 files changed, 131 deletions(-)
 delete mode 100644 internal/homing/homing.go
 delete mode 100644 internal/homing/homing_test.go

diff --git a/internal/homing/homing.go b/internal/homing/homing.go
deleted file mode 100644
index def393facd9..00000000000
--- a/internal/homing/homing.go
+++ /dev/null
@@ -1,116 +0,0 @@
-package homing
-
-import (
-	"bytes"
-	"context"
-	"encoding/json"
-	"fmt"
-	"io"
-	"net/http"
-	"time"
-
-	mflog "github.com/mainflux/mainflux/logger"
-)
-
-const (
-	HomeUrl      = "localhost:9022"
-	stopWaitTime = 5 * time.Second
-)
-
-var ipEndpoints = []string{
-	"https://checkip.amazonaws.com/",
-	"https://ipinfo.io/ip",
-	"https://api.ipify.org/",
-}
-
-func New(svc, version string, homingLogger mflog.Logger, cancel context.CancelFunc) *homingService {
-	return &homingService{
-		serviceName: svc,
-		version:     version,
-		logger:      homingLogger,
-		cancel:      cancel,
-	}
-}
-
-type homingService struct {
-	serviceName string
-	version     string
-	logger      mflog.Logger
-	cancel      context.CancelFunc
-}
-
-func (hs *homingService) CallHome(ctx context.Context) {
-	for {
-		select {
-		case <-ctx.Done():
-			hs.Stop()
-		default:
-			var data telemetryData
-			var err error
-			data.Service = hs.serviceName
-			data.Version = hs.version
-			data.LastSeen = time.Now()
-			for _, endpoint := range ipEndpoints {
-				data.IpAddress, err = getIP(endpoint)
-				if err != nil {
-					hs.logger.Warn(fmt.Sprintf("failed to get ip address with error: %v", err))
-					continue
-				}
-				break
-			}
-			if err = data.send(); err != nil && data.IpAddress != "" {
-				hs.logger.Warn(fmt.Sprintf("failed to send telemtry data with error: %v", err))
-				continue
-			}
-		}
-		time.Sleep(time.Hour * 2)
-	}
-}
-
-func (hs *homingService) Stop() {
-	defer hs.cancel()
-	c := make(chan bool)
-	defer close(c)
-	select {
-	case <-c:
-	case <-time.After(stopWaitTime):
-	}
-	hs.logger.Info("call home service shutdown")
-}
-
-type telemetryData struct {
-	Service   string    `json:"service"`
-	IpAddress string    `json:"ip_address"`
-	Version   string    `json:"mainflux_version"`
-	LastSeen  time.Time `json:"last_seen"`
-}
-
-func getIP(endpoint string) (string, error) {
-	req, err := http.NewRequest(http.MethodGet, endpoint, nil)
-	if err != nil {
-		return "", err
-	}
-	res, err := http.DefaultClient.Do(req)
-	if err != nil {
-		return "", err
-	}
-	b, err := io.ReadAll(res.Body)
-	defer res.Body.Close()
-	if err != nil {
-		return "", err
-	}
-	return string(b), nil
-}
-
-func (telDat *telemetryData) send() error {
-	b, err := json.Marshal(telDat)
-	if err != nil {
-		return err
-	}
-	req, err := http.NewRequest(http.MethodPost, HomeUrl, bytes.NewReader(b))
-	if err != nil {
-		return err
-	}
-	_, err = http.DefaultClient.Do(req)
-	return err
-}
diff --git a/internal/homing/homing_test.go b/internal/homing/homing_test.go
deleted file mode 100644
index 66b4ead061b..00000000000
--- a/internal/homing/homing_test.go
+++ /dev/null
@@ -1,15 +0,0 @@
-package homing
-
-import (
-	"testing"
-)
-
-func TestGetIp(t *testing.T) {
-	t.Run("success", func(t *testing.T) {
-		for _, endpoint := range ipEndpoints {
-			if _, err := getIP(endpoint); err != nil {
-				t.Errorf(err.Error())
-			}
-		}
-	})
-}