notification smtp configuration api integration

Author: raghavyuva

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

@@ -33,7 +33,16 @@ func (c *NotificationController) AddSmtp(w http.ResponseWriter, r *http.Request)
 		return
 	}
 
-	err := c.service.AddSmtp(SMTPConfigs)
+	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)

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

@@ -1,12 +1,13 @@
 package service
 
 import (
+	"github.com/google/uuid"
 	"github.com/raghavyuva/nixopus-api/internal/features/logger"
 	"github.com/raghavyuva/nixopus-api/internal/features/notification"
 )
 
-func (s *NotificationService) AddSmtp(SMTPConfigs notification.CreateSMTPConfigRequest) error {
+func (s *NotificationService) AddSmtp(SMTPConfigs notification.CreateSMTPConfigRequest, userID uuid.UUID) error {
 	s.logger.Log(logger.Info, "Adding SMTP configuration", "")
-	config := notification.NewSMTPConfig(&SMTPConfigs)
+	config := notification.NewSMTPConfig(&SMTPConfigs, userID)
 	return s.storage.AddSmtp(config)
 }

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

@@ -20,14 +20,14 @@ func (s NotificationStorage) AddSmtp(config *shared_types.SMTPConfigs) error {
 }
 
 func (s NotificationStorage) UpdateSmtp(config *notification.UpdateSMTPConfigRequest) error {
-	var smtp shared_types.SMTPConfigs
+	var smtp *shared_types.SMTPConfigs
 	_, err := s.DB.NewUpdate().Model(smtp).
-		SetColumn("host", config.Host).
-		SetColumn("port", strconv.Itoa(config.Port)).
-		SetColumn("username", config.Username).
-		SetColumn("password", config.Password).
-		SetColumn("from_name", config.FromName).
-		SetColumn("from_email", config.FromEmail).
+		Set("host = ?", config.Host).
+		Set("port = ?", strconv.Itoa(config.Port)).
+		Set("username = ?", config.Username).
+		Set("password = ?", config.Password).
+		Set("from_name = ?", config.FromName).
+		Set("from_email = ?", config.FromEmail).
 		Where("id = ?", config.ID).Exec(s.Ctx)
 	return err
 }

api/internal/features/notification/types.go

@@ -110,7 +110,6 @@ type CreateSMTPConfigRequest struct {
 	Password  string    `json:"password"`
 	FromName  string    `json:"from_name"`
 	FromEmail string    `json:"from_email"`
-	UserID    uuid.UUID `json:"user_id"`
 }
 
 type UpdateSMTPConfigRequest struct {
@@ -140,7 +139,7 @@ var (
 	ErrMissingID          = errors.New("id is required")
 )
 
-func NewSMTPConfig(c *CreateSMTPConfigRequest) *shared_types.SMTPConfigs {
+func NewSMTPConfig(c *CreateSMTPConfigRequest,userID uuid.UUID) *shared_types.SMTPConfigs {
 	if c.FromEmail == "" {
 		c.FromEmail = c.Username
 	}
@@ -155,6 +154,7 @@ func NewSMTPConfig(c *CreateSMTPConfigRequest) *shared_types.SMTPConfigs {
 		Password:  c.Password,
 		FromName:  c.FromName,
 		FromEmail: c.FromEmail,
-		UserID:    c.UserID,
+		UserID:    userID,
+		ID:        uuid.New(),
 	}
 }

view/app/settings/hooks/use-notification-settings.ts

@@ -0,0 +1,53 @@
+import {
+    useCreateSMPTConfigurationMutation,
+    useGetSMTPConfigurationsQuery,
+    useUpdateSMTPConfigurationMutation
+} from '@/redux/services/settings/notification';
+import { CreateSMTPConfigRequest, UpdateSMTPConfigRequest } from '@/redux/types/notification';
+import { toast } from 'sonner';
+
+function useNotificationSettings() {
+    const { data: smtpConfigs, isLoading, error } = useGetSMTPConfigurationsQuery();
+    const [createSMTPConfiguration, { isLoading: isCreating }] = useCreateSMPTConfigurationMutation();
+    const [updateSMTPConfiguration, { isLoading: isUpdating }] = useUpdateSMTPConfigurationMutation();
+
+    const handleCreateSMTPConfiguration = async (data: CreateSMTPConfigRequest) => {
+        await createSMTPConfiguration(data);
+    };
+
+    const handleUpdateSMTPConfiguration = async (data: UpdateSMTPConfigRequest) => {
+        await updateSMTPConfiguration(data);
+    };
+
+    const handleOnSave = async (data: any) => {
+        try {
+            const smtpConfig = {
+                host: data.smtpServer,
+                port: parseInt(data.port),
+                username: data.username,
+                password: data.password,
+                from_email: data.fromEmail,
+                from_name: data.fromName
+            }
+            if (smtpConfigs?.id) {
+                await handleUpdateSMTPConfiguration({ ...smtpConfig, id: smtpConfigs?.id, });
+            } else {
+                await handleCreateSMTPConfiguration(smtpConfig);
+            }
+            toast.success('Email configuration saved successfully');
+        } catch (error) {
+            toast.error('Failed to save email configuration');
+        }
+    };
+
+    return {
+        smtpConfigs,
+        isLoading,
+        error,
+        isCreating,
+        isUpdating,
+        handleOnSave
+    };
+}
+
+export default useNotificationSettings;