From ed69e36576999ea2189a31d04d3e51496fdf2871 Mon Sep 17 00:00:00 2001
From: Satindar Dhillon <satindar@gmail.com>
Date: Tue, 19 Apr 2022 11:25:40 -0700
Subject: [PATCH] remove unused publishers

---
 .../Queries/LibraryItemsQuery.swift           | 51 -------------------
 .../DataService/Queries/ViewerFetcher.swift   | 43 ----------------
 2 files changed, 94 deletions(-)

diff --git a/apple/OmnivoreKit/Sources/Services/DataService/Queries/LibraryItemsQuery.swift b/apple/OmnivoreKit/Sources/Services/DataService/Queries/LibraryItemsQuery.swift
index e43d63efb..766a34ecb 100644
--- a/apple/OmnivoreKit/Sources/Services/DataService/Queries/LibraryItemsQuery.swift
+++ b/apple/OmnivoreKit/Sources/Services/DataService/Queries/LibraryItemsQuery.swift
@@ -3,57 +3,6 @@ import Foundation
 import Models
 import SwiftGraphQL
 
-public extension DataService {
-  func articlePublisher(slug: String) -> AnyPublisher<FeedItemDep, BasicError> {
-    internalViewerPublisher()
-      .flatMap { self.internalArticlePublisher(username: $0.username ?? "", slug: slug) }
-      .receive(on: DispatchQueue.main)
-      .eraseToAnyPublisher()
-  }
-}
-
-extension DataService {
-  func internalArticlePublisher(username: String, slug: String) -> AnyPublisher<FeedItemDep, BasicError> {
-    enum QueryResult {
-      case success(result: FeedItemDep)
-      case error(error: String)
-    }
-
-    let selection = Selection<QueryResult, Unions.ArticleResult> {
-      try $0.on(
-        articleSuccess: .init { QueryResult.success(result: try $0.article(selection: homeFeedItemSelection)) },
-        articleError: .init { QueryResult.error(error: try $0.errorCodes().description) }
-      )
-    }
-
-    let query = Selection.Query {
-      try $0.article(username: username, slug: slug, selection: selection)
-    }
-
-    let path = appEnvironment.graphqlPath
-    let headers = networker.defaultHeaders
-
-    return Deferred {
-      Future { promise in
-        send(query, to: path, headers: headers) { result in
-          switch result {
-          case let .success(payload):
-            switch payload.data {
-            case let .success(result: result):
-              promise(.success(result))
-            case let .error(error: error):
-              promise(.failure(.message(messageText: error.debugDescription)))
-            }
-          case .failure:
-            promise(.failure(.message(messageText: "ger article fetch failed")))
-          }
-        }
-      }
-    }
-    .eraseToAnyPublisher()
-  }
-}
-
 public extension DataService {
   func libraryItemsPublisher(
     limit: Int,
diff --git a/apple/OmnivoreKit/Sources/Services/DataService/Queries/ViewerFetcher.swift b/apple/OmnivoreKit/Sources/Services/DataService/Queries/ViewerFetcher.swift
index f526c23f3..2e2e46367 100644
--- a/apple/OmnivoreKit/Sources/Services/DataService/Queries/ViewerFetcher.swift
+++ b/apple/OmnivoreKit/Sources/Services/DataService/Queries/ViewerFetcher.swift
@@ -49,49 +49,6 @@ public extension DataService {
   }
 }
 
-extension DataService {
-  @available(*, deprecated, message: "use async version instead")
-  func internalViewerPublisher() -> AnyPublisher<Viewer, BasicError> {
-    let selection = Selection<ViewerInternal, Objects.User> {
-      ViewerInternal(
-        userID: try $0.id(),
-        username: try $0.profile(
-          selection: .init { try $0.username() }
-        ),
-        name: try $0.name(),
-        profileImageURL: try $0.profile(
-          selection: .init { try $0.pictureUrl() }
-        )
-      )
-    }
-
-    let query = Selection.Query {
-      try $0.me(selection: selection.nonNullOrFail)
-    }
-
-    let path = appEnvironment.graphqlPath
-    let headers = networker.defaultHeaders
-
-    return Deferred {
-      Future { [weak self] promise in
-        send(query, to: path, headers: headers) { result in
-          switch result {
-          case let .success(payload):
-            if let self = self, let viewer = payload.data.persist(context: self.persistentContainer.viewContext) {
-              promise(.success(viewer))
-            } else {
-              promise(.failure(.message(messageText: "coredata error")))
-            }
-          case .failure:
-            promise(.failure(.message(messageText: "http error")))
-          }
-        }
-      }
-    }
-    .eraseToAnyPublisher()
-  }
-}
-
 private struct ViewerInternal {
   let userID: String
   let username: String