mastodon-app-ufficiale-ipho.../ShareActionExtension/Scene/ComposeViewModel.swift

418 lines
17 KiB
Swift

//
// ComposeViewModel.swift
// MastodonShareAction
//
// Created by MainasuK Cirno on 2021-7-16.
//
import os.log
import Foundation
import Combine
import CoreData
import CoreDataStack
import MastodonSDK
import MastodonUI
import SwiftUI
import UniformTypeIdentifiers
import MastodonAsset
import MastodonLocalization
import MastodonUI
import MastodonCore
final class ComposeViewModel {
let logger = Logger(subsystem: "ComposeViewModel", category: "ViewModel")
var disposeBag = Set<AnyCancellable>()
static let composeContentLimit: Int = 500
// input
let context: AppContext
// private var coreDataStack: CoreDataStack?
// var managedObjectContext: NSManagedObjectContext?
// var api: APIService?
//
// var inputItems = CurrentValueSubject<[NSExtensionItem], Never>([])
// let viewDidAppear = CurrentValueSubject<Bool, Never>(false)
// let traitCollectionDidChangePublisher = CurrentValueSubject<Void, Never>(Void()) // use CurrentValueSubject to make initial event emit
// let selectedStatusVisibility = CurrentValueSubject<ComposeToolbarView.VisibilitySelectionType, Never>(.public)
//
// // output
// let authentication = CurrentValueSubject<Result<MastodonAuthentication, Error>?, Never>(nil)
// let isFetchAuthentication = CurrentValueSubject<Bool, Never>(true)
// let isPublishing = CurrentValueSubject<Bool, Never>(false)
// let isBusy = CurrentValueSubject<Bool, Never>(true)
// let isValid = CurrentValueSubject<Bool, Never>(false)
// let shouldDismiss = CurrentValueSubject<Bool, Never>(true)
// let composeViewModel = ComposeViewModel()
// let characterCount = CurrentValueSubject<Int, Never>(0)
init(context: AppContext) {
self.context = context
// end init
// viewDidAppear.receive(on: DispatchQueue.main)
// .removeDuplicates()
// .sink { [weak self] viewDidAppear in
// guard let self = self else { return }
// guard viewDidAppear else { return }
// self.setupCoreData()
// }
// .store(in: &disposeBag)
//
// Publishers.CombineLatest(
// inputItems.removeDuplicates(),
// viewDidAppear.removeDuplicates()
// )
// .receive(on: DispatchQueue.main)
// .sink { [weak self] inputItems, _ in
// guard let self = self else { return }
// self.parse(inputItems: inputItems)
// }
// .store(in: &disposeBag)
//
// // bind authentication loading state
// authentication
// .map { result in result == nil }
// .assign(to: \.value, on: isFetchAuthentication)
// .store(in: &disposeBag)
//
// // bind user locked state
// authentication
// .compactMap { result -> Bool? in
// guard let result = result else { return nil }
// switch result {
// case .success(let authentication):
// return authentication.user.locked
// case .failure:
// return nil
// }
// }
// .map { locked -> ComposeToolbarView.VisibilitySelectionType in
// locked ? .private : .public
// }
// .assign(to: \.value, on: selectedStatusVisibility)
// .store(in: &disposeBag)
//
// // bind author
// authentication
// .receive(on: DispatchQueue.main)
// .sink { [weak self] result in
// guard let self = self else { return }
// guard let result = result else { return }
// switch result {
// case .success(let authentication):
// self.composeViewModel.avatarImageURL = authentication.user.avatarImageURL()
// self.composeViewModel.authorName = authentication.user.displayNameWithFallback
// self.composeViewModel.authorUsername = "@" + authentication.user.username
// case .failure:
// self.composeViewModel.avatarImageURL = nil
// self.composeViewModel.authorName = " "
// self.composeViewModel.authorUsername = " "
// }
// }
// .store(in: &disposeBag)
//
// // bind authentication to compose view model
// authentication
// .map { result -> MastodonAuthentication? in
// guard let result = result else { return nil }
// switch result {
// case .success(let authentication):
// return authentication
// case .failure:
// return nil
// }
// }
// .assign(to: &composeViewModel.$authentication)
//
// // bind isBusy
// Publishers.CombineLatest(
// isFetchAuthentication,
// isPublishing
// )
// .receive(on: DispatchQueue.main)
// .map { $0 || $1 }
// .assign(to: \.value, on: isBusy)
// .store(in: &disposeBag)
//
// // pass initial i18n string
// composeViewModel.statusPlaceholder = L10n.Scene.Compose.contentInputPlaceholder
// composeViewModel.contentWarningPlaceholder = L10n.Scene.Compose.ContentWarning.placeholder
// composeViewModel.toolbarHeight = ComposeToolbarView.toolbarHeight
//
// // bind compose bar button item UI state
// let isComposeContentEmpty = composeViewModel.$statusContent
// .map { $0.isEmpty }
//
// isComposeContentEmpty
// .assign(to: \.value, on: shouldDismiss)
// .store(in: &disposeBag)
//
// let isComposeContentValid = composeViewModel.$characterCount
// .map { characterCount -> Bool in
// return characterCount <= ShareViewModel.composeContentLimit
// }
// let isMediaEmpty = composeViewModel.$attachmentViewModels
// .map { $0.isEmpty }
// let isMediaUploadAllSuccess = composeViewModel.$attachmentViewModels
// .map { viewModels in
// viewModels.allSatisfy { $0.uploadStateMachineSubject.value is StatusAttachmentViewModel.UploadState.Finish }
// }
//
// let isPublishBarButtonItemEnabledPrecondition1 = Publishers.CombineLatest4(
// isComposeContentEmpty,
// isComposeContentValid,
// isMediaEmpty,
// isMediaUploadAllSuccess
// )
// .map { isComposeContentEmpty, isComposeContentValid, isMediaEmpty, isMediaUploadAllSuccess -> Bool in
// if isMediaEmpty {
// return isComposeContentValid && !isComposeContentEmpty
// } else {
// return isComposeContentValid && isMediaUploadAllSuccess
// }
// }
// .eraseToAnyPublisher()
//
// let isPublishBarButtonItemEnabledPrecondition2 = Publishers.CombineLatest(
// isComposeContentEmpty,
// isComposeContentValid
// )
// .map { isComposeContentEmpty, isComposeContentValid -> Bool in
// return isComposeContentValid && !isComposeContentEmpty
// }
// .eraseToAnyPublisher()
//
// Publishers.CombineLatest(
// isPublishBarButtonItemEnabledPrecondition1,
// isPublishBarButtonItemEnabledPrecondition2
// )
// .map { $0 && $1 }
// .assign(to: \.value, on: isValid)
// .store(in: &disposeBag)
//
// // bind counter
// composeViewModel.$characterCount
// .assign(to: \.value, on: characterCount)
// .store(in: &disposeBag)
//
// // setup theme
// setupBackgroundColor(theme: ThemeService.shared.currentTheme.value)
// ThemeService.shared.currentTheme
// .receive(on: DispatchQueue.main)
// .sink { [weak self] theme in
// guard let self = self else { return }
// self.setupBackgroundColor(theme: theme)
// }
// .store(in: &disposeBag)
}
private func setupBackgroundColor(theme: Theme) {
// composeViewModel.contentWarningBackgroundColor = Color(theme.contentWarningOverlayBackgroundColor)
}
}
//extension ShareViewModel {
// enum ShareError: Error {
// case `internal`(error: Error)
// case userCancelShare
// case missingAuthentication
// }
//}
extension ComposeViewModel {
// private func setupCoreData() {
// logger.debug("\((#file as NSString).lastPathComponent, privacy: .public)[\(#line, privacy: .public)], \(#function, privacy: .public)")
// DispatchQueue.global().async {
// let _coreDataStack = CoreDataStack()
// self.coreDataStack = _coreDataStack
// self.managedObjectContext = _coreDataStack.persistentContainer.viewContext
//
// _coreDataStack.didFinishLoad
// .receive(on: RunLoop.main)
// .sink { [weak self] didFinishLoad in
// guard let self = self else { return }
// guard didFinishLoad else { return }
// guard let managedObjectContext = self.managedObjectContext else { return }
//
//
// self.api = APIService(backgroundManagedObjectContext: _coreDataStack.newTaskContext())
//
// self.logger.debug("\((#file as NSString).lastPathComponent, privacy: .public)[\(#line, privacy: .public)], \(#function, privacy: .public): fetch authentication")
// managedObjectContext.perform {
// do {
// let request = MastodonAuthentication.sortedFetchRequest
// let authentications = try managedObjectContext.fetch(request)
// let authentication = authentications.sorted(by: { $0.activedAt > $1.activedAt }).first
// guard let activeAuthentication = authentication else {
// self.authentication.value = .failure(ShareError.missingAuthentication)
// return
// }
// self.authentication.value = .success(activeAuthentication)
// self.logger.debug("\((#file as NSString).lastPathComponent, privacy: .public)[\(#line, privacy: .public)], \(#function, privacy: .public): fetch authentication success \(activeAuthentication.userID)")
// } catch {
// self.authentication.value = .failure(ShareError.internal(error: error))
// self.logger.debug("\((#file as NSString).lastPathComponent, privacy: .public)[\(#line, privacy: .public)], \(#function, privacy: .public): fetch authentication fail \(error.localizedDescription)")
// assertionFailure(error.localizedDescription)
// }
// }
// }
// .store(in: &self.disposeBag)
// }
// }
}
//extension ShareViewModel {
// func parse(inputItems: [NSExtensionItem]) {
// var itemProviders: [NSItemProvider] = []
//
// for item in inputItems {
// itemProviders.append(contentsOf: item.attachments ?? [])
// }
//
// let _textProvider = itemProviders.first { provider in
// return provider.hasRepresentationConforming(toTypeIdentifier: UTType.plainText.identifier, fileOptions: [])
// }
//
// let _urlProvider = itemProviders.first { provider in
// return provider.hasRepresentationConforming(toTypeIdentifier: UTType.url.identifier, fileOptions: [])
// }
//
// let _movieProvider = itemProviders.first { provider in
// return provider.hasRepresentationConforming(toTypeIdentifier: UTType.movie.identifier, fileOptions: [])
// }
//
// let imageProviders = itemProviders.filter { provider in
// return provider.hasRepresentationConforming(toTypeIdentifier: UTType.image.identifier, fileOptions: [])
// }
//
// Task { @MainActor in
// async let text = ShareViewModel.loadText(textProvider: _textProvider)
// async let url = ShareViewModel.loadURL(textProvider: _urlProvider)
//
// let content = await [text, url]
// .compactMap { $0 }
// .joined(separator: " ")
// self.composeViewModel.statusContent = content
// }
//
// guard let api = self.api else { return }
//
// if let movieProvider = _movieProvider {
// composeViewModel.setupAttachmentViewModels([
// StatusAttachmentViewModel(api: api, itemProvider: movieProvider)
// ])
// } else if !imageProviders.isEmpty {
// let viewModels = imageProviders.map { provider in
// StatusAttachmentViewModel(api: api, itemProvider: provider)
// }
// composeViewModel.setupAttachmentViewModels(viewModels)
// }
//
// }
//
// private static func loadText(textProvider: NSItemProvider?) async -> String? {
// guard let textProvider = textProvider else { return nil }
// do {
// let item = try await textProvider.loadItem(forTypeIdentifier: UTType.plainText.identifier)
// guard let text = item as? String else { return nil }
// return text
// } catch {
// return nil
// }
// }
//
// private static func loadURL(textProvider: NSItemProvider?) async -> String? {
// guard let textProvider = textProvider else { return nil }
// do {
// let item = try await textProvider.loadItem(forTypeIdentifier: UTType.url.identifier)
// guard let url = item as? URL else { return nil }
// return url.absoluteString
// } catch {
// return nil
// }
// }
//
//}
//
//extension ShareViewModel {
// func publish() -> AnyPublisher<Mastodon.Response.Content<Mastodon.Entity.Status>, Error> {
// guard let authentication = composeViewModel.authentication,
// let api = self.api
// else {
// return Fail(error: APIService.APIError.implicit(.authenticationMissing)).eraseToAnyPublisher()
// }
// let authenticationBox = MastodonAuthenticationBox(
// authenticationRecord: .init(objectID: authentication.objectID),
// domain: authentication.domain,
// userID: authentication.userID,
// appAuthorization: Mastodon.API.OAuth.Authorization(accessToken: authentication.appAccessToken),
// userAuthorization: Mastodon.API.OAuth.Authorization(accessToken: authentication.userAccessToken)
// )
//
// let domain = authentication.domain
// let attachmentViewModels = composeViewModel.attachmentViewModels
// let mediaIDs = attachmentViewModels.compactMap { viewModel in
// viewModel.attachment.value?.id
// }
// let sensitive: Bool = composeViewModel.isContentWarningComposing
// let spoilerText: String? = {
// let text = composeViewModel.contentWarningContent
// guard !text.isEmpty else { return nil }
// return text
// }()
// let visibility = selectedStatusVisibility.value.visibility
//
// let updateMediaQuerySubscriptions: [AnyPublisher<Mastodon.Response.Content<Mastodon.Entity.Attachment>, Error>] = {
// var subscriptions: [AnyPublisher<Mastodon.Response.Content<Mastodon.Entity.Attachment>, Error>] = []
// for attachmentViewModel in attachmentViewModels {
// guard let attachmentID = attachmentViewModel.attachment.value?.id else { continue }
// let description = attachmentViewModel.descriptionContent.trimmingCharacters(in: .whitespacesAndNewlines)
// guard !description.isEmpty else { continue }
// let query = Mastodon.API.Media.UpdateMediaQuery(
// file: nil,
// thumbnail: nil,
// description: description,
// focus: nil
// )
// let subscription = api.updateMedia(
// domain: domain,
// attachmentID: attachmentID,
// query: query,
// mastodonAuthenticationBox: authenticationBox
// )
// subscriptions.append(subscription)
// }
// return subscriptions
// }()
//
// let status = composeViewModel.statusContent
//
// return Publishers.MergeMany(updateMediaQuerySubscriptions)
// .collect()
// .asyncMap { attachments in
// let query = Mastodon.API.Statuses.PublishStatusQuery(
// status: status,
// mediaIDs: mediaIDs.isEmpty ? nil : mediaIDs,
// pollOptions: nil,
// pollExpiresIn: nil,
// inReplyToID: nil,
// sensitive: sensitive,
// spoilerText: spoilerText,
// visibility: visibility
// )
// return try await api.publishStatus(
// domain: domain,
// idempotencyKey: nil, // FIXME:
// query: query,
// authenticationBox: authenticationBox
// )
// }
// .eraseToAnyPublisher()
// }
//}