NetNewsWire/Frameworks/Account/NewsBlur/NewsBlurAPICaller.swift

281 lines
8.3 KiB
Swift
Raw Normal View History

2020-03-10 01:19:24 +01:00
//
// NewsBlurAPICaller.swift
// Account
//
// Created by Anh-Quang Do on 3/9/20.
// Copyright (c) 2020 Ranchero Software, LLC. All rights reserved.
//
import Foundation
import RSWeb
2020-04-10 04:07:56 +02:00
import Secrets
2020-03-10 01:19:24 +01:00
final class NewsBlurAPICaller: NSObject {
2020-03-10 04:26:11 +01:00
static let SessionIdCookie = "newsblur_sessionid"
2020-03-10 01:19:24 +01:00
let baseURL = URL(string: "https://www.newsblur.com/")!
var transport: Transport!
var suspended = false
2020-03-10 01:19:24 +01:00
var credentials: Credentials?
weak var accountMetadata: AccountMetadata?
init(transport: Transport!) {
super.init()
self.transport = transport
}
2020-03-14 03:23:54 +01:00
/// Cancels all pending requests rejects any that come in later
func suspend() {
transport.cancelAll()
suspended = true
}
func resume() {
suspended = false
}
2020-03-10 01:19:24 +01:00
func validateCredentials(completion: @escaping (Result<Credentials?, Error>) -> Void) {
requestData(endpoint: "api/login", resultType: NewsBlurLoginResponse.self) { result in
2020-03-10 01:19:24 +01:00
switch result {
2020-04-21 09:09:59 +02:00
case .success((let response, let payload)):
2020-03-10 04:26:11 +01:00
guard let url = response.url, let headerFields = response.allHeaderFields as? [String: String], payload?.code != -1 else {
2020-03-10 01:19:24 +01:00
let error = payload?.errors?.username ?? payload?.errors?.others
if let message = error?.first {
completion(.failure(NewsBlurError.general(message: message)))
} else {
2020-03-15 01:00:29 +01:00
completion(.failure(NewsBlurError.unknown))
2020-03-10 01:19:24 +01:00
}
return
}
2020-03-10 04:26:11 +01:00
guard let username = self.credentials?.username else {
2020-03-15 01:00:29 +01:00
completion(.failure(NewsBlurError.unknown))
2020-03-10 04:26:11 +01:00
return
}
let cookies = HTTPCookie.cookies(withResponseHeaderFields: headerFields, for: url)
for cookie in cookies where cookie.name == Self.SessionIdCookie {
let credentials = Credentials(type: .newsBlurSessionId, username: username, secret: cookie.value)
completion(.success(credentials))
return
}
completion(.failure(NewsBlurError.general(message: "Failed to retrieve session")))
2020-03-10 01:19:24 +01:00
case .failure(let error):
completion(.failure(error))
}
}
}
func logout(completion: @escaping (Result<Void, Error>) -> Void) {
requestData(endpoint: "api/logout", completion: completion)
2020-03-10 01:19:24 +01:00
}
2020-03-10 04:26:48 +01:00
func retrieveFeeds(completion: @escaping (Result<([NewsBlurFeed]?, [NewsBlurFolder]?), Error>) -> Void) {
2020-03-10 04:26:48 +01:00
let url = baseURL
.appendingPathComponent("reader/feeds")
.appendingQueryItems([
URLQueryItem(name: "flat", value: "true"),
URLQueryItem(name: "update_counts", value: "false"),
])
requestData(callURL: url, resultType: NewsBlurFeedsResponse.self) { result in
switch result {
case .success((_, let payload)):
completion(.success((payload?.feeds, payload?.folders)))
case .failure(let error):
completion(.failure(error))
}
2020-03-10 04:26:48 +01:00
}
}
2020-03-10 04:26:48 +01:00
func retrieveStoryHashes(endpoint: String, completion: @escaping (Result<[NewsBlurStoryHash]?, Error>) -> Void) {
let url = baseURL
.appendingPathComponent(endpoint)
.appendingQueryItems([
URLQueryItem(name: "include_timestamps", value: "true"),
])
2020-03-14 03:23:54 +01:00
requestData(
callURL: url,
resultType: NewsBlurStoryHashesResponse.self,
dateDecoding: .secondsSince1970
) { result in
2020-03-10 04:26:48 +01:00
switch result {
2020-03-11 02:08:56 +01:00
case .success((_, let payload)):
let hashes = payload?.unread ?? payload?.starred
completion(.success(hashes))
2020-03-11 02:08:56 +01:00
case .failure(let error):
completion(.failure(error))
}
}
}
func retrieveUnreadStoryHashes(completion: @escaping (Result<[NewsBlurStoryHash]?, Error>) -> Void) {
retrieveStoryHashes(
endpoint: "reader/unread_story_hashes",
completion: completion
)
2020-03-14 21:10:05 +01:00
}
2020-03-14 03:23:54 +01:00
2020-03-14 21:10:05 +01:00
func retrieveStarredStoryHashes(completion: @escaping (Result<[NewsBlurStoryHash]?, Error>) -> Void) {
retrieveStoryHashes(
endpoint: "reader/starred_story_hashes",
completion: completion
)
}
2020-03-22 04:28:29 +01:00
func retrieveStories(feedID: String, page: Int, completion: @escaping (Result<([NewsBlurStory]?, Date?), Error>) -> Void) {
let url = baseURL
.appendingPathComponent("reader/feed/\(feedID)")
.appendingQueryItems([
URLQueryItem(name: "page", value: String(page)),
URLQueryItem(name: "order", value: "newest"),
URLQueryItem(name: "read_filter", value: "all"),
URLQueryItem(name: "include_hidden", value: "true"),
URLQueryItem(name: "include_story_content", value: "true"),
])
requestData(callURL: url, resultType: NewsBlurStoriesResponse.self) { result in
switch result {
2020-03-22 04:28:29 +01:00
case .success(let (response, payload)):
completion(.success((payload?.stories, HTTPDateInfo(urlResponse: response)?.date)))
case .failure(let error):
completion(.failure(error))
}
}
2020-03-13 23:18:47 +01:00
}
2020-03-22 04:28:29 +01:00
func retrieveStories(hashes: [NewsBlurStoryHash], completion: @escaping (Result<([NewsBlurStory]?, Date?), Error>) -> Void) {
2020-03-13 23:18:47 +01:00
let url = baseURL
.appendingPathComponent("reader/river_stories")
.appendingQueryItem(.init(name: "include_hidden", value: "true"))?
2020-03-14 21:10:05 +01:00
.appendingQueryItems(hashes.map {
URLQueryItem(name: "h", value: $0.hash)
})
2020-03-13 23:18:47 +01:00
requestData(callURL: url, resultType: NewsBlurStoriesResponse.self) { result in
2020-03-13 23:18:47 +01:00
switch result {
2020-03-22 04:28:29 +01:00
case .success(let (response, payload)):
completion(.success((payload?.stories, HTTPDateInfo(urlResponse: response)?.date)))
2020-03-10 04:26:48 +01:00
case .failure(let error):
completion(.failure(error))
}
}
}
2020-03-14 04:16:52 +01:00
func markAsUnread(hashes: [String], completion: @escaping (Result<Void, Error>) -> Void) {
sendUpdates(
endpoint: "reader/mark_story_hash_as_unread",
payload: NewsBlurStoryStatusChange(hashes: hashes),
completion: completion
)
2020-03-14 04:16:52 +01:00
}
func markAsRead(hashes: [String], completion: @escaping (Result<Void, Error>) -> Void) {
sendUpdates(
endpoint: "reader/mark_story_hashes_as_read",
payload: NewsBlurStoryStatusChange(hashes: hashes),
completion: completion
)
2020-03-14 04:16:52 +01:00
}
func star(hashes: [String], completion: @escaping (Result<Void, Error>) -> Void) {
sendUpdates(
endpoint: "reader/mark_story_hash_as_starred",
payload: NewsBlurStoryStatusChange(hashes: hashes),
completion: completion
)
2020-03-14 04:16:52 +01:00
}
func unstar(hashes: [String], completion: @escaping (Result<Void, Error>) -> Void) {
sendUpdates(
endpoint: "reader/mark_story_hash_as_unstarred",
payload: NewsBlurStoryStatusChange(hashes: hashes),
completion: completion
)
2020-03-14 04:16:52 +01:00
}
2020-03-15 01:00:29 +01:00
func addFolder(named name: String, completion: @escaping (Result<Void, Error>) -> Void) {
sendUpdates(
endpoint: "reader/add_folder",
payload: NewsBlurFolderChange.add(name),
completion: completion
)
2020-03-15 01:42:45 +01:00
}
2020-03-15 01:00:29 +01:00
2020-03-15 01:42:45 +01:00
func renameFolder(with folder: String, to name: String, completion: @escaping (Result<Void, Error>) -> Void) {
sendUpdates(
endpoint: "reader/rename_folder",
payload: NewsBlurFolderChange.rename(folder, name),
completion: completion
)
2020-03-15 01:42:45 +01:00
}
2020-03-15 01:00:29 +01:00
2020-03-15 02:09:42 +01:00
func removeFolder(named name: String, feedIDs: [String], completion: @escaping (Result<Void, Error>) -> Void) {
sendUpdates(
endpoint: "reader/delete_folder",
payload: NewsBlurFolderChange.delete(name, feedIDs),
completion: completion
)
}
func addURL(_ url: String, folder: String?, completion: @escaping (Result<NewsBlurFeed?, Error>) -> Void) {
sendUpdates(
endpoint: "reader/add_url",
payload: NewsBlurFeedChange.add(url, folder),
resultType: NewsBlurAddURLResponse.self
) { result in
2020-03-14 04:16:52 +01:00
switch result {
2020-04-21 09:09:59 +02:00
case .success((_, let payload)):
completion(.success(payload?.feed))
2020-03-14 04:16:52 +01:00
case .failure(let error):
completion(.failure(error))
}
}
}
func renameFeed(feedID: String, newName: String, completion: @escaping (Result<Void, Error>) -> Void) {
sendUpdates(
endpoint: "reader/rename_feed",
payload: NewsBlurFeedChange.rename(feedID, newName)
) { result in
switch result {
case .success:
completion(.success(()))
case .failure(let error):
completion(.failure(error))
}
}
}
func deleteFeed(feedID: String, folder: String? = nil, completion: @escaping (Result<Void, Error>) -> Void) {
sendUpdates(
endpoint: "reader/delete_feed",
payload: NewsBlurFeedChange.delete(feedID, folder)
) { result in
switch result {
case .success:
completion(.success(()))
case .failure(let error):
completion(.failure(error))
}
}
}
2020-03-22 03:17:01 +01:00
func moveFeed(feedID: String, from: String?, to: String?, completion: @escaping (Result<Void, Error>) -> Void) {
sendUpdates(
endpoint: "reader/move_feed_to_folder",
payload: NewsBlurFeedChange.move(feedID, from, to)
) { result in
switch result {
case .success:
completion(.success(()))
case .failure(let error):
completion(.failure(error))
}
}
}
2020-03-10 01:19:24 +01:00
}