yhia

git-svn-id: http://xapek.org/svn/common/omegle@1174 d0e8fea9-7529-0410-93fb-d39fd5b9c1dd

3 files changed, 146 insertions, 24 deletions

diff --git a/megahal_icq.py b/megahal_icq.py
index f9afeaa..8ae3dd6 100644
--- a/megahal_icq.py
+++ b/megahal_icq.py
@@ -1,6 +1,7 @@
 #!/usr/bin/python
 import struct
 import sys
+import thread
 
 from twisted.words.protocols import oscar
 from twisted.internet import reactor, protocol
@@ -11,30 +12,31 @@ uin = '370496181'
 print "Enter icq password(megahal...): ",
 password = sys.stdin.readline().strip()
 
-mh_python.initbrain()
+def fill_hal():
+	mh_python.initbrain()
 
-conn = pyPgSQL.PgSQL.connect(database="omegle")
-cur = conn.cursor()
+	conn = pyPgSQL.PgSQL.connect(database="omegle")
+	cur = conn.cursor()
 
-cur.execute("""
-SELECT message from omegle_messages WHERE LENGTH(message) BETWEEN 3 AND 30
-AND NOT ( message ILIKE '%www.%'
-                             OR message ILIKE '%http%'
-                             OR message ILIKE '%@%.%')
-""")
-messages = cur.fetchall()
-c=0
-for message in messages:
-	c+=1
-	if c%500==0:
-		print "%s%s/%s" % ("\033[2K\033[E",c,len(messages)),
-	#XXX pass massage[0] to mh and end with a fucked up python
-	mh_python.learn("%s " % (message[0]))
+	cur.execute("""
+	SELECT message from omegle_messages WHERE LENGTH(message) BETWEEN 3 AND 30
+	AND NOT ( message ILIKE '%www.%'
+				     OR message ILIKE '%http%'
+				     OR message ILIKE '%@%.%')
+	""")
+	messages = cur.fetchall()
+	c=0
+	for message in messages:
+		c+=1
+		if c%500==0:
+			print "%s%s/%s" % ("\033[2K\033[E",c,len(messages)),
+		#XXX pass massage[0] to mh and end with a fucked up python
+		mh_python.learn("%s " % (message[0]))
 
-print "%s%s/%s" % ("\033[2K\033[E",len(messages),len(messages))
-cur.close()
-conn.close()
-del messages
+	print "%s%s/%s" % ("\033[2K\033[E",len(messages),len(messages))
+	cur.close()
+	conn.close()
+	del messages
 
 
 
@@ -56,6 +58,8 @@ class icqBot( oscar.BOSConnection ):
 		self.setProfile("Forget ICQ, MSN, Yahoo and the other shitty protocols! Use Jabber!")
 		self.setIdleTime( 0 )
 		self.clientReady()
+		for user in buddylist[0][0].users:
+			self.sendAuthorizationResponse(user.name, True, '')
  
 		print buddylist
 		print 'ICQ-Autoresponder-Bot aktiviert ;-)'
@@ -89,7 +93,8 @@ class icqBot( oscar.BOSConnection ):
 
 class OscarCrap( oscar.OscarAuthenticator ):
 	BOSClass = icqBot
- 
+
+thread.start_new_thread(fill_hal,()) 
 protocol.ClientCreator( reactor, OscarCrap, uin, password, icq=1 ).connectTCP( 'login.icq.com', 5238 )
 reactor.run()
 
diff --git a/omegle.py b/omegle.py
index 62a3892..2a8eae2 100644
--- a/omegle.py
+++ b/omegle.py
@@ -34,6 +34,7 @@ class Timer(Thread):
 		self.logger.debug("self.running == False")
 
 	def stop(self):
+		""" XXX break func() ? """
 		self.running = False
 		self.event.set()
 
@@ -65,9 +66,10 @@ class RESTClient(object):
 class OmegleChat(RESTClient):
 	def __init__(self,poll_interval=0.5,name="",host="omegle.com"):
 		self.name = name
+		self.poll_interval=poll_interval
 		RESTClient.__init__(self,host)
-		self.timer = Timer(self._events, poll_interval)
 
+		self.timer = Timer(self._events, poll_interval)
 		self.logger = logging.getLogger(__name__ + "." + self.__class__.__name__ + name)
 		self.is_confirmed = False #after getting a connection confirm
 		self.is_connected = False #after having self.id
@@ -86,8 +88,9 @@ class OmegleChat(RESTClient):
 			self.id = id[1]
 			self.logger.info("Connected id=%s" % self.id)
 			#start /events polling
-			self.timer.start()
 			self.is_connected = True
