| // Copyright 2019 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 SERVICES_DATA_DECODER_WEB_BUNDLE_PARSER_H_ |
| #define SERVICES_DATA_DECODER_WEB_BUNDLE_PARSER_H_ |
| |
| #include <memory> |
| |
| #include "base/containers/flat_set.h" |
| #include "base/macros.h" |
| #include "base/memory/ref_counted.h" |
| #include "mojo/public/cpp/bindings/receiver.h" |
| #include "mojo/public/cpp/bindings/remote.h" |
| #include "services/data_decoder/public/mojom/web_bundle_parser.mojom.h" |
| |
| namespace data_decoder { |
| |
| class WebBundleParser : public mojom::WebBundleParser { |
| public: |
| WebBundleParser(mojo::PendingReceiver<mojom::WebBundleParser> receiver, |
| mojo::PendingRemote<mojom::BundleDataSource> data_source); |
| ~WebBundleParser() override; |
| |
| private: |
| class MetadataParser; |
| class ResponseParser; |
| |
| class SharedBundleDataSource |
| : public base::RefCounted<SharedBundleDataSource>, |
| public mojom::BundleDataSource { |
| public: |
| class Observer; |
| |
| explicit SharedBundleDataSource( |
| mojo::PendingRemote<mojom::BundleDataSource> pending_data_source); |
| |
| void AddObserver(Observer* observer); |
| void RemoveObserver(Observer* observer); |
| |
| // Implements mojom::BundleDataSource. |
| void GetSize(GetSizeCallback callback) override; |
| void Read(uint64_t offset, uint64_t length, ReadCallback callback) override; |
| |
| private: |
| friend class base::RefCounted<SharedBundleDataSource>; |
| |
| ~SharedBundleDataSource() override; |
| |
| void OnDisconnect(); |
| |
| mojo::Remote<mojom::BundleDataSource> data_source_; |
| base::flat_set<Observer*> observers_; |
| |
| DISALLOW_COPY_AND_ASSIGN(SharedBundleDataSource); |
| }; |
| |
| // mojom::WebBundleParser implementation. |
| void ParseMetadata(ParseMetadataCallback callback) override; |
| void ParseResponse(uint64_t response_offset, |
| uint64_t response_length, |
| ParseResponseCallback callback) override; |
| |
| mojo::Receiver<mojom::WebBundleParser> receiver_; |
| scoped_refptr<SharedBundleDataSource> data_source_; |
| |
| DISALLOW_COPY_AND_ASSIGN(WebBundleParser); |
| }; |
| |
| } // namespace data_decoder |
| |
| #endif // SERVICES_DATA_DECODER_WEB_BUNDLE_PARSER_H_ |