Implement sync testflight config command

.gitignore

@@ -30,4 +30,4 @@ Temporary Items
 /Packages
 /*.xcodeproj
 xcuserdata/
-config/auth.yml
+/config

Sources/AppStoreConnectCLI/Commands/TestFlight/Sync/TestFlightPullCommand.swift

@@ -0,0 +1,35 @@
+// Copyright 2020 Itty Bitty Apps Pty Ltd
+
+import ArgumentParser
+import Foundation
+import FileSystem
+
+struct TestFlightPullCommand: CommonParsableCommand {
+
+    static var configuration = CommandConfiguration(
+        commandName: "pull",
+        abstract: "Pull down existing testflight configs, refreshing local config files"
+    )
+
+    @OptionGroup()
+    var common: CommonOptions
+
+    @Option(
+        default: "./config/apps",
+        help: "Path to the Folder containing the testflight configs."
+    ) var outputPath: String
+
+    func run() throws {
+        let service = try makeService()
+
+        let configs = try service.pullTestFlightConfigs()
+
+        configs.forEach {
+            print($0.app.name)
+            print($0.betagroups.count)
+        }
+
+        try TestFlightConfigLoader().save(configs, in: outputPath)
+    }
+
+}

Sources/AppStoreConnectCLI/Commands/TestFlight/Sync/TestFlightPushCommand.swift

@@ -0,0 +1,148 @@
+// Copyright 2020 Itty Bitty Apps Pty Ltd
+
+import ArgumentParser
+import FileSystem
+import Foundation
+
+struct TestFlightPushCommand: CommonParsableCommand {
+
+    static var configuration =  CommandConfiguration(
+        commandName: "push",
+        abstract: "Push local testflight config files to server, update server configs"
+    )
+
+    @OptionGroup()
+    var common: CommonOptions
+
+    @Option(
+        default: "./config/apps",
+        help: "Path to the Folder containing the testflight configs."
+    ) var inputPath: String
+
+    @Flag(help: "Perform a dry run.")
+    var dryRun: Bool
+
+    func run() throws {
+        let service = try makeService()
+
+        let localConfigs = try TestFlightConfigLoader().load(appsFolderPath: inputPath)
+
+        let serverConfigs = try service.pullTestFlightConfigs()
+
+        serverConfigs.forEach { serverConfig in
+            guard
+                let localConfig = localConfigs
+                    .first(where: { $0.app.id == serverConfig.app.id }) else {
+                return
+            }
+
+            let appId = localConfig.app.id
+
+            // 1. compare shared testers in app
+            let sharedTestersHandleStrategies = SyncResourceComparator(
+                localResources: localConfig.testers,
+                serverResources: serverConfig.testers
+            ).compare()
+
+            // 1.1 handle shared testers delete only
+            processAppTesterStrategies(sharedTestersHandleStrategies, appId: appId)
+
+
+            // 2. compare beta groups
+            let localBetagroups = localConfig.betagroups
+            let serverBetagroups = serverConfig.betagroups
+
+            let betaGroupHandlingStrategies = SyncResourceComparator(
+                    localResources: localBetagroups,
+                    serverResources: serverBetagroups
+                )
+                .compare()
+
+            // 2.1 handle groups create, update, delete
+            processBetagroupsStrategies(betaGroupHandlingStrategies, appId: appId)
+
+
+            // 3. compare testers in group and add, delete
+            localBetagroups.forEach { localBetagroup in
+                guard let serverBetagroup = serverBetagroups
+                    .first(where: {  $0.id == localBetagroup.id } ) else {
+                        return
+                }
+
+                let betagroupId = serverBetagroup.id
+
+                let localGroupTesters = localBetagroup.testers
+
+                let serverGroupTesters = serverBetagroup.testers
+
+                let testersInGroupHandlingStrategies = SyncResourceComparator(
+                    localResources: localGroupTesters,
+                    serverResources: serverGroupTesters
+                ).compare()
+
+                // 3.1 handling adding/deleting testers per group
+                processTestersInBetaGroupStrategies(testersInGroupHandlingStrategies, betagroupId: betagroupId, appTesters: localConfig.testers)
+            }
+        }
+    }
+
+    func processAppTesterStrategies(_ strategies: [SyncStrategy<FileSystem.BetaTester>], appId: String) {
+        if dryRun {
+            SyncResultRenderer<FileSystem.BetaTester>().render(strategies, isDryRun: true)
+        } else {
+            strategies.forEach { strategy in
+                switch strategy {
+                case .delete(let betatester):
+                    print("delete testers \(betatester) from app \(appId)")
+                default:
+                    return
+                }
+            }
+        }
+
+    }
+
+    func processBetagroupsStrategies(_ strategies: [SyncStrategy<FileSystem.BetaGroup>], appId: String) {
+        if dryRun {
+            SyncResultRenderer<FileSystem.BetaGroup>().render(strategies, isDryRun: true)
+        } else {
+            strategies.forEach { strategy in
+                switch strategy {
+                case .create(let betagroup):
+                    print("create new beta group \(betagroup) in app \(appId)")
+                case .delete(let betagroup):
+                    print("delete betagroup \(betagroup)")
+                case .update(let betagroup):
+                    print("update betagroup \(betagroup)")
+                }
+            }
+        }
+
+    }
+
+    func processTestersInBetaGroupStrategies(_ strategies: [SyncStrategy<BetaGroup.EmailAddress>], betagroupId: String, appTesters: [BetaTester]) {
+        if dryRun {
+            SyncResultRenderer<FileSystem.BetaGroup.EmailAddress>().render(strategies, isDryRun: true)
+        } else {
+            strategies.forEach { strategy in
+                switch strategy {
+                case .create(let email):
+                    print("add tester with email\(email) into betagroup\(betagroupId)")
+                case .delete(let email):
+                    print("delete tester with email \(email) from betagroup \(betagroupId)")
+                default:
+                    return
+                }
+            }
+        }
+    }
+
+}
+
+
+func testPrint<T: Codable>(json: T) {
+    let jsonEncoder = JSONEncoder()
+    jsonEncoder.outputFormatting = [.prettyPrinted, .sortedKeys]
+    let json = try! jsonEncoder.encode(json) // swiftlint:disable:this force_try
+    print(String(data: json, encoding: .utf8)!)
+}

Sources/AppStoreConnectCLI/Commands/TestFlight/Sync/TestFlightSyncCommand.swift

@@ -0,0 +1,14 @@
+// Copyright 2020 Itty Bitty Apps Pty Ltd
+
+import ArgumentParser
+
+struct TestFlightSyncCommand: ParsableCommand {
+    static var configuration = CommandConfiguration(
+        commandName: "sync",
+        abstract: "Sync information about testflight with provided configuration file.",
+        subcommands: [
+            TestFlightPullCommand.self,
+            TestFlightPushCommand.self
+        ]
+    )
+}

Sources/AppStoreConnectCLI/Commands/TestFlight/TestFlightCommand.swift

@@ -13,6 +13,7 @@ public struct TestFlightCommand: ParsableCommand {
             TestFlightBetaTestersCommand.self,
             TestFlightBuildsCommand.self,
             TestFlightPreReleaseVersionCommand.self,
+            TestFlightSyncCommand.self
         ])
 
     public init() {

Sources/AppStoreConnectCLI/Model/BetaGroup.swift

@@ -3,6 +3,7 @@
 import AppStoreConnect_Swift_SDK
 import Combine
 import Foundation
+import FileSystem
 import struct Model.App
 import struct Model.BetaGroup
 import SwiftyTextTable
@@ -57,3 +58,15 @@ extension BetaGroup {
         )
     }
 }
+
+extension FileSystem.BetaGroup: SyncResourceProcessable {
+
+    var compareIdentity: String {
+        id
+    }
+
+    var syncResultText: String {
+        groupName
+    }
+
+}

Sources/AppStoreConnectCLI/Model/BetaTester.swift

@@ -3,6 +3,7 @@
 import AppStoreConnect_Swift_SDK
 import Combine
 import Foundation
+import FileSystem
 import struct Model.BetaTester
 import SwiftyTextTable
 
@@ -58,3 +59,25 @@ extension BetaTester: ResultRenderable, TableInfoProvider {
         ]
     }
 }
+
+extension FileSystem.BetaTester: SyncResourceProcessable {
+
+    var syncResultText: String {
+        email
+    }
+
+    var compareIdentity: String {
+        email
+    }
+
+}
+
+extension String: SyncResourceProcessable {
+    var syncResultText: String {
+        self
+    }
+
+    var compareIdentity: String {
+        self
+    }
+}

Sources/AppStoreConnectCLI/Readers and Renderers/Renderers.swift

@@ -113,3 +113,32 @@ extension ResultRenderable where Self: TableInfoProvider {
         return table.render()
     }
 }
+
+protocol SyncResultRenderable: Equatable {
+    var syncResultText: String { get }
+}
+
+struct SyncResultRenderer<T: SyncResultRenderable> {
+
+       func render(_ strategy: [SyncStrategy<T>], isDryRun: Bool) {
+           strategy.forEach { renderResultText($0, isDryRun) }
+       }
+
+       func render(_ strategy: SyncStrategy<T>, isDryRun: Bool) {
+           renderResultText(strategy, isDryRun)
+       }
+
+       private func renderResultText(_ strategy: SyncStrategy<T>, _ isDryRun: Bool) {
+           let resultText: String
+           switch strategy {
+           case .create(let input):
+               resultText = "➕ \(input.syncResultText)"
+           case .delete(let input):
+               resultText = "➖ \(input.syncResultText)"
+           case .update(let input):
+               resultText = "⬆️  \(input.syncResultText)"
+           }
+
+           print("\(isDryRun ? "" : "✅") \(resultText)")
+       }
+   }

Sources/AppStoreConnectCLI/Services/AppStoreConnectService.swift

@@ -3,6 +3,7 @@
 import AppStoreConnect_Swift_SDK
 import Combine
 import Foundation
+import FileSystem
 import Model
 
 class AppStoreConnectService {
@@ -798,6 +799,62 @@ class AppStoreConnectService {
             .await()
     }
 
+    func pullTestFlightConfigs() throws -> [TestFlightConfiguration] {
+
+        let apps = try listApps(bundleIds: [], names: [], skus: [], limit: nil)
+
+
+        testPrint(json: apps)
+
+        return try apps.map {
+            let testers: [FileSystem.BetaTester] = try ListBetaTestersOperation(options:
+                    .init(appIds: [$0.id])
+                )
+                .execute(with: requestor)
+                .await()
+                .map{
+                    FileSystem.BetaTester(
+                        email: ($0.betaTester.attributes?.email)!,
+                        firstName: $0.betaTester.attributes?.firstName,
+                        lastName: $0.betaTester.attributes?.lastName,
+                        inviteType: $0.betaTester.attributes?.inviteType?.rawValue
+                    )
+                }
+
+            testPrint(json: testers)
+
+            let betagroups = try ListBetaGroupsOperation(
+                    options: .init(appIds: [$0.id], names: [], sort: nil)
+                )
+                .execute(with: requestor)
+                .await()
+                .map { output -> FileSystem.BetaGroup in
+                    let testersEmails = try ListBetaTestersOperation(
+                            options: .init(groupIds: [output.betaGroup.id])
+                        )
+                        .execute(with: requestor)
+                        .await()
+                        .compactMap { $0.betaTester.attributes?.email }
+
+                    return FileSystem.BetaGroup(
+                        id: output.betaGroup.id,
+                        groupName: (output.betaGroup.attributes?.name)!,
+                        isInternal: output.betaGroup.attributes?.isInternalGroup,
+                        publicLink: output.betaGroup.attributes?.publicLink,
+                        publicLinkEnabled: output.betaGroup.attributes?.publicLinkEnabled,
+                        publicLinkLimit: output.betaGroup.attributes?.publicLinkLimit,
+                        publicLinkLimitEnabled: output.betaGroup.attributes?.publicLinkLimitEnabled,
+                        creationDate: output.betaGroup.attributes?.createdDate?.formattedDate,
+                        testers: testersEmails
+                    )
+                }
+
+            testPrint(json: betagroups)
+
+            return TestFlightConfiguration(app: $0, testers: testers, betagroups: betagroups)
+        }
+    }
+
     /// Make a request for something `Decodable`.
     ///
     /// - Parameters: