From 5f0dc6840701a352eb7229cbc24aa050b7503af4 Mon Sep 17 00:00:00 2001
From: Jan Kaluza <jkaluza@redhat.com>
Date: Sun, 27 Dec 2015 16:31:00 +0100
Subject: [PATCH] Tests for twitter

---
 backends/twitter/TwitterPlugin.cpp |   7 +--
 libtransport/Config.cpp            |   1 +
 tests/start.py                     |  19 +++++--
 tests/twitter/twitter.sql          | Bin 0 -> 14336 bytes
 tests/twitter/twitter_test.cfg     |  47 ++++++++++++++++++
 tests/twitter/twitter_test.py      |  77 +++++++++++++++++++++++++++++
 6 files changed, 145 insertions(+), 6 deletions(-)
 create mode 100644 tests/twitter/twitter.sql
 create mode 100644 tests/twitter/twitter_test.cfg
 create mode 100644 tests/twitter/twitter_test.py

diff --git a/backends/twitter/TwitterPlugin.cpp b/backends/twitter/TwitterPlugin.cpp
index a91d288e..573323e8 100644
--- a/backends/twitter/TwitterPlugin.cpp
+++ b/backends/twitter/TwitterPlugin.cpp
@@ -75,9 +75,10 @@ TwitterPlugin::TwitterPlugin(Config *config, Swift::SimpleEventLoop *loop, Stora
 	m_conn->connect(Swift::HostAddressPort(Swift::HostAddress(host), port));
 
 	tp = new ThreadPool(loop_, 10);
-		
-	tweet_timer = m_factories->getTimerFactory()->createTimer(90000);
-	message_timer = m_factories->getTimerFactory()->createTimer(90000);
+
+	LOG4CXX_INFO(logger, "Fetch timeout is set to " << CONFIG_INT_DEFAULTED(config, "twitter.fetch_timeout", 90000));
+	tweet_timer = m_factories->getTimerFactory()->createTimer(CONFIG_INT_DEFAULTED(config, "twitter.fetch_timeout", 90000));
+	message_timer = m_factories->getTimerFactory()->createTimer(CONFIG_INT_DEFAULTED(config, "twitter.fetch_timeout", 90000));
 
 	tweet_timer->onTick.connect(boost::bind(&TwitterPlugin::pollForTweets, this));
 	message_timer->onTick.connect(boost::bind(&TwitterPlugin::pollForDirectMessages, this));
diff --git a/libtransport/Config.cpp b/libtransport/Config.cpp
index ee513e0c..0208ce87 100644
--- a/libtransport/Config.cpp
+++ b/libtransport/Config.cpp
@@ -141,6 +141,7 @@ bool Config::load(std::istream &ifs, boost::program_options::options_description
 		("proxy.user", value<std::string>()->default_value(""), "Proxy user.")
 		("proxy.password", value<std::string>()->default_value(""), "Proxy Password.")
 		("proxy.port", value<int>()->default_value(0), "Proxy port.")
+		("twitter.fetch_timeout", value<int>()->default_value(0), "Proxy port.")
 
 	;
 
diff --git a/tests/start.py b/tests/start.py
index ca15b5e4..c4625a61 100644
--- a/tests/start.py
+++ b/tests/start.py
@@ -167,23 +167,36 @@ class JabberSlackServerModeConf(BaseTest):
 		if test.find("bad_password") != -1:
 			print "Changing password to 'badpassword'"
 			os.system("sqlite3 slack.sql \"UPDATE users SET password='badpassword' WHERE id=1\"")
-			#os.system("sqlite3 slack.sql \"SELECT * FROM users\"")
 		return False
 
 	def pre_test(self):
 		os.system("prosody --config ../slack_jabber/prosody.cfg.lua > prosody.log &")
-		#time.sleep(3)
-		#os.system("../../../spectrum_manager/src/spectrum2_manager -c manager.conf localhostxmpp set_oauth2_code xoxb-17213576196-VV2K8kEwwrJhJFfs5YWv6La6 use_bot_token 2>/dev/null >/dev/null")
 
 	def post_test(self):
 		os.system("killall lua-5.1 2>/dev/null")
 		os.system("killall spectrum2_libpurple_backend 2>/dev/null")
 
+class TwitterServerModeConf(BaseTest):
+	def __init__(self):
+		BaseTest.__init__(self, "../twitter/twitter_test.cfg", True, "")
+		self.directory = "../twitter/"
+		self.client_password = "testpass123"
+
+	def skip_test(self, test):
+		os.system("cp ../twitter/twitter.sql .")
+
+	def pre_test(self):
+		pass
+
+	def post_test(self):
+		os.system("killall spectrum2_twitter_backend 2>/dev/null")
+
 configurations = []
 configurations.append(LibcommuniServerModeSingleServerConf())
 configurations.append(LibcommuniServerModeConf())
 configurations.append(JabberServerModeConf())
 configurations.append(JabberSlackServerModeConf())
+configurations.append(TwitterServerModeConf())
 
 exitcode = 0
 
diff --git a/tests/twitter/twitter.sql b/tests/twitter/twitter.sql
new file mode 100644
index 0000000000000000000000000000000000000000..840aa0167c882aeef66bc3af233b28945a70175d
GIT binary patch
literal 14336
zcmeI3-*4MQ9Kd}(JBia~V;dzKMXIMhw9%H%j`Opd#?md_+V#i!Yoia7<-~5|HnCIN
z>5sunH}MxBAx*r%0}|s2w5Mqj@B)Y@#Ka3c@GuZe0$xC34?~PQCw1a38A#Kns<V}x
z&v)m$`+n}e-@D6QW~RneOJNsuqbymhKu`n##3_~~2!co7J?Oi2F~~!0J)k>i^0)Ky
zMD*tl8YhMia2lp|YnR*$_Xv0do*jVz9YTeX@FN0#gB<Vj2zUf`G=Uy6Krp>s-63GD
zsg|V}0|mXD*R5jxk&FVAAbQ|%Hz<@;MYB$o^nz3>>ZT=`%cGLUo|j71E7DL^mQ}?h
zgGgEueow$(k>gz+0gu2gA@Bml^fns_@<ob?GTV(pZT!DUz%Ss<T_U(AhDTsG6WB-k
z7|;Vkq*~B5u_&3vP#X9crUzVZgrqW=cswS=()m<M$a4#vtP})J5t0k3L?$C=Btb?Y
ziclN>?-KA2cy~8L^JMb~Jf8&iQpi{|Yy}yjm>$M46gB<7Pr$$7{pXX9C$&f5xg$V9
z29OXk44(f3_%VS#-sKVS2<&tM;~+>xBfa~=LLjhxF>h9sf@M_8F-tKm6FU{jH2IjI
zXjN+=nvQXNBFe|2u@uX5g90}gOJMz{QI;S`_K+1Q!}oVOfTvZztNVdJ+}#bXy>3bQ
zl9I3eKw7_%r>Aq-*&I8Y9U9BA^+2|tWmTCSnV8L;%}uixrbouJ)AQ{4+&numIm=GW
zjg1{;*{Z1+B1)!eRzJ^0Tv4jVu1ZFsC>i~+M8XwkR`X`TP%D<IHzjhvuc?J)O)4vG
zGg&nBYQ=0Dy-<=CO}k?8M%nC{+;DboY?kfg`XZC04>MU)HCb7&OH!8}){)Fjj7-ht
z5QQ_j*BoIdCmN9IuN`HpsutN?f&Oqb3a)iEQx;9dvQ%x+tmo}KQ?0l=vA6*qgBNGE
z(FQ%j?qEr{sahKqWjhqqj;rW*^Y)~h8^3?6;G?*RNaR(@7oLd%!iH$Bl+cE|C{-=p
zeipZjEb`k!=y}=~?ui1#uh9xzY<n_aot3L4xER}LizaY&Y!R&gKH>&J+yD>B<1hqA
z;d@U@!=5PLt1~`-I2;CV(sswe^*3$D@9H9U(En4+C8U(?v=5<n;^JJ!t(w@VuIWbm
zw@Z??Sd|u=drL#VP*+m4f-a-(?iA770~`8>Y<9X2B`-;)C6@F>R3}-o6iY2DxIe0u
znoVhB-FTJ5@9A1e)oNXtZ=EPI==X&Wgu%Ssvk(v)U$B*CV_K*u)%l{Q$mV3gAC5%8
z)%iw?I6cfx=R9>h+D1;?e<<;jD(WMx=h9SMO=KbJih7*!g(oBJ6xA(~$h)6A=YmK{
zBVfg)q=Gw9sHKVu4%j9r^_oR4clg7H4};BGx0mzcD(d)XOlbJ_xZpOzF<6w?8K1Vs
zq((0h`XYG!58!VE`goT|z$37W2^@ee_W!_7L?^fo(Ei^`@B?_2d`R8{*U4e<4|yBh
zCg0t~ICi#Zte*ziK!{vW4K(_j8(N`g=$d*(!V3aX)-|QCg9bd+OV&?*i1swWT2mD3
z*k8k+@qAj~l8Ho2NRw|7FSizUn4y_OU~wx49nDIMXbdVCiY2Y5vqKk_rNXo>Ny-#A
zdx0P25<{8M>^WVImo|)%aY@ggnaU5RCX=H9nh^pk?tCnLS<!f&OQte>Djtm&a;4d^
z>ZPU1#Wa6*ZDvxqWSuEa$A{yU)Tp(*lFO}Dm$Ic8B)=r^th9C=>ZHLDD&!VYE@KIU
zL7M3b>@DlE!ohcl!&|Skym$F%CIa@NQ!pDM+BVbBLRpb1u8Xb(E1E186-mYuCX?cp
z&=y-5Y>pVZUN%Dm&bpdiLX-9Z9Ll0IH>~YBQM9be;IU&U*9FBuQ#)nAIdbzxtH6`&
ziQd!Px#aNp+|1m`V3?wrDA=oLc-1LdhNPJl-LNQp{I<d26-YCEpvNppg=G;f7?A{}
z5YA<Yo0%F<0~&4riKtGZO+B=(ujiwDD#i<mRFcmmqZcp6&Zn1iYiq`6adddWOw3<e
zO^!*)AnYVM$vb%e?-Q7TzrYXSxA1Lv8eS&vz+UptmN30QkHC&4z)~O!9%DBB2Pwb<
zw?VP3W(Qm)!Y#z=qQH@D>E&`KLor<d+n(Sdib-r8v=N(4D07fvgl#dldInG_Y>Sed
zpaT>#R&HD6tA)7?72So7^ngb!$9@W#3YVpTK?>P3+nUw({~SvZgr5_g@Rq&*hit&_
z@E-gTeur$p*YFnn6n^DY$@6#wJOVq101W{k{kGcye;_E^*NOM_g4kiOgY67WV4n{=
gG<GQLK<qT_|2-hQ|K;qQruAy#5qJg!ARqz!7j_?wy8r+H

literal 0
HcmV?d00001

diff --git a/tests/twitter/twitter_test.cfg b/tests/twitter/twitter_test.cfg
new file mode 100644
index 00000000..0945c4fb
--- /dev/null
+++ b/tests/twitter/twitter_test.cfg
@@ -0,0 +1,47 @@
+[service]
+jid = localhostxmpp
+password = secret
+server = 0.0.0.0
+port = 5223
+server_mode = 1
+backend_host=127.0.0.1
+pidfile=./test.pid
+# < this option doesn't work yet
+#backend_port=10001
+admin_jid=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=../..//backends/swiften/spectrum2_swiften_backend
+#backend=../../../backends/twitter/spectrum2_twitter_backend
+backend=../../backends/twitter/spectrum2_twitter_backend
+protocol=prpl-jabber
+#protocol=prpl-msn
+#protocol=any
+#protocol=prpl-icq
+working_dir=./
+portfile=./$jid.port
+irc_server=localhost
+
+[twitter]
+fetch_timeout=5000
+
+[backend]
+#default_avatar=catmelonhead.jpg
+#no_vcard_fetch=true
+
+[logging]
+#config=logging.cfg # log4cxx/log4j logging configuration file
+#backend_config=/home/hanzz/code/libtransport/spectrum/src/backend-logging.cfg # log4cxx/log4j logging configuration file for backends
+
+[database]
+type=sqlite3
+database=twitter.sql
+prefix=
+#type = mysql # or "none" without database backend.......................................................................................................................
+#database = test
+#prefix=
+#user=root
+#password=yourrootsqlpassword
+#encryption_key=hanzzik
diff --git a/tests/twitter/twitter_test.py b/tests/twitter/twitter_test.py
new file mode 100644
index 00000000..da6b6218
--- /dev/null
+++ b/tests/twitter/twitter_test.py
@@ -0,0 +1,77 @@
+import optparse
+import sys
+import time
+import subprocess
+import os
+
+import sleekxmpp
+
+
+class Responder(sleekxmpp.ClientXMPP):
+	def __init__(self, jid, password, room, room_password, nick):
+		sleekxmpp.ClientXMPP.__init__(self, jid, password)
+		self.room = room
+		self.room_password = room_password
+		self.nick = nick
+		self.finished = False
+
+		self.tests = {}
+
+
+class Client(sleekxmpp.ClientXMPP):
+	def __init__(self, jid, password, room, nick):
+		sleekxmpp.ClientXMPP.__init__(self, jid, password)
+		self.room = room
+		self.nick = nick
+		self.add_event_handler("session_start", self.start)
+		self.add_event_handler("message", self.message)
+		self.finished = False
+
+		self.tests = {}
+		self.tests["timeline_poll"] = ["Timeline received automatically", False]
+		self.tests["help"] = ["#help command", False]
+		self.tests["status1"] = ["#status command response", False]
+		self.tests["status2"] = ["#status command pushes status", False]
+		self.tests["follow"] = ["#follow command", False]
+		self.tests["friends"] = ["#friends command", False]
+		self.tests["unfollow"] = ["#unfollow command", False]
+		self.tests["friends2"] = ["#friends after unfollow command", False]
+
+		self.status = "timeline"
+		self.timestamp = int(time.time())
+
+	def message(self, msg):
+		if self.status == "timeline" and msg['body'].find("spectrum2tests") != -1 and msg['body'].find("MsgId") != -1:
+			self.tests["timeline_poll"][1] = True
+			self.send_message(mto=msg['from'], mbody="#help")
+			self.status = "help"
+		elif self.status == "help" and msg['body'].find("You will receive tweets of people you follow") != -1:
+			self.tests["help"][1] = True
+			self.send_message(mto=msg['from'], mbody="#status My testing status " + str(self.timestamp))
+			self.status = "status"
+		elif self.status == "status" and msg['body'].find("Status Update successful") != -1:
+			self.tests["status1"][1] = True
+		elif self.status == "status" and msg['body'].find("spectrum2tests") != -1 and msg['body'].find("MsgId") != -1:
+			self.tests["status2"][1] = True
+			self.status = "follow"
+			self.send_message(mto=msg['from'], mbody="#follow colinpwheeler")
+		elif self.status == "follow" and msg['body'] == "You are now following colinpwheeler":
+			self.status = "friends"
+			self.tests["follow"][1] = True
+			self.send_message(mto=msg['from'], mbody="#friends")
+		elif self.status == "friends" and msg['body'].find("USER LIST") != -1 and msg['body'].find("colinpwheeler") != -1:
+			self.status = "unfollow"
+			self.tests["friends"][1] = True
+			self.send_message(mto=msg['from'], mbody="#unfollow colinpwheeler")
+		elif self.status == "unfollow" and msg['body'] == "You are not following colinpwheeler anymore":
+			self.status = "friends2"
+			self.tests["unfollow"][1] = True
+			self.send_message(mto=msg['from'], mbody="#friends")
+		elif self.status == "friends2" and msg['body'].find("USER LIST") != -1 and msg['body'].find("colinpwheeler") == -1:
+			self.tests["friends2"][1] = True
+			self.finished = True
+
+	def start(self, event):
+		self.getRoster()
+		self.sendPresence()
+