Implement sync testers in sync beta group command

Sources/AppStoreConnectCLI/Commands/TestFlight/BetaGroups/BetaGroupCommand.swift

@@ -18,6 +18,7 @@ struct TestFlightBetaGroupCommand: ParsableCommand {
             ReadBetaGroupCommand.self,
             RemoveTestersFromGroupCommand.self,
             AddTestersToGroupCommand.self,
+            SyncBetaGroupsCommand.self,
         ],
         defaultSubcommand: ListBetaGroupsCommand.self
     )

Sources/AppStoreConnectCLI/Commands/TestFlight/BetaGroups/Sync/PullBetaGroupsCommand.swift

@@ -0,0 +1,30 @@
+// Copyright 2020 Itty Bitty Apps Pty Ltd
+
+import ArgumentParser
+import FileSystem
+
+struct PullBetaGroupsCommand: CommonParsableCommand {
+
+    static var configuration = CommandConfiguration(
+        commandName: "pull",
+        abstract: "Pull down server beta groups, refresh local beta group config files"
+    )
+
+    @OptionGroup()
+    var common: CommonOptions
+
+    @Option(
+        default: "./config/betagroups",
+        help: "Path to the Folder containing the information about beta groups. (default: './config/betagroups')"
+    ) var outputPath: String
+
+    func run() throws {
+        let service = try makeService()
+
+        let betaGroupWithTesters = try service.pullBetaGroups()
+
+        try BetaGroupProcessor(path: .folder(path: outputPath))
+            .write(groupsWithTesters: betaGroupWithTesters)
+    }
+
+}

Sources/AppStoreConnectCLI/Commands/TestFlight/BetaGroups/Sync/PushBetaGroupsCommand.swift

@@ -0,0 +1,137 @@
+// Copyright 2020 Itty Bitty Apps Pty Ltd
+
+import ArgumentParser
+import FileSystem
+import Foundation
+import struct Model.BetaGroup
+import struct Model.BetaTester
+
+struct PushBetaGroupsCommand: CommonParsableCommand {
+
+    static var configuration = CommandConfiguration(
+        commandName: "push",
+        abstract: "Push local beta group config files to server, update server beta groups"
+    )
+
+    @OptionGroup()
+    var common: CommonOptions
+
+    @Option(
+        default: "./config/betagroups",
+        help: "Path to the Folder containing the information about beta groups. (default: './config/betagroups')"
+    ) var inputPath: String
+
+    @Flag(help: "Perform a dry run.")
+    var dryRun: Bool
+
+    func run() throws {
+        let service = try makeService()
+
+        let resourceProcessor = BetaGroupProcessor(path: .folder(path: inputPath))
+
+        let serverGroupsWithTesters = try service.pullBetaGroups()
+        let localGroups = try resourceProcessor.read()
+
+        // Sync Beta Groups
+        let strategies = SyncResourceComparator(
+                localResources: localGroups,
+                serverResources: serverGroupsWithTesters.map { $0.betaGroup }
+            )
+            .compare()
+
+        let renderer = Renderers.SyncResultRenderer<BetaGroup>()
+
+        if dryRun {
+            renderer.render(strategies, isDryRun: true)
+        } else {
+            try strategies.forEach { (strategy: SyncStrategy) in
+                try syncBetaGroup(strategy: strategy, with: service)
+                renderer.render(strategy, isDryRun: false)
+            }
+        }
+
+        // Sync Beta Testers
+        let localGroupWithTesters = try resourceProcessor.readGroupAndTesters()
+
+        try localGroupWithTesters.forEach {
+            let localGroup = $0.betaGroup
+            let localTesters = $0.testers
+
+            let serverTesters = serverGroupsWithTesters.first {
+                $0.betaGroup.id == localGroup.id
+            }?.testers ?? []
+
+            let testerStrategies = SyncResourceComparator(
+                    localResources: localTesters,
+                    serverResources: serverTesters
+                )
+                .compare()
+
+            let renderer = Renderers.SyncResultRenderer<BetaTester>()
+
+            if testerStrategies.count > 0 {
+                print("\(localGroup.groupName): ")
+            }
+
+            if dryRun {
+                renderer.render(testerStrategies, isDryRun: true)
+            } else {
+                try testerStrategies.forEach {
+                    try syncTester(with: service,
+                                   bundleId: localGroup.app.bundleId!,
+                                   groupName: localGroup.groupName,
+                                   strategies: $0)
+
+                    renderer.render($0, isDryRun: false)
+                }
+            }
+        }
+
+        // After all operations, sync group and testers
+        if !dryRun {
+            try resourceProcessor.write(groupsWithTesters: try service.pullBetaGroups())
+        }
+    }
+
+    func syncBetaGroup(
+        strategy: SyncStrategy<BetaGroup>,
+        with service: AppStoreConnectService
+    ) throws {
+        switch strategy {
+        case .create(let group):
+            _ = try service.createBetaGroup(
+                appBundleId: group.app.bundleId!,
+                groupName: group.groupName,
+                publicLinkEnabled: group.publicLinkEnabled ?? false,
+                publicLinkLimit: group.publicLinkLimit
+            )
+        case .delete(let group):
+            try service.deleteBetaGroup(with: group.id!)
+        case .update(let group):
+            try service.updateBetaGroup(betaGroup: group)
+        }
+    }
+
+    func syncTester(
+        with service: AppStoreConnectService,
+        bundleId: String,
+        groupName: String,
+        strategies: SyncStrategy<BetaTester>
+    ) throws {
+        switch strategies {
+        case .create(let tester):
+            _ = try service.inviteBetaTesterToGroups(
+                firstName: tester.firstName,
+                lastName: tester.lastName,
+                email: tester.email!,
+                bundleId: bundleId,
+                groupNames: [groupName]
+            )
+        case .update:
+            print("Update single beta tester is not supported.")
+        case .delete(let tester):
+            try service.removeTesterFromGroups(email: tester.email!, groupNames: [groupName])
+        }
+    }
+
+}

