/* * Copyright (C) 2009 Ericsson AB * All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer * in the documentation and/or other materials provided with the * distribution. * 3. Neither the name of Ericsson nor the names of its contributors * may be used to endorse or promote products derived from this * software without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. */ #include "config.h" #if ENABLE(EVENTSOURCE) #include "EventSource.h" #include "Cache.h" #include "DOMWindow.h" #include "Event.h" #include "EventException.h" #include "PlatformString.h" #include "MessageEvent.h" #include "ResourceError.h" #include "ResourceRequest.h" #include "ResourceResponse.h" #include "ScriptExecutionContext.h" #include "SerializedScriptValue.h" #include "TextResourceDecoder.h" #include "ThreadableLoader.h" namespace WebCore { const unsigned long long EventSource::defaultReconnectDelay = 3000; EventSource::EventSource(const String& url, ScriptExecutionContext* context, ExceptionCode& ec) : ActiveDOMObject(context, this) , m_state(CONNECTING) , m_reconnectTimer(this, &EventSource::reconnectTimerFired) , m_discardTrailingNewline(false) , m_failSilently(false) , m_requestInFlight(false) , m_reconnectDelay(defaultReconnectDelay) { if (url.isEmpty() || !(m_url = context->completeURL(url)).isValid()) { ec = SYNTAX_ERR; return; } // FIXME: should support cross-origin requests if (!scriptExecutionContext()->securityOrigin()->canRequest(m_url)) { ec = SECURITY_ERR; return; } m_origin = scriptExecutionContext()->securityOrigin()->toString(); m_decoder = TextResourceDecoder::create("text/plain", "UTF-8"); setPendingActivity(this); connect(); } EventSource::~EventSource() { } void EventSource::connect() { ResourceRequest request(m_url); request.setHTTPMethod("GET"); request.setHTTPHeaderField("Accept", "text/event-stream"); request.setHTTPHeaderField("Cache-Control", "no-cache"); if (!m_lastEventId.isEmpty()) request.setHTTPHeaderField("Last-Event-ID", m_lastEventId); ThreadableLoaderOptions options; options.sendLoadCallbacks = true; options.sniffContent = false; options.allowCredentials = true; m_loader = ThreadableLoader::create(scriptExecutionContext(), this, request, options); m_requestInFlight = true; if (!scriptExecutionContext()->isWorkerContext()) cache()->loader()->nonCacheRequestInFlight(m_url); } void EventSource::endRequest() { m_requestInFlight = false; if (!m_failSilently) dispatchEvent(Event::create(eventNames().errorEvent, false, false)); if (!scriptExecutionContext()->isWorkerContext()) cache()->loader()->nonCacheRequestComplete(m_url); if (m_state != CLOSED) scheduleReconnect(); else unsetPendingActivity(this); } void EventSource::scheduleReconnect() { m_state = CONNECTING; m_reconnectTimer.startOneShot(m_reconnectDelay / 1000); } void EventSource::reconnectTimerFired(Timer<EventSource>*) { connect(); } String EventSource::url() const { return m_url.string(); } EventSource::State EventSource::readyState() const { return m_state; } void EventSource::close() { if (m_state == CLOSED) return; if (m_reconnectTimer.isActive()) { m_reconnectTimer.stop(); unsetPendingActivity(this); } m_state = CLOSED; m_failSilently = true; if (m_requestInFlight) m_loader->cancel(); } ScriptExecutionContext* EventSource::scriptExecutionContext() const { return ActiveDOMObject::scriptExecutionContext(); } void EventSource::didReceiveResponse(const ResourceResponse& response) { int statusCode = response.httpStatusCode(); if (statusCode == 200 && response.httpHeaderField("Content-Type") == "text/event-stream") { m_state = OPEN; dispatchEvent(Event::create(eventNames().openEvent, false, false)); } else { if (statusCode <= 200 || statusCode > 299) m_state = CLOSED; m_loader->cancel(); } } void EventSource::didReceiveData(const char* data, int length) { append(m_receiveBuf, m_decoder->decode(data, length)); parseEventStream(); } void EventSource::didFinishLoading(unsigned long) { if (m_receiveBuf.size() > 0 || m_data.size() > 0) { append(m_receiveBuf, "\n\n"); parseEventStream(); } m_state = CONNECTING; endRequest(); } void EventSource::didFail(const ResourceError& error) { int canceled = error.isCancellation(); if (((m_state == CONNECTING) && !canceled) || ((m_state == OPEN) && canceled)) m_state = CLOSED; endRequest(); } void EventSource::didFailRedirectCheck() { m_state = CLOSED; m_loader->cancel(); } void EventSource::parseEventStream() { unsigned int bufPos = 0; unsigned int bufSize = m_receiveBuf.size(); while (bufPos < bufSize) { if (m_discardTrailingNewline) { if (m_receiveBuf[bufPos] == '\n') bufPos++; m_discardTrailingNewline = false; } int lineLength = -1; int fieldLength = -1; for (unsigned int i = bufPos; lineLength < 0 && i < bufSize; i++) { switch (m_receiveBuf[i]) { case ':': if (fieldLength < 0) fieldLength = i - bufPos; break; case '\r': m_discardTrailingNewline = true; case '\n': lineLength = i - bufPos; break; } } if (lineLength < 0) break; parseEventStreamLine(bufPos, fieldLength, lineLength); bufPos += lineLength + 1; } if (bufPos == bufSize) m_receiveBuf.clear(); else if (bufPos) m_receiveBuf.remove(0, bufPos); } void EventSource::parseEventStreamLine(unsigned int bufPos, int fieldLength, int lineLength) { if (!lineLength) { if (!m_data.isEmpty()) dispatchEvent(createMessageEvent()); if (!m_eventName.isEmpty()) m_eventName = ""; } else if (fieldLength) { bool noValue = fieldLength < 0; String field(&m_receiveBuf[bufPos], noValue ? lineLength : fieldLength); int step; if (noValue) step = lineLength; else if (m_receiveBuf[bufPos + fieldLength + 1] != ' ') step = fieldLength + 1; else step = fieldLength + 2; bufPos += step; int valueLength = lineLength - step; if (field == "data") { if (m_data.size() > 0) m_data.append('\n'); if (valueLength) m_data.append(&m_receiveBuf[bufPos], valueLength); } else if (field == "event") m_eventName = valueLength ? String(&m_receiveBuf[bufPos], valueLength) : ""; else if (field == "id") m_lastEventId = valueLength ? String(&m_receiveBuf[bufPos], valueLength) : ""; else if (field == "retry") { if (!valueLength) m_reconnectDelay = defaultReconnectDelay; else { String value(&m_receiveBuf[bufPos], valueLength); bool ok; unsigned long long retry = value.toUInt64(&ok); if (ok) m_reconnectDelay = retry; } } } } void EventSource::stop() { close(); } PassRefPtr<MessageEvent> EventSource::createMessageEvent() { RefPtr<MessageEvent> event = MessageEvent::create(); event->initMessageEvent(m_eventName.isEmpty() ? eventNames().messageEvent : AtomicString(m_eventName), false, false, SerializedScriptValue::create(String::adopt(m_data)), m_origin, m_lastEventId, 0, 0); return event.release(); } EventTargetData* EventSource::eventTargetData() { return &m_eventTargetData; } EventTargetData* EventSource::ensureEventTargetData() { return &m_eventTargetData; } } // namespace WebCore #endif // ENABLE(EVENTSOURCE)