RCOCOA-2289: Update Base url API

CHANGELOG.md

@@ -9,6 +9,15 @@ x.y.z Release notes (yyyy-MM-dd)
  ([Core #7552](https://github.com/realm/realm-core/pull/7552)).
 * Improve perfomance of IN queries and chained OR equality queries for
  UUID/ObjectId types. ([.Net #3566](https://github.com/realm/realm-dotnet/issues/3566))
+* Added support for updating Atlas Device Sync's base url, in case the need to roam between 
+ servers (cloud and/or edge server). This API is private and can only be imported using 
+ `@_spi(Private)` 
+ ```swift
+ @_spi(RealmSwiftExperimental) import RealmSwift
+
+ try await app.updateBaseUrl(to: "https://services.cloud.mongodb.com")
+ ```
+ ([#8486](https://github.com/realm/realm-swift/issues/8486)).
 * Enable building RealmSwift as a dynamic framework when installing via SPM, which
  lets us supply a privacy manifest. When RealmSwift is built as a static
  library you must supply your own manifest, as Xcode does not build static

Realm/ObjectServerTests/AsyncSyncTests.swift

@@ -20,7 +20,7 @@
 
 import Realm
 import Realm.Private
-import RealmSwift
+@_spi(RealmSwiftExperimental) import RealmSwift
 import XCTest
 
 #if canImport(RealmTestSupport)
@@ -78,6 +78,21 @@
  }
  }
 
+ func testUpdateBaseUrl() async throws {
+ let app = App(id: appId)
+ XCTAssertNotNil(app.baseURL)
+ XCTAssertEqual(app.baseURL, "http://localhost:9090")
+
+ try await app.updateBaseUrl(to: "http://localhost:8080")
+ XCTAssertEqual(app.baseURL, "http://localhost:8080")
+
+ try await app.updateBaseUrl(to: "http://localhost:7070/")
+ XCTAssertEqual(app.baseURL, "http://localhost:7070")
+
+ try await app.updateBaseUrl(to: nil)
+ XCTAssertEqual(app.baseURL, "https://services.cloud.mongodb.com")
+ }
+
  @MainActor func testAsyncOpenStandalone() async throws {
  try autoreleasepool {
  let configuration = Realm.Configuration(objectTypes: [SwiftPerson.self])
@@ -263,7 +278,7 @@
 
  let configuration = try configuration()
  func isolatedOpen(_ actor: isolated CustomExecutorActor) async throws {
  _ = try await Realm(configuration: configuration, actor: actor, downloadBeforeOpen: .always)
  }
 
  // Try opening the Realm with the Task being cancelled at every possible
@@ -406,7 +421,7 @@
  ["favourite_colour": "green", "apples": 10]
  ])
 
  try await user.refreshCustomData()
  XCTAssertEqual(user.customData["favourite_colour"], .string("green"))
  XCTAssertEqual(user.customData["apples"], .int64(10))
  }
@@ -794,7 +809,7 @@
  _ = try await results0.subscribe()
  ex.fulfill()
  }
  await fulfillment(of: [ex], timeout: 1.0)
  try await task.value
  XCTAssertEqual(realm.subscriptions.count, 1)
  }
@@ -817,7 +832,7 @@
  XCTAssertEqual(realm.subscriptions.count, 1)
  ex.fulfill()
  }
  await fulfillment(of: [ex], timeout: 5.0)
  XCTAssertEqual(realm.subscriptions.count, 1)
  }
 
@@ -859,7 +874,7 @@
  let user = try await createUser()
  var config = user.flexibleSyncConfiguration()
  config.objectTypes = [SwiftPerson.self]
  let realm = try await Realm(configuration: config, actor: MainActor.shared)
  let results1 = try await realm.objects(SwiftPerson.self)
  .where { $0.firstName == name && $0.age > 8 }.subscribe(waitForSync: .onCreation)
  XCTAssertEqual(results1.count, 2)
@@ -879,7 +894,7 @@
  let user = try await createUser()
  var config = user.flexibleSyncConfiguration()
  config.objectTypes = [SwiftPerson.self]
  let realm = try await Realm(configuration: config, actor: CustomGlobalActor.shared)
  let results1 = try await realm.objects(SwiftPerson.self)
  .where { $0.firstName == name && $0.age > 8 }.subscribe(waitForSync: .onCreation)
  XCTAssertEqual(results1.count, 2)
@@ -1047,7 +1062,7 @@
  XCTAssertEqual(realm.subscriptions.count, 1)
  expectation.fulfill()
  }
  await fulfillment(of: [expectation], timeout: 2.0)
  try await task.value
  }
 
@@ -1094,7 +1109,7 @@
  XCTAssertEqual(realm.subscriptions.count, 1)
  expectation.fulfill()
  }
  await fulfillment(of: [expectation], timeout: 1)
  }
 
  @MainActor

Realm/ObjectServerTests/RLMObjectServerTests.mm

