/*

 * 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_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();

    for (;;) {

        int lineLength = -1;

        int fieldLength = -1;

        int carriageReturn = 0;

        for (unsigned int i = bufPos; lineLength < 0 && i < bufSize; i++) {

            switch (m_receiveBuf[i]) {

            case ':':

                if (fieldLength < 0)

                    fieldLength = i - bufPos;

                break;

            case '\n':

                if (i > bufPos && m_receiveBuf[i - 1] == '\r') {

                    carriageReturn++;

                    i--;

                }

                lineLength = i - bufPos;

                break;

            }

        }

        if (lineLength < 0)

            break;

        parseEventStreamLine(bufPos, fieldLength, lineLength);

        bufPos += lineLength + carriageReturn + 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)