patx/mrhttp-asgi

# TODO Not sure we support json here at the moment.  Need to change to mrpacker or support both
#
# What is this?
#
# Json is posted to mrhttp and forwarded to a mrworkserver cluster using C code.  This is much faster than doing it using python
# in the page handler.
#
# Why do this?
#
# My game server receives json. Instead of receiving the json, doing work and then replying 
# the json is passed off to a mrworkserver and we respond immediately so the client doesn't
# wait.  By gathering messages in mrworkserver I'm able to process many related messages 
# together to speed up msg handling
#
# Note - /sq/ will use the user id in the session key to decide which server in the cluster gets the message.
#        /q/{} will use the path arg to choose the cluster server - so /q/{thread_id} with 2 servers 
#          would have the even ids go to server 0 and odd to server 1
#
# Setup the memcached and mrq servers first:
#
# memcached -l 127.0.0.1 -p 11211 -d -m 50
# pip install mrworkserver
# git clone https://github.com/MarkReedZ/mrworkserver.git; cd mrworkserver
# python tst.py 7100
# python tst.py 7101
#
# curl -H "Content-Type: application/mrpacker" --data-binary @tests/lua/test.mrp http://localhost:8080/q/0
# curl -H "Content-Type: application/mrpacker" --data-binary @tests/lua/test.mrp http://localhost:8080/q2/0
#

# To fetch a user's session and pass it to mrworkserver:
#
# Set a session in memcached by logging in:
#   curl -v http://localhost:8080/login
#   example output:   AeeZjIBxhxDEaTKc69MTge3tq_kqf7Bh
#
# Use the session key that was output:
#   curl -v http://localhost:8080/sq2/ -H "Cookie: mrsession=AeexlGcHq_dFZd6pJnvjgqu3NhrAS4qu;" -H "Content-Type: application/mrpacker" --data-binary @tests/lua/test.mrp 

import mrhttp
import mrjson as json

app = mrhttp.Application()
app.config["memcache"] = [ ("127.0.0.1", 11211) ]

# We setup 2 clusters of 1 server each
app.config["mrq"]  = [("127.0.0.1",7100)]
app.config["mrq2"] = [("127.0.0.1",7101)]

@app.route('/q/{}/',options=['mrq'])
def queue(r, arg1):
  if r.servers_down:
    return "Servers not available, try again later"
  return 'Hello World!'

@app.route('/q2/{}/',options=['mrq2'])
def q2(r, arg1):
  if r.servers_down:
    return "Servers not available, try again later"
  return 'Hello World!'


@app.route('/login')
async def login(r):
  user_id = 10999
  user = {"name":"Mark"}
  return str( app.setUserSessionAndCookies( r, user_id, user ) ) + "\n"


@app.route('/sq/',options=['session','mrq','append_user'])
def session_queue(r):
  if r.user == None:
    return "Not logged in"
  if r.servers_down:
    return "Servers not available, try again later"
  return 'Hello World!'

@app.route('/sq2/',options=['session','mrq2','append_user'])
def sq2(r):
  if r.user == None:
    return "Not logged in"
  if r.servers_down:
    return "Servers not available, try again later"
  return 'Hello World!'
   
   
app.run(cores=1)