RPC not broadcast message #162

Khamonluckssa · 2022-09-11T17:59:35Z

Khamonluckssa
Sep 11, 2022

Hi, i have set up any cable with docker and the message not broadcasting some how, i got this error

[2022-09-11 17:49:41.950] ERROR -- NotImplementedError: nil

and if i remove stream_from "room_channel_#{params[:room_id]}" the error is gone and i can connect to channel but it is not received the data

this is room_channel.js

import consumer from "./consumer"
document.addEventListener('turbolinks:load', () => {
  console.log("enter room_channel");
  const room_element = document.getElementById('room-id');
  console.log("room_element" + room_element);

  if(room_element){
    const room_id = room_element.getAttribute('data-room-id');
    console.log("room_id" + room_id);

    consumer.subscriptions.subscriptions.forEach((subscription) => {
      console.log("consumer" + consumer);
      console.log("subscription" + subscription);
      consumer.subscriptions.remove(subscription);
    })

    console.log("connect_room_id" + room_id);

    if(room_id){
      console.log("room id is exist_" + room_id);
      consumer.subscriptions.create({channel: "RoomChannel", room_id: room_id}, {
        connected() {
          console.log('connected' + room_id);
        },

        disconnected() {
          // Called when the subscription has been terminated by the server
        },

        received(data) {
          console.log(data);

          const user_element = document.getElementById('chat-user-id');
          const user_id = user_element.getAttribute('data-chat-user-id');

          let html;

          if(user_id === data.user_id){
            html = data.mine
          }else{
            html = data.theris
          }

          const messageContainer = document.querySelector("#messages:last-child")
          messageContainer.innerHTML = messageContainer.innerHTML + html

          //reset text box
          
          var text_box = document.getElementById('message_content');
          text_box.value = "";
          // Called when there's incoming data on the websocket for this channel
        }
      });
    }
  
  }
 

})

my room_channel.rb

class RoomChannel < ApplicationCable::Channel
  state_attr_accessor :room

  def subscribed
    stream_from "room_channel_#{params[:room_id]}"
  end

  def unsubscribed
    Rails.logger.info("---unsubscribed ---")
  end
end

this is docker-compose

version: "3"

volumes:
  data-uploads:
  packs:
