Sha256: f95eacb3bed73bee3ce9cc16a399d68ba5fe5112864eebac14e089e8f55c81f3
Contents?: true
Size: 1.7 KB
Versions: 48
Compression:
Stored size: 1.7 KB
Contents
# This file is part of CPEE.
#
# CPEE is free software: you can redistribute it and/or modify it under the terms
# of the GNU General Public License as published by the Free Software Foundation,
# either version 3 of the License, or (at your option) any later version.
#
# CPEE is distributed in the hope that it will be useful, but WITHOUT ANY
# WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
# PARTICULAR PURPOSE. See the GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License along with
# CPEE (file COPYING in the main directory). If not, see
# <http://www.gnu.org/licenses/>.
class NotificationsHandler < Riddl::Utils::Notifications::Producer::HandlerBase
def ws_open(socket)
@data.add_websocket(@key,socket)
end
def ws_close
@data.unserialize_notifications!(:del,@key)
@data.notify('properties/handlers/change', :instance => @data.instance)
end
def ws_message(data)
begin
doc = XML::Smart::string(data)
callback = doc.find("string(/vote/@id)")
result = doc.find("string(/vote)")
@data.callbacks[callback].callback(result == 'true' ? true : false)
@data.callbacks.delete(callback)
rescue
puts "Invalid message over websocket"
end
end
def create
@data.unserialize_notifications!(:cre,@key)
@data.notify('properties/handlers/change', :instance => @data.instance)
end
def delete
@data.unserialize_notifications!(:del,@key)
@data.notify('properties/handlers/change', :instance => @data.instance)
end
def update
@data.unserialize_notifications!(:upd,@key)
@data.notify('properties/handlers/change', :instance => @data.instance)
end
end
Version data entries
48 entries across 48 versions & 1 rubygems