feat:Add tests to mproxy

Signed-off-by: felix.gateru <felix.gateru@gmail.com>

Author: felixgateru

go.mod

@@ -11,4 +11,11 @@ require (
 	golang.org/x/sync v0.6.0
 )
 
-require golang.org/x/net v0.20.0 // indirect
+require (
+	github.com/davecgh/go-spew v1.1.1 // indirect
+	github.com/pmezard/go-difflib v1.0.0 // indirect
+	github.com/stretchr/objx v0.5.0 // indirect
+	github.com/stretchr/testify v1.8.4 // indirect
+	golang.org/x/net v0.20.0 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
+)

go.sum

@@ -1,10 +1,27 @@
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/eclipse/paho.mqtt.golang v1.4.3 h1:2kwcUGn8seMUfWndX0hGbvH8r7crgcJguQNCyp70xik=
 github.com/eclipse/paho.mqtt.golang v1.4.3/go.mod h1:CSYvoAlsMkhYOXh/oKyxa8EcBci6dVkLCbo5tTC1RIE=
 github.com/google/uuid v1.5.0 h1:1p67kYwdtXjb0gL0BPiP1Av9wiZPo5A8z2cWkTZ+eyU=
 github.com/google/uuid v1.5.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/gorilla/websocket v1.5.1 h1:gmztn0JnHVt9JZquRuzLw3g4wouNVzKL15iLr/zn/QY=
 github.com/gorilla/websocket v1.5.1/go.mod h1:x3kM2JMyaluk02fnUJpQuwD2dCS5NDG2ZHL0uE0tcaY=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
+github.com/stretchr/objx v0.5.0 h1:1zr/of2m5FGMsad5YfcqgdqdWrIhu+EBEJRhR1U7z/c=
+github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
+github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
+github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk=
+github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
 golang.org/x/net v0.20.0 h1:aCL9BSgETF1k+blQaYUBx9hJ9LOGP3gAVemcZlf1Kpo=
 golang.org/x/net v0.20.0/go.mod h1:z8BVo6PvndSri0LbOE3hAn0apkU+1YvI6E70E9jsnvY=
 golang.org/x/sync v0.6.0 h1:5BMeUDZ7vkXGfEr1x9B4bRcTH4lpkTkpdh0T/J+qjbQ=
 golang.org/x/sync v0.6.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

pkg/http/http_test.go

@@ -0,0 +1,100 @@
+package http_test
+
+import (
+	"fmt"
+	"log/slog"
+	"net/http"
+	"net/http/httptest"
+	"testing"
+
+	"github.com/absmach/mproxy/pkg/session/mocks"
+
+	mhttp "github.com/absmach/mproxy/pkg/http"
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/mock"
+)
+
+const (
+	validUrl    = "http://example.com"
+	validAddess = "localhost:8080"
+)
+
+var (
+	han *mocks.Handler
+	log *slog.Logger
+)
+
+func newProxy(address, url string) (mhttp.Proxy, error) {
+	han = new(mocks.Handler)
+	log = new(slog.Logger)
+	return mhttp.NewProxy(address, url, han, log)
+}
+
+func TestNewProxy(t *testing.T) {
+	cases := []struct {
+		desc    string
+		address string
+		url     string
+		err     error
+	}{
+		{
+			desc:    "create proxy with valid",
+			address: validAddess,
+			url:     validUrl,
+			err:     nil,
+		},
+		{
+			desc:    "create proxy with invalid url",
+			address: validAddess,
+			url:     "0000",
+			err:     nil,
+		},
+	}
+	for _, c := range cases {
+		_, err := newProxy(c.address, c.url)
+		assert.Equal(t, c.err, err, fmt.Sprintf("%s: expected %s got %s\n", c.desc, c.err, err))
+
+	}
+}
+
+func TestHandler(t *testing.T) {
+	proxy, err := newProxy(validAddess, validUrl)
+	assert.Nil(t, err, fmt.Sprintf("expected nil got %s\n", err))
+
+	t.Run("Successful Request", func(t *testing.T) {
+		request := httptest.NewRequest(http.MethodGet, "http://example.com", nil)
+		request.SetBasicAuth("username", "password")
+		responseRecorder := httptest.NewRecorder()
+
+		han.On("AuthConnect", mock.Anything).Return(nil)
+		han.On("Publish", mock.Anything, mock.Anything, mock.Anything).Return(nil)
+		proxy.Handler(responseRecorder, request)
+
+		assert.Equal(t, http.StatusOK, responseRecorder.Code, "Handler should return status OK for successful request")
+	})
+}
+
+func TestListen(t *testing.T) {
+	proxy, err := newProxy(validAddess, validUrl)
+	assert.Nil(t, err, fmt.Sprintf("expected nil got %s\n", err))
+
+	t.Run("Listen", func(t *testing.T) {
+		go func() {
+			err := proxy.Listen()
+			assert.Nil(t, err, fmt.Sprintf("expected nil got %s\n", err))
+		}()
+	})
+}
+
+// func TestListenTLS(t *testing.T) {
+// 	proxy, err := newProxy(validAddess, validUrl)
+// 	assert.Nil(t, err, fmt.Sprintf("expected nil got %s\n", err))
+
+
+// 	t.Run("ListenTLS", func(t *testing.T) {
+// 		go func() {
+// 			err := proxy.ListenTLS("cert", "key")
+// 			assert.Nil(t, err, fmt.Sprintf("expected nil got %s\n", err))
+// 		}()
+// 	})
+// }

pkg/mqtt/websocket/websocket_test.go

@@ -0,0 +1,2 @@
+package websocket_test
+

pkg/session/handler.go

@@ -3,6 +3,8 @@ package session
 import "context"
 
 // Handler is an interface for mProxy hooks
+
+//go:generate mockery --name Handler --filename handler.go --quiet --note "Copyright (c) Abstract Machines"
 type Handler interface {
 	// Authorization on client `CONNECT`
 	// Each of the params are passed by reference, so that it can be changed