services:
  app:
    build:
      context: .
      dockerfile: ./dockers/app/Dockerfile
    container_name: comp_moto_app
    restart: unless-stopped
    ports:
      - 3000:3000
    volumes:
      - .:/app
      - /app/node_modules
      - /app/public/assets
      - /app/public/packs
    depends_on:
      - redis
    environment:
      - REDIS_URL_CACHING=redis://redis@redis:6379/0
  db:
    image: "postgres:14.1-alpine"
    container_name: comp_moto_db
    environment:
      POSTGRES_USER: ${DOCKER_DB_USER}
      POSTGRES_PASSWORD: ${DOCKER_DB_PASSWORD}
      POSTGRES_DB: ${DOCKER_DB_NAME}
    volumes:
      - /docker_data/comp_moto_app/postgres:/var/lib/postgresql/data
    ports:
      - 5432:5432
  nginx:
    build:
      context: .
      dockerfile: ./dockers/web/Dockerfile
    container_name: comp_moto_web
    restart: unless-stopped
    ports:
      - 80:80
      - 443:443
    depends_on:
      - app
    volumes:
      - ./dockers/web/nginx.conf:/etc/nginx/conf.d/default.conf
      - ./public:/app/public
      - ./data/certbot/conf:/etc/letsencrypt
      - ./data/certbot/www:/var/www/certbot
    command: "/bin/sh -c 'while :; do sleep 6h & wait $${!}; nginx -s reload; done & nginx -g \"daemon off;\"'"
  certbot:
    image: certbot/certbot
    restart: unless-stopped
    volumes:
      - ./data/certbot/conf:/etc/letsencrypt
      - ./data/certbot/www:/var/www/certbot
    entrypoint: "/bin/sh -c 'trap exit TERM; while :; do certbot renew; sleep 12h & wait $${!}; done;'"
  redis:
    image: redis:6.2.6-alpine
    container_name: comp_moto_redis
    command: redis-server --requirepass ${REDIS_PASSWORD}
    volumes:
      - /docker_data/comp_moto/production/redis:/data
      - ./dockers/redis/redis.conf:/usr/local/etc/redis/redis.conf
    ports:
      - 6379:6379
  delayed_job:
    build:
      context: .
      dockerfile: ./dockers/delayed_job/Dockerfile
    container_name: comp_moto_delayed_job
    command: bundle exec rails jobs:work
    depends_on:
      - db
    volumes:
      - .:/app    
  anycable:
    build:
      context: .
      dockerfile: ./dockers/cable/Dockerfile
    container_name: comp_moto_anycable
    command: bundle exec anycable 
    environment:
      ANYCABLE_REDIS_URL: redis://redis@redis:6379/0
      ANYCABLE_RPC_HOST: 0.0.0.0:50051
      ANYCABLE_DEBUG: 1
    ports:
      - '50051:50051'
    depends_on:
      - redis
      - db
  ws: 
    image:  anycable/anycable-go:latest-alpine
    command: anycable-go 
    container_name: comp_moto_ws
    ports:
      - '8080:8080'
    environment: 
      ANYCABLE_HOST: "0.0.0.0"
      ANYCABLE_PORT: 8080
      ANYCABLE_REDIS_URL: redis://redis@redis:6379/0
      ANYCABLE_RPC_HOST: anycable:50051
      ANYCABLE_DEBUG: 1
    depends_on:
      - redis
      - anycable
  sidekiq:
    build:
      context: .
      dockerfile: ./dockers/sidekiq/Dockerfile
    container_name: comp_moto_sidekiq
    command: bundle exec sidekiq
    depends_on:
      - db
      - redis
    volumes:
       - data-uploads:/app/public/uploads

this is log for anycable-go container, is it running?

D 2022-09-11T17:49:31.753Z context=main 🔧 🔧 🔧 Debug mode is on 🔧 🔧 🔧
I 2022-09-11T17:49:31.753Z context=main Starting AnyCable 1.2.2-4ef479c (pid: 1, open file limit: 1048576, gomaxprocs: 4)
D 2022-09-11T17:49:31.753Z context=disconnector Calls rate: 10ms         
I 2022-09-11T17:49:31.756Z context=rpc RPC controller initialized: anycable:50051 (concurrency: 28, enable_tls: false, proto_versions: v1)
I 2022-09-11T17:49:31.756Z context=main Handle WebSocket connections at http://0.0.0.0:8080/cable
I 2022-09-11T17:49:31.756Z context=main Handle health connections at http://0.0.0.0:8080/health
D 2022-09-11T17:49:31.756Z context=main Go pools initialized (broadcast: 16)
D 2022-09-11T17:49:31.756Z context=http Starting WebSocket server at http://0.0.0.0:8080
D 2022-09-11T17:49:31.756Z context=metrics No metrics writers. Disable metrics rotation
I 2022-09-11T17:49:31.850Z context=pubsub Subscribed to Redis channel: __anycable__

this is log for anycable (normally when the message broadcast message, it should called RPC Connect right? because on my local it show log RPC Connect but on production this log is nothing like below)

Starting AnyCable RPC server (pid: 1)
AnyCable version: 1.2.3 (proto_version: v1)
Serving Rails application from ./config/environment.rb
gRPC version: 1.48.0
handling /anycable.RPC/Connect with #<Method: AnyCable::GRPC::Handler#connect(request, call) /usr/local/bundle/gems/anycable-core-1.2.3/lib/anycable/grpc/handler.rb:12>
handling /anycable.RPC/Command with #<Method: AnyCable::GRPC::Handler#command(request, call) /usr/local/bundle/gems/anycable-core-1.2.3/lib/anycable/grpc/handler.rb:20>
handling /anycable.RPC/Disconnect with #<Method: AnyCable::GRPC::Handler#disconnect(request, call) /usr/local/bundle/gems/anycable-core-1.2.3/lib/anycable/grpc/handler.rb:16>
handling /grpc.health.v1.Health/Check with #<Method: Grpc::Health::Checker#check(req, _call) /usr/local/bundle/gems/grpc-1.48.0-x86_64-linux/src/ruby/pb/grpc/health/checker.rb:34>
handling /grpc.health.v1.Health/Watch with #<Method: Grpc::Health::Checker(Grpc::Health::V1::Health::Service)#watch(*) /usr/local/bundle/gems/grpc-1.48.0-x86_64-linux/src/ruby/lib/grpc/generic/service.rb:99>
Broadcasting Redis channel: __anycable__
RPC server is starting...
RPC server is listening on 0.0.0.0:50051 (workers_num: 30)

palkan · 2022-09-11T23:39:47Z

palkan
Sep 11, 2022
Maintainer

Hey!
Can you share your cable.yml, please? Does it have adapter set to any_cable?

11 replies

dmgrinko1 Oct 12, 2022

Hi @palkan thank you for quick responce
ruby '3.1.2'
gem 'rails', '~> 6.1', '>= 6.1.6.1'

cable.yml

   development:
     adapter: <%= ENV.fetch("ACTION_CABLE_ADAPTER", "any_cable") %>
     channel_prefix: 5andgo_development
   test:
      adapter: test
   production:
      adapter: <%= ENV.fetch("ACTION_CABLE_ADAPTER", "any_cable") %> 
      channel_prefix: 5andgo_production

development.rb

  config.after_initialize do
    if AnyCable::Rails.enabled?
       config.action_cable.url = ActionCable.server.config.url = ENV.fetch('CABLE_URL', 'ws://localhost:8080/cable')
    end
  end

ActionCable.server.pubsub

    #<ActionCable::SubscriptionAdapter::AnyCable:0x00000001107a51f0>

anycable.yml

default: &default
  access_logs_disabled: false
  rpc_host: "127.0.0.1:50051"
  log_grpc: false
  broadcast_adapter: redis
  redis_channel: "__anycable__"

development:
  <<: *default
  redis_url: redis://localhost:6379/3
test:
  <<: *default
production:
  <<: *default
  redis_url: redis://redis-service:6379/3

bundle exec anycable

Starting AnyCable RPC server (pid: 48512)
AnyCable version: 1.2.3 (proto_version: v1)
Serving Rails application from ./config/environment.rb
gRPC version: 1.49.1
Broadcasting Redis channel: __anycable__
RPC server is starting...
RPC server is listening on 127.0.0.1:50051 (workers_num: 30)

anycable-go --port=8080

INFO 2022-10-12T05:06:10.848Z context=main Starting AnyCable 1.2.1 (pid: 48762, open file limit: 10240, gomaxprocs: 8)
  INFO 2022-10-12T05:06:10.849Z context=rpc RPC controller initialized: localhost:50051 (concurrency: 28, enable_tls: false, proto_versions: v1)
  INFO 2022-10-12T05:06:10.849Z context=main Handle WebSocket connections at http://localhost:8080/cable
  INFO 2022-10-12T05:06:10.849Z context=main Handle health connections at http://localhost:8080/health
  INFO 2022-10-12T05:06:10.855Z context=pubsub Subscribed to Redis channel: __anycable__

log

Started GET "/cable/" [WebSocket] for 127.0.0.1 at 2022-10-12 09:01:35 +0400
Successfully upgraded to WebSocket (REQUEST_METHOD: GET, HTTP_CONNECTION: Upgrade, HTTP_UPGRADE: websocket)
[2022-10-12 05:01:35 UTC] Websocket event occured: #<struct WebSocket::Driver::OpenEvent>
source=rack-timeout id=17e8f0f8-c30b-4785-95ff-adfb687c818c timeout=15000ms service=463ms state=completed
Registered connection (BQoar_K25GOVqSF6zWDYHQ)
[2022-10-12 09:01:35.988] ERROR -- NotImplementedError: nil
[2022-10-12 05:01:38 UTC] Websocket beat transmitted
[2022-10-12 05:01:41 UTC] Websocket beat transmitted
[2022-10-12 05:01:44 UTC] Websocket beat transmitted
[2022-10-12 05:01:45 UTC] Websocket event occured: #<struct WebSocket::Driver::MessageEvent data="{\"command\":\"subscribe\",\"identifier\":\"{\\\"channel\\\":\\\"NotificationChannel\\\"}\"}">
[2022-10-12 09:01:45.838] ERROR -- NotImplementedError: nil
[2022-10-12 05:01:47 UTC] Websocket beat transmitted