Sources/AppStoreConnectCLI/Commands/TestFlight/BetaGroups/Sync/SyncBetaGroupsCommand.swift

@@ -0,0 +1,17 @@
+// Copyright 2020 Itty Bitty Apps Pty Ltd
+
+import ArgumentParser
+
+struct SyncBetaGroupsCommand: ParsableCommand {
+    static var configuration = CommandConfiguration(
+        commandName: "sync",
+        abstract: """
+        Sync information about beta groups with provided configuration file.
+        """,
+        subcommands: [
+            PullBetaGroupsCommand.self,
+            PushBetaGroupsCommand.self,
+        ],
+        defaultSubcommand: PullBetaGroupsCommand.self
+    )
+}

Sources/AppStoreConnectCLI/Model/App.swift

@@ -38,7 +38,7 @@ extension App: TableInfoProvider {
 
     var tableRow: [CustomStringConvertible] {
         return [
-            id,
+            id ?? "",
             bundleId ?? "",
             name ?? "",
             primaryLocale ?? "",

Sources/AppStoreConnectCLI/Model/BetaGroup.swift

@@ -26,10 +26,10 @@ extension BetaGroup: TableInfoProvider, ResultRenderable {
 
     var tableRow: [CustomStringConvertible] {
         [
-            app.id,
+            app.id ?? "",
             app.bundleId ?? "",
             app.name ?? "",
-            groupName ?? "",
+            groupName,
             isInternal ?? "",
             publicLink ?? "",
             publicLinkEnabled ?? "",
@@ -41,13 +41,29 @@ extension BetaGroup: TableInfoProvider, ResultRenderable {
 }
 
 extension BetaGroup {
+    enum Error: LocalizedError {
+        case invalidName
+
+        var errorDescription: String? {
+            switch self {
+            case .invalidName:
+                return "Beta group doesn't have a valid group name."
+            }
+        }
+    }
+
     init(
         _ apiApp: AppStoreConnect_Swift_SDK.App,
         _ apiBetaGroup: AppStoreConnect_Swift_SDK.BetaGroup
-    ) {
+    ) throws {
+        guard let groupName = apiBetaGroup.attributes?.name else {
+            throw Error.invalidName
+        }
+
         self.init(
             app: App(apiApp),
-            groupName: apiBetaGroup.attributes?.name,
+            id: apiBetaGroup.id,
+            groupName: groupName,
             isInternal: apiBetaGroup.attributes?.isInternalGroup,
             publicLink: apiBetaGroup.attributes?.publicLink,
             publicLinkEnabled: apiBetaGroup.attributes?.publicLinkEnabled,
@@ -57,3 +73,15 @@ extension BetaGroup {
         )
     }
 }
+
+extension BetaGroup: SyncResultRenderable {
+    var syncResultText: String {
+        "\(app.bundleId ?? "" )_\(groupName)"
+    }
+}
+
+extension BetaGroup: SyncResourceProcessable {
+    var compareIdentity: String {
+        id ?? ""
+    }
+}

Sources/AppStoreConnectCLI/Model/BetaTester.swift

@@ -58,3 +58,13 @@ extension BetaTester: ResultRenderable, TableInfoProvider {
         ]
     }
 }
+
+extension BetaTester: SyncResourceProcessable {
+    var syncResultText: String {
+        email!
+    }
+
+    var compareIdentity: String {
+        email!
+    }
+}

Sources/AppStoreConnectCLI/Readers and Renderers/Renderers.swift

@@ -113,3 +113,42 @@ extension ResultRenderable where Self: TableInfoProvider {
         return table.render()
     }
 }
+
+protocol SyncResultRenderable: Equatable {
+    var syncResultText: String { get }
+}
+
+enum SyncStrategy<T: SyncResultRenderable> {
+    case delete(T)
+    case create(T)
+    case update(T)
+}
+
+extension Renderers {
+
+    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

@@ -410,7 +410,7 @@ class AppStoreConnectService {
             .execute(with: requestor)
             .await()
 
-        return Model.BetaGroup(app, betaGroup)
+        return try Model.BetaGroup(app, betaGroup)
     }
 
     func createBetaGroup(
@@ -432,7 +432,7 @@ class AppStoreConnectService {
         )
 
         let betaGroupResponse = createBetaGroupOperation.execute(with: requestor)
-        return try betaGroupResponse.map(Model.BetaGroup.init).await()
+        return try betaGroupResponse.tryMap(Model.BetaGroup.init).await()
     }
 
     func deleteBetaGroup(appBundleId: String, betaGroupName: String) throws {
@@ -507,7 +507,34 @@ class AppStoreConnectService {
         let modifyBetaGroupOperation = ModifyBetaGroupOperation(options: modifyBetaGroupOptions)
         let modifiedBetaGroup = try modifyBetaGroupOperation.execute(with: requestor).await()
 
-        return Model.BetaGroup(app, modifiedBetaGroup)
+        return try Model.BetaGroup(app, modifiedBetaGroup)
+    }
+
+    func pullBetaGroups() throws -> [(betaGroup: Model.BetaGroup, testers: [Model.BetaTester])] {
+        let groupOutputs = try ListBetaGroupsOperation(options: .init(appIds: [], names: [], sort: nil)).execute(with: requestor).await()
+
+        return try groupOutputs.map {
+            let testers = try ListBetaTestersOperation(
+                    options: .init(groupIds: [$0.betaGroup.id])
+                )
+                .execute(with: requestor)
+                .await()
+                .map(BetaTester.init)
+
+            return (try BetaGroup($0.app, $0.betaGroup), testers)
+        }
+    }
+
+    func updateBetaGroup(betaGroup: Model.BetaGroup) throws {
+        _ = try UpdateBetaGroupOperation(options: .init(betaGroup: betaGroup))
+            .execute(with: requestor)
+            .await()
+    }
+
+    func deleteBetaGroup(with id: String) throws {
+        try DeleteBetaGroupOperation(options: .init(betaGroupId: id))
+            .execute(with: requestor)
+            .await()
     }
 
     func readBuild(bundleId: String, buildNumber: String, preReleaseVersion: String) throws -> Model.Build {