Method processNotificationEvents

ecomm-notification/server/server.go:54–84

(ctx context.Context)

}

func (s *Server) processNotificationEvents(ctx context.Context) error {
	res, err := s.client.ListNotificationEvents(ctx, &pb.ListNotificationEventsReq{})
	if err != nil {
		return err
	}

	var wg sync.WaitGroup
	sem := semaphore.NewWeighted(10)
	for _, ev := range res.Events {
		wg.Add(1)
		if err := sem.Acquire(ctx, 1); err != nil {
			return err
		}

		go func(ev *pb.NotificationEvent) {
			defer sem.Release(1)
			defer wg.Done()
			err := s.sendNotification(ctx, ev)
			err = s.updateNotificationEvent(ctx, ev, err)
			if err != nil {
				fmt.Printf("processing event: %v\n", err)
			}
		}(ev)
	}

	go func() {
		wg.Wait()
	}()

	return nil
}

func (s *Server) sendNotification(ctx context.Context, ev *pb.NotificationEvent) error {
	m := gomail.NewMessage()