+			self.timer = Timer(self._events, self.poll_interval)
+			self.timer.start()
 		else:
 			self.logger.error("Bad response: %s" % body)
 			raise Exception("Bad response: %s" % body)
diff --git a/omegle_icq.py b/omegle_icq.py
new file mode 100644
index 0000000..bd38526
--- /dev/null
+++ b/omegle_icq.py
@@ -0,0 +1,114 @@
+#!/usr/bin/python
+import struct
+import sys
+import thread
+
+from twisted.words.protocols import oscar
+from twisted.internet import reactor, protocol
+from twisted.python import log
+
+from omegle import OmegleChat
+
+
+randoms = [['370496181', 'megahal123'], ['446323989','gagaga']]
+i=0
+uin = randoms[i][0]
+password = randoms[i][1]
+
+class OmegleICQChat(OmegleChat):
+	def __init__(self,icqconn,user):
+		self.user = user
+		self.icqconn = icqconn
+		OmegleChat.__init__(self,name="("+user.name+")")
+	def on_message(self,message):
+		print "got message %s" % message
+		self.send_icqconn( message )
+
+	def send_icqconn(self,message):
+		reactor.callFromThread(self.icqconn.sendMessage, self.user.name, str(message) )
+
+	def on_connect(self):
+		print "connected"
+		self.send_icqconn(  "== Stranger CONNECTED   (type disconnect to disconnect) ==" )
+	def on_disconnect(self):
+		print "disconnecteed"
+		self.send_icqconn( "==Stranger Disconnected ==" )
+
+
+class icqBot( oscar.BOSConnection ):
+	capabilities = [oscar.CAP_CHAT]
+ 
+	def initDone( self ):
+		self.requestSelfInfo()
+		self.requestSSI().addCallback(self.gotBuddyList)
+
+		self.omegleConns = {}
+
+	def shutdown( self ):
+		for conn in self.omegleConns:
+			if conn.is_connected:
+				conn.disconnect()
+
+	def updateBuddy(self, user):
+		print "Update buddy %s" % user
+ 
+	def gotBuddyList( self, buddylist ):
+		self.activateSSI()
+		self.setProfile("Forget ICQ, MSN, Yahoo and the other shitty protocols! Use Jabber!")
+		self.setIdleTime( 0 )
+		self.clientReady()
+		for user in buddylist[0][0].users:
+			print "Authorize %s" % user.name
+			self.sendAuthorizationResponse(user.name, True, '')
+ 
+		print 'ICQ-Autoresponder-Bot aktiviert ;-)'
+ 
+	def receiveMessage( self, user, multiparts, flags ):
+		print "receiveMessage(%s,%s,%s)" % (user,multiparts,flags)
+		if not self.omegleConns.has_key(user.name):
+			self.omegleConns[user.name] = OmegleICQChat(self,user)
+		
+		try:
+			message = str(multiparts[0][0])
+			if not self.omegleConns[user.name].is_connected:
+				if message == "connect":
+					self.omegleConns[user.name].start()
+					self.sendMessage(user.name, "Connecting you to omegle")
+				else:
+					self.sendMessage(user.name, "Not connected, type >connect<")
+			elif self.omegleConns[user.name].is_connected and not self.omegleConns[user.name].is_confirmed:
+				self.sendMessage(user.name, "Wait for connection confirm from omegle")
+			elif self.omegleConns[user.name].is_confirmed and message == "disconnect":
+				self.omegleConns[user.name].disconnect()
+				self.sendMessage(user.name, "Disconnecting")
+			else:
+				print "Send: %s" % message
+				self.omegleConns[user.name].send(message)
+		except Exception,e:
+			print "error: %s %s\n%s" % (user,multiparts,e)
+
+	def chatReceiveMessage( self, chat, user, message ):
+		self.receiveMessage( self, user, message, 0 )
+
+	def receiveSendFileRequest(self, *args):
+#	def receiveSendFileRequest(self, user, file, description, cookie):
+		print args
+ 
+	def sendAuthorizationResponse(self, uin, success, responsString):
+		packet  = struct.pack("b", len(uin)) + uin
+		if success:
+			packet += struct.pack("b", 1)
+		else:
+			packet += struct.pack("b", 0)
+		packet += struct.pack(">H", len(responsString)) + responsString
+		self.sendSNACnr(0x13, 0x1a, packet)
+
+
+class OscarCrap( oscar.OscarAuthenticator ):
+	BOSClass = icqBot
+
+
+log.startLogging(sys.stdout)
+protocol.ClientCreator( reactor, OscarCrap, uin, password, icq=1 ).connectTCP( 'login.icq.com', 5238 )
+reactor.run()
+