sync conect

Sources/DDGSync/DDGSync.swift

@@ -65,6 +65,14 @@ public class DDGSync: DDGSyncing {
         updateIsAuthenticated()
     }
 
+    public func remoteConnect() throws -> RemoteConnecting {
+        guard try dependencies.secureStore.account() == nil else {
+            throw SyncError.accountAlreadyExists
+        }
+
+        return dependencies.createRemoteConnector()
+    }
+
     public func sender() throws -> UpdatesSending {
         return try dependencies.createUpdatesSender(persistence)
     }

Sources/DDGSync/DDGSyncing.swift

@@ -58,6 +58,9 @@ public protocol DDGSyncing {
      */
     func login(_ recoveryKey: SyncCode.RecoveryKey, deviceName: String, deviceType: String) async throws
 
+    /// Returns a device id and temporary secret key ready for display then polls the end point for a recovery key.
+    func remoteConnect() throws -> RemoteConnecting
+
     /**
     Creates an atomic sender.  Add items to the sender and then call send to send them all in a single PATCH.  Will automatically re-try if there is a network failure.
      */
@@ -155,3 +158,11 @@ public struct SavedSiteFolder: Codable {
     }
 
 }
+
+public protocol RemoteConnecting {
+
+    var code: String { get }
+
+    func connect() async throws
+
+}

Sources/DDGSync/internal/ProductionDependencies.swift

@@ -53,6 +53,39 @@ struct ProductionDependencies: SyncDependencies {
         responseHandler = ResponseHandler(persistence: persistence, crypter: crypter)
     }
 
+    func createRemoteConnector() -> RemoteConnecting {
+
+        // TODO move this somewhere else
+        struct RemoteConnector: RemoteConnecting {
+
+            let code: String = "device id + temp secret key as base64 encoded json"
+
+            func connect() async throws {
+                // TODO create device id
+
+                // TODO create temporary secret key
+
+                // TODO call end the point
+
+                while true {
+                    // If the UI closes it should cancel the task
+                    try Task.checkCancellation()
+
+                    // TODO poll the endpoint
+
+                    // TODO parse the recovery key if available
+
+                    // TODO login using the recovery key
+
+                    // Wait for 5 seconds before polling again
+                    try await Task.sleep(nanoseconds: 5 * 1_000_000_000)
+                }
+            }
+        }
+
+        return RemoteConnector()
+    }
+
     func createUpdatesSender(_ persistence: LocalDataPersisting) throws -> UpdatesSending {
         return UpdatesSender(fileStorageUrl: fileStorageUrl, persistence: persistence, dependencies: self)
     }

Sources/DDGSync/internal/SyncDependencies.swift

@@ -27,6 +27,7 @@ protocol SyncDependencies {
     var responseHandler: ResponseHandling { get }
     var crypter: Crypting { get }
 
+    func createRemoteConnector() -> RemoteConnecting
     func createUpdatesSender(_ persistence: LocalDataPersisting) throws -> UpdatesSending
     func createUpdatesFetcher(_ persistence: LocalDataPersisting) throws -> UpdatesFetching
 
@@ -37,6 +38,7 @@ protocol AccountManaging {
     func createAccount(deviceName: String, deviceType: String) async throws -> SyncAccount
 
     func login(_ recoveryKey: SyncCode.RecoveryKey, deviceName: String, deviceType: String) async throws -> (account: SyncAccount, devices: [RegisteredDevice])
+
     func logout(deviceId: String, token: String) async throws
 
 }