| // 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_BUNDLED_EXCHANGES_PARSER_H_ |
| #define SERVICES_DATA_DECODER_BUNDLED_EXCHANGES_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/bundled_exchanges_parser.mojom.h" |
| #include "services/service_manager/public/cpp/service_context_ref.h" |
| |
| namespace data_decoder { |
| |
| class BundledExchangesParser : public mojom::BundledExchangesParser { |
| public: |
| BundledExchangesParser( |
| mojo::PendingReceiver<mojom::BundledExchangesParser> receiver, |
| mojo::PendingRemote<mojom::BundleDataSource> data_source); |
| ~BundledExchangesParser() 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::BundledExchangesParser implementation. |
| void ParseMetadata(ParseMetadataCallback callback) override; |
| void ParseResponse(uint64_t response_offset, |
| uint64_t response_length, |
| ParseResponseCallback callback) override; |
| |
| mojo::Receiver<mojom::BundledExchangesParser> receiver_; |
| scoped_refptr<SharedBundleDataSource> data_source_; |
| |
| DISALLOW_COPY_AND_ASSIGN(BundledExchangesParser); |
| }; |
| |
| } // namespace data_decoder |
| |
| #endif // SERVICES_DATA_DECODER_BUNDLED_EXCHANGES_PARSER_H_ |