Sha256: d040ab881250dc69afa5b3b2597580268e8df49b3106b2638fd5dcb27b716224
Contents?: true
Size: 1.51 KB
Versions: 10
Compression:
Stored size: 1.51 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_ws(@key,socket)
end
def ws_close
@data.del_ws(@key)
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')
end
def delete
@data.unserialize_notifications!(:del,@key)
@data.notify('properties/handlers/change')
end
def update
@data.unserialize_notifications!(:upd,@key)
@data.notify('properties/handlers/change')
end
end
Version data entries
10 entries across 10 versions & 1 rubygems