/*
 * Copyright (C) 2017 The Android Open Source Project
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include "perfetto/ext/tracing/core/trace_packet.h"

#include <string>

#include "protos/perfetto/trace/test_event.gen.h"
#include "protos/perfetto/trace/trace.gen.h"
#include "protos/perfetto/trace/trace_packet.gen.h"
#include "test/gtest_and_gmock.h"

namespace perfetto {
namespace {

TEST(TracePacketTest, Simple) {
  protos::gen::TracePacket proto;
  proto.mutable_for_testing()->set_str("string field");
  std::string ser_buf = proto.SerializeAsString();
  TracePacket tp;
  tp.AddSlice(ser_buf.data(), ser_buf.size());
  auto slice = tp.slices().begin();
  ASSERT_NE(tp.slices().end(), slice);
  ASSERT_EQ(ser_buf.data(), slice->start);
  ASSERT_EQ(ser_buf.size(), slice->size);
  ASSERT_EQ(tp.slices().end(), ++slice);

  protos::gen::TracePacket decoded_packet;
  ASSERT_TRUE(decoded_packet.ParseFromString(tp.GetRawBytesForTesting()));
  ASSERT_EQ(proto.for_testing().str(), decoded_packet.for_testing().str());
}

TEST(TracePacketTest, Sliced) {
  protos::gen::TracePacket proto;
  proto.mutable_for_testing()->set_str(
      "this is an arbitrarily long string ........................");
  std::string ser_buf = proto.SerializeAsString();
  TracePacket tp;
  tp.AddSlice({ser_buf.data(), 3});
  tp.AddSlice({ser_buf.data() + 3, 5});
  tp.AddSlice({ser_buf.data() + 3 + 5, ser_buf.size() - 3 - 5});
  ASSERT_EQ(ser_buf.size(), tp.size());

  auto slice = tp.slices().begin();
  ASSERT_NE(tp.slices().end(), slice);
  ASSERT_EQ(ser_buf.data(), slice->start);
  ASSERT_EQ(3u, slice->size);

  ASSERT_NE(tp.slices().end(), ++slice);
  ASSERT_EQ(ser_buf.data() + 3, slice->start);
  ASSERT_EQ(5u, slice->size);

  ASSERT_NE(tp.slices().end(), ++slice);
  ASSERT_EQ(ser_buf.data() + 3 + 5, slice->start);
  ASSERT_EQ(ser_buf.size() - 3 - 5, slice->size);

  ASSERT_EQ(tp.slices().end(), ++slice);

  protos::gen::TracePacket decoded_packet;
  ASSERT_TRUE(decoded_packet.ParseFromString(tp.GetRawBytesForTesting()));
  ASSERT_EQ(proto.for_testing().str(), decoded_packet.for_testing().str());
}

TEST(TracePacketTest, Corrupted) {
  protos::gen::TracePacket proto;
  proto.mutable_for_testing()->set_str("string field");
  std::string ser_buf = proto.SerializeAsString();
  TracePacket tp;
  tp.AddSlice({ser_buf.data(), ser_buf.size() - 2});  // corrupted.
  protos::gen::TracePacket decoded_packet;
  ASSERT_FALSE(decoded_packet.ParseFromString(tp.GetRawBytesForTesting()));
}

// Tests that the GetProtoPreamble() logic returns a valid preamble that allows
// to encode a TracePacket as a field of the root trace.proto message.
TEST(TracePacketTest, GetProtoPreamble) {
  char* preamble;
  size_t preamble_size;

  // Test empty packet.
  TracePacket tp;
  std::tie(preamble, preamble_size) = tp.GetProtoPreamble();
  ASSERT_EQ(2u, preamble_size);
  ASSERT_EQ(0, preamble[1]);

  // Test packet with one slice.
  protos::gen::TracePacket tp_proto;
  char payload[257];
  for (size_t i = 0; i < sizeof(payload) - 1; i++)
    payload[i] = 'a' + (i % 16);
  payload[sizeof(payload) - 1] = '\0';
  tp_proto.mutable_for_testing()->set_str(payload);
  std::string ser_buf = tp_proto.SerializeAsString();
  tp.AddSlice({ser_buf.data(), ser_buf.size()});

  std::tie(preamble, preamble_size) = tp.GetProtoPreamble();
  ASSERT_EQ(3u, preamble_size);

  // Verify that the content is actually parsable using libprotobuf.
  char buf[512];
  memcpy(buf, preamble, preamble_size);
  ASSERT_EQ(1u, tp.slices().size());
  memcpy(&buf[preamble_size], tp.slices()[0].start, tp.slices()[0].size);
  protos::gen::Trace trace;
  ASSERT_TRUE(trace.ParseFromArray(buf, preamble_size + tp.size()));
  ASSERT_EQ(1, trace.packet_size());
  ASSERT_EQ(payload, trace.packet()[0].for_testing().str());
}

TEST(TracePacketTest, MoveOperators) {
  char buf1[5]{};
  char buf2[7]{};

  TracePacket tp;
  tp.AddSlice(buf1, sizeof(buf1));
  tp.AddSlice(buf2, sizeof(buf2));
  tp.AddSlice(Slice::Allocate(11));

  TracePacket moved_tp(std::move(tp));
  ASSERT_EQ(0u, tp.size());
  ASSERT_TRUE(tp.slices().empty());
  ASSERT_EQ(3u, moved_tp.slices().size());
  ASSERT_EQ(5u + 7u + 11u, moved_tp.size());

  TracePacket moved_tp_2;
  moved_tp_2 = std::move(moved_tp);
  ASSERT_EQ(0u, moved_tp.size());
  ASSERT_TRUE(moved_tp.slices().empty());
  ASSERT_EQ(3u, moved_tp_2.slices().size());
  ASSERT_EQ(5u + 7u + 11u, moved_tp_2.size());
}

}  // namespace
}  // namespace perfetto