Changeset - e84ea9b1029b
Parent rev.
Child rev.
[Not reviewed]
0 4 0
HanzZ - 13 years ago 2012-04-08 16:44:31
hanzz.k@gmail.com
Merged SoC teaser tasks solutions
4 files changed with 21 insertions and 1 deletions:
backends/template/main.cpp
5
src/admininterface.cpp
11
src/config.cpp
2
src/gatewayresponder.cpp
3
1
0 comments (0 inline, 0 general)
backends/template/main.cpp
➞
Show inline comments
 
@@ -47,31 +47,36 @@ class TemplatePlugin : public NetworkPlugin {
 
		void sendData(const std::string &string) {
 
			m_conn->write(Swift::createSafeByteArray(string));
 
		}
 

			




	
	
	
		
 
		// This method has to call handleDataRead with all received data from network plugin server

			




	
	
	
		
 
		void _handleDataRead(boost::shared_ptr<Swift::SafeByteArray> data) {

			




	
	
	
		
 
			std::string d(data->begin(), data->end());

			




	
	
	
		
 
			handleDataRead(d);

			




	
	
	
		
 
		}

			




	
	
	
		
 

			




	
	
	
		
 
		void handleLoginRequest(const std::string &user, const std::string &legacyName, const std::string &password) {

			




	
	
	
		
 
			handleConnected(user);

			




	
	
	
		
 
			LOG4CXX_INFO(logger, user << ": Added buddy - Echo.");

			




	
	
	
		
 
			handleBuddyChanged(user, "echo", "Echo", std::vector<std::string>(), pbnetwork::STATUS_ONLINE);

			




	
	
	
		
 
		}

			




	
	
	
		
 

			




	
	
	
		
 
		void handleLogoutRequest(const std::string &user, const std::string &legacyName) {

			




	
	
	
		
 
		}

			




	
	
	
		
 

			




	
	
	
		
 
		void handleMessageSendRequest(const std::string &user, const std::string &legacyName, const std::string &message, const std::string &xhtml = "") {

			




	
	
	
		
 
			LOG4CXX_INFO(logger, "Sending message from " << user << " to " << legacyName << ".");

			




	
	
	
		
 
			if (legacyName == "echo") {

			




	
	
	
		
 
				handleMessage(user, legacyName, message);

			




	
	
	
		
 
			}

			




	
	
	
		
 
		}

			




	
	
	
		
 

			




	
	
	
		
 
		void handleBuddyUpdatedRequest(const std::string &user, const std::string &buddyName, const std::string &alias, const std::vector<std::string> &groups) {

			




	
	
	
		
 
			LOG4CXX_INFO(logger, user << ": Added buddy " << buddyName << ".");

			




	
	
	
		
 
			handleBuddyChanged(user, buddyName, alias, groups, pbnetwork::STATUS_ONLINE);

			




	
	
	
		
 
		}

			




	
	
	
		
 

			




	
	
	
		
 
		void handleBuddyRemovedRequest(const std::string &user, const std::string &buddyName, const std::vector<std::string> &groups) {

			




	
	
	
		
 

			




	
	
	
		
 
		}

			




	
	
	
		
 

			




	
	
	
		
 
	private:

			




        

    


    
    

    

        

                

                    src/admininterface.cpp
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -248,34 +248,45 @@ void AdminInterface::handleMessageReceived(Swift::Message::ref message) {

			




	
	
	
		
 
	}

			




	
	
	
		
 
	else if (message->getBody() == "collect_backend") {

			




	
	
	
		
 
		m_server->collectBackend();

			




	
	
	
		
 
	}

			




	
	
	
		
 
	else if (message->getBody() == "crashed_backends") {

			




	
	
	
		
 
		std::string lst;

			




	
	
	
		
 
		const std::vector<std::string> &backends = m_server->getCrashedBackends();

			




	
	
	
		
 
		BOOST_FOREACH(const std::string &backend, backends) {

			




	
	
	
		
 
			lst += backend + "\n";

			




	
	
	
		
 
		}

			




	
	
	
		
 
		message->setBody(lst);

			




	
	
	
		
 
	}

			




	
	
	
		
 
	else if (message->getBody() == "messages_from_xmpp") {

			




	
	
	
		
 
		int msgCount = m_userManager->getMessagesToBackend();

			




	
	
	
		
 
		message->setBody(boost::lexical_cast<std::string>(msgCount));

			




	
	
	
		
 
	}

			




	
	
	
		
 
	else if (message->getBody() == "messages_to_xmpp") {

			




	
	
	
		
 
		int msgCount = m_userManager->getMessagesToXMPP();

			




	
	
	
		
 
		message->setBody(boost::lexical_cast<std::string>(msgCount));

			




	
	
	
		
 
	}

			




	
	
	
		
 
	else if (message->getBody().find("help") == 0) {

			




	
	
	
		
 
		std::string help;

			




	
	
	
		
 
		help += "General:\n";

			




	
	
	
		
 
		help += "    status - shows instance status\n";

			




	
	
	
		
 
		help += "    reload - Reloads config file\n";

			




	
	
	
		
 
		help += "Users:\n";

			




	
	
	
		
 
		help += "    online_users - returns list of all online users\n";

			




	
	
	
		
 
		help += "    online_users_count - number of online users\n";

			




	
	
	
		
 
		help += "    online_users_per_backend - shows online users per backends\n";

			




	
	
	
		
 
		help += "    has_online_user <bare_JID> - returns 1 if user is online\n";

			




	
	
	
		
 
		help += "Messages:\n";

			




	
	
	
		
 
		help += "    messages_from_xmpp - get number of messages received from XMPP users\n";

			




	
	
	
		
 
		help += "    messages_to_xmpp - get number of messages sent to XMPP users\n";

			




	
	
	
		
 
		help += "Backends:\n";

			




	
	
	
		
 
		help += "    backends_count - number of active backends\n";

			




	
	
	
		
 
		help += "    crashed_backends - returns IDs of crashed backends\n";

			




	
	
	
		
 
		help += "Memory:\n";

			




	
	
	
		
 
		help += "    res_memory - Total RESident memory spectrum2 and its backends use in KB\n";

			




	
	
	
		
 
		help += "    shr_memory - Total SHaRed memory spectrum2 backends share together in KB\n";

			




	
	
	
		
 
		help += "    used_memory - (res_memory - shr_memory)\n";

			




	
	
	
		
 
		help += "    average_memory_per_user - (memory_used_without_any_user - res_memory)\n";

			




	
	
	
		
 
		help += "    res_memory_per_backend - RESident memory used by backends in KB\n";

			




	
	
	
		
 
		help += "    shr_memory_per_backend - SHaRed memory used by backends in KB\n";

			




	
	
	
		
 
		help += "    used_memory_per_backend - (res_memory - shr_memory) per backend\n";

			




	
	
	
		
 
		help += "    average_memory_per_user_per_backend - (memory_used_without_any_user - res_memory) per backend\n";

			




        

    


    
    

    

        

                

                    src/config.cpp
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -90,24 +90,26 @@ bool Config::load(std::istream &ifs, boost::program_options::options_description

			




	
	
	
		
 
		("identity.type", value<std::string>()->default_value(""), "Type of transport ('icq','msn','gg','irc', ...)")

			




	
	
	
		
 
		("registration.enable_public_registration", value<bool>()->default_value(true), "True if users should be able to register.")

			




	
	
	
		
 
		("registration.language", value<std::string>()->default_value("en"), "Default language for registration form")

			




	
	
	
		
 
		("registration.instructions", value<std::string>()->default_value("Enter your legacy network username and password."), "Instructions showed to user in registration form")

			




	
	
	
		
 
		("registration.username_label", value<std::string>()->default_value("Legacy network username:"), "Label for username field")

			




	
	
	
		
 
		("registration.username_mask", value<std::string>()->default_value(""), "Username mask")

			




	
	
	
		
 
		("registration.auto_register", value<bool>()->default_value(false), "Register new user automatically when the presence arrives.")

			




	
	
	
		
 
		("registration.encoding", value<std::string>()->default_value("utf8"), "Default encoding in registration form")

			




	
	
	
		
 
		("registration.require_local_account", value<bool>()->default_value(false), "True if users have to have a local account to register to this transport from remote servers.")

			




	
	
	
		
 
		("registration.local_username_label", value<std::string>()->default_value("Local username:"), "Label for local usernme field")

			




	
	
	
		
 
		("registration.local_account_server", value<std::string>()->default_value("localhost"), "The server on which the local accounts will be checked for validity")

			




	
	
	
		
 
		("registration.local_account_server_timeout", value<int>()->default_value(10000), "Timeout when checking local user on local_account_server (msecs)")

			




	
	
	
		
 
		("gateway_responder.prompt", value<std::string>()->default_value("Contact ID"), "Value of <prompt> </promt> field")

			




	
	
	
		
 
		("gateway_responder.label", value<std::string>()->default_value("Enter legacy network contact ID."), "Label for add contact ID field")

			




	
	
	
		
 
		("database.type", value<std::string>()->default_value("none"), "Database type.")

			




	
	
	
		
 
		("database.database", value<std::string>()->default_value("/var/lib/spectrum2/$jid/database.sql"), "Database used to store data")

			




	
	
	
		
 
		("database.server", value<std::string>()->default_value("localhost"), "Database server.")

			




	
	
	
		
 
		("database.user", value<std::string>()->default_value(""), "Database user.")

			




	
	
	
		
 
		("database.password", value<std::string>()->default_value(""), "Database Password.")

			




	
	
	
		
 
		("database.port", value<int>()->default_value(0), "Database port.")

			




	
	
	
		
 
		("database.prefix", value<std::string>()->default_value(""), "Prefix of tables in database")

			




	
	
	
		
 
		("database.encryption_key", value<std::string>()->default_value(""), "Encryption key.")

			




	
	
	
		
 
		("logging.config", value<std::string>()->default_value(""), "Path to log4cxx config file which is used for Spectrum 2 instance")

			




	
	
	
		
 
		("logging.backend_config", value<std::string>()->default_value(""), "Path to log4cxx config file which is used for backends")

			




	
	
	
		
 
		("backend.default_avatar", value<std::string>()->default_value(""), "Full path to default avatar")

			




	
	
	
		
 
		("backend.avatars_directory", value<std::string>()->default_value(""), "Path to directory with avatars")

			




        

    


    
    

    

        

                

                    src/gatewayresponder.cpp
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -36,25 +36,27 @@ using namespace boost;

			




	
	
	
		
 
namespace Transport {

			




	
	
	
		
 

			




	
	
	
		
 
DEFINE_LOGGER(logger, "GatewayResponder");

			




	
	
	
		
 

			




	
	
	
		
 
GatewayResponder::GatewayResponder(Swift::IQRouter *router, UserManager *userManager) : Swift::Responder<GatewayPayload>(router) {

			




	
	
	
		
 
	m_userManager = userManager;

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
GatewayResponder::~GatewayResponder() {

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
bool GatewayResponder::handleGetRequest(const Swift::JID& from, const Swift::JID& to, const std::string& id, boost::shared_ptr<Swift::GatewayPayload> payload) {

			




	
	
	
		
 
	sendResponse(from, id, boost::shared_ptr<GatewayPayload>(new GatewayPayload(Swift::JID(), "Enter legacy network contact ID.", "Contact ID")));

			




	
	
	
		
 
	std::string prompt = CONFIG_STRING(m_userManager->getComponent()->getConfig(), "gateway_responder.prompt");

			




	
	
	
		
 
	std::string label = CONFIG_STRING(m_userManager->getComponent()->getConfig(), "gateway_responder.label");

			




	
	
	
		
 
	sendResponse(from, id, boost::shared_ptr<GatewayPayload>(new GatewayPayload(Swift::JID(), label, prompt)));

			




	
	
	
		
 
	return true;

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
bool GatewayResponder::handleSetRequest(const Swift::JID& from, const Swift::JID& to, const std::string& id, boost::shared_ptr<Swift::GatewayPayload> payload) {

			




	
	
	
		
 
	std::string prompt = payload->getPrompt();

			




	
	
	
		
 
	std::string escaped = Swift::JID::getEscapedNode(prompt);

			




	
	
	
		
 
	std::string jid = escaped + "@" + m_userManager->getComponent()->getJID().toBare().toString();

			




	
	
	
		
 
	

			




	
	
	
		
 
	sendResponse(from, id, boost::shared_ptr<GatewayPayload>(new GatewayPayload(jid)));

			




	
	
	
		
 
	return true;

			




	
	
	
		
 
}

			




	
	
	
		
 

			




        

    



    


    



    



      

      





    
    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