michzio

struct DocumentPreview: UIViewControllerRepresentable {
    
    final class Coordintor: NSObject, UIDocumentInteractionControllerDelegate {
    
        private let parent: DocumentPreview
        
        init(_ parent: DocumentPreview) {
            self.parent = parent
        }
        

michzio

@Published var categories: [WorsetCategory] = []
@Published var error: Error?
@Published var isLoading: Bool = false

func fetchWordsetCategories() {
        guard !isLoading else { return }
        
        repo.fetchWordsetCategories()
            .sink(receiveCompletion: { completion in
                switch completion {

michzio

 public func fetchWordsetCategories() -> AnyPublisher<[WordsetCategory], Error> {
    
    let cachedDataPublisher = dao.fetchCategories()
    let refreshedDataPublisher = service.getCategories(from: "pl", to: "en")
          .flatMap { [weak self] categories in
               self?.dao.update(categories)
           }
           .eraseToAnyPublisher()
      
      return Publishers.MergeMany(cachedDataPublisher, refreshedDataPublisher)

michzio

@objc(WordsetCategory)
public class WordsetCategory: NSManagedObject { }

extension WordsetCategory {

    @nonobjc public class func fetchRequest() -> NSFetchRequest<WordsetCategory> {
        return NSFetchRequest<WordsetCategory>(entityName: "WordsetCategory")
    }

    @NSManaged public var categoryId: String?

michzio

class WordsetCategoryDao: BaseDao<WordsetCategoryDTO, WordsetCategory>, WordsetCategoryDaoProtocol {
    
    func update(_ entities: [WordsetCategoryDTO]) -> Future<UpdateResult, Error> {
        
        Future { [weak self] promise in

            let context = self?.storage.backgroundContext
            context.perform {
                switch Self.update(context: context, entities) {
                case .success(let change):

michzio

public protocol WordsetCategoryDaoProtocol {
    
    // DaoProtocol
    func insert(_ e: WordsetCategoryDTO) -> Future<WordsetCategory, Error>
    func delete(_ e: WordsetCategoryDTO) ->  Future<Int, Error>
    func update(_ e: WordsetCategoryDTO) ->  Future<WordsetCategory, Error>
    func load(id: String) -> Future<WordsetCategory, Error>
    
    // WordsetCategoryDaoProtocol
    func update(_ entities: [WordsetCategoryDTO]) -> Future<UpdateResult, Error>

michzio

struct WordsetCategoryDTO: Codable {
    let categoryId: String
    let foreignName: String
    let nativeName: String
    var image: String?
    
    enum CodingKeys: String, CodingKey {
        case categoryId = "cid"
        case foreignName = "foreignName"
        case nativeName = "nativeName"

michzio

enum WordsetRouter: Router {
    
    case getWordsets
    case getWordset(id: String)
    
    static var baseURL: String = "https://mockapi.com"
    
    var path: String {
        switch self {
        case .getWordsets:

michzio

public protocol WordsetServiceProtocol {
    func getCategories(from fromLang: String, to toLang: String) -> AnyPublisher<[WordsetCategoryDTO], Error>
}


public final class WordsetService: BaseService, WordsetServiceProtocol {
    
    func getCategories(from fromLang: String, to toLang: String) -> AnyPublisher<[WordsetCategoryDTO], Error> {
        let endpoint = Router.wordsetCategories(fromLang: fromLang, toLang: toLang)
        let xml : AnyPublisher<WordsetCategoriesDTO, Error> = request(endpoint)

michzio

public protocol WordsetCategoriesRepositoryProtocol {
    
    func syncWordsetCategories() -> AnyPublisher<UpdateResult, Error>
    func insertWordsetCategory() -> AnyPublisher<WordsetCategory, Error>
}

public final class WordsetCategoriesRepository: WordsetCategoryRepositoryProtocol {
    
    @Inject private var service: WordsetCategoriesServiceProtocol