WIP Pull Request for Issue #7 #8 ( Bryan + Minja)

Gemfile

@@ -2,3 +2,9 @@ source 'https://rubygems.org'
 ruby '2.5.1'
 gem 'karafka'
 
+# include the basic plezi framework and server
+gem 'plezi'
+## Redis servers are used to allow websocket scaling.
+## Plezi can be configured to automatically use Redis for easy scaling.
+# gem 'redis'
+gem 'iodine', '~>0.6'  # may need to fix the version

README.md

@@ -0,0 +1,3 @@
+YACS Event Stream Websocket API
+---
+Implemented using Kafka & Plezi

app.rb

@@ -1,3 +1,35 @@
-require 'karafka'
+# encoding: UTF-8
 
-puts 'Hello world'
+## Set environment, working directory, load gems and create logs
+ENV['ENV'] ||= ENV['RACK_ENV'] ||= ENV['RAILS_ENV'] # production ENV will render SASS as compressed.
+## Using pathname extentions for setting public folder
+require 'pathname'
+## Set up root object, it might be used by the environment and\or the plezi extension gems.
+Root ||= Pathname.new(File.dirname(__FILE__)).expand_path
+## If this app is independant, use bundler to load gems (including the plezi gem).
+## otherwise, use the original app's Gemfile and Plezi will automatically switch to Rack mode.
+require 'bundler'
+Bundler.require(:default, ENV['ENV'].to_s.to_sym)
+
+# Load all the code from a subfolder called 'app'
+Dir[File.join '{controllers}', '**', '*.rb'].each { |file| load File.expand_path(file) }
+# Load all the code from a subfolder called 'lib'
+Dir[File.join '{lib}', '**', '*.rb'].each { |file| load File.expand_path(file) }
+
+## Logging
+Iodine::DEFAULT_HTTP_ARGS[:log] = 1 if Iodine::DEFAULT_HTTP_ARGS[:log].nil?
+
+# # Optional Scaling (across processes or machines):
+ENV['PL_REDIS_URL'] ||= ENV['REDIS_URL'] ||
+                        ENV['REDISCLOUD_URL'] ||
+                        ENV['REDISTOGO_URL'] ||
+                        nil # "redis://:[email protected]:6389/0"
+# # redis channel name should be changed IF using the same Plezi code within
+# # more then one application (i.e., using both Rails and Plezi together).
+# Plezi.app_name = 'yacs_websocket_a027e2d668a7dc21c59fe56f018432ea'
+
+# Map the views folder to the template root (for the {#render} function).
+#Plezi.templates = Root.join('views').to_s
+
+# load routes.
+load Root.join('routes.rb').to_s

app/consumers/courses_consumer.rb

@@ -0,0 +1,14 @@
+require 'karafka'
+require_relative 'application_consumer'
+require 'eventstream'
+
+class CourseConsumer < ApplicationConsumer
+  def consume
+	if ( Object.const_defined?('EventStream') == false )
+	  puts "EventStream class not initialized" 
+	else 
+	  EventStream.on_message(params)
+	  puts "Consumer message sent to websocket"
+	end	
+  end
+end

app/consumers/sections_consumer.rb

@@ -1,8 +1,14 @@
 require 'karafka'
 require_relative 'application_consumer'
+require 'eventstream'
 
 class SectionConsumer < ApplicationConsumer
-	def consume
-	  puts params #print out the single message received
-	end
+  def consume
+    if ( Object.const_defined?('EventStream') == false )
+      puts "EventStream class not initialized" 
+    else 
+      EventStream.on_message(params)
+      puts "Consumer message sent to websocket"
+    end	
+  end
 end

app/controllers/eventstream.rb

@@ -0,0 +1,18 @@
+require 'plezi'
+
+class EventStream
+
+  def on_open
+    puts 'Opened the YACS-EventStream Websocket!'
+  end
+
+  ## When receiving a single message from Consumer pusblish to socket
+  def on_message(data)
+    unless write { notifications: :data }.to_json
+      write "no message sent"
+    end
+  end 
+
+  def on_close
+  end
+end

config.ru

@@ -0,0 +1,8 @@
+# Default Rack interface
+
+# load the application
+load ::File.expand_path(File.join('..', 'app.rb'), __FILE__)
+
+Iodine::DEFAULT_HTTP_ARGS[:public] ||= './public'
+
+run Plezi.app

karafka.rb

@@ -15,6 +15,7 @@
 # require ::File.expand_path('../config/environment', __FILE__)
 # Rails.application.eager_load!
 require 'karafka'
+require 'app'
 
 class KarafkaApp < Karafka::App
   setup do |config|
@@ -38,6 +39,9 @@ class KarafkaApp < Karafka::App
         consumer SectionConsumer #Single message from section_change
         end
       end
+      topic :course_change do
+        consumer CourseConsumer
+      end
     end
 end
-KarafkaApp.boot!
+KarafkaApp.boot!

rakefile

@@ -0,0 +1,7 @@
+# load all application code and gems
+require 'bundler'
+Bundler.require(:default, ENV['ENV'].to_s.to_sym)
+# set Plezi to rake mode and load it's tasks (if relevant).
+Plezi.no_autostart
+
+# Add your tasks

routes.rb

@@ -0,0 +1,3 @@
+## 
+# ws://0.0.0.0/EventStream
+Plezi.route '/', EventStream