yannvery · August 29, 2015 14:25
diff --git a/0_Readme.md b/0_Readme.md
diff --git a/1_Gemfile b/1_Gemfile
 # ...
 gem 'faye'
 gem 'thin'
 # ...
diff --git a/2_faye.ru b/2_faye.ru
 # To launch faye server you need to call : rackup faye.ru -s thin -E production
 require 'faye'
 Faye::WebSocket.load_adapter('thin')
 Faye.logger = Logger.new('log/faye.log')
 faye_server = Faye::RackAdapter.new(:mount => '/faye', :timeout => 45)
 run faye_server
diff --git a/3_application.html.erb b/3_application.html.erb
 ....
 <head>
 <!-- Include faye library to make connection to faye server from browser -->
  <%= javascript_include_tag "http://localhost:9292/faye.js" %>
 </head>
 ....
diff --git a/4_faye_websocket.js b/4_faye_websocket.js
 // app/assets/javascripts/faye_websocket.js
 // Make a connection to faye server from browser and subscribe to /login channel
 //= require notify.min.js
 $(function() {
  var faye = new Faye.Client('http://localhost:9292/faye');
  var subscription = faye.subscribe('/login', function(message) {
    $.notify(message, 'info');
  });
 });
diff --git a/5_application.js b/5_application.js
 // Load faye_websocket
 // ...
 //= require faye_websocket
 // ...
diff --git a/6_faye_notification.rb b/6_faye_notification.rb
 # app/services/faye_notification.rb
 # Service object to publish a message to a faye channel without use EventMachine
 class FayeNotification
  def initialize(channel:, text:)
    @channel = channel
    @text = text
  end

  def publish
    uri = URI.parse("http://localhost:9292/faye")
    message = {channel: @channel, data: @text}
    Net::HTTP.post_form(uri, message:  message.to_json)
  end
 end 
diff --git a/7_application_controller.rb b/7_application_controller.rb
 class ApplicationController < ActionController::Base
  # ...
  # Use devise callback to send a notification to faye server
  def after_sign_in_path_for(resource)
    stored_location_for(resource) ||
      if resource.is_a?(User)
        FayeNotification.new(channel: '/login', text: "#{current_user.email} is logged").publish
        root_url
      else
        super
      end
  end
  
  # ...
 end
	# To launch faye server you need to call : rackup faye.ru -s thin -E production
	require 'faye'
	Faye::WebSocket.load_adapter('thin')
	Faye.logger = Logger.new('log/faye.log')
	faye_server = Faye::RackAdapter.new(:mount => '/faye', :timeout => 45)
	run faye_server
	....
	<head>
	<!-- Include faye library to make connection to faye server from browser -->
	<%= javascript_include_tag "http://localhost:9292/faye.js" %>
	</head>
	....
	// app/assets/javascripts/faye_websocket.js
	// Make a connection to faye server from browser and subscribe to /login channel
	//= require notify.min.js
	$(function() {
	var faye = new Faye.Client('http://localhost:9292/faye');
	var subscription = faye.subscribe('/login', function(message) {
	$.notify(message, 'info');
	});
	});
	// Load faye_websocket
	// ...
	//= require faye_websocket
	// ...
	# app/services/faye_notification.rb
	# Service object to publish a message to a faye channel without use EventMachine
	class FayeNotification
	def initialize(channel:, text:)
	@channel = channel
	@text = text
	end

	def publish
	uri = URI.parse("http://localhost:9292/faye")
	message = {channel: @channel, data: @text}
	Net::HTTP.post_form(uri, message: message.to_json)
	end
	end
	class ApplicationController < ActionController::Base
	# ...
	# Use devise callback to send a notification to faye server
	def after_sign_in_path_for(resource)
	stored_location_for(resource) \|\|
	if resource.is_a?(User)
	FayeNotification.new(channel: '/login', text: "#{current_user.email} is logged").publish
	root_url
	else
	super
	end
	end

	# ...
	end