Add tests of support types of partition values

scripts/test.sh

@@ -66,12 +66,16 @@ start_server() {
   else
     echo "no existing stitch instance running in docker, attempting to start one"
     . "${SRCROOT}/dependencies.list"
+    DOCKER_VOLUMES=""
+    for app in common-tests pv-int-tests pv-string-tests pv-uuid-tests pv-objectid-tests; do
+      DOCKER_VOLUMES="$DOCKER_VOLUMES -v ${SRCROOT}/tests/mongodb/${app}:/apps/${app}"
+    done
     echo "using object-store stitch dependency: ${MDBREALM_TEST_SERVER_TAG}"
     if [[ -n "$RUN_STITCH_IN_FORGROUND" ]]; then
       # we don't worry about tracking the STITCH_DOCKER_ID because without the -d flag, this docker is tied to the shell
-      docker run -v "${SRCROOT}/tests/mongodb:/apps/os-integration-tests" -p 9090:9090 -it "docker.pkg.github.com/realm/ci/mongodb-realm-test-server:${MDBREALM_TEST_SERVER_TAG}"
+      docker run $DOCKER_VOLUMES -p 9090:9090 -it "docker.pkg.github.com/realm/ci/mongodb-realm-test-server:${MDBREALM_TEST_SERVER_TAG}"
     else
-      STITCH_DOCKER_ID=$(docker run -d $BACKGROUND_FLAG -v "${SRCROOT}/tests/mongodb:/apps/os-integration-tests" -p 9090:9090 -it "docker.pkg.github.com/realm/ci/mongodb-realm-test-server:${MDBREALM_TEST_SERVER_TAG}")
+      STITCH_DOCKER_ID=$(docker run -d $BACKGROUND_FLAG $DOCKER_VOLUMES -p 9090:9090 -it "docker.pkg.github.com/realm/ci/mongodb-realm-test-server:${MDBREALM_TEST_SERVER_TAG}")
       echo "starting docker image $STITCH_DOCKER_ID"
       # wait for stitch to import apps and start serving before continuing
       docker logs --follow "$STITCH_DOCKER_ID" | grep -m 1 "Serving on.*9090" || true

tests/js/app-tests.js

@@ -6,7 +6,7 @@ const require_method = require;
 
 const Realm = require('realm');
 const TestCase = require('./asserts');
-const AppConfig = require('./support/testConfig')
+const AppConfig = require('./support/testConfig');
 const Utils = require('./test-utils');
 const schemas = require('./schemas');
 

tests/js/index.js

@@ -69,6 +69,7 @@ if (global.enableSyncTests) {
         TESTS.UserTests = require("./user-tests");
         TESTS.SessionTests = require("./session-tests");
         TESTS.UUIDSyncTests= node_require("./uuid-sync-tests");
+        TESTS.PvTests = node_require("./pv-tests.js");
     }
 }
 

tests/js/pv-tests.js

