package nextrek.photoupload;

import java.util.ArrayList;

import nextrek.lib.HTTPHelper;

import android.app.Notification;
import android.app.NotificationManager;
import android.app.PendingIntent;
import android.app.Service;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.net.ConnectivityManager;
import android.os.Bundle;
import android.os.Handler;
import android.os.IBinder;
import android.util.Log;
import android.widget.Toast;

import nextrek.services.ServiceConnector;

public class UploadService extends Service {

    private static final String TAG = "PhotoUpload.Service";

    static ArrayList<Bundle> mUploads = new ArrayList<Bundle>();

    static Handler mHandler = new Handler();

    Runnable mRunnable = new Runnable() {

        @Override
        public void run() {

            if (!HTTPHelper.isNetworkAvailable(UploadService.this)) {
                noNetworkNotification();
                return;
            }

            Bundle bundle;
            synchronized (mUploads) {

                if (mUploads.size() == 0) {
                    return;
                }
                bundle = mUploads.get(0);
                mUploads.remove(0);
            }

            String filename = bundle.getString("photo");
            String pratica = bundle.getString("pratica");
            String descrizione = bundle.getString("descrizione");

            bundle.putString("work-progress", "started");
            mServiceConnector.sendProgress(bundle);

            Log.e(TAG, "[START] " + filename + " " + pratica + " " + descrizione);
            startNotification(pratica);
            
            boolean success = true;

            try {
                HTTPHelper.doUPLOAD("http://www.nextrek.net/piroux/upload.php", bundle, filename);
                //HTTPHelper.doUPLOAD("http://10.9.1.68/piroux/upload.php", bundle, filename);
            } catch (Exception e) {
                Log.e(TAG, "[ERR] " + filename + " " + e.toString());
                success = false;
            }

            if (!success) {
                // retry
                synchronized (mUploads) {
                    mUploads.add(bundle);
                }
            }
            
            stopNotification(pratica);

            Log.e(TAG, "[STOP] " + filename + " " + pratica + " " + descrizione);

            bundle.putString("work-progress", "finished");
            mServiceConnector.sendProgress(bundle);

            synchronized (mUploads) {
                if (HTTPHelper.isNetworkAvailable(UploadService.this)) {
                    if (mUploads.size() > 0) {
                        runQueueHandler();
                    }
                } else {
                    noNetworkNotification();
                }
            }
        }
    };

    ServiceConnector mServiceConnector = new ServiceConnector() {

        public void onHandleRequest(Bundle bundle) {

            bundle.putString("work-progress", "queued");
            synchronized (mUploads) {
                mUploads.add(bundle);
            }
            sendProgress(bundle);

            runQueueHandler();
        }

    };

    private synchronized void runQueueHandler() {
        synchronized (mHandler) {
            mHandler.removeCallbacks(mRunnable);
            mHandler.post(mRunnable);
        }
    }

    /** For showing and hiding our notification. */
    NotificationManager mNM;

    private BroadcastReceiver mConnReceiver = new BroadcastReceiver() {

        @Override
        public void onReceive(Context context, Intent intent) {
            boolean noConnectivity = intent.getBooleanExtra(ConnectivityManager.EXTRA_NO_CONNECTIVITY, false);
/*
            String reason = intent.getStringExtra(ConnectivityManager.EXTRA_REASON);
            boolean isFailover = intent.getBooleanExtra(ConnectivityManager.EXTRA_IS_FAILOVER, false);
            NetworkInfo currentNetworkInfo = (NetworkInfo) intent.getParcelableExtra(ConnectivityManager.EXTRA_NETWORK_INFO);
            NetworkInfo otherNetworkInfo = (NetworkInfo) intent.getParcelableExtra(ConnectivityManager.EXTRA_OTHER_NETWORK_INFO);
*/
            if (!noConnectivity) {
                // quindi c'è connettività
                runQueueHandler();
            }

        }
    };