@@ -81,6 +81,32 @@ - (NSArray *)defaultObjectTypes {
 
 #pragma mark - Authentication and Tokens
 
+- (void)testUpdateBaseUrl {
+ RLMApp *app = self.app;
+ XCTAssertEqual(app.baseURL, @"http://localhost:9090");
+
+ XCTestExpectation *expectation = [self expectationWithDescription:@"should update base url"];
+ [app updateBaseURL:@"http://localhost:8080" completion:^(NSError *error) {
+ XCTAssertNil(error);
+ [expectation fulfill];
+ }];
+ XCTAssertEqual(app.baseURL, @"http://localhost:8080");
+
+ XCTestExpectation *expectation1 = [self expectationWithDescription:@"should update base url"];
+ [app updateBaseURL:@"http://localhost:7070/" completion:^(NSError *error) {
+ XCTAssertNil(error);
+ [expectation1 fulfill];
+ }];
+ XCTAssertEqual(app.baseURL, @"http://localhost:7070");
+
+ XCTestExpectation *expectation2 = [self expectationWithDescription:@"should update base url to default value"];
+ [app updateBaseURL:nil completion:^(NSError *error) {
+ XCTAssertNil(error);
+ [expectation2 fulfill];
+ }];
+ XCTAssertEqual(app.baseURL, @"https://services.cloud.mongodb.com");
+}
+
 - (void)testAnonymousAuthentication {
  RLMUser *syncUser = self.anonymousUser;
  RLMUser *currentUser = [self.app currentUser];

Realm/ObjectServerTests/SwiftObjectServerTests.swift

@@ -21,7 +21,7 @@
 import Combine
 import Realm
 import Realm.Private
-import RealmSwift
+@_spi(RealmSwiftExperimental) import RealmSwift
 import XCTest
 
 #if canImport(RealmTestSupport)
@@ -62,6 +62,45 @@ class SwiftObjectServerTests: SwiftSyncTestCase {
  ]
  }
 
+ func testUpdateBaseUrl() {
+ let app = App(id: appId)
+ XCTAssertNotNil(app.baseURL)
+ XCTAssertEqual(app.baseURL, "http://localhost:9090")
+
+ let ex = expectation(description: "update base url")
+ app.updateBaseUrl(to: "http://localhost:8080", { result in
+ switch result {
+ case .success:
+ ex.fulfill()
+ case .failure:
+ XCTFail("Should not return an error")
+ }
+ })
+ XCTAssertEqual(app.baseURL, "http://localhost:8080")
+
+ let ex1 = expectation(description: "update base url")
+ app.updateBaseUrl(to: "http://localhost:7070/", { result in
+ switch result {
+ case .success:
+ ex1.fulfill()
+ case .failure:
+ XCTFail("Should not return an error")
+ }
+ })
+ XCTAssertEqual(app.baseURL, "http://localhost:7070")
+
+ let ex2 = expectation(description: "update base url")
+ app.updateBaseUrl(to: nil, { result in
+ switch result {
+ case .success:
+ ex2.fulfill()
+ case .failure:
+ XCTFail("Should not return an error")
+ }
+ })
+ XCTAssertEqual(app.baseURL, "https://services.cloud.mongodb.com")
+ }
+
  func testBasicSwiftSync() throws {
  XCTAssert(try openRealm().isEmpty, "Freshly synced Realm was not empty...")
  }

Realm/RLMApp.mm

@@ -414,6 +414,25 @@ - (RLMEmailPasswordAuth *)emailPasswordAuth {
  return [[RLMEmailPasswordAuth alloc] initWithApp:_app];
 }
 
+- (NSString *)baseUrl {
+ return getOptionalString(_app->get_base_url()) ?: RLMStringViewToNSString(_app->default_base_url());
+}
+
+- (void)updateBaseURL:(NSString * _Nullable)baseURL completion:(nonnull RLMOptionalErrorBlock)completionHandler {
+ auto completion = ^(std::optional<app::AppError> error) {
+ if (error) {
+ return completionHandler(makeError(*error));
+ }
+
+ completionHandler(nil);
+ };
+ return RLMTranslateError([&] {
+ NSString *url = (baseURL ?: @"");
+ NSString *newUrl = [url stringByReplacingOccurrencesOfString:@"/" withString:@"" options:0 range:NSMakeRange(url.length-1, 1)];
+ return _app->update_base_url(newUrl.UTF8String, completion);
+ });
+}
+
 - (void)loginWithCredential:(RLMCredentials *)credentials
  completion:(RLMUserCompletionBlock)completionHandler {
  auto completion = ^(std::shared_ptr<app::User> user, std::optional<app::AppError> error) {

Realm/RLMApp_Private.h

@@ -31,6 +31,8 @@ typedef void(^RLMAppNotificationBlock)(RLMApp *);
 @end
 
 @interface RLMApp ()
+/// A custom base URL to request against. If not set or set to nil, the default base url for app services will be returned.
+@property (nonatomic, readonly) NSString *baseURL;
 /// Returns all currently cached Apps
 + (NSArray<RLMApp *> *)allApps;
 /// Subscribe to notifications for this RLMApp.
@@ -40,6 +42,13 @@ typedef void(^RLMAppNotificationBlock)(RLMApp *);
 + (RLMApp *_Nullable)cachedAppWithId:(NSString *)appId;
 
 + (void)resetAppCache;
+
+/// Updates the base url used by Atlas device sync, in case the need to roam between servers (cloud and/or edge server).
+/// @param baseURL The new base url to connect to. Setting `nil` will reset the base url to the default url.
+/// @note Updating the base URL would trigger a client reset.
+- (void)updateBaseURL:(NSString *_Nullable)baseURL
+ completion:(RLMOptionalErrorBlock)completionHandler NS_REFINED_FOR_SWIFT;
+
 @end
 
 @interface RLMAppConfiguration ()

RealmSwift/App.swift

@@ -220,6 +220,18 @@ let credentials = Credentials.JWT(token: myToken)
 public typealias App = RLMApp
 
 public extension App {
+ /**
+ Updates the base url used by Atlas device sync, in case the need to roam between servers (cloud and/or edge server).
+ - parameter url: The new base url to connect to. Setting `nil` will reset the base url to the default url.
+ - parameter completion: A callback invoked after completion.
+ - note: Updating the base URL would trigger a client reset.
+ */
+ @preconcurrency
+ @available(macOS 10.15, iOS 13.0, tvOS 13.0, watchOS 6.0, *)
+ @_spi(RealmSwiftExperimental) func updateBaseUrl(to url: String?, _ completion: @Sendable @escaping (Error?) -> Void) {
+ self.__updateBaseURL(url, completion: completion)
+ }
+
  /**
  Login to a user for the Realm app.
 
@@ -237,21 +249,52 @@ public extension App {
  }
  }
 
- /// Login to a user for the Realm app.
- /// @param credentials The credentials identifying the user.
- /// @returns A publisher that eventually return `User` or `Error`.
+ /**
+ Updates the base url used by Atlas device sync, in case the need to roam between servers (cloud and/or edge server).
+ - parameter url: The new base url to connect to. Setting `nil` will reset the base url to the default url.
+ - parameter completion: A callback invoked after completion. Will return `Result.success` or `Result.failure(Error)`.
+ - note: Updating the base URL would trigger a client reset.
+ */
+ @preconcurrency
+ @available(macOS 10.15, iOS 13.0, tvOS 13.0, watchOS 6.0, *)
+ @_spi(RealmSwiftExperimental) func updateBaseUrl(to url: String?, _ completion: @Sendable @escaping (Result<Void, Error>) -> Void) {
+ self.__updateBaseURL(url, completion: { error in
+ if let error = error {
+ completion(.failure(error))
+ } else {
+ completion(.success(()))
+ }
+ })
+ }
+
+ /**
+ Login to a user for the Realm app.
+ - parameter credentials: The credentials identifying the user.
+ - returns: A publisher that eventually return `User` or `Error`.
+ */
  @available(macOS 10.15, watchOS 6.0, iOS 13.0, tvOS 13.0, *)
  func login(credentials: Credentials) -> Future<User, Error> {
  return future { self.login(credentials: credentials, $0) }
  }
 
- /// Login to a user for the Realm app.
- /// @param credentials The credentials identifying the user.
- /// @returns A publisher that eventually return `User` or `Error`.
+ /**
+ Login to a user for the Realm app.
+ - parameter credentials: The credentials identifying the user.
+ */
  @available(macOS 10.15, iOS 13.0, tvOS 13.0, watchOS 6.0, *)
  func login(credentials: Credentials) async throws -> User {
  try await __login(withCredential: ObjectiveCSupport.convert(object: credentials))
  }
+
+ /**
+ Updates the base url used by Atlas device sync, in case the need to roam between servers (cloud and/or edge server).
+ - parameter url: The new base url to connect to. Setting `nil` will reset the base url to the default url.
+ - note: Updating the base URL would trigger a client reset.
+ */
+ @available(macOS 10.15, iOS 13.0, tvOS 13.0, watchOS 6.0, *)
+ @_spi(RealmSwiftExperimental) func updateBaseUrl(to url: String?) async throws {
+ try await __updateBaseURL(url)
+ }
 }
 
 /// Use this delegate to be provided a callback once authentication has succeed or failed

dependencies.list

@@ -1,3 +1,3 @@
 VERSION=10.49.2
 REALM_CORE_VERSION=v14.6.0-7-gb2bb4f550
-STITCH_VERSION=8bf8ebcff6e804586c30a6ccbadb060753071a42
+STITCH_VERSION=40f356fbaf61e8df4f897e58357cd6a2c211825a