@@ -0,0 +1,218 @@
+////////////////////////////////////////////////////////////////////////////
+//
+// Copyright 2021 Realm Inc.
+//
+// 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.
+//
+////////////////////////////////////////////////////////////////////////////
+
+'use strict';
+
+/* global navigator, WorkerNavigator */
+
+const require_method = require;
+
+const Realm = require("realm");
+const TestCase = require("./asserts");
+const AppConfig = require("./support/testConfig");
+const { ObjectId, UUID } = Realm.BSON;
+
+const PvIntDog = {
+    name: "Dog",
+    primaryKey: "_id",
+    properties: {
+        _id: "objectId?", // NOTE: this needs to be changed to non-optional in the docker image.
+        breed: "string?",
+        name: "string",
+        realm_id: "int?"
+    }
+};
+
+const PvStringDog = {
+    name: "Dog",
+    primaryKey: "_id",
+    properties: {
+        _id: "objectId?", // NOTE: this needs to be changed to non-optional in the docker image.
+        breed: "string?",
+        name: "string",
+        realm_id: "string?"
+    }
+};
+
+const PvUuidDog = {
+    name: "Dog",
+    primaryKey: "_id",
+    properties: {
+        _id: "objectId?", // NOTE: this needs to be changed to non-optional in the docker image.
+        breed: "string?",
+        name: "string",
+        realm_id: "uuid?"
+    }
+};
+
+const PvObjectidDog = {
+    name: "Dog",
+    primaryKey: "_id",
+    properties: {
+        _id: "objectId?", // NOTE: this needs to be changed to non-optional in the docker image.
+        breed: "string?",
+        name: "string",
+        realm_id: "objectId?"
+    }
+};
+
+module.exports = {
+    async testPvInt() {
+        let app = new Realm.App(AppConfig.pvIntAppConfig);
+
+        let credentials = Realm.Credentials.anonymous();
+        let user = await app.logIn(credentials);
+        const realmConfig = {
+            schema: [PvIntDog],
+            sync: {
+                user: user,
+                partitionValue: 42,
+                _sessionStopPolicy: "immediately", // Make it safe to delete files after realm.close()
+            }
+        };
+
+        Realm.deleteFile(realmConfig);
+        let realm1 = await Realm.open(realmConfig);
+        realm1.write(() => {
+            realm1.create("Dog", { "_id": new ObjectId(), name: "King" });
+        });
+
+        await realm1.syncSession.uploadAllLocalChanges();
+        TestCase.assertEqual(realm1.objects("Dog").length, 1);
+        realm1.close();
+
+        Realm.deleteFile(realmConfig);
+
+        let realm2 = await Realm.open(realmConfig);
+        await realm2.syncSession.downloadAllServerChanges();
+
+        let dogs = realm2.objects("Dog");
+        TestCase.assertEqual(dogs.length, 1);
+
+        realm2.close();
+        await user.logOut();
+    },
+
+    async testPvString() {
+        let app = new Realm.App(AppConfig.pvStringAppConfig);
+
+        let credentials = Realm.Credentials.anonymous();
+        let user = await app.logIn(credentials);
+        const realmConfig = {
+            schema: [PvStringDog],
+            sync: {
+                user: user,
+                partitionValue: "42",
+                _sessionStopPolicy: "immediately", // Make it safe to delete files after realm.close()
+            }
+        };
+
+        Realm.deleteFile(realmConfig);
+        let realm1 = await Realm.open(realmConfig);
+        realm1.write(() => {
+            realm1.create("Dog", { "_id": new ObjectId(), name: "King" });
+        });
+
+        await realm1.syncSession.uploadAllLocalChanges();
+        TestCase.assertEqual(realm1.objects("Dog").length, 1);
+        realm1.close();
+
+        Realm.deleteFile(realmConfig);
+
+        let realm2 = await Realm.open(realmConfig);
+        await realm2.syncSession.downloadAllServerChanges();
+
+        let dogs = realm2.objects("Dog");
+        TestCase.assertEqual(dogs.length, 1);
+
+        realm2.close();
+        await user.logOut();
+    },
+
+    /*async testUuidString() {
+        let app = new Realm.App(AppConfig.pvUuidAppConfig);
+
+        let credentials = Realm.Credentials.anonymous();
+        let user = await app.logIn(credentials);
+        const realmConfig = {
+            schema: [PvUuidDog],
+            sync: {
+                user: user,
+                partitionValue: new UUID(),
+                _sessionStopPolicy: "immediately", // Make it safe to delete files after realm.close()
+            }
+        };
+
+        Realm.deleteFile(realmConfig);
+        let realm1 = await Realm.open(realmConfig);
+        realm1.write(() => {
+            realm1.create("Dog", { "_id": new ObjectId(), name: "King" });
+        });
+
+        await realm1.syncSession.uploadAllLocalChanges();
+        TestCase.assertEqual(realm1.objects("Dog").length, 1);
+        realm1.close();
+
+        Realm.deleteFile(realmConfig);
+
+        let realm2 = await Realm.open(realmConfig);
+        await realm2.syncSession.downloadAllServerChanges();
+
+        let dogs = realm2.objects("Dog");
+        TestCase.assertEqual(dogs.length, 1);
+
+        realm2.close();
+        await user.logOut();
+    },*/
+
+    async testObjectidString() {
+        let app = new Realm.App(AppConfig.pvObjectidAppConfig);
+
+        let credentials = Realm.Credentials.anonymous();
+        let user = await app.logIn(credentials);
+        const realmConfig = {
+            schema: [PvObjectidDog],
+            sync: {
+                user: user,
+                partitionValue: new ObjectId(),
+                _sessionStopPolicy: "immediately", // Make it safe to delete files after realm.close()
+            }
+        };
+
+        Realm.deleteFile(realmConfig);
+        let realm1 = await Realm.open(realmConfig);
+        realm1.write(() => {
+            realm1.create("Dog", { "_id": new ObjectId(), name: "King" });
+        });
+
+        await realm1.syncSession.uploadAllLocalChanges();
+        TestCase.assertEqual(realm1.objects("Dog").length, 1);
+        realm1.close();
+
+        Realm.deleteFile(realmConfig);
+
+        let realm2 = await Realm.open(realmConfig);
+        await realm2.syncSession.downloadAllServerChanges();
+
+        let dogs = realm2.objects("Dog");
+        TestCase.assertEqual(dogs.length, 1);
+
+        realm2.close();
+        await user.logOut();
+    },
+}

