#include "Cache.hpp"

#include <iostream>

#include <giomm.h>
#include <glibmm.h>

using namespace std;
using namespace net::lliurex::apt;


Cache::Cache()
{
}


Cache::Cache(function<void(int,string)> progress,function<void(void)> ready)
{
	this->cb_progress=progress;
	this->cb_ready=ready;
}



Cache::~Cache()
{
}

void Cache::OnSignal(const Glib::ustring& sender_name, const Glib::ustring& signal_name, const Glib::VariantContainerBase& parameters)
{

	//cout<<"-- "<<signal_name<<endl;
	
	if(signal_name=="PropertyChanged")
	{
	
				
		Glib::Variant<Glib::ustring> prop_name;
		parameters.get_child(prop_name,0);
		
		//cout<<"-- "<<prop_name.get()<<endl;
		
		if(prop_name.get()=="StatusDetails")
		{
			
			Glib::VariantContainerBase q;
			parameters.get_child(q,1);
			
			Glib::Variant<Glib::ustring> p;
			q.get_child(p,0);
			
			//cout<<"* ["<<p.get()<<"]"<<endl;
		}
		
		if(prop_name.get()=="ProgressDownload")
		{
			Glib::VariantContainerBase q;
			parameters.get_child(q,1);
			
			Glib::VariantContainerBase qq;
			q.get_child(qq,0);
			
			Glib::Variant<Glib::ustring> desc;
			qq.get_child(desc,2);
			
			//cout<<desc.get()<<endl;
			
			cb_progress(progress,desc.get());
			
		}
		
		if(prop_name.get()=="ProgressDetails")
		{
			Glib::VariantContainerBase q;
			parameters.get_child(q,1);
			
			Glib::VariantContainerBase qq;
			q.get_child(qq,0);
			
			Glib::Variant<int> current;
			Glib::Variant<int> total;

			qq.get_child(current,0);
			qq.get_child(total,1);
			
			//cout<<"progress: "<<(float)100.0f * current.get()/total.get()<<endl;
			
			if(total.get()>0)
			{
				progress = (int)(100.0f * current.get()/total.get());
			}
			
		}
		
		
	}
	
	if(signal_name=="Finished")
	{
		if(cancel_request==false)
			cb_ready();
			
		loop->quit();
	}
	
}





void Cache::Update()
{
	cancel_request=false;
	Glib::Thread::create(sigc::mem_fun(*this, &Cache::UpdateThread), true);
}

void Cache::UpdateThread()
{

	progress=0;

	connection = Gio::DBus::Connection::get_sync(Gio::DBus::BUS_TYPE_SYSTEM);

	
	if(!connection)
	{
		throw runtime_error("Failed to connect to system bus");
	}
	
	Glib::RefPtr<Gio::DBus::Proxy> proxy;
	
	proxy = Gio::DBus::Proxy::create_sync(connection, "org.debian.apt",
"/org/debian/apt", "org.debian.apt");

	try
	{
		const Glib::VariantContainerBase address = proxy->call_sync("UpdateCache");
		Glib::Variant<Glib::ustring> res;
		address.get_child(res);
		cout<<"Address: "<<res.get()<<endl;
		
		
		
		transaction_proxy=Gio::DBus::Proxy::create_sync(connection, "org.debian.apt",
res.get(), "org.debian.apt.transaction");

		
		transaction_proxy->signal_signal().connect(sigc::mem_fun(*this,&Cache::OnSignal));
		transaction_proxy->call_sync("Run");
		
		cout<<"waiting for a train..."<<endl;
		
		loop = Glib::MainLoop::create();
		loop->run();
		
		
		
	}
	catch(Gio::DBus::Error e)
	{
		//should we really exit from the application?
		cerr<<"Error: "<<e.code()<<endl;
		std::exit(1);
	}
	
	

	
}

void Cache::Cancel()
{
	try
	{
		cancel_request=true;
		transaction_proxy->call_sync("Cancel");
	}
	catch(Gio::DBus::Error e)
	{
		cerr<<"Error: "<<e.code()<<endl;
		std::exit(1);
	}
}