-
Notifications
You must be signed in to change notification settings - Fork 19
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Update
tophatctl so that it can wait for a response from Tophat (#43)
- Loading branch information
Showing
27 changed files
with
433 additions
and
336 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,96 @@ | ||
| // | ||
| // RemoteControlReceiver.swift | ||
| // Tophat | ||
| // | ||
| // Created by Lukas Romsicki on 2023-01-27. | ||
| // Copyright © 2023 Shopify. All rights reserved. | ||
| // | ||
|
|
||
| import Foundation | ||
| import TophatFoundation | ||
| import TophatControlServices | ||
|
|
||
| protocol RemoteControlReceiverDelegate: AnyObject { | ||
| func remoteControlReceiver(didReceiveRequestToAddQuickLaunchEntry quickLaunchEntry: QuickLaunchEntry) | ||
| func remoteControlReceiver(didReceiveRequestToRemoveQuickLaunchEntryWithIdentifier quickLaunchEntryIdentifier: QuickLaunchEntry.ID) | ||
| func remoteControlReceiver(didReceiveRequestToLaunchApplicationWithRecipes recipes: [InstallRecipe]) async | ||
| func remoteControlReceiver(didOpenURL url: URL, launchArguments: [String]) async | ||
| } | ||
|
|
||
| final class RemoteControlReceiver { | ||
| weak var delegate: RemoteControlReceiverDelegate? | ||
|
|
||
| private let service = TophatRemoteControlService() | ||
|
|
||
| init() { | ||
| Task { | ||
| for await request in service.requests(for: InstallFromURLRequest.self) { | ||
| let requestValue = request.value | ||
|
|
||
| await delegate?.remoteControlReceiver(didOpenURL: requestValue.url, launchArguments: requestValue.launchArguments) | ||
| request.reply(.init()) | ||
| } | ||
| } | ||
|
|
||
| Task { | ||
| for await request in service.requests(for: InstallFromRecipesRequest.self) { | ||
| let requestValue = request.value | ||
|
|
||
| let recipes = requestValue.recipes.map { recipe in | ||
| let artifactProviderMetadata = ArtifactProviderMetadata( | ||
| id: recipe.artifactProviderID, | ||
| parameters: recipe.artifactProviderParameters | ||
| ) | ||
|
|
||
| return InstallRecipe( | ||
| source: .artifactProvider(metadata: artifactProviderMetadata), | ||
| launchArguments: recipe.launchArguments, | ||
| platformHint: recipe.platformHint, | ||
| destinationHint: recipe.destinationHint | ||
| ) | ||
| } | ||
|
|
||
| await delegate?.remoteControlReceiver(didReceiveRequestToLaunchApplicationWithRecipes: recipes) | ||
| request.reply(.init()) | ||
| } | ||
| } | ||
|
|
||
| Task { | ||
| for await request in service.requests(for: AddQuickLaunchEntryRequest.self) { | ||
| let requestValue = request.value | ||
|
|
||
| let configuration = requestValue.configuration | ||
|
|
||
| let quickLaunchEntry = QuickLaunchEntry( | ||
| id: configuration.id, | ||
| name: configuration.name, | ||
| recipes: configuration.recipes.map { source in | ||
| let artifactProviderMetadata = ArtifactProviderMetadata( | ||
| id: source.artifactProviderID, | ||
| parameters: source.artifactProviderParameters | ||
| ) | ||
|
|
||
| return QuickLaunchEntryRecipe( | ||
| artifactProviderID: artifactProviderMetadata.id, | ||
| artifactProviderParameters: artifactProviderMetadata.parameters, | ||
| launchArguments: source.launchArguments, | ||
| platformHint: source.platformHint, | ||
| destinationHint: source.destinationHint | ||
| ) | ||
| } | ||
| ) | ||
|
|
||
| delegate?.remoteControlReceiver(didReceiveRequestToAddQuickLaunchEntry: quickLaunchEntry) | ||
| } | ||
| } | ||
|
|
||
| Task { | ||
| for await request in service.requests(for: RemoveQuickLaunchEntryRequest.self) { | ||
| let requestValue = request.value | ||
| delegate?.remoteControlReceiver( | ||
| didReceiveRequestToRemoveQuickLaunchEntryWithIdentifier: requestValue.quickLaunchEntryID | ||
| ) | ||
| } | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.