Omegle-Spy thread! Post your logs!

Omegle-Spy is a Java application that acts as an omegle host, and connects two unsuspecting omgle-users to you, so you can snoop in on the conversation, and send messages to the participants individually, without letting the other party know.

It's hilarious.

http://code.google.com/p/omegle-spy/
http://www.mediafire.com/download.php?bh96rtq85r3tc57

The MediaFire link is an SVN checkout, since there are no downloads available at the Google Code page.

Run the "OmegleSpy.jar" file to start the program, requires that you have Java installed. Enjoy!

>>4

#!/usr/bin/env python2.6
# vim: encoding=utf-8

import json
from threading import Thread
from Queue import Queue, Empty
from urllib2 import urlopen
from urllib import urlencode
from time import sleep

import sys
reload(sys)
sys.setdefaultencoding('utf-8')

class OmegleConnection(object):

    class OmegleEvents(Thread):
        """ They are as follows:

        [u'connected']
        [u'typing']
        [u'gotMessage', u'lolwhut']
        [u'stoppedTyping']
        [u'strangerDisconnected']

        """
        def __init__(self, parent):
            self.id = parent.id
            self.queue = Queue()
            Thread.__init__(self)
        def run(self):
            while True:
                r = json.loads(urlopen("http://bajor.omegle.com/events", urlencode({'id': self.id}), 10000).read())
                if r == None:
                    self.queue.put(None)
                    return
                for i in r:
                    self.queue.put(i)
        def get(self):
            x = []
            try:
                while True:
                    x.append(self.queue.get(False))
            except Empty:
                pass
            return x

    def __init__(self):
        self.id = json.loads(urlopen("http://bajor.omegle.com/start?rcs=1&pid=").read())
        self.events = self.OmegleEvents(self)
        self.events.start()

    def typing(self):
        urlopen("http://bajor.omegle.com/typing", urlencode({'id': self.id}))
    def stoppedtyping(self):
        urlopen("http://bajor.omegle.com/stoppedtyping", urlencode({'id': self.id}))
    def send(self, msg):
        urlopen("http://bajor.omegle.com/send", urlencode({'msg': msg, 'id': self.id}))
    def disconnect(self):
        urlopen("http://bajor.omegle.com/disconnect", urlencode({'id': self.id}))
    def read(self):
        return self.events.get()

def tr(a, b, pr):
    es = a.read()
    for e in es:
        if e == None or e[0] == "strangerDisconnected":
            print pr, "<disconnected>"
            b.disconnect()
            sleep(2) # Give the threads time to die.
            raise SystemExit(0)
        elif e[0] == 'connected' or e[0] == 'waiting':
            pass
        elif e[0] == "typing":
            print pr, "<typing>"
            b.typing()
        elif e[0] == "gotMessage":
            print pr, e[1]
            b.send(e[1])
        elif e[0] == "stoppedTyping":
            print pr, "<stoppedTyping>"
            b.stoppedtyping()
        else:
            print pr, "<unknown:"+repr(e)+">"

def main():
    a = OmegleConnection()
    b = OmegleConnection()
    while True:
        tr(a, b, "a→")
        tr(b, a, "b→")
        sleep(0.5)

if __name__ == '__main__':
    main()