// Copyright (c) 2012 The Chromium 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 "dbus/message.h"
#include "base/basictypes.h"
#include "base/logging.h"
#include "base/memory/scoped_ptr.h"
#include "base/posix/eintr_wrapper.h"
#include "dbus/object_path.h"
#include "dbus/test_proto.pb.h"
#include "testing/gtest/include/gtest/gtest.h"
namespace dbus {
// Test that a byte can be properly written and read. We only have this
// test for byte, as repeating this for other basic types is too redundant.
TEST(MessageTest, AppendAndPopByte) {
scoped_ptr<Response> message(Response::CreateEmpty());
MessageWriter writer(message.get());
writer.AppendByte(123); // The input is 123.
MessageReader reader(message.get());
ASSERT_TRUE(reader.HasMoreData()); // Should have data to read.
ASSERT_EQ(Message::BYTE, reader.GetDataType());
bool bool_value = false;
// Should fail as the type is not bool here.
ASSERT_FALSE(reader.PopBool(&bool_value));
uint8 byte_value = 0;
ASSERT_TRUE(reader.PopByte(&byte_value));
EXPECT_EQ(123, byte_value); // Should match with the input.
ASSERT_FALSE(reader.HasMoreData()); // Should not have more data to read.
// Try to get another byte. Should fail.
ASSERT_FALSE(reader.PopByte(&byte_value));
}
// Check all basic types can be properly written and read.
TEST(MessageTest, AppendAndPopBasicDataTypes) {
scoped_ptr<Response> message(Response::CreateEmpty());
MessageWriter writer(message.get());
// Append 0, 1, 2, 3, 4, 5, 6, 7, 8, "string", "/object/path".
writer.AppendByte(0);
writer.AppendBool(true);
writer.AppendInt16(2);
writer.AppendUint16(3);
writer.AppendInt32(4);
writer.AppendUint32(5);
writer.AppendInt64(6);
writer.AppendUint64(7);
writer.AppendDouble(8.0);
writer.AppendString("string");
writer.AppendObjectPath(ObjectPath("/object/path"));
uint8 byte_value = 0;
bool bool_value = false;
int16 int16_value = 0;
uint16 uint16_value = 0;
int32 int32_value = 0;
uint32 uint32_value = 0;
int64 int64_value = 0;
uint64 uint64_value = 0;
double double_value = 0;
std::string string_value;
ObjectPath object_path_value;
MessageReader reader(message.get());
ASSERT_TRUE(reader.HasMoreData());
ASSERT_TRUE(reader.PopByte(&byte_value));
ASSERT_TRUE(reader.PopBool(&bool_value));
ASSERT_TRUE(reader.PopInt16(&int16_value));
ASSERT_TRUE(reader.PopUint16(&uint16_value));
ASSERT_TRUE(reader.PopInt32(&int32_value));
ASSERT_TRUE(reader.PopUint32(&uint32_value));
ASSERT_TRUE(reader.PopInt64(&int64_value));
ASSERT_TRUE(reader.PopUint64(&uint64_value));
ASSERT_TRUE(reader.PopDouble(&double_value));
ASSERT_TRUE(reader.PopString(&string_value));
ASSERT_TRUE(reader.PopObjectPath(&object_path_value));
ASSERT_FALSE(reader.HasMoreData());
// 0, 1, 2, 3, 4, 5, 6, 7, 8, "string", "/object/path" should be returned.
EXPECT_EQ(0, byte_value);
EXPECT_EQ(true, bool_value);
EXPECT_EQ(2, int16_value);
EXPECT_EQ(3U, uint16_value);
EXPECT_EQ(4, int32_value);
EXPECT_EQ(5U, uint32_value);
EXPECT_EQ(6, int64_value);
EXPECT_EQ(7U, uint64_value);
EXPECT_DOUBLE_EQ(8.0, double_value);
EXPECT_EQ("string", string_value);
EXPECT_EQ(ObjectPath("/object/path"), object_path_value);
}
// Check all basic types can be properly written and read.
TEST(MessageTest, AppendAndPopFileDescriptor) {
if (!IsDBusTypeUnixFdSupported()) {
LOG(WARNING) << "FD passing is not supported";
return;
}
scoped_ptr<Response> message(Response::CreateEmpty());
MessageWriter writer(message.get());
// Append stdout.
FileDescriptor temp(1);
// Descriptor should not be valid until checked.
ASSERT_FALSE(temp.is_valid());
// NB: thread IO requirements not relevant for unit tests.
temp.CheckValidity();
ASSERT_TRUE(temp.is_valid());
writer.AppendFileDescriptor(temp);
FileDescriptor fd_value;
MessageReader reader(message.get());
ASSERT_TRUE(reader.HasMoreData());
ASSERT_TRUE(reader.PopFileDescriptor(&fd_value));
ASSERT_FALSE(reader.HasMoreData());
// Descriptor is not valid until explicitly checked.
ASSERT_FALSE(fd_value.is_valid());
fd_value.CheckValidity();
ASSERT_TRUE(fd_value.is_valid());
// Stdout should be returned but we cannot check the descriptor
// value because stdout will be dup'd. Instead check st_rdev
// which should be identical.
struct stat sb_stdout;
int status_stdout = HANDLE_EINTR(fstat(1, &sb_stdout));
ASSERT_GE(status_stdout, 0);
struct stat sb_fd;
int status_fd = HANDLE_EINTR(fstat(fd_value.value(), &sb_fd));
ASSERT_GE(status_fd, 0);
EXPECT_EQ(sb_stdout.st_rdev, sb_fd.st_rdev);
}
// Check all variant types can be properly written and read.
TEST(MessageTest, AppendAndPopVariantDataTypes) {
scoped_ptr<Response> message(Response::CreateEmpty());
MessageWriter writer(message.get());
// Append 0, 1, 2, 3, 4, 5, 6, 7, 8, "string", "/object/path".
writer.AppendVariantOfByte(0);
writer.AppendVariantOfBool(true);
writer.AppendVariantOfInt16(2);
writer.AppendVariantOfUint16(3);
writer.AppendVariantOfInt32(4);
writer.AppendVariantOfUint32(5);
writer.AppendVariantOfInt64(6);
writer.AppendVariantOfUint64(7);
writer.AppendVariantOfDouble(8.0);
writer.AppendVariantOfString("string");
writer.AppendVariantOfObjectPath(ObjectPath("/object/path"));
uint8 byte_value = 0;
bool bool_value = false;
int16 int16_value = 0;
uint16 uint16_value = 0;
int32 int32_value = 0;
uint32 uint32_value = 0;
int64 int64_value = 0;
uint64 uint64_value = 0;
double double_value = 0;
std::string string_value;
ObjectPath object_path_value;
MessageReader reader(message.get());
ASSERT_TRUE(reader.HasMoreData());
ASSERT_TRUE(reader.PopVariantOfByte(&byte_value));
ASSERT_TRUE(reader.PopVariantOfBool(&bool_value));
ASSERT_TRUE(reader.PopVariantOfInt16(&int16_value));
ASSERT_TRUE(reader.PopVariantOfUint16(&uint16_value));
ASSERT_TRUE(reader.PopVariantOfInt32(&int32_value));
ASSERT_TRUE(reader.PopVariantOfUint32(&uint32_value));
ASSERT_TRUE(reader.PopVariantOfInt64(&int64_value));
ASSERT_TRUE(reader.PopVariantOfUint64(&uint64_value));
ASSERT_TRUE(reader.PopVariantOfDouble(&double_value));
ASSERT_TRUE(reader.PopVariantOfString(&string_value));
ASSERT_TRUE(reader.PopVariantOfObjectPath(&object_path_value));
ASSERT_FALSE(reader.HasMoreData());
// 0, 1, 2, 3, 4, 5, 6, 7, 8, "string", "/object/path" should be returned.
EXPECT_EQ(0, byte_value);
EXPECT_EQ(true, bool_value);
EXPECT_EQ(2, int16_value);
EXPECT_EQ(3U, uint16_value);
EXPECT_EQ(4, int32_value);
EXPECT_EQ(5U, uint32_value);
EXPECT_EQ(6, int64_value);
EXPECT_EQ(7U, uint64_value);
EXPECT_DOUBLE_EQ(8.0, double_value);
EXPECT_EQ("string", string_value);
EXPECT_EQ(ObjectPath("/object/path"), object_path_value);
}
TEST(MessageTest, ArrayOfBytes) {
scoped_ptr<Response> message(Response::CreateEmpty());
MessageWriter writer(message.get());
std::vector<uint8> bytes;
bytes.push_back(1);
bytes.push_back(2);
bytes.push_back(3);
writer.AppendArrayOfBytes(bytes.data(), bytes.size());
MessageReader reader(message.get());
const uint8* output_bytes = NULL;
size_t length = 0;
ASSERT_TRUE(reader.PopArrayOfBytes(&output_bytes, &length));
ASSERT_FALSE(reader.HasMoreData());
ASSERT_EQ(3U, length);
EXPECT_EQ(1, output_bytes[0]);
EXPECT_EQ(2, output_bytes[1]);
EXPECT_EQ(3, output_bytes[2]);
}
TEST(MessageTest, ArrayOfBytes_Empty) {
scoped_ptr<Response> message(Response::CreateEmpty());
MessageWriter writer(message.get());
std::vector<uint8> bytes;
writer.AppendArrayOfBytes(bytes.data(), bytes.size());
MessageReader reader(message.get());
const uint8* output_bytes = NULL;
size_t length = 0;
ASSERT_TRUE(reader.PopArrayOfBytes(&output_bytes, &length));
ASSERT_FALSE(reader.HasMoreData());
ASSERT_EQ(0U, length);
EXPECT_EQ(NULL, output_bytes);
}
TEST(MessageTest, ArrayOfStrings) {
scoped_ptr<Response> message(Response::CreateEmpty());
MessageWriter writer(message.get());
std::vector<std::string> strings;
strings.push_back("fee");
strings.push_back("fie");
strings.push_back("foe");
strings.push_back("fum");
writer.AppendArrayOfStrings(strings);
MessageReader reader(message.get());
std::vector<std::string> output_strings;
ASSERT_TRUE(reader.PopArrayOfStrings(&output_strings));
ASSERT_FALSE(reader.HasMoreData());
ASSERT_EQ(4U, output_strings.size());
EXPECT_EQ("fee", output_strings[0]);
EXPECT_EQ("fie", output_strings[1]);
EXPECT_EQ("foe", output_strings[2]);
EXPECT_EQ("fum", output_strings[3]);
}
TEST(MessageTest, ArrayOfObjectPaths) {
scoped_ptr<Response> message(Response::CreateEmpty());
MessageWriter writer(message.get());
std::vector<ObjectPath> object_paths;
object_paths.push_back(ObjectPath("/object/path/1"));
object_paths.push_back(ObjectPath("/object/path/2"));
object_paths.push_back(ObjectPath("/object/path/3"));
writer.AppendArrayOfObjectPaths(object_paths);
MessageReader reader(message.get());
std::vector<ObjectPath> output_object_paths;
ASSERT_TRUE(reader.PopArrayOfObjectPaths(&output_object_paths));
ASSERT_FALSE(reader.HasMoreData());
ASSERT_EQ(3U, output_object_paths.size());
EXPECT_EQ(ObjectPath("/object/path/1"), output_object_paths[0]);
EXPECT_EQ(ObjectPath("/object/path/2"), output_object_paths[1]);
EXPECT_EQ(ObjectPath("/object/path/3"), output_object_paths[2]);
}
TEST(MessageTest, ProtoBuf) {
scoped_ptr<Response> message(Response::CreateEmpty());
MessageWriter writer(message.get());
TestProto send_message;
send_message.set_text("testing");
send_message.set_number(123);
writer.AppendProtoAsArrayOfBytes(send_message);
MessageReader reader(message.get());
TestProto receive_message;
ASSERT_TRUE(reader.PopArrayOfBytesAsProto(&receive_message));
EXPECT_EQ(receive_message.text(), send_message.text());
EXPECT_EQ(receive_message.number(), send_message.number());
}
// Test that an array can be properly written and read. We only have this
// test for array, as repeating this for other container types is too
// redundant.
TEST(MessageTest, OpenArrayAndPopArray) {
scoped_ptr<Response> message(Response::CreateEmpty());
MessageWriter writer(message.get());
MessageWriter array_writer(NULL);
writer.OpenArray("s", &array_writer); // Open an array of strings.
array_writer.AppendString("foo");
array_writer.AppendString("bar");
array_writer.AppendString("baz");
writer.CloseContainer(&array_writer);
MessageReader reader(message.get());
ASSERT_EQ(Message::ARRAY, reader.GetDataType());
MessageReader array_reader(NULL);
ASSERT_TRUE(reader.PopArray(&array_reader));
ASSERT_FALSE(reader.HasMoreData()); // Should not have more data to read.
std::string string_value;
ASSERT_TRUE(array_reader.PopString(&string_value));
EXPECT_EQ("foo", string_value);
ASSERT_TRUE(array_reader.PopString(&string_value));
EXPECT_EQ("bar", string_value);
ASSERT_TRUE(array_reader.PopString(&string_value));
EXPECT_EQ("baz", string_value);
// Should not have more data to read.
ASSERT_FALSE(array_reader.HasMoreData());
}
// Create a complex message using array, struct, variant, dict entry, and
// make sure it can be read properly.
TEST(MessageTest, CreateComplexMessageAndReadIt) {
scoped_ptr<Response> message(Response::CreateEmpty());
MessageWriter writer(message.get());
{
MessageWriter array_writer(NULL);
// Open an array of variants.
writer.OpenArray("v", &array_writer);
{
// The first value in the array.
{
MessageWriter variant_writer(NULL);
// Open a variant of a boolean.
array_writer.OpenVariant("b", &variant_writer);
variant_writer.AppendBool(true);
array_writer.CloseContainer(&variant_writer);
}
// The second value in the array.
{
MessageWriter variant_writer(NULL);
// Open a variant of a struct that contains a string and an int32.
array_writer.OpenVariant("(si)", &variant_writer);
{
MessageWriter struct_writer(NULL);
variant_writer.OpenStruct(&struct_writer);
struct_writer.AppendString("string");
struct_writer.AppendInt32(123);
variant_writer.CloseContainer(&struct_writer);
}
array_writer.CloseContainer(&variant_writer);
}
// The third value in the array.
{
MessageWriter variant_writer(NULL);
// Open a variant of an array of string-to-int64 dict entries.
array_writer.OpenVariant("a{sx}", &variant_writer);
{
// Opens an array of string-to-int64 dict entries.
MessageWriter dict_array_writer(NULL);
variant_writer.OpenArray("{sx}", &dict_array_writer);
{
// Opens a string-to-int64 dict entries.
MessageWriter dict_entry_writer(NULL);
dict_array_writer.OpenDictEntry(&dict_entry_writer);
dict_entry_writer.AppendString("foo");
dict_entry_writer.AppendInt64(GG_INT64_C(1234567890123456789));
dict_array_writer.CloseContainer(&dict_entry_writer);
}
variant_writer.CloseContainer(&dict_array_writer);
}
array_writer.CloseContainer(&variant_writer);
}
}
writer.CloseContainer(&array_writer);
}
// What we have created looks like this:
EXPECT_EQ("message_type: MESSAGE_METHOD_RETURN\n"
"signature: av\n"
"\n"
"array [\n"
" variant bool true\n"
" variant struct {\n"
" string \"string\"\n"
" int32 123\n"
" }\n"
" variant array [\n"
" dict entry {\n"
" string \"foo\"\n"
" int64 1234567890123456789\n"
" }\n"
" ]\n"
"]\n",
message->ToString());
MessageReader reader(message.get());
MessageReader array_reader(NULL);
ASSERT_TRUE(reader.PopArray(&array_reader));
// The first value in the array.
bool bool_value = false;
ASSERT_TRUE(array_reader.PopVariantOfBool(&bool_value));
EXPECT_EQ(true, bool_value);
// The second value in the array.
{
MessageReader variant_reader(NULL);
ASSERT_TRUE(array_reader.PopVariant(&variant_reader));
{
MessageReader struct_reader(NULL);
ASSERT_TRUE(variant_reader.PopStruct(&struct_reader));
std::string string_value;
ASSERT_TRUE(struct_reader.PopString(&string_value));
EXPECT_EQ("string", string_value);
int32 int32_value = 0;
ASSERT_TRUE(struct_reader.PopInt32(&int32_value));
EXPECT_EQ(123, int32_value);
ASSERT_FALSE(struct_reader.HasMoreData());
}
ASSERT_FALSE(variant_reader.HasMoreData());
}
// The third value in the array.
{
MessageReader variant_reader(NULL);
ASSERT_TRUE(array_reader.PopVariant(&variant_reader));
{
MessageReader dict_array_reader(NULL);
ASSERT_TRUE(variant_reader.PopArray(&dict_array_reader));
{
MessageReader dict_entry_reader(NULL);
ASSERT_TRUE(dict_array_reader.PopDictEntry(&dict_entry_reader));
std::string string_value;
ASSERT_TRUE(dict_entry_reader.PopString(&string_value));
EXPECT_EQ("foo", string_value);
int64 int64_value = 0;
ASSERT_TRUE(dict_entry_reader.PopInt64(&int64_value));
EXPECT_EQ(GG_INT64_C(1234567890123456789), int64_value);
}
ASSERT_FALSE(dict_array_reader.HasMoreData());
}
ASSERT_FALSE(variant_reader.HasMoreData());
}
ASSERT_FALSE(array_reader.HasMoreData());
ASSERT_FALSE(reader.HasMoreData());
}
TEST(MessageTest, MethodCall) {
MethodCall method_call("com.example.Interface", "SomeMethod");
EXPECT_TRUE(method_call.raw_message() != NULL);
EXPECT_EQ(Message::MESSAGE_METHOD_CALL, method_call.GetMessageType());
EXPECT_EQ("MESSAGE_METHOD_CALL", method_call.GetMessageTypeAsString());
method_call.SetDestination("com.example.Service");
method_call.SetPath(ObjectPath("/com/example/Object"));
MessageWriter writer(&method_call);
writer.AppendString("payload");
EXPECT_EQ("message_type: MESSAGE_METHOD_CALL\n"
"destination: com.example.Service\n"
"path: /com/example/Object\n"
"interface: com.example.Interface\n"
"member: SomeMethod\n"
"signature: s\n"
"\n"
"string \"payload\"\n",
method_call.ToString());
}
TEST(MessageTest, MethodCall_FromRawMessage) {
DBusMessage* raw_message = dbus_message_new(DBUS_MESSAGE_TYPE_METHOD_CALL);
dbus_message_set_interface(raw_message, "com.example.Interface");
dbus_message_set_member(raw_message, "SomeMethod");
scoped_ptr<MethodCall> method_call(MethodCall::FromRawMessage(raw_message));
EXPECT_EQ("com.example.Interface", method_call->GetInterface());
EXPECT_EQ("SomeMethod", method_call->GetMember());
}
TEST(MessageTest, Signal) {
Signal signal("com.example.Interface", "SomeSignal");
EXPECT_TRUE(signal.raw_message() != NULL);
EXPECT_EQ(Message::MESSAGE_SIGNAL, signal.GetMessageType());
EXPECT_EQ("MESSAGE_SIGNAL", signal.GetMessageTypeAsString());
signal.SetPath(ObjectPath("/com/example/Object"));
MessageWriter writer(&signal);
writer.AppendString("payload");
EXPECT_EQ("message_type: MESSAGE_SIGNAL\n"
"path: /com/example/Object\n"
"interface: com.example.Interface\n"
"member: SomeSignal\n"
"signature: s\n"
"\n"
"string \"payload\"\n",
signal.ToString());
}
TEST(MessageTest, Signal_FromRawMessage) {
DBusMessage* raw_message = dbus_message_new(DBUS_MESSAGE_TYPE_SIGNAL);
dbus_message_set_interface(raw_message, "com.example.Interface");
dbus_message_set_member(raw_message, "SomeSignal");
scoped_ptr<Signal> signal(Signal::FromRawMessage(raw_message));
EXPECT_EQ("com.example.Interface", signal->GetInterface());
EXPECT_EQ("SomeSignal", signal->GetMember());
}
TEST(MessageTest, Response) {
scoped_ptr<Response> response(Response::CreateEmpty());
EXPECT_TRUE(response->raw_message());
EXPECT_EQ(Message::MESSAGE_METHOD_RETURN, response->GetMessageType());
EXPECT_EQ("MESSAGE_METHOD_RETURN", response->GetMessageTypeAsString());
}
TEST(MessageTest, Response_FromMethodCall) {
const uint32 kSerial = 123;
MethodCall method_call("com.example.Interface", "SomeMethod");
method_call.SetSerial(kSerial);
scoped_ptr<Response> response(
Response::FromMethodCall(&method_call));
EXPECT_EQ(Message::MESSAGE_METHOD_RETURN, response->GetMessageType());
EXPECT_EQ("MESSAGE_METHOD_RETURN", response->GetMessageTypeAsString());
// The serial should be copied to the reply serial.
EXPECT_EQ(kSerial, response->GetReplySerial());
}
TEST(MessageTest, ErrorResponse_FromMethodCall) {
const uint32 kSerial = 123;
const char kErrorMessage[] = "error message";
MethodCall method_call("com.example.Interface", "SomeMethod");
method_call.SetSerial(kSerial);
scoped_ptr<ErrorResponse> error_response(
ErrorResponse::FromMethodCall(&method_call,
DBUS_ERROR_FAILED,
kErrorMessage));
EXPECT_EQ(Message::MESSAGE_ERROR, error_response->GetMessageType());
EXPECT_EQ("MESSAGE_ERROR", error_response->GetMessageTypeAsString());
// The serial should be copied to the reply serial.
EXPECT_EQ(kSerial, error_response->GetReplySerial());
// Error message should be added to the payload.
MessageReader reader(error_response.get());
std::string error_message;
ASSERT_TRUE(reader.PopString(&error_message));
EXPECT_EQ(kErrorMessage, error_message);
}
TEST(MessageTest, GetAndSetHeaders) {
scoped_ptr<Response> message(Response::CreateEmpty());
EXPECT_EQ("", message->GetDestination());
EXPECT_EQ(ObjectPath(std::string()), message->GetPath());
EXPECT_EQ("", message->GetInterface());
EXPECT_EQ("", message->GetMember());
EXPECT_EQ("", message->GetErrorName());
EXPECT_EQ("", message->GetSender());
EXPECT_EQ(0U, message->GetSerial());
EXPECT_EQ(0U, message->GetReplySerial());
EXPECT_TRUE(message->SetDestination("org.chromium.destination"));
EXPECT_TRUE(message->SetPath(ObjectPath("/org/chromium/path")));
EXPECT_TRUE(message->SetInterface("org.chromium.interface"));
EXPECT_TRUE(message->SetMember("member"));
EXPECT_TRUE(message->SetErrorName("org.chromium.error"));
EXPECT_TRUE(message->SetSender(":1.2"));
message->SetSerial(123);
message->SetReplySerial(456);
EXPECT_EQ("org.chromium.destination", message->GetDestination());
EXPECT_EQ(ObjectPath("/org/chromium/path"), message->GetPath());
EXPECT_EQ("org.chromium.interface", message->GetInterface());
EXPECT_EQ("member", message->GetMember());
EXPECT_EQ("org.chromium.error", message->GetErrorName());
EXPECT_EQ(":1.2", message->GetSender());
EXPECT_EQ(123U, message->GetSerial());
EXPECT_EQ(456U, message->GetReplySerial());
}
TEST(MessageTest, SetInvalidHeaders) {
scoped_ptr<Response> message(Response::CreateEmpty());
EXPECT_EQ("", message->GetDestination());
EXPECT_EQ(ObjectPath(std::string()), message->GetPath());
EXPECT_EQ("", message->GetInterface());
EXPECT_EQ("", message->GetMember());
EXPECT_EQ("", message->GetErrorName());
EXPECT_EQ("", message->GetSender());
// Empty element between periods.
EXPECT_FALSE(message->SetDestination("org..chromium"));
// Trailing '/' is only allowed for the root path.
EXPECT_FALSE(message->SetPath(ObjectPath("/org/chromium/")));
// Interface name cannot contain '/'.
EXPECT_FALSE(message->SetInterface("org/chromium/interface"));
// Member name cannot begin with a digit.
EXPECT_FALSE(message->SetMember("1member"));
// Error name cannot begin with a period.
EXPECT_FALSE(message->SetErrorName(".org.chromium.error"));
// Disallowed characters.
EXPECT_FALSE(message->SetSender("?!#*"));
EXPECT_EQ("", message->GetDestination());
EXPECT_EQ(ObjectPath(std::string()), message->GetPath());
EXPECT_EQ("", message->GetInterface());
EXPECT_EQ("", message->GetMember());
EXPECT_EQ("", message->GetErrorName());
EXPECT_EQ("", message->GetSender());
}
TEST(MessageTest, ToString_LongString) {
const std::string kLongString(1000, 'o');
scoped_ptr<Response> message(Response::CreateEmpty());
MessageWriter writer(message.get());
writer.AppendString(kLongString);
ASSERT_EQ("message_type: MESSAGE_METHOD_RETURN\n"
"signature: s\n\n"
"string \"oooooooooooooooooooooooooooooooooooooooooooooooo"
"oooooooooooooooooooooooooooooooooooooooooooooooooooo... "
"(1000 bytes in total)\"\n",
message->ToString());
}
} // namespace dbus