mirror of
https://github.com/leonboe1/QuickDrop.git
synced 2026-11-11 02:51:11 +00:00
529 lines
19 KiB
Swift
529 lines
19 KiB
Swift
//
|
||
// ReceiveModel.swift
|
||
// QuickDrop
|
||
//
|
||
// Created by Leon Böttger on 16.08.25.
|
||
//
|
||
|
||
import SwiftUI
|
||
import StoreKit
|
||
import LUI
|
||
|
||
class ReceiveModel: ObservableObject, InboundAppDelegate {
|
||
|
||
/// For each connection ID, store the last reported progress value
|
||
private var processes: [String: Double] = [:]
|
||
|
||
#if os(macOS)
|
||
@Published var progress: Double? = nil
|
||
@Published var toastActions: ToastViewAction? = nil
|
||
@Published var consentState: ConsentToastState? = nil
|
||
@Published var activeDeviceName: String? = nil
|
||
private var pendingReview = false
|
||
private var toastWindow: NSWindow?
|
||
private var toastHosting: NSHostingView<QuickDropToastView>?
|
||
private let monitor = AllowedWorkMonitor()
|
||
#endif
|
||
|
||
let controlPlusScreen: (Bool) -> Void
|
||
|
||
|
||
init(controlPlusScreen: @escaping (Bool) -> Void) {
|
||
self.controlPlusScreen = controlPlusScreen
|
||
|
||
NearbyConnectionManager.shared.addInboundAppDelegate(self)
|
||
|
||
#if os(macOS)
|
||
self.monitor.onAllowed = {
|
||
NearbyConnectionManager.shared.becomeVisible()
|
||
}
|
||
self.monitor.onStopped = {
|
||
NearbyConnectionManager.shared.becomeInvisible()
|
||
}
|
||
|
||
self.monitor.start()
|
||
#else
|
||
NearbyConnectionManager.shared.becomeVisible()
|
||
#endif
|
||
}
|
||
|
||
|
||
deinit {
|
||
NearbyConnectionManager.shared.removeInboundAppDelegate(self)
|
||
|
||
#if os(macOS)
|
||
self.monitor.stop()
|
||
#endif
|
||
}
|
||
|
||
|
||
func obtainUserConsent(transfer: TransferMetadata, device: RemoteDeviceInfo) {
|
||
|
||
#if os(macOS)
|
||
NSApp.activate(ignoringOtherApps: true)
|
||
AudioManager.playIncomingFileSound()
|
||
#endif
|
||
|
||
let mainMessage = transfer.getDescription(deviceName: device.name ?? "UnknownDevice".localized())
|
||
let pinCodeMessage = transfer.getPinCodeMessage()
|
||
let transferID = transfer.id
|
||
|
||
let title = "QuickDrop - \(pinCodeMessage)"
|
||
let primaryButtonTitle = "Accept".localized()
|
||
let primaryButtonAction = { (trustDevice: Bool) in
|
||
NearbyConnectionManager.shared.submitUserConsent(transferID: transferID, accept: true, trustDevice: trustDevice)
|
||
}
|
||
|
||
let secondaryButtonTitle = "Decline".localized()
|
||
let secondaryButtonAction = { NearbyConnectionManager.shared.submitUserConsent(transferID: transferID, accept: false, trustDevice: false) }
|
||
|
||
#if os(macOS)
|
||
DispatchQueue.main.async {
|
||
self.toastActions = nil
|
||
self.progress = nil
|
||
self.activeDeviceName = device.name ?? "UnknownDevice".localized()
|
||
self.consentState = ConsentToastState(
|
||
transferID: transferID,
|
||
pinCodeMessage: pinCodeMessage,
|
||
message: mainMessage,
|
||
allowsTrust: transfer.allowsToBeAddedAsTrustedDevice,
|
||
acceptAction: { [weak self] trustDevice in
|
||
DispatchQueue.main.async {
|
||
withAnimation {
|
||
self?.consentState = nil
|
||
}
|
||
}
|
||
primaryButtonAction(trustDevice)
|
||
},
|
||
declineAction: { [weak self] in
|
||
self?.consentState = nil
|
||
secondaryButtonAction()
|
||
self?.hideQuickDropToast()
|
||
}
|
||
)
|
||
self.showQuickDropToast(for: transferID)
|
||
}
|
||
#else
|
||
// iOS
|
||
let alwaysAcceptLabel = transfer.allowsToBeAddedAsTrustedDevice ? "AlwaysAccept".localized() : nil
|
||
ProgressAlert.shared.askForUserPermission(title: title, message: mainMessage, acceptLabel: primaryButtonTitle, acceptAlwaysLabel: alwaysAcceptLabel, rejectLabel: secondaryButtonTitle) { accepted in
|
||
|
||
switch accepted {
|
||
case .Accept:
|
||
primaryButtonAction(false)
|
||
case .AcceptAlways:
|
||
primaryButtonAction(true)
|
||
case .Decline:
|
||
secondaryButtonAction()
|
||
}
|
||
}
|
||
#endif
|
||
}
|
||
|
||
|
||
func obtainedUserConsentAutomatically(transfer: TransferMetadata, device: RemoteDeviceInfo) {
|
||
|
||
let mainMessage = transfer.getDescription(deviceName: device.name ?? "UnknownDevice".localized())
|
||
|
||
#if os(macOS)
|
||
|
||
NSApp.activate(ignoringOtherApps: true)
|
||
AudioManager.playIncomingFileSound()
|
||
DispatchQueue.main.async {
|
||
self.toastActions = nil
|
||
self.progress = nil
|
||
self.activeDeviceName = device.name ?? "UnknownDevice".localized()
|
||
self.consentState = nil
|
||
self.showQuickDropToast(for: transfer.id)
|
||
}
|
||
#else
|
||
// If text is received, nothing is shown, as it is directly inserted into clipboard automatically
|
||
// Therefore, give a feedback dialog in this case
|
||
if transfer.type == .text {
|
||
showAlert(title: "QuickDrop", message: mainMessage)
|
||
}
|
||
#endif
|
||
}
|
||
|
||
|
||
func transferProgress(connectionID: String, progress: Double) {
|
||
|
||
// Update process dictionary
|
||
processes[connectionID] = progress
|
||
|
||
// Calcualate average value for all ongoing transfers
|
||
let totalProgress = processes.values.reduce(0, +)
|
||
let averageProgress = totalProgress / Double(processes.count)
|
||
|
||
#if os(iOS)
|
||
ProgressAlert.shared.updateProgress(averageProgress, onCancel: {
|
||
NearbyConnectionManager.shared.cancelTransfer(id: connectionID)
|
||
}, completion: {})
|
||
#else
|
||
DispatchQueue.main.async {
|
||
self.toastActions = nil
|
||
self.progress = averageProgress
|
||
self.showQuickDropToast(for: connectionID)
|
||
}
|
||
#endif
|
||
}
|
||
|
||
|
||
func connectionWasTerminated(connectionID: String, from device: RemoteDeviceInfo?, savedFiles: [URL], wasPlainTextTransfer: Bool, error: (any Error)?) {
|
||
|
||
processes.removeValue(forKey: connectionID)
|
||
|
||
#if os(macOS)
|
||
DispatchQueue.main.async {
|
||
let wasPendingConsent = self.consentState?.transferID == connectionID
|
||
if self.processes.isEmpty {
|
||
self.progress = nil
|
||
}
|
||
if wasPendingConsent {
|
||
self.consentState = nil
|
||
self.toastActions = nil
|
||
self.hideQuickDropToast()
|
||
}
|
||
finishMacTermination(device: device, savedFiles: savedFiles, error: error, wasPendingConsent: wasPendingConsent)
|
||
}
|
||
#else
|
||
if self.processes.isEmpty {
|
||
ProgressAlert.shared.updateProgress(nil, onCancel: {}) {
|
||
finish()
|
||
}
|
||
}
|
||
#endif
|
||
|
||
func finish() {
|
||
if let error = error {
|
||
if let name = device?.name {
|
||
|
||
#if os(macOS)
|
||
DispatchQueue.main.async {
|
||
self.hideQuickDropToast()
|
||
}
|
||
#endif
|
||
|
||
controlPlusScreen(false)
|
||
|
||
errorVibration()
|
||
ErrorAlertHandler.shared.showErrorAlert(for: name, error: error)
|
||
}
|
||
} else {
|
||
|
||
#if os(iOS)
|
||
doubleVibration()
|
||
if !savedFiles.isEmpty {
|
||
|
||
let hasPhotoOrVideos = PhotoManager.hasPhotosOrVideos(at: savedFiles)
|
||
let photoSaveAction: (() -> ())? = hasPhotoOrVideos ? {
|
||
Task {
|
||
do {
|
||
try await PhotoManager.saveMediaToPhotoLibrary(from: savedFiles)
|
||
}
|
||
catch {
|
||
showAlert(title: "CouldNotSaveMediaToPhotoLibrary", message: error.localizedDescription)
|
||
}
|
||
}
|
||
} : nil
|
||
|
||
ProgressAlert.shared.presentIncomingTransferDoneAlert(title: "FileTransferCompleted".localized(), message: "FileTransferCompletedMessage".localized(), onImportToPhotos: photoSaveAction)
|
||
}
|
||
|
||
#endif
|
||
|
||
let currentCount = Settings.sharedInstance.incomingTransmissionCount
|
||
|
||
#if os(macOS)
|
||
|
||
let completionKey: String
|
||
let autoHideDelay: TimeInterval
|
||
|
||
if !savedFiles.isEmpty {
|
||
completionKey = "Saved"
|
||
autoHideDelay = 10
|
||
} else if wasPlainTextTransfer {
|
||
completionKey = "CopiedToClipboard"
|
||
autoHideDelay = 10
|
||
} else {
|
||
completionKey = "URLOpened"
|
||
autoHideDelay = 4
|
||
}
|
||
|
||
if currentCount == 0 {
|
||
pendingReview = true
|
||
}
|
||
|
||
let openFilesAction: (() -> ())? = savedFiles.isEmpty ? nil : {
|
||
log("[SaveFilesManager] Opening \(savedFiles.count) file(s) in Finder.")
|
||
NSWorkspace.shared.activateFileViewerSelecting(savedFiles)
|
||
showReviewIfAppropriate(currentTransmissionCount: currentCount)
|
||
}
|
||
|
||
let hasPhotoOrVideos = PhotoManager.hasPhotosOrVideos(at: savedFiles)
|
||
let importPhotosAction: (()->())? = hasPhotoOrVideos ? {
|
||
Task {
|
||
do {
|
||
try await PhotoManager.saveMediaToPhotoLibrary(from: savedFiles)
|
||
showReviewIfAppropriate(currentTransmissionCount: currentCount)
|
||
}
|
||
catch {
|
||
DispatchQueue.main.async {
|
||
let alert = NSAlert()
|
||
alert.alertStyle = .critical
|
||
alert.messageText = "CouldNotSaveMediaToPhotoLibrary".localized()
|
||
alert.informativeText = error.localizedDescription
|
||
alert.addButton(withTitle: "CloseAlert".localized())
|
||
|
||
alert.runModal()
|
||
}
|
||
}
|
||
}
|
||
} : nil
|
||
|
||
let closeToastAction = {
|
||
self.hideQuickDropToast()
|
||
showReviewIfAppropriate(currentTransmissionCount: currentCount)
|
||
}
|
||
|
||
DispatchQueue.main.async {
|
||
withAnimation {
|
||
self.toastActions = ToastViewAction(completionMessageKey: completionKey, autoHideDelay: autoHideDelay, openFilesAction: openFilesAction, importPhotosAction: importPhotosAction, closeToastAction: closeToastAction)
|
||
}
|
||
|
||
// Show received files if wanted
|
||
if Settings.sharedInstance.openFinderAfterReceiving {
|
||
self.toastActions?.openFilesAction?()
|
||
}
|
||
}
|
||
#endif
|
||
|
||
Settings.sharedInstance.incomingTransmissionCount = currentCount + 1
|
||
log("[ReceiveModel] Successful transmission. Current count: \(currentCount)")
|
||
}
|
||
}
|
||
|
||
|
||
#if os(macOS)
|
||
func finishMacTermination(device: RemoteDeviceInfo?, savedFiles: [URL], error: (any Error)?, wasPendingConsent: Bool) {
|
||
if wasPendingConsent {
|
||
return
|
||
}
|
||
|
||
if let error = error {
|
||
if let name = device?.name {
|
||
self.hideQuickDropToast()
|
||
|
||
controlPlusScreen(false)
|
||
|
||
errorVibration()
|
||
ErrorAlertHandler.shared.showErrorAlert(for: name, error: error)
|
||
}
|
||
return
|
||
}
|
||
|
||
let currentCount = Settings.sharedInstance.incomingTransmissionCount
|
||
let completionKey: String
|
||
let autoHideDelay: TimeInterval
|
||
|
||
if !savedFiles.isEmpty {
|
||
completionKey = "Saved"
|
||
autoHideDelay = 10
|
||
} else if wasPlainTextTransfer {
|
||
completionKey = "CopiedToClipboard"
|
||
autoHideDelay = 10
|
||
} else {
|
||
completionKey = "URLOpened"
|
||
autoHideDelay = 4
|
||
}
|
||
|
||
if currentCount == 0 {
|
||
pendingReview = true
|
||
}
|
||
|
||
let openFilesAction: (() -> ())? = savedFiles.isEmpty ? nil : {
|
||
log("[SaveFilesManager] Opening \(savedFiles.count) file(s) in Finder.")
|
||
NSWorkspace.shared.activateFileViewerSelecting(savedFiles)
|
||
showReviewIfAppropriate(currentTransmissionCount: currentCount)
|
||
}
|
||
|
||
let hasPhotoOrVideos = PhotoManager.hasPhotosOrVideos(at: savedFiles)
|
||
let importPhotosAction: (()->())? = hasPhotoOrVideos ? {
|
||
Task {
|
||
do {
|
||
try await PhotoManager.saveMediaToPhotoLibrary(from: savedFiles)
|
||
showReviewIfAppropriate(currentTransmissionCount: currentCount)
|
||
}
|
||
catch {
|
||
DispatchQueue.main.async {
|
||
let alert = NSAlert()
|
||
alert.alertStyle = .critical
|
||
alert.messageText = "CouldNotSaveMediaToPhotoLibrary".localized()
|
||
alert.informativeText = error.localizedDescription
|
||
alert.addButton(withTitle: "CloseAlert".localized())
|
||
|
||
alert.runModal()
|
||
}
|
||
}
|
||
}
|
||
} : nil
|
||
|
||
let closeToastAction = {
|
||
self.hideQuickDropToast()
|
||
showReviewIfAppropriate(currentTransmissionCount: currentCount)
|
||
}
|
||
|
||
withAnimation {
|
||
self.toastActions = ToastViewAction(completionMessageKey: completionKey, autoHideDelay: autoHideDelay, openFilesAction: openFilesAction, importPhotosAction: importPhotosAction, closeToastAction: closeToastAction)
|
||
}
|
||
|
||
// Show received files if wanted
|
||
if Settings.sharedInstance.openFinderAfterReceiving {
|
||
self.toastActions?.openFilesAction?()
|
||
}
|
||
|
||
Settings.sharedInstance.incomingTransmissionCount = currentCount + 1
|
||
log("[ReceiveModel] Successful transmission. Current count: \(currentCount)")
|
||
}
|
||
|
||
func showReviewIfAppropriate(currentTransmissionCount: Int) {
|
||
if pendingReview {
|
||
// Dont request review again
|
||
pendingReview = false
|
||
|
||
DispatchQueue.main.asyncAfter(deadline: .now() + 1) {
|
||
SKStoreReviewController.requestReview()
|
||
}
|
||
}
|
||
}
|
||
#endif
|
||
}
|
||
|
||
|
||
func showPlusScreen() {
|
||
DispatchQueue.main.async {
|
||
#if os(macOS)
|
||
self.consentState = nil
|
||
self.toastActions = nil
|
||
self.progress = nil
|
||
self.hideQuickDropToast()
|
||
#endif
|
||
self.controlPlusScreen(true)
|
||
}
|
||
}
|
||
|
||
|
||
// MARK: - macOS Progress Overlay
|
||
|
||
#if os(macOS)
|
||
func showQuickDropToast(for connectionID: String) {
|
||
guard toastWindow == nil else { return }
|
||
|
||
let contentView = QuickDropToastView(
|
||
receiveModel: self,
|
||
onCancel: {
|
||
NearbyConnectionManager.shared.cancelTransfer(id: connectionID)
|
||
}
|
||
)
|
||
|
||
let hostingView = NSHostingView(rootView: contentView)
|
||
hostingView.frame.size = toastViewSize
|
||
|
||
// Prefer the screen under the mouse, then the key window’s screen, then main
|
||
let screen = NSScreen.screens.first { $0.frame.contains(NSEvent.mouseLocation) }
|
||
?? NSApp.keyWindow?.screen
|
||
?? NSScreen.main
|
||
|
||
guard let screen else { return }
|
||
|
||
let frame = screen.frame
|
||
let visible = screen.visibleFrame
|
||
|
||
let marginX: CGFloat = 20
|
||
let marginFromTop: CGFloat = 20
|
||
|
||
// If the menu bar is auto-hidden, visible.maxY == frame.maxY; subtract the status bar thickness to stay clear
|
||
let menuBarHidden = abs(frame.maxY - visible.maxY) < 0.5
|
||
let extraTopInset = menuBarHidden ? NSStatusBar.system.thickness : 0
|
||
|
||
let targetX = visible.maxX - toastViewSize.width - marginX
|
||
let targetY = visible.maxY - toastViewSize.height - marginFromTop - extraTopInset
|
||
|
||
// Start slightly above the final spot for a smooth slide-in
|
||
let startY = min(frame.maxY + 10, targetY + 10)
|
||
let startFrame = CGRect(x: targetX, y: startY, width: toastViewSize.width, height: toastViewSize.height)
|
||
|
||
let window = NSWindow(contentRect: startFrame,
|
||
styleMask: [.borderless],
|
||
backing: .buffered,
|
||
defer: false)
|
||
window.isOpaque = false
|
||
window.backgroundColor = .clear
|
||
window.hasShadow = true
|
||
window.level = .statusBar
|
||
window.collectionBehavior = [.canJoinAllSpaces, .fullScreenAuxiliary]
|
||
window.contentView = hostingView
|
||
window.ignoresMouseEvents = false
|
||
window.alphaValue = 0
|
||
window.makeKeyAndOrderFront(nil)
|
||
|
||
self.toastWindow = window
|
||
self.toastHosting = hostingView
|
||
|
||
NSAnimationContext.runAnimationGroup { ctx in
|
||
ctx.duration = 0.35
|
||
ctx.timingFunction = CAMediaTimingFunction(name: .easeInEaseOut)
|
||
window.animator().setFrameOrigin(CGPoint(x: targetX, y: targetY))
|
||
window.animator().alphaValue = 1
|
||
}
|
||
}
|
||
|
||
|
||
func hideQuickDropToast() {
|
||
guard let window = toastWindow,
|
||
let screen = NSScreen.main else {
|
||
self.toastWindow = nil
|
||
self.toastHosting = nil
|
||
self.toastActions = nil
|
||
self.consentState = nil
|
||
return
|
||
}
|
||
|
||
let offscreenY = screen.visibleFrame.origin.y + screen.visibleFrame.height + 20
|
||
|
||
NSAnimationContext.runAnimationGroup({ ctx in
|
||
ctx.duration = 0.35
|
||
ctx.timingFunction = CAMediaTimingFunction(name: .easeInEaseOut)
|
||
window.animator().setFrameOrigin(CGPoint(x: window.frame.origin.x, y: offscreenY))
|
||
window.animator().alphaValue = 0
|
||
}, completionHandler: {
|
||
window.orderOut(nil)
|
||
self.toastWindow = nil
|
||
self.toastHosting = nil
|
||
self.toastActions = nil
|
||
self.consentState = nil
|
||
self.activeDeviceName = nil
|
||
})
|
||
}
|
||
|
||
|
||
struct ToastViewAction {
|
||
let completionMessageKey: String
|
||
let autoHideDelay: TimeInterval
|
||
let openFilesAction: (() -> ())?
|
||
let importPhotosAction: (() -> ())?
|
||
let closeToastAction: () -> ()
|
||
}
|
||
|
||
|
||
struct ConsentToastState {
|
||
let transferID: String
|
||
let pinCodeMessage: String
|
||
let message: String
|
||
let allowsTrust: Bool
|
||
let acceptAction: (Bool) -> ()
|
||
let declineAction: () -> ()
|
||
}
|
||
#endif
|
||
}
|