874Gateway/binaryClient.py at master · EmSysGateWay/874Gateway · GitHub

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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
import socket
import struct

class BinaryClient:
	ACK = 0
	NACK = 1
	LOGIN = 2
	REPORT = 3
	CONTROL = 4
	LOGOUT = 5

	def __init__(self,device_id,device_key,device_fmt,server_addr,server_port):
		self.device_id = device_id
		self.device_key = device_key
		self.device_fmt = device_fmt
		self.server_addr = server_addr;
		self.server_port = server_port;
		address = (self.server_addr, self.server_port)
		self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM,0)
		self.socket.connect(address)


	def login(self):
		packet = struct.pack("<bL32s", self.LOGIN, self.device_id, self.device_key)
		self.socket.send(packet)
		packet = self.socket.recv(1)
		if(self.is_ack(packet)):
			print("login success")
		else:
			print("login failed")
		#return self.control_receive()


	def is_ack(self,packet):
		data = struct.unpack("<b",packet)
		if(data[0] == self.ACK):
			return 1
		else:
			return 0

	def logout(self):
		packet = struct.pack("<b", self.LOGOUT)
		self.socket.send(packet)
		print("logged out")
		self.socket.close()

	def control_receive(self):
		packet_head = self.socket.recv(5)
		packet_type,get_id = struct.unpack("<bL",packet_head)
		print packet_type,get_id
		if(packet_type != self.CONTROL or get_id != self.device_id):
			print "wrong packet type and device id"

		packet_data = self.socket.recv(struct.calcsize(self.device_fmt))
		control_data = struct.unpack(self.device_fmt, packet_data)
		return control_data


	def report(self,data,packet_id):
		packet = struct.pack("<bLL", self.REPORT, self.device_id,packet_id)	#if nya then packet_id = 0
		self.socket.send(packet+data)
		packet = self.socket.recv(1)
		if(self.is_ack(packet)):
			print("report success")
		else:
			print("report failed")

nya_client = BinaryClient(39,"bd997d7a2d74157cce1b3358e0125652","<8s","nya.fatmou.se",10659)
fat_client = BinaryClient(26,"33bcaf15032f0b2baa25f390376f1cdf","<4s","fat.fatmou.se",10659)
nya_client.login()
fat_client.login()

def fat_report(data,packet_id):
	fat_client.report(data,packet_id)

def nya_report(data):
	nya_client.report(data,0)

def fat_logout():
	fat_client.logout()

def nya_logout():
	nya_client.logout()


def main():
	report_data = struct.pack("<4sLf","abcd",23,2.2)
	nya_report(report_data)
	fat_report(report_data,22)

	nya_logout()
	fat_logout()

if __name__ == '__main__':
    main()