and on close event

[2022-10-12 05:07:15 UTC] Websocket beat transmitted
[2022-10-12 05:07:17 UTC] Websocket close occured: reason - , code - 1000
[2022-10-12 05:07:17 UTC] Websocket event occured: #<struct WebSocket::Driver::CloseEvent code=1000, reason="">
Finished "/cable/" [WebSocket] for 127.0.0.1 at 2022-10-12 09:07:17 +0400
There was an exception - NotImplementedError(NotImplementedError)
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/subscription_adapter/base.rb:25:in `unsubscribe'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/channel/streams.rb:122:in `block in stop_all_streams'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/channel/streams.rb:121:in `each'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/channel/streams.rb:121:in `stop_all_streams'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/anycable-rails-1.3.4/lib/anycable/rails/action_cable_ext/channel.rb:38:in `stop_all_streams'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:427:in `block in make_lambda'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:270:in `block in simple'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:516:in `block in invoke_after'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:516:in `each'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:516:in `invoke_after'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:131:in `block in run_callbacks'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/sentry-rails-5.4.2/lib/sentry/rails/action_cable.rb:21:in `block in capture'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/sentry-ruby-5.4.2/lib/sentry/hub.rb:59:in `with_scope'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/sentry-ruby-5.4.2/lib/sentry-ruby.rb:352:in `with_scope'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/sentry-rails-5.4.2/lib/sentry/rails/action_cable.rb:13:in `capture'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/sentry-rails-5.4.2/lib/sentry/rails/action_cable.rb:78:in `sentry_capture'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/sentry-rails-5.4.2/lib/sentry/rails/action_cable.rb:69:in `block (2 levels) in included'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:126:in `instance_exec'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:126:in `block in run_callbacks'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/execution_wrapper.rb:87:in `wrap'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/engine.rb:68:in `block (3 levels) in <class:Engine>'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:126:in `instance_exec'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:126:in `block in run_callbacks'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:137:in `run_callbacks'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/anycable-rails-1.3.4/lib/anycable/rails/compatibility.rb:31:in `block in run_callbacks'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/anycable-rails-1.3.4/lib/anycable/rails/compatibility.rb:38:in `__anycable_check_ivars__'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/anycable-rails-1.3.4/lib/anycable/rails/compatibility.rb:31:in `run_callbacks'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/channel/base.rb:191:in `unsubscribe_from_channel'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/connection/subscriptions.rb:51:in `remove_subscription'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/connection/subscriptions.rb:64:in `block in unsubscribe_from_all'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/connection/subscriptions.rb:64:in `each'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/connection/subscriptions.rb:64:in `unsubscribe_from_all'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/connection/base.rb:188:in `handle_close'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/sentry-rails-5.4.2/lib/sentry/rails/action_cable.rb:59:in `block in handle_close'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/sentry-rails-5.4.2/lib/sentry/rails/action_cable.rb:21:in `block in capture'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/sentry-ruby-5.4.2/lib/sentry/hub.rb:59:in `with_scope'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/sentry-ruby-5.4.2/lib/sentry-ruby.rb:352:in `with_scope'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/sentry-rails-5.4.2/lib/sentry/rails/action_cable.rb:13:in `capture'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/sentry-rails-5.4.2/lib/sentry/rails/action_cable.rb:58:in `handle_close'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/server/worker.rb:60:in `block in invoke'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/server/worker.rb:42:in `block in work'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:117:in `block in run_callbacks'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/server/worker/active_record_connection_management.rb:16:in `block in with_database_connections'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/connection/tagged_logger_proxy.rb:24:in `block in tag'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/tagged_logging.rb:99:in `block in tagged'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/tagged_logging.rb:37:in `tagged'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/tagged_logging.rb:99:in `tagged'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/connection/tagged_logger_proxy.rb:24:in `tag'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/server/worker/active_record_connection_management.rb:16:in `with_database_connections'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:126:in `block in run_callbacks'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/engine.rb:62:in `block (4 levels) in <class:Engine>'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/execution_wrapper.rb:91:in `wrap'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/engine.rb:57:in `block (3 levels) in <class:Engine>'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:126:in `instance_exec'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:126:in `block in run_callbacks'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/activesupport-6.1.7/lib/active_support/callbacks.rb:137:in `run_callbacks'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/server/worker.rb:41:in `work'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/server/worker.rb:59:in `invoke'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/actioncable-6.1.7/lib/action_cable/server/worker.rb:54:in `block in async_invoke'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/concurrent-ruby-1.1.10/lib/concurrent-ruby/concurrent/executor/ruby_thread_pool_executor.rb:352:in `run_task'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/concurrent-ruby-1.1.10/lib/concurrent-ruby/concurrent/executor/ruby_thread_pool_executor.rb:343:in `block (3 levels) in create_worker'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/concurrent-ruby-1.1.10/lib/concurrent-ruby/concurrent/executor/ruby_thread_pool_executor.rb:334:in `loop'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/concurrent-ruby-1.1.10/lib/concurrent-ruby/concurrent/executor/ruby_thread_pool_executor.rb:334:in `block (2 levels) in create_worker'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/concurrent-ruby-1.1.10/lib/concurrent-ruby/concurrent/executor/ruby_thread_pool_executor.rb:333:in `catch'
/Users/admin/.rvm/gems/ruby-3.1.2@fiveandgo/gems/concurrent-ruby-1.1.10/lib/concurrent-ruby/concurrent/executor/ruby_thread_pool_executor.rb:333:in `block in create_worker'

