summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorThe Android Open Source Project <initial-contribution@android.com>2008-10-21 07:00:00 -0700
committerThe Android Open Source Project <initial-contribution@android.com>2008-10-21 07:00:00 -0700
commitef4989eb3bd594f384dd24ac3b2e7e13e180a026 (patch)
treed2e849dc1d962c4fd6f5e6930fd8f0e9272d5ebb
downloadImProvider-ef4989eb3bd594f384dd24ac3b2e7e13e180a026.tar.gz
Initial Contributionandroid-1.0release-1.0cdma-import
Diffstat
-rw-r--r--Android.mk13
-rw-r--r--AndroidManifest.xml29
-rw-r--r--MODULE_LICENSE_APACHE20
-rw-r--r--NOTICE190
-rw-r--r--res/drawable/ic_launcher_im.pngbin0 -> 2951 bytes
-rw-r--r--res/values-de-rDE/strings.xml12
-rw-r--r--res/values-en-rGB/strings.xml12
-rw-r--r--res/values-es-rUS/strings.xml12
-rw-r--r--res/values-fr-rFR/strings.xml12
-rw-r--r--res/values-it-rIT/strings.xml12
-rw-r--r--res/values-zh-rTW/strings.xml12
-rw-r--r--res/values/strings.xml29
-rw-r--r--res/xml/im_service_providers.xml19
-rw-r--r--src/com/android/providers/im/ImProvider.java2471
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
diff --git a/NOTICE b/NOTICE
new file mode 100644
index 0000000..c5b1efa
--- /dev/null
+++ b/NOTICE
@@ -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
new file mode 100644
index 0000000..afc35a2
--- /dev/null
+++ b/res/drawable/ic_launcher_im.png
Binary files differ
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);
+ }
+}
generated by cgit v1.2.3 (git 2.25.1) at 2024-05-03 23:17:56 +0000