feat(notification): integrates discord and slack along with email, creates migrations, ui, and controllers and service files to add update delete the webhooks configs

Author: raghavyuva

api/doc/openapi.json

@@ -0,0 +1,52 @@
+package controller
+
+import (
+	"net/http"
+
+	"github.com/go-fuego/fuego"
+	"github.com/google/uuid"
+	"github.com/raghavyuva/nixopus-api/internal/features/notification"
+	"github.com/raghavyuva/nixopus-api/internal/utils"
+
+	shared_types "github.com/raghavyuva/nixopus-api/internal/types"
+)
+
+func (c *NotificationController) CreateWebhookConfig(f fuego.ContextWithBody[notification.CreateWebhookConfigRequest]) (*shared_types.Response, error) {
+	req, err := f.Body()
+	if err != nil {
+		return nil, fuego.HTTPError{
+			Err:    err,
+			Status: http.StatusBadRequest,
+		}
+	}
+
+	user := utils.GetUser(f.Response(), f.Request())
+	if user == nil {
+		return nil, fuego.HTTPError{
+			Err:    nil,
+			Status: http.StatusUnauthorized,
+		}
+	}
+
+	orgID := utils.GetOrganizationID(f.Request())
+	if orgID == uuid.Nil {
+		return nil, fuego.HTTPError{
+			Err:    nil,
+			Status: http.StatusUnauthorized,
+		}
+	}
+
+	config, err := c.service.CreateWebhookConfig(f, &req, user.ID, orgID)
+	if err != nil {
+		return nil, fuego.HTTPError{
+			Err:    err,
+			Status: http.StatusInternalServerError,
+		}
+	}
+
+	return &shared_types.Response{
+		Status:  "success",
+		Message: "Webhook config created successfully",
+		Data:    config,
+	}, nil
+}

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

@@ -0,0 +1,43 @@
+package controller
+
+import (
+	"net/http"
+
+	"github.com/go-fuego/fuego"
+	"github.com/google/uuid"
+	"github.com/raghavyuva/nixopus-api/internal/features/notification"
+	shared_types "github.com/raghavyuva/nixopus-api/internal/types"
+	"github.com/raghavyuva/nixopus-api/internal/utils"
+)
+
+func (c *NotificationController) DeleteWebhookConfig(f fuego.ContextWithBody[notification.DeleteWebhookConfigRequest]) (*shared_types.Response, error) {
+	req, err := f.Body()
+	if err != nil {
+		return nil, fuego.HTTPError{
+			Err:    err,
+			Status: http.StatusBadRequest,
+		}
+	}
+
+	orgID := utils.GetOrganizationID(f.Request())
+	if orgID == uuid.Nil {
+		return nil, fuego.HTTPError{
+			Err:    nil,
+			Status: http.StatusUnauthorized,
+		}
+	}
+
+	err = c.service.DeleteWebhookConfig(f, &req, orgID)
+	if err != nil {
+		return nil, fuego.HTTPError{
+			Err:    err,
+			Status: http.StatusInternalServerError,
+		}
+	}
+
+	return &shared_types.Response{
+		Status:  "success",
+		Message: "Webhook config deleted successfully",
+		Data:    nil,
+	}, nil
+}

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

@@ -0,0 +1,38 @@
+package controller
+
+import (
+	"net/http"
+
+	"github.com/go-fuego/fuego"
+	"github.com/google/uuid"
+	"github.com/raghavyuva/nixopus-api/internal/features/notification"
+	"github.com/raghavyuva/nixopus-api/internal/utils"
+
+	shared_types "github.com/raghavyuva/nixopus-api/internal/types"
+)
+
+func (c *NotificationController) GetWebhookConfig(f fuego.ContextNoBody) (*shared_types.Response, error) {
+	orgID := utils.GetOrganizationID(f.Request())
+	if orgID == uuid.Nil {
+		return nil, fuego.HTTPError{
+			Err:    nil,
+			Status: http.StatusUnauthorized,
+		}
+	}
+
+	webhookType := f.PathParam("type")
+
+	config, err := c.service.GetWebhookConfig(f, &notification.GetWebhookConfigRequest{Type: webhookType}, orgID)
+	if err != nil {
+		return nil, fuego.HTTPError{
+			Err:    err,
+			Status: http.StatusInternalServerError,
+		}
+	}
+
+	return &shared_types.Response{
+		Status:  "success",
+		Message: "Webhook config retrieved successfully",
+		Data:    config,
+	}, nil
+}

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

