equal
deleted
inserted
replaced
1 from twisted.internet.defer import inlineCallbacks |
1 from twisted.internet.defer import inlineCallbacks |
2 from datetime import datetime |
2 from datetime import datetime |
|
3 from Queue import deque |
3 |
4 |
4 from iro.model.schema import User, Offer, Userright, Job, Message |
5 from iro.model.schema import User, Offer, Userright, Job, Message |
5 from iro.controller.viewinterface import Interface |
6 from iro.controller.viewinterface import Interface |
|
7 from iro.controller.pool import taskPool |
|
8 |
6 from iro.model.pool import data |
9 from iro.model.pool import data |
|
10 from iro.model.offer import offers |
|
11 from iro.model.job import exJobs |
7 |
12 |
8 import iro.error as IroError |
13 import iro.error as IroError |
9 |
14 |
10 from .dbtestcase import DBTestCase |
15 from .dbtestcase import DBTestCase |
11 |
16 |
19 DBTestCase.setUp(self) |
24 DBTestCase.setUp(self) |
20 self.pool = data.pool |
25 self.pool = data.pool |
21 data.pool = DummyPool() |
26 data.pool = DummyPool() |
22 |
27 |
23 def tearDown(self): |
28 def tearDown(self): |
|
29 exJobs.clear() |
|
30 offers.clear() |
|
31 taskPool.pool.q.queue = deque() |
24 data.pool = self.pool |
32 data.pool = self.pool |
25 self.pool = None |
33 self.pool = None |
26 DBTestCase.tearDown(self) |
34 DBTestCase.tearDown(self) |
27 |
35 |
28 @inlineCallbacks |
36 @inlineCallbacks |
184 'info':{'i':{'price':0.4,'anz':1}, |
192 'info':{'i':{'price':0.4,'anz':1}, |
185 'a':{'price':0.4,'anz':1}, |
193 'a':{'price':0.4,'anz':1}, |
186 } |
194 } |
187 }) |
195 }) |
188 |
196 |
189 def testSMS(self): |
197 @inlineCallbacks |
190 pass |
198 def testSMS(self): |
191 testSMS.todo = "To implement" |
199 with self.session() as session: |
192 |
200 u = User(name='test',apikey='abcdef123456789') |
193 |
201 o = Offer(name='sipgate_basic',provider="sipgate",route="basic",typ="sms") |
194 def testMail(self): |
202 u.rights.append(Userright(o)) |
195 pass |
203 session.add(u) |
196 testMail.todo = "To implement" |
204 |
197 |
205 jobid = yield Interface().sms('abcdef123456789','message',['0123325456'],['basic']) |
198 def testFax(self): |
206 |
199 pass |
207 with self.session() as session: |
200 testFax.todo = "To implement" |
208 u = session.merge(u) |
|
209 u.job(jobid) |
|
210 |
|
211 self.assertEqual(taskPool.pool.q.qsize(),1) |
|
212 |
|
213 |
|
214 def testMail(self): |
|
215 pass |
|
216 testMail.todo = "To implement" |
|
217 |
|
218 def testFax(self): |
|
219 pass |
|
220 testFax.todo = "To implement" |