Merge lp:~nelsondovale/walls/walls into lp:walls

[Nelson do Vale]

Creating the game server.

[isacvale (isac)]

review: Approve

Unmerged revisions

3. By Nelson do Vale on 2017-07-16

Incluindo primeira versão do servidor.
Apenas um script que permite três mensagens entre servidor e cliente.

=== added directory 'prototypes/server'
=== added file 'prototypes/server/client.py'
--- prototypes/server/client.py	1970-01-01 00:00:00 +0000
+++ prototypes/server/client.py	2017-07-23 19:38:45 +0000
@@ -0,0 +1,21 @@
+import socket
+import sys
+
+server_address = ('localhost',10000)
+s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+
+print('Conectando a {} porta {}'.format(*server_address), file=sys.stderr)
+s.connect(server_address)
+
+while True:
+	message = input("Send message:")
+	outgoing_data = message.encode()
+	print('{}: sending {!r}'.format(s.getsockname(),outgoing_data), file=sys.stderr)
+	s.send(outgoing_data)
+	data=s.recv(1024)
+	print(data.decode("utf-8"))
+	if not data:
+		print('closing', s.getsockname(), file=sys.stderr)
+		s.close()
+
+

=== added file 'prototypes/server/server.py'
--- prototypes/server/server.py	1970-01-01 00:00:00 +0000
+++ prototypes/server/server.py	2017-07-23 19:38:45 +0000
@@ -0,0 +1,88 @@
+import select
+import socket
+import sys
+import queue
+import json
+
+#Criar socket TCP/IP
+server = socket.socket()
+server.setblocking(0)
+server_address = ('localhost', 10000)
+print('starting up on {} port {}'.format(*server_address),file=sys.stderr)
+server.bind(server_address)
+server.listen(5)
+
+
+inputs = [server]
+outputs = []
+message_queues = {}
+
+def get_response(data):
+	data = parse_message(data)
+	respostas = {
+		'lista':'João, Pedro, Maria, Leonardo',
+		'movepeao':'Peão morreu',
+		'moverainha':'Você Venceu',
+	}
+	if data not in respostas:
+		resposta = "Não entendi, por favor, use "+",".join(respostas.keys())
+	else:
+		resposta = respostas[data]
+	return str.encode(resposta)
+
+
+
+def parse_message(data):
+	data = data.decode("utf-8")
+	#data = json.loads(data)
+	return data
+
+while inputs:
+	print('Aguardando o próximo evento', file=sys.stderr)
+	readable,writable,exceptional = select.select(inputs,outputs,inputs)
+
+	for s in readable:
+		if s is server:
+			(connection, client_address) = s.accept()
+			print('   connection from', client_address, file=sys.stderr)
+			connection.setblocking(0)
+			inputs.append(connection)
+			message_queues[connection] = queue.Queue()
+		else:
+			data = s.recv(1024)
+			print(s)
+			if data:
+				response = get_response(data)
+				print('    received {!r} from {}'.format(data, s.getpeername()), file=sys.stderr)
+				message_queues[s].put(response)
+				if s not in outputs:
+					outputs.append(s)
+			else:
+				print('    closing', client_address, file=sys.stderr)
+				if s in outputs:
+					outputs.remove(s)
+				inputs.remove(s)
+				s.close()
+
+				del message_queues[s]
+
+	for s in writable:
+		try:
+			next_msg = message_queues[s].get_nowait()
+		except queue.Empty:
+			print('    ',s.getpeername(),'queue empty', file=sys.stderr)
+			outputs.remove(s)
+		else:
+			print('    sending {!r} to {}'.format(next_msg, s.getpeername()),file=sys.stderr)
+			s.send(next_msg)
+			
+	
+	for s in exceptional:
+		print('exception condition on', s.getpeername(), file=sys.stderr)
+		inputs.remove(s)
+		if s in outputs:
+			outputs.remove(s)
+		s.close()
+		del message_queues[s]
+	print(readable, writable)
+

=== added file 'prototypes/server/server2.py'
--- prototypes/server/server2.py	1970-01-01 00:00:00 +0000
+++ prototypes/server/server2.py	2017-07-23 19:38:45 +0000
@@ -0,0 +1,10 @@
+import socket
+
+s=socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+s.bind((socket.gethostname(),80))
+s.listen(5)
+
+while True:
+	(clientsocket, address) = s.accept()
+	ct=client_thread(clientsoket)
+	ct.run()

=== added file 'prototypes/server/server3.py'
--- prototypes/server/server3.py	1970-01-01 00:00:00 +0000
+++ prototypes/server/server3.py	2017-07-23 19:38:45 +0000
@@ -0,0 +1,13 @@
+import socket               # Import socket module
+
+s = socket.socket()         # Create a socket object
+host = socket.gethostname() # Get local machine name
+port = 12345                # Reserve a port for your service.
+s.bind((host, port))        # Bind to the port
+
+s.listen(5)                 # Now wait for client connection.
+while True:
+	c, addr = s.accept()     # Establish connection with client.
+	print( 'Got connection from', addr)
+	c.send(b'Thank you for connecting')   # Send bytes
+	c.close()                # Close the connection