Войти Регистрация
Код-ревью

7. Массовая отправка push-уведомлений

Сложная

Go · 56 строк

SendAll отправляет пачку уведомлений через HTTP-провайдера и считает, сколько push ушло каждому клиенту. В обычный день в пачке 5–20 тысяч уведомлений, в день зарплаты — до 2 млн.

Отметьте строки с ошибками. Код собирается Go 1.22.

В работе: Уведомления о списаниях и зачислениях: клиент ждёт push через секунды после операции.

Как проверяем Нажмите на строку с ошибкой и коротко напишите, что не так. Баг засчитан, если отмечена хотя бы одна его строка. Зачёт — найдено не меньше 60 % багов с учётом серьёзности (критичный весит 3, обычный 2, мелкий 1), а лишних отметок не больше, чем багов в коде. Пустые строки, скобки и комментарии лишними не считаем. Ответ один на подход: после него показываем разбор.
горутиныканалыHTTP-клиентгонка на map

Источник: на задачах Сбера: push-уведомления о платежах. Условие пересказано своими словами.

Давали на собеседовании? Ответов пока мало — ваш поможет.
  1. package push
  3. import (
  4. "bytes"
  5. "encoding/json"
  6. "fmt"
  7. "log"
  8. "net/http"
  9. "sync"
  10. )
  12. type Notification struct {
  13. ClientID string
  14. Phone string
  15. Text string
  16. }
  18. type Sender struct {
  19. client *http.Client
  20. url string
  21. sent map[string]int
  22. }
  24. func NewSender(url string) *Sender {
  25. return &Sender{client: &http.Client{}, url: url, sent: map[string]int{}}
  26. }
  28. func (s *Sender) SendAll(batch []Notification) error {
  29. var wg sync.WaitGroup
  30. errs := make(chan error)
  31. for _, n := range batch {
  32. wg.Add(1)
  33. go func() {
  34. defer wg.Done()
  35. body, _ := json.Marshal(n)
  36. resp, err := s.client.Post(s.url, "application/json", bytes.NewReader(body))
  37. if err != nil {
  38. log.Printf("push failed for %s: %v", n.Phone, err)
  39. errs <- err
  40. return
  41. }
  42. if resp.StatusCode != http.StatusOK {
  43. errs <- fmt.Errorf("push status %d", resp.StatusCode)
  44. return
  45. }
  46. resp.Body.Close()
  47. s.sent[n.ClientID]++
  48. }()
  49. }
  50. wg.Wait()
  51. close(errs)
  52. for err := range errs {
  53. return err
  54. }
  55. return nil
  56. }