tests/js/support/testConfig.js

@@ -28,31 +28,55 @@ function nodeRequire(module) {
     return require_method(module);
 }
 
-let pathToStitchJson = "../../mongodb/config.json";
-const isNodeProcess = typeof process === 'object' && process + '' === '[object process]';
+function makeAppConfig(appId) {
+    const appUrl = process.env.MONGODB_REALM_ENDPOINT ? process.env.MONGODB_REALM_ENDPOINT.replace(/\"/g,'') : "http://localhost";
+    const appPort = process.env.MONGODB_REALM_PORT || "9090";
 
-if (isNodeProcess && process.env.ELECTRON_TESTS_REALM_MODULE_PATH) {
-    const path = nodeRequire("path");
-    console.log("ELECTRON_TESTS_REALM_MODULE_PATH " + process.env.ELECTRON_TESTS_REALM_MODULE_PATH);
-    pathToStitchJson = path.resolve(process.env.ELECTRON_TESTS_REALM_MODULE_PATH, '../../../mongodb/config.json')
+    console.log(`tests are using integration tests app id: ${appId} on ${appUrl}:${appPort}`);
+
+    return {
+        id: appId,
+        url: `${appUrl}:${appPort}`,
+        timeout: 1000,
+        app: {
+            name: "default",
+            version: "0"
+        }
+    };
+}
+
+function getConfigPath(testName) {
+    let pathToJson = `../../mongodb/${testName}/config.json`;
+    const isNodeProcess = typeof process === 'object' && process + '' === '[object process]';
+
+    if (isNodeProcess && process.env.ELECTRON_TESTS_REALM_MODULE_PATH) {
+        const path = nodeRequire("path");
+        console.log("ELECTRON_TESTS_REALM_MODULE_PATH " + process.env.ELECTRON_TESTS_REALM_MODULE_PATH);
+        pathToStitchJson = path.resolve(process.env.ELECTRON_TESTS_REALM_MODULE_PATH, `../${pathToJson}`);
+    }
+    return pathToJson;
 }
-console.log("pathToStitchJson " + pathToStitchJson);
 
+let pathToStitchJson = getConfigPath("common-tests");
 const integrationTestsAppId = `${nodeRequire(pathToStitchJson).app_id}`;
-const appUrl = process.env.MONGODB_REALM_ENDPOINT ? process.env.MONGODB_REALM_ENDPOINT.replace(/\"/g,'') : "http://localhost";
-const appPort = process.env.MONGODB_REALM_PORT || "9090";
-console.log(`tests are using integration tests app id: ${integrationTestsAppId} on ${appUrl}:${appPort}`);
-
-const integrationAppConfig = {
-    id: integrationTestsAppId,
-    url: `${appUrl}:${appPort}`,
-    timeout: 1000,
-    app: {
-        name: "default",
-        version: '0'
-    },
-};
+const integrationAppConfig = makeAppConfig(integrationTestsAppId);
+
+let pathToPvIntJSON = getConfigPath("pv-int-tests");
+const pvIntTestsAppId = `${nodeRequire(pathToPvIntJSON).app_id}`;
+const pvIntAppConfig = makeAppConfig(pvIntTestsAppId);
+
+let pathToPvStringJSON = getConfigPath("pv-string-tests");
+const pvStringTestsAppId = `${nodeRequire(pathToPvStringJSON).app_id}`;
+const pvStringAppConfig = makeAppConfig(pvStringTestsAppId);
+
+let pathToPvUuidJSON = getConfigPath("pv-uuid-tests");
+const pvUuidTestsAppId = `${nodeRequire(pathToPvUuidJSON).app_id}`;
+const pvUuidAppConfig = makeAppConfig(pvUuidTestsAppId);
+
+let pathToPvObjectidJSON = getConfigPath("pv-objectid-tests");
+const pvObjectidTestsAppId = `${nodeRequire(pathToPvObjectidJSON).app_id}`;
+const pvObjectidAppConfig = makeAppConfig(pvObjectidTestsAppId);
 
 module.exports = {
-    integrationAppConfig
+    integrationAppConfig, pvIntAppConfig, pvStringAppConfig, pvUuidAppConfig, pvObjectidAppConfig
 }

tests/mongodb/auth_providers/anon-user.json → tests/mongodb/common-tests/auth_providers/anon-user.json

@@ -1,5 +1,5 @@
 {
-    "id": "6037be866c917b9bd04fb555",
+    "id": "606453b13d297b2d11f1d042",
     "name": "anon-user",
     "type": "anon-user",
     "disabled": false

tests/mongodb/auth_providers/api-key.json → tests/mongodb/common-tests/auth_providers/api-key.json

@@ -1,5 +1,5 @@
 {
-    "id": "6037be866c917b9bd04fb556",
+    "id": "606453b13d297b2d11f1d043",
     "name": "api-key",
     "type": "api-key",
     "disabled": false

tests/mongodb/auth_providers/custom-function.json → tests/mongodb/common-tests/auth_providers/custom-function.json

@@ -1,5 +1,5 @@
 {
-    "id": "6037be866c917b9bd04fb557",
+    "id": "606453b13d297b2d11f1d044",
     "name": "custom-function",
     "type": "custom-function",
     "config": {

tests/mongodb/auth_providers/local-userpass.json → tests/mongodb/common-tests/auth_providers/local-userpass.json

@@ -1,5 +1,5 @@
 {
-    "id": "6037be866c917b9bd04fb558",
+    "id": "606453b13d297b2d11f1d045",
     "name": "local-userpass",
     "type": "local-userpass",
     "config": {

tests/mongodb/config.json → tests/mongodb/common-tests/config.json

@@ -1,5 +1,5 @@
 {
-    "app_id": "auth-integration-tests-bhnql",
+    "app_id": "auth-integration-tests-uxnzd",
     "config_version": 20200603,
     "name": "auth-integration-tests",
     "location": "US-VA",

tests/mongodb/common-tests/environments/development.json

@@ -0,0 +1,3 @@
+{
+    "values": {}
+}

tests/mongodb/common-tests/environments/no-environment.json

@@ -0,0 +1,3 @@
+{
+    "values": {}
+}

tests/mongodb/common-tests/environments/production.json

@@ -0,0 +1,3 @@
+{
+    "values": {}
+}

tests/mongodb/common-tests/environments/qa.json

@@ -0,0 +1,3 @@
+{
+    "values": {}
+}

tests/mongodb/common-tests/environments/staging.json

@@ -0,0 +1,3 @@
+{
+    "values": {}
+}

tests/mongodb/common-tests/environments/testing.json

@@ -0,0 +1,3 @@
+{
+    "values": {}
+}

tests/mongodb/functions/authFunc/config.json → tests/mongodb/common-tests/functions/authFunc/config.json

@@ -1,6 +1,6 @@
 {
     "can_evaluate": {},
-    "id": "6037be866c917b9bd04fb551",
+    "id": "606453b13d297b2d11f1d03e",
     "name": "authFunc",
     "private": false
 }