1 # -*- coding: utf-8 -*- |
1 # -*- coding: utf-8 -*- |
2 |
2 |
3 import unittest, ConfigParser |
3 import unittest, ConfigParser |
4 import iro |
4 import iro |
5 from job import MessageJob |
5 from job import SMSJob, FAXJob, MailJob |
6 from joblist import Joblist |
6 from joblist import Joblist |
7 from providerlist import Providerlist |
7 from providerlist import Providerlist |
8 import threading, xmlrpclib |
8 import threading, xmlrpclib |
9 from multiprocessing import Queue |
9 from multiprocessing import Queue |
10 from multiprocessing.managers import BaseManager |
10 from multiprocessing.managers import BaseManager |
36 |
36 |
37 |
37 |
38 class MyManager(BaseManager): |
38 class MyManager(BaseManager): |
39 pass |
39 pass |
40 |
40 |
41 MyManager.register('MessageJob', MessageJob) |
41 MyManager.register('SMSJob', SMSJob) |
|
42 MyManager.register('FAXob', FAXJob) |
|
43 MyManager.register('MailJob',MailJob) |
|
44 MyManager.register('Providerlist',Providerlist) |
42 manager = MyManager() |
45 manager = MyManager() |
43 manager.start() |
46 manager.start() |
44 |
47 |
45 |
48 |
46 #anbieter erzeugen und konfigurieren |
49 #anbieter erzeugen und konfigurieren |
118 self.assertEqual(client1.status(),{id1: {'status': ['init',{}], 'name': 'test'}}) |
121 self.assertEqual(client1.status(),{id1: {'status': ['init',{}], 'name': 'test'}}) |
119 self.assertEqual(client2.status(),{id2: {'status': ['init',{}], 'name': 'test2'}}) |
122 self.assertEqual(client2.status(),{id2: {'status': ['init',{}], 'name': 'test2'}}) |
120 self.assertEqual(admin.status(),{id1: {'status': ['init',{}], 'name': 'test'}, |
123 self.assertEqual(admin.status(),{id1: {'status': ['init',{}], 'name': 'test'}, |
121 id2: {'status': ['init',{}], 'name': 'test2'}} ) |
124 id2: {'status': ['init',{}], 'name': 'test2'}} ) |
122 |
125 |
123 self.assertRaises(xmlrpclib.Fault, client2.status, id1) |
126 self.assertEqual(client2.status(id1), {}) |
124 self.assertRaises(xmlrpclib.Fault, client1.status, id2) |
127 self.assertEqual(client1.status(id2), {}) |
125 |
128 |
126 def testGetProvider(self): |
129 def testGetProvider(self): |
127 servstr="https://test:test@localhost:8000" |
130 servstr="https://test:test@localhost:8000" |
128 client=xmlrpclib.Server(servstr) |
131 client=xmlrpclib.Server(servstr) |
129 self.assertEqual(client.getProvider("sms"), ["fax.de","geonet", "sipgate", "smstrade"]) |
132 self.assertEqual(client.getProvider("sms"), ["fax.de","geonet", "sipgate", "smstrade"]) |