LOG4CXX_INFO(logger,  m_username << ": Login data=" << login_data);

	write(fd, login_data.c_str(), login_data.size());

	close(fd);

	fcntl (fd_output, F_SETFL, O_NONBLOCK);

	free(db);

	//Initialise threading

	dbus_threads_init_default();

	if (m_connection == NULL)

	{

		LOG4CXX_INFO(logger, "Creating DBus connection.");

		GError *error = NULL;

		m_connection = dbus_g_bus_get (DBUS_BUS_SESSION, &error);

		if (m_connection == NULL && error != NULL)

		{

			LOG4CXX_INFO(logger,  m_username << ": DBUS Error: " << error->message);

			g_error_free(error);

			return;

		}

	}

	m_timer = g_timeout_add_seconds(1, create_dbus_proxy, this);

}

bool Skype::loadSkypeBuddies() {

//	std::string re = "CONNSTATUS OFFLINE";

//	while (re == "CONNSTATUS OFFLINE" || re.empty()) {

//		sleep(1);

	gchar buffer[1024];

	int bytes_read = read(fd_output, buffer, 1023);

	if (bytes_read > 0) {

		buffer[bytes_read] = 0;

		np->handleDisconnected(m_user, 0, buffer);

		close(fd_output);

		logout();

		return FALSE;

	}

	std::string re = send_command("NAME Spectrum");

	if (m_counter++ > 15) {

		np->handleDisconnected(m_user, 0, "");

		close(fd_output);

		logout();

		return FALSE;

	}

	if (re.empty() || re == "CONNSTATUS OFFLINE") {

		return TRUE;

	}

	close(fd_output);

	if (send_command("PROTOCOL 7") != "PROTOCOL 7") {

		np->handleDisconnected(m_user, 0, "Skype is not ready");

		logout();

		return FALSE;

	}

	np->handleConnected(m_user);

	std::map<std::string, std::string> group_map;

	std::string groups = send_command("SEARCH GROUPS CUSTOM");

	groups = groups.substr(groups.find(' ') + 1);

	std::vector<std::string> grps;

	boost::split(grps, groups, boost::is_any_of(","));

	BOOST_FOREACH(std::string grp, grps) {

		std::vector<std::string> data;

		std::string name = send_command("GET GROUP " + grp + " DISPLAYNAME");

		boost::split(data, name, boost::is_any_of(" "));

		name = name.substr(name.find("DISPLAYNAME") + 12);

		std::string users = send_command("GET GROUP " + data[1] + " USERS");

		users = name.substr(name.find("USERS") + 6);

		boost::split(data, users, boost::is_any_of(","));

		BOOST_FOREACH(std::string u, data) {

			group_map[u] = grp;

		}

	}

	std::string friends = send_command("GET AUTH_CONTACTS_PROFILES");

	char **full_friends_list = g_strsplit((strchr(friends.c_str(), ' ')+1), ";", 0);

	if (full_friends_list && full_friends_list[0])

	{

		//in the format of: username;full name;phone;office phone;mobile phone;

		//                  online status;friendly name;voicemail;mood

		// (comma-seperated lines, usernames can have comma's)

		for (int i=0; full_friends_list[i] && *full_friends_list[i] != '\0'; i+=8)

		{

			std::string buddy = full_friends_list[i];

			if (buddy[0] == ',') {

				buddy.erase(buddy.begin());

			}

			LOG4CXX_INFO(logger, "Got buddy " << buddy);

			std::string st = full_friends_list[i + 5];

			pbnetwork::StatusType status = getStatus(st);

			std::string alias = full_friends_list[i + 6];

			std::string mood_text = "";

			if (full_friends_list[i + 8] && *full_friends_list[i + 8] != '\0' && *full_friends_list[i + 8] != ',') {

				mood_text = full_friends_list[i + 8];

			}

			std::vector<std::string> groups;

			groups.push_back(group_map[buddy]);

			np->handleBuddyChanged(m_user, buddy, alias, groups, status, mood_text);

		}

	}

	g_strfreev(full_friends_list);

	send_command("SET AUTOAWAY OFF");

	return FALSE;

}

void Skype::logout() {

	if (m_pid != 0) {

		send_command("SET USERSTATUS INVISIBLE");

		send_command("SET USERSTATUS OFFLINE");

		sleep(2);

		g_object_unref(m_proxy);

		LOG4CXX_INFO(logger,  m_username << ": Killing Skype instance");

		kill((int) m_pid, SIGTERM);

		m_pid = 0;

	}

}

std::string Skype::send_command(const std::string &message) {

	GError *error = NULL;

	gchar *str = NULL;

// 			int message_num;

// 			gchar error_return[30];

	if (!dbus_g_proxy_call (m_proxy, "Invoke", &error, G_TYPE_STRING, message.c_str(), G_TYPE_INVALID,

						G_TYPE_STRING, &str, G_TYPE_INVALID))

	{

			if (error && error->message)

			{

			LOG4CXX_INFO(logger,  m_username << ": DBUS Error: " << error->message);

			g_error_free(error);

		} else {

			LOG4CXX_INFO(logger,  m_username << ": DBUS no response");

		}

	}

	if (str != NULL)

	{

		LOG4CXX_INFO(logger,  m_username << ": DBUS:" << str);

	}

	return str ? std::string(str) : std::string();

}

static void handle_skype_message(std::string &message, Skype *sk) {

	std::vector<std::string> cmd;

	boost::split(cmd, message, boost::is_any_of(" "));

	if (cmd[0] == "USER") {

		if (cmd[1] == sk->getUsername()) {

			return;

		}

		if (cmd[2] == "ONLINESTATUS") {

			if (cmd[3] == "SKYPEOUT" || cmd[3] == "UNKNOWN") {

				return;

			}

			else {

				pbnetwork::StatusType status = getStatus(cmd[3]);

				std::string mood_text = sk->send_command("GET USER " + cmd[1] + " MOOD_TEXT");

				mood_text = mood_text.substr(mood_text.find("MOOD_TEXT") + 10);

				std::string alias = sk->send_command("GET USER " + cmd[1] + " FULLNAME");

				alias = alias.substr(alias.find("FULLNAME") + 9);

				std::vector<std::string> groups;

				np->handleBuddyChanged(sk->getUser(), cmd[1], alias, groups, status, mood_text);

			}

		}

		else if (cmd[2] == "MOOD_TEXT") {

			std::string st = sk->send_command("GET USER " + cmd[1] + " ONLINESTATUS");

			st = st.substr(st.find("ONLINESTATUS") + 13);

			pbnetwork::StatusType status = getStatus(st);

			std::string mood_text = message.substr(message.find("MOOD_TEXT") + 10);

			std::vector<std::string> groups;

			np->handleBuddyChanged(sk->getUser(), cmd[1], "", groups, status, mood_text);

		}

		else if (cmd[2] == "BUDDYSTATUS" && cmd[3] == "3") {