Kurdtvs-Live-Kurdish-TV-Kurdmax/Mastodon/Service/APIService/APIService+Search.swift

//
//  APIService+Search.swift
//  Mastodon
//
//  Created by sxiaojian on 2021/3/31.
//

import Foundation
import Combine
import MastodonSDK
import CommonOSLog

extension APIService {
 
    func search(
        query: Mastodon.API.V2.Search.Query,
        authenticationBox: MastodonAuthenticationBox
    ) async throws -> Mastodon.Response.Content<Mastodon.Entity.SearchResult> {
        let domain = authenticationBox.domain
        let authorization = authenticationBox.userAuthorization

        let response = try await Mastodon.API.V2.Search.search(
            session: session,
            domain: domain,
            query: query,
            authorization: authorization
        ).singleOutput()
            
        let managedObjectContext = self.backgroundManagedObjectContext
        try await managedObjectContext.performChanges {
            let me = authenticationBox.authenticationRecord.object(in: managedObjectContext)?.user
            
            // user
            for entity in response.value.accounts {
                _ = Persistence.MastodonUser.createOrMerge(
                    in: managedObjectContext,
                    context: Persistence.MastodonUser.PersistContext(
                        domain: domain,
                        entity: entity,
                        cache: nil,
                        networkDate: response.networkDate
                    )
                )
            }
            
            // statuses
            for entity in response.value.statuses {
                _ = Persistence.Status.createOrMerge(
                    in: managedObjectContext,
                    context: Persistence.Status.PersistContext(
                        domain: domain,
                        entity: entity,
                        me: me,
                        statusCache: nil,
                        userCache: nil,
                        networkDate: response.networkDate
                    )
                )
            }
        }   // ent try await managedObjectContext.performChanges { … } 
        
        return response
    }
}