Moved all pipe functionality into a self-containing Communication::Pipe class

src/shared/Communication.h

 #ifndef COMMUNICATION_H
 #define COMMUNICATION_H
 
 #include <memory>
 #include <sstream>
 #include <stdexcept>
 #include <stdint.h>
 #include <string>
 #include <vector>
 #include <Windows.h>
 
 namespace Communication
 {
   extern const std::wstring pipeName;
-  const int bufferSize = 1024;
 
   enum ProcType : uint32_t {
     PROC_MATCHES,
     PROC_GET_ELEMHIDE_SELECTORS,
     PROC_AVAILABLE_SUBSCRIPTIONS,
     PROC_LISTED_SUBSCRIPTIONS,
     PROC_SET_SUBSCRIPTION,
     PROC_UPDATE_ALL_SUBSCRIPTIONS,
     PROC_GET_EXCEPTION_DOMAINS,
     PROC_ADD_FILTER,
@@ skipping 11 matching lines @@
     InputBuffer& operator>>(std::string& value) { return ReadString(value, TYPE_STRING); }
     InputBuffer& operator>>(std::wstring& value) { return ReadString(value, TYPE_WSTRING); }
     InputBuffer& operator>>(int64_t& value) { return Read(value, TYPE_INT64); }
     InputBuffer& operator>>(int32_t& value) { return Read(value, TYPE_INT32); }
     InputBuffer& operator>>(bool& value) { return Read(value, TYPE_BOOL); }
   private:
     std::istringstream buffer;
     ValueType currentType;
     bool hasType;
 
-    void CheckType(ValueType expectedType)
-    {
-      if (!hasType)
-        ReadBinary(currentType);
-
-      if (currentType != expectedType)
-      {
-        // Make sure we don't attempt to read the type again
-        hasType = true;
-        throw new std::runtime_error("Unexpected type found in input buffer");
-      }
-      else
-        hasType = false;
-    }
+    void CheckType(ValueType expectedType);
 
     template<class T>
     InputBuffer& ReadString(T& value, ValueType expectedType)
     {
       CheckType(expectedType);
 
       SizeType length;
       ReadBinary(length);
 
       std::auto_ptr<T::value_type> data(new T::value_type[length]);
@@ skipping 94 matching lines @@
 
     InputBuffer ReadMessage();
     void WriteMessage(OutputBuffer& message);
 
   protected:
     HANDLE pipe;
   };
 }
 
 #endif