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!

I got tired of the captchas so I jizzed it up a bit with proxies and some other stuff. It's still python2 as python3 doesn't have pycurl-support.

#!/usr/bin/env python2
# coding=utf-8

from __future__ import print_function
import json
from threading import Thread
from Queue import Queue, Empty
import pycurl
from urllib import urlencode
from time import sleep
from functools import wraps

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

def urlopen(proxy, url, data = ''):
    class Buffa:
        def __init__(self):
            self.contents = ''
        def body_callback(self, buf):
            self.contents = self.contents + buf
        def read(self):
            return self.contents
    b = Buffa()

    c = pycurl.Curl()
    c.setopt(pycurl.URL, url)
    if proxy:
        c.setopt(pycurl.PROXY, 'localhost')
        c.setopt(pycurl.PROXYPORT, 9050)
        c.setopt(pycurl.PROXYTYPE, pycurl.PROXYTYPE_SOCKS5)
    if data != '':
        c.setopt(pycurl.POSTFIELDS, data)
    c.setopt(pycurl.WRITEFUNCTION, b.body_callback)
    c.setopt(pycurl.TIMEOUT, 9001)

    c.perform()
    return b

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.proxy = parent.proxy
            self.queue = Queue()
            Thread.__init__(self)

        def run(self):
            while True:
                r = json.loads(urlopen(self.proxy,
                                     "http://bajor.omegle.com/events",
                                     urlencode({'id': self.id})).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, pr, proxy):
        self.proxy = proxy
        self.id = json.loads(urlopen(self.proxy,
                            "http://bajor.omegle.com/start?rcs=1&pid=").read())
        print(pr, "<connected:" + self.id + ">")
        self.events = self.OmegleEvents(self)
        self.events.start()

    def typing(self):
        urlopen(self.proxy, "http://bajor.omegle.com/typing", urlencode({'id': self.id}))
    def stoppedtyping(self):
        urlopen(self.proxy, "http://bajor.omegle.com/stoppedtyping", urlencode({'id': self.id}))
    def send(self, msg):
        urlopen(self.proxy, "http://bajor.omegle.com/send", urlencode({'msg': msg, 'id': self.id}))
    def disconnect(self):
        urlopen(self.proxy, "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":
            b.typing()
        elif e[0] == "gotMessage":
            print(pr, e[1])
            b.send(e[1])
        elif e[0] == "stoppedTyping":
            b.stoppedtyping()
        else:
            print(pr, "<unknown:"+repr(e)+">")

def main():
    a = OmegleConnection("\x1B[31ma:\x1b[0m", True)
    b = OmegleConnection("\x1B[32mb:\x1b[0m", False)
    #b.send("[WARNING: Omegle™ is required under United States Federal Law to inform you that the IP (98.179.227.210) of the person whom you are chatting with is linked to a registered sex offender. Omegle™ encourages you to consider this when giving out personal information. The stranger cannot see this message.]")
    while True:
        tr(a, b, "\x1b[31ma:\x1b[0m")
        tr(b, a, "\x1b[32mb:\x1b[0m")
        sleep(0.2)

if __name__ == '__main__':
    main()