# -*- coding: utf-8 -*- import sys, time import simplejson import openerpweb #---------------------------------------------------------- # OpenERP Web ajaxim Controllers #---------------------------------------------------------- class PollServerMessageQueue(object): def __init__(self): # message queue self.l = [] # online users self.users = {} # should contains: { # 'user1234' : { s:1, m:"status message", timestamp: last_contact_timestamp } # } def userlist(): # return user list pass def write(self, m_type, m_sender, m_recipent, m_message, m_group): # appends messages to l # when status message uupdate users pass def read(self, recpient, timestamp): # return matching message pass def gc(): # remove message older than 300s from self.l # remove dead users from self.users pass class PollServer(openerpweb.Controller): _cp_path = "/web_chat/pollserver" @openerpweb.httprequest def login(self, req, **kw): """ --> POST http://ajaxim.com/wp-content/plugins/im/ajaxim.php/login Form Data username:"" password:"d41d8cd98f00b204e9800998ecf8427e" <-- 200 OK Content-Type:text/html { "r":"logged in", "u":"Guest130213866190.85", "s":"f9e1811536f19ad5b9e00376f9ff1532", "f":[ {"u":"Guest130205108745.47","s":{"s":1,"m":""},"g":"Users"}, {"u":"Guest130209838956.76","s":{"s":1,"m":""},"g":"Users"}, ] } """ mq = req.applicationsession.setdefault("web_chat",PollServerMessageQueue()) print "chat login",kw # r = 'loggued in' #u = generate random.randint(0,2**32) #s = cherrypy cookie id #f = mq.userlist() return """ { "r":"logged in", "u":"Guest130213866190.85", "s":"f9e1811536f19ad5b9e00376f9ff1532", "f":[ {"u":"Guest130205108745.47","s":{"s":1,"m":""},"g":"Users"}, {"u":"Guest130209838956.76","s":{"s":1,"m":""},"g":"Users"}, ] } """ @openerpweb.httprequest def logout(self, req): """ --> GET http://im.ajaxim.com/logout { "r":"logged out" } """ @openerpweb.httprequest def poll(self, req, **kw): """ --> GET http://im.ajaxim.com/poll?callback=jsonp1302138663582&_1302138663582= <-- 200 OK Content-Type:text/html noop: jsonp1302138663582([]); roster user online: jsonp1302140366243([{"t":"s","s":"Guest130214038974.31","r":"all","m":"1:","g":"Users"}]); roster user left: jsonp1302140441577([{"t":"s","s":"Guest130214038974.31","r":"","m":"0:"}]); receive message: jsonp1302140191599([{"t":"m","s":"Guest130214008855.5","r":"Guest130214013134.26","m":"fuck"}]); ('t' => $msg->type, 's' => $msg->from, 'r' => $msg->to, 'm' => $msg->message ) mag type s or m echo '' """ # for i in range(60): #r = mq.read(username,timestamp) # if messages # return r # if no message sleep 2s and retry # sleep 2 # else # return emptylist print "chat poll",kw time.sleep(2) # it's http://localhost:8002/web_chat/pollserver/poll?method=long?callback=jsonp1302147330483&_1302147330483= return '%s([{"t":"m","s":"Guest130214008855.5","r":"Guest130214013134.26","m":"fuck"}]);'%kw.get('callback','') return None @openerpweb.jsonrequest def send(self, req, **kw): """ --> GET http://im.ajaxim.com/send?callback=jsonp1302139980022&to=Guest130205108745.47&message=test&_1302139980022= callback: jsonp1302139980022 to: Guest130205108745.47 message: test _1302139980022: <-- 200 OK Content-Type:text/html return array('r' => 'sent'); return array('r' => 'error', 'e' => 'no session found'); return array('r' => 'error', 'e' => 'no_recipient'); return array('r' => 'error', 'e' => 'send error'); """ print "chat send",kw # mq.write() return {"action": actions} @openerpweb.jsonrequest def status(self, req, **kw): """ --> GET status call const Offline = 0; const Available = 1; const Away = 2; const Invisible = 3; <-- 200 OK Content-Type:text/html return array('r' => 'status set'); return array('r' => 'error', 'e' => 'no session found'); return array('r' => 'error', 'e' => 'status error'); """ print "chat status",kw # mq.write() return {"action": actions}