15c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/* 25c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Copyright (C) 2011, 2012 Google Inc. All rights reserved. 35c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * 45c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Redistribution and use in source and binary forms, with or without 55c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * modification, are permitted provided that the following conditions are 65c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * met: 75c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * 85c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * * Redistributions of source code must retain the above copyright 95c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * notice, this list of conditions and the following disclaimer. 105c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * * Redistributions in binary form must reproduce the above 115c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * copyright notice, this list of conditions and the following disclaimer 125c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * in the documentation and/or other materials provided with the 135c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * distribution. 145c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * * Neither the name of Google Inc. nor the names of its 155c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * contributors may be used to endorse or promote products derived from 165c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * this software without specific prior written permission. 175c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * 185c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 195c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 205c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR 215c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT 225c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 235c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT 245c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, 255c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY 265c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 275c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 285c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 295c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 305c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 315c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)#ifndef WebSocketImpl_h 325c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)#define WebSocketImpl_h 335c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 3453e740f4a82e17f3ae59772501622dc354e42336Torne (Richard Coles)#include "modules/websockets/WebSocketChannelClient.h" 35323480423219ecd77329f8326dc5e0e3b50926d4Torne (Richard Coles)#include "platform/heap/Handle.h" 365267f701546148b83dfbe1d151cb184385bb5c22Torne (Richard Coles)#include "public/platform/WebCommon.h" 375d92fedcae5e801a8b224de090094f2d9df0b54aTorne (Richard Coles)#include "public/platform/WebString.h" 38f91f5fa1608c2cdd9af1842fb5dadbe78275be2aBo Liu#include "public/web/WebSocket.h" 39f91f5fa1608c2cdd9af1842fb5dadbe78275be2aBo Liu#include "public/web/WebSocketClient.h" 40591b958dee2cf159d33a0b931e6231072eaf38d5Ben Murdoch#include "wtf/OwnPtr.h" 41591b958dee2cf159d33a0b931e6231072eaf38d5Ben Murdoch#include "wtf/RefPtr.h" 425c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 4351b2906e11752df6c18351cf520e30522d3b53a1Torne (Richard Coles)namespace blink { 445c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 455c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)class WebDocument; 46c1847b1379d12d0e05df27436bf19a9b1bf12deaTorne (Richard Coles)class WebSocketChannel; 47c1847b1379d12d0e05df27436bf19a9b1bf12deaTorne (Richard Coles)class WebSocketChannelClientProxy; 485c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)class WebURL; 495c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 50c1847b1379d12d0e05df27436bf19a9b1bf12deaTorne (Richard Coles)class WebSocketImpl FINAL : public WebSocket { 515c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)public: 525c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) WebSocketImpl(const WebDocument&, WebSocketClient*); 535c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) virtual ~WebSocketImpl(); 545c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 555c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) bool isNull() const { return !m_private; } 565c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 575c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) virtual BinaryType binaryType() const OVERRIDE; 585c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) virtual bool setBinaryType(BinaryType) OVERRIDE; 595c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) virtual void connect(const WebURL&, const WebString& protocol) OVERRIDE; 605c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) virtual WebString subprotocol() OVERRIDE; 615c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) virtual WebString extensions() OVERRIDE; 625c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) virtual bool sendText(const WebString&) OVERRIDE; 635c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) virtual bool sendArrayBuffer(const WebArrayBuffer&) OVERRIDE; 645c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) virtual unsigned long bufferedAmount() const OVERRIDE; 655c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) virtual void close(int code, const WebString& reason) OVERRIDE; 665c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) virtual void fail(const WebString& reason) OVERRIDE; 675c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) virtual void disconnect() OVERRIDE; 685c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 69c1847b1379d12d0e05df27436bf19a9b1bf12deaTorne (Richard Coles) // WebSocketChannelClient methods proxied by WebSocketChannelClientProxy. 70c1847b1379d12d0e05df27436bf19a9b1bf12deaTorne (Richard Coles) void didConnect(const String& subprotocol, const String& extensions); 71c1847b1379d12d0e05df27436bf19a9b1bf12deaTorne (Richard Coles) void didReceiveMessage(const String& message); 72c1847b1379d12d0e05df27436bf19a9b1bf12deaTorne (Richard Coles) void didReceiveBinaryData(PassOwnPtr<Vector<char> > binaryData); 73c1847b1379d12d0e05df27436bf19a9b1bf12deaTorne (Richard Coles) void didReceiveMessageError(); 74c1847b1379d12d0e05df27436bf19a9b1bf12deaTorne (Richard Coles) void didConsumeBufferedAmount(unsigned long consumed); 75c1847b1379d12d0e05df27436bf19a9b1bf12deaTorne (Richard Coles) void didStartClosingHandshake(); 76c1847b1379d12d0e05df27436bf19a9b1bf12deaTorne (Richard Coles) void didClose(WebSocketChannelClient::ClosingHandshakeCompletionStatus, unsigned short code, const String& reason); 77197021e6b966cfb06891637935ef33fff06433d1Ben Murdoch 785c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)private: 79e38fbeeb576b5094e34e038ab88d9d6a5c5c2214Torne (Richard Coles) Persistent<WebSocketChannel> m_private; 805c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) WebSocketClient* m_client; 81c1847b1379d12d0e05df27436bf19a9b1bf12deaTorne (Richard Coles) Persistent<WebSocketChannelClientProxy> m_channelProxy; 825c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) BinaryType m_binaryType; 835d92fedcae5e801a8b224de090094f2d9df0b54aTorne (Richard Coles) WebString m_subprotocol; 845d92fedcae5e801a8b224de090094f2d9df0b54aTorne (Richard Coles) WebString m_extensions; 8576c265b59aa821ccbf8c75ab2bb0d036e97d2956Torne (Richard Coles) bool m_isClosingOrClosed; 8676c265b59aa821ccbf8c75ab2bb0d036e97d2956Torne (Richard Coles) // m_bufferedAmount includes m_bufferedAmountAfterClose. 8776c265b59aa821ccbf8c75ab2bb0d036e97d2956Torne (Richard Coles) unsigned long m_bufferedAmount; 8876c265b59aa821ccbf8c75ab2bb0d036e97d2956Torne (Richard Coles) unsigned long m_bufferedAmountAfterClose; 895c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 905c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 9151b2906e11752df6c18351cf520e30522d3b53a1Torne (Richard Coles)} // namespace blink 925c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 935c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)#endif // WebWebSocketChannelImpl_h 94