Как правильно использовать cable?

Question

[Заур Ашурбеков]

Здравствуй, Тостер!
В rails 5 появился удобный cable для вебсокетов, но меня мучает как правильно организовывать процесс обмена данных и их обработки. Где можно почитать про это? К примеру, кейс - комментарии для постов в вк: я подгрузил 30 последних новостей.
1) Теперь я должен оформить подписку на изменения на все 30 новостей по отдельности? Хорошо, у меня в друзьях 300чел, я буду оформлять подписку на каждый чат сообщений?
2) Как создавать новый коммент: через restful интерфейс, а потом через broadcast транслировать? Или через каналы, создав/изменив/удалив новый коммент внутри?
3) Как правильно организовывать доступ пользователей к подпискам?

Answer 1

[Andrey Demidenko]

1) Оформлять подписку нужно по id на конкретного пользователя, если появится новое сообщение(новость и т.д) мы его не получим, т.к на этот диалог(новость) ты не был подписан.

Пример подписки

def subscribed
  stop_all_streams
  stream_from "conversations:#{current_user.id}"
end

2) Можно и так и так.
3) Пример авторизации пользователя для devise

module ApplicationCable
  class Connection < ActionCable::Connection::Base
    identified_by :current_user

    def connect
      self.current_user = find_verified_user
      logger.add_tags 'ActionCable', "User #{current_user.id}"
    end

    protected

    def find_verified_user
      if (verified_user = env['warden'].user)
        verified_user
      else
        reject_unauthorized_connection
      end
    end
  end
end

Comments

[Заур Ашурбеков]

Мне как раз интересно, от того, что будет прорва подписок на сервере, сервер тормозиться не начнет? Вот ты представь 1000 чел подписались на 100 событий каждый. 100к поддерживаемых каналов

[Заур Ашурбеков]

3) это у меня почему-то не заработало, пришлось какой-то костыль в файле конфиг делать, помню через класс wargen кажется. Поэтому спрашивал

[Andrey Demidenko]

Заур Ашурбеков, Если боитесь за на нагрузку на основной сервер, попробуйте anycable

[Заур Ашурбеков]

Andrey Demidenko, спс))