#ifndef COMPONENTS_SYNC_TEST_TEST_MATCHERS_H_
#define COMPONENTS_SYNC_TEST_TEST_MATCHERS_H_
#include <map>
#include <memory>
#include <string>
#include <utility>
#include "components/sync/model/metadata_batch.h"
#include "components/sync/protocol/entity_metadata.pb.h"
#include "components/sync/protocol/model_type_state.pb.h"
#include "testing/gmock/include/gmock/gmock.h"
namespace syncer {
MATCHER(NoModelError, "") {
if (arg.has_value()) {
*result_listener << "which represents error: " << arg->ToString();
return false;
}
return true;
}
MATCHER(IsEmptyMetadataBatch, "") {
return arg != nullptr &&
sync_pb::ModelTypeState().SerializeAsString() ==
arg->GetModelTypeState().SerializeAsString() &&
arg->TakeAllMetadata().empty();
}
MATCHER_P2(MetadataBatchContains, state, entities, "") {
if (arg == nullptr) {
*result_listener << "which is null";
return false;
}
if (!ExplainMatchResult(testing::Matcher<sync_pb::ModelTypeState>(state),
arg->GetModelTypeState(), result_listener)) {
return false;
}
std::map<std::string, std::unique_ptr<sync_pb::EntityMetadata>>
metadata_by_storage_key = arg->TakeAllMetadata();
std::map<std::string, sync_pb::EntityMetadata> copyable_metadata;
for (auto& [storage_key, metadata] : metadata_by_storage_key) {
copyable_metadata[storage_key] = std::move(*metadata);
}
return ExplainMatchResult(
testing::Matcher<std::map<std::string, sync_pb::EntityMetadata>>(
entities),
copyable_metadata, result_listener);
}
MATCHER_P(HasEncryptionKeyName, expected_key_name, "") {
return arg.encryption_key_name() == expected_key_name;
}
MATCHER(HasInitialSyncDone, "") {
return arg.initial_sync_state() ==
sync_pb::ModelTypeState_InitialSyncState_INITIAL_SYNC_DONE;
}
MATCHER(HasNotInitialSyncDone, "") {
return arg.initial_sync_state() ==
sync_pb::
ModelTypeState_InitialSyncState_INITIAL_SYNC_STATE_UNSPECIFIED;
}
}
#endif