using System;
using Android.App;
using Android.Content;
using Android.Util;
using System.Net;
using System.IO;
using Android.Gms.Gcm;
using Android.Gms.Gcm.Iid;
using Android.OS;
using Android;
using ZicMoove.Settings;
using System.Linq;

namespace ZicMoove.Droid
{

	[Service(Exported = false), IntentFilter(new[] { "com.google.android.c2dm.intent.REGISTRATION" })]
	class GcmRegistrationIntentService : IntentService
	{
		static object locker = new object();

		public GcmRegistrationIntentService() : base("RegistrationIntentService") {
		}

		static PowerManager.WakeLock sWakeLock;
		static object LOCK = new object();

        public override void OnCreate()
        {
            base.OnCreate();
            sWakeLock = PowerManager.FromContext(this).NewWakeLock(WakeLockFlags.Partial,
                "ZicMoove");
            sWakeLock.Acquire();
        }
        public override void OnDestroy()
        {
            base.OnDestroy();
            sWakeLock.Release();
        }
        protected override void OnHandleIntent (Intent intent)
		{
			try
			{
				Log.Info ("RegistrationIntentService", "Calling InstanceID.GetToken");
				lock (locker)
				{

                    var instanceID = InstanceID.GetInstance(this);

#if DEBUG
                    // When debugging, and application data/cache is preserved, 
                    // a previous instance comes from another application installation
                    // and the old registration against GCM fails,
                    // until one delete it.
                    try
                    {
                        instanceID.DeleteInstanceID();
                    }
                    catch(Exception ex)
                    {
                        Debug.WaitForDebugger();
                        Log.Debug("bas.GCM", ex.StackTrace.ToString());
                    }
#endif

                    var senderid = Constants.GoogleSenderId;
					var token = instanceID.GetToken ( senderid,
						 GoogleCloudMessaging.InstanceIdScope, null);

					Log.Info ("RegistrationIntentService", "GCM Registration Token: " + token);
					SendRegistrationToAppServer (token);
					Subscribe (token);
				}
			}
			catch (WebException e) {
				Log.Debug ("RegistrationIntentService", "Failed to get a registration token");
				if (e.Response!=null)
				using (var s = e.Response.GetResponseStream ()) {
					using (var r = new StreamReader (s)) {
						var t = r.ReadToEnd ();
						Log.Debug("RegistrationIntentService",t);
					}
				}
				return;
			}
			catch (Exception e)
			{
				Log.Error ("RegistrationIntentService", "Failed to get a registration token");
				Log.Error ("RegistrationIntentService", e.Message);
				return;
			}
		}

		void SendRegistrationToAppServer (string token)
		{
            MainSettings.GoogleRegId = token;
		}

		void Subscribe (string token)
		{
			var pubSub = GcmPubSub.GetInstance(this);
			pubSub.Subscribe(token, "/topics/global", null);
            ///if (MainSettings.CurrentUser.Roles.Contains("Performer"))
            // TODO add activity codes in the bundle
                //pubSub.Subscribe(token, "/topics/jobs", null);
            // TODO if a Activity is specified,
            // and general annonces in this activity are accepted:
            // pubSub.Subscribe(token, "/topics/jobs/"+ActivityCode, null);
            
        }
	}
	
}