[Sync] Display the client server traffic log in about:sync.

sync/engine/traffic_recorder.cc

 // 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 "sync/engine/traffic_recorder.h"
 
 #include "base/json/json_writer.h"
 #include "base/logging.h"
 #include "base/memory/scoped_ptr.h"
+#include "base/stringprintf.h"
 #include "base/values.h"
 #include "sync/protocol/proto_value_conversions.h"
 #include "sync/protocol/sync.pb.h"
 #include "sync/sessions/sync_session.h"
 
 namespace browser_sync {
 
 TrafficRecorder::TrafficRecord::TrafficRecord(const std::string& message,
                                               TrafficMessageType message_type,
                                               bool truncated) :
@@ skipping 12 matching lines @@
 
 TrafficRecorder::TrafficRecorder(unsigned int max_messages,
     unsigned int max_message_size)
     : max_messages_(max_messages),
       max_message_size_(max_message_size) {
 }
 
 TrafficRecorder::~TrafficRecorder() {
 }
 
+namespace {
+#define ENUM_CASE(x) case TrafficRecorder::##x: return #x; break;

[akalin, 2012/03/30 01:45:35]

looks like you don't use this macro after all

[lipalani1, 2012/03/30 20:35:16]

Done.

+
+const char* GetMessageTypeString(TrafficRecorder::TrafficMessageType type) {
+  switch(type) {
+    case TrafficRecorder::CLIENT_TO_SERVER_MESSAGE:
+      return "Request";
+    case TrafficRecorder::CLIENT_TO_SERVER_RESPONSE:
+      return "Response";
+  }
+  NOTREACHED();
+  return "";
+}
+
+#undef ENUM_CASE
+}
+
+DictionaryValue* TrafficRecorder::TrafficRecord::ToValue() const {
+  scoped_ptr<DictionaryValue> value;
+  if (truncated) {
+    value.reset(new DictionaryValue());
+    value->SetString("message_type",
+                               GetMessageTypeString(message_type));

[akalin, 2012/03/30 01:45:35]

line up with (

[lipalani1, 2012/03/30 20:35:16]

Done.

+    value->SetBoolean("truncated", true);
+  } else if (message_type == TrafficRecorder::CLIENT_TO_SERVER_MESSAGE) {
+    sync_pb::ClientToServerMessage message_proto;
+    if (message_proto.ParseFromString(message))
+      value.reset(
+          ClientToServerMessageToValue(message_proto,
+                                       false /* include_specifics */));
+  } else if (message_type == TrafficRecorder::CLIENT_TO_SERVER_RESPONSE) {
+    sync_pb::ClientToServerResponse message_proto;
+    if (message_proto.ParseFromString(message))
+      value.reset(
+          ClientToServerResponseToValue(message_proto,
+                                        false /* include_specifics */));
+  } else {
+    NOTREACHED();
+  }
+
+  return value.release();
+}
+
+
+DictionaryValue* TrafficRecorder::ToValue() const {
+  int message_count = 0;
+  scoped_ptr<DictionaryValue> dictionary(new DictionaryValue());
+  std::deque<TrafficRecord>::const_iterator it;
+  for (it = records_.begin(); it != records_.end(); ++it) {
+    const TrafficRecord& record = *it;
+    std::string message_id = StringPrintf("message%d", message_count);

[akalin, 2012/03/30 01:45:35]

is it necessary to have a string ID?  Why not fill a ListValue and return that
instead?  As a bonus you preserve order.

[lipalani1, 2012/03/30 20:35:16]

Done.

+    dictionary->Set(message_id, record.ToValue());
+    ++message_count;
+  }
+
+  return dictionary.release();
+}
+
+
 
 void TrafficRecorder::AddTrafficToQueue(TrafficRecord* record) {
   records_.resize(records_.size() + 1);
   std::swap(records_.back(), *record);
 
   // We might have more records than our limit.
   // Maintain the size invariant by deleting items.
   while (records_.size() > max_messages_) {
     records_.pop_front();
   }
@@ skipping 17 matching lines @@
 
 void TrafficRecorder::RecordClientToServerMessage(
     const sync_pb::ClientToServerMessage& msg) {
   StoreProtoInQueue(msg, CLIENT_TO_SERVER_MESSAGE);
 }
 
 void TrafficRecorder::RecordClientToServerResponse(
     const sync_pb::ClientToServerResponse& response) {
   StoreProtoInQueue(response, CLIENT_TO_SERVER_RESPONSE);
 }
-
 }  // namespace browser_sync