diff options
-rw-r--r-- | Android.mk | 13 | ||||
-rw-r--r-- | AndroidManifest.xml | 29 | ||||
-rw-r--r-- | MODULE_LICENSE_APACHE2 | 0 | ||||
-rw-r--r-- | NOTICE | 190 | ||||
-rw-r--r-- | res/drawable/ic_launcher_im.png | bin | 0 -> 2951 bytes | |||
-rw-r--r-- | res/values-de-rDE/strings.xml | 12 | ||||
-rw-r--r-- | res/values-en-rGB/strings.xml | 12 | ||||
-rw-r--r-- | res/values-es-rUS/strings.xml | 12 | ||||
-rw-r--r-- | res/values-fr-rFR/strings.xml | 12 | ||||
-rw-r--r-- | res/values-it-rIT/strings.xml | 12 | ||||
-rw-r--r-- | res/values-zh-rTW/strings.xml | 12 | ||||
-rw-r--r-- | res/values/strings.xml | 29 | ||||
-rw-r--r-- | res/xml/im_service_providers.xml | 19 | ||||
-rw-r--r-- | src/com/android/providers/im/ImProvider.java | 2471 |
14 files changed, 2823 insertions, 0 deletions
diff --git a/Android.mk b/Android.mk new file mode 100644 index 0000000..f86f79c --- /dev/null +++ b/Android.mk @@ -0,0 +1,13 @@ +LOCAL_PATH:= $(call my-dir) +include $(CLEAR_VARS) + +LOCAL_MODULE_TAGS := user + +LOCAL_SRC_FILES := $(call all-subdir-java-files) + +LOCAL_JAVA_LIBRARIES := ext + +LOCAL_PACKAGE_NAME := ImProvider +LOCAL_CERTIFICATE := shared + +include $(BUILD_PACKAGE) diff --git a/AndroidManifest.xml b/AndroidManifest.xml new file mode 100644 index 0000000..d3ad6d8 --- /dev/null +++ b/AndroidManifest.xml @@ -0,0 +1,29 @@ +<manifest xmlns:android="http://schemas.android.com/apk/res/android" + package="com.android.providers.im" + android:sharedUserId="android.uid.shared"> + + <permission android:name="com.android.providers.im.permission.READ_ONLY" + android:permissionGroup="android.permission-group.MESSAGES" + android:protectionLevel="dangerous" + android:label="@string/ro_perm_label" + android:description="@string/ro_perm_desc" /> + + <permission android:name="com.android.providers.im.permission.WRITE_ONLY" + android:permissionGroup="android.permission-group.MESSAGES" + android:protectionLevel="dangerous" + android:label="@string/wo_perm_label" + android:description="@string/wo_perm_desc" /> + + <uses-permission android:name="com.android.providers.im.permission.READ_ONLY" /> + <uses-permission android:name="com.android.providers.im.permission.WRITE_ONLY" /> + + <application android:process="android.process.acore" + android:label="IM Storage" + android:icon="@drawable/ic_launcher_im"> + <provider android:name="ImProvider" android:authorities="im" + android:multiprocess="false" + android:readPermission="com.android.providers.im.permission.READ_ONLY" + android:writePermission="com.android.providers.im.permission.WRITE_ONLY" + android:grantUriPermissions="true" /> + </application> +</manifest> diff --git a/MODULE_LICENSE_APACHE2 b/MODULE_LICENSE_APACHE2 new file mode 100644 index 0000000..e69de29 --- /dev/null +++ b/MODULE_LICENSE_APACHE2 @@ -0,0 +1,190 @@ + + Copyright (c) 2005-2008, The Android Open Source Project + + Licensed under the Apache License, Version 2.0 (the "License"); + you may not use this file except in compliance with the License. + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + + + Apache License + Version 2.0, January 2004 + http://www.apache.org/licenses/ + + TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION + + 1. Definitions. + + "License" shall mean the terms and conditions for use, reproduction, + and distribution as defined by Sections 1 through 9 of this document. + + "Licensor" shall mean the copyright owner or entity authorized by + the copyright owner that is granting the License. + + "Legal Entity" shall mean the union of the acting entity and all + other entities that control, are controlled by, or are under common + control with that entity. For the purposes of this definition, + "control" means (i) the power, direct or indirect, to cause the + direction or management of such entity, whether by contract or + otherwise, or (ii) ownership of fifty percent (50%) or more of the + outstanding shares, or (iii) beneficial ownership of such entity. + + "You" (or "Your") shall mean an individual or Legal Entity + exercising permissions granted by this License. + + "Source" form shall mean the preferred form for making modifications, + including but not limited to software source code, documentation + source, and configuration files. + + "Object" form shall mean any form resulting from mechanical + transformation or translation of a Source form, including but + not limited to compiled object code, generated documentation, + and conversions to other media types. + + "Work" shall mean the work of authorship, whether in Source or + Object form, made available under the License, as indicated by a + copyright notice that is included in or attached to the work + (an example is provided in the Appendix below). + + "Derivative Works" shall mean any work, whether in Source or Object + form, that is based on (or derived from) the Work and for which the + editorial revisions, annotations, elaborations, or other modifications + represent, as a whole, an original work of authorship. For the purposes + of this License, Derivative Works shall not include works that remain + separable from, or merely link (or bind by name) to the interfaces of, + the Work and Derivative Works thereof. + + "Contribution" shall mean any work of authorship, including + the original version of the Work and any modifications or additions + to that Work or Derivative Works thereof, that is intentionally + submitted to Licensor for inclusion in the Work by the copyright owner + or by an individual or Legal Entity authorized to submit on behalf of + the copyright owner. For the purposes of this definition, "submitted" + means any form of electronic, verbal, or written communication sent + to the Licensor or its representatives, including but not limited to + communication on electronic mailing lists, source code control systems, + and issue tracking systems that are managed by, or on behalf of, the + Licensor for the purpose of discussing and improving the Work, but + excluding communication that is conspicuously marked or otherwise + designated in writing by the copyright owner as "Not a Contribution." + + "Contributor" shall mean Licensor and any individual or Legal Entity + on behalf of whom a Contribution has been received by Licensor and + subsequently incorporated within the Work. + + 2. Grant of Copyright License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + copyright license to reproduce, prepare Derivative Works of, + publicly display, publicly perform, sublicense, and distribute the + Work and such Derivative Works in Source or Object form. + + 3. Grant of Patent License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + (except as stated in this section) patent license to make, have made, + use, offer to sell, sell, import, and otherwise transfer the Work, + where such license applies only to those patent claims licensable + by such Contributor that are necessarily infringed by their + Contribution(s) alone or by combination of their Contribution(s) + with the Work to which such Contribution(s) was submitted. If You + institute patent litigation against any entity (including a + cross-claim or counterclaim in a lawsuit) alleging that the Work + or a Contribution incorporated within the Work constitutes direct + or contributory patent infringement, then any patent licenses + granted to You under this License for that Work shall terminate + as of the date such litigation is filed. + + 4. Redistribution. You may reproduce and distribute copies of the + Work or Derivative Works thereof in any medium, with or without + modifications, and in Source or Object form, provided that You + meet the following conditions: + + (a) You must give any other recipients of the Work or + Derivative Works a copy of this License; and + + (b) You must cause any modified files to carry prominent notices + stating that You changed the files; and + + (c) You must retain, in the Source form of any Derivative Works + that You distribute, all copyright, patent, trademark, and + attribution notices from the Source form of the Work, + excluding those notices that do not pertain to any part of + the Derivative Works; and + + (d) If the Work includes a "NOTICE" text file as part of its + distribution, then any Derivative Works that You distribute must + include a readable copy of the attribution notices contained + within such NOTICE file, excluding those notices that do not + pertain to any part of the Derivative Works, in at least one + of the following places: within a NOTICE text file distributed + as part of the Derivative Works; within the Source form or + documentation, if provided along with the Derivative Works; or, + within a display generated by the Derivative Works, if and + wherever such third-party notices normally appear. The contents + of the NOTICE file are for informational purposes only and + do not modify the License. You may add Your own attribution + notices within Derivative Works that You distribute, alongside + or as an addendum to the NOTICE text from the Work, provided + that such additional attribution notices cannot be construed + as modifying the License. + + You may add Your own copyright statement to Your modifications and + may provide additional or different license terms and conditions + for use, reproduction, or distribution of Your modifications, or + for any such Derivative Works as a whole, provided Your use, + reproduction, and distribution of the Work otherwise complies with + the conditions stated in this License. + + 5. Submission of Contributions. Unless You explicitly state otherwise, + any Contribution intentionally submitted for inclusion in the Work + by You to the Licensor shall be under the terms and conditions of + this License, without any additional terms or conditions. + Notwithstanding the above, nothing herein shall supersede or modify + the terms of any separate license agreement you may have executed + with Licensor regarding such Contributions. + + 6. Trademarks. This License does not grant permission to use the trade + names, trademarks, service marks, or product names of the Licensor, + except as required for reasonable and customary use in describing the + origin of the Work and reproducing the content of the NOTICE file. + + 7. Disclaimer of Warranty. Unless required by applicable law or + agreed to in writing, Licensor provides the Work (and each + Contributor provides its Contributions) on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + implied, including, without limitation, any warranties or conditions + of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A + PARTICULAR PURPOSE. You are solely responsible for determining the + appropriateness of using or redistributing the Work and assume any + risks associated with Your exercise of permissions under this License. + + 8. Limitation of Liability. In no event and under no legal theory, + whether in tort (including negligence), contract, or otherwise, + unless required by applicable law (such as deliberate and grossly + negligent acts) or agreed to in writing, shall any Contributor be + liable to You for damages, including any direct, indirect, special, + incidental, or consequential damages of any character arising as a + result of this License or out of the use or inability to use the + Work (including but not limited to damages for loss of goodwill, + work stoppage, computer failure or malfunction, or any and all + other commercial damages or losses), even if such Contributor + has been advised of the possibility of such damages. + + 9. Accepting Warranty or Additional Liability. While redistributing + the Work or Derivative Works thereof, You may choose to offer, + and charge a fee for, acceptance of support, warranty, indemnity, + or other liability obligations and/or rights consistent with this + License. However, in accepting such obligations, You may act only + on Your own behalf and on Your sole responsibility, not on behalf + of any other Contributor, and only if You agree to indemnify, + defend, and hold each Contributor harmless for any liability + incurred by, or claims asserted against, such Contributor by reason + of your accepting any such warranty or additional liability. + + END OF TERMS AND CONDITIONS + diff --git a/res/drawable/ic_launcher_im.png b/res/drawable/ic_launcher_im.png Binary files differnew file mode 100644 index 0000000..afc35a2 --- /dev/null +++ b/res/drawable/ic_launcher_im.png diff --git a/res/values-de-rDE/strings.xml b/res/values-de-rDE/strings.xml new file mode 100644 index 0000000..80a4437 --- /dev/null +++ b/res/values-de-rDE/strings.xml @@ -0,0 +1,12 @@ +<?xml version="1.0" encoding="utf-8"?> +<resources xmlns:android="http://schemas.android.com/apk/res/android" + xmlns:xliff="urn:oasis:names:tc:xliff:document:1.2"> + <string name="ro_perm_desc"> + Ermöglicht einer Anwendung, Daten vom IM-Inhalteanbieter zu lesen. + </string> + <string name="ro_perm_label">Sofortnachrichten lesen</string> + <string name="wo_perm_desc"> + Ermöglicht einer Anwendung, Daten zum IM-Inhalteanbieter zu schreiben. +</string> + <string name="wo_perm_label">Sofortnachrichten schreiben</string> +</resources> diff --git a/res/values-en-rGB/strings.xml b/res/values-en-rGB/strings.xml new file mode 100644 index 0000000..ab27737 --- /dev/null +++ b/res/values-en-rGB/strings.xml @@ -0,0 +1,12 @@ +<?xml version="1.0" encoding="utf-8"?> +<resources xmlns:android="http://schemas.android.com/apk/res/android" + xmlns:xliff="urn:oasis:names:tc:xliff:document:1.2"> + <string name="ro_perm_desc"> + Allows applications to read data from the IM content provider. + </string> + <string name="ro_perm_label">read instant messages</string> + <string name="wo_perm_desc"> + Allows applications to write data to the IM content provider. + </string> + <string name="wo_perm_label">write instant messages</string> +</resources> diff --git a/res/values-es-rUS/strings.xml b/res/values-es-rUS/strings.xml new file mode 100644 index 0000000..af5b2d4 --- /dev/null +++ b/res/values-es-rUS/strings.xml @@ -0,0 +1,12 @@ +<?xml version="1.0" encoding="utf-8"?> +<resources xmlns:android="http://schemas.android.com/apk/res/android" + xmlns:xliff="urn:oasis:names:tc:xliff:document:1.2"> + <string name="ro_perm_desc"> + Permite a la aplicación leer datos del proveedor del contenido de MI. + </string> + <string name="ro_perm_label">leer mensajes instantáneos</string> + <string name="wo_perm_desc"> + Permite a la aplicación escribir datos en el proveedor del contenido de MI. +</string> + <string name="wo_perm_label">escribir mensajes instantáneos</string> +</resources> diff --git a/res/values-fr-rFR/strings.xml b/res/values-fr-rFR/strings.xml new file mode 100644 index 0000000..1243bf5 --- /dev/null +++ b/res/values-fr-rFR/strings.xml @@ -0,0 +1,12 @@ +<?xml version="1.0" encoding="utf-8"?> +<resources xmlns:android="http://schemas.android.com/apk/res/android" + xmlns:xliff="urn:oasis:names:tc:xliff:document:1.2"> + <string name="ro_perm_desc"> + Permet aux applications de lire les données du fournisseur de contenu IM. + </string> + <string name="ro_perm_label">lire les messages instantanés</string> + <string name="wo_perm_desc"> + Permet aux applications d\'écrire les données vers le fournisseur de contenu IM. + </string> + <string name="wo_perm_label">écrire les messages instantanés</string> +</resources> diff --git a/res/values-it-rIT/strings.xml b/res/values-it-rIT/strings.xml new file mode 100644 index 0000000..619b8c0 --- /dev/null +++ b/res/values-it-rIT/strings.xml @@ -0,0 +1,12 @@ +<?xml version="1.0" encoding="utf-8"?> +<resources xmlns:android="http://schemas.android.com/apk/res/android" + xmlns:xliff="urn:oasis:names:tc:xliff:document:1.2"> + <string name="ro_perm_desc"> + Consente alle applicazioni di leggere i dati dal provider di contenuti IM. + </string> + <string name="ro_perm_label">leggi messaggi immediati</string> + <string name="wo_perm_desc"> + Consente alle applicazioni di scrivere i dati nel provider di contenuti IM. +</string> + <string name="wo_perm_label">scrivi messaggi immediati</string> +</resources> diff --git a/res/values-zh-rTW/strings.xml b/res/values-zh-rTW/strings.xml new file mode 100644 index 0000000..303b986 --- /dev/null +++ b/res/values-zh-rTW/strings.xml @@ -0,0 +1,12 @@ +<?xml version="1.0" encoding="utf-8"?> +<resources xmlns:android="http://schemas.android.com/apk/res/android" + xmlns:xliff="urn:oasis:names:tc:xliff:document:1.2"> + <string name="ro_perm_desc"> + 允許應用程式從立即訊息內容提供者讀取資料。 + </string> + <string name="ro_perm_label">讀取立即訊息</string> + <string name="wo_perm_desc"> + 允許應用程式將資料寫入立即訊息內容提供者。 + </string> + <string name="wo_perm_label">寫入立即訊息</string> +</resources> diff --git a/res/values/strings.xml b/res/values/strings.xml new file mode 100644 index 0000000..a60fc70 --- /dev/null +++ b/res/values/strings.xml @@ -0,0 +1,29 @@ +<?xml version="1.0" encoding="utf-8"?> +<!-- +** +** Copyright 2007, The Android Open Source Project +** +** Licensed under the Apache License, Version 2.0 (the "License"); +** you may not use this file except in compliance with the License. +** You may obtain a copy of the License at +** +** http://www.apache.org/licenses/LICENSE-2.0 +** +** Unless required by applicable law or agreed to in writing, software +** distributed under the License is distributed on an "AS IS" BASIS, +** WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +** See the License for the specific language governing permissions and +** limitations under the License. +*/ +--> +<resources> + <string name="ro_perm_label">read instant messages</string> + <string name="ro_perm_desc"> + Allows applications to read data from the IM content provider. + </string> + + <string name="wo_perm_label">write instant messages</string> + <string name="wo_perm_desc"> + Allows applications to write data to the IM content provider. + </string> +</resources> diff --git a/res/xml/im_service_providers.xml b/res/xml/im_service_providers.xml new file mode 100644 index 0000000..d8d88b1 --- /dev/null +++ b/res/xml/im_service_providers.xml @@ -0,0 +1,19 @@ +<?xml version="1.0" encoding="utf-8"?> +<!-- Copyright (C) 2007 The Android Open Source Project + + Licensed under the Apache License, Version 2.0 (the "License"); + you may not use this file except in compliance with the License. + You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. +--> + +<im_providers version="1"> + <provider name="GTalk" full_name="Google Talk"/> +</im_providers> diff --git a/src/com/android/providers/im/ImProvider.java b/src/com/android/providers/im/ImProvider.java new file mode 100644 index 0000000..c3b59a7 --- /dev/null +++ b/src/com/android/providers/im/ImProvider.java @@ -0,0 +1,2471 @@ +/* + * Copyright (C) 2007 The Android Open Source Project + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package com.android.providers.im; + +import android.content.ContentProvider; +import android.content.ContentValues; +import android.content.Context; +import android.content.UriMatcher; +import android.content.res.XmlResourceParser; +import android.database.Cursor; +import android.database.DatabaseUtils; +import android.database.sqlite.SQLiteConstraintException; +import android.database.sqlite.SQLiteDatabase; +import android.database.sqlite.SQLiteOpenHelper; +import android.database.sqlite.SQLiteQueryBuilder; +import android.net.Uri; +import android.os.ParcelFileDescriptor; +import android.provider.Im; +import android.text.TextUtils; +import android.util.Log; +import com.android.internal.util.XmlUtils; + +import org.xmlpull.v1.XmlPullParserException; + +import java.io.FileNotFoundException; +import java.io.IOException; +import java.io.UnsupportedEncodingException; +import java.net.URLDecoder; +import java.util.ArrayList; +import java.util.HashMap; + +/** + * A content provider for IM + */ +public class ImProvider extends ContentProvider { + private static final String LOG_TAG = "imProvider"; + private static final boolean DBG = false; + + private static final String AUTHORITY = "im"; + + private static final boolean USE_CONTACT_PRESENCE_TRIGGER = false; + + private static final String TABLE_ACCOUNTS = "accounts"; + private static final String TABLE_PROVIDERS = "providers"; + private static final String TABLE_PROVIDER_SETTINGS = "providerSettings"; + + private static final String TABLE_CONTACTS = "contacts"; + private static final String TABLE_CONTACTS_ETAG = "contactsEtag"; + private static final String TABLE_BLOCKED_LIST = "blockedList"; + private static final String TABLE_CONTACT_LIST = "contactList"; + private static final String TABLE_INVITATIONS = "invitations"; + private static final String TABLE_GROUP_MEMBERS = "groupMembers"; + private static final String TABLE_GROUP_MESSAGES = "groupMessages"; + private static final String TABLE_PRESENCE = "presence"; + private static final String USERNAME = "username"; + private static final String TABLE_CHATS = "chats"; + private static final String TABLE_AVATARS = "avatars"; + private static final String TABLE_SESSION_COOKIES = "sessionCookies"; + private static final String TABLE_MESSAGES = "messages"; + private static final String TABLE_OUTGOING_RMQ_MESSAGES = "outgoingRmqMessages"; + private static final String TABLE_LAST_RMQ_ID = "lastrmqid"; + + private static final String DATABASE_NAME = "im.db"; + private static final int DATABASE_VERSION = 44; + + protected static final int MATCH_PROVIDERS = 1; + protected static final int MATCH_PROVIDERS_BY_ID = 2; + protected static final int MATCH_PROVIDERS_WITH_ACCOUNT = 3; + protected static final int MATCH_ACCOUNTS = 10; + protected static final int MATCH_ACCOUNTS_BY_ID = 11; + protected static final int MATCH_CONTACTS = 18; + protected static final int MATCH_CONTACTS_JOIN_PRESENCE = 19; + protected static final int MATCH_CONTACTS_BAREBONE = 20; + protected static final int MATCH_CHATTING_CONTACTS = 21; + protected static final int MATCH_CONTACTS_BY_PROVIDER = 22; + protected static final int MATCH_CHATTING_CONTACTS_BY_PROVIDER = 23; + protected static final int MATCH_NO_CHATTING_CONTACTS_BY_PROVIDER = 24; + protected static final int MATCH_ONLINE_CONTACTS_BY_PROVIDER = 25; + protected static final int MATCH_OFFLINE_CONTACTS_BY_PROVIDER = 26; + protected static final int MATCH_CONTACT = 27; + protected static final int MATCH_CONTACTS_BULK = 28; + protected static final int MATCH_ONLINE_CONTACT_COUNT = 30; + protected static final int MATCH_BLOCKED_CONTACTS = 31; + protected static final int MATCH_CONTACTLISTS = 32; + protected static final int MATCH_CONTACTLISTS_BY_PROVIDER = 33; + protected static final int MATCH_CONTACTLIST = 34; + protected static final int MATCH_BLOCKEDLIST = 35; + protected static final int MATCH_BLOCKEDLIST_BY_PROVIDER = 36; + protected static final int MATCH_CONTACTS_ETAGS = 37; + protected static final int MATCH_CONTACTS_ETAG = 38; + protected static final int MATCH_PRESENCE = 40; + protected static final int MATCH_PRESENCE_ID = 41; + protected static final int MATCH_PRESENCE_BY_ACCOUNT = 42; + protected static final int MATCH_PRESENCE_SEED_BY_ACCOUNT = 43; + protected static final int MATCH_PRESENCE_BULK = 44; + protected static final int MATCH_MESSAGES = 50; + protected static final int MATCH_MESSAGES_BY_CONTACT = 51; + protected static final int MATCH_MESSAGE = 52; + protected static final int MATCH_GROUP_MESSAGES = 53; + protected static final int MATCH_GROUP_MESSAGE_BY = 54; + protected static final int MATCH_GROUP_MESSAGE = 55; + protected static final int MATCH_GROUP_MEMBERS = 58; + protected static final int MATCH_GROUP_MEMBERS_BY_GROUP = 59; + protected static final int MATCH_AVATARS = 60; + protected static final int MATCH_AVATAR = 61; + protected static final int MATCH_AVATAR_BY_PROVIDER = 62; + protected static final int MATCH_CHATS = 70; + protected static final int MATCH_CHATS_BY_ACCOUNT = 71; + protected static final int MATCH_CHATS_ID = 72; + protected static final int MATCH_SESSIONS = 80; + protected static final int MATCH_SESSIONS_BY_PROVIDER = 81; + protected static final int MATCH_PROVIDER_SETTINGS = 90; + protected static final int MATCH_PROVIDER_SETTINGS_BY_ID = 91; + protected static final int MATCH_PROVIDER_SETTINGS_BY_ID_AND_NAME = 92; + protected static final int MATCH_INVITATIONS = 100; + protected static final int MATCH_INVITATION = 101; + protected static final int MATCH_OUTGOING_RMQ_MESSAGES = 110; + protected static final int MATCH_OUTGOING_RMQ_MESSAGE = 111; + protected static final int MATCH_OUTGOING_HIGHEST_RMQ_ID = 112; + protected static final int MATCH_LAST_RMQ_ID = 113; + + protected final UriMatcher mUrlMatcher = new UriMatcher(UriMatcher.NO_MATCH); + private final String mTransientDbName; + + private static final HashMap<String, String> sProviderAccountsProjectionMap; + private static final HashMap<String, String> sContactsProjectionMap; + private static final HashMap<String, String> sContactListProjectionMap; + private static final HashMap<String, String> sBlockedListProjectionMap; + + private static final String PROVIDER_JOIN_ACCOUNT_TABLE = + "providers LEFT OUTER JOIN accounts ON (providers._id = accounts.provider AND accounts.active = 1)"; + + private static final String CONTACT_JOIN_PRESENCE_TABLE = + "contacts LEFT OUTER JOIN presence ON (contacts._id = presence.contact_id)"; + + private static final String CONTACT_JOIN_PRESENCE_CHAT_TABLE = + CONTACT_JOIN_PRESENCE_TABLE + + " LEFT OUTER JOIN chats ON (contacts._id = chats.contact_id)"; + + private static final String CONTACT_JOIN_PRESENCE_CHAT_AVATAR_TABLE = + CONTACT_JOIN_PRESENCE_CHAT_TABLE + + " LEFT OUTER JOIN avatars ON (contacts.username = avatars.contact" + + " AND contacts.account = avatars.account_id)"; + + private static final String BLOCKEDLIST_JOIN_AVATAR_TABLE = + "blockedList LEFT OUTER JOIN avatars ON (blockedList.username = avatars.contact" + + " AND blockedList.account = avatars.account_id)"; + + /** + * The where clause for filtering out blocked contacts + */ + private static final String NON_BLOCKED_CONTACTS_WHERE_CLAUSE = "(" + + Im.Contacts.TYPE + " IS NULL OR " + + Im.Contacts.TYPE + "!=" + + String.valueOf(Im.Contacts.TYPE_BLOCKED) + + ")"; + + private static final String BLOCKED_CONTACTS_WHERE_CLAUSE = + "(contacts." + Im.Contacts.TYPE + "=" + Im.Contacts.TYPE_BLOCKED + ")"; + + private static final String CONTACT_ID = TABLE_CONTACTS + '.' + Im.Contacts._ID; + private static final String PRESENCE_CONTACT_ID = TABLE_PRESENCE + '.' + Im.Presence.CONTACT_ID; + + protected SQLiteOpenHelper mOpenHelper; + private final String mDatabaseName; + private final int mDatabaseVersion; + + private class DatabaseHelper extends SQLiteOpenHelper { + + DatabaseHelper(Context context) { + super(context, mDatabaseName, null, mDatabaseVersion); + } + + @Override + public void onCreate(SQLiteDatabase db) { + + if (DBG) log("##### bootstrapDatabase"); + + db.execSQL("CREATE TABLE " + TABLE_PROVIDERS + " (" + + "_id INTEGER PRIMARY KEY," + + "name TEXT," + // eg AIM + "fullname TEXT," + // eg AOL Instance Messenger + "signup_url TEXT" + // web url to visit to create a new account + ");"); + + db.execSQL("CREATE TABLE " + TABLE_ACCOUNTS + " (" + + "_id INTEGER PRIMARY KEY," + + "name TEXT," + + "provider INTEGER," + + "username TEXT," + + "pw TEXT," + + "active INTEGER NOT NULL DEFAULT 0," + + "locked INTEGER NOT NULL DEFAULT 0," + + "keep_signed_in INTEGER NOT NULL DEFAULT 0," + + "last_login_state INTEGER NOT NULL DEFAULT 0," + + "UNIQUE (provider, username)" + + ");"); + + createContactsTables(db, null); + + db.execSQL("CREATE TABLE " + TABLE_AVATARS + " (" + + "_id INTEGER PRIMARY KEY," + + "contact TEXT," + + "provider_id INTEGER," + + "account_id INTEGER," + + "hash TEXT," + + "data BLOB," + // raw image data + "UNIQUE (account_id, contact)" + + ");"); + + db.execSQL("CREATE TABLE " + TABLE_PROVIDER_SETTINGS + " (" + + "_id INTEGER PRIMARY KEY," + + "provider INTEGER," + + "name TEXT," + + "value TEXT," + + "UNIQUE (provider, name)" + + ");"); + loadProviderSettings(db); + + db.execSQL("create TABLE " + TABLE_OUTGOING_RMQ_MESSAGES + " (" + + "_id INTEGER PRIMARY KEY," + + "rmq_id INTEGER," + + "type INTEGER," + + "ts INTEGER," + + "data TEXT" + + ");"); + + db.execSQL("create TABLE " + TABLE_LAST_RMQ_ID + " (" + + "_id INTEGER PRIMARY KEY," + + "rmq_id INTEGER" + + ");"); + + // clean up account specific data when an account is deleted. + db.execSQL("CREATE TRIGGER account_cleanup " + + "DELETE ON " + TABLE_ACCOUNTS + + " BEGIN " + + "DELETE FROM " + TABLE_AVATARS + " WHERE account_id= OLD._id;" + + "END"); + + // add a database trigger to clean up associated provider settings + // while deleting a provider + db.execSQL("CREATE TRIGGER provider_cleanup " + + "DELETE ON " + TABLE_PROVIDERS + + " BEGIN " + + "DELETE FROM " + TABLE_PROVIDER_SETTINGS + " WHERE provider= OLD._id;" + + "END"); + } + + /** + * Load settings of providers from the initial configuration file. Should only + * be done once, as the table of providerSettings is a persistent table. + * + * NOTE: This method must be called after table provider and table providerSettings + * have been created. + * @param db + */ + private void loadProviderSettings(SQLiteDatabase db) { + XmlResourceParser parser = getContext().getResources() + .getXml(R.xml.im_service_providers); + + try { + XmlUtils.beginDocument(parser, "im_providers"); + + while (true) { + XmlUtils.nextElement(parser); + String tag = parser.getName(); + if (!"provider".equals(tag)) { + break; + } + + int numAttrs = parser.getAttributeCount(); + + HashMap<String, String> prefs = new HashMap<String, String>(); + for (int i = 0; i < numAttrs; i++) { + String attrName = parser.getAttributeName(i); + String value = parser.getAttributeValue(i); + + prefs.put(attrName, value); + } + + String name = prefs.get("name"); + String fullname = prefs.get("full_name"); + String signup_url = prefs.get("signup_url"); + + // insert to table provider + ContentValues values = new ContentValues(); + values.put(Im.Provider.NAME, name); + values.put(Im.Provider.FULLNAME, fullname); + values.put(Im.Provider.SIGNUP_URL, signup_url); + + db.insert(TABLE_PROVIDERS, "name", values); + } + } catch (XmlPullParserException e) { + } catch (IOException e) { + } finally { + parser.close(); + } + } + + @Override + public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) { + Log.w(LOG_TAG, "Upgrading database from version " + oldVersion + + " to " + newVersion + ", which will destroy all old data"); + + db.execSQL("DROP TABLE IF EXISTS " + TABLE_PROVIDERS); + db.execSQL("DROP TABLE IF EXISTS " + TABLE_ACCOUNTS); + db.execSQL("DROP TABLE IF EXISTS " + TABLE_CONTACT_LIST); + db.execSQL("DROP TABLE IF EXISTS " + TABLE_CONTACTS); + db.execSQL("DROP TABLE IF EXISTS " + TABLE_CONTACTS_ETAG); + db.execSQL("DROP TABLE IF EXISTS " + TABLE_AVATARS); + db.execSQL("DROP TABLE IF EXISTS " + TABLE_PROVIDER_SETTINGS); + db.execSQL("DROP TABLE IF EXISTS " + TABLE_OUTGOING_RMQ_MESSAGES); + db.execSQL("DROP TABLE IF EXISTS " + TABLE_LAST_RMQ_ID); + + onCreate(db); + } + + private void createContactsTables(SQLiteDatabase db, String tablePrefix) { + StringBuilder buf = new StringBuilder(); + String contactsTableName; + + if (tablePrefix != null) { + contactsTableName = tablePrefix + TABLE_CONTACTS; + } else { + contactsTableName = TABLE_CONTACTS; + } + + // creating the "contacts" table + buf.append("CREATE TABLE IF NOT EXISTS "); + buf.append(contactsTableName); + buf.append(" ("); + buf.append("_id INTEGER PRIMARY KEY,"); + buf.append("username TEXT,"); + buf.append("nickname TEXT,"); + buf.append("provider INTEGER,"); + buf.append("account INTEGER,"); + buf.append("contactList INTEGER,"); + buf.append("type INTEGER,"); + buf.append("subscriptionStatus INTEGER,"); + buf.append("subscriptionType INTEGER,"); + + // the following are derived from Google Contact Extension, we don't include all + // the attributes, just the ones we can use. + // (see http://code.google.com/apis/talk/jep_extensions/roster_attributes.html) + // + // qc: quick contact (derived from message count) + // rejected: if the contact has ever been rejected by the user + buf.append("qc INTEGER,"); + buf.append("rejected INTEGER"); + + buf.append(");"); + + db.execSQL(buf.toString()); + + buf.delete(0, buf.length()); + + // creating contact etag table + buf.append("CREATE TABLE IF NOT EXISTS "); + if (tablePrefix != null) { + buf.append(tablePrefix); + } + buf.append(TABLE_CONTACTS_ETAG); + buf.append(" ("); + buf.append("_id INTEGER PRIMARY KEY,"); + buf.append("etag TEXT,"); + buf.append("account INTEGER UNIQUE"); + buf.append(");"); + + db.execSQL(buf.toString()); + + buf.delete(0, buf.length()); + + // creating the "contactList" table + buf.append("CREATE TABLE IF NOT EXISTS "); + if (tablePrefix != null) { + buf.append(tablePrefix); + } + buf.append(TABLE_CONTACT_LIST); + buf.append(" ("); + buf.append("_id INTEGER PRIMARY KEY,"); + buf.append("name TEXT,"); + buf.append("provider INTEGER,"); + buf.append("account INTEGER"); + buf.append(");"); + + db.execSQL(buf.toString()); + + buf.delete(0, buf.length()); + + // creating the "blockedList" table + buf.append("CREATE TABLE IF NOT EXISTS "); + if (tablePrefix != null) { + buf.append(tablePrefix); + } + buf.append(TABLE_BLOCKED_LIST); + buf.append(" ("); + buf.append("_id INTEGER PRIMARY KEY,"); + buf.append("username TEXT,"); + buf.append("nickname TEXT,"); + buf.append("provider INTEGER,"); + buf.append("account INTEGER"); + buf.append(");"); + + db.execSQL(buf.toString()); + } + + @Override + public void onOpen(SQLiteDatabase db) { + if (db.isReadOnly()) { + Log.w(LOG_TAG, "ImProvider database opened in read only mode."); + Log.w(LOG_TAG, "Transient tables not created."); + return; + } + + if (DBG) log("##### createTransientTables"); + + // Create transient tables + String cpDbName; + db.execSQL("ATTACH DATABASE ':memory:' AS " + mTransientDbName + ";"); + cpDbName = mTransientDbName + "."; + + // message table (since the UI currently doesn't require saving message history + // across IM sessions, store the message table in memory db only) + db.execSQL("CREATE TABLE IF NOT EXISTS " + cpDbName + TABLE_MESSAGES + " (" + + "_id INTEGER PRIMARY KEY," + + "packet_id TEXT UNIQUE," + + "contact TEXT," + + "provider INTEGER," + + "account INTEGER," + + "body TEXT," + + "date INTEGER," + // in seconds + "type INTEGER," + + "err_code INTEGER NOT NULL DEFAULT 0," + + "err_msg TEXT" + + ");"); + + // presence + db.execSQL("CREATE TABLE IF NOT EXISTS " + cpDbName + TABLE_PRESENCE + " ("+ + "_id INTEGER PRIMARY KEY," + + "contact_id INTEGER UNIQUE," + + "jid_resource TEXT," + // jid resource for the presence + "client_type INTEGER," + // client type + "priority INTEGER," + // presence priority (XMPP) + "mode INTEGER," + // presence mode + "status TEXT" + // custom status + ");"); + + // group chat invitations + db.execSQL("CREATE TABLE IF NOT EXISTS " + cpDbName + TABLE_INVITATIONS + " (" + + "_id INTEGER PRIMARY KEY," + + "providerId INTEGER," + + "accountId INTEGER," + + "inviteId TEXT," + + "sender TEXT," + + "groupName TEXT," + + "note TEXT," + + "status INTEGER" + + ");"); + + // group chat members + db.execSQL("CREATE TABLE IF NOT EXISTS " + cpDbName + TABLE_GROUP_MEMBERS + " (" + + "_id INTEGER PRIMARY KEY," + + "groupId INTEGER," + + "username TEXT," + + "nickname TEXT" + + ");"); + + // group chat messages + db.execSQL("CREATE TABLE IF NOT EXISTS " + cpDbName + TABLE_GROUP_MESSAGES + " (" + + "_id INTEGER PRIMARY KEY," + + "packet_id TEXT UNIQUE," + + "contact TEXT," + + "groupId INTEGER," + + "body TEXT," + + "date INTEGER," + + "type INTEGER," + + "err_code INTEGER NOT NULL DEFAULT 0," + + "err_msg TEXT" + + ");"); + + // chat sessions, including single person chats and group chats + db.execSQL("CREATE TABLE IF NOT EXISTS " + cpDbName + TABLE_CHATS + " ("+ + "_id INTEGER PRIMARY KEY," + + "contact_id INTEGER UNIQUE," + + "jid_resource TEXT," + // the JID resource for the user, only for non-group chats + "groupchat INTEGER," + // 1 if group chat, 0 if not TODO: remove this column + "last_unread_message TEXT," + // the last unread message + "last_message_date INTEGER," + // in seconds + "unsent_composed_message TEXT" + // a composed, but not sent message + + ");"); + + /* when we moved the contact table out of transient_db and into the main db, the + contact_cleanup and group_cleanup triggers don't work anymore. It seems we can't + create triggers that reference objects in a different database! + + // creates in-memory contacts tables. Because we need to download the + // contacts after each login, there is no need to store them in + // persistent storage. When the client server protocol supports the + // client storing contacts offline, we can move these tables to + // persistent storage + createContactsTables(db, cpDbName); + + String contactsTableName = TABLE_CONTACTS; + + if (USE_CONTACT_PRESENCE_TRIGGER) { + // Insert a default presence for newly inserted contact + db.execSQL("CREATE TRIGGER IF NOT EXISTS " + cpDbName + "contact_create_presence " + + "INSERT ON " + cpDbName + contactsTableName + + " FOR EACH ROW WHEN NEW.type != " + Im.Contacts.TYPE_GROUP + + " OR NEW.type != " + Im.Contacts.TYPE_BLOCKED + + " BEGIN " + + "INSERT INTO presence (contact_id) VALUES (NEW._id);" + + " END"); + } + + db.execSQL("CREATE TRIGGER IF NOT EXISTS " + cpDbName + "contact_cleanup " + + "DELETE ON " + cpDbName + contactsTableName + + " BEGIN " + + "DELETE FROM presence WHERE contact_id = OLD._id;" + + "DELETE FROM chats WHERE contact_id = OLD._id;" + + "END"); + + // Cleans up group members and group messages when a group chat is deleted + db.execSQL("CREATE TRIGGER IF NOT EXISTS " + cpDbName + "group_cleanup " + + "DELETE ON " + cpDbName + contactsTableName + + " FOR EACH ROW WHEN OLD.type = " + Im.Contacts.TYPE_GROUP + + " BEGIN " + + "DELETE FROM groupMembers WHERE groupId = OLD._id;" + + "DELETE FROM groupMessages WHERE groupId = OLD._id;" + + " END"); + */ + + // only store the session cookies in memory right now. This means + // that we don't persist them across device reboot + db.execSQL("CREATE TABLE IF NOT EXISTS " + cpDbName + TABLE_SESSION_COOKIES + " ("+ + "_id INTEGER PRIMARY KEY," + + "provider INTEGER," + + "account INTEGER," + + "name TEXT," + + "value TEXT" + + ");"); + + } + } + + static { + sProviderAccountsProjectionMap = new HashMap<String, String>(); + sProviderAccountsProjectionMap.put(Im.Provider._ID, + "providers._id AS _id"); + sProviderAccountsProjectionMap.put(Im.Provider._COUNT, + "COUNT(*) AS _account"); + sProviderAccountsProjectionMap.put(Im.Provider.NAME, + "providers.name AS name"); + sProviderAccountsProjectionMap.put(Im.Provider.FULLNAME, + "providers.fullname AS fullname"); + sProviderAccountsProjectionMap.put(Im.Provider.ACTIVE_ACCOUNT_ID, + "accounts._id AS account_id"); + sProviderAccountsProjectionMap.put(Im.Provider.ACTIVE_ACCOUNT_USERNAME, + "accounts.username AS account_username"); + sProviderAccountsProjectionMap.put(Im.Provider.ACTIVE_ACCOUNT_PW, + "accounts.pw AS account_pw"); + + // contacts projection map + sContactsProjectionMap = new HashMap<String, String>(); + + // Base column + sContactsProjectionMap.put(Im.Contacts._ID, "contacts._id AS _id"); + sContactsProjectionMap.put(Im.Contacts._COUNT, "COUNT(*) AS _count"); + + // contacts column + sContactsProjectionMap.put(Im.Contacts.USERNAME, "contacts.username as username"); + sContactsProjectionMap.put(Im.Contacts.NICKNAME, "contacts.nickname as nickname"); + sContactsProjectionMap.put(Im.Contacts.PROVIDER, "contacts.provider as provider"); + sContactsProjectionMap.put(Im.Contacts.ACCOUNT, "contacts.account as account"); + sContactsProjectionMap.put(Im.Contacts.CONTACTLIST, "contacts.contactList as contactList"); + sContactsProjectionMap.put(Im.Contacts.TYPE, "contacts.type as type"); + sContactsProjectionMap.put(Im.Contacts.SUBSCRIPTION_STATUS, + "contacts.subscriptionStatus as subscriptionStatus"); + sContactsProjectionMap.put(Im.Contacts.SUBSCRIPTION_TYPE, + "contacts.subscriptionType as subscriptionType"); + sContactsProjectionMap.put(Im.Contacts.QUICK_CONTACT, "contacts.qc as qc"); + sContactsProjectionMap.put(Im.Contacts.REJECTED, "contacts.rejected as rejected"); + + // Presence columns + sContactsProjectionMap.put(Im.Presence.CONTACT_ID, + "presence.contact_id AS contact_id"); + sContactsProjectionMap.put(Im.Contacts.PRESENCE_STATUS, + "presence.mode AS mode"); + sContactsProjectionMap.put(Im.Contacts.PRESENCE_CUSTOM_STATUS, + "presence.status AS status"); + sContactsProjectionMap.put(Im.Contacts.CLIENT_TYPE, + "presence.client_type AS client_type"); + + // Chats columns + sContactsProjectionMap.put(Im.Contacts.CHATS_CONTACT, + "chats.contact_id AS chats_contact_id"); + sContactsProjectionMap.put(Im.Chats.JID_RESOURCE, + "chats.jid_resource AS jid_resource"); + sContactsProjectionMap.put(Im.Chats.GROUP_CHAT, + "chats.groupchat AS groupchat"); + sContactsProjectionMap.put(Im.Contacts.LAST_UNREAD_MESSAGE, + "chats.last_unread_message AS last_unread_message"); + sContactsProjectionMap.put(Im.Contacts.LAST_MESSAGE_DATE, + "chats.last_message_date AS last_message_date"); + sContactsProjectionMap.put(Im.Contacts.UNSENT_COMPOSED_MESSAGE, + "chats.unsent_composed_message AS unsent_composed_message"); + + // Avatars columns + sContactsProjectionMap.put(Im.Contacts.AVATAR_HASH, "avatars.hash AS avatars_hash"); + sContactsProjectionMap.put(Im.Contacts.AVATAR_DATA, "avatars.data AS avatars_data"); + + // contactList projection map + sContactListProjectionMap = new HashMap<String, String>(); + sContactListProjectionMap.put(Im.ContactList._ID, + "contactList._id AS _id"); + sContactListProjectionMap.put(Im.ContactList._COUNT, + "COUNT(*) AS _count"); + sContactListProjectionMap.put(Im.ContactList.NAME, "name"); + sContactListProjectionMap.put(Im.ContactList.PROVIDER, "provider"); + sContactListProjectionMap.put(Im.ContactList.ACCOUNT, "account"); + + // blockedList projection map + sBlockedListProjectionMap = new HashMap<String, String>(); + sBlockedListProjectionMap.put(Im.BlockedList._ID, + "blockedList._id AS _id"); + sBlockedListProjectionMap.put(Im.BlockedList._COUNT, + "COUNT(*) AS _count"); + sBlockedListProjectionMap.put(Im.BlockedList.USERNAME, "username"); + sBlockedListProjectionMap.put(Im.BlockedList.NICKNAME, "nickname"); + sBlockedListProjectionMap.put(Im.BlockedList.PROVIDER, "provider"); + sBlockedListProjectionMap.put(Im.BlockedList.ACCOUNT, "account"); + sBlockedListProjectionMap.put(Im.BlockedList.AVATAR_DATA, + "avatars.data AS avatars_data"); + } + + public ImProvider() { + this(AUTHORITY, DATABASE_NAME, DATABASE_VERSION); + } + + protected ImProvider(String authority, String dbName, int dbVersion) { + mDatabaseName = dbName; + mDatabaseVersion = dbVersion; + + mTransientDbName = "transient_" + dbName.replace(".", "_"); + + mUrlMatcher.addURI(authority, "providers", MATCH_PROVIDERS); + mUrlMatcher.addURI(authority, "providers/#", MATCH_PROVIDERS_BY_ID); + mUrlMatcher.addURI(authority, "providers/account", MATCH_PROVIDERS_WITH_ACCOUNT); + + mUrlMatcher.addURI(authority, "accounts", MATCH_ACCOUNTS); + mUrlMatcher.addURI(authority, "accounts/#", MATCH_ACCOUNTS_BY_ID); + + mUrlMatcher.addURI(authority, "contacts", MATCH_CONTACTS); + mUrlMatcher.addURI(authority, "contactsWithPresence", MATCH_CONTACTS_JOIN_PRESENCE); + mUrlMatcher.addURI(authority, "contactsBarebone", MATCH_CONTACTS_BAREBONE); + mUrlMatcher.addURI(authority, "contacts/#/#", MATCH_CONTACTS_BY_PROVIDER); + mUrlMatcher.addURI(authority, "contacts/chatting", MATCH_CHATTING_CONTACTS); + mUrlMatcher.addURI(authority, "contacts/chatting/#/#", MATCH_CHATTING_CONTACTS_BY_PROVIDER); + mUrlMatcher.addURI(authority, "contacts/online/#/#", MATCH_ONLINE_CONTACTS_BY_PROVIDER); + mUrlMatcher.addURI(authority, "contacts/offline/#/#", MATCH_OFFLINE_CONTACTS_BY_PROVIDER); + mUrlMatcher.addURI(authority, "contacts/#", MATCH_CONTACT); + mUrlMatcher.addURI(authority, "contacts/blocked", MATCH_BLOCKED_CONTACTS); + mUrlMatcher.addURI(authority, "bulk_contacts", MATCH_CONTACTS_BULK); + mUrlMatcher.addURI(authority, "contacts/onlineCount", MATCH_ONLINE_CONTACT_COUNT); + + mUrlMatcher.addURI(authority, "contactLists", MATCH_CONTACTLISTS); + mUrlMatcher.addURI(authority, "contactLists/#/#", MATCH_CONTACTLISTS_BY_PROVIDER); + mUrlMatcher.addURI(authority, "contactLists/#", MATCH_CONTACTLIST); + mUrlMatcher.addURI(authority, "blockedList", MATCH_BLOCKEDLIST); + mUrlMatcher.addURI(authority, "blockedList/#/#", MATCH_BLOCKEDLIST_BY_PROVIDER); + + mUrlMatcher.addURI(authority, "contactsEtag", MATCH_CONTACTS_ETAGS); + mUrlMatcher.addURI(authority, "contactsEtag/#", MATCH_CONTACTS_ETAG); + + mUrlMatcher.addURI(authority, "presence", MATCH_PRESENCE); + mUrlMatcher.addURI(authority, "presence/#", MATCH_PRESENCE_ID); + mUrlMatcher.addURI(authority, "presence/account/#", MATCH_PRESENCE_BY_ACCOUNT); + mUrlMatcher.addURI(authority, "seed_presence/account/#", MATCH_PRESENCE_SEED_BY_ACCOUNT); + mUrlMatcher.addURI(authority, "bulk_presence", MATCH_PRESENCE_BULK); + + mUrlMatcher.addURI(authority, "messages", MATCH_MESSAGES); + mUrlMatcher.addURI(authority, "messagesBy/#/#/*", MATCH_MESSAGES_BY_CONTACT); + mUrlMatcher.addURI(authority, "messages/#", MATCH_MESSAGE); + + mUrlMatcher.addURI(authority, "groupMessages", MATCH_GROUP_MESSAGES); + mUrlMatcher.addURI(authority, "groupMessagesBy/#", MATCH_GROUP_MESSAGE_BY); + mUrlMatcher.addURI(authority, "groupMessages/#", MATCH_GROUP_MESSAGE); + mUrlMatcher.addURI(authority, "groupMembers", MATCH_GROUP_MEMBERS); + mUrlMatcher.addURI(authority, "groupMembers/#", MATCH_GROUP_MEMBERS_BY_GROUP); + + mUrlMatcher.addURI(authority, "avatars", MATCH_AVATARS); + mUrlMatcher.addURI(authority, "avatars/#", MATCH_AVATAR); + mUrlMatcher.addURI(authority, "avatarsBy/#/#", MATCH_AVATAR_BY_PROVIDER); + mUrlMatcher.addURI(authority, "chats", MATCH_CHATS); + mUrlMatcher.addURI(authority, "chats/account/#", MATCH_CHATS_BY_ACCOUNT); + mUrlMatcher.addURI(authority, "chats/#", MATCH_CHATS_ID); + + mUrlMatcher.addURI(authority, "sessionCookies", MATCH_SESSIONS); + mUrlMatcher.addURI(authority, "sessionCookiesBy/#/#", MATCH_SESSIONS_BY_PROVIDER); + mUrlMatcher.addURI(authority, "providerSettings", MATCH_PROVIDER_SETTINGS); + mUrlMatcher.addURI(authority, "providerSettings/#", MATCH_PROVIDER_SETTINGS_BY_ID); + mUrlMatcher.addURI(authority, "providerSettings/#/*", + MATCH_PROVIDER_SETTINGS_BY_ID_AND_NAME); + + mUrlMatcher.addURI(authority, "invitations", MATCH_INVITATIONS); + mUrlMatcher.addURI(authority, "invitations/#", MATCH_INVITATION); + + mUrlMatcher.addURI(authority, "outgoingRmqMessages", MATCH_OUTGOING_RMQ_MESSAGES); + mUrlMatcher.addURI(authority, "outgoingRmqMessages/#", MATCH_OUTGOING_RMQ_MESSAGE); + mUrlMatcher.addURI(authority, "outgoingHighestRmqId", MATCH_OUTGOING_HIGHEST_RMQ_ID); + mUrlMatcher.addURI(authority, "lastRmqId", MATCH_LAST_RMQ_ID); + } + + @Override + public boolean onCreate() { + mOpenHelper = new DatabaseHelper(getContext()); + return true; + } + + @Override + public final int update(final Uri url, final ContentValues values, + final String selection, final String[] selectionArgs) { + + int result; + SQLiteDatabase db = mOpenHelper.getWritableDatabase(); + db.beginTransaction(); + try { + result = updateInternal(url, values, selection, selectionArgs); + db.setTransactionSuccessful(); + } finally { + db.endTransaction(); + } + if (result > 0) { + getContext().getContentResolver() + .notifyChange(url, null /* observer */, false /* sync */); + } + return result; + } + + @Override + public final int delete(final Uri url, final String selection, + final String[] selectionArgs) { + int result; + SQLiteDatabase db = mOpenHelper.getWritableDatabase(); + db.beginTransaction(); + try { + result = deleteInternal(url, selection, selectionArgs); + db.setTransactionSuccessful(); + } finally { + db.endTransaction(); + } + if (result > 0) { + getContext().getContentResolver() + .notifyChange(url, null /* observer */, false /* sync */); + } + return result; + } + + @Override + public final Uri insert(final Uri url, final ContentValues values) { + Uri result; + SQLiteDatabase db = mOpenHelper.getWritableDatabase(); + db.beginTransaction(); + try { + result = insertInternal(url, values); + db.setTransactionSuccessful(); + } finally { + db.endTransaction(); + } + if (result != null) { + getContext().getContentResolver() + .notifyChange(url, null /* observer */, false /* sync */); + } + return result; + } + + @Override + public final Cursor query(final Uri url, final String[] projection, + final String selection, final String[] selectionArgs, + final String sortOrder) { + return queryInternal(url, projection, selection, selectionArgs, sortOrder); + } + + public Cursor queryInternal(Uri url, String[] projectionIn, + String selection, String[] selectionArgs, String sort) { + SQLiteQueryBuilder qb = new SQLiteQueryBuilder(); + StringBuilder whereClause = new StringBuilder(); + if(selection != null) { + whereClause.append(selection); + } + String groupBy = null; + String limit = null; + + // Generate the body of the query + int match = mUrlMatcher.match(url); + + if (DBG) { + log("query " + url + ", match " + match + ", where " + selection); + if (selectionArgs != null) { + for (String selectionArg : selectionArgs) { + log(" selectionArg: " + selectionArg); + } + } + } + + switch (match) { + case MATCH_PROVIDERS_BY_ID: + appendWhere(whereClause, Im.Provider._ID, "=", url.getPathSegments().get(1)); + // fall thru. + + case MATCH_PROVIDERS: + qb.setTables(TABLE_PROVIDERS); + break; + + case MATCH_PROVIDERS_WITH_ACCOUNT: + qb.setTables(PROVIDER_JOIN_ACCOUNT_TABLE); + qb.setProjectionMap(sProviderAccountsProjectionMap); + break; + + case MATCH_ACCOUNTS_BY_ID: + appendWhere(whereClause, Im.Account._ID, "=", url.getPathSegments().get(1)); + // falls down + case MATCH_ACCOUNTS: + qb.setTables(TABLE_ACCOUNTS); + break; + + case MATCH_CONTACTS: + qb.setTables(CONTACT_JOIN_PRESENCE_CHAT_AVATAR_TABLE); + qb.setProjectionMap(sContactsProjectionMap); + break; + + case MATCH_CONTACTS_JOIN_PRESENCE: + qb.setTables(CONTACT_JOIN_PRESENCE_TABLE); + qb.setProjectionMap(sContactsProjectionMap); + break; + + case MATCH_CONTACTS_BAREBONE: + qb.setTables(TABLE_CONTACTS); + break; + + case MATCH_CHATTING_CONTACTS: + qb.setTables(CONTACT_JOIN_PRESENCE_CHAT_AVATAR_TABLE); + qb.setProjectionMap(sContactsProjectionMap); + appendWhere(whereClause, "chats.last_message_date IS NOT NULL"); + // no need to add the non blocked contacts clause because + // blocked contacts can't have conversations. + break; + + case MATCH_CONTACTS_BY_PROVIDER: + buildQueryContactsByProvider(qb, whereClause, url); + appendWhere(whereClause, NON_BLOCKED_CONTACTS_WHERE_CLAUSE); + break; + + case MATCH_CHATTING_CONTACTS_BY_PROVIDER: + buildQueryContactsByProvider(qb, whereClause, url); + appendWhere(whereClause, "chats.last_message_date IS NOT NULL"); + // no need to add the non blocked contacts clause because + // blocked contacts can't have conversations. + break; + + case MATCH_NO_CHATTING_CONTACTS_BY_PROVIDER: + buildQueryContactsByProvider(qb, whereClause, url); + appendWhere(whereClause, "chats.last_message_date IS NULL"); + appendWhere(whereClause, NON_BLOCKED_CONTACTS_WHERE_CLAUSE); + break; + + case MATCH_ONLINE_CONTACTS_BY_PROVIDER: + buildQueryContactsByProvider(qb, whereClause, url); + appendWhere(whereClause, Im.Contacts.PRESENCE_STATUS, "!=", Im.Presence.OFFLINE); + appendWhere(whereClause, NON_BLOCKED_CONTACTS_WHERE_CLAUSE); + break; + + case MATCH_OFFLINE_CONTACTS_BY_PROVIDER: + buildQueryContactsByProvider(qb, whereClause, url); + appendWhere(whereClause, Im.Contacts.PRESENCE_STATUS, "=", Im.Presence.OFFLINE); + appendWhere(whereClause, NON_BLOCKED_CONTACTS_WHERE_CLAUSE); + break; + + case MATCH_BLOCKED_CONTACTS: + qb.setTables(CONTACT_JOIN_PRESENCE_CHAT_AVATAR_TABLE); + qb.setProjectionMap(sContactsProjectionMap); + appendWhere(whereClause, BLOCKED_CONTACTS_WHERE_CLAUSE); + break; + + case MATCH_CONTACT: + qb.setTables(CONTACT_JOIN_PRESENCE_CHAT_AVATAR_TABLE); + qb.setProjectionMap(sContactsProjectionMap); + appendWhere(whereClause, "contacts._id", "=", url.getPathSegments().get(1)); + break; + + case MATCH_ONLINE_CONTACT_COUNT: + qb.setTables(CONTACT_JOIN_PRESENCE_CHAT_TABLE); + qb.setProjectionMap(sContactsProjectionMap); + appendWhere(whereClause, Im.Contacts.PRESENCE_STATUS, "!=", Im.Presence.OFFLINE); + appendWhere(whereClause, "chats.last_message_date IS NULL"); + appendWhere(whereClause, NON_BLOCKED_CONTACTS_WHERE_CLAUSE); + groupBy = Im.Contacts.CONTACTLIST; + break; + + case MATCH_CONTACTLISTS_BY_PROVIDER: + appendWhere(whereClause, Im.ContactList.ACCOUNT, "=", + url.getPathSegments().get(2)); + // fall through + case MATCH_CONTACTLISTS: + qb.setTables(TABLE_CONTACT_LIST); + qb.setProjectionMap(sContactListProjectionMap); + break; + + case MATCH_CONTACTLIST: + qb.setTables(TABLE_CONTACT_LIST); + appendWhere(whereClause, Im.ContactList._ID, "=", url.getPathSegments().get(1)); + break; + + case MATCH_BLOCKEDLIST: + qb.setTables(BLOCKEDLIST_JOIN_AVATAR_TABLE); + qb.setProjectionMap(sBlockedListProjectionMap); + break; + + case MATCH_BLOCKEDLIST_BY_PROVIDER: + qb.setTables(BLOCKEDLIST_JOIN_AVATAR_TABLE); + qb.setProjectionMap(sBlockedListProjectionMap); + appendWhere(whereClause, Im.BlockedList.ACCOUNT, "=", + url.getPathSegments().get(2)); + break; + + case MATCH_CONTACTS_ETAGS: + qb.setTables(TABLE_CONTACTS_ETAG); + break; + + case MATCH_CONTACTS_ETAG: + qb.setTables(TABLE_CONTACTS_ETAG); + appendWhere(whereClause, "_id", "=", url.getPathSegments().get(1)); + break; + + case MATCH_MESSAGES: + qb.setTables(TABLE_MESSAGES); + break; + + case MATCH_MESSAGES_BY_CONTACT: + // we don't really need the provider id in query. account id + // is enough. + qb.setTables(TABLE_MESSAGES); + appendWhere(whereClause, Im.Messages.ACCOUNT, "=", + url.getPathSegments().get(2)); + appendWhere(whereClause, Im.Messages.CONTACT, "=", + decodeURLSegment(url.getPathSegments().get(3))); + break; + + case MATCH_MESSAGE: + qb.setTables(TABLE_MESSAGES); + appendWhere(whereClause, Im.Messages._ID, "=", url.getPathSegments().get(1)); + break; + + case MATCH_INVITATIONS: + qb.setTables(TABLE_INVITATIONS); + break; + + case MATCH_INVITATION: + qb.setTables(TABLE_INVITATIONS); + appendWhere(whereClause, Im.Invitation._ID, "=", url.getPathSegments().get(1)); + break; + + case MATCH_GROUP_MEMBERS: + qb.setTables(TABLE_GROUP_MEMBERS); + break; + + case MATCH_GROUP_MEMBERS_BY_GROUP: + qb.setTables(TABLE_GROUP_MEMBERS); + appendWhere(whereClause, Im.GroupMembers.GROUP, "=", url.getPathSegments().get(1)); + break; + + case MATCH_GROUP_MESSAGES: + qb.setTables(TABLE_GROUP_MESSAGES); + break; + + case MATCH_GROUP_MESSAGE_BY: + qb.setTables(TABLE_GROUP_MESSAGES); + appendWhere(whereClause, Im.GroupMessages.GROUP, "=", + url.getPathSegments().get(1)); + break; + + case MATCH_GROUP_MESSAGE: + qb.setTables(TABLE_GROUP_MESSAGES); + appendWhere(whereClause, Im.GroupMessages._ID, "=", + url.getPathSegments().get(1)); + break; + + case MATCH_AVATARS: + qb.setTables(TABLE_AVATARS); + break; + + case MATCH_AVATAR_BY_PROVIDER: + qb.setTables(TABLE_AVATARS); + appendWhere(whereClause, Im.Avatars.ACCOUNT, "=", url.getPathSegments().get(2)); + break; + + case MATCH_CHATS: + qb.setTables(TABLE_CHATS); + break; + + case MATCH_CHATS_ID: + qb.setTables(TABLE_CHATS); + appendWhere(whereClause, Im.Chats.CONTACT_ID, "=", url.getPathSegments().get(1)); + break; + + case MATCH_PRESENCE: + qb.setTables(TABLE_PRESENCE); + break; + + case MATCH_PRESENCE_ID: + qb.setTables(TABLE_PRESENCE); + appendWhere(whereClause, Im.Presence.CONTACT_ID, "=", url.getPathSegments().get(1)); + break; + + case MATCH_SESSIONS: + qb.setTables(TABLE_SESSION_COOKIES); + break; + + case MATCH_SESSIONS_BY_PROVIDER: + qb.setTables(TABLE_SESSION_COOKIES); + appendWhere(whereClause, Im.SessionCookies.ACCOUNT, "=", url.getPathSegments().get(2)); + break; + + case MATCH_PROVIDER_SETTINGS_BY_ID_AND_NAME: + appendWhere(whereClause, Im.ProviderSettings.NAME, "=", url.getPathSegments().get(2)); + // fall through + case MATCH_PROVIDER_SETTINGS_BY_ID: + appendWhere(whereClause, Im.ProviderSettings.PROVIDER, "=", url.getPathSegments().get(1)); + // fall through + case MATCH_PROVIDER_SETTINGS: + qb.setTables(TABLE_PROVIDER_SETTINGS); + break; + + case MATCH_OUTGOING_RMQ_MESSAGES: + qb.setTables(TABLE_OUTGOING_RMQ_MESSAGES); + break; + + case MATCH_OUTGOING_HIGHEST_RMQ_ID: + qb.setTables(TABLE_OUTGOING_RMQ_MESSAGES); + sort = "rmq_id DESC"; + limit = "1"; + break; + + case MATCH_LAST_RMQ_ID: + qb.setTables(TABLE_LAST_RMQ_ID); + limit = "1"; + break; + + default: + throw new IllegalArgumentException("Unknown URL " + url); + } + + // run the query + final SQLiteDatabase db = mOpenHelper.getReadableDatabase(); + Cursor c = null; + + try { + c = qb.query(db, projectionIn, whereClause.toString(), selectionArgs, + groupBy, null, sort, limit); + if (c != null) { + switch(match) { + case MATCH_CHATTING_CONTACTS: + case MATCH_CONTACTS_BY_PROVIDER: + case MATCH_CHATTING_CONTACTS_BY_PROVIDER: + case MATCH_ONLINE_CONTACTS_BY_PROVIDER: + case MATCH_OFFLINE_CONTACTS_BY_PROVIDER: + case MATCH_CONTACTS_BAREBONE: + case MATCH_CONTACTS_JOIN_PRESENCE: + case MATCH_ONLINE_CONTACT_COUNT: + url = Im.Contacts.CONTENT_URI; + break; + } + if (DBG) log("set notify url " + url); + c.setNotificationUri(getContext().getContentResolver(), url); + } + } catch (Exception ex) { + Log.e(LOG_TAG, "query db caught ", ex); + } + + return c; + } + + private void buildQueryContactsByProvider(SQLiteQueryBuilder qb, + StringBuilder whereClause, Uri url) { + qb.setTables(CONTACT_JOIN_PRESENCE_CHAT_AVATAR_TABLE); + qb.setProjectionMap(sContactsProjectionMap); + // we don't really need the provider id in query. account id + // is enough. + appendWhere(whereClause, Im.Contacts.ACCOUNT, "=", url.getLastPathSegment()); + } + + @Override + public String getType(Uri url) { + int match = mUrlMatcher.match(url); + switch (match) { + case MATCH_PROVIDERS: + return Im.Provider.CONTENT_TYPE; + + case MATCH_ACCOUNTS: + return Im.Account.CONTENT_TYPE; + + case MATCH_ACCOUNTS_BY_ID: + return Im.Account.CONTENT_ITEM_TYPE; + + case MATCH_CONTACTS: + case MATCH_CONTACTS_BY_PROVIDER: + case MATCH_ONLINE_CONTACTS_BY_PROVIDER: + case MATCH_OFFLINE_CONTACTS_BY_PROVIDER: + case MATCH_CONTACTS_BULK: + case MATCH_CONTACTS_BAREBONE: + case MATCH_CONTACTS_JOIN_PRESENCE: + return Im.Contacts.CONTENT_TYPE; + + case MATCH_CONTACT: + return Im.Contacts.CONTENT_ITEM_TYPE; + + case MATCH_CONTACTLISTS: + case MATCH_CONTACTLISTS_BY_PROVIDER: + return Im.ContactList.CONTENT_TYPE; + + case MATCH_CONTACTLIST: + return Im.ContactList.CONTENT_ITEM_TYPE; + + case MATCH_BLOCKEDLIST: + case MATCH_BLOCKEDLIST_BY_PROVIDER: + return Im.BlockedList.CONTENT_TYPE; + + case MATCH_CONTACTS_ETAGS: + case MATCH_CONTACTS_ETAG: + return Im.ContactsEtag.CONTENT_TYPE; + + case MATCH_MESSAGES: + case MATCH_MESSAGES_BY_CONTACT: + return Im.Messages.CONTENT_TYPE; + + case MATCH_MESSAGE: + return Im.Messages.CONTENT_ITEM_TYPE; + + case MATCH_GROUP_MESSAGES: + case MATCH_GROUP_MESSAGE_BY: + return Im.GroupMessages.CONTENT_TYPE; + + case MATCH_GROUP_MESSAGE: + return Im.GroupMessages.CONTENT_ITEM_TYPE; + + case MATCH_PRESENCE: + case MATCH_PRESENCE_BULK: + return Im.Presence.CONTENT_TYPE; + + case MATCH_AVATARS: + return Im.Avatars.CONTENT_TYPE; + + case MATCH_AVATAR: + return Im.Avatars.CONTENT_ITEM_TYPE; + + case MATCH_CHATS: + return Im.Chats.CONTENT_TYPE; + + case MATCH_CHATS_ID: + return Im.Chats.CONTENT_ITEM_TYPE; + + case MATCH_INVITATIONS: + return Im.Invitation.CONTENT_TYPE; + + case MATCH_INVITATION: + return Im.Invitation.CONTENT_ITEM_TYPE; + + case MATCH_GROUP_MEMBERS: + case MATCH_GROUP_MEMBERS_BY_GROUP: + return Im.GroupMembers.CONTENT_TYPE; + + case MATCH_SESSIONS: + case MATCH_SESSIONS_BY_PROVIDER: + return Im.SessionCookies.CONTENT_TYPE; + + case MATCH_PROVIDER_SETTINGS: + return Im.ProviderSettings.CONTENT_TYPE; + + default: + throw new IllegalArgumentException("Unknown URL"); + } + } + + // package scope for testing. + boolean insertBulkContacts(ContentValues values) { + ArrayList<String> usernames = values.getStringArrayList(Im.Contacts.USERNAME); + ArrayList<String> nicknames = values.getStringArrayList(Im.Contacts.NICKNAME); + int usernameCount = usernames.size(); + int nicknameCount = nicknames.size(); + + if (usernameCount != nicknameCount) { + Log.e(LOG_TAG, "[ImProvider] insertBulkContacts: input bundle " + + "username & nickname lists have diff. length!"); + return false; + } + + ArrayList<String> contactTypeArray = values.getStringArrayList(Im.Contacts.TYPE); + ArrayList<String> subscriptionStatusArray = + values.getStringArrayList(Im.Contacts.SUBSCRIPTION_STATUS); + ArrayList<String> subscriptionTypeArray = + values.getStringArrayList(Im.Contacts.SUBSCRIPTION_TYPE); + ArrayList<String> quickContactArray = values.getStringArrayList(Im.Contacts.QUICK_CONTACT); + ArrayList<String> rejectedArray = values.getStringArrayList(Im.Contacts.REJECTED); + + final SQLiteDatabase db = mOpenHelper.getWritableDatabase(); + + db.beginTransaction(); + try { + Long provider = values.getAsLong(Im.Contacts.PROVIDER); + Long account = values.getAsLong(Im.Contacts.ACCOUNT); + Long listId = values.getAsLong(Im.Contacts.CONTACTLIST); + + ContentValues contactValues = new ContentValues(); + contactValues.put(Im.Contacts.PROVIDER, provider); + contactValues.put(Im.Contacts.ACCOUNT, account); + contactValues.put(Im.Contacts.CONTACTLIST, listId); + ContentValues presenceValues = new ContentValues(); + presenceValues.put(Im.Presence.PRESENCE_STATUS, + Im.Presence.OFFLINE); + + for (int i=0; i<usernameCount; i++) { + String username = usernames.get(i); + String nickname = nicknames.get(i); + int type = 0; + int subscriptionStatus = 0; + int subscriptionType = 0; + int quickContact = 0; + int rejected = 0; + + try { + type = Integer.parseInt(contactTypeArray.get(i)); + if (subscriptionStatusArray != null) { + subscriptionStatus = Integer.parseInt(subscriptionStatusArray.get(i)); + } + if (subscriptionTypeArray != null) { + subscriptionType = Integer.parseInt(subscriptionTypeArray.get(i)); + } + if (quickContactArray != null) { + quickContact = Integer.parseInt(quickContactArray.get(i)); + } + if (rejectedArray != null) { + rejected = Integer.parseInt(rejectedArray.get(i)); + } + } catch (NumberFormatException ex) { + Log.e(LOG_TAG, "insertBulkContacts: caught " + ex); + } + + if (DBG) log("insertBulkContacts[" + i + "] username=" + + username + ", nickname=" + nickname + ", type=" + type + + ", subscriptionStatus=" + subscriptionStatus + ", subscriptionType=" + + subscriptionType + ", qc=" + quickContact); + + contactValues.put(Im.Contacts.USERNAME, username); + contactValues.put(Im.Contacts.NICKNAME, nickname); + contactValues.put(Im.Contacts.TYPE, type); + if (subscriptionStatusArray != null) { + contactValues.put(Im.Contacts.SUBSCRIPTION_STATUS, subscriptionStatus); + } + if (subscriptionTypeArray != null) { + contactValues.put(Im.Contacts.SUBSCRIPTION_TYPE, subscriptionType); + } + if (quickContactArray != null) { + contactValues.put(Im.Contacts.QUICK_CONTACT, quickContact); + } + if (rejectedArray != null) { + contactValues.put(Im.Contacts.REJECTED, rejected); + } + + long rowId = db.insert(TABLE_CONTACTS, USERNAME, contactValues); + + if (!USE_CONTACT_PRESENCE_TRIGGER) { + // seed the presence for the new contact + //if (DBG) log("seedPresence for pid " + rowId); + presenceValues.put(Im.Presence.CONTACT_ID, rowId); + db.insert(TABLE_PRESENCE, null, presenceValues); + } + + // yield the lock if anyone else is trying to + // perform a db operation here. + db.yieldIfContended(); + } + + db.setTransactionSuccessful(); + } finally { + db.endTransaction(); + } + + // We know that we succeeded becuase endTransaction throws if the transaction failed. + if (DBG) log("insertBulkContacts: success = " + true); + return true; + } + + // package scope for testing. + int updateBulkContacts(ContentValues values, String userWhere) { + ArrayList<String> usernames = values.getStringArrayList(Im.Contacts.USERNAME); + ArrayList<String> nicknames = values.getStringArrayList(Im.Contacts.NICKNAME); + + int usernameCount = usernames.size(); + int nicknameCount = nicknames.size(); + + if (usernameCount != nicknameCount) { + Log.e(LOG_TAG, "[ImProvider] updateBulkContacts: input bundle " + + "username & nickname lists have diff. length!"); + return 0; + } + + ArrayList<String> contactTypeArray = values.getStringArrayList(Im.Contacts.TYPE); + ArrayList<String> subscriptionStatusArray = + values.getStringArrayList(Im.Contacts.SUBSCRIPTION_STATUS); + ArrayList<String> subscriptionTypeArray = + values.getStringArrayList(Im.Contacts.SUBSCRIPTION_TYPE); + ArrayList<String> quickContactArray = values.getStringArrayList(Im.Contacts.QUICK_CONTACT); + ArrayList<String> rejectedArray = values.getStringArrayList(Im.Contacts.REJECTED); + final SQLiteDatabase db = mOpenHelper.getWritableDatabase(); + + db.beginTransaction(); + int sum = 0; + + try { + Long provider = values.getAsLong(Im.Contacts.PROVIDER); + Long account = values.getAsLong(Im.Contacts.ACCOUNT); + + ContentValues contactValues = new ContentValues(); + contactValues.put(Im.Contacts.PROVIDER, provider); + contactValues.put(Im.Contacts.ACCOUNT, account); + + for (int i=0; i<usernameCount; i++) { + String username = usernames.get(i); + String nickname = nicknames.get(i); + int type = 0; + int subscriptionStatus = 0; + int subscriptionType = 0; + int quickContact = 0; + int rejected = 0; + + try { + type = Integer.parseInt(contactTypeArray.get(i)); + subscriptionStatus = Integer.parseInt(subscriptionStatusArray.get(i)); + subscriptionType = Integer.parseInt(subscriptionTypeArray.get(i)); + quickContact = Integer.parseInt(quickContactArray.get(i)); + rejected = Integer.parseInt(rejectedArray.get(i)); + } catch (NumberFormatException ex) { + Log.e(LOG_TAG, "insertBulkContacts: caught " + ex); + } + + if (DBG) log("updateBulkContacts[" + i + "] username=" + + username + ", nickname=" + nickname + ", type=" + type + + ", subscriptionStatus=" + subscriptionStatus + ", subscriptionType=" + + subscriptionType + ", qc=" + quickContact); + + contactValues.put(Im.Contacts.USERNAME, username); + contactValues.put(Im.Contacts.NICKNAME, nickname); + contactValues.put(Im.Contacts.TYPE, type); + contactValues.put(Im.Contacts.SUBSCRIPTION_STATUS, subscriptionStatus); + contactValues.put(Im.Contacts.SUBSCRIPTION_TYPE, subscriptionType); + contactValues.put(Im.Contacts.QUICK_CONTACT, quickContact); + contactValues.put(Im.Contacts.REJECTED, rejected); + + // append username to the selection clause + StringBuilder selection = new StringBuilder(userWhere); + selection.append(" AND "); + selection.append(Im.Contacts.USERNAME); + selection.append("=?"); + + int numUpdated = db.update(TABLE_CONTACTS, contactValues, + selection.toString(), new String[] {username}); + if (numUpdated == 0) { + Log.e(LOG_TAG, "[ImProvider] updateBulkContacts: " + + " update failed for selection = " + selection); + } else { + sum += numUpdated; + } + + // yield the lock if anyone else is trying to + // perform a db operation here. + db.yieldIfContended(); + } + + db.setTransactionSuccessful(); + } finally { + db.endTransaction(); + } + + if (DBG) log("updateBulkContacts: " + sum + " entries updated"); + return sum; + } + + // constants definitions use for the query in seedInitialPresenceByAccount() + private static final String[] CONTACT_ID_PROJECTION = new String[] { + Im.Contacts._ID, // 0 + }; + + private static final int COLUMN_ID = 0; + + private static final String CONTACTS_WITH_NO_PRESENCE_SELECTION = + Im.Contacts.ACCOUNT + "=?" + " AND " + Im.Contacts._ID + + " in (select " + CONTACT_ID + " from " + TABLE_CONTACTS + + " left outer join " + TABLE_PRESENCE + " on " + CONTACT_ID + '=' + + PRESENCE_CONTACT_ID + " where " + PRESENCE_CONTACT_ID + " IS NULL)"; + + // selection args for the query. + private String[] mQueryContactPresenceSelectionArgs = new String[1]; + + /** + * This method first performs a query for all the contacts (for the given account) that + * don't have a presence entry in the presence table. Then for each of those contacts, + * the method creates a presence row. The whole thing is done inside one database transaction + * to increase performance. + * + * @param account the account of the contacts for which we want to create seed presence rows. + */ + private void seedInitialPresenceByAccount(long account) { + SQLiteQueryBuilder qb = new SQLiteQueryBuilder(); + qb.setTables(TABLE_CONTACTS); + qb.setProjectionMap(sContactsProjectionMap); + + mQueryContactPresenceSelectionArgs[0] = String.valueOf(account); + + if (DBG) { + log("seedInitialPresence: contacts_with_no_presence_selection => " + + CONTACTS_WITH_NO_PRESENCE_SELECTION); + } + + final SQLiteDatabase db = mOpenHelper.getWritableDatabase(); + db.beginTransaction(); + + Cursor c = null; + + try { + ContentValues presenceValues = new ContentValues(); + presenceValues.put(Im.Presence.PRESENCE_STATUS, Im.Presence.OFFLINE); + presenceValues.put(Im.Presence.PRESENCE_CUSTOM_STATUS, ""); + + // First: update all the presence so they are offline + // + // TODO: this doesn't take into the accountId. It's ok for GTalk account for now + // as we only support one account. However, for multiple account this will be a problem. + int count = db.update(TABLE_PRESENCE, presenceValues, null, null); + if (DBG) log("seedInitialPresence: reset " + count + " presence rows to OFFLINE"); + + // second: add a presence row for each contact that doesn't have a presence + c = qb.query(db, + CONTACT_ID_PROJECTION, + CONTACTS_WITH_NO_PRESENCE_SELECTION, + mQueryContactPresenceSelectionArgs, + null, null, null, null); + + if (DBG) log("seedInitialPresence: found " + c.getCount() + " contacts w/o presence"); + + count = 0; + + while (c.moveToNext()) { + long id = c.getLong(COLUMN_ID); + presenceValues.put(Im.Presence.CONTACT_ID, id); + + try { + if (db.insert(TABLE_PRESENCE, null, presenceValues) > 0) { + count++; + } + } catch (SQLiteConstraintException ex) { + // we could possibly catch this exception, since there could be a presence + // row with the same contact_id. That's fine, just ignore the error + if (DBG) log("seedInitialPresence: insert presence for contact_id " + id + + " failed, caught " + ex); + } + } + + db.setTransactionSuccessful(); + + if (DBG) log("seedInitialPresence: added " + count + " new presence rows"); + } finally { + c.close(); + db.endTransaction(); + } + } + + private int updateBulkPresence(ContentValues values, String userWhere, String[] whereArgs) { + ArrayList<String> usernames = values.getStringArrayList(Im.Contacts.USERNAME); + int count = usernames.size(); + Long account = values.getAsLong(Im.Contacts.ACCOUNT); + + ArrayList<String> priorityArray = values.getStringArrayList(Im.Presence.PRIORITY); + ArrayList<String> modeArray = values.getStringArrayList(Im.Presence.PRESENCE_STATUS); + ArrayList<String> statusArray = values.getStringArrayList( + Im.Presence.PRESENCE_CUSTOM_STATUS); + ArrayList<String> clientTypeArray = values.getStringArrayList(Im.Presence.CLIENT_TYPE); + ArrayList<String> resourceArray = values.getStringArrayList(Im.Presence.JID_RESOURCE); + + // append username to the selection clause + StringBuilder buf = new StringBuilder(); + + if (!TextUtils.isEmpty(userWhere)) { + buf.append(userWhere); + buf.append(" AND "); + } + + buf.append(Im.Presence.CONTACT_ID); + buf.append(" in (select "); + buf.append(Im.Contacts._ID); + buf.append(" from "); + buf.append(TABLE_CONTACTS); + buf.append(" where "); + buf.append(Im.Contacts.ACCOUNT); + buf.append("=? AND "); + + // use username LIKE ? for case insensitive comparison + buf.append(Im.Contacts.USERNAME); + buf.append(" LIKE ?) AND ("); + + buf.append(Im.Presence.PRIORITY); + buf.append("<=? OR "); + buf.append(Im.Presence.PRIORITY); + buf.append(" IS NULL OR "); + buf.append(Im.Presence.JID_RESOURCE); + buf.append("=?)"); + + String selection = buf.toString(); + + if (DBG) log("updateBulkPresence: selection => " + selection); + + int numArgs = (whereArgs != null ? whereArgs.length + 4 : 4); + String[] selectionArgs = new String[numArgs]; + int selArgsIndex = 0; + + if (whereArgs != null) { + for (selArgsIndex=0; selArgsIndex<numArgs-1; selArgsIndex++) { + selectionArgs[selArgsIndex] = whereArgs[selArgsIndex]; + } + } + + final SQLiteDatabase db = mOpenHelper.getWritableDatabase(); + + db.beginTransaction(); + int sum = 0; + + try { + ContentValues presenceValues = new ContentValues(); + + for (int i=0; i<count; i++) { + String username = usernames.get(i); + int priority = 0; + int mode = 0; + String status = statusArray.get(i); + String jidResource = resourceArray == null ? "" : resourceArray.get(i); + int clientType = Im.Presence.CLIENT_TYPE_DEFAULT; + + try { + if (priorityArray != null) { + priority = Integer.parseInt(priorityArray.get(i)); + } + if (modeArray != null) { + mode = Integer.parseInt(modeArray.get(i)); + } + if (clientTypeArray != null) { + clientType = Integer.parseInt(clientTypeArray.get(i)); + } + } catch (NumberFormatException ex) { + Log.e(LOG_TAG, "[ImProvider] updateBulkPresence: caught " + ex); + } + + if (DBG) { + log("updateBulkPresence[" + i + "] username=" + username + ", priority=" + + priority + ", mode=" + mode + ", status=" + status + ", resource=" + + jidResource + ", clientType=" + clientType); + } + + if (modeArray != null) { + presenceValues.put(Im.Presence.PRESENCE_STATUS, mode); + } + if (priorityArray != null) { + presenceValues.put(Im.Presence.PRIORITY, priority); + } + presenceValues.put(Im.Presence.PRESENCE_CUSTOM_STATUS, status); + if (clientTypeArray != null) { + presenceValues.put(Im.Presence.CLIENT_TYPE, clientType); + } + + if (!TextUtils.isEmpty(jidResource)) { + presenceValues.put(Im.Presence.JID_RESOURCE, jidResource); + } + + // fill in the selection args + int idx = selArgsIndex; + selectionArgs[idx++] = String.valueOf(account); + selectionArgs[idx++] = username; + selectionArgs[idx++] = String.valueOf(priority); + selectionArgs[idx] = jidResource; + + int numUpdated = db.update(TABLE_PRESENCE, + presenceValues, selection, selectionArgs); + if (numUpdated == 0) { + Log.e(LOG_TAG, "[ImProvider] updateBulkPresence: failed for " + username); + } else { + sum += numUpdated; + } + + // yield the lock if anyone else is trying to + // perform a db operation here. + db.yieldIfContended(); + } + + db.setTransactionSuccessful(); + } finally { + db.endTransaction(); + } + + if (DBG) log("updateBulkPresence: " + sum + " entries updated"); + return sum; + } + + public Uri insertInternal(Uri url, ContentValues initialValues) { + Uri resultUri = null; + long rowID = 0; + boolean notifyContactListContentUri = false; + boolean notifyContactContentUri = false; + boolean notifyMessagesContentUri = false; + boolean notifyGroupMessagesContentUri = false; + + final SQLiteDatabase db = mOpenHelper.getWritableDatabase(); + int match = mUrlMatcher.match(url); + + if (DBG) log("insert to " + url + ", match " + match); + switch (match) { + case MATCH_PROVIDERS: + // Insert into the providers table + rowID = db.insert(TABLE_PROVIDERS, "name", initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.Provider.CONTENT_URI + "/" + rowID); + } + break; + + case MATCH_ACCOUNTS: + // Insert into the accounts table + rowID = db.insert(TABLE_ACCOUNTS, "name", initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.Account.CONTENT_URI + "/" + rowID); + } + break; + + case MATCH_CONTACTS_BY_PROVIDER: + appendValuesFromUrl(initialValues, url, Im.Contacts.PROVIDER, + Im.Contacts.ACCOUNT); + // fall through + case MATCH_CONTACTS: + case MATCH_CONTACTS_BAREBONE: + // Insert into the contacts table + rowID = db.insert(TABLE_CONTACTS, "username", initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.Contacts.CONTENT_URI + "/" + rowID); + } + + notifyContactContentUri = true; + break; + + case MATCH_CONTACTS_BULK: + if (insertBulkContacts(initialValues)) { + // notify change using the "content://im/contacts" url, + // so the change will be observed by listeners interested + // in contacts changes. + resultUri = Im.Contacts.CONTENT_URI; + } + notifyContactContentUri = true; + break; + + case MATCH_CONTACTLISTS_BY_PROVIDER: + appendValuesFromUrl(initialValues, url, Im.ContactList.PROVIDER, + Im.ContactList.ACCOUNT); + // fall through + case MATCH_CONTACTLISTS: + // Insert into the contactList table + rowID = db.insert(TABLE_CONTACT_LIST, "name", initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.ContactList.CONTENT_URI + "/" + rowID); + } + notifyContactListContentUri = true; + break; + + case MATCH_BLOCKEDLIST_BY_PROVIDER: + appendValuesFromUrl(initialValues, url, Im.BlockedList.PROVIDER, + Im.BlockedList.ACCOUNT); + // fall through + case MATCH_BLOCKEDLIST: + // Insert into the blockedList table + rowID = db.insert(TABLE_BLOCKED_LIST, "username", initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.BlockedList.CONTENT_URI + "/" + rowID); + } + + break; + + case MATCH_CONTACTS_ETAGS: + rowID = db.replace(TABLE_CONTACTS_ETAG, Im.ContactsEtag.ETAG, initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.ContactsEtag.CONTENT_URI + "/" + rowID); + } + break; + + case MATCH_MESSAGES_BY_CONTACT: + appendValuesFromUrl(initialValues, url, Im.Messages.PROVIDER, + Im.Messages.ACCOUNT, Im.Messages.CONTACT); + notifyMessagesContentUri = true; + // fall through + case MATCH_MESSAGES: + // Insert into the messages table. + rowID = db.insert(TABLE_MESSAGES, "contact", initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.Messages.CONTENT_URI + "/" + rowID); + } + + break; + + case MATCH_INVITATIONS: + rowID = db.insert(TABLE_INVITATIONS, null, initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.Invitation.CONTENT_URI + "/" + rowID); + } + break; + + case MATCH_GROUP_MEMBERS: + rowID = db.insert(TABLE_GROUP_MEMBERS, "nickname", initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.GroupMembers.CONTENT_URI + "/" + rowID); + } + break; + + case MATCH_GROUP_MEMBERS_BY_GROUP: + appendValuesFromUrl(initialValues, url, Im.GroupMembers.GROUP); + rowID = db.insert(TABLE_GROUP_MEMBERS, "nickname", initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.GroupMembers.CONTENT_URI + "/" + rowID); + } + break; + + case MATCH_GROUP_MESSAGE_BY: + appendValuesFromUrl(initialValues, url, Im.GroupMembers.GROUP); + notifyGroupMessagesContentUri = true; + // fall through + case MATCH_GROUP_MESSAGES: + rowID = db.insert(TABLE_GROUP_MESSAGES, "group", initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.GroupMessages.CONTENT_URI + "/" + rowID); + } + break; + + case MATCH_AVATAR_BY_PROVIDER: + appendValuesFromUrl(initialValues, url, Im.Avatars.PROVIDER, Im.Avatars.ACCOUNT); + // fall through + case MATCH_AVATARS: + // Insert into the avatars table + rowID = db.replace(TABLE_AVATARS, "contact", initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.Avatars.CONTENT_URI + "/" + rowID); + } + break; + + case MATCH_CHATS_ID: + appendValuesFromUrl(initialValues, url, Im.Chats.CONTACT_ID); + // fall through + case MATCH_CHATS: + // Insert into the chats table + rowID = db.replace(TABLE_CHATS, Im.Chats.CONTACT_ID, initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.Chats.CONTENT_URI + "/" + rowID); + } + notifyContactContentUri = true; + break; + + case MATCH_PRESENCE: + rowID = db.replace(TABLE_PRESENCE, null, initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.Presence.CONTENT_URI + "/" + rowID); + } + notifyContactContentUri = true; + break; + + case MATCH_PRESENCE_SEED_BY_ACCOUNT: + try { + seedInitialPresenceByAccount(Long.parseLong(url.getLastPathSegment())); + resultUri = Im.Presence.CONTENT_URI; + } catch (NumberFormatException ex) { + throw new IllegalArgumentException(); + } + break; + + case MATCH_SESSIONS_BY_PROVIDER: + appendValuesFromUrl(initialValues, url, Im.SessionCookies.PROVIDER, + Im.SessionCookies.ACCOUNT); + // fall through + case MATCH_SESSIONS: + rowID = db.insert(TABLE_SESSION_COOKIES, null, initialValues); + if(rowID > 0) { + resultUri = Uri.parse(Im.SessionCookies.CONTENT_URI + "/" + rowID); + } + break; + + case MATCH_PROVIDER_SETTINGS: + rowID = db.replace(TABLE_PROVIDER_SETTINGS, null, initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.ProviderSettings.CONTENT_URI + "/" + rowID); + } + break; + + case MATCH_OUTGOING_RMQ_MESSAGES: + rowID = db.insert(TABLE_OUTGOING_RMQ_MESSAGES, null, initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.OutgoingRmq.CONTENT_URI + "/" + rowID); + } + break; + + case MATCH_LAST_RMQ_ID: + rowID = db.replace(TABLE_LAST_RMQ_ID, null, initialValues); + if (rowID > 0) { + resultUri = Uri.parse(Im.LastRmqId.CONTENT_URI + "/" + rowID); + } + break; + + default: + throw new UnsupportedOperationException("Cannot insert into URL: " + url); + } + // TODO: notify the data change observer? + + if (resultUri != null) { + // In most case, we query contacts with presence and chats joined, thus + // we should also notify that contacts changes when presence or chats changed. + if (notifyContactContentUri) { + getContext().getContentResolver().notifyChange(Im.Contacts.CONTENT_URI, null); + } + + if (notifyContactListContentUri) { + getContext().getContentResolver().notifyChange(Im.ContactList.CONTENT_URI, null); + } + + if (notifyMessagesContentUri) { + getContext().getContentResolver().notifyChange(Im.Messages.CONTENT_URI, null); + } + + if (notifyGroupMessagesContentUri) { + getContext().getContentResolver().notifyChange(Im.GroupMessages.CONTENT_URI, null); + } + } + return resultUri; + } + + private void appendValuesFromUrl(ContentValues values, Uri url, String...columns){ + if(url.getPathSegments().size() <= columns.length) { + throw new IllegalArgumentException("Not enough values in url"); + } + for(int i = 0; i < columns.length; i++){ + if(values.containsKey(columns[i])){ + throw new UnsupportedOperationException("Cannot override the value for " + columns[i]); + } + values.put(columns[i], decodeURLSegment(url.getPathSegments().get(i + 1))); + } + } + + /** + * manual trigger for deleting contacts + */ + private static final String DELETE_PRESENCE_SELECTION = + Im.Presence.CONTACT_ID + " in (select " + + PRESENCE_CONTACT_ID + " from " + TABLE_PRESENCE + " left outer join " + TABLE_CONTACTS + + " on " + PRESENCE_CONTACT_ID + '=' + CONTACT_ID + " where " + CONTACT_ID + " IS NULL)"; + + private static final String CHATS_CONTACT_ID = TABLE_CHATS + '.' + Im.Chats.CONTACT_ID; + private static final String DELETE_CHATS_SELECTION = Im.Chats.CONTACT_ID + " in (select "+ + CHATS_CONTACT_ID + " from " + TABLE_CHATS + " left outer join " + TABLE_CONTACTS + + " on " + CHATS_CONTACT_ID + '=' + CONTACT_ID + " where " + CONTACT_ID + " IS NULL)"; + + private static final String GROUP_MEMBER_ID = TABLE_GROUP_MEMBERS + '.' + Im.GroupMembers.GROUP; + private static final String DELETE_GROUP_MEMBER_SELECTION = + Im.GroupMembers.GROUP + " in (select "+ + GROUP_MEMBER_ID + " from " + TABLE_GROUP_MEMBERS + " left outer join " + TABLE_CONTACTS + + " on " + GROUP_MEMBER_ID + '=' + CONTACT_ID + " where " + CONTACT_ID + " IS NULL)"; + + private static final String GROUP_MESSAGES_ID = + TABLE_GROUP_MESSAGES + '.' + Im.GroupMessages.GROUP; + private static final String DELETE_GROUP_MESSAGES_SELECTION = + Im.GroupMessages.GROUP + " in (select "+ GROUP_MESSAGES_ID + " from " + + TABLE_GROUP_MESSAGES + " left outer join " + TABLE_CONTACTS + " on " + + GROUP_MESSAGES_ID + '=' + CONTACT_ID + " where " + CONTACT_ID + " IS NULL)"; + + private void performContactRemovalCleanup(long contactId) { + final SQLiteDatabase db = mOpenHelper.getWritableDatabase(); + + if (contactId > 0) { + deleteWithContactId(db, contactId, TABLE_PRESENCE, Im.Presence.CONTACT_ID); + deleteWithContactId(db, contactId, TABLE_CHATS, Im.Chats.CONTACT_ID); + deleteWithContactId(db, contactId, TABLE_GROUP_MEMBERS, Im.GroupMembers.GROUP); + deleteWithContactId(db, contactId, TABLE_GROUP_MESSAGES, Im.GroupMessages.GROUP); + } else { + performComplexDelete(db, TABLE_PRESENCE, DELETE_PRESENCE_SELECTION, null); + performComplexDelete(db, TABLE_CHATS, DELETE_CHATS_SELECTION, null); + performComplexDelete(db, TABLE_GROUP_MEMBERS, DELETE_GROUP_MEMBER_SELECTION, null); + performComplexDelete(db, TABLE_GROUP_MESSAGES, DELETE_GROUP_MESSAGES_SELECTION, null); + } + } + + private void deleteWithContactId(SQLiteDatabase db, long contactId, + String tableName, String columnName) { + db.delete(tableName, columnName + '=' + contactId, null /* selection args */); + } + + private void performComplexDelete(SQLiteDatabase db, String tableName, + String selection, String[] selectionArgs) { + if (DBG) log("performComplexDelete for table " + tableName + ", selection => " + selection); + int count = db.delete(tableName, selection, selectionArgs); + if (DBG) log("performComplexDelete: deleted " + count + " rows"); + } + + public int deleteInternal(Uri url, String userWhere, + String[] whereArgs) { + String tableToChange; + String idColumnName = null; + String changedItemId = null; + + StringBuilder whereClause = new StringBuilder(); + if(userWhere != null) { + whereClause.append(userWhere); + } + + boolean notifyMessagesContentUri = false; + boolean notifyGroupMessagesContentUri = false; + boolean notifyContactListContentUri = false; + int match = mUrlMatcher.match(url); + + boolean contactDeleted = false; + long deletedContactId = 0; + + switch (match) { + case MATCH_PROVIDERS: + tableToChange = TABLE_PROVIDERS; + break; + + case MATCH_ACCOUNTS_BY_ID: + changedItemId = url.getPathSegments().get(1); + // fall through + case MATCH_ACCOUNTS: + tableToChange = TABLE_ACCOUNTS; + break; + + case MATCH_CONTACTS: + case MATCH_CONTACTS_BAREBONE: + tableToChange = TABLE_CONTACTS; + contactDeleted = true; + break; + + case MATCH_CONTACT: + tableToChange = TABLE_CONTACTS; + changedItemId = url.getPathSegments().get(1); + + try { + deletedContactId = Long.parseLong(changedItemId); + } catch (NumberFormatException ex) { + } + + contactDeleted = true; + break; + + case MATCH_CONTACTS_BY_PROVIDER: + tableToChange = TABLE_CONTACTS; + appendWhere(whereClause, Im.Contacts.ACCOUNT, "=", url.getPathSegments().get(2)); + contactDeleted = true; + break; + + case MATCH_CONTACTLISTS_BY_PROVIDER: + appendWhere(whereClause, Im.ContactList.ACCOUNT, "=", + url.getPathSegments().get(2)); + // fall through + case MATCH_CONTACTLISTS: + tableToChange = TABLE_CONTACT_LIST; + notifyContactListContentUri = true; + break; + + case MATCH_CONTACTLIST: + tableToChange = TABLE_CONTACT_LIST; + changedItemId = url.getPathSegments().get(1); + break; + + case MATCH_BLOCKEDLIST: + tableToChange = TABLE_BLOCKED_LIST; + break; + + case MATCH_BLOCKEDLIST_BY_PROVIDER: + tableToChange = TABLE_BLOCKED_LIST; + appendWhere(whereClause, Im.BlockedList.ACCOUNT, "=", url.getPathSegments().get(2)); + break; + + case MATCH_CONTACTS_ETAGS: + tableToChange = TABLE_CONTACTS_ETAG; + break; + + case MATCH_CONTACTS_ETAG: + tableToChange = TABLE_CONTACTS_ETAG; + changedItemId = url.getPathSegments().get(1); + break; + + case MATCH_MESSAGES: + tableToChange = TABLE_MESSAGES; + break; + + case MATCH_MESSAGES_BY_CONTACT: + tableToChange = TABLE_MESSAGES; + appendWhere(whereClause, Im.Messages.ACCOUNT, "=", + url.getPathSegments().get(2)); + appendWhere(whereClause, Im.Messages.CONTACT, "=", + decodeURLSegment(url.getPathSegments().get(3))); + notifyMessagesContentUri = true; + break; + + case MATCH_MESSAGE: + tableToChange = TABLE_MESSAGES; + changedItemId = url.getPathSegments().get(1); + notifyMessagesContentUri = true; + break; + + case MATCH_GROUP_MEMBERS: + tableToChange = TABLE_GROUP_MEMBERS; + break; + + case MATCH_GROUP_MEMBERS_BY_GROUP: + tableToChange = TABLE_GROUP_MEMBERS; + appendWhere(whereClause, Im.GroupMembers.GROUP, "=", url.getPathSegments().get(1)); + break; + + case MATCH_GROUP_MESSAGES: + tableToChange = TABLE_GROUP_MESSAGES; + break; + + case MATCH_GROUP_MESSAGE_BY: + tableToChange = TABLE_GROUP_MESSAGES; + changedItemId = url.getPathSegments().get(1); + idColumnName = Im.GroupMessages.GROUP; + notifyGroupMessagesContentUri = true; + break; + + case MATCH_GROUP_MESSAGE: + tableToChange = TABLE_GROUP_MESSAGES; + changedItemId = url.getPathSegments().get(1); + notifyGroupMessagesContentUri = true; + break; + + case MATCH_INVITATIONS: + tableToChange = TABLE_INVITATIONS; + break; + + case MATCH_INVITATION: + tableToChange = TABLE_INVITATIONS; + changedItemId = url.getPathSegments().get(1); + break; + + case MATCH_AVATARS: + tableToChange = TABLE_AVATARS; + break; + + case MATCH_AVATAR: + tableToChange = TABLE_AVATARS; + changedItemId = url.getPathSegments().get(1); + break; + + case MATCH_AVATAR_BY_PROVIDER: + tableToChange = TABLE_AVATARS; + changedItemId = url.getPathSegments().get(2); + idColumnName = Im.Avatars.ACCOUNT; + break; + + case MATCH_CHATS: + tableToChange = TABLE_CHATS; + break; + + case MATCH_CHATS_BY_ACCOUNT: + tableToChange = TABLE_CHATS; + + if (whereClause.length() > 0) { + whereClause.append(" AND "); + } + whereClause.append(Im.Chats.CONTACT_ID); + whereClause.append(" in (select "); + whereClause.append(Im.Contacts._ID); + whereClause.append(" from "); + whereClause.append(TABLE_CONTACTS); + whereClause.append(" where "); + whereClause.append(Im.Contacts.ACCOUNT); + whereClause.append("='"); + whereClause.append(url.getLastPathSegment()); + whereClause.append("')"); + + if (DBG) log("deleteInternal (MATCH_CHATS_BY_ACCOUNT): sel => " + + whereClause.toString()); + + changedItemId = null; + break; + + case MATCH_CHATS_ID: + tableToChange = TABLE_CHATS; + changedItemId = url.getPathSegments().get(1); + idColumnName = Im.Chats.CONTACT_ID; + break; + + case MATCH_PRESENCE: + tableToChange = TABLE_PRESENCE; + break; + + case MATCH_PRESENCE_ID: + tableToChange = TABLE_PRESENCE; + changedItemId = url.getPathSegments().get(1); + idColumnName = Im.Presence.CONTACT_ID; + break; + + case MATCH_PRESENCE_BY_ACCOUNT: + tableToChange = TABLE_PRESENCE; + + if (whereClause.length() > 0) { + whereClause.append(" AND "); + } + whereClause.append(Im.Presence.CONTACT_ID); + whereClause.append(" in (select "); + whereClause.append(Im.Contacts._ID); + whereClause.append(" from "); + whereClause.append(TABLE_CONTACTS); + whereClause.append(" where "); + whereClause.append(Im.Contacts.ACCOUNT); + whereClause.append("='"); + whereClause.append(url.getLastPathSegment()); + whereClause.append("')"); + + if (DBG) log("deleteInternal (MATCH_PRESENCE_BY_ACCOUNT): sel => " + + whereClause.toString()); + + changedItemId = null; + break; + + case MATCH_SESSIONS: + tableToChange = TABLE_SESSION_COOKIES; + break; + + case MATCH_SESSIONS_BY_PROVIDER: + tableToChange = TABLE_SESSION_COOKIES; + changedItemId = url.getPathSegments().get(2); + idColumnName = Im.SessionCookies.ACCOUNT; + break; + + case MATCH_PROVIDER_SETTINGS_BY_ID_AND_NAME: + tableToChange = TABLE_PROVIDER_SETTINGS; + + String providerId = url.getPathSegments().get(1); + String name = url.getPathSegments().get(2); + + appendWhere(whereClause, Im.ProviderSettings.PROVIDER, "=", providerId); + appendWhere(whereClause, Im.ProviderSettings.NAME, "=", name); + break; + + case MATCH_OUTGOING_RMQ_MESSAGES: + tableToChange = TABLE_OUTGOING_RMQ_MESSAGES; + break; + + case MATCH_LAST_RMQ_ID: + tableToChange = TABLE_LAST_RMQ_ID; + break; + + default: + throw new UnsupportedOperationException("Cannot delete that URL: " + url); + } + + if (idColumnName == null) { + idColumnName = "_id"; + } + + if (changedItemId != null) { + appendWhere(whereClause, idColumnName, "=", changedItemId); + } + + if (DBG) log("delete from " + url + " WHERE " + whereClause); + + final SQLiteDatabase db = mOpenHelper.getWritableDatabase(); + int count = db.delete(tableToChange, whereClause.toString(), whereArgs); + + if (contactDeleted && count > 0) { + // since the contact cleanup triggers no longer work for cross database tables, + // we have to do it by hand here. + performContactRemovalCleanup(deletedContactId); + } + + if (count > 0) { + // In most case, we query contacts with presence and chats joined, thus + // we should also notify that contacts changes when presence or chats changed. + if (match == MATCH_CHATS || match == MATCH_CHATS_ID + || match == MATCH_PRESENCE || match == MATCH_PRESENCE_ID + || match == MATCH_CONTACTS_BAREBONE) { + getContext().getContentResolver().notifyChange(Im.Contacts.CONTENT_URI, null); + } else if (notifyMessagesContentUri) { + getContext().getContentResolver().notifyChange(Im.Messages.CONTENT_URI, null); + } else if (notifyGroupMessagesContentUri) { + getContext().getContentResolver().notifyChange(Im.GroupMessages.CONTENT_URI, null); + } else if (notifyContactListContentUri) { + getContext().getContentResolver().notifyChange(Im.ContactList.CONTENT_URI, null); + } + } + + return count; + } + + public int updateInternal(Uri url, ContentValues values, String userWhere, + String[] whereArgs) { + String tableToChange; + String idColumnName = null; + String changedItemId = null; + int count; + + StringBuilder whereClause = new StringBuilder(); + if(userWhere != null) { + whereClause.append(userWhere); + } + + boolean notifyMessagesContentUri = false; + boolean notifyGroupMessagesContentUri = false; + boolean notifyContactListContentUri = false; + + int match = mUrlMatcher.match(url); + switch (match) { + case MATCH_ACCOUNTS_BY_ID: + changedItemId = url.getPathSegments().get(1); + // fall through + case MATCH_ACCOUNTS: + tableToChange = TABLE_ACCOUNTS; + break; + + case MATCH_CONTACTS: + case MATCH_CONTACTS_BAREBONE: + tableToChange = TABLE_CONTACTS; + break; + + case MATCH_CONTACTS_BY_PROVIDER: + tableToChange = TABLE_CONTACTS; + changedItemId = url.getPathSegments().get(2); + idColumnName = Im.Contacts.ACCOUNT; + break; + + case MATCH_CONTACT: + tableToChange = TABLE_CONTACTS; + changedItemId = url.getPathSegments().get(1); + break; + + case MATCH_CONTACTS_BULK: + count = updateBulkContacts(values, userWhere); + // notify change using the "content://im/contacts" url, + // so the change will be observed by listeners interested + // in contacts changes. + if (count > 0) { + getContext().getContentResolver().notifyChange( + Im.Contacts.CONTENT_URI, null); + } + return count; + + case MATCH_CONTACTLIST: + tableToChange = TABLE_CONTACT_LIST; + changedItemId = url.getPathSegments().get(1); + notifyContactListContentUri = true; + break; + + case MATCH_CONTACTS_ETAGS: + tableToChange = TABLE_CONTACTS_ETAG; + break; + + case MATCH_CONTACTS_ETAG: + tableToChange = TABLE_CONTACTS_ETAG; + changedItemId = url.getPathSegments().get(1); + break; + + case MATCH_MESSAGES: + tableToChange = TABLE_MESSAGES; + break; + + case MATCH_MESSAGES_BY_CONTACT: + tableToChange = TABLE_MESSAGES; + appendWhere(whereClause, Im.Messages.ACCOUNT, "=", + url.getPathSegments().get(2)); + appendWhere(whereClause, Im.Messages.CONTACT, "=", + decodeURLSegment(url.getPathSegments().get(3))); + notifyMessagesContentUri = true; + break; + + case MATCH_MESSAGE: + tableToChange = TABLE_MESSAGES; + changedItemId = url.getPathSegments().get(1); + notifyMessagesContentUri = true; + break; + + case MATCH_GROUP_MESSAGES: + tableToChange = TABLE_GROUP_MESSAGES; + break; + + case MATCH_GROUP_MESSAGE_BY: + tableToChange = TABLE_GROUP_MESSAGES; + changedItemId = url.getPathSegments().get(1); + idColumnName = Im.GroupMessages.GROUP; + notifyGroupMessagesContentUri = true; + break; + + case MATCH_GROUP_MESSAGE: + tableToChange = TABLE_GROUP_MESSAGES; + changedItemId = url.getPathSegments().get(1); + notifyGroupMessagesContentUri = true; + break; + + case MATCH_AVATARS: + tableToChange = TABLE_AVATARS; + break; + + case MATCH_AVATAR: + tableToChange = TABLE_AVATARS; + changedItemId = url.getPathSegments().get(1); + break; + + case MATCH_AVATAR_BY_PROVIDER: + tableToChange = TABLE_AVATARS; + changedItemId = url.getPathSegments().get(2); + idColumnName = Im.Avatars.ACCOUNT; + break; + + case MATCH_CHATS: + tableToChange = TABLE_CHATS; + break; + + case MATCH_CHATS_ID: + tableToChange = TABLE_CHATS; + changedItemId = url.getPathSegments().get(1); + idColumnName = Im.Chats.CONTACT_ID; + break; + + case MATCH_PRESENCE: + //if (DBG) log("update presence: where='" + userWhere + "'"); + tableToChange = TABLE_PRESENCE; + break; + + case MATCH_PRESENCE_ID: + tableToChange = TABLE_PRESENCE; + changedItemId = url.getPathSegments().get(1); + idColumnName = Im.Presence.CONTACT_ID; + break; + + case MATCH_PRESENCE_BULK: + count = updateBulkPresence(values, userWhere, whereArgs); + // notify change using the "content://im/contacts" url, + // so the change will be observed by listeners interested + // in contacts changes. + if (count > 0) { + getContext().getContentResolver().notifyChange(Im.Contacts.CONTENT_URI, null); + } + return count; + + case MATCH_INVITATION: + tableToChange = TABLE_INVITATIONS; + changedItemId = url.getPathSegments().get(1); + break; + + case MATCH_SESSIONS: + tableToChange = TABLE_SESSION_COOKIES; + break; + + case MATCH_PROVIDER_SETTINGS_BY_ID_AND_NAME: + tableToChange = TABLE_PROVIDER_SETTINGS; + + String providerId = url.getPathSegments().get(1); + String name = url.getPathSegments().get(2); + + if (values.containsKey(Im.ProviderSettings.PROVIDER) || + values.containsKey(Im.ProviderSettings.NAME)) { + throw new SecurityException("Cannot override the value for provider|name"); + } + + appendWhere(whereClause, Im.ProviderSettings.PROVIDER, "=", providerId); + appendWhere(whereClause, Im.ProviderSettings.NAME, "=", name); + + break; + + case MATCH_OUTGOING_RMQ_MESSAGES: + tableToChange = TABLE_OUTGOING_RMQ_MESSAGES; + break; + + case MATCH_LAST_RMQ_ID: + tableToChange = TABLE_LAST_RMQ_ID; + break; + + default: + throw new UnsupportedOperationException("Cannot update URL: " + url); + } + + if (idColumnName == null) { + idColumnName = "_id"; + } + if(changedItemId != null) { + appendWhere(whereClause, idColumnName, "=", changedItemId); + } + + if (DBG) log("update " + url + " WHERE " + whereClause); + + final SQLiteDatabase db = mOpenHelper.getWritableDatabase(); + count = db.update(tableToChange, values, whereClause.toString(), whereArgs); + + if (count > 0) { + // In most case, we query contacts with presence and chats joined, thus + // we should also notify that contacts changes when presence or chats changed. + if (match == MATCH_CHATS || match == MATCH_CHATS_ID + || match == MATCH_PRESENCE || match == MATCH_PRESENCE_ID + || match == MATCH_CONTACTS_BAREBONE) { + getContext().getContentResolver().notifyChange(Im.Contacts.CONTENT_URI, null); + } else if (notifyMessagesContentUri) { + log("notify change for " + Im.Messages.CONTENT_URI); + getContext().getContentResolver().notifyChange(Im.Messages.CONTENT_URI, null); + } else if (notifyGroupMessagesContentUri) { + getContext().getContentResolver().notifyChange(Im.GroupMessages.CONTENT_URI, null); + } else if (notifyContactListContentUri) { + getContext().getContentResolver().notifyChange(Im.ContactList.CONTENT_URI, null); + } + } + + return count; + } + + @Override + public ParcelFileDescriptor openFile(Uri uri, String mode) + throws FileNotFoundException { + return openFileHelper(uri, mode); + } + + private static void appendWhere(StringBuilder where, String columnName, + String condition, Object value) { + if (where.length() > 0) { + where.append(" AND "); + } + where.append(columnName).append(condition); + if(value != null) { + DatabaseUtils.appendValueToSql(where, value); + } + } + + private static void appendWhere(StringBuilder where, String clause) { + if (where.length() > 0) { + where.append(" AND "); + } + where.append(clause); + } + + private static String decodeURLSegment(String segment) { + try { + return URLDecoder.decode(segment, "UTF-8"); + } catch (UnsupportedEncodingException e) { + // impossible + return segment; + } + } + + static void log(String message) { + Log.d(LOG_TAG, message); + } +} |