// Copyright © 2020 Metabolist. All rights reserved.

import Combine
import Foundation
import ImageIO
#if canImport(UIKit)
import UIKit
#endif
import UniformTypeIdentifiers

enum MediaProcessingError: Error {
    case invalidMimeType
    case fileURLNotFound
    case imageNotFound
    case unsupportedType
    case unableToCreateImageSource
    case unableToDownsample
    case unableToCreateImageDataDestination
}

public enum MediaProcessingService {}

public extension MediaProcessingService {
    static func dataAndMimeType(itemProvider: NSItemProvider) -> AnyPublisher<(data: Data, mimeType: String), Error> {
        let registeredTypes = itemProvider.registeredTypeIdentifiers.compactMap(UTType.init)

        let mimeType: String
        let dataPublisher: AnyPublisher<Data, Error>

        if let type = registeredTypes.first(where: {
            guard let mimeType = $0.preferredMIMEType else { return false }

            return uploadableMimeTypes.contains(mimeType)
        }), let preferredMIMEType = type.preferredMIMEType {
            mimeType = preferredMIMEType
            dataPublisher = fileRepresentationDataPublisher(itemProvider: itemProvider, type: type)
        } else if registeredTypes == [UTType.image], let pngMIMEType = UTType.png.preferredMIMEType { // screenshot
            mimeType = pngMIMEType
            dataPublisher = UIImagePNGDataPublisher(itemProvider: itemProvider)
        } else {
            return Fail(error: MediaProcessingError.invalidMimeType).eraseToAnyPublisher()
        }

        return dataPublisher.map { (data: $0, mimeType: mimeType) }.eraseToAnyPublisher()
    }
}

private extension MediaProcessingService {
    static let uploadableMimeTypes = Set(
        [UTType.png,
         UTType.jpeg,
         UTType.gif,
         UTType.webP,
         UTType.mpeg4Movie,
         UTType.quickTimeMovie,
         UTType.mp3,
         UTType.wav]
            .compactMap(\.preferredMIMEType))
    static let imageSourceOptions =  [kCGImageSourceShouldCache: false] as CFDictionary
    static let thumbnailOptions = [
        kCGImageSourceCreateThumbnailFromImageAlways: true,
        kCGImageSourceCreateThumbnailWithTransform: true,
        kCGImageSourceThumbnailMaxPixelSize: 1280
    ] as CFDictionary

    static func fileRepresentationDataPublisher(itemProvider: NSItemProvider,
                                                type: UTType) -> AnyPublisher<Data, Error> {
        Future<Data, Error> { promise in
            itemProvider.loadFileRepresentation(forTypeIdentifier: type.identifier) { url, error in
                if let error = error {
                    promise(.failure(error))
                } else if let url = url {
                    promise(Result {
                        if type.conforms(to: .image) && type != .gif {
                            return try imageData(url: url, type: type)
                        } else {
                            return try Data(contentsOf: url)
                        }
                    })
                } else {
                    promise(.failure(MediaProcessingError.fileURLNotFound))
                }
            }
        }
        .eraseToAnyPublisher()
    }

    static func UIImagePNGDataPublisher(itemProvider: NSItemProvider) -> AnyPublisher<Data, Error> {
        #if canImport(UIKit)
        return Future<Data, Error> { promise in
            itemProvider.loadItem(forTypeIdentifier: UTType.image.identifier, options: nil) { item, error in
                if let error = error {
                    promise(.failure(error))
                } else if let image = item as? UIImage, let data = image.pngData() {
                    promise(Result {
                        let url = URL(fileURLWithPath: NSTemporaryDirectory(), isDirectory: true)
                            .appendingPathComponent(UUID().uuidString)

                        try data.write(to: url)

                        return try imageData(url: url, type: .png)
                    })
                } else {
                    promise(.failure(MediaProcessingError.imageNotFound))
                }
            }
        }
        .eraseToAnyPublisher()
        #else
        return Fail<Data, Error>(error: MediaProcessingError.invalidMimeType).eraseToAnyPublisher()
        #endif
    }

    static func imageData(url: URL, type: UTType) throws -> Data {
        guard let source = CGImageSourceCreateWithURL(url as CFURL, Self.imageSourceOptions) else {
            throw MediaProcessingError.unableToCreateImageSource
        }

        guard let image = CGImageSourceCreateThumbnailAtIndex(source, 0, thumbnailOptions) else {
            throw MediaProcessingError.unableToDownsample
        }

        let data = NSMutableData()

        guard let imageDestination = CGImageDestinationCreateWithData(data, type.identifier as CFString, 1, nil) else {
            throw MediaProcessingError.unableToCreateImageDataDestination
        }

        CGImageDestinationAddImage(imageDestination, image, nil)
        CGImageDestinationFinalize(imageDestination)

        return data as Data
    }
}