summaryrefslogtreecommitdiff
path: root/src/meetingtools/ac/__init__.py
diff options
context:
space:
mode:
Diffstat (limited to 'src/meetingtools/ac/__init__.py')
-rw-r--r--src/meetingtools/ac/__init__.py40
1 files changed, 37 insertions, 3 deletions
diff --git a/src/meetingtools/ac/__init__.py b/src/meetingtools/ac/__init__.py
index 1250a5f..4fdc2f5 100644
--- a/src/meetingtools/ac/__init__.py
+++ b/src/meetingtools/ac/__init__.py
@@ -1,12 +1,46 @@
from meetingtools.ac.api import ACPClient
+import time
-def ac_api_client_cached(request,acc):
+def ac_api_client_cache(request,acc):
tag = 'ac_api_client_%s' % acc.name
if not request.session.has_key(tag):
- request.session[tag] = ACPClient(acc.api_url,acc.user,acc.password)
+ request.session[tag] = ACPClientWrapper(acc)
return request.session[tag]
-def ac_api_client(request,acc):
+def ac_api_client_nocache(request,acc):
+ return ACPClientWrapper(acc)
+
+ac_api_client = ac_api_client_nocache
+
+def ac_api(request,acc):
return ACPClient(acc.api_url,acc.user,acc.password)
+
+
+MAXCALLS = 10
+MAXIDLE = 10
+
+class ACPClientWrapper(object):
+
+ def __init__(self,acc):
+ self.acc = acc
+ self._delegate = None
+ self.ncalls = 0
+ self.lastcall = time.time()
+
+ def invalidate(self):
+ self._delegate = None
+
+ def client_factory(self):
+ now = time.time()
+ if self.ncalls > MAXCALLS or now - self.lastcall > MAXIDLE or not self._delegate:
+ self._delegate = ACPClient(self.acc.api_url,self.acc.user,self.acc.password)
+ self.ncalls = 0
+ self.ncalls += 1
+ self.lastcall = now
+ return self._delegate
+
+ def __getattr__(self,name):
+ client = self.client_factory()
+ return getattr(client,name)
\ No newline at end of file