Test with actioncable

Author: Fabrizio Monti

Gemfile

@@ -24,6 +24,7 @@ gem "title"
 gem "uglifier"
 gem "omniauth"
 gem "omniauth-github"
+gem "actioncable", github: "rails/actioncable"
 
 source "https://rails-assets.org" do
   gem "rails-assets-fontawesome", "4.3.0"

Gemfile.lock

@@ -1,3 +1,17 @@
+GIT
+  remote: git://github.com/rails/actioncable.git
+  revision: 63cdbf87ddaeb6bbc852de7ca2c504b7f6a22321
+  specs:
+    actioncable (0.0.3)
+      actionpack (>= 4.2.0)
+      activesupport (>= 4.2.0)
+      celluloid (~> 0.16.0)
+      coffee-rails
+      em-hiredis (~> 0.3.0)
+      faye-websocket (~> 0.10.0)
+      redis (~> 3.0)
+      websocket-driver (~> 0.6.1)
+
 GEM
   remote: https://rubygems.org/
   remote: https://rails-assets.org/
@@ -81,6 +95,8 @@ GEM
     capybara-webkit (1.7.1)
       capybara (>= 2.3.0, < 2.6.0)
       json
+    celluloid (0.16.0)
+      timers (~> 4.0.0)
     coderay (1.1.0)
     coffee-rails (4.1.0)
       coffee-script (>= 2.2.0)
@@ -113,9 +129,13 @@ GEM
       json
       thread
       thread_safe
+    em-hiredis (0.3.0)
+      eventmachine (~> 1.0)
+      hiredis (~> 0.5.0)
     email_validator (1.6.0)
       activemodel
     erubis (2.7.0)
+    eventmachine (1.0.8)
     execjs (2.6.0)
     factory_girl (4.5.0)
       activesupport (>= 3.0.0)
@@ -127,6 +147,9 @@ GEM
     faraday (0.9.2)
       multipart-post (>= 1.2, < 3)
     fastercsv (1.5.5)
+    faye-websocket (0.10.1)
+      eventmachine (>= 0.12.0)
+      websocket-driver (>= 0.5.1)
     flutie (2.0.0)
     formulaic (0.3.0)
       activesupport
@@ -140,6 +163,8 @@ GEM
     hashie (3.4.3)
     high_voltage (2.4.0)
     highline (1.7.8)
+    hiredis (0.5.2)
+    hitimes (1.2.3)
     i18n (0.7.0)
     i18n-tasks (0.9.1)
       activesupport (>= 4.0.2)
@@ -250,6 +275,7 @@ GEM
       thor (>= 0.18.1, < 2.0)
     rainbow (2.0.0)
     rake (10.4.2)
+    redis (3.2.1)
     refills (0.1.0)
     request_store (1.2.0)
     rspec-core (3.3.2)
@@ -332,6 +358,8 @@ GEM
     thread_safe (0.3.5)
     tilt (2.0.1)
     timecop (0.8.0)
+    timers (4.0.4)
+      hitimes
     tins (1.6.0)
     title (0.0.5)
       i18n
@@ -346,13 +374,17 @@ GEM
       addressable (>= 2.3.6)
       crack (>= 0.3.2)
       hashdiff
+    websocket-driver (0.6.3)
+      websocket-extensions (>= 0.1.0)
+    websocket-extensions (0.1.2)
     xpath (2.0.0)
       nokogiri (~> 1.3)
 
 PLATFORMS
   ruby
 
 DEPENDENCIES
+  actioncable!
   airbrake
   autoprefixer-rails
   awesome_print

Procfile

@@ -1,2 +1,2 @@
 web: bundle exec puma -p $PORT -C ./config/puma.rb
-worker: bundle exec rake jobs:work
+/* worker: bundle exec rake jobs:work */

app/assets/javascripts/application.js

@@ -13,4 +13,5 @@
 //= require jquery
 //= require jquery-ujs
 //= require lodash
+//= require cable
 //= require_tree .

app/assets/javascripts/application_cable.js.coffee

@@ -0,0 +1,2 @@
+@App = {}
+App.cable = Cable.createConsumer('ws://' + window.location.host + '/websocket')

app/assets/javascripts/cable/subscriptions/appearance.js.coffee

@@ -0,0 +1,12 @@
+$ ->
+  App.appearance = App.cable.subscriptions.create "AppearanceChannel",
+    connected: ->
+      @appear()
+
+    appear: ->
+      console.log "APPEARING"
+      @perform 'appear'
+
+    received: (data) ->
+      console.log "RICEVO DATI"
+      console.log data

app/channels/appearance_channel.rb

@@ -0,0 +1,12 @@
+class AppearanceChannel < ApplicationCable::Channel
+  @@total_players_count = 0
+
+  def subscribed
+    stream_from "appearance_count"
+  end
+
+  def appear
+    @@total_players_count += 1
+    ActionCable.server.broadcast "appearance_count", total_players_count: @@total_players_count
+  end
+end

app/channels/application_cable/channel.rb

@@ -0,0 +1,4 @@
+module ApplicationCable
+  class Channel < ActionCable::Channel::Base
+  end
+end

app/channels/application_cable/connection.rb

@@ -0,0 +1,6 @@
+module ApplicationCable
+  class Connection < ActionCable::Connection::Base
+    def connect
+    end
+  end
+end

config/redis/cable.yml

@@ -0,0 +1,8 @@
+production: &production
+  :url: <%= ENV['REDIS_URL'] %>
+  :timeout: 1
+development: &development
+  :url: redis://localhost:6379
+  :timeout: 1
+  :inline: true
+test: *development

config/routes.rb

@@ -1,5 +1,6 @@
 Rails.application.routes.draw do
   root to: 'static#home'
+  match "/websocket", to: ActionCable.server, via: [:get, :post]
 
   get '/auth/:provider/callback' => 'sessions#create'
   get '/signin' => 'sessions#new', as: :signin