/**

 * libtransport -- C++ library for easy XMPP Transports development

 *

 * Copyright (C) 2011, Jan Kaluza <hanzz.k@gmail.com>

 *

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 2 of the License, or

 * (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02111-1301  USA

 */

#include "skypeplugin.h"

#include "skype.h"

#include "skypedb.h"

#include "transport/config.h"

#include "transport/logging.h"

#include "transport/transport.h"

#include "transport/usermanager.h"

#include "transport/memoryusage.h"

#include "transport/sqlite3backend.h"

#include "transport/userregistration.h"

#include "transport/user.h"

#include "transport/storagebackend.h"

#include "transport/rostermanager.h"

#include "transport/conversation.h"

#include "transport/networkplugin.h"

#include <boost/filesystem.hpp>

#include "sys/wait.h"

#include "sys/signal.h"

// #include "valgrind/memcheck.h"

#ifndef __FreeBSD__

#include "malloc.h"

#endif

using namespace Transport;

DEFINE_LOGGER(logger, "SkypePlugin");

static int m_sock;

static gboolean transportDataReceived(GIOChannel *source, GIOCondition condition, gpointer data) {

	SkypePlugin *np = (SkypePlugin *) data;

	char buffer[65535];

	char *ptr = buffer;

	ssize_t n = read(m_sock, ptr, sizeof(buffer));

	if (n <= 0) {

		LOG4CXX_INFO(logger, "Diconnecting from spectrum2 server");

		Logging::shutdownLogging();

		exit(errno);

	}

	std::string d = std::string(buffer, n);

	np->handleDataRead(d);

	return TRUE;

}

static int create_socket(const char *host, int portno) {

	struct sockaddr_in serv_addr;

	int m_sock = socket(AF_INET, SOCK_STREAM, 0);

	memset((char *) &serv_addr, 0, sizeof(serv_addr));

	serv_addr.sin_family = AF_INET;

	serv_addr.sin_port = htons(portno);

	hostent *hos;  // Resolve name

	if ((hos = gethostbyname(host)) == NULL) {

		// strerror() will not work for gethostbyname() and hstrerror() 

		// is supposedly obsolete

		Logging::shutdownLogging();

		exit(1);

	}

	serv_addr.sin_addr.s_addr = *((unsigned long *) hos->h_addr_list[0]);

	if (connect(m_sock, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0) {

		close(m_sock);

		m_sock = 0;

	}

	int flags = fcntl(m_sock, F_GETFL);

	flags |= O_NONBLOCK;

	fcntl(m_sock, F_SETFL, flags);

	return m_sock;

}