Merge pull request #12 from raghavyuva/feature/notifications-conf

notification configuration setup, any controller can now make use of …

Author: raghavyuva

api/go.mod

@@ -10,6 +10,7 @@ require (
 	github.com/jackc/pgx/v5 v5.7.2
 	github.com/joho/godotenv v1.5.1
 	github.com/sirupsen/logrus v1.9.3
+	github.com/slack-go/slack v0.16.0
 	github.com/swaggo/http-swagger/v2 v2.0.2
 	github.com/swaggo/swag v1.16.4
 	github.com/uptrace/bun v1.2.10

api/go.sum

@@ -13,12 +13,18 @@ github.com/go-openapi/spec v0.21.0 h1:LTVzPc3p/RzRnkQqLRndbAzjY0d0BCL72A6j3CdL9Z
 github.com/go-openapi/spec v0.21.0/go.mod h1:78u6VdPw81XU44qEWGhtr982gJ5BWg2c0I5XwVMotYk=
 github.com/go-openapi/swag v0.23.0 h1:vsEVJDUo2hPJ2tu0/Xc+4noaxyEffXNIs3cOULZ+GrE=
 github.com/go-openapi/swag v0.23.0/go.mod h1:esZ8ITTYEsH1V2trKHjAN8Ai7xHb8RV+YSZ577vPjgQ=
+github.com/go-test/deep v1.0.4 h1:u2CU3YKy9I2pmu9pX0eq50wCgjfGIt539SqR7FbHiho=
+github.com/go-test/deep v1.0.4/go.mod h1:wGDj63lr65AM2AQyKZd/NYHGb0R+1RLqB8NKt3aSFNA=
 github.com/golang-jwt/jwt v3.2.2+incompatible h1:IfV12K8xAKAnZqdXVzCZ+TOjboZ2keLg81eXfW3O+oY=
 github.com/golang-jwt/jwt v3.2.2+incompatible/go.mod h1:8pz2t5EyA70fFQQSrl6XZXzqecmYZeUEB8OUGHkxJ+I=
+github.com/google/go-cmp v0.5.7/go.mod h1:n+brtR0CgQNWTVd5ZUFpTBC8YFBDLK/h/bpaJ8/DtOE=
+github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
+github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
 github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/gorilla/mux v1.8.1 h1:TuBL49tXwgrFYWhqrNgrUNEY92u81SPhu7sTdzQEiWY=
 github.com/gorilla/mux v1.8.1/go.mod h1:AKf9I4AEqPTmMytcMc0KkNouC66V3BtZ4qD5fmWSiMQ=
+github.com/gorilla/websocket v1.4.2/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
 github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=
 github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
 github.com/jackc/pgpassfile v1.0.0 h1:/6Hmqy13Ss2zCq62VdNG8tM1wchn8zjSGOBJ6icpsIM=
@@ -53,7 +59,10 @@ github.com/rogpeppe/go-internal v1.11.0 h1:cWPaGQEPrBb5/AsnsZesgZZ9yb1OQ+GOISoDN
 github.com/rogpeppe/go-internal v1.11.0/go.mod h1:ddIwULY96R17DhadqLgMfk9H9tvdUzkipdSkR5nkCZA=
 github.com/sirupsen/logrus v1.9.3 h1:dueUQJ1C2q9oE3F7wvmSGAaVtTmUizReu6fjN8uqzbQ=
 github.com/sirupsen/logrus v1.9.3/go.mod h1:naHLuLoDiP4jHNo9R0sCBMtWGeIprob74mVsIT4qYEQ=
+github.com/slack-go/slack v0.16.0 h1:khp/WCFv+Hb/B/AJaAwvcxKun0hM6grN0bUZ8xG60P8=
+github.com/slack-go/slack v0.16.0/go.mod h1:hlGi5oXA+Gt+yWTPP0plCdRKmjsDxecdHxYQdlMQKOw=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
 github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
@@ -94,6 +103,7 @@ golang.org/x/time v0.10.0 h1:3usCWA8tQn0L8+hFJQNgzpWbd89begxN66o1Ojdn5L4=
 golang.org/x/time v0.10.0/go.mod h1:3BpzKBy/shNhVucY/MWOyx10tF3SFh9QdLuxbVysPQM=
 golang.org/x/tools v0.30.0 h1:BgcpHewrV5AUp2G9MebG4XPFI1E2W41zU1SaqVA9vJY=
 golang.org/x/tools v0.30.0/go.mod h1:c347cR/OJfw5TI+GfX7RUPNMdDRRbjvYTS0jPyvsVtY=
+golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=

api/internal/features/auth/controller/init.go

@@ -6,15 +6,17 @@ import (
 	"github.com/raghavyuva/nixopus-api/internal/features/auth/service"
 	"github.com/raghavyuva/nixopus-api/internal/features/auth/validation"
 	"github.com/raghavyuva/nixopus-api/internal/features/logger"
+	"github.com/raghavyuva/nixopus-api/internal/features/notification"
 	shared_storage "github.com/raghavyuva/nixopus-api/internal/storage"
 )
 
 type AuthController struct {
-	store     *shared_storage.Store
-	validator *validation.Validator
-	service   *service.AuthService
-	ctx       context.Context
-	logger    logger.Logger
+	store        *shared_storage.Store
+	validator    *validation.Validator
+	service      *service.AuthService
+	ctx          context.Context
+	logger       logger.Logger
+	notification *notification.NotificationManager
 }
 
 // NewAuthController creates a new AuthController with the given App.
@@ -26,12 +28,14 @@ func NewAuthController(
 	store *shared_storage.Store,
 	ctx context.Context,
 	l logger.Logger,
+	notificationManager *notification.NotificationManager,
 ) *AuthController {
 	return &AuthController{
-		store:     store,
-		validator: validation.NewValidator(),
-		service:   service.NewAuthService(store, ctx, l),
-		ctx:       ctx,
-		logger:    l,
+		store:        store,
+		validator:    validation.NewValidator(),
+		service:      service.NewAuthService(store, ctx, l),
+		ctx:          ctx,
+		logger:       l,
+		notification: notificationManager,
 	}
 }

api/internal/features/auth/controller/login.go

@@ -5,6 +5,7 @@ import (
 
 	"github.com/raghavyuva/nixopus-api/internal/features/auth/types"
 	"github.com/raghavyuva/nixopus-api/internal/features/logger"
+	"github.com/raghavyuva/nixopus-api/internal/features/notification"
 	"github.com/raghavyuva/nixopus-api/internal/utils"
 )
 
@@ -42,5 +43,19 @@ func (c *AuthController) Login(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
+	c.notification.SendNotification(notification.NewNotificationPayload(
+		notification.NotificationPayloadTypeLogin,
+		response.User.ID.String(),
+		notification.NotificationAuthenticationData{
+			Email: login_request.Email,
+			NotificationBaseData: notification.NotificationBaseData{
+				IP:      r.RemoteAddr,
+				Browser: r.UserAgent(),
+			},
+			UserName: response.User.Username,
+		},
+		notification.NotificationCategoryAuthentication,
+	))
+
 	utils.SendJSONResponse(w, "success", "User logged in successfully", response)
 }

api/internal/features/auth/controller/logout.go

@@ -5,7 +5,10 @@ import (
 
 	"github.com/raghavyuva/nixopus-api/internal/features/auth/types"
 	"github.com/raghavyuva/nixopus-api/internal/features/logger"
+	"github.com/raghavyuva/nixopus-api/internal/features/notification"
 	"github.com/raghavyuva/nixopus-api/internal/utils"
+
+	shared_types "github.com/raghavyuva/nixopus-api/internal/types"
 )
 
 // Logout godoc
@@ -36,10 +39,33 @@ func (c *AuthController) Logout(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
+	userAny := r.Context().Value(shared_types.UserContextKey)
+	user, ok := userAny.(*shared_types.User)
+
+	if !ok {
+		c.logger.Log(logger.Error, types.ErrFailedToGetUserFromContext.Error(), types.ErrFailedToGetUserFromContext.Error())
+		utils.SendErrorResponse(w, types.ErrFailedToGetUserFromContext.Error(), http.StatusInternalServerError)
+		return
+	}
+
 	if err := c.service.Logout(logoutRequest.RefreshToken); err != nil {
 		utils.SendErrorResponse(w, err.Error(), http.StatusInternalServerError)
 		return
 	}
 
+	c.notification.SendNotification(notification.NewNotificationPayload(
+		notification.NotificationPayloadTypeLogout,
+		user.ID.String(),
+		notification.NotificationAuthenticationData{
+			Email: user.Email,
+			NotificationBaseData: notification.NotificationBaseData{
+				IP:      r.RemoteAddr,
+				Browser: r.UserAgent(),
+			},
+			UserName: user.Username,
+		},
+		notification.NotificationCategoryAuthentication,
+	))
+
 	utils.SendJSONResponse(w, "success", "Logged out successfully", nil)
 }

api/internal/features/auth/controller/reset_password.go

@@ -6,6 +6,7 @@ import (
 
 	"github.com/raghavyuva/nixopus-api/internal/features/auth/types"
 	"github.com/raghavyuva/nixopus-api/internal/features/logger"
+	"github.com/raghavyuva/nixopus-api/internal/features/notification"
 	shared_types "github.com/raghavyuva/nixopus-api/internal/types"
 	"github.com/raghavyuva/nixopus-api/internal/utils"
 )
@@ -54,6 +55,20 @@ func (c *AuthController) ResetPassword(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
+	c.notification.SendNotification(notification.NewNotificationPayload(
+		notification.NotificationPayloadTypePasswordReset,
+		user.ID.String(),
+		notification.NotificationAuthenticationData{
+			Email: user.Email,
+			NotificationBaseData: notification.NotificationBaseData{
+				IP:      r.RemoteAddr,
+				Browser: r.UserAgent(),
+			},
+			UserName: user.Username,
+		},
+		notification.NotificationCategoryAuthentication,
+	))
+
 	utils.SendJSONResponse(w, "success", "Password reset successfully", nil)
 }
 

api/internal/features/notification/controller/add_smtp.go

@@ -0,0 +1,53 @@
+package controller
+
+import (
+	"net/http"
+
+	"github.com/raghavyuva/nixopus-api/internal/features/logger"
+	"github.com/raghavyuva/nixopus-api/internal/features/notification"
+	shared_types "github.com/raghavyuva/nixopus-api/internal/types"
+	"github.com/raghavyuva/nixopus-api/internal/utils"
+)
+
+// @Summary Add SMTP configuration
+// @Description Add SMTP configuration
+// @Tags notification
+// @Accept json
+// @Produce json
+// @Param SMTPConfigs body notification.CreateSMTPConfigRequest true "SMTP configuration"
+// @Success 200 {object} types.Response "SMTP added successfully"
+// @Failure 400 {object} types.Response "Bad request"
+// @Failure 500 {object} types.Response "Internal server error"
+// @Router /notification/add-smtp [post]
+func (c *NotificationController) AddSmtp(w http.ResponseWriter, r *http.Request) {
+	var SMTPConfigs notification.CreateSMTPConfigRequest
+	if err := c.validator.ParseRequestBody(r, r.Body, &SMTPConfigs); err != nil {
+		c.logger.Log(logger.Error, shared_types.ErrFailedToDecodeRequest.Error(), err.Error())
+		utils.SendErrorResponse(w, shared_types.ErrFailedToDecodeRequest.Error(), http.StatusBadRequest)
+		return
+	}
+
+	if err := c.validator.ValidateRequest(SMTPConfigs); err != nil {
+		c.logger.Log(logger.Error, err.Error(), "")
+		utils.SendErrorResponse(w, err.Error(), http.StatusBadRequest)
+		return
+	}
+
+	userAny := r.Context().Value(shared_types.UserContextKey)
+	user, ok := userAny.(*shared_types.User)
+
+	if !ok {
+		c.logger.Log(logger.Error, shared_types.ErrFailedToGetUserFromContext.Error(), shared_types.ErrFailedToGetUserFromContext.Error())
+		utils.SendErrorResponse(w, shared_types.ErrFailedToGetUserFromContext.Error(), http.StatusInternalServerError)
+		return
+	}
+
+	err := c.service.AddSmtp(SMTPConfigs,user.ID)
+	if err != nil {
+		c.logger.Log(logger.Error, err.Error(), "")
+		utils.SendErrorResponse(w, err.Error(), http.StatusInternalServerError)
+		return
+	}
+
+	utils.SendJSONResponse(w, "success", "SMTP added successfully", nil)
+}

api/internal/features/notification/controller/delete_smtp.go

@@ -0,0 +1,45 @@
+package controller
+
+import (
+	"net/http"
+
+	"github.com/raghavyuva/nixopus-api/internal/features/logger"
+	"github.com/raghavyuva/nixopus-api/internal/features/notification"
+	"github.com/raghavyuva/nixopus-api/internal/utils"
+
+	shared_types "github.com/raghavyuva/nixopus-api/internal/types"
+)
+
+// @Summary Delete SMTP configuration
+// @Description Delete SMTP configuration
+// @Tags notification
+// @Accept json
+// @Produce json
+// @Param SMTPConfigs body notification.DeleteSMTPConfigRequest true "SMTP configuration"
+// @Success 200 {object} types.Response "SMTP deleted successfully"
+// @Failure 400 {object} types.Response "Bad request"
+// @Failure 500 {object} types.Response "Internal server error"
+// @Router /notification/delete-smtp [post]
+func (c *NotificationController) DeleteSmtp(w http.ResponseWriter, r *http.Request) {
+	var SMTPConfigs notification.DeleteSMTPConfigRequest
+	if err := c.validator.ParseRequestBody(r, r.Body, &SMTPConfigs); err != nil {
+		c.logger.Log(logger.Error, shared_types.ErrFailedToDecodeRequest.Error(), err.Error())
+		utils.SendErrorResponse(w, shared_types.ErrFailedToDecodeRequest.Error(), http.StatusBadRequest)
+		return
+	}
+
+	if err := c.validator.ValidateRequest(SMTPConfigs); err != nil {
+		c.logger.Log(logger.Error, err.Error(), "")
+		utils.SendErrorResponse(w, err.Error(), http.StatusBadRequest)
+		return
+	}
+
+	err := c.service.DeleteSmtp(SMTPConfigs.ID.String())
+	if err != nil {
+		c.logger.Log(logger.Error, err.Error(), "")
+		utils.SendErrorResponse(w, err.Error(), http.StatusInternalServerError)
+		return
+	}
+
+	utils.SendJSONResponse(w, "success", "SMTP deleted successfully", nil)
+}

api/internal/features/notification/controller/get_smtp.go

@@ -0,0 +1,37 @@
+package controller
+
+import (
+	"github.com/raghavyuva/nixopus-api/internal/features/logger"
+	"github.com/raghavyuva/nixopus-api/internal/utils"
+	"net/http"
+
+	shared_types "github.com/raghavyuva/nixopus-api/internal/types"
+)
+
+// @Summary Get SMTP configuration
+// @Description Get SMTP configuration
+// @Tags notification
+// @Accept json
+// @Produce json
+// @Success 200 {object} types.Response "SMTP configuration"
+// @Failure 400 {object} types.Response "Bad request"
+// @Failure 500 {object} types.Response "Internal server error"
+// @Router /notification/get-smtp [get]
+func (c *NotificationController) GetSmtp(w http.ResponseWriter, r *http.Request) {
+	userAny := r.Context().Value(shared_types.UserContextKey)
+	user, ok := userAny.(*shared_types.User)
+
+	if !ok {
+		c.logger.Log(logger.Error, shared_types.ErrFailedToGetUserFromContext.Error(), shared_types.ErrFailedToGetUserFromContext.Error())
+		utils.SendErrorResponse(w, shared_types.ErrFailedToGetUserFromContext.Error(), http.StatusInternalServerError)
+		return
+	}
+	SMTPConfigs, err := c.service.GetSmtp(user.ID.String())
+	if err != nil {
+		c.logger.Log(logger.Error, err.Error(), "")
+		utils.SendErrorResponse(w, err.Error(), http.StatusInternalServerError)
+		return
+	}
+
+	utils.SendJSONResponse(w, "success", "SMTP configuration", SMTPConfigs)
+}

api/internal/features/notification/controller/init.go

@@ -0,0 +1,41 @@
+package controller
+
+import (
+	"context"
+
+	"github.com/raghavyuva/nixopus-api/internal/features/logger"
+	"github.com/raghavyuva/nixopus-api/internal/features/notification"
+	"github.com/raghavyuva/nixopus-api/internal/features/notification/service"
+	"github.com/raghavyuva/nixopus-api/internal/features/notification/validation"
+	shared_storage "github.com/raghavyuva/nixopus-api/internal/storage"
+)
+
+type NotificationController struct {
+	store        *shared_storage.Store
+	validator    *validation.Validator
+	service      *service.NotificationService
+	ctx          context.Context
+	logger       logger.Logger
+	notification *notification.NotificationManager
+}
+
+// NewNotificationController creates a new NotificationController with the given App.
+//
+// This function creates a new NotificationController with the given App and returns a pointer to it.
+//
+// The App passed to this function should be a valid App that has been created with storage.NewApp.
+func NewNotificationController(
+	store *shared_storage.Store,
+	ctx context.Context,
+	l logger.Logger,
+	notificationManager *notification.NotificationManager,
+) *NotificationController {
+	return &NotificationController{
+		store:        store,
+		validator:    validation.NewValidator(),
+		service:      service.NewNotificationService(store, ctx, l),
+		ctx:          ctx,
+		logger:       l,
+		notification: notificationManager,
+	}
+}