Sha256: 016c02129cbce76f85bd31418af8b2bf9cd69ceef356c86000ef13e099983b2e
Contents?: true
Size: 1.1 KB
Versions: 19
Compression:
Stored size: 1.1 KB
Contents
# frozen_string_literal: true
new({ particle: :connection, category: :communication, type: :hash }) do |params, bloc|
# FIXME : html method shouldn't be here
html.connect(params, &bloc)
end
new({ particle: :message, category: :communication, type: :hash }) do |params, bloc|
if Universe.database_ready
params = { data: params } unless params.instance_of? Hash
message_id= "msg_#{Universe.messages.length}"
params[:message_id]=message_id
Universe.store_messages({msg_nb:message_id, proc: bloc })
html.send_message(params)
else
puts "server not ready "
end
end
new({ particle: :int8, category: :communication, type: :int })
new({ particle: :language, category: :communication, type: :string }) do |params|
@data = int8[params]
params
end
# method below are used for communication with ntaive core
def receptor(msg)
parsed = JSON.parse(msg)
A.controller_code[:controller].call(parsed)
end
new({ particle: :controller, category: :communication, type: :hash }) do |msg|
Atome.controller_sender(msg)
end
new({post: :controller}) do |_p, bloc|
@controller_proc << bloc
end
Version data entries
19 entries across 19 versions & 1 rubygems