feat(email): add new email service protocol

Signed-off-by: Chayan Das <[email protected]>

Author: ChayanDass

pkg/email/admin.go

@@ -13,9 +13,8 @@ func FetchAdminEmails() ([]string, error) {
 	admin := "ADMIN"
 	err := db.DB.
 		Model(&models.User{}).
-		Where(&models.User{UserLevel: &admin}).
+		Where(&models.User{UserLevel: &admin}). // can add super_admin too
 		Pluck("user_email", &emails).Error
-
 	if err != nil {
 		return nil, err
 	}

pkg/email/email_service.go

@@ -35,14 +35,14 @@ type EmailService interface {
 
 type AsyncEmailService struct {
 	queue   chan EmailData
-	from    string // From address shown in emails
-	user    string // SMTP username (may differ from from)
+	from    string
+	user    string
 	pass    string
 	host    string
 	port    int
 	logger  *zap.Logger
 	wg      sync.WaitGroup
-	mu      sync.Mutex // protects running/closed
+	mu      sync.Mutex
 	running bool
 	closed  bool
 
@@ -209,16 +209,13 @@ func (s *AsyncEmailService) doSend(job EmailData) error {
 	}
 }
 
-// ctx allows timeout for shutdown.
 func (s *AsyncEmailService) Stop(ctx context.Context) error {
 	s.mu.Lock()
 	if s.closed {
 		s.mu.Unlock()
 		return nil
 	}
-	// mark closed so Queue() returns error
 	s.closed = true
-	// close queue to signal workers to finish
 	close(s.queue)
 	s.mu.Unlock()