Fusion python files

bzr revid: nicolas.vanhoren@openerp.com-20121127100615-07mv10gxj19y43v4
This commit is contained in:
niv-openerp
2012-11-27 11:06:15 +01:00
parent 01e12e5462
commit a77339ccf0
3 changed files with 17 additions and 23 deletions
-1
View File
@@ -1,3 +1,2 @@
import im
import im_controller
+17
View File
@@ -84,6 +84,23 @@ if openerp.tools.config.options["gevent"]:
self.waiting -= 1
class ImportController(openerp.addons.web.http.Controller):
_cp_path = '/im'
@openerp.addons.web.http.jsonrequest
def poll(self, req, last=None):
if not openerp.tools.config.options["gevent"]:
raise Exception("Not usable in a server not running gevent")
num = 0
while True:
res = req.session.model('im.message').get_messages(last, req.session.eval_context(req.context))
if num >= 1 or len(res["res"]) > 0:
return res
last = res["last"]
num += 1
print "waiting"
Watcher.get_watcher(res["dbname"]).stop(30)
class im_message(osv.osv):
_name = 'im.message'
-22
View File
@@ -1,22 +0,0 @@
# -*- coding: utf-8 -*-
import openerp
import openerp.tools.config
import im
class ImportController(openerp.addons.web.http.Controller):
_cp_path = '/im'
@openerp.addons.web.http.jsonrequest
def poll(self, req, last=None):
if not openerp.tools.config.options["gevent"]:
raise Exception("Not usable in a server not running gevent")
num = 0
while True:
res = req.session.model('im.message').get_messages(last, req.session.eval_context(req.context))
if num >= 1 or len(res["res"]) > 0:
return res
last = res["last"]
num += 1
print "waiting"
im.Watcher.get_watcher(res["dbname"]).stop(30)