src/logger/observation_writer.cc

// Copyright 2018 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "src/logger/observation_writer.h"

#include <memory>
#include <utility>

#include "src/logging.h"
#include "src/tracing.h"

namespace cobalt::logger {

using ::cobalt::observation_store::ObservationStoreWriterInterface;

Status ObservationWriter::WriteObservation(const Observation2 &observation,
                                           std::unique_ptr<ObservationMetadata> metadata) const {
  TRACE_DURATION("cobalt_core", "ObservationWriter::WriteObservation");
  auto encrypted_observation = std::make_unique<EncryptedMessage>();
  if (!observation_encrypter_->Encrypt(observation, encrypted_observation.get())) {
    LOG(ERROR) << "Encryption of an Observation failed.";
    return kOther;
  }
  auto store_status =
      observation_store_->StoreObservation(std::move(encrypted_observation), std::move(metadata));
  if (store_status != ObservationStoreWriterInterface::kOk) {
    LOG_FIRST_N(ERROR, 10) << "ObservationStore::StoreObservation() failed with status "
                           << store_status;
    return kOther;
  }
  update_recipient_->NotifyObservationsAdded();
  return kOK;
}

}  // namespace cobalt::logger