Switch to udp

client/client.py

@@ -12,19 +12,13 @@ LARGEUR_BLOCK =  10
 NB_BLOCKS =      30
 LARGEUR_ECRAN = LARGEUR_BLOCK * NB_BLOCKS
 
-def connect():
+s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
-    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+
-    s.connect((ip_adress,port))
-    return s
 
 def sendData(data):
-    s  = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    s.sendto(data,(ip_adress,port))
-    s.connect((ip_adress,port))
+    received = s.recvfrom(1024)
-    s.sendall(data.encode('utf-8'))
+    return received[0]
-    s.send('#EOF\n'.encode('utf-8'))
-    received = s.recv(RESP_BUFFER_LENGTH)
-    s.close()
-    return received
 
 def newGame():
     received = sendData('{"type": "new-game"}')
@@ -39,6 +33,7 @@ def update(gameId = 1, direction = None):
     received = sendData(json.dumps(data))
     return json.loads(received)
 
+
 # ---------- END SOCKETS ----------
 
 LARGEUR_BLOCK =  20

server/remote-snake-server.asd

@@ -3,7 +3,7 @@
   :description "Remote Snake Server."
   :version "0.0.1"
   :author "Loic Guegan"
-  :depends-on ( "usocket" "jonathan" "cl-strings" )
+  :depends-on ( "usocket-server" "jonathan" "cl-strings" )
   :components ((:file "packages")
                (:module "game"
                         :depends-on ("packages")

server/server.lisp

@@ -7,23 +7,13 @@
                                           :element-type '(unsigned-byte 8)
                                           :initial-element 0))
 
-(defun handle-client (client-socket)
+(defun handle-client (buffer) ; echo
-  (unwind-protect ; To be sure to close the client socket
+  (declare (type (simple-array (unsigned-byte 8) *) buffer)) ; Seems to be to tell lisp which type is buffer
-      (let* ((request (read-line (usocket:socket-stream client-socket))))
+  (let ((request (babel:octets-to-string buffer)))
-        (loop while (eq (search "#EOF" request) nil) do
+    (format t "Receive client request: ~a" request)
-              (setf request (concatenate 'string request (read-line (usocket:socket-stream client-socket) nil nil))))
+    (babel:string-to-octets
-        (setf request (cl-strings:replace-all request "#EOF" ""))
+     (handle-request *server-api* request))))
-        (format (usocket:socket-stream client-socket) (handle-request *server-api* request))
-        (force-output (usocket:socket-stream client-socket)))
-    (usocket:socket-close client-socket)))
-    
 
 ;;; The server :D
-(defun start (interface port)
+(defun start (host port)
-  (format t "Server started!~%")
+  (usocket:socket-server host port #'handle-client nil :in-new-thread nil :protocol :datagram))
-  (let ((socket (usocket:socket-listen interface port)))
-    (unwind-protect ; To be sure to close server socket
-        (loop
-         (handle-client (usocket:socket-accept socket :element-type 'character)))
-      (usocket:socket-close socket))))
-