Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import json
- import socket
- import time
- class Client():
- HOST = "127.0.0.1"
- PORT = 30001
- PACKET_SIZE = 110000
- def __init__(self, host: str = None, port: int = None, packet_size: int = None) -> None:
- self.host = host if host else self.HOST
- self.port = port if port else self.PORT
- self.packet_size = packet_size if packet_size else self.PACKET_SIZE
- try:
- # Creating socket:
- self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
- # Connect:
- self.socket.connect((self.host, self.port))
- except ConnectionRefusedError:
- raise ConnectionRefusedError(f'Could not connect to {self.host} on port {self.port}')
- print('Connection was successful!')
- def close_socket(self) -> None:
- self.socket.close()
- def get_status(self) -> str:
- response = self.socket.recv(self.PACKET_SIZE)
- response = response.strip()
- try:
- data = json.loads(response)
- except JSONDecodeError:
- raise JSONDecodeError(f'data could not be parsed as json: {data}')
- try:
- status = data['data']['status']
- except KeyError:
- raise KeyError(f"keys: ['data']['status'] were not found in data: {data}")
- return status
- client = Client()
- while True:
- time.sleep(2)
- print(client.get_status())
- client.close_socket()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement