libtransport.git Changeset - 00c5273fbb13

Changeset - 00c5273fbb13

Parent rev.

Child rev.

[Not reviewed]

0 6 0

Jan Kaluza - 9 years ago 2016-02-20 07:23:07
jkaluza@redhat.com

Slack: Handle channels starting with hash, do not reconnect to Slack RTM when URL expired

6 files changed with 43 insertions and 3 deletions:

backends/libpurple/main.cpp

include/transport/WebSocketClient.h

libtransport/WebSocketClient.cpp

spectrum/src/frontends/slack/SlackRTM.cpp

spectrum/src/frontends/slack/SlackSession.cpp

spectrum/src/frontends/slack/SlackUserRegistration.cpp

0 comments (0 inline, 0 general)

backends/libpurple/main.cpp

➞

Show inline comments

 			if (CONFIG_STRING(config, "service.protocol") == "prpl-telegram") {
 				cfg.setNeedPassword(false);
+			}
-			if (CONFIG_STRING(config, "service.protocol") != "prpl-irc") {
+			if (CONFIG_STRING(config, "service.protocol") == "prpl-irc") {
 				cfg.setNeedRegistration(false);
+			}
 			else {
 				cfg.setNeedRegistration(true);
+			}
 			np->sendConfig(cfg);
+		}

include/transport/WebSocketClient.h

➞

Show inline comments

@@ @@ -55,6 +55,7 @@ class WebSocketClient { @@
 		virtual ~WebSocketClient();
 		void connectServer(const std::string &u);
 		void disconnectServer();
 		void write(const std::string &data);

libtransport/WebSocketClient.cpp

➞

Show inline comments

 	connectServer();
+}
 void WebSocketClient::disconnectServer() {
 	if (m_conn) {
 		m_conn->onDataRead.disconnect(boost::bind(&WebSocketClient::handleDataRead, this, _1));
 		m_conn->disconnect();
+	}
+}
 void WebSocketClient::write(const std::string &data) {
 	if (!m_conn) {
 		return;

spectrum/src/frontends/slack/SlackRTM.cpp

➞

Show inline comments

@@ @@ -92,6 +92,14 @@ void SlackRTM::start() { @@
 		return; \
+	}
 #define STORE_INT(FROM, NAME) rapidjson::Value &NAME##_tmp = FROM[#NAME]; \
 	if (!NAME##_tmp.IsInt()) {  \
 		LOG4CXX_ERROR(logger, "No '" << #NAME << "' number in the reply."); \
 		LOG4CXX_ERROR(logger, payload); \
 		return; \
 	} \
 	int NAME = NAME##_tmp.GetInt();
 void SlackRTM::handlePayloadReceived(const std::string &payload) {
 	rapidjson::Document d;
 	if (d.Parse<0>(payload.c_str()).HasParseError()) {
 		std::map<std::string, SlackChannelInfo> &channels = m_idManager->getChannels();
 		SlackAPI::getSlackChannelInfo(NULL, true, d, payload, channels);
+	}
 	else if (type == "error") {
 		GET_OBJECT(d, error);
 		STORE_INT(error, code);
 		if (code == 1) {
 			LOG4CXX_INFO(logger, "Reconnecting to Slack network");
 			m_pingTimer->stop();
 			m_client->disconnectServer();
 			start();
+		}
+	}
+}
 void SlackRTM::sendMessage(const std::string &channel, const std::string &message) {

spectrum/src/frontends/slack/SlackSession.cpp

➞

Show inline comments

+}
 void SlackSession::handleJoinMessage(const std::string &message, std::vector<std::string> &args, bool quiet) {
 	if (args[5][0] == '#') {
 		args[5].erase(0, 1);
+	}
 	LOG4CXX_INFO(logger, m_uinfo.jid << ": Going to join the room " << args[3] << "@" << args[4] << ", transporting it to channel " << args[5]);
 	m_api->createChannel(args[5], m_idManager->getSelfId(), boost::bind(&SlackSession::handleJoinRoomCreated, this, _1, args));
+}
 	m_component->getFrontend()->onPresenceReceived(presence);
+}
 void SlackSession::leaveRoom(const std::string &channel) {
 void SlackSession::leaveRoom(const std::string &channel_) {
 	std::string channel = channel_;
 	if (channel[0] == '#') {
 		channel.erase(0, 1);
+	}
 	std::string channelId = m_idManager->getId(channel);
 	std::string to = m_channel2jid[channelId];
 	if (to.empty()) {

spectrum/src/frontends/slack/SlackUserRegistration.cpp

➞

Show inline comments

 	m_authsData[oauth2->getState()] = args;
 	if (args.size() >= 3) {
-		LOG4CXX_INFO(logger, "Generating OAUth2 URL with slack_channel=" << args[0] << ", 3rd_party_account=" << args[1]);
+		LOG4CXX_INFO(logger, "Generating OAUth2 URL with slack_channel=" << args[1] << ", 3rd_party_account=" << args[2]);
+	}
 	else {
 		LOG4CXX_WARN(logger, "Generating OAUth2 URL with too few arguments");
 	m_storageBackend->getUser(user.jid, user);
 	if (!slackChannel.empty()) {
 		if (slackChannel[0] == '#') {
 			slackChannel.erase(0, 1);
+		}
 		m_storageBackend->getUserSetting(user.id, "slack_channel", type, slackChannel);
+	}

0 comments (0 inline, 0 general)