-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathsender.py
40 lines (39 loc) · 1.01 KB
/
sender.py
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
# Public Part:
messages_paths: dict = {
'SIG': ('External', 'Sender'),
'MSG': ('Sender', 'Receiver'),
'REC': ('Receiver', 'Sender'),
'ACK': ('Sender', 'External')
}
machines_addresses: dict = {
'External': 'http://127.0.0.1:8001',
'Sender': 'http://127.0.0.1:8002',
'Receiver': 'http://127.0.0.1:8003'
}
# Private Part
listen_port: int = 8002
entity_type: str = 'Sender'
machine_name: str = entity_type
entity_default_data: dict = {}
messages_to_receive: dict = {
'SIG': (
lambda message_data, entity_data: None,
(
['SIG'],
lambda entity_data: True,
[
('MSG', lambda entity_id, entity_data: [entity_id], lambda entity_data: {})
]
)
),
'REC': (
lambda message_data, entity_data: None,
(
['SIG', 'REC'],
lambda entity_data: True,
[
('ACK', lambda entity_id, entity_data: [entity_id], lambda entity_data: {})
]
)
)
}