o ˆì_c ã@svddlmZddlmZmZmZmZddlmZddlm Z m Z gd¢Z Gdd„dƒZ Gd d „d ƒZ Gd d „d ƒZd S)é)Ú annotations)ÚListÚOptionalÚSequenceÚTupleé)Úframes)Ú ExtensionNameÚExtensionParameter)Ú ExtensionÚClientExtensionFactoryÚServerExtensionFactoryc@s6eZdZUdZded< ddœdd d „Zdd d„ZdS)r z% Base class for extensions. r ÚnameN)Úmax_sizeÚframeú frames.Framerú Optional[int]ÚreturncCódS)a) Decode an incoming frame. Args: frame (Frame): incoming frame. max_size: maximum payload size in bytes. Returns: Frame: Decoded frame. Raises: PayloadTooBig: if decoding the payload exceeds ``max_size``. N©)ÚselfrrrrúE/usr/local/lib/python3.10/dist-packages/websockets/extensions/base.pyÚdecodeózExtension.decodecCr)zš Encode an outgoing frame. Args: frame (Frame): outgoing frame. Returns: Frame: Encoded frame. Nr)rrrrrÚencode*rzExtension.encode)rrrrrr)rrrr)Ú__name__Ú __module__Ú __qualname__Ú__doc__Ú__annotations__rrrrrrr s ür c@s0eZdZUdZded< ddd„Zdd d„ZdS)r z: Base class for client-side extension factories. r rrúList[ExtensionParameter]cCr)z§ Build parameters to send to the server for this extension. Returns: List[ExtensionParameter]: Parameters to send to the server. Nr)rrrrÚget_request_params@rz)ClientExtensionFactory.get_request_paramsÚparamsúSequence[ExtensionParameter]Úaccepted_extensionsúSequence[Extension]r cCr)aÈ Process parameters received from the server. Args: params (Sequence[ExtensionParameter]): parameters received from the server for this extension. accepted_extensions (Sequence[Extension]): list of previously accepted extensions. Returns: Extension: An extension instance. Raises: NegotiationError: if parameters aren't acceptable. Nr©rr"r$rrrÚprocess_response_paramsIrz.ClientExtensionFactory.process_response_paramsN)rr )r"r#r$r%rr )rrrrrr!r'rrrrr 7s   r c@s&eZdZUdZded< d d d „Zd S)r z: Base class for server-side extension factories. r rr"r#r$r%rú*Tuple[List[ExtensionParameter], Extension]cCr)aŒ Process parameters received from the client. Args: params (Sequence[ExtensionParameter]): parameters received from the client for this extension. accepted_extensions (Sequence[Extension]): list of previously accepted extensions. Returns: Tuple[List[ExtensionParameter], Extension]: To accept the offer, parameters to send to the client for this extension and an extension instance. Raises: NegotiationError: to reject the offer, if parameters received from the client aren't acceptable. Nrr&rrrÚprocess_request_paramsirz-ServerExtensionFactory.process_request_paramsN)r"r#r$r%rr()rrrrrr)rrrrr `s r N)Ú __future__rÚtypingrrrrÚrr r Ú__all__r r r rrrrÚs  +)