Index: chrome/browser/resources/sync_internals/chrome_sync.js |
diff --git a/chrome/browser/resources/sync_internals/chrome_sync.js b/chrome/browser/resources/sync_internals/chrome_sync.js |
new file mode 100644 |
index 0000000000000000000000000000000000000000..c8dbcc676832ae7d6c56c9e3b63fd2f5a834fe55 |
--- /dev/null |
+++ b/chrome/browser/resources/sync_internals/chrome_sync.js |
@@ -0,0 +1,215 @@ |
+var chrome = chrome || {}; |
+// TODO(akalin): Add mocking code for e.g. chrome.send() so that we |
+// can test this without rebuilding chrome. |
+chrome.sync = chrome.sync || {}; |
+(function () { |
+ |
+// This Event class is a simplified version of the one from |
+// event_bindings.js. |
+function Event() { |
+ this.listeners_ = []; |
+} |
+ |
+Event.prototype.addListener = function(listener) { |
+ this.listeners_.push(listener); |
+}; |
+ |
+Event.prototype.removeListener = function(listener) { |
+ var i = this.findListener_(listener); |
+ if (i == -1) { |
+ return; |
+ } |
+ this.listeners_.splice(i, 1); |
+}; |
+ |
+Event.prototype.hasListener = function(listener) { |
+ return this.findListener_(listener) > -1; |
+}; |
+ |
+Event.prototype.hasListeners = function(listener) { |
+ return this.listeners_.length > 0; |
+}; |
+ |
+// Returns the index of the given listener, or -1 if not found. |
+Event.prototype.findListener_ = function(listener) { |
+ for (var i = 0; i < this.listeners_.length; i++) { |
+ if (this.listeners_[i] == listener) { |
+ return i; |
+ } |
+ } |
+ return -1; |
+}; |
+ |
+// Fires the event. Called by the actual event callback. |
+Event.prototype.dispatch_ = function() { |
+ var args = Array.prototype.slice.call(arguments); |
+ for (var i = 0; i < this.listeners_.length; i++) { |
+ try { |
+ this.listeners_[i].apply(null, args); |
+ } catch (e) { |
+ console.error(e); |
+ } |
+ } |
+}; |
+ |
+// Sync service events. |
+chrome.sync.onSyncServiceStateChanged = new Event(); |
+ |
+// Notification events. |
+chrome.sync.onSyncNotificationStateChange = new Event(); |
+chrome.sync.onSyncIncomingNotification = new Event(); |
+ |
+// Sync manager events. |
+chrome.sync.onChangesApplied = new Event(); |
+chrome.sync.onChangesComplete = new Event(); |
+chrome.sync.onSyncCycleCompleted = new Event(); |
+chrome.sync.onAuthError = new Event(); |
+chrome.sync.onUpdatedToken = new Event(); |
+chrome.sync.onPassphraseRequired = new Event(); |
+chrome.sync.onPassphraseAccepted = new Event(); |
+chrome.sync.onInitializationComplete = new Event(); |
+chrome.sync.onPaused = new Event(); |
+chrome.sync.onResumed = new Event(); |
+chrome.sync.onStopSyncingPermanently = new Event(); |
+chrome.sync.onClearServerDataSucceeded = new Event(); |
+chrome.sync.onClearServerDataFailed = new Event(); |
+ |
+function AsyncFunction(name) { |
+ this.name_ = name; |
+ this.callbacks_ = []; |
+} |
+ |
+// Calls the function, assuming the last argument is a callback to be |
+// called with the return value. |
+AsyncFunction.prototype.call = function() { |
+ var args = Array.prototype.slice.call(arguments); |
+ this.callbacks_.push(args.pop()); |
+ chrome.send(this.name_, args); |
+} |
+ |
+// Handle a reply, assuming that messages are processed in FIFO order. |
+AsyncFunction.prototype.handleReply = function() { |
+ var args = Array.prototype.slice.call(arguments); |
+ var callback = this.callbacks_.shift(); |
+ try { |
+ callback.apply(null, args); |
+ } catch (e) { |
+ console.error(e); |
+ } |
+} |
+ |
+// Sync service functions. |
+chrome.sync.getAboutInfo_ = new AsyncFunction('getAboutInfo'); |
+chrome.sync.getAboutInfo = function(callback) { |
+ chrome.sync.getAboutInfo_.call(callback); |
+} |
+ |
+// Notification functions. |
+chrome.sync.getNotificationState_ = |
+ new AsyncFunction('getNotificationState'); |
+chrome.sync.getNotificationState = function(callback) { |
+ chrome.sync.getNotificationState_.call(callback); |
+} |
+ |
+// Node lookup functions. |
+chrome.sync.getRootNode_ = new AsyncFunction('getRootNode'); |
+chrome.sync.getRootNode = function(callback) { |
+ chrome.sync.getRootNode_.call(callback); |
+} |
+ |
+chrome.sync.getNodeById_ = new AsyncFunction('getNodeById'); |
+chrome.sync.getNodeById = function(id, callback) { |
+ chrome.sync.getNodeById_.call(id, callback); |
+} |
+ |
+})(); |
+ |
+// TODO(akalin): Rewrite the C++ side to not need the handlers below. |
+ |
+// Sync service event handlers. |
+ |
+function onSyncServiceStateChanged() { |
+ chrome.sync.onSyncServiceStateChanged.dispatch_(); |
+} |
+ |
+// Notification event handlers. |
+ |
+function onSyncNotificationStateChange(notificationsEnabled) { |
+ chrome.sync.onSyncNotificationStateChange.dispatch_(notificationsEnabled); |
+} |
+ |
+function onSyncIncomingNotification(changedTypes) { |
+ chrome.sync.onSyncIncomingNotification.dispatch_(changedTypes); |
+} |
+ |
+// Sync manager event handlers. |
+ |
+function onChangesApplied(modelType, changes) { |
+ chrome.sync.onChangesApplied.dispatch_(modelType, changes); |
+} |
+ |
+function onChangesComplete(modelType) { |
+ chrome.sync.onChangesComplete.dispatch_(modelType); |
+} |
+ |
+function onSyncCycleCompleted(snapshot) { |
+ chrome.sync.onSyncCycleCompleted.dispatch_(snapshot); |
+} |
+ |
+function onAuthError(authError) { |
+ chrome.sync.onAuthError.dispatch_(authError); |
+} |
+ |
+function onUpdatedToken(token) { |
+ chrome.sync.onUpdatedToken.dispatch_(token); |
+} |
+ |
+function onPassphraseRequired(forDecryption) { |
+ chrome.sync.onPassphraseRequired.dispatch_(forDecryption); |
+} |
+ |
+function onPassphraseAccepted(bootstrapToken) { |
+ chrome.sync.onPassphraseAccepted.dispatch_(bootstrapToken); |
+} |
+ |
+function onInitializationComplete() { |
+ chrome.sync.onInitializationComplete.dispatch_(); |
+} |
+ |
+function onPaused() { |
+ chrome.sync.onPaused.dispatch_(); |
+} |
+ |
+function onResumed() { |
+ chrome.sync.onResumed.dispatch_(); |
+} |
+ |
+function onStopSyncingPermanently() { |
+ chrome.sync.onStopSyncingPermanently.dispatch_(); |
+} |
+ |
+function onClearServerDataSucceeded() { |
+ chrome.sync.onClearServerDataSucceeded(); |
+} |
+ |
+function onClearServerDataFailed() { |
+ chrome.sync.onClearServerDataFailed(); |
+} |
+ |
+// Function reply handlers. |
+ |
+function onGetAboutInfoFinished(aboutInfo) { |
+ chrome.sync.getAboutInfo_.handleReply(aboutInfo); |
+} |
+ |
+function onGetNotificationStateFinished(notificationState) { |
+ chrome.sync.getNotificationState_.handleReply(notificationState); |
+} |
+ |
+function onGetRootNodeFinished(rootNode) { |
+ chrome.sync.getRootNode_.handleReply(rootNode); |
+} |
+ |
+function onGetNodeByIdFinished(node) { |
+ chrome.sync.getNodeById_.handleReply(node); |
+} |