Make Feedbin a separate module.

This commit is contained in:
Brent Simmons
2023-09-02 11:27:15 -07:00
parent fa33971fea
commit 9d362c8262
19 changed files with 364 additions and 174 deletions

View File

@@ -1,48 +1,35 @@
// swift-tools-version:5.7.1
import PackageDescription
var dependencies: [Package.Dependency] = [
.package(url: "https://github.com/Ranchero-Software/RSCore.git", .upToNextMajor(from: "2.0.1")),
.package(url: "https://github.com/Ranchero-Software/RSDatabase.git", .upToNextMajor(from: "2.0.0")),
.package(url: "https://github.com/Ranchero-Software/RSParser.git", .upToNextMajor(from: "2.0.2")),
.package(url: "https://github.com/Ranchero-Software/RSWeb.git", .upToNextMajor(from: "1.0.0")),
]
#if swift(>=5.6)
dependencies.append(contentsOf: [
.package(path: "../AccountError"),
.package(path: "../Articles"),
.package(path: "../ArticlesDatabase"),
.package(path: "../FeedFinder"),
.package(path: "../Secrets"),
.package(path: "../SyncDatabase"),
.package(path: "../SyncClients/NewsBlur"),
.package(path: "../SyncClients/ReaderAPI"),
])
#else
dependencies.append(contentsOf: [
.package(url: "../Articles", .upToNextMajor(from: "1.0.0")),
.package(url: "../ArticlesDatabase", .upToNextMajor(from: "1.0.0")),
.package(url: "../Secrets", .upToNextMajor(from: "1.0.0")),
.package(url: "../SyncDatabase", .upToNextMajor(from: "1.0.0")),
])
#endif
let package = Package(
name: "Account",
defaultLocalization: "en",
name: "Account",
defaultLocalization: "en",
platforms: [.macOS(.v13), .iOS(.v16)],
products: [
.library(
name: "Account",
products: [
.library(
name: "Account",
type: .dynamic,
targets: ["Account"]),
],
dependencies: dependencies,
targets: [
.target(
name: "Account",
dependencies: [
targets: ["Account"]),
],
dependencies: [
.package(url: "https://github.com/Ranchero-Software/RSCore.git", .upToNextMajor(from: "2.0.1")),
.package(url: "https://github.com/Ranchero-Software/RSDatabase.git", .upToNextMajor(from: "2.0.0")),
.package(url: "https://github.com/Ranchero-Software/RSParser.git", .upToNextMajor(from: "2.0.2")),
.package(url: "https://github.com/Ranchero-Software/RSWeb.git", .upToNextMajor(from: "1.0.0")),
.package(path: "../AccountError"),
.package(path: "../Articles"),
.package(path: "../ArticlesDatabase"),
.package(path: "../FeedFinder"),
.package(path: "../Secrets"),
.package(path: "../SyncDatabase"),
.package(path: "../SyncClients/NewsBlur"),
.package(path: "../SyncClients/ReaderAPI"),
.package(path: "../SyncClients/Feedbin"),
],
targets: [
.target(
name: "Account",
dependencies: [
"RSCore",
"RSDatabase",
"RSParser",
@@ -54,16 +41,17 @@ let package = Package(
"Secrets",
"SyncDatabase",
"NewsBlur",
"ReaderAPI"
"ReaderAPI",
"Feedbin"
],
linkerSettings: [
.unsafeFlags(["-Xlinker", "-no_application_extension"])
]),
.testTarget(
name: "AccountTests",
dependencies: ["Account"],
linkerSettings: [
.unsafeFlags(["-Xlinker", "-no_application_extension"])
]),
.testTarget(
name: "AccountTests",
dependencies: ["Account"],
resources: [
.copy("JSON"),
]),
]
]
)

View File

@@ -15,6 +15,7 @@ import RSWeb
import SyncDatabase
import Secrets
import FeedFinder
import Feedbin
public enum FeedbinAccountDelegateError: String, Error {
case invalidParameter = "There was an invalid parameter passed."
@@ -37,25 +38,20 @@ public enum FeedbinAccountDelegateError: String, Error {
}
}
weak var accountMetadata: AccountMetadata? {
didSet {
caller.accountMetadata = accountMetadata
}
}
weak var accountMetadata: AccountMetadata?
var refreshProgress = DownloadProgress(numberOfTasks: 0)
init(dataFolder: String, transport: Transport?) {
let databaseFilePath = (dataFolder as NSString).appendingPathComponent("Sync.sqlite3")
database = SyncDatabase(databaseFilePath: databaseFilePath)
self.database = SyncDatabase(databaseFilePath: databaseFilePath)
if transport != nil {
caller = FeedbinAPICaller(transport: transport!)
self.caller = FeedbinAPICaller(transport: transport!)
} else {
let sessionConfiguration = URLSessionConfiguration.default
sessionConfiguration.requestCachePolicy = .reloadIgnoringLocalCacheData
sessionConfiguration.timeoutIntervalForRequest = 60.0
@@ -69,10 +65,10 @@ public enum FeedbinAccountDelegateError: String, Error {
sessionConfiguration.httpAdditionalHeaders = userAgentHeaders
}
caller = FeedbinAPICaller(transport: URLSession(configuration: sessionConfiguration))
self.caller = FeedbinAPICaller(transport: URLSession(configuration: sessionConfiguration))
}
self.caller.delegate = self
}
func receiveRemoteNotification(for account: Account, userInfo: [AnyHashable : Any], completion: @escaping () -> Void) {
@@ -647,7 +643,37 @@ public enum FeedbinAccountDelegateError: String, Error {
}
}
// MARK: Private
// MARK: - FeedbinAPICallerDelegate
extension FeedbinAccountDelegate: FeedbinAPICallerDelegate {
var lastArticleFetchStartTime: Date? {
accountMetadata?.lastArticleFetchStartTime
}
func conditionalGetInfo(key: String) -> HTTPConditionalGetInfo? {
accountMetadata?.conditionalGetInfo[key]
}
func setConditionalGetInfo(_ info: HTTPConditionalGetInfo, forKey key: String) {
if var conditionalGetInfo = accountMetadata?.conditionalGetInfo {
conditionalGetInfo[key] = info
}
else {
var conditionalGetInfo = [String: HTTPConditionalGetInfo]()
conditionalGetInfo[key] = info
accountMetadata?.conditionalGetInfo = conditionalGetInfo
}
}
func createURLRequest(url: URL, credentials: Secrets.Credentials?, conditionalGet: RSWeb.HTTPConditionalGetInfo?) -> URLRequest {
URLRequest(url: url, credentials: credentials, conditionalGet: conditionalGet)
}
}
// MARK: - Private
private extension FeedbinAccountDelegate {

View File

@@ -1345,6 +1345,7 @@
841ABA5D20145E9200980E11 /* FolderInspectorViewController.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = FolderInspectorViewController.swift; sourceTree = "<group>"; };
841ABA5F20145EC100980E11 /* BuiltinSmartFeedInspectorViewController.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = BuiltinSmartFeedInspectorViewController.swift; sourceTree = "<group>"; };
84208B732A9CEE2B009FE5B9 /* FeedFinder */ = {isa = PBXFileReference; lastKnownFileType = wrapper; path = FeedFinder; sourceTree = "<group>"; };
84208B742A9CF1B3009FE5B9 /* Feedbin */ = {isa = PBXFileReference; lastKnownFileType = wrapper; name = Feedbin; path = SyncClients/Feedbin; sourceTree = "<group>"; };
84216D0222128B9D0049B9B9 /* DetailWebViewController.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = DetailWebViewController.swift; sourceTree = "<group>"; };
842611891FCB67AA0086A189 /* FeedIconDownloader.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = FeedIconDownloader.swift; sourceTree = "<group>"; };
8426119D1FCB6ED40086A189 /* HTMLMetadataDownloader.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = HTMLMetadataDownloader.swift; sourceTree = "<group>"; };
@@ -2509,6 +2510,7 @@
84208B732A9CEE2B009FE5B9 /* FeedFinder */,
8486EC3F2A9C2431007EF90D /* ReaderAPI */,
8486EC3E2A9BE083007EF90D /* NewsBlur */,
84208B742A9CF1B3009FE5B9 /* Feedbin */,
51CD32C424D2CF1D009ABAEF /* Articles */,
51CD32C324D2CD57009ABAEF /* ArticlesDatabase */,
51CD32C724D2E06C009ABAEF /* Secrets */,

9
SyncClients/Feedbin/.gitignore vendored Normal file
View File

@@ -0,0 +1,9 @@
.DS_Store
/.build
/Packages
/*.xcodeproj
xcuserdata/
DerivedData/
.swiftpm/config/registries.json
.swiftpm/xcode/package.xcworkspace/contents.xcworkspacedata
.netrc

View File

@@ -0,0 +1,36 @@
// swift-tools-version: 5.8
// The swift-tools-version declares the minimum version of Swift required to build this package.
import PackageDescription
let package = Package(
name: "Feedbin",
platforms: [.macOS(.v13), .iOS(.v16)],
products: [
// Products define the executables and libraries a package produces, and make them visible to other packages.
.library(
name: "Feedbin",
targets: ["Feedbin"]),
],
dependencies: [
.package(path: "../../Secrets"),
.package(url: "https://github.com/Ranchero-Software/RSWeb.git", .upToNextMajor(from: "1.0.0")),
.package(url: "https://github.com/Ranchero-Software/RSCore.git", .upToNextMajor(from: "2.0.1")),
.package(url: "https://github.com/Ranchero-Software/RSParser.git", .upToNextMajor(from: "2.0.2"))
],
targets: [
// Targets are the basic building blocks of a package. A target can define a module or a test suite.
// Targets can depend on other targets in this package, and on products in packages this package depends on.
.target(
name: "Feedbin",
dependencies: [
"RSCore",
"RSParser",
"RSWeb",
"Secrets"
]),
.testTarget(
name: "FeedbinTests",
dependencies: ["Feedbin"]),
]
)

View File

@@ -0,0 +1,3 @@
# Feedbin
A description of this package.

View File

@@ -14,21 +14,31 @@ import Foundation
import RSWeb
import Secrets
enum CreateSubscriptionResult {
public enum CreateSubscriptionResult {
case created(FeedbinSubscription)
case multipleChoice([FeedbinSubscriptionChoice])
case alreadySubscribed
case notFound
}
final class FeedbinAPICaller: NSObject {
public protocol FeedbinAPICallerDelegate: AnyObject {
var lastArticleFetchStartTime: Date? { get }
func conditionalGetInfo(key: String) -> HTTPConditionalGetInfo?
func setConditionalGetInfo(_: HTTPConditionalGetInfo, forKey: String)
func createURLRequest(url: URL, credentials: Secrets.Credentials?, conditionalGet: HTTPConditionalGetInfo?) -> URLRequest
}
public final class FeedbinAPICaller {
struct ConditionalGetKeys {
static let subscriptions = "subscriptions"
static let tags = "tags"
static let taggings = "taggings"
static let unreadEntries = "unreadEntries"
static let starredEntries = "starredEntries"
public struct ConditionalGetKeys {
public static let subscriptions = "subscriptions"
public static let tags = "tags"
public static let taggings = "taggings"
public static let unreadEntries = "unreadEntries"
public static let starredEntries = "starredEntries"
}
private let feedbinBaseURL = URL(string: "https://api.feedbin.com/v2/")!
@@ -36,28 +46,30 @@ final class FeedbinAPICaller: NSObject {
private var suspended = false
private var lastBackdateStartTime: Date?
var credentials: Credentials?
weak var accountMetadata: AccountMetadata?
public var credentials: Credentials?
public weak var delegate: FeedbinAPICallerDelegate?
init(transport: Transport) {
super.init()
public init(transport: Transport) {
self.transport = transport
}
/// Cancels all pending requests rejects any that come in later
func suspend() {
public func suspend() {
transport.cancelAll()
suspended = true
}
func resume() {
public func resume() {
suspended = false
}
func validateCredentials(completion: @escaping (Result<Credentials?, Error>) -> Void) {
public func validateCredentials(completion: @escaping (Result<Credentials?, Error>) -> Void) {
let callURL = feedbinBaseURL.appendingPathComponent("authentication.json")
let request = URLRequest(url: callURL, credentials: credentials)
guard let request = delegate?.createURLRequest(url: callURL, credentials: credentials, conditionalGet: nil) else {
completion(.failure(TransportError.suspended))
return
}
transport.send(request: request) { result in
@@ -85,10 +97,15 @@ final class FeedbinAPICaller: NSObject {
}
func importOPML(opmlData: Data, completion: @escaping (Result<FeedbinImportResult, Error>) -> Void) {
public func importOPML(opmlData: Data, completion: @escaping (Result<FeedbinImportResult, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let callURL = feedbinBaseURL.appendingPathComponent("imports.json")
var request = URLRequest(url: callURL, credentials: credentials)
var request = delegate.createURLRequest(url: callURL, credentials: credentials, conditionalGet: nil)
request.addValue("text/xml; charset=utf-8", forHTTPHeaderField: HTTPRequestHeader.contentType)
transport.send(request: request, method: HTTPMethod.post, payload: opmlData) { result in
@@ -121,10 +138,15 @@ final class FeedbinAPICaller: NSObject {
}
func retrieveOPMLImportResult(importID: Int, completion: @escaping (Result<FeedbinImportResult?, Error>) -> Void) {
public func retrieveOPMLImportResult(importID: Int, completion: @escaping (Result<FeedbinImportResult?, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let callURL = feedbinBaseURL.appendingPathComponent("imports/\(importID).json")
let request = URLRequest(url: callURL, credentials: credentials)
let request = delegate.createURLRequest(url: callURL, credentials: credentials, conditionalGet: nil)
transport.send(request: request, resultType: FeedbinImportResult.self) { result in
@@ -144,11 +166,16 @@ final class FeedbinAPICaller: NSObject {
}
func retrieveTags(completion: @escaping (Result<[FeedbinTag]?, Error>) -> Void) {
public func retrieveTags(completion: @escaping (Result<[FeedbinTag]?, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let callURL = feedbinBaseURL.appendingPathComponent("tags.json")
let conditionalGet = accountMetadata?.conditionalGetInfo[ConditionalGetKeys.tags]
let request = URLRequest(url: callURL, credentials: credentials, conditionalGet: conditionalGet)
let conditionalGet = delegate.conditionalGetInfo(key: ConditionalGetKeys.tags)
let request = delegate.createURLRequest(url: callURL, credentials: credentials, conditionalGet: conditionalGet)
transport.send(request: request, resultType: [FeedbinTag].self) { result in
@@ -169,9 +196,15 @@ final class FeedbinAPICaller: NSObject {
}
func renameTag(oldName: String, newName: String, completion: @escaping (Result<Void, Error>) -> Void) {
public func renameTag(oldName: String, newName: String, completion: @escaping (Result<Void, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let callURL = feedbinBaseURL.appendingPathComponent("tags.json")
let request = URLRequest(url: callURL, credentials: credentials)
let request = delegate.createURLRequest(url: callURL, credentials: credentials, conditionalGet: nil)
let payload = FeedbinRenameTag(oldName: oldName, newName: newName)
transport.send(request: request, method: HTTPMethod.post, payload: payload) { result in
@@ -189,13 +222,18 @@ final class FeedbinAPICaller: NSObject {
}
}
func retrieveSubscriptions(completion: @escaping (Result<[FeedbinSubscription]?, Error>) -> Void) {
public func retrieveSubscriptions(completion: @escaping (Result<[FeedbinSubscription]?, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
var callComponents = URLComponents(url: feedbinBaseURL.appendingPathComponent("subscriptions.json"), resolvingAgainstBaseURL: false)!
callComponents.queryItems = [URLQueryItem(name: "mode", value: "extended")]
let conditionalGet = accountMetadata?.conditionalGetInfo[ConditionalGetKeys.subscriptions]
let request = URLRequest(url: callComponents.url!, credentials: credentials, conditionalGet: conditionalGet)
let conditionalGet = delegate.conditionalGetInfo(key: ConditionalGetKeys.subscriptions)
let request = delegate.createURLRequest(url: callComponents.url!, credentials: credentials, conditionalGet: conditionalGet)
transport.send(request: request, resultType: [FeedbinSubscription].self) { result in
@@ -216,12 +254,17 @@ final class FeedbinAPICaller: NSObject {
}
func createSubscription(url: String, completion: @escaping (Result<CreateSubscriptionResult, Error>) -> Void) {
public func createSubscription(url: String, completion: @escaping (Result<CreateSubscriptionResult, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
var callComponents = URLComponents(url: feedbinBaseURL.appendingPathComponent("subscriptions.json"), resolvingAgainstBaseURL: false)!
callComponents.queryItems = [URLQueryItem(name: "mode", value: "extended")]
var request = URLRequest(url: callComponents.url!, credentials: credentials)
var request = delegate.createURLRequest(url: callComponents.url!, credentials: credentials, conditionalGet: nil)
request.addValue("application/json; charset=utf-8", forHTTPHeaderField: HTTPRequestHeader.contentType)
let payload: Data
@@ -295,9 +338,15 @@ final class FeedbinAPICaller: NSObject {
}
func renameSubscription(subscriptionID: String, newName: String, completion: @escaping (Result<Void, Error>) -> Void) {
public func renameSubscription(subscriptionID: String, newName: String, completion: @escaping (Result<Void, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let callURL = feedbinBaseURL.appendingPathComponent("subscriptions/\(subscriptionID)/update.json")
let request = URLRequest(url: callURL, credentials: credentials)
let request = delegate.createURLRequest(url: callURL, credentials: credentials, conditionalGet: nil)
let payload = FeedbinUpdateSubscription(title: newName)
transport.send(request: request, method: HTTPMethod.post, payload: payload) { result in
@@ -315,9 +364,15 @@ final class FeedbinAPICaller: NSObject {
}
}
func deleteSubscription(subscriptionID: String, completion: @escaping (Result<Void, Error>) -> Void) {
public func deleteSubscription(subscriptionID: String, completion: @escaping (Result<Void, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let callURL = feedbinBaseURL.appendingPathComponent("subscriptions/\(subscriptionID).json")
let request = URLRequest(url: callURL, credentials: credentials)
let request = delegate.createURLRequest(url: callURL, credentials: credentials, conditionalGet: nil)
transport.send(request: request, method: HTTPMethod.delete) { result in
if self.suspended {
completion(.failure(TransportError.suspended))
@@ -333,11 +388,16 @@ final class FeedbinAPICaller: NSObject {
}
}
func retrieveTaggings(completion: @escaping (Result<[FeedbinTagging]?, Error>) -> Void) {
public func retrieveTaggings(completion: @escaping (Result<[FeedbinTagging]?, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let callURL = feedbinBaseURL.appendingPathComponent("taggings.json")
let conditionalGet = accountMetadata?.conditionalGetInfo[ConditionalGetKeys.taggings]
let request = URLRequest(url: callURL, credentials: credentials, conditionalGet: conditionalGet)
let conditionalGet = delegate.conditionalGetInfo(key: ConditionalGetKeys.taggings)
let request = delegate.createURLRequest(url: callURL, credentials: credentials, conditionalGet: conditionalGet)
transport.send(request: request, resultType: [FeedbinTagging].self) { result in
if self.suspended {
@@ -357,10 +417,15 @@ final class FeedbinAPICaller: NSObject {
}
func createTagging(feedID: Int, name: String, completion: @escaping (Result<Int, Error>) -> Void) {
public func createTagging(feedID: Int, name: String, completion: @escaping (Result<Int, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let callURL = feedbinBaseURL.appendingPathComponent("taggings.json")
var request = URLRequest(url: callURL, credentials: credentials)
var request = delegate.createURLRequest(url: callURL, credentials: credentials, conditionalGet: nil)
request.addValue("application/json; charset=utf-8", forHTTPHeaderField: HTTPRequestHeader.contentType)
let payload: Data
@@ -396,9 +461,15 @@ final class FeedbinAPICaller: NSObject {
}
func deleteTagging(taggingID: String, completion: @escaping (Result<Void, Error>) -> Void) {
public func deleteTagging(taggingID: String, completion: @escaping (Result<Void, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let callURL = feedbinBaseURL.appendingPathComponent("taggings/\(taggingID).json")
var request = URLRequest(url: callURL, credentials: credentials)
var request = delegate.createURLRequest(url: callURL, credentials: credentials, conditionalGet: nil)
request.addValue("application/json; charset=utf-8", forHTTPHeaderField: HTTPRequestHeader.contentType)
transport.send(request: request, method: HTTPMethod.delete) { result in
if self.suspended {
@@ -415,8 +486,13 @@ final class FeedbinAPICaller: NSObject {
}
}
func retrieveEntries(articleIDs: [String], completion: @escaping (Result<([FeedbinEntry]?), Error>) -> Void) {
public func retrieveEntries(articleIDs: [String], completion: @escaping (Result<([FeedbinEntry]?), Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
guard !articleIDs.isEmpty else {
completion(.success(([FeedbinEntry]())))
return
@@ -431,7 +507,7 @@ final class FeedbinAPICaller: NSObject {
URLQueryItem(name: "ids", value: paramIDs),
URLQueryItem(name: "mode", value: "extended")
])
let request = URLRequest(url: url!, credentials: credentials)
let request = delegate.createURLRequest(url: url!, credentials: credentials, conditionalGet: nil)
transport.send(request: request, resultType: [FeedbinEntry].self) { result in
@@ -451,8 +527,13 @@ final class FeedbinAPICaller: NSObject {
}
func retrieveEntries(feedID: String, completion: @escaping (Result<([FeedbinEntry]?, String?), Error>) -> Void) {
public func retrieveEntries(feedID: String, completion: @escaping (Result<([FeedbinEntry]?, String?), Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let since = Calendar.current.date(byAdding: .month, value: -3, to: Date()) ?? Date()
let sinceString = FeedbinDate.formatter.string(from: since)
@@ -463,7 +544,7 @@ final class FeedbinAPICaller: NSObject {
URLQueryItem(name: "per_page", value: "100"),
URLQueryItem(name: "mode", value: "extended")
])
let request = URLRequest(url: url!, credentials: credentials)
let request = delegate.createURLRequest(url: url!, credentials: credentials, conditionalGet: nil)
transport.send(request: request, resultType: [FeedbinEntry].self) { result in
@@ -486,7 +567,12 @@ final class FeedbinAPICaller: NSObject {
}
func retrieveEntries(completion: @escaping (Result<([FeedbinEntry]?, String?, Date?, Int?), Error>) -> Void) {
public func retrieveEntries(completion: @escaping (Result<([FeedbinEntry]?, String?, Date?, Int?), Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
// If this is an initial sync, go and grab the previous 3 months of entries. If not, use the last
// article fetch to only get the articles **published** since the last article fetch.
@@ -495,7 +581,7 @@ final class FeedbinAPICaller: NSObject {
// getting **updated** articles that normally wouldn't be found with a regular fetch.
// https://github.com/Ranchero-Software/NetNewsWire/issues/2549#issuecomment-722341356
let since: Date = {
if let lastArticleFetch = accountMetadata?.lastArticleFetchStartTime {
if let lastArticleFetch = delegate.lastArticleFetchStartTime {
if let lastBackdateStartTime = lastBackdateStartTime {
if lastBackdateStartTime.byAdding(days: 1) < lastArticleFetch {
self.lastBackdateStartTime = lastArticleFetch
@@ -520,7 +606,8 @@ final class FeedbinAPICaller: NSObject {
URLQueryItem(name: "per_page", value: "100"),
URLQueryItem(name: "mode", value: "extended")
])
let request = URLRequest(url: url!, credentials: credentials)
let request = delegate.createURLRequest(url: url!, credentials: credentials, conditionalGet: nil)
transport.send(request: request, resultType: [FeedbinEntry].self) { result in
@@ -546,14 +633,18 @@ final class FeedbinAPICaller: NSObject {
}
func retrieveEntries(page: String, completion: @escaping (Result<([FeedbinEntry]?, String?), Error>) -> Void) {
public func retrieveEntries(page: String, completion: @escaping (Result<([FeedbinEntry]?, String?), Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
guard let url = URL(string: page) else {
completion(.success((nil, nil)))
return
}
let request = URLRequest(url: url, credentials: credentials)
let request = delegate.createURLRequest(url: url, credentials: credentials, conditionalGet: nil)
transport.send(request: request, resultType: [FeedbinEntry].self) { result in
@@ -576,11 +667,16 @@ final class FeedbinAPICaller: NSObject {
}
func retrieveUnreadEntries(completion: @escaping (Result<[Int]?, Error>) -> Void) {
public func retrieveUnreadEntries(completion: @escaping (Result<[Int]?, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let callURL = feedbinBaseURL.appendingPathComponent("unread_entries.json")
let conditionalGet = accountMetadata?.conditionalGetInfo[ConditionalGetKeys.unreadEntries]
let request = URLRequest(url: callURL, credentials: credentials, conditionalGet: conditionalGet)
let conditionalGet = delegate.conditionalGetInfo(key: ConditionalGetKeys.unreadEntries)
let request = delegate.createURLRequest(url: callURL, credentials: credentials, conditionalGet: conditionalGet)
transport.send(request: request, resultType: [Int].self) { result in
@@ -601,9 +697,15 @@ final class FeedbinAPICaller: NSObject {
}
func createUnreadEntries(entries: [Int], completion: @escaping (Result<Void, Error>) -> Void) {
public func createUnreadEntries(entries: [Int], completion: @escaping (Result<Void, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let callURL = feedbinBaseURL.appendingPathComponent("unread_entries.json")
let request = URLRequest(url: callURL, credentials: credentials)
let request = delegate.createURLRequest(url: callURL, credentials: credentials, conditionalGet: nil)
let payload = FeedbinUnreadEntry(unreadEntries: entries)
transport.send(request: request, method: HTTPMethod.post, payload: payload) { result in
if self.suspended {
@@ -620,9 +722,15 @@ final class FeedbinAPICaller: NSObject {
}
}
func deleteUnreadEntries(entries: [Int], completion: @escaping (Result<Void, Error>) -> Void) {
public func deleteUnreadEntries(entries: [Int], completion: @escaping (Result<Void, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let callURL = feedbinBaseURL.appendingPathComponent("unread_entries.json")
let request = URLRequest(url: callURL, credentials: credentials)
let request = delegate.createURLRequest(url: callURL, credentials: credentials, conditionalGet: nil)
let payload = FeedbinUnreadEntry(unreadEntries: entries)
transport.send(request: request, method: HTTPMethod.delete, payload: payload) { result in
if self.suspended {
@@ -639,11 +747,16 @@ final class FeedbinAPICaller: NSObject {
}
}
func retrieveStarredEntries(completion: @escaping (Result<[Int]?, Error>) -> Void) {
public func retrieveStarredEntries(completion: @escaping (Result<[Int]?, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let callURL = feedbinBaseURL.appendingPathComponent("starred_entries.json")
let conditionalGet = accountMetadata?.conditionalGetInfo[ConditionalGetKeys.starredEntries]
let request = URLRequest(url: callURL, credentials: credentials, conditionalGet: conditionalGet)
let conditionalGet = delegate.conditionalGetInfo(key: ConditionalGetKeys.starredEntries)
let request = delegate.createURLRequest(url: callURL, credentials: credentials, conditionalGet: conditionalGet)
transport.send(request: request, resultType: [Int].self) { result in
if self.suspended {
@@ -663,9 +776,15 @@ final class FeedbinAPICaller: NSObject {
}
func createStarredEntries(entries: [Int], completion: @escaping (Result<Void, Error>) -> Void) {
public func createStarredEntries(entries: [Int], completion: @escaping (Result<Void, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let callURL = feedbinBaseURL.appendingPathComponent("starred_entries.json")
let request = URLRequest(url: callURL, credentials: credentials)
let request = delegate.createURLRequest(url: callURL, credentials: credentials, conditionalGet: nil)
let payload = FeedbinStarredEntry(starredEntries: entries)
transport.send(request: request, method: HTTPMethod.post, payload: payload) { result in
if self.suspended {
@@ -682,9 +801,15 @@ final class FeedbinAPICaller: NSObject {
}
}
func deleteStarredEntries(entries: [Int], completion: @escaping (Result<Void, Error>) -> Void) {
public func deleteStarredEntries(entries: [Int], completion: @escaping (Result<Void, Error>) -> Void) {
guard let delegate else {
completion(.failure(TransportError.suspended))
return
}
let callURL = feedbinBaseURL.appendingPathComponent("starred_entries.json")
let request = URLRequest(url: callURL, credentials: credentials)
let request = delegate.createURLRequest(url: callURL, credentials: credentials, conditionalGet: nil)
let payload = FeedbinStarredEntry(starredEntries: entries)
transport.send(request: request, method: HTTPMethod.delete, payload: payload) { result in
if self.suspended {
@@ -708,9 +833,8 @@ final class FeedbinAPICaller: NSObject {
extension FeedbinAPICaller {
func storeConditionalGet(key: String, headers: [AnyHashable : Any]) {
if var conditionalGet = accountMetadata?.conditionalGetInfo {
conditionalGet[key] = HTTPConditionalGetInfo(headers: headers)
accountMetadata?.conditionalGetInfo = conditionalGet
if let conditionalGetInfo = HTTPConditionalGetInfo(headers: headers) {
delegate?.setConditionalGetInfo(conditionalGetInfo, forKey: key)
}
}

View File

@@ -10,24 +10,24 @@ import Foundation
import RSParser
import RSCore
final class FeedbinEntry: Decodable {
public final class FeedbinEntry: Decodable {
let articleID: Int
let feedID: Int
let title: String?
let url: String?
let authorName: String?
let contentHTML: String?
let summary: String?
let datePublished: String?
let dateArrived: String?
let jsonFeed: FeedbinEntryJSONFeed?
public let articleID: Int
public let feedID: Int
public let title: String?
public let url: String?
public let authorName: String?
public let contentHTML: String?
public let summary: String?
public let datePublished: String?
public let dateArrived: String?
public let jsonFeed: FeedbinEntryJSONFeed?
// Feedbin dates can't be decoded by the JSONDecoding 8601 decoding strategy. Feedbin
// requires a very specific date formatter to work and even then it fails occasionally.
// Rather than loose all the entries we only lose the one date by decoding as a string
// and letting the one date fail when parsed.
lazy var parsedDatePublished: Date? = {
public lazy var parsedDatePublished: Date? = {
if let datePublished = datePublished {
return RSDateWithString(datePublished)
}
@@ -50,9 +50,9 @@ final class FeedbinEntry: Decodable {
}
}
struct FeedbinEntryJSONFeed: Decodable {
let jsonFeedAuthor: FeedbinEntryJSONFeedAuthor?
let jsonFeedExternalURL: String?
public struct FeedbinEntryJSONFeed: Decodable {
public let jsonFeedAuthor: FeedbinEntryJSONFeedAuthor?
public let jsonFeedExternalURL: String?
enum CodingKeys: String, CodingKey {
case jsonFeedAuthor = "author"
@@ -75,9 +75,9 @@ struct FeedbinEntryJSONFeed: Decodable {
}
struct FeedbinEntryJSONFeedAuthor: Decodable {
let url: String?
let avatarURL: String?
public struct FeedbinEntryJSONFeedAuthor: Decodable {
public let url: String?
public let avatarURL: String?
enum CodingKeys: String, CodingKey {
case url = "url"
case avatarURL = "avatar"

View File

@@ -8,10 +8,10 @@
import Foundation
struct FeedbinImportResult: Codable {
public struct FeedbinImportResult: Codable {
let importResultID: Int
let complete: Bool
public let importResultID: Int
public let complete: Bool
enum CodingKeys: String, CodingKey {
case importResultID = "id"

View File

@@ -10,14 +10,14 @@ import Foundation
import RSCore
import RSParser
struct FeedbinSubscription: Hashable, Codable {
public struct FeedbinSubscription: Hashable, Codable {
let subscriptionID: Int
let feedID: Int
let name: String?
let url: String
let homePageURL: String?
let jsonFeed: FeedbinSubscriptionJSONFeed?
public let subscriptionID: Int
public let feedID: Int
public let name: String?
public let url: String
public let homePageURL: String?
public let jsonFeed: FeedbinSubscriptionJSONFeed?
enum CodingKeys: String, CodingKey {
case subscriptionID = "id"
@@ -32,15 +32,15 @@ struct FeedbinSubscription: Hashable, Codable {
hasher.combine(subscriptionID)
}
static func == (lhs: FeedbinSubscription, rhs: FeedbinSubscription) -> Bool {
public static func == (lhs: FeedbinSubscription, rhs: FeedbinSubscription) -> Bool {
return lhs.subscriptionID == rhs.subscriptionID
}
}
struct FeedbinSubscriptionJSONFeed: Codable {
let favicon: String?
let icon: String?
public struct FeedbinSubscriptionJSONFeed: Codable {
public let favicon: String?
public let icon: String?
enum CodingKeys: String, CodingKey {
case favicon = "favicon"
case icon = "icon"
@@ -61,10 +61,10 @@ struct FeedbinUpdateSubscription: Codable {
}
}
struct FeedbinSubscriptionChoice: Codable {
public struct FeedbinSubscriptionChoice: Codable {
let name: String?
let url: String
public let name: String?
public let url: String
enum CodingKeys: String, CodingKey {
case name = "title"

View File

@@ -8,10 +8,10 @@
import Foundation
struct FeedbinTag: Codable {
public struct FeedbinTag: Codable {
let tagID: Int
let name: String
public let name: String
enum CodingKeys: String, CodingKey {
case tagID = "id"

View File

@@ -8,11 +8,11 @@
import Foundation
struct FeedbinTagging: Codable {
public struct FeedbinTagging: Codable {
let taggingID: Int
let feedID: Int
let name: String
public let taggingID: Int
public let feedID: Int
public let name: String
enum CodingKeys: String, CodingKey {
case taggingID = "id"

View File

@@ -0,0 +1,2 @@
import XCTest
@testable import Feedbin