Looking at logs I`ve added marker here. 'anycable/rails/action_cable_ext/channel.rb' AndI see that 'anycabled?' method returns false,
Maybe here the problem

def anycabled?
     connection.instance_variable_defined?(:@anycable_socket)
    # Use instance variable check here for testing compatibility
    connection.instance_variable_defined?(:@anycable_socket)
end

other methods here using super unless anycabled?
seems thats why it raises NotEmplementedError from here (base class(
/gems/actioncable-6.1.7/lib/action_cable/subscription_adapter/base.rb:25:in unsubscribe' or /gems/actioncable-6.1.7/lib/action_cable/subscription_adapter/base.rb:25:in subscribe'
Also I have a doubt about 'stream_for' method that I showed above, maybe it does not support? But I saw it your example PR
https://github.com/anycable/anycable_rails_demo/pull/2/files

palkan Oct 12, 2022
Maintainer

As I see from the logs, you're connecting to the Action Cable server:

Started GET "/cable/" [WebSocket]

I guess, that's the problem; you should use your anycable-go server URL to connect to. Make sure this line sets the URL (or check your client code, maybe, it's using a hardcoded URL value):

config.action_cable.url = ActionCable.server.config.url = ENV.fetch('CABLE_URL', 'ws://localhost:8080/cable')

dmgrinko1 Oct 13, 2022

@palkan You was right, problem was with url which referred to port :3000 and pass to ActionCable as result.
I very appreciate your answers and time, but may I ask you one question?
This works perfect with action cable. But it does not work with any, looks like callback does not work. I saw in documentation that it probably should not work witn any. What is the best practice to handle such cases?

class NotificationChannel < ApplicationCable::Channel
  def subscribed
    stream_for non_session_user
    return unless non_session_user

    NotificationChannel.broadcast_to(non_session_user, {'name' => 'lastname'})
  end
end

here is my anycable logs. I see that it broadcasting, but nothing on client side.

[AnyCable sid=rc6zCRShb17OuI_OHjqHb] RPC Command: <AnyCable::CommandMessage: command: "subscribe", identifier: "{"channel":"NotificationChannel"}", connection_identifiers: "{"non_session_user":"Z2lkOi8vYW55Y2FibGUvVXNlci8x"}", data: "", env: <AnyCable::Env: url: "http://localhost:8080/cable", headers: {"REMOTE_ADDR"=>"127.0.0.1", "cookie"=>""}, cstate: {}, istate: {}>>
[AnyCable sid=rc6zCRShb17OuI_OHjqHb]   News Load (1.1ms)  SELECT "news".* FROM "news" WHERE "news"."user_id" = $1  [["user_id", 12949]]
[AnyCable sid=rc6zCRShb17OuI_OHjqHb]    (1.9ms)  SELECT COUNT(*) FROM "notifications" WHERE "notifications"."user_id" = $1 AND "notifications"."read" = $2 AND "notifications"."notification_type" = $3  [["user_id", 12949], ["read", false], ["notification_type", "creation_liked"]]
[AnyCable sid=rc6zCRShb17OuI_OHjqHb]    (0.4ms)  SELECT COUNT(*) FROM "notifications" WHERE "notifications"."user_id" = $1 AND "notifications"."read" = $2 AND "notifications"."notification_type" = $3  [["user_id", 12949], ["read", false], ["notification_type", "friend_request"]]
[AnyCable sid=rc6zCRShb17OuI_OHjqHb]    (1.3ms)  SELECT COUNT(*) FROM "users_awards" WHERE "users_awards"."user_id" = $1 AND "users_awards"."viewed" = $2  [["user_id", 12949], ["viewed", false]]
[AnyCable sid=rc6zCRShb17OuI_OHjqHb] [ActionCable] Broadcasting to notification:Z2lkOi8vYW55Y2FibGUvVXNlci8x:  {'name' => 'lastname'}
[AnyCable sid=rc6zCRShb17OuI_OHjqHb] NotificationChannel is transmitting the subscription confirmation

here is redis queue

palkan Oct 18, 2022
Maintainer

There is a race condition: subscribing and broadcasting happens concurrently, there is no order guarantee. With Action Cable, it works most of a time since everything is happening within the same Ruby process (at least, locally), and thus, the stream_from and broadcast command are usually executed in order. With AnyCable, the execution is also concurrent, but it's done within anycable-go server, which has true parallelism, so the order of these commands is random (and, yes, broadcasting via Redis Pub/Sub is quicker than responding to an RPC call when the load is low).

Consider using transmit instead (which sends a message directly to the current socket):

-  NotificationChannel.broadcast_to(non_session_user, {'name' => 'lastname'})
+  transmit({'name' => 'lastname'})

dmgrinko1 Oct 19, 2022

@palkan thank so much.
transmit and moving broadcast to other channel action and firing it after channel confirmation callback (for example) works fine.

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

AnyCable

RPC not broadcast message #162

{{title}}

Replies: 1 comment 11 replies

{{title}}

{{title}}

{{editor}}'s edit

{{editor}}'s edit

{{title}}

{{title}}

{{editor}}'s edit

{{editor}}'s edit

{{title}}

{{editor}}'s edit

{{editor}}'s edit

{{title}}

Select a reply

AnyCable

RPC not broadcast message #162

Khamonluckssa Sep 11, 2022

Replies: 1 comment · 11 replies

palkan Sep 11, 2022 Maintainer

dmgrinko1 Oct 12, 2022

palkan Oct 12, 2022 Maintainer

dmgrinko1 Oct 13, 2022

palkan Oct 18, 2022 Maintainer

dmgrinko1 Oct 19, 2022

Khamonluckssa
Sep 11, 2022

Replies: 1 comment 11 replies

palkan
Sep 11, 2022
Maintainer

palkan Oct 12, 2022
Maintainer

palkan Oct 18, 2022
Maintainer