Contents

#!/bin/env ruby

require './config/environment.rb'

require 'websocket-eventmachine-client'
require 'json'


Rails.application.eager_load!
notifiers = Hash[*ActiveRecord::Base.descendants.select { |cls| cls.respond_to?('seapig_dependency_version') }.map { |notifier| [notifier.name,notifier] }.flatten ]

$last_versions = {}
$payloads = Queue.new

EM.run {

	socket = WebSocket::EventMachine::Client.connect(uri: ARGV[0])

	
	on_database_change = Proc.new {
		payloads = Set.new
		payloads << $payloads.pop while not $payloads.empty?
		payloads.each { |notifier_name|
			version = notifiers[notifier_name].seapig_dependency_version #F handle wrong names
			p version
			if $last_versions[notifier_name] != version	
				#socket.send(JSON.dump(action: 'object-update', id: notifier_name, version: version))
				socket.send(JSON.dump(action: 'object-patch', id: notifier_name, new_version: version, old_version: 0))
				$last_versions[notifier_name] = version
			end
		}
	}


	socket.onopen {
		socket.send(JSON.dump(action: 'client-options-set', options: {name: 'notifier'}))
		Thread.new {
			ActiveRecord::Base.connection_pool.with_connection { |connection|
				connection = connection.instance_variable_get(:@connection)
				connection.exec("LISTEN seapig_dependency_changed")
				loop {
					connection.wait_for_notify { |channel, pid, payloads|
						puts "Got notification: channel="+channel+", pid="+pid.inspect+", payload="+payloads.inspect
						payloads.split(",").each { |payload| $payloads << payload }
						EM.schedule(on_database_change)
					}
				}
			}
		}
		EM.schedule on_database_change
	}

	
	socket.onclose { |code, reason|
		EM.stop
	}


	EM.add_periodic_timer(60) {
#		socket.send(JSON.dump(action: 'object-update', id: 'Minute', version: Time.new.to_i/60))
		socket.send(JSON.dump(action: 'object-patch', id: 'Minute', new_version: Time.new.to_i/60, old_version: 0))
	}
	
}

	

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
seapig-rails-0.0.3	bin/seapig-notifier
seapig-rails-0.0.2	bin/seapig-notifier
seapig-rails-0.0.1	bin/seapig-notifier