(self, peer_ip, peer_port, cmd, parameters)
| 499 | print(peer.getFile(site, filename).read()) |
| 500 | |
| 501 | def peerCmd(self, peer_ip, peer_port, cmd, parameters): |
| 502 | logging.info("Opening a simple connection server") |
| 503 | global file_server |
| 504 | from Connection import ConnectionServer |
| 505 | file_server = ConnectionServer() |
| 506 | file_server.start(check_connections=False) |
| 507 | from Crypt import CryptConnection |
| 508 | CryptConnection.manager.loadCerts() |
| 509 | |
| 510 | from Peer import Peer |
| 511 | peer = Peer(peer_ip, peer_port) |
| 512 | |
| 513 | import json |
| 514 | if parameters: |
| 515 | parameters = json.loads(parameters.replace("'", '"')) |
| 516 | else: |
| 517 | parameters = {} |
| 518 | try: |
| 519 | res = peer.request(cmd, parameters) |
| 520 | print(json.dumps(res, indent=2, ensure_ascii=False)) |
| 521 | except Exception as err: |
| 522 | print("Unknown response (%s): %s" % (err, res)) |
| 523 | |
| 524 | def getConfig(self): |
| 525 | import json |
nothing calls this directly
no test coverage detected