--- deliantra/server/include/client.h	2006/12/15 20:08:45	1.3
+++ deliantra/server/include/client.h	2006/12/16 18:39:26	1.6
@@ -1,4 +1,3 @@
-
 /*
     CrossFire, A Multiplayer game for the X Window System
 
@@ -22,20 +21,12 @@
     The author can be reached via e-mail to crossfire@schmorp.de
 */
 
-/*
-    newserver.h defines various structures and values that are use for the
-    new client server communication method.  Values defined here are only
-    used on the server side code.  For shared client/server values, see
-    newclient.h
-*/
-
 #ifndef CLIENT_H
 #define CLIENT_H
 
-/* Reduce this from 50 to 5 - as it is now, there will never be more
- * than 3 anyways.
- */
+#include <deque>
 
+// (possibly) max. number of objects "per page" in the ground container
 #define NUM_LOOK_OBJECTS 50
 
 struct MapCell
@@ -96,6 +87,33 @@
   int len;
 };
 
+// a handler for a specific type of packet
+enum {
+  PF_PLAYER    = 0x01, // must have valid player
+  PF_IMMEDIATE = 0x02, // TODO: hack, can be executed immediately
+  PF_PLAYING   = 0x04, // must be in playing state
+};
+
+struct packet_type
+{
+  const char *name;
+  void *cb;
+  int flags;
+};
+
+struct command
+{
+  tstamp stamp;
+  const packet_type *handler;
+  char *data;
+  int datalen;
+
+  ~command ()
+  {
+    sfree (data, datalen);
+  }
+};
+
 /* how many times we are allowed to give the wrong password before being kicked. */
 #define MAX_PASSWORD_FAILURES 5
 
@@ -148,18 +166,32 @@
   int ACC (RW, current_x), ACC (RW, current_y);     // CF+ last/current map position
   char ACC (RW, version)[64];              // CF+ client name/version
 
-  /* If we get an incomplete packet, this is used to hold the data. */
-  uint8 inbuf[MAXSOCKBUF];
+  // if we get an incomplete packet, this is used to hold the data.
+  // we add 2 byte for the header, one for the trailing 0 byte
+  uint8 inbuf[MAXSOCKBUF + 2 + 1];
   player *ACC (RO, pl);//TODO should not be here, preferably
 
   int ACC (RW, rtt), ACC (RW, rttvar); /* round-trip time and -variance, if known */
 
-  iow socket_ev; void socket_cb (iow &w, int got);
-
   client (int fd, const char *from_ip);
   ~client ();
+  void destroy ();
+
+  iw  cmd_ev;    void cmd_cb (iw &w);
+  iow socket_ev; void socket_cb (iow &w, int got);
+
+  std::deque< command, slice_allocator<command> > cmd_queue;
+
+  // resets movement state
+  bool may_execute (const packet_type *pkt) const;
+  void execute (const packet_type *pkt, char *data, int datalen);
+
+  void queue_command (packet_type *handler, char *data, int datalen);
+  bool handle_command ();
+  void reset_state ();
 
-  int read_packet ();                     // returns length of packet or 0
+  bool handle_packet ();
+  int next_packet ();                     // returns length of packet or 0
   void skip_packet (int len);             // we have processed the packet, skip it
 
   void flush ();
@@ -168,6 +200,7 @@
 
   void send_packet (const char *buf);
   void send_packet (const char *buf, int len);
+  void send_packet_printf (const char *format, ...);
   void send_packet (packet &sl);
 };