diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-28 14:29:10 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-28 14:29:10 +0000 |
commit | 2aa4a82499d4becd2284cdb482213d541b8804dd (patch) | |
tree | b80bf8bf13c3766139fbacc530efd0dd9d54394c /dom/base/EventSource.h | |
parent | Initial commit. (diff) | |
download | firefox-upstream.tar.xz firefox-upstream.zip |
Adding upstream version 86.0.1.upstream/86.0.1upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'dom/base/EventSource.h')
-rw-r--r-- | dom/base/EventSource.h | 104 |
1 files changed, 104 insertions, 0 deletions
diff --git a/dom/base/EventSource.h b/dom/base/EventSource.h new file mode 100644 index 0000000000..22c3f78a37 --- /dev/null +++ b/dom/base/EventSource.h @@ -0,0 +1,104 @@ +/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */ +/* vim: set ts=8 sts=2 et sw=2 tw=80: */ +/* This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ + +/* + * This implementation has support only for http requests. It is because the + * spec has defined event streams only for http. HTTP is required because + * this implementation uses some http headers: "Last-Event-ID", "Cache-Control" + * and "Accept". + */ + +#ifndef mozilla_dom_EventSource_h +#define mozilla_dom_EventSource_h + +#include "mozilla/Atomics.h" +#include "mozilla/Attributes.h" +#include "mozilla/DOMEventTargetHelper.h" +#include "nsDeque.h" +#include "nsICookieJarSettings.h" + +class nsIGlobalObject; + +namespace mozilla { + +class ErrorResult; + +namespace dom { + +struct EventSourceInit; + +class EventSourceImpl; + +class EventSource final : public DOMEventTargetHelper { + friend class EventSourceImpl; + + public: + NS_DECL_ISUPPORTS_INHERITED + NS_DECL_CYCLE_COLLECTION_CLASS_INHERITED(EventSource, DOMEventTargetHelper) + virtual bool IsCertainlyAliveForCC() const override; + + // EventTarget + void DisconnectFromOwner() override { + DOMEventTargetHelper::DisconnectFromOwner(); + Close(); + } + + JSObject* WrapObject(JSContext* aCx, + JS::Handle<JSObject*> aGivenProto) override; + + // WebIDL + static already_AddRefed<EventSource> Constructor( + const GlobalObject& aGlobal, const nsAString& aURL, + const EventSourceInit& aEventSourceInitDict, ErrorResult& aRv); + + void GetUrl(nsAString& aURL) const { + AssertIsOnTargetThread(); + aURL = mOriginalURL; + } + + bool WithCredentials() const { + AssertIsOnTargetThread(); + return mWithCredentials; + } + + uint16_t ReadyState() const { + AssertIsOnTargetThread(); + return mReadyState; + } + + IMPL_EVENT_HANDLER(open) + IMPL_EVENT_HANDLER(message) + IMPL_EVENT_HANDLER(error) + + void Close(); + + private: + EventSource(nsIGlobalObject* aGlobal, + nsICookieJarSettings* aCookieJarSettings, bool aWithCredentials); + virtual ~EventSource(); + // prevent bad usage + EventSource(const EventSource& x) = delete; + EventSource& operator=(const EventSource& x) = delete; + + void AssertIsOnTargetThread() const { + MOZ_ASSERT(NS_IsMainThread() == mIsMainThread); + } + + nsresult CreateAndDispatchSimpleEvent(const nsAString& aName); + + // This EventSourceImpl is created, managed and destroyed + // by EventSource. + RefPtr<EventSourceImpl> mESImpl; + nsString mOriginalURL; + Atomic<uint32_t> mReadyState; + const bool mWithCredentials; + const bool mIsMainThread; +}; + +} // namespace dom +} // namespace mozilla + +#endif // mozilla_dom_EventSource_h |