Fixed created QJsonDbWatcher with invalid state number

if the state number is too far in the future, or the partition is not
available, or the watcher spans multiple object tables, report an error to the
caller.

Change-Id: I4b1e4fa2859b1e781f5b3d70e639c70fab1ae2db
Reviewed-by: Jamey Hicks <jamey.hicks@nokia.com>

3 files changed, 60 insertions, 2 deletions

diff --git a/tests/auto/qjsondbwatcher/partitions.json b/tests/auto/qjsondbwatcher/partitions.json
index f8a7c87e..4619bc6e 100644
--- a/tests/auto/qjsondbwatcher/partitions.json
+++ b/tests/auto/qjsondbwatcher/partitions.json
@@ -1,3 +1,4 @@
 [
-  { "name" :"com.qt-project.shared", "path":".", "default" : true }
+  { "name" :"com.qt-project.shared", "path":".", "default" : true },
+  { "name" :"com.qt-project.removable", "path":"/nonexistentdir", "removable" : true }
 ]
diff --git a/tests/auto/qjsondbwatcher/testqjsondbwatcher.cpp b/tests/auto/qjsondbwatcher/testqjsondbwatcher.cpp
index 66ff74a4..cb465cca 100644
--- a/tests/auto/qjsondbwatcher/testqjsondbwatcher.cpp
+++ b/tests/auto/qjsondbwatcher/testqjsondbwatcher.cpp
@@ -870,6 +870,59 @@ void TestQJsonDbWatcher::invalid()
     mConnection->addWatcher(&watcher3);
     QVERIFY(waitForError(&watcher3, QJsonDbWatcher::InvalidPartition));
     mConnection->removeWatcher(&watcher3);
+
+    // invalid initial state number
+    QJsonDbWatcher watcher4;
+    watcher4.setQuery(QStringLiteral("[?_type=\"Contact\"]"));
+    watcher4.setInitialStateNumber(1234567);
+    mConnection->addWatcher(&watcher4);
+    QVERIFY(waitForError(&watcher4, QJsonDbWatcher::InvalidStateNumber));
+    mConnection->removeWatcher(&watcher4);
+
+    // unavailable partition
+    QJsonDbWatcher watcher5;
+    watcher5.setQuery(QStringLiteral("[?_type=\"Contact\"]"));
+    watcher5.setPartition(QStringLiteral("com.qt-project.removable"));
+    mConnection->addWatcher(&watcher5);
+    QVERIFY(waitForError(&watcher5, QJsonDbWatcher::InvalidPartition));
+    mConnection->removeWatcher(&watcher5);
+
+    // watcher over multiple object tables
+    {
+        static const char schemaJson[] =
+"{ \
+    \"_type\": \"_schemaType\", \
+    \"name\": \"invalidMapType\", \
+    \"schema\": { \
+        \"type\": \"object\", \
+        \"extends\": {\"$ref\": \"View\"} \
+     } \
+}";
+        QJsonDbObject schema = QJsonDocument::fromJson(QByteArray(schemaJson)).object();
+
+        QJsonDbObject map;
+        map.insert(QLatin1String("_type"), QLatin1String("Map"));
+        map.insert(QLatin1String("targetType"), QLatin1String("invalidMapType"));
+        QJsonObject submap;
+        submap.insert(QLatin1String("com.test.indextest"), QLatin1String("function (o) { jsondb.emit(o); }"));
+        map.insert(QLatin1String("join"), submap);
+
+        QJsonDbCreateRequest request(QList<QJsonObject>() << schema << map);
+        QVERIFY(mConnection->send(&request));
+        QVERIFY(waitForResponse(&request));
+        QJsonDbWatcher watcher6;
+        watcher6.setQuery(QStringLiteral("[?_type=\"Contact\" | _type = \"invalidMapType\"]"));
+        mConnection->addWatcher(&watcher6);
+        QVERIFY(waitForError(&watcher6, QJsonDbWatcher::MissingQuery));
+        mConnection->removeWatcher(&watcher6);
+    }
+
+    // watcher over multiple types in the same object table
+    QJsonDbWatcher watcher7;
+    watcher7.setQuery(QStringLiteral("[?_type in [\"Contact\", \"AnotherContact\"]]"));
+    mConnection->addWatcher(&watcher7);
+    QVERIFY(waitForStatus(&watcher7, QJsonDbWatcher::Active));
+    mConnection->removeWatcher(&watcher7);
 }
 
 void TestQJsonDbWatcher::privatePartition()
diff --git a/tests/shared/testhelper.cpp b/tests/shared/testhelper.cpp
index b0dcd7c9..346c4bb8 100644
--- a/tests/shared/testhelper.cpp
+++ b/tests/shared/testhelper.cpp
@@ -376,7 +376,11 @@ bool TestHelper::waitForStatus(QJsonDbWatcher *watcher, QJsonDbWatcher::Status s
 
     connect(watcher, SIGNAL(statusChanged(QtJsonDb::QJsonDbWatcher::Status)),
             this, SLOT(watcherStatusChanged(QtJsonDb::QJsonDbWatcher::Status)));
+    connect(watcher, SIGNAL(error(QtJsonDb::QJsonDbWatcher::ErrorCode,QString)),
+            this, SLOT(watcherError(QtJsonDb::QJsonDbWatcher::ErrorCode,QString)));
     blockWithTimeout();
+    disconnect(watcher, SIGNAL(error(QtJsonDb::QJsonDbWatcher::ErrorCode,QString)),
+               this, SLOT(watcherError(QtJsonDb::QJsonDbWatcher::ErrorCode,QString)));
     disconnect(watcher, SIGNAL(statusChanged(QtJsonDb::QJsonDbWatcher::Status)),
                this, SLOT(watcherStatusChanged(QtJsonDb::QJsonDbWatcher::Status)));
 
@@ -519,7 +523,7 @@ void TestHelper::watcherLastStateNumberChanged(int stateNumber)
 
 void TestHelper::watcherError(QtJsonDb::QJsonDbWatcher::ErrorCode code, QString msg)
 {
-    qWarning() << "Watcher error:" << code << msg;
+    Q_UNUSED(msg);
     mReceivedError = code;
     if (code == mExpectedError)
         mEventLoop.quit();