@@ -0,0 +1,44 @@
+package controller
+
+import (
+	"net/http"
+
+	"github.com/go-fuego/fuego"
+	"github.com/google/uuid"
+	"github.com/raghavyuva/nixopus-api/internal/features/notification"
+	"github.com/raghavyuva/nixopus-api/internal/utils"
+
+	shared_types "github.com/raghavyuva/nixopus-api/internal/types"
+)
+
+func (c *NotificationController) UpdateWebhookConfig(f fuego.ContextWithBody[notification.UpdateWebhookConfigRequest]) (*shared_types.Response, error) {
+	req, err := f.Body()
+	if err != nil {
+		return nil, fuego.HTTPError{
+			Err:    err,
+			Status: http.StatusBadRequest,
+		}
+	}
+
+	orgID := utils.GetOrganizationID(f.Request())
+	if orgID == uuid.Nil {
+		return nil, fuego.HTTPError{
+			Err:    nil,
+			Status: http.StatusUnauthorized,
+		}
+	}
+
+	config, err := c.service.UpdateWebhookConfig(f, &req, orgID)
+	if err != nil {
+		return nil, fuego.HTTPError{
+			Err:    err,
+			Status: http.StatusInternalServerError,
+		}
+	}
+
+	return &shared_types.Response{
+		Status:  "success",
+		Message: "Webhook config updated successfully",
+		Data:    config,
+	}, nil
+}

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

@@ -3,16 +3,19 @@ package notification
 import (
 	"bytes"
 	"context"
+	"encoding/json"
 	"fmt"
 	"html/template"
 	"log"
+	"net/http"
 	"net/smtp"
 	"os"
 	"path/filepath"
 	"time"
 
 	"github.com/google/uuid"
 	shared_types "github.com/raghavyuva/nixopus-api/internal/types"
+	"github.com/slack-go/slack"
 	"github.com/uptrace/bun"
 )
 
@@ -67,12 +70,16 @@ func (m *NotificationManager) Start() {
 						fmt.Printf("Password Reset Notification - %+v", payload)
 						if data, ok := payload.Data.(NotificationPasswordResetData); ok {
 							m.SendPasswordResetEmail(payload.UserID, data.Token)
+							m.SendSlackNotification(payload.UserID, "Password reset requested")
+							m.SendDiscordNotification(payload.UserID, "Password reset requested")
 						}
 					}
 					if payload.Type == NotificationPayloadTypeVerificationEmail {
 						fmt.Printf("Verification Email Notification - %+v", payload)
 						if data, ok := payload.Data.(NotificationVerificationEmailData); ok {
 							m.SendVerificationEmail(payload.UserID, data.Token)
+							m.SendSlackNotification(payload.UserID, "Email verification requested")
+							m.SendDiscordNotification(payload.UserID, "Email verification requested")
 						}
 					}
 				case NotificationCategoryOrganization:
@@ -81,6 +88,8 @@ func (m *NotificationManager) Start() {
 						fmt.Printf("Update User Role Notification - %+v", payload)
 						if data, ok := payload.Data.(NotificationOrganizationData); ok {
 							m.SendUpdateUserRoleEmail(payload.UserID, data.OrganizationID, data.UserID)
+							m.SendSlackNotification(payload.UserID, fmt.Sprintf("User role updated in organization %s", data.OrganizationID))
+							m.SendDiscordNotification(payload.UserID, fmt.Sprintf("User role updated in organization %s", data.OrganizationID))
 						}
 					}
 				}
@@ -320,3 +329,46 @@ func (m *NotificationManager) GetSmtp(ID string) (*shared_types.SMTPConfigs, err
 	}
 	return config, nil
 }
+
+func (m *NotificationManager) SendSlackNotification(userID string, message string) error {
+	if m.Channels.Slack == nil || m.Channels.Slack.SlackClient == nil {
+		return nil
+	}
+
+	_, _, err := m.Channels.Slack.SlackClient.PostMessage(
+		m.Channels.Slack.ChannelID,
+		slack.MsgOptionText(message, false),
+	)
+	if err != nil {
+		return fmt.Errorf("failed to send slack notification: %w", err)
+	}
+
+	return nil
+}
+
+func (m *NotificationManager) SendDiscordNotification(userID string, message string) error {
+	if m.Channels.Discord == nil || m.Channels.Discord.WebhookUrl == "" {
+		return nil
+	}
+
+	payload := map[string]interface{}{
+		"content": message,
+	}
+
+	jsonData, err := json.Marshal(payload)
+	if err != nil {
+		return fmt.Errorf("failed to marshal discord payload: %w", err)
+	}
+
+	resp, err := http.Post(m.Channels.Discord.WebhookUrl, "application/json", bytes.NewBuffer(jsonData))
+	if err != nil {
+		return fmt.Errorf("failed to send discord message: %w", err)
+	}
+	defer resp.Body.Close()
+
+	if resp.StatusCode != http.StatusOK && resp.StatusCode != http.StatusNoContent {
+		return fmt.Errorf("discord webhook returned non-200 status code: %d", resp.StatusCode)
+	}
+
+	return nil
+}