Connecting webrtc-internals WebUI frontend with the backend

chrome/browser/media/chrome_webrtc_internals.cc

+// Copyright (c) 2013 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 "chrome/browser/media/chrome_webrtc_internals.h"
+
+#include "chrome/browser/media/webrtc_internals_ui_observer.h"
+#include "content/public/browser/browser_thread.h"
+
+using base::DictionaryValue;
+using base::ProcessId;
+using content::BrowserThread;
+using std::string;
+
+namespace media {
+
+ChromeWebRTCInternals::ChromeWebRTCInternals() {
+}
+
+ChromeWebRTCInternals::~ChromeWebRTCInternals() {
+}
+
+ChromeWebRTCInternals* ChromeWebRTCInternals::GetInstance() {
+  return Singleton<ChromeWebRTCInternals>::get();
+}
+
+void ChromeWebRTCInternals::AddPeerConnection(ProcessId pid,
+                                        int lid,
+                                        const string& url,
+                                        const string& servers,
+                                        const string& constraints) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  if (observers_.size()) {

[jam, 2013/01/18 18:27:33]

nit: here and below, better to early return when the rest of the body is under
an if statement. this helps avoid unnecessary indentation, which is nice with
the 80 char limit

[jiayl, 2013/01/18 19:20:00]

Done.

+    DictionaryValue* dict = new DictionaryValue();
+    if (dict != NULL) {
+      dict->SetInteger("pid", static_cast<int>(pid));
+      dict->SetInteger("lid", lid);
+      dict->SetString("servers", servers);
+      dict->SetString("constraints", constraints);
+      dict->SetString("url", url);
+
+      SendUpdate("addPeerConnection", dict);
+      peer_connection_data_.Append(dict);
+    }
+  }
+}
+
+void ChromeWebRTCInternals::RemovePeerConnection(ProcessId pid, int lid) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  if (observers_.size()) {
+    for (size_t i = 0; i < peer_connection_data_.GetSize(); ++i) {
+      DictionaryValue* dict = NULL;
+      peer_connection_data_.GetDictionary(i, &dict);
+
+      int this_pid = 0;
+      int this_lid = 0;
+      dict->GetInteger("pid", &this_pid);
+      dict->GetInteger("lid", &this_lid);
+      if (this_pid == static_cast<int>(pid) && this_lid == lid) {
+        peer_connection_data_.Remove(i, NULL);
+
+        DictionaryValue dict;
+        dict.SetInteger("pid", static_cast<int>(pid));
+        dict.SetInteger("lid", lid);
+        SendUpdate("removePeerConnection", &dict);
+
+        break;
+      }
+    }
+  }
+}
+
+void ChromeWebRTCInternals::AddObserver(
+      WebRTCInternalsUIObserver *observer) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  observers_.AddObserver(observer);
+}
+
+void ChromeWebRTCInternals::RemoveObserver(
+      WebRTCInternalsUIObserver *observer) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  observers_.RemoveObserver(observer);
+}
+
+void ChromeWebRTCInternals::SendUpdate(const string& command, Value* value) {
+  DCHECK(observers_.size());
+
+  FOR_EACH_OBSERVER(WebRTCInternalsUIObserver,
+                    observers_,
+                    OnUpdate(command, value));
+}
+
+}  // namespace media