Merge pull request #1 from flbe/master

Added python websocket server implementation

server/server.py

@@ -0,0 +1,81 @@
+#!/usr/bin/env python
+
+import asyncio
+import datetime
+import websockets
+import pprint
+
+#server config <change ip if you like>
+ip = "127.0.0.1"
+port = 8080
+
+#global vars
+clients = set()
+
+@asyncio.coroutine
+def sendMsg(socket, msg):
+	print ("info>send>begin:\n" + msg + "\ninfo>send>end")
+	yield from socket.send(msg)
+
+@asyncio.coroutine
+def broadcast(msg):
+
+	command = msg.split("###");
+	print("info>broadcasting msg(" + str(len(msg)) + ") command=" + command[0])
+
+	for client in clients:
+		
+		print("info>broadcast>send to" + str(client.remote_address))
+		yield from client.send(msg)
+
+@asyncio.coroutine
+def client_connect(websocket, path):
+	print("info>Client connected:" + str(websocket.remote_address));
+	clients.add(websocket)
+
+	try:
+		while True:
+			msg = yield from websocket.recv()
+
+			command = msg.split("###");
+
+			pprint.pprint(command)
+
+			if command[0] == "fileOp":
+				print("info>got filop");
+
+				if command[1] == "read":
+					print("info>fileop> got read")
+					print("info>fileop>read:" + command[2])
+
+					f = open(command[2], "r")
+					content = f.read()
+					f.close()
+
+					print("reading done")
+
+					#send content
+					#yield from sendMsg(websocket, "file###" + command[2] + "###" + content)
+					yield from broadcast("file###" + command[2] + "###" + content);
+
+				elif command[1] == "write":
+					f = open(command[2], "w")
+					f.write(command[3])
+					f.close()
+
+					yield from broadcast("file###" + command[2] + "###" + command[3])
+
+			else:
+				yield from broadcast(msg)
+
+	except:
+		print("info>client disconnected:" + path);
+		clients.remove(websocket)
+		#raise
+
+print("info>starting server " + ip + ":" + str(port))
+server = websockets.serve(client_connect, ip, port)
+
+print ("info>go into loop")
+asyncio.get_event_loop().run_until_complete(server)
+asyncio.get_event_loop().run_forever()