content/browser/resources/media/main.js

   1 // Copyright 2013 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 /**
   6  * A global object that gets used by the C++ interface.
   7  */
   8 var media = (function() {
   9   'use strict';
  10
  11   var manager = null;
  12
  13   // A number->string mapping that is populated through the backend that
  14   // describes the phase that the network entity is in.
  15   var eventPhases = {};
  16
  17   // A number->string mapping that is populated through the backend that
  18   // describes the type of event sent from the network.
  19   var eventTypes = {};
  20
  21   // A mapping of number->CacheEntry where the number is a unique id for that
  22   // network request.
  23   var cacheEntries = {};
  24
  25   // A mapping of url->CacheEntity where the url is the url of the resource.
  26   var cacheEntriesByKey = {};
  27
  28   var requrestURLs = {};
  29
  30   var media = {
  31     BAR_WIDTH: 200,
  32     BAR_HEIGHT: 25
  33   };
  34
  35   /**
  36    * Users of |media| must call initialize prior to calling other methods.
  37    */
  38   media.initialize = function(theManager) {
  39     manager = theManager;
  40   };
  41
  42   media.onReceiveEverything = function(everything) {
  43     for (var component in everything) {
  44       media.updateAudioComponent(everything[component]);
  45     }
  46   };
  47
  48   media.onReceiveConstants = function(constants) {
  49     for (var key in constants.eventTypes) {
  50       var value = constants.eventTypes[key];
  51       eventTypes[value] = key;
  52     }
  53
  54     for (var key in constants.eventPhases) {
  55       var value = constants.eventPhases[key];
  56       eventPhases[value] = key;
  57     }
  58   };
  59
  60   media.cacheForUrl = function(url) {
  61     return cacheEntriesByKey[url];
  62   };
  63
  64   media.onNetUpdate = function(updates) {
  65     updates.forEach(function(update) {
  66       var id = update.source.id;
  67       if (!cacheEntries[id])
  68         cacheEntries[id] = new media.CacheEntry;
  69
  70       switch (eventPhases[update.phase] + '.' + eventTypes[update.type]) {
  71         case 'PHASE_BEGIN.DISK_CACHE_ENTRY_IMPL':
  72           var key = update.params.key;
  73
  74           // Merge this source with anything we already know about this key.
  75           if (cacheEntriesByKey[key]) {
  76             cacheEntriesByKey[key].merge(cacheEntries[id]);
  77             cacheEntries[id] = cacheEntriesByKey[key];
  78           } else {
  79             cacheEntriesByKey[key] = cacheEntries[id];
  80           }
  81           cacheEntriesByKey[key].key = key;
  82           break;
  83
  84         case 'PHASE_BEGIN.SPARSE_READ':
  85           cacheEntries[id].readBytes(update.params.offset,
  86                                       update.params.buff_len);
  87           cacheEntries[id].sparse = true;
  88           break;
  89
  90         case 'PHASE_BEGIN.SPARSE_WRITE':
  91           cacheEntries[id].writeBytes(update.params.offset,
  92                                        update.params.buff_len);
  93           cacheEntries[id].sparse = true;
  94           break;
  95
  96         case 'PHASE_BEGIN.URL_REQUEST_START_JOB':
  97           requrestURLs[update.source.id] = update.params.url;
  98           break;
  99
 100         case 'PHASE_NONE.HTTP_TRANSACTION_READ_RESPONSE_HEADERS':
 101           // Record the total size of the file if this was a range request.
 102           var range = /content-range:\s*bytes\s*\d+-\d+\/(\d+)/i.exec(
 103               update.params.headers);
 104           var key = requrestURLs[update.source.id];
 105           delete requrestURLs[update.source.id];
 106           if (range && key) {
 107             if (!cacheEntriesByKey[key]) {
 108               cacheEntriesByKey[key] = new media.CacheEntry;
 109               cacheEntriesByKey[key].key = key;
 110             }
 111             cacheEntriesByKey[key].size = range[1];
 112           }
 113           break;
 114       }
 115     });
 116   };
 117
 118   media.onRendererTerminated = function(renderId) {
 119     util.object.forEach(manager.players_, function(playerInfo, id) {
 120       if (playerInfo.properties['render_id'] == renderId) {
 121         manager.removePlayer(id);
 122       }
 123     });
 124   };
 125
 126   media.updateAudioComponent = function(component) {
 127     var uniqueComponentId = component.owner_id + ':' + component.component_id;
 128     switch (component.status) {
 129       case 'closed':
 130         manager.removeAudioComponent(
 131             component.component_type, uniqueComponentId);
 132         break;
 133       default:
 134         manager.updateAudioComponent(
 135             component.component_type, uniqueComponentId, component);
 136         break;
 137     }
 138   };
 139
 140   media.onPlayerOpen = function(id, timestamp) {
 141     manager.addPlayer(id, timestamp);
 142   };
 143
 144   media.onMediaEvent = function(event) {
 145     var source = event.renderer + ':' + event.player;
 146
 147     // Although this gets called on every event, there is nothing we can do
 148     // because there is no onOpen event.
 149     media.onPlayerOpen(source);
 150     manager.updatePlayerInfoNoRecord(
 151         source, event.ticksMillis, 'render_id', event.renderer);
 152     manager.updatePlayerInfoNoRecord(
 153         source, event.ticksMillis, 'player_id', event.player);
 154
 155     var propertyCount = 0;
 156     util.object.forEach(event.params, function(value, key) {
 157       key = key.trim();
 158
 159       // These keys get spammed *a lot*, so put them on the display
 160       // but don't log list.
 161       if (key === 'buffer_start' ||
 162           key === 'buffer_end' ||
 163           key === 'buffer_current' ||
 164           key === 'is_downloading_data') {
 165         manager.updatePlayerInfoNoRecord(
 166             source, event.ticksMillis, key, value);
 167       } else {
 168         manager.updatePlayerInfo(source, event.ticksMillis, key, value);
 169       }
 170       propertyCount += 1;
 171     });
 172
 173     if (propertyCount === 0) {
 174       manager.updatePlayerInfo(
 175           source, event.ticksMillis, 'EVENT', event.type);
 176     }
 177   };
 178
 179   // |chrome| is not defined during tests.
 180   if (window.chrome && window.chrome.send) {
 181     chrome.send('getEverything');
 182   }
 183   return media;
 184 }());