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
|
import Pyro5.core
import Pyro5.api
secret_code = "pancakes"
class CustomDaemon(Pyro5.api.Daemon):
def validateHandshake(self, conn, data):
print("Daemon received handshake request from:", conn.sock.getpeername())
print("Handshake data:", data)
# if needed, you can inspect Pyro5.callcontext.current_context:
ctx = Pyro5.api.current_context
print(" context.client: ", ctx.client)
print(" context.client_sock_addr: ", ctx.client_sock_addr)
print(" context.seq: ", ctx.seq)
print(" context.msg_flags: ", ctx.msg_flags)
print(" context.serializer_id: ", ctx.serializer_id)
print(" context.correlation_id:", ctx.correlation_id)
if data == secret_code:
print("Secret code okay! Connection accepted.")
# return some custom handshake data:
return ["how", "are", "you", "doing"]
else:
print("Secret code wrong! Connection refused.")
raise ValueError("wrong secret code, connection refused")
def clientDisconnect(self, conn):
print("Daemon client disconnects:", conn.sock.getpeername())
with CustomDaemon() as daemon:
print("Server is ready. You can use the following URI to connect:")
print(daemon.uriFor(Pyro5.core.DAEMON_NAME))
print("When asked, enter the following secret code: ", secret_code)
daemon.requestLoop()
|
