app/src/main/java/de/danoeh/antennapod/discovery/FyydPodcastSearcher.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

package de.danoeh.antennapod.discovery;

import de.danoeh.antennapod.core.service.download.AntennapodHttpClient;
import de.mfietz.fyydlin.FyydClient;
import de.mfietz.fyydlin.FyydResponse;
import de.mfietz.fyydlin.SearchHit;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.functions.Consumer;
import io.reactivex.schedulers.Schedulers;

import java.util.ArrayList;
import java.util.List;

public class FyydPodcastSearcher implements PodcastSearcher {
    private final String query;
    private final FyydClient client = new FyydClient(AntennapodHttpClient.getHttpClient());

    public FyydPodcastSearcher(String query) {
        this.query = query;
    }

    public Disposable search(Consumer<? super List<PodcastSearchResult>> successHandler, Consumer<? super Throwable> errorHandler) {
        return client.searchPodcasts(query, 10)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(result -> {
                    ArrayList<PodcastSearchResult> results = processSearchResult(result);
                    successHandler.accept(results);
                }, errorHandler);
    }

    private ArrayList<PodcastSearchResult> processSearchResult(FyydResponse response) {
        ArrayList<PodcastSearchResult> searchResults = new ArrayList<>();

        if (!response.getData().isEmpty()) {
            for (SearchHit searchHit : response.getData()) {
                PodcastSearchResult podcast = PodcastSearchResult.fromFyyd(searchHit);
                searchResults.add(podcast);
            }
        }

        return searchResults;
    }
}