NetNewsWire/Shared/Article Extractor/ArticleExtractor.swift

113 lines
2.9 KiB
Swift
Raw Normal View History

2019-09-19 01:15:55 +02:00
//
// ArticleExtractor.swift
// NetNewsWire
//
// Created by Maurice Parker on 9/18/19.
// Copyright © 2019 Ranchero Software. All rights reserved.
//
import Foundation
import Account
2020-04-10 04:07:56 +02:00
import Secrets
2019-09-19 01:15:55 +02:00
public enum ArticleExtractorState {
case ready
case processing
case failedToParse
case complete
case cancelled
2019-09-19 01:15:55 +02:00
}
protocol ArticleExtractorDelegate {
2024-03-20 07:05:30 +01:00
@MainActor func articleExtractionDidFail(with: Error)
@MainActor func articleExtractionDidComplete(extractedArticle: ExtractedArticle)
2019-09-19 01:15:55 +02:00
}
2024-03-20 07:05:30 +01:00
final class ArticleExtractor {
private var dataTask: URLSessionDataTask? = nil
2019-09-19 01:15:55 +02:00
var state: ArticleExtractorState!
var article: ExtractedArticle?
var delegate: ArticleExtractorDelegate?
var articleLink: String?
private var url: URL!
public init?(_ articleLink: String, secretsProvider: SecretsProvider) {
2019-09-19 01:15:55 +02:00
self.articleLink = articleLink
let clientURL = "https://extract.feedbin.com/parser"
let username = secretsProvider.mercuryClientId
let signature = articleLink.hmacUsingSHA1(key: secretsProvider.mercuryClientSecret)
2019-09-19 01:15:55 +02:00
if let base64URL = articleLink.data(using: .utf8)?.base64EncodedString() {
let fullURL = "\(clientURL)/\(username)/\(signature)?base64_url=\(base64URL)"
2019-09-19 01:15:55 +02:00
if let url = URL(string: fullURL) {
self.url = url
return
}
}
return nil
}
public func process() {
state = .processing
dataTask = URLSession.shared.dataTask(with: url) { [weak self] data, response, error in
2019-09-19 01:15:55 +02:00
guard let self = self else { return }
if let error = error {
self.state = .failedToParse
DispatchQueue.main.async {
self.delegate?.articleExtractionDidFail(with: error)
}
return
}
guard let data = data else {
self.state = .failedToParse
DispatchQueue.main.async {
self.delegate?.articleExtractionDidFail(with: URLError(.cannotDecodeContentData))
2019-09-19 01:15:55 +02:00
}
return
}
do {
let decoder = JSONDecoder()
decoder.dateDecodingStrategy = .iso8601
self.article = try decoder.decode(ExtractedArticle.self, from: data)
DispatchQueue.main.async {
if self.article?.content == nil {
self.state = .failedToParse
self.delegate?.articleExtractionDidFail(with: URLError(.cannotDecodeContentData))
} else {
self.state = .complete
self.delegate?.articleExtractionDidComplete(extractedArticle: self.article!)
}
2019-09-19 01:15:55 +02:00
}
} catch {
self.state = .failedToParse
DispatchQueue.main.async {
self.delegate?.articleExtractionDidFail(with: error)
}
}
}
dataTask!.resume()
2019-09-19 01:15:55 +02:00
}
public func cancel() {
state = .cancelled
dataTask?.cancel()
}
2019-09-19 01:15:55 +02:00
}