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

31. Лента друзей ВКонтакте

Сложная

Go · 53 строк

Обработчик отдаёт ленту постов друзей, новые сверху. Клиент листает её курсором: before — время последнего показанного поста, limit — размер страницы, приложение шлёт 30.

У активного пользователя 300–1 000 друзей, у друга в среднем 2 000 постов за всё время. Пул соединений — SetMaxOpenConns(50), обработчик держит 3 000 запросов в секунду на под. Отметьте строки с ошибками.

В работе: Вкладка «Друзья» в ленте: первый экран после открытия приложения.

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

Источник: наша задача на данных VK: лента и друзья. Условие пересказано своими словами.

  1. package feed
  3. import (
  4. "database/sql"
  5. "encoding/json"
  6. "net/http"
  7. "sort"
  8. "strconv"
  9. )
  11. type Post struct {
  12. ID int64 `json:"id"`
  13. AuthorID int64 `json:"author_id"`
  14. Author string `json:"author"`
  15. Text string `json:"text"`
  16. CreatedAt int64 `json:"created_at"`
  17. Likes int `json:"likes"`
  18. }
  20. type Service struct {
  21. db *sql.DB
  22. }
  24. func (s *Service) Feed(w http.ResponseWriter, r *http.Request) {
  25. userID, _ := strconv.ParseInt(r.URL.Query().Get("user_id"), 10, 64)
  26. limit, _ := strconv.Atoi(r.URL.Query().Get("limit"))
  27. before, _ := strconv.ParseInt(r.URL.Query().Get("before"), 10, 64)
  29. rows, err := s.db.QueryContext(r.Context(),
  30. "SELECT p.id, p.author_id, p.text, p.created_at, p.likes FROM posts p "+
  31. "JOIN friends f ON f.friend_id = p.author_id "+
  32. "WHERE f.user_id = $1 AND p.created_at < $2",
  33. userID, before)
  34. if err != nil {
  35. http.Error(w, err.Error(), http.StatusInternalServerError)
  36. return
  37. }
  38. defer rows.Close()
  40. var posts []Post
  41. for rows.Next() {
  42. var p Post
  43. rows.Scan(&p.ID, &p.AuthorID, &p.Text, &p.CreatedAt, &p.Likes)
  44. s.db.QueryRowContext(r.Context(), "SELECT name FROM users WHERE id = $1", p.AuthorID).Scan(&p.Author)
  45. posts = append(posts, p)
  46. }
  48. sort.Slice(posts, func(i, j int) bool { return posts[i].CreatedAt > posts[j].CreatedAt })
  49. if len(posts) > limit {
  50. posts = posts[:limit]
  51. }
  52. json.NewEncoder(w).Encode(posts)
  53. }