feat(swift-ios): share into durable composer drafts

apps/swift-ios/App/Platform/PlatformRootView.swift

@@ -1,5 +1,28 @@
 import SwiftUI
 
+@MainActor
+final class PlatformIncomingShareRoutingGate {
+ private var isRouting = false
+ private var pendingOperation: (@MainActor () async -> Void)?
+
+ func request(_ operation: @escaping @MainActor () async -> Void) async {
+ pendingOperation = operation
+ guard !isRouting else { return }
+ isRouting = true
+ while let operation = pendingOperation {
+ pendingOperation = nil
+ await operation()
+ }
+ isRouting = false
+ }
+}
+
+enum PlatformIncomingShareDestinationConnectionPolicy {
+ static func canResolveThread(connectionState: FeatureConnection.State?) -> Bool {
+ connectionState == .connected
+ }
+}
+
 struct PlatformRootView: View {
  @SwiftUI.Environment(\.scenePhase) private var scenePhase
  @Bindable private var model: FeatureRootModel
@@ -11,6 +34,8 @@ struct PlatformRootView: View {
  @State private var incomingShareCoordinator = PlatformIncomingShareCoordinator()
  @State private var incomingShareNeedsProject = false
  @State private var importedShareProjectID: String?
+ @State private var stagedIncomingShareID: String?
+ @State private var incomingShareRoutingGate = PlatformIncomingShareRoutingGate()
  @State private var recentThreadsPersistenceTask: Task<Void, Never>?
 
  init(model: FeatureRootModel) {
@@ -24,6 +49,15 @@ struct PlatformRootView: View {
  onNavigationRequestConsumed: { requestID in
  guard navigationRequest?.id == requestID else { return }
  navigationRequest = nil
+ },
+ acknowledgeIncomingShare: { shareID in
+ await acknowledgeStagedIncomingShare(id: shareID)
+ },
+ releaseIncomingSharePresentation: { shareID in
+ if stagedIncomingShareID?.caseInsensitiveCompare(shareID) == .orderedSame {
+ stagedIncomingShareID = nil
+ incomingShareCoordinator.dismissStagedNewThread(id: shareID)
+ }
  }
  )
  .onOpenURL { url in
@@ -68,9 +102,19 @@ struct PlatformRootView: View {
  synchronizeAgentAwareness()
  synchronizeCloudDelivery()
  }
+ .onChange(of: model.snapshot.settings.appearance, initial: true) { _, appearance in
+ T3SharedAppearanceStore.shared.update(appearance.sharedAppearance)
+ }
  .onChange(of: model.snapshot.projects.map(\.id)) { _, _ in
  refreshIncomingShares()
  }
+ .onChange(of: incomingShareConnectionStates) { _, _ in
+ guard incomingShareCoordinator.pendingEnvelope?.destination?.kind == .existingThread,
+ !incomingShareCoordinator.isImporting else { return }
+ Task { @MainActor in
+ await routePendingIncomingShareIfNeeded()
+ }
+ }
  .sheet(item: presentedIncomingShare, onDismiss: openImportedShareDraft) { envelope in
  PlatformIncomingShareDestinationSheet(
  envelope: envelope,
@@ -106,6 +150,9 @@ struct PlatformRootView: View {
  Binding(
  get: {
  guard !incomingShareProjects.isEmpty else { return nil }
+ guard incomingShareCoordinator.pendingEnvelope?.destination == nil else {
+ return nil
+ }
  return incomingShareCoordinator.pendingEnvelope
  },
  set: { value in
@@ -190,13 +237,101 @@ struct PlatformRootView: View {
  )
  }
 
- private func refreshIncomingShares() {
+ private func refreshIncomingShares(preferredID: String? = nil) {
  guard !model.isLoading else { return }
  let hasProjects = !incomingShareProjects.isEmpty
  Task { @MainActor in
- if await incomingShareCoordinator.refresh(hasProjects: hasProjects) {
+ if await incomingShareCoordinator.refresh(
+ preferredID: preferredID,
+ hasProjects: hasProjects
+ ) {
  incomingShareNeedsProject = true
  }
+ await routePendingIncomingShareIfNeeded()
+ }
+ }
+
+ @MainActor
+ private func routePendingIncomingShareIfNeeded() async {
+ await incomingShareRoutingGate.request {
+ await performPendingIncomingShareRoute()
+ }
+ }
+
+ private func performPendingIncomingShareRoute() async {
+ guard let envelope = incomingShareCoordinator.pendingEnvelope,
+ let destination = envelope.destination,
+ stagedIncomingShareID != envelope.id else { return }
+ do {
+ switch destination.kind {
+ case .newThread:
+ guard let shareID = try await incomingShareCoordinator.stagePendingForNewThread()
+ else { return }
+ stagedIncomingShareID = shareID
+ navigationRequest = FeatureWorkspaceNavigationRequest(
+ destination: .sharedNewTask(shareID: shareID)
+ )
+ case .existingThread:
+ guard let threadID = destination.threadID else {
+ try await incomingShareCoordinator.requestAnotherDestination()
+ model.errorMessage = "That thread is no longer available. Choose another destination."
+ return
+ }
+ if let environmentID = destination.environmentID,
+ !model.snapshot.environments.contains(where: { $0.id == environmentID }) {
+ try await incomingShareCoordinator.requestAnotherDestination()
+ model.errorMessage = "That thread's environment is no longer saved. Choose another destination."
+ return
+ }
+ guard await enableEnvironmentIfNeeded(destination.environmentID) else {
+ // Keep the saved destination so a temporarily unavailable
+ // environment can retry when its connection recovers.
+ return
+ }
+ guard incomingShareDestinationIsConnected(destination.environmentID) else {
+ // A disconnected snapshot cannot authoritatively prove that
+ // the saved thread disappeared. Keep it queued for retry.
+ return
+ }
+ guard let thread = PlatformRouteResolver.thread(
+ in: model.snapshot,
+ environmentID: destination.environmentID,
+ id: threadID
+ ) else {
+ try await incomingShareCoordinator.requestAnotherDestination()
+ model.errorMessage = "That thread is no longer available. Choose another destination."
+ return
+ }
+ guard let imported = try await incomingShareCoordinator.importPending(
+ into: thread
+ ) else { return }
+ navigationRequest = FeatureWorkspaceNavigationRequest(
+ destination: .sharedThread(
+ id: thread.id,
+ importDraft: imported.sharedContent
+ )
+ )
+ }
+ PlatformHapticEngine.shared.emit(
+ .success,
+ enabled: model.snapshot.settings.hapticsEnabled
+ )
+ } catch {
+ model.errorMessage = error.localizedDescription
+ }
+ }
+
+ @MainActor
+ private func acknowledgeStagedIncomingShare(id: String) async -> Bool {
+ do {
+ try await incomingShareCoordinator.acknowledgeStagedNewThread(id: id)
+ if stagedIncomingShareID?.caseInsensitiveCompare(id) == .orderedSame {
+ stagedIncomingShareID = nil
+ }
+ return true
+ } catch {
+ model.errorMessage = error.localizedDescription
+ return false
  }
  }
 
@@ -307,6 +442,20 @@ struct PlatformRootView: View {
  return await model.setEnvironmentEnabled(id, enabled: true)
  }
 
+ private func incomingShareDestinationIsConnected(_ id: String?) -> Bool {
+ let state = id.flatMap { environmentID in
+ model.snapshot.environments.first(where: { $0.id == environmentID })?.connectionState
+ } ?? (id == nil ? model.snapshot.connection.state : nil)
+ return PlatformIncomingShareDestinationConnectionPolicy.canResolveThread(
+ connectionState: state
+ )
+ }
+
+ private var incomingShareConnectionStates: [FeatureConnection.State?] {
+ [model.snapshot.connection.state]
+ + model.snapshot.environments.map(\.connectionState)
+ }
+
  /// Home revisions are coalesced by FeatureRootModel, so this performs one
  /// bounded scan per meaningful snapshot change rather than on every render.
  private func processThreadChanges() {
@@ -345,3 +494,13 @@ struct PlatformRootView: View {
  )
  }
 }
+
+private extension FeatureAppearance {
+ var sharedAppearance: T3SharedAppearance {
+ switch self {
+ case .system: .system
+ case .light: .light
+ case .dark: .dark
+ }
+ }
+}

apps/swift-ios/App/Platform/PlatformShortcuts.swift

@@ -1,25 +1,16 @@
 import AppIntents
 import Foundation
 
-struct PlatformRecentThreadRecord: Codable, Equatable, Sendable {
- let id: String
- let environmentID: String?
- let wireID: String
- let title: String
- let environmentName: String?
- let updatedAt: Date
-}
-
 final class PlatformRecentThreadStore: @unchecked Sendable {
  static let shared = PlatformRecentThreadStore()
 
- private let defaults: UserDefaults
- private let key: String
- private let lock = NSLock()
+ private let sharedStore: T3SharedRecentThreadStore
 
- init(defaults: UserDefaults = .standard, key: String = "swift-ios.recent-threads.v1") {
- self.defaults = defaults
- self.key = key
+ init(
+ defaults: UserDefaults? = UserDefaults(suiteName: T3SharedContainer.appGroupID),
+ key: String = "swift-ios.shared-recent-threads.v1"
+ ) {
+ sharedStore = T3SharedRecentThreadStore(defaults: defaults, key: key)
  }
 
  func update(from threads: [FeatureThread]) {
@@ -29,9 +20,9 @@ final class PlatformRecentThreadStore: @unchecked Sendable {
  if lhs.updatedAt != rhs.updatedAt { return lhs.updatedAt > rhs.updatedAt }
  return lhs.id < rhs.id
  }
- .prefix(12)
+ .prefix(T3SharedRecentThreadStore.maximumCount)
  .map {
-PlatformRecentThreadRecord(
+T3SharedRecentThreadRecord(
  id: $0.id,
  environmentID: $0.environmentID,
  wireID: $0.wireID ?? $0.id,
@@ -40,16 +31,11 @@ final class PlatformRecentThreadStore: @unchecked Sendable {
  updatedAt: $0.updatedAt
  )
  }
- lock.withLock {
- defaults.set(try? JSONEncoder().encode(records), forKey: key)
- }
+ sharedStore.update(records)
  }
 
- func records() -> [PlatformRecentThreadRecord] {
- lock.withLock {
- guard let data = defaults.data(forKey: key) else { return [] }
- return (try? JSONDecoder().decode([PlatformRecentThreadRecord].self, from: data)) ?? []
- }
+ func records() -> [T3SharedRecentThreadRecord] {
+ sharedStore.records()
  }
 }
 
@@ -70,7 +56,7 @@ struct PlatformRecentThreadEntity: AppEntity {
  )
  }
 
- init(record: PlatformRecentThreadRecord) {
+ init(record: T3SharedRecentThreadRecord) {
  id = record.id
  environmentID = record.environmentID
  wireID = record.wireID
@@ -88,7 +74,9 @@ struct PlatformRecentThreadQuery: EntityQuery {
  }
 
  func suggestedEntities() async throws -> [PlatformRecentThreadEntity] {
- PlatformRecentThreadStore.shared.records().map(PlatformRecentThreadEntity.init)
+ PlatformRecentThreadStore.shared.records()
+ .prefix(12)
+ .map(PlatformRecentThreadEntity.init)
  }
 }
 

apps/swift-ios/Extensions/Share/Info.plist

@@ -4,6 +4,8 @@
 <dict>
 	<key>CFBundleDisplayName</key>
 	<string>$(T3CODE_SHARE_DISPLAY_NAME)</string>
+	<key>T3CodeAppGroupIdentifier</key>
+	<string>$(T3CODE_APP_GROUP_IDENTIFIER)</string>
 	<key>NSExtension</key>
 	<dict>
  <key>NSExtensionAttributes</key>
@@ -14,6 +16,8 @@
  <integer>2</integer>
  <key>NSExtensionActivationSupportsImageWithMaxCount</key>
  <integer>8</integer>
+ <key>NSExtensionActivationSupportsMovieWithMaxCount</key>
+ <integer>1</integer>
  <key>NSExtensionActivationSupportsText</key>
  <true/>
  <key>NSExtensionActivationSupportsWebURLWithMaxCount</key>