/*
 * Copyright (C) 2014 Hippo Seven
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package com.hippo.ehviewer;

import java.util.Stack;

import android.content.Context;
import android.graphics.Bitmap;
import android.os.Message;

import com.hippo.ehviewer.cache.ImageCache;
import com.hippo.ehviewer.network.HttpHelper;

public class ImageLoader {
    @SuppressWarnings("unused")
    private static final String TAG = ImageLoader.class.getSimpleName();

    private static ImageLoader sInstance;

    class LoadTask {
        public String url;
        public String key;
        public OnGetImageListener listener;
        public Bitmap bitmap;

        public LoadTask(String url, String key, OnGetImageListener listener) {
            this.url = url;
            this.key = key;
            this.listener = listener;
        }
    }

    private final Context mContext;
    private final Stack<LoadTask> mLoadTasks;
    private final ImageCache mImageCache;
    private final ImageDownloader mImageDownloader;

    public ImageLoader(Context context) {
        mLoadTasks = new Stack<LoadTask>();
        mImageDownloader = new ImageDownloader();

        mContext = context;
        mImageCache = ImageCache.getInstance(mContext);

        Thread thread = new Thread(new LoadFromCacheTask());
        thread.setPriority(android.os.Process.THREAD_PRIORITY_BACKGROUND);
        thread.start();
    }

    public final static ImageLoader getInstance(final Context context) {
        if (sInstance == null) {
            sInstance = new ImageLoader(context.getApplicationContext());
        }
        return sInstance;
    }

    public void add(String url, String key, OnGetImageListener listener) {
        synchronized (mLoadTasks) {
            mLoadTasks.push(new LoadTask(url, key, listener));
            mLoadTasks.notify();
        }
    }

    private class LoadFromCacheTask implements Runnable {
        @Override
        public void run() {
            LoadTask loadTask;
            while (true) {
                synchronized (mLoadTasks) {
                    if (mLoadTasks.isEmpty()) {
                        try {
                            mLoadTasks.wait();
                        } catch (InterruptedException e) {}
                        continue;
                    }
                    loadTask = mLoadTasks.pop();
                }

                String key = loadTask.key;
                loadTask.bitmap = mImageCache.getCachedBitmap(key);

                if (loadTask.bitmap != null)
                    AppHandler.getInstance().sendMessage(
                            Message.obtain(null, AppHandler.IMAGE_LOADER_TAG, loadTask));
                else
                    mImageDownloader.add(loadTask);
            }
        }
    }

    private class ImageDownloader {
        private static final int MAX_DOWNLOAD_THREADS = 5;
        private final Stack<LoadTask> mDownloadTasks;
        private int mWorkingThreadNum = 0;

        public ImageDownloader() {
            mDownloadTasks = new Stack<LoadTask>();
        }

        public void add(LoadTask loadTask) {
            synchronized (mDownloadTasks) {
                mDownloadTasks.push(loadTask);
                if (mWorkingThreadNum < MAX_DOWNLOAD_THREADS) {
                    Thread thread = new Thread(new DownloadImageTask());
                    thread.setPriority(android.os.Process.THREAD_PRIORITY_BACKGROUND);
                    thread.start();
                    mWorkingThreadNum++;
                }
            }
        }

        private class DownloadImageTask implements Runnable {
            @Override
            public void run() {
                LoadTask loadTask;
                HttpHelper httpHelper = new HttpHelper(mContext);
                while (true) {
                    synchronized (mDownloadTasks) {
                        if (mDownloadTasks.isEmpty()) {
                            loadTask = null;
                            mWorkingThreadNum--;
                            break;
                        }
                        loadTask = mDownloadTasks.pop();
                    }

                    // TODO use proxy to get image
                    loadTask.bitmap = httpHelper.getImage(loadTask.url);
                    mImageCache.addBitmapToCache(loadTask.key, loadTask.bitmap);

                    AppHandler.getInstance().sendMessage(
                            Message.obtain(null, AppHandler.IMAGE_LOADER_TAG, loadTask));
                }
            }
        }
    }

    public interface OnGetImageListener {
        /**
         * bmp is null for fail
         * @param key
         * @param bmp
         */
        void onGetImage(String key, Bitmap bmp);
    }
}