Function ProcessNotifications

worker/task/process_notifications.go:25–144

(sc smtp.SmtpClient)

var ErrInvalidNotificationType = errors.New("invalid notification type")

func ProcessNotifications(sc smtp.SmtpClient) func(context.Context, *asynq.Task) error {
	return func(ctx context.Context, t *asynq.Task) error {
		n := &notification.Notification{}
		err := msgpack.DecodeMsgPack(t.Payload(), &n)
		if err != nil {
			err := json.Unmarshal(t.Payload(), &n)
			if err != nil {
				// If unmarshal fails, try parsing as raw email.Message (backward compatibility)
				np := &email.Message{}
				err := msgpack.DecodeMsgPack(t.Payload(), np)
				if err != nil {
					err := json.Unmarshal(t.Payload(), np)
					if err != nil {
						return ErrInvalidNotificationPayload
					}
				}
				// Successfully parsed as email, process it
				if np.Email != "" {
					newEmail := email.NewEmail(sc)
					err = newEmail.Build(string(np.TemplateName), np.Params)
					if err != nil {
						return err
					}
					return newEmail.Send(np.Email, np.Subject)
				}
				return ErrInvalidNotificationPayload
			}
		}

		// If NotificationType is empty and Payload is nil/empty, try parsing original payload as raw email.Message
		payloadEmpty := n.Payload == nil
		if !payloadEmpty {
			// Check if payload is an empty map/interface
			if payloadMap, ok := n.Payload.(map[string]interface{}); ok && len(payloadMap) == 0 {
				payloadEmpty = true
			}
		}
		if n.NotificationType == "" && payloadEmpty {
			np := &email.Message{}
			err := msgpack.DecodeMsgPack(t.Payload(), np)
			if err != nil {
				err := json.Unmarshal(t.Payload(), np)
				if err != nil {
					return ErrInvalidNotificationPayload
				}
			}
			// Successfully parsed as email, process it
			if np.Email != "" {
				newEmail := email.NewEmail(sc)
				err = newEmail.Build(string(np.TemplateName), np.Params)
				if err != nil {
					return err
				}
				return newEmail.Send(np.Email, np.Subject)
			}
			return ErrInvalidNotificationPayload
		}