aburan28

# -*- coding: utf-8 -*-

from gevent import monkey; monkey.patch_all()
import gevent
from gevent_zeromq import zmq



class WebSocketHandler(object):
    def __init__(self, _id, in_queue, socket):

aburan28

# NOTE:  This code was extracted from a larger class and has not been
# tested in this form.  Caveat emptor.
import django.conf
import django.contrib.auth
import django.core.handlers.wsgi
import django.db
import django.utils.importlib
import httplib
import json
import logging

aburan28

from flask import Flask

app=Flask(__name__)

@app.route('/')
def index():
    return """
<span id="now">loading<span>
<script type="text/javascript">
window.WebSocket=window.WebSocket || window.MozWebSocket || false;

aburan28

import tornado.ioloop
import tornado.web
import tornado.websocket

class Socket(tornado.websocket.WebSocketHandler):
    def open(self):
        print "Socket opened"

    def on_message(self, message):
        self.write_message("Msg is " + message)

aburan28

import datetime
import brukva
import json
import phpserialize

from tornado import web
from tornadio2 import SocketConnection, TornadioRouter, event, SocketServer

c = brukva.Client()
c.connect()

aburan28

class Application(tornado.web.Application):
    def __init__(self):
        tornado.web.Application.__init__(self, handlers, **settings)
        self.db_session = db_session
        self.redis = redis.StrictRedis()
        self.session_store = RedisSessionStore(self.redis)



class BaseHandler(tornado.web.RequestHandler):

aburan28

import collections
import json
import redis
import threading
from tornado import gen
from tornado import ioloop
from tornado import web
from tornado.options import define
from tornado.options import options
import tornadoredis

aburan28

class DropboxMixin(tornado.auth.OAuthMixin):
    """ Dropbox  OAuth authentication.
    """
    _OAUTH_REQUEST_TOKEN_URL = "https://api.dropbox.com/1/oauth/request_token"
    _OAUTH_ACCESS_TOKEN_URL = "https://api.dropbox.com/1/oauth/access_token"
    _OAUTH_AUTHORIZE_URL = "https://www.dropbox.com/1/oauth/authorize"
    _OAUTH_VERSION = "1.0"
    _OAUTH_NO_CALLBACKS = False

    def authorize_redirect(self, callback_uri=None, extra_params=None,

aburan28

from tornado import ioloop
from tornado import iostream
import socket

class Envelope(object):
    def __init__(self, sender, rcpt, body, callback):
        self.sender = sender
        self.rcpt   = rcpt[:]
        self.body   = body
        self.callback = callback

aburan28

import redis
import threading

class Listener(threading.Thread):
    def __init__(self, r, channels):
        threading.Thread.__init__(self)
        self.redis = r
        self.pubsub = self.redis.pubsub()
        self.pubsub.subscribe(channels)