Changeset - 7102c90a4eb0
Parent rev.
Child rev.
[Not reviewed]
Merge
0 3 0
HanzZ - 13 years ago 2012-03-14 18:01:09
hanzz.k@gmail.com
Merge branch 'master' of github.com:hanzz/libtransport
2 files changed with 47 insertions and 15 deletions:
backends/skype/main.cpp
45
14
spectrum/src/sample.cfg
2
1
0 comments (0 inline, 0 general)
backends/skype/main.cpp
➞
Show inline comments
 
@@ -354,25 +354,25 @@ static gboolean load_skype_buddies(gpointer data) {
 
bool Skype::createDBusProxy() {
 
	if (m_proxy == NULL) {
 
		LOG4CXX_INFO(logger, "Creating DBus proxy for com.Skype.Api.");
 
		m_counter++;
 

			




	
	
	
		
 
		GError *error = NULL;

			




	
	
	
		
 
		m_proxy = dbus_g_proxy_new_for_name_owner (m_connection, "com.Skype.API", "/com/Skype", "com.Skype.API", &error);

			




	
	
	
		
 
		if (m_proxy == NULL && error != NULL) {

			




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

			




	
	
	
		
 

			




	
	
	
		
 
			if (m_counter == 15) {

			




	
	
	
		
 
				LOG4CXX_ERROR(logger, "Logging out, proxy couldn't be created");

			




	
	
	
		
 
				np->handleDisconnected(m_user, 0, error->message);

			




	
	
	
		
 
				np->handleDisconnected(m_user, pbnetwork::CONNECTION_ERROR_AUTHENTICATION_IMPOSSIBLE, error->message);

			




	
	
	
		
 
				logout();

			




	
	
	
		
 
				g_error_free(error);

			




	
	
	
		
 
				return FALSE;

			




	
	
	
		
 
			}

			




	
	
	
		
 
			g_error_free(error);

			




	
	
	
		
 
		}

			




	
	
	
		
 

			




	
	
	
		
 
		if (m_proxy) {

			




	
	
	
		
 
			LOG4CXX_INFO(logger, "Proxy created.");

			




	
	
	
		
 
			DBusObjectPathVTable vtable;

			




	
	
	
		
 
			vtable.message_function = &skype_notify_handler;

			




	
	
	
		
 
			dbus_connection_register_object_path(dbus_g_connection_get_connection(m_connection), "/com/Skype/Client", &vtable, this);

			




	
	
		
 
@@ -384,25 +384,25 @@ bool Skype::createDBusProxy() {

			




	
	
	
		
 
		return TRUE;

			




	
	
	
		
 
	}

			




	
	
	
		
 
	return FALSE;

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
static gboolean create_dbus_proxy(gpointer data) {

			




	
	
	
		
 
	Skype *skype = (Skype *) data;

			




	
	
	
		
 
	return skype->createDBusProxy();

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
void Skype::login() {

			




	
	
	
		
 
	if (m_username.find("..") == 0 || m_username.find("/") != std::string::npos) {

			




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

			




	
	
	
		
 
		np->handleDisconnected(m_user, pbnetwork::CONNECTION_ERROR_AUTHENTICATION_IMPOSSIBLE, "Invalid username");

			




	
	
	
		
 
		return;

			




	
	
	
		
 
	}

			




	
	
	
		
 
	boost::filesystem::remove_all(std::string("/tmp/skype/") + m_username);

			




	
	
	
		
 

			




	
	
	
		
 
	boost::filesystem::path	path(std::string("/tmp/skype/") + m_username);

			




	
	
	
		
 
	if (!boost::filesystem::exists(path)) {

			




	
	
	
		
 
		boost::filesystem::create_directories(path);

			




	
	
	
		
 
		boost::filesystem::path	path2(std::string("/tmp/skype/") + m_username + "/" + m_username );

			




	
	
	
		
 
		boost::filesystem::create_directories(path2);

			




	
	
	
		
 
	}

			




	
	
	
		
 

			




	
	
	
		
 
	std::string shared_xml = "<?xml version=\"1.0\"?>\n"

			




	
	
		
 
@@ -428,25 +428,25 @@ void Skype::login() {

			




	
	
	
		
 
									"<Authorizations>Spectrum</Authorizations>\n"

			




	
	
	
		
 
									"<BlockedPrograms></BlockedPrograms>\n"

			




	
	
	
		
 
									"</API>\n"

			




	
	
	
		
 
								"</UI>\n"

			




	
	
	
		
 
							"</config>\n";

			




	
	
	
		
 
	g_file_set_contents(std::string(std::string("/tmp/skype/") + m_username + "/" + m_username +"/config.xml").c_str(), config_xml.c_str(), -1, NULL);

			




	
	
	
		
 

			




	
	
	
		
 
	sleep(1);

			




	
	
	
		
 
	std::string db_path = std::string("/tmp/skype/") + m_username;

			




	
	
	
		
 
	char *db = (char *) malloc(db_path.size() + 1);

			




	
	
	
		
 
	strcpy(db, db_path.c_str());

			




	
	
	
		
 
	LOG4CXX_INFO(logger,  m_username << ": Spawning new Skype instance dbpath=" << db);

			




	
	
	
		
 
	gchar* argv[8] = {"skype", "--enable-dbus", "--use-session-dbus", "--disable-cleanlooks", "--pipelogin", "--dbpath", db, 0};

			




	
	
	
		
 
	gchar* argv[6] = {"skype", "--disable-cleanlooks", "--pipelogin", "--dbpath", db, 0};

			




	
	
	
		
 

			




	
	
	
		
 
	int fd;

			




	
	
	
		
 
	g_spawn_async_with_pipes(NULL,

			




	
	
	
		
 
		argv,

			




	
	
	
		
 
		NULL /*envp*/,

			




	
	
	
		
 
		G_SPAWN_SEARCH_PATH,

			




	
	
	
		
 
		NULL /*child_setup*/,

			




	
	
	
		
 
		NULL /*user_data*/,

			




	
	
	
		
 
		&m_pid /*child_pid*/,

			




	
	
	
		
 
		&fd,

			




	
	
	
		
 
		NULL,

			




	
	
	
		
 
		&fd_output,

			




	
	
		
 
@@ -476,52 +476,57 @@ void Skype::login() {

			




	
	
	
		
 
		}

			




	
	
	
		
 
	}

			




	
	
	
		
 

			




	
	
	
		
 
	sleep(1);

			




	
	
	
		
 
	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;

			




	
	
	
		
 
// 	}

			




	
	
	
		
 
	gchar buffer[1024];

			




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

			




	
	
	
		
 
	if (bytes_read > 0) {

			




	
	
	
		
 
		buffer[bytes_read] = 0;

			




	
	
	
		
 
		std::string b(buffer);

			




	
	
	
		
 
		LOG4CXX_WARN(logger, "Skype wrote this on stdout '" << b << "'");

			




	
	
	
		
 
		if (b.find("Incorrect Password") != std::string::npos) {

			




	
	
	
		
 
			LOG4CXX_INFO(logger, "Incorrect password, logging out")

			




	
	
	
		
 
			np->handleDisconnected(m_user, pbnetwork::CONNECTION_ERROR_AUTHENTICATION_FAILED, "Incorrect password");

			




	
	
	
		
 
			close(fd_output);

			




	
	
	
		
 
			logout();

			




	
	
	
		
 
			return FALSE;

			




	
	
	
		
 
		}

			




	
	
	
		
 
	}

			




	
	
	
		
 

			




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

			




	
	
	
		
 
	if (m_counter++ > 15) {

			




	
	
	
		
 
		LOG4CXX_ERROR(logger, "Logging out, because we tried to connect the Skype over DBUS 15 times without success");

			




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

			




	
	
	
		
 
		np->handleDisconnected(m_user, pbnetwork::CONNECTION_ERROR_AUTHENTICATION_IMPOSSIBLE, "Skype is not read.");

			




	
	
	
		
 
		close(fd_output);

			




	
	
	
		
 
		logout();

			




	
	
	
		
 
		return FALSE;

			




	
	
	
		
 
	}

			




	
	
	
		
 

			




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

			




	
	
	
		
 
		return TRUE;

			




	
	
	
		
 
	}

			




	
	
	
		
 

			




	
	
	
		
 
	close(fd_output);

			




	
	
	
		
 

			




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

			




	
	
	
		
 
		LOG4CXX_ERROR(logger, "PROTOCOL 7 failed, logging out");

			




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

			




	
	
	
		
 
		np->handleDisconnected(m_user, pbnetwork::CONNECTION_ERROR_AUTHENTICATION_IMPOSSIBLE, "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) {

			




	
	
		
 
@@ -701,24 +706,50 @@ static void handle_skype_message(std::string &message, Skype *sk) {

			




	
	
	
		
 
			std::string from_handle = sk->send_command("GET CHATMESSAGE " + cmd[1] + " FROM_HANDLE");

			




	
	
	
		
 
			from_handle = from_handle.substr(from_handle.find("FROM_HANDLE") + 12);

			




	
	
	
		
 

			




	
	
	
		
 
// 			if (from_handle != sk->getUsername()) {

			




	
	
	
		
 
				from = from_handle;

			




	
	
	
		
 
// 			}

			




	
	
	
		
 
			if (from_handle == sk->getUsername())

			




	
	
	
		
 
				return;

			




	
	
	
		
 

			




	
	
	
		
 
			np->handleMessage(sk->getUser(), from, body);

			




	
	
	
		
 
		}

			




	
	
	
		
 
	}

			




	
	
	
		
 
	else if (cmd[0] == "CALL") {

			




	
	
	
		
 
		// CALL 884 STATUS RINGING

			




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

			




	
	
	
		
 
			if (cmd[3] == "RINGING" || cmd[3] == "MISSED") {

			




	
	
	
		
 
				// handle only incoming calls

			




	
	
	
		
 
				std::string type = sk->send_command("GET CALL " + cmd[1] + " TYPE");

			




	
	
	
		
 
				type = type.substr(type.find("TYPE") + 5);

			




	
	
	
		
 
				if (type.find("INCOMING") != 0) {

			




	
	
	
		
 
					return;

			




	
	
	
		
 
				}

			




	
	
	
		
 

			




	
	
	
		
 
				std::string from = sk->send_command("GET CALL " + cmd[1] + " PARTNER_HANDLE");

			




	
	
	
		
 
				from = from.substr(from.find("PARTNER_HANDLE") + 15);

			




	
	
	
		
 

			




	
	
	
		
 
				std::string dispname = sk->send_command("GET CALL " + cmd[1] + " PARTNER_DISPNAME");

			




	
	
	
		
 
				dispname = dispname.substr(dispname.find("PARTNER_DISPNAME") + 17);

			




	
	
	
		
 

			




	
	
	
		
 
				if (cmd[3] == "RINGING") {

			




	
	
	
		
 
					np->handleMessage(sk->getUser(), from, "User " + dispname + " is calling you.");

			




	
	
	
		
 
				}

			




	
	
	
		
 
				else {

			




	
	
	
		
 
					np->handleMessage(sk->getUser(), from, "You have missed call from user " + dispname + ".");

			




	
	
	
		
 
				}

			




	
	
	
		
 
			}

			




	
	
	
		
 
		}

			




	
	
	
		
 
	}

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
DBusHandlerResult skype_notify_handler(DBusConnection *connection, DBusMessage *message, gpointer user_data) {

			




	
	
	
		
 
	DBusMessageIter iterator;

			




	
	
	
		
 
	gchar *message_temp;

			




	
	
	
		
 
	DBusMessage *temp_message;

			




	
	
	
		
 
	

			




	
	
	
		
 
	temp_message = dbus_message_ref(message);

			




	
	
	
		
 
	dbus_message_iter_init(temp_message, &iterator);

			




	
	
	
		
 
	if (dbus_message_iter_get_arg_type(&iterator) != DBUS_TYPE_STRING)

			




	
	
	
		
 
	{

			




	
	
	
		
 
		dbus_message_unref(message);

			




        

    


    
    

    

        

                

                    spectrum/src/sample.cfg
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -4,29 +4,30 @@ password = secret

			




	
	
	
		
 
server = 127.0.0.1

			




	
	
	
		
 
port = 5222

			




	
	
	
		
 
server_mode = 1

			




	
	
	
		
 
backend_host=localhost

			




	
	
	
		
 
pidfile=./test.pid

			




	
	
	
		
 
# < this option doesn't work yet

			




	
	
	
		
 
backend_port=10001

			




	
	
	
		
 
admin_username=admin

			




	
	
	
		
 
admin_password=test

			




	
	
	
		
 
#cert=server.pfx #patch to PKCS#12 certificate

			




	
	
	
		
 
#cert_password=test #password to that certificate if any

			




	
	
	
		
 
users_per_backend=10

			




	
	
	
		
 
backend=/home/hanzz/code/libtransport/backends/libpurple/spectrum2_libpurple_backend

			




	
	
	
		
 
#backend=/home/hanzz/code/libtransport/backends/libpurple/spectrum2_libpurple_backend

			




	
	
	
		
 
#backend=/home/hanzz/code/libtransport/backends/smstools3/spectrum2_smstools3_backend

			




	
	
	
		
 
#backend=/usr/bin/mono /home/hanzz/code/networkplugin-csharp/msnp-sharp-backend/bin/Debug/msnp-sharp-backend.exe

			




	
	
	
		
 
#backend=/home/hanzz/code/libtransport/backends/frotz/spectrum2_frotz_backend

			




	
	
	
		
 
#backend=/home/hanzz/code/libtransport/backends/libircclient-qt/spectrum2_libircclient-qt_backend

			




	
	
	
		
 
backend=/usr/bin/xvfb-run -n BACKEND_ID -s "-screen 0 10x10x8" -f /tmp/x-skype-gw /home/hanzz/code/libtransport/backends/skype/spectrum2_skype_backend

			




	
	
	
		
 
#protocol=prpl-msn

			




	
	
	
		
 
protocol=any

			




	
	
	
		
 
#protocol=prpl-icq

			




	
	
	
		
 
irc_server=irc.freenode.org

			




	
	
	
		
 
working_dir=./

			




	
	
	
		
 

			




	
	
	
		
 
[backend]

			




	
	
	
		
 
#default_avatar=catmelonhead.jpg

			




	
	
	
		
 
#no_vcard_fetch=true

			




	
	
	
		
 
incoming_dir=/var/spool/sms/incoming

			




	
	
	
		
 

			




	
	
	
		
 
[logging]

			




        

    



    


    



    



      

      





    
    0 comments (0 inline, 0 general)
    





    


  

  







  


    




    








    
        Server instance: srv01-28608
    
    
        This site is powered by
            Kallithea,
        which is
        © 2010–2021 by various authors & licensed under GPLv3.
            – Support