roombot omegle

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

1 files changed, 274 insertions, 0 deletions

diff --git a/icq_roombot_omegle.py b/icq_roombot_omegle.py
new file mode 100644
index 0000000..e3fef73
--- /dev/null
+++ b/icq_roombot_omegle.py
@@ -0,0 +1,274 @@
+#!/usr/bin/python
+# -*- vim: encoding: utf-8 -*-
+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
+
+accs = [['370496181', 'megahal123'], ['446323989','gagaga']]
+i=1
+uin = accs[i][0]
+password = accs[i][1]
+
+CHATROOM_UID = "370496181"
+
+class OmegleICQChat(OmegleChat):
+    def __init__(self,icqconn,user):
+        self.user = user
+        self.icqconn = icqconn
+        OmegleChat.__init__(self,name="omegle")
+    def on_message(self,message):
+        self.send_icqconn( message )
+
+    def send_icqconn(self,message):
+        #send stopped typing snac
+        reactor.callFromThread(self.icqconn.sendSNAC, 0x04, 0x14, '\x00\x00\x00\x00\x00\x00\x00\x00\x00\x01'+chr(len(self.user))+self.user+"\x00\x00")
+        #von omegle kommt immer unicode
+        message = unicode(message) #message.decode("utf-8")
+        message = message.encode("iso-8859-1","replace")
+        print "Omegle->%s: %s" % (self.user,message.__repr__())
+        reactor.callFromThread(self.icqconn.sendMessage, self.user, message )
+
+    def on_typing(self):
+        """
+        0x02 begin
+        0x01 idle
+        0x00 finish
+        """
+        reactor.callFromThread(self.icqconn.sendSNAC, 0x04, 0x14, '\x00\x00\x00\x00\x00\x00\x00\x00\x00\x01'+chr(len(self.user))+self.user+"\x00\x02")
+        print "Omegle->%s: (begin typing)" % self.user
+
+    def on_stopped_typing(self):
+        reactor.callFromThread(self.icqconn.sendSNAC, 0x04, 0x14, '\x00\x00\x00\x00\x00\x00\x00\x00\x00\x01'+chr(len(self.user))+self.user+"\x00\x01")
+
+    def on_connect(self):
+        print "Omegle->%s: (connected)" % self.user
+        self.send_icqconn(  "== Sup dawg, we heard u need some stranger in ur chatroom, so we put a Stranger in ur chatroom so u can chat with him while u chat with others (until you type %disconnect% without quotes) ==" )
+
+    def on_disconnect(self):
+        print "Omegle->%s: (disconnected)" % self.user
+        self.send_icqconn( "==Stranger Disconnected ==" )
+
+CAP_TYPING  = '\x56\x3f\xc8\x09\x0b\x6f\x41\xbd\x9f\x79\x42\x26\x09\xdf\xa2\xf3'
+# [4, 20, 0, 0, 2854066430L, '\x00\x00\x00\x00\x00\x00\x00\x00\x00\x01\t222840035\x00\x02']
+
+class icqBot( oscar.BOSConnection ):
+    capabilities = [oscar.CAP_CHAT,CAP_TYPING]
+
+    def __init__(self,s,p,factory,**kwargs):
+        self.factory = factory
+        oscar.BOSConnection.__init__(self, s, p,**kwargs)
+ 
+    """
+    handles typing SNAC
+    """
+    def oscar_04_14(self,snac):
+        data = snac[3]
+        if len(data) == len("\x00\x00\x00\x00\x00\x00\x00\x00\x00\x01\t222840035\x00\x02"):
+            user = data[11:20]
+            state = data[20:22]
+            if not self.omegleConns.has_key(user):
+                self.omegleConns[user] = OmegleICQChat(self,user)
+        
+            if state == "\x00\x00": #finish
+                try:
+                    self.omegleConns[user].stopped_typing()
+                except:
+                    pass
+            elif state == "\x00\x01": #idle
+                pass
+            elif state == "\x00\x02": #begin
+                try:
+                    self.omegleConns[user].typing()
+                except:
+                    pass
+            else:
+                print "Unknown state in typing snac\nuser %s\ndata %s\nsnac %s\nstate %X%X" % (user,data,snac,state[0],sate[1])
+        else:
+            print "komisches tpying snac"
+
+    def initDone( self ):
+        self.requestSelfInfo()
+        self.requestSSI().addCallback(self.gotBuddyList)
+
+        self.omegleConns = {}
+
+    def shutdown( self ):
+        self.sendMessage(CHATROOM_UID, "/leave")
+        for conn in self.omegleConns:
+            if conn.is_connected:
+                conn.disconnect()
+
+    def updateBuddy(self, user):
+        print "icq: Update buddy %s" % user
+ 
+    def gotBuddyList( self, buddylist ):
+        self.activateSSI()
+        self.setProfile("Forget ICQ, MSN, Yahoo and the other shitty protocols! Use XMPP/Jabber!")
+        self.setIdleTime( 0 )
+        self.clientReady()
+        for user in buddylist[0][0].users:
+            print "icq: Authorize %s" % user.name
+            self.sendAuthorizationResponse(user.name, True, '')
+        self.sendMessage(CHATROOM_UID, "/join OMEGLE")
+ 
+    def receiveMessage( self, user, multiparts, flags ):
+        print "icq: receiveMessage(%s,%s,%s)" % (user,multiparts,flags)
+        if "auto" in flags:
+            print "'auto' message, abort"
+            return
+
+        # because i cant receive the "budded added signal" i auth on every message
+        self.sendAuthorizationResponse(user.name, True, '')
+
+        if not self.omegleConns.has_key(user.name):
+            self.omegleConns[user.name] = OmegleICQChat(self,user.name)
+        
+        try:
+            message = None
+            if len(multiparts[0]) == 2:
+                if multiparts[0][1] == "unicode":
+                    message = unicode(multiparts[0][0])
+                else:
+                    try:
+                        message = multiparts[0][0].decode(multiparts[0][1])
+                    except Exception,e:
+                        self.sendMessage(user.name,str(e))
+            else:
+                try:
+                    message = multiparts[0][0].decode('latin1')
+                except Exception,e:
+                    self.sendMessage(user.name,str(e))
+
+            #filter qip \x00CHAR\x00CHAR - qip sucks at unicode?
+            message_neu = filter(lambda x: x!=u"\x00", message)
+            if len(message_neu) != len(message):
+                client_sucks  = True
+            message = message_neu
+
+            if not self.omegleConns[user.name].is_connected:
+                if u"%connect%" in message:
+                    self.omegleConns[user.name].start()
+                    self.sendMessage(user.name, "Please stand by.....")
+                    if client_sucks:
+                        self.sendMessage(user.name, "Hey, dein ICQ-Client sendet scheiss")
+                else:
+                    print "Not connected"
+#                   self.sendMessage(user.name, "Not connected, type >connect<")
+            elif self.omegleConns[user.name].is_connected and u"%disconnect%" in message:
+                try:
+                    self.omegleConns[user.name].disconnect()
+                except Exception,e:
+                    self.sendMessage(user.name, str(e))
+                self.sendMessage(user.name, "Disconnecting")
+            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")
+            else:
+#               if len(multiparts[0]) == 2:
+#                   print "send to omegle: %s" % message.decode(multiparts[0][1])
+#                   if multiparts[0][1] == "unicode":
+#                       self.omegleConns[user.name].send(unicode(message))
+#                   else:
+                        try:
+#                           self.omegleConns[user.name].send(message.decode(multiparts[0][1]))
+                            print "%s->Omegle: %s" % (user.name, message.__repr__())
+                            self.omegleConns[user.name].send(message)
+                        except Exception,e:
+                            print "icq(%s): Error %s" % (user.name,e)
+                            self.sendMessage(user.name,str(e))
+#               else:
+#                   print "send to omegle: %s" % message
+#                   self.omegleConns[user.name].send(message)
+        except Exception,e:
+            print "error: %s %s -> %s" % (user,multiparts,e)
+
+    def chatReceiveMessage( self, chat, user, message ):
+        self.receiveMessage( self, user, message, 0 )
+
+    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)
+    def connectionLost(self,reason):
+        print "connnection los called: %s " % reason
+        print dir(self)
+        self.factory.connectionLost(reason)
+        #self.shutdown()
+
+
+
+class OscarCrap( oscar.OscarAuthenticator ):
+    BOSClass = icqBot
+    # override this to connect our factory to our clients
+    def connectToBOS(self, server, port):
+        c = protocol.ClientCreator(reactor, OscarCrap.BOSClass,
+                self.username, self.cookie, self.factory)
+        return c.connectTCP(server, port)
+
+
+
+
+from twisted.internet.protocol import Protocol, ReconnectingClientFactory, ClientFactory
+
+
+class OscarFactory(ClientFactory):
+    OAClass=OscarCrap
+    def __init__(self, uid,password,icq=1):
+        self.uid = uid
+        self.password = password
+        self.icq = icq
+
+    def buildProtocol(self, addr):
+        p = OscarFactory.OAClass(self.uid,password,icq=self.icq)
+        p.factory = self
+        return p
+    
+    def startedConnecting(self, connector):
+        print 'Started to connect to oscar'
+
+    def connectionLost(self,reason):
+        print "CONECTION LOST - start njew factory"
+        reactor.connectTCP('login.icq.com', 5238, OscarFactory(uin,password,icq=1))
+
+class OscarClientFactory(ReconnectingClientFactory):
+    def startedConnecting(self, connector):
+        print 'Started to connect.'
+
+    def buildProtocol(self, addr):
+        print 'Connected.'
+        print 'Resetting reconnection delay'
+        self.resetDelay()
+        #return protocol.ClientCreator( reactor, OscarCrap, uin, password, icq=1 )
+        p=OscarCrap(uin, password, icq=1 )
+        p.factory = self
+        return p
+
+
+    def clientConnectionLost(self, connector, reason):
+        print 'Lost connection.  Reason:', reason
+#        ReconnectingClientFactory.clientConnectionLost(self, connector, reason)
+
+    def clientConnectionFailed(self, connector, reason):
+        print 'Connection failed. Reason:', reason
+#        ReconnectingClientFactory.clientConnectionFailed(self, connector,
+#                                                         reason)
+
+
+import logging
+logging.basicConfig(level=logging.INFO)
+
+log.startLogging(sys.stdout)
+#protocol.ClientCreator( reactor, OscarCrap, uin, password, icq=1 ).connectTCP( 'login.icq.com', 5238 )
+reactor.connectTCP('login.icq.com', 5238, OscarFactory(uin,password,icq=1))
+#.connectTCP( 'login.icq.com', 5238 )
+reactor.run()
+