1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
extend Algebrick::Matching # => main
# Lets define message-protocol for a cross-process communication.
Request = Algebrick.type do
User = type { fields login: String, password: String }
variants CreateUser = type { fields User },
GetUser = type { fields login: String }
end # => Request(CreateUser | GetUser)
Response = Algebrick.type do
variants Success = type { fields Object },
Failure = type { fields error: String }
end # => Response(Success | Failure)
Message = Algebrick.type { variants Request, Response }
# => Message(Request | Response)
require 'algebrick/serializer' # => true
require 'multi_json' # => true
# Prepare a message for sending.
serializer = Algebrick::Serializer.new # => #<Algebrick::Serializer:0x007fab42bdf6d8>
request = CreateUser[User['root', 'lajDh4']]
# => CreateUser[User[login: root, password: lajDh4]]
raw_request = MultiJson.dump serializer.dump(request)
# => "{\"algebrick_type\":\"CreateUser\",\"algebrick_fields\":[{\"algebrick_type\":\"User\",\"login\":\"root\",\"password\":\"lajDh4\"}]}"
# Receive the message.
response = match serializer.load(MultiJson.load(raw_request)),
(on CreateUser.(~any) do |user|
# create the user and send success
Success[user]
end) # => Success[User[login: root, password: lajDh4]]
# Send response.
response_raw = MultiJson.dump serializer.dump(response)
# => "{\"algebrick_type\":\"Success\",\"algebrick_fields\":[{\"algebrick_type\":\"User\",\"login\":\"root\",\"password\":\"lajDh4\"}]}"
# Receive response.
serializer.load(MultiJson.load(response_raw)) # => Success[User[login: root, password: lajDh4]]
|
