[WebSocket] Add tests for permessage deflate split frames.

Tools/Scripts/webkitpy/thirdparty/mod_pywebsocket/extensions.py

 # Copyright 2012, Google Inc.
 # All rights reserved.
 #
 # Redistribution and use in source and binary forms, with or without
 # modification, are permitted provided that the following conditions are
 # met:
 #
 #     * Redistributions of source code must retain the above copyright
 # notice, this list of conditions and the following disclaimer.
 #     * Redistributions in binary form must reproduce the above
@@ skipping 312 matching lines @@
 _compression_extension_names.append(common.DEFLATE_FRAME_EXTENSION)
 
 _available_processors[common.X_WEBKIT_DEFLATE_FRAME_EXTENSION] = (
     DeflateFrameExtensionProcessor)
 _compression_extension_names.append(common.X_WEBKIT_DEFLATE_FRAME_EXTENSION)
 
 
 def _parse_compression_method(data):
     """Parses the value of "method" extension parameter."""
 
-    return common.parse_extensions(data, allow_quoted_string=True)
+    return common.parse_extensions(data)
 
 
 def _create_accepted_method_desc(method_name, method_params):
     """Creates accepted-method-desc from given method name and parameters"""
 
     extension = common.ExtensionParameter(method_name)
     for name, value in method_params:
         extension.add_parameter(name, value)
     return common.format_extension(extension)
 
@@ skipping 70 matching lines @@
             return
         self._compression_processor.setup_stream_options(stream_options)
 
     def set_compression_processor_hook(self, hook):
         self._compression_processor_hook = hook
 
     def get_compression_processor(self):
         return self._compression_processor
 
 
-class PerFrameCompressExtensionProcessor(CompressionExtensionProcessorBase):
-    """perframe-compress processor.
-
-    Specification:
-    http://tools.ietf.org/html/draft-ietf-hybi-websocket-perframe-compression
-    """
-
-    _DEFLATE_METHOD = 'deflate'
-
-    def __init__(self, request):
-        CompressionExtensionProcessorBase.__init__(self, request)
-
-    def name(self):
-        return common.PERFRAME_COMPRESSION_EXTENSION
-
-    def _lookup_compression_processor(self, method_desc):
-        if method_desc.name() == self._DEFLATE_METHOD:
-            return DeflateFrameExtensionProcessor(method_desc)
-        return None
-
-
-_available_processors[common.PERFRAME_COMPRESSION_EXTENSION] = (
-    PerFrameCompressExtensionProcessor)
-_compression_extension_names.append(common.PERFRAME_COMPRESSION_EXTENSION)
-
-
 class PerMessageDeflateExtensionProcessor(ExtensionProcessorInterface):
     """permessage-deflate extension processor. It's also used for
     permessage-compress extension when the deflate method is chosen.
 
     Specification:
     http://tools.ietf.org/html/draft-ietf-hybi-permessage-compression-08
     """
 
     _SERVER_MAX_WINDOW_BITS_PARAM = 'server_max_window_bits'
     _SERVER_NO_CONTEXT_TAKEOVER_PARAM = 'server_no_context_takeover'
@@ skipping 223 matching lines @@
             message = message.encode('utf-8')
 
         if not self._compress_outgoing_enabled:
             return message
 
         original_payload_size = len(message)
         self._outgoing_average_ratio_calculator.add_original_bytes(
             original_payload_size)
 
         message = self._rfc1979_deflater.filter(
-            message, flush=end, bfinal=self._bfinal)
+            message, end=end, bfinal=self._bfinal)
 
         filtered_payload_size = len(message)
         self._outgoing_average_ratio_calculator.add_result_bytes(
             filtered_payload_size)
 
         _log_outgoing_compression_ratio(
                 self._logger,
                 original_payload_size,
                 filtered_payload_size,
                 self._outgoing_average_ratio_calculator.get_average_ratio())
@@ skipping 133 matching lines @@
             name = processor.name()
             if name == self.name():
                 before_mux = False
                 continue
             if not processor.is_active():
                 continue
             if before_mux:
                 # Mux extension cannot be used after extensions
                 # that depend on frame boundary, extension data field, or any
                 # reserved bits which are attributed to each frame.
-                if (name == common.PERFRAME_COMPRESSION_EXTENSION or
-                    name == common.DEFLATE_FRAME_EXTENSION or
+                if (name == common.DEFLATE_FRAME_EXTENSION or
                     name == common.X_WEBKIT_DEFLATE_FRAME_EXTENSION):
                     self.set_active(False)
                     return
             else:
                 # Mux extension should not be applied before any history-based
                 # compression extension.
-                if (name == common.PERFRAME_COMPRESSION_EXTENSION or
-                    name == common.DEFLATE_FRAME_EXTENSION or
+                if (name == common.DEFLATE_FRAME_EXTENSION or
                     name == common.X_WEBKIT_DEFLATE_FRAME_EXTENSION or
                     name == common.PERMESSAGE_COMPRESSION_EXTENSION or
                     name == common.X_WEBKIT_PERMESSAGE_COMPRESSION_EXTENSION):
                     self.set_active(False)
                     return
 
     def _get_extension_response_internal(self):
         self._active = False
         quota = self._request.get_parameter_value(self._QUOTA_PARAM)
         if quota is not None:
@@ skipping 37 matching lines @@
     if processor_class is None:
         return None
     return processor_class(extension_request)
 
 
 def is_compression_extension(extension_name):
     return extension_name in _compression_extension_names
 
 
 # vi:sts=4 sw=4 et