Make MediaInternals handle MediaLogEvents.

chrome/browser/media/media_internals.cc

 // Copyright (c) 2011 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/media_internals.h"
 
 #include "base/memory/scoped_ptr.h"
 #include "base/string16.h"
 #include "base/stringprintf.h"
 #include "chrome/browser/media/media_internals_observer.h"
 #include "content/browser/browser_thread.h"
 #include "content/browser/webui/web_ui.h"
+#include "media/base/media_log.h"
 #include "media/base/media_log_event.h"
 
 // The names of the javascript functions to call with updates.
+static const char kAudioUpdateFunction[] = "media.addAudioStream";
 static const char kDeleteItemFunction[] = "media.onItemDeleted";
-static const char kAudioUpdateFunction[] = "media.addAudioStream";
+static const char kMediaEventFunction[] = "media.onMediaEvent";
+static const char kMediaPlayerUpdateFunction[] = "media.addMediaPlayer";
 static const char kSendEverythingFunction[] = "media.onReceiveEverything";
 
 MediaInternals::~MediaInternals() {}
 
 void MediaInternals::OnDeleteAudioStream(void* host, int stream_id) {
   DCHECK(CalledOnValidThread());
   std::string stream = base::StringPrintf("audio_streams.%p:%d",
                                           host, stream_id);
   DeleteItem(stream);
 }
@@ skipping 15 matching lines @@
 void MediaInternals::OnSetAudioStreamVolume(
     void* host, int stream_id, double volume) {
   DCHECK(CalledOnValidThread());
   UpdateAudioStream(host, stream_id,
                     "volume", Value::CreateDoubleValue(volume));
 }
 
 void MediaInternals::OnMediaEvent(
     int render_process_id, const media::MediaLogEvent& event) {
   DCHECK(CalledOnValidThread());
-  // TODO(scottfr): Handle |event|. Record status information in data_ and pass
-  //                |event| along to observers.
+  std::string source = base::StringPrintf("media_players.%d.%d",
+                                          render_process_id, event.id);
+
+  // Notify observers that |event| has occured.
+  DictionaryValue dict;
+  dict.SetString("source", source);
+  dict.SetString("type", media::MediaLog::EventTypeToString(event.type));
+  dict.SetDouble("time", event.time.ToDoubleT());
+  dict.Set("params", event.params.DeepCopy());
+  SendUpdate(kMediaEventFunction, &dict);
+
+  // Handle parameterless events specially, but otherwise just add parameters
+  // to this.details_ and send an updated property list to any obsevers.

[scherkus (not reviewing), 2011/08/10 16:00:37]

ack should have clarified my comment

I don't see what this.details_ refers to

Is it javascript code? or is details_ some C++ member variable?

[Scott Franklin, 2011/08/10 22:26:51]

oh wow, s/details_/data_/. I imagine it would be hard to find what it refers to
when it doesn't exist.

+  switch (event.type) {
+    case media::MediaLogEvent::WEBMEDIAPLAYER_CREATED:
+      SetItemProperty(kMediaPlayerUpdateFunction, source, "player_state",
+                      base::Value::CreateStringValue("created"));
+      break;
+    case media::MediaLogEvent::WEBMEDIAPLAYER_DESTROYED:
+      SetItemProperty(kMediaPlayerUpdateFunction, source, "player_state",
+                      base::Value::CreateStringValue("destroyed"));
+      break;
+    case media::MediaLogEvent::PLAY:
+      SetItemProperty(kMediaPlayerUpdateFunction, source, "player_state",
+                      base::Value::CreateStringValue("playing"));
+      break;
+    case media::MediaLogEvent::PAUSE:
+      SetItemProperty(kMediaPlayerUpdateFunction, source, "player_state",
+                      base::Value::CreateStringValue("paused"));
+      break;
+    default:
+      SetItemProperties(kMediaPlayerUpdateFunction, source,
+                        event.params.DeepCopy());
+      break;
+  }
 }
 
 void MediaInternals::AddObserver(MediaInternalsObserver* observer) {
   DCHECK(CalledOnValidThread());
   observers_.AddObserver(observer);
 }
 
 void MediaInternals::RemoveObserver(MediaInternalsObserver* observer) {
   DCHECK(CalledOnValidThread());
   observers_.RemoveObserver(observer);
 }
 
 void MediaInternals::SendEverything() {
   DCHECK(CalledOnValidThread());
   SendUpdate(kSendEverythingFunction, &data_);
 }
 
 MediaInternals::MediaInternals() {}
 
 void MediaInternals::UpdateAudioStream(
     void* host, int stream_id, const std::string& property, Value* value) {
   std::string stream = base::StringPrintf("audio_streams.%p:%d",
                                           host, stream_id);
-  UpdateItem(kAudioUpdateFunction, stream, property, value);
+  SetItemProperty(kAudioUpdateFunction, stream, property, value);
 }
 
 void MediaInternals::DeleteItem(const std::string& item) {
   data_.Remove(item, NULL);
   scoped_ptr<Value> value(Value::CreateStringValue(item));
   SendUpdate(kDeleteItemFunction, value.get());
 }
 
-void MediaInternals::UpdateItem(
+void MediaInternals::SetItemProperty(
     const std::string& update_fn, const std::string& id,
     const std::string& property, Value* value) {
+  DictionaryValue* properties = new DictionaryValue();
+  properties->Set(property, value);
+  SetItemProperties(update_fn, id, properties);
+}
+
+void MediaInternals::SetItemProperties(
+    const std::string& update_fn, const std::string& id,
+    DictionaryValue* properties) {
   DictionaryValue* item_properties;
   if (!data_.GetDictionary(id, &item_properties)) {
     item_properties = new DictionaryValue();
     data_.Set(id, item_properties);
     item_properties->SetString("id", id);
   }
-  item_properties->Set(property, value);
+  item_properties->MergeDictionary(properties);
   SendUpdate(update_fn, item_properties);
 }
 
 void MediaInternals::SendUpdate(const std::string& function, Value* value) {
   // Only bother serializing the update to JSON if someone is watching.
   if (observers_.size()) {
     std::vector<const Value*> args;
     args.push_back(value);
     string16 update = WebUI::GetJavascriptCall(function, args);
     FOR_EACH_OBSERVER(MediaInternalsObserver, observers_, OnUpdate(update));
   }
 }