package com.cappielloantonio.play.service;

import android.content.Context;
import android.net.Uri;

import androidx.annotation.NonNull;
import androidx.annotation.Nullable;

import com.cappielloantonio.play.App;
import com.cappielloantonio.play.model.Song;
import com.cappielloantonio.play.repository.SongRepository;
import com.cappielloantonio.play.util.MusicUtil;
import com.google.android.exoplayer2.MediaItem;
import com.google.android.exoplayer2.offline.Download;
import com.google.android.exoplayer2.offline.DownloadCursor;
import com.google.android.exoplayer2.offline.DownloadHelper;
import com.google.android.exoplayer2.offline.DownloadIndex;
import com.google.android.exoplayer2.offline.DownloadManager;
import com.google.android.exoplayer2.offline.DownloadRequest;
import com.google.android.exoplayer2.offline.DownloadService;
import com.google.android.exoplayer2.trackselection.DefaultTrackSelector;
import com.google.android.exoplayer2.upstream.HttpDataSource;
import com.google.android.exoplayer2.util.Log;

import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.concurrent.CopyOnWriteArraySet;

import static com.google.android.exoplayer2.util.Assertions.checkNotNull;

public class DownloadTracker {

    private static final String TAG = "DownloadTracker";
    private final Context context;
    private final HttpDataSource.Factory httpDataSourceFactory;
    private final CopyOnWriteArraySet<Listener> listeners;
    private final HashMap<Uri, Download> downloads;
    private final DownloadIndex downloadIndex;
    private final DefaultTrackSelector.Parameters trackSelectorParameters;

    public DownloadTracker(Context context, HttpDataSource.Factory httpDataSourceFactory, DownloadManager downloadManager) {
        this.context = context.getApplicationContext();
        this.httpDataSourceFactory = httpDataSourceFactory;
        listeners = new CopyOnWriteArraySet<>();
        downloads = new HashMap<>();
        downloadIndex = downloadManager.getDownloadIndex();
        trackSelectorParameters = DownloadHelper.getDefaultTrackSelectorParameters(context);
        downloadManager.addListener(new DownloadManagerListener());
        loadDownloads();
    }

    public void addListener(Listener listener) {
        checkNotNull(listener);
        listeners.add(listener);
    }

    public void removeListener(Listener listener) {
        listeners.remove(listener);
    }

    public boolean isDownloaded(Song song) {
        MediaItem mediaItem = MusicUtil.getMediaItemFromSong(song);
        @Nullable Download download = downloads.get(checkNotNull(mediaItem.playbackProperties).uri);
        return download != null && download.state != Download.STATE_FAILED;
    }

    @Nullable
    public DownloadRequest getDownloadRequest(String id, Uri uri) {
        return new DownloadRequest.Builder(id, uri).build();
    }

    public void toggleDownload(List<Song> songs) {
        SongRepository songRepository = new SongRepository(App.getInstance());

        for (Song song : songs) {
            MediaItem mediaItem = MusicUtil.getMediaItemFromSong(song);

            @Nullable Download download = downloads.get(checkNotNull(mediaItem.playbackProperties).uri);

            if (download != null && download.state != Download.STATE_FAILED) {
                song.setOffline(false);
                DownloadService.sendRemoveDownload(context, DownloaderService.class, download.request.id, false);
            } else {
                song.setOffline(true);
                DownloadService.sendAddDownload(context, DownloaderService.class, getDownloadRequest(song.getId(), mediaItem.playbackProperties.uri), false);
            }

            songRepository.setOfflineStatus(song);
        }
    }

    public void removeAllDownloads() {
        SongRepository songRepository = new SongRepository(App.getInstance());
        songRepository.setAllOffline();
        DownloadService.sendRemoveAllDownloads(context, DownloaderService.class, false);
    }

    private void loadDownloads() {
        try (DownloadCursor loadedDownloads = downloadIndex.getDownloads()) {
            while (loadedDownloads.moveToNext()) {
                Download download = loadedDownloads.getDownload();
                downloads.put(download.request.uri, download);
            }
        } catch (IOException e) {
            Log.w(TAG, "Failed to query downloads", e);
        }
    }


    public interface Listener {
        void onDownloadsChanged();
    }

    private class DownloadManagerListener implements DownloadManager.Listener {
        @Override
        public void onDownloadChanged(@NonNull DownloadManager downloadManager, @NonNull Download download, @Nullable Exception finalException) {
            downloads.put(download.request.uri, download);

            for (Listener listener : listeners) {
                listener.onDownloadsChanged();
            }
        }

        @Override
        public void onDownloadRemoved(@NonNull DownloadManager downloadManager, @NonNull Download download) {
            downloads.remove(download.request.uri);

            for (Listener listener : listeners) {
                listener.onDownloadsChanged();
            }
        }
    }
}