    @Override
    public void onCreate() {
        super.onCreate();

        mNM = (NotificationManager) getSystemService(NOTIFICATION_SERVICE);

        // Display a notification about us starting.
        showNotification();

        Toast.makeText(this, R.string.remote_service_started, Toast.LENGTH_SHORT).show();

        registerReceiver(mConnReceiver, new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION));
    }

    @Override
    public void onDestroy() {
        super.onDestroy();

        // Cancel the persistent notification.
        mNM.cancel(R.string.remote_service_started);

        // Tell the user we stopped.
        Toast.makeText(this, R.string.remote_service_stopped, Toast.LENGTH_SHORT).show();
        
        unregisterReceiver(mConnReceiver);
    }

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        super.onStartCommand(intent, flags, startId);
        return START_STICKY;
    }

    /**
     * When binding to the service, we return an interface to our messenger
     * for sending messages to the service.
     */
    @Override
    public IBinder onBind(Intent intent) {
        return mServiceConnector.getBinder();
    }

    /**
     * Show a notification while this service is running.
     */
    private void showNotification() {
        // In this sample, we'll use the same text for the ticker and the expanded notification
        CharSequence text = getText(R.string.remote_service_started);

        // Set the icon, scrolling text and timestamp
        Notification notification = new Notification(R.drawable.ic_launcher, text, System.currentTimeMillis());

        // The PendingIntent to launch our activity if the user selects this notification
        PendingIntent contentIntent = PendingIntent.getActivity(this, 0, new Intent(this, MainActivity.class), 0);

        // Set the info for the views that show in the notification panel.
        notification.setLatestEventInfo(this, getText(R.string.remote_service_label), text, contentIntent);

        // Send the notification.
        // We use a string id because it is a unique number. We use it later to cancel.
        mNM.notify(R.string.remote_service_started, notification);
    }

    /**
     * Show a notification while this service is running.
     */
    private void startNotification(String pratica) {
        // In this sample, we'll use the same text for the ticker and the expanded notification
        CharSequence text = getText(R.string.start_label);

        // Set the icon, scrolling text and timestamp
        Notification notification = new Notification(R.drawable.ic_launcher, text, System.currentTimeMillis());

        // The PendingIntent to launch our activity if the user selects this notification
        PendingIntent contentIntent = PendingIntent.getActivity(this, 0, new Intent(this, MainActivity.class), 0);

        // Set the info for the views that show in the notification panel.
        notification.setLatestEventInfo(this, pratica, text, contentIntent);

        // Send the notification.
        // We use a string id because it is a unique number. We use it later to cancel.
        mNM.notify(R.string.remote_service_started, notification);
    }

    /**
     * Show a notification while this service is running.
     */
    private void stopNotification(String pratica) {
        // In this sample, we'll use the same text for the ticker and the expanded notification
        CharSequence text = getText(R.string.stop_label);

        // Set the icon, scrolling text and timestamp
        Notification notification = new Notification(R.drawable.ic_launcher, text, System.currentTimeMillis());

        // The PendingIntent to launch our activity if the user selects this notification
        PendingIntent contentIntent = PendingIntent.getActivity(this, 0, new Intent(this, MainActivity.class), 0);

        // Set the info for the views that show in the notification panel.
        notification.setLatestEventInfo(this, pratica, text, contentIntent);

        // Send the notification.
        // We use a string id because it is a unique number. We use it later to cancel.
        mNM.notify(R.string.remote_service_started, notification);
    }

    private void noNetworkNotification() {
        // In this sample, we'll use the same text for the ticker and the expanded notification
        CharSequence text = getText(R.string.stop_label);

        // Set the icon, scrolling text and timestamp
        Notification notification = new Notification(R.drawable.ic_launcher, text, System.currentTimeMillis());

        // The PendingIntent to launch our activity if the user selects this notification
        PendingIntent contentIntent = PendingIntent.getActivity(this, 0, new Intent(this, MainActivity.class), 0);

        // Set the info for the views that show in the notification panel.
        notification.setLatestEventInfo(this, getText(R.string.no_network_label), text, contentIntent);

        // Send the notification.
        // We use a string id because it is a unique number. We use it later to cancel.
        mNM.notify(R.string.remote_service_started, notification);
    }
}