| OLD | NEW |
| 1 #!/usr/bin/python2.4 | 1 #!/usr/bin/python2.4 |
| 2 # Copyright (c) 2011 The Chromium Authors. All rights reserved. | 2 # Copyright (c) 2011 The Chromium Authors. All rights reserved. |
| 3 # Use of this source code is governed by a BSD-style license that can be | 3 # Use of this source code is governed by a BSD-style license that can be |
| 4 # found in the LICENSE file. | 4 # found in the LICENSE file. |
| 5 | 5 |
| 6 """An implementation of the server side of the Chromium sync protocol. | 6 """An implementation of the server side of the Chromium sync protocol. |
| 7 | 7 |
| 8 The details of the protocol are described mostly by comments in the protocol | 8 The details of the protocol are described mostly by comments in the protocol |
| 9 buffer definition at chrome/browser/sync/protocol/sync.proto. | 9 buffer definition at chrome/browser/sync/protocol/sync.proto. |
| 10 """ | 10 """ |
| 11 | 11 |
| 12 import cgi | 12 import cgi |
| 13 import copy | 13 import copy |
| 14 import operator | 14 import operator |
| 15 import pickle | 15 import pickle |
| 16 import random | 16 import random |
| 17 import sys | 17 import sys |
| 18 import threading | 18 import threading |
| 19 import urlparse | 19 import urlparse |
| 20 | 20 |
| 21 import app_specifics_pb2 | 21 import app_specifics_pb2 |
| 22 import autofill_specifics_pb2 | 22 import autofill_specifics_pb2 |
| 23 import bookmark_specifics_pb2 | 23 import bookmark_specifics_pb2 |
| 24 import extension_specifics_pb2 | 24 import extension_specifics_pb2 |
| 25 import nigori_specifics_pb2 | 25 import nigori_specifics_pb2 |
| 26 import password_specifics_pb2 | 26 import password_specifics_pb2 |
| 27 import preference_specifics_pb2 | 27 import preference_specifics_pb2 |
| 28 import search_engine_specifics_pb2 |
| 28 import session_specifics_pb2 | 29 import session_specifics_pb2 |
| 29 import sync_pb2 | 30 import sync_pb2 |
| 30 import theme_specifics_pb2 | 31 import theme_specifics_pb2 |
| 31 import typed_url_specifics_pb2 | 32 import typed_url_specifics_pb2 |
| 32 | 33 |
| 33 # An enumeration of the various kinds of data that can be synced. | 34 # An enumeration of the various kinds of data that can be synced. |
| 34 # Over the wire, this enumeration is not used: a sync object's type is | 35 # Over the wire, this enumeration is not used: a sync object's type is |
| 35 # inferred by which EntitySpecifics extension it has. But in the context | 36 # inferred by which EntitySpecifics extension it has. But in the context |
| 36 # of a program, it is useful to have an enumeration. | 37 # of a program, it is useful to have an enumeration. |
| 37 ALL_TYPES = ( | 38 ALL_TYPES = ( |
| 38 TOP_LEVEL, # The type of the 'Google Chrome' folder. | 39 TOP_LEVEL, # The type of the 'Google Chrome' folder. |
| 39 APPS, | 40 APPS, |
| 40 AUTOFILL, | 41 AUTOFILL, |
| 41 AUTOFILL_PROFILE, | 42 AUTOFILL_PROFILE, |
| 42 BOOKMARK, | 43 BOOKMARK, |
| 43 EXTENSIONS, | 44 EXTENSIONS, |
| 44 NIGORI, | 45 NIGORI, |
| 45 PASSWORD, | 46 PASSWORD, |
| 46 PREFERENCE, | 47 PREFERENCE, |
| 48 SEARCH_ENGINE, |
| 47 SESSION, | 49 SESSION, |
| 48 THEME, | 50 THEME, |
| 49 TYPED_URL) = range(12) | 51 TYPED_URL) = range(13) |
| 50 | 52 |
| 51 # Well-known server tag of the top level 'Google Chrome' folder. | 53 # Well-known server tag of the top level 'Google Chrome' folder. |
| 52 TOP_LEVEL_FOLDER_TAG = 'google_chrome' | 54 TOP_LEVEL_FOLDER_TAG = 'google_chrome' |
| 53 | 55 |
| 54 # Given a sync type from ALL_TYPES, find the extension token corresponding | 56 # Given a sync type from ALL_TYPES, find the extension token corresponding |
| 55 # to that datatype. Note that TOP_LEVEL has no such token. | 57 # to that datatype. Note that TOP_LEVEL has no such token. |
| 56 SYNC_TYPE_TO_EXTENSION = { | 58 SYNC_TYPE_TO_EXTENSION = { |
| 57 APPS: app_specifics_pb2.app, | 59 APPS: app_specifics_pb2.app, |
| 58 AUTOFILL: autofill_specifics_pb2.autofill, | 60 AUTOFILL: autofill_specifics_pb2.autofill, |
| 59 AUTOFILL_PROFILE: autofill_specifics_pb2.autofill_profile, | 61 AUTOFILL_PROFILE: autofill_specifics_pb2.autofill_profile, |
| 60 BOOKMARK: bookmark_specifics_pb2.bookmark, | 62 BOOKMARK: bookmark_specifics_pb2.bookmark, |
| 61 EXTENSIONS: extension_specifics_pb2.extension, | 63 EXTENSIONS: extension_specifics_pb2.extension, |
| 62 NIGORI: nigori_specifics_pb2.nigori, | 64 NIGORI: nigori_specifics_pb2.nigori, |
| 63 PASSWORD: password_specifics_pb2.password, | 65 PASSWORD: password_specifics_pb2.password, |
| 64 PREFERENCE: preference_specifics_pb2.preference, | 66 PREFERENCE: preference_specifics_pb2.preference, |
| 67 SEARCH_ENGINE: search_engine_specifics_pb2.search_engine, |
| 65 SESSION: session_specifics_pb2.session, | 68 SESSION: session_specifics_pb2.session, |
| 66 THEME: theme_specifics_pb2.theme, | 69 THEME: theme_specifics_pb2.theme, |
| 67 TYPED_URL: typed_url_specifics_pb2.typed_url, | 70 TYPED_URL: typed_url_specifics_pb2.typed_url, |
| 68 } | 71 } |
| 69 | 72 |
| 70 # The parent ID used to indicate a top-level node. | 73 # The parent ID used to indicate a top-level node. |
| 71 ROOT_ID = '0' | 74 ROOT_ID = '0' |
| 72 | 75 |
| 73 | 76 |
| 74 class Error(Exception): | 77 class Error(Exception): |
| (...skipping 299 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 374 PermanentItem('google_chrome_preferences', name='Preferences', | 377 PermanentItem('google_chrome_preferences', name='Preferences', |
| 375 parent_tag='google_chrome', sync_type=PREFERENCE), | 378 parent_tag='google_chrome', sync_type=PREFERENCE), |
| 376 PermanentItem('google_chrome_autofill', name='Autofill', | 379 PermanentItem('google_chrome_autofill', name='Autofill', |
| 377 parent_tag='google_chrome', sync_type=AUTOFILL), | 380 parent_tag='google_chrome', sync_type=AUTOFILL), |
| 378 PermanentItem('google_chrome_autofill_profiles', name='Autofill Profiles', | 381 PermanentItem('google_chrome_autofill_profiles', name='Autofill Profiles', |
| 379 parent_tag='google_chrome', sync_type=AUTOFILL_PROFILE), | 382 parent_tag='google_chrome', sync_type=AUTOFILL_PROFILE), |
| 380 PermanentItem('google_chrome_extensions', name='Extensions', | 383 PermanentItem('google_chrome_extensions', name='Extensions', |
| 381 parent_tag='google_chrome', sync_type=EXTENSIONS), | 384 parent_tag='google_chrome', sync_type=EXTENSIONS), |
| 382 PermanentItem('google_chrome_passwords', name='Passwords', | 385 PermanentItem('google_chrome_passwords', name='Passwords', |
| 383 parent_tag='google_chrome', sync_type=PASSWORD), | 386 parent_tag='google_chrome', sync_type=PASSWORD), |
| 387 PermanentItem('google_chrome_search_engines', name='Search Engines', |
| 388 parent_tag='google_chrome', sync_type=SEARCH_ENGINE), |
| 384 PermanentItem('google_chrome_sessions', name='Sessions', | 389 PermanentItem('google_chrome_sessions', name='Sessions', |
| 385 parent_tag='google_chrome', sync_type=SESSION), | 390 parent_tag='google_chrome', sync_type=SESSION), |
| 386 PermanentItem('google_chrome_themes', name='Themes', | 391 PermanentItem('google_chrome_themes', name='Themes', |
| 387 parent_tag='google_chrome', sync_type=THEME), | 392 parent_tag='google_chrome', sync_type=THEME), |
| 388 PermanentItem('google_chrome_typed_urls', name='Typed URLs', | 393 PermanentItem('google_chrome_typed_urls', name='Typed URLs', |
| 389 parent_tag='google_chrome', sync_type=TYPED_URL), | 394 parent_tag='google_chrome', sync_type=TYPED_URL), |
| 390 PermanentItem('google_chrome_nigori', name='Nigori', | 395 PermanentItem('google_chrome_nigori', name='Nigori', |
| 391 parent_tag='google_chrome', sync_type=NIGORI), | 396 parent_tag='google_chrome', sync_type=NIGORI), |
| 392 PermanentItem('google_chrome_apps', name='Apps', | 397 PermanentItem('google_chrome_apps', name='Apps', |
| 393 parent_tag='google_chrome', sync_type=APPS), | 398 parent_tag='google_chrome', sync_type=APPS), |
| (...skipping 688 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1082 | 1087 |
| 1083 update_sieve.CheckMigrationState() | 1088 update_sieve.CheckMigrationState() |
| 1084 | 1089 |
| 1085 new_timestamp, entries, remaining = self.account.GetChanges(update_sieve) | 1090 new_timestamp, entries, remaining = self.account.GetChanges(update_sieve) |
| 1086 | 1091 |
| 1087 update_response.changes_remaining = remaining | 1092 update_response.changes_remaining = remaining |
| 1088 for entry in entries: | 1093 for entry in entries: |
| 1089 reply = update_response.entries.add() | 1094 reply = update_response.entries.add() |
| 1090 reply.CopyFrom(entry) | 1095 reply.CopyFrom(entry) |
| 1091 update_sieve.SaveProgress(new_timestamp, update_response) | 1096 update_sieve.SaveProgress(new_timestamp, update_response) |
| OLD | NEW |