| // Copyright 2014 The Chromium Authors |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #ifndef COMPONENTS_SYNC_ENGINE_COMMIT_CONTRIBUTION_IMPL_H_ |
| #define COMPONENTS_SYNC_ENGINE_COMMIT_CONTRIBUTION_IMPL_H_ |
| |
| #include <stddef.h> |
| #include <stdint.h> |
| |
| #include "base/functional/callback.h" |
| #include "base/memory/raw_ptr.h" |
| #include "components/sync/base/passphrase_enums.h" |
| #include "components/sync/engine/commit_and_get_updates_types.h" |
| #include "components/sync/engine/commit_contribution.h" |
| #include "components/sync/protocol/data_type_progress_marker.pb.h" |
| |
| namespace sync_pb { |
| class ClientToServerMessage; |
| class SyncEntity; |
| class ClientToServerResponse; |
| } // namespace sync_pb |
| |
| namespace syncer { |
| |
| class Cryptographer; |
| class ModelTypeWorker; |
| |
| // A sync type's contribution to an outgoing commit message. |
| // |
| // Helps build a commit message and process its response. It collaborates |
| // closely with the ModelTypeWorker. |
| class CommitContributionImpl : public CommitContribution { |
| public: |
| // If a non-null |cryptographer| is passed, it must outlive this object and |
| // will be used to encrypt the constructed commit. Otherwise, the commit won't |
| // be encrypted. Only one of |on_commit_response_callback| and |
| // |on_full_commit_failure_callback| will be called. |
| // TODO(rushans): there is still possible rare case when both of these |
| // callbacks are never called, i.e. if get updates from the server fails. |
| CommitContributionImpl( |
| ModelType type, |
| const sync_pb::DataTypeContext& context, |
| CommitRequestDataList commit_requests, |
| base::OnceCallback<void(const CommitResponseDataList&, |
| const FailedCommitResponseDataList&)> |
| on_commit_response_callback, |
| base::OnceCallback<void(SyncCommitError)> on_full_commit_failure_callback, |
| Cryptographer* cryptographer, |
| PassphraseType passphrase_type, |
| bool only_commit_specifics); |
| |
| CommitContributionImpl(const CommitContributionImpl&) = delete; |
| CommitContributionImpl& operator=(const CommitContributionImpl&) = delete; |
| |
| ~CommitContributionImpl() override; |
| |
| // Implementation of CommitContribution |
| void AddToCommitMessage(sync_pb::ClientToServerMessage* msg) override; |
| SyncerError ProcessCommitResponse( |
| const sync_pb::ClientToServerResponse& response, |
| StatusController* status) override; |
| void ProcessCommitFailure(SyncCommitError commit_error) override; |
| size_t GetNumEntries() const override; |
| |
| // Public for testing. |
| // Copies data to be committed from CommitRequestData into SyncEntity proto. |
| static void PopulateCommitProto(ModelType type, |
| const CommitRequestData& commit_entity, |
| sync_pb::SyncEntity* commit_proto); |
| |
| private: |
| // Generates id for new entities and encrypts entity if needed. |
| void AdjustCommitProto(sync_pb::SyncEntity* commit_proto); |
| |
| const ModelType type_; |
| |
| // A callback to inform the object that created this contribution about commit |
| // result. |
| base::OnceCallback<void(const CommitResponseDataList&, |
| const FailedCommitResponseDataList&)> |
| on_commit_response_callback_; |
| |
| // A callback to inform the object that created this contribution about commit |
| // failure. This callback differs from |on_commit_response_callback_| and will |
| // be called when the server respond with any error code or do not respond at |
| // all (i.e. there is no internet connection). |
| base::OnceCallback<void(SyncCommitError)> on_full_commit_failure_callback_; |
| |
| // Null if |type_| is not encrypted. Otherwise this is used to encrypt the |
| // committed entities. |
| const raw_ptr<Cryptographer> cryptographer_; |
| |
| const PassphraseType passphrase_type_; |
| |
| // The type-global context information. |
| const sync_pb::DataTypeContext context_; |
| |
| // The list of entities to be committed. |
| CommitRequestDataList commit_requests_; |
| |
| // The index in the commit message where this contribution's entities are |
| // added. Used to correlate per-item requests with per-item responses. |
| size_t entries_start_index_; |
| |
| // Don't send any metadata to server, only specifics. This is needed for |
| // commit only types to save bandwidth. |
| bool only_commit_specifics_; |
| }; |
| |
| } // namespace syncer |
| |
| #endif // COMPONENTS_SYNC_ENGINE_COMMIT_CONTRIBUTION_IMPL_H_ |