src/extensions/browser/api/cast_channel/cast_framer_unittest.cc

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "extensions/browser/api/cast_channel/cast_framer.h"
   6
   7 #include <algorithm>
   8
   9 #include "extensions/common/api/cast_channel/cast_channel.pb.h"
  10 #include "testing/gtest/include/gtest/gtest.h"
  11
  12 namespace extensions {
  13 namespace core_api {
  14 namespace cast_channel {
  15 class CastFramerTest : public testing::Test {
  16  public:
  17   CastFramerTest() {}
  18   virtual ~CastFramerTest() {}
  19
  20   virtual void SetUp() OVERRIDE {
  21     cast_message_.set_protocol_version(CastMessage::CASTV2_1_0);
  22     cast_message_.set_source_id("source");
  23     cast_message_.set_destination_id("destination");
  24     cast_message_.set_namespace_("namespace");
  25     cast_message_.set_payload_type(CastMessage::STRING);
  26     cast_message_.set_payload_utf8("payload");
  27     ASSERT_TRUE(MessageFramer::Serialize(cast_message_, &cast_message_str_));
  28
  29     buffer_ = new net::GrowableIOBuffer;
  30     buffer_->SetCapacity(MessageFramer::MessageHeader::max_message_size());
  31     framer_.reset(new MessageFramer(buffer_.get()));
  32   }
  33
  34   void WriteToBuffer(const std::string& data) {
  35     memcpy(buffer_->StartOfBuffer(), data.data(), data.size());
  36   }
  37
  38  protected:
  39   CastMessage cast_message_;
  40   std::string cast_message_str_;
  41   scoped_refptr<net::GrowableIOBuffer> buffer_;
  42   scoped_ptr<MessageFramer> framer_;
  43 };
  44
  45 TEST_F(CastFramerTest, TestMessageFramerCompleteMessage) {
  46   ChannelError error;
  47   size_t message_length;
  48
  49   WriteToBuffer(cast_message_str_);
  50
  51   // Receive 1 byte of the header, framer demands 3 more bytes.
  52   EXPECT_EQ(4u, framer_->BytesRequested());
  53   EXPECT_EQ(NULL, framer_->Ingest(1, &message_length, &error).get());
  54   EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, error);
  55   EXPECT_EQ(3u, framer_->BytesRequested());
  56
  57   // Ingest remaining 3, expect that the framer has moved on to requesting the
  58   // body contents.
  59   EXPECT_EQ(NULL, framer_->Ingest(3, &message_length, &error).get());
  60   EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, error);
  61   EXPECT_EQ(
  62       cast_message_str_.size() - MessageFramer::MessageHeader::header_size(),
  63       framer_->BytesRequested());
  64
  65   // Remainder of packet sent over the wire.
  66   scoped_ptr<CastMessage> message;
  67   message = framer_->Ingest(framer_->BytesRequested(), &message_length, &error);
  68   EXPECT_NE(static_cast<CastMessage*>(NULL), message.get());
  69   EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, error);
  70   EXPECT_EQ(message->SerializeAsString(), cast_message_.SerializeAsString());
  71   EXPECT_EQ(4u, framer_->BytesRequested());
  72   EXPECT_EQ(message->SerializeAsString().size(), message_length);
  73 }
  74
  75 TEST_F(CastFramerTest, TestSerializeErrorMessageTooLarge) {
  76   std::string serialized;
  77   CastMessage big_message;
  78   big_message.CopyFrom(cast_message_);
  79   std::string payload;
  80   payload.append(MessageFramer::MessageHeader::max_message_size() + 1, 'x');
  81   big_message.set_payload_utf8(payload);
  82   EXPECT_FALSE(MessageFramer::Serialize(big_message, &serialized));
  83 }
  84
  85 TEST_F(CastFramerTest, TestIngestIllegalLargeMessage) {
  86   std::string mangled_cast_message = cast_message_str_;
  87   mangled_cast_message[0] = 88;
  88   mangled_cast_message[1] = 88;
  89   mangled_cast_message[2] = 88;
  90   mangled_cast_message[3] = 88;
  91   WriteToBuffer(mangled_cast_message);
  92
  93   size_t bytes_ingested;
  94   ChannelError error;
  95   EXPECT_EQ(4u, framer_->BytesRequested());
  96   EXPECT_EQ(NULL, framer_->Ingest(4, &bytes_ingested, &error).get());
  97   EXPECT_EQ(cast_channel::CHANNEL_ERROR_INVALID_MESSAGE, error);
  98   EXPECT_EQ(0u, framer_->BytesRequested());
  99
 100   // Test that the parser enters a terminal error state.
 101   WriteToBuffer(cast_message_str_);
 102   EXPECT_EQ(0u, framer_->BytesRequested());
 103   EXPECT_EQ(NULL, framer_->Ingest(4, &bytes_ingested, &error).get());
 104   EXPECT_EQ(cast_channel::CHANNEL_ERROR_INVALID_MESSAGE, error);
 105   EXPECT_EQ(0u, framer_->BytesRequested());
 106 }
 107
 108 TEST_F(CastFramerTest, TestUnparsableBodyProto) {
 109   // Message header is OK, but the body is replaced with "x"en.
 110   std::string mangled_cast_message = cast_message_str_;
 111   for (size_t i = MessageFramer::MessageHeader::header_size();
 112        i < mangled_cast_message.size();
 113        ++i) {
 114     std::fill(mangled_cast_message.begin() +
 115                   MessageFramer::MessageHeader::header_size(),
 116               mangled_cast_message.end(),
 117               'x');
 118   }
 119   WriteToBuffer(mangled_cast_message);
 120
 121   // Send header.
 122   size_t message_length;
 123   ChannelError error;
 124   EXPECT_EQ(4u, framer_->BytesRequested());
 125   EXPECT_EQ(NULL, framer_->Ingest(4, &message_length, &error).get());
 126   EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, error);
 127   EXPECT_EQ(cast_message_str_.size() - 4, framer_->BytesRequested());
 128
 129   // Send body, expect an error.
 130   scoped_ptr<CastMessage> message;
 131   EXPECT_EQ(NULL,
 132             framer_->Ingest(framer_->BytesRequested(), &message_length, &error)
 133                 .get());
 134   EXPECT_EQ(cast_channel::CHANNEL_ERROR_INVALID_MESSAGE, error);
 135 }
 136 }  // namespace cast_channel
 137 }  // namespace core_api
 138 }  // namespace extensions