← Back to branch summary

~ubuntu-branches/ubuntu/trusty/openerp-client/trusty

« back to all changes in this revision

Viewing changes to bin/modules/spool/__init__.py

  • Committer: Bazaar Package Importer
  • Author(s): Daniel Baumann
  • Date: 2008-12-07 20:17:00 UTC
  • Revision ID: james.westby@ubuntu.com-20081207201700-a875pic3sd7xkoru
Tags: upstream-5.0.0~alpha
Import upstream version 5.0.0~alpha

Show diffs side-by-side

added added

removed removed

Lines of Context:
bin/modules/spool/__init__.py
 
1
# -*- encoding: utf-8 -*-
 
2
##############################################################################
 
3
#
 
4
#    OpenERP, Open Source Management Solution   
 
5
#    Copyright (C) 2004-2008 Tiny SPRL (<http://tiny.be>). All Rights Reserved
 
6
#    $Id$
 
7
#
 
8
#    This program is free software: you can redistribute it and/or modify
 
9
#    it under the terms of the GNU General Public License as published by
 
10
#    the Free Software Foundation, either version 3 of the License, or
 
11
#    (at your option) any later version.
 
12
#
 
13
#    This program is distributed in the hope that it will be useful,
 
14
#    but WITHOUT ANY WARRANTY; without even the implied warranty of
 
15
#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
16
#    GNU General Public License for more details.
 
17
#
 
18
#    You should have received a copy of the GNU General Public License
 
19
#    along with this program.  If not, see <http://www.gnu.org/licenses/>.
 
20
#
 
21
##############################################################################
 
22
 
 
23
import service
 
24
 
 
25
class spool(service.Service):
 
26
    def __init__(self, name='spool'):
 
27
        service.Service.__init__(self, name, '*')
 
28
        self.obj_sub = {}
 
29
        self.report = {}
 
30
 
 
31
    def publish(self, name, obj, datas, trigger=True):
 
32
        if name not in self.report:
 
33
            self.report[name]=[]
 
34
        self.report[name].append((obj, datas))
 
35
        if trigger:
 
36
            return self.trigger(name)
 
37
        return 0
 
38
 
 
39
    def subscribe(self, name, method, datas={}):
 
40
        if name not in self.obj_sub:
 
41
            self.obj_sub[name]=[]
 
42
        self.obj_sub[name].append( (method, datas) )
 
43
 
 
44
    def trigger(self, name):
 
45
        nbr = 0
 
46
        while len(self.report[name]):
 
47
            (obj, datas) = self.report[name].pop()
 
48
            if name in self.obj_sub:
 
49
                for i in self.obj_sub[name]:
 
50
                    new_datas = datas.copy()
 
51
                    new_datas.update(i[1])
 
52
                    i[0](obj, new_datas)
 
53
                    nbr +=1
 
54
        return nbr
 
55
spool()
 
56
 
 
57
# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:
 
58