Introduce EventSourceParser

third_party/WebKit/Source/core/page/EventSourceParser.h

+// Copyright 2016 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+#ifndef EventSourceParser_h
+#define EventSourceParser_h
+
+#include "core/CoreExport.h"
+#include "platform/heap/Handle.h"
+#include "wtf/Vector.h"
+#include "wtf/text/AtomicString.h"
+#include "wtf/text/WTFString.h"
+
+namespace blink {
+
+class CORE_EXPORT EventSourceParser final : public GarbageCollectedFinalized<EventSourceParser> {
+public:
+    class CORE_EXPORT Client : public GarbageCollectedMixin {
+    public:
+        virtual ~Client() {}
+        virtual void onMessageEvent(const AtomicString& type, const String& data, const AtomicString& lastEventId) = 0;
+        virtual void onReconnectionTimeSet(unsigned long long reconnectionTime) = 0;
+        DEFINE_INLINE_VIRTUAL_TRACE() {}
+    };
+
+    EventSourceParser(const AtomicString& lastEventId, Client* client)
+        : m_id(lastEventId)
+        , m_lastEventId(lastEventId)
+        , m_client(client)
+    {
+    }
+    void addBytes(const char*, size_t);
+    const AtomicString& lastEventId() const { return m_lastEventId; }
+    // Stop parsing. This can be called from Client::onMessageEvent.
+    void stop() { m_isStopped = true; }
+    DECLARE_TRACE();
+
+private:
+    void parseLine();
+
+    Vector<char> m_line;
+    AtomicString m_event;
+    Vector<char> m_data;
+    // This is used to store the currently processed ID field value.
+    AtomicString m_id;
+    // This is used to store the last dispatched ID field value.
+    AtomicString m_lastEventId;
+    Member<Client> m_client;
+    bool m_isRecognizingCRLF = false;
+    bool m_isRecognizingBOM = true;
+    bool m_isStopped = false;
+};
+
+} // namespace blink
+
+#endif // EventSourceParser_h